name

Documentation

Index

• Constants
• func MergeConfig(masterRole *hdfsv1alpha1.NameNodeSpec, ...) *hdfsv1alpha1.NameNodeRoleGroupSpec
• func NewNameNodeLogging(scheme *runtime.Scheme, instance *hdfsv1alpha1.HdfsCluster, ...) *common.OverrideExistLoggingRecociler[*hdfsv1alpha1.HdfsCluster, any]
• type ConfigMapReconciler
  • func NewConfigMap(scheme *runtime.Scheme, instance *hdfsv1alpha1.HdfsCluster, ...) *ConfigMapReconciler
  • func (c *ConfigMapReconciler) Build(ctx context.Context) (client.Object, error)
  • func (c *ConfigMapReconciler) ConfigurationOverride(resource client.Object)
  • func (c *ConfigMapReconciler) LoggingOverride(current *corev1.ConfigMap)
• type LogDataBuilder
  • func (l *LogDataBuilder) MakeContainerLogData() map[string]string
  • func (l *LogDataBuilder) OverrideConfigMapData(cmData *map[string]string, container common.ContainerComponent, ...)
• type Role
  • func NewRoleNameNode(scheme *runtime.Scheme, instance *hdfsv1alpha1.HdfsCluster, ...) *Role
  • func (r *Role) CacheRoleGroupConfig()
  • func (r *Role) ReconcileRole(ctx context.Context) (ctrl.Result, error)
  • func (r *Role) RoleName() common.Role
• type RoleGroup
  • func NewRoleGroupReconciler(scheme *runtime.Scheme, instance *hdfsv1alpha1.HdfsCluster, ...) *RoleGroup
  • func (m *RoleGroup) MergeGroupConfigSpec() any
  • func (m *RoleGroup) MergeLabels(mergedCfg any) map[string]string
  • func (m *RoleGroup) RegisterResource()
• type ServiceReconciler
  • func NewServiceHeadless(scheme *runtime.Scheme, instance *hdfsv1alpha1.HdfsCluster, ...) *ServiceReconciler
  • func (s *ServiceReconciler) Build(_ context.Context) (client.Object, error)
• type StatefulSetReconciler
  • func NewStatefulSet(scheme *runtime.Scheme, instance *hdfsv1alpha1.HdfsCluster, ...) *StatefulSetReconciler
  • func (s *StatefulSetReconciler) Build(ctx context.Context) (client.Object, error)
  • func (s *StatefulSetReconciler) CommandOverride(resource client.Object)
  • func (s *StatefulSetReconciler) EnvOverride(resource client.Object)
  • func (s *StatefulSetReconciler) GetConditions() *[]metav1.Condition
  • func (s *StatefulSetReconciler) LogOverride(_ client.Object)
  • func (s *StatefulSetReconciler) SetAffinity(resource client.Object)

Constants

const (
	ServiceHttpPort   = 9870
	ServiceHttpsPort  = 9871
	ServiceRpcPort    = 8020
	ServiceMetricPort = 8183
)

Functions

func MergeConfig

func MergeConfig(masterRole *hdfsv1alpha1.NameNodeSpec,
	group *hdfsv1alpha1.NameNodeRoleGroupSpec) *hdfsv1alpha1.NameNodeRoleGroupSpec

MergeConfig merge the role's config into the role group's config

func NewNameNodeLogging

func NewNameNodeLogging(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *hdfsv1alpha1.NameNodeRoleGroupSpec,
	currentConfigMap *corev1.ConfigMap,
) *common.OverrideExistLoggingRecociler[*hdfsv1alpha1.HdfsCluster, any]

Types

type ConfigMapReconciler

type ConfigMapReconciler struct {
	common.ConfigurationStyleReconciler[*hdfsv1alpha1.HdfsCluster, *hdfsv1alpha1.NameNodeRoleGroupSpec]
}

func NewConfigMap

func NewConfigMap(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *hdfsv1alpha1.NameNodeRoleGroupSpec,
) *ConfigMapReconciler

NewConfigMap new a ConfigMapReconciler

func (*ConfigMapReconciler) Build

func (c *ConfigMapReconciler) Build(ctx context.Context) (client.Object, error)

func (*ConfigMapReconciler) ConfigurationOverride

func (c *ConfigMapReconciler) ConfigurationOverride(resource client.Object)

func (*ConfigMapReconciler) LoggingOverride

func (c *ConfigMapReconciler) LoggingOverride(current *corev1.ConfigMap)

type LogDataBuilder

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

func (*LogDataBuilder) MakeContainerLogData

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

func (*LogDataBuilder) OverrideConfigMapData

func (l *LogDataBuilder) OverrideConfigMapData(cmData *map[string]string, container common.ContainerComponent,
	containerLogSpec *hdfsv1alpha1.LoggingConfigSpec)

OverrideConfigMapData override log4j properties and update the configmap

type Role

type Role struct {
	common.BaseRoleReconciler[*hdfsv1alpha1.HdfsCluster]
}

func NewRoleNameNode

func NewRoleNameNode(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	log logr.Logger) *Role

NewRoleNameNode new roleMaster

func (*Role) CacheRoleGroupConfig

func (r *Role) CacheRoleGroupConfig()

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[*hdfsv1alpha1.HdfsCluster]
}

RoleGroup master role group reconcile

func NewRoleGroupReconciler

func NewRoleGroupReconciler(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	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 ServiceReconciler

type ServiceReconciler struct {
	common.GeneralResourceStyleReconciler[*hdfsv1alpha1.HdfsCluster, *hdfsv1alpha1.NameNodeRoleGroupSpec]
}

func NewServiceHeadless

func NewServiceHeadless(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *hdfsv1alpha1.NameNodeRoleGroupSpec,
) *ServiceReconciler

NewServiceHeadless new a ServiceReconciler

func (*ServiceReconciler) Build

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

type StatefulSetReconciler

type StatefulSetReconciler struct {
	common.WorkloadStyleReconciler[*hdfsv1alpha1.HdfsCluster, *hdfsv1alpha1.NameNodeRoleGroupSpec]
}

func NewStatefulSet

func NewStatefulSet(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *hdfsv1alpha1.NameNodeRoleGroupSpec,
	replicate int32,
) *StatefulSetReconciler

func (*StatefulSetReconciler) Build

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

func (*StatefulSetReconciler) CommandOverride

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

func (*StatefulSetReconciler) EnvOverride

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

func (*StatefulSetReconciler) GetConditions

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

func (*StatefulSetReconciler) LogOverride

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

func (*StatefulSetReconciler) SetAffinity

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