Struct WorkflowObserver 

pub struct WorkflowObserver { /* private fields */ }

Workflow-aware observer that focuses on correlation and performance tracking.

Designed for n8n-style workflow engines where understanding the relationship between service resolution and workflow execution is critical.

Examples

use ferrous_di::{ServiceCollection, WorkflowObserver, ObservationContext};
use std::sync::Arc;

let mut services = ServiceCollection::new();
services.add_observer(Arc::new(WorkflowObserver::new()));

let provider = services.build();
 
// When resolving with workflow context, correlation will be tracked

Implementations

impl WorkflowObserver

pub fn new() -> Self

Creates a new workflow observer.

pub fn with_name(name: impl Into<String>) -> Self

Creates a workflow observer with a custom name.

pub fn with_performance_tracking(self, enabled: bool) -> Self

Enables or disables performance tracking.

Trait Implementations

impl Default for WorkflowObserver

fn default() -> Self

Returns the “default value” for a type.

impl DiObserver for WorkflowObserver

fn resolving(&self, key: &Key)

Called when starting to resolve a service.

fn resolved(&self, key: &Key, duration: Duration)

Called when a service is successfully resolved.

fn factory_panic(&self, key: &Key, message: &str)

Called when a factory function panics during resolution.

fn resolving_with_context(&self, key: &Key, context: &ObservationContext)

Called when starting to resolve a service with workflow context.

fn resolved_with_context( &self, key: &Key, duration: Duration, context: &ObservationContext, )

Called when a service is successfully resolved with workflow context.

fn factory_panic_with_context( &self, key: &Key, message: &str, context: &ObservationContext, )

Called when a factory function panics during resolution with workflow context.