redis: Improve ClusterPubSub types (#8627)

This commit is contained in:
Nikita Sobolev
2022-08-27 18:13:46 +03:00
committed by GitHub
parent d1d9b98aff
commit 481027e194

View File

@@ -161,15 +161,22 @@ class NodesManager:
def reset(self) -> None: ...
class ClusterPubSub(PubSub):
node: Any
cluster: Any
node: ClusterNode | None
cluster: RedisCluster[Any]
def __init__(
self, redis_cluster, node: Any | None = ..., host: Any | None = ..., port: Any | None = ..., **kwargs
self,
redis_cluster: RedisCluster[Any],
node: ClusterNode | None = ...,
host: str | None = ...,
port: int | None = ...,
**kwargs,
) -> None: ...
def set_pubsub_node(self, cluster, node: Any | None = ..., host: Any | None = ..., port: Any | None = ...) -> None: ...
def get_pubsub_node(self): ...
def set_pubsub_node(
self, cluster: RedisCluster[Any], node: ClusterNode | None = ..., host: str | None = ..., port: int | None = ...
) -> None: ...
def get_pubsub_node(self) -> ClusterNode | None: ...
def execute_command(self, *args, **kwargs) -> None: ...
def get_redis_connection(self): ...
def get_redis_connection(self) -> Redis[Any] | None: ...
class ClusterPipeline(RedisCluster[_StrType], Generic[_StrType]):
command_stack: list[Incomplete]