Add update nodegroup support (#16)

* Add update nodegroup support

* Fix missing fixture in nodegroup test

* Update acktest commit

* Update acktest commit hash

* Fix incorrect assertion in test

* Fix key error in nodegroup test

* Remove faulty cluster test assertion

Author: RedbackThomson

apis/v1alpha1/ack-generate-metadata.yaml

@@ -1,13 +1,13 @@
 ack_generate_info:
-  build_date: "2022-01-07T20:46:14Z"
+  build_date: "2022-01-09T00:30:18Z"
   build_hash: 3e184727de8a4dfd4769e3d88f4f52f885858335
-  go_version: go1.17.5
+  go_version: go1.17.1
   version: v0.16.0
 api_directory_checksum: 18423a5aa90c547e267c460f25ce08e5c0b4aaa6
 api_version: v1alpha1
 aws_sdk_go_version: v1.38.67
 generator_config_info:
-  file_checksum: f94cfb6bf61dca6a809c8d7cf0dfc1edc561add6
+  file_checksum: b66d077bc28c12a65378f3eb515c5ab814a93090
   original_file_name: generator.yaml
 last_modification:
   reason: API generation

apis/v1alpha1/generator.yaml

@@ -114,4 +114,17 @@ resources:
         - MalformedQueryString
         - MissingAction
         - MissingParameter
-        - ValidationError
+        - ValidationError
+    hooks:
+      delta_pre_compare:
+        code: customPreCompare(a, b)
+      sdk_create_post_set_output:
+        template_path: hooks/nodegroup/sdk_create_post_set_output.go.tpl
+      sdk_read_one_post_set_output:
+        template_path: hooks/nodegroup/sdk_read_one_post_set_output.go.tpl
+      sdk_delete_pre_build_request:
+        template_path: hooks/nodegroup/sdk_delete_pre_build_request.go.tpl
+      sdk_file_end: 
+        template_path: hooks/nodegroup/sdk_file_end.go.tpl
+    update_operation:
+      custom_method_name: customUpdate

generator.yaml

@@ -114,4 +114,17 @@ resources:
         - MalformedQueryString
         - MissingAction
         - MissingParameter
-        - ValidationError
+        - ValidationError
+    hooks:
+      delta_pre_compare:
+        code: customPreCompare(a, b)
+      sdk_create_post_set_output:
+        template_path: hooks/nodegroup/sdk_create_post_set_output.go.tpl
+      sdk_read_one_post_set_output:
+        template_path: hooks/nodegroup/sdk_read_one_post_set_output.go.tpl
+      sdk_delete_pre_build_request:
+        template_path: hooks/nodegroup/sdk_delete_pre_build_request.go.tpl
+      sdk_file_end: 
+        template_path: hooks/nodegroup/sdk_file_end.go.tpl
+    update_operation:
+      custom_method_name: customUpdate

go.local.mod

@@ -5,12 +5,13 @@ go 1.14
 replace github.com/aws-controllers-k8s/runtime => ../runtime
 
 require (
-	github.com/aws-controllers-k8s/runtime v0.15.2
+	github.com/aws-controllers-k8s/runtime v0.16.0
 	github.com/aws/aws-sdk-go v1.38.67
-	github.com/go-logr/logr v0.1.0
+	github.com/go-logr/logr v1.2.0
 	github.com/spf13/pflag v1.0.5
-	k8s.io/api v0.18.2
-	k8s.io/apimachinery v0.18.6
-	k8s.io/client-go v0.18.2
-	sigs.k8s.io/controller-runtime v0.6.0
+	github.com/stretchr/objx v0.2.0 // indirect
+	k8s.io/api v0.23.0
+	k8s.io/apimachinery v0.23.0
+	k8s.io/client-go v0.23.0
+	sigs.k8s.io/controller-runtime v0.11.0
 )

go.local.sum

@@ -15,7 +15,6 @@ package cluster
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"time"
 
@@ -54,9 +53,7 @@ var (
 
 var (
 	requeueWaitWhileDeleting = ackrequeue.NeededAfter(
-		errors.New(
-			fmt.Sprintf("Cluster in '%s' state, cannot be modified or deleted.", StatusDeleting),
-		),
+		fmt.Errorf("cluster in '%s' state, cannot be modified or deleted", StatusDeleting),
 		ackrequeue.DefaultRequeueAfterDuration,
 	)
 	RequeueAfterUpdateDuration = 15 * time.Second
@@ -69,12 +66,9 @@ func requeueWaitUntilCanModify(r *resource) *ackrequeue.RequeueNeededAfter {
 		return nil
 	}
 	status := *r.ko.Status.Status
-	msg := fmt.Sprintf(
-		"Cluster in '%s' state, cannot be modified until '%s'.",
-		status, StatusActive,
-	)
 	return ackrequeue.NeededAfter(
-		errors.New(msg),
+		fmt.Errorf("cluster in '%s' state, cannot be modified until '%s'",
+			status, StatusActive),
 		ackrequeue.DefaultRequeueAfterDuration,
 	)
 }
@@ -84,12 +78,9 @@ func requeueWaitUntilCanModify(r *resource) *ackrequeue.RequeueNeededAfter {
 // has (first, started and then) completed and the cluster reaches an active
 // status.
 func requeueAfterAsyncUpdate() *ackrequeue.RequeueNeededAfter {
-	msg := fmt.Sprintf(
-		"Cluster has started asynchronously updating, cannot be modified until '%s'.",
-		StatusActive,
-	)
 	return ackrequeue.NeededAfter(
-		errors.New(msg),
+		fmt.Errorf("cluster has started asynchronously updating, cannot be modified until '%s'",
+			StatusActive),
 		RequeueAfterUpdateDuration,
 	)
 }