Merge pull request #1350 from vimalk78/log-2259

LOG-2259: Vector: Add Route transform for application routing only once

internal/generator/vector/sources_to_inputs.go

@@ -96,6 +96,7 @@ func SourcesToInputs(spec *logging.ClusterLogForwarderSpec, o generator.Options)
 		el = append(el, r)
 	}
 	userDefined := spec.InputMap()
+	routeMap := map[string]string{}
 	for _, pipeline := range spec.Pipelines {
 		for _, inRef := range pipeline.InputRefs {
 			if input, ok := userDefined[inRef]; ok {
@@ -121,18 +122,19 @@ func SourcesToInputs(spec *logging.ClusterLogForwarderSpec, o generator.Options)
 						}
 					}
 					if len(matchNS) != 0 || len(matchLabels) != 0 {
-						el = append(el, Route{
-							ComponentID: RouteApplicationLogs,
-							Inputs:      helpers.MakeInputs(logging.InputNameApplication),
-							Routes: map[string]string{
-								input.Name: Quote(AND(OR(matchNS...), AND(matchLabels...))),
-							},
-						})
+						routeMap[input.Name] = Quote(AND(OR(matchNS...), AND(matchLabels...)))
 					}
 				}
 			}
 		}
 	}
+	if len(routeMap) != 0 {
+		el = append(el, Route{
+			ComponentID: RouteApplicationLogs,
+			Inputs:      helpers.MakeInputs(logging.InputNameApplication),
+			Routes:      routeMap,
+		})
+	}
 
 	return el
 }