[chore] remove usage of deprecated component.Receiver (#16441)

Signed-off-by: Bogdan Drutu <[email protected]> Signed-off-by: Bogdan Drutu <[email protected]>
codeboten · Nov 22, 2022 · 86facb2 · 86facb2
1 parent 6cdf6a7
commit 86facb2
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/receiver/awsfirehosereceiver/receiver.go b/receiver/awsfirehosereceiver/receiver.go
@@ -112,7 +112,7 @@ type firehoseCommonAttributes struct {
  CommonAttributes map[string]string `json:"commonAttributes"`
 }
 
-var _ component.Receiver = (*firehoseReceiver)(nil)
+var _ component.MetricsReceiver = (*firehoseReceiver)(nil)
 var _ http.Handler = (*firehoseReceiver)(nil)
 
 // Start spins up the receiver's HTTP server and makes the receiver start

diff --git a/receiver/kafkareceiver/kafka_receiver.go b/receiver/kafkareceiver/kafka_receiver.go
@@ -81,9 +81,9 @@ type kafkaLogsConsumer struct {
  messageMarking MessageMarking
 }
 
-var _ component.Receiver = (*kafkaTracesConsumer)(nil)
-var _ component.Receiver = (*kafkaMetricsConsumer)(nil)
-var _ component.Receiver = (*kafkaLogsConsumer)(nil)
+var _ component.TracesReceiver = (*kafkaTracesConsumer)(nil)
+var _ component.MetricsReceiver = (*kafkaMetricsConsumer)(nil)
+var _ component.LogsReceiver = (*kafkaLogsConsumer)(nil)
 
 func newTracesReceiver(config Config, set component.ReceiverCreateSettings, unmarshalers map[string]TracesUnmarshaler, nextConsumer consumer.Traces) (*kafkaTracesConsumer, error) {
  unmarshaler := unmarshalers[config.Encoding]

diff --git a/receiver/receivercreator/receivermap_test.go b/receiver/receivercreator/receivermap_test.go
@@ -38,7 +38,7 @@ func TestReceiverMap(t *testing.T) {
  rm.Put("b", r3)
  assert.Equal(t, 3, rm.Size())
 
- assert.Equal(t, []component.Receiver{r1, r2}, rm.Get("a"))
+ assert.Equal(t, []component.Component{r1, r2}, rm.Get("a"))
  assert.Nil(t, rm.Get("missing"))
 
  rm.RemoveAll("missing")
@@ -53,5 +53,5 @@ func TestReceiverMap(t *testing.T) {
  rm.Put("a", r1)
  rm.Put("b", r2)
  assert.Equal(t, 2, rm.Size())
- assert.Equal(t, []component.Receiver{r1, r2}, rm.Values())
+ assert.Equal(t, []component.Component{r1, r2}, rm.Values())
 }
diff --git a/receiver/vcenterreceiver/scraper.go b/receiver/vcenterreceiver/scraper.go
@@ -30,7 +30,7 @@ import (
  "github.com/open-telemetry/opentelemetry-collector-contrib/receiver/vcenterreceiver/internal/metadata"
 )
 
-var _ component.Receiver = (*vcenterMetricScraper)(nil)
+var _ component.MetricsReceiver = (*vcenterMetricScraper)(nil)
 
 type vcenterMetricScraper struct {
  client *vcenterClient