func (c *ProxyController) HandleEndpoints() {
	eventType, endpoints, err := c.NextEndpoints()
	if err != nil {
		utilruntime.HandleError(fmt.Errorf("unable to handle endpoints: %v", err))
		return
	}

	c.lock.Lock()
	defer c.lock.Unlock()

	// Change the local sync state within the lock to ensure that all
	// event handlers have the same view of the sync state.
	c.endpointsListConsumed = c.EndpointsListConsumed()
	c.updateLastSyncProcessed()

	if err := c.Proxier.HandleEndpoints(eventType, endpoints); err != nil {
		utilruntime.HandleError(err)
	}
}
// HandleEndpoints handles a single Endpoints event and refreshes the proxy backend.
HandleEndpoints handles a single Endpoints event and refreshes the proxy backend.
// HandleEndpoints handles a single Endpoints event and refreshes the proxy backend .
func (c *ProxyController) HandleEndpoints() {
	eventType, endpoints, err := c.NextEndpoints()
	if err != nil {
		utilruntime.HandleError(fmt.Errorf("unable to handle endpoints: %v", err))
		return
	}
	c.lock.Lock()
	defer c.lock.Unlock()
	c.endpointsListConsumed = c.EndpointsListConsumed()
	c.updateLastSyncProcessed()
	if err := c.Proxier.HandleEndpoints(eventType, endpoints); err != nil {
		utilruntime.HandleError(err)
	}
}
func ( c * ProxyController ) HandleEndpoints ( ) { eventType , endpoints , err := c . NextEndpoints ( ) if err != nil { utilruntime . HandleError ( fmt . Errorf ( " " , err ) ) return } c . lock . Lock ( ) defer c . lock . Unlock ( ) c . endpointsListConsumed = c . EndpointsListConsumed ( ) c . updateLastSyncProcessed ( ) if err := c . Proxier . HandleEndpoints ( eventType , endpoints ) ; err != nil { utilruntime . HandleError ( err ) } }
HandleEndpoints handles a single Endpoints event and refreshes the proxy backend.
HandleEndpoints handles a single Endpoints event and refreshes the proxy backend .
// Change the local sync state within the lock to ensure that all // event handlers have the same view of the sync state.