Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultAuthMethod = "PLAIN" DefaultBroker = "amqp://localhost:5672/influxdb" DefaultExchangeType = "topic" DefaultExchangeDurability = "durable" DefaultQueueDurability = "durable" DefaultPrefetchCount = 50 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQPConsumer ¶
type AMQPConsumer struct { URL string `toml:"url"` // deprecated in 1.7; use brokers Brokers []string `toml:"brokers"` Username string `toml:"username"` Password string `toml:"password"` Exchange string `toml:"exchange"` ExchangeType string `toml:"exchange_type"` ExchangeDurability string `toml:"exchange_durability"` ExchangePassive bool `toml:"exchange_passive"` ExchangeArguments map[string]string `toml:"exchange_arguments"` MaxUndeliveredMessages int `toml:"max_undelivered_messages"` // Queue Name Queue string `toml:"queue"` QueueDurability string `toml:"queue_durability"` // Binding Key BindingKey string `toml:"binding_key"` // Controls how many messages the server will try to keep on the network // for consumers before receiving delivery acks. PrefetchCount int // AMQP Auth method AuthMethod string tls.ClientConfig // contains filtered or unexported fields }
AMQPConsumer is the top level struct for this plugin
func (*AMQPConsumer) Description ¶
func (a *AMQPConsumer) Description() string
func (*AMQPConsumer) Gather ¶
func (a *AMQPConsumer) Gather(_ telegraf.Accumulator) error
All gathering is done in the Start function
func (*AMQPConsumer) SampleConfig ¶
func (a *AMQPConsumer) SampleConfig() string
func (*AMQPConsumer) SetParser ¶
func (a *AMQPConsumer) SetParser(parser parsers.Parser)
func (*AMQPConsumer) Start ¶
func (a *AMQPConsumer) Start(acc telegraf.Accumulator) error
Start satisfies the telegraf.ServiceInput interface
func (*AMQPConsumer) Stop ¶
func (a *AMQPConsumer) Stop()
Click to show internal directories.
Click to hide internal directories.