Add trace-id filter

Signed-off-by: Chance Zibolski <chance.zibolski@gmail.com>
cilium · Oct 13, 2022 · e65862c · e65862c
1 parent 4b6193d
commit e65862c
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 0 deletions.
diff --git a/cmd/observe/flows.go b/cmd/observe/flows.go
@@ -324,6 +324,10 @@ more.`,
 		"http-path", ofilter,
 		`Show only flows which match this HTTP path regular expressions (e.g. "/page/\\d+")`))
 
+	filterFlags.Var(filterVar(
+		"trace-id", ofilter,
+		"Show only flows which match this trace ID"))
+
 	filterFlags.Var(filterVar(
 		"from-fqdn", ofilter,
 		`Show all flows originating at the given fully qualified domain name (e.g. "*.cilium.io").`))

diff --git a/cmd/observe/flows_filter.go b/cmd/observe/flows_filter.go
@@ -403,6 +403,11 @@ func (of *flowFilter) set(f *filterTracker, name, val string, track bool) error
 			f.DestinationPort = append(f.DestinationPort, val)
 		})
 
+	case "trace-id":
+		f.apply(func(f *flowpb.FlowFilter) {
+			f.TraceId = append(f.TraceId, val)
+		})
+
 	case "verdict":
 		if wipe {
 			f.apply(func(f *flowpb.FlowFilter) {