job

Documentation

Index

• Constants
• type JobProvider
  • func NewJobProvider(logCtx log.Entry, kubeclientset kubernetes.Interface, ...) *JobProvider
  • func (p *JobProvider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, limit int) error
  • func (p *JobProvider) Resume(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (p *JobProvider) Run(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement
  • func (p *JobProvider) Terminate(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, ...) v1alpha1.Measurement
  • func (p *JobProvider) Type() string

Constants

const (
	ProviderType = "job"
	// JobNameKey is the measurement's metadata key holding the job name associated with the measurement
	JobNameKey = "job-name"
	// AnalysisRunNameAnnotationKey is the job's annotation key containing the name of the controller AnalysisRun
	AnalysisRunNameAnnotationKey = "analysisrun.argoproj.io/name"
	// AnalysisRunMetricLabelKey is the job's annotation key containing the name of the associated AnalysisRun metric
	AnalysisRunMetricAnnotationKey = "analysisrun.argoproj.io/metric-name"
	// AnalysisRunUIDLabelKey is the job's label key containing the uid of the associated AnalysisRun
	// Also used to filter the job informer
	AnalysisRunUIDLabelKey = "analysisrun.argoproj.io/uid"
)

Types

type JobProvider

type JobProvider struct {
	// contains filtered or unexported fields
}

func NewJobProvider

func NewJobProvider(logCtx log.Entry, kubeclientset kubernetes.Interface, jobLister batchlisters.JobLister) *JobProvider

func (*JobProvider) GarbageCollect

func (p *JobProvider) GarbageCollect(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, limit int) error

GarbageCollect deletes an old jobs

func (*JobProvider) Resume

func (p *JobProvider) Resume(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

func (*JobProvider) Run

func (p *JobProvider) Run(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric) v1alpha1.Measurement

func (*JobProvider) Terminate

func (p *JobProvider) Terminate(run *v1alpha1.AnalysisRun, metric v1alpha1.Metric, measurement v1alpha1.Measurement) v1alpha1.Measurement

func (*JobProvider) Type

func (p *JobProvider) Type() string