- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 138 for updatePod (0.15 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
// First update, so originalPod is outdated. updatedPod := &example.Pod{} if err := store.GuaranteedUpdate(ctx, key, updatedPod, false, nil, storage.SimpleUpdate(func(obj runtime.Object) (runtime.Object, error) { pod := obj.(*example.Pod) pod.ObjectMeta.Labels = map[string]string{"foo": "bar"} return pod, nil }), nil); err != nil { t.Errorf("Unexpected failure during updated: %v", err) } out := &example.Pod{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
updatedPod := createdPod.DeepCopy() updatedPod.Labels = map[string]string{"foo": "bar"} updatedPod.ResourceVersion = "2" errs = Strategy.ValidateUpdate(ctx, updatedPod, createdPod) if len(errs) != 0 { t.Errorf("Unexpected error: %v", errs.ToAggregate()) } Strategy.PrepareForUpdate(ctx, updatedPod, createdPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
) }) t.Run("update service entry host", func(t *testing.T) { updated := func() *config.Config { d := selector.DeepCopy() se := d.Spec.(*networking.ServiceEntry) se.Hosts = []string{"updated.com"} return &d }() instances := []*model.ServiceInstance{ makeInstanceWithServiceAccount(updated, "2.2.2.2", 444, updated.Spec.(*networking.ServiceEntry).Ports[0],
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
src/runtime/mgcpacer.go
// during this cycle. This is updated atomically, and must also // be updated atomically even during a STW, because it is read // by sysmon. Updates occur in bounded batches, since it is both // written and read throughout the cycle. assistTime atomic.Int64 // dedicatedMarkTime is the nanoseconds spent in dedicated mark workers // during this cycle. This is updated at the end of the concurrent mark // phase.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/resource_op_lifting.cc
if (info1_it == infos1.end()) continue; auto& info = result[entry.getFirst()]; info = entry.getSecond(); if (info.updated) continue; if (info1_it->getSecond().used) { info.used = true; info.updated = info1_it->getSecond().updated; info.data_type = info1_it->getSecond().data_type; } } return result; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 55.1K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_7.adoc
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Apr 01 15:00:23 UTC 2024 - 87.7K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_8.adoc
== Upgrading from 8.6 and earlier === Potential breaking changes ==== Upgrade to Kotlin 1.9.22 The embedded Kotlin has been updated from 1.9.10 to link:https://github.com/JetBrains/kotlin/releases/tag/v1.9.22[Kotlin 1.9.22]. ==== Upgrade to Apache SSHD 2.10.0 Apache SSHD has been updated from 2.0.0 to https://mina.apache.org/sshd-project/download_2.10.0.html[2.10.0]. ==== Replacement and upgrade of JSch
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 17:01:07 UTC 2024 - 90.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go
// clients are expecting an updated object if a PUT succeeded, // but finalizeDelete returns a metav1.Status, so return // the object in the request instead. return obj, false, err } return nil, false, storeerr.InterpretDeleteError(err, e.qualifiedResourceFromContext(ctx), name) } _, err := e.finalizeDelete(ctx, out, true, options) // clients are expecting an updated object if a PUT succeeded, but
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 23:22:44 UTC 2024 - 60.8K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
wg := sync.WaitGroup{} wg.Add(2) updated := atomic.Bool{} updated.Store(false) go func() { defer wg.Done() for i := 0; i < test.count; i++ { // simulate the device plugin to send device updates mimpl.genericDeviceUpdateCallback(testResourceName, devs) } updated.Store(true) }() go func() { defer wg.Done()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
} if loggerV := logger.V(5); loggerV.Enabled() { loggerV.Info("Node ReadyCondition updated. Updating timestamp", "node", klog.KObj(node), "nodeHealthStatus", nodeHealth.status, "nodeStatus", node.Status) } else { logger.V(3).Info("Node ReadyCondition updated. Updating timestamp", "node", klog.KObj(node)) } nodeHealth = &nodeHealthData{ status: &node.Status,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0)