Update PerformUpdateMessage to PerformUpdateInput

- Same Struct Types
- TODO: handle AckRequest (not a type in V2) so either create a AckRequest type or use PerformUpdateOutput

Author: Thean Lim

agent/acs/updater/updater.go

@@ -228,8 +228,8 @@ func (u *updater) download(info *ecsacs.UpdateInfo) (err error) {
 
 var exit = os.Exit
 
-func (u *updater) performUpdateHandler() func(req *ecsacs.PerformUpdateMessage) {
-	return func(req *ecsacs.PerformUpdateMessage) {
+func (u *updater) performUpdateHandler() func(req *ecsacs.PerformUpdateInput) {
+	return func(req *ecsacs.PerformUpdateInput) {
 		u.Lock()
 		defer u.Unlock()
 

agent/acs/updater/updater_test.go

@@ -128,7 +128,7 @@ func TestPerformUpdateWithUpdatesDisabled(t *testing.T) {
 		Reason:            ptr("Updates are disabled").(*string),
 	}})
 
-	msg := &ecsacs.PerformUpdateMessage{
+	msg := &ecsacs.PerformUpdateInput{
 		ClusterArn:           ptr("cluster").(*string),
 		ContainerInstanceArn: ptr("containerInstance").(*string),
 		MessageId:            ptr("mid").(*string),
@@ -181,7 +181,7 @@ func TestFullUpdateFlow(t *testing.T) {
 
 			require.Equal(t, "update-tar-data", writtenFile.String(), "incorrect data written")
 
-			msg := &ecsacs.PerformUpdateMessage{
+			msg := &ecsacs.PerformUpdateInput{
 				ClusterArn:           ptr("cluster").(*string),
 				ContainerInstanceArn: ptr("containerInstance").(*string),
 				MessageId:            ptr("mid2").(*string),
@@ -248,7 +248,7 @@ func TestUndownloadedUpdate(t *testing.T) {
 		MessageId:         ptr("mid").(*string),
 	}})
 
-	msg := &ecsacs.PerformUpdateMessage{
+	msg := &ecsacs.PerformUpdateInput{
 		ClusterArn:           ptr("cluster").(*string),
 		ContainerInstanceArn: ptr("containerInstance").(*string),
 		MessageId:            ptr("mid").(*string),
@@ -305,7 +305,7 @@ func TestDuplicateUpdateMessagesWithSuccess(t *testing.T) {
 
 	require.Equal(t, "update-tar-data", writtenFile.String(), "incorrect data written")
 
-	msg := &ecsacs.PerformUpdateMessage{
+	msg := &ecsacs.PerformUpdateInput{
 		ClusterArn:           ptr("cluster").(*string),
 		ContainerInstanceArn: ptr("containerInstance").(*string),
 		MessageId:            ptr("mid3").(*string),
@@ -373,7 +373,7 @@ func TestDuplicateUpdateMessagesWithFailure(t *testing.T) {
 
 	require.Equal(t, "update-tar-data", writtenFile.String(), "incorrect data written")
 
-	msg := &ecsacs.PerformUpdateMessage{
+	msg := &ecsacs.PerformUpdateInput{
 		ClusterArn:           ptr("cluster").(*string),
 		ContainerInstanceArn: ptr("containerInstance").(*string),
 		MessageId:            ptr("mid3").(*string),
@@ -443,7 +443,7 @@ func TestNewerUpdateMessages(t *testing.T) {
 
 	require.Equal(t, "newer-update-tar-data", writtenFile.String(), "incorrect data written")
 
-	msg := &ecsacs.PerformUpdateMessage{
+	msg := &ecsacs.PerformUpdateInput{
 		ClusterArn:           ptr("cluster").(*string),
 		ContainerInstanceArn: ptr("containerInstance").(*string),
 		MessageId:            ptr("mid2").(*string),

ecs-agent/acs/client/acs_client_types.go

@@ -37,7 +37,7 @@ func init() {
 		ecsacs.PollOutput{},
 		ecsacs.AckRequest{},
 		ecsacs.UpdateFailureInput{},
-		ecsacs.PerformUpdateMessage{},
+		ecsacs.PerformUpdateInput{},
 		ecsacs.StageUpdateMessage{},
 		ecsacs.RefreshTaskIAMRoleCredentialsInput{},
 		ecsacs.RefreshTaskIAMRoleCredentialsOutput{},