components

Documentation

Index

• Constants
• func ConfigureHistoryServer(comp *v1alpha1.WaveComponent, ...) (bool, error)
• func GetEnterpriseGatewayConditions(config *rest.Config, client client.Client, log logr.Logger) ([]*v1alpha1.WaveComponentCondition, error)
• func GetEnterpriseGatewayProperties(c *v1alpha1.WaveComponent, client client.Client, log logr.Logger) (map[string]string, error)
• func GetSparkHistoryConditions(client client.Client, releaseName string) ([]*v1alpha1.WaveComponentCondition, error)
• func GetSparkHistoryProperties(c *v1alpha1.WaveComponent, client client.Client, log logr.Logger, ...) (map[string]string, error)
• func GetSparkOperatorConditions(config *rest.Config, client client.Client, releaseName string) ([]*v1alpha1.WaveComponentCondition, error)
• func GetSparkOperatorProperties(c *v1alpha1.WaveComponent, client client.Client, log logr.Logger) (map[string]string, error)
• func NewWaveComponentCondition(condType v1alpha1.WaveComponentConditionType, status v1.ConditionStatus, ...) *v1alpha1.WaveComponentCondition

Constants

const (
	EnterpriseGatewayChartName      = "enterprise-gateway"
	EnterpriseGatewayIngressName    = "enterprise-gateway-ingress"
	EnterpriseGatewayAuthSecretName = "enterprise-gateway-auth"
)

const (
	SparkHistoryIngressName = "spark-history-server"
)

Functions

func ConfigureHistoryServer

func ConfigureHistoryServer(comp *v1alpha1.WaveComponent, storageProvider cloudstorage.CloudStorageProvider) (bool, error)

func GetEnterpriseGatewayConditions

func GetEnterpriseGatewayConditions(config *rest.Config, client client.Client, log logr.Logger) ([]*v1alpha1.WaveComponentCondition, error)

func GetEnterpriseGatewayProperties

func GetEnterpriseGatewayProperties(c *v1alpha1.WaveComponent, client client.Client, log logr.Logger) (map[string]string, error)

func GetSparkHistoryConditions

func GetSparkHistoryConditions(client client.Client, releaseName string) ([]*v1alpha1.WaveComponentCondition, error)

func GetSparkHistoryProperties

func GetSparkHistoryProperties(c *v1alpha1.WaveComponent, client client.Client, log logr.Logger, releaseName string) (map[string]string, error)

func GetSparkOperatorConditions

func GetSparkOperatorConditions(config *rest.Config, client client.Client, releaseName string) ([]*v1alpha1.WaveComponentCondition, error)

func GetSparkOperatorProperties

func GetSparkOperatorProperties(c *v1alpha1.WaveComponent, client client.Client, log logr.Logger) (map[string]string, error)

func NewWaveComponentCondition

func NewWaveComponentCondition(condType v1alpha1.WaveComponentConditionType, status v1.ConditionStatus, reason, message string) *v1alpha1.WaveComponentCondition

NewWaveComponentCondition creates a new WaveComponent condition.