Skip to main content

wait_for_integration_diff_conditional

Function wait_for_integration_diff_conditional 

Source
pub async fn wait_for_integration_diff_conditional(
    cells: &[(&AgentPubKey, &DhtStoreRead, Option<&DhtStoreRead>)],
    timeout: Duration,
    conditions: ConsistencyConditions,
) -> ConsistencyResult
Expand description

Wait for all cell envs to reach consistency, meaning that every op published by every cell has been integrated by every node.

Each cell is (author, authored_store, online_dht_store). The published set is read from each cell’s own DHT store (self-authored ops), and the integrated set from each online cell’s DHT store. Cells with None for the DHT store are treated as offline: their published ops still count towards the total, but their integration is not checked.