controllers

Documentation

Index

• Constants
• func GetValidNames() []string
• func IsDisabled(name string) bool
• func ValidateNamesAndDisable(names []string) error
• type AWSClusterReconciler
  • func (r *AWSClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *AWSClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type AWSMachineReconciler
  • func (r *AWSMachineReconciler) AWSClusterToAWSMachines(log logger.Wrapper) handler.MapFunc
  • func (r *AWSMachineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *AWSMachineReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type AWSManagedClusterReconciler
  • func (r *AWSManagedClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *AWSManagedClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error
• type ROSAClusterReconciler
  • func (r *ROSAClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *ROSAClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

Constants

const (
	// InstanceIDIndex defines the aws machine controller's instance ID index.
	InstanceIDIndex = ".spec.instanceID"

	// DefaultReconcilerRequeue is the default value for the reconcile retry.
	DefaultReconcilerRequeue = 30 * time.Second
)

const (
	// TagsLastAppliedAnnotation is the key for the machine object annotation
	// which tracks the AdditionalTags in the Machine Provider Config.
	// See https://kubernetes.io/docs/concepts/overview/working-with-objects/annotations/
	// for annotation formatting rules.
	TagsLastAppliedAnnotation = "sigs.k8s.io/cluster-api-provider-aws-last-applied-tags"

	// VolumeTagsLastAppliedAnnotation is the key for the ebs volumes annotation
	// which tracks the AdditionalTags in the Machine Provider Config.
	// See https://kubernetes.io/docs/concepts/overview/working-with-objects/annotations/
	// for annotation formatting rules.
	VolumeTagsLastAppliedAnnotation = "sigs.k8s.io/cluster-api-provider-last-applied-tags-on-volumes"
)

const (
	// AWSManagedControlPlaneRefKind is the string value indicating that a cluster is AWS managed.
	AWSManagedControlPlaneRefKind = "AWSManagedControlPlane"
)

const (
	// SecurityGroupsLastAppliedAnnotation is the key for the machine object
	// annotation which tracks the SecurityGroups that the machine actuator is
	// responsible for. These are the SecurityGroups that have been handled by
	// the AdditionalSecurityGroups in the Machine Provider Config.
	// See https://kubernetes.io/docs/concepts/overview/working-with-objects/annotations/
	// for annotation formatting rules.
	SecurityGroupsLastAppliedAnnotation = "sigs.k8s.io/cluster-api-provider-aws-last-applied-security-groups"
)

const (
	Unmanaged = "unmanaged"
)

TODO: EKS and ROSA are excluded from this list for the time being because they are behind feature gates. They should be added to this list when they graduate.

Functions

func GetValidNames

func GetValidNames() []string

GetValidNames returns a list of controller names that are valid to disable.

func IsDisabled

func IsDisabled(name string) bool

IsDisabled checks if a controller is disabled. If the name provided is not in the map, this will return 'false'.

func ValidateNamesAndDisable

func ValidateNamesAndDisable(names []string) error

ValidateNamesAndDisable validates a list of controller names against the known set, and disables valid names.

Types

type AWSClusterReconciler

type AWSClusterReconciler struct {
	client.Client
	Recorder record.EventRecorder

	WatchFilterValue             string
	ExternalResourceGC           bool
	AlternativeGCStrategy        bool
	TagUnmanagedNetworkResources bool
	MaxWaitActiveUpdateDelete    time.Duration
	// contains filtered or unexported fields
}

AWSClusterReconciler reconciles a AwsCluster object.

func (*AWSClusterReconciler) Reconcile

func (r *AWSClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*AWSClusterReconciler) SetupWithManager

func (r *AWSClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

type AWSMachineReconciler

type AWSMachineReconciler struct {
	client.Client
	Log      logr.Logger
	Recorder record.EventRecorder

	SSMServiceFactory func(cloud.ClusterScoper) services.SecretInterface

	WatchFilterValue             string
	TagUnmanagedNetworkResources bool
	MaxWaitActiveUpdateDelete    time.Duration
	// contains filtered or unexported fields
}

AWSMachineReconciler reconciles a AwsMachine object.

func (*AWSMachineReconciler) AWSClusterToAWSMachines

func (r *AWSMachineReconciler) AWSClusterToAWSMachines(log logger.Wrapper) handler.MapFunc

AWSClusterToAWSMachines is a handler.ToRequestsFunc to be used to enqeue requests for reconciliation of AWSMachines.

func (*AWSMachineReconciler) Reconcile

func (r *AWSMachineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*AWSMachineReconciler) SetupWithManager

func (r *AWSMachineReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

type AWSManagedClusterReconciler

type AWSManagedClusterReconciler struct {
	client.Client
	Recorder         record.EventRecorder
	WatchFilterValue string
}

AWSManagedClusterReconciler reconciles AWSManagedCluster.

func (*AWSManagedClusterReconciler) Reconcile

func (r *AWSManagedClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*AWSManagedClusterReconciler) SetupWithManager

func (r *AWSManagedClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error

type ROSAClusterReconciler

type ROSAClusterReconciler struct {
	client.Client
	Recorder         record.EventRecorder
	WatchFilterValue string
}

ROSAClusterReconciler reconciles ROSACluster.

func (*ROSAClusterReconciler) Reconcile

func (r *ROSAClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

func (*ROSAClusterReconciler) SetupWithManager

func (r *ROSAClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error