instancetype

Documentation

Index

• Constants
• Variables
• func ENILimitedPods(ctx context.Context, info *ec2.InstanceTypeInfo) *resource.Quantity
• func NewInstanceType(ctx context.Context, info *ec2.InstanceTypeInfo, ...) *cloudprovider.InstanceType
• type NetworkCard
• type Provider
  • func NewProvider(region string, cache *cache.Cache, ec2api ec2iface.EC2API, ...) *Provider
  • func (p *Provider) GetInstanceTypes(ctx context.Context) ([]*ec2.InstanceTypeInfo, error)
  • func (p *Provider) List(ctx context.Context, kc *corev1beta1.KubeletConfiguration, ...) ([]*cloudprovider.InstanceType, error)
  • func (p *Provider) LivenessProbe(req *http.Request) error
• type VPCLimits

Constants

const (
	InstanceTypesCacheKey         = "types"
	InstanceTypeOfferingsCacheKey = "offerings"
	ZonesCacheKey                 = "zones"
)

const (
	MemoryAvailable = "memory.available"
	NodeFSAvailable = "nodefs.available"
)

Variables

var (
	InstanceTypeLabel = "instance_type"

	InstanceTypeVCPU = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: metrics.Namespace,
			Subsystem: cloudProviderSubsystem,
			Name:      "instance_type_cpu_cores",
			Help:      "VCPUs cores for a given instance type.",
		},
		[]string{
			InstanceTypeLabel,
		})

	InstanceTypeMemory = prometheus.NewGaugeVec(
		prometheus.GaugeOpts{
			Namespace: metrics.Namespace,
			Subsystem: cloudProviderSubsystem,
			Name:      "instance_type_memory_bytes",
			Help:      "Memory, in bytes, for a given instance type.",
		},
		[]string{
			InstanceTypeLabel,
		})
)

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

)

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

VPC Limits and flags for ENI and IPv4 Addresses

Functions

func ENILimitedPods

func ENILimitedPods(ctx context.Context, info *ec2.InstanceTypeInfo) *resource.Quantity

func NewInstanceType

func NewInstanceType(ctx context.Context, info *ec2.InstanceTypeInfo, kc *corev1beta1.KubeletConfiguration,
	region string, nodeClass *v1beta1.EC2NodeClass, offerings cloudprovider.Offerings) *cloudprovider.InstanceType

Types

type NetworkCard

type NetworkCard struct {
	// max number of interfaces supported per card
	MaximumNetworkInterfaces int64
	// the index of current card
	NetworkCardIndex   int64
	NetworkPerformance string
}

type Provider

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

func NewProvider

func NewProvider(region string, cache *cache.Cache, ec2api ec2iface.EC2API, subnetProvider *subnet.Provider,
	unavailableOfferingsCache *awscache.UnavailableOfferings, pricingProvider *pricing.Provider) *Provider

func (*Provider) GetInstanceTypes

func (p *Provider) GetInstanceTypes(ctx context.Context) ([]*ec2.InstanceTypeInfo, error)

GetInstanceTypes retrieves all instance types from the ec2 DescribeInstanceTypes API using some opinionated filters

func (*Provider) List

func (p *Provider) List(ctx context.Context, kc *corev1beta1.KubeletConfiguration, nodeClass *v1beta1.EC2NodeClass) ([]*cloudprovider.InstanceType, error)

func (*Provider) LivenessProbe

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

type VPCLimits

type VPCLimits struct {
	Interface               int
	IPv4PerInterface        int
	IsTrunkingCompatible    bool
	BranchInterface         int
	NetworkCards            []NetworkCard
	DefaultNetworkCardIndex int
	Hypervisor              string
	IsBareMetal             bool
}