disque

README

Disque Input

Disque is an ongoing experiment to build a distributed, in-memory, message broker.

Configuration:

[[inputs.disque]]  
  ## An array of URI to gather stats about. Specify an ip or hostname
  ## with optional port and password.
  ## ie disque://localhost, disque://10.10.3.33:18832, 10.0.0.1:10000, etc.
  ## If no servers are specified, then localhost is used as the host.
  servers = ["localhost"]

Metrics

• disque
  • disque_host
    • uptime_in_seconds
    • connected_clients
    • blocked_clients
    • used_memory
    • used_memory_rss
    • used_memory_peak
    • total_connections_received
    • total_commands_processed
    • instantaneous_ops_per_sec
    • latest_fork_usec
    • mem_fragmentation_ratio
    • used_cpu_sys
    • used_cpu_user
    • used_cpu_sys_children
    • used_cpu_user_children
    • registered_jobs
    • registered_queues

Documentation

Index

• Variables
• type Disque
  • func (r *Disque) Description() string
  • func (g *Disque) Gather(acc telegraf.Accumulator) error
  • func (r *Disque) SampleConfig() string

Variables

var ErrProtocolError = errors.New("disque protocol error")

var Tracking = map[string]string{
	"uptime_in_seconds":          "uptime",
	"connected_clients":          "clients",
	"blocked_clients":            "blocked_clients",
	"used_memory":                "used_memory",
	"used_memory_rss":            "used_memory_rss",
	"used_memory_peak":           "used_memory_peak",
	"total_connections_received": "total_connections_received",
	"total_commands_processed":   "total_commands_processed",
	"instantaneous_ops_per_sec":  "instantaneous_ops_per_sec",
	"latest_fork_usec":           "latest_fork_usec",
	"mem_fragmentation_ratio":    "mem_fragmentation_ratio",
	"used_cpu_sys":               "used_cpu_sys",
	"used_cpu_user":              "used_cpu_user",
	"used_cpu_sys_children":      "used_cpu_sys_children",
	"used_cpu_user_children":     "used_cpu_user_children",
	"registered_jobs":            "registered_jobs",
	"registered_queues":          "registered_queues",
}

Types

type Disque

type Disque struct {
	Servers []string
	// contains filtered or unexported fields
}

func (*Disque) Description

func (r *Disque) Description() string

func (*Disque) Gather

func (g *Disque) Gather(acc telegraf.Accumulator) error

Reads stats from all configured servers accumulates stats. Returns one of the errors encountered while gather stats (if any).

func (*Disque) SampleConfig

func (r *Disque) SampleConfig() string