faust.web.cache.backends.redis

Redis cache backend.

class faust.web.cache.backends.redis.RedisScheme[source]

Types of Redis configurations.

SINGLE_NODE = 'redis'
CLUSTER = 'rediscluster'
class faust.web.cache.backends.redis.CacheBackend(app: faust.types.app.AppT, url: Union[yarl.URL, str], *, connect_timeout: float = None, stream_timeout: float = None, max_connections: int = None, max_connections_per_node: int = None, **kwargs: Any) → None[source]

Backend for cache operations using Redis.

async on_start() → None[source]

Call when Redis backend starts.

Return type

None

async connect() → None[source]

Connect to Redis/Redis Cluster server.

Return type

None

client[source]

Return Redis client instance.