graylog

README

GrayLog plugin

The Graylog plugin can collect data from remote Graylog service URLs.

Plugin currently support two type of end points:-

• multiple (Ex http://[graylog-server-ip]:12900/system/metrics/multiple)
• namespace (Ex http://[graylog-server-ip]:12900/system/metrics/namespace/{namespace})

End Point can be a mixe of one multiple end point and several namespaces end points

Note: if namespace end point specified metrics array will be ignored for that call.

Configuration:

# Read flattened metrics from one or more GrayLog HTTP endpoints
[[inputs.graylog]]
  ## API endpoint, currently supported API:
  ##
  ##   - multiple  (Ex http://<host>:12900/system/metrics/multiple)
  ##   - namespace (Ex http://<host>:12900/system/metrics/namespace/{namespace})
  ##
  ## For namespace endpoint, the metrics array will be ignored for that call.
  ## Endpoint can contain namespace and multiple type calls.
  ##
  ## Please check http://[graylog-server-ip]:12900/api-browser for full list
  ## of endpoints
  servers = [
    "http://[graylog-server-ip]:12900/system/metrics/multiple",
  ]

  ## Metrics list
  ## List of metrics can be found on Graylog webservice documentation.
  ## Or by hitting the the web service api at:
  ##   http://[graylog-host]:12900/system/metrics
  metrics = [
    "jvm.cl.loaded",
    "jvm.memory.pools.Metaspace.committed"
  ]

  ## Username and password
  username = ""
  password = ""

  ## Optional SSL Config
  # ssl_ca = "/etc/telegraf/ca.pem"
  # ssl_cert = "/etc/telegraf/cert.pem"
  # ssl_key = "/etc/telegraf/key.pem"
  ## Use SSL but skip chain & host verification
  # insecure_skip_verify = false

Please refer to GrayLog metrics api browser for full metric end points http://host:12900/api-browser

Documentation

Index

• type GrayLog
  • func (h *GrayLog) Description() string
  • func (h *GrayLog) Gather(acc telegraf.Accumulator) error
  • func (h *GrayLog) SampleConfig() string
• type HTTPClient
• type Messagebody
• type Metric
• type RealHTTPClient
  • func (c *RealHTTPClient) HTTPClient() *http.Client
  • func (c *RealHTTPClient) MakeRequest(req *http.Request) (*http.Response, error)
  • func (c *RealHTTPClient) SetHTTPClient(client *http.Client)
• type ResponseMetrics

Types

type GrayLog

type GrayLog struct {
	Servers  []string
	Metrics  []string
	Username string
	Password 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 (*GrayLog) Description

func (h *GrayLog) Description() string

func (*GrayLog) Gather

func (h *GrayLog) Gather(acc telegraf.Accumulator) error

Gathers data for all servers.

func (*GrayLog) SampleConfig

func (h *GrayLog) SampleConfig() string

type HTTPClient

type HTTPClient interface {
	// Returns the result of an http request
	//
	// Parameters:
	// req: HTTP request object
	//
	// Returns:
	// http.Response:  HTTP respons object
	// error        :  Any error that may have occurred
	MakeRequest(req *http.Request) (*http.Response, error)

	SetHTTPClient(client *http.Client)
	HTTPClient() *http.Client
}

type Messagebody

type Messagebody struct {
	Metrics []string `json:"metrics"`
}

type Metric

type Metric struct {
	FullName string                 `json:"full_name"`
	Name     string                 `json:"name"`
	Type     string                 `json:"type"`
	Fields   map[string]interface{} `json:"metric"`
}

type RealHTTPClient

type RealHTTPClient struct {
	// contains filtered or unexported fields
}

func (*RealHTTPClient) HTTPClient

func (c *RealHTTPClient) HTTPClient() *http.Client

func (*RealHTTPClient) MakeRequest

func (c *RealHTTPClient) MakeRequest(req *http.Request) (*http.Response, error)

func (*RealHTTPClient) SetHTTPClient

func (c *RealHTTPClient) SetHTTPClient(client *http.Client)

type ResponseMetrics

type ResponseMetrics struct {
	Metrics []Metric `json:"metrics"`
	// contains filtered or unexported fields
}