Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 68 for PodRunning (0.19 sec)

  1. pkg/kubelet/kubelet_test.go

    	pods[2].Status.Phase = v1.PodRunning
    	pods[2].DeletionTimestamp = &now
    	pods[2].Status.ContainerStatuses = []v1.ContainerStatus{
    		{State: v1.ContainerState{
    			Running: &v1.ContainerStateRunning{
    				StartedAt: now,
    			},
    		}},
    	}
    
    	// pending and running pods are included
    	pods[3].Status.Phase = v1.PodPending
    	pods[4].Status.Phase = v1.PodRunning
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  2. pkg/controller/controller_utils.go

    	Duration: 100 * time.Millisecond,
    	Jitter:   1.0,
    }
    
    var (
    	KeyFunc           = cache.DeletionHandlingMetaNamespaceKeyFunc
    	podPhaseToOrdinal = map[v1.PodPhase]int{v1.PodPending: 0, v1.PodUnknown: 1, v1.PodRunning: 2}
    )
    
    type ResyncPeriodFunc func() time.Duration
    
    // Returns 0 for resyncPeriod in case resyncing is not needed.
    func NoResyncPeriodFunc() time.Duration {
    	return 0
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 12 15:34:44 UTC 2024
    - 47.6K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/pod_test.go

    	}
    
    	pod2 := metav1.ObjectMeta{Name: "pod2", Namespace: ns}
    	if err := f(nil, &v1.Pod{ObjectMeta: pod2, Status: v1.PodStatus{Conditions: readyCondition, PodIP: ip, Phase: v1.PodRunning}}, model.EventAdd); err != nil {
    		t.Error(err)
    	}
    	if handled != 3 {
    		t.Errorf("notified workload handler %d times, want %d", handled, 3)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 18:27:40 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/util/apiclient/wait.go

    				lastKnownPodNumber = len(pods.Items)
    			}
    
    			if len(pods.Items) == 0 {
    				return false, nil
    			}
    
    			for _, pod := range pods.Items {
    				if pod.Status.Phase != v1.PodRunning {
    					return false, nil
    				}
    			}
    
    			return true, nil
    		})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_set_utils.go

    		pod.Labels[apps.PodIndexLabel] = strconv.Itoa(ordinal)
    	}
    }
    
    // isRunningAndReady returns true if pod is in the PodRunning Phase, if it has a condition of PodReady.
    func isRunningAndReady(pod *v1.Pod) bool {
    	return pod.Status.Phase == v1.PodRunning && podutil.IsPodReady(pod)
    }
    
    func isRunningAndAvailable(pod *v1.Pod, minReadySeconds int32) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  6. pkg/controller/podgc/gc_controller.go

    	gcc.gcOrphaned(ctx, pods, nodes)
    	gcc.gcUnscheduledTerminating(ctx, pods)
    }
    
    func isPodTerminated(pod *v1.Pod) bool {
    	if phase := pod.Status.Phase; phase != v1.PodPending && phase != v1.PodRunning && phase != v1.PodUnknown {
    		return true
    	}
    	return false
    }
    
    // isPodTerminating returns true if the pod is terminating.
    func isPodTerminating(pod *v1.Pod) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  7. pkg/controller/volume/attachdetach/testing/testvolumespec.go

    		podNamePrefix := "mypod"
    		namespace := "mynamespace"
    		for i := 0; i < 5; i++ {
    			podName := fmt.Sprintf("%s-%d", podNamePrefix, i)
    			pod := v1.Pod{
    				Status: v1.PodStatus{
    					Phase: v1.PodRunning,
    				},
    				ObjectMeta: metav1.ObjectMeta{
    					Name:      podName,
    					UID:       types.UID(podName),
    					Namespace: namespace,
    					Labels: map[string]string{
    						"name": podName,
    					},
    				},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 17 08:48:30 UTC 2023
    - 16.5K bytes
    - Viewed (0)
  8. pilot/pkg/xds/workload_test.go

    			ServiceAccountName: sa,
    			NodeName:           node,
    		},
    		Status: corev1.PodStatus{
    			PodIP: ip,
    			PodIPs: []corev1.PodIP{
    				{
    					IP: ip,
    				},
    			},
    			Phase: corev1.PodRunning,
    			Conditions: []corev1.PodCondition{
    				{
    					Type:               corev1.PodReady,
    					Status:             corev1.ConditionTrue,
    					LastTransitionTime: metav1.Now(),
    				},
    			},
    		},
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 18 19:09:43 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  9. pkg/apis/core/fuzzer/fuzzer.go

    			}
    		},
    		func(s *core.PodStatus, c fuzz.Continue) {
    			c.Fuzz(&s)
    			s.HostIPs = []core.HostIP{{IP: s.HostIP}}
    		},
    		func(j *core.PodPhase, c fuzz.Continue) {
    			statuses := []core.PodPhase{core.PodPending, core.PodRunning, core.PodFailed, core.PodUnknown}
    			*j = statuses[c.Rand.Intn(len(statuses))]
    		},
    		func(j *core.Binding, c fuzz.Continue) {
    			c.Fuzz(&j.ObjectMeta)
    			j.Target.Name = c.RandString()
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 04:32:01 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  10. pkg/registry/core/pod/storage/storage_test.go

    					},
    				},
    				SecurityContext: &api.PodSecurityContext{},
    				SchedulerName:   v1.DefaultSchedulerName,
    			},
    			Status: api.PodStatus{
    				Phase:   api.PodRunning,
    				PodIPs:  []api.PodIP{{IP: "127.0.0.1"}},
    				Message: "is now scheduled",
    			},
    		},
    		{
    			ObjectMeta: metav1.ObjectMeta{
    				Name: "foo",
    				Labels: map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 07:18:44 UTC 2024
    - 38.8K bytes
    - Viewed (0)
Back to top