Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PatternPayload ¶
PatternPayload builds a payload that can be verified using VerifyPayloadPattern. It repeats the pattern to fill a []byte slice of finalSize. Last remaining bytes (finalSize mod patternSize) are left unpopulated (hence set to 0 bytes). If final payload size is smaller than the pattern size, we return the pattern unmodified.
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.
func VerifyPayloadPattern ¶
VerifyPayloadPattern verifies the payload built using PatternPayload.
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.
Source Files