Struct SqlxInvalidationOutbox 

pub struct SqlxInvalidationOutbox { /* private fields */ }

SQLx-backed invalidation outbox.

Implementations

impl SqlxInvalidationOutbox

pub fn sqlite(pool: Pool<Sqlite>) -> SqlxInvalidationOutbox

Build a SQLite-backed outbox.

pub fn postgres(pool: Pool<Postgres>) -> SqlxInvalidationOutbox

Build a Postgres-backed outbox.

pub async fn install_schema(&self) -> Result<(), DbCacheError>

Install the outbox schema if it is missing.

Migrations are copyable and idempotent. Applications may run their own migration system instead; this helper exists for tests and small demos.

pub async fn check_schema(&self) -> Result<(), DbCacheError>

Refuse to operate against missing or unknown future schema versions.

pub async fn enqueue_in_sqlite_tx( &self, tx: &mut Transaction<'_, Sqlite>, namespace: &str, commit_position: &CommitPosition, batch: &InvalidationIntentBatch, ) -> Result<usize, DbCacheError>

Enqueue intent inside an existing SQLite transaction.

pub async fn enqueue_in_postgres_tx( &self, tx: &mut Transaction<'_, Postgres>, namespace: &str, commit_position: &CommitPosition, batch: &InvalidationIntentBatch, ) -> Result<usize, DbCacheError>

Enqueue intent inside an existing Postgres transaction.

pub async fn postgres_commit_position( &self, tx: &mut Transaction<'_, Postgres>, ) -> Result<CommitPosition, DbCacheError>

Read the current Postgres transaction id as a commit-position fallback.

Trait Implementations

impl Clone for SqlxInvalidationOutbox

fn clone(&self) -> SqlxInvalidationOutbox

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqlxInvalidationOutbox

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

Formats the value using the given formatter.

impl InvalidationOutbox for SqlxInvalidationOutbox

fn enqueue<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, namespace: &'life1 str, commit_position: &'life2 CommitPosition, batch: &'life3 InvalidationIntentBatch, ) -> Pin<Box<dyn Future<Output = Result<usize, DbCacheError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, SqlxInvalidationOutbox: 'async_trait,

Enqueue a batch for a namespace and commit position.

fn claim<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace: &'life1 str, owner: &'life2 str, limit: usize, claim_ttl: Duration, ) -> Pin<Box<dyn Future<Output = Result<Vec<OutboxRow>, DbCacheError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SqlxInvalidationOutbox: 'async_trait,

Claim up to limit rows for a worker owner.

fn mark_published<'life0, 'life1, 'async_trait>( &'life0 self, ids: &'life1 [String], ) -> Pin<Box<dyn Future<Output = Result<(), DbCacheError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, SqlxInvalidationOutbox: 'async_trait,

Mark rows published after invalidation was applied.

fn mark_failed<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, id: &'life1 str, error: &'life2 str, backoff: Duration, dead: bool, ) -> Pin<Box<dyn Future<Output = Result<(), DbCacheError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, SqlxInvalidationOutbox: 'async_trait,

Mark one row failed, with retry backoff or dead-letter state.

fn reset_dead_letters<'life0, 'life1, 'async_trait>( &'life0 self, namespace: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<u64, DbCacheError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, SqlxInvalidationOutbox: 'async_trait,

Re-enable all dead-lettered rows for a namespace.

fn status<'life0, 'life1, 'async_trait>( &'life0 self, namespace: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<OutboxStatus, DbCacheError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, SqlxInvalidationOutbox: 'async_trait,

Read-only status snapshot for operators.