Extend beholder log config for loops

Author: kirqz23

pkg/loop/config.go

@@ -65,6 +65,11 @@ const (
 	envTelemetryEmitterMaxQueueSize       = "CL_TELEMETRY_EMITTER_MAX_QUEUE_SIZE"
 	envTelemetryLogStreamingEnabled       = "CL_TELEMETRY_LOG_STREAMING_ENABLED"
 	envTelemetryLogLevel                  = "CL_TELEMETRY_LOG_LEVEL"
+	envTelemetryLogBatchProcessor         = "CL_TELEMETRY_LOG_BATCH_PROCESSOR"
+	envTelemetryLogExportTimeout          = "CL_TELEMETRY_LOG_EXPORT_TIMEOUT"
+	envTelemetryLogExportMaxBatchSize     = "CL_TELEMETRY_LOG_EXPORT_MAX_BATCH_SIZE"
+	envTelemetryLogExportInterval         = "CL_TELEMETRY_LOG_EXPORT_INTERVAL"
+	envTelemetryLogMaxQueueSize           = "CL_TELEMETRY_LOG_MAX_QUEUE_SIZE"
 
 	envChipIngressEndpoint           = "CL_CHIP_INGRESS_ENDPOINT"
 	envChipIngressInsecureConnection = "CL_CHIP_INGRESS_INSECURE_CONNECTION"
@@ -123,6 +128,11 @@ type EnvConfig struct {
 	TelemetryEmitterMaxQueueSize       int
 	TelemetryLogStreamingEnabled       bool
 	TelemetryLogLevel                  zapcore.Level
+	TelemetryLogBatchProcessor         bool
+	TelemetryLogExportTimeout          time.Duration
+	TelemetryLogExportMaxBatchSize     int
+	TelemetryLogExportInterval         time.Duration
+	TelemetryLogMaxQueueSize           int
 
 	ChipIngressEndpoint           string
 	ChipIngressInsecureConnection bool
@@ -194,6 +204,11 @@ func (e *EnvConfig) AsCmdEnv() (env []string) {
 	add(envTelemetryEmitterMaxQueueSize, strconv.Itoa(e.TelemetryEmitterMaxQueueSize))
 	add(envTelemetryLogStreamingEnabled, strconv.FormatBool(e.TelemetryLogStreamingEnabled))
 	add(envTelemetryLogLevel, e.TelemetryLogLevel.String())
+	add(envTelemetryLogBatchProcessor, strconv.FormatBool(e.TelemetryLogBatchProcessor))
+	add(envTelemetryLogExportTimeout, e.TelemetryLogExportTimeout.String())
+	add(envTelemetryLogExportMaxBatchSize, strconv.Itoa(e.TelemetryLogExportMaxBatchSize))
+	add(envTelemetryLogExportInterval, e.TelemetryLogExportInterval.String())
+	add(envTelemetryLogMaxQueueSize, strconv.Itoa(e.TelemetryLogMaxQueueSize))
 
 	add(envChipIngressEndpoint, e.ChipIngressEndpoint)
 	add(envChipIngressInsecureConnection, strconv.FormatBool(e.ChipIngressInsecureConnection))
@@ -371,6 +386,27 @@ func (e *EnvConfig) parse() error {
 			logLevel = zapcore.InfoLevel // Fallback to info level on invalid input
 		}
 		e.TelemetryLogLevel = logLevel
+		e.TelemetryLogBatchProcessor, err = getBool(envTelemetryLogBatchProcessor)
+		if err != nil {
+			return fmt.Errorf("failed to parse %s: %w", envTelemetryLogBatchProcessor, err)
+		}
+		e.TelemetryLogExportTimeout, err = getDuration(envTelemetryLogExportTimeout)
+		if err != nil {
+			return fmt.Errorf("failed to parse %s: %w", envTelemetryLogExportTimeout, err)
+		}
+		e.TelemetryLogExportMaxBatchSize, err = getInt(envTelemetryLogExportMaxBatchSize)
+		if err != nil {
+			return fmt.Errorf("failed to parse %s: %w", envTelemetryLogExportMaxBatchSize, err)
+		}
+		e.TelemetryLogExportInterval, err = getDuration(envTelemetryLogExportInterval)
+		if err != nil {
+			return fmt.Errorf("failed to parse %s: %w", envTelemetryLogExportInterval, err)
+		}
+		e.TelemetryLogMaxQueueSize, err = getInt(envTelemetryLogMaxQueueSize)
+		if err != nil {
+			return fmt.Errorf("failed to parse %s: %w", envTelemetryLogMaxQueueSize, err)
+		}
+
 		// Optional
 		e.ChipIngressEndpoint = os.Getenv(envChipIngressEndpoint)
 		e.ChipIngressInsecureConnection, err = getBool(envChipIngressInsecureConnection)

pkg/loop/server.go

@@ -141,6 +141,8 @@ func (s *Server) start() error {
 			EmitterMaxQueueSize:            s.EnvConfig.TelemetryEmitterMaxQueueSize,
 			LogStreamingEnabled:            s.EnvConfig.TelemetryLogStreamingEnabled,
 			LogLevel:                       s.EnvConfig.TelemetryLogLevel,
+			LogBatchProcessor:              s.EnvConfig.TelemetryLogBatchProcessor,
+			LogExportTimeout:               s.EnvConfig.TelemetryLogExportTimeout,
 			ChipIngressEmitterEnabled:      s.EnvConfig.ChipIngressEndpoint != "",
 			ChipIngressEmitterGRPCEndpoint: s.EnvConfig.ChipIngressEndpoint,
 			ChipIngressInsecureConnection:  s.EnvConfig.ChipIngressInsecureConnection,