clustercontroller

package
v0.0.0-...-1b11d85 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 20, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewServerLogging 

func NewServerLogging(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg any,
	logDataBuilder common.RoleLoggingDataBuilder,
	role common.Role,
) *common.LoggingRecociler

Types

type ClusterReconciler 

type ClusterReconciler struct {
	Log logr.Logger
	// contains filtered or unexported fields
}

func NewClusterReconciler 

func NewClusterReconciler(client client.Client, scheme *runtime.Scheme, cr *stackv1alpha1.ZookeeperCluster) *ClusterReconciler

func (*ClusterReconciler) ReconcileCluster 

func (c *ClusterReconciler) ReconcileCluster(ctx context.Context) (ctrl.Result, error)

func (*ClusterReconciler) RegisterResource 

func (c *ClusterReconciler) RegisterResource()

func (*ClusterReconciler) RegisterRole 

func (c *ClusterReconciler) RegisterRole()

RegisterRole register role reconciler

type ConfigMapReconciler 

type ConfigMapReconciler struct {
	common.MultiConfigurationStyleReconciler[*zkv1alpha1.ZookeeperCluster, *zkv1alpha1.RoleGroupSpec]
}

ConfigMapReconciler create configmap for zookeeper servers(zoo.cfg, logback.xml) create configmap for zookeeper script

func NewConfigMap 

func NewConfigMap(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *zkv1alpha1.RoleGroupSpec,
) *ConfigMapReconciler

NewConfigMap new a ConfigMapReconcile

func (*ConfigMapReconciler) Build 

func (c *ConfigMapReconciler) Build(_ context.Context) ([]common.ResourceBuilder, error)

Build implements the MultiResourceReconcilerBuilder interface

type LogDataBuilder 

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

func (*LogDataBuilder) MakeConsoleAppenderData 

func (c *LogDataBuilder) MakeConsoleAppenderData(consoleLevel *zkv1alpha1.LogLevelSpec) string

func (*LogDataBuilder) MakeContainerLogData 

func (c *LogDataBuilder) MakeContainerLogData() map[string]string

MakeContainerLogData MakeContainerLog4jData implement RoleLoggingDataBuilder

func (*LogDataBuilder) MakeCustomLogData 

func (c *LogDataBuilder) MakeCustomLogData(loggers map[string]*zkv1alpha1.LogLevelSpec) string

func (*LogDataBuilder) MakeFileAppenderData 

func (c *LogDataBuilder) MakeFileAppenderData(fileLevel *zkv1alpha1.LogLevelSpec) string

func (*LogDataBuilder) MakeLogbackData 

func (c *LogDataBuilder) MakeLogbackData(logSpec *zkv1alpha1.LoggingConfigSpec) string

type Role 

type Role struct {
	common.BaseRoleReconciler[*zkv1alpha1.ZookeeperCluster]
}

func NewRoleServer 

func NewRoleServer(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	log logr.Logger) *Role

NewRoleServer new roleMaster

func (*Role) MergeLabels 

func (r *Role) MergeLabels() map[string]string

func (*Role) ReconcileRole 

func (r *Role) ReconcileRole(ctx context.Context) (ctrl.Result, error)

func (*Role) RoleName 

func (r *Role) RoleName() common.Role

type RoleGroup 

type RoleGroup struct {
	common.BaseRoleGroupReconciler[*zkv1alpha1.ZookeeperCluster]
}

RoleGroup master role group reconcile

func NewRoleGroupReconciler 

func NewRoleGroupReconciler(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	groupName string,
	roleLabels map[string]string,
	log logr.Logger) *RoleGroup

func (*RoleGroup) MergeGroupConfigSpec 

func (m *RoleGroup) MergeGroupConfigSpec() any

func (*RoleGroup) MergeLabels 

func (m *RoleGroup) MergeLabels(mergedCfg any) map[string]string

func (*RoleGroup) RegisterResource 

func (m *RoleGroup) RegisterResource()

type ServiceAccountReconciler 

type ServiceAccountReconciler struct {
	common.GeneralResourceStyleReconciler[*zkv1alpha1.ZookeeperCluster, *zkv1alpha1.RoleGroupSpec]
}

func NewServiceAccount 

func NewServiceAccount(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *zkv1alpha1.RoleGroupSpec,
) *ServiceAccountReconciler

NewServiceAccount new a ServiceAccountReconciler

func (*ServiceAccountReconciler) Build 

func (r *ServiceAccountReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

type ServiceHeadlessReconciler 

type ServiceHeadlessReconciler struct {
	common.GeneralResourceStyleReconciler[*zkv1alpha1.ZookeeperCluster, *zkv1alpha1.RoleGroupSpec]
}

func NewServiceHeadless 

func NewServiceHeadless(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *zkv1alpha1.RoleGroupSpec,
) *ServiceHeadlessReconciler

NewServiceHeadless new a ServiceHeadlessReconciler

func (*ServiceHeadlessReconciler) Build 

func (r *ServiceHeadlessReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

type ServiceReconciler 

type ServiceReconciler struct {
	common.GeneralResourceStyleReconciler[*zkv1alpha1.ZookeeperCluster, *zkv1alpha1.RoleGroupSpec]
}

ServiceReconciler cluster service reconcile

func NewClusterService 

func NewClusterService(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *zkv1alpha1.RoleGroupSpec,
) *ServiceReconciler

NewClusterService new a ServiceHeadlessReconciler

func (*ServiceReconciler) Build 

func (r *ServiceReconciler) Build(_ context.Context) (client.Object, error)

Build implements the ResourceBuilder interface

type StatefulSetReconciler 

type StatefulSetReconciler struct {
	common.WorkloadStyleReconciler[*zkv1alpha1.ZookeeperCluster, *zkv1alpha1.RoleGroupSpec]
}

func NewStatefulSet 

func NewStatefulSet(
	scheme *runtime.Scheme,
	instance *zkv1alpha1.ZookeeperCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *zkv1alpha1.RoleGroupSpec,
	replicate int32,
) *StatefulSetReconciler

NewStatefulSet new a StatefulSetReconciler

func (*StatefulSetReconciler) Build 

func (s *StatefulSetReconciler) Build(_ context.Context) (client.Object, error)

Build implement the ResourceBuilder interface

func (*StatefulSetReconciler) CommandOverride 

func (s *StatefulSetReconciler) CommandOverride(resource client.Object)

CommandOverride implement the WorkloadOverride interface

func (*StatefulSetReconciler) EnvOverride 

func (s *StatefulSetReconciler) EnvOverride(resource client.Object)

EnvOverride implement the WorkloadOverride interface

func (*StatefulSetReconciler) GetConditions 

func (s *StatefulSetReconciler) GetConditions() *[]metav1.Condition

GetConditions implement the ConditionGetter interface

func (*StatefulSetReconciler) LogOverride 

func (s *StatefulSetReconciler) LogOverride(resource client.Object)

LogOverride implement the WorkloadOverride interface

type ZookeeperClusterReconciler 

type ZookeeperClusterReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Log    logr.Logger
}

ZookeeperClusterReconciler reconciles a ZookeeperCluster object

func (*ZookeeperClusterReconciler) Reconcile 

func (r *ZookeeperClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

- https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.15.0/pkg/reconcile

func (*ZookeeperClusterReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

func (*ZookeeperClusterReconciler) UpdateStatus 

func (r *ZookeeperClusterReconciler) UpdateStatus(ctx context.Context, instance *zkv1alpha1.ZookeeperCluster) error

UpdateStatus updates the status of the ZookeeperCluster resource https://stackoverflow.com/questions/76388004/k8s-controller-update-status-and-condition

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.