nebulacluster

Documentation

Index

• Constants
• type ClusterConditionUpdater
  • func NewClusterConditionUpdater() ClusterConditionUpdater
• type ClusterReconciler
  • func NewClusterReconciler(mgr ctrl.Manager, enableKruise bool) (*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(client client.Client, nebulaClient kube.NebulaCluster, ...) ControlInterface
• type FakeClusterControl
  • func NewFakeClusterControl() *FakeClusterControl
  • func (f *FakeClusterControl) SetUpdateNebulaClusterError(err error)
  • func (f *FakeClusterControl) UpdateNebulaCluster(_ *v1alpha1.NebulaCluster) error

Constants

const (
	KruiseReferenceName = "statefulsets.apps.kruise.io"
)

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
	EnableKruise bool
}

ClusterReconciler reconciles a NebulaCluster object

func NewClusterReconciler

func NewClusterReconciler(mgr ctrl.Manager, enableKruise bool) (*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(
	client client.Client,
	nebulaClient kube.NebulaCluster,
	graphdCluster component.ReconcileManager,
	metadCluster component.ReconcileManager,
	storagedCluster component.ReconcileManager,
	exporter component.ReconcileManager,
	console 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