Struct MemoryProvider 

pub struct MemoryProvider { /* private fields */ }

In-memory event provider

Uses tokio::sync::broadcast for pub/sub and a Vec for persistence. Suitable for testing, development, and single-process deployments.

Implementations

impl MemoryProvider

pub fn new(config: MemoryConfig) -> Self

Create a new in-memory provider

Trait Implementations

impl Default for MemoryProvider

fn default() -> Self

Returns the “default value” for a type.

impl EventProvider for MemoryProvider

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

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

Publish an event, returning the provider-assigned sequence number

fn subscribe_durable<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _consumer_name: &'life1 str, filter_subject: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Subscription>>> + Send + 'async_trait>>

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

Create a durable subscription (survives reconnects)

fn subscribe<'life0, 'life1, 'async_trait>( &'life0 self, filter_subject: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Subscription>>> + Send + 'async_trait>>

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

Create an ephemeral subscription (cleaned up on disconnect)

fn history<'life0, 'life1, 'async_trait>( &'life0 self, filter_subject: Option<&'life1 str>, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Event>>> + Send + 'async_trait>>

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

Fetch historical events from the backend

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

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

Delete a durable subscription by consumer name

fn info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ProviderInfo>> + Send + 'async_trait>>

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

Get provider info (message count, etc.)

fn subject_prefix(&self) -> &str

Subject prefix for this provider (e.g., “events”)

fn name(&self) -> &str

Provider name (e.g., “nats”, “memory”, “redis”)

fn build_subject(&self, category: &str, topic: &str) -> String

Build a full subject from category and topic

fn category_subject(&self, category: &str) -> String

Build a wildcard subject for a category

fn publish_with_options<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, event: &'life1 Event, _opts: &'life2 PublishOptions, ) -> Pin<Box<dyn Future<Output = Result<u64>> + Send + 'async_trait>>

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

Publish an event with provider-specific options

fn subscribe_durable_with_options<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, consumer_name: &'life1 str, filter_subject: &'life2 str, _opts: &'life3 SubscribeOptions, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Subscription>>> + Send + 'async_trait>>

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

Create a durable subscription with provider-specific options

fn subscribe_with_options<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, filter_subject: &'life1 str, _opts: &'life2 SubscribeOptions, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Subscription>>> + Send + 'async_trait>>

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

Create an ephemeral subscription with provider-specific options

fn health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Health check — returns true if the provider is connected and operational