/// <reference types="node" />
/// <reference types="node" />
import { StreamMetadataWrapper } from "../models.js";
import { Duration } from "durr";
import { BasePayload, ClientEvents, JobQueue, WorkerEvents } from "../job";
import EventEmitter from "events";
export interface Cache {
    mkJobQueue<Payload extends BasePayload = BasePayload, Response = undefined, Client extends ClientEvents<Response> = ClientEvents<Response>, Worker extends WorkerEvents = WorkerEvents>(id: string): Promise<JobQueue<Payload, Response, Client, Worker>>;
    getStreamMetadata(id: string): Promise<StreamMetadataWrapper | null>;
    putStreamMetadata(id: string, m3u8: StreamMetadataWrapper, expiration: Date): Promise<void>;
    delStreamMetadata(id: string): Promise<void>;
    expireStreamMetadata(id: string, expiration: Date): 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>;
    expireSegmentM4s(streamId: string, segmentId: number, expiration: Date): Promise<void>;
    getInitMp4(streamId: string): Promise<Buffer | null>;
    putInitMp4(streamId: string, initMp4: Buffer, expiration: Date): Promise<void>;
    delInitMp4(streamId: string): Promise<void>;
    expireInitMp4(id: string, expiration: Date): Promise<void>;
    getImage(imageId: string): Promise<Buffer | null>;
    putImage(imageId: string, image: Buffer, expirationSecs: number): Promise<void>;
    delImage(imageId: string): Promise<void>;
    expireImage(imageId: string, seconds: number): Promise<void>;
    put(key: string, value: string, expiration: Date): Promise<void>;
    get(key: string): Promise<string | null>;
    del(key: string): Promise<void>;
    tryAcquire(key: string, timeout: Duration): Promise<Lock | undefined>;
    pub(key: string, value: string): Promise<void>;
    sub(key: string): Promise<NotificationEmitter>;
}
export interface SubEmitterEvents {
    readonly message: (value: string) => void;
}
export interface NotificationEmitter extends EventEmitter {
    on<U extends keyof SubEmitterEvents>(event: U, listener: SubEmitterEvents[U]): this;
    emit<U extends keyof SubEmitterEvents>(event: U, ...args: Parameters<SubEmitterEvents[U]>): boolean;
}
export declare class NotificationEmitter extends EventEmitter {
    close(): Promise<void>;
    constructor();
}
export interface Lock {
    readonly extend: (timeout: Duration) => Promise<Lock>;
    readonly release: () => Promise<void>;
}
//# sourceMappingURL=Cache.d.ts.map