pipebase 0.2.0

A tokio based runtime library for data integration app
Documentation 
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
44

use async_trait::async_trait;
use serde::de::DeserializeOwned;

#[async_trait]
pub trait FromPath: Sized + DeserializeOwned {
    async fn from_path<P>(path: P) -> anyhow::Result<Self>
    where
        P: AsRef<std::path::Path> + Send,
    {
        let file = std::fs::File::open(path)?;
        let config = serde_yaml::from_reader::<std::fs::File, Self>(file)?;
        Ok(config)
    }
}

#[async_trait]
pub trait FromConfig<T>: Sized {
    async fn from_config(config: T) -> anyhow::Result<Self>;
}

#[async_trait]
pub trait ConfigInto<T: FromConfig<Self>>: Sized {
    async fn config_into(self) -> anyhow::Result<T> {
        T::from_config(self).await
    }
}

#[macro_export]
macro_rules! config {
    {
        $config:ty
    } => {
        config!($config, "")
    };
    {
        $config:ty, $path:expr
    } => {
        {
            <$config>::from_path($path)
                .await
                .expect(&format!("invalid config file '{}'", $path))
        }
    };
}