Struct ObservationContext 

pub struct ObservationContext {
    pub run_id: Option<String>,
    pub workflow_name: Option<String>,
    pub node_id: Option<String>,
    pub metadata: HashMap<String, String>,
}

Context information for correlated observation of workflow executions.

Provides run_id and workflow metadata for correlating DI events with n8n-style workflow execution traces.

Fields

run_id: Option<String>

Unique identifier for the current workflow run

workflow_name: Option<String>

Name of the workflow being executed

node_id: Option<String>

Current node/step being executed

metadata: HashMap<String, String>

Additional metadata for the execution context

Implementations

impl ObservationContext

pub fn new() -> Self

Creates a new empty observation context.

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

Creates an observation context with a run ID.

pub fn workflow( run_id: impl Into<String>, workflow_name: impl Into<String>, node_id: Option<impl Into<String>>, ) -> Self

Creates a full workflow context.

pub fn with_metadata( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Adds metadata to the context.

pub fn correlation_id(&self) -> String

Gets a correlation string for logging/tracing.

Trait Implementations

impl Clone for ObservationContext

fn clone(&self) -> ObservationContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ObservationContext

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

Formats the value using the given formatter.

impl Default for ObservationContext

fn default() -> Self

Returns the “default value” for a type.