Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
outputs.TLSConfig
// Enabled indicates if the AMQP output is enabled
Enabled bool `mapstructure:"enabled"`
// URL represents the AMQP connection string.
URL string `mapstructure:"url"`
// Timeout specifies the AMQP connection timeout.
Timeout time.Duration `mapstructure:"timeout"`
// Exchange is the AMQP exchange for publishing events.
Exchange string `mapstructure:"exchange"`
// ExchangeType is the AMQP exchange type.
ExchangeType string `mapstructure:"exchange-type"`
// Passive indicates that the server checks whether the exchange already exists and raises an error if it doesn't exist.
Passive bool `mapstructure:"passive"`
// Durable indicates that the exchange is marked as durable. Durable exchanges can survive server restarts.
Durable bool `mapstructure:"durable"`
// DeliveryMode determines if a published message is persistent or transient.
DeliveryMode string `mapstructure:"delivery-mode"`
// RoutingKey represents the static routing key to link exchanges with queues.
RoutingKey string `mapstructure:"routing-key"`
// Username is the username for the plain authentication method.
Username string `mapstructure:"username"`
// Password is the password for the plain authentication method.
Password string `mapstructure:"password"`
// Vhost represents the virtual host name.
Vhost string `mapstructure:"vhost"`
// Headers contains a list of headers that are added to AMQP message
Headers map[string]string `mapstructure:"headers"`
}
Config contains the tweaks that influence the behaviour of the AMQP output.
Directories
¶
| Path | Synopsis |
|---|---|
|
_fixtures
|
|
|
garagemq/amqp
Package amqp for read, write, parse amqp frames Autogenerated code.
|
Package amqp for read, write, parse amqp frames Autogenerated code. |
Click to show internal directories.
Click to hide internal directories.