EventBase

An application-level event-driven framework for Rust — type-safe, macro-driven, and built for reliability.

event_base lets you define message handlers, compose middleware pipelines, and orchestrate events inside your Rust application. It is not a distributed message queue — it focuses on in-process event orchestration with persistence, observability, and graceful shutdown built in.

Features

Quick Start

use event_base::prelude::*;

#[handler(topic = "order", workers = 2)]
async fn handle_order(msg: &EMessage) -> Ack {
    println!("Received order: {:?}", msg);
    Ack::Ack
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let wal = event_base::memory_wal::MemoryWal::new();
    start_queue_system! {
        factory: MemoryQueueFactory::new(1000),
        wal: Some(wal),
    }
    send_msg!("order", EMessage::new("order", b"hello".to_vec())).await?;
    Ok(())
}

Installation

cargo add event_base

Enable features as needed:

[dependencies]
event_base = { version = "0.1", features = ["full"] }

Feature flags

Performance

Benchmarks measured with criterion (see event_base_test/benches/).

Queue benchmarks

System send benchmarks

System process benchmarks (10K messages)

Parallel processing (10K messages)

Full pipeline (10K messages)

Documentation

• Quick Start
• Core Concepts
• Handlers
• Middleware
• Sending Messages
• Persistence & WAL
• Shutdown Strategies
• Distributed Mode
• Architecture
• API Reference

License

BSD-3-Clause. See LICENSE.