import GRPCClient from "./GRPCClient";
import IClientPubSub from "../../../interfaces/Client/IClientPubSub";
import { KeyValueType } from "../../../types/KeyValue.type";
import { PubSubPublishResponseType } from "../../../types/pubsub/PubSubPublishResponse.type";
import { PubSubBulkPublishResponse } from "../../../types/pubsub/PubSubBulkPublishResponse.type";
import { PubSubBulkPublishMessage } from "../../../types/pubsub/PubSubBulkPublishMessage.type";
import { PubSubPublishOptions } from "../../../types/pubsub/PubSubPublishOptions.type";
export default class GRPCClientPubSub implements IClientPubSub {
    client: GRPCClient;
    private readonly logger;
    constructor(client: GRPCClient);
    publish(pubSubName: string, topic: string, data: object | string, options?: PubSubPublishOptions): Promise<PubSubPublishResponseType>;
    publishBulk(pubSubName: string, topic: string, messages: PubSubBulkPublishMessage[], metadata?: KeyValueType | undefined): Promise<PubSubBulkPublishResponse>;
}