Add Kiali trace details

Signed-off-by: josunect <[email protected]>

Author: josunect

README.md

@@ -462,16 +462,19 @@ In case multi-cluster support is enabled (default) and you have access to multip
   - `startMicros` (`string`) - Start time for traces in microseconds since epoch (optional)
   - `tags` (`string`) - JSON string of tags to filter traces (optional)
 
-- **workload_traces** - Get distributed tracing data for a specific workload in a namespace. Returns trace information including spans, duration, and error details for troubleshooting and performance analysis.
+- **workload_traces** - Get distributed tracing data for a specific workload in a namespace. Returns trace information including spans, duration, and error details for troubleshooting and performance analysis. Note: startMicros and endMicros are typically required by the Kiali API.
   - `clusterName` (`string`) - Cluster name for multi-cluster environments (optional)
-  - `endMicros` (`string`) - End time for traces in microseconds since epoch (optional)
+  - `endMicros` (`string`) - End time for traces in microseconds since epoch (required by Kiali API)
   - `limit` (`integer`) - Maximum number of traces to return (default: 100)
   - `minDuration` (`integer`) - Minimum trace duration in microseconds (optional)
   - `namespace` (`string`) **(required)** - Namespace containing the workload
-  - `startMicros` (`string`) - Start time for traces in microseconds since epoch (optional)
+  - `startMicros` (`string`) - Start time for traces in microseconds since epoch (required by Kiali API)
   - `tags` (`string`) - JSON string of tags to filter traces (optional)
   - `workload` (`string`) **(required)** - Name of the workload to get traces for
 
+- **trace_details** - Get detailed information for a specific trace by its ID. Returns complete trace information including all spans, timing details, and metadata for in-depth analysis.
+  - `traceId` (`string`) **(required)** - Unique identifier of the trace to retrieve
+
 </details>
 
 

pkg/kiali/mesh_test.go

@@ -38,3 +38,29 @@ func (s *KialiSuite) TestMeshStatus() {
 	})
 
 }
+
+func (s *KialiSuite) TestTraceDetails() {
+	var capturedURL *url.URL
+	s.MockServer.Config().BearerToken = "token-xyz"
+	s.MockServer.Handle(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		u := *r.URL
+		capturedURL = &u
+		_, _ = w.Write([]byte(`{"traceId":"test-trace-123","spans":[]}`))
+	}))
+
+	s.Config = test.Must(config.ReadToml([]byte(fmt.Sprintf(`
+		[toolset_configs.kiali]
+		url = "%s"
+	`, s.MockServer.Config().Host))))
+	k := NewKiali(s.Config, s.MockServer.Config())
+
+	traceId := "test-trace-123"
+	out, err := k.TraceDetails(s.T().Context(), traceId)
+	s.Require().NoError(err, "Expected no error executing request")
+	s.Run("response body is correct", func() {
+		s.Contains(out, traceId, "Response should contain trace ID")
+	})
+	s.Run("path is correct", func() {
+		s.Equal("/api/traces/test-trace-123", capturedURL.Path, "Unexpected path")
+	})
+}

pkg/kiali/traces.go

@@ -105,3 +105,16 @@ func (k *Kiali) WorkloadTraces(ctx context.Context, namespace string, workload s
 
 	return k.executeRequest(ctx, http.MethodGet, endpoint, "", nil)
 }
+
+// TraceDetails returns detailed information for a specific trace by its ID.
+// Parameters:
+//   - traceId: the unique identifier of the trace
+func (k *Kiali) TraceDetails(ctx context.Context, traceId string) (string, error) {
+	if traceId == "" {
+		return "", fmt.Errorf("trace ID is required")
+	}
+
+	endpoint := fmt.Sprintf("/api/traces/%s", url.PathEscape(traceId))
+
+	return k.executeRequest(ctx, http.MethodGet, endpoint, "", nil)
+}

pkg/toolsets/kiali/traces.go

@@ -128,7 +128,7 @@ func initTraces() []api.ServerTool {
 	ret = append(ret, api.ServerTool{
 		Tool: api.Tool{
 			Name:        "workload_traces",
-			Description: "Get distributed tracing data for a specific workload in a namespace. Returns trace information including spans, duration, and error details for troubleshooting and performance analysis.",
+			Description: "Get distributed tracing data for a specific workload in a namespace. Returns trace information including spans, duration, and error details for troubleshooting and performance analysis. Note: startMicros and endMicros are typically required by the Kiali API.",
 			InputSchema: &jsonschema.Schema{
 				Type: "object",
 				Properties: map[string]*jsonschema.Schema{
@@ -142,11 +142,11 @@ func initTraces() []api.ServerTool {
 					},
 					"startMicros": {
 						Type:        "string",
-						Description: "Start time for traces in microseconds since epoch (optional)",
+						Description: "Start time for traces in microseconds since epoch (required by Kiali API)",
 					},
 					"endMicros": {
 						Type:        "string",
-						Description: "End time for traces in microseconds since epoch (optional)",
+						Description: "End time for traces in microseconds since epoch (required by Kiali API)",
 					},
 					"limit": {
 						Type:        "integer",
@@ -180,6 +180,32 @@ func initTraces() []api.ServerTool {
 		Handler: workloadTracesHandler,
 	})
 
+	// Trace details tool
+	ret = append(ret, api.ServerTool{
+		Tool: api.Tool{
+			Name:        "trace_details",
+			Description: "Get detailed information for a specific trace by its ID. Returns complete trace information including all spans, timing details, and metadata for in-depth analysis.",
+			InputSchema: &jsonschema.Schema{
+				Type: "object",
+				Properties: map[string]*jsonschema.Schema{
+					"traceId": {
+						Type:        "string",
+						Description: "Unique identifier of the trace to retrieve",
+					},
+				},
+				Required: []string{"traceId"},
+			},
+			Annotations: api.ToolAnnotations{
+				Title:           "Trace: Details",
+				ReadOnlyHint:    ptr.To(true),
+				DestructiveHint: ptr.To(false),
+				IdempotentHint:  ptr.To(true),
+				OpenWorldHint:   ptr.To(true),
+			},
+		},
+		Handler: traceDetailsHandler,
+	})
+
 	return ret
 }
 
@@ -283,3 +309,18 @@ func workloadTracesHandler(params api.ToolHandlerParams) (*api.ToolCallResult, e
 	}
 	return api.NewToolCallResult(content, nil), nil
 }
+
+func traceDetailsHandler(params api.ToolHandlerParams) (*api.ToolCallResult, error) {
+	// Extract required parameter
+	traceId, ok := params.GetArguments()["traceId"].(string)
+	if !ok || traceId == "" {
+		return api.NewToolCallResult("", fmt.Errorf("traceId parameter is required")), nil
+	}
+
+	k := params.NewKiali()
+	content, err := k.TraceDetails(params.Context, traceId)
+	if err != nil {
+		return api.NewToolCallResult("", fmt.Errorf("failed to get trace details: %v", err)), nil
+	}
+	return api.NewToolCallResult(content, nil), nil
+}