pub async fn commit_relay_rows<S: NamespaceStore>(
store: &S,
source: &Partition,
rows: &[RelayV1],
now_ms: u64,
deadline_ms: u64,
source_lease: Option<&Value>,
) -> Result<(), StoreError>Expand description
Commit a relay-row chain, re-reading os and re-planning the remaining
rows when another writer wins. The caller supplies its current source
lease and deadline; a stale lease fails closed.