Struct EdgeSnapshotTelemetry 

#[non_exhaustive]
pub struct EdgeSnapshotTelemetry { /* private fields */ }

Structured snapshot describing the state of a single edge.

These snapshots are typically taken by runtimes when they want to record backpressure or queue depth for a link between nodes.

Implementations

impl EdgeSnapshotTelemetry

pub const fn new( graph_id: GraphInstanceId, edge_index: EdgeIndex, source_node_index: NodeIndex, target_node_index: NodeIndex, timestamp_ns: u64, current_occupancy: u32, soft_watermark: u32, hard_watermark: u32, watermark_state: WatermarkState, ) -> Self

Creates a new snapshot record for a single edge.

pub const fn graph_id(&self) -> &GraphInstanceId

Returns the identifier of the graph instance this edge belongs to.

pub const fn edge_index(&self) -> &EdgeIndex

Returns the index of the edge within the graph.

pub const fn source_node_index(&self) -> &NodeIndex

Returns the index of the source node for this edge.

pub const fn target_node_index(&self) -> &NodeIndex

Returns the index of the target node for this edge.

pub const fn timestamp_ns(&self) -> &u64

Returns the snapshot timestamp in nanoseconds since an arbitrary epoch.

pub const fn current_occupancy(&self) -> &u32

Returns the current occupancy of the edge buffer.

pub const fn soft_watermark(&self) -> &u32

Returns the configured soft watermark for this edge.

pub const fn hard_watermark(&self) -> &u32

Returns the configured hard watermark for this edge.

pub const fn watermark_state(&self) -> &WatermarkState

Returns the current watermark state relative to the configured thresholds.

Trait Implementations

impl Clone for EdgeSnapshotTelemetry

fn clone(&self) -> EdgeSnapshotTelemetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EdgeSnapshotTelemetry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Copy for EdgeSnapshotTelemetry