Documentation
¶
Index ¶
- type DataLoadReconciler
- func (r *DataLoadReconciler) AddOwnerAndRequeue(ctx cruntime.ReconcileRequestContext, targetDataLoad datav1alpha1.DataLoad, ...) (ctrl.Result, error)
- func (r *DataLoadReconciler) GetOrCreateEngine(ctx cruntime.ReconcileRequestContext) (engine base.Engine, err error)
- func (r *DataLoadReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
- func (r *DataLoadReconciler) SetupWithManager(mgr ctrl.Manager) error
- type DataLoadReconcilerImplement
- func (r *DataLoadReconcilerImplement) ReconcileDataLoad(ctx cruntime.ReconcileRequestContext, targetDataload datav1alpha1.DataLoad, ...) (ctrl.Result, error)
- func (r *DataLoadReconcilerImplement) ReconcileDataLoadDeletion(ctx cruntime.ReconcileRequestContext, targetDataload datav1alpha1.DataLoad, ...) (ctrl.Result, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataLoadReconciler ¶
type DataLoadReconciler struct {
Scheme *runtime.Scheme
*DataLoadReconcilerImplement
// contains filtered or unexported fields
}
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) AddOwnerAndRequeue ¶ added in v0.5.0
func (r *DataLoadReconciler) AddOwnerAndRequeue(ctx cruntime.ReconcileRequestContext, targetDataLoad datav1alpha1.DataLoad, targetDataset *datav1alpha1.Dataset) (ctrl.Result, error)
AddOwnerAndRequeue adds Owner and requeue
func (*DataLoadReconciler) GetOrCreateEngine ¶ added in v0.6.0
func (r *DataLoadReconciler) GetOrCreateEngine( ctx cruntime.ReconcileRequestContext) (engine base.Engine, err error)
GetOrCreateEngine gets the Engine
func (*DataLoadReconciler) Reconcile ¶
+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) error
SetupWithManager sets up the controller with the given controller manager
type DataLoadReconcilerImplement ¶ added in v0.4.0
type DataLoadReconcilerImplement struct {
client.Client
Log logr.Logger
Recorder record.EventRecorder
}
DataLoadReconcilerImplement implements the actual reconciliation logic of DataLoadReconciler
func NewDataLoadReconcilerImplement ¶ added in v0.4.0
func NewDataLoadReconcilerImplement(client client.Client, log logr.Logger, recorder record.EventRecorder) *DataLoadReconcilerImplement
NewDataLoadReconcilerImplement returns a DataLoadReconcilerImplement
func (*DataLoadReconcilerImplement) ReconcileDataLoad ¶ added in v0.4.0
func (r *DataLoadReconcilerImplement) ReconcileDataLoad(ctx cruntime.ReconcileRequestContext, targetDataload datav1alpha1.DataLoad, engine base.Engine) (ctrl.Result, error)
ReconcileDataLoad reconciles the DataLoad according to its phase status
func (*DataLoadReconcilerImplement) ReconcileDataLoadDeletion ¶ added in v0.4.0
func (r *DataLoadReconcilerImplement) ReconcileDataLoadDeletion(ctx cruntime.ReconcileRequestContext, targetDataload datav1alpha1.DataLoad, engines map[string]base.Engine, mutex *sync.Mutex) (ctrl.Result, error)
ReconcileDataLoadDeletion reconciles the deletion of the DataLoad
Source Files