Skip to content

Commit 9ff8208

Browse files
Merge pull request #7680 from r4f4/aws-destroy-sets-deprec
NO-JIRA: destroy/aws: replaced deprecated sets syntax
2 parents b36d7c2 + a7c7cdb commit 9ff8208

File tree

3 files changed

+16
-16
lines changed

3 files changed

+16
-16
lines changed

pkg/destroy/aws/aws.go

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,7 @@ func (o *ClusterUninstaller) RunWithContext(ctx context.Context) ([]string, erro
171171

172172
// Get the initial resources to delete, so that they can be returned if the context is canceled while terminating
173173
// instances.
174-
deleted := sets.NewString()
174+
deleted := sets.New[string]()
175175
resourcesToDelete, tagClientsWithResources, err := o.findResourcesToDelete(ctx, tagClients, iamClient, iamRoleSearch, iamUserSearch, deleted)
176176
if err != nil {
177177
o.Logger.WithError(err).Info("error while finding resources to delete")
@@ -269,8 +269,8 @@ func (o *ClusterUninstaller) RunWithContext(ctx context.Context) ([]string, erro
269269
// a shared tag will be ignored.
270270
//
271271
// deleted - the resources that have already been deleted. Any resources specified in this set will be ignored.
272-
func (o *ClusterUninstaller) findUntaggableResources(ctx context.Context, iamClient *iam.IAM, deleted sets.String) (sets.String, error) { //nolint:staticcheck
273-
resources := sets.NewString()
272+
func (o *ClusterUninstaller) findUntaggableResources(ctx context.Context, iamClient *iam.IAM, deleted sets.Set[string]) (sets.Set[string], error) {
273+
resources := sets.New[string]()
274274
o.Logger.Debug("search for IAM instance profiles")
275275
for _, profileType := range []string{"master", "worker", "bootstrap"} {
276276
profile := fmt.Sprintf("%s-%s-profile", o.ClusterID, profileType)
@@ -300,9 +300,9 @@ func (o *ClusterUninstaller) findResourcesToDelete(
300300
iamClient *iam.IAM,
301301
iamRoleSearch *iamRoleSearch,
302302
iamUserSearch *iamUserSearch,
303-
deleted sets.String,
304-
) (sets.String, []*resourcegroupstaggingapi.ResourceGroupsTaggingAPI, error) {
305-
resources := sets.NewString()
303+
deleted sets.Set[string],
304+
) (sets.Set[string], []*resourcegroupstaggingapi.ResourceGroupsTaggingAPI, error) {
305+
resources := sets.New[string]()
306306
var tagClientsWithResources []*resourcegroupstaggingapi.ResourceGroupsTaggingAPI
307307
var errs []error
308308

@@ -353,9 +353,9 @@ func (o *ClusterUninstaller) findResourcesToDelete(
353353
func (o *ClusterUninstaller) findResourcesByTag(
354354
ctx context.Context,
355355
tagClient *resourcegroupstaggingapi.ResourceGroupsTaggingAPI,
356-
deleted sets.String,
357-
) (sets.String, error) {
358-
resources := sets.NewString()
356+
deleted sets.Set[string],
357+
) (sets.Set[string], error) {
358+
resources := sets.New[string]()
359359
for _, filter := range o.Filters {
360360
o.Logger.Debugf("search for matching resources by tag in %s matching %#+v", *tagClient.Config.Region, filter)
361361
tagFilters := make([]*resourcegroupstaggingapi.TagFilter, 0, len(filter))
@@ -392,8 +392,8 @@ func (o *ClusterUninstaller) findResourcesByTag(
392392
// resources - the resources to be deleted.
393393
//
394394
// The first return is the ARNs of the resources that were successfully deleted
395-
func (o *ClusterUninstaller) deleteResources(ctx context.Context, awsSession *session.Session, resources []string, tracker *errorTracker) (sets.String, error) {
396-
deleted := sets.NewString()
395+
func (o *ClusterUninstaller) deleteResources(ctx context.Context, awsSession *session.Session, resources []string, tracker *errorTracker) (sets.Set[string], error) {
396+
deleted := sets.New[string]()
397397
for _, arnString := range resources {
398398
logger := o.Logger.WithField("arn", arnString)
399399
parsedARN, err := arn.Parse(arnString)

pkg/destroy/aws/ec2helpers.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ import (
2323
// stage and the second list is the list of resources that are not terminated.
2424
//
2525
// deleted - the resources that have already been deleted. Any resources specified in this set will be ignored.
26-
func findEC2Instances(ctx context.Context, ec2Client *ec2.EC2, deleted sets.String, filters []Filter, logger logrus.FieldLogger) ([]string, []string, error) {
26+
func findEC2Instances(ctx context.Context, ec2Client *ec2.EC2, deleted sets.Set[string], filters []Filter, logger logrus.FieldLogger) ([]string, []string, error) {
2727
if ec2Client.Config.Region == nil {
2828
return nil, nil, errors.New("EC2 client does not have region configured")
2929
}

pkg/destroy/aws/iamhelpers.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -158,27 +158,27 @@ func (search *iamUserSearch) arns(ctx context.Context) ([]string, error) {
158158
// findIAMRoles returns the IAM roles for the cluster.
159159
//
160160
// deleted - the resources that have already been deleted. Any resources specified in this set will be ignored.
161-
func findIAMRoles(ctx context.Context, search *iamRoleSearch, deleted sets.String, logger logrus.FieldLogger) (sets.String, error) {
161+
func findIAMRoles(ctx context.Context, search *iamRoleSearch, deleted sets.Set[string], logger logrus.FieldLogger) (sets.Set[string], error) {
162162
logger.Debug("search for IAM roles")
163163
resources, _, err := search.find(ctx)
164164
if err != nil {
165165
logger.Info(err)
166166
return nil, err
167167
}
168-
return sets.NewString(resources...).Difference(deleted), nil
168+
return sets.New[string](resources...).Difference(deleted), nil
169169
}
170170

171171
// findIAMUsers returns the IAM users for the cluster.
172172
//
173173
// deleted - the resources that have already been deleted. Any resources specified in this set will be ignored.
174-
func findIAMUsers(ctx context.Context, search *iamUserSearch, deleted sets.String, logger logrus.FieldLogger) (sets.String, error) {
174+
func findIAMUsers(ctx context.Context, search *iamUserSearch, deleted sets.Set[string], logger logrus.FieldLogger) (sets.Set[string], error) {
175175
logger.Debug("search for IAM users")
176176
resources, err := search.arns(ctx)
177177
if err != nil {
178178
logger.Info(err)
179179
return nil, err
180180
}
181-
return sets.NewString(resources...).Difference(deleted), nil
181+
return sets.New[string](resources...).Difference(deleted), nil
182182
}
183183

184184
func deleteIAM(ctx context.Context, session *session.Session, arn arn.ARN, logger logrus.FieldLogger) error {

0 commit comments

Comments
 (0)