dataload

Documentation

Overview

Copyright 2021 The Fluid Authors.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type DataLoadReconciler
  • func NewDataLoadReconciler(client client.Client, log logr.Logger, scheme *runtime.Scheme, ...) *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(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *DataLoadReconciler) SetupWithManager(mgr ctrl.Manager) error
• type DataLoadReconcilerImplement
  • func NewDataLoadReconcilerImplement(client client.Client, log logr.Logger, recorder record.EventRecorder) *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)

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

func (r *DataLoadReconciler) AddOwnerAndRequeue(ctx cruntime.ReconcileRequestContext, targetDataLoad datav1alpha1.DataLoad, targetDataset *datav1alpha1.Dataset) (ctrl.Result, error)

AddOwnerAndRequeue adds Owner and requeue

func (*DataLoadReconciler) GetOrCreateEngine

func (r *DataLoadReconciler) GetOrCreateEngine(
	ctx cruntime.ReconcileRequestContext) (engine base.Engine, err error)

GetOrCreateEngine gets the Engine

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) error

SetupWithManager sets up the controller with the given controller manager

type DataLoadReconcilerImplement

type DataLoadReconcilerImplement struct {
	client.Client
	Log      logr.Logger
	Recorder record.EventRecorder
}

DataLoadReconcilerImplement implements the actual reconciliation logic of DataLoadReconciler

func NewDataLoadReconcilerImplement

func NewDataLoadReconcilerImplement(client client.Client, log logr.Logger, recorder record.EventRecorder) *DataLoadReconcilerImplement

NewDataLoadReconcilerImplement returns a DataLoadReconcilerImplement

func (*DataLoadReconcilerImplement) ReconcileDataLoad

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

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