- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 119 for pidStatus (0.23 sec)
-
pkg/kubelet/container/testing/runtime_mock.go
} // SyncPod mocks base method. func (m *MockRuntime) SyncPod(ctx context.Context, pod *v1.Pod, podStatus *container.PodStatus, pullSecrets []v1.Secret, backOff *flowcontrol.Backoff) container.PodSyncResult { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "SyncPod", ctx, pod, podStatus, pullSecrets, backOff) ret0, _ := ret[0].(container.PodSyncResult) return ret0 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 27K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
SyncTerminatedPod(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus) error } type syncPodFnType func(ctx context.Context, updateType kubetypes.SyncPodType, pod *v1.Pod, mirrorPod *v1.Pod, podStatus *kubecontainer.PodStatus) (bool, error) type syncTerminatingPodFnType func(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus, gracePeriod *int64, podStatusFn func(*v1.PodStatus)) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/example/v1/generated.proto
// If not specified, the pod will be dispatched by default scheduler. // +optional optional string schedulername = 19; } // PodStatus represents information about the status of a pod. Status may trail the actual // state of a system. message PodStatus { // Current condition of the pod. // More info: http://kubernetes.io/docs/user-guide/pod-states#pod-phase // +optional optional string phase = 1;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 7.6K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter.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: Sat Apr 13 00:50:31 UTC 2024 - 6.9K bytes - Viewed (0) -
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/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/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) -
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)