Struct ConditionEval

Source

pub struct ConditionEval<'a, S> {
    pub state: &'a S,
    pub values: &'a ValueStore,
    pub conditions: &'a ConditionMap<S>,
    pub source_skipped: bool,
    pub source_errored: bool,
}

Expand description

Evaluation context handed to conditions when a source node completes (or fails).

Conditions never mutate anything; they read the consumer state and the value store, plus two engine-computed flags describing how the source node’s execution went.

Fields§

§state: &'a S

The branch state produced by the source node’s execution (pre-merge).

§values: &'a ValueStore

The engine-owned value store, after the source’s outputs were written.

§conditions: &'a ConditionMap<S>

Named condition registry for Condition::Named resolution.

§source_skipped: bool

true when the source node’s execution was bypassed by BspSkip propagation or any value it produced carries the skip marker (dataflow profile).

§source_errored: bool

true when evaluation happens in the error context: the source node failed and its recovery policy routed the failure to error edges instead of aborting the run.

Auto Trait Implementations§

§

impl<'a, S> !RefUnwindSafe for ConditionEval<'a, S>

§

impl<'a, S> !UnwindSafe for ConditionEval<'a, S>

§

impl<'a, S> Freeze for ConditionEval<'a, S>
where &'a S: Freeze, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Freeze,

§

impl<'a, S> Send for ConditionEval<'a, S>
where &'a S: Send, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Send,

§

impl<'a, S> Sync for ConditionEval<'a, S>
where &'a S: Sync, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Sync,

§

ConditionEval

Struct ConditionEval Copy item path

Fields§

Auto Trait Implementations§

impl<'a, S> !RefUnwindSafe for ConditionEval<'a, S>

impl<'a, S> !UnwindSafe for ConditionEval<'a, S>

impl<'a, S> Freeze for ConditionEval<'a, S>where &'a S: Freeze, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Freeze,

impl<'a, S> Send for ConditionEval<'a, S>where &'a S: Send, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Send,

impl<'a, S> Sync for ConditionEval<'a, S>where &'a S: Sync, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Sync,

impl<'a, S> Unpin for ConditionEval<'a, S>where &'a S: Unpin, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Unpin,

impl<'a, S> UnsafeUnpin for ConditionEval<'a, S>where &'a S: UnsafeUnpin, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: UnsafeUnpin,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

fn in_current_span(self) -> Instrumented<Self> ⓘ

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, !>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘwhere S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Struct ConditionEval

impl<'a, S> Freeze for ConditionEval<'a, S>
where &'a S: Freeze, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Freeze,

impl<'a, S> Send for ConditionEval<'a, S>
where &'a S: Send, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Send,

impl<'a, S> Sync for ConditionEval<'a, S>
where &'a S: Sync, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Sync,

impl<'a, S> Unpin for ConditionEval<'a, S>
where &'a S: Unpin, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: Unpin,

impl<'a, S> UnsafeUnpin for ConditionEval<'a, S>
where &'a S: UnsafeUnpin, &'a HashMap<String, Arc<dyn Fn(&S, &ValueStore) -> bool + Send + Sync>>: UnsafeUnpin,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,