Skip to main content

FlushMetrics

Struct FlushMetrics 

Source
pub struct FlushMetrics {
Show 28 fields pub batch_count: u64, pub sync_batch_count: u64, pub write_request_count: u64, pub write_bytes: u64, pub callback_count: u64, pub group_wait_count: u64, pub group_wait_us: u64, pub group_wait_max_us: u64, pub queued_wait_us: u64, pub queued_wait_max_us: u64, pub write_us: u64, pub write_max_us: u64, pub sync_us: u64, pub sync_max_us: u64, pub batch_us: u64, pub batch_max_us: u64, pub batch_size_max: u64, pub batch_bytes_max: u64, pub last_batch_size: u64, pub last_batch_bytes: u64, pub last_callback_count: u64, pub last_sync_us: u64, pub last_queued_wait_max_us: u64, pub group_wait_percentiles: FlushLatencyPercentiles, pub queued_wait_percentiles: FlushLatencyPercentiles, pub write_percentiles: FlushLatencyPercentiles, pub sync_percentiles: FlushLatencyPercentiles, pub batch_percentiles: FlushLatencyPercentiles,
}
Expand description

Aggregated flush worker metrics.

Fields§

§batch_count: u64

Number of write batches processed by the flush worker.

§sync_batch_count: u64

Number of batches that required a filesystem sync.

§write_request_count: u64

Number of write requests included in all batches.

§write_bytes: u64

Total bytes written by the flush worker.

§callback_count: u64

Number of callbacks sent after write batches.

§group_wait_count: u64

Number of times the flush worker intentionally waited for batching.

§group_wait_us: u64

Total intentional group-commit wait time, in microseconds.

§group_wait_max_us: u64

Maximum intentional group-commit wait time, in microseconds.

§queued_wait_us: u64

Total request queue wait before a batch starts writing, in microseconds.

§queued_wait_max_us: u64

Maximum request queue wait before a batch starts writing, in microseconds.

§write_us: u64

Total file write time, in microseconds.

§write_max_us: u64

Maximum file write time for one batch, in microseconds.

§sync_us: u64

Total filesystem sync time, in microseconds.

§sync_max_us: u64

Maximum filesystem sync time for one batch, in microseconds.

§batch_us: u64

Total batch processing time, in microseconds.

§batch_max_us: u64

Maximum batch processing time, in microseconds.

§batch_size_max: u64

Largest number of write requests in one batch.

§batch_bytes_max: u64

Largest number of bytes written by one batch.

§last_batch_size: u64

Number of write requests in the latest batch.

§last_batch_bytes: u64

Number of bytes written by the latest batch.

§last_callback_count: u64

Number of callbacks sent by the latest batch.

§last_sync_us: u64

Filesystem sync duration of the latest batch, in microseconds.

§last_queued_wait_max_us: u64

Request queue wait maximum of the latest batch, in microseconds.

§group_wait_percentiles: FlushLatencyPercentiles

Intentional group-commit wait latency percentiles, in microseconds.

§queued_wait_percentiles: FlushLatencyPercentiles

Per-batch max request queue wait latency percentiles, in microseconds.

§write_percentiles: FlushLatencyPercentiles

File write latency percentiles, in microseconds.

§sync_percentiles: FlushLatencyPercentiles

Filesystem sync latency percentiles, in microseconds.

§batch_percentiles: FlushLatencyPercentiles

Whole batch processing latency percentiles, in microseconds.

Trait Implementations§

Source§

impl Clone for FlushMetrics

Source§

fn clone(&self) -> FlushMetrics

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 FlushMetrics

Source§

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

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

impl Default for FlushMetrics

Source§

fn default() -> FlushMetrics

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

impl PartialEq for FlushMetrics

Source§

fn eq(&self, other: &FlushMetrics) -> 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 FlushMetrics

Source§

impl StructuralPartialEq for FlushMetrics

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

Source§

fn from(t: T) -> T

Returns the argument unchanged.

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> 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.