Struct SqliteDedupeStore 

pub struct SqliteDedupeStore { /* private fields */ }

Implementations

impl SqliteDedupeStore

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

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

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

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

Trait Implementations

impl Clone for SqliteDedupeStore

fn clone(&self) -> SqliteDedupeStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DedupeStore for SqliteDedupeStore

async fn exists(&self, event: &Event) -> Result<bool>

async fn mark_processed(&self, event: &Event) -> Result<()>

async fn mark_if_new(&self, event: &Event) -> Result<bool>

Atomically marks the event as seen, returning whether it was newly recorded (true) or was already present (false). The default implementation calls exists then mark_processed, which is racy across concurrent callers. Backends with native atomicity (e.g., Postgres INSERT ON CONFLICT DO NOTHING) should override.