import { ClusterInfo } from "./cluster-state";
import { MessageHandler, PubSub } from "./pub-sub";
import { Redis } from "./redis";
declare class RedisPubSub implements PubSub {
    private redis;
    private clusterInfo;
    private subClient;
    private pubClient;
    private handlers;
    private subscriptions;
    constructor(redis: Redis, clusterInfo: ClusterInfo);
    connect(): Promise<void>;
    subscribe(channelName: string, callback?: MessageHandler): Promise<void>;
    addHandler(channelName: string, callback: MessageHandler): void;
    publish(channelName: string, payload: string): Promise<number>;
    unsubscribe(channelName: string): Promise<void>;
    private onMessage(channelName, payload);
}
export default RedisPubSub;
export { RedisPubSub };