- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 140 for oldpod (0.32 sec)
-
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
defer destroyFunc() // cached object has old UID oldPod, err := registry.Create(ctx, pod, rest.ValidateAllObjectFunc, &metav1.CreateOptions{}) if err != nil { t.Fatal(err) } registry.Storage.Storage = &staleGuaranteedUpdateStorage{Interface: registry.Storage.Storage, cachedObj: oldPod} // delete and re-create the same object with new UID
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pkg/apis/core/validation/validation_test.go
for _, oldTestCase := range testCases { newPod := testCase.pod.DeepCopy() newPod.ResourceVersion = "1" oldPod := oldTestCase.pod.DeepCopy() oldPod.ResourceVersion = "1" oldPod.Name = newPod.Name errs := ValidatePodStatusUpdate(newPod, oldPod, PodValidationOptions{}) if len(errs) == 0 && testCase.expectError {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 857.7K bytes - Viewed (0) -
pkg/kubelet/container/runtime_cache_test.go
} func TestForceUpdateIfOlder(t *testing.T) { ctx := context.Background() runtime := &ctest.FakeRuntime{} cache := NewTestRuntimeCache(runtime) // Cache old pods. oldpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}} runtime.PodList = oldpods cache.UpdateCacheWithLock() // Update the runtime to new pods. newpods := []*ctest.FakePod{{Pod: &Pod{ID: "1111"}}, {Pod: &Pod{ID: "2222"}}, {Pod: &Pod{ID: "3333"}}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 2.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
func (c *Controller) deletePod(obj interface{}) { pod := endpointsliceutil.GetPodFromDeleteAction(obj) if pod != nil { c.addPod(pod) } } func (c *Controller) addNode() { c.topologyQueue.Add(topologyQueueItemKey) } func (c *Controller) updateNode(old, cur interface{}) { oldNode := old.(*v1.Node) curNode := cur.(*v1.Node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/registry/batch/job/strategy.go
newJob := obj.(*batch.Job) oldJob := old.(*batch.Job) newJob.Spec = oldJob.Spec } func (jobStatusStrategy) ValidateUpdate(ctx context.Context, obj, old runtime.Object) field.ErrorList { newJob := obj.(*batch.Job) oldJob := old.(*batch.Job) opts := getStatusValidationOptions(newJob, oldJob) return batchvalidation.ValidateJobUpdateStatus(newJob, oldJob, opts) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 16:43:24 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/registry/core/node/strategy_test.go
old := tc.oldNode.DeepCopy() // old node should never be changed if !reflect.DeepEqual(tc.oldNode, old) { t.Errorf("%v: old node changed: %v", tc.name, cmp.Diff(tc.oldNode, old)) } if !reflect.DeepEqual(tc.node, tc.compareNode) { t.Errorf("%v: unexpected node spec: %v", tc.name, cmp.Diff(tc.node, tc.compareNode)) } }() } } func TestValidateUpdate(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 9.7K bytes - Viewed (0) -
pkg/kubelet/config/config.go
pods = make(map[types.UID]*v1.Pod) } // updatePodFunc is the local function which updates the pod cache *oldPods* with new pods *newPods*. // After updated, new pod will be stored in the pod cache *pods*. // Notice that *pods* and *oldPods* could be the same cache. updatePodsFunc := func(newPods []*v1.Pod, oldPods, pods map[types.UID]*v1.Pod) { filtered := filterInvalidPods(newPods, source, s.recorder) for _, ref := range filtered {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
dsw.AddNode(nodeName) generatedVolumeName1, pod1AddErr := dsw.AddPod(types.UniquePodName(pod1Name), controllervolumetesting.NewPod(pod1Name, pod1Name), volumeSpec, nodeName) if pod1AddErr != nil { t.Fatalf( "AddPod failed for pod %q. Expected: <no error> Actual: <%v>", pod1Name, pod1AddErr) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
newObj interface{} }{ { name: "pod updated with the same UID", oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"), newObj: withPodName(podWithPort("oldUID", nodeName, 8080), "pod"), }, { name: "pod updated with different UIDs", oldObj: withPodName(podWithPort("oldUID", nodeName, 80), "pod"), newObj: withPodName(podWithPort("newUID", nodeName, 8080), "pod"), }, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/volume/util/resize_util.go
Patch(context.TODO(), oldPVC.Name, types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{}, "status") if updateErr != nil { return oldPVC, fmt.Errorf("patchPVCStatus failed to patch PVC %q: %v", oldPVC.Name, updateErr) } return updatedClaim, nil } func createPVCPatch( oldPVC *v1.PersistentVolumeClaim, newPVC *v1.PersistentVolumeClaim, addResourceVersionCheck bool) ([]byte, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K bytes - Viewed (0)