- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 3,431 for delete1 (0.12 sec)
-
pkg/kubelet/checkpointmanager/testing/util.go
defer mstore.Unlock() data, ok := mstore.mem[key] if !ok { return nil, fmt.Errorf("checkpoint is not found") } return data, nil } // Delete deletes data from the store func (mstore *MemStore) Delete(key string) error { mstore.Lock() defer mstore.Unlock() delete(mstore.mem, key) return nil } // List returns all the keys from the store func (mstore *MemStore) List() ([]string, error) { mstore.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 16 05:30:20 UTC 2018 - 1.7K bytes - Viewed (0) -
pkg/registry/flowcontrol/ensurer/strategy.go
err = objectOps.Delete(ctx, object.GetName(), metav1.DeleteOptions{ /* TODO: expectedResourceVersion */ }) if err == nil { klog.V(2).InfoS(fmt.Sprintf("Successfully deleted the unwanted %s", object.GetObjectKind().GroupVersionKind().Kind), "name", name) continue } if apierrors.IsNotFound(err) { klog.V(5).InfoS("Unwanted APF object was concurrently deleted", "name", name) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 14K bytes - Viewed (0) -
pkg/kubelet/util/store/store.go
Write(key string, data []byte) error // Read retrieves data with key // Read must return ErrKeyNotFound if key is not found. Read(key string) ([]byte, error) // Delete deletes data by key // Delete must not return error if key does not exist Delete(key string) error // List lists all existing keys. List() ([]string, error) } // ValidateKey returns an error if the given key does not meet the requirement
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 22:18:30 UTC 2017 - 1.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
return framework.QueueSkip, nil } // Pod is deleted. Return Queue when the deleted Pod has a label that matches with topologySpread's selector. if podLabelsMatchSpreadConstraints(constraints, originalPod.Labels) { logger.V(5).Info("a scheduled pod which matches with the pod's topology spread constraints was deleted, and the pod may be schedulable now", "pod", klog.KObj(pod), "deletedPod", klog.KObj(originalPod))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch_test.go
f.Modify(testType("bar")) f.Delete(testType("bar")) f.Error(testType("error: blah")) f.Stop() } go sender() consumer(f) } func TestRaceFreeFake(t *testing.T) { f := NewRaceFreeFake() table := []struct { t EventType s testType }{ {Added, testType("foo")}, {Modified, testType("qux")}, {Modified, testType("bar")}, {Deleted, testType("bar")},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 15 11:34:31 UTC 2018 - 3.7K bytes - Viewed (0) -
pkg/kube/watcher/configmapwatcher/configmapwatcher_test.go
steps := []struct { added *v1.ConfigMap updated *v1.ConfigMap deleted *v1.ConfigMap expectCalled bool expectCM *v1.ConfigMap }{ {added: cm2}, {added: cm, expectCalled: true, expectCM: cm}, {updated: cm}, {updated: cm1, expectCalled: true, expectCM: cm1}, {deleted: cm1, expectCalled: true}, {deleted: cm2}, } stop := make(chan struct{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 3.1K bytes - Viewed (0) -
platforms/jvm/language-groovy/src/main/java/org/gradle/api/internal/tasks/compile/incremental/recomp/GroovyRecompilationSpecProvider.java
import org.gradle.internal.file.Deleter; import org.gradle.work.FileChange; import java.util.Set; import java.util.stream.Collectors; public class GroovyRecompilationSpecProvider extends AbstractRecompilationSpecProvider { private static final Set<String> SUPPORTED_FILE_EXTENSIONS = ImmutableSet.of(".java", ".groovy"); public GroovyRecompilationSpecProvider( Deleter deleter,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/scheduler/util/assumecache/assume_cache.go
c.add(newObj) } func (c *AssumeCache) delete(obj interface{}) { if obj == nil { return } name, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj) if err != nil { c.logger.Error(&ObjectNameError{err}, "Failed to delete") return } c.rwMutex.Lock() defer c.rwMutex.Unlock() objInfo := &objInfo{name: name} err = c.store.Delete(objInfo) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 10.6K bytes - Viewed (0) -
tools/convert_RbacConfig_to_ClusterRbacConfig.sh
metadata: name: default ${SPEC} EOF # shellcheck disable=SC2181 if [ $? -ne 0 ] then echo "failed to apply ClusterRbacConfig" exit 1 fi echo "waiting for 15 seconds to delete RbacConfig" sleep 15
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Sep 14 20:15:07 UTC 2019 - 2K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
} } // DeleteBucket deletes monitoring the 'bucket' func (m *Monitor) DeleteBucket(bucket string) { m.tlock.Lock() for opts := range m.bucketsThrottle { if opts.Name == bucket { delete(m.bucketsThrottle, opts) } } m.tlock.Unlock() m.mlock.Lock() for opts := range m.bucketsMeasurement { if opts.Name == bucket { delete(m.bucketsMeasurement, opts) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0)