Struct PostgresTaskStore 

pub struct PostgresTaskStore { /* private fields */ }

PostgreSQL durable-task attribution with atomic, once-only claims.

Implementations

impl PostgresTaskStore

pub fn new(pool: PgPool, ttl: Duration) -> Result<Self, StoreConfigError>

Construct a store from an application-owned connection pool.

ttl must outlive the longest task the upstream server can run, not the client’s polling interval. A task that outlives it bills zero. See the crate-level notes.

Errors

Returns StoreConfigError::InvalidTtl when the TTL is zero or cannot be represented by PostgreSQL’s signed interval input.

pub fn with_timeout( pool: PgPool, ttl: Duration, operation_timeout: Duration, ) -> Result<Self, StoreConfigError>

Construct a store with an explicit bound for every database operation.

Errors

Returns a configuration error for an invalid TTL or zero timeout.

pub async fn install(&self) -> Result<(), StoreConfigError>

Install the idempotent table and expiry index.

Safe to call concurrently from every instance of a horizontally scaled application, which is the situation this store exists for. CREATE TABLE IF NOT EXISTS is not atomic in PostgreSQL: racing sessions check the catalog, all decide the table is absent, and every loser fails with a duplicate key violation on pg_type_typname_nsp_index. A transaction scoped advisory lock serializes the check so late arrivals simply find the table already present and do nothing.

Applications with migration-controlled schemas can apply schema/postgres.sql themselves and skip this operation.

Errors

Returns a sanitized schema error without exposing connection details.

pub async fn prune_expired(&self) -> Result<u64, TaskStoreError>

Delete expired task origins and return the affected row count.

The application must call this on a timer. Unlike Redis, Postgres has no native expiry: every read filters on expires_at, so nothing is served stale, but the rows themselves stay until something deletes them and the table otherwise grows without bound.

Errors

Returns a sanitized backend error.

Trait Implementations

impl Clone for PostgresTaskStore

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PostgresTaskStore

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

Formats the value using the given formatter.

impl TaskAttributionStore for PostgresTaskStore

fn insert<'a>( &'a self, tenant_id: &'a str, task_id: &'a str, attribution: TaskAttribution, ) -> TaskStoreFuture<'a, ()>

Associate a task with its resolved price and fixed origin category.

fn get<'a>( &'a self, tenant_id: &'a str, task_id: &'a str, ) -> TaskStoreFuture<'a, Option<TaskAttribution>>

Resolve an association without consuming it.

fn claim<'a>( &'a self, tenant_id: &'a str, task_id: &'a str, ) -> TaskStoreFuture<'a, Option<TaskAttribution>>

Atomically consume and return an association.

fn remove<'a>( &'a self, tenant_id: &'a str, task_id: &'a str, ) -> TaskStoreFuture<'a, ()>

Remove an association after a terminal task is accounted for.