tailer

package

v0.0.0-...-e3fb0e6 Latest Latest Go to latest Published: Dec 12, 2017 License: Apache-2.0 Imports: 14 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(sources []*config.IntegrationConfigLogSource, pp *pipeline.PipelineProvider, auditor *auditor.Auditor) *Scanner

New returns an initialized Scanner

func (s *Scanner) Start()

Start starts the Scanner

func (s *Scanner) Stop()

Stop stops the Scanner and its tailers

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

Tailer tails one file and sends messages to an output channel

func NewTailer(outputChan chan message.Message, source *config.IntegrationConfigLogSource) *Tailer

NewTailer returns an initialized Tailer

func (t *Tailer) GetReadOffset() int64

func (t *Tailer) Identifier() string

Identifier returns a string that uniquely identifies a source

func (t *Tailer) Stop(shouldTrackOffset bool)

Stop lets the tailer stop