nodeclass

package
v1.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2025 License: Apache-2.0 Imports: 51 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	ConditionReasonCreateFleetAuthFailed          = "CreateFleetAuthCheckFailed"
	ConditionReasonCreateLaunchTemplateAuthFailed = "CreateLaunchTemplateAuthCheckFailed"
	ConditionReasonRunInstancesAuthFailed         = "RunInstancesAuthCheckFailed"
	ConditionReasonDependenciesNotReady           = "DependenciesNotReady"
	ConditionReasonTagValidationFailed            = "TagValidationFailed"
)

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 CapacityReservationFromEC2 added in v1.3.0 

func CapacityReservationFromEC2(cr *ec2types.CapacityReservation) (v1.CapacityReservation, error)

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(
	ctx context.Context,
	clk clock.Clock,
	kubeClient client.Client,
	recorder events.Recorder,
	subnetProvider subnet.Provider,
	securityGroupProvider securitygroup.Provider,
	amiProvider amifamily.Provider,
	instanceProfileProvider instanceprofile.Provider,
	launchTemplateProvider launchtemplate.Provider,
	capacityReservationProvider capacityreservation.Provider,
	ec2api sdk.EC2API,
	validationCache *cache.Cache,
) *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) *InstanceProfile

func (*InstanceProfile) Reconcile added in v1.2.0 

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

type Readiness added in v1.2.0 

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

func NewReadinessReconciler added in v1.3.0 

func NewReadinessReconciler(launchTemplateProvider launchtemplate.Provider) *Readiness

func (Readiness) Reconcile added in v1.2.0 

func (n Readiness) 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 

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(ec2api sdk.EC2API, amiProvider amifamily.Provider, cache *cache.Cache) *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.