func()

in pipeline/inputs/aggregator.go [268:281]

• 13 lines of code
• 4 McCabe index (conditional complexity)

func (b *bucket) addReport(mr metrics.MetricReport) error {
	for _, ar := range b.Reports[mr.Name] {
		accepted, err := ar.accept(mr)
		if err != nil {
			return err
		}
		if accepted {
			return nil
		}
	}

	b.Reports[mr.Name] = append(b.Reports[mr.Name], (*aggregatedReport)(&mr))
	return nil
}