Skip to main content

Module outbound

nodedb_lite::sync::array

Module outbound 

Source
Expand description

High-level emitter for array CRDT ops on the send path.

ArrayOutbound is called by the array engine hooks after each local mutation succeeds. It:

  1. Looks up the current schema_hlc from the SchemaRegistry.
  2. Mints a fresh HLC via ReplicaState::next_hlc.
  3. Builds the ArrayOp.
  4. Appends to the durable KvOpLogStore (permanent record for GC).
  5. Enqueues in the durable PendingQueue, which the sync push loop drains to Origin.

The caller must ensure the local engine write has already succeeded before calling ArrayOutbound methods. If emit fails after a successful engine write, the error is returned to the caller and the write is not rolled back. The cell stays local and never reaches Origin.

Structs§

ArrayOutbound
Emitter for locally-originated array CRDT ops.