Struct MemoryBus 

pub struct MemoryBus {
    pub pubsub: Arc<dyn Pubsub>,
    pub request_reply: Arc<dyn RequestReply>,
    pub kv: Arc<dyn KvStore>,
    pub jobs: Arc<dyn JobQueue>,
}

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

Fields

pubsub: Arc<dyn Pubsub>

Pub/sub.

request_reply: Arc<dyn RequestReply>

Synchronous request/reply, riding on pubsub.

kv: Arc<dyn KvStore>

KV store.

jobs: Arc<dyn JobQueue>

Durable job queue with DLQ + dedup-CAS, riding on pubsub + kv.

Implementations

impl MemoryBus

pub fn new() -> Self

Build a fresh in-process bus.

pub fn shared() -> Arc<Self>

Capability-shaped default — build a fresh in-process bus and wrap it in Arc for cheap cross-task sharing.

Equivalent to Arc::new(MemoryBus::new()). Lead-with this constructor when wiring agents that hold the bus behind an Arc<MemoryBus>; reach for Self::new when you want owned access to the four trait handles via field destructuring.

Trait Implementations

impl Default for MemoryBus

fn default() -> Self

Returns the “default value” for a type.

impl From<MemoryBus> for BusHandles

fn from(value: MemoryBus) -> Self

Converts to this type from the input type.