Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for terminatingPod (0.22 sec)

  1. pkg/kubelet/kubelet_pods.go

    	for uid, sync := range workingPods {
    		switch sync.State {
    		case SyncPod:
    			runningPods[uid] = struct{}{}
    			possiblyRunningPods[uid] = struct{}{}
    		case TerminatingPod:
    			possiblyRunningPods[uid] = struct{}{}
    		default:
    		}
    	}
    
    	// Retrieve the list of running containers from the runtime to perform cleanup.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  2. pkg/kubelet/pod_workers_test.go

    	state = podWorkers.SyncKnownPods([]*v1.Pod{
    		newNamedPod("8-static", "test1", "pod1", true),
    	})
    	drainAllWorkers(podWorkers)
    	if e, a := map[types.UID]PodWorkerSync{
    		"1-normal": {State: TerminatingPod, Orphan: true, HasConfig: true},
    		"8-static": {State: SyncPod, HasConfig: true, Static: true},
    	}, state; !reflect.DeepEqual(e, a) {
    		t.Fatalf("unexpected actual restartable: %s", cmp.Diff(e, a))
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller_test.go

    		pods = append(pods, newPod)
    	}
    	return pods
    }
    
    func setPodsStatuses(podIndexer cache.Indexer, job *batch.Job, pendingPods, activePods, succeededPods, failedPods, terminatingPods, readyPods int) {
    	for _, pod := range newPodList(pendingPods, v1.PodPending, job) {
    		podIndexer.Add(pod)
    	}
    	running := newPodList(activePods, v1.PodRunning, job)
    	for i, p := range running {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
Back to top