controller

Documentation

Index

• func SetupControllers(mgr ctrl.Manager, runtimes map[string]runtime.Runtime, ...) (string, error)
• type ClusterTrainingRuntimeReconciler
  • func NewClusterTrainingRuntimeReconciler(cli client.Client, recorder record.EventRecorder) *ClusterTrainingRuntimeReconciler
  • func (r *ClusterTrainingRuntimeReconciler) NotifyTrainJobUpdate(oldJob, newJob *trainer.TrainJob)
  • func (r *ClusterTrainingRuntimeReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterTrainingRuntimeReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
• type TrainJobReconciler
  • func NewTrainJobReconciler(client client.Client, recorder record.EventRecorder, ...) *TrainJobReconciler
  • func (r *TrainJobReconciler) Create(e event.TypedCreateEvent[*trainer.TrainJob]) bool
  • func (r *TrainJobReconciler) Delete(e event.TypedDeleteEvent[*trainer.TrainJob]) bool
  • func (r *TrainJobReconciler) Generic(e event.TypedGenericEvent[*trainer.TrainJob]) bool
  • func (r *TrainJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TrainJobReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
  • func (r *TrainJobReconciler) Update(e event.TypedUpdateEvent[*trainer.TrainJob]) bool
• type TrainJobReconcilerOption
  • func WithWatchers(watchers ...TrainJobWatcher) TrainJobReconcilerOption
• type TrainJobReconcilerOptions
• type TrainJobWatcher
• type TrainingRuntimeReconciler
  • func NewTrainingRuntimeReconciler(cli client.Client, recorder record.EventRecorder) *TrainingRuntimeReconciler
  • func (r *TrainingRuntimeReconciler) NotifyTrainJobUpdate(oldJob, newJob *trainer.TrainJob)
  • func (r *TrainingRuntimeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TrainingRuntimeReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

Functions

func SetupControllers

func SetupControllers(mgr ctrl.Manager, runtimes map[string]runtime.Runtime, options controller.Options) (string, error)

Types

type ClusterTrainingRuntimeReconciler

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

func NewClusterTrainingRuntimeReconciler

func NewClusterTrainingRuntimeReconciler(cli client.Client, recorder record.EventRecorder) *ClusterTrainingRuntimeReconciler

func (*ClusterTrainingRuntimeReconciler) NotifyTrainJobUpdate

func (r *ClusterTrainingRuntimeReconciler) NotifyTrainJobUpdate(oldJob, newJob *trainer.TrainJob)

func (*ClusterTrainingRuntimeReconciler) Reconcile

func (r *ClusterTrainingRuntimeReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*ClusterTrainingRuntimeReconciler) SetupWithManager

func (r *ClusterTrainingRuntimeReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

type TrainJobReconciler

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

func NewTrainJobReconciler

func NewTrainJobReconciler(client client.Client, recorder record.EventRecorder, runtimes map[string]jobruntimes.Runtime, opts ...TrainJobReconcilerOption) *TrainJobReconciler

func (*TrainJobReconciler) Create

func (r *TrainJobReconciler) Create(e event.TypedCreateEvent[*trainer.TrainJob]) bool

func (*TrainJobReconciler) Delete

func (r *TrainJobReconciler) Delete(e event.TypedDeleteEvent[*trainer.TrainJob]) bool

func (*TrainJobReconciler) Generic

func (r *TrainJobReconciler) Generic(e event.TypedGenericEvent[*trainer.TrainJob]) bool

func (*TrainJobReconciler) Reconcile

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

func (*TrainJobReconciler) SetupWithManager

func (r *TrainJobReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error

func (*TrainJobReconciler) Update

func (r *TrainJobReconciler) Update(e event.TypedUpdateEvent[*trainer.TrainJob]) bool

type TrainJobReconcilerOption

type TrainJobReconcilerOption func(*TrainJobReconcilerOptions)

func WithWatchers

func WithWatchers(watchers ...TrainJobWatcher) TrainJobReconcilerOption

type TrainJobReconcilerOptions

type TrainJobReconcilerOptions struct {
	Watchers iter.Seq[TrainJobWatcher]
}

type TrainJobWatcher

type TrainJobWatcher interface {
	NotifyTrainJobUpdate(oldJob, newJob *trainer.TrainJob)
}

type TrainingRuntimeReconciler

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

func NewTrainingRuntimeReconciler

func NewTrainingRuntimeReconciler(cli client.Client, recorder record.EventRecorder) *TrainingRuntimeReconciler

func (*TrainingRuntimeReconciler) NotifyTrainJobUpdate

func (r *TrainingRuntimeReconciler) NotifyTrainJobUpdate(oldJob, newJob *trainer.TrainJob)

func (*TrainingRuntimeReconciler) Reconcile

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

func (*TrainingRuntimeReconciler) SetupWithManager

func (r *TrainingRuntimeReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error