- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 365 for DELETING (0.13 sec)
-
tensorflow/c/experimental/filesystem/plugins/gcs/expiring_lru_cache_test.cc
int value = 0; EXPECT_TRUE(cache.Lookup("a", &value)); EXPECT_EQ(value, 1); // Delete the entry. EXPECT_TRUE(cache.Delete("a")); EXPECT_FALSE(cache.Lookup("a", &value)); // Try deleting the entry again. EXPECT_FALSE(cache.Delete("a")); EXPECT_FALSE(cache.Lookup("a", &value)); } } // namespace
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jul 09 19:31:22 UTC 2020 - 7.1K bytes - Viewed (0) -
pilot/pkg/xds/xdsgen.go
// Note: we do not need to account for unsubscribed resources as these are handled by parent removal; // See https://www.envoyproxy.io/docs/envoy/latest/api-docs/xds_protocol#deleting-resources. // This means if there are only removals, we will not respond. var logFiltered string if !req.Delta.IsEmpty() && !con.proxy.IsProxylessGrpc() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 6.3K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/expiring.go
// compares its generation with the current generation of the entry. It // deletes the entry iff the generation matches. This prevents cleanups // scheduled for earlier versions of an entry from deleting later versions of // an entry when Set() is called multiple times with the same key. // // The integer value of the generation of an entry is meaningless. generation uint64 heap expiringHeap }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 22 15:51:23 UTC 2023 - 5.6K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/gradle-properties/service_injection.adoc
5. <<workerexecutor,`WorkerExecutor`>> - Allows a task to run work in parallel. 6. <<filesystemoperations,`FileSystemOperations`>> - Allows a task to run operations on the filesystem such as deleting files, copying files or syncing directories. 7. <<archiveoperations,`ArchiveOperations`>> - Allows a task to run operations on archive files such as ZIP or TAR files.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 24 04:19:09 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager_test.go
t.Fatalf("Bad bundle; diff (-got +want)\n%s", diff) } }) if err := kc.CertificatesV1alpha1().ClusterTrustBundles().Delete(ctx, ctb1.ObjectMeta.Name, metav1.DeleteOptions{}); err != nil { t.Fatalf("Error while deleting the old CTB: %v", err) } if _, err := kc.CertificatesV1alpha1().ClusterTrustBundles().Create(ctx, ctb2, metav1.CreateOptions{}); err != nil { t.Fatalf("Error while adding new CTB: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 15.5K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
for reporter, w := range fractions { // check for stale data here if c.clock.Since(c.ObservationTime[reporter]) > c.StaleInterval { scope.Warnf("Status reporter %s has not been heard from since %v, deleting report.", reporter, c.ObservationTime[reporter]) staleReporters = append(staleReporters, reporter) } else { distributionState.PlusEquals(w) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go
} castObj, ok = tombstone.Obj.(*apiextensionsv1.CustomResourceDefinition) if !ok { klog.Errorf("Tombstone contained object that is not expected %#v", obj) return } } klog.V(4).Infof("Deleting customresourcedefinition %q", castObj.Name) c.enqueue(castObj) } func (c *Controller) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { c.queue.Add(obj.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.9K bytes - Viewed (0) -
tests/integration/operator/switch_cr_test.go
installWithCRFile(t, t, cs, istioCtl, "default", "v2") installWithCRFile(t, t, cs, istioCtl, "default", "") // istio control plane resources expected to be deleted after deleting CRs cleanupInClusterCRs(t, cs) // test operator remove command scopes.Framework.Infof("checking operator remove command for default revision") removeCmd := []string{ "operator", "remove",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/proxy/ipvs/graceful_termination_test.go
rs *utilipvs.RealServer existingIPVS *utilipvstest.FakeIPVS expectedIPVS *utilipvstest.FakeIPVS err error }{ { name: "graceful delete, no connections results in deleting the real server immediatetly", vs: &utilipvs.VirtualServer{ Address: netutils.ParseIPSloppy("1.1.1.1"), Protocol: "tcp", Port: uint16(80), }, rs: &utilipvs.RealServer{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Dec 19 01:20:51 UTC 2023 - 11K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
return func(ctx context.Context, fireAt time.Time, args *WorkArgs) error { ns := args.NamespacedName.Namespace name := args.NamespacedName.Name klog.FromContext(ctx).Info("Deleting pod", "controller", controllerName, "pod", args.NamespacedName) if emitEventFunc != nil { emitEventFunc(args.NamespacedName) } var err error for i := 0; i < retries; i++ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0)