Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newUIDTrackingExpectations (0.24 sec)

  1. pkg/controller/job/tracking_utils.go

    		}
    	}
    }
    
    // NewUIDTrackingControllerExpectations returns a wrapper around
    // ControllerExpectations that is aware of deleteKeys.
    func newUIDTrackingExpectations() *uidTrackingExpectations {
    	return &uidTrackingExpectations{store: cache.NewStore(uidSetKeyFunc)}
    }
    
    func hasJobTrackingFinalizer(pod *v1.Pod) bool {
    	for _, fin := range pod.Finalizers {
    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/tracking_utils_test.go

    			firstRound:  []string{"x", "y", "z"},
    			secondRound: []string{"u", "v", "w"},
    		},
    		{
    			job:         "baz",
    			firstRound:  []string{"w"},
    			secondRound: []string{"a"},
    		},
    	}
    	expectations := newUIDTrackingExpectations()
    
    	// Insert first round of keys in parallel.
    
    	var wg sync.WaitGroup
    	wg.Add(len(tracks))
    	errs := make([]error, len(tracks))
    	for i := range tracks {
    		track := tracks[i]
    		go func(errID int) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 14 05:40:02 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller.go

    			Recorder:   eventBroadcaster.NewRecorder(scheme.Scheme, v1.EventSource{Component: "job-controller"}),
    		},
    		expectations:          controller.NewControllerExpectations(),
    		finalizerExpectations: newUIDTrackingExpectations(),
    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