core

Documentation

Index

• Variables
• func New(ctx context.Context, client client.Client, indexer client.FieldIndexer) (map[string]runtime.Runtime, error)
• func NewClusterTrainingRuntime(context.Context, client.Client, client.FieldIndexer) (runtime.Runtime, error)
• func NewTrainingRuntime(ctx context.Context, c client.Client, indexer client.FieldIndexer) (runtime.Runtime, error)
• type ClusterTrainingRuntime
  • func (r *ClusterTrainingRuntime) EventHandlerRegistrars() []runtime.ReconcilerBuilder
  • func (r *ClusterTrainingRuntime) NewObjects(ctx context.Context, trainJob *kubeflowv2.TrainJob) ([]client.Object, error)
  • func (r *ClusterTrainingRuntime) TerminalCondition(ctx context.Context, trainJob *kubeflowv2.TrainJob) (*metav1.Condition, error)
  • func (r *ClusterTrainingRuntime) ValidateObjects(ctx context.Context, old, new *kubeflowv2.TrainJob) (admission.Warnings, field.ErrorList)
• type Registry
  • func NewRuntimeRegistry() Registry
• type TrainingRuntime
  • func (r *TrainingRuntime) EventHandlerRegistrars() []runtime.ReconcilerBuilder
  • func (r *TrainingRuntime) NewObjects(ctx context.Context, trainJob *kubeflowv2.TrainJob) ([]client.Object, error)
  • func (r *TrainingRuntime) TerminalCondition(ctx context.Context, trainJob *kubeflowv2.TrainJob) (*metav1.Condition, error)
  • func (r *TrainingRuntime) ValidateObjects(ctx context.Context, old, new *kubeflowv2.TrainJob) (admission.Warnings, field.ErrorList)

Variables

var ClusterTrainingRuntimeGroupKind = schema.GroupKind{
	Group: kubeflowv2.GroupVersion.Group,
	Kind:  kubeflowv2.ClusterTrainingRuntimeKind,
}.String()

var TrainingRuntimeGroupKind = schema.GroupKind{
	Group: kubeflowv2.GroupVersion.Group,
	Kind:  kubeflowv2.TrainingRuntimeKind,
}.String()

Functions

func New

func New(ctx context.Context, client client.Client, indexer client.FieldIndexer) (map[string]runtime.Runtime, error)

func NewClusterTrainingRuntime

func NewClusterTrainingRuntime(context.Context, client.Client, client.FieldIndexer) (runtime.Runtime, error)

func NewTrainingRuntime

func NewTrainingRuntime(ctx context.Context, c client.Client, indexer client.FieldIndexer) (runtime.Runtime, error)

Types

type ClusterTrainingRuntime

type ClusterTrainingRuntime struct {
	*TrainingRuntime
}

func (*ClusterTrainingRuntime) EventHandlerRegistrars

func (r *ClusterTrainingRuntime) EventHandlerRegistrars() []runtime.ReconcilerBuilder

func (*ClusterTrainingRuntime) NewObjects

func (r *ClusterTrainingRuntime) NewObjects(ctx context.Context, trainJob *kubeflowv2.TrainJob) ([]client.Object, error)

func (*ClusterTrainingRuntime) TerminalCondition

func (r *ClusterTrainingRuntime) TerminalCondition(ctx context.Context, trainJob *kubeflowv2.TrainJob) (*metav1.Condition, error)

func (*ClusterTrainingRuntime) ValidateObjects

func (r *ClusterTrainingRuntime) ValidateObjects(ctx context.Context, old, new *kubeflowv2.TrainJob) (admission.Warnings, field.ErrorList)

type Registry

type Registry map[string]func(ctx context.Context, client client.Client, indexer client.FieldIndexer) (runtime.Runtime, error)

func NewRuntimeRegistry

func NewRuntimeRegistry() Registry

type TrainingRuntime

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

func (*TrainingRuntime) EventHandlerRegistrars

func (r *TrainingRuntime) EventHandlerRegistrars() []runtime.ReconcilerBuilder

func (*TrainingRuntime) NewObjects

func (r *TrainingRuntime) NewObjects(ctx context.Context, trainJob *kubeflowv2.TrainJob) ([]client.Object, error)

func (*TrainingRuntime) TerminalCondition

func (r *TrainingRuntime) TerminalCondition(ctx context.Context, trainJob *kubeflowv2.TrainJob) (*metav1.Condition, error)

func (*TrainingRuntime) ValidateObjects

func (r *TrainingRuntime) ValidateObjects(ctx context.Context, old, new *kubeflowv2.TrainJob) (admission.Warnings, field.ErrorList)