Replicant.Transaction (Replicant v0.1.0)

A decoded, committed transaction: an ordered list of Replicant.Change rows plus the transaction-granularity commit LSN (every row in a pgoutput proto-v1 transaction shares one commit LSN — a per-row LSN would collapse an N-row transaction into one row).

A completed transaction's changes is ordinarily a List; for a SPILLED streamed transaction it is a lazy, single-pass, disk-backed Enumerable (Replicant.Spill.Reader) valid only during the delivery call. Iterate with Enum/Stream; do not retain it past handle_transaction/1.

Summary

Types

t()

Types

t()

@type t() :: %Replicant.Transaction{
  changes: Enumerable.t(),
  commit_lsn: Replicant.lsn() | nil,
  commit_timestamp: DateTime.t() | nil
}