import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire"; import type { CallContext, CallOptions } from "nice-grpc-common"; import { Empty } from "./google/protobuf/empty"; export declare const protobufPackage = "Cratis.Chronicle.Contracts.Observation.EventStoreSubscriptions"; export interface AddEventStoreSubscriptions { TargetEventStore: string; Subscriptions: EventStoreSubscriptionDefinition[]; } export interface EventStoreSubscriptionDefinition { Identifier: string; SourceEventStore: string; EventTypes: EventType[]; } export interface EventType { Id: string; Generation: number; Tombstone: boolean; } export interface GetEventStoreSubscriptionsRequest { TargetEventStore: string; } export interface IEnumerableEventStoreSubscriptionDefinition { items: EventStoreSubscriptionDefinition[]; } export interface RemoveEventStoreSubscriptions { TargetEventStore: string; SubscriptionIds: string[]; } export declare const AddEventStoreSubscriptions: MessageFns; export declare const EventStoreSubscriptionDefinition: MessageFns; export declare const EventType: MessageFns; export declare const GetEventStoreSubscriptionsRequest: MessageFns; export declare const IEnumerableEventStoreSubscriptionDefinition: MessageFns; export declare const RemoveEventStoreSubscriptions: MessageFns; export type EventStoreSubscriptionsDefinition = typeof EventStoreSubscriptionsDefinition; export declare const EventStoreSubscriptionsDefinition: { readonly name: "EventStoreSubscriptions"; readonly fullName: "Cratis.Chronicle.Contracts.Observation.EventStoreSubscriptions.EventStoreSubscriptions"; readonly methods: { readonly add: { readonly name: "Add"; readonly requestType: typeof AddEventStoreSubscriptions; readonly requestStream: false; readonly responseType: typeof Empty; readonly responseStream: false; readonly options: {}; }; readonly getSubscriptions: { readonly name: "GetSubscriptions"; readonly requestType: typeof GetEventStoreSubscriptionsRequest; readonly requestStream: false; readonly responseType: typeof IEnumerableEventStoreSubscriptionDefinition; readonly responseStream: false; readonly options: {}; }; readonly remove: { readonly name: "Remove"; readonly requestType: typeof RemoveEventStoreSubscriptions; readonly requestStream: false; readonly responseType: typeof Empty; readonly responseStream: false; readonly options: {}; }; }; }; export interface EventStoreSubscriptionsServiceImplementation { add(request: AddEventStoreSubscriptions, context: CallContext & CallContextExt): Promise>; getSubscriptions(request: GetEventStoreSubscriptionsRequest, context: CallContext & CallContextExt): Promise>; remove(request: RemoveEventStoreSubscriptions, context: CallContext & CallContextExt): Promise>; } export interface EventStoreSubscriptionsClient { add(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; getSubscriptions(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; remove(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; } type Builtin = Date | Function | Uint8Array | string | number | boolean | bigint | undefined; export type DeepPartial = T extends bigint ? string | number | bigint : T extends Builtin ? T : T extends globalThis.Array ? globalThis.Array> : T extends ReadonlyArray ? ReadonlyArray> : T extends {} ? { [K in keyof T]?: DeepPartial; } : Partial; export interface MessageFns { encode(message: T, writer?: BinaryWriter): BinaryWriter; decode(input: BinaryReader | Uint8Array, length?: number): T; fromJSON(object: any): T; toJSON(message: T): unknown; create(base?: DeepPartial): T; fromPartial(object: DeepPartial): T; } export {}; //# sourceMappingURL=observation_eventstoresubscriptions.d.ts.map