feat: Feature/opentel

cmd/relayproxy/config/exporter.go

@@ -4,30 +4,34 @@ import (
 	"fmt"
 
 	"github.com/thomaspoignant/go-feature-flag/exporter/kafkaexporter"
+	"github.com/thomaspoignant/go-feature-flag/exporter/opentelemetryexporter"
 	"github.com/xitongsys/parquet-go/parquet"
 )
 
 // ExporterConf contains all the field to configure an exporter
+// The parquet compression line is too long.
+// nolint:lll
 type ExporterConf struct {
-	Kind                    ExporterKind           `mapstructure:"kind" koanf:"kind"`
-	OutputDir               string                 `mapstructure:"outputDir" koanf:"outputdir"`
-	Format                  string                 `mapstructure:"format" koanf:"format"`
-	Filename                string                 `mapstructure:"filename" koanf:"filename"`
-	CsvTemplate             string                 `mapstructure:"csvTemplate" koanf:"csvtemplate"`
-	Bucket                  string                 `mapstructure:"bucket" koanf:"bucket"`
-	Path                    string                 `mapstructure:"path" koanf:"path"`
-	EndpointURL             string                 `mapstructure:"endpointUrl" koanf:"endpointurl"`
-	Secret                  string                 `mapstructure:"secret" koanf:"secret"`
-	Meta                    map[string]string      `mapstructure:"meta" koanf:"meta"`
-	LogFormat               string                 `mapstructure:"logFormat" koanf:"logformat"`
-	FlushInterval           int64                  `mapstructure:"flushInterval" koanf:"flushinterval"`
-	MaxEventInMemory        int64                  `mapstructure:"maxEventInMemory" koanf:"maxeventinmemory"`
-	ParquetCompressionCodec string                 `mapstructure:"parquetCompressionCodec" koanf:"parquetcompressioncodec"`
-	Headers                 map[string][]string    `mapstructure:"headers" koanf:"headers"`
-	QueueURL                string                 `mapstructure:"queueUrl" koanf:"queueurl"`
-	Kafka                   kafkaexporter.Settings `mapstructure:"kafka" koanf:"kafka"`
+	Kind                    ExporterKind                   `mapstructure:"kind" koanf:"kind"`
+	OutputDir               string                         `mapstructure:"outputDir" koanf:"outputdir"`
+	Format                  string                         `mapstructure:"format" koanf:"format"`
+	Filename                string                         `mapstructure:"filename" koanf:"filename"`
+	CsvTemplate             string                         `mapstructure:"csvTemplate" koanf:"csvtemplate"`
+	Bucket                  string                         `mapstructure:"bucket" koanf:"bucket"`
+	Path                    string                         `mapstructure:"path" koanf:"path"`
+	EndpointURL             string                         `mapstructure:"endpointUrl" koanf:"endpointurl"`
+	Secret                  string                         `mapstructure:"secret" koanf:"secret"`
+	Meta                    map[string]string              `mapstructure:"meta" koanf:"meta"`
+	LogFormat               string                         `mapstructure:"logFormat" koanf:"logformat"`
+	FlushInterval           int64                          `mapstructure:"flushInterval" koanf:"flushinterval"`
+	MaxEventInMemory        int64                          `mapstructure:"maxEventInMemory" koanf:"maxeventinmemory"`
+	ParquetCompressionCodec string                         `mapstructure:"parquetCompressionCodec" koanf:"parquetcompressioncodec"`
+	Headers                 map[string][]string            `mapstructure:"headers" koanf:"headers"`
+	QueueURL                string                         `mapstructure:"queueUrl" koanf:"queueurl"`
+	Kafka                   kafkaexporter.Settings         `mapstructure:"kafka" koanf:"kafka"`
 	ProjectID               string                 `mapstructure:"projectID" koanf:"projectid"`
 	Topic                   string                 `mapstructure:"topic" koanf:"topic"`
+	OpenTel                 opentelemetryexporter.Settings `mapstructure:"opentel" koanf:"opentel"`
 }
 
 func (c *ExporterConf) IsValid() error {
@@ -60,6 +64,10 @@ func (c *ExporterConf) IsValid() error {
 		return fmt.Errorf("invalid exporter: \"projectID\" and \"topic\" are required for kind \"%s\"", c.Kind)
 	}
 
+	if c.Kind == OpenTelExporter && (c.OpenTel.OpentelSettings.URI == "") {
+		return fmt.Errorf("invalid exporter: \"opentel.uri\" is required for kind \"%s\"", c.Kind)
+	}
+
 	return nil
 }
 
@@ -74,13 +82,14 @@ const (
 	SQSExporter           ExporterKind = "sqs"
 	KafkaExporter         ExporterKind = "kafka"
 	PubSubExporter        ExporterKind = "pubsub"
+	OpenTelExporter       ExporterKind = "opentel"
 )
 
 // IsValid is checking if the value is part of the enum
 func (r ExporterKind) IsValid() error {
 	switch r {
 	case FileExporter, WebhookExporter, LogExporter, S3Exporter, GoogleStorageExporter, SQSExporter, KafkaExporter,
-		PubSubExporter:
+		OpenTelExporter, PubSubExporter:
 		return nil
 	}
 	return fmt.Errorf("invalid exporter: kind \"%s\" is not supported", r)

cmd/relayproxy/config/exporter_test.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/stretchr/testify/assert"
 	"github.com/thomaspoignant/go-feature-flag/cmd/relayproxy/config"
+	"github.com/thomaspoignant/go-feature-flag/exporter/opentelemetryexporter"
 )
 
 func TestExporterConf_IsValid(t *testing.T) {
@@ -23,6 +24,7 @@ func TestExporterConf_IsValid(t *testing.T) {
 		QueueURL                string
 		ProjectID               string
 		Topic                   string
+		OpenTel                 opentelemetryexporter.Settings
 	}
 	tests := []struct {
 		name     string
@@ -186,6 +188,35 @@ func TestExporterConf_IsValid(t *testing.T) {
 			wantErr:  true,
 			errValue: "invalid exporter: \"projectID\" and \"topic\" are required for kind \"pubsub\"",
 		},
+		{
+			name: "kind OpenTel with no creds",
+			fields: fields{
+				Kind:    "opentel",
+				OpenTel: opentelemetryexporter.Settings{OpentelSettings: opentelemetryexporter.OpenTelSettings{URI: "localhost"}},
+			},
+			wantErr: false,
+		},
+		{
+			name: "kind OpenTel with creds",
+			fields: fields{
+				Kind: "opentel",
+				OpenTel: opentelemetryexporter.Settings{
+					OpentelSettings: opentelemetryexporter.OpenTelSettings{URI: "localhost", CACertPath: "/tmp/does-not-exist"},
+				},
+			},
+			wantErr: false,
+		},
+		{
+			name: "kind OpenTel with no uri",
+			fields: fields{
+				Kind: "opentel",
+				OpenTel: opentelemetryexporter.Settings{
+					OpentelSettings: opentelemetryexporter.OpenTelSettings{CACertPath: "/tmp/does-not-exist"},
+				},
+			},
+			wantErr:  true,
+			errValue: "invalid exporter: \"opentel.uri\" is required for kind \"opentel\"",
+		},
 	}
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
@@ -204,6 +235,7 @@ func TestExporterConf_IsValid(t *testing.T) {
 				QueueURL:                tt.fields.QueueURL,
 				ProjectID:               tt.fields.ProjectID,
 				Topic:                   tt.fields.Topic,
+				OpenTel:                 tt.fields.OpenTel,
 			}
 			err := c.IsValid()
 			assert.Equal(t, tt.wantErr, err != nil)