Merge pull request #159 from devopsext/5745

update filter_ex processor
devopsext · Oct 1, 2024 · f1577a7 · f1577a7
2 parents 3d6fa43 + a0b5666
commit f1577a7
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/plugins/processors/filter_ex/filter_ex.go b/plugins/processors/filter_ex/filter_ex.go
@@ -27,11 +27,12 @@ type FilterIf struct {
 }
 
 type Filter struct {
-	Ifs    []*FilterIf       `toml:"if"`
-	Fields []string          `toml:"fields,omitempty"`
-	Tags   map[string]string `toml:"tags,omitempty"`
-	Log    telegraf.Logger   `toml:"-"`
-	rAll   *regexp.Regexp
+	DropOriginal bool              `toml:"drop_original"`
+	Ifs          []*FilterIf       `toml:"if"`
+	Fields       []string          `toml:"fields,omitempty"`
+	Tags         map[string]string `toml:"tags,omitempty"`
+	Log          telegraf.Logger   `toml:"-"`
+	rAll         *regexp.Regexp
 }
 
 var description = "Advanced filtering for metrics based on tags"
@@ -158,7 +159,11 @@ func (f *Filter) Apply(metrics ...telegraf.Metric) []telegraf.Metric {
 			}
 		}
 
-		if len(valids) == 0 {
+		if len(valids) == 0 && f.DropOriginal {
+
+			metric.Drop()
+
+		} else if len(valids) == 0 {
 
 			only = append(only, metric)