devsper-bus 0.1.0

Distributed AI Swarm Runtime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

pub mod kafka;
pub mod memory;
pub mod redis;

pub use memory::InMemoryBus;

use devsper_core::Bus;
use std::sync::Arc;

/// Create a bus from a config string.
/// "memory"      → InMemoryBus
/// "redis://..."  → stub (returns error until Phase 8)
/// "kafka://..."  → stub
pub fn create_bus(_config: &str) -> Arc<dyn Bus> {
    Arc::new(InMemoryBus::new())
}