import { ChainableCommander, Redis } from "ioredis";
import { Span } from "opentracing";
import type { Logger } from "pino";
import { Job } from "../Job";
import { Producer } from "../producer/producer";
declare module "ioredis" {
    type AcknowledgeArgs = [
        id: string,
        queue: string,
        timestampToRescheduleFor: number | undefined
    ];
    interface RedisCommander {
        acknowledge(...args: AcknowledgeArgs): Promise<void>;
    }
}
export interface AcknowledgementDescriptor {
    queueId: string;
    jobId: string;
    timestampForNextRetry?: number;
    nextExecutionDate?: number;
}
export declare type OnError<ScheduleType extends string> = (ack: AcknowledgementDescriptor, job: Job<ScheduleType>, error: any) => void;
export declare class Acknowledger<ScheduleType extends string> {
    private readonly redis;
    private readonly producer;
    private readonly onError?;
    private readonly logger?;
    constructor(redis: Redis, producer: Producer<ScheduleType>, onError?: OnError<ScheduleType> | undefined, logger?: Logger | undefined);
    _reportFailure(descriptor: AcknowledgementDescriptor, job: Job<ScheduleType> | null, error: any, pipeline: ChainableCommander, options?: {
        dontReschedule?: boolean;
    }): Promise<void>;
    reportFailure(descriptor: AcknowledgementDescriptor, job: Job<ScheduleType> | null, error: any, options?: {
        dontReschedule?: boolean;
    }): Promise<void>;
    acknowledge(descriptor: AcknowledgementDescriptor, options?: {
        dontReschedule?: boolean;
    }, parentSpan?: Span): Promise<void>;
}
//# sourceMappingURL=acknowledger.d.ts.map