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
27
28
29
30
31
32
33
34
35
36
37
38
39

#[tokio::main]
async fn main() {
    let mut handles = vec![];
    for tenant in 0..100 {
        let h = tokio::spawn(async move {
            for n in 0..20 {
                let client = reqwest::Client::new();
                let tot = 2000;
                for i in 0..tot {
                    let k = protolib::Key {
                        version: 1,
                        tenant,
                        item: n,
                        hash: i,
                    };
                    let req = client
                        .get(format!("http://localhost:8080/stores/test/{k}"))
                        .build()
                        .expect("Could not build request");
                    if !client
                        .execute(req)
                        .await
                        .expect("Could not query store")
                        .status()
                        .is_success()
                    {
                        panic!("Key {k} not found");
                    }

                    println!("-- {k}");
                }
            }
        });
        handles.push(h);
    }
    for h in handles {
        h.await.unwrap();
    }
}