Enum ReducerInput 

pub enum ReducerInput {
    HostEvent {
        host: String,
        rollout_id: RolloutId,
        event: Event,
    },
    ManifestSetUpdated(Box<SignedManifestSet>),
    HeartbeatReceived {
        host: String,
        rollout_id: Option<RolloutId>,
        current_closure: Option<String>,
        at: DateTime<Utc>,
        reply: Sender<HeartbeatReply>,
    },
    PlanTick,
}

Reducer-task inputs. Workers and HTTP route handlers obtain a mpsc::Sender<ReducerInput> from the RuntimeHandle and emit values of this type. Variants partition by the reducer action they drive:

• ReducerInput::HostEvent — call step() on the CP-mirror per-host state for (host, rollout_id), run applier on resulting effects.
• ReducerInput::ManifestSetUpdated — refresh the cached SignedManifestSet and run plan_next().
• ReducerInput::HeartbeatReceived — touch last_heartbeat_at; if the agent’s current_closure disagrees with the CP mirror, the reply contains the last-known-seq for Replay-From (RFC-0005 §4.3).
• ReducerInput::PlanTick — safety-net periodic re-run of plan_next() in case a manifest update was missed by a poller crash.

Variants

HostEvent

Fields

host: String

rollout_id: RolloutId

event: Event

ManifestSetUpdated(Box<SignedManifestSet>)

HeartbeatReceived

Fields

host: String

rollout_id: Option<RolloutId>

current_closure: Option<String>

at: DateTime<Utc>

reply: Sender<HeartbeatReply>

PlanTick