controllers

Documentation

Index

• Constants
• type DLpipeJobReconciler
  • func (r *DLpipeJobReconciler) CreateMaster(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob, placements []string) error
  • func (r *DLpipeJobReconciler) CreateWorker(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob, rank int, ...) error
  • func (r *DLpipeJobReconciler) DeleteAllPod(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob)
  • func (r *DLpipeJobReconciler) GetMasterAddr(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) (error, string)
  • func (r *DLpipeJobReconciler) IsJobFailed(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) bool
  • func (r *DLpipeJobReconciler) IsJobSucceeded(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) bool
  • func (r *DLpipeJobReconciler) IsMasterReady(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) (error, bool)
  • func (r *DLpipeJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DLpipeJobReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const HostNameKey = "kubernetes.io/hostname"

Types

type DLpipeJobReconciler

type DLpipeJobReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

DLpipeJobReconciler reconciles a DLpipeJob object

func (*DLpipeJobReconciler) CreateMaster

func (r *DLpipeJobReconciler) CreateMaster(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob, placements []string) error

func (*DLpipeJobReconciler) CreateWorker

func (r *DLpipeJobReconciler) CreateWorker(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob, rank int, placements []string) error

func (*DLpipeJobReconciler) DeleteAllPod

func (r *DLpipeJobReconciler) DeleteAllPod(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob)

func (*DLpipeJobReconciler) GetMasterAddr

func (r *DLpipeJobReconciler) GetMasterAddr(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) (error, string)

func (*DLpipeJobReconciler) IsJobFailed

func (r *DLpipeJobReconciler) IsJobFailed(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) bool

func (*DLpipeJobReconciler) IsJobSucceeded

func (r *DLpipeJobReconciler) IsJobSucceeded(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) bool

func (*DLpipeJobReconciler) IsMasterReady

func (r *DLpipeJobReconciler) IsMasterReady(ctx context.Context, dlpipeJob *v1alpha1.DLpipeJob) (error, bool)

func (*DLpipeJobReconciler) Reconcile

func (r *DLpipeJobReconciler) 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. TODO(user): Modify the Reconcile function to compare the state specified by the DLpipeJob object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

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

func (*DLpipeJobReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.