Module queue 

Structs

BalancedPusher

Round-robin, non-blocking pusher that fails over when a queue is full or closed.

FanoutPusher

Pusher that offers a clone of each message to every configured queue.

PushError

QueueMetrics

Prometheus instruments shared by queue producers and consumers.

QueueProducer

A clonable producer for a supervised queue.

QueueReceiver

Receiving half of a bounded service queue.

QueueRuntime

Starts a queue and supervises a configurable pool of consumers.

QueueRuntimeConfig

Configuration for a supervised in-process consumer queue.

QueueSender

Sending half of a bounded service queue.

RunningQueue

Control and supervision handle for a running queue.

Enums

PusherConfigError

QueueConfigError

QueueEvent

Lifecycle and processing notifications emitted by a running queue.

QueueRuntimeError

Functions

bounded

Creates a bounded, backpressure-aware queue for asynchronous service handoff.