import type BeeQueue from "bee-queue"; import { QueueAdapter, type AdaptedJob, type JobCounts, type FeatureSupport, type JobPageMeta, type JobScanToken, type WorkerInfo } from "./base.adapter"; type BeeStatus = "waiting" | "active" | "completed" | "failed" | "delayed"; type BeeCleanableStatus = never; export declare class BeeAdapter extends QueueAdapter { private queue; private setSnapshots; private setSnapshotExpiries; private setSnapshotTails; private pageMeta; supports: FeatureSupport; constructor(queue: BeeQueue, displayName: string, jobNameFn?: (data: Record) => string); getName(): string; getType(): "bee"; beginJobScan(status: BeeStatus, _scanLimit?: number): JobScanToken | undefined; endJobScan(scanToken: JobScanToken): void; getJobCounts(): Promise; getFailedCount(): Promise; isPaused(): Promise; pause(): Promise; resume(): Promise; empty(): Promise; clean(status: BeeCleanableStatus, graceMs: number): Promise; getRedisInfo(): Promise; getJobs(status: BeeStatus, start: number, end: number, scanLimit?: number, scanToken?: JobScanToken): Promise; private getOrderedJobIds; private readStoredJobs; getJob(jobId: string): Promise; getJobStatus(jobId: string): Promise; addJob(data: Record): Promise; rerunJob(jobId: string): Promise; removeJob(jobId: string): Promise; retryJob(): Promise; promoteJob(): Promise; discardJob(jobId: string): Promise; getJobLogs(): Promise; getWorkers(): Promise; private scanSet; private scheduleSetSnapshotExpiry; private createSetSnapshot; private populateSetSnapshot; private readSetSnapshotPage; private getSetJobsPage; getJobPageMeta(jobs: AdaptedJob[]): JobPageMeta | undefined; private adaptJob; } export {}; //# sourceMappingURL=bee.adapter.d.ts.map