func Init()

in internal/metrics/batching/metrics.go [33:54]


func Init(meter api.Meter) error {
	var err error
	batchingCount, err = meter.Int64Counter(metricName("batching_total"), api.WithDescription("total number of times tattler handles batching input"))
	if err != nil {
		return err
	}
	batchesEmittedCount, err = meter.Int64Counter(metricName("batches_emitted_total"), api.WithDescription("total number of batches emitted by tattler"))
	if err != nil {
		return err
	}
	batchItemsEmittedCount, err = meter.Int64Counter(metricName("batch_items_emitted_total"), api.WithDescription("total number of batch items emitted by tattler"))
	if err != nil {
		return err
	}
	batchAgeMilliseconds, err = meter.Int64Histogram(
		metricName("batch_age_ms"),
		api.WithDescription("age of batch when emitted"),
		api.WithExplicitBucketBoundaries(50, 100, 200, 400, 600, 800, 1000, 1250, 1500, 2000, 3000, 4000, 5000, 10000),
	)

	return nil
}