func (c *ProxyController) HandleService() {
	eventType, service, err := c.NextService()
	if err != nil {
		utilruntime.HandleError(fmt.Errorf("unable to handle service: %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.serviceListConsumed = c.ServiceListConsumed()
	c.updateLastSyncProcessed()

	if err := c.Proxier.HandleService(eventType, service); err != nil {
		utilruntime.HandleError(err)
	}
}
// HandleServices handles a single Service event and refreshes the proxy backend.
HandleServices handles a single Service event and refreshes the proxy backend.
// HandleServices handles a single Service event and refreshes the proxy backend .
func (c *ProxyController) HandleService() {
	eventType, service, err := c.NextService()
	if err != nil {
		utilruntime.HandleError(fmt.Errorf("unable to handle service: %v", err))
		return
	}
	c.lock.Lock()
	defer c.lock.Unlock()
	c.serviceListConsumed = c.ServiceListConsumed()
	c.updateLastSyncProcessed()
	if err := c.Proxier.HandleService(eventType, service); err != nil {
		utilruntime.HandleError(err)
	}
}
func ( c * ProxyController ) HandleService ( ) { eventType , service , err := c . NextService ( ) if err != nil { utilruntime . HandleError ( fmt . Errorf ( " " , err ) ) return } c . lock . Lock ( ) defer c . lock . Unlock ( ) c . serviceListConsumed = c . ServiceListConsumed ( ) c . updateLastSyncProcessed ( ) if err := c . Proxier . HandleService ( eventType , service ) ; err != nil { utilruntime . HandleError ( err ) } }
HandleServices handles a single Service event and refreshes the proxy backend.
HandleServices handles a single Service 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.