/// import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js'; import _m0 from 'protobufjs/minimal'; import { ConnectorSpec, UpdateConnectorSpec, Connector } from '../../../../../yandex/cloud/mdb/kafka/v1/connector'; import { FieldMask } from '../../../../../google/protobuf/field_mask'; import { Operation } from '../../../../../yandex/cloud/operation/operation'; export declare const protobufPackage = "yandex.cloud.mdb.kafka.v1"; export interface GetConnectorRequest { /** * ID of the Apache Kafka® cluster the connector belongs to. * * To get this ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the Apache Kafka® connector to return information about. * * To get this name, make a [ConnectorService.List] request. */ connectorName: string; } export interface ListConnectorsRequest { /** * ID of the Apache Kafka® cluster to list connectors in. * * To get this ID, make a [ClusterService.List] request. */ clusterId: string; /** * The maximum number of results per page to return. * * If the number of available results is larger than [page_size], the API returns a [ListConnectorsResponse.next_page_token] that can be used to get the next page of results in the subsequent [ConnectorService.List] requests. */ pageSize: number; /** * Page token that can be used to iterate through multiple pages of results. * * To get the next page of results, set [page_token] to the [ListConnectorsResponse.next_page_token] returned by the previous [ConnectorService.List] request. */ pageToken: string; } export interface ListConnectorsResponse { /** List of Apache Kafka® Connectors. */ connectors: Connector[]; /** * The token that can be used to get the next page of results. * * If the number of results is larger than [ListConnectorsRequest.page_size], use the [next_page_token] as the value for the [ListConnectorsRequest.page_token] in the subsequent [ConnectorService.List] request to iterate through multiple pages of results. */ nextPageToken: string; } export interface CreateConnectorRequest { /** * ID of the Apache Kafka® cluster to create the connector in. * * To get this ID, make a [ClusterService.List] request. */ clusterId: string; /** Configuration of the connector to create. */ connectorSpec?: ConnectorSpec; } export interface CreateConnectorMetadata { /** ID of the Apache Kafka® cluster the connector is being created in. */ clusterId: string; /** Name of the Apache Kafka® connector that is being created. */ connectorName: string; } export interface UpdateConnectorRequest { /** * ID of the Apache Kafka® cluster to update the connector in. * * To get this ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the connector to update. * * To get this name, make a [ConnectorService.List] request. */ connectorName: string; /** Field mask that specifies which settings of the connector should be updated. */ updateMask?: FieldMask; /** Configuration of the connector to update. */ connectorSpec?: UpdateConnectorSpec; } export interface UpdateConnectorMetadata { /** ID of the Apache Kafka® cluster the connector is being updated in. */ clusterId: string; /** Name of the Apache Kafka® connector that is being updated. */ connectorName: string; } export interface DeleteConnectorRequest { /** * ID of the Apache Kafka® cluster to delete the connector from. * * To get this ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the connector to delete. * * To get this name, make a [ConnectorService.List] request. */ connectorName: string; } export interface DeleteConnectorMetadata { /** ID of the Apache Kafka® cluster the connector is being deleted from. */ clusterId: string; /** Name of the Apache Kafka® connector that is being deleted. */ connectorName: string; } export interface ResumeConnectorRequest { /** * ID of the Apache Kafka® cluster to resume the connector in. * * To get this ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the Apache Kafka® connector to resume. * * To get this name, make a [ConnectorService.List] request. */ connectorName: string; } export interface ResumeConnectorMetadata { /** ID of the Apache Kafka® cluster the connector is being resumed in. */ clusterId: string; /** Name of the Apache Kafka® connector that is beign resumed. */ connectorName: string; } export interface PauseConnectorRequest { /** * ID of the Apache Kafka® cluster to pause the connector in. * * To get this ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the Apache Kafka® connector to pause. * * To get this name, make a [ConnectorService.List] request. */ connectorName: string; } export interface PauseConnectorMetadata { /** ID of the Apache Kafka® cluster the connector is being paused in. */ clusterId: string; /** Name of the Apache Kafka® connector that is being paused. */ connectorName: string; } export declare const GetConnectorRequest: { encode(message: GetConnectorRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): GetConnectorRequest; fromJSON(object: any): GetConnectorRequest; toJSON(message: GetConnectorRequest): unknown; fromPartial, never>>(object: I): GetConnectorRequest; }; export declare const ListConnectorsRequest: { encode(message: ListConnectorsRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListConnectorsRequest; fromJSON(object: any): ListConnectorsRequest; toJSON(message: ListConnectorsRequest): unknown; fromPartial, never>>(object: I): ListConnectorsRequest; }; export declare const ListConnectorsResponse: { encode(message: ListConnectorsResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListConnectorsResponse; fromJSON(object: any): ListConnectorsResponse; toJSON(message: ListConnectorsResponse): unknown; fromPartial, never>) | undefined; health?: import("../../../../../yandex/cloud/mdb/kafka/v1/connector").Connector_Health | undefined; status?: import("../../../../../yandex/cloud/mdb/kafka/v1/connector").Connector_Status | undefined; clusterId?: string | undefined; connectorConfigMirrormaker?: ({ sourceCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } | undefined; targetCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & { sourceCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>) | undefined; connectorConfigS3Sink?: ({ topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: { bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } | undefined; } & { topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: ({ bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } & { bucketName?: string | undefined; externalS3?: ({ accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & { accessKeyId?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>)[] & Record, never>) | undefined; nextPageToken?: string | undefined; } & Record, never>>(object: I): ListConnectorsResponse; }; export declare const CreateConnectorRequest: { encode(message: CreateConnectorRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): CreateConnectorRequest; fromJSON(object: any): CreateConnectorRequest; toJSON(message: CreateConnectorRequest): unknown; fromPartial, never>) | undefined; connectorConfigMirrormaker?: ({ sourceCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; targetCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & { sourceCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>) | undefined; connectorConfigS3Sink?: ({ topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: { bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } | undefined; } & { topics?: string | undefined; fileCompressionType?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: ({ bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } & { bucketName?: string | undefined; externalS3?: ({ accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): CreateConnectorRequest; }; export declare const CreateConnectorMetadata: { encode(message: CreateConnectorMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): CreateConnectorMetadata; fromJSON(object: any): CreateConnectorMetadata; toJSON(message: CreateConnectorMetadata): unknown; fromPartial, never>>(object: I): CreateConnectorMetadata; }; export declare const UpdateConnectorRequest: { encode(message: UpdateConnectorRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateConnectorRequest; fromJSON(object: any): UpdateConnectorRequest; toJSON(message: UpdateConnectorRequest): unknown; fromPartial, never>) | undefined; } & Record, never>) | undefined; connectorSpec?: ({ tasksMax?: number | undefined; properties?: { [x: string]: string | undefined; } | undefined; connectorConfigMirrormaker?: { sourceCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; targetCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } | undefined; connectorConfigS3Sink?: { topics?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: { bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } | undefined; } | undefined; } & { tasksMax?: number | undefined; properties?: ({ [x: string]: string | undefined; } & { [x: string]: string | undefined; } & Record, never>) | undefined; connectorConfigMirrormaker?: ({ sourceCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; targetCluster?: { alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & { sourceCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; targetCluster?: ({ alias?: string | undefined; thisCluster?: {} | undefined; externalCluster?: { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } | undefined; } & { alias?: string | undefined; thisCluster?: ({} & {} & Record, never>) | undefined; externalCluster?: ({ bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & { bootstrapServers?: string | undefined; saslUsername?: string | undefined; saslPassword?: string | undefined; saslMechanism?: string | undefined; securityProtocol?: string | undefined; sslTruststoreCertificates?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; topics?: string | undefined; replicationFactor?: number | undefined; } & Record, never>) | undefined; connectorConfigS3Sink?: ({ topics?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: { bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } | undefined; } & { topics?: string | undefined; fileMaxRecords?: number | undefined; s3Connection?: ({ bucketName?: string | undefined; externalS3?: { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } | undefined; } & { bucketName?: string | undefined; externalS3?: ({ accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & { accessKeyId?: string | undefined; secretAccessKey?: string | undefined; endpoint?: string | undefined; region?: string | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): UpdateConnectorRequest; }; export declare const UpdateConnectorMetadata: { encode(message: UpdateConnectorMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateConnectorMetadata; fromJSON(object: any): UpdateConnectorMetadata; toJSON(message: UpdateConnectorMetadata): unknown; fromPartial, never>>(object: I): UpdateConnectorMetadata; }; export declare const DeleteConnectorRequest: { encode(message: DeleteConnectorRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): DeleteConnectorRequest; fromJSON(object: any): DeleteConnectorRequest; toJSON(message: DeleteConnectorRequest): unknown; fromPartial, never>>(object: I): DeleteConnectorRequest; }; export declare const DeleteConnectorMetadata: { encode(message: DeleteConnectorMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): DeleteConnectorMetadata; fromJSON(object: any): DeleteConnectorMetadata; toJSON(message: DeleteConnectorMetadata): unknown; fromPartial, never>>(object: I): DeleteConnectorMetadata; }; export declare const ResumeConnectorRequest: { encode(message: ResumeConnectorRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ResumeConnectorRequest; fromJSON(object: any): ResumeConnectorRequest; toJSON(message: ResumeConnectorRequest): unknown; fromPartial, never>>(object: I): ResumeConnectorRequest; }; export declare const ResumeConnectorMetadata: { encode(message: ResumeConnectorMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ResumeConnectorMetadata; fromJSON(object: any): ResumeConnectorMetadata; toJSON(message: ResumeConnectorMetadata): unknown; fromPartial, never>>(object: I): ResumeConnectorMetadata; }; export declare const PauseConnectorRequest: { encode(message: PauseConnectorRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): PauseConnectorRequest; fromJSON(object: any): PauseConnectorRequest; toJSON(message: PauseConnectorRequest): unknown; fromPartial, never>>(object: I): PauseConnectorRequest; }; export declare const PauseConnectorMetadata: { encode(message: PauseConnectorMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): PauseConnectorMetadata; fromJSON(object: any): PauseConnectorMetadata; toJSON(message: PauseConnectorMetadata): unknown; fromPartial, never>>(object: I): PauseConnectorMetadata; }; /** A set of methods for managing Apache Kafka® connectors. */ export declare const ConnectorServiceService: { /** Returns information about an Apache Kafka® connector. */ readonly get: { readonly path: "/yandex.cloud.mdb.kafka.v1.ConnectorService/Get"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: GetConnectorRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => GetConnectorRequest; readonly responseSerialize: (value: Connector) => Buffer; readonly responseDeserialize: (value: Buffer) => Connector; }; /** Retrieves the list of Apache Kafka® connectors in a cluster. */ readonly list: { readonly path: "/yandex.cloud.mdb.kafka.v1.ConnectorService/List"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: ListConnectorsRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => ListConnectorsRequest; readonly responseSerialize: (value: ListConnectorsResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => ListConnectorsResponse; }; /** Creates a new Apache Kafka® connector in a cluster. */ readonly create: { readonly path: "/yandex.cloud.mdb.kafka.v1.ConnectorService/Create"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: CreateConnectorRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => CreateConnectorRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; /** Updates an Apache Kafka® connector. */ readonly update: { readonly path: "/yandex.cloud.mdb.kafka.v1.ConnectorService/Update"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: UpdateConnectorRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => UpdateConnectorRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; /** Deletes an Apache Kafka® connector. */ readonly delete: { readonly path: "/yandex.cloud.mdb.kafka.v1.ConnectorService/Delete"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: DeleteConnectorRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => DeleteConnectorRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; /** Resumes an Apache Kafka® connector. */ readonly resume: { readonly path: "/yandex.cloud.mdb.kafka.v1.ConnectorService/Resume"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: ResumeConnectorRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => ResumeConnectorRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; /** Pauses an Apache Kafka® connector. */ readonly pause: { readonly path: "/yandex.cloud.mdb.kafka.v1.ConnectorService/Pause"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: PauseConnectorRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => PauseConnectorRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; }; export interface ConnectorServiceServer extends UntypedServiceImplementation { /** Returns information about an Apache Kafka® connector. */ get: handleUnaryCall; /** Retrieves the list of Apache Kafka® connectors in a cluster. */ list: handleUnaryCall; /** Creates a new Apache Kafka® connector in a cluster. */ create: handleUnaryCall; /** Updates an Apache Kafka® connector. */ update: handleUnaryCall; /** Deletes an Apache Kafka® connector. */ delete: handleUnaryCall; /** Resumes an Apache Kafka® connector. */ resume: handleUnaryCall; /** Pauses an Apache Kafka® connector. */ pause: handleUnaryCall; } export interface ConnectorServiceClient extends Client { /** Returns information about an Apache Kafka® connector. */ get(request: GetConnectorRequest, callback: (error: ServiceError | null, response: Connector) => void): ClientUnaryCall; get(request: GetConnectorRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Connector) => void): ClientUnaryCall; get(request: GetConnectorRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Connector) => void): ClientUnaryCall; /** Retrieves the list of Apache Kafka® connectors in a cluster. */ list(request: ListConnectorsRequest, callback: (error: ServiceError | null, response: ListConnectorsResponse) => void): ClientUnaryCall; list(request: ListConnectorsRequest, metadata: Metadata, callback: (error: ServiceError | null, response: ListConnectorsResponse) => void): ClientUnaryCall; list(request: ListConnectorsRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: ListConnectorsResponse) => void): ClientUnaryCall; /** Creates a new Apache Kafka® connector in a cluster. */ create(request: CreateConnectorRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; create(request: CreateConnectorRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; create(request: CreateConnectorRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; /** Updates an Apache Kafka® connector. */ update(request: UpdateConnectorRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; update(request: UpdateConnectorRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; update(request: UpdateConnectorRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; /** Deletes an Apache Kafka® connector. */ delete(request: DeleteConnectorRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; delete(request: DeleteConnectorRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; delete(request: DeleteConnectorRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; /** Resumes an Apache Kafka® connector. */ resume(request: ResumeConnectorRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; resume(request: ResumeConnectorRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; resume(request: ResumeConnectorRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; /** Pauses an Apache Kafka® connector. */ pause(request: PauseConnectorRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; pause(request: PauseConnectorRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; pause(request: PauseConnectorRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; } export declare const ConnectorServiceClient: { new (address: string, credentials: ChannelCredentials, options?: Partial): ConnectorServiceClient; service: typeof ConnectorServiceService; }; 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 {};