func()

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)
}