feat(update-collection-v3): migrate otellogs.config.override

src/go/cmd/update-collection-v3/main.go

@@ -13,6 +13,7 @@ import (
 	eventsconfigmerge "github.com/SumoLogic/sumologic-kubernetes-collection/tools/cmd/update-collection-v3/migrations/events-config-merge"
 	kubestatemetricscollectors "github.com/SumoLogic/sumologic-kubernetes-collection/tools/cmd/update-collection-v3/migrations/kube-state-metrics-collectors"
 	"github.com/SumoLogic/sumologic-kubernetes-collection/tools/cmd/update-collection-v3/migrations/logsmetadataconfig"
+	otellogsconfigmerge "github.com/SumoLogic/sumologic-kubernetes-collection/tools/cmd/update-collection-v3/migrations/otellogs-config-merge"
 	tracingreplaces "github.com/SumoLogic/sumologic-kubernetes-collection/tools/cmd/update-collection-v3/migrations/tracing-replaces"
 	"gopkg.in/yaml.v3"
 )
@@ -86,6 +87,10 @@ var migrations = []Migration{
 		directory: "logs-metadata-config",
 		action:    logsmetadataconfig.Migrate,
 	},
+	{
+		directory: "otellogs-config-merge",
+		action:    otellogsconfigmerge.Migrate,
+	},
 }
 
 func migrateYaml(input string) (string, error) {

src/go/cmd/update-collection-v3/migrations/otellogs-config-merge/migrate.go

@@ -0,0 +1,70 @@
+package otellogsconfigmerge
+
+import (
+	"bytes"
+	"fmt"
+
+	"gopkg.in/yaml.v3"
+)
+
+type InputValues struct {
+	Otellogs struct {
+		Config struct {
+			Override map[string]interface{} `yaml:"override,omitempty"`
+		} `yaml:"config,omitempty"`
+		Rest map[string]interface{} `yaml:",inline"`
+	} `yaml:"otellogs,omitempty"`
+	Rest map[string]interface{} `yaml:",inline"`
+}
+
+type OutputValues struct {
+	Otellogs Otellogs               `yaml:"otellogs,omitempty"`
+	Rest     map[string]interface{} `yaml:",inline"`
+}
+
+type Otellogs struct {
+	Config Config                 `yaml:"config,omitempty"`
+	Rest   map[string]interface{} `yaml:",inline"`
+}
+
+type Config struct {
+	Merge    map[string]interface{} `yaml:"merge,omitempty"`
+	Override map[string]interface{} `yaml:"override,omitempty"`
+}
+
+func Migrate(inputYaml string) (outputYaml string, err error) {
+	inputValues, err := parseValues(inputYaml)
+	if err != nil {
+		return "", fmt.Errorf("error parsing input yaml: %v", err)
+	}
+
+	outputValues, err := migrate(&inputValues)
+	if err != nil {
+		return "", fmt.Errorf("error migrating: %v", err)
+	}
+
+	buffer := bytes.Buffer{}
+	encoder := yaml.NewEncoder(&buffer)
+	encoder.SetIndent(2)
+	err = encoder.Encode(outputValues)
+	return buffer.String(), err
+}
+
+func parseValues(inputYaml string) (InputValues, error) {
+	var inputValues InputValues
+	err := yaml.Unmarshal([]byte(inputYaml), &inputValues)
+	return inputValues, err
+}
+
+func migrate(inputValues *InputValues) (OutputValues, error) {
+	outputValues := OutputValues{
+		Rest: inputValues.Rest,
+		Otellogs: Otellogs{
+			Config: Config{
+				Merge: inputValues.Otellogs.Config.Override,
+			},
+			Rest: inputValues.Otellogs.Rest,
+		},
+	}
+	return outputValues, nil
+}

src/go/cmd/update-collection-v3/migrations/otellogs-config-merge/testdata/basic.input.yaml

@@ -0,0 +1,4 @@
+otellogs:
+  config:
+    override:
+      key: value

src/go/cmd/update-collection-v3/migrations/otellogs-config-merge/testdata/basic.output.yaml

@@ -0,0 +1,4 @@
+otellogs:
+  config:
+    merge:
+      key: value

src/go/cmd/update-collection-v3/testdata/simple.input.yaml

@@ -12,6 +12,10 @@ otelevents:
   config:
     override:
       key: value
+otellogs:
+  config:
+    override:
+      key: value
 metadata:
   logs:
     config:

src/go/cmd/update-collection-v3/testdata/simple.output.yaml

@@ -7,6 +7,10 @@ otelevents:
   config:
     merge:
       key: value
+otellogs:
+  config:
+    merge:
+      key: value
 sumologic:
   accessId: xxx
   accessKey: yyy