Support updating all parameters at once (#75)

Issue #, if available:
`update-parameter-group` API has a maximum limitation to parameters update. Only 20 parameters are allowed to update at once.

Description of changes:
Add `for` loop for calling `update-parameter-group` API to update up to 20 parameters each time.

By submitting this pull request, I confirm that my contribution is made under the terms of the Apache 2.0 license.

Author: kyriechen96

apis/v1alpha1/ack-generate-metadata.yaml

@@ -1,13 +1,13 @@
 ack_generate_info:
-  build_date: "2023-03-13T22:29:26Z"
+  build_date: "2023-03-16T17:00:50Z"
   build_hash: 910a8e0744a99c5c87d8c1615926985215a60d8c
   go_version: go1.19
   version: v0.24.3
 api_directory_checksum: 863961569e4c45d940e482713a85bac302b37d66
 api_version: v1alpha1
 aws_sdk_go_version: v1.44.93
 generator_config_info:
-  file_checksum: c6f69226d010aa15f4ed3ac9f2b619bbdcdf798b
+  file_checksum: dac41922c947186d4f3c532d8c4ddafa933faa2b
   original_file_name: generator.yaml
 last_modification:
   reason: API generation

apis/v1alpha1/generator.yaml

@@ -312,15 +312,13 @@ resources:
         from:
           operation: DescribeParameters
           path: Parameters
+    update_operation:
+      custom_method_name: customUpdate
     hooks:
       sdk_read_many_post_set_output:
         template_path: hooks/parametergroup/sdk_read_many_post_set_output.go.tpl
       sdk_create_post_set_output:
         template_path: hooks/parametergroup/sdk_create_post_set_output.go.tpl
-      sdk_update_post_set_output:
-        template_path: hooks/parametergroup/sdk_update_post_set_output.go.tpl
-      sdk_update_pre_build_request:
-        template_path: hooks/parametergroup/sdk_update_pre_build_request.go.tpl
     renames:
       operations:
         CreateParameterGroup:

generator.yaml

@@ -312,15 +312,13 @@ resources:
         from:
           operation: DescribeParameters
           path: Parameters
+    update_operation:
+      custom_method_name: customUpdate
     hooks:
       sdk_read_many_post_set_output:
         template_path: hooks/parametergroup/sdk_read_many_post_set_output.go.tpl
       sdk_create_post_set_output:
         template_path: hooks/parametergroup/sdk_create_post_set_output.go.tpl
-      sdk_update_post_set_output:
-        template_path: hooks/parametergroup/sdk_update_post_set_output.go.tpl
-      sdk_update_pre_build_request:
-        template_path: hooks/parametergroup/sdk_update_pre_build_request.go.tpl
     renames:
       operations:
         CreateParameterGroup:

pkg/resource/parameter_group/hooks.go

@@ -21,10 +21,15 @@ import (
 	ackerr "github.com/aws-controllers-k8s/runtime/pkg/errors"
 	ackrtlog "github.com/aws-controllers-k8s/runtime/pkg/runtime/log"
 	svcsdk "github.com/aws/aws-sdk-go/service/memorydb"
+	"github.com/samber/lo"
 
 	svcapitypes "github.com/aws-controllers-k8s/memorydb-controller/apis/v1alpha1"
 )
 
+const (
+	maxNumberOfParametersUpdate = 20
+)
+
 func (rm *resourceManager) setParameters(
 	ctx context.Context,
 	ko *svcapitypes.ParameterGroup,
@@ -158,6 +163,117 @@ func (rm *resourceManager) resetAllParameters(
 	return &resource{ko}, nil
 }
 
+// customUpdate overrides sdkUpdate by custom logic
+func (rm *resourceManager) customUpdate(
+	ctx context.Context,
+	desired *resource,
+	latest *resource,
+	delta *ackcompare.Delta,
+) (updated *resource, err error) {
+	rlog := ackrtlog.FromContext(ctx)
+	exit := rlog.Trace("rm.customUpdate")
+	defer func() {
+		exit(err)
+	}()
+	if delta.DifferentAt("Spec.Tags") {
+		err = rm.updateTags(ctx, desired, latest)
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	if delta.DifferentAt("Spec.ParameterNameValues") {
+		ko, err := rm.resetParameterGroup(ctx, desired, latest)
+
+		if ko != nil || err != nil {
+			return ko, err
+		}
+	}
+
+	if !delta.DifferentExcept("Spec.Tags") {
+		return desired, nil
+	}
+
+	inputs := rm.updateRequestPayload(desired)
+
+	var resp *svcsdk.UpdateParameterGroupOutput
+
+	// Update 20 parameters each time
+	for _, input := range inputs {
+		resp, err = rm.sdkapi.UpdateParameterGroupWithContext(ctx, input)
+		rm.metrics.RecordAPICall("UPDATE", "UpdateParameterGroup", err)
+		if err != nil {
+			return nil, err
+		}
+	}
+
+	// Merge in the information we read from the API call above to the copy of
+	// the original Kubernetes object we passed to the function
+	ko := desired.ko.DeepCopy()
+
+	if ko.Status.ACKResourceMetadata == nil {
+		ko.Status.ACKResourceMetadata = &ackv1alpha1.ResourceMetadata{}
+	}
+
+	if resp != nil {
+		if resp.ParameterGroup.ARN != nil {
+			arn := ackv1alpha1.AWSResourceName(*resp.ParameterGroup.ARN)
+			ko.Status.ACKResourceMetadata.ARN = &arn
+		}
+		if resp.ParameterGroup.Description != nil {
+			ko.Spec.Description = resp.ParameterGroup.Description
+		} else {
+			ko.Spec.Description = nil
+		}
+		if resp.ParameterGroup.Family != nil {
+			ko.Spec.Family = resp.ParameterGroup.Family
+		} else {
+			ko.Spec.Family = nil
+		}
+		if resp.ParameterGroup.Name != nil {
+			ko.Spec.Name = resp.ParameterGroup.Name
+		} else {
+			ko.Spec.Name = nil
+		}
+	}
+
+	rm.setStatusDefaults(ko)
+	ko, err = rm.setParameters(ctx, ko)
+
+	if err != nil {
+		return nil, err
+	}
+	return &resource{ko}, nil
+}
+
+// updateRequestPayload returns an array of SDK-specific struct for the HTTP request
+// payload of the Update API call for the resource
+// each element in return value has maximum 20 parameters
+func (rm *resourceManager) updateRequestPayload(
+	desired *resource,
+) []*svcsdk.UpdateParameterGroupInput {
+	parameterNameValues := lo.Chunk(desired.ko.Spec.ParameterNameValues, maxNumberOfParametersUpdate)
+	return lo.Map(parameterNameValues, func(parameters []*svcapitypes.ParameterNameValue, index int) *svcsdk.UpdateParameterGroupInput {
+		res := &svcsdk.UpdateParameterGroupInput{}
+		if desired.ko.Spec.Name != nil {
+			res.SetParameterGroupName(*desired.ko.Spec.Name)
+		}
+		f1 := []*svcsdk.ParameterNameValue{}
+		for _, f1iter := range parameters {
+			f1elem := &svcsdk.ParameterNameValue{}
+			if f1iter.ParameterName != nil {
+				f1elem.SetParameterName(*f1iter.ParameterName)
+			}
+			if f1iter.ParameterValue != nil {
+				f1elem.SetParameterValue(*f1iter.ParameterValue)
+			}
+			f1 = append(f1, f1elem)
+		}
+		res.SetParameterNameValues(f1)
+		return res
+	})
+}
+
 // getTags gets tags from given ParameterGroup.
 func (rm *resourceManager) getTags(
 	ctx context.Context,