Struct TelemetryBuffer 

#[repr(C, align(64))]
pub struct TelemetryBuffer {
    pub messages_processed: u64,
    pub messages_dropped: u64,
    pub total_latency_us: u64,
    pub min_latency_us: u64,
    pub max_latency_us: u64,
    pub input_queue_depth: u32,
    pub output_queue_depth: u32,
    pub last_error: u32,
    pub _reserved: [u32; 3],
}

Telemetry buffer (64 bytes, cache-line aligned).

This structure is updated by the GPU kernel and read by the host for monitoring and debugging purposes.

Fields

messages_processed: u64

Total messages processed successfully.

messages_dropped: u64

Total messages dropped (queue full, timeout, etc.).

total_latency_us: u64

Sum of processing latencies in microseconds.

min_latency_us: u64

Minimum processing latency in microseconds.

max_latency_us: u64

Maximum processing latency in microseconds.

input_queue_depth: u32

Current input queue depth.

output_queue_depth: u32

Current output queue depth.

last_error: u32

Last error code (0 = no error).

_reserved: [u32; 3]

Reserved for alignment (pad to 64 bytes).

Implementations

impl TelemetryBuffer

pub const fn new() -> Self

Create a new telemetry buffer.

pub fn avg_latency_us(&self) -> f64

Calculate average latency in microseconds.

pub fn throughput(&self, elapsed_secs: f64) -> f64

Get throughput (messages per second) given elapsed time.

pub fn drop_rate(&self) -> f64

Get drop rate (0.0 to 1.0).

pub fn reset(&mut self)

Reset all counters to initial state.

pub fn merge(&mut self, other: &TelemetryBuffer)

Merge another telemetry buffer into this one.

Trait Implementations

impl Clone for TelemetryBuffer

fn clone(&self) -> TelemetryBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryBuffer

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

Formats the value using the given formatter.

impl Default for TelemetryBuffer

fn default() -> Self

Returns the “default value” for a type.

impl Copy for TelemetryBuffer