worker

package

v0.0.0-...-db59c9c Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/zncdata-labs/alluxio-operator

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL