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(sources *logsconfig.LogSources, frameSize int, pipelineProvider pipeline.Provider) *Launcher
NewLauncher returns an initialized Launcher
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 *logsconfig.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 Tailer ¶
type Tailer struct {
// contains filtered or unexported fields
}
Tailer reads data from a connection
func NewTailer ¶
func NewTailer(source *logsconfig.LogSource, conn net.Conn, outputChan chan *message.Message, read func(*Tailer) ([]byte, error)) *Tailer
NewTailer returns a new Tailer
type UDPListener ¶
type UDPListener struct {
// 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 *logsconfig.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.
Source Files