Skip to content

Commit

Permalink
fix import path
Browse files Browse the repository at this point in the history
  • Loading branch information
VineethReddy02 committed Dec 14, 2021
1 parent 9f6410d commit 8d47f26
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions pkg/collector/parser/receiver_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@ import (
"testing"

"github.com/go-logr/logr"
"github.com/open-telemetry/opentelemetry-operator/pkg/collector/parser"
"github.com/stretchr/testify/assert"
corev1 "k8s.io/api/core/v1"
logf "sigs.k8s.io/controller-runtime/pkg/log"
Expand Down Expand Up @@ -98,10 +97,11 @@ func TestReceiverFailsWhenPortIsntString(t *testing.T) {
// verify
assert.Nil(t, p)
}

func TestIgnorekubeletstatsEndpoint(t *testing.T) {
// ignore "kubeletstats" receiver endpoint field, this is special case
// as this receiver gets parsed by generic receiver parser
builder := parser.NewGenericReceiverParser(logger, "kubeletstats", map[interface{}]interface{}{
builder := NewGenericReceiverParser(logger, "kubeletstats", map[interface{}]interface{}{
"endpoint": "0.0.0.0:9000",
})

Expand All @@ -112,6 +112,7 @@ func TestIgnorekubeletstatsEndpoint(t *testing.T) {
assert.NoError(t, err)
assert.Len(t, ports, 0)
}

func TestReceiverFallbackWhenNotRegistered(t *testing.T) {
// test
p := For(logger, "myreceiver", map[interface{}]interface{}{})
Expand Down

0 comments on commit 8d47f26

Please sign in to comment.