fluent-plugin-nats

NATS plugin for fluentd Event Collector

Requirements

Getting Started

Setup the NATS input:

  <source>
    @type nats
    tag nats
    host localhost
    port 4222
    user nats
    password nats
    queues fluent.>,fluent2.>
    ssl false
  </source>

Setup the match output:

  <match nats.fluent.**>
    @type stdout
  </match>

Configuration

Plugin helpers

• thread

• See also: Fluent::Plugin::Input

Fluent::Plugin::NATSInput

• host (string) (optional): NATS server hostname
  • Default value: localhost
• user (string) (optional): Username for authorized connection
  • Default value: nats
• password (string) (optional): Password for authorized connection
  • Default value: nats
• port (integer) (optional): NATS server port
  • Default value: 4222
• queues (array) (optional): Subscribing queue names
  • Default value: ["fluent.>"]
• queue (string) (optional):
  • Default value: fluent.>
  • Obsoleted: Use queues instead
• tag (string) (optional): The tag prepend before queue name
  • Default value: nats
• ssl (bool) (optional): Enable secure SSL/TLS connection
  • Default value: false
• max_reconnect_attempts (integer) (optional): The max number of reconnect tries
  • Default value: 150
• reconnect_time_wait (integer) (optional): The number of seconds to wait between reconnect tries
  • Default value: 2

Suitable Queues

Components

• dea.>
• cloudcontrollers.>
• router.>
• cloudcontroller.>
• vcap.>
• droplet.>
• healthmanager.>

Services

• FilesystemaaS.>
• AtmosaaS.>
• MongoaaS.>
• MyaaS.>
• Neo4jaaS.>
• AuaaS.>
• RMQaaS.>
• RaaS.>