StreamingMetrics

rangebar_streaming::processor

Struct StreamingMetrics

pub struct StreamingMetrics {
    pub trades_processed: AtomicU64,
    pub bars_generated: AtomicU64,
    pub errors_total: AtomicU64,
    pub backpressure_events: AtomicU64,
    pub circuit_breaker_trips: AtomicU64,
    pub memory_usage_bytes: AtomicU64,
}

Expand description

Streaming metrics for observability

Fields§

§trades_processed: AtomicU64§bars_generated: AtomicU64§errors_total: AtomicU64§backpressure_events: AtomicU64§circuit_breaker_trips: AtomicU64§memory_usage_bytes: AtomicU64

Implementations§

impl StreamingMetrics

pub fn summary(&self) -> MetricsSummary

Get metrics summary

Trait Implementations§

impl Debug for StreamingMetrics

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

Formats the value using the given formatter. Read more

impl Default for StreamingMetrics

fn default() -> StreamingMetrics

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

Auto Trait Implementations§

impl !Freeze for StreamingMetrics

impl RefUnwindSafe for StreamingMetrics

impl Send for StreamingMetrics

impl Sync for StreamingMetrics

impl Unpin for StreamingMetrics

impl UnwindSafe for StreamingMetrics

Blanket Implementations§

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

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

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

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

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

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

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

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

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

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

type Error = Infallible

The type returned in the event of a conversion error.

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

Performs the conversion.

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

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

The type returned in the event of a conversion error.

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

Performs the conversion.