sched

Documentation

Overview

Package sched provides utilities to schedule Probes.

Index

• Variables
• type ProbeResult
• type Scheduler
  • func (s *Scheduler) UpdateTargetsAndStartProbes(ctx context.Context)
  • func (s *Scheduler) Wait()

Variables

var DefaultTargetsUpdateInterval = 1 * time.Minute

DefaultTargetsUpdateInterval defines default frequency for target updates. Actual targets update interval is: max(DefaultTargetsUpdateInterval, probe_interval)

Types

type ProbeResult

type ProbeResult interface {
	// Metrics returns ProbeResult metrics as a metrics.EventMetrics object.
	Metrics(time.Time, *options.Options) *metrics.EventMetrics
}

ProbeResult represents results of a probe run.

type Scheduler

type Scheduler struct {
	ProbeName              string
	DataChan               chan *metrics.EventMetrics
	Opts                   *options.Options
	NewResult              func() ProbeResult
	RunProbeForTarget      func(context.Context, endpoint.Endpoint, ProbeResult)
	IntervalBetweenTargets time.Duration
	// contains filtered or unexported fields
}

func (*Scheduler) UpdateTargetsAndStartProbes

func (s *Scheduler) UpdateTargetsAndStartProbes(ctx context.Context)

func (*Scheduler) Wait

func (s *Scheduler) Wait()