func Emitted()

in internal/metrics/batching/metrics.go [79:93]

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

func Emitted(ctx context.Context, sourceType data.SourceType, batchItemCount int, elapsed time.Duration) {
	opt := api.WithAttributes(
		attribute.Key(sourceTypeLabel).String(sourceType.String()),
	)
	// check if initialized first so someone doesn't have to initialize metrics
	if batchesEmittedCount != nil {
		batchesEmittedCount.Add(ctx, 1, opt)
	}
	if batchItemsEmittedCount != nil {
		batchItemsEmittedCount.Add(ctx, int64(batchItemCount), opt)
	}
	if batchAgeMilliseconds != nil {
		batchAgeMilliseconds.Record(ctx, elapsed.Milliseconds(), opt)
	}
}