Documentation
¶
Index ¶
- func FilterRejectInstanceTypes(nodeClaim *karpv1.NodeClaim, instanceTypes []*cloudprovider.InstanceType) ([]*cloudprovider.InstanceType, []*cloudprovider.InstanceType, error)
- func GetCreateFleetInput(nodeClass *v1.EC2NodeClass, capacityType string, tags map[string]string, ...) *ec2.CreateFleetInput
- func SpotServiceLinkedRoleCreationFailure(nodeClaim *v1.NodeClaim) events.Event
- type 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
- type Provider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterRejectInstanceTypes ¶ added in v1.5.0
func FilterRejectInstanceTypes(nodeClaim *karpv1.NodeClaim, instanceTypes []*cloudprovider.InstanceType) ([]*cloudprovider.InstanceType, []*cloudprovider.InstanceType, error)
func GetCreateFleetInput ¶ added in v1.3.0
func GetCreateFleetInput(nodeClass *v1.EC2NodeClass, capacityType string, tags map[string]string, launchTemplateConfigs []ec2types.FleetLaunchTemplateConfigRequest) *ec2.CreateFleetInput
Types ¶
type DefaultProvider ¶ added in v0.36.0
type DefaultProvider struct {
// contains filtered or unexported fields
}
func NewDefaultProvider ¶ added in v0.36.0
func NewDefaultProvider( ctx context.Context, region string, recorder events.Recorder, ec2api sdk.EC2API, unavailableOfferings *cache.UnavailableOfferings, subnetProvider subnet.Provider, launchTemplateProvider launchtemplate.Provider, capacityReservationProvider capacityreservation.Provider, ) *DefaultProvider
func (*DefaultProvider) Create ¶ added in v0.36.0
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 ¶ added in v0.36.0
func (*DefaultProvider) Delete ¶ added in v0.36.0
func (p *DefaultProvider) Delete(ctx context.Context, id string) 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 NewInstanceFromFleet ¶
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.