scraper

Documentation

Index

• Constants
• type Factory
• type Incrementer
• type IncrementerVec
  • func NewIncrementerFromCounterVec(c *prometheus.CounterVec) IncrementerVec
• type LabelsLimiter
• type Metrics
  • func NewMetrics(scrapeCounter Incrementer, errorCounter IncrementerVec) Metrics
• type Scraper
  • func New(ctx context.Context, check model.Check, publisher pusher.Publisher, ...) (*Scraper, error)
  • func NewWithOpts(ctx context.Context, check model.Check, opts ScraperOpts) (*Scraper, error)
  • func (s Scraper) CheckType() sm.CheckType
  • func (s Scraper) ConfigVersion() string
  • func (s Scraper) LastModified() float64
  • func (s *Scraper) Run(ctx context.Context)
  • func (s *Scraper) Stop()
• type ScraperOpts
• type Streams
• type Telemeter
• type TenantCals
• type TimeSeries

Constants

const (
	ProbeSuccessMetricName = "probe_success"
	CheckInfoMetricName    = "sm_check_info"
	CheckInfoSource        = "synthetic-monitoring-agent"
)

Types

type Factory

type Factory func(
	ctx context.Context, check model.Check, publisher pusher.Publisher, probe sm.Probe,
	features feature.Collection,
	logger zerolog.Logger,
	metrics Metrics,
	k6runner k6runner.Runner,
	labelsLimiter LabelsLimiter,
	telemeter *telemetry.Telemeter,
	secretStore secrets.SecretProvider,
	cals TenantCals,
) (*Scraper, error)

type Incrementer

type Incrementer interface {
	Inc()
}

type IncrementerVec

type IncrementerVec interface {
	WithLabelValues(...string) Incrementer
}

func NewIncrementerFromCounterVec

func NewIncrementerFromCounterVec(c *prometheus.CounterVec) IncrementerVec

type LabelsLimiter

type LabelsLimiter interface {
	MetricLabels(ctx context.Context, tenantID model.GlobalID) (int, error)
	LogLabels(ctx context.Context, tenantID model.GlobalID) (int, error)
}

type Metrics

type Metrics interface {
	AddScrape()
	AddCheckError()
	AddCollectorError()
}

func NewMetrics

func NewMetrics(scrapeCounter Incrementer, errorCounter IncrementerVec) Metrics

type Scraper

type Scraper struct {
	// contains filtered or unexported fields
}

func New

func New(
	ctx context.Context, check model.Check, publisher pusher.Publisher, probe sm.Probe,
	features feature.Collection,
	logger zerolog.Logger,
	metrics Metrics,
	k6runner k6runner.Runner,
	labelsLimiter LabelsLimiter,
	telemeter *telemetry.Telemeter,
	secretStore secrets.SecretProvider,
	cals TenantCals,
) (*Scraper, error)

func NewWithOpts

func NewWithOpts(ctx context.Context, check model.Check, opts ScraperOpts) (*Scraper, error)

func (Scraper) CheckType

func (s Scraper) CheckType() sm.CheckType

func (Scraper) ConfigVersion

func (s Scraper) ConfigVersion() string

func (Scraper) LastModified

func (s Scraper) LastModified() float64

func (*Scraper) Run

func (s *Scraper) Run(ctx context.Context)

func (*Scraper) Stop

func (s *Scraper) Stop()

type ScraperOpts

type ScraperOpts struct {
	Probe                 sm.Probe
	Publisher             pusher.Publisher
	Logger                zerolog.Logger
	Metrics               Metrics
	ProbeFactory          prober.ProberFactory
	LabelsLimiter         LabelsLimiter
	Telemeter             Telemeter
	CostAttributionLabels TenantCals
}

type Streams

type Streams = []logproto.Stream

type Telemeter

type Telemeter interface {
	AddExecution(e telemetry.Execution)
}

type TenantCals

type TenantCals interface {
	CostAttributionLabels(ctx context.Context, tenantID model.GlobalID) ([]string, error)
}

type TimeSeries

type TimeSeries = []prompb.TimeSeries