listener

Documentation

Index

• type Launcher
  • func NewLauncher(frameSize int) *Launcher
  • func (l *Launcher) Start(sourceProvider launchers.SourceProvider, pipelineProvider pipeline.Provider, ...)
  • func (l *Launcher) Stop()
• type TCPListener
  • func NewTCPListener(pipelineProvider pipeline.Provider, source *sources.LogSource, frameSize int) *TCPListener
  • func (l *TCPListener) Start()
  • func (l *TCPListener) Stop()
• type UDPListener
  • func NewUDPListener(pipelineProvider pipeline.Provider, source *sources.LogSource, frameSize int) *UDPListener
  • func (l *UDPListener) Start()
  • func (l *UDPListener) Stop()

Types

type Launcher

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

Launcher summons different protocol specific listeners based on configuration

func NewLauncher

func NewLauncher(frameSize int) *Launcher

NewLauncher returns an initialized Launcher

func (*Launcher) Start

func (l *Launcher) Start(sourceProvider launchers.SourceProvider, pipelineProvider pipeline.Provider, _ auditor.Registry, _ *tailers.TailerTracker)

Start starts the listener.

func (*Launcher) Stop

func (l *Launcher) Stop()

Stop stops all listeners

type TCPListener

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

A TCPListener listens and accepts TCP connections and delegates the read operations to a tailer.

func NewTCPListener

func NewTCPListener(pipelineProvider pipeline.Provider, source *sources.LogSource, frameSize int) *TCPListener

NewTCPListener returns an initialized TCPListener

func (*TCPListener) Start

func (l *TCPListener) Start()

Start starts the listener to accepts new incoming connections.

func (*TCPListener) Stop

func (l *TCPListener) Stop()

Stop stops the listener from accepting new connections and all the activer tailers.

type UDPListener

type UDPListener struct {
	Conn net.UDPConn
	// contains filtered or unexported fields
}

A UDPListener opens a new UDP connection, keeps it alive and delegates the read operations to a tailer.

func NewUDPListener

func NewUDPListener(pipelineProvider pipeline.Provider, source *sources.LogSource, frameSize int) *UDPListener

NewUDPListener returns an initialized UDPListener

func (*UDPListener) Start

func (l *UDPListener) Start()

Start opens a new UDP connection and starts a tailer.

func (*UDPListener) Stop

func (l *UDPListener) Stop()

Stop stops the tailer.