/// import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js'; import _m0 from 'protobufjs/minimal'; export declare const protobufPackage = "yandex.cloud.iot.broker.v1"; export interface PublishBrokerDataRequest { /** ID of broker publishing message */ brokerId: string; /** Topic where message should be published */ topic: string; /** Content of the message */ data: Buffer; } export interface PublishBrokerDataResponse { } export declare const PublishBrokerDataRequest: { encode(message: PublishBrokerDataRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): PublishBrokerDataRequest; fromJSON(object: any): PublishBrokerDataRequest; toJSON(message: PublishBrokerDataRequest): unknown; fromPartial, never>>(object: I): PublishBrokerDataRequest; }; export declare const PublishBrokerDataResponse: { encode(_: PublishBrokerDataResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): PublishBrokerDataResponse; fromJSON(_: any): PublishBrokerDataResponse; toJSON(_: PublishBrokerDataResponse): unknown; fromPartial, never>>(_: I): PublishBrokerDataResponse; }; /** A set of methods to work with IoT Core messages on behalf of broker */ export declare const BrokerDataServiceService: { /** Publishes message on behalf of specified broker */ readonly publish: { readonly path: "/yandex.cloud.iot.broker.v1.BrokerDataService/Publish"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: PublishBrokerDataRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => PublishBrokerDataRequest; readonly responseSerialize: (value: PublishBrokerDataResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => PublishBrokerDataResponse; }; }; export interface BrokerDataServiceServer extends UntypedServiceImplementation { /** Publishes message on behalf of specified broker */ publish: handleUnaryCall; } export interface BrokerDataServiceClient extends Client { /** Publishes message on behalf of specified broker */ publish(request: PublishBrokerDataRequest, callback: (error: ServiceError | null, response: PublishBrokerDataResponse) => void): ClientUnaryCall; publish(request: PublishBrokerDataRequest, metadata: Metadata, callback: (error: ServiceError | null, response: PublishBrokerDataResponse) => void): ClientUnaryCall; publish(request: PublishBrokerDataRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: PublishBrokerDataResponse) => void): ClientUnaryCall; } export declare const BrokerDataServiceClient: { new (address: string, credentials: ChannelCredentials, options?: Partial): BrokerDataServiceClient; service: typeof BrokerDataServiceService; }; 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 {};
= P extends Builtin ? P : P & { [K in keyof P]: Exact
; } & Record>, never>; export {};