`kuu.brokers.memory`¶

Module Contents¶

Classes¶

`MemoryReceipt`
`MemoryBroker`

API¶

class kuu.brokers.memory.MemoryReceipt[source]¶

Bases: typing.NamedTuple

queue: str = None¶

seq: int = None¶

class kuu.brokers.memory.MemoryBroker(buffer: int = 1024, pump_interval: float = 0.05)[source]¶

Bases: kuu.brokers.base.Broker[kuu.brokers.memory.MemoryReceipt]

property scheduled_count: int¶

property pending_count: int¶

property dead_count: int¶

dead(queue: str) → list[kuu.message.Message][source]¶: Dead-lettered messages for queue (oldest first).

async connect() → None[source]¶

async close() → None[source]¶

async declare(queue: str) → None[source]¶

async enqueue(msg: kuu.message.Message) → None[source]¶

async schedule(msg: kuu.message.Message, not_before: datetime.datetime) → None[source]¶

async consume(queues: list[str], prefetch: int) → collections.abc.AsyncIterator[kuu.brokers.base.Delivery[kuu.brokers.memory.MemoryReceipt]][source]¶

async revoke(task_id: str) → None[source]¶

async watch_revocations() → collections.abc.AsyncIterator[str][source]¶

async ack(delivery: kuu.brokers.base.Delivery) → None[source]¶

async queue_depth(queue: str) → int | None[source]¶

async nack(delivery: kuu.brokers.base.Delivery, requeue: bool = True, delay: float | None = None) → None[source]¶