Enum CancelFlowHeader 

#[non_exhaustive]
pub enum CancelFlowHeader {
    Cancelled {
        cancellation_policy: String,
        member_execution_ids: Vec<String>,
    },
    AlreadyTerminal {
        stored_cancellation_policy: Option<String>,
        stored_cancel_reason: Option<String>,
        member_execution_ids: Vec<String>,
    },
}

RFC-017 Stage E2: result of the “header” portion of a cancel_flow operation — the atomic flow-state flip + member enumeration.

The Server composes this with its own wait/async member-dispatch machinery to build the wire-level CancelFlowResult. Backends implement crate::engine_backend::EngineBackend::cancel_flow_header (default: Unavailable) so the Valkey-native ff_cancel_flow FCALL (with its flow_already_terminal idempotency branch) can be driven through the trait without re-shaping the existing public cancel_flow(id, policy, wait) signature.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Cancelled

Flow-state flipped this call. member_execution_ids is the full (uncapped) membership at flip time.

Fields

cancellation_policy: String

member_execution_ids: Vec<String>

AlreadyTerminal

Flow was already in a terminal state on entry. The backend has surfaced the stored cancellation_policy, cancel_reason, and full membership so the Server can return an idempotent CancelFlowResult::Cancelled without re-doing the flip.

Fields

stored_cancellation_policy: Option<String>

None only for flows cancelled by pre-E2 Lua that never persisted the policy field.

stored_cancel_reason: Option<String>

None when the flow was never cancel-reason-stamped.

member_execution_ids: Vec<String>

Full membership. Server caps to ALREADY_TERMINAL_MEMBER_CAP before wiring.

Trait Implementations

impl Clone for CancelFlowHeader

fn clone(&self) -> CancelFlowHeader

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CancelFlowHeader

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

Formats the value using the given formatter.

impl PartialEq for CancelFlowHeader

fn eq(&self, other: &CancelFlowHeader) -> 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 Eq for CancelFlowHeader

impl StructuralPartialEq for CancelFlowHeader