infrastructureclusterxk8sio

Documentation

Index

• func GetASGByTag(kopsMachinePool *infrastructurev1alpha1.KopsMachinePool, ...) (*autoscaling.Group, error)
• type KopsMachinePoolReconciler
  • func (r *KopsMachinePoolReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, rerr error)
  • func (r *KopsMachinePoolReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

Functions

func GetASGByTag

func GetASGByTag(kopsMachinePool *infrastructurev1alpha1.KopsMachinePool, awsClient *session.Session) (*autoscaling.Group, error)

GetASGByTag returns the existing ASG or nothing if it doesn't exist.

Types

type KopsMachinePoolReconciler

type KopsMachinePoolReconciler struct {
	client.Client
	Scheme *runtime.Scheme

	WatchFilterValue string

	Recorder                   record.EventRecorder
	ValidateKopsClusterFactory func(kopsClientset simple.Clientset, kopsCluster *kopsapi.Cluster, igs *kopsapi.InstanceGroupList) (*validation.ValidationCluster, error)
	GetASGByTagFactory         func(kopsMachinePool *infrastructurev1alpha1.KopsMachinePool, awsClient *session.Session) (*autoscaling.Group, error)
	// contains filtered or unexported fields
}

KopsMachinePoolReconciler reconciles a KopsMachinePool object

func (*KopsMachinePoolReconciler) Reconcile

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

func (*KopsMachinePoolReconciler) SetupWithManager

func (r *KopsMachinePoolReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error