Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for mypods (0.11 sec)

  1. pkg/printers/internalversion/printers_test.go

    								},
    							},
    						},
    					},
    				},
    			},
    			// Columns: Name, Reference, Targets, MinPods, MaxPods, Replicas, Age
    			expected: []metav1.TableRow{{Cells: []interface{}{"some-hpa", "ReplicationController/some-rc", "50m/100m", "2", int64(10), int64(4), "<unknown>"}}},
    		},
    		// pods source type (no current)
    		{
    			hpa: autoscaling.HorizontalPodAutoscaler{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 218.6K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    						Failed: []types.UID{"a", "b"},
    					},
    				},
    			},
    			pods: func() []*v1.Pod {
    				pods := make([]*v1.Pod, 500)
    				for i := range pods {
    					pods[i] = buildPod().uid(strconv.Itoa(i)).phase(v1.PodSucceeded).trackingFinalizer().Pod
    				}
    				pods = append(pods, buildPod().uid("b").phase(v1.PodFailed).trackingFinalizer().Pod)
    				return pods
    			}(),
    			wantRmFinalizers: 499,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet.go

    			handler.HandlePodUpdates(u.Pods)
    		case kubetypes.REMOVE:
    			klog.V(2).InfoS("SyncLoop REMOVE", "source", u.Source, "pods", klog.KObjSlice(u.Pods))
    			handler.HandlePodRemoves(u.Pods)
    		case kubetypes.RECONCILE:
    			klog.V(4).InfoS("SyncLoop RECONCILE", "source", u.Source, "pods", klog.KObjSlice(u.Pods))
    			handler.HandlePodReconcile(u.Pods)
    		case kubetypes.DELETE:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  4. pkg/printers/internalversion/printers.go

    		obj.Spec.ScaleTargetRef.Name)
    	minPods := "<unset>"
    	metrics := formatHPAMetrics(obj.Spec.Metrics, obj.Status.CurrentMetrics)
    	if obj.Spec.MinReplicas != nil {
    		minPods = fmt.Sprintf("%d", *obj.Spec.MinReplicas)
    	}
    	maxPods := obj.Spec.MaxReplicas
    	currentReplicas := obj.Status.CurrentReplicas
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  5. pkg/controller/statefulset/stateful_set_control_test.go

    		}
    
    		sort.Sort(ascendingOrdinal(pods))
    
    		// expected number of pod is 0,1,2,3
    		if !reflect.DeepEqual(pods, originalPods[:4]) {
    			t.Fatalf("Expected pods %v, got pods %v", originalPods[:4], pods)
    		}
    
    		// create new pods
    		if _, err = ssc.UpdateStatefulSet(context.TODO(), set, pods); err != nil {
    			t.Fatal(err)
    		}
    		pods, err = spc.podsLister.Pods(set.Namespace).List(selector)
    		if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_test.go

    	pods[2].Spec.ActiveDeadlineSeconds = &exceededActiveDeadlineSeconds
    
    	kubelet.podManager.SetPods(pods)
    	kubelet.workQueue.Enqueue(pods[2].UID, 0)
    	kubelet.workQueue.Enqueue(pods[3].UID, 30*time.Second)
    	kubelet.workQueue.Enqueue(pods[4].UID, 2*time.Minute)
    
    	clock.Step(1 * time.Minute)
    
    	expected := []*v1.Pod{pods[2], pods[3], pods[0]}
    	podsToSync := kubelet.getPodsToSync()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  7. pkg/scheduler/internal/queue/scheduling_queue_test.go

    	}{
    		{
    			name:      "create, update, delete subset of pods",
    			podsToAdd: []*v1.Pod{pods[0], pods[1], pods[2], pods[3]},
    			expectedMapAfterAdd: map[string]*framework.QueuedPodInfo{
    				util.GetPodFullName(pods[0]): {PodInfo: mustNewTestPodInfo(t, pods[0]), UnschedulablePlugins: sets.New[string]()},
    				util.GetPodFullName(pods[1]): {PodInfo: mustNewTestPodInfo(t, pods[1]), UnschedulablePlugins: sets.New[string]()},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  8. pkg/controller/garbagecollector/garbagecollector_test.go

    			"GET" + "/api/v1/namespaces/ns1/pods/rc1Pod1": {
    				200,
    				serilizeOrDie(t, rc1Pod1),
    			},
    			"GET" + "/api/v1/namespaces/ns1/pods/rc1Pod2": {
    				200,
    				serilizeOrDie(t, rc1Pod2),
    			},
    			"GET" + "/api/v1/namespaces/ns1/pods/rc2Pod1": {
    				200,
    				serilizeOrDie(t, rc2Pod1),
    			},
    			"GET" + "/api/v1/namespaces/ns1/pods/rc3Pod1": {
    				200,
    				serilizeOrDie(t, rc3Pod1),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  9. pkg/kubelet/eviction/helpers_test.go

    					},
    				},
    			},
    		},
    		Pods: []statsapi.PodStats{},
    	}
    	pods := []*v1.Pod{
    		podMaker("pod1", "ns1", "uuid1", 1),
    		podMaker("pod1", "ns2", "uuid2", 1),
    		podMaker("pod3", "ns3", "uuid3", 1),
    	}
    	podWorkingSetBytes := uint64(1024 * 1024 * 1024)
    	for _, pod := range pods {
    		fakeStats.Pods = append(fakeStats.Pods, newPodStats(pod, podWorkingSetBytes))
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 106.7K bytes
    - Viewed (0)
  10. pkg/api/pod/util_test.go

    	tests := []struct {
    		name        string
    		enabled     bool
    		podSpec     *api.PodSpec
    		oldPodSpec  *api.PodSpec
    		wantPodSpec *api.PodSpec
    	}{
    		{
    			name:    "feature disabled, both pods don't use the fields",
    			enabled: false,
    			oldPodSpec: &api.PodSpec{
    				TopologySpreadConstraints: []api.TopologySpreadConstraint{},
    			},
    			podSpec: &api.PodSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
Back to top