edgy-s 1.4.0

A minimalist WebSocket bidirectional RPC framework for building microservice applications
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120

use {
    super::{super::types::ReqId, StreamingBody},
    hyper::{HeaderMap, StatusCode, Uri},
    std::{io::Result as IoResult, net::SocketAddr},
    tokio::sync::watch::Sender as WatchSender,
    tokio::{
        sync::{mpsc::Sender as MpscSender, oneshot::Sender as OneshotSender},
        task::JoinHandle,
    },
    tokio_tungstenite::tungstenite::Message,
    tokio_util::sync::CancellationToken,
};

type WsStreamSender = MpscSender<(
    Uri,
    SocketAddr,
    HeaderMap,
    Message,
    OneshotSender<Option<Message>>,
)>;
type OpenSender = MpscSender<(
    Uri,
    SocketAddr,
    HeaderMap,
    WatchSender<HeaderMap>,
    WatchSender<StatusCode>,
    OneshotSender<()>,
)>;
type CloseSender = MpscSender<(Uri, SocketAddr, HeaderMap)>;
pub(super) type HttpReqSender = MpscSender<(
    Uri,
    SocketAddr,
    HeaderMap,
    StreamingBody,
    OneshotSender<(HeaderMap, StatusCode, StreamingBody)>,
    CancellationToken,
)>;

#[derive(Debug)]
pub enum Command {
    AddWsRoute {
        path: String,
        stream: WsStreamSender,
        opt_return: OneshotSender<IoResult<()>>,
        open: OpenSender,
        close: CloseSender,
    },

    RemoveWsRoute {
        path: String,
        opt_return: OneshotSender<IoResult<()>>,
    },

    AddHttpRoute {
        path: String,
        req_tx: HttpReqSender,
        opt_return: OneshotSender<IoResult<()>>,
        task: JoinHandle<()>,
    },

    RemoveHttpRoute {
        path: String,
        opt_return: OneshotSender<IoResult<()>>,
    },

    Transfer {
        uri: Uri,
        socket_addr: SocketAddr,
        msg: Message,
        headers: HeaderMap,
        ret_tx: OneshotSender<Option<Message>>,
    },

    CallRemotely {
        path: String,
        socket_addr: SocketAddr,
        id: ReqId,
        msg: Message,
        ret_tx: OneshotSender<IoResult<Message>>,
    },

    CommitReturn {
        path: String,
        socket_addr: SocketAddr,
        id: ReqId,
        msg: Message,
    },

    Request {
        uri: Uri,
        socket_addr: SocketAddr,
        headers: HeaderMap,
        body: StreamingBody,
        ret_tx: OneshotSender<(HeaderMap, StatusCode, StreamingBody)>,
        cancel_token: CancellationToken,
    },

    WsOpen {
        uri: Uri,
        socket_addr: SocketAddr,
        headers: HeaderMap,
        open_tx: OneshotSender<(HeaderMap, StatusCode)>,
    },

    WsClose {
        uri: Uri,
        socket_addr: SocketAddr,
        headers: HeaderMap,
    },

    SetDefaultHttpRoute {
        req_tx: HttpReqSender,
        task: JoinHandle<()>,
        opt_return: OneshotSender<IoResult<()>>,
    },

    RemoveDefaultHttpRoute {
        opt_return: OneshotSender<IoResult<()>>,
    },
}