labrpc 0.2.3

A RPC framework for testing
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

use futures::channel::oneshot::Receiver;

use crate::{ReplyMessage, RequestMessage, Result, RpcOnWire};

pub(crate) mod junk_server;

pub(crate) fn make_aborting_rpc<C: Into<String>, S: Into<String>>(
    client: C,
    server: S,
) -> (RpcOnWire, Receiver<Result<ReplyMessage>>) {
    make_rpc(client, server, junk_server::JunkRpcs::Aborting, &[])
}

pub(crate) fn make_echo_rpc<C: Into<String>, S: Into<String>>(
    client: C,
    server: S,
    data: &[u8],
) -> (RpcOnWire, Receiver<Result<ReplyMessage>>) {
    make_rpc(client, server, junk_server::JunkRpcs::Echo, data)
}

pub(crate) fn make_rpc<C: Into<String>, S: Into<String>>(
    client: C,
    server: S,
    service_method: junk_server::JunkRpcs,
    data: &[u8],
) -> (RpcOnWire, Receiver<Result<ReplyMessage>>) {
    let (tx, rx) = futures::channel::oneshot::channel();
    (
        RpcOnWire {
            client: client.into(),
            server: server.into(),
            service_method: service_method.name(),
            request: RequestMessage::copy_from_slice(data),
            reply_channel: tx,
            #[cfg(feature = "tracing")]
            trace: crate::tracing::TraceHolder::make(),
        },
        rx,
    )
}