checks

Documentation

Index

• type Backoffer
• type Error
  • func (e Error) Error() string
• type Streams
• type TimeSeries
• type TransientError
  • func (e TransientError) Error() string
• type Updater
  • func NewUpdater(opts UpdaterOptions) (*Updater, error)
  • func (c *Updater) Run(ctx context.Context) error
• type UpdaterOptions

Types

type Backoffer

type Backoffer interface {
	// Reset causes the backoff provider to go back its initial
	// state, before any calls to Duration() were made.
	Reset()
	// Duration returns the duration to sleep.
	Duration() time.Duration
}

Backoffer defines an interface to provide backoff durations.

The implementation of this interface SHOULD NOT perform the actual sleep, but rather return the duration to sleep.

type Error

type Error string

func (Error) Error

func (e Error) Error() string

type Streams

type Streams = []logproto.Stream

type TimeSeries

type TimeSeries = []prompb.TimeSeries

type TransientError

type TransientError Error

func (TransientError) Error

func (e TransientError) Error() string

type Updater

type Updater struct {
	IsConnected func(bool)
	// contains filtered or unexported fields
}

Updater represents a probe along with the collection of scrapers running on that probe and it manages the configuration for blackbox-exporter that corresponds to the collection of scrapers.

func NewUpdater

func NewUpdater(opts UpdaterOptions) (*Updater, error)

func (*Updater) Run

func (c *Updater) Run(ctx context.Context) error

type UpdaterOptions

type UpdaterOptions struct {
	Conn           *grpc.ClientConn
	Logger         zerolog.Logger
	Backoff        Backoffer
	Publisher      pusher.Publisher
	TenantCh       chan<- sm.Tenant
	IsConnected    func(bool)
	PromRegisterer prometheus.Registerer
	Features       feature.Collection
	K6Runner       k6runner.Runner
	ScraperFactory func(context.Context, model.Check, pusher.Publisher, sm.Probe, zerolog.Logger, scraper.Incrementer, scraper.IncrementerVec, k6runner.Runner) (*scraper.Scraper, error)
}