malkuth 0.1.0

A composable service-supervision toolkit for Rust
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

//! Wire-level transport trait contracts.
//!
//! A [`WireConn`] is a framed connection: it reads/writes one JSON value per
//! message. The generic [`FramedConn<S>`] in [`crate::codec`] adapts any
//! `tokio::io` duplex stream into a `WireConn`.

use serde_json::Value;
use std::io;

use async_trait::async_trait;

/// A framed, object-safe JSON-RPC connection.
#[async_trait]
pub trait WireConn: Send {
    async fn read_msg(&mut self) -> io::Result<Option<Value>>;
    async fn write_msg(&mut self, msg: &Value) -> io::Result<()>;
}

/// A server-side listener that yields accepted [`WireConn`]s.
#[async_trait]
pub trait WireListener: Send + Sync {
    async fn accept(&self) -> io::Result<Box<dyn WireConn>>;
    fn local_addr(&self) -> io::Result<String>;
}

/// A connection factory + listener factory addressed by string.
#[async_trait]
pub trait Transport: Send + Sync {
    async fn listen(&self, addr: &str) -> io::Result<Box<dyn WireListener>>;
    async fn connect(&self, addr: &str) -> io::Result<Box<dyn WireConn>>;
    fn name(&self) -> &'static str;
}