datamigrate

Documentation

Index

• type DataMigrateReconciler
  • func NewDataMigrateReconciler(client client.Client, log logr.Logger, scheme *runtime.Scheme, ...) *DataMigrateReconciler
  • func (r *DataMigrateReconciler) ControllerName() string
  • func (r *DataMigrateReconciler) GetChartsDirectory() string
  • func (r *DataMigrateReconciler) GetOperationType() dataoperation.OperationType
  • func (r *DataMigrateReconciler) GetReleaseNameSpacedName(object client.Object) types.NamespacedName
  • func (r *DataMigrateReconciler) GetTargetDataset(object client.Object) (*datav1alpha1.Dataset, error)
  • func (r *DataMigrateReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DataMigrateReconciler) RemoveTargetDatasetStatusInProgress(dataset *datav1alpha1.Dataset)
  • func (r *DataMigrateReconciler) SetTargetDatasetStatusInProgress(dataset *datav1alpha1.Dataset)
  • func (r *DataMigrateReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
  • func (r *DataMigrateReconciler) UpdateOperationApiStatus(object client.Object, opStatus *datav1alpha1.OperationStatus) error
  • func (r *DataMigrateReconciler) UpdateStatusByHelmStatus(ctx cruntime.ReconcileRequestContext, object client.Object, ...) error
  • func (r *DataMigrateReconciler) UpdateStatusInfoForCompleted(object client.Object, infos map[string]string) error
  • func (r *DataMigrateReconciler) Validate(ctx cruntime.ReconcileRequestContext, object client.Object) ([]datav1alpha1.Condition, error)

Types

type DataMigrateReconciler

type DataMigrateReconciler struct {
	Scheme *runtime.Scheme
	*controllers.OperationReconciler
}

DataMigrateReconciler reconciles a DataMigrate object

func NewDataMigrateReconciler

func NewDataMigrateReconciler(client client.Client,
	log logr.Logger,
	scheme *runtime.Scheme,
	recorder record.EventRecorder) *DataMigrateReconciler

NewDataMigrateReconciler returns a DataMigrateReconciler

func (*DataMigrateReconciler) ControllerName

func (r *DataMigrateReconciler) ControllerName() string

func (*DataMigrateReconciler) GetChartsDirectory

func (r *DataMigrateReconciler) GetChartsDirectory() string

func (*DataMigrateReconciler) GetOperationType

func (r *DataMigrateReconciler) GetOperationType() dataoperation.OperationType

func (*DataMigrateReconciler) GetReleaseNameSpacedName

func (r *DataMigrateReconciler) GetReleaseNameSpacedName(object client.Object) types.NamespacedName

func (*DataMigrateReconciler) GetTargetDataset

func (r *DataMigrateReconciler) GetTargetDataset(object client.Object) (*datav1alpha1.Dataset, error)

func (*DataMigrateReconciler) Reconcile

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

+kubebuilder:rbac:groups=data.fluid.io,resources=datamigrates,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=data.fluid.io,resources=datamigrates/status,verbs=get;update;patch Reconcile reconciles the DataMigrate object

func (*DataMigrateReconciler) RemoveTargetDatasetStatusInProgress

func (r *DataMigrateReconciler) RemoveTargetDatasetStatusInProgress(dataset *datav1alpha1.Dataset)

func (*DataMigrateReconciler) SetTargetDatasetStatusInProgress

func (r *DataMigrateReconciler) SetTargetDatasetStatusInProgress(dataset *datav1alpha1.Dataset)

func (*DataMigrateReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the given controller manager

func (*DataMigrateReconciler) UpdateOperationApiStatus

func (r *DataMigrateReconciler) UpdateOperationApiStatus(object client.Object, opStatus *datav1alpha1.OperationStatus) error

func (*DataMigrateReconciler) UpdateStatusByHelmStatus

func (r *DataMigrateReconciler) UpdateStatusByHelmStatus(ctx cruntime.ReconcileRequestContext,
	object client.Object, opStatus *datav1alpha1.OperationStatus) error

func (*DataMigrateReconciler) UpdateStatusInfoForCompleted

func (r *DataMigrateReconciler) UpdateStatusInfoForCompleted(object client.Object, infos map[string]string) error

func (*DataMigrateReconciler) Validate

func (r *DataMigrateReconciler) Validate(ctx cruntime.ReconcileRequestContext, object client.Object) ([]datav1alpha1.Condition, error)