listener

Documentation

Index

• type ConnectionHandler
• type Listener
  • func New(sources []*config.IntegrationConfigLogSource, pp pipeline.Provider) *Listener
  • func (l *Listener) Start()
• type TCPListener
  • func NewTCPListener(pp pipeline.Provider, source *config.IntegrationConfigLogSource) (*TCPListener, error)
  • func (tcpListener *TCPListener) Start()
• type UDPListener
  • func NewUDPListener(pp pipeline.Provider, source *config.IntegrationConfigLogSource) (*UDPListener, error)
  • func (udpListener *UDPListener) Start()

Types

type ConnectionHandler

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

ConnectionHandler reads bytes from new connections, passes them to a decoder and transforms decoder output into messages to forward them

type Listener

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

A Listener summons different protocol specific listeners based on configuration

func New

func New(sources []*config.IntegrationConfigLogSource, pp pipeline.Provider) *Listener

New returns an initialized Listener

func (*Listener) Start

func (l *Listener) Start()

Start starts the Listener

type TCPListener

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

A TCPListener listens and accepts TCP connections and delegates the work to connHandler

func NewTCPListener

func NewTCPListener(pp pipeline.Provider, source *config.IntegrationConfigLogSource) (*TCPListener, error)

NewTCPListener returns an initialized TCPListener

func (*TCPListener) Start

func (tcpListener *TCPListener) Start()

Start listens to TCP connections on another routine

type UDPListener

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

A UDPListener listens for UDP connections and delegates the work to connHandler

func NewUDPListener

func NewUDPListener(pp pipeline.Provider, source *config.IntegrationConfigLogSource) (*UDPListener, error)

NewUDPListener returns an initialized UDPListener

func (*UDPListener) Start

func (udpListener *UDPListener) Start()

Start listens to UDP connections on another routine