compact: Include DNS observation source

Signed-off-by: Michi Mutsuzaki <michi@isovalent.com>
cilium · Oct 26, 2022 · 86233b6 · 86233b6
1 parent 21a3eff
commit 86233b6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/pkg/printer/printer.go b/pkg/printer/printer.go
@@ -213,6 +213,7 @@ func GetFlowType(f *pb.Flow) string {
 			l7Protocol = "http"
 		case *pb.Layer7_Dns:
 			l7Protocol = "dns"
+			l7Type += " " + l7.GetDns().ObservationSource
 		case *pb.Layer7_Kafka:
 			l7Protocol = "kafka"
 		}

diff --git a/pkg/printer/printer_test.go b/pkg/printer/printer_test.go
@@ -620,15 +620,17 @@ func Test_getFlowType(t *testing.T) {
 			args: args{
 				f: &pb.Flow{
 					L7: &pb.Layer7{
-						Type:   pb.L7FlowType_REQUEST,
-						Record: &pb.Layer7_Dns{},
+						Type: pb.L7FlowType_REQUEST,
+						Record: &pb.Layer7_Dns{
+							Dns: &pb.DNS{ObservationSource: "proxy"},
+						},
 					},
 					EventType: &pb.CiliumEventType{
 						Type: monitorAPI.MessageTypeAccessLog,
 					},
 				},
 			},
-			want: "dns-request",
+			want: "dns-request proxy",
 		},
 		{
 			name: "L4",