Struct WorkflowContext 

pub struct WorkflowContext { /* private fields */ }

Standard workflow context for n8n-style execution engines.

Provides common workflow execution metadata that most workflow engines need. This is a convenience struct that workflow engines can use directly or extend.

Examples

use ferrous_di::{ServiceCollection, ScopeLocal, WorkflowContext, Resolver};
use std::sync::Arc;

let mut services = ServiceCollection::new();
 
services.add_scope_local::<WorkflowContext, _>(|_resolver| {
    Arc::new(WorkflowContext::new("user_onboarding"))
});

services.add_scoped_factory::<String, _>(|resolver| {
    let ctx = resolver.get_required::<ScopeLocal<WorkflowContext>>();
    format!("Executing step in workflow '{}' (run: {})", 
        ctx.workflow_name(), 
        ctx.run_id())
});

let provider = services.build();
let scope = provider.create_scope();
let status = scope.get_required::<String>();

Implementations

impl WorkflowContext

pub fn new(workflow_name: impl Into<String>) -> Self

Creates a new workflow context with an auto-generated run ID.

pub fn with_run_id( workflow_name: impl Into<String>, run_id: impl Into<String>, ) -> Self

Creates a new workflow context with a specific run ID.

pub fn run_id(&self) -> &str

Gets the run ID for this workflow execution.

pub fn workflow_name(&self) -> &str

Gets the workflow name.

pub fn elapsed(&self) -> Duration

Gets the elapsed time since this workflow execution started.

pub fn started_at(&self) -> Instant

Gets the start time for this workflow execution.

pub fn add_metadata(&mut self, key: impl Into<String>, value: impl Into<String>)

Adds metadata to the workflow context.

pub fn get_metadata(&self, key: &str) -> Option<&String>

Gets metadata from the workflow context.

pub fn metadata(&self) -> &HashMap<String, String>

Gets all metadata for the workflow context.

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 Debug for WorkflowContext

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

Formats the value using the given formatter.

impl Default for WorkflowContext

fn default() -> Self

Returns the “default value” for a type.

impl WorkflowContextProvider for WorkflowContext

Helper for integrating with ScopeLocal workflow contexts.

fn observation_context(&self) -> ObservationContext

Extracts observation context from the workflow state.