v1beta4

Documentation

Index

• Constants
• func NewRequesterByPod(ctx context.Context, k8sClient client.Client, instance appsv1beta4.Emqx) (innerReq.RequesterInterface, error)
• type EmqxBrokerReconciler
  • func (r *EmqxBrokerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EmqxBrokerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EmqxEnterpriseReconciler
  • func (r *EmqxEnterpriseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EmqxEnterpriseReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EmqxPluginReconciler
  • func NewEmqxPluginReconciler(mgr manager.Manager) *EmqxPluginReconciler
  • func (r *EmqxPluginReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *EmqxPluginReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EmqxReconciler
  • func NewEmqxReconciler(mgr manager.Manager) *EmqxReconciler
  • func (r *EmqxReconciler) Do(ctx context.Context, instance appsv1beta4.Emqx) (ctrl.Result, error)
• type PodsByCreationTimestamp
  • func (o PodsByCreationTimestamp) Len() int
  • func (o PodsByCreationTimestamp) Less(i, j int) bool
  • func (o PodsByCreationTimestamp) Swap(i, j int)
• type PodsByNameNewer
  • func (o PodsByNameNewer) Len() int
  • func (o PodsByNameNewer) Less(i, j int) bool
  • func (o PodsByNameNewer) Swap(i, j int)
• type PodsByNameOlder
  • func (o PodsByNameOlder) Len() int
  • func (o PodsByNameOlder) Less(i, j int) bool
  • func (o PodsByNameOlder) Swap(i, j int)
• type StatefulSetsByCreationTimestamp
  • func (o StatefulSetsByCreationTimestamp) Len() int
  • func (o StatefulSetsByCreationTimestamp) Less(i, j int) bool
  • func (o StatefulSetsByCreationTimestamp) Swap(i, j int)
• type StatefulSetsBySizeNewer
  • func (o StatefulSetsBySizeNewer) Len() int
  • func (o StatefulSetsBySizeNewer) Less(i, j int) bool
  • func (o StatefulSetsBySizeNewer) Swap(i, j int)
• type StatefulSetsBySizeOlder
  • func (o StatefulSetsBySizeOlder) Len() int
  • func (o StatefulSetsBySizeOlder) Less(i, j int) bool
  • func (o StatefulSetsBySizeOlder) Swap(i, j int)

Constants

const EmqxContainerName string = "emqx"

const (
	ReloaderContainerName = "reloader"
)

Functions

func NewRequesterByPod

func NewRequesterByPod(ctx context.Context, k8sClient client.Client, instance appsv1beta4.Emqx) (innerReq.RequesterInterface, error)

Types

type EmqxBrokerReconciler

type EmqxBrokerReconciler struct {
	*EmqxReconciler
}

EmqxBrokerReconciler reconciles a EmqxBroker object

func (*EmqxBrokerReconciler) Reconcile

func (r *EmqxBrokerReconciler) 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.8.3/pkg/reconcile

func (*EmqxBrokerReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type EmqxEnterpriseReconciler

type EmqxEnterpriseReconciler struct {
	*EmqxReconciler
}

EmqxEnterpriseReconciler reconciles a EmqxEnterprise object

func (*EmqxEnterpriseReconciler) Reconcile

func (r *EmqxEnterpriseReconciler) 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 EmqxEnterprise 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.8.3/pkg/reconcile

func (*EmqxEnterpriseReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type EmqxPluginReconciler

type EmqxPluginReconciler struct {
	*handler.Handler
	Clientset *kubernetes.Clientset
	Config    *rest.Config
}

EmqxPluginReconciler reconciles a EmqxPlugin object

func NewEmqxPluginReconciler

func NewEmqxPluginReconciler(mgr manager.Manager) *EmqxPluginReconciler

func (*EmqxPluginReconciler) Reconcile

func (r *EmqxPluginReconciler) 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 EmqxPlugin 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.8.3/pkg/reconcile

func (*EmqxPluginReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type EmqxReconciler

type EmqxReconciler struct {
	*handler.Handler
	Clientset     *kubernetes.Clientset
	Config        *rest.Config
	Scheme        *runtime.Scheme
	EventRecorder record.EventRecorder
}

func NewEmqxReconciler

func NewEmqxReconciler(mgr manager.Manager) *EmqxReconciler

func (*EmqxReconciler) Do

func (r *EmqxReconciler) Do(ctx context.Context, instance appsv1beta4.Emqx) (ctrl.Result, error)

type PodsByCreationTimestamp

type PodsByCreationTimestamp []*corev1.Pod

PodsByCreationTimestamp sorts a list of Pod by creation timestamp, using their names as a tie breaker.

func (PodsByCreationTimestamp) Len

func (o PodsByCreationTimestamp) Len() int

func (PodsByCreationTimestamp) Less

func (o PodsByCreationTimestamp) Less(i, j int) bool

func (PodsByCreationTimestamp) Swap

func (o PodsByCreationTimestamp) Swap(i, j int)

type PodsByNameNewer

type PodsByNameNewer []*corev1.Pod

PodsByNameNewer sorts a list of Pod by size in descending order, using their creation timestamp or name as a tie breaker. By using the creation timestamp, this sorts from new to old replica sets.

func (PodsByNameNewer) Len

func (o PodsByNameNewer) Len() int

func (PodsByNameNewer) Less

func (o PodsByNameNewer) Less(i, j int) bool

func (PodsByNameNewer) Swap

func (o PodsByNameNewer) Swap(i, j int)

type PodsByNameOlder

type PodsByNameOlder []*corev1.Pod

PodsByNameOlder sorts a list of Pod by size in descending order, using their creation timestamp or name as a tie breaker. By using the creation timestamp, this sorts from old to new replica sets.

func (PodsByNameOlder) Len

func (o PodsByNameOlder) Len() int

func (PodsByNameOlder) Less

func (o PodsByNameOlder) Less(i, j int) bool

func (PodsByNameOlder) Swap

func (o PodsByNameOlder) Swap(i, j int)

type StatefulSetsByCreationTimestamp

type StatefulSetsByCreationTimestamp []*appsv1.StatefulSet

StatefulSetsByCreationTimestamp sorts a list of StatefulSet by creation timestamp, using their names as a tie breaker.

func (StatefulSetsByCreationTimestamp) Len

func (o StatefulSetsByCreationTimestamp) Len() int

func (StatefulSetsByCreationTimestamp) Less

func (o StatefulSetsByCreationTimestamp) Less(i, j int) bool

func (StatefulSetsByCreationTimestamp) Swap

func (o StatefulSetsByCreationTimestamp) Swap(i, j int)

type StatefulSetsBySizeNewer

type StatefulSetsBySizeNewer []*appsv1.StatefulSet

StatefulSetsBySizeNewer sorts a list of StatefulSet by size in descending order, using their creation timestamp or name as a tie breaker. By using the creation timestamp, this sorts from new to old replica sets.

func (StatefulSetsBySizeNewer) Len

func (o StatefulSetsBySizeNewer) Len() int

func (StatefulSetsBySizeNewer) Less

func (o StatefulSetsBySizeNewer) Less(i, j int) bool

func (StatefulSetsBySizeNewer) Swap

func (o StatefulSetsBySizeNewer) Swap(i, j int)

type StatefulSetsBySizeOlder

type StatefulSetsBySizeOlder []*appsv1.StatefulSet

StatefulSetsBySizeOlder sorts a list of StatefulSet by size in descending order, using their creation timestamp or name as a tie breaker. By using the creation timestamp, this sorts from old to new replica sets.

func (StatefulSetsBySizeOlder) Len

func (o StatefulSetsBySizeOlder) Len() int

func (StatefulSetsBySizeOlder) Less

func (o StatefulSetsBySizeOlder) Less(i, j int) bool

func (StatefulSetsBySizeOlder) Swap

func (o StatefulSetsBySizeOlder) Swap(i, j int)