- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 139 for pidStatus (0.23 sec)
-
pkg/controller/endpointslice/endpointslice_controller_test.go
ResourceVersion: fmt.Sprint(n), }, Spec: v1.PodSpec{ Containers: []v1.Container{{ Name: "container-1", }}, NodeName: "node-1", }, Status: v1.PodStatus{ PodIP: fmt.Sprintf("1.2.3.%d", 4+n), PodIPs: []v1.PodIP{{ IP: fmt.Sprintf("1.2.3.%d", 4+n), }}, Conditions: []v1.PodCondition{ { Type: v1.PodReady, Status: status,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/kubelet/lifecycle/handlers_test.go
return podStatusProviderFunc(func(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) { return &kubecontainer.PodStatus{ ID: uid, Name: name, Namespace: namespace, IPs: []string{podIP}, }, nil }) } type podStatusProviderFunc func(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/volume/util/util.go
func IsPodTerminated(pod *v1.Pod, podStatus v1.PodStatus) bool { // TODO: the guarantees provided by kubelet status are not sufficient to guarantee it's safe to ignore a deleted pod, // even if everything is notRunning (kubelet does not guarantee that when pod status is waiting that it isn't trying // to start a container).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller_test.go
pods = append(pods, &v1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: pod.name, Namespace: metav1.NamespaceDefault, CreationTimestamp: metav1.Time{Time: creationTime}}, Status: v1.PodStatus{Phase: pod.phase, Reason: pod.reason}, Spec: v1.PodSpec{NodeName: "node"}, }) } client := setupNewSimpleClient(nodes, pods) gcc, podInformer, _ := NewFromClient(ctx, client, test.threshold)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 08:16:48 UTC 2024 - 29K bytes - Viewed (0) -
pkg/kubelet/container/helpers_test.go
Spec: v1.PodSpec{ Containers: []v1.Container{ {Name: "no-history"}, {Name: "alive"}, {Name: "succeed"}, {Name: "failed"}, {Name: "unknown"}, }, }, } podStatus := &PodStatus{ ID: pod.UID, Name: pod.Name, Namespace: pod.Namespace, ContainerStatuses: []*Status{ { Name: "alive", State: ContainerStateRunning, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 22 01:55:46 UTC 2024 - 24.5K bytes - Viewed (0) -
pkg/kube/krt/bench_test.go
Namespace: fmt.Sprintf("ns-%d", i%2), Labels: map[string]string{ "app": fmt.Sprintf("app-%d", i%25), }, }, Spec: v1.PodSpec{ ServiceAccountName: "fake-sa", }, Status: v1.PodStatus{ Phase: v1.PodRunning, PodIP: GetIP(), }, }) } initialServices := []*v1.Service{} for i := 0; i < 50; i++ { initialServices = append(initialServices, &v1.Service{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 7K bytes - Viewed (0) -
pkg/kubelet/stats/cadvisor_stats_provider_test.go
mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName0)).Return(v1.PodStatus{StartTime: &p0Time}, true) mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName1)).Return(v1.PodStatus{StartTime: &p1Time}, true) mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName2)).Return(v1.PodStatus{StartTime: &p2Time}, true) mockStatus.EXPECT().GetPodStatus(types.UID("UID"+pName3)).Return(v1.PodStatus{StartTime: &p3Time}, true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 30.2K 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/controller/job/indexed_job_utils_test.go
Operator: batch.PodFailurePolicyOnExitCodesOpIn, Values: []int32{3}, }, }, }, }, }, }, pod: buildPod().indexFailureCount("0").status(v1.PodStatus{ Phase: v1.PodFailed, ContainerStatuses: []v1.ContainerStatus{ { State: v1.ContainerState{ Terminated: &v1.ContainerStateTerminated{ ExitCode: 3, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 27.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/helpers_test.go
"k8s.io/utils/ptr" ) type podStatusProviderFunc func(uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) func (f podStatusProviderFunc) GetPodStatus(_ context.Context, uid types.UID, name, namespace string) (*kubecontainer.PodStatus, error) { return f(uid, name, namespace) } func TestIsInitContainerFailed(t *testing.T) { tests := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 11.7K bytes - Viewed (0)