Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for onEndpointsDelete (0.12 sec)

  1. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    		return
    	}
    	c.queueEndpoints(obj)
    }
    
    // onEndpointsDelete queues a sync for the relevant Endpoints resource.
    func (c *Controller) onEndpointsDelete(logger klog.Logger, obj interface{}) {
    	endpoints := getEndpointsFromDeleteAction(obj)
    	if endpoints == nil {
    		utilruntime.HandleError(fmt.Errorf("onEndpointsDelete() expected type v1.Endpoints, got %T", obj))
    		return
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  2. pkg/controller/endpoint/endpoints_controller.go

    	})
    	e.podLister = podInformer.Lister()
    	e.podsSynced = podInformer.Informer().HasSynced
    
    	endpointsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		DeleteFunc: e.onEndpointsDelete,
    	})
    	e.endpointsLister = endpointsInformer.Lister()
    	e.endpointsSynced = endpointsInformer.Informer().HasSynced
    
    	e.triggerTimeTracker = endpointsliceutil.NewTriggerTimeTracker()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  3. pkg/proxy/config/config.go

    			utilruntime.HandleError(fmt.Errorf("unexpected object type: %T", obj))
    			return
    		}
    	}
    	for _, h := range c.eventHandlers {
    		c.logger.V(4).Info("Calling handler.OnEndpointsDelete")
    		h.OnEndpointSliceDelete(endpointSlice)
    	}
    }
    
    // ServiceConfig tracks a set of service configurations.
    type ServiceConfig struct {
    	listerSynced  cache.InformerSynced
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  4. pkg/controller/endpoint/endpoints_controller_test.go

    		}
    
    		if req.Method == "DELETE" {
    			go func() {
    				// Delay the deletion of endoints to make endpoint cache out of sync
    				<-blockDelete
    				controller.endpointsStore.Delete(endpoint)
    				controller.onEndpointsDelete(endpoint)
    			}()
    			blockNextAction <- struct{}{}
    		}
    
    		res.WriteHeader(http.StatusOK)
    		res.Write([]byte(runtime.EncodeOrDie(clientscheme.Codecs.LegacyCodec(v1.SchemeGroupVersion), &v1.Endpoints{})))
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 87.7K bytes
    - Viewed (0)
Back to top