Skip to content

Commit 6af454e

Browse files
committed
fix logic for describe tke group
1 parent c07ef2e commit 6af454e

File tree

2 files changed

+19
-31
lines changed

2 files changed

+19
-31
lines changed

tencentcloud/resource_tc_kubernetes_as_scaling_group.go

Lines changed: 10 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -715,29 +715,24 @@ func resourceKubernetesAsScalingGroupRead(d *schema.ResourceData, meta interface
715715
return nil
716716
}
717717

718-
err = resource.Retry(3*readRetryTimeout, func() *resource.RetryError {
719-
groupId := []*string{&asGroupId}
720-
_, clusterAsGroupSet, err := service.DescribeClusterAsGroupsByGroupId(ctx, clusterId, groupId)
721-
718+
err = resource.Retry(readRetryTimeout, func() *resource.RetryError {
719+
clusterAsGroupSet, err := service.DescribeClusterAsGroupsByGroupId(ctx, clusterId, asGroupId)
722720
if err != nil {
723721
return retryError(err)
724722
}
725723

726-
var labelsMap = map[string]string{}
727-
if len(clusterAsGroupSet) == 0 {
728-
d.Set("labels", labelsMap)
724+
if clusterAsGroupSet == nil {
729725
return nil
730726
}
731727

732-
for _, value := range clusterAsGroupSet {
733-
labels := value.Labels
734-
if len(labels) == 0 {
735-
continue
736-
}
728+
labels := clusterAsGroupSet.Labels
729+
if len(labels) == 0 {
730+
return nil
731+
}
737732

738-
for _, v := range labels {
739-
labelsMap[*v.Name] = *v.Value
740-
}
733+
var labelsMap = map[string]string{}
734+
for _, v := range labels {
735+
labelsMap[*v.Name] = *v.Value
741736
}
742737
d.Set("labels", labelsMap)
743738
return nil
@@ -746,7 +741,6 @@ func resourceKubernetesAsScalingGroupRead(d *schema.ResourceData, meta interface
746741
if err != nil {
747742
return err
748743
}
749-
750744
return nil
751745
}
752746

tencentcloud/service_tencentcloud_tke.go

Lines changed: 9 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -513,31 +513,25 @@ func (me *TkeService) CreateClusterAsGroup(ctx context.Context, id, groupPara, c
513513
return
514514
}
515515

516-
func (me *TkeService) DescribeClusterAsGroupsByGroupId(ctx context.Context, id string, groupId []*string) (totalCount *uint64, clusterAsGroupSet []*tke.ClusterAsGroup, errRet error) {
516+
func (me *TkeService) DescribeClusterAsGroupsByGroupId(ctx context.Context, id string, groupId string) (clusterAsGroupSet *tke.ClusterAsGroup, errRet error) {
517517
logId := getLogId(ctx)
518518
request := tke.NewDescribeClusterAsGroupsRequest()
519519

520-
defer func() {
521-
if errRet != nil {
522-
log.Printf("[CRITAL]%s api[%s] fail, reason[%s]\n", logId, request.GetAction(), errRet.Error())
523-
}
524-
}()
525520
request.ClusterId = &id
526-
if len(groupId) > 0 {
527-
request.AutoScalingGroupIds = groupId
528-
}
521+
request.AutoScalingGroupIds = []*string{&groupId}
529522

530523
ratelimit.Check(request.GetAction())
531-
response, errRet := me.client.UseTkeClient().DescribeClusterAsGroups(request)
524+
response, err := me.client.UseTkeClient().DescribeClusterAsGroups(request)
532525

533-
if response == nil || response.Response == nil {
534-
errRet = fmt.Errorf("DescribeClusterAsGroupsByGroupId return nil response")
526+
if err != nil {
527+
log.Printf("[CRITAL]%s api[%s] fail, reason[%s]\n", logId, request.GetAction(), errRet.Error())
528+
errRet = err
535529
return
536530
}
537531

538-
totalCount = response.Response.TotalCount
539-
clusterAsGroupSet = response.Response.ClusterAsGroupSet
540-
532+
if len(response.Response.ClusterAsGroupSet) > 0 {
533+
clusterAsGroupSet = response.Response.ClusterAsGroupSet[0]
534+
}
541535
return
542536
}
543537

0 commit comments

Comments
 (0)