controllers

Documentation

Index

• Variables
• type GetObjectFunc
• type JobManager
• type JobManagerFunc
• type PyTorchJobManager
  • func NewPyTorchJobManager(tjob *tj.TrainingJob) *PyTorchJobManager
  • func (m *PyTorchJobManager) GetObject() client.Object
  • func (m *PyTorchJobManager) GetStatus() *tj.TrainingJobStatus
  • func (m *PyTorchJobManager) GetTJob() *tj.TrainingJob
  • func (m *PyTorchJobManager) NewJob() client.Object
• type TFJobManager
  • func NewTFJobManager(tjob *tj.TrainingJob) *TFJobManager
  • func (m *TFJobManager) GetObject() client.Object
  • func (m *TFJobManager) GetStatus() *tj.TrainingJobStatus
  • func (m *TFJobManager) GetTJob() *tj.TrainingJob
  • func (m *TFJobManager) NewJob() client.Object
• type TrainingJobReconciler
  • func (r *TrainingJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TrainingJobReconciler) SetupWithManager(mgr ctrl.Manager, enabledSchemes string) error

Variables

var (
	JobManagerBuilder = map[string]JobManagerFunc{}
	RegisteredSchemes = map[string]GetObjectFunc{}
)

Types

type GetObjectFunc

type GetObjectFunc func() client.Object

type JobManager

type JobManager interface {
	GetObject() client.Object
	NewJob() client.Object
	GetStatus() *tj.TrainingJobStatus
	GetTJob() *tj.TrainingJob
}

type JobManagerFunc

type JobManagerFunc func(tjob *tj.TrainingJob) JobManager

type PyTorchJobManager

type PyTorchJobManager struct {
	TJob *tj.TrainingJob
	Job  *kubeflowv1.PyTorchJob
}

func NewPyTorchJobManager

func NewPyTorchJobManager(tjob *tj.TrainingJob) *PyTorchJobManager

func (*PyTorchJobManager) GetObject

func (m *PyTorchJobManager) GetObject() client.Object

func (*PyTorchJobManager) GetStatus

func (m *PyTorchJobManager) GetStatus() *tj.TrainingJobStatus

func (*PyTorchJobManager) GetTJob

func (m *PyTorchJobManager) GetTJob() *tj.TrainingJob

func (*PyTorchJobManager) NewJob

func (m *PyTorchJobManager) NewJob() client.Object

type TFJobManager

type TFJobManager struct {
	TJob *tj.TrainingJob
	Job  *kubeflowv1.TFJob
}

func NewTFJobManager

func NewTFJobManager(tjob *tj.TrainingJob) *TFJobManager

func (*TFJobManager) GetObject

func (m *TFJobManager) GetObject() client.Object

func (*TFJobManager) GetStatus

func (m *TFJobManager) GetStatus() *tj.TrainingJobStatus

func (*TFJobManager) GetTJob

func (m *TFJobManager) GetTJob() *tj.TrainingJob

func (*TFJobManager) NewJob

func (m *TFJobManager) NewJob() client.Object

type TrainingJobReconciler

type TrainingJobReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
}

TrainingJobReconciler reconciles a TrainingJob object

func (*TrainingJobReconciler) Reconcile

func (r *TrainingJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.1/pkg/reconcile

func (*TrainingJobReconciler) SetupWithManager

func (r *TrainingJobReconciler) SetupWithManager(mgr ctrl.Manager, enabledSchemes string) error

SetupWithManager sets up the controller with the Manager.