import { Queue } from '../core/queue.ts';
import type { JobStatus, JobMeta, QueueMessage, BaseJobOptions, WithPriority, WithDelay } from '../interfaces/job.ts';
import type { QueueOptions } from '../interfaces/plugin.ts';
export interface RedisJobRequest<TPayload> extends BaseJobOptions, WithPriority, WithDelay {
    /** Job payload */
    payload: TPayload;
}
export interface RedisClient {
    incr(key: string): Promise<number>;
    hSet(key: string, field: string, value: string): Promise<number>;
    hGet(key: string, field: string): Promise<string | null>;
    hDel(key: string, fields: string[]): Promise<number>;
    hIncrBy(key: string, field: string, increment: number): Promise<number>;
    zAdd(key: string, members: {
        score: number;
        value: string;
    }): Promise<number>;
    zRem(key: string, members: string[]): Promise<number>;
    zRangeByScore(key: string, min: number | string, max: number | string, options?: {
        REV?: boolean;
        LIMIT?: {
            offset: number;
            count: number;
        };
    }): Promise<string[]>;
    zRange(key: string, start: number, stop: number, options?: {
        REV?: boolean;
    }): Promise<string[]>;
    zScore(key: string, member: string): Promise<number | null>;
    del(keys: string[]): Promise<number>;
}
export declare class RedisQueue<TJobMap = Record<string, any>> extends Queue<TJobMap, RedisJobRequest<any>> {
    private queueName;
    private messagesKey;
    private waitingKey;
    private delayedKey;
    private reservedKey;
    private attemptsKey;
    private idKey;
    private redis;
    constructor(redisClient: any, // Accept any Redis client
    queueName: string | undefined, options: QueueOptions & {
        keyPrefix?: string;
    });
    protected pushMessage(payload: unknown, meta: JobMeta): Promise<string>;
    protected reserve(timeout: number): Promise<QueueMessage | null>;
    protected completeJob(message: QueueMessage): Promise<void>;
    protected failJob(message: QueueMessage, error: unknown): Promise<void>;
    status(id: string): Promise<JobStatus>;
    private moveDelayedJobs;
    private moveExpiredJobs;
    /**
     * Get the number of jobs in the waiting queue
     */
    getWaitingCount(): Promise<number>;
    /**
     * Get the number of jobs in the delayed queue
     */
    getDelayedCount(): Promise<number>;
    /**
     * Get the number of jobs in the reserved queue
     */
    getReservedCount(): Promise<number>;
    /**
     * Clear all jobs from this queue
     */
    clear(): Promise<void>;
}