func()

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)
		}

	}

}