WIP

Signed-off-by: Thomas Poignant <[email protected]>

Author: thomaspoignant

Diff for: cmd/relayproxy/config/config.go

@@ -18,6 +18,7 @@ import (
 	"github.com/knadh/koanf/providers/posflag"
 	"github.com/knadh/koanf/v2"
 	"github.com/spf13/pflag"
+	ffclient "github.com/thomaspoignant/go-feature-flag"
 	"github.com/xitongsys/parquet-go/parquet"
 	"go.uber.org/zap"
 	"go.uber.org/zap/zapcore"
@@ -45,6 +46,7 @@ var DefaultExporter = struct {
 	MaxEventInMemory        int64
 	ParquetCompressionCodec string
 	LogLevel                string
+	ExporterEventType       ffclient.ExporterEventType
 }{
 	Format:    "JSON",
 	LogFormat: "[{{ .FormattedDate}}] user=\"{{ .UserKey}}\", flag=\"{{ .Key}}\", value=\"{{ .Value}}\"",
@@ -55,6 +57,7 @@ var DefaultExporter = struct {
 	MaxEventInMemory:        100000,
 	ParquetCompressionCodec: parquet.CompressionCodec_SNAPPY.String(),
 	LogLevel:                DefaultLogLevel,
+	ExporterEventType:       ffclient.FeatureEventExporter,
 }
 
 // New is reading the configuration file

Diff for: cmd/relayproxy/config/exporter.go

@@ -33,6 +33,7 @@ type ExporterConf struct {
 	AccountName             string                 `mapstructure:"accountName"             koanf:"accountname"`
 	AccountKey              string                 `mapstructure:"accountKey"              koanf:"accountkey"`
 	Container               string                 `mapstructure:"container"               koanf:"container"`
+	ExporterEventType       string                 `mapstructure:"eventType"               koanf:"eventtype"`
 }
 
 func (c *ExporterConf) IsValid() error {

Diff for: cmd/relayproxy/controller/collect_eval_data_test.go

@@ -193,7 +193,7 @@ func Test_collect_tracking_and_evaluation_events(t *testing.T) {
 	//
 	// PLEASE REWORK THIS TEST
 	//
-	//
+	// TODO: Do some tests that the exporterEventType is correctly set in the exporter
 	//
 	//
 	//

Diff for: cmd/relayproxy/service/gofeatureflag.go

@@ -168,6 +168,10 @@ func initDataExporters(proxyConf *config.Config) ([]ffclient.DataExporter, error
 }
 
 func initDataExporter(c *config.ExporterConf) (ffclient.DataExporter, error) {
+	exporterEventType := c.ExporterEventType
+	if exporterEventType == "" {
+		exporterEventType = config.DefaultExporter.ExporterEventType
+	}
 	dataExp := ffclient.DataExporter{
 		FlushInterval: func() time.Duration {
 			if c.FlushInterval != 0 {
@@ -181,6 +185,7 @@ func initDataExporter(c *config.ExporterConf) (ffclient.DataExporter, error) {
 			}
 			return config.DefaultExporter.MaxEventInMemory
 		}(),
+		ExporterEventType: exporterEventType,
 	}
 
 	var err error