Struct FanoutPlan 

pub struct FanoutPlan {
    pub target: Target,
    pub rollout: Option<Rollout>,
    pub jitter: Option<String>,
    pub deadline_at: Option<DateTime<Utc>>,
}

“Who + how + when-to-stagger” — the fanout-plan side of an exec. Used both as the POST /api/exec/{job_id} body and as the embedded target / rollout / jitter slot on Schedule. Centralising here keeps the validation + serialisation logic in one place.

Fields

target: Target

rollout: Option<Rollout>

Optional wave rollout — when present, the backend publishes each wave’s group subject on its own delay schedule instead of fanning out the target block in one go. target then only labels the deploy for the audit log.

jitter: Option<String>

Optional humantime jitter; agent uses it to randomise execution start. Lives here (not on the script) so different schedules / ad-hoc fires of the same job can pick different stagger windows.

deadline_at: Option<DateTime<Utc>>

Absolute time the scheduler stamps on each emitted Command when this exec was driven by a Schedule with starting_deadline. Agents receiving a Command after this instant publish a synthetic skipped-result instead of running the script. None (default) = no deadline / catch up whenever delivered. Operators don’t usually set this directly — the scheduler computes it from tick_at + starting_deadline.

Trait Implementations

impl Clone for FanoutPlan

fn clone(&self) -> FanoutPlan

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FanoutPlan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for FanoutPlan

fn default() -> FanoutPlan

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FanoutPlan

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FanoutPlan

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.