coerce 0.8.6

Async actor runtime and distributed systems framework
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

use crate::actor::LocalActorRef;
use crate::remote::api::sharding::cluster::{get_shard_host_stats, get_sharding_stats};
use crate::remote::api::sharding::node::{get_node_stats, GetAllStats};
use crate::remote::api::sharding::{get_sharding_types, ShardingApi};
use crate::remote::api::Routes;

use axum::routing::get;
use axum::{Json, Router};

impl Routes for LocalActorRef<ShardingApi> {
    fn routes(&self, router: Router) -> Router {
        router
            .route("/sharding/types", {
                let actor_ref = self.clone();
                get(move || get_sharding_types(actor_ref))
            })
            .route("/sharding/stats/cluster/:entity", {
                let actor_ref = self.clone();
                get(move |path| get_sharding_stats(actor_ref, path))
            })
            .route("/sharding/host/stats/:entity", {
                let actor_ref = self.clone();
                get(move |path| get_shard_host_stats(actor_ref, path))
            })
            .route("/sharding/stats/node/:entity", {
                let actor_ref = self.clone();
                get(move |path| get_node_stats(actor_ref, path))
            })
            .route("/sharding/node/stats/all", {
                let actor_ref = self.clone();
                get(|| async move {
                    let actor_ref = actor_ref;
                    Json(
                        actor_ref
                            .send(GetAllStats)
                            .await
                            .expect("unable to get shard types"),
                    )
                })
            })
    }
}