HyperdriveJobQueue

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:120

A job queue in a SQL table on D1 or another SQLite, Postgres (Hyperdrive) or MySQL.

With leaseMs, a processing job’s process_at holds its lease’s end, so the table needs no new column. dequeue() settles expired leases and takes the next job with statements that each settle or take a job only once: Postgres skips rows another dequeue() has locked, SQLite runs each statement under its write lock, and MySQL locks the rows it changes, which holds only when the client provides transaction(). Without onLeaseExpired, Postgres does both in one statement; with it, the callbacks run between the two, so they do not shorten the new lease.

A job already processing without a lease, taken by an earlier version or by a queue without leaseMs, cannot be told from one whose lease has expired, so it is due at once.

Type Parameters

T

T

Implements

JobQueue<T>

Constructors

Constructor

new HyperdriveJobQueue<T>(client, options?): HyperdriveJobQueue<T>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:128

Parameters

client

CloudflareSqlClient

options?

HyperdriveJobQueueOptions<T> = {}

Returns

HyperdriveJobQueue<T>

Methods

cleanupTerminal()

cleanupTerminal(options?): Promise<number>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:401

Removes finished jobs: completed and failed ones by default, or those with the given statuses, and with olderThan, only those that finished before it.

Parameters

options?

JobQueueCleanupOptions | JobStatus[]

Returns

Promise<number>

Implementation of

JobQueue.cleanupTerminal

clear()

clear(): Promise<void>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:391

Returns

Promise<void>

Implementation of

JobQueue.clear

close()

close(): Promise<void>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:442

Returns

Promise<void>

complete()

complete(jobId, _result?): Promise<void>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:245

Parameters

jobId

string

_result?

any

Returns

Promise<void>

Implementation of

JobQueue.complete

dequeue()

dequeue(options?): Promise<Job<T> | undefined>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:225

Takes the next due job and, with leaseMs, leases it. Jobs whose lease expired are due again first, or fail when they have no attempts left. Jobs in options.running are left as they are.

Parameters

options?

JobDequeueOptions = {}

Returns

Promise<Job<T> | undefined>

Implementation of

JobQueue.dequeue

enqueue()

enqueue(type, data, options?): Promise<Job<T>>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:159

Parameters

type

string

data

T

options?

{ delay?: number; maxAttempts?: number; metadata?: Record<string, any>; priority?: number; } | undefined

Returns

Promise<Job<T>>

Implementation of

JobQueue.enqueue

fail()

fail(jobId, error, retry?): Promise<void>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:264

Counts a failed attempt: the job is due again after retry.delayMs when retries are enabled and attempts are left, and fails otherwise. A completed job stays completed, even for a worker whose lease expired.

Parameters

jobId

string

error

string | Error

retry?

JobRetryDirective = ...

Returns

Promise<void>

Implementation of

JobQueue.fail

getJob()

getJob(jobId): Promise<Job<T> | undefined>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:361

Parameters

jobId

string

Returns

Promise<Job<T> | undefined>

Implementation of

JobQueue.getJob

init()

init(): Promise<void>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:141

Returns

Promise<void>

nextDueAt()

nextDueAt(): Promise<Date | undefined>

Defined in: packages/messaging/src/adapters/cloudflare/hyperdrive-job-queue.ts:347

When dequeue() next has work: the earliest due time of a pending job or, with leaseMs, lease expiry of a processing one. A time in the past means dequeue() has work now, even when it only settles an expired lease, so call dequeue() rather than checking size(). undefined when no job is pending or leased.