Skip to content
Registry

pubsub

v0.21.1

pubsub is deprecated (pubsub) and will be removed in an upcoming release. Behavior is unchanged for now. Migration guide: https://github.com/iii-hq/iii/blob/6901a589dd39d9c34f9d5b6bd8bc82170ee21548/docs/next/upgrading/migrate-from-streams.mdx — Topic-based publish/subscribe messaging; registers the `subscribe` trigger type and the `publish` function.

eventsmessagingpubsubtopics
Deprecated

pubsub is deprecated and will be removed in an upcoming release. Behavior is unchanged for now. For fan-out notifications, have your worker register its own trigger type; when delivery must not be lost, use the queue worker (iii::durable::publish + durable:subscriber). Migration guide: https://iii.dev/docs/upgrading/migrate-from-streams

Install

bash
iii trigger compose::add worker=pubsub@0.21.1

Run in your project with the iii engine running. Exact versions are immutable and digest-pinned.

Functions2

publish

Function

Publishes an event

Request
  • dataunknownrequired

    JSON payload delivered to each subscriber.

  • topicstringrequired

    Topic to publish to. Subscribers registered for this topic receive the event.

Response
valuenull

pubsub::on-config-change

Function

Internal: reload pubsub configuration from the authoritative store on change.

Request
Empty object
Response
  • okbooleanrequired

Triggers1

subscribe

Trigger

Subscribe to a topic

Invocation
  • condition_function_idstring

    Optional function ID to evaluate before invoking handler. Accepted for schema parity; the builtin never evaluated it and neither does this worker.

  • topicstringrequired

    Topic to subscribe to

Return
valueunknown

Search the registry

Find workers, kits and executables, or jump to a page.