eks

Documentation

Index

• Constants
• func CreateInstanceIAMRole(topology EksTopology) string
• func DeployNginxIngressController(commandEnvironment framework.CommandEnvironment, topology EksTopology) map[string]interface{}
• func UpdateSparkTopologyByS3BucketName(topology *EksTopology, s3BucketName string)
• type EksTemplateData
  • func CreateEksTemplateData(data framework.TemplateData) EksTemplateData
• type EksTopology
  • func CreateDefaultEksTopology(namePrefix string, s3BucketName string) EksTopology
  • func (t *EksTopology) GetKind() string
  • func (t *EksTopology) ToString() string
• type EksTopologySpec
• type NginxIngress
• type SparkApiGateway
• type SparkOperator
• type TopologyHandler
  • 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) Resolve(topology framework.Topology, data framework.TemplateData) (framework.Topology, error)
  • func (t *TopologyHandler) Uninstall(topology framework.Topology) (framework.DeploymentOutput, error)

Constants

const (
	ToBeReplacedS3BucketName           = "todo_use_your_own_bucket_name"
	DefaultInstanceType                = "t3.large"
	DefaultNodeGroupSize               = 4
	DefaultNginxIngressHelmInstallName = "ingress-nginx"
	DefaultNginxIngressNamespace       = "ingress-nginx"
	DefaultNginxEnableHttp             = true
	DefaultNginxEnableHttps            = true

	KindEksTopology = "Eks"

	CmdEnvHelmExecutable = "helmExecutable"
	CmdEnvNginxHelmChart = "nginxHelmChart"
	CmdEnvKubeConfig     = "kubeConfig"

	DefaultVersion        = "datapunch.org/v1alpha1"
	DefaultRegion         = "us-west-1"
	DefaultNamePrefix     = "my"
	DefaultHelmExecutable = "helm"
)

Functions

func CreateInstanceIAMRole

func CreateInstanceIAMRole(topology EksTopology) string

func DeployNginxIngressController

func DeployNginxIngressController(commandEnvironment framework.CommandEnvironment, topology EksTopology) map[string]interface{}

TODO remove log.Fatalf

func UpdateSparkTopologyByS3BucketName

func UpdateSparkTopologyByS3BucketName(topology *EksTopology, s3BucketName string)

Types

type EksTemplateData

type EksTemplateData struct {
	framework.TemplateDataWithRegion
}

func CreateEksTemplateData

func CreateEksTemplateData(data framework.TemplateData) EksTemplateData

type EksTopology

type EksTopology struct {
	ApiVersion string                     `json:"apiVersion" yaml:"apiVersion"`
	Kind       string                     `json:"kind" yaml:"kind"`
	Metadata   framework.TopologyMetadata `json:"metadata"`
	Spec       EksTopologySpec            `json:"spec"`
}

func CreateDefaultEksTopology

func CreateDefaultEksTopology(namePrefix string, s3BucketName string) EksTopology

func (*EksTopology) GetKind

func (t *EksTopology) GetKind() string

func (*EksTopology) ToString

func (t *EksTopology) ToString() string

type EksTopologySpec

type EksTopologySpec struct {
	NamePrefix   string               `json:"namePrefix" yaml:"namePrefix"`
	Region       string               `json:"region"`
	VpcId        string               `json:"vpcId" yaml:"vpcId"`
	S3BucketName string               `json:"s3BucketName" yaml:"s3BucketName"`
	S3Policy     resource.IAMPolicy   `json:"s3Policy" yaml:"s3Policy"`
	EKS          resource.EKSCluster  `json:"eks" yaml:"eks"`
	NodeGroups   []resource.NodeGroup `json:"nodeGroups" yaml:"nodeGroups"`
	NginxIngress NginxIngress         `json:"nginxIngress" yaml:"nginxIngress"`
}

type NginxIngress

type NginxIngress struct {
	HelmInstallName string `json:"helmInstallName" yaml:"helmInstallName"`
	Namespace       string `json:"namespace" yaml:"namespace"`
	EnableHttp      bool   `json:"enableHttp" yaml:"enableHttp"`
	EnableHttps     bool   `json:"enableHttps" yaml:"enableHttps"`
}

type SparkApiGateway

type SparkApiGateway struct {
	UserName     string `json:"userName" yaml:"userName"`
	UserPassword string `json:"userPassword" yaml:"userPassword"`
}

type SparkOperator

type SparkOperator struct {
	HelmInstallName           string `json:"helmInstallName" yaml:"helmInstallName"`
	Namespace                 string `json:"namespace" yaml:"namespace"`
	ImageRepository           string `json:"imageRepository" yaml:"imageRepository"`
	ImageTag                  string `json:"imageTag" yaml:"imageTag"`
	SparkApplicationNamespace string `json:"sparkApplicationNamespace" yaml:"sparkApplicationNamespace"`
}

type TopologyHandler

type TopologyHandler struct {
}

func (*TopologyHandler) Generate

func (t *TopologyHandler) Generate() (framework.Topology, error)

func (*TopologyHandler) Install

func (t *TopologyHandler) Install(topology framework.Topology) (framework.DeploymentOutput, error)

func (*TopologyHandler) Parse

func (t *TopologyHandler) Parse(yamlContent []byte) (framework.Topology, error)

func (*TopologyHandler) Resolve

func (t *TopologyHandler) Resolve(topology framework.Topology, data framework.TemplateData) (framework.Topology, error)

func (*TopologyHandler) Uninstall

func (t *TopologyHandler) Uninstall(topology framework.Topology) (framework.DeploymentOutput, error)