tcp_listener

README

TCP Listener 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

	Log telegraf.Logger
	// 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