thingvellir 0.0.4-alpha0

a concurrent, shared-nothing abstraction that manages an assembly of things
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

use anyhow::Error;
use thingvellir::{service_builder, DataLoadRequest, LoadFromUpstream, ServiceData};

#[derive(Clone, Default)]
struct MaybeExists {}

impl<Data: Default> LoadFromUpstream<u64, Option<Data>> for MaybeExists {
    fn load(&mut self, request: DataLoadRequest<u64, Option<Data>>) {
        if *request.key() == 1 {
            println!("loading {} found", request.key());
            request.resolve(Some(Default::default()));
        } else {
            println!("loading {} not found", request.key());
            request.resolve(None);
        }
    }
}

#[derive(Default, Clone)]
struct Counter;

impl ServiceData for Counter {}

#[tokio::main]
async fn main() -> Result<(), Error> {
    let mut service = service_builder::<u64, Option<Counter>>(1000).build(MaybeExists {});

    assert!(service.execute(1, |x| x.is_some()).await? == true);
    assert!(service.execute(2, |x| x.is_some()).await? == false);
    // service
    //     .execute_mut(2, |x| Persist::default(x.replace(Default::default())))
    //     .await?;
    assert!(service.execute(2, |x| x.is_some()).await? == true);

    Ok(())
}