Struct NodeCtx 

pub struct NodeCtx { /* private fields */ }

Per-node bundle of metric attributes and instrument handles.

Constructed once per node by spawn_pipeline (or by tests). The hot-path code in BasicTransform / ManagedSink stores the NodeCtx alongside its other state and calls processed_add(1) without hashmap lookups.

Implementations

impl NodeCtx

pub fn for_node( pipeline: &str, node_id: &str, node_kind: NodeKind, handle: ObsHandle, ) -> Self

Build a NodeCtx for a single node. The attribute set is pipeline, node_id, node_kind — kept tight on purpose to avoid cardinality blow-ups (no meta.key, no payload labels).

pub fn noop() -> Self

No-op context with empty attributes, backed by a private no-op meter. Used by tests that build pipelines manually and by the default state of BasicTransform / ManagedSink until spawn_pipeline attaches a real ctx.

pub fn attrs(&self) -> &[KeyValue]

pub fn handle(&self) -> &ObsHandle

pub fn pipeline(&self) -> &str

pub fn node_id(&self) -> &str

pub fn node_kind(&self) -> NodeKind

pub fn node_kind_str(&self) -> &'static str

pub fn log_keys(&self) -> bool

pub fn record_processed(&self)

pub fn record_filtered(&self)

pub fn record_failed(&self)

pub fn record_retry(&self)

pub fn record_dead_letter(&self)

pub fn record_stage_duration_ms(&self, ms: f64)

pub fn record_end_to_end_latency_ms(&self, ms: f64)

pub fn record_channel_capacity_used(&self, used: u64)

Trait Implementations

impl Clone for NodeCtx

fn clone(&self) -> NodeCtx

Returns a duplicate of the value.

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

Performs copy-assignment from source.