Skip to main content

run_coordinator

Function run_coordinator 

Source
pub async fn run_coordinator(
    registry: TaskRegistry,
    rx: Receiver<CoordinatorMessage>,
    runtime: SharedRuntime,
    engine: StandardEngine,
)
Expand description

Run the coordinator loop