queue

Documentation

Index

• type Queue
• 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)

Types

type Queue

type Queue interface {
	Subscribe()
	Read() string
}

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"`

	QueueType string `json:"queue_type,omitempty" yaml:"queue_type,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.