perf(pipe): test without copy

pkg/jsonline/jsonline.go

@@ -126,9 +126,7 @@ func (s Sink) ProcessDictionary(dictionary model.Entry) error {
 // JSONToDictionary return a model.Dictionary from a jsonline
 func JSONToDictionary(jsonline []byte) (model.Dictionary, error) {
 	dict := model.NewDictionary()
-
 	err := dict.UnmarshalJSON(jsonline)
-
 	return model.CleanDictionary(dict), err
 }
 

pkg/model/ordered_dict.go

@@ -109,18 +109,14 @@ func CleanTypes(inter interface{}) interface{} {
 		}
 		return tab
 	case json.Number:
-
 		resFloat64, err := typedInter.Float64()
 		if err == nil {
 			return resFloat64
 		}
-
 		return typedInter.String()
-
 	case uint64:
 		res := float64(typedInter)
 		return res
-
 	case int64:
 		res := float64(typedInter)
 		return res
@@ -259,29 +255,23 @@ func UnorderedTypes(inter interface{}) interface{} {
 		return cleanmap
 	case []interface{}:
 		tab := []Entry{}
-
 		for _, item := range typedInter {
 			tab = append(tab, UnorderedTypes(item))
 		}
-
 		return tab
 
 	case []Dictionary:
 		tab := []Entry{}
-
 		for _, item := range typedInter {
 			tab = append(tab, UnorderedTypes(item))
 		}
-
 		return tab
 
 	case []Entry:
 		tab := []Entry{}
-
 		for _, item := range typedInter {
 			tab = append(tab, UnorderedTypes(item))
 		}
-
 		return tab
 
 	default:

pkg/pipe/pipe.go

@@ -60,7 +60,8 @@ func (me MaskEngine) MaskContext(e model.Dictionary, key string, context ...mode
 	var result []model.Entry
 	input := []model.Dictionary{}
 
-	copy := model.CopyDictionary(e)
+	// copy := model.CopyDictionary(e)
+	copy := e
 
 	value, ok := e.GetValue(key)
 	if !ok || value == nil {
@@ -99,7 +100,7 @@ func (me MaskEngine) MaskContext(e model.Dictionary, key string, context ...mode
 	over.MDC().Set("path", savePath)
 	over.MDC().Set("context", saveContext)
 	if err != nil {
-		return model.NewDictionary(), err
+		return copy, err
 	}
 	for _, dict := range result {
 		if len(me.injectParent) > 0 {