in pipeline/inputs/inputs.go [107:119]
func (i *labelingInput) AddReport(report metrics.MetricReport) error {
for k, v := range i.labels {
if _, exists := report.Labels[k]; exists {
glog.Warningf("labelingInput: received report that already had label '%v'; skipping", k)
continue
}
if report.Labels == nil {
report.Labels = make(map[string]string)
}
report.Labels[k] = v
}
return i.delegate.AddReport(report)
}