scrape

Documentation

Index

• Variables
• func PopulateLabels(lset labels.Labels, cfg *config.Config) (res, orig labels.Labels, err error)
• type Manager
  • func NewManager(logger logrus.FieldLogger, putter storage.Putter, r prometheus.Registerer) *Manager
  • func (m *Manager) ApplyConfig(cfg []*config.Config) error
  • func (m *Manager) Run(tsets <-chan map[string][]*targetgroup.Group) error
  • func (m *Manager) Stop()
  • func (m *Manager) TargetsActive() map[string][]*Target
  • func (m *Manager) TargetsAll() map[string][]*Target
  • func (m *Manager) TargetsDropped() map[string][]*Target
• type Target
  • func NewTarget(origLabels, discoveredLabels labels.Labels, profile *config.Profile) *Target
  • func TargetsFromGroup(tg *targetgroup.Group, cfg *config.Config) ([]*Target, []error)
  • func (t *Target) DiscoveredLabels() labels.Labels
  • func (t *Target) GetValue(name string) string
  • func (t *Target) Health() TargetHealth
  • func (t *Target) Labels() labels.Labels
  • func (t *Target) LastError() error
  • func (t *Target) LastScrape() time.Time
  • func (t *Target) LastScrapeDuration() time.Duration
  • func (t *Target) SetDiscoveredLabels(l labels.Labels)
  • func (t *Target) SpyName() string
  • func (t *Target) String() string
  • func (t *Target) URL() *url.URL
• type TargetHealth
• type Targets
  • func (ts Targets) Len() int
  • func (ts Targets) Less(i, j int) bool
  • func (ts Targets) Swap(i, j int)

Variables

var UserAgent = fmt.Sprintf("Pyroscope/%s", build.Version)

Functions

func PopulateLabels

func PopulateLabels(lset labels.Labels, cfg *config.Config) (res, orig labels.Labels, err error)

PopulateLabels builds a label set from the given label set and scrape configuration. It returns a label set before relabeling was applied as the second return value. Returns the original discovered label set found before relabelling was applied if the target is dropped during relabeling.

Types

type Manager

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

Manager maintains a set of scrape pools and manages start/stop cycles when receiving new target groups from the discovery manager.

func NewManager

func NewManager(logger logrus.FieldLogger, putter storage.Putter, r prometheus.Registerer) *Manager

NewManager is the Manager constructor

func (*Manager) ApplyConfig

func (m *Manager) ApplyConfig(cfg []*config.Config) error

ApplyConfig resets the manager's target providers and job configurations as defined by the new cfg.

func (*Manager) Run

func (m *Manager) Run(tsets <-chan map[string][]*targetgroup.Group) error

Run receives and saves target set updates and triggers the scraping loops reloading. Reloading happens in the background so that it doesn't block receiving targets updates.

func (*Manager) Stop

func (m *Manager) Stop()

Stop cancels all running scrape pools and blocks until all have exited.

func (*Manager) TargetsActive

func (m *Manager) TargetsActive() map[string][]*Target

TargetsActive returns the active targets currently being scraped.

func (*Manager) TargetsAll

func (m *Manager) TargetsAll() map[string][]*Target

TargetsAll returns active and dropped targets grouped by job_name.

func (*Manager) TargetsDropped

func (m *Manager) TargetsDropped() map[string][]*Target

TargetsDropped returns the dropped targets during relabelling.

type Target

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

Target refers to a singular HTTP or HTTPS endpoint.

func NewTarget

func NewTarget(origLabels, discoveredLabels labels.Labels, profile *config.Profile) *Target

NewTarget creates a reasonably configured target for querying.

func TargetsFromGroup

func TargetsFromGroup(tg *targetgroup.Group, cfg *config.Config) ([]*Target, []error)

TargetsFromGroup builds targets based on the given TargetGroup and config.

func (*Target) DiscoveredLabels

func (t *Target) DiscoveredLabels() labels.Labels

DiscoveredLabels returns a copy of the target's labels before any processing.

func (*Target) GetValue

func (t *Target) GetValue(name string) string

GetValue gets a label value from the entire label set.

func (*Target) Health

func (t *Target) Health() TargetHealth

Health returns the last known health state of the target.

func (*Target) Labels

func (t *Target) Labels() labels.Labels

Labels returns a copy of the set of all public labels of the target.

func (*Target) LastError

func (t *Target) LastError() error

LastError returns the error encountered during the last scrape.

func (*Target) LastScrape

func (t *Target) LastScrape() time.Time

LastScrape returns the time of the last scrape.

func (*Target) LastScrapeDuration

func (t *Target) LastScrapeDuration() time.Duration

LastScrapeDuration returns how long the last scrape of the target took.

func (*Target) SetDiscoveredLabels

func (t *Target) SetDiscoveredLabels(l labels.Labels)

SetDiscoveredLabels sets new DiscoveredLabels

func (*Target) SpyName

func (t *Target) SpyName() string

func (*Target) String

func (t *Target) String() string

func (*Target) URL

func (t *Target) URL() *url.URL

URL returns a copy of the target's URL.

type TargetHealth

type TargetHealth string

TargetHealth describes the health state of a target.

const (
	HealthUnknown TargetHealth = "unknown"
	HealthGood    TargetHealth = "up"
	HealthBad     TargetHealth = "down"
)

The possible health states of a target based on the last performed scrape.

type Targets

type Targets []*Target

Targets is a sortable list of targets.

func (Targets) Len

func (ts Targets) Len() int

func (Targets) Less

func (ts Targets) Less(i, j int) bool

func (Targets) Swap

func (ts Targets) Swap(i, j int)