Skip to content

Latest commit

 

History

History
32 lines (25 loc) · 1.12 KB

nats.md

File metadata and controls

32 lines (25 loc) · 1.12 KB
Raw

nats: NATS Trigger

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 sepcified in the funtion metadata
Annotations map Annotations sepcified in the funtion metadata

Attributes

Path Type Description
topic string The topic on which to listen
queueName string The name of a shared worker queue to join; (defaults to 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 }}"