Skip to main content

run_coordinator

espresso_node::consensus_handle

Function run_coordinator

async fn run_coordinator<T, S>(
    coord: Coordinator<T, S>,
    tx: Sender<CoordinatorEvent<T>>,
    queue_len: Option<Arc<dyn Gauge>>,
    seed: Option<PreCutoverSeed<T>>,
    shutdown: CancellationToken,
)where
    T: NodeType,
    S: NewProtocolStorage<T>,