hanabi-core 0.1.0-alpha.2

Core library for Hanabi
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::sync::Arc;
use std::sync::atomic::AtomicU64;

#[derive(Clone)]
pub struct PubSubMetrics {
    messages_processed: Arc<AtomicU64>,
}

impl PubSubMetrics {
    pub fn new() -> Self {
        Self {
            messages_processed: Arc::new(AtomicU64::new(0)),
        }
    }

    pub fn messages_processed(&self) -> Arc<AtomicU64> {
        self.messages_processed.clone()
    }
}