import { JobStatus } from '../constants'; import type { JobDetail, JobSummary, QueueSummary } from '../interfaces/dto.interface'; import { QueueDiscoveryService } from './queue-discovery.service'; export declare class QueueActionsService { private readonly discovery; constructor(discovery: QueueDiscoveryService); listQueues(): Promise; getQueueSummary(name: string): Promise; listJobs(name: string, status: JobStatus, start: number, end: number): Promise; getJob(name: string, id: string): Promise; retryJob(name: string, id: string): Promise; promoteJob(name: string, id: string): Promise; removeJob(name: string, id: string): Promise; pauseQueue(name: string): Promise; resumeQueue(name: string): Promise; cleanQueue(name: string, status: JobStatus, grace: number, limit: number): Promise; /** Make: enqueue a new job. */ addJob(name: string, jobName: string, data: unknown, opts?: Record): Promise<{ id: string | null; name: string; }>; /** Extract: dump up to EXPORT_CAP jobs of a state (with payloads). Reports when capped. */ exportJobs(name: string, status: JobStatus, limit: number): Promise<{ count: number; capped: boolean; jobs: Record[]; }>; /** Manage at scale: retry/promote a whole state in one batch (capped, reports truncation). */ bulkAction(name: string, action: 'retry' | 'promote', status: JobStatus, limit: number): Promise<{ processed: number; capped: boolean; }>; private fetchBatch; private summarize; private toSummary; private requireQueue; private requireJob; }