disque

Documentation

Index

• Variables
• type Disque
  • func (r *Disque) Description() string
  • func (g *Disque) Gather(acc inputs.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 inputs.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