continuo 0.12.0

Runtime service composition for multi-service Rust applications: typed component resolution, dependency-ordered lifecycle, reload, runnable tasks, graceful drain, and finalization.
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

use std::sync::Arc;
use std::sync::atomic::{AtomicUsize, Ordering};

pub struct AtomicParser(pub Arc<AtomicUsize>);

#[async_trait::async_trait]
impl congif::ConfigParser for AtomicParser {
    fn extensions(&self) -> &[&str] {
        &["test"]
    }

    async fn parse(
        &self,
        _: congif::ConfigSource<'_>,
    ) -> std::result::Result<congif::ConfigValue, congif::BoxError> {
        Ok(congif::ConfigValue::U64(self.0.load(Ordering::Relaxed) as u64))
    }
}

pub fn source() -> congif::ConfigFile {
    congif::ConfigFile {
        path: std::path::Path::new(env!("CARGO_MANIFEST_DIR"))
            .join("tests/fixtures/counter/valid.json"),
        format: congif::Format::Custom("test".into()),
    }
}