VimPlug/typeshed
1
0
Fork 0
mirror of https://github.com/davidhalter/typeshed.git synced 2026-02-07 18:30:57 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

redis: remove unused type: ignores (#11062)

Browse Source
This commit is contained in:
Alex Waygood
2023-11-23 13:02:25 +00:00
committed by GitHub
parent 10febc4fe0
commit b04e50d522
5 changed files with 364 additions and 333 deletions
Download Patch File Download Diff File Expand all files Collapse all files

548
stubs/redis/redis/asyncio/client.pyi
View File

@@ -314,7 +314,7 @@ class Pipeline(Redis[_StrType]):
def __await__(self) -> Generator[Any, None, Self]: ...
def __len__(self) -> int: ...
def __bool__(self) -> bool: ...
async def reset(self) -> None: ... # type: ignore[override]
async def reset(self) -> None: ...
def multi(self) -> None: ...
def execute_command(self, *args, **kwargs) -> Pipeline[_StrType] | Awaitable[Pipeline[_StrType]]: ...
async def immediate_execute_command(self, *args, **options): ...
@@ -328,16 +328,16 @@ class Pipeline(Redis[_StrType]):
async def watch(self, *names: KeyT) -> bool: ...
async def unwatch(self) -> bool: ...
# region acl commands
def acl_cat(self, category: str | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_deluser(self, *username: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_genpass(self, bits: int | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_getuser(self, username: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_help(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_list(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_log(self, count: int | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_log_reset(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_load(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_save(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_cat(self, category: str | None = None, **kwargs: _CommandOptions) -> Any: ...
def acl_deluser(self, *username: str, **kwargs: _CommandOptions) -> Any: ...
def acl_genpass(self, bits: int | None = None, **kwargs: _CommandOptions) -> Any: ...
def acl_getuser(self, username: str, **kwargs: _CommandOptions) -> Any: ...
def acl_help(self, **kwargs: _CommandOptions) -> Any: ...
def acl_list(self, **kwargs: _CommandOptions) -> Any: ...
def acl_log(self, count: int | None = None, **kwargs: _CommandOptions) -> Any: ...
def acl_log_reset(self, **kwargs: _CommandOptions) -> Any: ...
def acl_load(self, **kwargs: _CommandOptions) -> Any: ...
def acl_save(self, **kwargs: _CommandOptions) -> Any: ...
def acl_setuser( # type: ignore[override]
self,
username: str,
@@ -356,33 +356,33 @@ class Pipeline(Redis[_StrType]):
reset_passwords: bool = False,
**kwargs: _CommandOptions,
) -> Pipeline[_StrType]: ...
def acl_users(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_whoami(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def acl_users(self, **kwargs: _CommandOptions) -> Any: ...
def acl_whoami(self, **kwargs: _CommandOptions) -> Any: ...
# endregion
# region cluster commands
def cluster(self, cluster_arg: str, *args, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def readwrite(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def readonly(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def cluster(self, cluster_arg: str, *args, **kwargs: _CommandOptions) -> Any: ...
def readwrite(self, **kwargs: _CommandOptions) -> Any: ...
def readonly(self, **kwargs: _CommandOptions) -> Any: ...
# endregion
# region BasicKey commands
def append(self, key, value) -> Any: ... # type: ignore[override]
def bitcount(self, key: _Key, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ... # type: ignore[override]
def bitfield(self, key, default_overflow: Incomplete | None = None) -> Any: ... # type: ignore[override]
def bitop(self, operation, dest, *keys) -> Any: ... # type: ignore[override]
def bitpos(self, key: _Key, bit: int, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ... # type: ignore[override]
def copy(self, source, destination, destination_db: Incomplete | None = None, replace: bool = False) -> Any: ... # type: ignore[override]
def decr(self, name, amount: int = 1) -> Any: ... # type: ignore[override]
def decrby(self, name, amount: int = 1) -> Any: ... # type: ignore[override]
def delete(self, *names: _Key) -> Any: ... # type: ignore[override]
def dump(self, name: _Key) -> Any: ... # type: ignore[override]
def exists(self, *names: _Key) -> Any: ... # type: ignore[override]
def expire( # type: ignore[override]
def append(self, key, value) -> Any: ...
def bitcount(self, key: _Key, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ...
def bitfield(self, key, default_overflow: Incomplete | None = None) -> Any: ...
def bitop(self, operation, dest, *keys) -> Any: ...
def bitpos(self, key: _Key, bit: int, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ...
def copy(self, source, destination, destination_db: Incomplete | None = None, replace: bool = False) -> Any: ...
def decr(self, name, amount: int = 1) -> Any: ...
def decrby(self, name, amount: int = 1) -> Any: ...
def delete(self, *names: _Key) -> Any: ...
def dump(self, name: _Key) -> Any: ...
def exists(self, *names: _Key) -> Any: ...
def expire(
self, name: _Key, time: int | timedelta, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False
) -> Any: ...
def expireat(self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Any: ... # type: ignore[override]
def get(self, name: _Key) -> Any: ... # type: ignore[override]
def getdel(self, name: _Key) -> Any: ... # type: ignore[override]
def getex( # type: ignore[override]
def expireat(self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Any: ...
def get(self, name: _Key) -> Any: ...
def getdel(self, name: _Key) -> Any: ...
def getex(
self,
name,
ex: Incomplete | None = None,
@@ -391,21 +391,21 @@ class Pipeline(Redis[_StrType]):
pxat: Incomplete | None = None,
persist: bool = False,
) -> Any: ...
def getbit(self, name: _Key, offset: int) -> Any: ... # type: ignore[override]
def getrange(self, key, start, end) -> Any: ... # type: ignore[override]
def getset(self, name, value) -> Any: ... # type: ignore[override]
def incr(self, name: _Key, amount: int = 1) -> Any: ... # type: ignore[override]
def incrby(self, name: _Key, amount: int = 1) -> Any: ... # type: ignore[override]
def incrbyfloat(self, name: _Key, amount: float = 1.0) -> Any: ... # type: ignore[override]
def keys(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def lmove( # type: ignore[override]
def getbit(self, name: _Key, offset: int) -> Any: ...
def getrange(self, key, start, end) -> Any: ...
def getset(self, name, value) -> Any: ...
def incr(self, name: _Key, amount: int = 1) -> Any: ...
def incrby(self, name: _Key, amount: int = 1) -> Any: ...
def incrbyfloat(self, name: _Key, amount: float = 1.0) -> Any: ...
def keys(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ...
def lmove(
self,
first_list: _Key,
second_list: _Key,
src: Literal["LEFT", "RIGHT"] = "LEFT",
dest: Literal["LEFT", "RIGHT"] = "RIGHT",
) -> Any: ...
def blmove( # type: ignore[override]
def blmove(
self,
first_list: _Key,
second_list: _Key,
@@ -413,24 +413,24 @@ class Pipeline(Redis[_StrType]):
src: Literal["LEFT", "RIGHT"] = "LEFT",
dest: Literal["LEFT", "RIGHT"] = "RIGHT",
) -> Any: ...
def mget(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def mset(self, mapping: Mapping[_Key, _Value]) -> Any: ... # type: ignore[override]
def msetnx(self, mapping: Mapping[_Key, _Value]) -> Any: ... # type: ignore[override]
def move(self, name: _Key, db: int) -> Any: ... # type: ignore[override]
def persist(self, name: _Key) -> Any: ... # type: ignore[override]
def pexpire( # type: ignore[override]
def mget(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
def mset(self, mapping: Mapping[_Key, _Value]) -> Any: ...
def msetnx(self, mapping: Mapping[_Key, _Value]) -> Any: ...
def move(self, name: _Key, db: int) -> Any: ...
def persist(self, name: _Key) -> Any: ...
def pexpire(
self, name: _Key, time: int | timedelta, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False
) -> Any: ...
def pexpireat( # type: ignore[override]
def pexpireat(
self, name: _Key, when: int | datetime, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False
) -> Any: ...
def psetex(self, name, time_ms, value) -> Any: ... # type: ignore[override]
def pttl(self, name: _Key) -> Any: ... # type: ignore[override]
def hrandfield(self, key, count: Incomplete | None = None, withvalues: bool = False) -> Any: ... # type: ignore[override]
def randomkey(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def rename(self, src, dst) -> Any: ... # type: ignore[override]
def renamenx(self, src, dst) -> Any: ... # type: ignore[override]
def restore( # type: ignore[override]
def psetex(self, name, time_ms, value) -> Any: ...
def pttl(self, name: _Key) -> Any: ...
def hrandfield(self, key, count: Incomplete | None = None, withvalues: bool = False) -> Any: ...
def randomkey(self, **kwargs: _CommandOptions) -> Any: ...
def rename(self, src, dst) -> Any: ...
def renamenx(self, src, dst) -> Any: ...
def restore(
self,
name,
ttl,
@@ -453,11 +453,11 @@ class Pipeline(Redis[_StrType]):
exat: Incomplete | None = None,
pxat: Incomplete | None = None,
) -> Any: ...
def setbit(self, name: _Key, offset: int, value: int) -> Any: ... # type: ignore[override]
def setex(self, name: _Key, time: int | timedelta, value: _Value) -> Any: ... # type: ignore[override]
def setnx(self, name: _Key, value: _Value) -> Any: ... # type: ignore[override]
def setrange(self, name, offset, value) -> Any: ... # type: ignore[override]
def stralgo( # type: ignore[override]
def setbit(self, name: _Key, offset: int, value: int) -> Any: ...
def setex(self, name: _Key, time: int | timedelta, value: _Value) -> Any: ...
def setnx(self, name: _Key, value: _Value) -> Any: ...
def setrange(self, name, offset, value) -> Any: ...
def stralgo(
self,
algo,
value1,
@@ -469,47 +469,49 @@ class Pipeline(Redis[_StrType]):
withmatchlen: bool = False,
**kwargs: _CommandOptions,
) -> Any: ...
def strlen(self, name) -> Any: ... # type: ignore[override]
def substr(self, name, start, end: int = -1) -> Any: ... # type: ignore[override]
def touch(self, *args) -> Any: ... # type: ignore[override]
def ttl(self, name: _Key) -> Any: ... # type: ignore[override]
def type(self, name) -> Any: ... # type: ignore[override]
def unlink(self, *names: _Key) -> Any: ... # type: ignore[override]
def strlen(self, name) -> Any: ...
def substr(self, name, start, end: int = -1) -> Any: ...
def touch(self, *args) -> Any: ...
def ttl(self, name: _Key) -> Any: ...
def type(self, name) -> Any: ...
def unlink(self, *names: _Key) -> Any: ...
# endregion
# region hyperlog commands
def pfadd(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override]
def pfcount(self, name: _Key) -> Any: ... # type: ignore[override]
def pfmerge(self, dest: _Key, *sources: _Key) -> Any: ... # type: ignore[override]
def pfadd(self, name: _Key, *values: _Value) -> Any: ...
def pfcount(self, name: _Key) -> Any: ...
def pfmerge(self, dest: _Key, *sources: _Key) -> Any: ...
# endregion
# region hash commands
def hdel(self, name: _Key, *keys: _Key) -> Any: ... # type: ignore[override]
def hexists(self, name: _Key, key: _Key) -> Any: ... # type: ignore[override]
def hget(self, name: _Key, key: _Key) -> Any: ... # type: ignore[override]
def hgetall(self, name: _Key) -> Any: ... # type: ignore[override]
def hincrby(self, name: _Key, key: _Key, amount: int = 1) -> Any: ... # type: ignore[override]
def hincrbyfloat(self, name: _Key, key: _Key, amount: float = 1.0) -> Any: ... # type: ignore[override]
def hkeys(self, name: _Key) -> Any: ... # type: ignore[override]
def hlen(self, name: _Key) -> Any: ... # type: ignore[override]
def hdel(self, name: _Key, *keys: _Key) -> Any: ...
def hexists(self, name: _Key, key: _Key) -> Any: ...
def hget(self, name: _Key, key: _Key) -> Any: ...
def hgetall(self, name: _Key) -> Any: ...
def hincrby(self, name: _Key, key: _Key, amount: int = 1) -> Any: ...
def hincrbyfloat(self, name: _Key, key: _Key, amount: float = 1.0) -> Any: ...
def hkeys(self, name: _Key) -> Any: ...
def hlen(self, name: _Key) -> Any: ...
@overload
def hset( # type: ignore[override]
def hset(
self, name: _Key, key: _Key, value: _Value, mapping: Mapping[_Key, _Value] | None = None, items: Incomplete | None = None
) -> Any: ...
@overload
def hset(self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Any: ... # type: ignore[override]
def hset(
self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value], items: Incomplete | None = None
) -> Any: ...
@overload
def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Any: ... # type: ignore[override]
def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Any: ... # type: ignore[override]
def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Any: ... # type: ignore[override]
def hmget(self, name: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def hvals(self, name: _Key) -> Any: ... # type: ignore[override]
def hstrlen(self, name, key) -> Any: ... # type: ignore[override]
def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Any: ...
def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Any: ...
def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Any: ...
def hmget(self, name: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
def hvals(self, name: _Key) -> Any: ...
def hstrlen(self, name, key) -> Any: ...
# endregion
# region geo commands
def geoadd(self, name, values, nx: bool = False, xx: bool = False, ch: bool = False) -> Any: ... # type: ignore[override]
def geodist(self, name, place1, place2, unit: Incomplete | None = None) -> Any: ... # type: ignore[override]
def geohash(self, name, *values) -> Any: ... # type: ignore[override]
def geopos(self, name, *values) -> Any: ... # type: ignore[override]
def georadius( # type: ignore[override]
def geoadd(self, name, values, nx: bool = False, xx: bool = False, ch: bool = False) -> Any: ...
def geodist(self, name, place1, place2, unit: Incomplete | None = None) -> Any: ...
def geohash(self, name, *values) -> Any: ...
def geopos(self, name, *values) -> Any: ...
def georadius(
self,
name,
longitude,
@@ -525,7 +527,7 @@ class Pipeline(Redis[_StrType]):
store_dist: Incomplete | None = None,
any: bool = False,
) -> Any: ...
def georadiusbymember( # type: ignore[override]
def georadiusbymember(
self,
name,
member,
@@ -540,7 +542,7 @@ class Pipeline(Redis[_StrType]):
store_dist: Incomplete | None = None,
any: bool = False,
) -> Any: ...
def geosearch( # type: ignore[override]
def geosearch(
self,
name,
member: Incomplete | None = None,
@@ -557,7 +559,7 @@ class Pipeline(Redis[_StrType]):
withdist: bool = False,
withhash: bool = False,
) -> Any: ...
def geosearchstore( # type: ignore[override]
def geosearchstore(
self,
dest,
name,
@@ -576,31 +578,33 @@ class Pipeline(Redis[_StrType]):
# endregion
# region list commands
@overload
def blpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ... # type: ignore[override]
def blpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ...
@overload
def blpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ... # type: ignore[override]
def blpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ...
@overload
def brpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ... # type: ignore[override]
def brpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ...
@overload
def brpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ... # type: ignore[override]
def brpoplpush(self, src, dst, timeout: int | None = 0) -> Any: ... # type: ignore[override]
def lindex(self, name: _Key, index: int) -> Any: ... # type: ignore[override]
def linsert( # type: ignore[override]
def brpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ...
def brpoplpush(self, src, dst, timeout: int | None = 0) -> Any: ...
def lindex(self, name: _Key, index: int) -> Any: ...
def linsert(
self, name: _Key, where: Literal["BEFORE", "AFTER", "before", "after"], refvalue: _Value, value: _Value
) -> Any: ...
def llen(self, name: _Key) -> Any: ... # type: ignore[override]
def lpop(self, name, count: int | None = None) -> Any: ... # type: ignore[override]
def lpush(self, name: _Value, *values: _Value) -> Any: ... # type: ignore[override]
def lpushx(self, name, value) -> Any: ... # type: ignore[override]
def lrange(self, name: _Key, start: int, end: int) -> Any: ... # type: ignore[override]
def lrem(self, name: _Key, count: int, value: _Value) -> Any: ... # type: ignore[override]
def lset(self, name: _Key, index: int, value: _Value) -> Any: ... # type: ignore[override]
def ltrim(self, name: _Key, start: int, end: int) -> Any: ... # type: ignore[override]
def rpop(self, name, count: int | None = None) -> Any: ... # type: ignore[override]
def rpoplpush(self, src, dst) -> Any: ... # type: ignore[override]
def rpush(self, name: _Value, *values: _Value) -> Any: ... # type: ignore[override]
def rpushx(self, name, value) -> Any: ... # type: ignore[override]
def lpos(self, name, value, rank: Incomplete | None = None, count: Incomplete | None = None, maxlen: Incomplete | None = None) -> Any: ... # type: ignore[override]
def llen(self, name: _Key) -> Any: ...
def lpop(self, name, count: int | None = None) -> Any: ...
def lpush(self, name: _Value, *values: _Value) -> Any: ...
def lpushx(self, name, value) -> Any: ...
def lrange(self, name: _Key, start: int, end: int) -> Any: ...
def lrem(self, name: _Key, count: int, value: _Value) -> Any: ...
def lset(self, name: _Key, index: int, value: _Value) -> Any: ...
def ltrim(self, name: _Key, start: int, end: int) -> Any: ...
def rpop(self, name, count: int | None = None) -> Any: ...
def rpoplpush(self, src, dst) -> Any: ...
def rpush(self, name: _Value, *values: _Value) -> Any: ...
def rpushx(self, name, value) -> Any: ...
def lpos(
self, name, value, rank: Incomplete | None = None, count: Incomplete | None = None, maxlen: Incomplete | None = None
) -> Any: ...
@overload # type: ignore[override]
def sort(
self,
@@ -614,7 +618,7 @@ class Pipeline(Redis[_StrType]):
store: None = None,
groups: bool = False,
) -> list[_StrType]: ...
@overload # type: ignore[override]
@overload
def sort(
self,
name: _Key,
@@ -628,7 +632,7 @@ class Pipeline(Redis[_StrType]):
store: _Key,
groups: bool = False,
) -> Any: ...
@overload # type: ignore[override]
@overload
def sort(
self,
name: _Key,
@@ -643,7 +647,7 @@ class Pipeline(Redis[_StrType]):
) -> Any: ...
# endregion
# region scan commands
def scan( # type: ignore[override]
def scan(
self,
cursor: int = 0,
match: _Key | None = None,
@@ -651,11 +655,11 @@ class Pipeline(Redis[_StrType]):
_type: str | None = None,
**kwargs: _CommandOptions,
) -> Any: ...
def sscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ... # type: ignore[override]
def hscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ... # type: ignore[override]
@overload # type: ignore[override]
def sscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ...
def hscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ...
@overload
def zscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ...
@overload # type: ignore[override]
@overload
def zscan(
self,
name: _Key,
@@ -665,37 +669,37 @@ class Pipeline(Redis[_StrType]):
*,
score_cast_func: Callable[[_StrType], Any],
) -> Any: ...
@overload # type: ignore[override]
@overload
def zscan(
self, name: _Key, cursor: int, match: _Key | None, count: int | None, score_cast_func: Callable[[_StrType], Any]
) -> Any: ...
# endregion
# region set commands
def sadd(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override]
def scard(self, name: _Key) -> Any: ... # type: ignore[override]
def sdiff(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def sdiffstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def sinter(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def sinterstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def sismember(self, name: _Key, value: _Value) -> Any: ... # type: ignore[override]
def smembers(self, name: _Key) -> Any: ... # type: ignore[override]
def smismember(self, name, values, *args) -> Any: ... # type: ignore[override]
def smove(self, src: _Key, dst: _Key, value: _Value) -> Any: ... # type: ignore[override]
@overload # type: ignore[override]
def sadd(self, name: _Key, *values: _Value) -> Any: ...
def scard(self, name: _Key) -> Any: ...
def sdiff(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
def sdiffstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
def sinter(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
def sinterstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
def sismember(self, name: _Key, value: _Value) -> Any: ...
def smembers(self, name: _Key) -> Any: ...
def smismember(self, name, values, *args) -> Any: ...
def smove(self, src: _Key, dst: _Key, value: _Value) -> Any: ...
@overload
def spop(self, name: _Key, count: None = None) -> Any: ...
@overload # type: ignore[override]
@overload
def spop(self, name: _Key, count: int) -> Any: ...
@overload # type: ignore[override]
@overload
def srandmember(self, name: _Key, number: None = None) -> Any: ...
@overload # type: ignore[override]
@overload
def srandmember(self, name: _Key, number: int) -> Any: ...
def srem(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override]
def sunion(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def sunionstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override]
def srem(self, name: _Key, *values: _Value) -> Any: ...
def sunion(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
def sunionstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ...
# endregion
# region stream commands
def xack(self, name, groupname, *ids) -> Any: ... # type: ignore[override]
def xadd( # type: ignore[override]
def xack(self, name, groupname, *ids) -> Any: ...
def xadd(
self,
name,
fields,
@@ -706,7 +710,7 @@ class Pipeline(Redis[_StrType]):
minid: Incomplete | None = None,
limit: Incomplete | None = None,
) -> Any: ...
def xautoclaim( # type: ignore[override]
def xautoclaim(
self,
name,
groupname,
@@ -716,7 +720,7 @@ class Pipeline(Redis[_StrType]):
count: Incomplete | None = None,
justid: bool = False,
) -> Any: ...
def xclaim( # type: ignore[override]
def xclaim(
self,
name,
groupname,
@@ -729,23 +733,23 @@ class Pipeline(Redis[_StrType]):
force=False,
justid=False,
) -> Any: ...
def xdel(self, name, *ids) -> Any: ... # type: ignore[override]
def xgroup_create(self, name, groupname, id: str = "$", mkstream: bool = False, entries_read: int | None = None) -> Any: ... # type: ignore[override]
def xgroup_delconsumer(self, name, groupname, consumername) -> Any: ... # type: ignore[override]
def xgroup_destroy(self, name, groupname) -> Any: ... # type: ignore[override]
def xgroup_createconsumer(self, name, groupname, consumername) -> Any: ... # type: ignore[override]
def xgroup_setid(self, name, groupname, id, entries_read: int | None = None) -> Any: ... # type: ignore[override]
def xinfo_consumers(self, name, groupname) -> Any: ... # type: ignore[override]
def xinfo_groups(self, name) -> Any: ... # type: ignore[override]
def xinfo_stream(self, name, full: bool = False) -> Any: ... # type: ignore[override]
def xlen(self, name: _Key) -> Any: ... # type: ignore[override]
def xpending(self, name, groupname) -> Any: ... # type: ignore[override]
def xpending_range( # type: ignore[override]
def xdel(self, name, *ids) -> Any: ...
def xgroup_create(self, name, groupname, id: str = "$", mkstream: bool = False, entries_read: int | None = None) -> Any: ...
def xgroup_delconsumer(self, name, groupname, consumername) -> Any: ...
def xgroup_destroy(self, name, groupname) -> Any: ...
def xgroup_createconsumer(self, name, groupname, consumername) -> Any: ...
def xgroup_setid(self, name, groupname, id, entries_read: int | None = None) -> Any: ...
def xinfo_consumers(self, name, groupname) -> Any: ...
def xinfo_groups(self, name) -> Any: ...
def xinfo_stream(self, name, full: bool = False) -> Any: ...
def xlen(self, name: _Key) -> Any: ...
def xpending(self, name, groupname) -> Any: ...
def xpending_range(
self, name: _Key, groupname, min, max, count: int, consumername: Incomplete | None = None, idle: int | None = None
) -> Any: ...
def xrange(self, name, min: str = "-", max: str = "+", count: Incomplete | None = None) -> Any: ... # type: ignore[override]
def xread(self, streams, count: Incomplete | None = None, block: Incomplete | None = None) -> Any: ... # type: ignore[override]
def xreadgroup( # type: ignore[override]
def xrange(self, name, min: str = "-", max: str = "+", count: Incomplete | None = None) -> Any: ...
def xread(self, streams, count: Incomplete | None = None, block: Incomplete | None = None) -> Any: ...
def xreadgroup(
self,
groupname,
consumername,
@@ -754,13 +758,13 @@ class Pipeline(Redis[_StrType]):
block: Incomplete | None = None,
noack: bool = False,
) -> Any: ...
def xrevrange(self, name, max: str = "+", min: str = "-", count: Incomplete | None = None) -> Any: ... # type: ignore[override]
def xtrim( # type: ignore[override]
def xrevrange(self, name, max: str = "+", min: str = "-", count: Incomplete | None = None) -> Any: ...
def xtrim(
self, name, maxlen: int | None = None, approximate: bool = True, minid: Incomplete | None = None, limit: int | None = None
) -> Any: ...
# endregion
# region sorted set commands
def zadd( # type: ignore[override]
def zadd(
self,
name: _Key,
mapping: Mapping[_Key, _Value],
@@ -771,24 +775,24 @@ class Pipeline(Redis[_StrType]):
gt: Incomplete | None = False,
lt: Incomplete | None = False,
) -> Any: ...
def zcard(self, name: _Key) -> Any: ... # type: ignore[override]
def zcount(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override]
def zdiff(self, keys, withscores: bool = False) -> Any: ... # type: ignore[override]
def zdiffstore(self, dest, keys) -> Any: ... # type: ignore[override]
def zincrby(self, name: _Key, amount: float, value: _Value) -> Any: ... # type: ignore[override]
def zinter(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ... # type: ignore[override]
def zinterstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ... # type: ignore[override]
def zlexcount(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override]
def zpopmax(self, name: _Key, count: int | None = None) -> Any: ... # type: ignore[override]
def zpopmin(self, name: _Key, count: int | None = None) -> Any: ... # type: ignore[override]
def zrandmember(self, key, count: Incomplete | None = None, withscores: bool = False) -> Any: ... # type: ignore[override]
@overload # type: ignore[override]
def zcard(self, name: _Key) -> Any: ...
def zcount(self, name: _Key, min: _Value, max: _Value) -> Any: ...
def zdiff(self, keys, withscores: bool = False) -> Any: ...
def zdiffstore(self, dest, keys) -> Any: ...
def zincrby(self, name: _Key, amount: float, value: _Value) -> Any: ...
def zinter(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ...
def zinterstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ...
def zlexcount(self, name: _Key, min: _Value, max: _Value) -> Any: ...
def zpopmax(self, name: _Key, count: int | None = None) -> Any: ...
def zpopmin(self, name: _Key, count: int | None = None) -> Any: ...
def zrandmember(self, key, count: Incomplete | None = None, withscores: bool = False) -> Any: ...
@overload
def bzpopmax(self, keys: _Key | Iterable[_Key], timeout: Literal[0] = 0) -> Any: ...
@overload # type: ignore[override]
@overload
def bzpopmax(self, keys: _Key | Iterable[_Key], timeout: float) -> Any: ...
@overload # type: ignore[override]
@overload
def bzpopmin(self, keys: _Key | Iterable[_Key], timeout: Literal[0] = 0) -> Any: ...
@overload # type: ignore[override]
@overload
def bzpopmin(self, keys: _Key | Iterable[_Key], timeout: float) -> Any: ...
@overload # type: ignore[override]
def zrange(
@@ -804,7 +808,7 @@ class Pipeline(Redis[_StrType]):
offset: int | None = None,
num: int | None = None,
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrange(
self,
name: _Key,
@@ -818,7 +822,7 @@ class Pipeline(Redis[_StrType]):
offset: int | None = None,
num: int | None = None,
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrange(
self,
name: _Key,
@@ -832,7 +836,7 @@ class Pipeline(Redis[_StrType]):
offset: int | None = None,
num: int | None = None,
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrange(
self,
name: _Key,
@@ -846,7 +850,7 @@ class Pipeline(Redis[_StrType]):
offset: int | None = None,
num: int | None = None,
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrange(
self,
name: _Key,
@@ -864,13 +868,13 @@ class Pipeline(Redis[_StrType]):
def zrevrange(
self, name: _Key, start: int, end: int, withscores: Literal[True], score_cast_func: Callable[[_StrType], None]
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrevrange(self, name: _Key, start: int, end: int, withscores: Literal[True]) -> Any: ...
@overload # type: ignore[override]
@overload
def zrevrange(
self, name: _Key, start: int, end: int, withscores: bool = False, score_cast_func: Callable[[Any], Any] = ...
) -> Any: ...
def zrangestore( # type: ignore[override]
def zrangestore(
self,
dest,
name,
@@ -882,8 +886,8 @@ class Pipeline(Redis[_StrType]):
offset: Incomplete | None = None,
num: Incomplete | None = None,
) -> Any: ...
def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: int | None = None, num: int | None = None) -> Any: ... # type: ignore[override]
def zrevrangebylex(self, name: _Key, max: _Value, min: _Value, start: int | None = None, num: int | None = None) -> Any: ... # type: ignore[override]
def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: int | None = None, num: int | None = None) -> Any: ...
def zrevrangebylex(self, name: _Key, max: _Value, min: _Value, start: int | None = None, num: int | None = None) -> Any: ...
@overload # type: ignore[override]
def zrangebyscore(
self,
@@ -896,11 +900,11 @@ class Pipeline(Redis[_StrType]):
withscores: Literal[True],
score_cast_func: Callable[[_StrType], None],
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrangebyscore(
self, name: _Key, min: _Value, max: _Value, start: int | None = None, num: int | None = None, *, withscores: Literal[True]
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrangebyscore(
self,
name: _Key,
@@ -911,7 +915,7 @@ class Pipeline(Redis[_StrType]):
withscores: bool = False,
score_cast_func: Callable[[_StrType], Any] = ...,
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrevrangebyscore(
self,
name: _Key,
@@ -923,11 +927,11 @@ class Pipeline(Redis[_StrType]):
withscores: Literal[True],
score_cast_func: Callable[[_StrType], Any],
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrevrangebyscore(
self, name: _Key, max: _Value, min: _Value, start: int | None = None, num: int | None = None, *, withscores: Literal[True]
) -> Any: ...
@overload # type: ignore[override]
@overload
def zrevrangebyscore(
self,
name: _Key,
@@ -938,23 +942,23 @@ class Pipeline(Redis[_StrType]):
withscores: bool = False,
score_cast_func: Callable[[_StrType], Any] = ...,
) -> Any: ...
def zrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ... # type: ignore[override]
def zrem(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override]
def zremrangebylex(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override]
def zremrangebyrank(self, name: _Key, min: int, max: int) -> Any: ... # type: ignore[override]
def zremrangebyscore(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override]
def zrevrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ... # type: ignore[override]
def zscore(self, name: _Key, value: _Value) -> Any: ... # type: ignore[override]
def zunion(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ... # type: ignore[override]
def zunionstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ... # type: ignore[override]
def zmscore(self, key, members) -> Any: ... # type: ignore[override]
def zrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ...
def zrem(self, name: _Key, *values: _Value) -> Any: ...
def zremrangebylex(self, name: _Key, min: _Value, max: _Value) -> Any: ...
def zremrangebyrank(self, name: _Key, min: int, max: int) -> Any: ...
def zremrangebyscore(self, name: _Key, min: _Value, max: _Value) -> Any: ...
def zrevrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ...
def zscore(self, name: _Key, value: _Value) -> Any: ...
def zunion(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ...
def zunionstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ...
def zmscore(self, key, members) -> Any: ...
# endregion
# region management commands
def bgrewriteaof(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def bgsave(self, schedule: bool = True, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def role(self) -> Any: ... # type: ignore[override]
def client_kill(self, address: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_kill_filter( # type: ignore[override]
def bgrewriteaof(self, **kwargs: _CommandOptions) -> Any: ...
def bgsave(self, schedule: bool = True, **kwargs: _CommandOptions) -> Any: ...
def role(self) -> Any: ...
def client_kill(self, address: str, **kwargs: _CommandOptions) -> Any: ...
def client_kill_filter(
self,
_id: Incomplete | None = None,
_type: Incomplete | None = None,
@@ -964,13 +968,13 @@ class Pipeline(Redis[_StrType]):
user: Incomplete | None = None,
**kwargs: _CommandOptions,
) -> Any: ...
def client_info(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_list(self, _type: str | None = None, client_id: list[str] = [], **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_getname(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_getredir(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_reply(self, reply, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_id(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_tracking_on( # type: ignore[override]
def client_info(self, **kwargs: _CommandOptions) -> Any: ...
def client_list(self, _type: str | None = None, client_id: list[str] = [], **kwargs: _CommandOptions) -> Any: ...
def client_getname(self, **kwargs: _CommandOptions) -> Any: ...
def client_getredir(self, **kwargs: _CommandOptions) -> Any: ...
def client_reply(self, reply, **kwargs: _CommandOptions) -> Any: ...
def client_id(self, **kwargs: _CommandOptions) -> Any: ...
def client_tracking_on(
self,
clientid: Incomplete | None = None,
prefix=[],
@@ -979,7 +983,7 @@ class Pipeline(Redis[_StrType]):
optout: bool = False,
noloop: bool = False,
) -> Any: ...
def client_tracking_off( # type: ignore[override]
def client_tracking_off(
self,
clientid: Incomplete | None = None,
prefix=[],
@@ -988,7 +992,7 @@ class Pipeline(Redis[_StrType]):
optout: bool = False,
noloop: bool = False,
) -> Any: ...
def client_tracking( # type: ignore[override]
def client_tracking(
self,
on: bool = True,
clientid: Incomplete | None = None,
@@ -999,32 +1003,32 @@ class Pipeline(Redis[_StrType]):
noloop: bool = False,
**kwargs: _CommandOptions,
) -> Any: ...
def client_trackinginfo(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_setname(self, name: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_unblock(self, client_id, error: bool = False, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_pause(self, timeout, all: bool = True, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def client_unpause(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def command(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def command_info(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def command_count(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def config_get(self, pattern: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def config_set(self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def config_resetstat(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def config_rewrite(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def dbsize(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def debug_object(self, key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def debug_segfault(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def echo(self, value: _Value, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def flushall(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def flushdb(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def sync(self) -> Any: ... # type: ignore[override]
def psync(self, replicationid, offset) -> Any: ... # type: ignore[override]
def swapdb(self, first, second, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def select(self, index, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def info(self, section: _Key | None = None, *args: _Key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def lastsave(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def lolwut(self, *version_numbers: _Value, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def migrate( # type: ignore[override]
def client_trackinginfo(self, **kwargs: _CommandOptions) -> Any: ...
def client_setname(self, name: str, **kwargs: _CommandOptions) -> Any: ...
def client_unblock(self, client_id, error: bool = False, **kwargs: _CommandOptions) -> Any: ...
def client_pause(self, timeout, all: bool = True, **kwargs: _CommandOptions) -> Any: ...
def client_unpause(self, **kwargs: _CommandOptions) -> Any: ...
def command(self, **kwargs: _CommandOptions) -> Any: ...
def command_info(self, **kwargs: _CommandOptions) -> Any: ...
def command_count(self, **kwargs: _CommandOptions) -> Any: ...
def config_get(self, pattern: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Any: ...
def config_set(self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions) -> Any: ...
def config_resetstat(self, **kwargs: _CommandOptions) -> Any: ...
def config_rewrite(self, **kwargs: _CommandOptions) -> Any: ...
def dbsize(self, **kwargs: _CommandOptions) -> Any: ...
def debug_object(self, key, **kwargs: _CommandOptions) -> Any: ...
def debug_segfault(self, **kwargs: _CommandOptions) -> Any: ...
def echo(self, value: _Value, **kwargs: _CommandOptions) -> Any: ...
def flushall(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ...
def flushdb(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ...
def sync(self) -> Any: ...
def psync(self, replicationid, offset) -> Any: ...
def swapdb(self, first, second, **kwargs: _CommandOptions) -> Any: ...
def select(self, index, **kwargs: _CommandOptions) -> Any: ...
def info(self, section: _Key | None = None, *args: _Key, **kwargs: _CommandOptions) -> Any: ...
def lastsave(self, **kwargs: _CommandOptions) -> Any: ...
def lolwut(self, *version_numbers: _Value, **kwargs: _CommandOptions) -> Any: ...
def migrate(
self,
host,
port,
@@ -1036,18 +1040,18 @@ class Pipeline(Redis[_StrType]):
auth: Incomplete | None = None,
**kwargs: _CommandOptions,
) -> Any: ...
def object(self, infotype, key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def memory_doctor(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def memory_help(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def memory_stats(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def memory_malloc_stats(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def memory_usage(self, key, samples: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def memory_purge(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def ping(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def quit(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def replicaof(self, *args, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def save(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def shutdown( # type: ignore[override]
def object(self, infotype, key, **kwargs: _CommandOptions) -> Any: ...
def memory_doctor(self, **kwargs: _CommandOptions) -> Any: ...
def memory_help(self, **kwargs: _CommandOptions) -> Any: ...
def memory_stats(self, **kwargs: _CommandOptions) -> Any: ...
def memory_malloc_stats(self, **kwargs: _CommandOptions) -> Any: ...
def memory_usage(self, key, samples: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ...
def memory_purge(self, **kwargs: _CommandOptions) -> Any: ...
def ping(self, **kwargs: _CommandOptions) -> Any: ...
def quit(self, **kwargs: _CommandOptions) -> Any: ...
def replicaof(self, *args, **kwargs: _CommandOptions) -> Any: ...
def save(self, **kwargs: _CommandOptions) -> Any: ...
def shutdown(
self,
save: bool = False,
nosave: bool = False,
@@ -1056,32 +1060,32 @@ class Pipeline(Redis[_StrType]):
abort: bool = False,
**kwargs: _CommandOptions,
) -> Any: ...
def slaveof(self, host: Incomplete | None = None, port: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def slowlog_get(self, num: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def slowlog_len(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def slowlog_reset(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def time(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def wait(self, num_replicas, timeout, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def slaveof(self, host: Incomplete | None = None, port: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ...
def slowlog_get(self, num: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ...
def slowlog_len(self, **kwargs: _CommandOptions) -> Any: ...
def slowlog_reset(self, **kwargs: _CommandOptions) -> Any: ...
def time(self, **kwargs: _CommandOptions) -> Any: ...
def wait(self, num_replicas, timeout, **kwargs: _CommandOptions) -> Any: ...
# endregion
# region module commands
def module_load(self, path, *args) -> Any: ... # type: ignore[override]
def module_unload(self, name) -> Any: ... # type: ignore[override]
def module_list(self) -> Any: ... # type: ignore[override]
def command_getkeys(self, *args) -> Any: ... # type: ignore[override]
def module_load(self, path, *args) -> Any: ...
def module_unload(self, name) -> Any: ...
def module_list(self) -> Any: ...
def command_getkeys(self, *args) -> Any: ...
# endregion
# region pubsub commands
def publish(self, channel: _Key, message: _Key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def pubsub_channels(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def pubsub_numpat(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def pubsub_numsub(self, *args: _Key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override]
def publish(self, channel: _Key, message: _Key, **kwargs: _CommandOptions) -> Any: ...
def pubsub_channels(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ...
def pubsub_numpat(self, **kwargs: _CommandOptions) -> Any: ...
def pubsub_numsub(self, *args: _Key, **kwargs: _CommandOptions) -> Any: ...
# endregion
# region script commands
def eval(self, script, numkeys, *keys_and_args) -> Any: ... # type: ignore[override]
def evalsha(self, sha, numkeys, *keys_and_args) -> Any: ... # type: ignore[override]
def script_exists(self, *args) -> Any: ... # type: ignore[override]
def script_debug(self, *args) -> Any: ... # type: ignore[override]
def script_flush(self, sync_type: Incomplete | None = None) -> Any: ... # type: ignore[override]
def script_kill(self) -> Any: ... # type: ignore[override]
def script_load(self, script) -> Any: ... # type: ignore[override]
def eval(self, script, numkeys, *keys_and_args) -> Any: ...
def evalsha(self, sha, numkeys, *keys_and_args) -> Any: ...
def script_exists(self, *args) -> Any: ...
def script_debug(self, *args) -> Any: ...
def script_flush(self, sync_type: Incomplete | None = None) -> Any: ...
def script_kill(self) -> Any: ...
def script_load(self, script) -> Any: ...
def register_script(self, script: str | _StrType) -> Any: ... # type: ignore[override]
# endregion

2
stubs/redis/redis/asyncio/connection.pyi
View File

@@ -60,7 +60,7 @@ class HiredisParser(BaseParser):
def on_connect(self, connection: Connection): ...
def on_disconnect(self) -> None: ...
async def read_from_socket(self) -> Literal[True]: ...
async def read_response(self, disable_decoding: bool = False) -> EncodableT | list[EncodableT]: ... # type: ignore[override]
async def read_response(self, disable_decoding: bool = False) -> EncodableT | list[EncodableT]: ...
DefaultParser: type[PythonParser | HiredisParser]

2
stubs/redis/redis/asyncio/sentinel.pyi
View File

@@ -16,7 +16,7 @@ class SentinelManagedConnection(Connection):
def __init__(self, **kwargs) -> None: ...
async def connect_to(self, address) -> None: ...
async def connect(self): ...
@overload # type: ignore[override]
@overload
async def read_response(self, *, timeout: float, disconnect_on_error: bool = True) -> Incomplete | None: ...
@overload
async def read_response(

143
stubs/redis/redis/client.pyi
View File

@@ -397,7 +397,7 @@ class Pipeline(Redis[_StrType]):
scripts: Any
explicit_transaction: Any
def __init__(self, connection_pool, response_callbacks, transaction, shard_hint) -> None: ...
def __enter__(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def __enter__(self) -> Pipeline[_StrType]: ...
def __exit__(
self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None
) -> None: ...
@@ -419,7 +419,7 @@ class Pipeline(Redis[_StrType]):
def unwatch(self) -> bool: ...
# in the Redis implementation, the following methods are inherited from client.
def set_response_callback(self, command, callback): ...
def pipeline(self, transaction: bool = True, shard_hint: Any = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def pipeline(self, transaction: bool = True, shard_hint: Any = None) -> Pipeline[_StrType]: ...
def acl_cat(self, category: str | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_deluser(self, username: str) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_genpass(self, bits: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
@@ -455,8 +455,10 @@ class Pipeline(Redis[_StrType]):
def client_setname(self, name: str) -> Pipeline[_StrType]: ... # type: ignore[override]
def readwrite(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def readonly(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_get(self, pattern: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_set(self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_get(self, pattern: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Pipeline[_StrType]: ...
def config_set(
self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions
) -> Pipeline[_StrType]: ...
def config_resetstat(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_rewrite(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def dbsize(self) -> Pipeline[_StrType]: ... # type: ignore[override]
@@ -469,23 +471,23 @@ class Pipeline(Redis[_StrType]):
def object(self, infotype, key) -> Pipeline[_StrType]: ... # type: ignore[override]
def ping(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def save(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_get_master_addr_by_name(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_master(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_masters(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_monitor(self, name, ip, port, quorum) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_remove(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_sentinels(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_set(self, name, option, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_slaves(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_get_master_addr_by_name(self, service_name) -> Pipeline[_StrType]: ...
def sentinel_master(self, service_name) -> Pipeline[_StrType]: ...
def sentinel_masters(self) -> Pipeline[_StrType]: ...
def sentinel_monitor(self, name, ip, port, quorum) -> Pipeline[_StrType]: ...
def sentinel_remove(self, name) -> Pipeline[_StrType]: ...
def sentinel_sentinels(self, service_name) -> Pipeline[_StrType]: ...
def sentinel_set(self, name, option, value) -> Pipeline[_StrType]: ...
def sentinel_slaves(self, service_name) -> Pipeline[_StrType]: ...
def slaveof(self, host=None, port=None) -> Pipeline[_StrType]: ... # type: ignore[override]
def slowlog_get(self, num=None) -> Pipeline[_StrType]: ... # type: ignore[override]
def slowlog_len(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def slowlog_reset(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def time(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def append(self, key, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def append(self, key, value) -> Pipeline[_StrType]: ...
def bitcount(self, key: _Key, start: int | None = None, end: int | None = None, mode: str | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def bitop(self, operation, dest, *keys) -> Pipeline[_StrType]: ... # type: ignore[override]
def bitpos(self, key, bit, start=None, end=None, mode: str | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def bitop(self, operation, dest, *keys) -> Pipeline[_StrType]: ...
def bitpos(self, key, bit, start=None, end=None, mode: str | None = None) -> Pipeline[_StrType]: ...
def decr(self, name, amount=1) -> Pipeline[_StrType]: ... # type: ignore[override]
def delete(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def __delitem__(self, _Key) -> None: ...
@@ -493,11 +495,13 @@ class Pipeline(Redis[_StrType]):
def exists(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def __contains__(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def expire(self, name: _Key, time: int | timedelta, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override]
def expireat(self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override]
def expireat(
self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False
) -> Pipeline[_StrType]: ...
def get(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def __getitem__(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def __getitem__(self, name) -> Pipeline[_StrType]: ...
def getbit(self, name: _Key, offset: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def getrange(self, key, start, end) -> Pipeline[_StrType]: ... # type: ignore[override]
def getrange(self, key, start, end) -> Pipeline[_StrType]: ...
def getset(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def incr(self, name, amount=1) -> Pipeline[_StrType]: ... # type: ignore[override]
def incrby(self, name, amount=1) -> Pipeline[_StrType]: ... # type: ignore[override]
@@ -510,12 +514,21 @@ class Pipeline(Redis[_StrType]):
def persist(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def pexpire(self, name: _Key, time: int | timedelta, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override]
def pexpireat(self, name: _Key, when: int | datetime, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override]
def psetex(self, name, time_ms, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def psetex(self, name, time_ms, value) -> Pipeline[_StrType]: ...
def pttl(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def randomkey(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def rename(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore[override]
def renamenx(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore[override]
def restore(self, name, ttl, value, replace: bool = False, absttl: bool = False, idletime: Incomplete | None = None, frequency: Incomplete | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def rename(self, src, dst) -> Pipeline[_StrType]: ...
def renamenx(self, src, dst) -> Pipeline[_StrType]: ...
def restore(
self,
name,
ttl,
value,
replace: bool = False,
absttl: bool = False,
idletime: Incomplete | None = None,
frequency: Incomplete | None = None,
) -> Pipeline[_StrType]: ...
def set( # type: ignore[override]
self,
name: _Key,
@@ -533,11 +546,11 @@ class Pipeline(Redis[_StrType]):
def setbit(self, name: _Key, offset: int, value: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def setex(self, name: _Key, time: int | timedelta, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def setnx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def setrange(self, name, offset, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def strlen(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def substr(self, name, start, end=-1) -> Pipeline[_StrType]: ... # type: ignore[override]
def setrange(self, name, offset, value) -> Pipeline[_StrType]: ...
def strlen(self, name) -> Pipeline[_StrType]: ...
def substr(self, name, start, end=-1) -> Pipeline[_StrType]: ...
def ttl(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def type(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def type(self, name) -> Pipeline[_StrType]: ...
def unlink(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def blmove( # type: ignore[override]
self,
@@ -549,7 +562,7 @@ class Pipeline(Redis[_StrType]):
) -> Pipeline[_StrType]: ...
def blpop(self, keys: _Value | Iterable[_Value], timeout: float = 0) -> Pipeline[_StrType]: ... # type: ignore[override]
def brpop(self, keys: _Value | Iterable[_Value], timeout: float = 0) -> Pipeline[_StrType]: ... # type: ignore[override]
def brpoplpush(self, src, dst, timeout=0) -> Pipeline[_StrType]: ... # type: ignore[override]
def brpoplpush(self, src, dst, timeout=0) -> Pipeline[_StrType]: ...
def lindex(self, name: _Key, index: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def linsert( # type: ignore[override]
self, name: _Key, where: Literal["BEFORE", "AFTER", "before", "after"], refvalue: _Value, value: _Value
@@ -562,17 +575,17 @@ class Pipeline(Redis[_StrType]):
src: Literal["LEFT", "RIGHT"] = "LEFT",
dest: Literal["LEFT", "RIGHT"] = "RIGHT",
) -> Pipeline[_StrType]: ...
def lpop(self, name, count: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def lpop(self, name, count: int | None = None) -> Pipeline[_StrType]: ...
def lpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def lpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def lpushx(self, name, value) -> Pipeline[_StrType]: ...
def lrange(self, name: _Key, start: int, end: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def lrem(self, name: _Key, count: int, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def lset(self, name: _Key, index: int, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def ltrim(self, name: _Key, start: int, end: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpop(self, name, count: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpoplpush(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpop(self, name, count: int | None = None) -> Pipeline[_StrType]: ...
def rpoplpush(self, src, dst) -> Pipeline[_StrType]: ...
def rpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpushx(self, name, value) -> Pipeline[_StrType]: ...
def sort( # type: ignore[override]
self,
name: _Key,
@@ -608,8 +621,18 @@ class Pipeline(Redis[_StrType]):
def srem(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def sunion(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def sunionstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def xack(self, name, groupname, *ids) -> Pipeline[_StrType]: ... # type: ignore[override]
def xadd(self, name, fields, id="*", maxlen=None, approximate: bool = True, nomkstream: bool = False, minid: Incomplete | None = None, limit: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xack(self, name, groupname, *ids) -> Pipeline[_StrType]: ...
def xadd(
self,
name,
fields,
id="*",
maxlen=None,
approximate: bool = True,
nomkstream: bool = False,
minid: Incomplete | None = None,
limit: int | None = None,
) -> Pipeline[_StrType]: ...
def xclaim(
self,
name,
@@ -622,23 +645,27 @@ class Pipeline(Redis[_StrType]):
retrycount=None,
force=False,
justid=False,
) -> Pipeline[_StrType]: ... # type: ignore[override]
def xdel(self, name, *ids) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_create(self, name, groupname, id="$", mkstream=False, entries_read: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_delconsumer(self, name, groupname, consumername) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_destroy(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_setid(self, name, groupname, id, entries_read: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xinfo_consumers(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore[override]
def xinfo_groups(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def xinfo_stream(self, name, full: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override]
) -> Pipeline[_StrType]: ...
def xdel(self, name, *ids) -> Pipeline[_StrType]: ...
def xgroup_create(self, name, groupname, id="$", mkstream=False, entries_read: int | None = None) -> Pipeline[_StrType]: ...
def xgroup_delconsumer(self, name, groupname, consumername) -> Pipeline[_StrType]: ...
def xgroup_destroy(self, name, groupname) -> Pipeline[_StrType]: ...
def xgroup_setid(self, name, groupname, id, entries_read: int | None = None) -> Pipeline[_StrType]: ...
def xinfo_consumers(self, name, groupname) -> Pipeline[_StrType]: ...
def xinfo_groups(self, name) -> Pipeline[_StrType]: ...
def xinfo_stream(self, name, full: bool = False) -> Pipeline[_StrType]: ...
def xlen(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def xpending(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore[override]
def xpending_range(self, name: _Key, groupname, min, max, count: int, consumername: Incomplete | None = None, idle: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xrange(self, name, min="-", max="+", count=None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xread(self, streams, count=None, block=None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xreadgroup(self, groupname, consumername, streams, count=None, block=None, noack=False) -> Pipeline[_StrType]: ... # type: ignore[override]
def xrevrange(self, name, max="+", min="-", count=None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xtrim(self, name, maxlen: int | None = None, approximate: bool = True, minid: Incomplete | None = None, limit: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def xpending(self, name, groupname) -> Pipeline[_StrType]: ...
def xpending_range(
self, name: _Key, groupname, min, max, count: int, consumername: Incomplete | None = None, idle: int | None = None
) -> Pipeline[_StrType]: ...
def xrange(self, name, min="-", max="+", count=None) -> Pipeline[_StrType]: ...
def xread(self, streams, count=None, block=None) -> Pipeline[_StrType]: ...
def xreadgroup(self, groupname, consumername, streams, count=None, block=None, noack=False) -> Pipeline[_StrType]: ...
def xrevrange(self, name, max="+", min="-", count=None) -> Pipeline[_StrType]: ...
def xtrim(
self, name, maxlen: int | None = None, approximate: bool = True, minid: Incomplete | None = None, limit: int | None = None
) -> Pipeline[_StrType]: ...
def zadd( # type: ignore[override]
self,
name: _Key,
@@ -722,23 +749,23 @@ class Pipeline(Redis[_StrType]):
def hset(
self, name: _Key, key: _Key, value: _Value, mapping: Mapping[_Key, _Value] | None = None, items: Incomplete | None = None
) -> Pipeline[_StrType]: ...
@overload # type: ignore[override]
@overload
def hset(
self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value], items: Incomplete | None = None
) -> Pipeline[_StrType]: ...
@overload # type: ignore[override]
@overload
def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Pipeline[_StrType]: ...
def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore[override]
def hmget(self, name: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hvals(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def publish(self, channel: _Key, message: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def eval(self, script, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... # type: ignore[override]
def evalsha(self, sha, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_exists(self, *args) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_flush(self, sync_type: Incomplete | None = None) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_kill(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_load(self, script) -> Pipeline[_StrType]: ... # type: ignore[override]
def eval(self, script, numkeys, *keys_and_args) -> Pipeline[_StrType]: ...
def evalsha(self, sha, numkeys, *keys_and_args) -> Pipeline[_StrType]: ...
def script_exists(self, *args) -> Pipeline[_StrType]: ...
def script_flush(self, sync_type: Incomplete | None = None) -> Pipeline[_StrType]: ...
def script_kill(self) -> Pipeline[_StrType]: ...
def script_load(self, script) -> Pipeline[_StrType]: ...
def pubsub_channels(self, pattern: _Key = "*") -> Pipeline[_StrType]: ... # type: ignore[override]
def pubsub_numsub(self, *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def pubsub_numpat(self) -> Pipeline[_StrType]: ... # type: ignore[override]

2
stubs/redis/redis/commands/core.pyi
View File

@@ -1490,7 +1490,7 @@ class AsyncScriptCommands(Generic[_StrType]):
async def script_flush(self, sync_type: Incomplete | None = None): ...
async def script_kill(self): ...
async def script_load(self, script): ...
def register_script(self, script: ScriptTextT) -> AsyncScript: ... # type: ignore[override]
def register_script(self, script: ScriptTextT) -> AsyncScript: ...
class GeoCommands:
def geoadd(self, name, values, nx: bool = False, xx: bool = False, ch: bool = False): ...