Struct ObservableNodeWrapper 

pub struct ObservableNodeWrapper { /* private fields */ }

Wrapper that makes a node function observable

Implementations

impl ObservableNodeWrapper

pub fn new(name: impl Into<String>, run_type: RunType) -> Self

pub fn with_observer(self, observer: Arc<dyn Observer>) -> Self

pub async fn execute<F, Fut, I, O>(&self, inputs: I, f: F) -> Result<O>

where F: FnOnce(I) -> Fut, Fut: Future<Output = Result<O>>, I: Serialize, O: Serialize,

Execute a node function with tracing and observation