tcp

Documentation

Index

• type TcpInput
  • func (self *TcpInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)
  • func (self *TcpInput) Run(runner plugins.InputRunner) error
• type TcpInputConfig

Types

type TcpInput

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

Input plugin implementation that listens for Heka proself.col messages on a specified TCP sockeself.g Creates a separate goroutine for each TCP connection.

func (*TcpInput) Init

func (self *TcpInput) Init(pcf *plugins.PluginCommonConfig, conf toml.Primitive) (err error)

func (*TcpInput) Run

func (self *TcpInput) Run(runner plugins.InputRunner) error

type TcpInputConfig

type TcpInputConfig struct {
	// Network type (e.g. "tcp", "tcp4", "tcp6", "unix" or "unixpacket").
	// Needs to match the input type.
	Net string
	// String representation of the address of the network connection on which
	// the listener should be listening (e.g. "127.0.0.1:5565").
	Address string
	// Set to true if TCP Keep Alive should be used.
	KeepAlive bool `toml:"keep_alive"`
	// Integer indicating seconds between keep alives.
	KeepAlivePeriod int `toml:"keep_alive_period"`
}