controllers

Documentation

Index

• func AzureClusterToAzureMachinePoolsFunc(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc
• func AzureClusterToAzureMachinePoolsMapper(ctx context.Context, c client.Client, scheme *runtime.Scheme, log logr.Logger) (handler.MapFunc, error)
• func AzureMachinePoolMachineMapper(scheme *runtime.Scheme, log logr.Logger) handler.MapFunc
• func AzureMachinePoolToAzureMachinePoolMachines(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc
• func KubeadmConfigToInfrastructureMapFunc(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc
• func MachinePoolMachineHasStateOrVersionChange(logger logr.Logger) predicate.Funcs
• func MachinePoolModelHasChanged(logger logr.Logger) predicate.Funcs
• func MachinePoolToInfrastructureMapFunc(gvk schema.GroupVersionKind, log logr.Logger) handler.MapFunc
• type AzureMachinePoolMachineController
  • func NewAzureMachinePoolMachineController(c client.Client, recorder record.EventRecorder, reconcileTimeout time.Duration, ...) *AzureMachinePoolMachineController
  • func (ampmr *AzureMachinePoolMachineController) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (ampmr *AzureMachinePoolMachineController) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options infracontroller.Options) error
• type AzureMachinePoolReconciler
  • func NewAzureMachinePoolReconciler(client client.Client, recorder record.EventRecorder, ...) *AzureMachinePoolReconciler
  • func (ampr *AzureMachinePoolReconciler) Annotation(rw annotationReaderWriter, annotation string) string
  • func (ampr *AzureMachinePoolReconciler) AnnotationJSON(rw annotationReaderWriter, annotation string) (map[string]interface{}, error)
  • func (ampr *AzureMachinePoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (ampr *AzureMachinePoolReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options infracontroller.Options) error

Functions

func AzureClusterToAzureMachinePoolsFunc

func AzureClusterToAzureMachinePoolsFunc(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc

AzureClusterToAzureMachinePoolsFunc is a handler.MapFunc to be used to enqueue requests for reconciliation of AzureMachinePools.

func AzureClusterToAzureMachinePoolsMapper

func AzureClusterToAzureMachinePoolsMapper(ctx context.Context, c client.Client, scheme *runtime.Scheme, log logr.Logger) (handler.MapFunc, error)

AzureClusterToAzureMachinePoolsMapper creates a mapping handler to transform AzureClusters into AzureMachinePools. The transform requires AzureCluster to map to the owning Cluster, then from the Cluster, collect the MachinePools belonging to the cluster, then finally projecting the infrastructure reference to the AzureMachinePool.

func AzureMachinePoolMachineMapper

func AzureMachinePoolMachineMapper(scheme *runtime.Scheme, log logr.Logger) handler.MapFunc

AzureMachinePoolMachineMapper creates a mapping handler to transform AzureMachinePoolMachine to AzureMachinePools.

func AzureMachinePoolToAzureMachinePoolMachines

func AzureMachinePoolToAzureMachinePoolMachines(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc

AzureMachinePoolToAzureMachinePoolMachines maps an AzureMachinePool to its child AzureMachinePoolMachines through Cluster and MachinePool labels.

func KubeadmConfigToInfrastructureMapFunc

func KubeadmConfigToInfrastructureMapFunc(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc

KubeadmConfigToInfrastructureMapFunc returns a handler.ToRequestsFunc that watches for KubeadmConfig events and returns.

func MachinePoolMachineHasStateOrVersionChange

func MachinePoolMachineHasStateOrVersionChange(logger logr.Logger) predicate.Funcs

MachinePoolMachineHasStateOrVersionChange predicates any events based on changes to the AzureMachinePoolMachine status relevant for the AzureMachinePool controller.

func MachinePoolModelHasChanged

func MachinePoolModelHasChanged(logger logr.Logger) predicate.Funcs

MachinePoolModelHasChanged predicates any events based on changes to the AzureMachinePool model.

func MachinePoolToInfrastructureMapFunc

func MachinePoolToInfrastructureMapFunc(gvk schema.GroupVersionKind, log logr.Logger) handler.MapFunc

MachinePoolToInfrastructureMapFunc returns a handler.MapFunc that watches for MachinePool events and returns reconciliation requests for an infrastructure provider object.

Types

type AzureMachinePoolMachineController

type AzureMachinePoolMachineController struct {
	client.Client
	Scheme           *runtime.Scheme
	Recorder         record.EventRecorder
	ReconcileTimeout time.Duration
	WatchFilterValue string
	// contains filtered or unexported fields
}

AzureMachinePoolMachineController handles Kubernetes change events for AzureMachinePoolMachine resources.

func NewAzureMachinePoolMachineController

func NewAzureMachinePoolMachineController(c client.Client, recorder record.EventRecorder, reconcileTimeout time.Duration, watchFilterValue string) *AzureMachinePoolMachineController

NewAzureMachinePoolMachineController creates a new AzureMachinePoolMachineController to handle updates to Azure Machine Pool Machines.

func (*AzureMachinePoolMachineController) Reconcile

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

Reconcile idempotently gets, creates, and updates a machine pool.

func (*AzureMachinePoolMachineController) SetupWithManager

func (ampmr *AzureMachinePoolMachineController) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options infracontroller.Options) error

SetupWithManager initializes this controller with a manager.

type AzureMachinePoolReconciler

type AzureMachinePoolReconciler struct {
	client.Client
	Scheme           *runtime.Scheme
	Recorder         record.EventRecorder
	ReconcileTimeout time.Duration
	WatchFilterValue string
	// contains filtered or unexported fields
}

AzureMachinePoolReconciler reconciles an AzureMachinePool object.

func NewAzureMachinePoolReconciler

func NewAzureMachinePoolReconciler(client client.Client, recorder record.EventRecorder, reconcileTimeout time.Duration, watchFilterValue string) *AzureMachinePoolReconciler

NewAzureMachinePoolReconciler returns a new AzureMachinePoolReconciler instance.

func (*AzureMachinePoolReconciler) Annotation

func (ampr *AzureMachinePoolReconciler) Annotation(rw annotationReaderWriter, annotation string) string

Annotation fetches the specific machine annotation.

func (*AzureMachinePoolReconciler) AnnotationJSON

func (ampr *AzureMachinePoolReconciler) AnnotationJSON(rw annotationReaderWriter, annotation string) (map[string]interface{}, error)

AnnotationJSON returns a map[string]interface from a JSON annotation. This method gets the given `annotation` from an `annotationReaderWriter` and unmarshalls it from a JSON string into a `map[string]interface{}`.

func (*AzureMachinePoolReconciler) Reconcile

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

Reconcile idempotently gets, creates, and updates a machine pool.

func (*AzureMachinePoolReconciler) SetupWithManager

func (ampr *AzureMachinePoolReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options infracontroller.Options) error

SetupWithManager initializes this controller with a manager.