Skip to content

Commit

Permalink
fix processors factory
Browse files Browse the repository at this point in the history
Signed-off-by: odubajDT <[email protected]>
  • Loading branch information
odubajDT committed Oct 31, 2024
1 parent 46938ef commit 9b13390
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 3 deletions.
2 changes: 1 addition & 1 deletion processor/resourcedetectionprocessor/factory.go
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ type factory struct {
}

// NewFactory creates a new factory for ResourceDetection processor.
func NewFactory() processorprofiles.Factory {
func NewFactory() processor.Factory {
resourceProviderFactory := internal.NewProviderFactory(map[internal.DetectorType]internal.DetectorFactory{
aks.TypeStr: aks.NewDetector,
azure.TypeStr: azure.NewDetector,
Expand Down

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ import (
"go.opentelemetry.io/collector/pdata/pprofile"
"go.opentelemetry.io/collector/pdata/ptrace"
"go.opentelemetry.io/collector/processor"
"go.opentelemetry.io/collector/processor/processorprofiles"
"go.opentelemetry.io/collector/processor/processortest"

"github.com/open-telemetry/opentelemetry-collector-contrib/processor/resourcedetectionprocessor/internal"
Expand Down Expand Up @@ -364,7 +365,7 @@ func BenchmarkConsumeLogsAll(b *testing.B) {
func benchmarkConsumeProfiles(b *testing.B, cfg *Config) {
factory := NewFactory()
sink := new(consumertest.ProfilesSink)
processor, _ := factory.CreateProfiles(context.Background(), processortest.NewNopSettings(), cfg, sink)
processor, _ := factory.(processorprofiles.Factory).CreateProfiles(context.Background(), processortest.NewNopSettings(), cfg, sink)

b.ResetTimer()
for n := 0; n < b.N; n++ {
Expand Down

0 comments on commit 9b13390

Please sign in to comment.