cloudprovider

package
v0.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 27, 2022 License: Apache-2.0 Imports: 55 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	InstanceTypesCacheKey           = "types"
	InstanceTypeZonesCacheKeyPrefix = "zones:"
	InstanceTypesAndZonesCacheTTL   = 5 * time.Minute
)
View Source 
const (
	// MaxInstanceTypes defines the number of instance type options to pass to CreateFleet
	MaxInstanceTypes = 60
)

Variables

View Source 
var Limits = map[string]*VPCLimits{}/* 560 elements not displayed */

VPC Limits and flags for ENI and IPv4 Addresses

Functions

func NewInstanceType added in v0.19.0 

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

func NewPricingAPI added in v0.19.0 

func NewPricingAPI(sess *session.Session, region string) pricingiface.PricingAPI

NewPricingAPI returns a pricing API configured based on a particular region

Types

type CloudProvider 

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

func New added in v0.19.0 

func New(ctx awscontext.Context) *CloudProvider

func (*CloudProvider) Create 

func (c *CloudProvider) Create(ctx context.Context, machine *corev1alpha1.Machine) (*v1.Node, error)

Create a node given the constraints.

func (*CloudProvider) Delete 

func (c *CloudProvider) Delete(ctx context.Context, machine *corev1alpha1.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 added in v0.21.0 

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

func (*CloudProvider) LivenessProbe added in v0.19.0 

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

func (*CloudProvider) Name added in v0.5.3 

func (c *CloudProvider) Name() string

Name returns the CloudProvider implementation name.

type CreateFleetBatcher added in v0.19.0 

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

CreateFleetBatcher is used to batch CreateFleet calls from the cloud provider with identical parameters into a single call that launches more instances simultaneously.

func NewCreateFleetBatcher added in v0.19.0 

func NewCreateFleetBatcher(ctx context.Context, ec2api ec2iface.EC2API) *CreateFleetBatcher

func (*CreateFleetBatcher) CreateFleet added in v0.19.0 

func (b *CreateFleetBatcher) CreateFleet(ctx context.Context, createFleetInput *ec2.CreateFleetInput) (*ec2.CreateFleetOutput, error)

type InstanceProvider added in v0.19.0 

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

func NewInstanceProvider added in v0.19.0 

func NewInstanceProvider(ctx context.Context, ec2api ec2iface.EC2API, instanceTypeProvider *InstanceTypeProvider, subnetProvider *SubnetProvider, launchTemplateProvider *LaunchTemplateProvider) *InstanceProvider

func (*InstanceProvider) Create added in v0.19.0 

func (p *InstanceProvider) Create(ctx context.Context, nodeTemplate *v1alpha1.AWSNodeTemplate, machine *corev1alpha1.Machine, instanceTypes []*cloudprovider.InstanceType) (*v1.Node, error)

Create an instance given the constraints. instanceTypes should be sorted by priority for spot capacity type. If spot is not used, the instanceTypes are not required to be sorted because we are using ec2 fleet's lowest-price OD allocation strategy

func (*InstanceProvider) Terminate added in v0.19.0 

func (p *InstanceProvider) Terminate(ctx context.Context, machine *corev1alpha1.Machine) error

type InstanceTypeProvider added in v0.19.0 

type InstanceTypeProvider struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewInstanceTypeProvider added in v0.19.0 

func NewInstanceTypeProvider(ctx context.Context, sess *session.Session, ec2api ec2iface.EC2API, subnetProvider *SubnetProvider,
	unavailableOfferingsCache *awscache.UnavailableOfferings, startAsync <-chan struct{}) *InstanceTypeProvider

func (*InstanceTypeProvider) Get added in v0.19.0 

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

Get all instance type options

func (*InstanceTypeProvider) LivenessProbe added in v0.19.0 

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

type LaunchTemplateProvider added in v0.19.0 

type LaunchTemplateProvider struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewLaunchTemplateProvider added in v0.19.0 

func NewLaunchTemplateProvider(ctx context.Context, ec2api ec2iface.EC2API, amiFamily *amifamily.Resolver, securityGroupProvider *SecurityGroupProvider, caBundle *string, startAsync <-chan struct{}, kubeDNSIP net.IP) *LaunchTemplateProvider

func (*LaunchTemplateProvider) Get added in v0.19.0 

func (p *LaunchTemplateProvider) Get(ctx context.Context, nodeTemplate *v1alpha1.AWSNodeTemplate, machine *corev1alpha1.Machine,
	instanceTypes []*cloudprovider.InstanceType, additionalLabels map[string]string) (map[string][]*cloudprovider.InstanceType, error)

func (*LaunchTemplateProvider) Invalidate added in v0.19.0 

func (p *LaunchTemplateProvider) Invalidate(ctx context.Context, ltName string, ltID string)

Invalidate deletes a launch template from cache if it exists

type PricingProvider added in v0.19.0 

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

PricingProvider provides actual pricing data to the AWS cloud provider to allow it to make more informed decisions regarding which instances to launch. This is initialized at startup with a periodically updated static price list to support running in locations where pricing data is unavailable. In those cases the static pricing data provides a relative ordering that is still more accurate than our previous pricing model. In the event that a pricing update fails, the previous pricing information is retained and used which may be the static initial pricing data if pricing updates never succeed.

func NewPricingProvider added in v0.19.0 

func NewPricingProvider(ctx context.Context, pricing pricingiface.PricingAPI, ec2Api ec2iface.EC2API, region string, isolatedVPC bool, startAsync <-chan struct{}) *PricingProvider

func (*PricingProvider) InstanceTypes added in v0.19.0 

func (p *PricingProvider) InstanceTypes() []string

InstanceTypes returns the list of all instance types for which either a spot or on-demand price is known.

func (*PricingProvider) LivenessProbe added in v0.19.0 

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

func (*PricingProvider) OnDemandLastUpdated added in v0.19.0 

func (p *PricingProvider) OnDemandLastUpdated() time.Time

OnDemandLastUpdated returns the time that the on-demand pricing was last updated

func (*PricingProvider) OnDemandPrice added in v0.19.0 

func (p *PricingProvider) OnDemandPrice(instanceType string) (float64, bool)

OnDemandPrice returns the last known on-demand price for a given instance type, returning an error if there is no known on-demand pricing for the instance type.

func (*PricingProvider) SpotLastUpdated added in v0.19.0 

func (p *PricingProvider) SpotLastUpdated() time.Time

SpotLastUpdated returns the time that the spot pricing was last updated

func (*PricingProvider) SpotPrice added in v0.19.0 

func (p *PricingProvider) SpotPrice(instanceType string, zone string) (float64, bool)

SpotPrice returns the last known spot price for a given instance type and zone, returning an error if there is no known spot pricing for that instance type or zone

type SecurityGroupProvider added in v0.19.0 

type SecurityGroupProvider struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSecurityGroupProvider added in v0.19.0 

func NewSecurityGroupProvider(ec2api ec2iface.EC2API) *SecurityGroupProvider

func (*SecurityGroupProvider) Get added in v0.19.0 

func (p *SecurityGroupProvider) Get(ctx context.Context, nodeTemplate *v1alpha1.AWSNodeTemplate) ([]string, error)

type SubnetProvider added in v0.19.0 

type SubnetProvider struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSubnetProvider added in v0.19.0 

func NewSubnetProvider(ec2api ec2iface.EC2API) *SubnetProvider

func (*SubnetProvider) Get added in v0.19.0 

func (p *SubnetProvider) Get(ctx context.Context, nodeTemplate *v1alpha1.AWSNodeTemplate) ([]*ec2.Subnet, error)

func (*SubnetProvider) LivenessProbe added in v0.19.0 

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

type VPCLimits added in v0.19.0 

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

Source Files

View all Source files

Directories

Path Synopsis
bootstrap

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.