Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 21 for pod3 (0.43 sec)

  1. pkg/kubelet/eviction/eviction_manager_test.go

    			summaryStatsMaker := makePIDStats
    			pods := []*v1.Pod{}
    			podStats := map[*v1.Pod]statsapi.PodStats{}
    			for _, podToMake := range tc.podsToMake {
    				pod, podStat := podMaker(podToMake.name, podToMake.priority, podToMake.pidUsage)
    				pods = append(pods, pod)
    				podStats[pod] = podStat
    			}
    			podToEvict := pods[tc.evictPodIndex]
    			activePodsFunc := func() []*v1.Pod { return pods }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_pods.go

    // or are known to be fully terminated. This method should only be used
    // when the set of pods being filtered is upstream of the pod worker, i.e.
    // the pods the pod manager is aware of.
    func (kl *Kubelet) filterOutInactivePods(pods []*v1.Pod) []*v1.Pod {
    	filteredPods := make([]*v1.Pod, 0, len(pods))
    	for _, p := range pods {
    		// if a pod is fully terminated by UID, it should be excluded from the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go

    		},
    		{
    			// not a desired case, but it can happen
    			// TODO(Huang-Wei): document this "pod-not-match-itself" case
    			// in this case, placement of the new pod doesn't change pod distribution of the cluster
    			// as the incoming pod doesn't have label "foo"
    			name: "pods spread across nodes as 2/1/0/3, but pod doesn't match itself",
    			pod: st.MakePod().Name("p").Label("bar", "").
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 143.1K bytes
    - Viewed (0)
  4. api/openapi-spec/v3/apis__autoscaling__v2_openapi.json

            "properties": {
              "container": {
                "default": "",
                "description": "container is the name of the container in the pods of the scaling target",
                "type": "string"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 186.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/autoscaling/v1/generated.pb.go

    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.Pods == nil {
    				m.Pods = &PodsMetricSource{}
    			}
    			if err := m.Pods.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 4:
    			if wireType != 2 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 153K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/autoscaling/v2/generated.pb.go

    			postIndex := iNdEx + msglen
    			if postIndex < 0 {
    				return ErrInvalidLengthGenerated
    			}
    			if postIndex > l {
    				return io.ErrUnexpectedEOF
    			}
    			if m.Pods == nil {
    				m.Pods = &PodsMetricSource{}
    			}
    			if err := m.Pods.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
    				return err
    			}
    			iNdEx = postIndex
    		case 4:
    			if wireType != 2 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 162.9K bytes
    - Viewed (0)
  7. pkg/volume/util/operationexecutor/operation_generator.go

    		verbosity := klog.Level(4)
    		og.recorder.Eventf(volumeToMount.Pod, v1.EventTypeNormal, kevents.SuccessfulMountVolume, simpleMsg)
    		klog.V(verbosity).InfoS(detailedMsg, "pod", klog.KObj(volumeToMount.Pod))
    
    		// Device mapping for pod device map path succeeded
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
  8. pkg/printers/internalversion/printers.go

    	case api.PodSucceeded:
    		row.Conditions = podSuccessConditions
    	case api.PodFailed:
    		row.Conditions = podFailedConditions
    	}
    
    	initContainers := make(map[string]*api.Container)
    	for i := range pod.Spec.InitContainers {
    		initContainers[pod.Spec.InitContainers[i].Name] = &pod.Spec.InitContainers[i]
    		if isRestartableInitContainer(&pod.Spec.InitContainers[i]) {
    			totalContainers++
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  9. tests/integration/pilot/common/routing.go

    				//	host: fmt.Sprintf("%s-v1-0.%s", StatefulSetSvc, apps.StatefulSet[0].Config().ClusterLocalFQDN()),
    				//},
    			)
    		}
    		for _, podA := range t.Apps.A {
    			testCases = append(testCases, vmCase{
    				name: "k8s to vm",
    				from: podA,
    				to:   vms,
    			})
    		}
    		for _, c := range testCases {
    			c := c
    			checker := check.OK()
    			if !match.Headless.Any(c.to) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 21:52:51 UTC 2024
    - 135.9K bytes
    - Viewed (0)
  10. pkg/registry/batch/job/strategy_test.go

    					Template:       validPodTemplateSpec,
    					ManualSelector: ptr.To(true),
    					Parallelism:    ptr.To[int32](1),
    				},
    			},
    		},
    		"pod instead": {
    			job:          nil,
    			nonJobObject: &api.Pod{},
    			wantErr:      "given object is not a job.",
    		},
    	}
    	for name, tc := range cases {
    		t.Run(name, func(t *testing.T) {
    			if tc.job == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 101.5K bytes
    - Viewed (0)
Back to top