controllers

Documentation

Index

• Constants
• type ClusterController
  • func NewClusterContoller(ctx *cluster.Context, operatorImage string) *ClusterController
  • func (c *ClusterController) UpdateStatus(state *topolvmv1.NodeStorageState) error
• type ConfigMapController
  • func NewConfigMapController(context *cluster.Context, namespace string, ref *metav1.OwnerReference, ...) *ConfigMapController
  • func (c *ConfigMapController) StartWatch(stopCh <-chan struct{})
  • func (c *ConfigMapController) UpdateRef(ref *metav1.OwnerReference)
• type PrePareVg
  • func NewPrepareVgController(nodeName string, nameSpace string, context *cluster.Context) *PrePareVg
  • func (c *PrePareVg) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (c *PrePareVg) SetupWithManager(mgr ctrl.Manager) error
• type TopolvmClusterReconciler
  • func NewTopolvmClusterReconciler(scheme *runtime.Scheme, context *cluster.Context, operatorImage string) *TopolvmClusterReconciler
  • func (r *TopolvmClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *TopolvmClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	ClassExpandWaring     = "expand warning"
	ClassExpandError      = "expand error"
	ClassCreateSuccessful = "create successful"
	ClassCreateFail       = "create failed"
	DeviceStateError      = "error"
)

Types

type ClusterController

type ClusterController struct {
	// contains filtered or unexported fields
}

ClusterController controls an instance of a topolvm cluster

func NewClusterContoller

func NewClusterContoller(ctx *cluster.Context, operatorImage string) *ClusterController

func (*ClusterController) UpdateStatus

func (c *ClusterController) UpdateStatus(state *topolvmv1.NodeStorageState) error

type ConfigMapController

type ConfigMapController struct {
	// contains filtered or unexported fields
}

func NewConfigMapController

func NewConfigMapController(context *cluster.Context, namespace string, ref *metav1.OwnerReference, controller *ClusterController) *ConfigMapController

NewClientController create controller for watching client custom resources created

func (*ConfigMapController) StartWatch

func (c *ConfigMapController) StartWatch(stopCh <-chan struct{})

Watch watches for instances of Client custom resources and acts on them

func (*ConfigMapController) UpdateRef

func (c *ConfigMapController) UpdateRef(ref *metav1.OwnerReference)

type PrePareVg

type PrePareVg struct {
	// contains filtered or unexported fields
}

func NewPrepareVgController

func NewPrepareVgController(nodeName string, nameSpace string, context *cluster.Context) *PrePareVg

func (*PrePareVg) Reconcile

func (c *PrePareVg) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*PrePareVg) SetupWithManager

func (c *PrePareVg) SetupWithManager(mgr ctrl.Manager) error

type TopolvmClusterReconciler

type TopolvmClusterReconciler struct {
	// contains filtered or unexported fields
}

TopolvmClusterReconciler reconciles a TopolvmCluster object

func NewTopolvmClusterReconciler

func NewTopolvmClusterReconciler(scheme *runtime.Scheme, context *cluster.Context, operatorImage string) *TopolvmClusterReconciler

func (*TopolvmClusterReconciler) Reconcile

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

func (*TopolvmClusterReconciler) SetupWithManager

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