nomad

README

Hashicorp Nomad Input Plugin

The Nomad plugin must grab metrics from every Nomad agent of the cluster. Telegraf may be present in every node and connect to the agent locally. In this case should be something like http://127.0.0.1:4646.

Tested on Nomad 1.1.6

Global configuration options

In addition to the plugin-specific configuration settings, plugins support additional global and plugin configuration settings. These settings are used to modify metrics, tags, and field or create aliases and configure ordering, etc. See the CONFIGURATION.md for more details.

Configuration

# Read metrics from the Nomad API
[[inputs.nomad]]
  ## URL for the Nomad agent
  # url = "http://127.0.0.1:4646"

  ## Set response_timeout (default 5 seconds)
  # response_timeout = "5s"

  ## Optional TLS Config
  # tls_ca = /path/to/cafile
  # tls_cert = /path/to/certfile
  # tls_key = /path/to/keyfile

Metrics

Both Nomad servers and agents collect various metrics. For every details, please have a look at Nomad following documentation:

• https://www.nomadproject.io/docs/operations/metrics
• https://www.nomadproject.io/docs/operations/telemetry

Example Output

Documentation

Index

• type AggregateSample
• type Nomad
  • func (n *Nomad) Gather(acc telegraf.Accumulator) error
  • func (n *Nomad) Init() error
  • func (*Nomad) SampleConfig() string

Types

type AggregateSample

type AggregateSample struct {
	Count       int       `json:"count"`
	Rate        float64   `json:"rate"`
	Sum         float64   `json:"sum"`
	SumSq       float64   `json:"-"`
	Min         float64   `json:"min"`
	Max         float64   `json:"max"`
	LastUpdated time.Time `json:"-"`
}

AggregateSample needs to be exported, because JSON decode cannot set embedded pointer to unexported struct

type Nomad

type Nomad struct {
	URL             string          `toml:"url"`
	ResponseTimeout config.Duration `toml:"response_timeout"`
	tls.ClientConfig
	// contains filtered or unexported fields
}

func (*Nomad) Gather

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

func (*Nomad) Init

func (n *Nomad) Init() error

func (*Nomad) SampleConfig

func (*Nomad) SampleConfig() string