From 86facb2da3d625944d98d41e4a6759e0284c4838 Mon Sep 17 00:00:00 2001 From: Bogdan Drutu Date: Tue, 22 Nov 2022 12:39:56 -0800 Subject: [PATCH] [chore] remove usage of deprecated component.Receiver (#16441) Signed-off-by: Bogdan Drutu Signed-off-by: Bogdan Drutu --- receiver/awsfirehosereceiver/receiver.go | 2 +- receiver/kafkareceiver/kafka_receiver.go | 6 +++--- receiver/receivercreator/receivermap_test.go | 4 ++-- receiver/vcenterreceiver/scraper.go | 2 +- 4 files changed, 7 insertions(+), 7 deletions(-) diff --git a/receiver/awsfirehosereceiver/receiver.go b/receiver/awsfirehosereceiver/receiver.go index 96bb56489ac39..8881f1161e0ef 100644 --- 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 index 96eb460df1951..aa9d969f9d5ee 100644 --- 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 index 53512bcf9d905..a58e7d1a67325 100644 --- 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 index d6747a61e8839..4eaf81d8852c7 100644 --- 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