mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
dabca90d34
#### Description Continuation of https://github.com/open-telemetry/opentelemetry-collector/pull/11085. <!-- Issue number if applicable --> #### Link to tracking issue Fixes https://github.com/open-telemetry/opentelemetry-collector/issues/7047 --------- Co-authored-by: Tyler Helmuth <[email protected]> Co-authored-by: Evan Bradley <[email protected]>
96 lines
2.6 KiB
Go
96 lines
2.6 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package consumererror
|
|
|
|
import (
|
|
"errors"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"go.opentelemetry.io/collector/pdata/testdata"
|
|
)
|
|
|
|
func TestTraces(t *testing.T) {
|
|
td := testdata.GenerateTraces(1)
|
|
err := errors.New("some error")
|
|
traceErr := NewTraces(err, td)
|
|
require.EqualError(t, err, traceErr.Error())
|
|
var target Traces
|
|
assert.NotErrorAs(t, nil, &target)
|
|
assert.NotErrorAs(t, err, &target)
|
|
require.ErrorAs(t, traceErr, &target)
|
|
assert.Equal(t, td, target.Data())
|
|
}
|
|
|
|
func TestTraces_Unwrap(t *testing.T) {
|
|
td := testdata.GenerateTraces(1)
|
|
var err error = testErrorType{"some error"}
|
|
// Wrapping err with error Traces.
|
|
traceErr := NewTraces(err, td)
|
|
target := testErrorType{}
|
|
require.NotEqual(t, err, target)
|
|
// Unwrapping traceErr for err and assigning to target.
|
|
require.ErrorAs(t, traceErr, &target)
|
|
require.Equal(t, err, target)
|
|
var e *Error
|
|
require.ErrorAs(t, traceErr, &e)
|
|
assert.True(t, e.IsRetryable())
|
|
}
|
|
|
|
func TestLogs(t *testing.T) {
|
|
td := testdata.GenerateLogs(1)
|
|
err := errors.New("some error")
|
|
logsErr := NewLogs(err, td)
|
|
require.EqualError(t, err, logsErr.Error())
|
|
var target Logs
|
|
assert.NotErrorAs(t, nil, &target)
|
|
assert.NotErrorAs(t, err, &target)
|
|
require.ErrorAs(t, logsErr, &target)
|
|
assert.Equal(t, td, target.Data())
|
|
}
|
|
|
|
func TestLogs_Unwrap(t *testing.T) {
|
|
td := testdata.GenerateLogs(1)
|
|
var err error = testErrorType{"some error"}
|
|
// Wrapping err with error Logs.
|
|
logsErr := NewLogs(err, td)
|
|
target := testErrorType{}
|
|
require.NotEqual(t, err, target)
|
|
// Unwrapping logsErr for err and assigning to target.
|
|
require.ErrorAs(t, logsErr, &target)
|
|
require.Equal(t, err, target)
|
|
var e *Error
|
|
require.ErrorAs(t, logsErr, &e)
|
|
assert.True(t, e.IsRetryable())
|
|
}
|
|
|
|
func TestMetrics(t *testing.T) {
|
|
td := testdata.GenerateMetrics(1)
|
|
err := errors.New("some error")
|
|
metricErr := NewMetrics(err, td)
|
|
require.EqualError(t, err, metricErr.Error())
|
|
var target Metrics
|
|
assert.NotErrorAs(t, nil, &target)
|
|
assert.NotErrorAs(t, err, &target)
|
|
require.ErrorAs(t, metricErr, &target)
|
|
assert.Equal(t, td, target.Data())
|
|
}
|
|
|
|
func TestMetrics_Unwrap(t *testing.T) {
|
|
td := testdata.GenerateMetrics(1)
|
|
var err error = testErrorType{"some error"}
|
|
// Wrapping err with error Metrics.
|
|
metricErr := NewMetrics(err, td)
|
|
target := testErrorType{}
|
|
require.NotEqual(t, err, target)
|
|
// Unwrapping metricErr for err and assigning to target.
|
|
require.ErrorAs(t, metricErr, &target)
|
|
require.Equal(t, err, target)
|
|
var e *Error
|
|
require.ErrorAs(t, metricErr, &e)
|
|
assert.True(t, e.IsRetryable())
|
|
}
|