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
- disque_host
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 (*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 ¶
Click to show internal directories.
Click to hide internal directories.