bakbon 0.1.2

BakBon is an infrastructure microkernel library in Rust that provides generic building blocks (Router, Registry, Balancer, Queue, Gateway, Cache, Middleware, Service/Processor) for message‑driven distributed systems.
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

//! Message primitives for BakBon.
//!
//! This module defines the core message types used inside the system:
//!
//! - [`Envelope`] represents an application-level message with `Payload`
//!   and routing  metadata.
//! - [Headers] is a map of string key/value pairs attached to an
//!   [`Envelope`].
//! - [Reply] models a optional reply message returned by
//!   [`Processor`](crate::Processor)
//!
//! High level components such as [`Gateway`](crate::Gateway),
//! [`Service`](crate::Service), [`Router`](crate::Router) build on top of
//! these primitives to exchange data between each other.

mod envelope;
mod route;

pub use envelope::Envelope;
use {
    bytes::Bytes,
    std::collections::HashMap,
};

/// Message metadata attached to an [`Envelope`](super::Envelope)
///
/// `Headers` are arbitrary key/value pairs. Some examples include:
/// - `content-type`
/// - `encoding`
/// - `x-correlation-id`
pub type Headers = HashMap<String, String>;

/// Optional reply message returned by a [`Processor`](crate::Processor)
pub type Reply = Option<Envelope>;

/// Message payload attached to an [`Envelope`](super::Envelope)
pub type Payload = Bytes;