nats

README

NATS Input Plugin

The NATS monitoring plugin gathers metrics from the NATS monitoring http server.

Configuration

[[inputs.nats]]
  ## The address of the monitoring endpoint of the NATS server
  server = "http://localhost:8222"

  ## Maximum time to receive response
  # response_timeout = "5s"

Metrics:

• nats
  • tags
    • server
  • fields:
    • uptime (integer, nanoseconds)
    • mem (integer, bytes)
    • subscriptions (integer, count)
    • out_bytes (integer, bytes)
    • connections (integer, count)
    • in_msgs (integer, bytes)
    • total_connections (integer, count)
    • cores (integer, count)
    • cpu (integer, count)
    • slow_consumers (integer, count)
    • routes (integer, count)
    • remotes (integer, count)
    • out_msgs (integer, count)
    • in_bytes (integer, bytes)

Example Output:

nats,server=http://localhost:8222 uptime=117158348682i,mem=6647808i,subscriptions=0i,out_bytes=0i,connections=0i,in_msgs=0i,total_connections=0i,cores=2i,cpu=0,slow_consumers=0i,routes=0i,remotes=0i,out_msgs=0i,in_bytes=0i 1517015107000000000

Documentation

Index

• type Nats
  • func (n *Nats) Description() string
  • func (n *Nats) Gather(acc telegraf.Accumulator) error
  • func (n *Nats) SampleConfig() string

Types

type Nats

type Nats struct {
	Server          string
	ResponseTimeout config.Duration
	// contains filtered or unexported fields
}

func (*Nats) Description

func (n *Nats) Description() string

func (*Nats) Gather

func (n *Nats) Gather(acc telegraf.Accumulator) error

func (*Nats) SampleConfig

func (n *Nats) SampleConfig() string