legacy-libs/grpc-cloned/node_modules/@grpc/grpc-js/build/src/client.d.ts

   1 /// <reference types="node" />
   2 import { ClientDuplexStream, ClientReadableStream, ClientUnaryCall, ClientWritableStream, ServiceError } from './call';
   3 import { CallCredentials } from './call-credentials';
   4 import { Call, Deadline } from './call-stream';
   5 import { Channel } from './channel';
   6 import { ChannelCredentials } from './channel-credentials';
   7 import { ChannelOptions } from './channel-options';
   8 import { Metadata } from './metadata';
   9 export declare const kChannel: unique symbol;
  10 export interface UnaryCallback<ResponseType> {
  11     (err: ServiceError | null, value?: ResponseType): void;
  12 }
  13 export interface CallOptions {
  14     deadline?: Deadline;
  15     host?: string;
  16     parent?: Call;
  17     propagate_flags?: number;
  18     credentials?: CallCredentials;
  19 }
  20 export declare type ClientOptions = Partial<ChannelOptions> & {
  21     channelOverride?: Channel;
  22     channelFactoryOverride?: (address: string, credentials: ChannelCredentials, options: ClientOptions) => Channel;
  23 };
  24 /**
  25  * A generic gRPC client. Primarily useful as a base class for all generated
  26  * clients.
  27  */
  28 export declare class Client {
  29     private readonly [kChannel];
  30     constructor(address: string, credentials: ChannelCredentials, options?: ClientOptions);
  31     close(): void;
  32     getChannel(): Channel;
  33     waitForReady(deadline: Deadline, callback: (error?: Error) => void): void;
  34     private handleUnaryResponse;
  35     private checkOptionalUnaryResponseArguments;
  36     makeUnaryRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, argument: RequestType, metadata: Metadata, options: CallOptions, callback: UnaryCallback<ResponseType>): ClientUnaryCall;
  37     makeUnaryRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, argument: RequestType, metadata: Metadata, callback: UnaryCallback<ResponseType>): ClientUnaryCall;
  38     makeUnaryRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, argument: RequestType, options: CallOptions, callback: UnaryCallback<ResponseType>): ClientUnaryCall;
  39     makeUnaryRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, argument: RequestType, callback: UnaryCallback<ResponseType>): ClientUnaryCall;
  40     makeClientStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, metadata: Metadata, options: CallOptions, callback: UnaryCallback<ResponseType>): ClientWritableStream<RequestType>;
  41     makeClientStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, metadata: Metadata, callback: UnaryCallback<ResponseType>): ClientWritableStream<RequestType>;
  42     makeClientStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, options: CallOptions, callback: UnaryCallback<ResponseType>): ClientWritableStream<RequestType>;
  43     makeClientStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, callback: UnaryCallback<ResponseType>): ClientWritableStream<RequestType>;
  44     private checkMetadataAndOptions;
  45     makeServerStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, argument: RequestType, metadata: Metadata, options?: CallOptions): ClientReadableStream<ResponseType>;
  46     makeServerStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, argument: RequestType, options?: CallOptions): ClientReadableStream<ResponseType>;
  47     makeBidiStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, metadata: Metadata, options?: CallOptions): ClientDuplexStream<RequestType, ResponseType>;
  48     makeBidiStreamRequest<RequestType, ResponseType>(method: string, serialize: (value: RequestType) => Buffer, deserialize: (value: Buffer) => ResponseType, options?: CallOptions): ClientDuplexStream<RequestType, ResponseType>;
  49 }