outputamqp

README

gogstash output amqp

Synopsis

{
	"output": [
		{
			"type": "amqp",

			// Array of AMQP connection strings formatted per the [RabbitMQ URI Spec](http://www.rabbitmq.com/uri-spec.html). Required.
			// Note: the connections will be used in a round-robin fashions
			"urls": [
				"amqp://guest:guest@localhost:5672//vhost"
			],

			// The message routing key used to bind the queue to the exchange. Defaults to empty string.
			"routing_key": "%{fieldstring}"

			// AMQP exchange name. Required.
			"exchange": "amq.topic",

			// AMQP exchange type (fanout, direct, topic or headers).
			"exchange_type": "topic",

			// Whether the exchange should be configured as a durable exchange. Defaults to false.
			"exchange_durable": false,

			// Whether the exchange is deleted when all queues have finished and there is no publishing. Defaults to false.
			"exchange_auto_delete": false,

			// Whether published messages should be marked as persistent or transient. Defaults to false.
			"persistent": false,

			// Number of attempts for sending a message. Defaults to 3.
			"retries": 3,

			// Delay between each attempt to reconnect to AMQP server. Defaults to 30 seconds.
			"reconnect_delay": 30
		}
	]
}

Documentation

Index

• Constants
• Variables
• func InitHandler(confraw *config.ConfigRaw) (retconf config.TypeOutputConfig, err error)
• type OutputConfig
  • func DefaultOutputConfig() OutputConfig
  • func (o *OutputConfig) Event(event logevent.LogEvent) (err error)

Constants

const ModuleName = "amqp"

ModuleName is the name used in config file

Variables

var (
	ErrorNoValidConn = errutil.NewFactory("no valid amqp server connection found")
)

errors

Functions

func InitHandler

func InitHandler(confraw *config.ConfigRaw) (retconf config.TypeOutputConfig, err error)

InitHandler initialize the output plugin

Types

type OutputConfig

type OutputConfig struct {
	config.OutputConfig
	URLs               []string `json:"urls"`                           // Array of AMQP connection strings formatted per the [RabbitMQ URI Spec](http://www.rabbitmq.com/uri-spec.html).
	RoutingKey         string   `json:"routing_key,omitempty"`          // The message routing key used to bind the queue to the exchange. Defaults to empty string.
	Exchange           string   `json:"exchange"`                       // AMQP exchange name
	ExchangeType       string   `json:"exchange_type"`                  // AMQP exchange type (fanout, direct, topic or headers).
	ExchangeDurable    bool     `json:"exchange_durable,omitempty"`     // Whether the exchange should be configured as a durable exchange. Defaults to false.
	ExchangeAutoDelete bool     `json:"exchange_auto_delete,omitempty"` // Whether the exchange is deleted when all queues have finished and there is no publishing. Defaults to true.
	Persistent         bool     `json:"persistent,omitempty"`           // Whether published messages should be marked as persistent or transient. Defaults to false.
	Retries            int      `json:"retries,omitempty"`              // Number of attempts to send a message. Defaults to 3.
	ReconnectDelay     int      `json:"reconnect_delay,omitempty"`      // Delay between each attempt to reconnect to AMQP server. Defaults to 30 seconds.
	// contains filtered or unexported fields
}

OutputConfig holds the output configuration json fields and internal objects

func DefaultOutputConfig

func DefaultOutputConfig() OutputConfig

DefaultOutputConfig returns an OutputConfig struct with default values

func (*OutputConfig) Event

func (o *OutputConfig) Event(event logevent.LogEvent) (err error)

Event send the event through AMQP