Skip to content

Feature/web UI pod pid mapping #11

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ianchen0119 merged 3 commits into from
Feb 2, 2026
Merged

Feature/web UI pod pid mapping #11

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
b60f3ef
feat(web-ui): add Pod-PID Mapping and UI improvements
c9274326 Jan 22, 2026
9c9ff26
chore: add Web UI development server files
c9274326 Jan 31, 2026
777fe1d
feat(api): add GET /api/v1/pods/pids endpoint for pod-PID mapping
c9274326 Feb 2, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions decisionmaker/rest/handler.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,8 @@ func (h *Handler) SetupRoutes(engine *echo.Echo) error {
apiV1.DELETE("/intents", h.echoHandler(h.DeleteIntent), echo.WrapMiddleware(authMiddleware))
apiV1.GET("/scheduling/strategies", h.echoHandler(h.ListIntents), echo.WrapMiddleware(authMiddleware))
apiV1.POST("/metrics", h.echoHandler(h.UpdateMetrics), echo.WrapMiddleware(authMiddleware))
// pod routes
apiV1.GET("/pods/pids", h.echoHandler(h.GetPodsPIDs), echo.WrapMiddleware(authMiddleware))
// token routes
apiV1.POST("/auth/token", h.echoHandler(h.GenTokenHandler))
}
Expand Down
96 changes: 96 additions & 0 deletions decisionmaker/rest/pod_handler.go
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,96 @@
package rest

import (
"net/http"
"os"
"time"

"github.com/Gthulhu/api/decisionmaker/domain"
)

// PodProcess represents a process information within a pod (for API response)
type PodProcess struct {
PID int `json:"pid"`
Command string `json:"command"`
PPID int `json:"ppid,omitempty"`
ContainerID string `json:"container_id,omitempty"`
}

// PodInfo represents pod information with associated processes (for API response)
type PodInfo struct {
PodUID string `json:"pod_uid"`
PodID string `json:"pod_id,omitempty"`
Processes []PodProcess `json:"processes"`
}

// GetPodsPIDsResponse is the response structure for the GET /api/v1/pods/pids endpoint
type GetPodsPIDsResponse struct {
Pods []PodInfo `json:"pods"`
Timestamp string `json:"timestamp"`
NodeName string `json:"node_name"`
NodeID string `json:"node_id,omitempty"`
}

// GetPodsPIDs godoc
// @Summary Get Pod to PID mappings
// @Description Returns all pods running on this node with their associated process IDs
// @Tags Pods
// @Produce json
// @Security BearerAuth
// @Success 200 {object} SuccessResponse[GetPodsPIDsResponse]
// @Failure 401 {object} ErrorResponse
// @Failure 500 {object} ErrorResponse
// @Router /api/v1/pods/pids [get]
func (h *Handler) GetPodsPIDs(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()

// Get all pod information from /proc filesystem
podInfoMap, err := h.Service.GetAllPodInfos(ctx)
if err != nil {
h.ErrorResponse(ctx, w, http.StatusInternalServerError, "Failed to retrieve pod information", err)
return
}

// Convert map to slice for response
pods := make([]PodInfo, 0, len(podInfoMap))
for _, podInfo := range podInfoMap {
processes := make([]PodProcess, 0, len(podInfo.Processes))
for _, proc := range podInfo.Processes {
processes = append(processes, PodProcess{
PID: proc.PID,
Command: proc.Command,
PPID: proc.PPID,
ContainerID: proc.ContainerID,
})
}
pods = append(pods, PodInfo{
PodUID: podInfo.PodUID,
PodID: podInfo.PodID,
Processes: processes,
})
}

// Get node name from hostname or environment variable
nodeName, _ := os.Hostname()
if envNodeName := os.Getenv("NODE_NAME"); envNodeName != "" {
nodeName = envNodeName
}

response := GetPodsPIDsResponse{
Pods: pods,
Timestamp: time.Now().UTC().Format(time.RFC3339),
NodeName: nodeName,
}

h.JSONResponse(ctx, w, http.StatusOK, NewSuccessResponse(&response))
}

// convertDomainPodProcess converts domain.PodProcess to rest.PodProcess
func convertDomainPodProcess(proc domain.PodProcess) PodProcess {
return PodProcess{
PID: proc.PID,
Command: proc.Command,
PPID: proc.PPID,
ContainerID: proc.ContainerID,
}
}
Loading