/// import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js'; import _m0 from 'protobufjs/minimal'; import { Empty } from '../../../../../google/protobuf/empty'; export declare const protobufPackage = "yandex.cloud.serverless.eventrouter.v1"; export interface PutEventRequest { /** ID of the bus to put event. */ busId: string; /** Event body. */ body: string; } export interface SendEventsRequest { /** ID of the connector to send events. */ connectorId: string; /** Batch of events bodies. */ message: string[]; } export declare const PutEventRequest: { encode(message: PutEventRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): PutEventRequest; fromJSON(object: any): PutEventRequest; toJSON(message: PutEventRequest): unknown; fromPartial, never>>(object: I): PutEventRequest; }; export declare const SendEventsRequest: { encode(message: SendEventsRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): SendEventsRequest; fromJSON(object: any): SendEventsRequest; toJSON(message: SendEventsRequest): unknown; fromPartial, never>) | undefined; } & Record, never>>(object: I): SendEventsRequest; }; /** Service for put events to bus for serverless eventrouter. */ export declare const EventServiceService: { /** Puts event to bus. */ readonly put: { readonly path: "/yandex.cloud.serverless.eventrouter.v1.EventService/Put"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: PutEventRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => PutEventRequest; readonly responseSerialize: (value: Empty) => Buffer; readonly responseDeserialize: (value: Buffer) => Empty; }; /** Send events to bus. */ readonly send: { readonly path: "/yandex.cloud.serverless.eventrouter.v1.EventService/Send"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: SendEventsRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => SendEventsRequest; readonly responseSerialize: (value: Empty) => Buffer; readonly responseDeserialize: (value: Buffer) => Empty; }; }; export interface EventServiceServer extends UntypedServiceImplementation { /** Puts event to bus. */ put: handleUnaryCall; /** Send events to bus. */ send: handleUnaryCall; } export interface EventServiceClient extends Client { /** Puts event to bus. */ put(request: PutEventRequest, callback: (error: ServiceError | null, response: Empty) => void): ClientUnaryCall; put(request: PutEventRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Empty) => void): ClientUnaryCall; put(request: PutEventRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Empty) => void): ClientUnaryCall; /** Send events to bus. */ send(request: SendEventsRequest, callback: (error: ServiceError | null, response: Empty) => void): ClientUnaryCall; send(request: SendEventsRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Empty) => void): ClientUnaryCall; send(request: SendEventsRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Empty) => void): ClientUnaryCall; } export declare const EventServiceClient: { new (address: string, credentials: ChannelCredentials, options?: Partial): EventServiceClient; service: typeof EventServiceService; }; type Builtin = Date | Function | Uint8Array | string | number | boolean | undefined; export type DeepPartial = T extends Builtin ? T : T extends Array ? Array> : T extends ReadonlyArray ? ReadonlyArray> : T extends {} ? { [K in keyof T]?: DeepPartial; } : Partial; type KeysOfUnion = T extends T ? keyof T : never; export type Exact = P extends Builtin ? P : P & { [K in keyof P]: Exact; } & Record>, never>; export {};