Struct SqliteHttpIdempotencyRepository 

pub struct SqliteHttpIdempotencyRepository { /* private fields */ }

Available on crate feature sqlite only.

SQLite repository over the http_idempotency_keys table.

Implementations

impl SqliteHttpIdempotencyRepository

pub const fn new(pool: Pool<SqliteConnectionManager>) -> Self

Trait Implementations

impl Debug for SqliteHttpIdempotencyRepository

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

Formats the value using the given formatter.

impl HttpIdempotencyRepository for SqliteHttpIdempotencyRepository

fn get( &self, tenant: &str, key: &str, expired_before: DateTime<Utc>, ) -> Result<Option<HttpIdempotencyRecord>>

Fetch the entry for (tenant, key).

fn put(&self, record: &HttpIdempotencyRecord) -> Result<bool>

Insert a new entry. Returns false (without overwriting) when an entry for (tenant, key) already exists — first write wins across replicas.

fn purge_expired(&self, expired_before: DateTime<Utc>) -> Result<u64>

Delete all entries created strictly before expired_before, returning the number of rows removed.