output

Feb 20, 2023

Changes in this version

+ type Constructor func(Params) (Output, error)

type Manager

+ func (om *Manager) Start(samplesChan chan metrics.SampleContainer) (wait func(), finish func(error), err error)

+ type WithStopWithTestError interface

+ StopWithTestError func(testRunErr error) error

May 4, 2022

Changes in this version

+ type Manager struct

+ func NewManager(outputs []Output, logger logrus.FieldLogger, testStopCallback func(error)) *Manager

+ func (om *Manager) AddMetricSamples(sampleContainers []metrics.SampleContainer)

+ func (om *Manager) SetRunStatus(status lib.RunStatus)

+ func (om *Manager) StartOutputs() error

+ func (om *Manager) StopOutputs()

Nov 17, 2021

Changes in this version

+ type WithBuiltinMetrics interface

+ SetBuiltinMetrics func(builtinMetrics *metrics.BuiltinMetrics)

May 12, 2021

Changes in this version

+ func GetExtensions() map[string]func(Params) (Output, error)

+ func RegisterExtension(name string, mod func(Params) (Output, error))

+ type Output interface

+ AddMetricSamples func(samples []stats.SampleContainer)

+ Description func() string

+ Start func() error

+ Stop func() error

+ type Params struct

+ ConfigArgument string

+ Environment map[string]string

+ ExecutionPlan []lib.ExecutionStep

+ FS afero.Fs

+ JSONConfig json.RawMessage

+ Logger logrus.FieldLogger

+ OutputType string

+ RuntimeOptions lib.RuntimeOptions

+ ScriptOptions lib.Options

+ ScriptPath *url.URL

+ StdErr io.Writer

+ StdOut io.Writer

+ type PeriodicFlusher struct

+ func NewPeriodicFlusher(period time.Duration, flushCallback func()) (*PeriodicFlusher, error)

+ func (pf *PeriodicFlusher) Stop()

+ type SampleBuffer struct

+ func (sc *SampleBuffer) AddMetricSamples(samples []stats.SampleContainer)

+ func (sc *SampleBuffer) GetBufferedSamples() []stats.SampleContainer

+ type WithRunStatusUpdates interface

+ SetRunStatus func(latestStatus lib.RunStatus)

+ type WithTestRunStop interface

+ SetTestRunStopCallback func(func(error))

+ type WithThresholds interface

+ SetThresholds func(map[string]stats.Thresholds)