iii / worker
$worker

iii-queue

v0.11.6-next.3

Queue worker for async job processing with named queues, retries, and dead-letter support.

engine module
baked into the iii engine; no separate install required.

functions

8

engine::queue::dlq_messages

function

Browse DLQ messages

request
valueunknown
response
valueunknown

engine::queue::dlq_topics

function

List DLQ topics with counts

request
valueunknown
response
valueunknown

engine::queue::list_topics

function

List all queue topics

request
valueunknown
response
valueunknown

engine::queue::topic_stats

function

Get stats for a queue topic

request
valueunknown
response
valueunknown

iii::durable::publish

function

Enqueue a message

request
  • dataunknownrequired
  • topicstringrequired
response
valueunknown

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

triggers

2

log

trigger

Log event trigger

invocation
  • levelany of

    Minimum log level to trigger on

    any of (2)
    variant 1
    valueunknown
    variant 2
    valuenull
return
  • attributesunknownrequired

    Log attributes

  • bodystringrequired

    Log message body

  • instrumentation_scope_namestringrequired

    Instrumentation scope name

  • instrumentation_scope_versionstringrequired

    Instrumentation scope version

  • observed_timestamp_unix_nanointeger· uint64requiredmin 0

    Observed timestamp in nanoseconds

  • resourceunknownrequired

    OpenTelemetry resource

  • service_namestringrequired

    Service name

  • severity_numberinteger· uint32requiredmin 0

    Severity number (OpenTelemetry)

  • severity_textstringrequired

    Severity text (e.g. INFO, ERROR)

  • span_idstringrequired

    Span ID

  • timestamp_unix_nanointeger· uint64requiredmin 0

    Log timestamp in nanoseconds

  • trace_idstringrequired

    Trace ID

durable:subscriber

trigger

Queue core module

invocation
  • condition_function_idstring

    Optional function ID to evaluate before invoking handler

  • queue_configunknown

    Queue-specific subscriber configuration

  • topicstringrequired

    Queue topic to subscribe to

return
valueunknown