tcp

Documentation

Index

• type TCPInput
  • func (t *TCPInput) Start() error
  • func (t *TCPInput) Stop() error
• type TCPInputConfig
  • func NewTCPInputConfig(operatorID string) *TCPInputConfig
  • func (c TCPInputConfig) Build(context operator.BuildContext) ([]operator.Operator, error)

Types

type TCPInput

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

TCPInput is an operator that listens for log entries over tcp.

func (*TCPInput) Start

func (t *TCPInput) Start() error

Start will start listening for log entries over tcp.

func (*TCPInput) Stop

func (t *TCPInput) Stop() error

Stop will stop listening for log entries over TCP.

type TCPInputConfig

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

	ListenAddress string `json:"listen_address,omitempty" yaml:"listen_address,omitempty"`
}

TCPInputConfig is the configuration of a tcp input operator.

func NewTCPInputConfig

func NewTCPInputConfig(operatorID string) *TCPInputConfig

NewTCPInputConfig creates a new TCP input config with default values

func (TCPInputConfig) Build

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

Build will build a tcp input operator.