Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for orderedIntervals (0.21 sec)

  1. pkg/controller/job/success_policy_test.go

    		},
    		"any rules are nothing": {
    			enableJobSuccessPolicy: true,
    			completions:            10,
    			succeededIndexes:       orderedIntervals{{0, 0}},
    			successPolicy:          &batch.SuccessPolicy{Rules: []batch.SuccessPolicyRule{}},
    		},
    		"rules.succeededIndexes is invalid format": {
    			enableJobSuccessPolicy: true,
    			completions:            10,
    			succeededIndexes:       orderedIntervals{{0, 0}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  2. pkg/controller/job/indexed_job_utils.go

    // with returns a new list of ordered intervals that contains the newOrderedIntervals.
    func (oi orderedIntervals) merge(newOi orderedIntervals) orderedIntervals {
    	var result orderedIntervals
    	i := 0
    	j := 0
    	var lastInterval *interval
    	appendOrMergeWithLastInterval := func(thisInterval interval) {
    		if lastInterval == nil || thisInterval.First > lastInterval.Last+1 {
    			result = append(result, thisInterval)
    			lastInterval = &result[len(result)-1]
    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/success_policy.go

    	"k8s.io/apiserver/pkg/util/feature"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/features"
    )
    
    func matchSuccessPolicy(logger klog.Logger, successPolicy *batch.SuccessPolicy, completions int32, succeededIndexes orderedIntervals) (string, bool) {
    	if !feature.DefaultFeatureGate.Enabled(features.JobSuccessPolicy) || successPolicy == nil || len(succeededIndexes) == 0 {
    		return "", false
    	}
    
    	rulesMatchedMsg := "Matched rules at index"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  4. pkg/controller/job/indexed_job_utils_test.go

    	logger, _ := ktesting.NewTestContext(t)
    	cases := map[string]struct {
    		prevSucceeded       string
    		pods                []indexPhase
    		completions         int32
    		wantStatusIntervals orderedIntervals
    		wantIntervals       orderedIntervals
    	}{
    		"one index": {
    			pods:          []indexPhase{{"1", v1.PodSucceeded}},
    			completions:   2,
    			wantIntervals: []interval{{1, 1}},
    		},
    		"two separate": {
    			pods: []indexPhase{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  5. pkg/controller/job/job_controller.go

    	activePods                      []*v1.Pod
    	succeeded                       int32
    	failed                          int32
    	prevSucceededIndexes            orderedIntervals
    	succeededIndexes                orderedIntervals
    	failedIndexes                   *orderedIntervals
    	newBackoffRecord                backoffRecord
    	expectedRmFinalizers            sets.Set[string]
    	uncounted                       *uncountedTerminatedPods
    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