func()

in processor/rollupprocessor/processor.go [56:114]

• 59 lines of code
• 6 McCabe index (conditional complexity)

func (p *rollupProcessor) processMetric(m pmetric.Metric) {
	switch m.Type() {
	case pmetric.MetricTypeGauge:
		newDataPoints := pmetric.NewNumberDataPointSlice()
		rollupDataPoints[pmetric.NumberDataPoint](
			p.cache,
			p.attributeGroups,
			p.dropOriginal,
			m.Name(),
			m.Gauge().DataPoints(),
			newDataPoints,
		)
		newDataPoints.CopyTo(m.Gauge().DataPoints())
	case pmetric.MetricTypeSum:
		newDataPoints := pmetric.NewNumberDataPointSlice()
		rollupDataPoints[pmetric.NumberDataPoint](
			p.cache,
			p.attributeGroups,
			p.dropOriginal,
			m.Name(),
			m.Sum().DataPoints(),
			newDataPoints,
		)
		newDataPoints.CopyTo(m.Sum().DataPoints())
	case pmetric.MetricTypeHistogram:
		newDataPoints := pmetric.NewHistogramDataPointSlice()
		rollupDataPoints[pmetric.HistogramDataPoint](
			p.cache,
			p.attributeGroups,
			p.dropOriginal,
			m.Name(),
			m.Histogram().DataPoints(),
			newDataPoints,
		)
		newDataPoints.CopyTo(m.Histogram().DataPoints())
	case pmetric.MetricTypeExponentialHistogram:
		newDataPoints := pmetric.NewExponentialHistogramDataPointSlice()
		rollupDataPoints[pmetric.ExponentialHistogramDataPoint](
			p.cache,
			p.attributeGroups,
			p.dropOriginal,
			m.Name(),
			m.ExponentialHistogram().DataPoints(),
			newDataPoints,
		)
		newDataPoints.CopyTo(m.ExponentialHistogram().DataPoints())
	case pmetric.MetricTypeSummary:
		newDataPoints := pmetric.NewSummaryDataPointSlice()
		rollupDataPoints[pmetric.SummaryDataPoint](
			p.cache,
			p.attributeGroups,
			p.dropOriginal,
			m.Name(),
			m.Summary().DataPoints(),
			newDataPoints,
		)
		newDataPoints.CopyTo(m.Summary().DataPoints())
	}
}