Skip to main content

LiveMetrics

ringkernel_core::introspection

Struct LiveMetrics

pub struct LiveMetrics {
    pub actor_id: ActorId,
    pub timestamp: HlcTimestamp,
    pub queue_depth: usize,
    pub inbound_rate: f64,
    pub outbound_rate: f64,
    pub latency_p50: Duration,
    pub latency_p99: Duration,
    pub state_size_bytes: u64,
    pub gpu_utilization: f32,
    pub tenant_id: u64,
}

Expand description

Live per-actor metrics delivered to subscribers.

A LiveMetrics observation represents a point-in-time snapshot of an actor’s operational state, emitted periodically (per the subscriber’s configured interval) by a backend or aggregator.

Fields§

§actor_id: ActorId

Actor whose metrics are being reported.

§timestamp: HlcTimestamp

HLC timestamp for this observation (causal ordering across nodes).

§queue_depth: usize

Current inbound queue depth.

§inbound_rate: f64

Inbound message rate (messages/sec), EWMA-smoothed.

§outbound_rate: f64

Outbound message rate (messages/sec), EWMA-smoothed.

§latency_p50: Duration

Observed p50 processing latency.

§latency_p99: Duration

Observed p99 processing latency.

§state_size_bytes: u64

Resident actor state size in bytes.

§gpu_utilization: f32

GPU utilization (0.0–1.0). Always 0.0 on the CPU backend.

§tenant_id: u64

Tenant this actor belongs to (0 = unspecified).

Trait Implementations§

impl Clone for LiveMetrics

fn clone(&self) -> LiveMetrics

Returns a duplicate of the value. Read more

1.0.0 · Source§

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

Performs copy-assignment from source. Read more

impl Debug for LiveMetrics

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl Freeze for LiveMetrics

impl RefUnwindSafe for LiveMetrics

impl Send for LiveMetrics

impl Sync for LiveMetrics

impl Unpin for LiveMetrics

impl UnsafeUnpin for LiveMetrics

impl UnwindSafe for LiveMetrics

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> ArchivePointee for T

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> CloneToUninit for T
where T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)

Performs copy-assignment from self to dest. Read more

impl<F, W, T, D> Deserialize<With<T, W>, D> for F
where W: DeserializeWith<F, T, D>, D: Fallible + ?Sized, F: ?Sized,

fn deserialize( &self, deserializer: &mut D, ) -> Result<With<T, W>, <D as Fallible>::Error>

Deserializes using the given deserializer

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> LayoutRaw for T

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

Gets the layout of the type.

impl<T> Pointee for T

type Metadata = ()

The type for metadata in pointers and references to Self.

impl<T> ToOwned for T
where T: Clone,

type Owned = T

The resulting type after obtaining ownership.

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more