repeat.d.ts 1.3 KB

12345678910111213141516171819202122232425
  1. import { RepeatBaseOptions, RepeatableJob, RepeatOptions } from '../interfaces';
  2. import { JobsOptions } from '../types';
  3. import { Job } from './job';
  4. import { QueueBase } from './queue-base';
  5. import { RedisConnection } from './redis-connection';
  6. export declare class Repeat extends QueueBase {
  7. private repeatStrategy;
  8. private repeatKeyHashAlgorithm;
  9. constructor(name: string, opts: RepeatBaseOptions, Connection?: typeof RedisConnection);
  10. updateRepeatableJob<T = any, R = any, N extends string = string>(name: N, data: T, opts: JobsOptions, { override }: {
  11. override: boolean;
  12. }): Promise<Job<T, R, N> | undefined>;
  13. private createNextJob;
  14. getRepeatJobKey<T = any, N extends string = string>(name: N, nextMillis: number, repeatJobKey: string, data: T): string;
  15. removeRepeatable(name: string, repeat: RepeatOptions, jobId?: string): Promise<number>;
  16. removeRepeatableByKey(repeatJobKey: string): Promise<number>;
  17. private getRepeatableData;
  18. private keyToData;
  19. getRepeatableJobs(start?: number, end?: number, asc?: boolean): Promise<RepeatableJob[]>;
  20. getRepeatableCount(): Promise<number>;
  21. private hash;
  22. private getRepeatDelayedJobId;
  23. private getRepeatJobId;
  24. }
  25. export declare const getNextMillis: (millis: number, opts: RepeatOptions) => number | undefined;