Struct StreamingMetrics

Source

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,
    pub max_queue_depth: AtomicU64,
    pub total_block_time_ms: AtomicU64,
}

Expand description

Streaming metrics for observability Issue #96 Task #6: Extended with queue depth and block time tracking

Fields§

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

Struct StreamingMetrics Copy item path

Fields§

Implementations§

impl StreamingMetrics

pub fn summary(&self) -> MetricsSummary

Trait Implementations§

impl Debug for StreamingMetrics

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

impl Default for StreamingMetrics

fn default() -> StreamingMetrics

Auto Trait Implementations§

impl !Freeze for StreamingMetrics

impl RefUnwindSafe for StreamingMetrics

impl Send for StreamingMetrics

impl Sync for StreamingMetrics

impl Unpin for StreamingMetrics

impl UnsafeUnpin for StreamingMetrics

impl UnwindSafe for StreamingMetrics

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

fn from(t: T) -> T

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

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

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>

Struct StreamingMetrics

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, 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<T, U> TryFrom<U> for T
where U: Into<T>,

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