Enum RolloutEffect 

pub enum RolloutEffect {
    RecordRolloutTransition {
        rollout_id: RolloutId,
        from: RolloutState,
        to: RolloutState,
        at: DateTime<Utc>,
    },
    UpdateCurrentWave {
        rollout_id: RolloutId,
        wave: u32,
    },
    InsertQuarantineFromRollout {
        channel: ChannelId,
        closure_hash: ClosureHash,
    },
    SchedulePruning {
        rollout_id: RolloutId,
        delay_seconds: i64,
    },
}

Variants

RecordRolloutTransition

Persist a rollout-level state transition. Drives the rollouts.state column update; the applier co-writes the corresponding event_log row (kind = 'rollout_event').

Fields

rollout_id: RolloutId

from: RolloutState

to: RolloutState

at: DateTime<Utc>

UpdateCurrentWave

Monotonic wave-index advance on the rollouts.current_wave column.

Fields

rollout_id: RolloutId

wave: u32

InsertQuarantineFromRollout

A rollback completed; insert a row into quarantined_closures referencing the triggering event_log seq (NULL-able under v0.2.1 baseline; RFC-0008 §6.1 item 3).

Fields

channel: ChannelId

closure_hash: ClosureHash

SchedulePruning

A rollout entered a terminal-set state (Terminal | Superseded | Failed | Reverted); schedule its retention-expiry event for the configured delay. The applier queues a delayed RetentionExpired re-entry into the reducer.

Fields

rollout_id: RolloutId

delay_seconds: i64

Implementations

impl RolloutEffect

pub fn kind(&self) -> &'static str

Trait Implementations

impl Clone for RolloutEffect

fn clone(&self) -> RolloutEffect

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RolloutEffect

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RolloutEffect

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for RolloutEffect

fn eq(&self, other: &RolloutEffect) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for RolloutEffect

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for RolloutEffect

impl StructuralPartialEq for RolloutEffect