mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Damien MathieuandGitHub
e0487504d7
<!--Ex. Fixing a bug - Describe the bug and how this fixes the issue. Ex. Adding a feature - Explain what this achieves.--> #### Description Following https://github.com/open-telemetry/opentelemetry-collector/pull/10464, this adds profiles support in consumertest. cc @mx-psi
30 lines
880 B
Go
30 lines
880 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package consumertest
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"go.opentelemetry.io/collector/pdata/plog"
|
|
"go.opentelemetry.io/collector/pdata/pmetric"
|
|
"go.opentelemetry.io/collector/pdata/pprofile"
|
|
"go.opentelemetry.io/collector/pdata/ptrace"
|
|
)
|
|
|
|
func TestErr(t *testing.T) {
|
|
err := errors.New("my error")
|
|
ec := NewErr(err)
|
|
require.NotNil(t, ec)
|
|
assert.NotPanics(t, ec.unexported)
|
|
assert.Equal(t, err, ec.ConsumeLogs(context.Background(), plog.NewLogs()))
|
|
assert.Equal(t, err, ec.ConsumeMetrics(context.Background(), pmetric.NewMetrics()))
|
|
assert.Equal(t, err, ec.ConsumeTraces(context.Background(), ptrace.NewTraces()))
|
|
assert.Equal(t, err, ec.ConsumeProfiles(context.Background(), pprofile.NewProfiles()))
|
|
}
|