Struct LogMetrics

pub struct LogMetrics {

    pub updates_received: RwLock<u64>,
    pub updates_processed: RwLock<u64>,
    pub updates_successful: RwLock<u64>,
    pub updates_failed: RwLock<u64>,
    pub updates_queued: RwLock<u64>,
    pub updates_processing_times: RwLock<Vec<u64>>,
    pub account_updates_processed: RwLock<u64>,
    pub transaction_updates_processed: RwLock<u64>,
    pub account_deletions_processed: RwLock<u64>,
    pub counters: RwLock<HashMap<String, u64>>,
    pub gauges: RwLock<HashMap<String, f64>>,
    pub histograms: RwLock<HashMap<String, Vec<f64>>>,
    pub start: RwLock<Instant>,
    pub last_flush: RwLock<Instant>,
}

Fields

updates_received: RwLock<u64>

updates_processed: RwLock<u64>

updates_successful: RwLock<u64>

updates_failed: RwLock<u64>

updates_queued: RwLock<u64>

updates_processing_times: RwLock<Vec<u64>>

account_updates_processed: RwLock<u64>

transaction_updates_processed: RwLock<u64>

account_deletions_processed: RwLock<u64>

counters: RwLock<HashMap<String, u64>>

gauges: RwLock<HashMap<String, f64>>

histograms: RwLock<HashMap<String, Vec<f64>>>

start: RwLock<Instant>

last_flush: RwLock<Instant>

Implementations

impl LogMetrics

pub fn new() -> Self

Trait Implementations

impl Default for LogMetrics

fn default() -> Self

Returns the “default value” for a type.

impl Metrics for LogMetrics

fn initialize<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initializes the metrics system, preparing it for data collection.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Flushes any buffered metrics data to ensure all metrics are reported.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Shuts down the metrics system, performing cleanup and ensuring all data is flushed.

fn increment_counter<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, value: u64, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Increments a counter metric by a specified value.

fn update_gauge<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, value: f64, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Updates a gauge metric, setting its value to represent the current state.

fn record_histogram<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, value: f64, ) -> Pin<Box<dyn Future<Output = CarbonResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Records a value in a histogram metric, representing distribution data.