QueueStorage

Type Alias QueueStorage 

Source
pub type QueueStorage<T> = RedisStorage<T, RefreshingConnection<ConnectionManager>>;
Expand description

Storage type for all queues.

Uses RefreshingConnection instead of a bare ConnectionManager so that connections are dropped/reopened on a bounded lifetime, letting them follow the endpoint’s DNS whenever it changes (e.g. after an ElastiCache failover repoints the endpoint to a new node). Connections are ALSO rebuilt reactively when a reply indicates the connection is pinned to a read-only node, which accelerates recovery; the bounded lifetime remains the guaranteed backstop.

Aliased Type§

pub struct QueueStorage<T> { /* private fields */ }