Struct MemoryEventBus 

pub struct MemoryEventBus { /* private fields */ }

In-memory event bus using tokio broadcast channels.

Events are only broadcast within a single process. If you have multiple server replicas, they will NOT receive each other’s events.

Implementations

impl MemoryEventBus

pub fn new() -> Self

Trait Implementations

impl Default for MemoryEventBus

fn default() -> Self

Returns the “default value” for a type.

impl EventBus for MemoryEventBus

fn publish<'life0, 'life1, 'async_trait>( &'life0 self, env_id: &'life1 EnvironmentId, event: SecretChangeEvent, ) -> Pin<Box<dyn Future<Output = Result<(), EventBusError>> + Send + 'async_trait>>

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

Publish a secret change event to all watchers of this environment.

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, env_id: &'life1 EnvironmentId, ) -> Pin<Box<dyn Future<Output = Result<EventStream, EventBusError>> + Send + 'async_trait>>

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

Subscribe to secret change events for an environment.