nebulacluster

Documentation

Index

• Variables
• type ClusterConditionUpdater
  • func NewClusterConditionUpdater() ClusterConditionUpdater
• type ClusterReconciler
  • func NewClusterReconciler(mgr ctrl.Manager) (*ClusterReconciler, error)
  • func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res reconcile.Result, retErr error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager, opts controller.Options) error
• type ControlInterface
  • func NewDefaultNebulaClusterControl(nebulaClient kube.NebulaCluster, graphdCluster component.ReconcileManager, ...) ControlInterface
• type FakeClusterControl
  • func NewFakeClusterControl() *FakeClusterControl
  • func (f *FakeClusterControl) SetUpdateNebulaClusterError(err error)
  • func (f *FakeClusterControl) UpdateNebulaCluster(_ *v1alpha1.NebulaCluster) error

Variables

var ReconcileWaitResult = reconcile.Result{RequeueAfter: reconcileTimeOut}

Types

type ClusterConditionUpdater

type ClusterConditionUpdater interface {
	Update(cluster *v1alpha1.NebulaCluster)
}

func NewClusterConditionUpdater

func NewClusterConditionUpdater() ClusterConditionUpdater

type ClusterReconciler

type ClusterReconciler struct {
	Control ControlInterface
	client.Client
	Log    logr.Logger
	Scheme *runtime.Scheme
}

ClusterReconciler reconciles a NebulaCluster object

func NewClusterReconciler

func NewClusterReconciler(mgr ctrl.Manager) (*ClusterReconciler, error)

func (*ClusterReconciler) Reconcile

func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res reconcile.Result, retErr error)

func (*ClusterReconciler) SetupWithManager

func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager, opts controller.Options) error

SetupWithManager sets up the controller with the Manager.

type ControlInterface

type ControlInterface interface {
	UpdateNebulaCluster(cluster *v1alpha1.NebulaCluster) error
}

func NewDefaultNebulaClusterControl

func NewDefaultNebulaClusterControl(
	nebulaClient kube.NebulaCluster,
	graphdCluster component.ReconcileManager,
	metadCluster component.ReconcileManager,
	storagedCluster component.ReconcileManager,
	metaReconciler component.ReconcileManager,
	pvcReclaimer reclaimer.PVCReclaimer,
	conditionUpdater ClusterConditionUpdater) ControlInterface

type FakeClusterControl

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

func NewFakeClusterControl

func NewFakeClusterControl() *FakeClusterControl

func (*FakeClusterControl) SetUpdateNebulaClusterError

func (f *FakeClusterControl) SetUpdateNebulaClusterError(err error)

func (*FakeClusterControl) UpdateNebulaCluster

func (f *FakeClusterControl) UpdateNebulaCluster(_ *v1alpha1.NebulaCluster) error