xgboostjob

Documentation

Index

• Variables
• func GetWorkloadNameForXGBoostJob(jobName string, jobUID types.UID) string
• func NewJob() jobframework.GenericJob
• func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error
• type JobControl
  • func (j *JobControl) GVK() schema.GroupVersionKind
  • func (j *JobControl) JobStatus() *kftraining.JobStatus
  • func (j *JobControl) Object() client.Object
  • func (j *JobControl) OrderedReplicaTypes() []kftraining.ReplicaType
  • func (j *JobControl) PodLabelSelector() string
  • func (j *JobControl) ReplicaSpecs() map[kftraining.ReplicaType]*kftraining.ReplicaSpec
  • func (j *JobControl) ReplicaSpecsFieldName() string
  • func (j *JobControl) RunPolicy() *kftraining.RunPolicy

Variables

var (
	FrameworkName = "kubeflow.org/xgboostjob"

	SetupXGBoostJobWebhook = jobframework.BaseWebhookFactory(
		NewJob(),
		func(o runtime.Object) jobframework.GenericJob {
			return fromObject(o)
		},
	)
)

var NewReconciler = jobframework.NewGenericReconcilerFactory(func() jobframework.GenericJob {
	return &kubeflowjob.KubeflowJob{KFJobControl: &JobControl{}}
})

Functions

func GetWorkloadNameForXGBoostJob

func GetWorkloadNameForXGBoostJob(jobName string, jobUID types.UID) string

func NewJob

func NewJob() jobframework.GenericJob

func SetupIndexes

func SetupIndexes(ctx context.Context, indexer client.FieldIndexer) error

Types

type JobControl

type JobControl kftraining.XGBoostJob

func (*JobControl) GVK

func (j *JobControl) GVK() schema.GroupVersionKind

func (*JobControl) JobStatus

func (j *JobControl) JobStatus() *kftraining.JobStatus

func (*JobControl) Object

func (j *JobControl) Object() client.Object

func (*JobControl) OrderedReplicaTypes

func (j *JobControl) OrderedReplicaTypes() []kftraining.ReplicaType

func (*JobControl) PodLabelSelector

func (j *JobControl) PodLabelSelector() string

func (*JobControl) ReplicaSpecs

func (j *JobControl) ReplicaSpecs() map[kftraining.ReplicaType]*kftraining.ReplicaSpec

func (*JobControl) ReplicaSpecsFieldName

func (j *JobControl) ReplicaSpecsFieldName() string

func (*JobControl) RunPolicy

func (j *JobControl) RunPolicy() *kftraining.RunPolicy