streex 0.1.12

Kafka store runner
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

#[tokio::main]
async fn main() {
    use mise_server::prelude::*;
    use protolib::Input as I;
    use protolib::Key as K;
    use protolib::Value as V;
    use serde_json::json;
    use streex::prelude::*;

    let config = StoreConfig::new()
        .id("test")
        .input_topic("test-input")
        .changelog_topic("test-changelog")
        .kafka_servers("localhost:9001,localhost:9002,localhost:9003")
        .build();

    let store = Store::<K, I, V>::new(config).await;
    let h = store.read_handle();

    Mise::new()
        .post("/store/test/*", move |r| {
            let i: K = serde_json::from_value(r.body().clone()).unwrap();
            json!(h.get(&i)).into()
        })
        .serve("127.0.0.1:8080".parse().unwrap());
}