- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for runningPod (0.2 sec)
-
pkg/kubelet/container/runtime.go
Sandboxes []*Container } // PodPair contains both runtime#Pod and api#Pod type PodPair struct { // APIPod is the v1.Pod APIPod *v1.Pod // RunningPod is the pod defined in pkg/kubelet/container/runtime#Pod RunningPod *Pod } // ContainerID is a type that identifies a container. type ContainerID struct { // The type of the container runtime. e.g. 'docker'. Type string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 27.8K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
RunningPod: runningPod, KillPodOptions: killPodOptions, }) // the running pod is now known as well workingPods[runningPod.ID] = PodWorkerSync{State: TerminatingPod, Orphan: true} orphanCount++ } } metrics.OrphanedRuntimePodTotal.Add(float64(orphanCount)) // Now that we have recorded any terminating pods, and added new pods that should be running,
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
testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */) defer testKubelet.Cleanup() runningPod := &kubecontainer.Pod{ ID: "12345678", Name: "pod1", Namespace: "ns", } apiPod := podWithUIDNameNs(runningPod.ID, runningPod.Name, runningPod.Namespace) // Sync once to create pod directory; confirm that the pod directory has // already been created.
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.go
// While resize is in progress, periodically call PLEG to update pod cache runningPod := kubecontainer.ConvertPodStatusToRunningPod(kl.getRuntime().Type(), podStatus) if err, _ := kl.pleg.UpdateCache(&runningPod, pod.UID); err != nil { klog.ErrorS(err, "Failed to update pod cache", "pod", klog.KObj(pod)) return false, err } }
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/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/printers/internalversion/printers_test.go
} if !reflect.DeepEqual(test.expect, rows) { t.Errorf("%d mismatch: %s", i, cmp.Diff(test.expect, rows)) } } } func TestPrintPodConditions(t *testing.T) { runningPod := &api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "test1", Labels: map[string]string{"a": "1", "b": "2"}}, Spec: api.PodSpec{Containers: make([]api.Container, 2)}, Status: api.PodStatus{ Phase: "Running",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/operations/TestListenerBuildOperationAdapter.java
long currentTime = clock.getCurrentTime(); InProgressExecuteTestBuildOperation runningOp = runningTests.remove(testDescriptor); listener.finished(runningOp.descriptor, new OperationFinishEvent(runningOp.startTime, currentTime, testResult.getException(), new Result(testResult))); } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager_test.go
podSetBeforeCleanup: []types.UID{"pod-1", "pod-2"}, runningPods: []*kubecontainer.Pod{{ID: "pod-1"}}, podSetAfterCleanup: []types.UID{"pod-1"}, podUnsetAfterCleanup: []types.UID{"pod-2"}, }, { name: "pod set before cleanup but not listed ==> unset", podSetBeforeCleanup: []types.UID{"pod-1", "pod-2"}, runningPods: []*kubecontainer.Pod{{ID: "pod-1"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 14.6K bytes - Viewed (0) -
pkg/kubelet/server/auth_test.go
"/portForward/{podNamespace}/{podID}/{uid}": "proxy", "/run/{podNamespace}/{podID}/{containerName}": "proxy", "/run/{podNamespace}/{podID}/{uid}/{containerName}": "proxy", "/runningpods/": "proxy", "/stats/": "stats", "/stats/summary": "stats", } testCases := []AuthzTestCase{} for path, subresource := range testPaths { testCases = append(testCases,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 18:09:38 UTC 2024 - 5K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes.go
func (kl *Kubelet) cleanupOrphanedPodDirs(pods []*v1.Pod, runningPods []*kubecontainer.Pod) error { allPods := sets.New[string]() for _, pod := range pods { allPods.Insert(string(pod.UID)) } for _, pod := range runningPods { allPods.Insert(string(pod.ID)) } found, err := kl.listPodsFromDisk() if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.1K bytes - Viewed (0)