mirror of
https://github.com/hanzoai/telemetry.git
synced 2026-10-30 20:01:49 +00:00
Bogdan DrutuandGitHub
8a94f0eb89
The problem here is that we have components like batchprocessor or others which are keeping a reference of the data and eventually modifying them without any concurrent access protection. Hence, it is required for the callers to not access any data that were passed downstream. This is not a backwards incompatible change, since pdata is not thread-safe this is a MUST to have here (consider a bug for not being documented) otherwise things will not work in the processing pipelines. Signed-off-by: Bogdan Drutu <[email protected]>
49 lines
1.5 KiB
Go
49 lines
1.5 KiB
Go
// Copyright The OpenTelemetry Authors
|
|
// SPDX-License-Identifier: Apache-2.0
|
|
|
|
package xconsumer // import "go.opentelemetry.io/collector/consumer/xconsumer"
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"go.opentelemetry.io/collector/consumer"
|
|
"go.opentelemetry.io/collector/consumer/internal"
|
|
"go.opentelemetry.io/collector/pdata/pprofile"
|
|
)
|
|
|
|
var errNilFunc = errors.New("nil consumer func")
|
|
|
|
// Profiles is an interface that receives pprofile.Profiles, processes it
|
|
// as needed, and sends it to the next processing node if any or to the destination.
|
|
type Profiles interface {
|
|
internal.BaseConsumer
|
|
// ConsumeProfiles processes the profiles. After the function returns, the profiles are no longer accessible,
|
|
// and accessing them is considered undefined behavior.
|
|
ConsumeProfiles(ctx context.Context, td pprofile.Profiles) error
|
|
}
|
|
|
|
// ConsumeProfilesFunc is a helper function that is similar to ConsumeProfiles.
|
|
type ConsumeProfilesFunc func(ctx context.Context, td pprofile.Profiles) error
|
|
|
|
// ConsumeProfiles calls f(ctx, td).
|
|
func (f ConsumeProfilesFunc) ConsumeProfiles(ctx context.Context, td pprofile.Profiles) error {
|
|
return f(ctx, td)
|
|
}
|
|
|
|
type baseProfiles struct {
|
|
*internal.BaseImpl
|
|
ConsumeProfilesFunc
|
|
}
|
|
|
|
// NewProfiles returns a Profiles configured with the provided options.
|
|
func NewProfiles(consume ConsumeProfilesFunc, options ...consumer.Option) (Profiles, error) {
|
|
if consume == nil {
|
|
return nil, errNilFunc
|
|
}
|
|
return &baseProfiles{
|
|
BaseImpl: internal.NewBaseImpl(options...),
|
|
ConsumeProfilesFunc: consume,
|
|
}, nil
|
|
}
|