Struct CatchupTracker 

pub struct CatchupTracker<S: StorageEngine> { /* private fields */ }

Tracks the last successfully applied inbound HLC per array.

Used by the transport layer to populate catchup-request messages after reconnect or when Origin’s log GC horizon advances past the local log.

Thread-safe via an internal Mutex.

Implementations

impl<S: StorageEngine> CatchupTracker<S>

pub async fn load(storage: Arc<S>) -> Result<Self, LiteError>

Load all persisted last_seen_hlc entries from Namespace::Meta.

Scans keys starting with b"array.last_seen_hlc:" and parses each 18-byte value as an Hlc. Returns an empty tracker if no entries are stored yet (first run or after a full wipe).

pub async fn record(&self, array: &str, hlc: Hlc) -> Result<(), LiteError>

Record that hlc has been successfully applied for array.

Updates both the in-memory map and the durable storage entry. Only persists if hlc is strictly greater than the current last-seen value (monotonic advancement).

pub fn last_seen(&self, array: &str) -> Hlc

Return the last-seen HLC for array, or Hlc::ZERO if unknown.

Hlc::ZERO in a catchup request tells Origin to replay all history for the array from the beginning.

pub fn build_request(&self, array: &str) -> ArrayCatchupRequestMsg

Build an ArrayCatchupRequestMsg for array.

The request starts at the stored last-seen HLC. An array flagged by a RetentionFloor reject starts at Hlc::ZERO instead: that HLC is below Origin’s GC boundary, so Origin answers with a snapshot followed by the op stream above it.

pub fn is_catchup_needed(&self, array: &str) -> bool

Returns true if a RetentionFloor reject flagged array and no snapshot has completed since.

pub fn should_request_catchup( &self, array: &str, _current_local_hlc: Hlc, ) -> bool

Returns true if array should request a full catch-up on connect.

True when:

• No last_seen_hlc is recorded (first connect), OR
• record_reject_retention_floor was called (Origin GC advanced past our log).

pub async fn record_reject_retention_floor( &self, array: &str, ) -> Result<(), LiteError>

Mark array as needing a full catch-up on the next connect.

Called when Origin sends ArrayRejectMsg::RetentionFloor. Persisted under Namespace::Meta "array.catchup_needed:{array}".

pub async fn clear_catchup_needed(&self, array: &str) -> Result<(), LiteError>

Clear the catchup-needed flag for array after a successful catch-up.

Called after the snapshot stream has been fully applied.

pub fn arrays_needing_catchup(&self) -> Vec<String>

Return all arrays that are marked as needing catch-up.