kubelet

Documentation

Index

• type Providers
• type Scraper
  • func NewScraper(config *config.Config, providers Providers, options ...ScraperOpt) (*Scraper, error)
  • func (s *Scraper) Close()
  • func (s *Scraper) IncCurrentReruns()
  • func (s *Scraper) IsMaxRerunReached() bool
  • func (s *Scraper) Run(i *integration.Integration) error
• type ScraperOpt
  • func WithFilterer(filterer discovery.NamespaceFilterer) ScraperOpt
  • func WithLogger(logger *log.Logger) ScraperOpt

Types

type Providers

type Providers struct {
	K8s      kubernetes.Interface
	Kubelet  client.HTTPGetter
	CAdvisor prometheus.MetricFamiliesGetFunc
}

Providers is a struct holding pointers to all the clients Scraper needs to get data from. TODO: Extract this out of the Kubelet package.

type Scraper

type Scraper struct {
	Providers

	Filterer discovery.NamespaceFilterer
	// contains filtered or unexported fields
}

Scraper takes care of getting metrics from an autodiscovered Kubelet instance.

func NewScraper

func NewScraper(config *config.Config, providers Providers, options ...ScraperOpt) (*Scraper, error)

NewScraper builds a new Scraper, initializing its internal informers. After use, informers should be closed by calling Close() to prevent resource leakage.

func (*Scraper) Close

func (s *Scraper) Close()

Close will signal internal informers to stop running.

func (*Scraper) IncCurrentReruns

func (s *Scraper) IncCurrentReruns()

Increase the kubelet currentReruns counter.

func (*Scraper) IsMaxRerunReached

func (s *Scraper) IsMaxRerunReached() bool

Check whether the max number of kubulet scraper reruns has been reached or not.

func (*Scraper) Run

func (s *Scraper) Run(i *integration.Integration) error

Run scraper collect the data populating the integration entities

type ScraperOpt

type ScraperOpt func(s *Scraper) error

ScraperOpt are options that can be used to configure the Scraper

func WithFilterer

func WithFilterer(filterer discovery.NamespaceFilterer) ScraperOpt

WithFilterer returns an OptionFunc to add a Filterer.

func WithLogger

func WithLogger(logger *log.Logger) ScraperOpt

WithLogger returns an OptionFunc to change the logger from the default noop logger.