feat: add service for managing Kubernetes resources

Author: dogukanoksuz

app/handlers/kubernetes.go

@@ -0,0 +1,68 @@
+package handlers
+
+import (
+	"github.com/gofiber/fiber/v2"
+	"github.com/limanmys/render-engine/app/models"
+	"github.com/limanmys/render-engine/internal/kubernetes"
+	"github.com/limanmys/render-engine/pkg/logger"
+	"github.com/limanmys/render-engine/pkg/validator"
+)
+
+var kubernetesService = kubernetes.NewService()
+
+// GetNamespaces lists all namespaces in the Kubernetes cluster
+func GetNamespaces(c *fiber.Ctx) error {
+	var req models.NamespaceRequest
+	if err := c.BodyParser(&req); err != nil {
+		return logger.FiberError(fiber.StatusBadRequest, "Invalid request body")
+	}
+
+	if err := validator.ValidateStruct(&req); err != nil {
+		return logger.FiberError(fiber.StatusBadRequest, err.Error())
+	}
+
+	namespaces, err := kubernetesService.GetNamespaces(c.Context(), req.Kubeconfig)
+	if err != nil {
+		return logger.FiberError(fiber.StatusInternalServerError, err.Error())
+	}
+
+	return c.JSON(namespaces)
+}
+
+// GetDeployments lists all deployments in a specific namespace
+func GetDeployments(c *fiber.Ctx) error {
+	var req models.DeploymentRequest
+	if err := c.BodyParser(&req); err != nil {
+		return logger.FiberError(fiber.StatusBadRequest, "Invalid request body")
+	}
+
+	if err := validator.ValidateStruct(&req); err != nil {
+		return logger.FiberError(fiber.StatusBadRequest, err.Error())
+	}
+
+	deployments, err := kubernetesService.GetDeployments(c.Context(), req.Kubeconfig, req.Namespace)
+	if err != nil {
+		return logger.FiberError(fiber.StatusInternalServerError, err.Error())
+	}
+
+	return c.JSON(deployments)
+}
+
+// GetDeploymentDetails gets detailed information about a specific deployment
+func GetDeploymentDetails(c *fiber.Ctx) error {
+	var req models.DeploymentDetailsRequest
+	if err := c.BodyParser(&req); err != nil {
+		return logger.FiberError(fiber.StatusBadRequest, "Invalid request body")
+	}
+
+	if err := validator.ValidateStruct(&req); err != nil {
+		return logger.FiberError(fiber.StatusBadRequest, err.Error())
+	}
+
+	deploymentDetails, err := kubernetesService.GetDeploymentDetails(c.Context(), req.Kubeconfig, req.Namespace, req.Deployment)
+	if err != nil {
+		return logger.FiberError(fiber.StatusNotFound, err.Error())
+	}
+
+	return c.JSON(deploymentDetails)
+}

app/models/kubernetes.go

@@ -0,0 +1,90 @@
+package models
+
+// Request models for Kubernetes API
+type KubeconfigRequest struct {
+	Kubeconfig string `json:"kubeconfig" validate:"required,base64"`
+}
+
+type NamespaceRequest struct {
+	Kubeconfig string `json:"kubeconfig" validate:"required,base64"`
+}
+
+type DeploymentRequest struct {
+	Kubeconfig string `json:"kubeconfig" validate:"required,base64"`
+	Namespace  string `json:"namespace" validate:"required"`
+}
+
+type DeploymentDetailsRequest struct {
+	Kubeconfig string `json:"kubeconfig" validate:"required,base64"`
+	Namespace  string `json:"namespace" validate:"required"`
+	Deployment string `json:"deployment" validate:"required"`
+}
+type NamespaceInfo struct {
+	Name         string            `json:"name"`
+	Status       string            `json:"status"`
+	CreationTime interface{}       `json:"creationTime"`
+	Labels       map[string]string `json:"labels"`
+	Annotations  map[string]string `json:"annotations"`
+}
+
+type DeploymentInfo struct {
+	Name              string            `json:"name"`
+	Namespace         string            `json:"namespace"`
+	Replicas          int32             `json:"replicas"`
+	ReadyReplicas     int32             `json:"readyReplicas"`
+	AvailableReplicas int32             `json:"availableReplicas"`
+	CreationTime      interface{}       `json:"creationTime"`
+	Labels            map[string]string `json:"labels"`
+	Annotations       map[string]string `json:"annotations"`
+}
+
+type PodInfo struct {
+	Name              string                `json:"name"`
+	Status            string                `json:"status"`
+	CreationTime      interface{}           `json:"creationTime"`
+	Node              string                `json:"node"`
+	ContainerStatuses []ContainerStatusInfo `json:"containerStatuses"`
+}
+
+type ContainerStatusInfo struct {
+	Name    string `json:"name"`
+	Ready   bool   `json:"ready"`
+	Started *bool  `json:"started"`
+	Image   string `json:"image"`
+}
+
+type ReplicaSetInfo struct {
+	Name           string      `json:"name"`
+	Replicas       int32       `json:"replicas"`
+	ReadyReplicas  int32       `json:"readyReplicas"`
+	CreationTime   interface{} `json:"creationTime"`
+	OwnerReference interface{} `json:"ownerReference"`
+}
+
+type ContainerInfo struct {
+	Name    string              `json:"name"`
+	Image   string              `json:"image"`
+	Ports   []ContainerPortInfo `json:"ports"`
+	Env     []ContainerEnvInfo  `json:"env"`
+	Command []string            `json:"command"`
+	Args    []string            `json:"args"`
+}
+
+type ContainerPortInfo struct {
+	ContainerPort int32  `json:"containerPort"`
+	Protocol      string `json:"protocol"`
+	Name          string `json:"name"`
+}
+
+type ContainerEnvInfo struct {
+	Name  string `json:"name"`
+	Value string `json:"value"`
+}
+
+type DeploymentDetails struct {
+	Metadata    interface{}      `json:"metadata"`
+	Spec        interface{}      `json:"spec"`
+	Status      interface{}      `json:"status"`
+	Pods        []PodInfo        `json:"pods"`
+	ReplicaSets []ReplicaSetInfo `json:"replicaSets"`
+}

app/routes/index.go

@@ -55,4 +55,10 @@ func Install(app *fiber.App) {
 	app.Post("/cronjobs", handlers.CreateCronJob)
 	app.Get("/cronjobs", handlers.IndexCronJobs)
 	app.Delete("/cronjobs/:id", handlers.DeleteCronJob)
+
+	// kubernetes
+	kubernetesGroup := app.Group("/kubernetes")
+	kubernetesGroup.Post("/namespaces", handlers.GetNamespaces)
+	kubernetesGroup.Post("/deployments", handlers.GetDeployments)
+	kubernetesGroup.Post("/deploymentDetails", handlers.GetDeploymentDetails)
 }

go.mod

@@ -1,13 +1,14 @@
 module github.com/limanmys/render-engine
 
-go 1.23.0
+go 1.24.0
 
-toolchain go1.24.2
+toolchain go1.24.3
 
 require (
 	al.essio.dev/pkg/shellescape v1.6.0
 	github.com/Nerzal/gocloak/v13 v13.9.0
 	github.com/go-co-op/gocron v1.37.0
+	github.com/go-playground/validator/v10 v10.26.0
 	github.com/go-resty/resty/v2 v2.16.5
 	github.com/gofiber/fiber/v2 v2.52.6
 	github.com/gofiber/helmet/v2 v2.2.26
@@ -17,17 +18,31 @@ require (
 	go.uber.org/zap v1.27.0
 	gorm.io/driver/postgres v1.5.11
 	gorm.io/gorm v1.25.12
+	k8s.io/apimachinery v0.33.1
+	k8s.io/client-go v0.33.1
 )
 
 require (
 	github.com/Azure/go-ntlmssp v0.0.0-20221128193559-754e69321358 // indirect
 	github.com/ChrisTrenkamp/goxpath v0.0.0-20210404020558-97928f7e12b6 // indirect
 	github.com/bodgit/ntlmssp v0.0.0-20240506230425-31973bb52d9b // indirect
 	github.com/bodgit/windows v1.0.1 // indirect
+	github.com/davecgh/go-spew v1.1.1 // indirect
+	github.com/emicklei/go-restful/v3 v3.11.0 // indirect
+	github.com/fxamacker/cbor/v2 v2.7.0 // indirect
+	github.com/gabriel-vasile/mimetype v1.4.8 // indirect
 	github.com/geoffgarside/ber v1.1.0 // indirect
 	github.com/go-logr/logr v1.4.2 // indirect
+	github.com/go-openapi/jsonpointer v0.21.0 // indirect
+	github.com/go-openapi/jsonreference v0.20.2 // indirect
+	github.com/go-openapi/swag v0.23.0 // indirect
+	github.com/go-playground/locales v0.14.1 // indirect
+	github.com/go-playground/universal-translator v0.18.1 // indirect
 	github.com/gofrs/uuid v4.4.0+incompatible // indirect
+	github.com/gogo/protobuf v1.3.2 // indirect
 	github.com/golang-jwt/jwt/v5 v5.2.2 // indirect
+	github.com/google/gnostic-models v0.6.9 // indirect
+	github.com/google/go-cmp v0.7.0 // indirect
 	github.com/hashicorp/go-cleanhttp v0.5.2 // indirect
 	github.com/hashicorp/go-uuid v1.0.3 // indirect
 	github.com/jackc/pgx/v5 v5.7.4 // indirect
@@ -38,21 +53,45 @@ require (
 	github.com/jcmturner/goidentity/v6 v6.0.1 // indirect
 	github.com/jcmturner/gokrb5/v8 v8.4.4 // indirect
 	github.com/jcmturner/rpc/v2 v2.0.3 // indirect
+	github.com/josharian/intern v1.0.0 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/kr/fs v0.1.0 // indirect
+	github.com/leodido/go-urn v1.4.0 // indirect
+	github.com/mailru/easyjson v0.7.7 // indirect
 	github.com/masterzen/simplexml v0.0.0-20190410153822-31eea3082786 // indirect
 	github.com/mattn/go-colorable v0.1.14 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
 	github.com/mattn/go-runewidth v0.0.16 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
 	github.com/opentracing/opentracing-go v1.2.0 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/rivo/uniseg v0.4.7 // indirect
 	github.com/robfig/cron/v3 v3.0.1 // indirect
 	github.com/segmentio/ksuid v1.0.4 // indirect
+	github.com/spf13/pflag v1.0.5 // indirect
 	github.com/tidwall/transform v0.0.0-20201103190739-32f242e2dbde // indirect
+	github.com/x448/float16 v0.8.4 // indirect
 	go.uber.org/atomic v1.11.0 // indirect
 	go.uber.org/multierr v1.11.0 // indirect
 	golang.org/x/net v0.39.0 // indirect
+	golang.org/x/oauth2 v0.27.0 // indirect
 	golang.org/x/sync v0.13.0 // indirect
+	golang.org/x/term v0.31.0 // indirect
+	golang.org/x/time v0.9.0 // indirect
+	google.golang.org/protobuf v1.36.5 // indirect
+	gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
+	gopkg.in/inf.v0 v0.9.1 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+	k8s.io/api v0.33.1 // indirect
+	k8s.io/klog/v2 v2.130.1 // indirect
+	k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff // indirect
+	k8s.io/utils v0.0.0-20241104100929-3ea5e8cea738 // indirect
+	sigs.k8s.io/json v0.0.0-20241010143419-9aa6b5e7a4b3 // indirect
+	sigs.k8s.io/randfill v1.0.0 // indirect
+	sigs.k8s.io/structured-merge-diff/v4 v4.6.0 // indirect
+	sigs.k8s.io/yaml v1.4.0 // indirect
 )
 
 require (