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§
Sourcefn record_step_completed(&self, connector: &str, duration_secs: f64)
fn record_step_completed(&self, connector: &str, duration_secs: f64)
Record a successful step completion with connector name and duration.
Sourcefn record_step_failed(&self, connector: &str)
fn record_step_failed(&self, connector: &str)
Record a step failure with connector name.
Sourcefn record_connector_invocation(&self, connector: &str)
fn record_connector_invocation(&self, connector: &str)
Record a connector invocation (before execution).
Sourcefn record_contextstore_write(&self)
fn record_contextstore_write(&self)
Record a ContextStore write operation.
Sourcefn record_flow_completed(&self)
fn record_flow_completed(&self)
Record a flow run completing successfully.
Sourcefn record_flow_failed(&self)
fn record_flow_failed(&self)
Record a flow run failing.