Skip to main content

enqueue_relay_rows

mkit_server::relay

Function enqueue_relay_rows 

Source 
pub fn enqueue_relay_rows(
    os: &RelayEnqueueSnapshot,
    source: &Partition,
    rows: &[RelayV1],
    now_ms: u64,
) -> Result<Vec<Batch>, StoreError>
Expand description

Plan chained source batches. Each has a deadline, an os guard/put, one relay kick, optional source lease guard, and bounded row puts. The caller commits in order; after an os CAS loss it re-plans only the uncommitted suffix from a fresh snapshot.