- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for deleteDevice (0.32 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/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) -
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) -
tensorflow/c/eager/c_api_experimental.h
void (*execute)(const TFE_Op* op, int* num_outputs, TFE_TensorHandle** outputs, TF_Status* s, void* device_info); // Method to delete a device. void (*delete_device)(void* device_info); // Implements TFE_CreatePackedTensorHandle when one of `handles` is on this // custom device. // // Many devices will want to simply return an "unimplemented" status
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 22:37:46 UTC 2024 - 39.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
s.deleteWaypoint(t, "waypoint-ns") s.assertEvent(t, s.podXdsName("pod1")) s.deleteService(t, "waypoint-ns") s.assertEvent(t, s.podXdsName("waypoint-ns-pod"), s.svcXdsName("waypoint-ns")) s.deleteWaypoint(t, "waypoint-sa2") s.assertEvent(t, s.podXdsName("pod4")) s.deleteService(t, "waypoint-sa2") s.assertEvent(t, s.podXdsName("waypoint-sa2-pod"), s.svcXdsName("waypoint-sa2"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K 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) -
tensorflow/c/eager/c_api.cc
CustomDeviceAPI(TFE_Context* context, TFE_CustomDevice device, void* info, string name) : context_(context), device_(device), info_(info), name_(name) {} ~CustomDeviceAPI() override { device_.delete_device(info_); } const string& name() override { return name_; } tensorflow::Status CopyTensorToDevice( ImmediateExecutionTensorHandle* handle, ImmediateExecutionTensorHandle** result) override {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 09 08:11:23 UTC 2024 - 44K bytes - Viewed (0)