- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for podWorker (0.15 sec)
-
pkg/kubelet/kubelet.go
// tracked by the podWorkers. Components that need to know the actual consumed resources of the // node or are driven by podWorkers and the sync*Pod methods (status, volume, stats) should also // consult the podWorkers when reconciling. // // TODO: review all kubelet components that need the actual set of pods (vs the desired set)
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/kubelet/pod_workers_test.go
if tc.runtimeStatus != nil { podWorkers.runtime.PodStatus = *tc.runtimeStatus podWorkers.runtime.Err = nil } else { podWorkers.runtime.PodStatus = kubecontainer.PodStatus{} podWorkers.runtime.Err = status.Error(codes.NotFound, "No such pod") } fns = append(fns, func() { podWorkers.runtime.PodStatus = kubecontainer.PodStatus{} podWorkers.runtime.Err = nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// containers), terminated (clean up and write status). WorkType PodWorkerState // Options contains the data to sync. Options UpdatePodOptions } // PodWorkers is an abstract interface for testability. type PodWorkers interface { // UpdatePod notifies the pod worker of a change to a pod, which will then // be processed in FIFO order by a goroutine per pod UID. The state of the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
dswp.findAndRemoveDeletedPods() if dswp.pods.processedPods[podName] { t.Fatalf("Failed to remove pods from desired state of world since they no longer exist") } // podWorker may call volume_manager WaitForUnmount() after we processed the pod in findAndRemoveDeletedPods() dswp.ReprocessPod(podName) dswp.findAndRemoveDeletedPods()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
// being created. If the pod has been deleted then it's // not a real error. // // SyncPod can still be running when we get here, which // means the PodWorker has not acked the deletion. if m.podStateProvider.IsPodTerminationRequested(pod.UID) { klog.V(4).InfoS("Pod was deleted and sandbox failed to be created", "pod", klog.KObj(pod), "podUID", pod.UID) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 02:01:31 UTC 2024 - 64.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
testKubelet := newTestKubelet(t, false) defer testKubelet.Cleanup() kl := testKubelet.kubelet podWorkers, _, processed := createPodWorkers() kl.podWorkers = podWorkers originalPodSyncer := podWorkers.podSyncer syncFuncs := newPodSyncerFuncs(originalPodSyncer) podWorkers.podSyncer = &syncFuncs if tt.terminatingErr != nil {
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/runonce_test.go
statusManager: status.NewManager(nil, podManager, &statustest.FakePodDeletionSafetyProvider{}, podStartupLatencyTracker, basePath), mirrorPodClient: podtest.NewFakeMirrorClient(), podManager: podManager, podWorkers: &fakePodWorkers{}, os: &containertest.FakeOS{}, containerRuntime: fakeRuntime, reasonCache: NewReasonCache(), clock: clock.RealClock{}, kubeClient: &fake.Clientset{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
if expect, actual := []types.UID(nil), kubelet.podWorkers.(*fakePodWorkers).triggeredDeletion; !reflect.DeepEqual(expect, actual) { t.Fatalf("expected %v kills, got %v", expect, actual) } ready = true kubelet.HandlePodRemoves(pods) time.Sleep(2 * time.Second) // Sources are ready. Remove unwanted pods.
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/kubelet/kubelet_pods.go
// if a pod is fully terminated by UID, it should be excluded from the // list of pods if kl.podWorkers.IsPodKnownTerminated(p.UID) { continue } // terminal pods are considered inactive UNLESS they are actively terminating if kl.isAdmittedPodTerminal(p) && !kl.podWorkers.IsPodTerminationRequested(p.UID) { continue } filteredPods = append(filteredPods, p) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)