opentelemetry-go/sdk/metric/aggregator/ddsketch/ddsketch_test.go

// Copyright 2019, OpenTelemetry Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package ddsketch

import (
	"context"
	"testing"

	"github.com/stretchr/testify/require"

	"go.opentelemetry.io/otel/sdk/export"
	"go.opentelemetry.io/otel/sdk/metric/aggregator/test"
)

const count = 100

// N.B. DDSketch only supports absolute measures

func TestDDSketchAbsolute(t *testing.T) {
	ctx := context.Background()

	test.RunProfiles(t, func(t *testing.T, profile test.Profile) {
		batcher, record := test.NewAggregatorTest(export.MeasureMetricKind, profile.NumberKind, false)

		agg := New(NewDefaultConfig(), record.Descriptor())

		var all test.Numbers
		for i := 0; i < count; i++ {
			x := profile.Random(+1)
			all = append(all, x)
			agg.Update(ctx, x, record)
		}

		agg.Collect(ctx, record, batcher)

		all.Sort()

		require.InEpsilon(t,
			all.Sum(profile.NumberKind).CoerceToFloat64(profile.NumberKind),
			agg.Sum(),
			0.0000001,
			"Same sum - absolute")
		require.Equal(t, all.Count(), agg.Count(), "Same count - absolute")
		require.Equal(t,
			all[len(all)-1].CoerceToFloat64(profile.NumberKind),
			agg.Max(),
			"Same max - absolute")
		require.InEpsilon(t,
			all.Median(profile.NumberKind).CoerceToFloat64(profile.NumberKind),
			agg.Quantile(0.5),
			0.1,
			"Same median - absolute")
	})
}

func TestDDSketchMerge(t *testing.T) {
	ctx := context.Background()

	test.RunProfiles(t, func(t *testing.T, profile test.Profile) {
		batcher, record := test.NewAggregatorTest(export.MeasureMetricKind, profile.NumberKind, false)

		agg1 := New(NewDefaultConfig(), record.Descriptor())
		agg2 := New(NewDefaultConfig(), record.Descriptor())

		var all test.Numbers
		for i := 0; i < count; i++ {
			x := profile.Random(+1)
			all = append(all, x)
			agg1.Update(ctx, x, record)
		}

		for i := 0; i < count; i++ {
			x := profile.Random(+1)
			all = append(all, x)
			agg2.Update(ctx, x, record)
		}

		agg1.Collect(ctx, record, batcher)
		agg2.Collect(ctx, record, batcher)

		agg1.Merge(agg2, record.Descriptor())

		all.Sort()

		require.InEpsilon(t,
			all.Sum(profile.NumberKind).CoerceToFloat64(profile.NumberKind),
			agg1.Sum(),
			0.0000001,
			"Same sum - absolute")
		require.Equal(t, all.Count(), agg1.Count(), "Same count - absolute")
		require.Equal(t,
			all[len(all)-1].CoerceToFloat64(profile.NumberKind),
			agg1.Max(),
			"Same max - absolute")
		require.InEpsilon(t,
			all.Median(profile.NumberKind).CoerceToFloat64(profile.NumberKind),
			agg1.Quantile(0.5),
			0.1,
			"Same median - absolute")
	})
}