instance

Documentation

Index

• func GetCreateFleetInput(nodeClass *v1.EC2NodeClass, capacityType string, tags map[string]string, ...) *ec2.CreateFleetInput
• type DefaultProvider
  • func NewDefaultProvider(ctx context.Context, region string, ec2api sdk.EC2API, ...) *DefaultProvider
  • func (p *DefaultProvider) Create(ctx context.Context, nodeClass *v1.EC2NodeClass, nodeClaim *karpv1.NodeClaim, ...) (*Instance, error)
  • func (p *DefaultProvider) CreateTags(ctx context.Context, id string, tags map[string]string) error
  • func (p *DefaultProvider) Delete(ctx context.Context, id string) error
  • func (p *DefaultProvider) Get(ctx context.Context, id string) (*Instance, error)
  • func (p *DefaultProvider) List(ctx context.Context) ([]*Instance, error)
• type Instance
  • func NewInstance(out ec2types.Instance) *Instance
  • func NewInstanceFromFleet(out ec2types.CreateFleetInstance, tags map[string]string, capacityType string, ...) *Instance
• type Provider

Functions

func GetCreateFleetInput

func GetCreateFleetInput(nodeClass *v1.EC2NodeClass, capacityType string, tags map[string]string, launchTemplateConfigs []ec2types.FleetLaunchTemplateConfigRequest) *ec2.CreateFleetInput

Types

type DefaultProvider

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

func NewDefaultProvider

func NewDefaultProvider(
	ctx context.Context,
	region string,
	ec2api sdk.EC2API,
	unavailableOfferings *cache.UnavailableOfferings,
	subnetProvider subnet.Provider,
	launchTemplateProvider launchtemplate.Provider,
	capacityReservationProvider capacityreservation.Provider,
) *DefaultProvider

func (*DefaultProvider) Create

func (p *DefaultProvider) Create(ctx context.Context, nodeClass *v1.EC2NodeClass, nodeClaim *karpv1.NodeClaim, tags map[string]string, instanceTypes []*cloudprovider.InstanceType) (*Instance, error)

func (*DefaultProvider) CreateTags

func (p *DefaultProvider) CreateTags(ctx context.Context, id string, tags map[string]string) error

func (*DefaultProvider) Delete

func (p *DefaultProvider) Delete(ctx context.Context, id string) error

func (*DefaultProvider) Get

func (p *DefaultProvider) Get(ctx context.Context, id string) (*Instance, error)

func (*DefaultProvider) List

func (p *DefaultProvider) List(ctx context.Context) ([]*Instance, error)

type Instance

type Instance struct {
	LaunchTime            time.Time
	State                 ec2types.InstanceStateName
	ID                    string
	ImageID               string
	Type                  ec2types.InstanceType
	Zone                  string
	CapacityType          string
	CapacityReservationID string
	SecurityGroupIDs      []string
	SubnetID              string
	Tags                  map[string]string
	EFAEnabled            bool
}

Instance is an internal data representation of either an ec2.Instance or an ec2.FleetInstance It contains all the common data that is needed to inject into the Machine from either of these responses

func NewInstance

func NewInstance(out ec2types.Instance) *Instance

func NewInstanceFromFleet

func NewInstanceFromFleet(
	out ec2types.CreateFleetInstance,
	tags map[string]string,
	capacityType string,
	capacityReservationID string,
	efaEnabled bool,
) *Instance

type Provider

type Provider interface {
	Create(context.Context, *v1.EC2NodeClass, *karpv1.NodeClaim, map[string]string, []*cloudprovider.InstanceType) (*Instance, error)
	Get(context.Context, string) (*Instance, error)
	List(context.Context) ([]*Instance, error)
	Delete(context.Context, string) error
	CreateTags(context.Context, string, map[string]string) error
}