- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 111 for oldpod (4.21 sec)
-
pkg/controller/endpoint/endpoints_controller_test.go
t.Fatalf("Pod %q doesn't exist", update.podName) } oldPod := old.(*v1.Pod) newPod := oldPod.DeepCopy() newPod.Status.PodIP = update.podIP newPod.Status.PodIPs[0].IP = update.podIP newPod.ResourceVersion = strconv.Itoa(resourceVersion) resourceVersion++ endpoints.podStore.Update(newPod) endpoints.updatePod(oldPod, newPod) } time.Sleep(tc.finalDelay)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
func TestJobBackoff(t *testing.T) { _, ctx := ktesting.NewTestContext(t) logger := klog.FromContext(ctx) job := newJob(1, 1, 1, batch.NonIndexedCompletion) oldPod := newPod(fmt.Sprintf("pod-%v", rand.String(10)), job) oldPod.ResourceVersion = "1" newPod := oldPod.DeepCopy() newPod.ResourceVersion = "2" testCases := map[string]struct { requeues int oldPodPhase v1.PodPhase phase v1.PodPhase
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
kubelet.kubeClient = testKubelet.fakeKubeClient defer testKubelet.fakeKubeClient.ClearActions() kubelet.podManager.AddPod(testPod1) kubelet.podManager.AddPod(testPod2) kubelet.podManager.AddPod(testPod3) kubelet.podWorkers.(*fakePodWorkers).running = map[types.UID]bool{ testPod1.UID: true, testPod2.UID: true, testPod3.UID: true, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
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/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/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)