faust.web.cache.backends.redis

Redis cache backend.

class faust.web.cache.backends.redis.RedisScheme(value)

Types of Redis configurations.

SINGLE_NODE = 'redis'

CLUSTER = 'rediscluster'

class faust.web.cache.backends.redis.CacheBackend(app: AppT, url: Union[URL, str], *, connect_timeout: Optional[float] = None, stream_timeout: Optional[float] = None, max_connections: Optional[int] = None, max_connections_per_node: Optional[int] = None, **kwargs: Any)

Backend for cache operations using Redis.

connect_timeout: Optional[float]

stream_timeout: Optional[float]

max_connections: Optional[int]

max_connections_per_node: Optional[int]

async on_start() → None

Call when Redis backend starts.

Return type:

None

async connect() → None

Connect to Redis/Redis Cluster server.

Return type:

None

client

Return Redis client instance.