- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for deleteService (0.17 sec)
-
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
c.endpointSliceTracker.DeleteService(namespace, name) return c.deleteMirroredSlices(namespace, name) } return err } if !c.shouldMirror(endpoints) { logger.V(4).Info("Endpoints should not be mirrored, cleaning up any mirrored EndpointSlices", "endpoints", klog.KRef(namespace, name)) c.endpointSliceTracker.DeleteService(namespace, name) return c.deleteMirroredSlices(namespace, name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
ic.opts.MeshServiceController.GetService(kube.ServiceHostname(name, ns, ic.opts.DomainSuffix)) == nil) { if prevMcsService != nil { // There are no vips in this cluster. Just delete the MCS service now. ic.deleteService(prevMcsService) } return nil } if prevMcsService != nil { event = model.EventUpdate } else { event = model.EventAdd }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
service, err := c.serviceLister.Services(namespace).Get(name) if err != nil { if !apierrors.IsNotFound(err) { return err } c.triggerTimeTracker.DeleteService(namespace, name) c.reconciler.DeleteService(namespace, name) c.endpointSliceTracker.DeleteService(namespace, name) // The service has been deleted, return nil so that it won't be retried. return nil }
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/proxy/servicechangetracker_test.go
svc.Spec.ClusterIP = "172.16.55.4" svc.Spec.Ports = addTestPort(svc.Spec.Ports, "p2", "UDP", 1235, 5321, 0) }) fp.updateService(services[0], oneService) fp.deleteService(services[1]) fp.deleteService(services[2]) fp.deleteService(services[3]) result = fp.svcPortMap.Update(fp.serviceChanges) if len(fp.svcPortMap) != 1 { t.Errorf("expected service map length 1, got %v", fp.svcPortMap) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
s.assertEvent(t, s.svcXdsName("svc1"), s.svcXdsName("waypoint-ns"), s.wleXdsName("name1"), s.wleXdsName("name2"), s.wleXdsName("name3")) s.deleteService(t, "waypoint-ns") s.assertEvent(t, s.podXdsName("waypoint-ns-pod"), s.svcXdsName("waypoint-ns")) s.deleteWorkloadEntry(t, "name3") s.assertEvent(t, s.wleXdsName("name3")) s.deleteWorkloadEntry(t, "name2")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
switch event { case model.EventDelete: c.deleteService(svcConv) default: c.addOrUpdateService(pre, curr, svcConv, event, false) } return nil } func (c *Controller) deleteService(svc *model.Service) { c.Lock() delete(c.servicesMap, svc.Hostname) delete(c.nodeSelectorsForServices, svc.Hostname)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
err = e.client.CoreV1().Endpoints(namespace).Delete(ctx, name, metav1.DeleteOptions{}) if err != nil && !errors.IsNotFound(err) { return err } e.triggerTimeTracker.DeleteService(namespace, name) return nil } if service.Spec.Type == v1.ServiceTypeExternalName { // services with Type ExternalName receive no endpoints from this controller; // Ref: https://issues.k8s.io/105986
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/winkernel/proxier_test.go
t.Errorf("Global refCount: %v does not match endpoint refCount: %v", *proxier.endPointsRefCount[endpointGuid1], *epInfo.refCount) } proxier.setInitialized(false) deleteServices(proxier, makeTestService(svcPortName2.Namespace, svcPortName2.Name, func(svc *v1.Service) { svc.Spec.Type = "NodePort" svc.Spec.ClusterIP = svcIP2 svc.Spec.Ports = []v1.ServicePort{{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
updatedSvcs = append(updatedSvcs, unchangedSvcs...) unchangedSvcs = nil } s.services.updateServices(key, cs) case model.EventDelete: deletedSvcs = cs s.services.deleteServices(key) case model.EventAdd: addedSvcs = cs s.services.updateServices(key, cs) default: // this should not happen unchangedSvcs = cs }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0)