Documentation ¶
Index ¶
- Variables
- type 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 MetadataMetricsCollector
- type MetricMetadata
- type MetricMetadataStore
- type Target
- func (t *Target) DiscoveredLabels() labels.Labels
- 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) Metadata(metric string) (MetricMetadata, bool)
- func (t *Target) MetadataLength() int
- func (t *Target) MetadataList() []MetricMetadata
- func (t *Target) MetadataSize() int
- func (t *Target) Report(start time.Time, dur time.Duration, err error)
- func (t *Target) SetDiscoveredLabels(l labels.Labels)
- func (t *Target) SetMetadataStore(s MetricMetadataStore)
- func (t *Target) String() string
- func (t *Target) URL() *url.URL
- type TargetHealth
- type Targets
Constants ¶
This section is empty.
Variables ¶
var AlignScrapeTimestamps = true
AlignScrapeTimestamps enables the tolerance for scrape appends timestamps described above.
Functions ¶
This section is empty.
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 log.Logger, app storage.Appendable) *Manager
NewManager is the Manager constructor
func (*Manager) ApplyConfig ¶
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 ¶
TargetsActive returns the active targets currently being scraped.
func (*Manager) TargetsAll ¶
TargetsAll returns active and dropped targets grouped by job_name.
func (*Manager) TargetsDropped ¶
TargetsDropped returns the dropped targets during relabelling.
type MetadataMetricsCollector ¶
type MetadataMetricsCollector struct { CacheEntries *prometheus.Desc CacheBytes *prometheus.Desc // contains filtered or unexported fields }
MetadataMetricsCollector is a Custom Collector for the metadata cache metrics.
func (*MetadataMetricsCollector) Collect ¶
func (mc *MetadataMetricsCollector) Collect(ch chan<- prometheus.Metric)
Collect creates and sends the metrics for the metadata cache.
func (*MetadataMetricsCollector) Describe ¶
func (mc *MetadataMetricsCollector) Describe(ch chan<- *prometheus.Desc)
Describe sends the metrics descriptions to the channel.
type MetricMetadata ¶
type MetricMetadata struct { Metric string Type textparse.MetricType Help string Unit string }
MetricMetadata is a piece of metadata for a metric.
type MetricMetadataStore ¶
type MetricMetadataStore interface { ListMetadata() []MetricMetadata GetMetadata(metric string) (MetricMetadata, bool) SizeMetadata() int LengthMetadata() int }
MetricMetadataStore represents a storage for metadata.
type Target ¶
type Target struct {
// contains filtered or unexported fields
}
Target refers to a singular HTTP or HTTPS endpoint.
func (*Target) DiscoveredLabels ¶
DiscoveredLabels returns a copy of the target's labels before any processing.
func (*Target) Health ¶
func (t *Target) Health() TargetHealth
Health returns the last known health state of the target.
func (*Target) LastScrape ¶
LastScrape returns the time of the last scrape.
func (*Target) LastScrapeDuration ¶
LastScrapeDuration returns how long the last scrape of the target took.
func (*Target) Metadata ¶
func (t *Target) Metadata(metric string) (MetricMetadata, bool)
Metadata returns type and help metadata for the given metric.
func (*Target) MetadataLength ¶
func (*Target) MetadataList ¶
func (t *Target) MetadataList() []MetricMetadata
func (*Target) MetadataSize ¶
func (*Target) SetDiscoveredLabels ¶
SetDiscoveredLabels sets new DiscoveredLabels
func (*Target) SetMetadataStore ¶
func (t *Target) SetMetadataStore(s MetricMetadataStore)
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.