add e2e tests

open-telemetry · Sep 25, 2024 · 481a6e3 · 481a6e3
1 parent 38e3c5f
commit 481a6e3
Showing 1 changed file with 27 additions and 0 deletions.
diff --git a/pkg/ottl/e2e/e2e_test.go b/pkg/ottl/e2e/e2e_test.go
@@ -300,6 +300,9 @@ func Test_e2e_editors(t *testing.T) {
 	}
 }
 
+
+
+
 func Test_e2e_converters(t *testing.T) {
 	tests := []struct {
 		statement string
@@ -609,6 +612,30 @@ func Test_e2e_converters(t *testing.T) {
 				m.PutStr("k2", "v2__!__v2")
 			},
 		},
+		{
+			statement: `set(attributes["test"], MarshalKeyValue(ParseKeyValue("k1=v1 k2=v2")))`,
+			want: func(tCtx ottllog.TransformContext) {
+				tCtx.GetLogRecord().Attributes().PutStr("test", "k1=v1 k2=v2")
+			},
+		},
+		{
+			statement: `set(attributes["test"], MarshalKeyValue(ParseKeyValue("k1:v1,k2:v2", ":" , ","), ":", ","))`,
+			want: func(tCtx ottllog.TransformContext) {
+				tCtx.GetLogRecord().Attributes().PutStr("test", "k1:v1,k2:v2")
+			},
+		},
+		{
+			statement: `set(attributes["test"], MarshalKeyValue(ParseKeyValue("k1=v1 k2=v2"), "!", "+"))`,
+			want: func(tCtx ottllog.TransformContext) {
+				tCtx.GetLogRecord().Attributes().PutStr("test", "k1!v1+k2!v2")
+			},
+		},
+		{
+			statement: `set(attributes["test"], MarshalKeyValue(ParseKeyValue("k1=v1 k2=v2=v3")))`,
+			want: func(tCtx ottllog.TransformContext) {
+				tCtx.GetLogRecord().Attributes().PutStr("test", "k1=v1 k2=\"v2=v3\"")
+			},
+		},
 		{
 			statement: `set(attributes["test"], ParseXML("<Log id=\"1\"><Message>This is a log message!</Message></Log>"))`,
 			want: func(tCtx ottllog.TransformContext) {