devsper_bus/lib.rs
1pub mod kafka;
2pub mod memory;
3pub mod redis;
4
5pub use memory::InMemoryBus;
6
7use devsper_core::Bus;
8use std::sync::Arc;
9
10/// Create a bus from a config string.
11/// "memory" → InMemoryBus
12/// "redis://..." → stub (returns error until Phase 8)
13/// "kafka://..." → stub
14pub fn create_bus(_config: &str) -> Arc<dyn Bus> {
15 Arc::new(InMemoryBus::new())
16}