mcrouter

README

Mcrouter Input Plugin

This plugin gathers statistics data from a Mcrouter server.

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 one or many mcrouter servers.
[[inputs.mcrouter]]
  ## An array of address to gather stats about. Specify an ip or hostname
  ## with port. ie tcp://localhost:11211, tcp://10.0.0.1:11211, etc.
  servers = ["tcp://localhost:11211", "unix:///var/run/mcrouter.sock"]

  ## Timeout for metric collections from all servers.  Minimum timeout is "1s".
  # timeout = "5s"

Metrics

The fields from this plugin are gathered in the mcrouter measurement.

Description of gathered fields can be found here.

Fields:

• uptime
• num_servers
• num_servers_new
• num_servers_up
• num_servers_down
• num_servers_closed
• num_clients
• num_suspect_servers
• destination_batches_sum
• destination_requests_sum
• outstanding_route_get_reqs_queued
• outstanding_route_update_reqs_queued
• outstanding_route_get_avg_queue_size
• outstanding_route_update_avg_queue_size
• outstanding_route_get_avg_wait_time_sec
• outstanding_route_update_avg_wait_time_sec
• retrans_closed_connections
• destination_pending_reqs
• destination_inflight_reqs
• destination_batch_size
• asynclog_requests
• proxy_reqs_processing
• proxy_reqs_waiting
• client_queue_notify_period
• rusage_system
• rusage_user
• ps_num_minor_faults
• ps_num_major_faults
• ps_user_time_sec
• ps_system_time_sec
• ps_vsize
• ps_rss
• fibers_allocated
• fibers_pool_size
• fibers_stack_high_watermark
• successful_client_connections
• duration_us
• destination_max_pending_reqs
• destination_max_inflight_reqs
• retrans_per_kbyte_max
• cmd_get_count
• cmd_delete_out
• cmd_lease_get
• cmd_set
• cmd_get_out_all
• cmd_get_out
• cmd_lease_set_count
• cmd_other_out_all
• cmd_lease_get_out
• cmd_set_count
• cmd_lease_set_out
• cmd_delete_count
• cmd_other
• cmd_delete
• cmd_get
• cmd_lease_set
• cmd_set_out
• cmd_lease_get_count
• cmd_other_out
• cmd_lease_get_out_all
• cmd_set_out_all
• cmd_other_count
• cmd_delete_out_all
• cmd_lease_set_out_all

Tags

• Mcrouter measurements have the following tags:
  • server (the host name from which metrics are gathered)

Example Output

$ ./telegraf --config telegraf.conf --input-filter mcrouter --test
mcrouter,server=localhost:11211 uptime=166,num_servers=1,num_servers_new=1,num_servers_up=0,num_servers_down=0,num_servers_closed=0,num_clients=1,num_suspect_servers=0,destination_batches_sum=0,destination_requests_sum=0,outstanding_route_get_reqs_queued=0,outstanding_route_update_reqs_queued=0,outstanding_route_get_avg_queue_size=0,outstanding_route_update_avg_queue_size=0,outstanding_route_get_avg_wait_time_sec=0,outstanding_route_update_avg_wait_time_sec=0,retrans_closed_connections=0,destination_pending_reqs=0,destination_inflight_reqs=0,destination_batch_size=0,asynclog_requests=0,proxy_reqs_processing=1,proxy_reqs_waiting=0,client_queue_notify_period=0,rusage_system=0.040966,rusage_user=0.020483,ps_num_minor_faults=2490,ps_num_major_faults=11,ps_user_time_sec=0.02,ps_system_time_sec=0.04,ps_vsize=697741312,ps_rss=10563584,fibers_allocated=0,fibers_pool_size=0,fibers_stack_high_watermark=0,successful_client_connections=18,duration_us=0,destination_max_pending_reqs=0,destination_max_inflight_reqs=0,retrans_per_kbyte_max=0,cmd_get_count=0,cmd_delete_out=0,cmd_lease_get=0,cmd_set=0,cmd_get_out_all=0,cmd_get_out=0,cmd_lease_set_count=0,cmd_other_out_all=0,cmd_lease_get_out=0,cmd_set_count=0,cmd_lease_set_out=0,cmd_delete_count=0,cmd_other=0,cmd_delete=0,cmd_get=0,cmd_lease_set=0,cmd_set_out=0,cmd_lease_get_count=0,cmd_other_out=0,cmd_lease_get_out_all=0,cmd_set_out_all=0,cmd_other_count=0,cmd_delete_out_all=0,cmd_lease_set_out_all=0 1453831884664956455

Documentation

Index

• type Mcrouter
  • func (m *Mcrouter) Gather(acc telegraf.Accumulator) error
  • func (m *Mcrouter) ParseAddress(address string) (parsedAddress string, protocol string, err error)
  • func (*Mcrouter) SampleConfig() string

Types

type Mcrouter

type Mcrouter struct {
	Servers []string
	Timeout config.Duration
}

Mcrouter is a mcrouter plugin

func (*Mcrouter) Gather

func (m *Mcrouter) Gather(acc telegraf.Accumulator) error

Gather reads stats from all configured servers accumulates stats

func (*Mcrouter) ParseAddress

func (m *Mcrouter) ParseAddress(address string) (parsedAddress string, protocol string, err error)

ParseAddress parses an address string into 'host:port' and 'protocol' parts

func (*Mcrouter) SampleConfig

func (*Mcrouter) SampleConfig() string