run

nixfleet_agent::runtime::reducer

Function run 

Source 
pub async fn run(
    cancel: CancellationToken,
    cfg: AgentConfig,
    clock: ClockHandle,
    input_rx: Receiver<ReducerInput>,
    input_tx: Sender<ReducerInput>,
    activation_tx: ActivationIntentTx,
    probe_reset_tx: ProbeResetTx,
    outbound_queue: Arc<OutboundQueue>,
    outbound_kick: OutboundKickTx,
    shutdown_senders: Vec<Sender<()>>,
)