Struct RedisIdempotencyStore 

pub struct RedisIdempotencyStore { /* private fields */ }

IdempotencyStore in Redis. Pair it with Idempotency::shared_seed so all instances hash scopes and payloads alike. Fails closed: when Redis is unreachable requests get 503.

Implementations

impl RedisIdempotencyStore

pub fn new(redis: Redis) -> Self

pub fn prefix(self, prefix: impl Into<String>) -> Self

Trait Implementations

impl IdempotencyStore for RedisIdempotencyStore

fn begin<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, fingerprint: u64, lock_ttl: Duration, ) -> Pin<Box<dyn Future<Output = Begin> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Claim key for a request with this fingerprint. A claim that is never completed must lapse after lock_ttl.

fn complete<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, response: StoredResponse, ttl: Duration, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Keep response for ttl

fn abandon<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Forget a claim so the request can be retried