/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
import { Metadata } from '@grpc/grpc-js';
import { AckMessageRequest, ChangeInvisibleDurationRequest, EndTransactionRequest, ForwardMessageToDeadLetterQueueRequest, GetOffsetRequest, HeartbeatRequest, NotifyClientTerminationRequest, PullMessageRequest, QueryAssignmentRequest, QueryOffsetRequest, QueryRouteRequest, ReceiveMessageRequest, SendMessageRequest, UpdateOffsetRequest } from '../../proto/apache/rocketmq/v2/service_pb';
import { Endpoints } from '../route';
import { ILogger } from './Logger';
import type { BaseClient } from './BaseClient';
export declare class RpcClientManager {
    #private;
    constructor(baseClient: BaseClient, logger: ILogger);
    close(): void;
    queryRoute(endpoints: Endpoints, request: QueryRouteRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").QueryRouteResponse>;
    heartbeat(endpoints: Endpoints, request: HeartbeatRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").HeartbeatResponse>;
    sendMessage(endpoints: Endpoints, request: SendMessageRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").SendMessageResponse>;
    queryAssignment(endpoints: Endpoints, request: QueryAssignmentRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").QueryAssignmentResponse>;
    receiveMessage(endpoints: Endpoints, request: ReceiveMessageRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").ReceiveMessageResponse[]>;
    ackMessage(endpoints: Endpoints, request: AckMessageRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").AckMessageResponse>;
    forwardMessageToDeadLetterQueue(endpoints: Endpoints, request: ForwardMessageToDeadLetterQueueRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").ForwardMessageToDeadLetterQueueResponse>;
    pullMessage(endpoints: Endpoints, request: PullMessageRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").PullMessageResponse[]>;
    updateOffset(endpoints: Endpoints, request: UpdateOffsetRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").UpdateOffsetResponse>;
    getOffset(endpoints: Endpoints, request: GetOffsetRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").GetOffsetResponse>;
    queryOffset(endpoints: Endpoints, request: QueryOffsetRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").QueryOffsetResponse>;
    endTransaction(endpoints: Endpoints, request: EndTransactionRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").EndTransactionResponse>;
    telemetry(endpoints: Endpoints, metadata: Metadata): import("@grpc/grpc-js").ClientDuplexStream<import("../../proto/apache/rocketmq/v2/service_pb").TelemetryCommand, import("../../proto/apache/rocketmq/v2/service_pb").TelemetryCommand>;
    changeInvisibleDuration(endpoints: Endpoints, request: ChangeInvisibleDurationRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").ChangeInvisibleDurationResponse>;
    notifyClientTermination(endpoints: Endpoints, request: NotifyClientTerminationRequest, duration: number): Promise<import("../../proto/apache/rocketmq/v2/service_pb").NotifyClientTerminationResponse>;
}