worker

Documentation

Index

• Constants
• func NewStatefulSet(ctx context.Context, scheme *runtime.Scheme, ...) ...
• func NewWorkerLogging(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) *resource.LoggingRecociler[*dolphinv1alpha1.DolphinschedulerCluster, any]
• func NewWorkerRole(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) *core.BaseRoleReconciler[*dolphinv1alpha1.DolphinschedulerCluster]
• func NewWorkerServiceHeadless(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) ...
• type ContainerBuilder
  • func NewWorkerContainerBuilder(image string, imagePullPolicy corev1.PullPolicy, ...) *ContainerBuilder
  • func (c *ContainerBuilder) ContainerEnv() []corev1.EnvVar
  • func (c *ContainerBuilder) ContainerEnvFromSource() []corev1.EnvFromSource
  • func (c *ContainerBuilder) ContainerName() string
  • func (c *ContainerBuilder) ContainerPorts() []corev1.ContainerPort
  • func (c *ContainerBuilder) LivenessProbe() *corev1.Probe
  • func (c *ContainerBuilder) ReadinessProbe() *corev1.Probe
  • func (c *ContainerBuilder) VolumeMount() []corev1.VolumeMount
• type ContainerWorkerBuilderType
• type RoleWorkerRequirements
  • func NewRoleWorkerRequirements(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) *RoleWorkerRequirements
  • func (r *RoleWorkerRequirements) MergeConfig() map[string]any
  • func (r *RoleWorkerRequirements) RegisterResources(ctx context.Context) map[string][]core.ResourceReconciler
• type StatefulSetBuilderRequirements
  • func (s *StatefulSetBuilderRequirements) Build(ctx context.Context) (client.Object, error)

Constants

const ContainerWorker resource.ContainerComponent = resource.ContainerComponent(common.Worker)

Functions

func NewStatefulSet

func NewStatefulSet(
	ctx context.Context,
	scheme *runtime.Scheme,
	instance *dolphinv1alpha1.DolphinschedulerCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *dolphinv1alpha1.WorkerRoleGroupSpec,
	replicate int32,
) *resource.GenericStatefulSetReconciler[*dolphinv1alpha1.DolphinschedulerCluster, *dolphinv1alpha1.WorkerRoleGroupSpec]

func NewWorkerLogging

func NewWorkerLogging(
	scheme *runtime.Scheme,
	instance *dolphinv1alpha1.DolphinschedulerCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *dolphinv1alpha1.WorkerRoleGroupSpec) *resource.LoggingRecociler[*dolphinv1alpha1.DolphinschedulerCluster, any]

func NewWorkerRole

func NewWorkerRole(
	scheme *runtime.Scheme,
	instance *dolphinv1alpha1.DolphinschedulerCluster,
	client client.Client) *core.BaseRoleReconciler[*dolphinv1alpha1.DolphinschedulerCluster]

func NewWorkerServiceHeadless

func NewWorkerServiceHeadless(
	scheme *runtime.Scheme,
	instance *dolphinv1alpha1.DolphinschedulerCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *dolphinv1alpha1.WorkerRoleGroupSpec,
) *resource.GenericServiceReconciler[*dolphinv1alpha1.DolphinschedulerCluster, *dolphinv1alpha1.WorkerRoleGroupSpec]

Types

type ContainerBuilder

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

func NewWorkerContainerBuilder

func NewWorkerContainerBuilder(
	image string,
	imagePullPolicy corev1.PullPolicy,
	zookeeperDiscoveryZNode string,
	resourceSpec *dolphinv1alpha1.ResourcesSpec,
	envConfigName string,
	configConfigMapName string,
	dbParams *resource.DatabaseParams,
) *ContainerBuilder

func (*ContainerBuilder) ContainerEnv

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

func (*ContainerBuilder) ContainerEnvFromSource

func (c *ContainerBuilder) ContainerEnvFromSource() []corev1.EnvFromSource

func (*ContainerBuilder) ContainerName

func (c *ContainerBuilder) ContainerName() string

func (*ContainerBuilder) ContainerPorts

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

func (*ContainerBuilder) LivenessProbe

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

func (*ContainerBuilder) ReadinessProbe

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

func (*ContainerBuilder) VolumeMount

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

type ContainerWorkerBuilderType

type ContainerWorkerBuilderType interface {
	resource.ContainerName
	resource.ContainerEnv
	resource.ContainerEnvFrom
	resource.VolumeMount
	resource.LivenessProbe
	resource.ReadinessProbe
	resource.ContainerPorts
}

type RoleWorkerRequirements

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

func NewRoleWorkerRequirements

func NewRoleWorkerRequirements(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster,
	roleLabels map[string]string, client client.Client) *RoleWorkerRequirements

func (*RoleWorkerRequirements) MergeConfig

func (r *RoleWorkerRequirements) MergeConfig() map[string]any

func (*RoleWorkerRequirements) RegisterResources

func (r *RoleWorkerRequirements) RegisterResources(ctx context.Context) map[string][]core.ResourceReconciler

type StatefulSetBuilderRequirements

type StatefulSetBuilderRequirements struct {
	core.WorkloadResourceRequirements
	// contains filtered or unexported fields
}

func (*StatefulSetBuilderRequirements) Build

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