aws

Documentation

Index

• Constants
• func GetPlatform(kfdef *kfdefs.KfDef) (kftypes.Platform, error)
• type Auth
• 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() (*AwsPluginSpec, error)
  • func (aws *Aws) Init(resources kftypes.ResourceEnum) error
• type AwsPluginSpec
  • func (plugin *AwsPluginSpec) IsValid() (bool, string)
• type BasicAuth
• type Coginito
• type OIDC

Constants

const (
	KUBEFLOW_AWS_INFRA_DIR      = "aws_config"
	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 = kftypes.AWS
)

Functions

func GetPlatform

func GetPlatform(kfdef *kfdefs.KfDef) (kftypes.Platform, error)

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

Types

type Auth

type Auth struct {
	BasicAuth *BasicAuth `json:"basicAuth,omitempty"`
	Oidc      *OIDC      `json:"oidc,omitempty"`
	Cognito   *Coginito  `json:"cognito,omitempty"`
}

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() (*AwsPluginSpec, error)

GetPluginSpec gets the plugin spec.

func (*Aws) Init

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

Init initializes aws kfapp - platform

type AwsPluginSpec

type AwsPluginSpec struct {
	Auth *Auth `json:"auth,omitempty"`

	Region string `json:"region,omitempty"`

	Roles []string `json:"roles,omitempty"`
}

AwsPlugin defines the extra data provided by the GCP Plugin in KfDef

func (*AwsPluginSpec) IsValid

func (plugin *AwsPluginSpec) IsValid() (bool, string)

IsValid returns true if the spec is a valid and complete spec. If false it will also return a string providing a message about why its invalid.

type BasicAuth

type BasicAuth struct {
	Username string            `json:"username,omitempty"`
	Password *kfdefs.SecretRef `json:"password,omitempty"`
}

type Coginito

type Coginito struct {
	CognitoAppClientId    string `json:"cognitoAppClientId,omitempty"`
	CognitoUserPoolArn    string `json:"cognitoUserPoolArn,omitempty"`
	CognitoUserPoolDomain string `json:"cognitoUserPoolDomain,omitempty"`
	CertArn               string `json:"certArn,omitempty"`
}

type OIDC

type OIDC struct {
	OidcAuthorizationEndpoint string `json:"oidcAuthorizationEndpoint,omitempty"`
	OidcIssuer                string `json:"oidcIssuer,omitempty"`
	OidcTokenEndpoint         string `json:"oidcTokenEndpoint,omitempty"`
	OidcUserInfoEndpoint      string `json:"oidcUserInfoEndpoint,omitempty"`
	CertArn                   string `json:"certArn,omitempty"`
	OAuthClientId             string `json:"oAuthClientId,omitempty"`
	OAuthClientSecret         string `json:"oAuthClientSecret,omitempty"`
}