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
23 lines
881 B
Go
23 lines
881 B
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package consumertest // import "go.opentelemetry.io/collector/consumer/consumertest"
|
|
import (
|
|
"context"
|
|
|
|
"go.opentelemetry.io/collector/pdata/plog"
|
|
"go.opentelemetry.io/collector/pdata/pmetric"
|
|
"go.opentelemetry.io/collector/pdata/pprofile"
|
|
"go.opentelemetry.io/collector/pdata/ptrace"
|
|
)
|
|
|
|
// NewErr returns a Consumer that just drops all received data and returns the specified error to Consume* callers.
|
|
func NewErr(err error) Consumer {
|
|
return &baseConsumer{
|
|
ConsumeTracesFunc: func(context.Context, ptrace.Traces) error { return err },
|
|
ConsumeMetricsFunc: func(context.Context, pmetric.Metrics) error { return err },
|
|
ConsumeLogsFunc: func(context.Context, plog.Logs) error { return err },
|
|
ConsumeProfilesFunc: func(context.Context, pprofile.Profiles) error { return err },
|
|
}
|
|
}
|