Create a /deep-dependencies endpoint

cmd/query/app/analytics/deep_dependencies_handler.go

@@ -0,0 +1,84 @@
+// Copyright (c) 2025 The Jaeger Authors.
+// SPDX-License-Identifier: Apache-2.0
+
+package analytics
+
+import (
+	"encoding/json"
+	"net/http"
+
+	"github.com/gorilla/mux"
+	"go.opentelemetry.io/otel/trace"
+)
+
+const (
+	routeGetDeepDependencies = "/api/deep-dependencies"
+)
+
+func RegisterRoutes(router *mux.Router) {
+	addRoute(router, getDeepDependencies, routeGetDeepDependencies).Methods(http.MethodGet)
+}
+
+// addRoute adds a new endpoint to the router with given path and handler function.
+// This code is mostly copied from ../http_handler.
+func addRoute(
+	router *mux.Router,
+	f func(http.ResponseWriter, *http.Request),
+	route string,
+	_ ...any, /* args */
+) *mux.Route {
+	var handler http.Handler = http.HandlerFunc(f)
+	handler = spanNameHandler(route, handler)
+	return router.HandleFunc(route, handler.ServeHTTP)
+}
+
+func spanNameHandler(spanName string, handler http.Handler) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		span := trace.SpanFromContext(r.Context())
+		span.SetName(spanName)
+		handler.ServeHTTP(w, r)
+	})
+}
+
+func getDeepDependencies(w http.ResponseWriter, _ *http.Request) {
+	dependencies := TDdgPayload{
+		Dependencies: []TDdgPayloadPath{
+			{
+				Path: []TDdgPayloadEntry{
+					{Service: "sample-serviceA", Operation: "sample-opA"},
+					{Service: "sample-serviceB", Operation: "sample-opB"},
+				},
+				Attributes: []Attribute{
+					{Key: "exemplar_trace_id", Value: "abc123"},
+				},
+			},
+		},
+	}
+	res, err := json.Marshal(dependencies)
+	if err != nil {
+		http.Error(w, "Failed to encode response", http.StatusInternalServerError)
+		return
+	}
+	w.Header().Set("Content-Type", "application/json")
+	w.Write(res)
+}
+
+// Structs that need to be used or created for deep dependencies
+type TDdgPayloadEntry struct {
+	Operation string `json:"operation"`
+	Service   string `json:"service"`
+}
+
+type Attribute struct {
+	Key   string `json:"key"`
+	Value string `json:"value"`
+}
+
+type TDdgPayloadPath struct {
+	Path       []TDdgPayloadEntry `json:"path"`
+	Attributes []Attribute        `json:"attributes"`
+}
+
+type TDdgPayload struct {
+	Dependencies []TDdgPayloadPath `json:"dependencies"`
+}

cmd/query/app/analytics/deep_dependencies_handler_test.go

@@ -0,0 +1,43 @@
+// Copyright (c) 2025 The Jaeger Authors.
+// SPDX-License-Identifier: Apache-2.0
+
+package analytics
+
+import (
+	"encoding/json"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+
+	"github.com/gorilla/mux"
+	"github.com/stretchr/testify/require"
+
+	_ "github.com/jaegertracing/jaeger/pkg/gogocodec" // force gogo codec registration
+)
+
+func TestGetDeepDependencies(t *testing.T) {
+	router := mux.NewRouter()
+	RegisterRoutes(router)
+
+	req, err := http.NewRequest(http.MethodGet, routeGetDeepDependencies, nil)
+	require.NoError(t, err)
+	rw := httptest.NewRecorder()
+	router.ServeHTTP(rw, req)
+	require.Equal(t, http.StatusOK, rw.Code)
+
+	var response TDdgPayload
+	err = json.Unmarshal(rw.Body.Bytes(), &response)
+	require.NoError(t, err)
+
+	expectedPath := []TDdgPayloadEntry{
+		{Service: "sample-serviceA", Operation: "sample-opA"},
+		{Service: "sample-serviceB", Operation: "sample-opB"},
+	}
+	expectedAttributes := []Attribute{
+		{Key: "exemplar_trace_id", Value: "abc123"},
+	}
+
+	require.Len(t, response.Dependencies, 1)
+	require.Equal(t, expectedPath, response.Dependencies[0].Path)
+	require.Equal(t, expectedAttributes, response.Dependencies[0].Attributes)
+}

cmd/query/app/analytics/package_test.go

@@ -0,0 +1,14 @@
+// Copyright (c) 2025 The Jaeger Authors.
+// SPDX-License-Identifier: Apache-2.0
+
+package analytics
+
+import (
+	"testing"
+
+	"github.com/jaegertracing/jaeger/pkg/testutils"
+)
+
+func TestMain(m *testing.M) {
+	testutils.VerifyGoLeaks(m)
+}

cmd/query/app/server.go

@@ -26,6 +26,7 @@ import (
 	"google.golang.org/grpc/reflection"
 
 	"github.com/jaegertracing/jaeger-idl/proto-gen/api_v2"
+	"github.com/jaegertracing/jaeger/cmd/query/app/analytics"
 	"github.com/jaegertracing/jaeger/cmd/query/app/apiv3"
 	"github.com/jaegertracing/jaeger/cmd/query/app/querysvc"
 	v2querysvc "github.com/jaegertracing/jaeger/cmd/query/app/querysvc/v2/querysvc"
@@ -105,7 +106,6 @@ func registerGRPCHandlers(
 
 	api_v2.RegisterQueryServiceServer(server, handler)
 	api_v3.RegisterQueryServiceServer(server, &apiv3.Handler{QueryService: v2QuerySvc})
-
 	healthServer.SetServingStatus("jaeger.api_v2.QueryService", grpc_health_v1.HealthCheckResponse_SERVING)
 	healthServer.SetServingStatus("jaeger.api_v2.metrics.MetricsQueryService", grpc_health_v1.HealthCheckResponse_SERVING)
 	healthServer.SetServingStatus("jaeger.api_v3.QueryService", grpc_health_v1.HealthCheckResponse_SERVING)
@@ -183,6 +183,8 @@ func initRouter(
 		Tracer:       telset.TracerProvider,
 	}).RegisterRoutes(r)
 
+	analytics.RegisterRoutes(r)
+
 	apiHandler.RegisterRoutes(r)
 	staticHandlerCloser := RegisterStaticHandler(r, telset.Logger, queryOpts, querySvc.GetCapabilities())