Body and etag, or `None` when the key does not exist.

Open (or replace) the connection for `scope`'s db file.

The database file path. Ported from `DB.Path` (db.go:275).

The current replication position (cached; recomputed from the max L0 file). Ported from `DB.Pos` (db.go:392-425). Wraps fs/decode failures in `LTXErr

Copies pending data from the WAL into the next L0 LTX file and applies the checkpoint policy. Ported from `DB.Sync` (db.go:994-1056). The public entr

Register an async op's future; returns its promise id. NOT spawned here — the region in `run_loop` owns spawning, so a task is never detached.

Create a JS promise for an async op `id` and return it to JS.

Restores a database from `client` into `output_path`, optionally up to a target `txid` (`TXID(0)` = most recent state). Ported from `Replica.Restore`

Opens a managed `Db` plus a *separate* writer connection over the same file (the analog of testingutil.MustOpenDBs: the app writes through its own con

Local path of a single LTX file. Ported from `DB.LTXPath` (db.go:338). `pub` so the [`crate::replica::Replica`] can read the local L0 LTX files the c

Overrides the owner identity (default `hostname:pid`).

Write one chunk and return whatever output it produced. Decoded output flows per chunk; encoders hold theirs until a full buffer accumulates (matching

Get-or-build the inner store, once.

Path to SQLite's WAL sidecar file (`<db>-wal`). Ported from `DB.WALPath` (db.go:287-289).

Decodes and fully verifies an in-memory LTX file: header, LZ4-framed pages, page index, trailer, the CRC64-ISO file checksum, and — for snapshots — th

Loads a WAL test vector from the **read-only** upstream Go testdata tree (`reference/litestream-go/testdata/wal-reader/<name>/wal`). These are the exa

Ported from `AcquireLease` (s3/leaser.go:90-136).

Creates a new [`LTXError`] with appropriate recovery hints based on the underlying error kind. Ported from `NewLTXError` in litestream@v0.5.11 litest

Reads the next frame into `data` and returns `(pgno, commit)`. Returns [`WalError::Eof`] at the end of the valid WAL (including on a salt or checksum

Performs a checkpoint on the WAL. Ported from `DB.Checkpoint`/`DB.checkpoint` (db.go:1801-1873, footgun F-9). Two-phase: copy the WAL tail, `exec_che

Encodes a complete LTX file from a header, an ordered set of pages, and the post-apply checksum. Mirrors encoder.go's layout; LZ4 framing uses lz4_fle

Every object under `prefix/`; the client paginates internally.