cloudprovider

Documentation

Index

• Constants
• Variables
• func NewInstanceType(ctx context.Context, info *ec2.InstanceTypeInfo, ...) *cloudprovider.InstanceType
• type CloudProvider
  • func New(ctx awscontext.Context) *CloudProvider
  • func (c *CloudProvider) Create(ctx context.Context, machine *v1alpha5.Machine) (*v1alpha5.Machine, error)
  • func (c *CloudProvider) Delete(ctx context.Context, machine *v1alpha5.Machine) error
  • func (c *CloudProvider) Get(ctx context.Context, providerID string) (*v1alpha5.Machine, error)
  • func (c *CloudProvider) GetInstanceTypes(ctx context.Context, provisioner *v1alpha5.Provisioner) ([]*cloudprovider.InstanceType, error)
  • func (c *CloudProvider) IsMachineDrifted(ctx context.Context, machine *v1alpha5.Machine) (bool, error)
  • func (c *CloudProvider) Link(ctx context.Context, machine *v1alpha5.Machine) error
  • func (c *CloudProvider) List(ctx context.Context) ([]*v1alpha5.Machine, error)
  • func (c *CloudProvider) LivenessProbe(req *http.Request) error
  • func (c *CloudProvider) Name() string
• type InstanceProvider
  • func NewInstanceProvider(ctx context.Context, region string, ec2api ec2iface.EC2API, ...) *InstanceProvider
  • func (p *InstanceProvider) Create(ctx context.Context, nodeTemplate *v1alpha1.AWSNodeTemplate, ...) (*ec2.Instance, error)
  • func (p *InstanceProvider) Delete(ctx context.Context, id string) error
  • func (p *InstanceProvider) Get(ctx context.Context, id string) (*ec2.Instance, error)
  • func (p *InstanceProvider) Link(ctx context.Context, id string) error
  • func (p *InstanceProvider) List(ctx context.Context) ([]*ec2.Instance, error)
  • func (p *InstanceProvider) Update(ctx context.Context, machine *v1alpha5.Machine) (*ec2.Instance, error)
• type InstanceTypeProvider
  • func NewInstanceTypeProvider(sess *session.Session, ec2api ec2iface.EC2API, subnetProvider *subnet.Provider, ...) *InstanceTypeProvider
  • func (p *InstanceTypeProvider) List(ctx context.Context, kc *v1alpha5.KubeletConfiguration, ...) ([]*cloudprovider.InstanceType, error)
  • func (p *InstanceTypeProvider) LivenessProbe(req *http.Request) error
• type VPCLimits

Constants

const (
	InstanceTypesCacheKey           = "types"
	InstanceTypeZonesCacheKeyPrefix = "zones:"
)

const (
	// MaxInstanceTypes defines the number of instance type options to pass to CreateFleet
	MaxInstanceTypes = 60
)

Variables

var (
	InstanceTypeBandwidthMegabits = map[string]int64{}/* 615 elements not displayed */

)

var Limits = map[string]*VPCLimits{}/* 605 elements not displayed */

VPC Limits and flags for ENI and IPv4 Addresses

Functions

func NewInstanceType

func NewInstanceType(ctx context.Context, info *ec2.InstanceTypeInfo, kc *v1alpha5.KubeletConfiguration,
	region string, nodeTemplate *v1alpha1.AWSNodeTemplate, offerings cloudprovider.Offerings) *cloudprovider.InstanceType

Types

type CloudProvider

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

func New

func New(ctx awscontext.Context) *CloudProvider

func (*CloudProvider) Create

func (c *CloudProvider) Create(ctx context.Context, machine *v1alpha5.Machine) (*v1alpha5.Machine, error)

Create a machine given the constraints.

func (*CloudProvider) Delete

func (c *CloudProvider) Delete(ctx context.Context, machine *v1alpha5.Machine) error

func (*CloudProvider) Get

func (c *CloudProvider) Get(ctx context.Context, providerID string) (*v1alpha5.Machine, error)

func (*CloudProvider) GetInstanceTypes

func (c *CloudProvider) GetInstanceTypes(ctx context.Context, provisioner *v1alpha5.Provisioner) ([]*cloudprovider.InstanceType, error)

GetInstanceTypes returns all available InstanceTypes

func (*CloudProvider) IsMachineDrifted

func (c *CloudProvider) IsMachineDrifted(ctx context.Context, machine *v1alpha5.Machine) (bool, error)

func (*CloudProvider) Link

func (c *CloudProvider) Link(ctx context.Context, machine *v1alpha5.Machine) error

Link adds a tag to the cloudprovider machine to tell the cloudprovider that it's now owned by a Machine

func (*CloudProvider) List

func (c *CloudProvider) List(ctx context.Context) ([]*v1alpha5.Machine, error)

func (*CloudProvider) LivenessProbe

func (c *CloudProvider) LivenessProbe(req *http.Request) error

func (*CloudProvider) Name

func (c *CloudProvider) Name() string

Name returns the CloudProvider implementation name.

type InstanceProvider

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

func NewInstanceProvider

func NewInstanceProvider(ctx context.Context, region string, ec2api ec2iface.EC2API, unavailableOfferings *cache.UnavailableOfferings, instanceTypeProvider *InstanceTypeProvider, subnetProvider *subnet.Provider, launchTemplateProvider *launchtemplate.Provider) *InstanceProvider

func (*InstanceProvider) Create

func (p *InstanceProvider) Create(ctx context.Context, nodeTemplate *v1alpha1.AWSNodeTemplate, machine *v1alpha5.Machine, instanceTypes []*cloudprovider.InstanceType) (*ec2.Instance, error)

func (*InstanceProvider) Delete

func (p *InstanceProvider) Delete(ctx context.Context, id string) error

func (*InstanceProvider) Get

func (p *InstanceProvider) Get(ctx context.Context, id string) (*ec2.Instance, error)

func (*InstanceProvider) Link

func (p *InstanceProvider) Link(ctx context.Context, id string) error

func (*InstanceProvider) List

func (p *InstanceProvider) List(ctx context.Context) ([]*ec2.Instance, error)

func (*InstanceProvider) Update

func (p *InstanceProvider) Update(ctx context.Context, machine *v1alpha5.Machine) (*ec2.Instance, error)

Update receives a machine and updates the EC2 instance with tags linking it to the machine Deprecated: This function can be removed when v1alpha6/v1beta1 migration has completed.

type InstanceTypeProvider

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

func NewInstanceTypeProvider

func NewInstanceTypeProvider(sess *session.Session, ec2api ec2iface.EC2API, subnetProvider *subnet.Provider,
	unavailableOfferingsCache *awscache.UnavailableOfferings, pricingProvider *pricing.Provider) *InstanceTypeProvider

func (*InstanceTypeProvider) List

func (p *InstanceTypeProvider) List(ctx context.Context, kc *v1alpha5.KubeletConfiguration, nodeTemplate *v1alpha1.AWSNodeTemplate) ([]*cloudprovider.InstanceType, error)

func (*InstanceTypeProvider) LivenessProbe

func (p *InstanceTypeProvider) LivenessProbe(req *http.Request) error

type VPCLimits

type VPCLimits struct {
	Interface            int
	IPv4PerInterface     int
	IsTrunkingCompatible bool
	BranchInterface      int
}