run

nixfleet_control_plane::runtime::reducer

Function run 

Source 
pub(super) async fn run(
    cancel: CancellationToken,
    state: Arc<AppState>,
    clock: ClockHandle,
    input_rx: Receiver<ReducerInput>,
    event_log_tx: EventLogTx,
    shutdown_senders: Vec<Sender<()>>,
)