journal

package
v0.0.0-...-ebe3fe6 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ServiceHttpPort   = 8480
	ServiceHttpsPort  = 8481
	ServiceRpcPort    = 8485
	ServiceMetricPort = 8081
)
View Source 
const ContainerJournalNode common.ContainerComponent = common.ContainerComponent(common.JournalNode)

Variables

This section is empty.

Functions

func GetRole 

func GetRole() common.Role

func MergeConfig 

func MergeConfig(masterRole *hdfsv1alpha1.JournalNodeSpec,
	group *hdfsv1alpha1.JournalNodeRoleGroupSpec) *hdfsv1alpha1.JournalNodeRoleGroupSpec

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

func NewJournalNodeLogging 

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

Types

type ConfigMapReconciler 

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

func NewConfigMap 

func NewConfigMap(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *hdfsv1alpha1.JournalNodeRoleGroupSpec,
) *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 ContainerBuilder 

type ContainerBuilder struct {
	common.ContainerBuilder
	// contains filtered or unexported fields
}

func NewJournalNodeContainerBuilder 

func NewJournalNodeContainerBuilder(
	instance *hdfsv1alpha1.HdfsCluster,
	resource corev1.ResourceRequirements,
) *ContainerBuilder

func (*ContainerBuilder) Command 

func (d *ContainerBuilder) Command() []string

func (*ContainerBuilder) CommandArgs 

func (d *ContainerBuilder) CommandArgs() []string

func (*ContainerBuilder) ContainerEnv 

func (d *ContainerBuilder) ContainerEnv() []corev1.EnvVar

func (*ContainerBuilder) ContainerName 

func (d *ContainerBuilder) ContainerName() string

func (*ContainerBuilder) ContainerPorts 

func (d *ContainerBuilder) ContainerPorts() []corev1.ContainerPort

ContainerPorts make container ports of data node

func (*ContainerBuilder) LivenessProbe 

func (d *ContainerBuilder) LivenessProbe() *corev1.Probe

func (*ContainerBuilder) ReadinessProbe 

func (d *ContainerBuilder) ReadinessProbe() *corev1.Probe

func (*ContainerBuilder) VolumeMount 

func (d *ContainerBuilder) VolumeMount() []corev1.VolumeMount

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 NewRoleJournalNode 

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

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.JournalNodeRoleGroupSpec]
}

func NewServiceHeadless 

func NewServiceHeadless(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *hdfsv1alpha1.JournalNodeRoleGroupSpec,
) *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.JournalNodeRoleGroupSpec]
}

func NewStatefulSet 

func NewStatefulSet(
	scheme *runtime.Scheme,
	instance *hdfsv1alpha1.HdfsCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *hdfsv1alpha1.JournalNodeRoleGroupSpec,
	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)

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.