instancetype

Documentation

Index

• Constants
• func NewInstanceType(ctx context.Context, ...) *cloudprovider.InstanceType
• type DefaultProvider
  • func NewDefaultProvider(region string, ecsClient *ecsclient.Client, instanceTypesCache *cache.Cache, ...) *DefaultProvider
  • func (p *DefaultProvider) List(ctx context.Context, kc *v1alpha1.KubeletConfiguration, ...) ([]*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 Provider
• type ZoneData

Constants

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

	GiBMiBRatio              = 1024
	MiBByteRatio             = 1024 * 1024
	TerwayMinENIRequirements = 11
	BaseHostNetworkPods      = 3
	FlannelDefaultPods       = 256

	ClusterCNITypeTerway  = "terway-eniip"
	ClusterCNITypeFlannel = "Flannel"
)

Functions

func NewInstanceType

func NewInstanceType(ctx context.Context,
	info *ecsclient.DescribeInstanceTypesResponseBodyInstanceTypesInstanceType,
	kc *v1alpha1.KubeletConfiguration, region string, systemDisk *v1alpha1.SystemDisk,
	offerings cloudprovider.Offerings, clusterCNI string) *cloudprovider.InstanceType

Types

type DefaultProvider

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

func NewDefaultProvider

func NewDefaultProvider(region string, ecsClient *ecsclient.Client,
	instanceTypesCache *cache.Cache, unavailableOfferingsCache *kcache.UnavailableOfferings,
	pricingProvider pricing.Provider, ackProvider ack.Provider) *DefaultProvider

func (*DefaultProvider) List

func (p *DefaultProvider) List(ctx context.Context, kc *v1alpha1.KubeletConfiguration, nodeClass *v1alpha1.ECSNodeClass) ([]*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 Provider

type Provider interface {
	LivenessProbe(*http.Request) error
	List(context.Context, *v1alpha1.KubeletConfiguration, *v1alpha1.ECSNodeClass) ([]*cloudprovider.InstanceType, error)
	UpdateInstanceTypes(ctx context.Context) error
	UpdateInstanceTypeOfferings(ctx context.Context) error
}

type ZoneData

type ZoneData struct {
	ID        string
	Available bool
}