eks

Documentation

Index

• Constants
• func New(ctx context.Context) Interface
• func NewConnector(ctx context.Context, cluster *api.Cluster) (*cloudConnector, error)
• type ClusterManager
  • func (cm *ClusterManager) Apply(in *api.Cluster, dryRun bool) ([]api.Action, error)
  • func (cm *ClusterManager) GetAdminClient() (kubernetes.Interface, error)
  • func (cm *ClusterManager) GetDefaultNodeSpec(cluster *api.Cluster, sku string) (api.NodeSpec, error)
  • func (cm *ClusterManager) GetEKSAdminClient() (kubernetes.Interface, error)
  • func (cm *ClusterManager) GetKubeConfig(cluster *api.Cluster) (*api.KubeConfig, error)
  • func (cm *ClusterManager) GetSSHConfig(cluster *api.Cluster, node *core.Node) (*api.SSHConfig, error)
  • func (cm *ClusterManager) IsValid(cluster *api.Cluster) (bool, error)
  • func (cm *ClusterManager) SetDefaults(cluster *api.Cluster) error
• type EKSNodeGroupManager
  • func NewEKSNodeGroupManager(ctx context.Context, conn *cloudConnector, ng *api.NodeGroup, ...) *EKSNodeGroupManager
  • func (igm *EKSNodeGroupManager) Apply(dryRun bool) (acts []api.Action, err error)

Constants

const (
	UID              = "eks"
	RoleClusterUser  = "clusterUser"
	RoleClusterAdmin = "clusterAdmin"

	EKSNodeConfigMap  = "aws-auth"
	EKSConfigMapRoles = "mapRoles"
	EKSVPCUrl         = "https://amazon-eks.s3-us-west-2.amazonaws.com/1.10.3/2018-06-05/amazon-eks-vpc-sample.yaml"
	ServiceRoleUrl    = "https://amazon-eks.s3-us-west-2.amazonaws.com/1.10.3/2018-06-05/amazon-eks-service-role.yaml"
	NodeGroupUrl      = "https://amazon-eks.s3-us-west-2.amazonaws.com/1.10.3/2018-06-05/amazon-eks-nodegroup.yaml"
)

const (
	AmazonEKSClusterPolicy = `` /* 3124-byte string literal not displayed */

	AmazonEKSServicePolicy = `` /* 920-byte string literal not displayed */

)

Functions

func New

func New(ctx context.Context) Interface

func NewConnector

func NewConnector(ctx context.Context, cluster *api.Cluster) (*cloudConnector, error)

Types

type ClusterManager

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

func (*ClusterManager) Apply

func (cm *ClusterManager) Apply(in *api.Cluster, dryRun bool) ([]api.Action, error)

func (*ClusterManager) GetAdminClient

func (cm *ClusterManager) GetAdminClient() (kubernetes.Interface, error)

func (*ClusterManager) GetDefaultNodeSpec

func (cm *ClusterManager) GetDefaultNodeSpec(cluster *api.Cluster, sku string) (api.NodeSpec, error)

func (*ClusterManager) GetEKSAdminClient

func (cm *ClusterManager) GetEKSAdminClient() (kubernetes.Interface, error)

func (*ClusterManager) GetKubeConfig

func (cm *ClusterManager) GetKubeConfig(cluster *api.Cluster) (*api.KubeConfig, error)

func (*ClusterManager) GetSSHConfig

func (cm *ClusterManager) GetSSHConfig(cluster *api.Cluster, node *core.Node) (*api.SSHConfig, error)

func (*ClusterManager) IsValid

func (cm *ClusterManager) IsValid(cluster *api.Cluster) (bool, error)

func (*ClusterManager) SetDefaults

func (cm *ClusterManager) SetDefaults(cluster *api.Cluster) error

type EKSNodeGroupManager

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

func NewEKSNodeGroupManager

func NewEKSNodeGroupManager(ctx context.Context, conn *cloudConnector, ng *api.NodeGroup, kc kubernetes.Interface) *EKSNodeGroupManager

func (*EKSNodeGroupManager) Apply

func (igm *EKSNodeGroupManager) Apply(dryRun bool) (acts []api.Action, err error)