Struct PgDedupeStore 

pub struct PgDedupeStore { /* private fields */ }

Implementations

impl PgDedupeStore

pub fn new(pool: PgPool, config: PgDedupeStoreConfig) -> Self

pub async fn connect(pool: PgPool, config: PgDedupeStoreConfig) -> Result<Self>

pub async fn prepare_schema( pool: &PgPool, config: &PgDedupeStoreConfig, ) -> Result<()>

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

Trait Implementations

impl Clone for PgDedupeStore

fn clone(&self) -> PgDedupeStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DedupeStore for PgDedupeStore

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.