pub struct WatcherStats {
pub files_ingested: u64,
pub files_failed: u64,
pub last_event_at: Option<SystemTime>,
pub last_error: Option<String>,
pub max_concurrent: u32,
pub in_flight: u32,
}Expand description
Running counters for a watcher. Updated in place as the background task processes events.
Fields§
§files_ingested: u64§files_failed: u64§last_event_at: Option<SystemTime>§last_error: Option<String>§max_concurrent: u32Configured parallelism ceiling (resolved to an actual number).
in_flight: u32Ingest tasks currently running — gives operators a live-load signal.
Trait Implementations§
Source§impl Clone for WatcherStats
impl Clone for WatcherStats
Source§fn clone(&self) -> WatcherStats
fn clone(&self) -> WatcherStats
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 WatcherStats
impl Debug for WatcherStats
Source§impl Default for WatcherStats
impl Default for WatcherStats
Source§fn default() -> WatcherStats
fn default() -> WatcherStats
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for WatcherStats
impl RefUnwindSafe for WatcherStats
impl Send for WatcherStats
impl Sync for WatcherStats
impl Unpin for WatcherStats
impl UnsafeUnpin for WatcherStats
impl UnwindSafe for WatcherStats
Blanket Implementations§
impl<T> Allocation for T
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
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