checks

Documentation

Index

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

Types

type Streams

type Streams = []logproto.Stream

type TimeSeries

type TimeSeries = []prompb.TimeSeries

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
	PublishCh      chan<- pusher.Payload
	TenantCh       chan<- sm.Tenant
	IsConnected    func(bool)
	PromRegisterer prometheus.Registerer
	Features       feature.Collection
	ScraperFactory func(context.Context, sm.Check, chan<- pusher.Payload, sm.Probe, zerolog.Logger, prometheus.Counter, *prometheus.CounterVec) (*scraper.Scraper, error)
}