Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 759 for deleteSV (0.18 sec)

  1. pkg/controller/volume/persistentvolume/delete_test.go

    			expectedEvents:  noevents,
    			errors:          noerrors,
    			// Inject deleter into the controller and call syncVolume. The
    			// deleter simulates one delete() call that succeeds.
    			test: wrapTestWithReclaimCalls(operationDelete, []error{nil}, testSyncVolume),
    		},
    		{
    			// PV requires external deleter
    			name:            "8-10-1 - external deleter when volume is dynamic provisioning",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  2. pkg/controller/replicaset/replica_set.go

    	if curPod.DeletionTimestamp != nil {
    		// when a pod is deleted gracefully it's deletion timestamp is first modified to reflect a grace period,
    		// and after such time has passed, the kubelet actually deletes it from the store. We receive an update
    		// for modification of the deletion timestamp and expect an rs to create more replicas asap, not wait
    		// until the kubelet actually deletes the pod. This is different from the Phase of a pod changing, because
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  3. platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/caching/ArtifactCacheUnusedEntryCleanupIntegrationTest.groovy

            files[1].assertDoesNotExist()
    
            and: // deletes empty parent directories
            findFiles(cacheDir, 'resources-*/*').isEmpty()
            findFiles(cacheDir, 'files-*/*').isEmpty()
        }
    
        @ToBeFixedForConfigurationCache(because = "does not re-download missing artifacts")
        def "downloads deleted files again when they are referenced"() {
            given:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Mar 22 12:06:23 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. src/internal/concurrent/hashtriemap.go

    				i.mu.Unlock()
    				return
    			}
    			if n.isEntry {
    				// What we saw is still true, so we can continue with the delete.
    				break
    			}
    		}
    		// We have to start over.
    		i.mu.Unlock()
    	}
    	// Try to delete the entry.
    	e, deleted := n.entry().compareAndDelete(key, old, ht.keyEqual, ht.valEqual)
    	if !deleted {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 16:01:55 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  5. src/sync/map.go

    		if !ok && read.amended {
    			e, ok = m.dirty[key]
    			delete(m.dirty, key)
    			// Regardless of whether the entry was present, record a miss: this key
    			// will take the slow path until the dirty map is promoted to the read
    			// map.
    			m.missLocked()
    		}
    		m.mu.Unlock()
    	}
    	if ok {
    		return e.delete()
    	}
    	return nil, false
    }
    
    // Delete deletes the value for a key.
    func (m *Map) Delete(key any) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/pod.go

    			}
    		}
    	}
    	return pmap
    }
    
    // deleteIP returns true if the pod and ip are really deleted.
    func (pc *PodCache) deleteIP(ip string, podKey types.NamespacedName) bool {
    	pc.Lock()
    	defer pc.Unlock()
    	if pc.podsByIP[ip].Contains(podKey) {
    		sets.DeleteCleanupLast(pc.podsByIP, ip, podKey)
    		delete(pc.IPByPods, podKey)
    		return true
    	}
    	return false
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/lifecycle.go

    	DeleteRestoredAction
    	// DeleteRestoredVersionAction deletes a particular version that was temporarily restored
    	DeleteRestoredVersionAction
    	// DeleteAllVersionsAction deletes all versions when an object expires
    	DeleteAllVersionsAction
    	// DelMarkerDeleteAllVersionsAction deletes all versions when an object with delete marker as latest version expires
    	DelMarkerDeleteAllVersionsAction
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  8. platforms/core-runtime/files/src/main/java/org/gradle/internal/file/impl/DefaultDeleter.java

     * limitations under the License.
     */
    package org.gradle.internal.file.impl;
    
    import com.google.common.annotations.VisibleForTesting;
    import org.gradle.internal.file.Deleter;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import javax.annotation.Nullable;
    import java.io.File;
    import java.io.IOException;
    import java.nio.file.Files;
    import java.util.ArrayDeque;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Feb 15 17:10:06 UTC 2024
    - 12.9K bytes
    - Viewed (0)
  9. subprojects/core/src/main/java/org/gradle/api/internal/file/DefaultFileOperations.java

            }
            GFileUtils.mkdirs(dir);
            return dir;
        }
    
        @Override
        public boolean delete(Object... paths) {
            return delete(deleteSpec -> deleteSpec.delete(paths).setFollowSymlinks(false)).getDidWork();
        }
    
        @Override
        public WorkResult delete(Action<? super DeleteSpec> action) {
            DeleteSpecInternal deleteSpec = new DefaultDeleteSpec();
            action.execute(deleteSpec);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 26 15:15:04 UTC 2024
    - 14K bytes
    - Viewed (0)
  10. tests/integration/helm/upgrade/util.go

    	if err := h.DeleteChart(helmtest.BaseReleaseName, helmtest.IstioNamespace); err != nil {
    		return fmt.Errorf("failed to delete %s release", helmtest.BaseReleaseName)
    	}
    	if err := cs.Kube().CoreV1().Namespaces().Delete(context.TODO(), helmtest.IstioNamespace, metav1.DeleteOptions{}); err != nil {
    		return fmt.Errorf("failed to delete istio namespace: %v", err)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 19:04:51 UTC 2024
    - 14.4K bytes
    - Viewed (0)
Back to top