Documentation
¶
Index ¶
Constants ¶
View Source
const ( ConditionReasonCreateFleetAuthFailed = "CreateFleetAuthCheckFailed" ConditionReasonCreateLaunchTemplateAuthFailed = "CreateLaunchTemplateAuthCheckFailed" ConditionReasonRunInstancesAuthFailed = "RunInstancesAuthCheckFailed" ConditionReasonDependenciesNotReady = "DependenciesNotReady" ConditionReasonTagValidationFailed = "TagValidationFailed" ConditionReasonDryRunDisabled = "DryRunDisabled" )
Variables ¶
View Source
var ValidationConditionMessages = map[string]string{ ConditionReasonCreateFleetAuthFailed: "Controller isn't authorized to call ec2:CreateFleet", ConditionReasonCreateLaunchTemplateAuthFailed: "Controller isn't authorized to call ec2:CreateLaunchTemplate", ConditionReasonRunInstancesAuthFailed: "Controller isn't authorized to call ec2:RunInstances", }
Functions ¶
func WaitingOnNodeClaimTerminationEvent ¶
func WaitingOnNodeClaimTerminationEvent(nodeClass *v1.EC2NodeClass, names []string) events.Event
Types ¶
type AMI ¶ added in v1.2.0
type AMI struct {
// contains filtered or unexported fields
}
func NewAMIReconciler ¶ added in v1.3.0
type CapacityReservation ¶ added in v1.3.0
type CapacityReservation struct {
// contains filtered or unexported fields
}
func NewCapacityReservationReconciler ¶ added in v1.3.0
func NewCapacityReservationReconciler(clk clock.Clock, provider capacityreservation.Provider) *CapacityReservation
func (*CapacityReservation) Reconcile ¶ added in v1.3.0
func (c *CapacityReservation) Reconcile(ctx context.Context, nc *v1.EC2NodeClass) (reconcile.Result, error)
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController( clk clock.Clock, kubeClient client.Client, cloudProvider cloudprovider.CloudProvider, recorder events.Recorder, region string, subnetProvider subnet.Provider, securityGroupProvider securitygroup.Provider, amiProvider amifamily.Provider, instanceProfileProvider instanceprofile.Provider, instanceTypeProvider instancetype.Provider, launchTemplateProvider launchtemplate.Provider, capacityReservationProvider capacityreservation.Provider, ec2api sdk.EC2API, validationCache *cache.Cache, recreationCache *cache.Cache, amiResolver amifamily.Resolver, disableDryRun bool, ) *Controller
func (*Controller) Name ¶
func (c *Controller) Name() string
func (*Controller) Reconcile ¶
func (c *Controller) Reconcile(ctx context.Context, nodeClass *v1.EC2NodeClass) (reconcile.Result, error)
type InstanceProfile ¶ added in v1.2.0
type InstanceProfile struct {
// contains filtered or unexported fields
}
func NewInstanceProfileReconciler ¶ added in v1.3.0
func NewInstanceProfileReconciler(instanceProfileProvider instanceprofile.Provider, region string, cache *cache.Cache) *InstanceProfile
func (*InstanceProfile) Reconcile ¶ added in v1.2.0
func (ip *InstanceProfile) Reconcile(ctx context.Context, nodeClass *v1.EC2NodeClass) (reconcile.Result, error)
type SecurityGroup ¶ added in v1.2.0
type SecurityGroup struct {
// contains filtered or unexported fields
}
func NewSecurityGroupReconciler ¶ added in v1.3.0
func NewSecurityGroupReconciler(securityGroupProvider securitygroup.Provider) *SecurityGroup
func (*SecurityGroup) Reconcile ¶ added in v1.2.0
func (sg *SecurityGroup) Reconcile(ctx context.Context, nodeClass *v1.EC2NodeClass) (reconcile.Result, error)
type Subnet ¶ added in v1.2.0
type Subnet struct {
// contains filtered or unexported fields
}
func NewSubnetReconciler ¶ added in v1.3.0
type Validation ¶ added in v1.2.0
type Validation struct {
// contains filtered or unexported fields
}
func NewValidationReconciler ¶ added in v1.3.0
func NewValidationReconciler( kubeClient client.Client, cloudProvider cloudprovider.CloudProvider, ec2api sdk.EC2API, amiResolver amifamily.Resolver, instanceTypeProvider instancetype.Provider, launchTemplateProvider launchtemplate.Provider, cache *cache.Cache, dryRunDisabled bool, ) *Validation
func (*Validation) Reconcile ¶ added in v1.2.0
func (v *Validation) Reconcile(ctx context.Context, nodeClass *v1.EC2NodeClass) (reconcile.Result, error)
nolint:gocyclo
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.