listener

package
v0.0.0-...-45a9bcf Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 3, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL