instancetype

Documentation

Index

• Constants
• Variables
• func ENILimitedPods(ctx context.Context, info ec2types.InstanceTypeInfo) *resource.Quantity
• func NewInstanceType(ctx context.Context, info ec2types.InstanceTypeInfo, region string, ...) *cloudprovider.InstanceType
• type DefaultProvider
  • func NewDefaultProvider(instanceTypesCache *cache.Cache, offeringCache *cache.Cache, ...) *DefaultProvider
  • func (p *DefaultProvider) List(ctx context.Context, nodeClass *v1.EC2NodeClass) ([]*cloudprovider.InstanceType, error)
  • func (p *DefaultProvider) Reset()
  • func (p *DefaultProvider) UpdateInstanceTypeCapacityFromNode(ctx context.Context, node *corev1.Node, nodeClaim *karpv1.NodeClaim, ...) error
  • func (p *DefaultProvider) UpdateInstanceTypeOfferings(ctx context.Context) error
  • func (p *DefaultProvider) UpdateInstanceTypes(ctx context.Context) error
• type DefaultResolver
  • func NewDefaultResolver(region string) *DefaultResolver
  • func (d *DefaultResolver) CacheKey(nodeClass *v1.EC2NodeClass) string
  • func (d *DefaultResolver) Resolve(ctx context.Context, info ec2types.InstanceTypeInfo, zones []string, ...) *cloudprovider.InstanceType
• type NetworkCard
• type Provider
• type Resolver
• type VPCLimits
• type ZoneData

Constants

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

Variables

var (
	InstanceTypeVCPU = opmetrics.NewPrometheusGauge(
		crmetrics.Registry,
		prometheus.GaugeOpts{
			Namespace: metrics.Namespace,
			Subsystem: cloudProviderSubsystem,
			Name:      "instance_type_cpu_cores",
			Help:      "VCPUs cores for a given instance type.",
		},
		[]string{
			instanceTypeLabel,
		},
	)
	InstanceTypeMemory = opmetrics.NewPrometheusGauge(
		crmetrics.Registry,
		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{}/* 838 elements not displayed */

)

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

VPC Limits and flags for ENI and IPv4 Addresses

Functions

func ENILimitedPods

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

func NewInstanceType

func NewInstanceType(
	ctx context.Context,
	info ec2types.InstanceTypeInfo,
	region string,
	offeringZones []string,
	subnetZonesToZoneIDs map[string]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,
	amiFamilyType string,
	capacityReservations []v1.CapacityReservation,
) *cloudprovider.InstanceType

Types

type DefaultProvider

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

func NewDefaultProvider

func NewDefaultProvider(
	instanceTypesCache *cache.Cache,
	offeringCache *cache.Cache,
	discoveredCapacityCache *cache.Cache,
	ec2api sdk.EC2API,
	subnetProvider subnet.Provider,
	pricingProvider pricing.Provider,
	capacityReservationProvider capacityreservation.Provider,
	unavailableOfferingsCache *awscache.UnavailableOfferings,
	instanceTypesResolver Resolver,
) *DefaultProvider

func (*DefaultProvider) List

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

func (*DefaultProvider) Reset

func (p *DefaultProvider) Reset()

func (*DefaultProvider) UpdateInstanceTypeCapacityFromNode

func (p *DefaultProvider) UpdateInstanceTypeCapacityFromNode(ctx context.Context, node *corev1.Node, nodeClaim *karpv1.NodeClaim, nodeClass *v1.EC2NodeClass) error

func (*DefaultProvider) UpdateInstanceTypeOfferings

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

func (*DefaultProvider) UpdateInstanceTypes

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

type DefaultResolver

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

func NewDefaultResolver

func NewDefaultResolver(region string) *DefaultResolver

func (*DefaultResolver) CacheKey

func (d *DefaultResolver) CacheKey(nodeClass *v1.EC2NodeClass) string

func (*DefaultResolver) Resolve

func (d *DefaultResolver) Resolve(ctx context.Context, info ec2types.InstanceTypeInfo, zones []string, zonesToZoneIDs map[string]string, nodeClass *v1.EC2NodeClass) *cloudprovider.InstanceType

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 {
	List(context.Context, *v1.EC2NodeClass) ([]*cloudprovider.InstanceType, error)
}

type Resolver

type Resolver interface {
	// CacheKey tells the InstanceType cache if something changes about the InstanceTypes or Offerings based on the NodeClass.
	CacheKey(nodeClass *v1.EC2NodeClass) string
	// Resolve generates an InstanceType based on raw InstanceTypeInfo and NodeClass setting data
	Resolve(ctx context.Context, info ec2types.InstanceTypeInfo, zones []string, zonesToZoneIDs map[string]string, nodeClass *v1.EC2NodeClass) *cloudprovider.InstanceType
}

type VPCLimits

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

type ZoneData

type ZoneData struct {
	Name      string
	ID        string
	Available bool
}