dsf-daemon 0.1.3

Distributed Service Framework (DSF) Daemon
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

use std::time::Duration;

pub mod net;
pub use net::{Net, NetError, NetKind, NetMessage};

pub mod unix;
pub use unix::{Unix, UnixError, UnixMessage};

pub mod wire;
pub use wire::{Wire, WireConnector};

pub mod mock;

use dsf_core::prelude::*;

use crate::error::Error;

#[async_trait]
pub trait Connector {
    // Send a request and receive a response or error at some time in the future
    async fn request(
        &self,
        req_id: RequestId,
        target: Address,
        req: NetRequest,
        timeout: Duration,
    ) -> Result<NetResponse, Error>;

    // Send a response message
    async fn respond(
        &self,
        req_id: RequestId,
        target: Address,
        resp: NetResponse,
    ) -> Result<(), Error>;
}