Skip to main content

MetricsRecorder

Trait MetricsRecorder 

Source
pub trait MetricsRecorder: Send + Sync {
    // Required methods
    fn record_step_completed(&self, connector: &str, duration_secs: f64);
    fn record_step_failed(&self, connector: &str);
    fn record_connector_invocation(&self, connector: &str);
    fn record_contextstore_write(&self);
    fn record_flow_completed(&self);
    fn record_flow_failed(&self);
}
Expand description

Trait for recording observability metrics across UI crates.

Implemented by the daemon’s Prometheus registry. When no metrics are configured, NoopMetricsRecorder is used.

Required Methods§

Source

fn record_step_completed(&self, connector: &str, duration_secs: f64)

Record a successful step completion with connector name and duration.

Source

fn record_step_failed(&self, connector: &str)

Record a step failure with connector name.

Source

fn record_connector_invocation(&self, connector: &str)

Record a connector invocation (before execution).

Source

fn record_contextstore_write(&self)

Record a ContextStore write operation.

Source

fn record_flow_completed(&self)

Record a flow run completing successfully.

Source

fn record_flow_failed(&self)

Record a flow run failing.

Implementors§