aws

Documentation

Index

• Constants
• func GetPlatform(kfdef *kfconfig.KfConfig) (kftypes.Platform, error)
• type Aws
  • func (aws *Aws) Apply(resources kftypes.ResourceEnum) error
  • func (aws *Aws) Delete(resources kftypes.ResourceEnum) error
  • func (aws *Aws) Generate(resources kftypes.ResourceEnum) error
  • func (aws *Aws) GetK8sConfig() (*rest.Config, *clientcmdapi.Config)
  • func (aws *Aws) GetPluginSpec() (*awsplugin.AwsPluginSpec, error)
  • func (aws *Aws) Init(resources kftypes.ResourceEnum) error

Constants

const (
	KUBEFLOW_AWS_INFRA_DIR      = "aws_config"
	KUBEFLOW_MANIFEST_DIR       = "kustomize"
	CLUSTER_CONFIG_FILE         = "cluster_config.yaml"
	CLUSTER_FEATURE_CONFIG_FILE = "cluster_features.yaml"
	PATH                        = "path"
	BASIC_AUTH_SECRET           = "kubeflow-login"

	// The namespace for Istio
	IstioNamespace = "istio-system"

	// Plugin parameter constants
	AwsPluginName = kfconfig.AWS_PLUGIN_KIND

	// Path in manifests repo to where the additional configs are located
	CONFIG_LOCAL_PATH = "aws/infra_configs"
)

Functions

func GetPlatform

func GetPlatform(kfdef *kfconfig.KfConfig) (kftypes.Platform, error)

GetKfApp returns the aws kfapp. It's called by coordinator.GetKfApp

Types

type Aws

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

Aws implements KfApp Interface It includes the KsApp along with additional Aws types

func (*Aws) Apply

func (aws *Aws) Apply(resources kftypes.ResourceEnum) error

Apply create eks cluster if needed, bind IAM policy to node group roles and enable cluster level configs. Remind: Need to be thread-safe: this entry is share among kfctl and deploy app

func (*Aws) Delete

func (aws *Aws) Delete(resources kftypes.ResourceEnum) error

func (*Aws) Generate

func (aws *Aws) Generate(resources kftypes.ResourceEnum) error

Generate generate aws infrastructure configs and aws kfapp manifest Remind: Need to be thread-safe: this entry is share among kfctl and deploy app

func (*Aws) GetK8sConfig

func (aws *Aws) GetK8sConfig() (*rest.Config, *clientcmdapi.Config)

GetK8sConfig is only used with ksonnet packageManager. NotImplemented in this version, return nil to use default config for API compatibility.

func (*Aws) GetPluginSpec

func (aws *Aws) GetPluginSpec() (*awsplugin.AwsPluginSpec, error)

GetPluginSpec gets the plugin spec.

func (*Aws) Init

func (aws *Aws) Init(resources kftypes.ResourceEnum) error

Init initializes aws kfapp - platform