import Redis from "ioredis";
import { OperationRegistry } from "../race";
import { CacheStats } from "../metrics/types";
import { logHandle } from "../logging";
import { ICacheStorage } from "../storage/storage-interface";
import { ICacheController, Operations } from "./controller-interface";
export declare class RedisCacheController implements ICacheController {
    private streamId;
    private pub;
    private sub;
    private combinedStats;
    private storage;
    private closing;
    private log;
    private operationRegistries;
    private unlocks;
    constructor({ streamId, redis, check, storage, log, }: {
        streamId: string;
        redis: Redis;
        check: () => boolean;
        storage?: ICacheStorage;
        log?: logHandle;
    });
    evictCacheKey(key: string): Promise<void>;
    storeCacheKey(key: string, ttlMilliseconds: number, value: any): Promise<void>;
    sendCacheStats(requester: string): Promise<void>;
    requestCacheStats(timeoutMs?: number): Promise<Map<string, CacheStats>>;
    listenForMessage(repeat: () => boolean): Promise<void>;
    processMessage(message: Operations): Promise<void>;
    requestCacheKeyEviction(key: string): Promise<void>;
    broadcastCacheKey(key: string, ttlMilliseconds: number, value: Awaited<any>): Promise<void>;
    requestOperationStart(operation: string, key: string): Promise<void>;
    requestOperationEnd(operation: string, key: string, data: any, error: boolean, unlock: Promise<void>): Promise<void>;
    lock(key: string, lockTtlMs: number): Promise<{
        lockResult: boolean;
        unlockFunction: Promise<void> | null;
    }>;
    unlock(key: string): Promise<void>;
    setRegistry(operation: string, operationRegistry: OperationRegistry): void;
    getOperationPromise<T>(operation: string, key: string): Promise<T> | undefined;
    close(): Promise<void>;
}
//# sourceMappingURL=redis-cache-controller.d.ts.map