import { Redis } from "ioredis";
import { Closable } from "../Closable";
import { Job } from "../Job";
import type { ScheduleMap } from "../index";
import { AcknowledgementDescriptor, Acknowledger, OnError } from "../shared/acknowledger";
import * as opentracing from "opentracing";
import type { Logger } from "pino";
declare module "ioredis" {
    interface RedisCommander {
        request(currentTimestamp: number): Promise<[
            queue: string,
            id: string,
            payload: string,
            runAt: string,
            schedule_type: string,
            schedule_meta: string,
            count: string,
            max_times: string,
            exclusive: "true" | "false",
            retry: string | null
        ] | null | -1 | number>;
    }
}
export declare type Processor<ScheduleType extends string> = (job: Readonly<Job<ScheduleType>>, ackDescriptor: AcknowledgementDescriptor, span: opentracing.Span) => Promise<void>;
export declare function getNextExecutionDate<ScheduleType extends string>(scheduleMap: ScheduleMap<ScheduleType>, schedule_type: ScheduleType | undefined, schedule_meta: string, lastExecution: Date): number | undefined;
export declare class Worker<ScheduleType extends string> implements Closable {
    private readonly scheduleMap;
    private readonly processor;
    private readonly logger?;
    private readonly maximumConcurrency;
    private readonly redis;
    private readonly redisSub;
    readonly acknowledger: Acknowledger<ScheduleType>;
    constructor(redisFactory: () => Redis, scheduleMap: ScheduleMap<ScheduleType>, processor: Processor<ScheduleType>, onError?: OnError<ScheduleType>, logger?: Logger | undefined, maximumConcurrency?: number);
    start(): Promise<void>;
    private listenForPubs;
    private getNextExecutionDate;
    private readonly distributor;
    close(): Promise<void>;
}
//# sourceMappingURL=worker.d.ts.map