scraper

Documentation

Index

• type Scraper
  • func New(ctx context.Context, check sm.Check, publishCh chan<- pusher.Payload, ...) (*Scraper, error)
  • func NewWithOpts(ctx context.Context, check sm.Check, opts ScraperOpts) (*Scraper, error)
  • func (s Scraper) CheckType() sm.CheckType
  • func (s Scraper) ConfigVersion() string
  • func (s *Scraper) Run(ctx context.Context)
  • func (s *Scraper) Stop()
• type ScraperOpts
• type Streams
• type TimeSeries

Types

type Scraper

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

func New

func New(ctx context.Context, check sm.Check, publishCh chan<- pusher.Payload, probe sm.Probe, logger zerolog.Logger, scrapeCounter prometheus.Counter, errorCounter *prometheus.CounterVec) (*Scraper, error)

func NewWithOpts

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

func (Scraper) CheckType

func (s Scraper) CheckType() sm.CheckType

func (Scraper) ConfigVersion

func (s Scraper) ConfigVersion() string

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
	PublishCh     chan<- pusher.Payload
	Logger        zerolog.Logger
	ScrapeCounter prometheus.Counter
	ErrorCounter  *prometheus.CounterVec
	ProbeFactory  func(context.Context, zerolog.Logger, sm.Check) (prober.Prober, string, error)
}

type Streams

type Streams = []logproto.Stream

type TimeSeries

type TimeSeries = []prompb.TimeSeries