Struct WorkflowContext

pub struct WorkflowContext {
    pub workflow_id: WorkflowId,
    pub current_stage: StageId,
    pub state: HashMap<String, Vec<u8>>,
    pub metrics: WorkflowMetrics,
    pub stage_start: Instant,
}

Context provided to workflow actions during execution

Fields

workflow_id: WorkflowId

Workflow ID

current_stage: StageId

Current stage

state: HashMap<String, Vec<u8>>

Shared state between stages

metrics: WorkflowMetrics

Metrics collector

stage_start: Instant

Start time of current stage

Implementations

impl WorkflowContext

pub fn set_state(&mut self, key: String, value: Vec<u8>)

Store a value in the workflow state

pub fn get_state(&self, key: &str) -> Option<&Vec<u8>>

Retrieve a value from the workflow state

pub fn record_metric(&mut self, name: String, value: f64)

Record a custom metric

Trait Implementations

impl Debug for WorkflowContext

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

Formats the value using the given formatter.