pub struct EventStats {
pub total_published: u64,
pub total_processed: u64,
pub total_failed: u64,
pub events_by_type: HashMap<String, u64>,
pub events_by_priority: HashMap<EventPriority, u64>,
pub avg_processing_time_ms: f64,
pub active_subscriptions: usize,
pub queue_size: usize,
}
Expand description
Event statistics
Fields§
§total_published: u64
Total events published
total_processed: u64
Total events processed
total_failed: u64
Total events failed
events_by_type: HashMap<String, u64>
Events by type
events_by_priority: HashMap<EventPriority, u64>
Events by priority
avg_processing_time_ms: f64
Average processing time in milliseconds
active_subscriptions: usize
Current active subscriptions
queue_size: usize
Queue size
Trait Implementations§
Source§impl Clone for EventStats
impl Clone for EventStats
Source§fn clone(&self) -> EventStats
fn clone(&self) -> EventStats
Returns a copy of the value. Read more
1.0.0 · 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 EventStats
impl Debug for EventStats
Source§impl<'de> Deserialize<'de> for EventStats
impl<'de> Deserialize<'de> for EventStats
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for EventStats
impl RefUnwindSafe for EventStats
impl Send for EventStats
impl Sync for EventStats
impl Unpin for EventStats
impl UnwindSafe for EventStats
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> InitializeFromFunction<T> for T
impl<T> InitializeFromFunction<T> for T
§fn initialize_from_function(f: fn() -> T) -> T
fn initialize_from_function(f: fn() -> T) -> T
Create an instance of this type from an initialization function
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T, O> SuperFrom<T> for Owhere
O: From<T>,
impl<T, O> SuperFrom<T> for Owhere
O: From<T>,
§fn super_from(input: T) -> O
fn super_from(input: T) -> O
Convert from a type to another type.
§impl<T, O, M> SuperInto<O, M> for Twhere
O: SuperFrom<T, M>,
impl<T, O, M> SuperInto<O, M> for Twhere
O: SuperFrom<T, M>,
§fn super_into(self) -> O
fn super_into(self) -> O
Convert from a type to another type.