- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 94 for updatePod (0.2 sec)
-
pkg/kubelet/kubelet_pods_test.go
Containers: []v1.Container{ {Name: "container-1"}, }, }, } w.UpdatePod(UpdatePodOptions{ UpdateType: kubetypes.SyncPodKill, StartTime: time.Unix(3, 0).UTC(), Pod: updatedPod, }) drainAllWorkers(w) r, ok := records[updatedPod.UID] if !ok || len(r) != 2 || r[1].gracePeriod == nil || *r[1].gracePeriod != 2 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
} kl.podManager.UpdatePod(updatedPod) kl.statusManager.SetPodStatus(updatedPod, updatedPod.Status) return updatedPod } // LatestLoopEntryTime returns the last time in the sync loop monitor. func (kl *Kubelet) LatestLoopEntryTime() time.Time { val := kl.syncLoopMonitor.Load() if val == nil { return time.Time{} } return val.(time.Time) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
} if updated == nil { t.Fatalf("Failed to get updated status") } if got, want := updated.Status.DesiredNumberScheduled, int32(podControl.FakePodControl.CreateLimit)*10; got != want { t.Errorf("Status.DesiredNumberScheduled = %v, want %v", got, want) } if got, want := updated.Status.CurrentNumberScheduled, int32(podControl.FakePodControl.CreateLimit); got != want {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
pod2 := newPod("pod2", job2) informer.Core().V1().Pods().Informer().GetIndexer().Add(pod1) informer.Core().V1().Pods().Informer().GetIndexer().Add(pod2) prev := *pod1 bumpResourceVersion(pod1) jm.updatePod(logger, &prev, pod1) verifyEmptyQueueAndAwaitForQueueLen(ctx, t, jm, 1) key, done := jm.queue.Get() if key == "" || done { t.Fatalf("failed to enqueue controller for pod %v", pod1.Name) }
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_pods.go
if pod == nil || wasMirror { klog.V(2).InfoS("Programmer error, restartable pod was a mirror pod but activePods should never contain a mirror pod", "podUID", desiredPod.UID) continue } kl.podWorkers.UpdatePod(UpdatePodOptions{ UpdateType: kubetypes.SyncPodCreate, Pod: pod, MirrorPod: mirrorPod, }) // the desired pod is now known as well
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
kubelet.handlePodResourcesResize(tt.pod) updatedPod, found := kubelet.podManager.GetPodByName(tt.pod.Namespace, tt.pod.Name) assert.True(t, found, "expected to find pod %s", tt.pod.Name) assert.Equal(t, tt.expectedAllocations, updatedPod.Status.ContainerStatuses[0].AllocatedResources, tt.name) assert.Equal(t, tt.expectedResize, updatedPod.Status.Resize, tt.name) testKubelet.fakeKubeClient.ClearActions() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
if err != nil { t.Fatalf("Error getting updated StatefulSet: %v", err) } *set.Spec.Replicas = 0 if err := scaleDownStatefulSetControl(set, ssc, om, invariants); err != nil { t.Errorf("Failed to scale StatefulSet : %s", err) } // Check updated set. set, err = om.setsLister.StatefulSets(set.Namespace).Get(set.Name) if err != nil { t.Fatalf("Error getting updated StatefulSet: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
pod := st.MakePod().Name("foo").NominatedNodeName(test.currentNominatedNodeName).Conditions(test.currentPodConditions).Obj() ctx, cancel := context.WithCancel(context.Background()) defer cancel() if err := updatePod(ctx, cs, pod, test.newPodCondition, test.newNominatingInfo); err != nil { t.Fatalf("Error calling update: %v", err) } if actualPatchRequests != test.expectedPatchRequests {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller_test.go
}, }, }, expectedPodStatusUpdate: false, }, // Node created long time ago, with status updated by kubelet exceeds grace period. Node lease is renewed. // Expect no action from node controller (within monitor grace period). { description: "Node created long time ago, with status updated by kubelet exceeds grace period. Node lease is renewed.", fakeNodeHandler: &testutil.FakeNodeHandler{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 03:26:45 UTC 2024 - 119K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
wantQ: activeQ, prepareFunc: func(t *testing.T, logger klog.Logger, q *PriorityQueue) (oldPod, newPod *v1.Pod) { updatedPod := medPriorityPodInfo.Pod.DeepCopy() updatedPod.Annotations["foo"] = "test" return medPriorityPodInfo.Pod, updatedPod }, schedulingHintsEnablement: []bool{false, true}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)