Add redis stream methods to the client stubs (#3051)

This commit is contained in:
Joe Juzl
2019-06-13 18:24:39 +02:00
committed by Jelle Zijlstra
parent 8e7c32846f
commit 8ffe20fc22

View File

@@ -201,6 +201,37 @@ class Redis(object):
def srem(self, name, *values): ...
def sunion(self, keys, *args): ...
def sunionstore(self, dest, keys, *args): ...
def xack(self, name, groupname, *ids): ...
def xadd(self, name, fields, id=..., maxlen=..., approximate=...): ...
def xclaim(
self,
name,
groupname,
consumername,
min_idle_time,
message_ids,
idle=...,
time=...,
retrycount=...,
force=...,
justid=...,
): ...
def xdel(self, name, *ids): ...
def xgroup_create(self, name, groupname, id=..., mkstream=...): ...
def xgroup_delconsumer(self, name, groupname, consumername): ...
def xgroup_destroy(self, name, groupname): ...
def xgroup_setid(self, name, groupname, id): ...
def xinfo_consumers(self, name, groupname): ...
def xinfo_groups(self, name): ...
def xinfo_stream(self, name): ...
def xlen(self, name): ...
def xpending(self, name, groupname): ...
def xpending_range(self, name, groupname, min, max, count, consumername=...): ...
def xrange(self, name, min=..., max=..., count=...): ...
def xread(self, streams, count=..., block=...): ...
def xreadgroup(self, groupname, consumername, streams, count=..., block=..., noack=...): ...
def xrevrange(self, name, max=..., min=..., count=...): ...
def xtrim(self, name, maxlen, approximate=...): ...
def zadd(self, name, mapping, nx: bool = ..., xx: bool = ..., ch: bool = ..., incr: bool = ...): ...
def zcard(self, name): ...
def zcount(self, name, min, max): ...