Crate 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
• 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)

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
REDIS_HOST_ENV=MONOLITH_STAGE_REDIS_MASTER_PORT_6379_TCP_ADDR
REDIS_PORT_ENV=MONOLITH_STAGE_REDIS_MASTER_SERVICE_PORT_REDIS

use redis::{AsyncCommands, RedisResult};
use redis_swapplex::get_connection;

async fn get_value(key: &str) -> RedisResult<String> {
  let mut conn = get_connection();
  conn.get(key).await
}

Structs

• EnvConnection
  Default env-configured Redis connection manager
• ManagedConnection
  A multiplexed connection utilizing the respective connection manager

Traits

• ConnectionInfo
  Trait for defining redis client creation and db selection
• ConnectionManagerContext
• IntoBytes

Functions

• connection_stream
  A stream notifying whenever the current or a new connection is connected; useful for client tracking redirection
• get
  Get the value of a key using auto-batched MGET commands
• get_connection
  Get a managed multiplexed connection for the default env-configured Redis database
• on_connected
  Notify the next time a connection is established
• set
  Set the value of a key using auto-batched MSET commands

Derive Macros

• ConnectionManagerContext