subnet

Documentation

Index

• type Provider
  • func NewProvider(ec2api ec2iface.EC2API, cache *cache.Cache) *Provider
  • func (p *Provider) CheckAnyPublicIPAssociations(ctx context.Context, nodeClass *v1beta1.EC2NodeClass) (bool, error)
  • func (p *Provider) List(ctx context.Context, nodeClass *v1beta1.EC2NodeClass) ([]*ec2.Subnet, error)
  • func (p *Provider) LivenessProbe(_ *http.Request) error
  • func (p *Provider) UpdateInflightIPs(createFleetInput *ec2.CreateFleetInput, ...)
  • func (p *Provider) ZonalSubnetsForLaunch(ctx context.Context, nodeClass *v1beta1.EC2NodeClass, ...) (map[string]*ec2.Subnet, error)

Types

type Provider

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

func NewProvider

func NewProvider(ec2api ec2iface.EC2API, cache *cache.Cache) *Provider

func (*Provider) CheckAnyPublicIPAssociations

func (p *Provider) CheckAnyPublicIPAssociations(ctx context.Context, nodeClass *v1beta1.EC2NodeClass) (bool, error)

CheckAnyPublicIPAssociations returns a bool indicating whether all referenced subnets assign public IPv4 addresses to EC2 instances created therein

func (*Provider) List

func (p *Provider) List(ctx context.Context, nodeClass *v1beta1.EC2NodeClass) ([]*ec2.Subnet, error)

func (*Provider) LivenessProbe

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

func (*Provider) UpdateInflightIPs

func (p *Provider) UpdateInflightIPs(createFleetInput *ec2.CreateFleetInput, createFleetOutput *ec2.CreateFleetOutput, instanceTypes []*cloudprovider.InstanceType,
	subnets []*ec2.Subnet, capacityType string)

UpdateInflightIPs is used to refresh the in-memory IP usage by adding back unused IPs after a CreateFleet response is returned

func (*Provider) ZonalSubnetsForLaunch

func (p *Provider) ZonalSubnetsForLaunch(ctx context.Context, nodeClass *v1beta1.EC2NodeClass, instanceTypes []*cloudprovider.InstanceType, capacityType string) (map[string]*ec2.Subnet, error)

ZonalSubnetsForLaunch returns a mapping of zone to the subnet with the most available IP addresses and deducts the passed ips from the available count