pub struct GetNodeStatsResponse {Show 19 fields
pub node_id: u64,
pub shard_stats: Vec<ShardStatsProto>,
pub cpu_usage_percent: f64,
pub memory_used_bytes: u64,
pub memory_total_bytes: u64,
pub disk_used_bytes: u64,
pub disk_total_bytes: u64,
pub wal_bytes_written_total: f64,
pub block_cache_hits_total: f64,
pub block_cache_misses_total: f64,
pub block_cache_evictions_total: f64,
pub memtable_freeze_total: f64,
pub memtable_flush_total: f64,
pub wal_file_size_bytes: u64,
pub wal_file_count: u64,
pub vector_index_stats: Vec<VectorIndexStatsProto>,
pub cross_shard_txn_enabled: bool,
pub hlc_physical_ms: u64,
pub hlc_logical: u32,
}Fields§
§node_id: u64§shard_stats: Vec<ShardStatsProto>§cpu_usage_percent: f64System resource usage
memory_used_bytes: u64§memory_total_bytes: u64§disk_used_bytes: u64§disk_total_bytes: u64§wal_bytes_written_total: f64Storage-engine metrics (aggregated from local Prometheus counters)
block_cache_hits_total: f64§block_cache_misses_total: f64§block_cache_evictions_total: f64§memtable_freeze_total: f64§memtable_flush_total: f64§wal_file_size_bytes: u64WAL file size on disk (bytes) — sum across all shards on this node.
wal_file_count: u64Number of shared raft-wal segment files on disk (GC health signal).
vector_index_stats: Vec<VectorIndexStatsProto>Per-index vector stats on this node.
cross_shard_txn_enabled: boolCross-shard ACID transactions (epic #1478, Phase 1). cross_shard_txn_enabled
reflects the effective gate (env flag OR cluster option); default false.
hlc_physical_ms / hlc_logical are the node’s current Hybrid Logical
Clock reading (physical Unix-ms + logical tie-break), 0 when the feature is
OFF (the clock is not sampled). Surfaces the flag + clock for observability.
hlc_physical_ms: u64§hlc_logical: u32Trait Implementations§
Source§impl Clone for GetNodeStatsResponse
impl Clone for GetNodeStatsResponse
Source§fn clone(&self) -> GetNodeStatsResponse
fn clone(&self) -> GetNodeStatsResponse
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for GetNodeStatsResponse
impl Debug for GetNodeStatsResponse
Source§impl Default for GetNodeStatsResponse
impl Default for GetNodeStatsResponse
Source§impl Message for GetNodeStatsResponse
impl Message for GetNodeStatsResponse
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Returns the encoded length of the message without a length delimiter.
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message to a buffer. Read more
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message to a newly allocated buffer.
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Encodes the message with a length-delimiter to a buffer. Read more
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Encodes the message with a length-delimiter to a newly allocated buffer.
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes an instance of the message from a buffer. Read more
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Decodes a length-delimited instance of the message from the buffer.
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes an instance of the message from a buffer, and merges it into
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
Decodes a length-delimited instance of the message from buffer, and
merges it into
self.Source§impl PartialEq for GetNodeStatsResponse
impl PartialEq for GetNodeStatsResponse
impl StructuralPartialEq for GetNodeStatsResponse
Auto Trait Implementations§
impl Freeze for GetNodeStatsResponse
impl RefUnwindSafe for GetNodeStatsResponse
impl Send for GetNodeStatsResponse
impl Sync for GetNodeStatsResponse
impl Unpin for GetNodeStatsResponse
impl UnsafeUnpin for GetNodeStatsResponse
impl UnwindSafe for GetNodeStatsResponse
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request