Documentation
¶
Index ¶
Constants ¶
View Source
const ( DefaultURL = "amqp://localhost:5672/influxdb" DefaultAuthMethod = "PLAIN" DefaultExchangeType = "topic" DefaultRetentionPolicy = "default" DefaultDatabase = "telegraf" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AMQP ¶
type AMQP struct { URL string `toml:"url" deprecated:"1.7.0;use 'brokers' instead"` Brokers []string `toml:"brokers"` Exchange string `toml:"exchange"` ExchangeType string `toml:"exchange_type"` ExchangePassive bool `toml:"exchange_passive"` ExchangeDurability string `toml:"exchange_durability"` ExchangeArguments map[string]string `toml:"exchange_arguments"` Username string `toml:"username"` Password string `toml:"password"` MaxMessages int `toml:"max_messages"` AuthMethod string `toml:"auth_method"` RoutingTag string `toml:"routing_tag"` RoutingKey string `toml:"routing_key"` DeliveryMode string `toml:"delivery_mode"` Database string `toml:"database" deprecated:"1.7.0;use 'headers' instead"` RetentionPolicy string `toml:"retention_policy" deprecated:"1.7.0;use 'headers' instead"` Precision string `toml:"precision" deprecated:"1.2.0;option is ignored"` Headers map[string]string `toml:"headers"` Timeout config.Duration `toml:"timeout"` UseBatchFormat bool `toml:"use_batch_format"` ContentEncoding string `toml:"content_encoding"` Log telegraf.Logger `toml:"-"` tls.ClientConfig // contains filtered or unexported fields }
func (*AMQP) SampleConfig ¶
func (*AMQP) SetSerializer ¶ added in v1.14.0
func (q *AMQP) SetSerializer(serializer serializers.Serializer)
type ClientConfig ¶ added in v1.14.0
type ClientConfig struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.