apps

Documentation

Index

• type EmqxBrokerReconciler
  • func NewEmqxBrokerReconciler(mgr manager.Manager) *EmqxBrokerReconciler
  • func (r *EmqxBrokerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EmqxEnterpriseReconciler
  • func NewEmqxEnterpriseReconciler(mgr manager.Manager) *EmqxEnterpriseReconciler
  • func (r *EmqxEnterpriseReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EmqxHandler
• type Handler
  • func NewHandler(mgr mgr.Manager) *Handler
  • func (handler *Handler) Do(emqx v1beta2.Emqx) error
  • func (handler *Handler) Ensure(emqx v1beta2.Emqx) error
  • func (handler *Handler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Types

type EmqxBrokerReconciler

type EmqxBrokerReconciler struct {
	Handler
}

EmqxBrokerReconciler reconciles a EmqxBroker object

func NewEmqxBrokerReconciler

func NewEmqxBrokerReconciler(mgr manager.Manager) *EmqxBrokerReconciler

func (*EmqxBrokerReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type EmqxEnterpriseReconciler

type EmqxEnterpriseReconciler struct {
	Handler
}

EmqxEnterpriseReconciler reconciles a EmqxEnterprise object

func NewEmqxEnterpriseReconciler

func NewEmqxEnterpriseReconciler(mgr manager.Manager) *EmqxEnterpriseReconciler

func (*EmqxEnterpriseReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type EmqxHandler

type EmqxHandler interface {
	Do(emqx v1beta2.Emqx) error
	Ensure(emqx v1beta2.Emqx, labels map[string]string, ownerRefs []metav1.OwnerReference) error
	Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
}

type Handler

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

func NewHandler

func NewHandler(mgr mgr.Manager) *Handler

func (*Handler) Do

func (handler *Handler) Do(emqx v1beta2.Emqx) error

Do will ensure the EMQX Cluster is in the expected state and update the EMQX Cluster status.

func (*Handler) Ensure

func (handler *Handler) Ensure(emqx v1beta2.Emqx) error

func (*Handler) Reconcile

func (handler *Handler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the EmqxBroker object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.9.2/pkg/reconcile