feature: event query support tags filter (#2772)

api/proto/core/monitor/event/event_query.proto

@@ -22,6 +22,7 @@ message GetEventsRequest {
   int64 pageNo = 7;
   int64 pageSize = 8;
   bool debug = 9;
+  map<string,string> tags = 10;
 }
 
 message GetEventsResponse {

modules/core/monitor/event/query/event.query.service.go

@@ -59,6 +59,15 @@ func (s *eventQueryService) GetEvents(ctx context.Context, req *pb.GetEventsRequ
 			Value: req.RelationId,
 		})
 	}
+	if len(req.Tags) > 0 {
+		for key, val := range req.Tags {
+			sel.Filters = append(sel.Filters, &storage.Filter{
+				Key:   "tags." + key,
+				Op:    storage.EQ,
+				Value: val,
+			})
+		}
+	}
 	list, err := s.storageReader.QueryPaged(ctx, sel, int(req.PageNo), int(req.PageSize))
 	if err != nil {
 		return nil, err

modules/core/monitor/event/query/event.query.service_test.go

@@ -95,6 +95,38 @@ func Test_eventQueryService_GetEvents_WithValidParams_Should_Return_NonEmptyList
 			{EventID: "event-id-1"},
 		}, nil)
 
+	querySvc := &eventQueryService{
+		storageReader: storage,
+	}
+	result, err := querySvc.GetEvents(context.Background(), &pb.GetEventsRequest{
+		Start:        1,
+		End:          2,
+		TraceId:      "trace-id",
+		RelationId:   "res-id",
+		RelationType: "res-type",
+		Tags: map[string]string{
+			"key-1": "val-1",
+		},
+	})
+	if err != nil {
+		t.Errorf("should not throw error")
+	}
+	if result == nil || len(result.Data.Items) != 1 {
+		t.Errorf("assert result failed")
+	}
+
+}
+
+func Test_eventQueryService_GetEvents_WithNilTags_Should_Not_Throw(t *testing.T) {
+	ctrl := gomock.NewController(t)
+	defer ctrl.Finish()
+	storage := NewMockStorage(ctrl)
+	storage.EXPECT().
+		QueryPaged(gomock.Any(), gomock.Any(), gomock.Any(), gomock.Any()).
+		Return([]*event.Event{
+			{EventID: "event-id-1"},
+		}, nil)
+
 	querySvc := &eventQueryService{
 		storageReader: storage,
 	}