aws

Documentation

Index

• func GetCredentialsForCluster(cloud kubermaticv1.CloudSpec, ...) (accessKeyID, secretAccessKey string, err error)
• func GetSubnets(accessKeyID, secretAccessKey, region, vpcID string) ([]*ec2.Subnet, error)
• func GetVPCS(accessKeyID, secretAccessKey, region string) ([]*ec2.Vpc, error)
• type AmazonEC2
  • func NewCloudProvider(dc *kubermaticv1.Datacenter, ...) (*AmazonEC2, error)
  • func (a *AmazonEC2) AddICMPRulesIfRequired(cluster *kubermaticv1.Cluster) error
  • func (a *AmazonEC2) CleanUpCloudProvider(cluster *kubermaticv1.Cluster, updater provider.ClusterUpdater) (*kubermaticv1.Cluster, error)
  • func (a *AmazonEC2) DefaultCloudSpec(spec *kubermaticv1.CloudSpec) error
  • func (a *AmazonEC2) InitializeCloudProvider(cluster *kubermaticv1.Cluster, update provider.ClusterUpdater) (*kubermaticv1.Cluster, error)
  • func (a *AmazonEC2) MigrateToMultiAZ(cluster *kubermaticv1.Cluster, clusterUpdater provider.ClusterUpdater) error
  • func (a *AmazonEC2) ValidateCloudSpec(spec kubermaticv1.CloudSpec) error
  • func (a *AmazonEC2) ValidateCloudSpecUpdate(oldSpec kubermaticv1.CloudSpec, newSpec kubermaticv1.CloudSpec) error
• type ClientSet
  • func GetClientSet(accessKeyID, secretAccessKey, region string) (*ClientSet, error)

Functions

func GetCredentialsForCluster

func GetCredentialsForCluster(cloud kubermaticv1.CloudSpec, secretKeySelector provider.SecretKeySelectorValueFunc) (accessKeyID, secretAccessKey string, err error)

GetCredentialsForCluster returns the credentials for the passed in cloud spec or an error

func GetSubnets

func GetSubnets(accessKeyID, secretAccessKey, region, vpcID string) ([]*ec2.Subnet, error)

GetSubnets returns the list of subnets for a selected AWS vpc.

func GetVPCS

func GetVPCS(accessKeyID, secretAccessKey, region string) ([]*ec2.Vpc, error)

GetVPCS returns the list of AWS VPC's.

Types

type AmazonEC2

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

func NewCloudProvider

func NewCloudProvider(dc *kubermaticv1.Datacenter, secretKeyGetter provider.SecretKeySelectorValueFunc) (*AmazonEC2, error)

NewCloudProvider returns a new AmazonEC2 provider.

func (*AmazonEC2) AddICMPRulesIfRequired

func (a *AmazonEC2) AddICMPRulesIfRequired(cluster *kubermaticv1.Cluster) error

AddICMPRulesIfRequired will create security rules that allow ICMP traffic if these do not yet exist. It is a part of a migration for older clusers (migrationRevision < 1) that didn't have these rules.

func (*AmazonEC2) CleanUpCloudProvider

func (a *AmazonEC2) CleanUpCloudProvider(cluster *kubermaticv1.Cluster, updater provider.ClusterUpdater) (*kubermaticv1.Cluster, error)

func (*AmazonEC2) DefaultCloudSpec

func (a *AmazonEC2) DefaultCloudSpec(spec *kubermaticv1.CloudSpec) error

func (*AmazonEC2) InitializeCloudProvider

func (a *AmazonEC2) InitializeCloudProvider(cluster *kubermaticv1.Cluster, update provider.ClusterUpdater) (*kubermaticv1.Cluster, error)

func (*AmazonEC2) MigrateToMultiAZ

func (a *AmazonEC2) MigrateToMultiAZ(cluster *kubermaticv1.Cluster, clusterUpdater provider.ClusterUpdater) error

MigrateToMultiAZ migrates an AWS cluster from the old AZ-hardcoded spec to multi-AZ spec

func (*AmazonEC2) ValidateCloudSpec

func (a *AmazonEC2) ValidateCloudSpec(spec kubermaticv1.CloudSpec) error

func (*AmazonEC2) ValidateCloudSpecUpdate

func (a *AmazonEC2) ValidateCloudSpecUpdate(oldSpec kubermaticv1.CloudSpec, newSpec kubermaticv1.CloudSpec) error

ValidateCloudSpecUpdate verifies whether an update of cloud spec is valid and permitted

type ClientSet

type ClientSet struct {
	EC2 ec2iface.EC2API
	IAM iamiface.IAMAPI
}

func GetClientSet

func GetClientSet(accessKeyID, secretAccessKey, region string) (*ClientSet, error)