Struct WorkflowContext 

pub struct WorkflowContext { /* private fields */ }

Shared state accessible to all workflow nodes during execution.

Nodes read and write values to this shared map to pass data between pipeline stages.

Implementations

impl WorkflowContext

pub fn new() -> Self

Create a new empty context.

pub async fn set(&self, key: impl Into<String>, value: Value)

Set a value in the shared state.

pub async fn get(&self, key: &str) -> Option<Value>

Get a value from the shared state.

pub async fn remove(&self, key: &str) -> Option<Value>

Remove a value from the shared state.

pub async fn node_result(&self, node_name: &str) -> Option<Value>

Get the result of a previously completed node.

pub async fn all_results(&self) -> HashMap<String, Value>

Get all results as a map.

Trait Implementations

impl Clone for WorkflowContext

fn clone(&self) -> WorkflowContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for WorkflowContext

fn default() -> Self

Returns the “default value” for a type.