- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 68 for DELETING (0.19 sec)
-
pkg/controller/servicecidrs/servicecidrs_controller.go
if err != nil { if apierrors.IsNotFound(err) { logger.V(4).Info("ServiceCIDR no longer exist", "ServiceCIDR", key) return nil } return err } // Deleting .... if !cidr.GetDeletionTimestamp().IsZero() { // check if the existing ServiceCIDR can be deleted before removing the finalizer ok, err := c.canDeleteCIDR(ctx, cidr) if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18K bytes - Viewed (0) -
pkg/volume/fc/fc.go
err := c.manager.DetachBlockFCDisk(*c, mapPath, devicePath) if err != nil { return fmt.Errorf("fc: failed to detach disk: %s\nError: %v", mapPath, err) } klog.V(4).Infof("fc: %s is unmounted, deleting the directory", mapPath) if err = os.RemoveAll(mapPath); err != nil { return fmt.Errorf("fc: failed to delete the directory: %s\nError: %v", mapPath, err) } klog.V(4).Infof("fc: successfully detached disk: %s", mapPath)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller.go
logger.V(5).Info("deleting unused generated claim", "claim", klog.KObj(claim), "pod", klog.KObj(pod)) err := ec.kubeClient.ResourceV1alpha2().ResourceClaims(claim.Namespace).Delete(ctx, claim.Name, metav1.DeleteOptions{}) if err != nil { return fmt.Errorf("delete claim: %v", err) } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 09 03:34:25 UTC 2024 - 37.1K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
if deleted { if !finalizers.Contains(finalizer) { scope.Infof("IstioOperator %s deleted", iopName) metrics.CRDeletionTotal.Increment() return reconcile.Result{}, nil } scope.Infof("Deleting IstioOperator %s", iopName) reconciler, err := helmreconciler.NewHelmReconciler(r.client, r.kubeClient, iopMerged, nil) if err != nil { return reconcile.Result{}, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
src/slices/slices.go
// Delete panics if j > len(s) or s[i:j] is not a valid slice of s. // Delete is O(len(s)-i), so if many items must be deleted, it is better to // make a single call deleting them all together than to delete one at a time. // Delete zeroes the elements s[len(s)-(j-i):len(s)]. func Delete[S ~[]E, E any](s S, i, j int) S { _ = s[i:j:len(s)] // bounds check if i == j { return s
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 29 14:01:59 UTC 2024 - 13.6K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
return } rq.addQuota(logger, curResourceQuota) }, // This will enter the sync loop and no-op, because the controller has been deleted from the store. // Note that deleting a controller immediately after scaling it to 0 will not work. The recommended // way of achieving this is by performing a `stop` operation on the controller. DeleteFunc: func(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
pkg/volume/iscsi/iscsi.go
err := c.manager.DetachBlockISCSIDisk(*c, mapPath) if err != nil { return fmt.Errorf("iscsi: failed to detach disk: %s\nError: %v", mapPath, err) } klog.V(4).Infof("iscsi: %q is unmounted, deleting the directory", mapPath) err = os.RemoveAll(mapPath) if err != nil { return fmt.Errorf("iscsi: failed to delete the directory: %s\nError: %v", mapPath, err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 23.4K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
} d, ok = tombstone.Obj.(*apps.Deployment) if !ok { utilruntime.HandleError(fmt.Errorf("tombstone contained object that is not a Deployment %#v", obj)) return } } logger.V(4).Info("Deleting deployment", "deployment", klog.KObj(d)) dc.enqueueDeployment(d) } // addReplicaSet enqueues the deployment that manages a ReplicaSet when the ReplicaSet is created.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/deployment.go
if !d.shouldCreateWLE { return } wle := d.workloadEntryYAML(w) if err := d.ctx.ConfigKube(d.cfg.Cluster.Primary()).YAML(d.cfg.Namespace.Name(), wle).Delete(); err != nil { log.Warnf("failed deleting echo WLE for %s/%s from primary cluster: %v", d.cfg.Namespace.Name(), d.cfg.Service, err) } } func (d *deployment) workloadEntryYAML(w *workload) string { name := w.pod.Name
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 24.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/convert_control_to_data_outputs.cc
while_body_func_to_while_ops; // Get all the while body functions and the corresponding while ops first // because the symbol user map is invalidated once we start deleting while // ops. for (auto func : module.getOps<func::FuncOp>()) { if (func.isExternal()) continue; SmallVector<TF::WhileOp> while_callers = GetWhileCallers(func, symbol_map);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 28.7K bytes - Viewed (0)