feat: 7074 | added summary view apis

ee/query-service/app/api/api.go

@@ -203,3 +203,21 @@ func (ah *APIHandler) getVersion(w http.ResponseWriter, r *http.Request) {
 
 	ah.WriteJSON(w, r, versionResponse)
 }
+
+func (ah *APIHandler) MetricExplorerRoutes(router *mux.Router, am *baseapp.AuthMiddleware) {
+	router.HandleFunc("/api/v1/metrics",
+		am.ViewAccess(ah.ListMetrics)).
+		Methods(http.MethodPost)
+	router.HandleFunc("/api/v1/metrics/treemap",
+		am.ViewAccess(ah.GetTreeMap)).
+		Methods(http.MethodPost)
+	router.HandleFunc("/api/v1/metrics/{metric_name}",
+		am.ViewAccess(ah.GetMetricsDetails)).
+		Methods(http.MethodGet)
+	router.HandleFunc("/api/v1/metrics/filters/keys",
+		am.ViewAccess(ah.FilterKeysSuggestion)).
+		Methods(http.MethodGet)
+	router.HandleFunc("/api/v1/metrics/filters/values",
+		am.ViewAccess(ah.FilterValuesSuggestion)).
+		Methods(http.MethodPost)
+}

ee/query-service/app/api/summary.go

@@ -0,0 +1,103 @@
+package api
+
+import (
+	"bytes"
+	"go.signoz.io/signoz/pkg/query-service/model"
+	"io"
+	"net/http"
+
+	"github.com/gorilla/mux"
+	explorer "go.signoz.io/signoz/pkg/query-service/app/metricsexplorer"
+	"go.uber.org/zap"
+)
+
+func (aH *APIHandler) FilterKeysSuggestion(w http.ResponseWriter, r *http.Request) {
+	bodyBytes, _ := io.ReadAll(r.Body)
+	r.Body = io.NopCloser(bytes.NewBuffer(bodyBytes))
+	ctx := r.Context()
+	params, apiError := explorer.ParseFilterKeySuggestions(r)
+	if apiError != nil {
+		zap.L().Error("error parsing summary filter keys request", zap.Error(apiError.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+	keys, apiError := aH.APIHandler.SummaryService.FilterKeys(ctx, params)
+	if apiError != nil {
+		zap.L().Error("error getting filter keys", zap.Error(apiError.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+	aH.Respond(w, keys)
+}
+
+func (aH *APIHandler) FilterValuesSuggestion(w http.ResponseWriter, r *http.Request) {
+	bodyBytes, _ := io.ReadAll(r.Body)
+	r.Body = io.NopCloser(bytes.NewBuffer(bodyBytes))
+	ctx := r.Context()
+	params, apiError := explorer.ParseFilterValueSuggestions(r)
+	if apiError != nil {
+		zap.L().Error("error parsing summary filter values request", zap.Error(apiError.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+
+	values, apiError := aH.APIHandler.SummaryService.FilterValues(ctx, params)
+	if apiError != nil {
+		zap.L().Error("error getting filter values", zap.Error(apiError.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+	aH.Respond(w, values)
+}
+
+func (aH *APIHandler) ListMetrics(w http.ResponseWriter, r *http.Request) {
+	bodyBytes, _ := io.ReadAll(r.Body)
+	r.Body = io.NopCloser(bytes.NewBuffer(bodyBytes))
+	ctx := r.Context()
+	params, apiError := explorer.ParseSummaryListMetricsParams(r)
+	if apiError != nil {
+		zap.L().Error("error parsing metric list metric summary api request", zap.Error(apiError.Err))
+		RespondError(w, model.BadRequest(apiError), nil)
+		return
+	}
+
+	slmr, apiErr := aH.APIHandler.SummaryService.ListMetricsWithSummary(ctx, params)
+	if apiErr != nil {
+		zap.L().Error("error parsing metric query range params", zap.Error(apiErr.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+	aH.Respond(w, slmr)
+}
+
+func (aH *APIHandler) GetMetricsDetails(w http.ResponseWriter, r *http.Request) {
+	metricName := mux.Vars(r)["metric_name"]
+	ctx := r.Context()
+	metricsDetail, apiError := aH.APIHandler.SummaryService.GetMetricsSummary(ctx, metricName)
+	if apiError != nil {
+		zap.L().Error("error parsing metric query range params", zap.Error(apiError.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+	aH.Respond(w, metricsDetail)
+}
+
+func (aH *APIHandler) GetTreeMap(w http.ResponseWriter, r *http.Request) {
+	bodyBytes, _ := io.ReadAll(r.Body)
+	r.Body = io.NopCloser(bytes.NewBuffer(bodyBytes))
+	ctx := r.Context()
+	params, apiError := explorer.ParseTreeMapMetricsParams(r)
+	if apiError != nil {
+		zap.L().Error("error parsing metric query range params", zap.Error(apiError.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+	result, apiError := aH.APIHandler.SummaryService.GetMetricsTreemap(ctx, params)
+	if apiError != nil {
+		zap.L().Error("error getting heatmap data", zap.Error(apiError.Err))
+		RespondError(w, apiError, nil)
+		return
+	}
+	aH.Respond(w, result)
+
+}

ee/query-service/app/server.go

@@ -374,6 +374,7 @@ func (s *Server) createPublicServer(apiHandler *api.APIHandler, web web.Web) (*h
 	apiHandler.RegisterQueryRangeV4Routes(r, am)
 	apiHandler.RegisterWebSocketPaths(r, am)
 	apiHandler.RegisterMessagingQueuesRoutes(r, am)
+	apiHandler.MetricExplorerRoutes(r, am)
 
 	c := cors.New(cors.Options{
 		AllowedOrigins: []string{"*"},