Struct BusManager 

pub struct BusManager { /* private fields */ }

Manager for all event buses in the system Supports multiple bus types for different streaming semantics

Implementations

impl BusManager

pub fn new() -> Self

pub fn with_capacity(capacity: usize) -> Self

pub async fn get_or_create_state_bus( &self, view_id: &str, key: &str, ) -> Receiver<Arc<Bytes>>

Get or create a state bus (latest-value semantics) Each (view_id, key) pair gets its own watch channel

pub async fn get_or_create_kv_bus( &self, view_id: &str, ) -> Receiver<Arc<BusMessage>>

Get or create a KV bus (key-value semantics with broadcast)

pub async fn get_or_create_list_bus( &self, view_id: &str, ) -> Receiver<Arc<BusMessage>>

Get or create a list bus (append-only semantics)

pub async fn publish_state(&self, view_id: &str, key: &str, frame: Arc<Bytes>)

Publish to a state bus (latest-value)

pub async fn publish_kv(&self, view_id: &str, message: Arc<BusMessage>)

Publish to a KV bus

pub async fn publish_list(&self, view_id: &str, message: Arc<BusMessage>)

Publish to a list bus

Trait Implementations

impl Clone for BusManager

fn clone(&self) -> BusManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for BusManager

fn default() -> Self

Returns the “default value” for a type.