`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]

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 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]¶