Class peagen.plugins.queues.base.QueueBase
peagen.plugins.queues.base.QueueBase
Bases: Protocol
sadd
async
sadd(key, member)
Source code in peagen/plugins/queues/base.py
7 |
|
smembers
async
smembers(key)
Source code in peagen/plugins/queues/base.py
8 |
|
rpush
async
rpush(key, value)
Source code in peagen/plugins/queues/base.py
9 |
|
lrange
async
lrange(key, start, end)
Source code in peagen/plugins/queues/base.py
10 |
|
blpop
async
blpop(keys, timeout)
Source code in peagen/plugins/queues/base.py
11 12 13 |
|
brpop
async
brpop(keys, timeout)
Source code in peagen/plugins/queues/base.py
14 15 16 |
|
get
async
get(key)
Source code in peagen/plugins/queues/base.py
17 |
|
set
async
set(key, mapping)
Source code in peagen/plugins/queues/base.py
18 |
|
hset
async
hset(key, mapping)
Source code in peagen/plugins/queues/base.py
19 |
|
hgetall
async
hgetall(key)
Source code in peagen/plugins/queues/base.py
20 |
|
hget
async
hget(key, field)
Source code in peagen/plugins/queues/base.py
21 |
|
expire
async
expire(key, ttl)
Source code in peagen/plugins/queues/base.py
22 |
|
exists
async
exists(key)
Source code in peagen/plugins/queues/base.py
23 |
|
keys
async
keys(pattern)
Source code in peagen/plugins/queues/base.py
24 |
|
publish
async
publish(channel, message)
Source code in peagen/plugins/queues/base.py
25 |
|