feat(route transform): Add option to enable/disable unmatched output

src/transforms/route.rs

@@ -19,6 +19,7 @@ pub(crate) const UNMATCHED_ROUTE: &str = "_unmatched";
 #[derive(Clone)]
 pub struct Route {
     conditions: Vec<(String, Condition)>,
+    reroute_unmatched: bool,
 }
 
 impl Route {
@@ -28,7 +29,10 @@ impl Route {
             let condition = condition.build(&context.enrichment_tables)?;
             conditions.push((output_name.clone(), condition));
         }
-        Ok(Self { conditions })
+        Ok(Self {
+            conditions,
+            reroute_unmatched: config.reroute_unmatched,
+        })
     }
 }
 
@@ -47,7 +51,7 @@ impl SyncTransform for Route {
                 check_failed += 1;
             }
         }
-        if check_failed == self.conditions.len() {
+        if self.reroute_unmatched && check_failed == self.conditions.len() {
             output.push(Some(UNMATCHED_ROUTE), event);
         }
     }
@@ -61,11 +65,24 @@ impl SyncTransform for Route {
 #[derive(Clone, Debug)]
 #[serde(deny_unknown_fields)]
 pub struct RouteConfig {
+    /// Reroutes unmatched events to a named output instead of silently discarding them.
+    ///
+    /// Normally, if an event doesn't match any defined route, it is sent to the `<transform_name>._unmatched`
+    /// output for further processing. In some cases, you may want to simply discard unmatched events and not
+    /// process them any further.
+    ///
+    /// In these cases, `reroute_unmatched` can be set to `false` to disable the `<transform_name>._unmatched`
+    /// output and instead silently discard any unmatched events.
+    #[serde(default = "crate::serde::default_true")]
+    #[configurable(metadata(docs::human_name = "Reroute Unmatched Events"))]
+    reroute_unmatched: bool,
+
     /// A table of route identifiers to logical conditions representing the filter of the route.
     ///
     /// Each route can then be referenced as an input by other components with the name
-    /// `<transform_name>.<route_id>`. If an event doesn’t match any route, it is sent to the
-    /// `<transform_name>._unmatched` output.
+    /// `<transform_name>.<route_id>`. If an event doesn’t match any route, and if `reroute_unmatched`
+    /// is set to `true` (the default), it is sent to the `<transform_name>._unmatched` output.
+    /// Otherwise, the unmatched event is instead silently discarded.
     ///
     /// Both `_unmatched`, as well as `_default`, are reserved output names and thus cannot be used
     /// as a route name.
@@ -76,6 +93,7 @@ pub struct RouteConfig {
 impl GenerateConfig for RouteConfig {
     fn generate_config() -> toml::Value {
         toml::Value::try_from(Self {
+            reroute_unmatched: true,
             route: IndexMap::new(),
         })
         .unwrap()
@@ -118,10 +136,12 @@ impl TransformConfig for RouteConfig {
                     .with_port(output_name)
             })
             .collect();
-        result.push(
-            TransformOutput::new(DataType::all(), clone_input_definitions(input_definitions))
-                .with_port(UNMATCHED_ROUTE),
-        );
+        if self.reroute_unmatched {
+            result.push(
+                TransformOutput::new(DataType::all(), clone_input_definitions(input_definitions))
+                    .with_port(UNMATCHED_ROUTE),
+            );
+        }
         result
     }
 

website/cue/reference/components/transforms/base/route.cue

@@ -1,20 +1,37 @@
 package metadata
 
-base: components: transforms: route: configuration: route: {
-	description: """
-		A table of route identifiers to logical conditions representing the filter of the route.
+base: components: transforms: route: configuration: {
+	reroute_unmatched: {
+		description: """
+			Reroutes unmatched events to a named output instead of silently discarding them.
 
-		Each route can then be referenced as an input by other components with the name
-		`<transform_name>.<route_id>`. If an event doesn’t match any route, it is sent to the
-		`<transform_name>._unmatched` output.
+			Normally, if an event doesn't match any defined route, it is sent to the `<transform_name>._unmatched`
+			output for further processing. In some cases, you may want to simply discard unmatched events and not
+			process them any further.
 
-		Both `_unmatched`, as well as `_default`, are reserved output names and thus cannot be used
-		as a route name.
-		"""
-	required: false
-	type: object: options: "*": {
-		description: "An individual route."
-		required:    true
-		type: condition: {}
+			In these cases, `reroute_unmatched` can be set to `false` to disable the `<transform_name>._unmatched`
+			output and instead silently discard any unmatched events.
+			"""
+		required: false
+		type: bool: default: true
+	}
+	route: {
+		description: """
+			A table of route identifiers to logical conditions representing the filter of the route.
+
+			Each route can then be referenced as an input by other components with the name
+			`<transform_name>.<route_id>`. If an event doesn’t match any route, and if `reroute_unmatched`
+			is set to `true` (the default), it is sent to the `<transform_name>._unmatched` output.
+			Otherwise, the unmatched event is instead silently discarded.
+
+			Both `_unmatched`, as well as `_default`, are reserved output names and thus cannot be used
+			as a route name.
+			"""
+		required: false
+		type: object: options: "*": {
+			description: "An individual route."
+			required:    true
+			type: condition: {}
+		}
 	}
 }