instancetype

Documentation

Index

• Constants
• Variables
• func ENILimitedPods(ctx context.Context, info *ec2.InstanceTypeInfo) *resource.Quantity
• func NewInstanceType(ctx context.Context, info *ec2.InstanceTypeInfo, region string, ...) *cloudprovider.InstanceType
• type DefaultProvider
  • func NewDefaultProvider(region string, instanceTypesCache *cache.Cache, ec2api ec2iface.EC2API, ...) *DefaultProvider
  • func (p *DefaultProvider) List(ctx context.Context, kc *v1.KubeletConfiguration, nodeClass *v1.EC2NodeClass) ([]*cloudprovider.InstanceType, error)
  • func (p *DefaultProvider) LivenessProbe(req *http.Request) error
  • func (p *DefaultProvider) Reset()
  • func (p *DefaultProvider) UpdateInstanceTypeOfferings(ctx context.Context) error
  • func (p *DefaultProvider) UpdateInstanceTypes(ctx context.Context) error
• type NetworkCard
• type Provider
• type VPCLimits

Constants

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

Variables

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

)

var Limits = map[string]*VPCLimits{}/* 774 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, region string,
	blockDeviceMappings []*v1.BlockDeviceMapping, instanceStorePolicy *v1.InstanceStorePolicy, maxPods *int32, podsPerCore *int32,
	kubeReserved map[string]string, systemReserved map[string]string, evictionHard map[string]string, evictionSoft map[string]string,
	amiFamily amifamily.AMIFamily, offerings cloudprovider.Offerings) *cloudprovider.InstanceType

Types

type DefaultProvider

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

func NewDefaultProvider

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

func (*DefaultProvider) List

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

func (*DefaultProvider) LivenessProbe

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

func (*DefaultProvider) Reset

func (p *DefaultProvider) Reset()

func (*DefaultProvider) UpdateInstanceTypeOfferings

func (p *DefaultProvider) UpdateInstanceTypeOfferings(ctx context.Context) error

func (*DefaultProvider) UpdateInstanceTypes

func (p *DefaultProvider) UpdateInstanceTypes(ctx context.Context) error

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 interface {
	LivenessProbe(*http.Request) error
	List(context.Context, *v1.KubeletConfiguration, *v1.EC2NodeClass) ([]*cloudprovider.InstanceType, error)
	UpdateInstanceTypes(ctx context.Context) error
	UpdateInstanceTypeOfferings(ctx context.Context) error
}

type VPCLimits

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