Documentation
¶
Index ¶
- Constants
- func NewRequesterByPod(ctx context.Context, k8sClient client.Client, instance appsv1beta4.Emqx) (innerReq.RequesterInterface, error)
- type EmqxBrokerReconciler
- type EmqxEnterpriseReconciler
- type EmqxPluginReconciler
- type EmqxReconciler
- type PodsByCreationTimestamp
- type PodsByNameNewer
- type PodsByNameOlder
- type StatefulSetsByCreationTimestamp
- type StatefulSetsBySizeNewer
- type StatefulSetsBySizeOlder
Constants ¶
const EmqxContainerName string = "emqx"
const (
ReloaderContainerName = "reloader"
)
Variables ¶
This section is empty.
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 ¶
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 ¶
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 ¶
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)
Source Files
¶
- add_emqx_bootstrap_user.go
- add_emqx_plugins.go
- add_emqx_resources.go
- add_emqx_statefulset.go
- add_listener.go
- emqx_controller.go
- emqxbroker_controller.go
- emqxenterprise_controller.go
- emqxplugin_controller.go
- generated.go
- statefulset.go
- statefulset_util.go
- update_emqx_status.go
- update_pod_conditions.go