Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for DELETING (0.19 sec)

  1. pkg/proxy/winkernel/proxier.go

    		klog.V(1).ErrorS(err, "Error deleting Hns loadbalancer policy resource.", "hnsID", svcInfo.hnsID, "ClusterIP", svcInfo.ClusterIP())
    	} else {
    		// On successful delete, remove hnsId
    		svcInfo.hnsID = ""
    	}
    
    	if err := hns.deleteLoadBalancer(svcInfo.nodePorthnsID); err != nil {
    		mapStaleLoadbalancer[svcInfo.nodePorthnsID] = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  2. pkg/controller/daemon/daemon_controller.go

    	eventRecorder    record.EventRecorder
    
    	podControl controller.PodControlInterface
    	crControl  controller.ControllerRevisionControlInterface
    
    	// An dsc is temporarily suspended after creating/deleting these many replicas.
    	// It resumes normal action after observing the watch events for them.
    	burstReplicas int
    
    	// To allow injection of syncDaemonSet for testing.
    	syncHandler func(ctx context.Context, dsKey string) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  3. cmd/test-utils_test.go

    	return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{})
    }
    
    // return URL for deleting the object from the bucket.
    func getDeleteObjectURL(endPoint, bucketName, objectName string) string {
    	return makeTestTargetURL(endPoint, bucketName, objectName, url.Values{})
    }
    
    // return URL for deleting multiple objects from a bucket.
    func getMultiDeleteObjectURL(endPoint, bucketName string) string {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    	}
    
    	err = firstDisk.Delete(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    		t.Errorf("Failure during deleting part.1 - %v", err)
    	}
    
    	err = firstDisk.WriteAll(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    		t.Errorf("Failure during creating part.1 - %v", err)
    	}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    	// delete if the existing object has no grace period or a grace period of 0
    	return oldMeta.GetDeletionGracePeriodSeconds() == nil || *oldMeta.GetDeletionGracePeriodSeconds() == 0
    }
    
    // deleteWithoutFinalizers handles deleting an object ignoring its finalizer list.
    // Used for objects that are either been finalized or have never initialized.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/pv_controller.go

    				// Save failed, retry on the next deletion attempt
    				return pluginName, err
    			}
    		}
    
    		// Despite the volume being Failed, the controller will retry deleting
    		// the volume in every syncVolume() call.
    		return pluginName, err
    	}
    	if !deleted {
    		// The volume waits for deletion by an external plugin. Do nothing.
    		return pluginName, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  7. pkg/controller/replicaset/replica_set_test.go

    		logger.V(8).Info("Waiting for queue to have 1 item", "length", manager.queue.Len())
    		return manager.queue.Len() == 1, nil
    	})
    	if err != nil {
    		t.Fatalf("Deleting RS didn't result in new item in the queue: %v", err)
    	}
    
    	_, exists, err = manager.expectations.GetExpectations(oldRSKey)
    	if err != nil {
    		t.Fatal(err)
    	}
    	if exists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    	verifyGetByIP("3.3.3.3", nil)
    	verifyGetByIP("2.2.2.2", []*model.WorkloadInstance{wi3, wi1})
    
    	// simulate deleting a workload entry
    	ctl.workloadInstanceHandler(wi3, model.EventDelete)
    
    	verifyGetByIP("2.2.2.2", []*model.WorkloadInstance{wi1})
    
    	// simulate deleting a workload entry
    	ctl.workloadInstanceHandler(wi1, model.EventDelete)
    
    	verifyGetByIP("2.2.2.2", nil)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  9. tensorflow/c/c_api.h

    // to `g`. Once `func`/`grad` is added to `g`, it can be called by creating
    // an operation using the function's name.
    // Any changes to `func`/`grad` (including deleting it) done after this method
    // returns, won't affect the copy of `func`/`grad` in `g`.
    // If `func` or `grad` are already in `g`, TF_GraphCopyFunction has no
    // effect on them, but can establish the function->gradient relationship
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Oct 26 21:08:15 UTC 2023
    - 82.3K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    	} else {
    		err = Rename(filePath, targetPath)
    	}
    
    	var targetPath2 string
    	if immediatePurge && HasSuffix(filePath, SlashSeparator) {
    		// With immediate purge also attempt deleting for `__XL_DIR__` folder/directory objects.
    		targetPath2 = pathutil.Join(s.drivePath, minioMetaTmpDeletedBucket, mustGetUUID())
    		renameAll(encodeDirObject(filePath), targetPath2, pathutil.Join(s.drivePath, minioMetaBucket))
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
Back to top