Struct InMemoryLiveReplayStore 

pub struct InMemoryLiveReplayStore { /* private fields */ }

Implementations

impl InMemoryLiveReplayStore

pub fn new(config: InMemoryLiveReplayStoreConfig) -> Self

pub fn with_bounds(max_events_per_session: usize, max_age: Duration) -> Self

Trait Implementations

impl Debug for InMemoryLiveReplayStore

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

Formats the value using the given formatter.

impl Default for InMemoryLiveReplayStore

fn default() -> Self

Returns the “default value” for a type.

impl LiveReplayStore for InMemoryLiveReplayStore

fn append( &self, session_id: &str, revision: SessionRevision, payload: SessionObservationEventPayload, ) -> Result<SessionObservationEvent, LiveReplayStoreError>

Append one observation event and return its assigned cursor.

fn replay_after_cursor( &self, cursor: &SessionCursor, ) -> Result<LiveReplayResult, LiveReplayStoreError>

Return buffered events after cursor, or report a recoverable gap.

fn subscribe_after_cursor( &self, cursor: &SessionCursor, ) -> Result<LiveReplaySubscribeResult, LiveReplayStoreError>

Subscribe after cursor, replaying buffered events before live events.

fn current_cursor( &self, session_id: &str, revision: SessionRevision, ) -> SessionCursor

Return the latest cursor known locally for a session.

fn trim_session(&self, session_id: &str) -> Result<(), LiveReplayStoreError>

Apply best-effort retention trimming for a session.