Module v1

Enumerations

Classes

Interfaces

Type Aliases

Variables

Functions

Type Aliases

ActiveEventCallback3<T>: ((job, jobPromise?) => void)

Type Parameters

  • T = any

Type declaration

    • (job, jobPromise?): void
    • Parameters

      Returns void

BackoffFunction: ((attemptsMade?, err?, job?) => number)

Type declaration

    • (attemptsMade?, err?, job?): number
    • Parameters

      • Optional attemptsMade: number
      • Optional err: Error
      • Optional job: Job

      Returns number

BulkJobOptions: Omit<JobsOptions, "repeat">
CleanedEventCallback3<T>: ((jobs, status) => void)

Type Parameters

  • T = any

Type declaration

ClusterOptions: IORedis.ClusterOptions & BaseOptions
CompletedEventCallback3<T>: ((job, result) => void)

Type Parameters

  • T = any

Type declaration

    • (job, result): void
    • Parameters

      • job: Job<T>
      • result: any

      Returns void

ConnectionOptions: RedisOptions | ClusterOptions | IORedis.Redis | IORedis.Cluster
EntryId: string
EntryRaw: [EntryId, string[]]
ErrorEventCallback3: ((error) => void)

Type declaration

    • (error): void
    • Parameters

      • error: Error

      Returns void

EventCallback3: (() => void)

Type declaration

    • (): void
    • Returns void

FailedEventCallback3<T>: ((job, error) => void)

Type Parameters

  • T = any

Type declaration

    • (job, error): void
    • Parameters

      • job: Job<T>
      • error: Error

      Returns void

FinishedPropValAttribute: "returnvalue" | "failedReason"
FinishedStatus: "completed" | "failed"
FlowQueuesOpts: Record<string, Omit<QueueOptions, "connection" | "prefix">>
JobData: [JobJsonRaw | number, string?]
JobJsonSandbox: JobJson & {
    prefix: string;
    queueName: string;
}

Type declaration

  • prefix: string
  • queueName: string
JobState: FinishedStatus | "active" | "delayed" | "waiting" | "waiting-children"
JobStatusClean3: "completed" | "wait" | "active" | "delayed" | "paused" | "failed"
JobType: JobState | "paused" | "repeat" | "wait"
KeysMap: {
    [index in string]: string
}
MinimalQueue: Pick<QueueBase, "name" | "client" | "toKey" | "keys" | "opts" | "closing" | "waitUntilReady" | "removeListener" | "emit" | "on" | "redisVersion">
ParentOpts: {
    parentDependenciesKey?: string;
    parentKey?: string;
    waitChildrenKey?: string;
}

Type declaration

  • Optional parentDependenciesKey?: string
  • Optional parentKey?: string
  • Optional waitChildrenKey?: string
Processor<T, R, N>: ((job, token?) => Promise<R>)

Type Parameters

  • T = any
  • R = any
  • N extends string = string

Type declaration

    • (job, token?): Promise<R>
    • An async function that receives Jobs and handles them.

      Parameters

      • job: Job<T, R, N>
      • Optional token: string

      Returns Promise<R>

ProgressEventCallback3<T>: ((job, progress) => void)

Type Parameters

  • T = any

Type declaration

    • (job, progress): void
    • Parameters

      • job: Job<T>
      • progress: any

      Returns void

RedisClient: Redis | Cluster
RedisOptions: IORedis.RedisOptions & BaseOptions
RemovedEventCallback3<T>: ((job) => void)

Type Parameters

  • T = any

Type declaration

    • (job): void
    • Parameters

      Returns void

RepeatStrategy: ((millis, opts, name?) => number)

Type declaration

    • (millis, opts, name?): number
    • Parameters

      Returns number

SandboxedJobProcessor<T, R>: ((job) => R | PromiseLike<R>) | ((job, callback) => void)

Type Parameters

  • T = any
  • R = any

Type declaration

    • (job): R | PromiseLike<R>
    • Parameters

      Returns R | PromiseLike<R>

Type declaration

    • (job, callback): void
    • Parameters

      • job: SandboxedJob<T, R>
      • callback: ((error, result) => void)
          • (error, result): void
          • Parameters

            • error: unknown
            • result: R

            Returns void

      Returns void

StalledEventCallback3<T>: ((job) => void)

Type Parameters

  • T = any

Type declaration

    • (job): void
    • Parameters

      Returns void

StreamName: string
StreamReadRaw: [StreamName, EntryRaw[]][]
WaitingEventCallback3: ((jobId) => void)

Type declaration

    • (jobId): void
    • Parameters

      • jobId: string

      Returns void

Generated using TypeDoc