socket

Documentation

Index

• type Tailer
  • func NewTailer(source *sources.LogSource, conn net.Conn, outputChan chan *message.Message, ...) *Tailer
  • func (t *Tailer) Start()
  • func (t *Tailer) Stop()

Types

type Tailer

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

Tailer reads data from a net.Conn. It uses a `read` callback to be generic over types of connections.

func NewTailer

func NewTailer(source *sources.LogSource, conn net.Conn, outputChan chan *message.Message, read func(*Tailer) ([]byte, string, error)) *Tailer

NewTailer returns a new Tailer

func (*Tailer) Start

func (t *Tailer) Start()

Start prepares the tailer to read and decode data from the connection

func (*Tailer) Stop

func (t *Tailer) Stop()

Stop stops the tailer and waits for the decoder to be flushed