oxide-mesh 0.3.0

Inter-agent communication for Rust Oxide. Tokio-channel mesh for in-process federation plus a JSON-framed TCP transport for cross-host peers; ties into oxide-k via the message bus.
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

//! Error type.

use thiserror::Error;

/// All errors produced by the mesh.
#[derive(Debug, Error)]
pub enum MeshError {
    /// I/O failure (TCP transport).
    #[error("io error: {0}")]
    Io(#[from] std::io::Error),

    /// JSON (de)serialization.
    #[error("json error: {0}")]
    Json(#[from] serde_json::Error),

    /// Peer was not found in the local registry.
    #[error("unknown peer `{0}`")]
    UnknownPeer(String),

    /// Wrapped kernel error.
    #[error("kernel error: {0}")]
    Kernel(#[from] oxide_k::KernelError),

    /// Catch-all.
    #[error(transparent)]
    Other(#[from] anyhow::Error),
}

/// Convenience alias.
pub type Result<T> = std::result::Result<T, MeshError>;