cluster

Documentation

Index

• func NewClusterRoleBindingReconciler(client client.Client, lables map[string]string) reconciler.ResourceReconciler[*builder.GenericRoleBindingBuilder]
• func NewClusterServiceReconciler(client *client.Client, option reconciler.ClusterInfo, ...) *reconciler.Service
• func NewServiceAccountReconciler(client client.Client, lables map[string]string) reconciler.ResourceReconciler[*builder.GenericServiceAccountBuilder]
• type Reconciler
  • func NewClusterReconciler(client *client.Client, clusterInfo reconciler.ClusterInfo, ...) *Reconciler
  • func (r *Reconciler) GetImage() *util.Image
  • func (r *Reconciler) RegisterResources(ctx context.Context) error

Functions

func NewClusterRoleBindingReconciler

func NewClusterRoleBindingReconciler(
	client client.Client,
	lables map[string]string,
) reconciler.ResourceReconciler[*builder.GenericRoleBindingBuilder]

enable this if cluster role is provided by adminitrator, and name must be "zookeeper-clusterrole"

func NewClusterServiceReconciler

func NewClusterServiceReconciler(
	client *client.Client,
	option reconciler.ClusterInfo,
	listenerClass constants.ListenerClass,
	zkSecurity *security.ZookeeperSecurity,
) *reconciler.Service

func NewServiceAccountReconciler

func NewServiceAccountReconciler(
	client client.Client,
	lables map[string]string,
) reconciler.ResourceReconciler[*builder.GenericServiceAccountBuilder]

Types

type Reconciler

type Reconciler struct {
	reconciler.BaseCluster[*zkv1alpha1.ZookeeperClusterSpec]
	ClusterConfig *zkv1alpha1.ClusterConfigSpec
}

func NewClusterReconciler

func NewClusterReconciler(
	client *client.Client,
	clusterInfo reconciler.ClusterInfo,
	spec *zkv1alpha1.ZookeeperClusterSpec,
) *Reconciler

func (*Reconciler) GetImage

func (r *Reconciler) GetImage() *util.Image

func (*Reconciler) RegisterResources

func (r *Reconciler) RegisterResources(ctx context.Context) error