channel

Documentation

Index

• type Launcher
  • func NewLauncher(sources *config.LogSources, pipelineProvider pipeline.Provider) *Launcher
  • func (l *Launcher) Start()
  • func (l *Launcher) Stop()
• type Tailer
  • func NewTailer(source *config.LogSource, inputChan chan *config.ChannelMessage, ...) *Tailer
  • func (t *Tailer) Start()
  • func (t *Tailer) WaitFlush()

Types

type Launcher

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

Launcher starts a channel reader on the given channel of string.

func NewLauncher

func NewLauncher(sources *config.LogSources, pipelineProvider pipeline.Provider) *Launcher

NewLauncher returns an initialized Launcher

func (*Launcher) Start

func (l *Launcher) Start()

Start starts the launcher.

func (*Launcher) Stop

func (l *Launcher) Stop()

Stop waits for any running tailer to be flushed.

type Tailer

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

Tailer consumes and processes a channel of strings, and sends them to a stream of log messages.

func NewTailer

func NewTailer(source *config.LogSource, inputChan chan *config.ChannelMessage, outputChan chan *message.Message) *Tailer

NewTailer returns a new Tailer

func (*Tailer) Start

func (t *Tailer) Start()

Start starts the tailer.

func (*Tailer) WaitFlush

func (t *Tailer) WaitFlush()

WaitFlush waits for all items in the input channel to be processed.