Struct SqliteBufferStore 

pub struct SqliteBufferStore<C> { /* private fields */ }

Implementations

impl<C> SqliteBufferStore<C>

pub fn new(conn: SqliteConn, config: SqliteBufferStoreConfig) -> Self

pub fn connect( conn: SqliteConn, config: SqliteBufferStoreConfig, ) -> Result<Self>

pub fn prepare_schema( conn: &SqliteConn, config: &SqliteBufferStoreConfig, ) -> Result<()>

pub fn schema_sql(config: &SqliteBufferStoreConfig) -> String

Trait Implementations

impl<C> BufferStore<C> for SqliteBufferStore<C>

where C: Serialize + DeserializeOwned + Clone + Send + Sync + 'static,

type Id = SqliteBufferStoreId

async fn push(&self, event: &Event, cursor: &C) -> Result<Self::Id>

async fn pending(&self) -> Result<Vec<BufferEntry<C, Self::Id>>>

Returns a snapshot of entries currently held by the store without removing them. Re-calling without ack/nack returns the same set.

async fn ack(&self, id: &Self::Id) -> Result<()>

async fn nack(&self, _id: &Self::Id) -> Result<()>

impl<C> Clone for SqliteBufferStore<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.