Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getExpectedUIDs (0.37 sec)

  1. pkg/controller/job/tracking_utils.go

    	if obj, exists, err := u.store.GetByKey(controllerKey); err == nil && exists {
    		return obj.(*uidSet)
    	}
    	return nil
    }
    
    func (u *uidTrackingExpectations) getExpectedUIDs(controllerKey string) sets.Set[string] {
    	uids := u.getSet(controllerKey)
    	if uids == nil {
    		return nil
    	}
    	uids.RLock()
    	set := uids.set.Clone()
    	uids.RUnlock()
    	return set
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 05:40:02 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    		podIndexer.Add(pods[i])
    		uids.Insert(string(pods[i].UID))
    	}
    	jobKey := testutil.GetKey(job, t)
    
    	manager.syncJob(context.TODO(), jobKey)
    	gotExpectedUIDs := manager.finalizerExpectations.getExpectedUIDs(jobKey)
    	if len(gotExpectedUIDs) != 0 {
    		t.Errorf("Got unwanted expectations for removed finalizers after first syncJob with client failures:\n%s", sets.List(gotExpectedUIDs))
    	}
    
    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/controller/job/job_controller.go

    		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)
Back to top