- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for pidStatus (0.37 sec)
-
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) -
pkg/kubelet/kubelet_test.go
}, } pods := []*v1.Pod{pod} kl.podManager.SetPods(pods) podStatus := &kubecontainer.PodStatus{ID: pod.UID} gracePeriodOverride := int64(0) err := kl.SyncTerminatingPod(context.Background(), pod, podStatus, &gracePeriodOverride, func(podStatus *v1.PodStatus) { podStatus.Phase = v1.PodFailed podStatus.Reason = "reason" podStatus.Message = "message" }) require.NoError(t, err)
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
} // convertStatusToAPIStatus initialize an api PodStatus for the given pod from // the given internal pod status and the previous state of the pod from the API. // It is purely transformative and does not alter the kubelet state at all. func (kl *Kubelet) convertStatusToAPIStatus(pod *v1.Pod, podStatus *kubecontainer.PodStatus, oldPodStatus v1.PodStatus) *v1.PodStatus { var apiPodStatus v1.PodStatus
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/api/pod/util_test.go
podWithHostIPs := func() *api.PodStatus { return &api.PodStatus{ HostIPs: makeHostIPs("10.0.0.1", "fd00:10::1"), } } podWithoutHostIPs := func() *api.PodStatus { return &api.PodStatus{ HostIPs: nil, } } tests := []struct { name string podStatus *api.PodStatus oldPodStatus *api.PodStatus wantPodStatus *api.PodStatus }{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 108.8K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
podStatus.IPs = append(podStatus.IPs, ipInfo.IP) } if len(podStatus.IPs) == 0 && len(apiPodStatus.PodIP) > 0 { podStatus.IPs = []string{apiPodStatus.PodIP} } // If the pod is terminal, we don't need to continue to setup the pod if apiPodStatus.Phase == v1.PodSucceeded || apiPodStatus.Phase == v1.PodFailed { kl.statusManager.SetPodStatus(pod, apiPodStatus) isTerminal = true return isTerminal, nil
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/printers/internalversion/printers_test.go
// Test name, num of containers, restarts, container ready status api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "test1"}, Spec: api.PodSpec{Containers: make([]api.Container, 2)}, Status: api.PodStatus{ Phase: "podPhase", ContainerStatuses: []api.ContainerStatus{ {Ready: true, RestartCount: 3, State: api.ContainerState{Running: &api.ContainerStateRunning{}}}, {RestartCount: 3}, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
PodFailurePolicy: &batch.PodFailurePolicy{ Rules: onExitCodeRules, }, }, }, pods: []v1.Pod{ { Status: v1.PodStatus{ Phase: v1.PodRunning, }, }, { Status: v1.PodStatus{ Phase: v1.PodFailed, ContainerStatuses: []v1.ContainerStatus{ { Name: "main-container", State: v1.ContainerState{
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/eviction/eviction_manager_test.go
wantPodStatus v1.PodStatus }{ "eviction due to memory pressure; no image fs": { wantPodStatus: v1.PodStatus{ Phase: v1.PodFailed, Reason: "Evicted", Message: "The node was low on resource: memory. Threshold quantity: 2Gi, available: 1500Mi. ", }, }, "eviction due to memory pressure; image fs": { wantPodStatus: v1.PodStatus{ Phase: v1.PodFailed,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
pod := newPod("matching-owned-succeeded-pod-0-", "node-0", simpleDaemonSetLabel, ds) pod.Status = v1.PodStatus{Phase: v1.PodSucceeded} return pod }(), func() *v1.Pod { pod := newPod("matching-owned-failed-pod-1-", "node-1", simpleDaemonSetLabel, ds) pod.Status = v1.PodStatus{Phase: v1.PodFailed} return pod }(), }, ignoredPods: []*v1.Pod{
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/apis/core/zz_generated.deepcopy.go
(*in)[i].DeepCopyInto(&(*out)[i]) } } return } // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodStatus. func (in *PodStatus) DeepCopy() *PodStatus { if in == nil { return nil } out := new(PodStatus) in.DeepCopyInto(out) return out }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 181.5K bytes - Viewed (0)