disque

package
v0.0.0-...-16a0e24 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 25, 2020 License: MIT Imports: 11 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
var ErrProtocolError = errors.New("disque protocol error")
View Source
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",
}

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL