Crate klieo_bus_memory 

In-process implementations of klieo-core’s bus traits (Pubsub, RequestReply, KvStore, JobQueue).

Use this crate for tests, single-binary applications, and local dev. For production multi-process deployment use klieo-bus-nats.

Limitations

• No durability across process restart. Pubsub messages and queued jobs live in process memory.
• Pubsub AckHandle is a no-op. In-process pubsub has no redelivery semantics; the trait surface is preserved for consistency but ack / nak / term succeed without effect.
• JobQueue lease-expiry is lazy — checked on the next claim() call, not via a background task. Sufficient for tests and single-binary apps where claim cadence is high.

Quickstart

use klieo_bus_memory::MemoryBus;
let bus = MemoryBus::new();
// bus.pubsub, bus.kv, bus.request_reply, bus.jobs are
// Arc<dyn …> ready to drop into AgentContext.

Structs

MemoryBus

Wired-together in-process bus. Build once, share across agents.

MemoryJobQueue

In-process JobQueue impl.

MemoryKv

In-process KvStore impl.

MemoryPubsub

In-process Pubsub impl.

MemoryRequestReply

In-process RequestReply impl.