Struct SqliteCheckpointStore 

pub struct SqliteCheckpointStore { /* private fields */ }

Implementations

impl SqliteCheckpointStore

pub fn new(config: SqliteConfig) -> Result<Self, SqliteEventStoreError>

pub fn in_memory() -> Result<Self, SqliteEventStoreError>

pub async fn migrate(&self) -> Result<(), SqliteEventStoreError>

Trait Implementations

impl CheckpointStore for SqliteCheckpointStore

type Error = SqliteCheckpointError

Error type returned by checkpoint operations.

async fn load(&self, name: &str) -> Result<Option<StreamPosition>, Self::Error>

Load the last saved checkpoint position for a subscription.

async fn save( &self, name: &str, position: StreamPosition, ) -> Result<(), Self::Error>

Save a checkpoint position for a subscription.

impl Debug for SqliteCheckpointStore

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

Formats the value using the given formatter.