import type FailedJobService from "./failedJobService";
import type { Job, Queue, QueuePriority } from "./index";
import { type QueueJobEnvelope } from "./jobRunner";
declare const QUEUE_LIST_KEY: string;
declare const QUEUE_HIGH_KEY: string;
declare const QUEUE_LOW_KEY: string;
declare function queueKeyForPriority(priority?: QueuePriority): string;
declare function parseQueueJobEnvelope(rawPayload: string): QueueJobEnvelope | null;
declare class RedisQueue implements Queue {
    private readonly client;
    constructor(redisUrl: string);
    dispatch<TPayload extends object>(job: Job<TPayload>, payload: TPayload): Promise<void>;
}
declare class QueueWorker {
    private readonly failedJobs;
    private readonly timeoutSeconds;
    private running;
    private stopping;
    private readonly client;
    constructor(redisUrl: string, failedJobs: FailedJobService, timeoutSeconds?: number);
    requestStop(): void;
    isRunning(): boolean;
    processNext(): Promise<boolean>;
    run(): Promise<void>;
    close(): void;
}
declare function countPendingQueueJobs(redisUrl: string): Promise<number>;
export type { QueueJobEnvelope };
export { countPendingQueueJobs, parseQueueJobEnvelope, QUEUE_HIGH_KEY, QUEUE_LIST_KEY, QUEUE_LOW_KEY, QueueWorker, queueKeyForPriority, RedisQueue, };