Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for onServiceDelete (0.23 sec)

  1. pkg/proxy/metaproxier/meta_proxier.go

    	proxier.ipv6Proxier.OnServiceUpdate(oldService, service)
    }
    
    // OnServiceDelete is called whenever deletion of an existing service
    // object is observed.
    func (proxier *metaProxier) OnServiceDelete(service *v1.Service) {
    	proxier.ipv4Proxier.OnServiceDelete(service)
    	proxier.ipv6Proxier.OnServiceDelete(service)
    
    }
    
    // OnServiceSynced is called once all the initial event handlers were
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 21 14:28:37 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  2. pkg/proxy/config/config.go

    	// OnServiceUpdate is called whenever modification of an existing
    	// service object is observed.
    	OnServiceUpdate(oldService, service *v1.Service)
    	// OnServiceDelete is called whenever deletion of an existing service
    	// object is observed.
    	OnServiceDelete(service *v1.Service)
    	// OnServiceSynced is called once all the initial event handlers were
    	// called and the state is fully propagated to local cache.
    	OnServiceSynced()
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  3. pkg/proxy/kubemark/hollow_proxy.go

    	select {}
    }
    func (*FakeProxier) OnServiceAdd(service *v1.Service)                                 {}
    func (*FakeProxier) OnServiceUpdate(oldService, service *v1.Service)                  {}
    func (*FakeProxier) OnServiceDelete(service *v1.Service)                              {}
    func (*FakeProxier) OnServiceSynced()                                                 {}
    func (*FakeProxier) OnEndpointSliceAdd(slice *discoveryv1.EndpointSlice)              {}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go

    		c.queueEndpoints(obj)
    	}
    }
    
    // onServiceDelete queues a sync for the relevant Endpoints resource.
    func (c *Controller) onServiceDelete(obj interface{}) {
    	service := getServiceFromDeleteAction(obj)
    	if service == nil {
    		utilruntime.HandleError(fmt.Errorf("onServiceDelete() expected type v1.Service, got %T", obj))
    		return
    	}
    	if service.Spec.Selector == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. pkg/controller/endpointslice/endpointslice_controller.go

    		utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err))
    		return
    	}
    
    	c.serviceQueue.Add(key)
    }
    
    // onServiceDelete removes the Service Selector from the cache and queues the Service for processing.
    func (c *Controller) onServiceDelete(obj interface{}) {
    	key, err := controller.KeyFunc(obj)
    	if err != nil {
    		utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  6. pkg/controller/endpoint/endpoints_controller.go

    	if err != nil {
    		utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err))
    		return
    	}
    	e.queue.Add(key)
    }
    
    // onServiceDelete removes the Service Selector from the cache and queues the Service for processing.
    func (e *Controller) onServiceDelete(obj interface{}) {
    	key, err := controller.KeyFunc(obj)
    	if err != nil {
    		utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  7. pkg/proxy/config/config_test.go

    	h.lock.Lock()
    	defer h.lock.Unlock()
    	namespacedName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name}
    	h.state[namespacedName] = service
    	h.sendServices()
    }
    
    func (h *ServiceHandlerMock) OnServiceDelete(service *v1.Service) {
    	h.lock.Lock()
    	defer h.lock.Unlock()
    	namespacedName := types.NamespacedName{Namespace: service.Namespace, Name: service.Name}
    	delete(h.state, namespacedName)
    	h.sendServices()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  8. pkg/proxy/winkernel/proxier.go

    	if proxier.serviceChanges.Update(oldService, service) && proxier.isInitialized() {
    		proxier.Sync()
    	}
    }
    
    // OnServiceDelete is called whenever deletion of an existing service
    // object is observed.
    func (proxier *Proxier) OnServiceDelete(service *v1.Service) {
    	proxier.OnServiceUpdate(service, nil)
    }
    
    // OnServiceSynced is called once all the initial event handlers were
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  9. pkg/proxy/nftables/proxier.go

    	if proxier.serviceChanges.Update(oldService, service) && proxier.isInitialized() {
    		proxier.Sync()
    	}
    }
    
    // OnServiceDelete is called whenever deletion of an existing service
    // object is observed.
    func (proxier *Proxier) OnServiceDelete(service *v1.Service) {
    	proxier.OnServiceUpdate(service, nil)
    
    }
    
    // OnServiceSynced is called once all the initial event handlers were
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  10. pkg/proxy/winkernel/proxier_test.go

    	}
    
    	proxier.mu.Lock()
    	defer proxier.mu.Unlock()
    	proxier.servicesSynced = true
    }
    func deleteServices(proxier *Proxier, allServices ...*v1.Service) {
    	for i := range allServices {
    		proxier.OnServiceDelete(allServices[i])
    	}
    
    	proxier.mu.Lock()
    	defer proxier.mu.Unlock()
    	proxier.servicesSynced = true
    }
    
    func makeTestService(namespace, name string, svcFunc func(*v1.Service)) *v1.Service {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 28 14:30:51 UTC 2024
    - 30.2K bytes
    - Viewed (0)
Back to top