options

Documentation

Overview

Package options provides a shared interface to common probe options.

Index

• type AdditionalLabel
  • func (al *AdditionalLabel) KeyValueForTarget(targetName string) (key, val string)
  • func (al *AdditionalLabel) UpdateForTarget(targetName string, targetLabels map[string]string)
• type Options
  • func BuildProbeOptions(p *configpb.ProbeDef, ldLister lameduck.Lister, ...) (*Options, error)

Types

type AdditionalLabel

type AdditionalLabel struct {
	Key string

	Value          string // static value
	TargetLabelKey string // from target

	// This map will allow for quick label lookup for a target. It will be
	// updated by the probe while updating targets.
	LabelForTarget map[string]string
}

AdditionalLabel encapsulates additional labels to attach to probe results.

func (*AdditionalLabel) KeyValueForTarget

func (al *AdditionalLabel) KeyValueForTarget(targetName string) (key, val string)

KeyValueForTarget returns key, value pair for the given target.

func (*AdditionalLabel) UpdateForTarget

func (al *AdditionalLabel) UpdateForTarget(targetName string, targetLabels map[string]string)

UpdateForTarget updates target-based label's value.

type Options

type Options struct {
	Targets             targets.Targets
	Interval, Timeout   time.Duration
	Logger              *logger.Logger
	ProbeConf           interface{} // Probe-type specific config
	LatencyDist         *metrics.Distribution
	LatencyUnit         time.Duration
	Validators          []*validators.ValidatorWithName
	SourceIP            net.IP
	IPVersion           int
	StatsExportInterval time.Duration
	LogMetrics          func(*metrics.EventMetrics)
	AdditionalLabels    []*AdditionalLabel
}

Options encapsulates common probe options.

func BuildProbeOptions

func BuildProbeOptions(p *configpb.ProbeDef, ldLister lameduck.Lister, globalTargetsOpts *targetspb.GlobalTargetsOptions, l *logger.Logger) (*Options, error)

BuildProbeOptions builds probe's options using the provided config and some global params.