aurelia 0.1.0

Embeddable service mesh for Rust distributed 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

// This file is part of the Aurelia workspace.
// SPDX-FileCopyrightText: 2026 Zivatar Limited
// SPDX-License-Identifier: Apache-2.0

//! Aurelia peering transport.

#![allow(unused_imports, dead_code, clippy::module_inception)]

mod address;
mod auth;
mod blob_io;
mod callis;
mod codec;
mod config;
mod delivery;
mod domus;
mod limiter;
mod message_id;
mod observability;
mod peering;
mod reliability;
pub mod ring_buffer;
mod routing;
mod send;
mod session;
mod simpleresolver;
mod taberna;
mod transport;
mod wire;

#[cfg(feature = "actix")]
mod actix_adapter;

pub use crate::ids::{
    log_ids, AureliaError, ErrorId, LogId, MessageType, PeerMessageId, TabernaId, MSG_ACK,
    MSG_BLOB_TRANSFER_CHUNK, MSG_BLOB_TRANSFER_COMPLETE, MSG_BLOB_TRANSFER_START, MSG_CLOSE,
    MSG_ERROR, MSG_HELLO, MSG_HELLO_RESPONSE, MSG_KEEPALIVE,
};
pub use address::{DomusAddr, TransportKind};
pub use auth::{DomusAuthConfig, Pkcs8AuthConfig, Pkcs8DerConfig, Pkcs8PemConfig};
pub use blob_io::{BlobReceiver, BlobSender};
pub use codec::{decode_error, encode_error, EncodedMessage, MessageCodec};
pub use config::{DomusConfig, DomusConfigAccess, DomusConfigBuilder};
pub use domus::{Domus, DomusBuilder};
pub use observability::{
    BlobCallisSettingsReport, CallisId, DisconnectReason, DomusMetrics, DomusMetricsDelta,
    DomusReporting, DomusReportingEvent, DomusReportingFeeds, HandshakePhase, PeerIdentityReport,
    RestartReason,
};
pub use routing::RouteResolver;
pub use send::{SendOptions, SendOutcome};
pub use simpleresolver::SimpleResolver;
pub use taberna::{Taberna, TabernaInbox, TabernaRequest};

#[cfg(feature = "actix")]
pub use actix_adapter::ActixTabernaSink;

#[cfg(test)]
mod tests;