Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ActivePods (0.19 sec)

  1. pkg/kubelet/cm/devicemanager/manager_test.go

    			expectedAllocatedResName1: 2,
    			expectedAllocatedResName2: 2,
    			expErr:                    nil,
    		},
    	}
    	activePods := []*v1.Pod{}
    	for _, testCase := range testCases {
    		pod := testCase.testPod
    		activePods = append(activePods, pod)
    		podsStub.updateActivePods(activePods)
    		err := testManager.Allocate(pod, &pod.Spec.Containers[0])
    		if !reflect.DeepEqual(err, testCase.expErr) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    		job:                  &job,
    		pods:                 pods,
    		activePods:           controller.FilterActivePods(logger, pods),
    		terminating:          terminating,
    		uncounted:            newUncountedTerminatedPods(*job.Status.UncountedTerminatedPods),
    		expectedRmFinalizers: jm.finalizerExpectations.getExpectedUIDs(key),
    	}
    	active := int32(len(jobCtx.activePods))
    	newSucceededPods, newFailedPods := getNewFinishedPods(jobCtx)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  3. pkg/controller/replicaset/replica_set_test.go

    		}
    
    		// Confirm that we've created the right number of replicas
    		activePods := int32(len(informers.Core().V1().Pods().Informer().GetIndexer().List()))
    		if activePods != *(rsSpec.Spec.Replicas) {
    			t.Fatalf("Unexpected number of active pods, expected %d, got %d", *(rsSpec.Spec.Replicas), activePods)
    		}
    		// Replenish the pod list, since we cut it down sizing up
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
Back to top