Struct InMemoryBackplane 

pub struct InMemoryBackplane { /* private fields */ }

Single-process Backplane: an in-memory registry with direct local delivery. The default — keeps the server runnable standalone. Multi-pod deployments install a Redis / NATS impl instead.

Implementations

impl InMemoryBackplane

pub fn new() -> Self

pub fn connection_count(&self) -> usize

Test/inspection helper: number of attached connections.

Trait Implementations

impl Backplane for InMemoryBackplane

fn attach<'life0, 'life1, 'async_trait>( &'life0 self, conn_id: &'life1 str, sink: LocalSink, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Attach a connection’s local outbound sink — this pod owns the socket. Idempotent re-attach replaces the sink. The connection is always reachable by Target::Connection with its own id.

fn detach<'life0, 'life1, 'async_trait>( &'life0 self, conn_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Detach a connection and drop all of its target associations and its local sink (call on disconnect).

fn associate<'life0, 'life1, 'async_trait>( &'life0 self, conn_id: &'life1 str, target: Target, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Associate a connection with a target (idempotent). Learned over the connection’s life: the session at create_conversation_session, the user/org from auth, etc.

fn publish<'life0, 'async_trait>( &'life0 self, target: Target, event: Value, ) -> Pin<Box<dyn Future<Output = usize> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Deliver event to every connection associated with target. Returns the number of local deliveries made on this pod; cross-pod impls also fan the event out to other pods (whose local deliveries this count omits).

impl Default for InMemoryBackplane

fn default() -> InMemoryBackplane

Returns the “default value” for a type.