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.Clients"; export interface CompatibilityRequest { ClientType: string; ClientVersion: string; ProtocolVersion: string; DescriptorSet: Buffer; } export interface CompatibilityResponse { IsCompatible: boolean; Incompatibilities: string[]; ServerVersion: string; ServerProtocolVersion: string; } export interface ConnectRequest { ConnectionId: string; ClientVersion: string; IsRunningWithDebugger: boolean; ProcessId: number; ProcessPath: string; MachineName: string; ClientType: string; } export interface ConnectedClient { ConnectionId: string; Version: string; LastSeen: SerializableDateTimeOffset | undefined; IsRunningWithDebugger: boolean; SiloAddress: string; ProcessId: number; ProcessPath: string; MachineName: string; ClientType: string; } export interface ConnectionKeepAlive { ConnectionId: string; } export interface DescriptorSetResponse { SchemaDefinition: string; } export interface IEnumerableConnectedClient { items: ConnectedClient[]; } export interface SerializableDateTimeOffset { Value: string; } export declare const CompatibilityRequest: MessageFns; export declare const CompatibilityResponse: MessageFns; export declare const ConnectRequest: MessageFns; export declare const ConnectedClient: MessageFns; export declare const ConnectionKeepAlive: MessageFns; export declare const DescriptorSetResponse: MessageFns; export declare const IEnumerableConnectedClient: MessageFns; export declare const SerializableDateTimeOffset: MessageFns; export type ConnectionServiceDefinition = typeof ConnectionServiceDefinition; export declare const ConnectionServiceDefinition: { readonly name: "ConnectionService"; readonly fullName: "Cratis.Chronicle.Contracts.Clients.ConnectionService"; readonly methods: { readonly checkCompatibility: { readonly name: "CheckCompatibility"; readonly requestType: typeof CompatibilityRequest; readonly requestStream: false; readonly responseType: typeof CompatibilityResponse; readonly responseStream: false; readonly options: {}; }; readonly connect: { readonly name: "Connect"; readonly requestType: typeof ConnectRequest; readonly requestStream: false; readonly responseType: typeof ConnectionKeepAlive; readonly responseStream: true; readonly options: {}; }; readonly connectionKeepAlive: { readonly name: "ConnectionKeepAlive"; readonly requestType: typeof ConnectionKeepAlive; readonly requestStream: false; readonly responseType: typeof Empty; readonly responseStream: false; readonly options: {}; }; readonly getConnectedClients: { readonly name: "GetConnectedClients"; readonly requestType: typeof Empty; readonly requestStream: false; readonly responseType: typeof IEnumerableConnectedClient; readonly responseStream: false; readonly options: {}; }; readonly getDescriptorSet: { readonly name: "GetDescriptorSet"; readonly requestType: typeof Empty; readonly requestStream: false; readonly responseType: typeof DescriptorSetResponse; readonly responseStream: false; readonly options: {}; }; readonly observeConnectedClients: { readonly name: "ObserveConnectedClients"; readonly requestType: typeof Empty; readonly requestStream: false; readonly responseType: typeof IEnumerableConnectedClient; readonly responseStream: true; readonly options: {}; }; }; }; export interface ConnectionServiceImplementation { checkCompatibility(request: CompatibilityRequest, context: CallContext & CallContextExt): Promise>; connect(request: ConnectRequest, context: CallContext & CallContextExt): ServerStreamingMethodResult>; connectionKeepAlive(request: ConnectionKeepAlive, context: CallContext & CallContextExt): Promise>; getConnectedClients(request: Empty, context: CallContext & CallContextExt): Promise>; getDescriptorSet(request: Empty, context: CallContext & CallContextExt): Promise>; observeConnectedClients(request: Empty, context: CallContext & CallContextExt): ServerStreamingMethodResult>; } export interface ConnectionServiceClient { checkCompatibility(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; connect(request: DeepPartial, options?: CallOptions & CallOptionsExt): AsyncIterable; connectionKeepAlive(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; getConnectedClients(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; getDescriptorSet(request: DeepPartial, options?: CallOptions & CallOptionsExt): Promise; observeConnectedClients(request: DeepPartial, options?: CallOptions & CallOptionsExt): AsyncIterable; } 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=clients.d.ts.map