Skip to main content

RuntimeMetricsSnapshot

ursula_runtime

Struct RuntimeMetricsSnapshot 

Source 
pub struct RuntimeMetricsSnapshot {
Show 85 fields
    pub accepted_appends: u64,
    pub per_core_appends: Vec<u64>,
    pub per_group_appends: Vec<u64>,
    pub applied_mutations: u64,
    pub per_core_applied_mutations: Vec<u64>,
    pub per_group_applied_mutations: Vec<u64>,
    pub mutation_apply_ns: u64,
    pub per_core_mutation_apply_ns: Vec<u64>,
    pub per_group_mutation_apply_ns: Vec<u64>,
    pub group_lock_wait_ns: u64,
    pub per_core_group_lock_wait_ns: Vec<u64>,
    pub per_group_group_lock_wait_ns: Vec<u64>,
    pub group_engine_exec_ns: u64,
    pub per_core_group_engine_exec_ns: Vec<u64>,
    pub per_group_group_engine_exec_ns: Vec<u64>,
    pub group_mailbox_depth: u64,
    pub per_group_group_mailbox_depth: Vec<u64>,
    pub group_mailbox_max_depth: u64,
    pub per_group_group_mailbox_max_depth: Vec<u64>,
    pub group_mailbox_full_events: u64,
    pub per_group_group_mailbox_full_events: Vec<u64>,
    pub raft_write_many_batches: u64,
    pub per_core_raft_write_many_batches: Vec<u64>,
    pub per_group_raft_write_many_batches: Vec<u64>,
    pub raft_write_many_commands: u64,
    pub per_core_raft_write_many_commands: Vec<u64>,
    pub per_group_raft_write_many_commands: Vec<u64>,
    pub raft_write_many_logical_commands: u64,
    pub per_core_raft_write_many_logical_commands: Vec<u64>,
    pub per_group_raft_write_many_logical_commands: Vec<u64>,
    pub raft_write_many_responses: u64,
    pub per_core_raft_write_many_responses: Vec<u64>,
    pub per_group_raft_write_many_responses: Vec<u64>,
    pub raft_write_many_submit_ns: u64,
    pub per_core_raft_write_many_submit_ns: Vec<u64>,
    pub per_group_raft_write_many_submit_ns: Vec<u64>,
    pub raft_write_many_response_ns: u64,
    pub per_core_raft_write_many_response_ns: Vec<u64>,
    pub per_group_raft_write_many_response_ns: Vec<u64>,
    pub raft_apply_entries: u64,
    pub per_core_raft_apply_entries: Vec<u64>,
    pub per_group_raft_apply_entries: Vec<u64>,
    pub raft_apply_ns: u64,
    pub per_core_raft_apply_ns: Vec<u64>,
    pub per_group_raft_apply_ns: Vec<u64>,
    pub live_read_waiters: u64,
    pub per_core_live_read_waiters: Vec<u64>,
    pub live_read_backpressure_events: u64,
    pub per_core_live_read_backpressure_events: Vec<u64>,
    pub routed_requests: u64,
    pub per_core_routed_requests: Vec<u64>,
    pub mailbox_send_wait_ns: u64,
    pub per_core_mailbox_send_wait_ns: Vec<u64>,
    pub mailbox_full_events: u64,
    pub per_core_mailbox_full_events: Vec<u64>,
    pub wal_batches: u64,
    pub per_core_wal_batches: Vec<u64>,
    pub per_group_wal_batches: Vec<u64>,
    pub wal_records: u64,
    pub per_core_wal_records: Vec<u64>,
    pub per_group_wal_records: Vec<u64>,
    pub wal_write_ns: u64,
    pub per_core_wal_write_ns: Vec<u64>,
    pub per_group_wal_write_ns: Vec<u64>,
    pub wal_sync_ns: u64,
    pub per_core_wal_sync_ns: Vec<u64>,
    pub per_group_wal_sync_ns: Vec<u64>,
    pub cold_flush_uploads: u64,
    pub cold_flush_upload_bytes: u64,
    pub cold_flush_upload_ns: u64,
    pub cold_flush_publishes: u64,
    pub cold_flush_publish_bytes: u64,
    pub cold_flush_publish_ns: u64,
    pub cold_orphan_cleanup_attempts: u64,
    pub cold_orphan_cleanup_errors: u64,
    pub cold_orphan_bytes: u64,
    pub cold_hot_bytes: u64,
    pub per_group_cold_hot_bytes: Vec<u64>,
    pub cold_hot_group_bytes_max: u64,
    pub per_group_cold_hot_bytes_max: Vec<u64>,
    pub cold_hot_stream_bytes_max: u64,
    pub cold_backpressure_events: u64,
    pub per_core_cold_backpressure_events: Vec<u64>,
    pub per_group_cold_backpressure_events: Vec<u64>,
    pub cold_backpressure_bytes: u64,

}

Fields§

§accepted_appends: u64§per_core_appends: Vec<u64>§per_group_appends: Vec<u64>§applied_mutations: u64§per_core_applied_mutations: Vec<u64>§per_group_applied_mutations: Vec<u64>§mutation_apply_ns: u64§per_core_mutation_apply_ns: Vec<u64>§per_group_mutation_apply_ns: Vec<u64>§group_lock_wait_ns: u64§per_core_group_lock_wait_ns: Vec<u64>§per_group_group_lock_wait_ns: Vec<u64>§group_engine_exec_ns: u64§per_core_group_engine_exec_ns: Vec<u64>§per_group_group_engine_exec_ns: Vec<u64>§group_mailbox_depth: u64§per_group_group_mailbox_depth: Vec<u64>§group_mailbox_max_depth: u64§per_group_group_mailbox_max_depth: Vec<u64>§group_mailbox_full_events: u64§per_group_group_mailbox_full_events: Vec<u64>§raft_write_many_batches: u64§per_core_raft_write_many_batches: Vec<u64>§per_group_raft_write_many_batches: Vec<u64>§raft_write_many_commands: u64§per_core_raft_write_many_commands: Vec<u64>§per_group_raft_write_many_commands: Vec<u64>§raft_write_many_logical_commands: u64§per_core_raft_write_many_logical_commands: Vec<u64>§per_group_raft_write_many_logical_commands: Vec<u64>§raft_write_many_responses: u64§per_core_raft_write_many_responses: Vec<u64>§per_group_raft_write_many_responses: Vec<u64>§raft_write_many_submit_ns: u64§per_core_raft_write_many_submit_ns: Vec<u64>§per_group_raft_write_many_submit_ns: Vec<u64>§raft_write_many_response_ns: u64§per_core_raft_write_many_response_ns: Vec<u64>§per_group_raft_write_many_response_ns: Vec<u64>§raft_apply_entries: u64§per_core_raft_apply_entries: Vec<u64>§per_group_raft_apply_entries: Vec<u64>§raft_apply_ns: u64§per_core_raft_apply_ns: Vec<u64>§per_group_raft_apply_ns: Vec<u64>§live_read_waiters: u64§per_core_live_read_waiters: Vec<u64>§live_read_backpressure_events: u64§per_core_live_read_backpressure_events: Vec<u64>§routed_requests: u64§per_core_routed_requests: Vec<u64>§mailbox_send_wait_ns: u64§per_core_mailbox_send_wait_ns: Vec<u64>§mailbox_full_events: u64§per_core_mailbox_full_events: Vec<u64>§wal_batches: u64§per_core_wal_batches: Vec<u64>§per_group_wal_batches: Vec<u64>§wal_records: u64§per_core_wal_records: Vec<u64>§per_group_wal_records: Vec<u64>§wal_write_ns: u64§per_core_wal_write_ns: Vec<u64>§per_group_wal_write_ns: Vec<u64>§wal_sync_ns: u64§per_core_wal_sync_ns: Vec<u64>§per_group_wal_sync_ns: Vec<u64>§cold_flush_uploads: u64§cold_flush_upload_bytes: u64§cold_flush_upload_ns: u64§cold_flush_publishes: u64§cold_flush_publish_bytes: u64§cold_flush_publish_ns: u64§cold_orphan_cleanup_attempts: u64§cold_orphan_cleanup_errors: u64§cold_orphan_bytes: u64§cold_hot_bytes: u64§per_group_cold_hot_bytes: Vec<u64>§cold_hot_group_bytes_max: u64§per_group_cold_hot_bytes_max: Vec<u64>§cold_hot_stream_bytes_max: u64§cold_backpressure_events: u64§per_core_cold_backpressure_events: Vec<u64>§per_group_cold_backpressure_events: Vec<u64>§cold_backpressure_bytes: u64

Trait Implementations§

Source§

impl Clone for RuntimeMetricsSnapshot

Source§

fn clone(&self) -> RuntimeMetricsSnapshot

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for RuntimeMetricsSnapshot

Source§

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

Formats the value using the given formatter. Read more
Source§

impl PartialEq for RuntimeMetricsSnapshot

Source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 (const: unstable) · Source§

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

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

impl Eq for RuntimeMetricsSnapshot

Source§

impl StructuralPartialEq for RuntimeMetricsSnapshot

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> CloneToUninit for T
where T: Clone,

Source§

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

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

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> 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> Same for T

Source§

type Output = T

Should always be Self
Source§

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

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

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

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

Uses borrowed data to replace owned data, usually by cloning. 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<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
Source§

impl<T> MaybeSend for T
where T: Send,