net_response

README

Network Response Input Plugin

The input plugin test UDP/TCP connections response time and can optional verify text in the response.

Configuration:

# Collect response time of a TCP or UDP connection
[[inputs.net_response]]
  ## Protocol, must be "tcp" or "udp"
  ## NOTE: because the "udp" protocol does not respond to requests, it requires
  ## a send/expect string pair (see below).
  protocol = "tcp"
  ## Server address (default localhost)
  address = "localhost:80"

  ## Set timeout
  # timeout = "1s"

  ## Set read timeout (only used if expecting a response)
  # read_timeout = "1s"

  ## The following options are required for UDP checks. For TCP, they are
  ## optional. The plugin will send the given string to the server and then
  ## expect to receive the given 'expect' string back.
  ## string sent to the server
  # send = "ssh"
  ## expected string in answer
  # expect = "ssh"

  ## Uncomment to remove deprecated fields; recommended for new deploys
  # fieldexclude = ["result_type", "string_found"]

Metrics:

• net_response
  • tags:
    • server
    • port
    • protocol
    • result
  • fields:
    • response_time (float, seconds)
    • success (int) # success 0, failure 1
    • result_code (int, success = 0, timeout = 1, connection_failed = 2, read_failed = 3, string_mismatch = 4)
    • result_type (string) DEPRECATED in 1.7; use result tag
    • string_found (boolean) DEPRECATED in 1.4; use result tag

Example Output:

net_response,port=8086,protocol=tcp,result=success,server=localhost response_time=0.000092948,result_code=0i,result_type="success" 1525820185000000000
net_response,port=8080,protocol=tcp,result=connection_failed,server=localhost result_code=2i,result_type="connection_failed" 1525820088000000000
net_response,port=8080,protocol=udp,result=read_failed,server=localhost result_code=3i,result_type="read_failed",string_found=false 1525820088000000000

Documentation

Index

• Constants
• type NetResponse
  • func (*NetResponse) Description() string
  • func (n *NetResponse) Gather(acc telegraf.Accumulator) error
  • func (*NetResponse) SampleConfig() string
  • func (n *NetResponse) TCPGather() (tags map[string]string, fields map[string]interface{})
  • func (n *NetResponse) UDPGather() (tags map[string]string, fields map[string]interface{})
• type ResultType

Constants

const (
	Success          ResultType = 0
	Timeout                     = 1
	ConnectionFailed            = 2
	ReadFailed                  = 3
	StringMismatch              = 4
)

Types

type NetResponse

type NetResponse struct {
	Address     string
	Timeout     internal.Duration
	ReadTimeout internal.Duration
	Send        string
	Expect      string
	Protocol    string
}

NetResponse struct

func (*NetResponse) Description

func (*NetResponse) Description() string

Description will return a short string to explain what the plugin does.

func (*NetResponse) Gather

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

Gather is called by telegraf when the plugin is executed on its interval. It will call either UDPGather or TCPGather based on the configuration and also fill an Accumulator that is supplied.

func (*NetResponse) SampleConfig

func (*NetResponse) SampleConfig() string

SampleConfig will return a complete configuration example with details about each field.

func (*NetResponse) TCPGather

func (n *NetResponse) TCPGather() (tags map[string]string, fields map[string]interface{})

TCPGather will execute if there are TCP tests defined in the configuration. It will return a map[string]interface{} for fields and a map[string]string for tags

func (*NetResponse) UDPGather

func (n *NetResponse) UDPGather() (tags map[string]string, fields map[string]interface{})

UDPGather will execute if there are UDP tests defined in the configuration. It will return a map[string]interface{} for fields and a map[string]string for tags

type ResultType

type ResultType uint64