Tell a cell to abandon a fetch, by name. `fetch_cell`'s own cancellation needs someone still awaiting it, which is exactly what a dropped connection

Begins a long-running read transaction to prevent external checkpoints. Ported from `acquireReadLock` (db.go:956-976): `BEGIN` then `SELECT COUNT(1)

Take responsibility for the entry a restored alarm implies. Hibernation forgets the cell, so whichever process revives it holds no record of the entr

Runs `f` (a parser call on `input`) and converts a panic into a test failure that prints the offending bytes + seed for reproduction. The return value

Wait until no consume-delete for `cell` is on the wire. An arm-time PUT — and any new reconcile — sequences behind it; see `reconcile`.

Enter an alarm handler. Until the handler changes the alarm, `getAlarm()` observes null as required by the Durable Object contract.

Build the configured `AmazonS3` store. Ported from the relevant subset of `Init` (s3/replica_client.go:322-477): bucket validation, region default, cu

The (guarded setup script, backing-object expression) pair for a builtin specifier, or None if `spec` is not one. The setup materializes a lazy module

Returns the size of the WAL for a given page size & count, in i64 math to avoid u32 overflow with large page sizes. Ported from `calcWALSize` (db.go:1

Returns `true` if any error in the `source()` chain is an `Error` enum variant matching `kind`. This handles the case where an `Error` sentinel is wr

Returns `true` if any error in the `source()` chain is an `io::Error` with kind `ErrorKind::NotFound`.

TestDB_CheckpointDoesNotTriggerSnapshot (db_internal_test.go:877-984): a checkpoint followed by a write must NOT make verify() request a snapshot (iss

Drop `scope`'s connection (hibernate) so the replicator can release the file.

Closes the database, releasing the read lock first so other processes can checkpoint. Ported from the read-lock-release + connection-close portion of

Collects the full page set for a snapshot: every page `1..=commit` (skipping the lock page), reading from the WAL where present, else the DB file. Por

Apply celld's manifest-first precedence for the optional AI binding.

A PUT landed: the entry is now proven present. Called by the celld binary's async executor (`WakeFlusher`) after a successful S3 PUT — a separate crat

Open a WebSocket to `url`, sending `extra` alongside the handshake headers. The caller owns the timeout: nothing here bounds how long a server may ta

Returns a CRC-64/ISO checksum of the database file and its current position, after forcing a RESTART checkpoint so the DB sits at the WAL start. Porte

Runs `db_equal.sh <mode> <a> <b>`; Ok on exit 0, else the captured output.

The size of the main database file in bytes, 0 if absent.