eks

Documentation

Index

• Constants
• func ConvertMDStatus(status ekstypes.NodegroupStatus) apiv2.ExternalClusterMDState
• func ConvertStatus(status ekstypes.ClusterStatus) kubermaticv1.ExternalClusterPhase
• func CreateCluster(ctx context.Context, client *awsprovider.ClientSet, ...) error
• func CreateNodeGroup(ctx context.Context, client *awsprovider.ClientSet, ...) error
• func DecodeError(err error) error
• func DeleteCluster(ctx context.Context, client *awsprovider.ClientSet, eksClusterName string) error
• func DeleteNodegroup(ctx context.Context, client *awsprovider.ClientSet, ...) error
• func DescribeNodeGroup(ctx context.Context, client *awsprovider.ClientSet, ...) (*ekstypes.Nodegroup, error)
• func GetCluster(ctx context.Context, client *awsprovider.ClientSet, eksClusterName string) (*ekstypes.Cluster, error)
• func GetClusterConfig(ctx context.Context, accessKeyID, secretAccessKey, clusterName, region string) (*api.Config, error)
• func GetClusterStatus(ctx context.Context, secretKeySelector provider.SecretKeySelectorValueFunc, ...) (*kubermaticv1.ExternalClusterCondition, error)
• func ListClusters(ctx context.Context, client *awsprovider.ClientSet) ([]string, error)
• func ListMachineDeploymentUpgrades(ctx context.Context, creds EKSCredentials, ...) ([]*apiv1.MasterVersion, error)
• func ListNodegroups(ctx context.Context, client *awsprovider.ClientSet, clusterName string) ([]string, error)
• func ListUpgrades(ctx context.Context, cluster *kubermaticv1.ExternalCluster, ...) ([]*apiv1.MasterVersion, error)
• func ResizeNodeGroup(ctx context.Context, client *awsprovider.ClientSet, ...) (*eks.UpdateNodegroupConfigOutput, error)
• func UpgradeClusterVersion(ctx context.Context, client *awsprovider.ClientSet, version *semverlib.Version, ...) error
• func UpgradeNodeGroup(ctx context.Context, client *awsprovider.ClientSet, ...) (*eks.UpdateNodegroupVersionOutput, error)
• func ValidateCredentials(ctx context.Context, credential resources.EKSCredential) error
• type EKSCredentials
  • func GetCredentialsForCluster(cloud *kubermaticv1.ExternalClusterEKSCloudSpec, ...) (EKSCredentials, error)

Constants

const (
	EKSNodeGroupStatus = "ACTIVE"

	ARM64Architecture = "arm64"
	X64Architecture   = "x64"

	// The architecture of the machine image.
	// Used for EKS api endpoints.
	EKSARM64Architecture  = "arm64"
	EKSX86_64Architecture = "x86_64"
)

Functions

func ConvertMDStatus

func ConvertMDStatus(status ekstypes.NodegroupStatus) apiv2.ExternalClusterMDState

func ConvertStatus

func ConvertStatus(status ekstypes.ClusterStatus) kubermaticv1.ExternalClusterPhase

func CreateCluster

func CreateCluster(ctx context.Context, client *awsprovider.ClientSet, clusterSpec *apiv2.EKSClusterSpec, eksClusterName string) error

func CreateNodeGroup

func CreateNodeGroup(ctx context.Context,
	client *awsprovider.ClientSet,
	clusterName, nodeGroupName string,
	eksMDCloudSpec *apiv2.EKSMachineDeploymentCloudSpec) error

func DecodeError

func DecodeError(err error) error

func DeleteCluster

func DeleteCluster(ctx context.Context, client *awsprovider.ClientSet, eksClusterName string) error

func DeleteNodegroup

func DeleteNodegroup(ctx context.Context, client *awsprovider.ClientSet, clusterName, nodeGroupName string) error

func DescribeNodeGroup

func DescribeNodeGroup(ctx context.Context, client *awsprovider.ClientSet, clusterName, nodeGroupName string) (*ekstypes.Nodegroup, error)

func GetCluster

func GetCluster(ctx context.Context, client *awsprovider.ClientSet, eksClusterName string) (*ekstypes.Cluster, error)

func GetClusterConfig

func GetClusterConfig(ctx context.Context, accessKeyID, secretAccessKey, clusterName, region string) (*api.Config, error)

func GetClusterStatus

func GetClusterStatus(ctx context.Context, secretKeySelector provider.SecretKeySelectorValueFunc, cloudSpec *kubermaticv1.ExternalClusterEKSCloudSpec) (*kubermaticv1.ExternalClusterCondition, error)

func ListClusters

func ListClusters(ctx context.Context, client *awsprovider.ClientSet) ([]string, error)

func ListMachineDeploymentUpgrades

func ListMachineDeploymentUpgrades(ctx context.Context,
	creds EKSCredentials, region, clusterName, machineDeployment string) ([]*apiv1.MasterVersion, error)

func ListNodegroups

func ListNodegroups(ctx context.Context, client *awsprovider.ClientSet, clusterName string) ([]string, error)

func ListUpgrades

func ListUpgrades(ctx context.Context,
	cluster *kubermaticv1.ExternalCluster,
	clusterProvider provider.ExternalClusterProvider,
	configGetter provider.KubermaticConfigurationGetter) ([]*apiv1.MasterVersion, error)

func ResizeNodeGroup

func ResizeNodeGroup(ctx context.Context, client *awsprovider.ClientSet, clusterName, nodeGroupName string, currentSize, desiredSize int32) (*eks.UpdateNodegroupConfigOutput, error)

func UpgradeClusterVersion

func UpgradeClusterVersion(ctx context.Context, client *awsprovider.ClientSet, version *semverlib.Version, eksClusterName string) error

func UpgradeNodeGroup

func UpgradeNodeGroup(ctx context.Context, client *awsprovider.ClientSet, clusterName, nodeGroupName, currentVersion, desiredVersion *string) (*eks.UpdateNodegroupVersionOutput, error)

func ValidateCredentials

func ValidateCredentials(ctx context.Context, credential resources.EKSCredential) error

Types

type EKSCredentials

type EKSCredentials struct {
	AccessKeyID          string
	SecretAccessKey      string
	AssumeRoleARN        string
	AssumeRoleExternalID string
}

func GetCredentialsForCluster

func GetCredentialsForCluster(cloud *kubermaticv1.ExternalClusterEKSCloudSpec, secretKeySelector provider.SecretKeySelectorValueFunc) (EKSCredentials, error)