@cfxdevkit/executor / RetryQueue

Class: RetryQueue

Defined in: packages/executor/src/retry-queue.ts:11

RetryQueue – wraps jobs for retry-with-exponential-backoff scheduling.

Backoff formula: delay = min(base × 2^attempt, maxDelay) × (1 + jitter × rand)

Constructors

Constructor

new RetryQueue(options?, logger?): RetryQueue

Defined in: packages/executor/src/retry-queue.ts:21

Parameters

options?

baseDelayMs?

number

jitter?

number

maxDelayMs?

number

logger?

AutomationLogger = noopLogger

Returns

RetryQueue

Methods

drainDue()

drainDue(now?): Job[]

Defined in: packages/executor/src/retry-queue.ts:54

Return all jobs whose retry time has arrived; removes them from the queue.

Parameters

now?

number = ...

Returns

Job[]

enqueue()

enqueue(job): void

Defined in: packages/executor/src/retry-queue.ts:36

Enqueue a job for retry after a calculated backoff delay.

Parameters

job

Job

Returns

void

remove()

remove(jobId): void

Defined in: packages/executor/src/retry-queue.ts:49

Remove a job from the queue (e.g. after success or manual cancel).

Parameters

jobId

string

Returns

void

size()

size(): number

Defined in: packages/executor/src/retry-queue.ts:65

Returns

number