Skip to content

Commit 1ca7f1c

Browse files
committed
fixup! feat: rebase to v1.11 cluster api core
1 parent ebad622 commit 1ca7f1c

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

bootstrap/eks/controllers/nodeadmconfig_controller.go

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,8 @@ import (
3737
"sigs.k8s.io/cluster-api/util/predicates"
3838
)
3939

40+
const nodeadmConfigKind = "NodeadmConfig"
41+
4042
// NodeadmConfigReconciler reconciles a NodeadmConfig object.
4143
type NodeadmConfigReconciler struct {
4244
client.Client
@@ -358,7 +360,7 @@ func (r *NodeadmConfigReconciler) SetupWithManager(ctx context.Context, mgr ctrl
358360

359361
if feature.Gates.Enabled(feature.MachinePool) {
360362
b = b.Watches(
361-
&clusterv1beta1.MachinePool{},
363+
&clusterv1.MachinePool{},
362364
handler.EnqueueRequestsFromMapFunc(r.MachinePoolToBootstrapMapFunc),
363365
)
364366
}
@@ -388,7 +390,7 @@ func (r *NodeadmConfigReconciler) MachineToBootstrapMapFunc(_ context.Context, o
388390
if !ok {
389391
klog.Errorf("Expected a Machine but got a %T", o)
390392
}
391-
if m.Spec.Bootstrap.ConfigRef.IsDefined() && m.Spec.Bootstrap.ConfigRef.APIGroup == eksbootstrapv1.GroupVersion.Group && m.Spec.Bootstrap.ConfigRef.Kind == eksConfigKind {
393+
if m.Spec.Bootstrap.ConfigRef.IsDefined() && m.Spec.Bootstrap.ConfigRef.APIGroup == eksbootstrapv1.GroupVersion.Group && m.Spec.Bootstrap.ConfigRef.Kind == nodeadmConfigKind {
392394
name := client.ObjectKey{Namespace: m.Namespace, Name: m.Spec.Bootstrap.ConfigRef.Name}
393395
result = append(result, ctrl.Request{NamespacedName: name})
394396
}
@@ -400,12 +402,12 @@ func (r *NodeadmConfigReconciler) MachineToBootstrapMapFunc(_ context.Context, o
400402
func (r *NodeadmConfigReconciler) MachinePoolToBootstrapMapFunc(_ context.Context, o client.Object) []ctrl.Request {
401403
result := []ctrl.Request{}
402404

403-
m, ok := o.(*clusterv1beta1.MachinePool)
405+
m, ok := o.(*clusterv1.MachinePool)
404406
if !ok {
405407
klog.Errorf("Expected a MachinePool but got a %T", o)
406408
}
407409
configRef := m.Spec.Template.Spec.Bootstrap.ConfigRef
408-
if configRef != nil && configRef.GroupVersionKind().GroupKind() == eksbootstrapv1.GroupVersion.WithKind("NodeadmConfig").GroupKind() {
410+
if configRef.IsDefined() && configRef.APIGroup == eksbootstrapv1.GroupVersion.Group && configRef.Kind == nodeadmConfigKind {
409411
name := client.ObjectKey{Namespace: m.Namespace, Name: configRef.Name}
410412
result = append(result, ctrl.Request{NamespacedName: name})
411413
}
@@ -437,7 +439,8 @@ func (r *NodeadmConfigReconciler) ClusterToNodeadmConfigs(_ context.Context, o c
437439

438440
for _, m := range machineList.Items {
439441
if m.Spec.Bootstrap.ConfigRef.IsDefined() &&
440-
m.Spec.Bootstrap.ConfigRef.GroupKind() == eksbootstrapv1.GroupVersion.WithKind("NodeadmConfig").GroupKind() {
442+
m.Spec.Bootstrap.ConfigRef.APIGroup == eksbootstrapv1.GroupVersion.Group &&
443+
m.Spec.Bootstrap.ConfigRef.Kind == nodeadmConfigKind {
441444
name := client.ObjectKey{Namespace: m.Namespace, Name: m.Spec.Bootstrap.ConfigRef.Name}
442445
result = append(result, ctrl.Request{NamespacedName: name})
443446
}

0 commit comments

Comments
 (0)