faust.web.cache.backends.redis

class faust.web.cache.backends.redis.RedisClientT

class faust.web.cache.backends.redis.RedisScheme

An enumeration.

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) → None

coroutine connect(self) → None

Return type:None

coroutine on_start(self) → None

Called every time before the service is started/restarted.

Return type:None

client