Struct LiveMetricsEvent 

#[repr(C)]
pub struct LiveMetricsEvent {
    pub subscription_id: u64,
    pub actor_id: u64,
    pub timestamp_us: u64,
    pub inbound_total: u64,
    pub outbound_total: u64,
    pub tenant_id: u64,
    pub queue_depth: u32,
    pub latency_p50_us: u32,
    pub latency_p99_us: u32,
    pub state_size_bytes: u32,
    pub gpu_utilization_pct: u8,
    pub _pad: [u8; 7],
}

K2H response: periodic metric emission from a GPU actor.

This is the on-wire form of LiveMetrics — fixed-size, #[repr(C)], and compact so it can be emitted at high frequency from GPU-side. The CPU-side K2H processor lifts it into a LiveMetrics for subscribers.

Fields

subscription_id: u64

Subscription this event is emitted for.

actor_id: u64

Source actor (thread-block index on GPU).

timestamp_us: u64

Microsecond-precision timestamp (wall clock, GPU-side origin).

inbound_total: u64

Total inbound messages observed (monotonic, cumulative).

outbound_total: u64

Total outbound messages observed (monotonic, cumulative).

tenant_id: u64

Tenant identifier (0 = unspecified).

queue_depth: u32

Current inbound queue depth.

latency_p50_us: u32

Observed p50 latency in microseconds.

latency_p99_us: u32

Observed p99 latency in microseconds.

state_size_bytes: u32

Resident actor state size in bytes (truncated to u32).

gpu_utilization_pct: u8

GPU utilization percentage 0–100.

_pad: [u8; 7]

Explicit padding for 16-byte alignment (C ABI stability).

Implementations

impl LiveMetricsEvent

pub const WIRE_SIZE: usize

Size of the wire representation in bytes.

pub const fn new( subscription_id: u64, actor_id: u64, timestamp_us: u64, inbound_total: u64, outbound_total: u64, tenant_id: u64, queue_depth: u32, latency_p50_us: u32, latency_p99_us: u32, state_size_bytes: u32, gpu_utilization_pct: u8, ) -> LiveMetricsEvent

Construct a new event. The padding field is zeroed.

pub fn to_bytes(&self) -> [u8; 72]

Serialize to a fixed-size byte array.

pub fn from_bytes(bytes: &[u8]) -> Option<LiveMetricsEvent>

Deserialize from a byte slice. Returns None if the slice is too short.

pub fn into_live_metrics(self, hlc_node_id: u64) -> LiveMetrics

Lift into a LiveMetrics observation.

Trait Implementations

impl Clone for LiveMetricsEvent

fn clone(&self) -> LiveMetricsEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LiveMetricsEvent

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

Formats the value using the given formatter.

impl PartialEq for LiveMetricsEvent

fn eq(&self, other: &LiveMetricsEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Copy for LiveMetricsEvent

impl Eq for LiveMetricsEvent

impl StructuralPartialEq for LiveMetricsEvent