diff --git a/pkg/collector/parser/receiver_aws-xray.go b/pkg/collector/parser/receiver_aws-xray.go new file mode 100644 index 0000000000..6d8f92c7bb --- /dev/null +++ b/pkg/collector/parser/receiver_aws-xray.go @@ -0,0 +1,34 @@ +// Copyright The OpenTelemetry Authors +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package parser + +import "github.com/go-logr/logr" + +const parserNameAWSXRAY = "__awsxray" + +// NewAWSXrayReceiverParser builds a new parser for AWS xray receivers, from the contrib repository. +func NewAWSXrayReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser { + return &GenericReceiver{ + logger: logger, + name: name, + config: config, + defaultPort: 2000, + parserName: parserNameAWSXRAY, + } +} + +func init() { + Register("awsxray", NewAWSXrayReceiverParser) +} diff --git a/pkg/collector/parser/receiver_aws-xray_test.go b/pkg/collector/parser/receiver_aws-xray_test.go new file mode 100644 index 0000000000..bbd752f080 --- /dev/null +++ b/pkg/collector/parser/receiver_aws-xray_test.go @@ -0,0 +1,17 @@ +// Copyright The OpenTelemetry Authors +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +package parser + +// all tests for the AWS XRAY parser are currently part of the test TestDownstreamParsers diff --git a/pkg/collector/parser/receiver_generic_test.go b/pkg/collector/parser/receiver_generic_test.go index 0bb6b845b3..7c0766dd68 100644 --- a/pkg/collector/parser/receiver_generic_test.go +++ b/pkg/collector/parser/receiver_generic_test.go @@ -79,6 +79,7 @@ func TestDownstreamParsers(t *testing.T) { {"statsd", "statsd", "__statsd", 8125, parser.NewStatsdReceiverParser}, {"influxdb", "influxdb", "__influxdb", 8086, parser.NewInfluxdbReceiverParser}, {"splunk-hec", "splunk-hec", "__splunk_hec", 8088, parser.NewSplunkHecReceiverParser}, + {"awsxray", "awsxray", "__awsxray", 2000, parser.NewAWSXrayReceiverParser}, } { t.Run(tt.receiverName, func(t *testing.T) { t.Run("builds successfully", func(t *testing.T) {