liminal-rs 0.2.0

A conversation-based messaging bus built on beamr
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

//! Channels: typed, schema-validated, in-memory message buses backed by real
//! supervised beamr actor processes (LIM-002).

pub mod actor;
pub mod observer;
pub mod registry;
pub mod schema;
pub mod subscription;
pub mod supervisor;
pub mod types;
pub mod wire;

pub use observer::ClusterObserver;
pub use registry::{ChannelRegistry, ChannelSummary};
pub use schema::{Schema, SchemaId, SchemaValidationError};
pub use subscription::SubscriptionHandle;
pub use supervisor::{ChannelRestartPolicy, ChannelSupervisor, shared_supervisor};
pub use types::{ChannelConfig, ChannelDelivery, ChannelHandle, ChannelMode, SchemaRef};
pub use wire::{WireError, decode_envelope, encode_envelope};

#[cfg(test)]
mod tests;