consul

README

Telegraf Input Plugin: Consul

This plugin will collect statistics about all helath checks registered in the Consul. It uses Consul API to query the data. It will not report the telemetry but Consul can report those stats already using StatsD protocol if needed.

Configuration:

# Gather health check statuses from services registered in Consul
[[inputs.consul]]
  ## Most of these values defaults to the one configured on a Consul's agent level.
  ## Optional Consul server address (default: "")
  # address = ""
  ## Optional URI scheme for the Consul server (default: "")
  # scheme = ""
  ## Optional ACL token used in every request (default: "")
  # token = ""
  ## Optional username used for request HTTP Basic Authentication (default: "")
  # username = ""
  ## Optional password used for HTTP Basic Authentication (default: "")
  # password = ""
  ## Optional data centre to query the health checks from (default: "")
  # datacentre = ""

Measurements:

Consul:

Tags:

• node: on which node check/service is registered on
• service_name: name of the service (this is the service name not the service ID)
• check_id

Fields:

• check_name
• service_id
• status

Example output

$ telegraf --config ./telegraf.conf -input-filter consul -test
* Plugin: consul, Collection 1
> consul_health_checks,host=wolfpit,node=consul-server-node,check_id="serfHealth" check_name="Serf Health Status",service_id="",status="passing" 1464698464486439902
> consul_health_checks,host=wolfpit,node=consul-server-node,service_name=www.example.com,check_id="service:www-example-com.test01" check_name="Service 'www.example.com' check",service_id="www-example-com.test01",status="critical" 1464698464486519036

Documentation

Index

• type Consul
  • func (c *Consul) Description() string
  • func (c *Consul) Gather(acc telegraf.Accumulator) error
  • func (c *Consul) GatherHealthCheck(acc telegraf.Accumulator, checks []*api.HealthCheck)
  • func (c *Consul) SampleConfig() string

Types

type Consul

type Consul struct {
	Address    string
	Scheme     string
	Token      string
	Username   string
	Password   string
	Datacentre string

	// Path to CA file
	SSLCA string `toml:"ssl_ca"`
	// Path to host cert file
	SSLCert string `toml:"ssl_cert"`
	// Path to cert key file
	SSLKey string `toml:"ssl_key"`
	// Use SSL but skip chain & host verification
	InsecureSkipVerify bool
	// contains filtered or unexported fields
}

func (*Consul) Description

func (c *Consul) Description() string

func (*Consul) Gather

func (c *Consul) Gather(acc telegraf.Accumulator) error

func (*Consul) GatherHealthCheck

func (c *Consul) GatherHealthCheck(acc telegraf.Accumulator, checks []*api.HealthCheck)

func (*Consul) SampleConfig

func (c *Consul) SampleConfig() string