import * as valleyed from 'valleyed';
import { PipeOutput } from 'valleyed';
import { D as DelayedJobs, C as CronTypes, R as RepeatableJobs } from '../overrides-6Hxg764S.js';

declare const redisJobsConfigPipe: () => valleyed.Pipe<{
    redisConfig: {
        host: string;
        port: number | undefined;
        password: string | undefined;
        username: string | undefined;
        tls: boolean | undefined;
        cluster: boolean | undefined;
    };
    queueName: string;
}, {
    redisConfig: {
        host: string;
        port: number | undefined;
        password: string | undefined;
        username: string | undefined;
        tls: boolean | undefined;
        cluster: boolean | undefined;
    };
    queueName: string;
}>;
type RedisJobConfig = PipeOutput<ReturnType<typeof redisJobsConfigPipe>>;

type Cron = CronTypes[keyof CronTypes];
type DelayedJobEvent = DelayedJobs[keyof DelayedJobs];
type RepeatableJobEvent = RepeatableJobs[keyof RepeatableJobs];
type DelayedJobCallback = (data: DelayedJobEvent) => Promise<void> | void;
type CronJobCallback = (name: CronTypes[keyof CronTypes]) => Promise<void> | void;
type RepeatableJobCallback = (data: RepeatableJobEvent) => Promise<void> | void;
type JobCallbacks = {
    onDelayed?: DelayedJobCallback;
    onCron?: CronJobCallback;
    onRepeatable?: RepeatableJobCallback;
};
declare class RedisJob {
    #private;
    constructor(config: RedisJobConfig);
    set callbacks(callbacks: JobCallbacks);
    set crons(crons: {
        name: Cron;
        cron: string;
    }[]);
    addDelayed(data: DelayedJobEvent, delayInMs: number): Promise<string>;
    addRepeatable(data: RepeatableJobEvent, cron: string, tz?: string): Promise<string>;
    removeDelayed(jobId: string): Promise<void>;
    retryAllFailedJobs(): Promise<void>;
}

export { RedisJob, type RedisJobConfig, redisJobsConfigPipe };