import { IHttpClient, ILogger } from "../../types/services/clients";
import { IAuthManager, IOptionManager, IRestQueueManager } from "../../types/services/managers";
import { AckJobOptions, EnqueueOptions, EnqueueResult, ListJobsOptions, NackJobOptions, PullJobsOptions, QueueConfig, QueueJob, QueueJobHandler, RegisterWorkerOptions, RunWorkerOptions, UpdateQueueConfigOptions, WorkerRegistration } from "../../types/protocol/queue";
export declare class RestQueueManager implements IRestQueueManager {
    private httpClient;
    private authManager;
    private optionManager;
    private logger;
    private defaultWorkerId;
    private running;
    constructor(httpClient: IHttpClient, authManager: IAuthManager, optionManager: IOptionManager, logger: ILogger, instanceId: string);
    private baseUrl;
    private authHeaders;
    enqueue(queueName: string, payload: unknown, opts?: EnqueueOptions): Promise<EnqueueResult>;
    getJob(queueName: string, jobId: string): Promise<QueueJob>;
    listJobs(queueName: string, opts?: ListJobsOptions): Promise<QueueJob[]>;
    cancelJob(queueName: string, jobId: string): Promise<void>;
    retryJob(queueName: string, jobId: string): Promise<void>;
    getConfig(queueName: string): Promise<QueueConfig>;
    updateConfig(queueName: string, opts: UpdateQueueConfigOptions): Promise<QueueConfig>;
    registerWorker(opts: RegisterWorkerOptions): Promise<WorkerRegistration>;
    heartbeat(workerId: string): Promise<WorkerRegistration>;
    pull(queueName: string, opts?: PullJobsOptions): Promise<QueueJob[]>;
    ack(queueName: string, jobId: string, opts: AckJobOptions): Promise<void>;
    nack(queueName: string, jobId: string, opts: NackJobOptions): Promise<void>;
    runWorker(queueName: string, handler: QueueJobHandler, opts?: RunWorkerOptions): Promise<void>;
    stopWorker(): void;
    reset(): void;
}
//# sourceMappingURL=queue-manager.d.ts.map