Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

PR 3/5 #8

Open
wants to merge 2 commits into
base: Otel-Contrib-Second-PR
Choose a base branch
from
Open

PR 3/5 #8

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
cdfebe6
Add advanced functionality for Metrics support for Sematext
AkhigbeEromo Feb 19, 2025
b3ba053
Fix lint issues
AkhigbeEromo Feb 19, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
33 changes: 29 additions & 4 deletions exporter/sematextexporter/factory.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,18 +7,19 @@ package sematextexporter // import "github.com/open-telemetry/opentelemetry-coll

import (
"context"
"fmt"
"time"

"github.com/google/uuid"
"github.com/influxdata/influxdb-observability/common"
"github.com/influxdata/influxdb-observability/otel2influx"
"go.opentelemetry.io/collector/component"
"go.opentelemetry.io/collector/config/confighttp"
"go.opentelemetry.io/collector/config/configopaque"
"go.opentelemetry.io/collector/config/configretry"
"go.opentelemetry.io/collector/exporter"
"go.opentelemetry.io/collector/exporter/exporterhelper"
"go.opentelemetry.io/collector/pdata/plog"
"go.opentelemetry.io/collector/pdata/pmetric"

"github.com/open-telemetry/opentelemetry-collector-contrib/exporter/sematextexporter/internal/metadata"
)
Expand Down Expand Up @@ -61,13 +62,37 @@ func createMetricsExporter(
) (exporter.Metrics, error) {
cfg := config.(*Config)

// Initialize the logger for Sematext
logger := newZapSematextLogger(set.Logger)

// Create a writer for sending metrics to Sematext
writer, err := newSematextHTTPWriter(logger, cfg, set.TelemetrySettings)
if err != nil {
return nil, fmt.Errorf("failed to create Sematext HTTP writer: %w", err)
}
schema, found := common.MetricsSchemata[cfg.MetricsSchema]
if !found {
return nil, fmt.Errorf("schema '%s' not recognized", cfg.MetricsSchema)
}

expConfig := otel2influx.DefaultOtelMetricsToLineProtocolConfig()
expConfig.Logger = logger
expConfig.Writer = writer
expConfig.Schema = schema
exp, err := otel2influx.NewOtelMetricsToLineProtocol(expConfig)
if err != nil {
return nil, err
}

return exporterhelper.NewMetrics(
ctx,
set,
cfg,
func(_ context.Context, _ pmetric.Metrics) error {
return nil
},
exp.WriteMetrics,
exporterhelper.WithQueue(cfg.QueueSettings),
exporterhelper.WithRetry(cfg.BackOffConfig),
exporterhelper.WithStart(writer.Start),
exporterhelper.WithShutdown(writer.Shutdown),
)
}

Expand Down
7 changes: 5 additions & 2 deletions exporter/sematextexporter/go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,8 @@ require (
github.com/cenkalti/backoff/v4 v4.3.0
github.com/google/uuid v1.6.0
github.com/influxdata/influxdb-observability/common v0.5.12
github.com/influxdata/influxdb-observability/otel2influx v0.5.12
github.com/influxdata/line-protocol/v2 v2.2.1
github.com/stretchr/testify v1.10.0
go.opentelemetry.io/collector/component v0.120.0
go.opentelemetry.io/collector/component/componenttest v0.120.0
Expand All @@ -14,10 +16,12 @@ require (
go.opentelemetry.io/collector/config/configretry v1.26.0
go.opentelemetry.io/collector/confmap v1.26.0
go.opentelemetry.io/collector/confmap/xconfmap v0.120.0
go.opentelemetry.io/collector/consumer/consumererror v0.120.0
go.opentelemetry.io/collector/exporter v0.120.0
go.opentelemetry.io/collector/exporter/exportertest v0.120.0
go.opentelemetry.io/collector/pdata v1.26.0
go.uber.org/goleak v1.3.0
go.uber.org/zap v1.27.0
)

require go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.59.0 // indirect
Expand Down Expand Up @@ -50,7 +54,6 @@ require (
go.opentelemetry.io/collector/config/configcompression v1.26.0 // indirect
go.opentelemetry.io/collector/config/configtls v1.26.0 // indirect
go.opentelemetry.io/collector/consumer v1.26.0 // indirect
go.opentelemetry.io/collector/consumer/consumererror v0.120.0 // indirect
go.opentelemetry.io/collector/consumer/consumertest v0.120.0 // indirect
go.opentelemetry.io/collector/consumer/xconsumer v0.120.0 // indirect
go.opentelemetry.io/collector/exporter/xexporter v0.120.0 // indirect
Expand All @@ -70,7 +73,7 @@ require (
go.opentelemetry.io/otel/sdk/metric v1.34.0 // indirect
go.opentelemetry.io/otel/trace v1.34.0 // indirect
go.uber.org/multierr v1.11.0 // indirect
go.uber.org/zap v1.27.0 // indirect
golang.org/x/exp v0.0.0-20240222234643-814bf88cf225 // indirect
golang.org/x/net v0.35.0 // indirect
golang.org/x/sys v0.30.0 // indirect
golang.org/x/text v0.22.0 // indirect
Expand Down
24 changes: 24 additions & 0 deletions exporter/sematextexporter/go.sum
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

25 changes: 25 additions & 0 deletions exporter/sematextexporter/logger.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
// Copyright The OpenTelemetry Authors
// SPDX-License-Identifier: Apache-2.0

package sematextexporter // import "github.com/open-telemetry/opentelemetry-collector-contrib/exporter/sematextexporter"

import (
"github.com/influxdata/influxdb-observability/common"
"go.uber.org/zap"
)

type zapSematextLogger struct {
*zap.SugaredLogger
}

func newZapSematextLogger(logger *zap.Logger) common.Logger {
return &common.ErrorLogger{
Logger: &zapSematextLogger{
logger.Sugar(),
},
}
}

func (l zapSematextLogger) Debug(msg string, kv ...any) {
l.SugaredLogger.Debugw(msg, kv...)
}
Loading
Loading