NATS trigger#
NOTE: NATS trigger is in tech-preview.
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 }}"