Versions in this module Expand all Collapse all v0 v0.1.0 Feb 11, 2022 Changes in this version + const CmdEnvHelmExecutable + const CmdEnvKubeConfig + const CmdEnvNginxHelmChart + const CmdEnvSparkOperatorHelmChart + const CmdEnvWithMinikube + const DefaultApiUserName + const DefaultHelmExecutable + const DefaultInstanceType + const DefaultNamePrefix + const DefaultNginxEnableHttp + const DefaultNginxEnableHttps + const DefaultNginxIngressHelmInstallName + const DefaultNginxIngressNamespace + const DefaultNodeGroupSize + const DefaultOperatorImageRepository + const DefaultRegion + const DefaultSparkApplicationNamespace + const DefaultSparkOperatorHelmInstallName + const DefaultSparkOperatorImageTag + const DefaultSparkOperatorNamespace + const DefaultVersion + const FieldMaskValue + const KindSparkTopology + const ToBeReplacedS3BucketName + func CreateApiGatewayIngress(clientset *kubernetes.Clientset, namespace string, ingressName string, ...) error + func CreateApiGatewayService(clientset *kubernetes.Clientset, namespace string, serviceName string, ...) + func CreateInstanceIAMRole(topology SparkTopology) string + func CreateSparkServiceAccount(clientset *kubernetes.Clientset, sparkOperatorNamespace string, ...) + func DeployNginxIngressController(commandEnvironment framework.CommandEnvironment, topology SparkTopology) map[string]interface + func DeploySparkOperator(commandEnvironment framework.CommandEnvironment, topology SparkTopology) + func InstallSparkOperatorHelm(commandEnvironment framework.CommandEnvironment, topology SparkTopology) + func UpdateSparkTopologyByS3BucketName(topology *SparkTopology, s3BucketName string) + type NginxIngress struct + EnableHttp bool + EnableHttps bool + HelmInstallName string + Namespace string + type SparkApiGateway struct + UserName string + UserPassword string + type SparkOperator struct + HelmInstallName string + ImageRepository string + ImageTag string + Namespace string + SparkApplicationNamespace string + type SparkTemplateData struct + func CreateSparkTemplateData(data framework.TemplateData) SparkTemplateData + type SparkTopology struct + ApiVersion string + Kind string + Metadata framework.TopologyMetadata + Spec SparkTopologySpec + func CreateDefaultSparkTopology(namePrefix string, s3BucketName string) SparkTopology + func (t *SparkTopology) GetKind() string + func (t *SparkTopology) ToString() string + type SparkTopologySpec struct + ApiGateway SparkApiGateway + EKS resource.EKSCluster + NamePrefix string + NginxIngress NginxIngress + NodeGroups []resource.NodeGroup + Region string + S3BucketName string + S3Policy resource.IAMPolicy + SparkOperator SparkOperator + VpcId string + type TopologyHandler struct + func (t *TopologyHandler) Generate() (framework.Topology, error) + func (t *TopologyHandler) Install(topology framework.Topology) (framework.DeploymentOutput, error) + func (t *TopologyHandler) Parse(yamlContent []byte) (framework.Topology, error) + func (t *TopologyHandler) PrintUsageExample(topology framework.Topology, deploymentOutput framework.DeploymentOutput) + func (t *TopologyHandler) Resolve(topology framework.Topology, data framework.TemplateData) (framework.Topology, error) + func (t *TopologyHandler) Uninstall(topology framework.Topology) (framework.DeploymentOutput, error)
Go to main page