rabbitmq

package
v0.1.9 Latest Latest
Warning

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

Go to latest
Published: Sep 22, 2015 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultPassword = "guest"
View Source
const DefaultURL = "http://localhost:15672"
View Source
const DefaultUsername = "guest"

Variables

This section is empty.

Functions

This section is empty.

Types

type MessageStats

type MessageStats struct {
	Ack     int64
	Deliver int64
	Publish int64
}

type Node

type Node struct {
	Name string

	DiskFree      int64 `json:"disk_free"`
	DiskFreeLimit int64 `json:"disk_free_limit"`
	FdTotal       int64 `json:"fd_total"`
	FdUsed        int64 `json:"fd_used"`
	MemLimit      int64 `json:"mem_limit"`
	MemUsed       int64 `json:"mem_used"`
	ProcTotal     int64 `json:"proc_total"`
	ProcUsed      int64 `json:"proc_used"`
	RunQueue      int64 `json:"run_queue"`
	SocketsTotal  int64 `json:"sockets_total"`
	SocketsUsed   int64 `json:"sockets_used"`
}

type ObjectTotals

type ObjectTotals struct {
	Channels    int64
	Connections int64
	Consumers   int64
	Exchanges   int64
	Queues      int64
}

type OverviewResponse

type OverviewResponse struct {
	MessageStats *MessageStats `json:"message_stats"`
	ObjectTotals *ObjectTotals `json:"object_totals"`
	QueueTotals  *QueueTotals  `json:"queue_totals"`
}

type QueueTotals

type QueueTotals struct {
	Messages               int64
	MessagesReady          int64 `json:"messages_ready"`
	MessagesUnacknowledged int64 `json:"messages_unacknowledged"`
}

type RabbitMQ

type RabbitMQ struct {
	Servers []*Server

	Client *http.Client
}

func (*RabbitMQ) Description

func (r *RabbitMQ) Description() string

func (*RabbitMQ) Gather

func (r *RabbitMQ) Gather(acc plugins.Accumulator) error

func (*RabbitMQ) SampleConfig

func (r *RabbitMQ) SampleConfig() string

type Server

type Server struct {
	URL      string
	Name     string
	Username string
	Password string
	Nodes    []string
}

Jump to

Keyboard shortcuts

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