rabbitmq

Documentation

Index

• type RabbitMQCollector
  • func NewRabbitMQCollector() *RabbitMQCollector
• type RabbitMQRule
  • func (p *RabbitMQRule) TelegrafInput() (telegraf.Input, error)
  • func (p *RabbitMQRule) Validate() error

Types

type RabbitMQCollector

type RabbitMQCollector struct {
	*collector.BaseCollector
}

func NewRabbitMQCollector

func NewRabbitMQCollector() *RabbitMQCollector

type RabbitMQRule

type RabbitMQRule struct {
	URL                       string   `label:"URL" json:"url,required" example:"http://localhost:15672"`
	Name                      string   `label:"Name" json:"Name" description:"Tag added to rabbitmq_overview series"`
	Username                  string   `label:"Username" json:"username,required" description:"specify username"`
	Password                  string   `label:"Password" json:"password,required" format:"password" description:"specify server password"`
	ResponseHeaderTimeout     int      `` /* 135-byte string literal not displayed */
	ClientTimeout             int      `` /* 135-byte string literal not displayed */
	Nodes                     []string `label:"nodes" json:"nodes" description:"A list of nodes to gather as the rabbitmq_node measurement"`
	Queues                    []string `label:"queues" json:"queues" description:"A list of queues to gather as the rabbitmq_queue measurement"`
	Exchanges                 []string `label:"exchanges" json:"exchanges" description:"A list of exchanges to gather as the rabbitmq_exchange measurement"`
	QueueNameInclude          []string `label:"queue name include" json:"queue_name_include" description:"Queues to include."`
	QueueNameExclude          []string `label:"queue name exclude" json:"queue_name_exclude" description:"Queues to exclude."`
	FederationUpstreamInclude []string `label:"FederationUpstreamInclude" json:"federation_upstream_include" description:"exchange filters include"`
	FederationUpstreamExclude []string `label:"FederationUpstreamExclude" json:"federation_upstream_exclude" description:"exchange filters exclude"`
	plugins.ClientConfig
}

func (*RabbitMQRule) TelegrafInput

func (p *RabbitMQRule) TelegrafInput() (telegraf.Input, error)

func (*RabbitMQRule) Validate

func (p *RabbitMQRule) Validate() error