Move `bytes` into a `Uint8Array` without copying.

The next step to perform, or `None` when the batch is finished. Deletes the core has since cancelled are dropped here rather than handed out, so an e

Parses an RFC-3339 timestamp (the trailing zone designator may be `Z` for UTC, or a numeric offset `±HH:MM`) with optional fractional seconds, back in

Builds a snapshot LTX file (MinTXID==1, tracked checksum) covering pages `1..=commit`, each page filled with a per-page byte. The lock page is skipped

Returns a mutable reference to the attached database, if any. Lets a caller drive `db.sync()` (the local capture half) before `replica.sync()` (the up

Returns the lock page number for a given page size (ltx.go:494). `page_size` is expected to be a validated SQLite page size (a power of two in `[512,

Publish committed alarm state to the watcher. Returns the committed value (`-1` for none) when publication happened, `None` when the mutation is still

Conditional write. `etag: None` requires the key to be absent (If-None-Match: *); `Some` requires the current etag (If-Match). `Ok(Some(new_etag))` ap

A fleet-wide immutable asset body key. The digest is validated before this is called by the receiver and again by the applying node.

Merges the LTX `files` (a snapshot followed by incrementals, in plan order) and reconstructs the full SQLite database image. This replaces Go's `ltx.

The transition: `was_shedding` is the only carried state — the latch that keeps shedding between the high crossing and the low release.

Borrows the inner [`LeaseExistsError`] if this error is one. The analogue of Go's `errors.As(err, &leaseErr)` (s3/leaser.go:117, 154).

Builds a real replicated database: a `t(id,v)` table with several transactions, each captured + uploaded through the file client. Captures a point-in-

Builds a single-page incremental LTX file (`NoChecksum`), mirroring the Go `mustBuildIncrementalLTX` helper (replica_internal_test.go:285-315): one pa

CRC64 checksum of a single page combined with its page number, with the ChecksumFlag set (checksum.go:106-116). Input is `BE_u32(pgno) ++ data`.

Runs `db_equal.sh <mode> <a> <b>`; `Ok(())` on exit 0, else the captured stdout+stderr so a failure pinpoints the mismatch. Requires `sqlite3`. `mode

Idempotent: deleting an absent key succeeds, as S3's DELETE does.