Function handleServiceMap

modules/sentry/api_service_map.go:9–109

(db *sql.DB)

)

func handleServiceMap(db *sql.DB) http.HandlerFunc {
	return func(w http.ResponseWriter, r *http.Request) {
		windowMinutes := 60
		if v := r.URL.Query().Get("window"); v != "" {
			if n, err := strconv.Atoi(v); err == nil && n > 0 && n <= 10080 {
				windowMinutes = n
			}
		}

		// Build edges from spans with peer_address.
		edgeRows, err := db.Query(
			`SELECT
				COALESCE(service_name, 'unknown') as source,
				peer_address as target,
				peer_type as op_type,
				COUNT(*) as request_count,
				SUM(CASE WHEN is_error = 1 THEN 1 ELSE 0 END) as error_count,
				CAST(AVG(duration_ms) AS INTEGER) as avg_duration_ms
			FROM sentry_spans
			WHERE peer_address IS NOT NULL
				AND start_ts >= datetime('now', ? || ' minutes')
			GROUP BY source, target, op_type
			ORDER BY request_count DESC`,
			strconv.Itoa(-windowMinutes),
		)
		if err != nil {
			apiError(w, err.Error(), http.StatusInternalServerError)
			return
		}
		defer edgeRows.Close()

		nodeMap := make(map[string]*serviceNode)
		var edges []map[string]any

		for edgeRows.Next() {
			var (
				source, target, opType      string
				requestCount, errorCount    int
				avgDuration                 sql.NullInt64
			)
			if err := edgeRows.Scan(&source, &target, &opType, &requestCount, &errorCount, &avgDuration); err != nil {
				continue
			}

			edges = append(edges, map[string]any{
				"source":          source,
				"target":          target,
				"op_type":         opType,
				"request_count":   requestCount,
				"error_count":     errorCount,
				"avg_duration_ms": scanNullInt(avgDuration),
			})

			// Accumulate node stats.
			if _, ok := nodeMap[source]; !ok {
				nodeMap[source] = &serviceNode{ID: source, Label: source}
			}
			nodeMap[source].RequestCount += requestCount