Remove occurrences of 'base' labels

This commit is contained in:
Fabian Reinartz 2016-02-15 10:31:38 +01:00
parent 0d44248fb8
commit a06bc75519
4 changed files with 20 additions and 20 deletions

View file

@ -174,7 +174,7 @@ type Target struct {
// Labels before any processing. // Labels before any processing.
metaLabels model.LabelSet metaLabels model.LabelSet
// Any base labels that are added to this target and its metrics. // Any labels that are added to this target and its metrics.
labels model.LabelSet labels model.LabelSet
// The HTTP client used to scrape the target's endpoint. // The HTTP client used to scrape the target's endpoint.
@ -199,11 +199,11 @@ func (t *Target) Status() *TargetStatus {
// Update overwrites settings in the target that are derived from the job config // Update overwrites settings in the target that are derived from the job config
// it belongs to. // it belongs to.
func (t *Target) Update(cfg *config.ScrapeConfig, baseLabels, metaLabels model.LabelSet) error { func (t *Target) Update(cfg *config.ScrapeConfig, labels, metaLabels model.LabelSet) error {
t.Lock() t.Lock()
t.scrapeConfig = cfg t.scrapeConfig = cfg
t.labels = baseLabels t.labels = labels
t.metaLabels = metaLabels t.metaLabels = metaLabels
t.Unlock() t.Unlock()
@ -440,11 +440,11 @@ func (t *Target) scrape(appender storage.SampleAppender) error {
var ( var (
err error err error
start = time.Now() start = time.Now()
baseLabels = t.BaseLabels() labels = t.Labels()
) )
defer func(appender storage.SampleAppender) { defer func(appender storage.SampleAppender) {
t.status.setLastError(err) t.status.setLastError(err)
recordScrapeHealth(appender, start, baseLabels, t.status.Health(), time.Since(start)) recordScrapeHealth(appender, start, labels, t.status.Health(), time.Since(start))
}(appender) }(appender)
t.RLock() t.RLock()
@ -460,12 +460,12 @@ func (t *Target) scrape(appender storage.SampleAppender) error {
if t.scrapeConfig.HonorLabels { if t.scrapeConfig.HonorLabels {
appender = honorLabelsAppender{ appender = honorLabelsAppender{
SampleAppender: appender, SampleAppender: appender,
labels: baseLabels, labels: labels,
} }
} else { } else {
appender = ruleLabelsAppender{ appender = ruleLabelsAppender{
SampleAppender: appender, SampleAppender: appender,
labels: baseLabels, labels: labels,
} }
} }
@ -585,8 +585,8 @@ func (app relabelAppender) Append(s *model.Sample) error {
return app.SampleAppender.Append(s) return app.SampleAppender.Append(s)
} }
// BaseLabels returns a copy of the target's base labels. // Labels returns a copy of the set of all public labels of the target.
func (t *Target) BaseLabels() model.LabelSet { func (t *Target) Labels() model.LabelSet {
t.RLock() t.RLock()
defer t.RUnlock() defer t.RUnlock()
@ -615,17 +615,17 @@ func (t *Target) MetaLabels() model.LabelSet {
func recordScrapeHealth( func recordScrapeHealth(
sampleAppender storage.SampleAppender, sampleAppender storage.SampleAppender,
timestamp time.Time, timestamp time.Time,
baseLabels model.LabelSet, labels model.LabelSet,
health TargetHealth, health TargetHealth,
scrapeDuration time.Duration, scrapeDuration time.Duration,
) { ) {
healthMetric := make(model.Metric, len(baseLabels)+1) healthMetric := make(model.Metric, len(labels)+1)
durationMetric := make(model.Metric, len(baseLabels)+1) durationMetric := make(model.Metric, len(labels)+1)
healthMetric[model.MetricNameLabel] = scrapeHealthMetricName healthMetric[model.MetricNameLabel] = scrapeHealthMetricName
durationMetric[model.MetricNameLabel] = scrapeDurationMetricName durationMetric[model.MetricNameLabel] = scrapeDurationMetricName
for ln, lv := range baseLabels { for ln, lv := range labels {
healthMetric[ln] = lv healthMetric[ln] = lv
durationMetric[ln] = lv durationMetric[ln] = lv
} }

View file

@ -32,14 +32,14 @@ import (
"github.com/prometheus/prometheus/config" "github.com/prometheus/prometheus/config"
) )
func TestBaseLabels(t *testing.T) { func TestTargetLabels(t *testing.T) {
target := newTestTarget("example.com:80", 0, model.LabelSet{"job": "some_job", "foo": "bar"}) target := newTestTarget("example.com:80", 0, model.LabelSet{"job": "some_job", "foo": "bar"})
want := model.LabelSet{ want := model.LabelSet{
model.JobLabel: "some_job", model.JobLabel: "some_job",
model.InstanceLabel: "example.com:80", model.InstanceLabel: "example.com:80",
"foo": "bar", "foo": "bar",
} }
got := target.BaseLabels() got := target.Labels()
if !reflect.DeepEqual(want, got) { if !reflect.DeepEqual(want, got) {
t.Errorf("want base labels %v, got %v", want, got) t.Errorf("want base labels %v, got %v", want, got)
} }
@ -252,7 +252,7 @@ func TestTargetRecordScrapeHealth(t *testing.T) {
now := model.Now() now := model.Now()
appender := &collectResultAppender{} appender := &collectResultAppender{}
testTarget.status.setLastError(nil) testTarget.status.setLastError(nil)
recordScrapeHealth(appender, now.Time(), testTarget.BaseLabels(), testTarget.status.Health(), 2*time.Second) recordScrapeHealth(appender, now.Time(), testTarget.Labels(), testTarget.status.Health(), 2*time.Second)
result := appender.result result := appender.result

View file

@ -323,7 +323,7 @@ func (tm *TargetManager) Pools() map[string][]*Target {
for _, ts := range tm.targets { for _, ts := range tm.targets {
for _, t := range ts { for _, t := range ts {
job := string(t.BaseLabels()[model.JobLabel]) job := string(t.Labels()[model.JobLabel])
pools[job] = append(pools[job], t) pools[job] = append(pools[job], t)
} }
} }

View file

@ -188,7 +188,7 @@ func TestTargetManagerChan(t *testing.T) {
for _, expt := range expTargets { for _, expt := range expTargets {
found := false found := false
for _, actt := range actTargets { for _, actt := range actTargets {
if reflect.DeepEqual(expt, actt.BaseLabels()) { if reflect.DeepEqual(expt, actt.Labels()) {
found = true found = true
break break
} }