Struct GraphTelemetry 

pub struct GraphTelemetry<const MAX_NODES: usize, const MAX_EDGES: usize, Sink: TelemetrySink> { /* private fields */ }

Fixed size telemetry collector backed by arrays.

This collector stores node and edge metrics in statically sized arrays and forwards structured events to a TelemetrySink. It is suitable for no_std environments where heap allocation is not available.

Implementations

impl<const MAX_NODES: usize, const MAX_EDGES: usize, Writer: TelemetrySink> GraphTelemetry<MAX_NODES, MAX_EDGES, Writer>

pub const fn new(id: u32, events: bool, writer: Writer) -> Self

Create a new fixed size collector with the given event writer.

All node and edge metrics are initialized to zero.

pub fn enable_events(&mut self)

Enable emission of structured telemetry events.

pub fn disable_events(&mut self)

Disable emission of structured telemetry events.

pub fn metrics(&self) -> &GraphMetrics<MAX_NODES, MAX_EDGES>

Access the underlying metrics record.

pub fn nodes(&self) -> &[NodeMetrics; MAX_NODES]

Access the full array of node metrics.

pub fn edges(&self) -> &[EdgeMetrics; MAX_EDGES]

Access the full array of edge metrics.

pub fn writer(&self) -> &Writer

Access the underlying event writer.

pub fn merge_from<const N2: usize, const E2: usize, W2: TelemetrySink>( &mut self, other: &GraphTelemetry<N2, E2, W2>, )

Merge metrics from another fixed size collector into this one.

Node metrics are combined by saturating addition and maximum for latency maxima, while edge queue depth uses a last writer wins strategy.

Trait Implementations

impl<const N: usize, const E: usize, W: TelemetrySink + Clone> Clone for GraphTelemetry<N, E, W>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<const N: usize, const E: usize, W: TelemetrySink> Telemetry for GraphTelemetry<N, E, W>

fn events_enabled(&self) -> bool

Return true if this telemetry collector wants structured events.

Runtimes and nodes can use this to avoid constructing TelemetryEvent values when events are disabled, keeping the hot path as cheap as possible.

const METRICS_ENABLED: bool = true

Compile-time flag indicating whether this telemetry implementation wants metrics (counters, gauges, latencies) at all.

const EVENTS_STATICALLY_ENABLED: bool = true

Compile-time flag indicating whether this telemetry implementation ever produces structured events.

fn incr_counter(&mut self, key: TelemetryKey, delta: u64)

Increment a counter metric identified by the given key.

fn set_gauge(&mut self, key: TelemetryKey, value: u64)

Set a gauge metric identified by the given key.

fn record_latency_ns(&mut self, key: TelemetryKey, value_ns: u64)

Record a latency sample in nanoseconds for the given key.

fn push_metrics(&mut self)

Optional: push a snapshot of aggregated metrics to the sink.

fn push_event(&mut self, event: TelemetryEvent)

Emit a structured telemetry event.

fn flush(&mut self)

Flush any buffered telemetry data to the underlying sink.