Struct ShardMetrics

source

pub struct ShardMetrics {Show 14 fields
    pub records_processed: u64,
    pub records_failed: u64,
    pub retry_attempts: u64,
    pub processing_time: Duration,
    pub checkpoints_succeeded: u64,
    pub checkpoints_failed: u64,
    pub iterator_renewals: u64,
    pub iterator_failures: u64,
    pub soft_errors: u64,
    pub hard_errors: u64,
    pub avg_processing_time: Duration,
    pub max_processing_time: Duration,
    pub window_start: Instant,
    pub last_updated: Instant,
}

Expand description

Holds aggregated metrics for a single shard

Fields§

§records_processed: u64§records_failed: u64§retry_attempts: u64§processing_time: Duration§checkpoints_succeeded: u64§checkpoints_failed: u64§iterator_renewals: u64§iterator_failures: u64§soft_errors: u64§hard_errors: u64§avg_processing_time: Duration§max_processing_time: Duration§window_start: Instant§last_updated: Instant

Struct ShardMetricsCopy item path

Fields§

Trait Implementations§

impl Clone for ShardMetrics

fn clone(&self) -> ShardMetrics

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

impl Debug for ShardMetrics

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

impl Default for ShardMetrics

fn default() -> Self

Auto Trait Implementations§

impl Freeze for ShardMetrics

impl RefUnwindSafe for ShardMetrics

impl Send for ShardMetrics

impl Sync for ShardMetrics

impl Unpin for ShardMetrics

impl UnwindSafe for ShardMetrics

Blanket Implementations§

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dst: *mut T)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

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

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unsharedwhere Shared: FromUnshared<Unshared>,

fn into_shared(self) -> Shared

impl<T> Same for T

type Output = T

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

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

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

type Error = Infallible

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

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

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

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

impl<V, T> VZip<V> for Twhere 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>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ShardMetrics

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

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

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

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

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

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<Unshared, Shared> IntoShared<Shared> for Unshared
where Shared: FromUnshared<Unshared>,

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

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

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

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

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,