diff options
author | Andy McCurdy <andy@andymccurdy.com> | 2018-10-31 15:17:09 -0700 |
---|---|---|
committer | Andy McCurdy <andy@andymccurdy.com> | 2018-10-31 15:17:09 -0700 |
commit | 5f7b956fb1d389e23cdfc4e1e1809fa6662ac368 (patch) | |
tree | 027f8c5ae756c7be5847b97f9e6fb73251ec3156 | |
parent | a3cfa77ab01e56d8af6d40c2d9e31f56017ef3eb (diff) | |
download | redis-py-5f7b956fb1d389e23cdfc4e1e1809fa6662ac368.tar.gz |
alphabetize part 2
-rwxr-xr-x | redis/client.py | 62 |
1 files changed, 31 insertions, 31 deletions
diff --git a/redis/client.py b/redis/client.py index a080a5c..1e06f18 100755 --- a/redis/client.py +++ b/redis/client.py @@ -2008,6 +2008,37 @@ class StrictRedis(object): pieces.extend(streams.values()) return self.execute_command('XREAD', *pieces) + def xreadgroup(self, groupname, consumername, streams, count=None, + block=None): + """ + Read from a stream via a consumer group. + groupname: name of the consumer group. + consumername: name of the requesting consumer. + streams: a dict of stream names to stream IDs, where + IDs indicate the last ID already seen. + count: if set, only return this many items, beginning with the + earliest available. + block: number of milliseconds to wait, if nothing already present. + """ + pieces = [Token.get_token('GROUP'), groupname, consumername] + if count is not None: + if not isinstance(count, (int, long)) or count < 1: + raise RedisError("XREADGROUP count must be a positive integer") + pieces.append(Token.get_token("COUNT")) + pieces.append(str(count)) + if block is not None: + if not isinstance(block, (int, long)) or block < 0: + raise RedisError("XREADGROUP block must be a non-negative " + "integer") + pieces.append(Token.get_token("BLOCK")) + pieces.append(str(block)) + if not isinstance(streams, dict) or len(streams) == 0: + raise RedisError('XREADGROUP streams must be a non empty dict') + pieces.append(Token.get_token('STREAMS')) + pieces.extend(streams.keys()) + pieces.extend(streams.values()) + return self.execute_command('XREADGROUP', *pieces) + def xrevrange(self, name, start='+', finish='-', count=None): """ Read stream values within an interval, in reverse order. @@ -2041,37 +2072,6 @@ class StrictRedis(object): pieces.append(maxlen) return self.execute_command('XTRIM', name, *pieces) - def xreadgroup(self, groupname, consumername, streams, count=None, - block=None): - """ - Read from a stream via a consumer group. - groupname: name of the consumer group. - consumername: name of the requesting consumer. - streams: a dict of stream names to stream IDs, where - IDs indicate the last ID already seen. - count: if set, only return this many items, beginning with the - earliest available. - block: number of milliseconds to wait, if nothing already present. - """ - pieces = [Token.get_token('GROUP'), groupname, consumername] - if count is not None: - if not isinstance(count, (int, long)) or count < 1: - raise RedisError("XREADGROUP count must be a positive integer") - pieces.append(Token.get_token("COUNT")) - pieces.append(str(count)) - if block is not None: - if not isinstance(block, (int, long)) or block < 0: - raise RedisError("XREADGROUP block must be a non-negative " - "integer") - pieces.append(Token.get_token("BLOCK")) - pieces.append(str(block)) - if not isinstance(streams, dict) or len(streams) == 0: - raise RedisError('XREADGROUP streams must be a non empty dict') - pieces.append(Token.get_token('STREAMS')) - pieces.extend(streams.keys()) - pieces.extend(streams.values()) - return self.execute_command('XREADGROUP', *pieces) - # SORTED SET COMMANDS def zadd(self, name, *args, **kwargs): """ |