Struct RedisTaskStore 

pub struct RedisTaskStore { /* private fields */ }

Redis or Valkey durable-task attribution with atomic, once-only claims.

Implementations

impl RedisTaskStore

pub async fn connect( connection_url: &str, key_prefix: impl Into<String>, ttl: Duration, ) -> Result<Self, StoreConfigError>

Connect with a reconnecting, multiplexed async connection manager.

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 a sanitized error for invalid configuration or connection failure. Connection URLs are never retained for debug output.

pub async fn connect_with_timeout( connection_url: &str, key_prefix: impl Into<String>, ttl: Duration, operation_timeout: Duration, ) -> Result<Self, StoreConfigError>

Connect with an explicit bound for connection and command operations.

Errors

Returns a sanitized error for invalid configuration or connection failure. Connection URLs are never retained for debug output.

Trait Implementations

impl Clone for RedisTaskStore

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 RedisTaskStore

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

Formats the value using the given formatter.

impl TaskAttributionStore for RedisTaskStore

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.