DatabaseCaptureQueueOptions

Defined in: packages/core/src/capture/db-queue/types.ts:16

Options of createDatabaseCaptureQueue.

Properties

kinds?

optional kinds?: readonly CaptureJobKind[]

Defined in: packages/core/src/capture/db-queue/types.ts:18

Job kinds this instance polls (default ["capture"]); enqueue accepts every kind.

---

leaseMs?

optional leaseMs?: number

Defined in: packages/core/src/capture/db-queue/types.ts:20

Lease granted per attempt, renewed by a heartbeat and by progress (default DEFAULT_LEASE_MS, 5 min; testing.leaseSeconds).

---

logger?

optional logger?: Logger

Defined in: packages/core/src/capture/db-queue/types.ts:30

Explicit logger override; the host normally binds one through setLogger.

---

now?

optional now?: () => number

Defined in: packages/core/src/capture/db-queue/types.ts:26

Clock in epoch ms (default Date.now); tests inject one to drive leases and visibility.

Returns

number

---

onExhausted?

optional onExhausted?: (job, error) => Promise<void>

Defined in: packages/core/src/capture/db-queue/types.ts:36

Called after a job failed because its last attempt lost its lease: nothing was running to record the failure, so the host writes it (a build left capturing). May run on every instance that finds the job, so it must be idempotent; a throw is logged and ignored.

Parameters

job

DatabaseJob

error

string

Returns

Promise<void>

---

owner?

optional owner?: string

Defined in: packages/core/src/capture/db-queue/types.ts:24

Identity written on the attempt rows this instance holds (default host, pid and a random tag).

---

retries?

optional retries?: number

Defined in: packages/core/src/capture/db-queue/types.ts:22

Retries after the first attempt (testing.retries, default 2: three attempts in total).

---

timers?

optional timers?: QueueTimers

Defined in: packages/core/src/capture/db-queue/types.ts:28

Timers of the local wake wait (default the global timers); tests inject a manual clock.