func remapDiskMetrics()

in remappers/hostmetrics/disk.go [39:59]

• 21 lines of code
• 5 McCabe index (conditional complexity)

func remapDiskMetrics(
	src, out pmetric.MetricSlice,
	_ pcommon.Resource,
	mutator func(pmetric.NumberDataPoint),
) error {
	var errs []error
	for i := 0; i < src.Len(); i++ {
		var err error
		metric := src.At(i)
		switch metric.Name() {
		case "system.disk.io", "system.disk.operations", "system.disk.pending_operations":
			err = addDiskMetric(metric, out, mutator, 1)
		case "system.disk.operation_time", "system.disk.io_time":
			err = addDiskMetric(metric, out, mutator, 1000)
		}
		if err != nil {
			errs = append(errs, err)
		}
	}
	return errors.Join(errs...)
}