runner

Documentation

Index

• Variables
• func GetCollectorsToRun(selectedCollectors []string) []string
• type CollectorRunner
  • func NewCollectorRunner(selectedCollectors []string) *CollectorRunner
  • func (runner *CollectorRunner) Run(kubeConfig string, outputFile string, requestedDuration time.Duration, ...)

Variables

var (
	OptionalCollectorNames []string
	RequiredCollectorNames []string
	All                    string = "all"
)

Functions

func GetCollectorsToRun

func GetCollectorsToRun(selectedCollectors []string) []string

GetCollectorsToRun returns a slice containing the names of the collectors to be run it will enfore that required colletors are returned

Types

type CollectorRunner

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

func NewCollectorRunner

func NewCollectorRunner(selectedCollectors []string) *CollectorRunner

func (*CollectorRunner) Run

func (runner *CollectorRunner) Run(
	kubeConfig string,
	outputFile string,
	requestedDuration time.Duration,
	pollInterval int,
	devInfoAnnouceInterval int,
	ptpInterface string,
	useAnalyserJSON bool,
	logsOutputFile string,
	includeLogTimestamps bool,
	tempDir string,
	keepDebugFiles bool,
)

Run manages set of collectors. It first initialises them, then polls them on the correct cadence and finally cleans up the collectors when exiting