nodata 0.1.0

nodata is a kafka like message broker that is simple and easy to use, while relying on either local or s3 like data storage for consistency
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use std::{ops::Deref, sync::Arc};

use prometheus::Registry;

use crate::services::{consumers::Consumers, handler::Handler, staging::Staging};

#[derive(Clone)]
pub struct SharedState(Arc<State>);

impl SharedState {
    pub async fn new() -> anyhow::Result<Self> {
        Ok(Self(Arc::new(State::new().await?)))
    }
}

impl Deref for SharedState {
    type Target = Arc<State>;

    fn deref(&self) -> &Self::Target {
        &self.0
    }
}

pub struct State {
    pub staging: Staging,
    pub consumers: Consumers,
    pub handler: Handler,
    pub metrics_registry: Registry,
}

impl State {
    pub async fn new() -> anyhow::Result<Self> {
        let staging = Staging::new().await?;
        let handler = Handler::new(staging.clone());

        Ok(Self {
            consumers: Consumers::new(),
            staging,
            handler,
            metrics_registry: Registry::new(),
        })
    }
}