server

Documentation

Index

• Constants
• func ExtendConfigMapByVector(ctx context.Context, params VectorConfigParams, data map[string]string)
• func ExtendWorkloadByVector(image *util.Image, dep *appsv1.StatefulSet, vectorConfigMapName string)
• func IsVectorEnable(roleLoggingConfig *commonsv1alpha1.LoggingSpec) bool
• func NewConfigMapBuilder(ctx context.Context, roleGroupInfo *reconciler.RoleGroupInfo, ...) *builder.ConfigMapBuilder
• func NewConfigMapReconciler(ctx context.Context, client *client.Client, repilicates *int32, ...) reconciler.ResourceReconciler[*builder.ConfigMapBuilder]
• func NewServiceReconciler(client *client.Client, option *reconciler.RoleGroupInfo, ...) *reconciler.Service
• func NewStatefulsetReconciler(client *client.Client, roleGroupInfo *reconciler.RoleGroupInfo, ...) (reconciler.ResourceReconciler[builder.StatefulSetBuilder], error)
• type ConfigGenerator
• type Reconciler
  • func NewReconciler(client *client.Client, roleInfo reconciler.RoleInfo, ...) *Reconciler
  • func (r *Reconciler) RegisterResourceWithRoleGroup(ctx context.Context, info *reconciler.RoleGroupInfo, repilicates *int32, ...) ([]reconciler.Reconciler, error)
  • func (r *Reconciler) RegisterResources(ctx context.Context) error
• type ServiceBuilder
  • func (b *ServiceBuilder) Build(_ context.Context) (ctrlclient.Object, error)
• type StatefulsetBuilder
  • func NewStatefulSetBuilder(client *client.Client, name string, ...) *StatefulsetBuilder
  • func (b *StatefulsetBuilder) Build(ctx context.Context) (ctrlClient.Object, error)
  • func (b *StatefulsetBuilder) GetReadinessProbe() *corev1.Probe
• type VectorConfigParams

Constants

const (
	ConsoleConversionPattern = "%d{ISO8601} [myid:%X{myid}] - %-5p [%t:%C{1}@%L] - %m%n"
	LogbackConfigFileName    = "logback.xml"
)

const ContainerVector = "vector"

Functions

func ExtendConfigMapByVector

func ExtendConfigMapByVector(ctx context.Context, params VectorConfigParams, data map[string]string)

func ExtendWorkloadByVector

func ExtendWorkloadByVector(
	image *util.Image,
	dep *appsv1.StatefulSet,
	vectorConfigMapName string)

ExtendWorkloadByVector extends a StatefulSet by adding a vector container, a vector config volume and a vector data volume. It also mounts the vector data volume to the vector container. The vector container is added to the StatefulSet's template. The vector config volume is added to the StatefulSet's template spec volumes. The vector data volume is added to the StatefulSet's template spec volumes. The vector data volume is mounted to the vector container at /kubedoop/vector/var.

func IsVectorEnable

func IsVectorEnable(roleLoggingConfig *commonsv1alpha1.LoggingSpec) bool

func NewConfigMapBuilder

func NewConfigMapBuilder(
	ctx context.Context,
	roleGroupInfo *reconciler.RoleGroupInfo,
	client client.Client,
	namespace string,
	replicates int32,
	myidOffset uint16,
	zooCfgOverride map[string]string,
	securityPropsOverride map[string]string,
	zkSecurity *security.ZookeeperSecurity,
	loggingSpec *commonsv1alpha1.LoggingSpec,
) *builder.ConfigMapBuilder

func NewConfigMapReconciler

func NewConfigMapReconciler(
	ctx context.Context,
	client *client.Client,
	repilicates *int32,
	options *reconciler.RoleGroupInfo,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupSpec *commonsv1alpha1.RoleGroupConfigSpec,
	zkSecurity *security.ZookeeperSecurity,
) reconciler.ResourceReconciler[*builder.ConfigMapBuilder]

func NewServiceReconciler

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

func NewStatefulsetReconciler

func NewStatefulsetReconciler(
	client *client.Client,
	roleGroupInfo *reconciler.RoleGroupInfo,
	clusterConfig *zkv1alpha1.ClusterConfigSpec,
	image *oputil.Image,
	repilicates *int32,
	stopped bool,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
	zkSecurity *security.ZookeeperSecurity,
) (reconciler.ResourceReconciler[builder.StatefulSetBuilder], error)

Types

type ConfigGenerator

type ConfigGenerator struct {
	*reconciler.RoleGroupInfo
	// contains filtered or unexported fields
}

type Reconciler

type Reconciler struct {
	reconciler.BaseRoleReconciler[*zkv1alph1.ServerSpec]
	ClusterConfig *zkv1alph1.ClusterConfigSpec
	Image         *util.Image
}

func NewReconciler

func NewReconciler(
	client *client.Client,
	roleInfo reconciler.RoleInfo,
	clusterOperation *commonsv1alpha1.ClusterOperationSpec,
	clusterConfig *zkv1alph1.ClusterConfigSpec,
	image *util.Image,
	spec *zkv1alph1.ServerSpec,
) *Reconciler

func (*Reconciler) RegisterResourceWithRoleGroup

func (r *Reconciler) RegisterResourceWithRoleGroup(
	ctx context.Context,
	info *reconciler.RoleGroupInfo,
	repilicates *int32,
	mergedRoleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
	mergedOverrides *commonsv1alpha1.OverridesSpec,
) ([]reconciler.Reconciler, error)

func (*Reconciler) RegisterResources

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

type ServiceBuilder

type ServiceBuilder struct {
	builder.BaseServiceBuilder
}

func (*ServiceBuilder) Build

func (b *ServiceBuilder) Build(_ context.Context) (ctrlclient.Object, error)

type StatefulsetBuilder

type StatefulsetBuilder struct {
	builder.StatefulSet
	ClusterConfig *zkv1alpha1.ClusterConfigSpec
	// contains filtered or unexported fields
}

func NewStatefulSetBuilder

func NewStatefulSetBuilder(
	client *client.Client,
	name string,
	clusterConfig *zkv1alpha1.ClusterConfigSpec,
	image *oputil.Image,
	repilicates *int32,
	zkSecurity *security.ZookeeperSecurity,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
	options ...builder.Option,
) *StatefulsetBuilder

func (*StatefulsetBuilder) Build

func (b *StatefulsetBuilder) Build(ctx context.Context) (ctrlClient.Object, error)

func (*StatefulsetBuilder) GetReadinessProbe

func (b *StatefulsetBuilder) GetReadinessProbe() *corev1.Probe

type VectorConfigParams

type VectorConfigParams struct {
	Client        client.Client
	ClusterConfig *zkv1alpha1.ClusterConfigSpec
	Namespace     string
	InstanceName  string
	Role          string
	GroupName     string
}