- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 186 for pidStatus (0.22 sec)
-
staging/src/k8s.io/apiserver/pkg/apis/example/v1/zz_generated.conversion.go
return err } if err := s.AddGeneratedConversionFunc((*PodStatus)(nil), (*example.PodStatus)(nil), func(a, b interface{}, scope conversion.Scope) error { return Convert_v1_PodStatus_To_example_PodStatus(a.(*PodStatus), b.(*example.PodStatus), scope) }); err != nil { return err } if err := s.AddGeneratedConversionFunc((*example.PodStatus)(nil), (*PodStatus)(nil), func(a, b interface{}, scope conversion.Scope) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 10.6K bytes - Viewed (0) -
pkg/kubelet/pleg/evented.go
func (e *EventedPLEG) updateRunningPodMetric(podStatus *kubecontainer.PodStatus) { cachedPodStatus, err := e.cache.Get(podStatus.ID) if err != nil { klog.ErrorS(err, "Evented PLEG: Get cache", "podID", podStatus.ID) } // cache miss condition: The pod status object will have empty state if missed in cache if len(cachedPodStatus.SandboxStatuses) < 1 { sandboxState := getPodSandboxState(podStatus)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 10:46:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_manager_test.go
makeAndSetFakePod(t, m, fakeRuntime, pod) podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace) assert.NoError(t, err) assert.Equal(t, pod.UID, podStatus.ID) assert.Equal(t, pod.Name, podStatus.Name) assert.Equal(t, pod.Namespace, podStatus.Namespace) assert.Equal(t, apitest.FakePodSandboxIPs, podStatus.IPs) } func TestStopContainerWithNotFoundError(t *testing.T) {
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/pod_container_deletor.go
func getContainersToDeleteInPod(filterContainerID string, podStatus *kubecontainer.PodStatus, containersToKeep int) containerStatusbyCreatedList { matchedContainer := func(filterContainerId string, podStatus *kubecontainer.PodStatus) *kubecontainer.Status { if filterContainerId == "" { return nil } for _, containerStatus := range podStatus.ContainerStatuses { if containerStatus.ID.ID == filterContainerId {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 05 13:02:13 UTC 2022 - 4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/util/util_test.go
for desc, test := range map[string]struct { pod *v1.Pod status *kubecontainer.PodStatus expectedChanged bool expectedAttempt uint32 expectedSandboxID string }{ "Pod with no existing sandboxes": { pod: &v1.Pod{}, status: &kubecontainer.PodStatus{}, expectedChanged: true, expectedAttempt: 0, expectedSandboxID: "", },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:14:48 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/kubelet/prober/testing/fake_manager.go
// Start simulates start syncing the probe status func (FakeManager) Start() {} // UpdatePodStatus simulates updating the Pod Status. func (FakeManager) UpdatePodStatus(_ *v1.Pod, podStatus *v1.PodStatus) { for i := range podStatus.ContainerStatuses { podStatus.ContainerStatuses[i].Ready = true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 07 22:26:12 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/controller/job/pod_failure_policy.go
func matchOnExitCodes(podStatus *v1.PodStatus, requirement *batch.PodFailurePolicyOnExitCodesRequirement) *v1.ContainerStatus { if containerStatus := getMatchingContainerFromList(podStatus.ContainerStatuses, requirement); containerStatus != nil { return containerStatus } return getMatchingContainerFromList(podStatus.InitContainerStatuses, requirement) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 20:44:11 UTC 2023 - 5.5K bytes - Viewed (0) -
pkg/api/v1/pod/util_test.go
LastTransitionTime: metav1.NewTime(time.Add(1000)), } tests := []struct { desc string podStatus v1.PodStatus expectedCondition *v1.PodCondition }{ { desc: "containers ready condition exists", podStatus: v1.PodStatus{ Conditions: []v1.PodCondition{containersReadyCondition}, }, expectedCondition: &containersReadyCondition, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 11:04:08 UTC 2023 - 32.1K bytes - Viewed (0) -
pkg/kubelet/container/testing/fake_cache.go
} func (c *fakeCache) Get(id types.UID) (*container.PodStatus, error) { return c.runtime.GetPodStatus(context.Background(), id, "", "") } func (c *fakeCache) GetNewerThan(id types.UID, minTime time.Time) (*container.PodStatus, error) { return c.Get(id) } func (c *fakeCache) Set(id types.UID, status *container.PodStatus, err error, timestamp time.Time) (updated bool) { return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 14:36:16 UTC 2022 - 1.3K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
pod.Status.PodIP = pod.Status.PodIPs[0].IP } // set old status podStatus := &kubecontainer.PodStatus{ ID: pod.UID, Name: pod.Name, Namespace: pod.Namespace, } podStatus.IPs = tc.nodeIPs status := kl.generateAPIPodStatus(pod, podStatus, false) if !reflect.DeepEqual(status.PodIPs, tc.expectedPodIPs) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0)