export interface QueueJob {
    id: string;
    type: "chain" | "pipeline";
    name: string;
    input: Record<string, string>;
    priority: number;
    status: "queued" | "running" | "done" | "error";
    executionId?: string;
    error?: string;
    createdAt: string;
    startedAt?: string;
    finishedAt?: string;
    retries: number;
    maxRetries: number;
}
type JobRunner = (job: QueueJob) => Promise<string>;
export declare function initQueue(runner: JobRunner): void;
export declare function enqueue(type: "chain" | "pipeline", name: string, input: Record<string, string>, options?: {
    priority?: number;
    maxRetries?: number;
}): QueueJob;
export declare function getQueueJob(id: string): QueueJob | null;
export declare function listQueueJobs(limit?: number, offset?: number): QueueJob[];
export declare function listQueueByStatus(status: string, limit?: number): QueueJob[];
export declare function cancelQueueJob(id: string): boolean;
export declare function getQueueStats(): {
    queued: number;
    running: number;
    done: number;
    errored: number;
    avgWaitSeconds: number;
    maxWorkers: number;
    activeWorkers: number;
};
export declare function purgeOldJobs(days?: number): number;
export declare function getActiveWorkerCount(): number;
export declare function closeQueue(): void;
export {};