nats: NATS Trigger

On This Page

Reads messages from NATS topics. Function replicas are subscribed to a worker group (queue), and messages are load-balanced across replicas. To join a specific worker group, specify a queue-name attribute in the trigger configuration.

The queue name may be a Go template, which may include any of the following fields:

Name Type Description
Id string The trigger id
Namespace string The function deployment namespace
Name string The deployed function name
Labels map Labels specified in the function metadata
Annotations map Annotations specified in the function metadata

Attributes

Path Type Description
topic string The topic on which to listen.
queueName string The name of a shared worker queue to join; (default: an auto-generated name per trigger).

Example

triggers:
  myNatsTopic:
    kind: "nats"
    url: "nats://10.0.0.3:4222"
    attributes:
      "topic": "my.topic"
      "queueName": "{{ .Namespace }}.{{ .Name }}.{{ .Id }}"