Expand description
[ArrayAckSender] — periodic ack sender from Lite to Origin.
A Tokio task (spawned on sync-session start, shut down on disconnect)
that runs every interval seconds and sends ArrayAckMsg for each known
array to Origin. Origin merges these into its ArrayAckRegistry to advance
the GC frontier.
§What gets acked
For each registered array the ack carries last_applied_hlc — the highest
HLC successfully applied by LiteApplyEngine. This is the correct value
because it represents “I have all ops up to this HLC” from Origin’s
perspective.
§Transport
Frames are sent via a tokio::sync::mpsc::Sender<Vec<u8>> that the
session’s WebSocket write loop drains. This matches the pattern used by
other Lite sync subsystems.
Constants§
- DEFAULT_
ACK_ INTERVAL - Default ack interval: 30 seconds.
Functions§
- spawn
- Periodic array ack sender task.