- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 186 for pidStatus (0.17 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go
func IsPodReadyConditionTrue(status v1.PodStatus) bool { condition := GetPodReadyCondition(status) return condition != nil && condition.Status == v1.ConditionTrue } func GetPodReadyCondition(status v1.PodStatus) *v1.PodCondition { _, condition := GetPodCondition(&status, v1.PodReady) return condition } func GetPodCondition(status *v1.PodStatus, conditionType v1.PodConditionType) (int, *v1.PodCondition) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 22 20:35:23 UTC 2024 - 7.2K 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/kubelet/status/generate.go
return v1.PodCondition{ Type: v1.PodInitialized, Status: v1.ConditionTrue, } } func GeneratePodReadyToStartContainersCondition(pod *v1.Pod, podStatus *kubecontainer.PodStatus) v1.PodCondition { newSandboxNeeded, _, _ := runtimeutil.PodSandboxChanged(pod, podStatus) // if a new sandbox does not need to be created for a pod, it indicates that // a sandbox for the pod with networking configured already exists.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 12 15:18:11 UTC 2023 - 9.8K bytes - Viewed (0) -
pkg/kubelet/status/testing/mock_pod_status_provider.go
return m.recorder } // GetPodStatus mocks base method. func (m *MockPodStatusProvider) GetPodStatus(uid types.UID) (v1.PodStatus, bool) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "GetPodStatus", uid) ret0, _ := ret[0].(v1.PodStatus) ret1, _ := ret[1].(bool) return ret0, ret1 } // GetPodStatus indicates an expected call of GetPodStatus.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods_test.go
Limits: api.ResourceList{api.ResourceName("example.com/dongle"): resource.MustParse("3")}, }, }}, }, Status: api.PodStatus{ Phase: api.PodSucceeded, }, }, usage: corev1.ResourceList{ generic.ObjectCountQuotaResourceNameFor(schema.GroupResource{Resource: "pods"}): resource.MustParse("1"), }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 41.6K bytes - Viewed (0) -
pkg/kubelet/active_deadline_test.go
} // GetPodStatus returns the status on the associated pod with matching uid (if found) func (m *mockPodStatusProvider) GetPodStatus(uid types.UID) (v1.PodStatus, bool) { for _, pod := range m.pods { if pod.UID == uid { return pod.Status, true } } return v1.PodStatus{}, false } func TestNewActiveDeadlineHandler(t *testing.T) { pods := newTestPods(1) podStatusProvider := &mockPodStatusProvider{pods: pods}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 08 09:06:42 UTC 2022 - 4.5K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
Status: v1.PodStatus{Phase: v1.PodUnknown}, }, { ObjectMeta: metav1.ObjectMeta{Name: "runningButNotReady"}, Spec: v1.PodSpec{NodeName: "foo"}, Status: v1.PodStatus{Phase: v1.PodRunning}, }, { ObjectMeta: metav1.ObjectMeta{Name: "runningNoLastTransitionTime"}, Spec: v1.PodSpec{NodeName: "foo"}, Status: v1.PodStatus{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller_test.go
Status: v1.PodStatus{Phase: v1.PodRunning}, Spec: v1.PodSpec{ Volumes: []v1.Volume{{Name: "vol"}}, Containers: []v1.Container{{Name: "ctr", Image: "image", Resources: getResourceRequirements(getResourceList("", ""), getResourceList("", ""))}}, }, }, &v1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "pod-running-2", Namespace: "testing"}, Status: v1.PodStatus{Phase: v1.PodRunning},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 12 16:29:33 UTC 2023 - 42.6K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter_test.go
p := s.pc.Get(name, pod.Namespace) if p == nil { // Apiserver doesn't allow Create to modify the pod status; in real world it's a 2 part process pod.Status = corev1.PodStatus{} newPod := s.pc.Create(pod) if markReady { setPodReady(newPod) } newPod.Status.PodIP = ip newPod.Status.Phase = corev1.PodRunning newPod.Status.PodIPs = []corev1.PodIP{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator_test.go
{ Name: "dswp-test-volume-name", VolumeSource: v1.VolumeSource{ RBD: &v1.RBDVolumeSource{ RBDImage: "dswp-test-fake-device", }, }, }, }, }, Status: v1.PodStatus{ Phase: v1.PodPhase("Running"), }, } fakePodInformer.Informer().GetStore().Add(pod) podName := util.GetUniquePodName(pod) generatedVolumeName := "fake-plugin/" + pod.Spec.Volumes[0].RBD.RBDImage
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 7.3K bytes - Viewed (0)