ruststream 0.4.0

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.
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

//! Colored console logging with zero boilerplate.
//!
//! ```text
//! RUST_LOG=ruststream=debug,info cargo run --example logging \
//!     --features macros,memory,json,logging -- run
//! ```
//!
//! The `#[ruststream::app]` CLI installs the logger automatically on `run`, so the events RustStream
//! emits during dispatch (and the one below) show up with colored levels. Set `RUST_LOG` to tune
//! verbosity; without it the default `info` filter applies.

use ruststream::memory::MemoryBroker;
use ruststream::runtime::{AppInfo, HandlerResult, RustStream};
use ruststream::subscriber;
use serde::Deserialize;

#[derive(Debug, Deserialize)]
struct Order {
    id: u64,
}

#[subscriber("orders")]
async fn handle(order: &Order) -> HandlerResult {
    tracing::info!(order.id, "processing order");
    HandlerResult::Ack
}

#[ruststream::app]
fn app() -> RustStream {
    RustStream::new(AppInfo::new("orders", "0.1.0"))
        .with_broker(MemoryBroker::new(), |b| b.include(handle))
}