diff --git a/processor/schemaprocessor/internal/translation/revision_v1.go b/processor/schemaprocessor/internal/translation/revision_v1.go index ec54235b24b7..f4f4c294fb62 100644 --- a/processor/schemaprocessor/internal/translation/revision_v1.go +++ b/processor/schemaprocessor/internal/translation/revision_v1.go @@ -124,11 +124,11 @@ func newSpanEventChangeList(spanEvents ast.SpanEvents) *changelist.ChangeList { acceptableEventNames = append(acceptableEventNames, string(eventName)) } - attributeChangeSet := migrate.NewMultiConditionalAttributeSet(renamedAttribute.AttributeMap, map[string][]string{ + multiConditionalAttributeSet := migrate.NewMultiConditionalAttributeSet(renamedAttribute.AttributeMap, map[string][]string{ "span.name": acceptableSpanNames, "event.name": acceptableEventNames, }) - spanEventAttributeChangeSet := operator.NewSpanEventConditionalAttributeOperator(attributeChangeSet) + spanEventAttributeChangeSet := operator.SpanEventConditionalAttributeOperator{MultiConditionalAttributeSet: multiConditionalAttributeSet} values = append(values, spanEventAttributeChangeSet) } else { panic("spanEvents change must have either RenameEvents or RenameAttributes") diff --git a/processor/schemaprocessor/internal/translation/revision_v1_test.go b/processor/schemaprocessor/internal/translation/revision_v1_test.go index b1b4a9894fb9..dffdf84bdef0 100644 --- a/processor/schemaprocessor/internal/translation/revision_v1_test.go +++ b/processor/schemaprocessor/internal/translation/revision_v1_test.go @@ -227,15 +227,15 @@ func TestNewRevisionV1(t *testing.T) { "started": "application started", }), }, - operator.NewSpanEventConditionalAttributeOperator( - migrate.NewMultiConditionalAttributeSet( + operator.SpanEventConditionalAttributeOperator{ + MultiConditionalAttributeSet: migrate.NewMultiConditionalAttributeSet( map[string]string{"service.app.name": "service.name"}, map[string][]string{ "span.name": {"service running"}, "event.name": {"service errored"}, }, ), - ), + }, }}, metrics: &changelist.ChangeList{Migrators: []migrate.Migrator{ operator.MetricSignalNameChange{SignalNameChange: migrate.NewSignalNameChange(map[string]string{