klieo-bus-memory

In-process Pubsub / RequestReply / KvStore / JobQueue impls for klieo-core.

Part of the klieo Rust agent framework.

Features

• All four bus traits on a single in-process implementation
• Zero configuration — ideal for single-process dev and tests
• Swap for klieo-bus-nats in production without changing agent code

Quickstart

[dependencies]
klieo-bus-memory = "2"

use klieo_bus_memory::MemoryBus;

let bus = MemoryBus::shared();
// bus.pubsub / bus.request_reply / bus.kv / bus.jobs are all
// Arc<dyn …> handles cheap to clone across tasks.

MemoryBus::shared() returns Arc<MemoryBus> — pass to agents holding the bus behind an Arc. For owned access to the four trait handles via field destructuring, reach for MemoryBus::new() directly.

Status

2.x — stable. See docs/SEMVER.md.

License

MIT — see LICENSE.