amqp

Oct 7, 2024

Changes in this version

type AMQP

+ func (q *AMQP) Init() error

Mar 17, 2021

Changes in this version

type AMQP

+ Log telegraf.Logger

Mar 26, 2020

Changes in this version

+ const DefaultAuthMethod

+ const DefaultExchangeType

+ const DefaultURL

+ func Connect(config *ClientConfig) (*client, error)

type AMQP

+ AuthMethod string

+ Brokers []string

+ ContentEncoding string

+ DeliveryMode string

+ ExchangeArguments map[string]string

+ ExchangeDurability string

+ ExchangePassive bool

+ ExchangeType string

+ Headers map[string]string

+ MaxMessages int

+ Password string

+ RoutingKey string

+ Timeout internal.Duration

+ UseBatchFormat bool

+ Username string

+ func (q *AMQP) SetSerializer(serializer serializers.Serializer)

+ type Client interface

+ Close func() error

+ Publish func(key string, body []byte) error

+ type ClientConfig struct

Jan 27, 2016

Changes in this version

type AMQP

+ SslCa string

+ SslCert string

+ SslKey string

Jan 9, 2016

Changes in this version

+ const DefaultDatabase

+ const DefaultPrecision

+ const DefaultRetentionPolicy

+ type AMQP struct

+ Database string

+ Exchange string

+ Precision string

+ RetentionPolicy string

+ RoutingTag string

+ URL string

+ func (q *AMQP) Close() error

+ func (q *AMQP) Connect() error

+ func (q *AMQP) Description() string

+ func (q *AMQP) SampleConfig() string

+ func (q *AMQP) Write(points []*client.Point) error