Skip to content

Commit

Permalink
Add Splunk Hec receiver (#422)
Browse files Browse the repository at this point in the history
  • Loading branch information
VineethReddy02 authored Sep 9, 2021
1 parent 55787a8 commit 8b00052
Show file tree
Hide file tree
Showing 3 changed files with 52 additions and 0 deletions.
1 change: 1 addition & 0 deletions pkg/collector/parser/receiver_generic_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -78,6 +78,7 @@ func TestDownstreamParsers(t *testing.T) {
{"fluentforward", "fluentforward", "__fluentforward", 8006, parser.NewFluentForwardReceiverParser},
{"statsd", "statsd", "__statsd", 8125, parser.NewStatsdReceiverParser},
{"influxdb", "influxdb", "__influxdb", 8086, parser.NewInfluxdbReceiverParser},
{"splunk-hec", "splunk-hec", "__splunk_hec", 8088, parser.NewSplunkHecReceiverParser},
} {
t.Run(tt.receiverName, func(t *testing.T) {
t.Run("builds successfully", func(t *testing.T) {
Expand Down
34 changes: 34 additions & 0 deletions pkg/collector/parser/receiver_splunk-hec.go
Original file line number Diff line number Diff line change
@@ -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 parserNameSplunkHec = "__splunk_hec"

// NewSplunkHecReceiverParser builds a new parser for Splunk Hec receivers, from the contrib repository.
func NewSplunkHecReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser {
return &GenericReceiver{
logger: logger,
name: name,
config: config,
defaultPort: 8088,
parserName: parserNameSplunkHec,
}
}

func init() {
Register("splunk_hec", NewSplunkHecReceiverParser)
}
17 changes: 17 additions & 0 deletions pkg/collector/parser/receiver_splunk-hec_test.go
Original file line number Diff line number Diff line change
@@ -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 Splunk Hec parser are currently part of the test TestDownstreamParsers

0 comments on commit 8b00052

Please sign in to comment.