Skip to content

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
async def sadd(self, key: str, member: str) -> None: ...

smembers async

smembers(key)
Source code in peagen/plugins/queues/base.py
8
async def smembers(self, key: str) -> list[str]: ...

rpush async

rpush(key, value)
Source code in peagen/plugins/queues/base.py
9
async def rpush(self, key: str, value: str) -> None: ...

lrange async

lrange(key, start, end)
Source code in peagen/plugins/queues/base.py
10
async def lrange(self, key: str, start: int, end: int) -> list[str]: ...

blpop async

blpop(keys, timeout)
Source code in peagen/plugins/queues/base.py
11
12
13
async def blpop(
    self, keys: list[str], timeout: float
) -> tuple[str, str] | None: ...

brpop async

brpop(keys, timeout)
Source code in peagen/plugins/queues/base.py
14
15
16
async def brpop(
    self, keys: list[str], timeout: float
) -> tuple[str, str] | None: ...

get async

get(key)
Source code in peagen/plugins/queues/base.py
17
async def get(self, key: str) -> dict[str, Any]: ...

set async

set(key, mapping)
Source code in peagen/plugins/queues/base.py
18
async def set(self, key: str, mapping: dict[str, Any]) -> None: ...

hset async

hset(key, mapping)
Source code in peagen/plugins/queues/base.py
19
async def hset(self, key: str, mapping: dict[str, Any]) -> None: ...

hgetall async

hgetall(key)
Source code in peagen/plugins/queues/base.py
20
async def hgetall(self, key: str) -> dict[str, Any]: ...

hget async

hget(key, field)
Source code in peagen/plugins/queues/base.py
21
async def hget(self, key: str, field: str) -> str | None: ...

expire async

expire(key, ttl)
Source code in peagen/plugins/queues/base.py
22
async def expire(self, key: str, ttl: int) -> None: ...

exists async

exists(key)
Source code in peagen/plugins/queues/base.py
23
async def exists(self, key: str) -> bool: ...

keys async

keys(pattern)
Source code in peagen/plugins/queues/base.py
24
async def keys(self, pattern: str) -> list[str]: ...

publish async

publish(channel, message)
Source code in peagen/plugins/queues/base.py
25
async def publish(self, channel: str, message: str) -> None: ...