KernelMetrics

rustkernel_core::observability::metrics

Struct KernelMetrics

pub struct KernelMetrics {
    pub kernel_id: String,
    pub domain: String,
    pub messages_total: AtomicU64,
    pub messages_success: AtomicU64,
    pub messages_failed: AtomicU64,
    pub processing_time_ns: AtomicU64,
    pub queue_depth: AtomicU64,
}

Expand description

Kernel-specific metrics

Fields§

§kernel_id: String

Kernel ID

§domain: String

Domain

§messages_total: AtomicU64

Total messages processed

§messages_success: AtomicU64

Successful messages

§messages_failed: AtomicU64

Failed messages

§processing_time_ns: AtomicU64

Total processing time in nanoseconds

§queue_depth: AtomicU64

Current queue depth

Implementations§

impl KernelMetrics

pub fn new(kernel_id: impl Into<String>, domain: impl Into<String>) -> Self

Create new metrics for a kernel

pub fn record_execution(&self, latency: Duration, success: bool)

Record a message execution

pub fn set_queue_depth(&self, depth: u64)

Update queue depth

pub fn avg_latency_us(&self) -> f64

Get average latency in microseconds

pub fn success_rate(&self) -> f64

Get success rate (0.0 - 1.0)

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

Get throughput (messages per second) over a given duration

Trait Implementations§

impl Debug for KernelMetrics

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

impl !Freeze for KernelMetrics

impl RefUnwindSafe for KernelMetrics

impl Send for KernelMetrics

impl Sync for KernelMetrics

impl Unpin for KernelMetrics

impl UnwindSafe for KernelMetrics

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<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, 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<V, T> VZip<V> for T
where V: MultiLane<T>,

fn vzip(self) -> V

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