Refactor PostgresProxy to resolve backend address for PostgreSQL and remove outdated Kubernetes deployment files

Author: hasirciogluhq

cmd/proxy/internal/proxy/postgresql/proxy.go

@@ -76,7 +76,7 @@ func (p *PostgresProxy) HandleConnection(clientConn net.Conn) {
 	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
 	defer cancel()
 
-	backendAddr, err := p.Resolver.Resolve(ctx, metadata, core.DatabaseTypeMysql)
+	backendAddr, err := p.Resolver.Resolve(ctx, metadata, core.DatabaseTypePostgresql)
 	if err != nil {
 		logger.Error("Resolution failed", "error", err, "remote_addr", clientConn.RemoteAddr())
 		_ = p.sendErrorResponse(clientConn, &ErrorResponse{

…ernetes/examples/development/deploy.yaml …tes/examples/development/postgresql.yamlkubernetes/examples/development/deploy.yaml renamed to kubernetes/examples/development/postgresql.yaml kubernetes/examples/development/deploy.yaml renamed to kubernetes/examples/development/postgresql.yaml

@@ -0,0 +1,150 @@
+apiVersion: v1
+kind: Namespace
+metadata:
+  name: xdatabase-proxy
+---
+apiVersion: v1
+kind: ServiceAccount
+metadata:
+  name: xdatabase-proxy-sa
+  namespace: xdatabase-proxy
+---
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRole
+metadata:
+  name: xdatabase-proxy-role
+  namespace: xdatabase-proxy
+rules:
+  - apiGroups: [""]
+    resources: ["pods", "services", "endpoints", "secrets", "configmaps"]
+    verbs: ["get", "list", "watch", "create", "update", "patch", "delete"]
+  - apiGroups: [""]
+    resources: ["events"]
+    verbs: ["create", "patch"]
+  - apiGroups: [""]
+    resources: ["nodes"]
+    verbs: ["list", "watch"]
+  - apiGroups: ["apps"]
+    resources: ["deployments", "daemonsets", "statefulsets", "replicasets"]
+    verbs: ["get", "list", "watch"]
+  - apiGroups: ["networking.k8s.io"]
+    resources: ["ingresses"]
+    verbs: ["get", "list", "watch"]
+  - apiGroups: ["metrics.k8s.io"]
+    resources: ["pods", "nodes"]
+    verbs: ["get", "list", "watch"]
+---
+apiVersion: rbac.authorization.k8s.io/v1
+kind: ClusterRoleBinding
+metadata:
+  name: xdatabase-proxy-role-binding
+  namespace: xdatabase-proxy
+subjects:
+  - kind: ServiceAccount
+    name: xdatabase-proxy-sa
+    namespace: xdatabase-proxy
+roleRef:
+  kind: ClusterRole
+  name: xdatabase-proxy-role
+  apiGroup: rbac.authorization.k8s.io
+---
+apiVersion: apps/v1
+kind: DaemonSet
+metadata:
+  name: xdatabase-proxy
+  namespace: xdatabase-proxy
+spec:
+  selector:
+    matchLabels:
+      app: xdatabase-proxy
+  template:
+    metadata:
+      labels:
+        app: xdatabase-proxy
+    spec:
+      serviceAccountName: xdatabase-proxy-sa
+      tolerations:
+        - key: node-role.kubernetes.io/control-plane
+          operator: Exists
+          effect: NoSchedule
+        - key: node-role.kubernetes.io/master
+          operator: Exists
+          effect: NoSchedule
+      containers:
+        - name: xdatabase-proxy
+          image: xdatabase-proxy-local-test:local-test
+          imagePullPolicy: Never
+          ports:
+            - containerPort: 5432
+              hostPort: 5432
+              name: proxy-port
+          env:
+            - name: DATABASE_TYPE
+              value: "postgresql"
+            - name: RUNTIME
+              value: "kubernetes"
+            - name: NAMESPACE
+              valueFrom:
+                fieldRef:
+                  fieldPath: metadata.namespace
+            - name: DISCOVERY_MODE
+              value: "kubernetes"
+            - name: PROXY_START_PORT
+              value: "5432"
+            - name: HEALTH_SERVER_PORT
+              value: "8080"
+            - name: TLS_ENABLED
+              value: "true"
+            - name: TLS_MODE
+              value: "kubernetes"
+            - name: TLS_SECRET_NAME
+              value: "xdatabase-proxy-tls"
+            - name: TLS_AUTO_GENERATE
+              value: "true"
+            - name: TLS_AUTO_RENEW
+              value: "true"
+            - name: TLS_RENEWAL_THRESHOLD_DAYS
+              value: "30"
+            - name: DEBUG
+              value: "true"
+          resources:
+            requests:
+              cpu: 100m
+              memory: 128Mi
+            limits:
+              cpu: 1000m
+              memory: 1Gi
+          livenessProbe:
+            httpGet:
+              path: /health
+              port: 8080
+              scheme: HTTP
+            initialDelaySeconds: 15
+            periodSeconds: 20
+            timeoutSeconds: 5
+            failureThreshold: 3
+            successThreshold: 1
+          readinessProbe:
+            httpGet:
+              path: /ready
+              port: 8080
+              scheme: HTTP
+            initialDelaySeconds: 5
+            periodSeconds: 10
+            timeoutSeconds: 3
+            failureThreshold: 3
+            successThreshold: 1
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: xdatabase-proxy
+  namespace: xdatabase-proxy
+spec:
+  selector:
+    app: xdatabase-proxy
+  ports:
+    - port: 5432
+      targetPort: proxy-port
+      name: proxy-port
+  type: ClusterIP

kubernetes/examples/local-test/postgresql.yaml

@@ -0,0 +1,64 @@
+#!/bin/bash
+
+# Local build and deploy to Kubernetes cluster
+# This script builds the image locally and loads it directly to the cluster
+# without pulling from remote registry
+
+set -e
+
+IMAGE_TAG="xdatabase-proxy-local-test:local-test"
+
+echo "🏗️  Building xdatabase-proxy locally..."
+echo "Environment: local-test"
+echo "Image: $IMAGE_TAG"    
+
+# Build the Docker image locally
+docker build -t "$IMAGE_TAG" -f Dockerfile .
+
+echo "✅ Build complete!"
+
+# Detect Kubernetes cluster type and load image
+if kubectl config current-context | grep -q "minikube"; then
+    echo "📦 Loading image to Minikube..."
+    minikube image load "$IMAGE_TAG"
+    echo "✅ Image loaded to Minikube"
+elif kubectl config current-context | grep -q "kind"; then
+    echo "📦 Loading image to Kind..."
+    kind load docker-image "$IMAGE_TAG" --name general
+    echo "✅ Image loaded to Kind"
+elif kubectl config current-context | grep -q "k3d"; then
+    echo "📦 Loading image to k3d..."
+    k3d image import "$IMAGE_TAG"
+    echo "✅ Image loaded to k3d"
+elif kubectl config current-context | grep -q "docker-desktop"; then
+    echo "📦 Docker Desktop detected - image is already available in local registry"
+    echo "✅ Image available locally"
+else
+    echo "⚠️  Unknown cluster type: $(kubectl config current-context)"
+    echo "Assuming local Docker registry is shared with cluster..."
+    echo "✅ Image should be available locally"
+fi
+
+# Apply Kubernetes manifests
+echo "🚀 Deploying to Kubernetes..."
+kubectl apply -f "kubernetes/examples/local-test/postgresql.yaml"
+
+# Wait a moment for the deployment to register
+sleep 2
+
+# Restart the DaemonSet to use the new image
+echo "🔄 Restarting xdatabase-proxy DaemonSet..."
+kubectl rollout restart daemonset/xdatabase-proxy -n xdatabase-proxy
+
+# Wait for rollout to complete
+echo "⏳ Waiting for rollout to complete..."
+kubectl rollout status daemonset/xdatabase-proxy -n xdatabase-proxy --timeout=120s
+
+echo "✅ Deployment complete!"
+echo ""
+echo "📊 Pod status:"
+kubectl get pods -n xdatabase-proxy -l app=xdatabase-proxy
+
+echo ""
+echo "📝 To view logs:"
+echo "kubectl logs -f -n xdatabase-proxy -l app=xdatabase-proxy"