file

Documentation

Index

• Constants
• func CheckProcessTelemetry(stats *util.ProcessFileStats)
• func Position(registry auditor.Registry, identifier string, mode config.TailingMode) (int64, int, error)
• type Launcher
  • func NewLauncher(tailingLimit int, tailerSleepDuration time.Duration, ...) *Launcher
  • func (s *Launcher) Start(sourceProvider launchers.SourceProvider, pipelineProvider pipeline.Provider, ...)
  • func (s *Launcher) Stop()

Constants

const DefaultSleepDuration = 1 * time.Second

DefaultSleepDuration represents the amount of time the tailer waits before reading new data when no data is received

Functions

func CheckProcessTelemetry

func CheckProcessTelemetry(stats *util.ProcessFileStats)

func Position

func Position(registry auditor.Registry, identifier string, mode config.TailingMode) (int64, int, error)

Position returns the position from where logs should be collected.

Types

type Launcher

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

Launcher checks all files provided by fileProvider and create new tailers or update the old ones if needed

func NewLauncher

func NewLauncher(tailingLimit int, tailerSleepDuration time.Duration, validatePodContainerID bool, scanPeriod time.Duration, wildcardMode string, flarecontroller *flareController.FlareController, tagger tagger.Component) *Launcher

NewLauncher returns a new launcher.

func (*Launcher) Start

func (s *Launcher) Start(sourceProvider launchers.SourceProvider, pipelineProvider pipeline.Provider, registry auditor.Registry, tracker *tailers.TailerTracker)

Start starts the Launcher

func (*Launcher) Stop

func (s *Launcher) Stop()

Stop stops the Scanner and its tailers in parallel, this call returns only when all the tailers are stopped