Skip to content

Commit

Permalink
Add influxdb receiver (open-telemetry#423)
Browse files Browse the repository at this point in the history
  • Loading branch information
VineethReddy02 authored and hero committed Dec 12, 2021
1 parent cdfd5cf commit a4b2ba1
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 @@ -77,6 +77,7 @@ func TestDownstreamParsers(t *testing.T) {
{"zipkin-scribe", "zipkin-scribe", "__zipkinscribe", 9410, parser.NewZipkinScribeReceiverParser},
{"fluentforward", "fluentforward", "__fluentforward", 8006, parser.NewFluentForwardReceiverParser},
{"statsd", "statsd", "__statsd", 8125, parser.NewStatsdReceiverParser},
{"influxdb", "influxdb", "__influxdb", 8086, parser.NewInfluxdbReceiverParser},
} {
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_influxdb.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 parserNameInfluxdb = "__influxdb"

// NewInfluxdbReceiverParser builds a new parser for Influxdb receivers, from the contrib repository.
func NewInfluxdbReceiverParser(logger logr.Logger, name string, config map[interface{}]interface{}) ReceiverParser {
return &GenericReceiver{
logger: logger,
name: name,
config: config,
defaultPort: 8086,
parserName: parserNameInfluxdb,
}
}

func init() {
Register("influxdb", NewInfluxdbReceiverParser)
}
17 changes: 17 additions & 0 deletions pkg/collector/parser/receiver_influxdb_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 Influxdb parser are currently part of the test TestDownstreamParsers

0 comments on commit a4b2ba1

Please sign in to comment.