diff --git a/receiver/googlecloudspannerreceiver/internal/filter/package_test.go b/receiver/googlecloudspannerreceiver/internal/filter/package_test.go new file mode 100644 index 000000000000..ab3099a83e53 --- /dev/null +++ b/receiver/googlecloudspannerreceiver/internal/filter/package_test.go @@ -0,0 +1,14 @@ +// Copyright The OpenTelemetry Authors +// SPDX-License-Identifier: Apache-2.0 + +package filter + +import ( + "testing" + + "go.uber.org/goleak" +) + +func TestMain(m *testing.M) { + goleak.VerifyTestMain(m) +} diff --git a/receiver/googlecloudspannerreceiver/internal/filterfactory/filterbuilder_test.go b/receiver/googlecloudspannerreceiver/internal/filterfactory/filterbuilder_test.go index a5f720344e8c..71ee09d89f21 100644 --- a/receiver/googlecloudspannerreceiver/internal/filterfactory/filterbuilder_test.go +++ b/receiver/googlecloudspannerreceiver/internal/filterfactory/filterbuilder_test.go @@ -96,6 +96,7 @@ func TestFilterBuilder_BuildFilterByMetricPositiveTotalLimit(t *testing.T) { assert.Equal(t, expectedLimit, f.TotalLimit()) assert.Equal(t, expectedLimit, f.LimitByTimestamp()) } + assert.NoError(t, f.Shutdown()) } } }) @@ -147,6 +148,7 @@ func TestFilterBuilder_HandleLowCardinalityGroups(t *testing.T) { assert.Equal(t, expectedLimit, f.TotalLimit()) assert.Equal(t, expectedLimit, f.LimitByTimestamp()) assert.Equal(t, testCase.expectedRemainingTotalLimit, remainingTotalLimit) + assert.NoError(t, f.Shutdown()) } } }) @@ -200,6 +202,7 @@ func TestFilterBuilder_HandleHighCardinalityGroups(t *testing.T) { assert.Equal(t, testCase.expectedHighCardinalityTotalLimit, f.TotalLimit()) assert.Equal(t, testCase.expectedHighCardinalityLimitByTimestamp, f.LimitByTimestamp()) assert.Equal(t, testCase.expectedRemainingTotalLimit, remainingTotalLimit) + assert.NoError(t, f.Shutdown()) } } }) @@ -234,6 +237,7 @@ func TestFilterBuilder_TestConstructFiltersForGroups(t *testing.T) { assert.Equal(t, totalLimitPerMetric, f.TotalLimit()) assert.Equal(t, limitPerMetricByTimestamp, f.LimitByTimestamp()) assert.Equal(t, expectedRemainingTotalLimit, result) + assert.NoError(t, f.Shutdown()) } } } diff --git a/receiver/googlecloudspannerreceiver/internal/filterfactory/itemfilterfactory_test.go b/receiver/googlecloudspannerreceiver/internal/filterfactory/itemfilterfactory_test.go index d2992a2a9a1d..3f07d8b6cebe 100644 --- a/receiver/googlecloudspannerreceiver/internal/filterfactory/itemfilterfactory_test.go +++ b/receiver/googlecloudspannerreceiver/internal/filterfactory/itemfilterfactory_test.go @@ -47,6 +47,7 @@ func TestNewItemFilterResolver(t *testing.T) { require.Nil(t, factory) } else { require.NoError(t, err) + require.NoError(t, factory.Shutdown()) } }) } diff --git a/receiver/googlecloudspannerreceiver/internal/filterfactory/package_test.go b/receiver/googlecloudspannerreceiver/internal/filterfactory/package_test.go new file mode 100644 index 000000000000..f35caa4efc4f --- /dev/null +++ b/receiver/googlecloudspannerreceiver/internal/filterfactory/package_test.go @@ -0,0 +1,15 @@ +// Copyright The OpenTelemetry Authors +// SPDX-License-Identifier: Apache-2.0 + +package filterfactory + +import ( + "testing" + + "go.uber.org/goleak" +) + +// See https://github.com/census-instrumentation/opencensus-go/issues/1191 for more information on ignore. +func TestMain(m *testing.M) { + goleak.VerifyTestMain(m, goleak.IgnoreTopFunction("go.opencensus.io/stats/view.(*worker).start")) +} diff --git a/receiver/googlecloudspannerreceiver/internal/statsreader/package_test.go b/receiver/googlecloudspannerreceiver/internal/statsreader/package_test.go new file mode 100644 index 000000000000..fbb8d96cfa7b --- /dev/null +++ b/receiver/googlecloudspannerreceiver/internal/statsreader/package_test.go @@ -0,0 +1,15 @@ +// Copyright The OpenTelemetry Authors +// SPDX-License-Identifier: Apache-2.0 + +package statsreader + +import ( + "testing" + + "go.uber.org/goleak" +) + +// See https://github.com/census-instrumentation/opencensus-go/issues/1191 for more information on ignore. +func TestMain(m *testing.M) { + goleak.VerifyTestMain(m, goleak.IgnoreTopFunction("go.opencensus.io/stats/view.(*worker).start")) +}