import type { DatabaseAdapter, QueueJobRecord } from '../interfaces/database.ts';
import type { JobMeta, JobStatus } from '../interfaces/job.ts';
import { DbQueue } from '../drivers/db.ts';
import { RedisQueue as NativeRedisQueue } from '../drivers/redis.ts';
export interface RedisClient {
    isOpen?: boolean;
    connect?(): Promise<any>;
    quit?(): Promise<any>;
    incr(key: string): Promise<number>;
    hSet(key: string, field: string | Record<string, string>, value?: string): Promise<number>;
    hGet(key: string, field: string): Promise<string | null>;
    hGetAll(key: string): Promise<Record<string, string>>;
    hDel(key: string, ...fields: string[]): Promise<number>;
    hIncrBy(key: string, field: string, increment: number): Promise<number>;
    zAdd(key: string, member: {
        score: number;
        value: string;
    }): Promise<number>;
    zRem(key: string, ...members: string[]): Promise<number>;
    zRangeByScore(key: string, min: number | string, max: number | string): Promise<string[]>;
    zScore(key: string, member: string): Promise<number | null>;
    zPopMax(key: string): Promise<{
        value: string;
        score: number;
    } | null>;
    del(...keys: string[]): Promise<number>;
}
export interface RedisConfig {
    url?: string;
    host?: string;
    port?: number;
    password?: string;
    database?: number;
    keyPrefix?: string;
}
export declare class RedisDatabaseAdapter implements DatabaseAdapter {
    private client;
    private keyPrefix;
    private connected;
    constructor(client: RedisClient, keyPrefix?: string);
    private ensureConnected;
    private getJobKey;
    private getCounterKey;
    private getWaitingKey;
    private getReservedKey;
    insertJob(payload: Buffer, meta: JobMeta): Promise<string>;
    reserveJob(timeout: number): Promise<QueueJobRecord | null>;
    completeJob(id: string): Promise<void>;
    releaseJob(id: string): Promise<void>;
    failJob(id: string, error: string): Promise<void>;
    getJobStatus(id: string): Promise<JobStatus | null>;
    deleteJob(id: string): Promise<void>;
    markJobDone(id: string): Promise<void>;
    private moveDelayedJobs;
    private recoverExpiredJobs;
    close(): Promise<void>;
}
export declare class RedisQueue<T = Record<string, any>> extends DbQueue<T> {
    constructor(config: {
        client: RedisClient;
        keyPrefix?: string;
        name: string;
    });
}
export declare function createRedisQueue<T = Record<string, any>>(name: string, url?: string): RedisQueue<T>;
export { DbQueue, NativeRedisQueue };