import { BinaryReader, BinaryWriter } from "@bufbuild/protobuf/wire";
import type { CallContext, CallOptions } from "nice-grpc-common";
import { Guid } from "./protobuf-net/bcl.js";
export declare const protobufPackage = "Cratis.Chronicle.Contracts.EventSources";
export declare enum ConcurrencyDimensions {
    CONCURRENCY_DIMENSIONS_None = 0,
    EventSourceId = 1,
    EventSourceType = 2,
    EventStreamType = 4,
    EventStreamId = 8,
    UNRECOGNIZED = -1
}
export declare function concurrencyDimensionsFromJSON(object: any): ConcurrencyDimensions;
export declare function concurrencyDimensionsToJSON(object: ConcurrencyDimensions): string;
export declare enum EventSourceOwner {
    EVENT_SOURCE_OWNER_None = 0,
    Client = 1,
    Kernel = 2,
    UNRECOGNIZED = -1
}
export declare function eventSourceOwnerFromJSON(object: any): EventSourceOwner;
export declare function eventSourceOwnerToJSON(object: EventSourceOwner): 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 AllEventSourcesRequest {
    EventStore: string;
}
export interface CommandResult {
    CorrelationId: Guid | undefined;
    IsAuthorized: boolean;
    ValidationResults: ValidationResult[];
    ExceptionMessages: string[];
    ExceptionStackTrace: string;
    AuthorizationFailureReason: string;
}
export interface EventSourceDefinition {
    Name: string;
    Description: string;
    Owner: EventSourceOwner;
    Concurrency: ConcurrencyDimensions;
    Streams: EventStreamDefinition[];
}
export interface EventSourceDetailsResponse {
    Id: string;
    Name: string;
    Description: string;
    Owner: EventSourceOwner;
    Concurrency: ConcurrencyDimensions;
    Streams: EventStreamDefinition[];
}
export interface EventStreamDefinition {
    Name: string;
    Description: string;
    Concurrency: ConcurrencyDimensions;
}
export interface ObserveEventSourcesRequest {
    EventStore: string;
}
export interface QueryResultIEnumerableEventSourceDetailsResponse {
    CorrelationId: Guid | undefined;
    IsAuthorized: boolean;
    ValidationResults: ValidationResult[];
    ExceptionMessages: string[];
    ExceptionStackTrace: string;
    Data: EventSourceDetailsResponse[];
}
export interface RegisterEventSourcesRequest {
    EventStore: string;
    Sources: EventSourceDefinition[];
}
export interface ValidationResult {
    Severity: ValidationResultSeverity;
    Message: string;
    Members: string[];
}
export declare const AllEventSourcesRequest: MessageFns<AllEventSourcesRequest>;
export declare const CommandResult: MessageFns<CommandResult>;
export declare const EventSourceDefinition: MessageFns<EventSourceDefinition>;
export declare const EventSourceDetailsResponse: MessageFns<EventSourceDetailsResponse>;
export declare const EventStreamDefinition: MessageFns<EventStreamDefinition>;
export declare const ObserveEventSourcesRequest: MessageFns<ObserveEventSourcesRequest>;
export declare const QueryResultIEnumerableEventSourceDetailsResponse: MessageFns<QueryResultIEnumerableEventSourceDetailsResponse>;
export declare const RegisterEventSourcesRequest: MessageFns<RegisterEventSourcesRequest>;
export declare const ValidationResult: MessageFns<ValidationResult>;
export type EventSourcesDefinition = typeof EventSourcesDefinition;
export declare const EventSourcesDefinition: {
    readonly name: "EventSources";
    readonly fullName: "Cratis.Chronicle.Contracts.EventSources.EventSources";
    readonly methods: {
        readonly allEventSources: {
            readonly name: "AllEventSources";
            readonly requestType: typeof AllEventSourcesRequest;
            readonly requestStream: false;
            readonly responseType: typeof QueryResultIEnumerableEventSourceDetailsResponse;
            readonly responseStream: false;
            readonly options: {};
        };
        readonly observeEventSources: {
            readonly name: "ObserveEventSources";
            readonly requestType: typeof ObserveEventSourcesRequest;
            readonly requestStream: false;
            readonly responseType: typeof QueryResultIEnumerableEventSourceDetailsResponse;
            readonly responseStream: true;
            readonly options: {};
        };
        readonly registerEventSources: {
            readonly name: "RegisterEventSources";
            readonly requestType: typeof RegisterEventSourcesRequest;
            readonly requestStream: false;
            readonly responseType: typeof CommandResult;
            readonly responseStream: false;
            readonly options: {};
        };
    };
};
export interface EventSourcesServiceImplementation<CallContextExt = {}> {
    allEventSources(request: AllEventSourcesRequest, context: CallContext & CallContextExt): Promise<DeepPartial<QueryResultIEnumerableEventSourceDetailsResponse>>;
    observeEventSources(request: ObserveEventSourcesRequest, context: CallContext & CallContextExt): ServerStreamingMethodResult<DeepPartial<QueryResultIEnumerableEventSourceDetailsResponse>>;
    registerEventSources(request: RegisterEventSourcesRequest, context: CallContext & CallContextExt): Promise<DeepPartial<CommandResult>>;
}
export interface EventSourcesClient<CallOptionsExt = {}> {
    allEventSources(request: DeepPartial<AllEventSourcesRequest>, options?: CallOptions & CallOptionsExt): Promise<QueryResultIEnumerableEventSourceDetailsResponse>;
    observeEventSources(request: DeepPartial<ObserveEventSourcesRequest>, options?: CallOptions & CallOptionsExt): AsyncIterable<QueryResultIEnumerableEventSourceDetailsResponse>;
    registerEventSources(request: DeepPartial<RegisterEventSourcesRequest>, options?: CallOptions & CallOptionsExt): Promise<CommandResult>;
}
type Builtin = Date | Function | Uint8Array | string | number | boolean | bigint | undefined;
export type DeepPartial<T> = T extends bigint ? string | number | bigint : T extends Builtin ? T : T extends globalThis.Array<infer U> ? globalThis.Array<DeepPartial<U>> : T extends ReadonlyArray<infer U> ? ReadonlyArray<DeepPartial<U>> : T extends {} ? {
    [K in keyof T]?: DeepPartial<T[K]>;
} : Partial<T>;
export type ServerStreamingMethodResult<Response> = {
    [Symbol.asyncIterator](): AsyncIterator<Response, void>;
};
export interface MessageFns<T> {
    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>): T;
    fromPartial(object: DeepPartial<T>): T;
}
export {};
//# sourceMappingURL=eventsources.d.ts.map