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 */ }