worker

Documentation

Index

• func EmptyDirVolumeSource(quota string) corev1.VolumeSource
• func HostPathVolumeSource(path string) corev1.VolumeSource
• func MakeShortCircuitVolumeMounts() []corev1.VolumeMount
• func MakeShortCircuitVolumes(instance *alluxiov1alpha1.AlluxioCluster, roleGroupName string) []corev1.Volume
• func MakeTieredStoreVolumeMounts(instance *alluxiov1alpha1.AlluxioCluster) []corev1.VolumeMount
• func MakeTieredStoreVolumes(instance *alluxiov1alpha1.AlluxioCluster) []corev1.Volume
• func PvcVolumeSource(claimName string) corev1.VolumeSource
• func VolumeSourceFromShortCircuit(shortCircuit alluxiov1alpha1.ShortCircuitSpec, roleGroupName string) corev1.VolumeSource
• func VolumeSourceFromTieredStore(tieredStore alluxiov1alpha1.TieredStore, mediumType string, index int) corev1.Volume
• type DeploymentReconciler
  • func NewDeployment(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *DeploymentReconciler
  • func (d *DeploymentReconciler) Build() (client.Object, error)
  • func (d *DeploymentReconciler) CommandOverride(obj client.Object)
  • func (d *DeploymentReconciler) EnableJobWorkerLogging() bool
  • func (d *DeploymentReconciler) EnableWorkerLogging() bool
  • func (d *DeploymentReconciler) EnvOverride(obj client.Object)
  • func (d *DeploymentReconciler) GetConditions() *[]metav1.Condition
  • func (d *DeploymentReconciler) LogOverride(resource client.Object)
  • func (d *DeploymentReconciler) RoleGroupConfig() *alluxiov1alpha1.WorkerConfigSpec
• type LogDataBuilder
  • func (c *LogDataBuilder) MakeContainerLog4jData() map[string]string
• type PvcReconciler
  • func NewPvc(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *PvcReconciler
  • func (s *PvcReconciler) Build() (client.Object, error)
• type RoleWorker
  • func NewRoleWorker(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *RoleWorker
  • func (r *RoleWorker) MergeLabels() map[string]string
  • func (r *RoleWorker) ReconcileRole(ctx context.Context) (ctrl.Result, error)
  • func (r *RoleWorker) RoleName() common.Role
• type RoleWorkerGroup
  • func NewRoleWorkerGroup(scheme *runtime.Scheme, instance *alluxiov1alpha1.AlluxioCluster, ...) *RoleWorkerGroup
  • func (m *RoleWorkerGroup) MergeGroupConfigSpec() any
  • func (m *RoleWorkerGroup) MergeLabels(mergedCfg any) map[string]string
  • func (m *RoleWorkerGroup) ReconcileGroup(ctx context.Context) (ctrl.Result, error)

Functions

func EmptyDirVolumeSource

func EmptyDirVolumeSource(quota string) corev1.VolumeSource

func HostPathVolumeSource

func HostPathVolumeSource(path string) corev1.VolumeSource

func MakeShortCircuitVolumeMounts

func MakeShortCircuitVolumeMounts() []corev1.VolumeMount

func MakeShortCircuitVolumes

func MakeShortCircuitVolumes(instance *alluxiov1alpha1.AlluxioCluster, roleGroupName string) []corev1.Volume

func MakeTieredStoreVolumeMounts

func MakeTieredStoreVolumeMounts(instance *alluxiov1alpha1.AlluxioCluster) []corev1.VolumeMount

func MakeTieredStoreVolumes

func MakeTieredStoreVolumes(instance *alluxiov1alpha1.AlluxioCluster) []corev1.Volume

func PvcVolumeSource

func PvcVolumeSource(claimName string) corev1.VolumeSource

func VolumeSourceFromShortCircuit

func VolumeSourceFromShortCircuit(shortCircuit alluxiov1alpha1.ShortCircuitSpec, roleGroupName string) corev1.VolumeSource

func VolumeSourceFromTieredStore

func VolumeSourceFromTieredStore(tieredStore alluxiov1alpha1.TieredStore, mediumType string, index int) corev1.Volume

Types

type DeploymentReconciler

type DeploymentReconciler struct {
	common.DeploymentStyleReconciler[*alluxiov1alpha1.AlluxioCluster, *alluxiov1alpha1.WorkerRoleGroupSpec]
}

func NewDeployment

func NewDeployment(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *alluxiov1alpha1.WorkerRoleGroupSpec,
	replicas int32,
) *DeploymentReconciler

NewDeployment New a StatefulSet

func (*DeploymentReconciler) Build

func (d *DeploymentReconciler) Build() (client.Object, error)

func (*DeploymentReconciler) CommandOverride

func (d *DeploymentReconciler) 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 (*DeploymentReconciler) EnableJobWorkerLogging

func (d *DeploymentReconciler) EnableJobWorkerLogging() bool

EnableJobWorkerLogging is job worker enabled logging

func (*DeploymentReconciler) EnableWorkerLogging

func (d *DeploymentReconciler) EnableWorkerLogging() bool

func (*DeploymentReconciler) EnvOverride

func (d *DeploymentReconciler) EnvOverride(obj client.Object)

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

func (*DeploymentReconciler) GetConditions

func (d *DeploymentReconciler) GetConditions() *[]metav1.Condition

func (*DeploymentReconciler) LogOverride

func (d *DeploymentReconciler) LogOverride(resource client.Object)

func (*DeploymentReconciler) RoleGroupConfig

func (d *DeploymentReconciler) RoleGroupConfig() *alluxiov1alpha1.WorkerConfigSpec

type LogDataBuilder

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

func (*LogDataBuilder) MakeContainerLog4jData

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

MakeContainerLog4jData implement RoleLoggingDataBuilder

type PvcReconciler

type PvcReconciler struct {
	common.GeneralResourceStyleReconciler[*alluxiov1alpha1.AlluxioCluster, *alluxiov1alpha1.WorkerRoleGroupSpec]
}

func NewPvc

func NewPvc(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	groupName string,
	mergedLabels map[string]string,
	mergedCfg *alluxiov1alpha1.WorkerRoleGroupSpec,
) *PvcReconciler

NewPvc NewService New a Service

func (*PvcReconciler) Build

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

type RoleWorker

type RoleWorker struct {
	common.BaseRoleReconciler[*alluxiov1alpha1.WorkerSpec]
}

func NewRoleWorker

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

NewRoleWorker new roleWorker

func (*RoleWorker) MergeLabels

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

func (*RoleWorker) ReconcileRole

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

func (*RoleWorker) RoleName

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

type RoleWorkerGroup

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

RoleWorkerGroup worker role group reconcile

func NewRoleWorkerGroup

func NewRoleWorkerGroup(
	scheme *runtime.Scheme,
	instance *alluxiov1alpha1.AlluxioCluster,
	client client.Client,
	groupName string,
	roleLables map[string]string,
	log logr.Logger) *RoleWorkerGroup

func (*RoleWorkerGroup) MergeGroupConfigSpec

func (m *RoleWorkerGroup) MergeGroupConfigSpec() any

func (*RoleWorkerGroup) MergeLabels

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

func (*RoleWorkerGroup) ReconcileGroup

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

ReconcileGroup ReconcileRole implements the Role interface