Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for podsToDelete (0.11 sec)

  1. pkg/controller/replicaset/replica_set.go

    		// expired even if other pods are deleted.
    		rsc.expectations.ExpectDeletions(logger, rsKey, getPodKeys(podsToDelete))
    
    		errCh := make(chan error, diff)
    		var wg sync.WaitGroup
    		wg.Add(diff)
    		for _, pod := range podsToDelete {
    			go func(targetPod *v1.Pod) {
    				defer wg.Done()
    				if err := rsc.podControl.DeletePod(ctx, rs.Namespace, targetPod.Name, rs); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_control.go

    	}
    
    	// Now we need to delete MaxUnavailable- unavailablePods
    	// start deleting one by one starting from the highest ordinal first
    	podsToDelete := maxUnavailable - unavailablePods
    
    	deletedPods := 0
    	for target := len(replicas) - 1; target >= updateMin && deletedPods < podsToDelete; target-- {
    
    		// delete the Pod if it is healthy and the revision doesnt match the target
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:03:46 UTC 2024
    - 30.9K bytes
    - Viewed (0)
Back to top