Enum ReducerInput 

pub enum ReducerInput {
    HostEvent {
        rollout_id: RolloutId,
        event: Event,
    },
    AgentAdvanceTick,
    ManifestSetUpdated(Box<SignedManifestSet>),
    BootstrapHost(Box<HostRolloutSnapshot>),
}

Reducer-task inputs.

• ReducerInput::HostEvent — workers synthesised a Local* event; reducer calls step() on the agent’s HostRolloutState for the given rollout_id, then runs the applier on the produced effects.
• ReducerInput::AgentAdvanceTick — periodic timer (mirror of CP’s PlanTick). Drives sustained-failure detection: when a Soaking host’s probe_failure_first_at exceeds the rollout’s policy threshold the reducer synthesises LocalSustainedFailureCrossed and feeds it through step().

Variants

HostEvent

Fields

rollout_id: RolloutId

event: Event

AgentAdvanceTick

ManifestSetUpdated(Box<SignedManifestSet>)

Refresh the reducer’s cached SignedManifestSet. Emitted by the longpoll worker (after verify_rollout_manifest succeeds)

• by the boot-recovery handshake (7f). The reducer needs a cached manifest to look up RolloutPolicy for step() and to resolve channel/target_closure when bootstrapping LocalActivate.

BootstrapHost(Box<HostRolloutSnapshot>)

LIFT #3: rehydrate the reducer’s in-memory HostRolloutState for an active rollout from a CP-supplied snapshot. Emitted only by runtime::spawn after the boot-recovery handshake returns snapshots, before any worker spawns. Directly assigns the state-machine cache from the snapshot fields, bypassing the transition machinery — the canonical source of truth lives on CP, the agent is just rebuilding its local view post-restart.