Enum SignalStepResolution 

pub enum SignalStepResolution {
    Resolved {
        run_id: Uuid,
        run_resumed: bool,
    },
    NotWaiting {
        output: Option<Value>,
    },
}

Outcome of SignalStore::resolve_signal_step.

Examples

use ironflow_store::entities::SignalStepResolution;
use uuid::Uuid;

let resolution = SignalStepResolution::Resolved {
    run_id: Uuid::now_v7(),
    run_resumed: true,
};
let json = serde_json::to_value(&resolution)?;
assert_eq!(json["outcome"], "resolved");

Variants

Resolved

The step was waiting and is now completed with the given output.

Fields

run_id: Uuid

Run owning the step.

run_resumed: bool

true when the run was Sleeping and went back to Pending. false when the run was still executing (it will see the step completed on its own).

NotWaiting

The step was no longer waiting: another delivery or a timeout won.

Fields

output: Option<Value>

Output recorded by whoever resolved the step first.

Trait Implementations

impl Clone for SignalStepResolution

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SignalStepResolution

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SignalStepResolution

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for SignalStepResolution

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for SignalStepResolution

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 SignalStepResolution