udp

Documentation

Index

• type UDPInput
  • func (u *UDPInput) Start() error
  • func (u *UDPInput) Stop() error
• type UDPInputConfig
  • func NewUDPInputConfig(operatorID string) *UDPInputConfig
  • func (c UDPInputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Types

type UDPInput

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

UDPInput is an operator that listens to a socket for log entries.

func (*UDPInput) Start

func (u *UDPInput) Start() error

Start will start listening for messages on a socket.

func (*UDPInput) Stop

func (u *UDPInput) Stop() error

Stop will stop listening for udp messages.

type UDPInputConfig

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

	ListenAddress string `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
	AddLabels     bool   `json:"add_labels,omitempty" yaml:"add_labels,omitempty"`
}

UDPInputConfig is the configuration of a udp input operator.

func NewUDPInputConfig

func NewUDPInputConfig(operatorID string) *UDPInputConfig

NewUDPInputConfig creates a new UDP input config with default values

func (UDPInputConfig) Build

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

Build will build a udp input operator.