Skip to main content

Module queue

Module queue 

Source
Expand description

Redis-backed queue implementation.

WARNING: This module should ONLY be used by infraqueue-server. All other components (senders, consumers, CLI) MUST use InfraQueueClient from lib::client to communicate via the HTTP API.

Structs§

DequeueWithReceipt
Result of dequeue with receipt token for ack/nack. In LLM workflows, treat receipt like a visibility token; your worker:
InfraQueueQueue
A minimal queue facade backed by Redis per topic.
RetryPolicy
Retry/backoff policy configuration.

Enums§

NackOutcome
Outcome of a NACK operation.