Replicant.Spill.Reader (Replicant v0.1.0)

A lazy, SINGLE-PASS Enumerable over a spilled transaction's changes (spec §5): it streams the on-disk frames (in commit order) followed by the still-resident in-memory tail, rejects any change whose subxid is in the aborted set, and stamps commit_lsn + an ascending ordinal at replay (streamed changes have no LSN before commit). It is value-free BY CONSTRUCTION — a File read or binary_to_term fault raises Replicant.Spill.Error (fixed reason, no bytes), never a raw-byte exception, even though the sink forces this enumeration inside its own DB transaction (spec §11).

Delivered as %Transaction{changes: reader} for a spilled transaction; the sink MUST consume it within the delivery call (single-pass; reading a deleted file raises Spill.Error, fail-loud).

Summary

Types

t()

Functions

new(path, tail, aborted, commit_lsn)

Build a Reader over spilled file path + the in-memory tail (stored newest-first, reversed to commit order here), filtering aborted subxids, stamping commit_lsn.

Types

t()

@type t() :: %Replicant.Spill.Reader{
  aborted: MapSet.t(non_neg_integer()),
  commit_lsn: Replicant.lsn(),
  path: String.t(),
  tail: [{non_neg_integer(), Replicant.Change.t()}]
}

Functions

new(path, tail, aborted, commit_lsn)

@spec new(
  String.t(),
  [{non_neg_integer(), Replicant.Change.t()}],
  MapSet.t(),
  Replicant.lsn()
) :: t()

Build a Reader over spilled file path + the in-memory tail (stored newest-first, reversed to commit order here), filtering aborted subxids, stamping commit_lsn.