nodeclass

package
v1.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 6, 2026 License: Apache-2.0 Imports: 56 Imported by: 1

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 

func NewAMIReconciler(provider amifamily.Provider) *AMI

func (*AMI) Reconcile added in v1.2.0 

func (a *AMI) Reconcile(ctx context.Context, nodeClass *v1.EC2NodeClass) (reconcile.Result, error)

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,
	placementGroupProvider placementgroup.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)

func (*Controller) Register added in v1.2.0 

func (c *Controller) Register(_ context.Context, m manager.Manager) 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 PlacementGroupReconciler added in v1.11.0 

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

func NewPlacementGroupReconciler added in v1.11.0 

func NewPlacementGroupReconciler(provider placementgroup.Provider) *PlacementGroupReconciler

func (*PlacementGroupReconciler) Reconcile added in v1.11.0 

func (p *PlacementGroupReconciler) Reconcile(ctx context.Context, nc *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 

func NewSubnetReconciler(subnetProvider subnet.Provider) *Subnet

func (*Subnet) Reconcile added in v1.2.0 

func (s *Subnet) Reconcile(ctx context.Context, nodeClass *v1.EC2NodeClass) (reconcile.Result, error)

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

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.