import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire"; import type { CallContext, CallOptions } from "nice-grpc-common"; import { Guid } from "./protobuf-net/bcl"; export declare const protobufPackage = "Cratis.Chronicle.Contracts.Captures"; export declare enum CaptureStatus { Stopped = 0, Started = 1, UNRECOGNIZED = -1 } export declare function captureStatusFromJSON(object: any): CaptureStatus; export declare function captureStatusToJSON(object: CaptureStatus): string; export declare enum EventObservationState { None = 0, Initial = 1, Replay = 2, UNRECOGNIZED = -1 } export declare function eventObservationStateFromJSON(object: any): EventObservationState; export declare function eventObservationStateToJSON(object: EventObservationState): string; export declare enum ValidationResultSeverity { Unknown = 0, Information = 1, Warning = 2, Error = 3, UNRECOGNIZED = -1 } export declare function validationResultSeverityFromJSON(object: any): ValidationResultSeverity; export declare function validationResultSeverityToJSON(object: ValidationResultSeverity): string; export interface CaptureDetailsResponse { Id: string; Name: string; Declaration: string; Status: CaptureStatus; } export interface CaptureValidationMessage { Message: string; Line: number; Column: number; } export interface CapturedEventResponse { Context: EventContext | undefined; Content: string; Id: string; } export interface CapturedEventsRequest { EventStore: string; CaptureName: string; Namespace: string; MaxEvents: number; } export interface Causation { Occurred: SerializableDateTimeOffset | undefined; Type: string; Properties: { [key: string]: string; }; } export interface Causation_PropertiesEntry { key: string; value: string; } export interface CommandResult { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; AuthorizationFailureReason: string; } export interface CommandResultSaveCaptureResponse { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; AuthorizationFailureReason: string; Response: SaveCaptureResponse | undefined; } export interface CommandResultStartCaptureResponse { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; AuthorizationFailureReason: string; Response: StartCaptureResponse | undefined; } export interface CommandResultValidateCaptureDeclarationResponse { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; AuthorizationFailureReason: string; Response: ValidateCaptureDeclarationResponse | undefined; } export interface DeleteCaptureRequest { EventStore: string; CaptureId: Guid | undefined; } export interface EventContext { EventType: EventType | undefined; EventSourceType: string; EventSourceId: string; SequenceNumber: bigint; EventStreamType: string; EventStreamId: string; Occurred: SerializableDateTimeOffset | undefined; EventStore: string; Namespace: string; CorrelationId: Guid | undefined; Causation: Causation[]; CausedBy: Identity | undefined; ObservationState: EventObservationState; Tags: string[]; Hash: string; Subject: string; } export interface EventType { Id: string; Generation: number; Tombstone: boolean; } export interface GetCapturesRequest { EventStore: string; } export interface Identity { Subject: string; Name: string; UserName: string; OnBehalfOf: Identity | undefined; } export interface ObserveCapturesRequest { EventStore: string; } export interface QueryResultIEnumerableCaptureDetailsResponse { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; Data: CaptureDetailsResponse[]; } export interface QueryResultIEnumerableCapturedEventResponse { CorrelationId: Guid | undefined; IsAuthorized: boolean; ValidationResults: ValidationResult[]; ExceptionMessages: string[]; ExceptionStackTrace: string; Data: CapturedEventResponse[]; } export interface SaveCaptureRequest { EventStore: string; Id: Guid | undefined; Declaration: string; } export interface SaveCaptureResponse { Capture: CaptureDetailsResponse | undefined; Messages: CaptureValidationMessage[]; } export interface SerializableDateTimeOffset { Value: string; } export interface StartCaptureRequest { EventStore: string; CaptureId: Guid | undefined; } export interface StartCaptureResponse { Messages: CaptureValidationMessage[]; } export interface StopCaptureRequest { EventStore: string; CaptureId: Guid | undefined; } export interface ValidateCaptureDeclarationRequest { EventStore: string; Declaration: string; } export interface ValidateCaptureDeclarationResponse { Messages: CaptureValidationMessage[]; } export interface ValidationResult { Severity: ValidationResultSeverity; Message: string; Members: string[]; } export declare const CaptureDetailsResponse: MessageFns; export declare const CaptureValidationMessage: MessageFns; export declare const CapturedEventResponse: MessageFns; export declare const CapturedEventsRequest: MessageFns; export declare const Causation: MessageFns; export declare const Causation_PropertiesEntry: MessageFns; export declare const CommandResult: MessageFns; export declare const CommandResultSaveCaptureResponse: MessageFns; export declare const CommandResultStartCaptureResponse: MessageFns; export declare const CommandResultValidateCaptureDeclarationResponse: MessageFns; export declare const DeleteCaptureRequest: MessageFns; export declare const EventContext: MessageFns; export declare const EventType: MessageFns; export declare const GetCapturesRequest: MessageFns; export declare const Identity: MessageFns; export declare const ObserveCapturesRequest: MessageFns; export declare const QueryResultIEnumerableCaptureDetailsResponse: MessageFns; export declare const QueryResultIEnumerableCapturedEventResponse: MessageFns; export declare const SaveCaptureRequest: MessageFns; export declare const SaveCaptureResponse: MessageFns; export declare const SerializableDateTimeOffset: MessageFns; export declare const StartCaptureRequest: MessageFns; export declare const StartCaptureResponse: MessageFns; export declare const StopCaptureRequest: MessageFns; export declare const ValidateCaptureDeclarationRequest: MessageFns; export declare const ValidateCaptureDeclarationResponse: MessageFns; export declare const ValidationResult: MessageFns; export type CapturesDefinition = typeof CapturesDefinition; export declare const CapturesDefinition: { readonly name: "Captures"; readonly fullName: "Cratis.Chronicle.Contracts.Captures.Captures"; readonly methods: { readonly capturedEvents: { readonly name: "CapturedEvents"; readonly requestType: typeof CapturedEventsRequest; readonly requestStream: false; readonly responseType: typeof QueryResultIEnumerableCapturedEventResponse; readonly responseStream: false; readonly options: {}; }; readonly deleteCapture: { readonly name: "DeleteCapture"; readonly requestType: typeof DeleteCaptureRequest; readonly requestStream: false; readonly responseType: typeof CommandResult; readonly responseStream: false; readonly options: {}; }; readonly getCaptures: { readonly name: "GetCaptures"; readonly requestType: typeof GetCapturesRequest; readonly requestStream: false; readonly responseType: typeof QueryResultIEnumerableCaptureDetailsResponse; readonly responseStream: false; readonly options: {}; }; readonly observeCaptures: { readonly name: "ObserveCaptures"; readonly requestType: typeof ObserveCapturesRequest; readonly requestStream: false; readonly responseType: typeof QueryResultIEnumerableCaptureDetailsResponse; readonly responseStream: true; readonly options: {}; }; readonly saveCapture: { readonly name: "SaveCapture"; readonly requestType: typeof SaveCaptureRequest; readonly requestStream: false; readonly responseType: typeof CommandResultSaveCaptureResponse; readonly responseStream: false; readonly options: {}; }; readonly startCapture: { readonly name: "StartCapture"; readonly requestType: typeof StartCaptureRequest; readonly requestStream: false; readonly responseType: typeof CommandResultStartCaptureResponse; readonly responseStream: false; readonly options: {}; }; readonly stopCapture: { readonly name: "StopCapture"; readonly requestType: typeof StopCaptureRequest; readonly requestStream: false; readonly responseType: typeof CommandResult; readonly responseStream: false; readonly options: {}; }; readonly validateCaptureDeclaration: { readonly name: "ValidateCaptureDeclaration"; readonly requestType: typeof ValidateCaptureDeclarationRequest; readonly requestStream: false; readonly responseType: typeof CommandResultValidateCaptureDeclarationResponse; readonly responseStream: false; readonly options: {}; }; }; }; export interface CapturesServiceImplementation { capturedEvents(request: CapturedEventsRequest, context: CallContext & CallContextExt): Promise>; deleteCapture(request: DeleteCaptureRequest, context: CallContext & CallContextExt): Promise>; getCaptures(request: GetCapturesRequest, context: CallContext & CallContextExt): Promise>; observeCaptures(request: ObserveCapturesRequest, context: CallContext & CallContextExt): ServerStreamingMethodResult>; saveCapture(request: SaveCaptureRequest, context: CallContext & CallContextExt): Promise>; startCapture(request: StartCaptureRequest, context: CallContext & CallContextExt): Promise>; stopCapture(request: StopCaptureRequest, context: CallContext & CallContextExt): Promise>; validateCaptureDeclaration(request: ValidateCaptureDeclarationRequest, context: CallContext & CallContextExt): Promise>; } export interface CapturesClient { capturedEvents(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; deleteCapture(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; getCaptures(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; observeCaptures(request: DeepPartial, options?: CallOptions & CallOptionsExt): AsyncIterable; saveCapture(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; startCapture(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; stopCapture(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; validateCaptureDeclaration(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 type ServerStreamingMethodResult = { [Symbol.asyncIterator](): AsyncIterator; }; 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=captures.d.ts.map