- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for onServiceDelete (0.28 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)