common

Documentation

Index

• Constants
• Variables
• func InjectCredentials(credentialsSecret string, builder builder.ContainerBuilder)
• func NewConfigReconciler(client *client.Client, clusterConfig *supersetv1alpha1.ClusterConfigSpec, ...) *reconciler.SimpleResourceReconciler[builder.ConfigBuilder]
• type AffinityBuilder
  • func NewAffinityBuilder(podAffinity ...PodAffinity) *AffinityBuilder
  • func (a *AffinityBuilder) AddPodAffinity(podAffinity PodAffinity) *AffinityBuilder
  • func (a *AffinityBuilder) Build() *corev1.Affinity
• type DeploymentBuilder
  • func NewDeploymentBuilder(client *client.Client, roleGroupInfo reconciler.RoleGroupInfo, ...) *DeploymentBuilder
  • func (b *DeploymentBuilder) Build(ctx context.Context) (ctrlclient.Object, error)
  • func (b *DeploymentBuilder) GetDefaultAffinityBuilder() *AffinityBuilder
  • func (b *DeploymentBuilder) GetInitContainerCommands() string
  • func (b *DeploymentBuilder) GetMainCommands() string
  • func (b *DeploymentBuilder) GetMainContainer() builder.ContainerBuilder
  • func (b *DeploymentBuilder) GetMetricsContainer() builder.ContainerBuilder
• type NodeAffinity
  • func (n *NodeAffinity) Weight(weight int32) *NodeAffinity
• type PodAffinity
  • func NewPodAffinity(labels map[string]string, affinityRequired, anti bool) *PodAffinity
  • func (p *PodAffinity) Weight(weight int32) *PodAffinity
• type SupersetConfigMapBuilder
  • func NewSupersetConfigBuilder(client *client.Client, roleGroupInfo reconciler.RoleGroupInfo, ...) *SupersetConfigMapBuilder
  • func (b *SupersetConfigMapBuilder) Build(ctx context.Context) (ctrlclient.Object, error)

Constants

const (
	SupersetConfigFilename = "superset_config.py"
	SupersetLogFilename    = "log_config.py"
)

const (
	DefaultLDAPFieldEmail     = "email"
	DefaultLDAPFieldGivenName = "givenName"
	DefaultLDAPFieldGroup     = "memberOf"
	DefaultLDAPFieldSurname   = "sn"
	DefaultLDAPFieldUid       = "uid"

	LDAPBindCredentialsUserFilename     = "user"
	LDAPBindCredentialsPasswordFilename = "password"
)

Variables

var (
	LogVolumeName    = "log"
	ConfigVolumeName = "config"
)

var (
	SupersetLogPath = path.Join(constants.KubedoopLogDir, "superset")
)

Functions

func InjectCredentials

func InjectCredentials(credentialsSecret string, builder builder.ContainerBuilder)

func NewConfigReconciler

func NewConfigReconciler(
	client *client.Client,
	clusterConfig *supersetv1alpha1.ClusterConfigSpec,
	roleGroupInfo reconciler.RoleGroupInfo,
) *reconciler.SimpleResourceReconciler[builder.ConfigBuilder]

Types

type AffinityBuilder

type AffinityBuilder struct {
	PodAffinity []PodAffinity
}

func NewAffinityBuilder

func NewAffinityBuilder(
	podAffinity ...PodAffinity,
) *AffinityBuilder

func (*AffinityBuilder) AddPodAffinity

func (a *AffinityBuilder) AddPodAffinity(podAffinity PodAffinity) *AffinityBuilder

func (*AffinityBuilder) Build

func (a *AffinityBuilder) Build() *corev1.Affinity

type DeploymentBuilder

type DeploymentBuilder struct {
	builder.Deployment
	Ports         []corev1.ContainerPort
	ClusterConfig *supersetv1alpha1.ClusterConfigSpec
	ClusterName   string
	RoleName      string
}

func NewDeploymentBuilder

func NewDeploymentBuilder(
	client *client.Client,
	roleGroupInfo reconciler.RoleGroupInfo,
	clusterConfig *supersetv1alpha1.ClusterConfigSpec,
	replicas *int32,
	ports []corev1.ContainerPort,
	image *util.Image,
	overrides *commonsv1alpha1.OverridesSpec,
	roleGroupConfig *commonsv1alpha1.RoleGroupConfigSpec,
) *DeploymentBuilder

func (*DeploymentBuilder) Build

func (b *DeploymentBuilder) Build(ctx context.Context) (ctrlclient.Object, error)

func (*DeploymentBuilder) GetDefaultAffinityBuilder

func (b *DeploymentBuilder) GetDefaultAffinityBuilder() *AffinityBuilder

func (*DeploymentBuilder) GetInitContainerCommands

func (b *DeploymentBuilder) GetInitContainerCommands() string

func (*DeploymentBuilder) GetMainCommands

func (b *DeploymentBuilder) GetMainCommands() string

func (*DeploymentBuilder) GetMainContainer

func (b *DeploymentBuilder) GetMainContainer() builder.ContainerBuilder

func (*DeploymentBuilder) GetMetricsContainer

func (b *DeploymentBuilder) GetMetricsContainer() builder.ContainerBuilder

type NodeAffinity

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

func (*NodeAffinity) Weight

func (n *NodeAffinity) Weight(weight int32) *NodeAffinity

type PodAffinity

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

func NewPodAffinity

func NewPodAffinity(labels map[string]string, affinityRequired, anti bool) *PodAffinity

func (*PodAffinity) Weight

func (p *PodAffinity) Weight(weight int32) *PodAffinity

type SupersetConfigMapBuilder

type SupersetConfigMapBuilder struct {
	builder.ConfigMapBuilder

	ClusterConfig *supersetv1alpha1.ClusterConfigSpec

	ClusterName   string
	RoleName      string
	RoleGroupName string
}

func NewSupersetConfigBuilder

func NewSupersetConfigBuilder(
	client *client.Client,
	roleGroupInfo reconciler.RoleGroupInfo,
	clusterConfig *supersetv1alpha1.ClusterConfigSpec,
) *SupersetConfigMapBuilder

func (*SupersetConfigMapBuilder) Build

func (b *SupersetConfigMapBuilder) Build(ctx context.Context) (ctrlclient.Object, error)