feat: datasource supports file_event_metrics

Author: xiaochaoren1

server/controller/http/service/data_source.go

@@ -144,6 +144,10 @@ func (d *DataSource) GetDataSources(orgID int, filter map[string]interface{}, sp
 				collection = "prometheus.*"
 			case "traffic_policy":
 				collection = "flow_metrics.traffic_policy"
+			case "in_process_metrics":
+				collection = "profile.in_process_metrics"
+			case "file_event_metrics":
+				collection = "event.file_event_metrics"
 			default:
 				collection = t.(string)
 			}

server/querier/engine/clickhouse/clickhouse.go

@@ -490,7 +490,7 @@ func (e *CHEngine) ParseShowSql(sql string, args *common.QuerierParams, DebugInf
 			formatMetricByLanguage(args.Language, result.Values)
 		}
 		return result, []string{}, true, err
-	case 4: // show tag X values from Y  X, Y not nil
+	case 4: // show tag X values from Y; X, Y not nil
 		result, sqlList, err := tagdescription.GetTagValues(e.DB, table, sql, args.QueryCacheTTL, args.ORGID, args.Language, args.UseQueryCache)
 		e.DB = "flow_tag"
 		return result, sqlList, true, err
@@ -506,7 +506,7 @@ func (e *CHEngine) ParseShowSql(sql string, args *common.QuerierParams, DebugInf
 			formatTagByLanguage(args.Language, data.Values)
 		}
 		return data, []string{}, true, err
-	case 6: // show  tables...
+	case 6: // show tables...
 		if e.DB == chCommon.DB_NAME_DEEPFLOW_TENANT && len(visibilityFilter) > 0 {
 			where = visibilityWhere
 		}
@@ -515,7 +515,7 @@ func (e *CHEngine) ParseShowSql(sql string, args *common.QuerierParams, DebugInf
 			result.Values = dataVisibilityfiltering(visibilityFilterRegexp, result.Values)
 		}
 		return result, []string{}, true, nil
-	case 7: // show  databases...
+	case 7: // show databases...
 		result := GetDatabases()
 		if len(visibilityFilter) > 0 {
 			result.Values = dataVisibilityfiltering(visibilityFilterRegexp, result.Values)

server/querier/engine/clickhouse/common/utils.go

@@ -110,14 +110,20 @@ func ParseResponse(response *http.Response) (map[string]interface{}, error) {
 func GetDatasources(db string, table string, orgID string) ([]string, error) {
 	var datasources []string
 	switch db {
-	case "flow_metrics":
+	case "flow_metrics", DB_NAME_PROFILE, DB_NAME_EVENT:
 		var tsdbType string
 		if table == "network" || table == "network_map" {
 			tsdbType = "network"
 		} else if table == "application" || table == "application_map" {
 			tsdbType = "application"
 		} else if table == TABLE_NAME_VTAP_ACL {
 			tsdbType = TABLE_NAME_VTAP_ACL
+		} else if table == TABLE_NAME_IN_PROCESS_METRICS {
+			tsdbType = TABLE_NAME_IN_PROCESS_METRICS
+		} else if table == TABLE_NAME_FILE_EVENT_METRICS {
+			tsdbType = TABLE_NAME_FILE_EVENT_METRICS
+		} else {
+			return datasources, nil
 		}
 		client := &http.Client{}
 		url := fmt.Sprintf("http://localhost:%d/v1/data-sources/?type=%s", config.ControllerCfg.ListenPort, tsdbType)