measurements

Documentation

Index

• func Collect()
• func Index(indexer indexers.Indexer, jobName string)
• func NewMeasurementFactory(configSpec config.Spec, metadata map[string]interface{})
• func SetJobConfig(jobConfig *config.Job, kubeClientProvider *config.KubeClientProvider)
• func Start()
• func Stop() error

Functions

func Collect

func Collect()

func Index

func Index(indexer indexers.Indexer, jobName string)

Index iterates through the createFuncs and indexes collected data from each measurement.

Parameters:

• indexer: a pointer to the indexer
• jobName: the name of the job, required as this task can be executed from a goroutine

func NewMeasurementFactory

func NewMeasurementFactory(configSpec config.Spec, metadata map[string]interface{})

NewMeasurementFactory initializes the measurement facture

func SetJobConfig

func SetJobConfig(jobConfig *config.Job, kubeClientProvider *config.KubeClientProvider)

func Start

func Start()

Start starts registered measurements

func Stop

func Stop() error

Stop stops registered measurements returns a concatenated list of error strings with a new line between each string