fix: Delete functionality

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

Author: harisudarsan1

relay-server/server/relayServer.go

@@ -98,7 +98,7 @@ type LogService struct {
 	//
 }
 
-// IP to K8sResource MAp
+// IP to K8sResource Map
 var Ipcache sync.Map
 
 // HealthCheck Function
@@ -883,9 +883,9 @@ func startIPInformers(ctx context.Context, wg *sync.WaitGroup) {
 		switch strings.ToUpper(kind) {
 
 		case "POD":
-			resource = fmt.Sprintf("%s.%s.pod", name, namespace)
+			resource = fmt.Sprintf("pod/%s/%s", namespace, name)
 		case "SERVICE":
-			resource = fmt.Sprintf("%s.%s.svc", name, namespace)
+			resource = fmt.Sprintf("svc/%s/%s", namespace, name)
 		}
 
 		Ipcache.Store(ip, resource)
@@ -913,8 +913,8 @@ func startIPInformers(ctx context.Context, wg *sync.WaitGroup) {
 			if !ok {
 				return
 			}
+			Ipcache.Delete(pod.Status.PodIP)
 
-			updateIP("POD", pod.Namespace, pod.Name, "")
 		},
 	})
 
@@ -945,7 +945,7 @@ func startIPInformers(ctx context.Context, wg *sync.WaitGroup) {
 			if !ok {
 				return
 			}
-			updateIP("SERVICE", svc.Namespace, svc.Name, "")
+			Ipcache.Delete(svc.Spec.ClusterIP)
 		},
 	})