diff --git a/pkg/collector/parser/receiver_fluent-forward.go b/pkg/collector/parser/receiver_fluent-forward.go new file mode 100644 index 0000000000..94170fa051 --- /dev/null +++ b/pkg/collector/parser/receiver_fluent-forward.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 parserNameFluentForward = "__fluentforward" + +// NewFluentForwardReceiverParser builds a new parser for FluentForward receivers, from the contrib repository. +func NewFluentForwardReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser { + return &GenericReceiver{ + logger: logger, + name: name, + config: config, + defaultPort: 8006, + parserName: parserNameFluentForward, + } +} + +func init() { + Register("fluentforward", NewFluentForwardReceiverParser) +} diff --git a/pkg/collector/parser/receiver_fluent-forward_test.go b/pkg/collector/parser/receiver_fluent-forward_test.go new file mode 100644 index 0000000000..ee8959260f --- /dev/null +++ b/pkg/collector/parser/receiver_fluent-forward_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 FluentForward 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 93c290c5f2..985343e295 100644 --- a/pkg/collector/parser/receiver_generic_test.go +++ b/pkg/collector/parser/receiver_generic_test.go @@ -75,6 +75,7 @@ func TestDownstreamParsers(t *testing.T) { {"signalfx", "signalfx", "__signalfx", 9943, parser.NewSignalFxReceiverParser}, {"wavefront", "wavefront", "__wavefront", 2003, parser.NewWavefrontReceiverParser}, {"zipkin-scribe", "zipkin-scribe", "__zipkinscribe", 9410, parser.NewZipkinScribeReceiverParser}, + {"fluentforward", "fluentforward", "__fluentforward", 8006, parser.NewFluentForwardReceiverParser}, } { t.Run(tt.receiverName, func(t *testing.T) { t.Run("builds successfully", func(t *testing.T) {