eks

Documentation

Index

• type ClientConfig
  • func (c *ClientConfig) NewClientSet() (*clientset.Clientset, error)
  • func (c *ClientConfig) NewClientSetWithEmbeddedToken() (*clientset.Clientset, error)
  • func (c *ClientConfig) WithEmbeddedToken() (*ClientConfig, error)
  • func (c *ClientConfig) WithExecAuthenticator() *ClientConfig
• type ClusterProvider
  • func New(clusterConfig *api.ClusterConfig) *ClusterProvider
  • func (c *ClusterProvider) AddDefaultStorageClass(clientSet *clientset.Clientset) error
  • func (c *ClusterProvider) CheckAuth() error
  • func (c *ClusterProvider) CreateDefaultNodeGroupAuthConfigMap(clientSet *clientset.Clientset) error
  • func (c *ClusterProvider) DeprecatedDeleteControlPlane() error
  • func (c *ClusterProvider) DescribeControlPlane() (*awseks.Cluster, error)
  • func (c *ClusterProvider) EnsureAMI() error
  • func (c *ClusterProvider) GetCredentials(cluster awseks.Cluster) error
  • func (c *ClusterProvider) GetCredentialsEnv() ([]string, error)
  • func (c *ClusterProvider) ListAllTaggedResources() error
  • func (c *ClusterProvider) ListClusters(chunkSize int, output string) error
  • func (c *ClusterProvider) LoadSSHPublicKey() error
  • func (c *ClusterProvider) MaybeDeletePublicSSHKey()
  • func (c *ClusterProvider) NewClientConfig() (*ClientConfig, error)
  • func (c *ClusterProvider) NewStackManager() *manager.StackCollection
  • func (c *ClusterProvider) SetAvailabilityZones(given []string) error
  • func (c *ClusterProvider) WaitForControlPlane(clientSet *kubernetes.Clientset) error
  • func (c *ClusterProvider) WaitForNodes(clientSet *clientset.Clientset) error
• type ProviderServices
  • func (p ProviderServices) CloudFormation() cloudformationiface.CloudFormationAPI
  • func (p ProviderServices) EC2() ec2iface.EC2API
  • func (p ProviderServices) EKS() eksiface.EKSAPI
  • func (p ProviderServices) STS() stsiface.STSAPI
• type ProviderStatus

Types

type ClientConfig

type ClientConfig struct {
	Client      *clientcmdapi.Config
	Cluster     *api.ClusterConfig
	ClusterName string
	ContextName string
	// contains filtered or unexported fields
}

func (*ClientConfig) NewClientSet

func (c *ClientConfig) NewClientSet() (*clientset.Clientset, error)

func (*ClientConfig) NewClientSetWithEmbeddedToken

func (c *ClientConfig) NewClientSetWithEmbeddedToken() (*clientset.Clientset, error)

func (*ClientConfig) WithEmbeddedToken

func (c *ClientConfig) WithEmbeddedToken() (*ClientConfig, error)

func (*ClientConfig) WithExecAuthenticator

func (c *ClientConfig) WithExecAuthenticator() *ClientConfig

WithExecAuthenticator creates a copy of ClientConfig with authenticator exec plugin it ensures that AWS_PROFILE environment variable gets added to config also

type ClusterProvider

type ClusterProvider struct {
	// core fields used for config and AWS APIs
	Spec     *api.ClusterConfig
	Provider api.ClusterProvider
	// informative fields, i.e. used as outputs
	Status *ProviderStatus
}

func New

func New(clusterConfig *api.ClusterConfig) *ClusterProvider

func (*ClusterProvider) AddDefaultStorageClass

func (c *ClusterProvider) AddDefaultStorageClass(clientSet *clientset.Clientset) error

func (*ClusterProvider) CheckAuth

func (c *ClusterProvider) CheckAuth() error

func (*ClusterProvider) CreateDefaultNodeGroupAuthConfigMap

func (c *ClusterProvider) CreateDefaultNodeGroupAuthConfigMap(clientSet *clientset.Clientset) error

func (*ClusterProvider) DeprecatedDeleteControlPlane

func (c *ClusterProvider) DeprecatedDeleteControlPlane() error

func (*ClusterProvider) DescribeControlPlane

func (c *ClusterProvider) DescribeControlPlane() (*awseks.Cluster, error)

func (*ClusterProvider) EnsureAMI

func (c *ClusterProvider) EnsureAMI() error

EnsureAMI ensures that the node AMI is set and is available

func (*ClusterProvider) GetCredentials

func (c *ClusterProvider) GetCredentials(cluster awseks.Cluster) error

func (*ClusterProvider) GetCredentialsEnv

func (c *ClusterProvider) GetCredentialsEnv() ([]string, error)

func (*ClusterProvider) ListAllTaggedResources

func (c *ClusterProvider) ListAllTaggedResources() error

func (*ClusterProvider) ListClusters

func (c *ClusterProvider) ListClusters(chunkSize int, output string) error

ListClusters display details of all the EKS cluster in your account

func (*ClusterProvider) LoadSSHPublicKey

func (c *ClusterProvider) LoadSSHPublicKey() error

func (*ClusterProvider) MaybeDeletePublicSSHKey

func (c *ClusterProvider) MaybeDeletePublicSSHKey()

func (*ClusterProvider) NewClientConfig

func (c *ClusterProvider) NewClientConfig() (*ClientConfig, error)

based on "k8s.io/kubernetes/cmd/kubeadm/app/util/kubeconfig" these are small, so we can copy these, and no need to deal with k/k as dependency

func (*ClusterProvider) NewStackManager

func (c *ClusterProvider) NewStackManager() *manager.StackCollection

func (*ClusterProvider) SetAvailabilityZones

func (c *ClusterProvider) SetAvailabilityZones(given []string) error

func (*ClusterProvider) WaitForControlPlane

func (c *ClusterProvider) WaitForControlPlane(clientSet *kubernetes.Clientset) error

func (*ClusterProvider) WaitForNodes

func (c *ClusterProvider) WaitForNodes(clientSet *clientset.Clientset) error

type ProviderServices

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

func (ProviderServices) CloudFormation

func (p ProviderServices) CloudFormation() cloudformationiface.CloudFormationAPI

func (ProviderServices) EC2

func (p ProviderServices) EC2() ec2iface.EC2API

func (ProviderServices) EKS

func (p ProviderServices) EKS() eksiface.EKSAPI

func (ProviderServices) STS

func (p ProviderServices) STS() stsiface.STSAPI

type ProviderStatus

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