/// <reference types="node" />
/// <reference types="node" />
import { Cache, Lock, NotificationEmitter } from "./Cache.js";
import { Redis } from "ioredis";
import { StreamMetadataWrapper } from "../models.js";
import { Duration } from "durr";
import { BasePayload, ClientEvents, JobQueue, WorkerEvents } from "../job";
import EventEmitter from "events";
export declare class RedisCache implements Cache {
    private readonly redis;
    constructor(redis: Redis);
    mkJobQueue<Payload extends BasePayload = unknown, Response = undefined, Client extends ClientEvents<Response> = ClientEvents<Response>, Worker extends WorkerEvents = WorkerEvents>(id: string): Promise<JobQueue<Payload, Response, Client, Worker>>;
    expireStreamMetadata(streamId: string, expiration: Date): Promise<void>;
    expireSegmentM4s(streamId: string, segmentId: number, expiration: Date): Promise<void>;
    expireInitMp4(streamId: string, expiration: Date): Promise<void>;
    getStreamMetadata(streamId: string): Promise<StreamMetadataWrapper | null>;
    putStreamMetadata(streamId: string, m3u8: StreamMetadataWrapper, expiration: Date): Promise<void>;
    delStreamMetadata(streamId: string): Promise<void>;
    getInitMp4(streamId: string): Promise<Buffer | null>;
    putInitMp4(streamId: string, initMp4: Buffer, expiration: Date): Promise<void>;
    delInitMp4(streamId: string): Promise<void>;
    getSegmentM4s(streamId: string, segmentId: number): Promise<Buffer | null>;
    putSegmentM4s(streamId: string, segmentId: number, segment: Buffer, expiration: Date): Promise<void>;
    delSegmentM4s(streamId: string, segmentId: number): Promise<void>;
    expireImage(imageId: string, seconds: number): Promise<void>;
    getImage(imageId: string): Promise<Buffer | null>;
    putImage(imageId: string, image: Buffer, expirationSecs: number): Promise<void>;
    delImage(imageId: string): Promise<void>;
    get(key: string): Promise<string | null>;
    del(key: string): Promise<void>;
    put(key: string, value: string, expiration: Date): Promise<void>;
    getPut(key: string, value: string, expiration: Date): Promise<string | null>;
    tryAcquire(key: string, timeout: Duration): Promise<Lock | undefined>;
    pub(key: string, value: string): Promise<void>;
    sub(key: string): Promise<NotificationEmitter>;
}
export declare class RedisNotificationEmitter extends EventEmitter {
    private conn;
    close(): Promise<void>;
    constructor(conn: Redis);
}
//# sourceMappingURL=RedisCache.d.ts.map