- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for runningPod (0.22 sec)
-
pkg/kubelet/pod_workers_test.go
return nil }, syncTerminatingRuntimePod: func(ctx context.Context, runningPod *kubecontainer.Pod) error { func() { lock.Lock() defer lock.Unlock() processed[runningPod.ID] = append(processed[runningPod.ID], syncPodRecord{ name: runningPod.Name, updateType: kubetypes.SyncPodKill, runningPod: runningPod, }) }() return 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
var uid types.UID var name, ns string if runningPod := options.RunningPod; runningPod != nil { if options.Pod == nil { // the sythetic pod created here is used only as a placeholder and not tracked if options.UpdateType != kubetypes.SyncPodKill { klog.InfoS("Pod update is ignored, runtime pods can only be killed", "pod", klog.KRef(runningPod.Namespace, runningPod.Name), "podUID", runningPod.ID, "updateType", options.UpdateType) return
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/kuberuntime/kuberuntime_container.go
killContainerResult.Fail(kubecontainer.ErrKillContainer, err.Error()) // Use runningPod for logging as the pod passed in could be *nil*. klog.ErrorS(err, "Kill container failed", "pod", klog.KRef(runningPod.Namespace, runningPod.Name), "podUID", runningPod.ID, "containerName", container.Name, "containerID", container.ID) } containerResults <- killContainerResult }(container)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 54.7K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager.go
func (m *kubeGenericRuntimeManager) KillPod(ctx context.Context, pod *v1.Pod, runningPod kubecontainer.Pod, gracePeriodOverride *int64) error { err := m.killPodWithSyncResult(ctx, pod, runningPod, gracePeriodOverride) return err.Error() } // killPodWithSyncResult kills a runningPod and returns SyncResult. // Note: The pod passed in could be *nil* when kubelet restarted.
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/kuberuntime/kuberuntime_manager_test.go
Image: fakeContainer.Image, ImageRef: fakeContainer.ImageRef, Labels: fakeContainer.Labels, }) if err != nil { t.Fatalf("unexpected error %v", err) } containers[i] = c } runningPod := kubecontainer.Pod{ ID: pod.UID, Name: pod.Name, Namespace: pod.Namespace, Containers: []*kubecontainer.Container{containers[0], containers[1], containers[2]},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 96K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0)