rabbitmq

Documentation

Index

• type QueueInput
  • func (g *QueueInput) Start() error
  • func (g *QueueInput) Stop() error
• type QueueInputConfig
  • func NewQueueInputConfig(operatorID string) *QueueInputConfig
  • func (c *QueueInputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)
• type Rabbitmq

Types

type QueueInput

type QueueInput struct {
	helper.InputOperator
	// contains filtered or unexported fields
}

QueueInput is an operator that reads input from a message queue.

func (*QueueInput) Start

func (g *QueueInput) Start() error

Start will start generating log entries.

func (*QueueInput) Stop

func (g *QueueInput) Stop() error

Stop will stop generating logs.

type QueueInputConfig

type QueueInputConfig struct {
	helper.InputConfig `yaml:",inline"`

	// required
	Username   string `json:"username,omitempty" yaml:"username,omitempty"`
	Password   string `json:"password,omitempty" yaml:"password,omitempty"`
	Address    string `json:"address,omitempty" yaml:"address,omitempty"`
	RoutingKey string `json:"routing_key,omitempty" yaml:"routing_key,omitempty"`

	// optional
	Port  string `json:"port,omitempty" yaml:"port,omitempty"`
	VHost string `json:"vhost,omitempty" yaml:"vhost,omitempty"`
	Tag   string `json:"tag,omitempty" yaml:"tag,omitempty"`
}

QueueInputConfig is the configuration of a message queue input operator.

func NewQueueInputConfig

func NewQueueInputConfig(operatorID string) *QueueInputConfig

NewQueueInputConfig creates a new message queue input config with default values

func (*QueueInputConfig) Build

func (c *QueueInputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Build will build a message queue input operator.

type Rabbitmq

type Rabbitmq struct {
	// contains filtered or unexported fields
}

Rabbitmq represents a Rabbitmq configuration.