Skip to main content

ZLayerMetrics

Struct ZLayerMetrics 

Source
pub struct ZLayerMetrics {
Show 17 fields pub services_total: Gauge, pub service_replicas: GaugeVec, pub service_health: GaugeVec, pub scale_events_total: CounterVec, pub scale_up_total: Counter, pub scale_down_total: Counter, pub requests_total: CounterVec, pub request_duration_seconds: HistogramVec, pub raft_is_leader: Gauge, pub raft_term: Gauge, pub raft_commit_index: Gauge, pub uptime_seconds: Gauge, pub gpu_utilization: GaugeVec, pub gpu_memory_used: GaugeVec, pub gpu_memory_total: GaugeVec, pub gpu_temperature: GaugeVec, pub gpu_power: GaugeVec, /* private fields */
}
Expand description

ZLayer metrics collection

Pre-defined metrics for the ZLayer system.

Fields§

§services_total: Gauge

Total number of registered services

§service_replicas: GaugeVec

Current replica count per service

§service_health: GaugeVec

Service health status (0=unknown, 1=healthy, 2=degraded, 3=unhealthy)

§scale_events_total: CounterVec

Total scaling events by service and direction

§scale_up_total: Counter

Total scale up events

§scale_down_total: Counter

Total scale down events

§requests_total: CounterVec

Total HTTP requests by method, path, and status

§request_duration_seconds: HistogramVec

HTTP request duration in seconds

§raft_is_leader: Gauge

Whether this node is the Raft leader (1) or not (0)

§raft_term: Gauge

Current Raft term

§raft_commit_index: Gauge

Current Raft commit index

§uptime_seconds: Gauge

Time since the service started in seconds

§gpu_utilization: GaugeVec

GPU utilization percentage per GPU index and node

§gpu_memory_used: GaugeVec

GPU memory used in bytes per GPU index and node

§gpu_memory_total: GaugeVec

GPU total memory in bytes per GPU index and node

§gpu_temperature: GaugeVec

GPU temperature in celsius per GPU index and node

§gpu_power: GaugeVec

GPU power draw in watts per GPU index and node

Implementations§

Source§

impl ZLayerMetrics

Source

pub fn new() -> Result<Self>

Create a new metrics collection

§Errors

Returns an error if Prometheus metric creation or registration fails.

Source

pub fn registry(&self) -> &Registry

Get the Prometheus registry

Source

pub fn encode(&self) -> Result<String>

Encode metrics in Prometheus text format

§Errors

Returns an error if metric encoding fails.

Source

pub fn record_scale_event(&self, service: &str, direction: &str)

Record a scale event

Source

pub fn set_replicas(&self, service: &str, count: u32)

Update service replica count

Source

pub fn set_health(&self, service: &str, health: HealthStatus)

Update service health status

Source

pub fn record_request( &self, method: &str, path: &str, status: u16, duration_secs: f64, )

Record an HTTP request

Source

pub fn set_raft_leader(&self, is_leader: bool)

Update Raft leader status

Source

pub fn set_raft_term(&self, term: u64)

Update Raft term

Source

pub fn set_raft_commit_index(&self, index: u64)

Update Raft commit index

Source

pub fn set_uptime(&self, seconds: f64)

Update uptime

Source

pub fn set_gpu_utilization(&self, gpu_index: u32, node: &str, percent: f64)

Update GPU utilization percentage

Source

pub fn set_gpu_memory_used(&self, gpu_index: u32, node: &str, bytes: u64)

Update GPU memory used in bytes

Source

pub fn set_gpu_memory_total(&self, gpu_index: u32, node: &str, bytes: u64)

Update GPU total memory in bytes

Source

pub fn set_gpu_temperature(&self, gpu_index: u32, node: &str, celsius: f64)

Update GPU temperature in celsius

Source

pub fn set_gpu_power(&self, gpu_index: u32, node: &str, watts: f64)

Update GPU power draw in watts

Trait Implementations§

Source§

impl Default for ZLayerMetrics

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

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

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

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

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

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

Source§

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

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FutureExt for T

Source§

fn with_context(self, otel_cx: Context) -> WithContext<Self>

Attaches the provided Context to this type, returning a WithContext wrapper. Read more
Source§

fn with_current_context(self) -> WithContext<Self>

Attaches the current Context to this type, returning a WithContext wrapper. Read more
Source§

impl<T> Instrument for T

Source§

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

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

fn in_current_span(self) -> Instrumented<Self>

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

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

Source§

fn into(self) -> U

Calls U::from(self).

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

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

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

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

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

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

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
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

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