Struct Stage 

pub struct Stage {
    pub name: String,
    pub action: Actor,
    pub result_check: Check,
    pub fail_action: FailAction,
    pub ff_only: bool,
}

One stage: an untrusted action, an independent result_check that judges it, and what to do when the reading is Fail.

The split is the point. The action is whatever produces the work and is never trusted to grade itself; the check is a separate actor (or the action’s own exit, or a worker’s report) that decides. Every judgement a stage can carry is a configuration of this one shape rather than a policy of its own.

Fields

name: String

action: Actor

result_check: Check

fail_action: FailAction

ff_only: bool

The merge builtin’s fast-forward-only mode, written inside the action as { builtin: merge, ff_only: true }. It is refused on every other action, so a true here always describes a merge stage.

It rides on the stage rather than inside Actor, keeping Builtin::Merge’s unit wire shape: an absent key is simply the mode switched off, in the flow file and in the snapshot alike.

Trait Implementations

impl Clone for Stage

fn clone(&self) -> Stage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Stage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Stage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Stage

impl PartialEq for Stage

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Stage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Stage