controllers

func (*TFJobReconciler) DeleteJob ¶

func (r *TFJobReconciler) DeleteJob(ctx context.Context, job interface{}) error

func (*TFJobReconciler) GenLabels ¶

func (r *TFJobReconciler) GenLabels(jobName string) map[string]string

func (*TFJobReconciler) GetAIMasterPodSpec ¶

func (r *TFJobReconciler) GetAIMasterPodSpec(obj interface{}) *corev1.PodTemplateSpec

func (*TFJobReconciler) GetAPIGroupVersion ¶

func (r *TFJobReconciler) GetAPIGroupVersion() schema.GroupVersion

func (*TFJobReconciler) GetAPIGroupVersionKind ¶

func (r *TFJobReconciler) GetAPIGroupVersionKind() schema.GroupVersionKind

func (*TFJobReconciler) GetDefaultContainerName ¶

func (r *TFJobReconciler) GetDefaultContainerName() string

func (*TFJobReconciler) GetDefaultContainerPortName ¶

func (r *TFJobReconciler) GetDefaultContainerPortName() string

func (*TFJobReconciler) GetDefaultPort ¶

func (r *TFJobReconciler) GetDefaultPort() int32

func (*TFJobReconciler) GetGroupNameLabelValue ¶

func (r *TFJobReconciler) GetGroupNameLabelValue() string

func (*TFJobReconciler) GetNativeJob ¶

func (r *TFJobReconciler) GetNativeJob(
	ctx context.Context,
	namespacedName types.NamespacedName) (interface{}, error)

GetNativeJob returns the native TFJob object, or nil if not found.

func (*TFJobReconciler) PreprocessJobSpec ¶

func (r *TFJobReconciler) PreprocessJobSpec(ctx context.Context, obj interface{}) (updated bool, err error)

func (*TFJobReconciler) Reconcile ¶

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

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*TFJobReconciler) ReconcileNativeJob ¶

func (r *TFJobReconciler) ReconcileNativeJob(
	ctx context.Context,
	nativeObj interface{},
	obj interface{},
	aimasterAddr string,
	status *apicommon.JobStatus,
	logger logr.Logger) error

ReconcileNativeJob reconciles the native TFJob object.

func (*TFJobReconciler) RemoveNativeJobFinalizer ¶

func (r *TFJobReconciler) RemoveNativeJobFinalizer(ctx context.Context, obj interface{}) error

RemoveNativeJobFinalizer removes the finalizer from the native TFJob object.

func (*TFJobReconciler) SetupWithManager ¶

func (r *TFJobReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*TFJobReconciler) UpdateStatus ¶

func (r *TFJobReconciler) UpdateStatus(ctx context.Context, obj interface{}, status *apicommon.JobStatus) error

UpdateStatus updates the Status of a TFJob object.