func metering()

in cmd/queuebench/metric.go [36:55]

• 20 lines of code
• 1 McCabe index (conditional complexity)

func metering() (*sdkmetric.MeterProvider, *sdkmetric.ManualReader) {
	rdr := sdkmetric.NewManualReader()
	mp := sdkmetric.NewMeterProvider(
		sdkmetric.WithReader(rdr),
		sdkmetric.WithView(
			sdkmetric.NewView(
				sdkmetric.Instrument{
					Name:  "consumer.messages.delay",
					Scope: instrumentation.Scope{Name: "github.com/elastic/apm-queue/kafka"},
				},
				sdkmetric.Stream{
					Aggregation: sdkmetric.AggregationExplicitBucketHistogram{
						Boundaries: customHistogramBoundaries,
					},
				},
			),
		),
	)
	return mp, rdr
}