redis-swapplex

Redis multiplexing with reconnection notifications and MGET auto-batching

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 - ENV configuration simplifies kubernetes usage - Reconnects can be observed allowing for Redis server-assisted client-side caching using client tracking redirection - Integrated MGET auto-batching (up to 180x more performant than GET)

ENV Configuration

Composible connection urls are provided by environment variables using env-url with the REDIS prefix:

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

Override env mapping for easy kubernetes config

REDISHOSTENV=MONOLITHSTAGEREDISMASTERPORT6379TCPADDR REDISPORTENV=MONOLITHSTAGEREDISMASTERSERVICEPORT_REDIS ```

Example

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

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

Runtime Configuration (optional)

For best performance, use the Tokio runtime as configured via the tokio::main or tokio::test macro with the crate attribute set to async_local while the barrier-protected-runtime feature is enabled on async-local. Doing so configures the Tokio runtime with a barrier that rendezvous runtime worker threads during shutdown in a way that ensures tasks never outlive thread local data owned by runtime worker threads and obviates the need for Box::leak as a means of lifetime extension.

Stable Usage

This crate conditionally makes use of typealiasimpltrait and impltraitinassoctype 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.