tcp_listener

README

TCP listener service input plugin

DEPRECATED: As of version 1.3 the TCP listener plugin has been deprecated in favor of the socket_listener plugin

Documentation

Index

• type TcpListener
  • func (t *TcpListener) Description() string
  • func (t *TcpListener) Gather(_ telegraf.Accumulator) error
  • func (t *TcpListener) SampleConfig() string
  • func (t *TcpListener) SetParser(parser parsers.Parser)
  • func (t *TcpListener) Start(acc telegraf.Accumulator) error
  • func (t *TcpListener) Stop()

Types

type TcpListener

type TcpListener struct {
	ServiceAddress         string
	AllowedPendingMessages int
	MaxTCPConnections      int `toml:"max_tcp_connections"`

	sync.Mutex

	MaxConnections     selfstat.Stat
	CurrentConnections selfstat.Stat
	TotalConnections   selfstat.Stat
	PacketsRecv        selfstat.Stat
	BytesRecv          selfstat.Stat
	// contains filtered or unexported fields
}

func (*TcpListener) Description

func (t *TcpListener) Description() string

func (*TcpListener) Gather

func (t *TcpListener) Gather(_ telegraf.Accumulator) error

All the work is done in the Start() function, so this is just a dummy function.

func (*TcpListener) SampleConfig

func (t *TcpListener) SampleConfig() string

func (*TcpListener) SetParser

func (t *TcpListener) SetParser(parser parsers.Parser)

func (*TcpListener) Start

func (t *TcpListener) Start(acc telegraf.Accumulator) error

Start starts the tcp listener service.

func (*TcpListener) Stop

func (t *TcpListener) Stop()

Stop cleans up all resources