/// import { ChannelCredentials, ChannelOptions, UntypedServiceImplementation, handleUnaryCall, Client, ClientUnaryCall, Metadata, CallOptions, ServiceError } from '@grpc/grpc-js'; import _m0 from 'protobufjs/minimal'; import { TopicSpec, Topic } from '../../../../../yandex/cloud/mdb/kafka/v1/topic'; 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 GetTopicRequest { /** * ID of the Apache Kafka® cluster that the topic belongs to. * * To get the cluster ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the Kafka topic resource to return. * * To get the name of the topic, make a [TopicService.List] request. */ topicName: string; } export interface ListTopicsRequest { /** * ID of the Apache Kafka® cluster to list topics in. * * To get the cluster 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 service returns a [ListTopicsResponse.next_page_token] that can be used to get the next page of results in subsequent list requests. */ pageSize: number; /** * Page token. * * To get the next page of results, set [page_token] to the [ListTopicsResponse.next_page_token] returned by the previous list request. */ pageToken: string; } export interface ListTopicsResponse { /** List of Kafka topics. */ topics: Topic[]; /** * This token allows you to get the next page of results for list requests. * * If the number of results is larger than [ListTopicsRequest.page_size], use the [next_page_token] as the value for the [ListTopicsRequest.page_token] parameter in the next list request. * Each subsequent list request will have its own [next_page_token] to continue paging through the results. */ nextPageToken: string; } export interface CreateTopicRequest { /** * ID of the Apache Kafka® cluster to create a topic in. * * To get the cluster ID, make a [ClusterService.List] request. */ clusterId: string; /** Configuration of the topic to create. */ topicSpec?: TopicSpec; } export interface CreateTopicMetadata { /** ID of the Apache Kafka® cluster where a topic is being created. */ clusterId: string; /** Name of the Kafka topic that is being created. */ topicName: string; } export interface UpdateTopicRequest { /** * ID of the Apache Kafka® cluster to update a topic in. * * To get the cluster ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the topic to update. * * To get the name of the topic, make a [TopicService.List] request. */ topicName: string; updateMask?: FieldMask; /** * New configuration of the topic. * * Use [update_mask] to prevent reverting all topic settings that are not listed in [topic_spec] to their default values. */ topicSpec?: TopicSpec; } export interface UpdateTopicMetadata { /** ID of the Apache Kafka® cluster where a topic is being updated. */ clusterId: string; /** Name of the Kafka topic that is being updated. */ topicName: string; } export interface DeleteTopicRequest { /** * ID of the Apache Kafka® cluster to delete a topic in. * * To get the cluster ID, make a [ClusterService.List] request. */ clusterId: string; /** * Name of the topic to delete. * * To get the name of the topic, make a [TopicService.List] request. */ topicName: string; } export interface DeleteTopicMetadata { /** ID of the Apache Kafka® cluster where a topic is being deleted. */ clusterId: string; /** Name of the Kafka topic that is being deleted. */ topicName: string; } export declare const GetTopicRequest: { encode(message: GetTopicRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): GetTopicRequest; fromJSON(object: any): GetTopicRequest; toJSON(message: GetTopicRequest): unknown; fromPartial, never>>(object: I): GetTopicRequest; }; export declare const ListTopicsRequest: { encode(message: ListTopicsRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListTopicsRequest; fromJSON(object: any): ListTopicsRequest; toJSON(message: ListTopicsRequest): unknown; fromPartial, never>>(object: I): ListTopicsRequest; }; export declare const ListTopicsResponse: { encode(message: ListTopicsResponse, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): ListTopicsResponse; fromJSON(object: any): ListTopicsResponse; toJSON(message: ListTopicsResponse): unknown; fromPartial, never>) | undefined; topicConfig3?: ({ cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").TopicConfig3_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & { cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").TopicConfig3_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & Record, never>) | undefined; } & Record, never>)[] & Record, never>) | undefined; nextPageToken?: string | undefined; } & Record, never>>(object: I): ListTopicsResponse; }; export declare const CreateTopicRequest: { encode(message: CreateTopicRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): CreateTopicRequest; fromJSON(object: any): CreateTopicRequest; toJSON(message: CreateTopicRequest): unknown; fromPartial, never>) | undefined; topicConfig3?: ({ cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").TopicConfig3_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & { cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").TopicConfig3_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): CreateTopicRequest; }; export declare const CreateTopicMetadata: { encode(message: CreateTopicMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): CreateTopicMetadata; fromJSON(object: any): CreateTopicMetadata; toJSON(message: CreateTopicMetadata): unknown; fromPartial, never>>(object: I): CreateTopicMetadata; }; export declare const UpdateTopicRequest: { encode(message: UpdateTopicRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateTopicRequest; fromJSON(object: any): UpdateTopicRequest; toJSON(message: UpdateTopicRequest): unknown; fromPartial, never>) | undefined; } & Record, never>) | undefined; topicSpec?: ({ name?: string | undefined; partitions?: number | undefined; replicationFactor?: number | undefined; topicConfig28?: { cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").Topicconfig28_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } | undefined; topicConfig3?: { cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").TopicConfig3_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } | undefined; } & { name?: string | undefined; partitions?: number | undefined; replicationFactor?: number | undefined; topicConfig28?: ({ cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").Topicconfig28_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & { cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").Topicconfig28_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & Record, never>) | undefined; topicConfig3?: ({ cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").TopicConfig3_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & { cleanupPolicy?: import("../../../../../yandex/cloud/mdb/kafka/v1/topic").TopicConfig3_CleanupPolicy | undefined; compressionType?: import("./common").CompressionType | undefined; deleteRetentionMs?: number | undefined; fileDeleteDelayMs?: number | undefined; flushMessages?: number | undefined; flushMs?: number | undefined; minCompactionLagMs?: number | undefined; retentionBytes?: number | undefined; retentionMs?: number | undefined; maxMessageBytes?: number | undefined; minInsyncReplicas?: number | undefined; segmentBytes?: number | undefined; preallocate?: boolean | undefined; } & Record, never>) | undefined; } & Record, never>) | undefined; } & Record, never>>(object: I): UpdateTopicRequest; }; export declare const UpdateTopicMetadata: { encode(message: UpdateTopicMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): UpdateTopicMetadata; fromJSON(object: any): UpdateTopicMetadata; toJSON(message: UpdateTopicMetadata): unknown; fromPartial, never>>(object: I): UpdateTopicMetadata; }; export declare const DeleteTopicRequest: { encode(message: DeleteTopicRequest, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): DeleteTopicRequest; fromJSON(object: any): DeleteTopicRequest; toJSON(message: DeleteTopicRequest): unknown; fromPartial, never>>(object: I): DeleteTopicRequest; }; export declare const DeleteTopicMetadata: { encode(message: DeleteTopicMetadata, writer?: _m0.Writer): _m0.Writer; decode(input: _m0.Reader | Uint8Array, length?: number): DeleteTopicMetadata; fromJSON(object: any): DeleteTopicMetadata; toJSON(message: DeleteTopicMetadata): unknown; fromPartial, never>>(object: I): DeleteTopicMetadata; }; /** A set of methods for managing Kafka topics. */ export declare const TopicServiceService: { /** * Returns the specified Kafka topic. * * To get the list of available Kafka topics, make a [List] request. */ readonly get: { readonly path: "/yandex.cloud.mdb.kafka.v1.TopicService/Get"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: GetTopicRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => GetTopicRequest; readonly responseSerialize: (value: Topic) => Buffer; readonly responseDeserialize: (value: Buffer) => Topic; }; /** Retrieves the list of Kafka topics in the specified cluster. */ readonly list: { readonly path: "/yandex.cloud.mdb.kafka.v1.TopicService/List"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: ListTopicsRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => ListTopicsRequest; readonly responseSerialize: (value: ListTopicsResponse) => Buffer; readonly responseDeserialize: (value: Buffer) => ListTopicsResponse; }; /** Creates a new Kafka topic in the specified cluster. */ readonly create: { readonly path: "/yandex.cloud.mdb.kafka.v1.TopicService/Create"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: CreateTopicRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => CreateTopicRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; /** Updates the specified Kafka topic. */ readonly update: { readonly path: "/yandex.cloud.mdb.kafka.v1.TopicService/Update"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: UpdateTopicRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => UpdateTopicRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; /** Deletes the specified Kafka topic. */ readonly delete: { readonly path: "/yandex.cloud.mdb.kafka.v1.TopicService/Delete"; readonly requestStream: false; readonly responseStream: false; readonly requestSerialize: (value: DeleteTopicRequest) => Buffer; readonly requestDeserialize: (value: Buffer) => DeleteTopicRequest; readonly responseSerialize: (value: Operation) => Buffer; readonly responseDeserialize: (value: Buffer) => Operation; }; }; export interface TopicServiceServer extends UntypedServiceImplementation { /** * Returns the specified Kafka topic. * * To get the list of available Kafka topics, make a [List] request. */ get: handleUnaryCall; /** Retrieves the list of Kafka topics in the specified cluster. */ list: handleUnaryCall; /** Creates a new Kafka topic in the specified cluster. */ create: handleUnaryCall; /** Updates the specified Kafka topic. */ update: handleUnaryCall; /** Deletes the specified Kafka topic. */ delete: handleUnaryCall; } export interface TopicServiceClient extends Client { /** * Returns the specified Kafka topic. * * To get the list of available Kafka topics, make a [List] request. */ get(request: GetTopicRequest, callback: (error: ServiceError | null, response: Topic) => void): ClientUnaryCall; get(request: GetTopicRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Topic) => void): ClientUnaryCall; get(request: GetTopicRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Topic) => void): ClientUnaryCall; /** Retrieves the list of Kafka topics in the specified cluster. */ list(request: ListTopicsRequest, callback: (error: ServiceError | null, response: ListTopicsResponse) => void): ClientUnaryCall; list(request: ListTopicsRequest, metadata: Metadata, callback: (error: ServiceError | null, response: ListTopicsResponse) => void): ClientUnaryCall; list(request: ListTopicsRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: ListTopicsResponse) => void): ClientUnaryCall; /** Creates a new Kafka topic in the specified cluster. */ create(request: CreateTopicRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; create(request: CreateTopicRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; create(request: CreateTopicRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; /** Updates the specified Kafka topic. */ update(request: UpdateTopicRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; update(request: UpdateTopicRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; update(request: UpdateTopicRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; /** Deletes the specified Kafka topic. */ delete(request: DeleteTopicRequest, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; delete(request: DeleteTopicRequest, metadata: Metadata, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; delete(request: DeleteTopicRequest, metadata: Metadata, options: Partial, callback: (error: ServiceError | null, response: Operation) => void): ClientUnaryCall; } export declare const TopicServiceClient: { new (address: string, credentials: ChannelCredentials, options?: Partial): TopicServiceClient; service: typeof TopicServiceService; }; 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 {};