d1
Type Aliases
Section titled “Type Aliases”D1AdmissionSource
Section titled “D1AdmissionSource”D1AdmissionSource =
Readonly<{text:string;values: readonly (string|number|null)[]; }>
Trusted parameter-bound SELECT yielding queued job fields; never lifecycle fields.
D1Admission
Section titled “D1Admission”D1Admission =
Readonly<{enqueue: (job) =>D1PreparedStatement;enqueueFromSelect: (source) =>D1PreparedStatement; }>
D1 runtime with admission statements that join the producer’s native batch.
D1Watchdog
Section titled “D1Watchdog”D1Watchdog =
AsyncWatchdogRuntime&D1Admission
D1 lifecycle and native transaction admission.
D1PurgeStatement
Section titled “D1PurgeStatement”D1PurgeStatement =
Readonly<{text:string;values: readonly (string|number|null)[]; }>
Parameterized native purge; caller commits it with its own erasure facts.
AsyncWatchdogOptions
Section titled “AsyncWatchdogOptions”AsyncWatchdogOptions =
Readonly<{execute:WatchdogExecutor;wake:Readonly<{recompute: () =>Promise<void>>; }>;now?: () =>number; }>
Host execution and wake scheduling for a shared-database Watchdog.
AsyncWatchdogRuntime
Section titled “AsyncWatchdogRuntime”AsyncWatchdogRuntime =
Omit<WatchdogRuntime,"transactional">>
Shared-database runtime; native admission replaces the SQLite projection.
Variables
Section titled “Variables”watchdogD1Schema
Section titled “watchdogD1Schema”
constwatchdogD1Schema: readonlystring[]
Package-owned schema statements, to run through the deployment migration owner.
Functions
Section titled “Functions”createD1Watchdog()
Section titled “createD1Watchdog()”createD1Watchdog(
options):D1Watchdog
Open the shared Effect engine on a migrated D1 database; no implicit schema writes.
Parameters
Section titled “Parameters”options
Section titled “options”Readonly<{ execute: WatchdogExecutor;
wake: Readonly<{ recompute: () => Promise<void>; }>; now?: ()
=> number; }> & Readonly<{ database: D1Database; }>
Returns
Section titled “Returns”prepareD1Admission()
Section titled “prepareD1Admission()”prepareD1Admission(
database):D1Admission
Prepare native admission without constructing an executor or performing I/O.
Parameters
Section titled “Parameters”database
Section titled “database”D1Database
Returns
Section titled “Returns”purgeD1Queues()
Section titled “purgeD1Queues()”purgeD1Queues(
source): readonlyReadonly<{text:string;values: readonly (string|number|null)[]; }>[]
Purge every attempt in selected queues, fencing any executor still holding a claim. The trusted SELECT yields queue_name. It never supplies lifecycle mutations.
Parameters
Section titled “Parameters”source
Section titled “source”Returns
Section titled “Returns”readonly Readonly<{ text: string; values: readonly (string |
number | null)[]; }>[]