alluxiocluster

Documentation

Index

• func ClusterReady(ctx AlluxioClusterReconcileReqCtx) bool
• func CreateAlluxioClusterIfNotExist(ctx AlluxioClusterReconcileReqCtx) error
• func DeleteAlluxioClusterIfExist(namespacedName types.NamespacedName) error
• func UpdateStatus(alluxioClusterCtx AlluxioClusterReconcileReqCtx) (ctrl.Result, error)
• type AlluxioClusterReconcileReqCtx
• type AlluxioClusterReconciler
  • func (r *AlluxioClusterReconciler) Reconcile(context context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AlluxioClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func ClusterReady

func ClusterReady(ctx AlluxioClusterReconcileReqCtx) bool

func CreateAlluxioClusterIfNotExist

func CreateAlluxioClusterIfNotExist(ctx AlluxioClusterReconcileReqCtx) error

func DeleteAlluxioClusterIfExist

func DeleteAlluxioClusterIfExist(namespacedName types.NamespacedName) error

func UpdateStatus

func UpdateStatus(alluxioClusterCtx AlluxioClusterReconcileReqCtx) (ctrl.Result, error)

Types

type AlluxioClusterReconcileReqCtx

type AlluxioClusterReconcileReqCtx struct {
	*alluxiov1alpha1.AlluxioCluster
	client.Client
	context.Context
	*alluxiov1alpha1.Dataset
	types.NamespacedName
}

type AlluxioClusterReconciler

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

AlluxioClusterReconciler reconciles a AlluxioCluster object

func (*AlluxioClusterReconciler) Reconcile

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

func (*AlluxioClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.