devsper-bus 0.2.0

Distributed AI Swarm Runtime
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
38
39
40
41
42

# devsper-bus

Message bus backends for the devsper runtime. Implements the `Bus` trait from `devsper-core` with pluggable backends.

## Backends

| Backend | Feature flag | Use case |
|---------|-------------|----------|
| `InMemoryBus` | _(always on)_ | Single-process, testing |
| `RedisBus` | `redis` | Multi-node distributed execution |
| `KafkaBus` | _(stub)_ | High-throughput future use |

## Usage

```toml
[dependencies]
devsper-bus = "0.1"
# For Redis support:
devsper-bus = { version = "0.1", features = ["redis"] }
```

```rust
use devsper_bus::create_bus;
use devsper_core::{Bus, BusMessage};

// "memory" → InMemoryBus, "redis://..." → RedisBus
let bus = create_bus("memory");

bus.subscribe("task.ready", Box::new(|msg| Box::pin(async move {
    println!("task ready: {:?}", msg);
}))).await?;

bus.publish(BusMessage {
    topic: "task.ready".into(),
    payload: serde_json::json!({ "node_id": "fetch" }),
    run_id: "run-123".into(),
}).await?;
```

## License

GPL-3.0-or-later — see [repository](https://github.com/devsper-com/runtime).