Struct EventStore 

pub struct EventStore { /* private fields */ }

Thread-safe event store for SSE resumability.

Stores events per stream with automatic expiration and size limits. Use this to enable clients to resume SSE streams after disconnection.

Thread Safety

The EventStore uses RwLock internally and is safe for concurrent access from multiple threads.

Implementations

impl EventStore

pub fn new() -> EventStore

Creates a new event store with default configuration.

pub fn with_config(config: EventStoreConfig) -> EventStore

Creates a new event store with custom configuration.

pub fn config(&self) -> &EventStoreConfig

Returns the configuration.

pub fn store_event(&self, stream_id: &str, data: Option<Value>) -> String

Stores an event and returns its ID.

Arguments

• stream_id - The stream (session) this event belongs to
• data - Event data, or None for a priming event

Returns

The unique event ID that can be used for resumption.

pub fn store_priming_event(&self, stream_id: &str) -> String

Stores a priming event (empty data) for SSE initialization.

Per SSE spec, servers should send an event with just an ID to prime the client’s Last-Event-ID tracking.

pub fn get_events_after( &self, stream_id: &str, after_id: Option<&str>, ) -> Vec<EventEntry>

Gets events after the specified event ID.

Arguments

• stream_id - The stream to get events from
• after_id - Get events after this ID (exclusive). None returns all events.

Returns

Vector of events in chronological order.

pub fn replay_events_after<F>( &self, last_event_id: &str, callback: F, ) -> Option<String>

where F: FnMut(&EventEntry),

Replays events after a specific event ID using a callback.

This is the primary method for SSE resumption. When a client reconnects with a Last-Event-ID, use this to replay missed events.

Arguments

• last_event_id - The client’s last received event ID
• callback - Called for each event to replay

Returns

The stream ID if the event was found, None otherwise.

pub fn find_stream_for_event(&self, event_id: &str) -> Option<String>

Looks up the stream ID for a given event ID.

Returns

The stream ID if the event exists, None otherwise.

pub fn clear_stream(&self, stream_id: &str)

Removes all events for a stream.

Call this when a session ends to free memory.

pub fn cleanup_expired(&self)

Removes all expired events across all streams.

This is called automatically during operations, but you can call it manually for cleanup.

pub fn stream_count(&self) -> usize

Returns the number of streams currently stored.

pub fn event_count(&self) -> usize

Returns the total number of events across all streams.

pub fn stats(&self) -> EventStoreStats

Returns statistics about the event store.

Trait Implementations

impl Debug for EventStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for EventStore

fn default() -> EventStore

Returns the “default value” for a type.