master

Documentation

Index

• type ConfigMapReconciler
  • func NewConfigMap(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *ConfigMapReconciler
  • func (s *ConfigMapReconciler) Build() (client.Object, error)
  • func (s *ConfigMapReconciler) ConfigurationOverride(origin client.Object)
• type LogDataBuilder
  • func (c *LogDataBuilder) MakeContainerLog4jData() map[string]string
• type RoleMaster
  • func NewRoleMaster(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *RoleMaster
  • func (r *RoleMaster) MergeLabels() map[string]string
  • func (r *RoleMaster) ReconcileRole(ctx context.Context) (ctrl.Result, error)
  • func (r *RoleMaster) RoleName() common.Role
• type RoleMasterGroup
  • func NewRoleMasterGroup(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *RoleMasterGroup
  • func (m *RoleMasterGroup) MergeGroupConfigSpec() any
  • func (m *RoleMasterGroup) MergeLabels(mergedCfg any) map[string]string
  • func (m *RoleMasterGroup) ReconcileGroup(ctx context.Context) (ctrl.Result, error)
• type ServiceReconciler
  • func NewService(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *ServiceReconciler
  • func (s *ServiceReconciler) Build() (client.Object, error)
• type StatefulSetReconciler
  • func NewStatefulSet(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *StatefulSetReconciler
  • func (s *StatefulSetReconciler) Build() (client.Object, error)
  • func (s *StatefulSetReconciler) CommandOverride(obj client.Object)
  • func (s *StatefulSetReconciler) EnableJobMasterLogging() bool
  • func (s *StatefulSetReconciler) EnabledMasterLogging() bool
  • func (s *StatefulSetReconciler) EnvOverride(obj client.Object)
  • func (s *StatefulSetReconciler) GetConditions() *[]metav1.Condition
  • func (s *StatefulSetReconciler) LogOverride(resource client.Object)
  • func (s *StatefulSetReconciler) RoleGroupConfig() *alluxiov1alpha1.MasterConfigSpec

Types

type ConfigMapReconciler

type ConfigMapReconciler struct {
	common.ConfigurationStyleReconciler[*alluxiov1alpha1.AlluxioCluster, *alluxiov1alpha1.MasterRoleGroupSpec]
}

func NewConfigMap

func NewConfigMap(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *alluxiov1alpha1.MasterRoleGroupSpec,
) *ConfigMapReconciler

NewConfigMap new a ConfigMapReconcile

func (*ConfigMapReconciler) Build

func (s *ConfigMapReconciler) Build() (client.Object, error)

func (*ConfigMapReconciler) ConfigurationOverride

func (s *ConfigMapReconciler) ConfigurationOverride(origin client.Object)

type LogDataBuilder

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

func (*LogDataBuilder) MakeContainerLog4jData

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

MakeContainerLog4jData implement RoleLoggingDataBuilder

type RoleMaster

type RoleMaster struct {
	common.BaseRoleReconciler[*alluxiov1alpha1.MasterSpec]
}

func NewRoleMaster

func NewRoleMaster(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	log logr.Logger) *RoleMaster

NewRoleMaster new roleMaster

func (*RoleMaster) MergeLabels

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

func (*RoleMaster) ReconcileRole

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

func (*RoleMaster) RoleName

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

type RoleMasterGroup

type RoleMasterGroup struct {
	Scheme     *runtime.Scheme
	Instance   *alluxiov1alpha1.AlluxioCluster
	Client     client.Client
	GroupName  string
	RoleLabels map[string]string
	Log        logr.Logger
}

RoleMasterGroup master role group reconcile

func NewRoleMasterGroup

func NewRoleMasterGroup(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	groupName string,
	roleLabels map[string]string,
	log logr.Logger) *RoleMasterGroup

func (*RoleMasterGroup) MergeGroupConfigSpec

func (m *RoleMasterGroup) MergeGroupConfigSpec() any

func (*RoleMasterGroup) MergeLabels

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

func (*RoleMasterGroup) ReconcileGroup

func (m *RoleMasterGroup) ReconcileGroup(ctx context.Context) (ctrl.Result, error)

ReconcileGroup ReconcileRole implements the Role interface

type ServiceReconciler

type ServiceReconciler struct {
	common.GeneralResourceStyleReconciler[*alluxiov1alpha1.AlluxioCluster, *alluxiov1alpha1.MasterRoleGroupSpec]
}

func NewService

func NewService(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *alluxiov1alpha1.MasterRoleGroupSpec,
) *ServiceReconciler

NewService New a ServiceReconciler

func (*ServiceReconciler) Build

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

type StatefulSetReconciler

type StatefulSetReconciler struct {
	common.DeploymentStyleReconciler[*alluxiov1alpha1.AlluxioCluster, *alluxiov1alpha1.MasterRoleGroupSpec]
}

func NewStatefulSet

func NewStatefulSet(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *alluxiov1alpha1.MasterRoleGroupSpec,
	replicas int32,
) *StatefulSetReconciler

NewStatefulSet New a StatefulSetReconciler

func (*StatefulSetReconciler) Build

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

func (*StatefulSetReconciler) CommandOverride

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

CommandOverride commandOverride only deployment and statefulset need to implement this method todo: set the same command for all containers currently

func (*StatefulSetReconciler) EnableJobMasterLogging

func (s *StatefulSetReconciler) EnableJobMasterLogging() bool

EnableJobMasterLogging is job master enabled logging

func (*StatefulSetReconciler) EnabledMasterLogging

func (s *StatefulSetReconciler) EnabledMasterLogging() bool

func (*StatefulSetReconciler) EnvOverride

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

EnvOverride only deployment and statefulset need to implement this method todo: set the same env for all containers currently

func (*StatefulSetReconciler) GetConditions

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

func (*StatefulSetReconciler) LogOverride

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

LogOverride only deployment and statefulset need to implement this method

func (*StatefulSetReconciler) RoleGroupConfig

func (s *StatefulSetReconciler) RoleGroupConfig() *alluxiov1alpha1.MasterConfigSpec