in watcher/handlerEndpoint.go [113:136]
func (e *EpHandler) delete(obj interface{}) {
eps, ok := obj.(*v1.Endpoints)
if !ok {
log.Println("In Endpoint DELETE; cannot cast to *v1.Endpoints.")
return
}
podSvcName := eps.GetObjectMeta().GetName()
namespace := eps.GetNamespace()
if !e.Ep.NsManager.IncludeNamespace(namespace) {
log.Println("Namespace not included")
return
}
for _, subset := range eps.Subsets {
for _, port := range subset.Ports {
portnum := fmt.Sprint(port.Port)
key := util.ConstructSvcPortString(namespace, podSvcName, portnum)
e.Ep.RedisClient.DefaultDBDel(key)
}
}
}