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 ¶
func Connect ¶ added in v1.14.0
func Connect(config *ClientConfig) (*client, error)
Connect opens a connection to one of the brokers at random
Types ¶
type AMQP ¶
type AMQP struct { URL string `toml:"url"` // deprecated in 1.7; use brokers 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 in 1.7; use headers RetentionPolicy string `toml:"retention_policy"` // deprecated in 1.7; use headers Precision string `toml:"precision"` // deprecated; has no effect Headers map[string]string `toml:"headers"` Timeout internal.Duration `toml:"timeout"` UseBatchFormat bool `toml:"use_batch_format"` ContentEncoding string `toml:"content_encoding"` tls.ClientConfig // contains filtered or unexported fields }
func (*AMQP) Description ¶
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.