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

async def sadd(self, key: str, member: str) -> None: ...

smembers async

smembers(key)

Source code in peagen/plugins/queues/base.py

async def smembers(self, key: str) -> list[str]: ...

rpush async

rpush(key, value)

Source code in peagen/plugins/queues/base.py

async def rpush(self, key: str, value: str) -> None: ...

lrange async

lrange(key, start, end)

Source code in peagen/plugins/queues/base.py

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

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

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

async def get(self, key: str) -> dict[str, Any]: ...

set async

set(key, mapping)

Source code in peagen/plugins/queues/base.py

async def set(self, key: str, mapping: dict[str, Any]) -> None: ...

hset async

hset(key, mapping)

Source code in peagen/plugins/queues/base.py

async def hset(self, key: str, mapping: dict[str, Any]) -> None: ...

hgetall async

hgetall(key)

Source code in peagen/plugins/queues/base.py

async def hgetall(self, key: str) -> dict[str, Any]: ...

hget async

hget(key, field)

Source code in peagen/plugins/queues/base.py

async def hget(self, key: str, field: str) -> str | None: ...

expire async

expire(key, ttl)

Source code in peagen/plugins/queues/base.py

async def expire(self, key: str, ttl: int) -> None: ...

exists async

exists(key)

Source code in peagen/plugins/queues/base.py

async def exists(self, key: str) -> bool: ...

keys async

keys(pattern)

Source code in peagen/plugins/queues/base.py

async def keys(self, pattern: str) -> list[str]: ...

publish async

publish(channel, message)

Source code in peagen/plugins/queues/base.py

async def publish(self, channel: str, message: str) -> None: ...