import type { ProxyRoutingInvalidationEvent, ProxyRoutingInvalidationPublisher } from "./routing-invalidation.js";
type RedisListener = (message: string, channel: string) => void;
export interface RoutingInvalidationRedisClient {
    connect(): Promise<void>;
    publish(channel: string, message: string): Promise<number>;
    subscribe(channel: string, listener: RedisListener): Promise<number | void>;
    unsubscribe(channel: string): Promise<number | void>;
    close(): Promise<void>;
    destroy(): void;
    on?(event: "error", listener: (error: unknown) => void): unknown;
}
interface RoutingInvalidationLogger {
    info(message: string, extra?: Record<string, unknown>): void;
    warn(message: string, extra?: Record<string, unknown>): void;
    error(message: string, error?: Error, extra?: Record<string, unknown>): void;
}
export interface ProxyRoutingInvalidationBus extends ProxyRoutingInvalidationPublisher {
    close(): Promise<void>;
}
interface StartProxyRoutingInvalidationBusOptions {
    acknowledgementTimeoutMs?: number;
    createClient?: (redisUrl: string) => RoutingInvalidationRedisClient | Promise<RoutingInvalidationRedisClient>;
    expectedReplicas?: number;
    now?: () => number;
    logger?: RoutingInvalidationLogger;
    onInvalidate: (event: ProxyRoutingInvalidationEvent) => unknown | Promise<unknown>;
    integritySecret?: string;
    redisUrl?: string;
    replicaId?: string;
}
export declare function startProxyRoutingInvalidationBus(options: StartProxyRoutingInvalidationBusOptions): Promise<ProxyRoutingInvalidationBus | null>;
export {};
//# sourceMappingURL=routing-invalidation-redis.d.ts.map