Skip to main content

Module queue

Module queue 

Source
Expand description

Request queue for burst traffic handling

Bounded dual-priority queue using tokio channels. Requests are queued when all backends are at capacity and drained as capacity becomes available.

Structs§

QueuedRequest
A request waiting in the queue
RequestQueue
Bounded dual-priority request queue.

Enums§

Priority
Priority level for queued requests
QueueError
Errors from queue operations

Functions§

build_timeout_response
Build a 503 response with retry_after header for timed-out requests.
queue_drain_loop
Background drain loop that processes queued requests as capacity becomes available.

Type Aliases§

QueueResponse
Response sent back through the oneshot channel