Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for hasJobTrackingFinalizer (0.32 sec)

  1. pkg/controller/job/tracking_utils.go

    // 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 {
    		if fin == batch.JobTrackingFinalizer {
    			return true
    		}
    	}
    	return false
    }
    
    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/indexed_job_utils.go

    		// has a finalizer (meaning that it is not counted yet).
    		if p.Status.Phase == v1.PodSucceeded && ix != unknownCompletionIndex && ix < int(*job.Spec.Completions) && hasJobTrackingFinalizer(p) {
    			newSucceeded.Insert(ix)
    		}
    	}
    	// List returns the items of the set in order.
    	result := prevIntervals.withOrderedIndexes(sets.List(newSucceeded))
    	return prevIntervals, result
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller.go

    			return
    		}
    		jm.expectations.CreationObserved(logger, jobKey)
    		jm.enqueueSyncJobBatched(logger, job)
    		return
    	}
    
    	// Otherwise, it's an orphan.
    	// Clean the finalizer.
    	if hasJobTrackingFinalizer(pod) {
    		jm.enqueueOrphanPod(pod)
    	}
    	// Get a list of all matching controllers and sync
    	// them to see if anyone wants to adopt it.
    	// DO NOT observe creation because no controller should be waiting for an
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  4. pkg/controller/job/job_controller_test.go

    			if err != nil {
    				t.Fatalf("getPodsForJob() error: %v", err)
    			}
    			got := make([]string, len(pods))
    			var gotFinalizer []string
    			for i, p := range pods {
    				got[i] = p.Name
    				if hasJobTrackingFinalizer(p) {
    					gotFinalizer = append(gotFinalizer, p.Name)
    				}
    			}
    			sort.Strings(got)
    			if diff := cmp.Diff(tc.wantPods, got); diff != "" {
    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