api

Documentation

Index

• Constants
• func NewApiLogging(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) *resource.LoggingRecociler[*dolphinv1alpha1.DolphinschedulerCluster, any]
• func NewApiRole(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) *core.BaseRoleReconciler[*dolphinv1alpha1.DolphinschedulerCluster]
• func NewApiService(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) ...
• func NewDeployment(ctx context.Context, scheme *runtime.Scheme, ...) ...
• type ContainerApiBuilderType
• type ContainerBuilder
  • func NewApiContainerBuilder(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 DeploymentBuilderRequirements
  • func (s *DeploymentBuilderRequirements) Build(ctx context.Context) (client.Object, error)
• type IngressReconciler
  • func NewIngress(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) *IngressReconciler
  • func (i *IngressReconciler) Build(ctx context.Context) (client.Object, error)
• type RoleApiRequirements
  • func NewRoleApiRequirements(scheme *runtime.Scheme, instance *dolphinv1alpha1.DolphinschedulerCluster, ...) *RoleApiRequirements
  • func (r *RoleApiRequirements) MergeConfig() map[string]any
  • func (r *RoleApiRequirements) RegisterResources(ctx context.Context) map[string][]core.ResourceReconciler

Constants

const ContainerApi resource.ContainerComponent = resource.ContainerComponent(common.Api)

Functions

func NewApiLogging

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

func NewApiRole

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

func NewApiService

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

func NewDeployment

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

Types

type ContainerApiBuilderType

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

type ContainerBuilder

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

func NewApiContainerBuilder

func NewApiContainerBuilder(
	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 DeploymentBuilderRequirements

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

func (*DeploymentBuilderRequirements) Build

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

type IngressReconciler

type IngressReconciler struct {
	core.GeneralResourceStyleReconciler[*dolphinv1alpha1.DolphinschedulerCluster, *dolphinv1alpha1.ApiRoleGroupSpec]
}

func NewIngress

func NewIngress(
	scheme *runtime.Scheme,
	instance *dolphinv1alpha1.DolphinschedulerCluster,
	client client.Client,
	groupName string,
	labels map[string]string,
	mergedCfg *dolphinv1alpha1.ApiRoleGroupSpec,
) *IngressReconciler

func (*IngressReconciler) Build

func (i *IngressReconciler) Build(ctx context.Context) (client.Object, error)

type RoleApiRequirements

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

func NewRoleApiRequirements

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

func (*RoleApiRequirements) MergeConfig

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

func (*RoleApiRequirements) RegisterResources

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