controllers

package
v0.0.0-...-8aa1181 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 27, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL