redis-swapplex

Redis multiplexing with reconnection notifications and MGET auto-batching. Connection configuration is provided by env-url.

Why use this instead of redis::aio::ConnectionManager? - Error-free reconnection behavior: when a command would otherwise fail as a consequence of the connection being dropped, this library will immediately reconnect and retry when able without producing an otherwise avoidable IoError and with subsequent reconnections debounced 1500ms - Less contention overhead: the usage of arc_swap::cache::Cache results in a 10-25x speed up of cached connection acquisition. - ENV configuration makes life easier and simplifies kubernetes usage - Reconnects can be observed, thus allowing for Redis server-assisted client-side caching using client tracking redirection - Integrated MGET auto-batching (up to 180x more performant than GET)

```` REDIS_URL=redis://127.0.0.1:6379

Override env mapping for easy kubernetes config

REDISHOSTENV=MONOLITHSTAGEREDISMASTERPORT6379TCPADDR REDISPORTENV=MONOLITHSTAGEREDISMASTERSERVICEPORT_REDIS ```

```rust use redis::{AsyncCommands, RedisResult}; use redisswapplex::getconnection;

async fn getvalue(key: &str) -> RedisResult { let mut conn = getconnection(); conn.get(key).await } ```

Runtime Configuration

By utilizing a barrier to guard thread local data destruction until runtime threads rendezvous during shutdown, it becomes possible to create thread-safe pointers to thread-local data owned by runtime worker threads. In order for async-local to protect thread local data within an async context, the provided barrier-protected Tokio Runtime must be used to ensure tasks never outlive thread local data owned by worker threads. By default, this crate makes no assumptions about the runtime used, and comes with the leaky-context feature flag enabled which prevents Context from ever deallocating by using Box::leak; to avoid this extra indirection, disable leaky-context and configure the runtime using the tokio::main or tokio::test macro with the crate attribute set to async_local with only the barrier-protected-runtime feature flag set on async-local.

Stable Usage

This crate conditionally makes use of the nightly only feature typealiasimpltrait to allow async fns in traits to be unboxed. To compile on stable the boxed feature flag can be used to downgrade asynct::asynctrait to asynctrait::async_trait.