iii / worker
$worker

queue

v0.1.3

Durable function queues - registers the `durable:subscriber` trigger type and the queue/DLQ service functions.

  • macOS: arm64 · x64
  • Linux: arm64 · armv7 · x64
  • Windows: arm64 · x64 · x86

functions

9

engine::queue::dlq_messages

function

Browse DLQ messages

request
  • limitinteger· uint64min 0
  • offsetinteger· uint64min 0
  • topicstringrequired
response
itemsobject[]
  • errorstringrequired
  • failed_atinteger· uint64requiredmin 0
  • idstringrequired
  • payloadunknownrequired
  • retriesinteger· uint32requiredmin 0
  • size_bytesinteger· uint64requiredmin 0

engine::queue::dlq_topics

function

List DLQ topics with counts

request
empty object
response
itemsobject[]
  • broker_typestringrequired
  • message_countinteger· uint64requiredmin 0
  • topicstringrequired

engine::queue::list_topics

function

List all queue topics

request
empty object
response
itemsobject[]
  • broker_typestringrequired
  • namestringrequired
  • subscriber_countinteger· uint64requiredmin 0

engine::queue::topic_stats

function

Get stats for a queue topic

request
  • topicstringrequired
response
  • configunknown
  • consumer_countinteger· uint64requiredmin 0
  • depthinteger· uint64requiredmin 0
  • dlq_depthinteger· uint64requiredmin 0

iii::durable::publish

function

Enqueue a message

request
  • dataunknownrequired
  • topicstringrequired

    Topic to publish to. `queue` is accepted for the migration worker API.

response
any of (2)
variant 1
empty object
variant 2
valuenull

iii::queue::discard_message

function

Discard (purge) a single DLQ message by ID

request
  • message_idstringrequired
  • queuestringrequired
response
  • message_idstringrequired
  • queuestringrequired
  • redriveninteger· uint64requiredmin 0

iii::queue::redrive

function

Redrive all DLQ messages back to the main queue

request
  • queuestringrequired
response
  • queuestringrequired
  • redriveninteger· uint64requiredmin 0

iii::queue::redrive_message

function

Redrive a single DLQ message by ID back to the main queue

request
  • message_idstringrequired
  • queuestringrequired
response
  • message_idstringrequired
  • queuestringrequired
  • redriveninteger· uint64requiredmin 0

queue::on-config-change

function

Internal: reload queue configuration from the authoritative store.

request
empty object
response
  • okbooleanrequired

triggers

1

durable:subscriber

trigger

Durable queue subscriber

invocation
  • backoff_msinteger· uint64min 0
  • condition_function_idstring
  • max_retriesinteger· uint32min 0
  • queuestringrequired

    Queue/topic name to consume.

  • queue_configany of
    any of (2)
    variant 1
    • backoff_delay_msinteger· uint64min 0
    • backoff_typestring
    • concurrencyinteger· uint32min 0
    • delay_secondsinteger· uint64min 0
    • max_priorityinteger· uint8min 0

      Declares this subscriber's queue as a RabbitMQ priority queue with this many levels (`x-max-priority`, 1–255). RabbitMQ-only; the priority value of each message comes from the adapter-level `priority_field`.

    • max_retriesinteger· uint32min 0
    • typestring
    • visibility_timeoutinteger· uint64min 0
    variant 2
    valuenull
return
valueunknown