mirror of
https://github.com/prometheus/prometheus.git
synced 2024-12-28 23:19:41 -08:00
dcfd09c801
If the metrics exported by a process already contain any of a target's base labels (such as "job" or "instance", but also any manually assigned target-group label), don't overwrite that label, but instead add a new label consisting of the original label name prepended with "exporter_". This is to accomodate intermediate exporter jobs, which might indicate e.g. the jobs and instances for which they are exporting data.
71 lines
2.5 KiB
Go
71 lines
2.5 KiB
Go
// Copyright 2013 Prometheus Team
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
|
|
package format
|
|
|
|
import (
|
|
"github.com/prometheus/prometheus/model"
|
|
"io"
|
|
"time"
|
|
)
|
|
|
|
// Processor is responsible for decoding the actual message responses from
|
|
// stream into a format that can be consumed with the end result written
|
|
// to the results channel.
|
|
type Processor interface {
|
|
// Process performs the work on the input and closes the incoming stream.
|
|
Process(stream io.ReadCloser, timestamp time.Time, baseLabels model.LabelSet, results chan Result) (err error)
|
|
}
|
|
|
|
// The ProcessorFunc type allows the use of ordinary functions for processors.
|
|
type ProcessorFunc func(io.ReadCloser, time.Time, model.LabelSet, chan Result) error
|
|
|
|
func (f ProcessorFunc) Process(stream io.ReadCloser, timestamp time.Time, baseLabels model.LabelSet, results chan Result) error {
|
|
return f(stream, timestamp, baseLabels, results)
|
|
}
|
|
|
|
// Helper function to convert map[string]string into model.LabelSet.
|
|
//
|
|
// NOTE: This should be deleted when support for go 1.0.3 is removed; 1.1 is
|
|
// smart enough to unmarshal JSON objects into model.LabelSet directly.
|
|
func LabelSet(labels map[string]string) model.LabelSet {
|
|
labelset := make(model.LabelSet, len(labels))
|
|
|
|
for k, v := range labels {
|
|
labelset[model.LabelName(k)] = model.LabelValue(v)
|
|
}
|
|
|
|
return labelset
|
|
}
|
|
|
|
// Helper function to merge a target's base labels ontop of the labels of an
|
|
// exported sample. If a label is already defined in the exported sample, we
|
|
// assume that we are scraping an intermediate exporter and attach
|
|
// "exporter_"-prefixes to Prometheus' own base labels.
|
|
func mergeTargetLabels(entityLabels, targetLabels model.LabelSet) model.LabelSet {
|
|
result := model.LabelSet{}
|
|
|
|
for label, value := range entityLabels {
|
|
result[label] = value
|
|
}
|
|
|
|
for label, labelValue := range targetLabels {
|
|
if _, exists := result[label]; exists {
|
|
result[model.ExporterLabelPrefix+label] = labelValue
|
|
} else {
|
|
result[label] = labelValue
|
|
}
|
|
}
|
|
return result
|
|
}
|