Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for JOB_COMPLETION_INDEX (0.17 sec)

  1. pkg/controller/job/indexed_job_utils.go

    	"k8s.io/apiserver/pkg/storage/names"
    	"k8s.io/apiserver/pkg/util/feature"
    	"k8s.io/klog/v2"
    	"k8s.io/kubernetes/pkg/controller"
    	"k8s.io/kubernetes/pkg/features"
    )
    
    const (
    	completionIndexEnvName = "JOB_COMPLETION_INDEX"
    	unknownCompletionIndex = -1
    )
    
    func isIndexedJob(job *batch.Job) bool {
    	return job.Spec.CompletionMode != nil && *job.Spec.CompletionMode == batch.IndexedCompletion
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller_test.go

    	} else {
    		fieldPath = fmt.Sprintf("metadata.labels['%s']", batch.JobCompletionIndexAnnotation)
    	}
    	want := []v1.EnvVar{
    		{
    			Name: "JOB_COMPLETION_INDEX",
    			ValueFrom: &v1.EnvVarSource{
    				FieldRef: &v1.ObjectFieldSelector{
    					FieldPath: fieldPath,
    				},
    			},
    		},
    	}
    	for _, c := range spec.InitContainers {
    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