dataload

Documentation

Index

• type CronStatusHandler
  • func (c *CronStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestContext, opStatus *datav1alpha1.OperationStatus) (result *datav1alpha1.OperationStatus, err error)
• type DataLoadReconciler
  • func NewDataLoadReconciler(client client.Client, log logr.Logger, scheme *runtime.Scheme, ...) *DataLoadReconciler
  • func (r *DataLoadReconciler) Build(object client.Object) (dataoperation.OperationInterface, error)
  • func (r *DataLoadReconciler) ControllerName() string
  • func (r *DataLoadReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DataLoadReconciler) SetupWithManager(mgr ctrl.Manager, options controller.Options) error
• type OnEventStatusHandler
  • func (o *OnEventStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestContext, opStatus *datav1alpha1.OperationStatus) (result *datav1alpha1.OperationStatus, err error)
• type OnceStatusHandler
  • func (r *OnceStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestContext, opStatus *datav1alpha1.OperationStatus) (result *datav1alpha1.OperationStatus, err error)

Types

type CronStatusHandler

type CronStatusHandler struct {
	client.Client
	// contains filtered or unexported fields
}

func (*CronStatusHandler) GetOperationStatus

func (c *CronStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestContext, opStatus *datav1alpha1.OperationStatus) (result *datav1alpha1.OperationStatus, err error)

type DataLoadReconciler

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

DataLoadReconciler reconciles a DataLoad object

func NewDataLoadReconciler

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

NewDataLoadReconciler returns a DataLoadReconciler

func (*DataLoadReconciler) Build

func (r *DataLoadReconciler) Build(object client.Object) (dataoperation.OperationInterface, error)

func (*DataLoadReconciler) ControllerName

func (r *DataLoadReconciler) ControllerName() string

func (*DataLoadReconciler) Reconcile

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

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

func (*DataLoadReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the given controller manager

type OnEventStatusHandler

type OnEventStatusHandler struct {
	client.Client
	// contains filtered or unexported fields
}

func (*OnEventStatusHandler) GetOperationStatus

func (o *OnEventStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestContext, opStatus *datav1alpha1.OperationStatus) (result *datav1alpha1.OperationStatus, err error)

type OnceStatusHandler

type OnceStatusHandler struct {
	client.Client
	// contains filtered or unexported fields
}

func (*OnceStatusHandler) GetOperationStatus

func (r *OnceStatusHandler) GetOperationStatus(ctx cruntime.ReconcileRequestContext, opStatus *datav1alpha1.OperationStatus) (result *datav1alpha1.OperationStatus, err error)