Struct SqliteSessionStore 

pub struct SqliteSessionStore { /* private fields */ }

Implementations

impl SqliteSessionStore

pub fn open(path: impl AsRef<Path>) -> StoreResult<Self>

pub fn open_in_memory() -> StoreResult<Self>

pub fn open_with_hooks( path: impl AsRef<Path>, hooks: StoreHooks, ) -> StoreResult<Self>

pub fn path(&self) -> &Path

Trait Implementations

impl Clone for SqliteSessionStore

fn clone(&self) -> SqliteSessionStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl SessionStore for SqliteSessionStore

fn hooks(&self) -> &StoreHooks

Plug-in processors configured for this store. The default Self::sweep_retention reads hooks.archive_sink so the retention loop can hand archived sessions to durable storage without callers wiring the sink explicitly.

fn create<'life0, 'async_trait>( &'life0 self, request: CreateSession, ) -> Pin<Box<dyn Future<Output = StoreResult<SessionMeta>> + Send + 'async_trait>>

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

fn describe<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StoreResult<SessionMeta>> + Send + 'async_trait>>

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

fn list<'life0, 'async_trait>( &'life0 self, filter: ListFilter, ) -> Pin<Box<dyn Future<Output = StoreResult<Vec<SessionMeta>>> + Send + 'async_trait>>

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

fn append<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, event: AppendEvent, ) -> Pin<Box<dyn Future<Output = StoreResult<StoredEvent>> + Send + 'async_trait>>

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

fn read<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, range: ReadRange, ) -> Pin<Box<dyn Future<Output = StoreResult<EventPage>> + Send + 'async_trait>>

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

fn fork<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, at_event_id: EventId, child_id: Option<SessionId>, ) -> Pin<Box<dyn Future<Output = StoreResult<ForkResult>> + Send + 'async_trait>>

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

fn truncate<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, at_event_id: EventId, ) -> Pin<Box<dyn Future<Output = StoreResult<TruncateResult>> + Send + 'async_trait>>

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

fn snapshot<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StoreResult<Snapshot>> + Send + 'async_trait>>

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

fn replay<'life0, 'life1, 'async_trait>( &'life0 self, snapshot_id: &'life1 SnapshotId, ) -> Pin<Box<dyn Future<Output = StoreResult<Snapshot>> + Send + 'async_trait>>

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

fn close<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StoreResult<StoredEvent>> + Send + 'async_trait>>

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

fn soft_delete<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StoreResult<SessionMeta>> + Send + 'async_trait>>

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

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

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

fn verify<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = StoreResult<VerifyReport>> + Send + 'async_trait>>

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

fn sweep_retention<'life0, 'life1, 'async_trait>( &'life0 self, policy: &'life1 RetentionPolicy, now_ms: i64, ) -> Pin<Box<dyn Future<Output = StoreResult<SweepReport>> + Send + 'async_trait>>

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

Sweep retention. Backends with native scheduling can override to skip the default loop; the default sweeps all sessions against the configured RetentionPolicy and routes archived sessions + tombstones through hooks().archive_sink when set.