Skip to content

Commit a551347

Browse files
authored
refactor(tke): [115058279]iacg generates versions, scale_worker (#2588)
* add * add * add * add * Update resource_tc_kubernetes_scale_worker.go * add * add * add
1 parent 59948cb commit a551347

14 files changed

+1270
-648
lines changed

tencentcloud/provider.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1118,7 +1118,7 @@ func Provider() *schema.Provider {
11181118
"tencentcloud_kubernetes_addon_attachment": tke.ResourceTencentCloudKubernetesAddonAttachment(),
11191119
"tencentcloud_kubernetes_auth_attachment": tke.ResourceTencentCloudKubernetesAuthAttachment(),
11201120
"tencentcloud_kubernetes_as_scaling_group": tke.ResourceTencentCloudKubernetesAsScalingGroup(),
1121-
"tencentcloud_kubernetes_scale_worker": tke.ResourceTencentCloudTkeScaleWorker(),
1121+
"tencentcloud_kubernetes_scale_worker": tke.ResourceTencentCloudKubernetesScaleWorker(),
11221122
"tencentcloud_kubernetes_cluster_attachment": tke.ResourceTencentCloudKubernetesClusterAttachment(),
11231123
"tencentcloud_kubernetes_node_pool": tke.ResourceTencentCloudKubernetesNodePool(),
11241124
"tencentcloud_kubernetes_backup_storage_location": tke.ResourceTencentCloudKubernetesBackupStorageLocation(),

tencentcloud/services/tke/data_source_tc_kubernetes_available_cluster_versions.go

Lines changed: 25 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -77,82 +77,67 @@ func dataSourceTencentCloudKubernetesAvailableClusterVersionsRead(d *schema.Reso
7777
defer tccommon.InconsistentCheck(d, meta)()
7878

7979
logId := tccommon.GetLogId(tccommon.ContextNil)
80+
ctx := tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta)
8081

81-
ctx := context.WithValue(context.TODO(), tccommon.LogIdKey, logId)
82-
83-
var (
84-
versions []*string
85-
clusters []*tke.ClusterVersion
86-
id *string
87-
ids []string
88-
)
82+
service := TkeService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
8983

9084
paramMap := make(map[string]interface{})
9185
if v, ok := d.GetOk("cluster_id"); ok {
92-
id = helper.String(v.(string))
93-
paramMap["cluster_id"] = id
86+
paramMap["ClusterId"] = helper.String(v.(string))
9487
}
9588

9689
if v, ok := d.GetOk("cluster_ids"); ok {
90+
clusterIdsList := []*string{}
9791
clusterIdsSet := v.(*schema.Set).List()
98-
ids = helper.InterfacesStrings(clusterIdsSet)
99-
paramMap["cluster_ids"] = helper.InterfacesStringsPoint(clusterIdsSet)
92+
for i := range clusterIdsSet {
93+
clusterIds := clusterIdsSet[i].(string)
94+
clusterIdsList = append(clusterIdsList, helper.String(clusterIds))
95+
}
96+
paramMap["ClusterIds"] = clusterIdsList
10097
}
10198

102-
service := TkeService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
103-
99+
var respData *tke.DescribeAvailableClusterVersionResponseParams
104100
err := resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError {
105101
result, e := service.DescribeKubernetesAvailableClusterVersionsByFilter(ctx, paramMap)
106102
if e != nil {
107103
return tccommon.RetryError(e)
108104
}
109-
if result != nil {
110-
versions = result.Versions
111-
clusters = result.Clusters
112-
}
105+
respData = result
113106
return nil
114107
})
115108
if err != nil {
116109
return err
117110
}
118111

119-
if versions != nil {
120-
_ = d.Set("versions", versions)
112+
if respData.Versions != nil {
113+
_ = d.Set("versions", respData.Versions)
121114
}
122115

123-
tmpList := make([]map[string]interface{}, 0, len(clusters))
124-
125-
if clusters != nil {
126-
for _, clusterVersion := range clusters {
127-
clusterVersionMap := map[string]interface{}{}
116+
clustersList := make([]map[string]interface{}, 0, len(respData.Clusters))
117+
if respData.Clusters != nil {
118+
for _, clusters := range respData.Clusters {
119+
clustersMap := map[string]interface{}{}
128120

129-
if clusterVersion.ClusterId != nil {
130-
clusterVersionMap["cluster_id"] = clusterVersion.ClusterId
121+
if clusters.ClusterId != nil {
122+
clustersMap["cluster_id"] = clusters.ClusterId
131123
}
132124

133-
if clusterVersion.Versions != nil {
134-
clusterVersionMap["versions"] = clusterVersion.Versions
125+
if clusters.Versions != nil {
126+
clustersMap["versions"] = clusters.Versions
135127
}
136128

137-
tmpList = append(tmpList, clusterVersionMap)
129+
clustersList = append(clustersList, clustersMap)
138130
}
139131

140-
_ = d.Set("clusters", tmpList)
132+
_ = d.Set("clusters", clustersList)
141133
}
142134

143-
var clusterIds []string
144-
if id != nil {
145-
clusterIds = []string{*id}
146-
} else {
147-
clusterIds = ids
148-
}
149-
150-
d.SetId(helper.DataResourceIdsHash(clusterIds))
151135
output, ok := d.GetOk("result_output_file")
152136
if ok && output.(string) != "" {
153-
if e := tccommon.WriteToFile(output.(string), tmpList); e != nil {
137+
if e := tccommon.WriteToFile(output.(string), dataSourceTencentCloudKubernetesAvailableClusterVersionsReadOutputContent(ctx)); e != nil {
154138
return e
155139
}
156140
}
141+
157142
return nil
158143
}
Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,42 @@
1+
package tke
2+
3+
import (
4+
"context"
5+
6+
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
7+
tke "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525"
8+
tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"
9+
"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
10+
)
11+
12+
func dataSourceTencentCloudKubernetesAvailableClusterVersionsReadPostRequest0(ctx context.Context, req *tke.DescribeAvailableClusterVersionRequest, resp *tke.DescribeAvailableClusterVersionResponse) error {
13+
d := tccommon.ResourceDataFromContext(ctx)
14+
15+
var (
16+
clusterIds []string
17+
id *string
18+
ids []string
19+
)
20+
21+
if v, ok := d.GetOk("cluster_id"); ok {
22+
id = helper.String(v.(string))
23+
}
24+
25+
if v, ok := d.GetOk("cluster_ids"); ok {
26+
clusterIdsSet := v.(*schema.Set).List()
27+
ids = helper.InterfacesStrings(clusterIdsSet)
28+
}
29+
30+
if id != nil {
31+
clusterIds = []string{*id}
32+
} else {
33+
clusterIds = ids
34+
}
35+
36+
d.SetId(helper.DataResourceIdsHash(clusterIds))
37+
return nil
38+
}
39+
40+
func dataSourceTencentCloudKubernetesAvailableClusterVersionsReadOutputContent(ctx context.Context) interface{} {
41+
return "clustersList"
42+
}
Lines changed: 8 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,14 @@
11
package tke_test
22

33
import (
4-
"fmt"
54
"testing"
65

76
tcacctest "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/acctest"
87

98
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
109
)
1110

11+
// go test -i; go test -test.run TestAccTencentCloudKubernetesAvailableClusterVersionsDataSource_basic -v
1212
func TestAccTencentCloudKubernetesAvailableClusterVersionsDataSource_basic(t *testing.T) {
1313
t.Parallel()
1414
resource.Test(t, resource.TestCase{
@@ -18,41 +18,33 @@ func TestAccTencentCloudKubernetesAvailableClusterVersionsDataSource_basic(t *te
1818
Providers: tcacctest.AccProviders,
1919
Steps: []resource.TestStep{
2020
{
21-
Config: fmt.Sprintf(testAccKubernetesAvailableClusterVersionsDataSource_basic, tcacctest.DefaultTkeClusterId),
21+
Config: testAccKubernetesAvailableClusterVersionsDataSource_basic,
2222
Check: resource.ComposeTestCheckFunc(
2323
tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_kubernetes_available_cluster_versions.id"),
2424
resource.TestCheckResourceAttrSet("data.tencentcloud_kubernetes_available_cluster_versions.id", "versions.#"),
2525
resource.TestCheckResourceAttrSet("data.tencentcloud_kubernetes_available_cluster_versions.id", "clusters.#"),
2626
),
2727
},
2828
{
29-
Config: fmt.Sprintf(testAccKubernetesAvailableClusterVersionsDataSource_multiple, tcacctest.DefaultTkeClusterId),
29+
Config: testAccKubernetesAvailableClusterVersionsDataSource_multiple,
3030
Check: resource.ComposeTestCheckFunc(
3131
tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_kubernetes_available_cluster_versions.ids"),
3232
resource.TestCheckResourceAttrSet("data.tencentcloud_kubernetes_available_cluster_versions.ids", "clusters.#"),
33-
resource.TestCheckResourceAttr("data.tencentcloud_kubernetes_available_cluster_versions.ids", "clusters.0.cluster_id", tcacctest.DefaultTkeClusterId),
33+
resource.TestCheckResourceAttrSet("data.tencentcloud_kubernetes_available_cluster_versions.ids", "clusters.0.cluster_id"),
3434
),
3535
},
3636
},
3737
})
3838
}
3939

40-
const testAccKubernetesAvailableClusterVersionsDataSource_basic = `
41-
40+
const testAccKubernetesAvailableClusterVersionsDataSource_basic = testAccTkeCluster + `
4241
data "tencentcloud_kubernetes_available_cluster_versions" "id" {
43-
cluster_id = "%s"
44-
}
45-
46-
output "versions"{
47-
value = data.tencentcloud_kubernetes_available_cluster_versions.id.versions
42+
cluster_id = tencentcloud_kubernetes_cluster.managed_cluster.id
4843
}
49-
5044
`
5145

52-
const testAccKubernetesAvailableClusterVersionsDataSource_multiple = `
53-
46+
const testAccKubernetesAvailableClusterVersionsDataSource_multiple = testAccTkeCluster + `
5447
data "tencentcloud_kubernetes_available_cluster_versions" "ids" {
55-
cluster_ids = ["%s"]
48+
cluster_ids = [tencentcloud_kubernetes_cluster.managed_cluster.id]
5649
}
57-
5850
`

tencentcloud/services/tke/resource_tc_kubernetes_addon_attachment.go

Lines changed: 3 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

tencentcloud/services/tke/resource_tc_kubernetes_addon_attachment_extension.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,11 @@ import (
44
"context"
55
"encoding/base64"
66
"fmt"
7+
"strings"
8+
79
tke "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525"
810
tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"
911
"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
10-
"strings"
1112

1213
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
1314
)

tencentcloud/services/tke/resource_tc_kubernetes_auth_attachment.go

Lines changed: 2 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

tencentcloud/services/tke/resource_tc_kubernetes_auth_attachment_extension.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package tke
22

33
import (
44
"context"
5+
56
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
67
tke "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525"
78
tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"

tencentcloud/services/tke/resource_tc_kubernetes_cluster_test.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -508,14 +508,13 @@ variable "default_img_id" {
508508
}
509509
510510
//DefaultSecurityGroupData
511-
resource "tencentcloud_security_group" "example" {
512-
name = "tf_tke_sg_test"
513-
description = "sg test"
511+
data "tencentcloud_security_groups" "example" {
512+
name = "keep-tke"
514513
}
515514
516515
locals {
517-
sg_id = tencentcloud_security_group.example.id
518-
sg_id2 = tencentcloud_security_group.example.id
516+
sg_id = data.tencentcloud_security_groups.example.security_groups.0.security_group_id
517+
sg_id2 = data.tencentcloud_security_groups.example.security_groups.0.security_group_id
519518
}
520519
`
521520

0 commit comments

Comments
 (0)