channel

Documentation

Index

• type Scheduler
  • func NewScheduler(sourceName, source string, logsChan chan *config.ChannelMessage) *Scheduler
  • func (s *Scheduler) GetLogsTags() []string
  • func (s *Scheduler) SetLogsTags(tags []string)
  • func (s *Scheduler) Start(sourceMgr schedulers.SourceManager)
  • func (s *Scheduler) Stop()

Types

type Scheduler

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

Scheduler is a logs-agent Scheduler that only manages one source, connected to a channel. Messages sent to the channel will be directed to a logs pipeline.

After the scheduler is started, the tags assigned to the log source can be updated with SetLogsTags.

func NewScheduler

func NewScheduler(sourceName, source string, logsChan chan *config.ChannelMessage) *Scheduler

NewScheduler creates a new Scheduler.

func (*Scheduler) GetLogsTags

func (s *Scheduler) GetLogsTags() []string

GetLogsTags returns a defensive copy of the used tags

func (*Scheduler) SetLogsTags

func (s *Scheduler) SetLogsTags(tags []string)

SetLogsTags updates the tags attached to channel messages.

This method retains the given tags slice, which must not be modified after this call.

func (*Scheduler) Start

func (s *Scheduler) Start(sourceMgr schedulers.SourceManager)

Start implements schedulers.Scheduler#Start.

func (*Scheduler) Stop

func (s *Scheduler) Stop()

Stop implements schedulers.Scheduler#Stop.