ame-bus 1.0.0

Modern microservices framework based on NATS.
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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

use crate as ame_bus;
use ame_bus_macros::*;
use tokio::sync::OnceCell;
use serde::{Deserialize, Serialize};
use ame_bus::service_rpc::NatsRpcRequest;
use crate::service_rpc::NatsRpcRequestMeta;

static NATS_CONNECTION: OnceCell<async_nats::Client> = OnceCell::const_new();

#[rpc_service(
    name = "user.info",
    version = "0.1.0"
)]
pub struct UserInfoService {
    // fields, like database connection
}

#[derive(Debug, Clone, Serialize, Deserialize, NatsJsonMessage)]
struct UserAvatarReq {
    user_id: String,
}

impl NatsRpcRequestMeta for UserAvatarReq {
    const ENDPOINT_NAME: &'static str = "avatar";
    type Service = UserInfoService;
}

#[async_trait::async_trait]
impl NatsRpcRequest for UserAvatarReq {
    type Response = ();

    async fn process_request(_: &Self::Service, _: Self) -> anyhow::Result<Self::Response> {
        Ok(())
    }
}

#[derive(Debug, Clone, Serialize, Deserialize, NatsJsonMessage)]
struct UserMetaReq {
    user_id: String,
}

impl NatsRpcRequestMeta for UserMetaReq {
    const ENDPOINT_NAME: &'static str = "meta";
    type Service = UserInfoService;
}

#[async_trait::async_trait]
impl NatsRpcRequest for UserMetaReq {
    type Response = ();
    async fn process_request(_: &Self::Service, _: Self) -> anyhow::Result<Self::Response> {
        Ok(())
    }
}

#[rpc_route(
    service="UserInfoService",
    nats_connection="NATS_CONNECTION.get().unwrap()"
)]
enum UserInfoRoute {
    #[rpc_endpoint(request="UserAvatarReq")]
    UserAvatar,
    #[rpc_endpoint(request="UserMetaReq")]
    UserMeta,
}