probeutils

package
v0.0.0-...-eff70b3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 11, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StatsKeeper

func StatsKeeper(ctx context.Context, ptype, name string, exportInterval time.Duration, targetsFunc func() []string, resultsChan <-chan ProbeResult, dataChan chan<- *metrics.EventMetrics, l *logger.Logger)

StatsKeeper manages and outputs probe results.

Typical StatsKeepr usage pattern is that the probes start a StatsKeeper goroutine in the beginning. StatsKeeper goroutine manages access to the per-target cumulative metrics. It listens on an input channel for probe results and updates the metrics whenever a new probe result is obtained. It exports aggregate probe statistics to the output channel, at intervals controlled by a Ticker. These two operations are mutually exclusive. This is the only goroutine that accesses the metrics. StatsKeeper runs indefinitely, across multiple probe runs, and should not stop during normal program execution.

If we get a new result on resultsChan, update the probe statistics. If we get a timer tick on doExport, export probe data for all targets. If context is canceled, return.

Note that StatsKeeper calls a function (targetsFunc) to get the list of the targets for exporting results, instead of getting a static list in the arguments. We do that as the list of targets is usually dynamic and is updated on a regular basis.

Types

type ProbeResult

type ProbeResult interface {
	// Metrics converts ProbeResult into a map of the metrics that is suitable for
	// working with metrics.EventMetrics.
	Metrics() *metrics.EventMetrics

	// Target returns the target associated with the probe result.
	Target() string
}

ProbeResult represents results of a probe run.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL