Struct Command 

pub struct Command {
    pub updates: Vec<StateUpdate>,
    pub control: ControlFlow,
}

Command returned by node functions

A Command encapsulates both state updates and control flow decisions. This allows nodes to update state AND determine where to go next in a single return value.

Example

// Update state and continue to next node
let cmd = Command::new()
    .update("result", json!("processed"))
    .continue_();

// Update state and jump to specific node
let cmd = Command::new()
    .update("classification", json!("type_a"))
.goto("handle_a");

// End execution with final state
let cmd = Command::new()
    .update("final_result", json!("done"))
    .return_();

// Create parallel branches for MapReduce
let cmd = Command::send(vec![
    SendCommand::new("process", json!({"item": 1})),
    SendCommand::new("process", json!({"item": 2})),
]);

Fields

updates: Vec<StateUpdate>

State updates to apply

control: ControlFlow

Control flow directive

Implementations

impl Command

pub fn new() -> Command

Create a new empty command

pub fn update(self, key: impl Into<String>, value: Value) -> Command

Add a state update

pub fn updates(self, updates: Vec<StateUpdate>) -> Command

Add multiple state updates

pub fn continue_(self) -> Command

Set control flow to continue to next node

pub fn goto(self, node: impl Into<String>) -> Command

Set control flow to jump to a specific node

pub fn return_(self) -> Command

Set control flow to end execution

pub fn send(targets: Vec<SendCommand>) -> Command

Set control flow to create parallel branches (MapReduce)

pub fn just_update(key: impl Into<String>, value: Value) -> Command

Create a command that just updates state (continues by default)

pub fn just_goto(node: impl Into<String>) -> Command

Create a command that just controls flow (no state update)

pub fn just_return() -> Command

Create a command that ends execution

pub fn is_return(&self) -> bool

Check if this command ends execution

pub fn is_send(&self) -> bool

Check if this command creates parallel branches

pub fn goto_target(&self) -> Option<&str>

Get the target node if this is a goto command

Trait Implementations

impl Clone for Command

fn clone(&self) -> Command

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Command

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

Formats the value using the given formatter.

impl Default for Command

fn default() -> Command

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Command

fn deserialize<__D>( __deserializer: __D, ) -> Result<Command, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Command

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

where __S: Serializer,

Serialize this value into the given Serde serializer.