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

use crate::dagger_engine::DaggerEngine;

pub struct Component {
    dagger_engine: DaggerEngine,
}

impl Component {
    pub fn new(dagger_engine: DaggerEngine) -> Self {
        Self { dagger_engine }
    }
    pub async fn start_component(&mut self) -> anyhow::Result<()> {
        self.dagger_engine.start().await?;

        Ok(())
    }

    pub async fn close_component(&mut self) -> anyhow::Result<()> {
        Ok(())
    }

    pub async fn handle_transform_message(&mut self) -> anyhow::Result<()> {
        Ok(())
    }
}