add new auth for tencentcloud cos backend

Author: SevenEarth

tencentcloud/services/tke/resource_tc_kubernetes_scale_worker.go

@@ -678,9 +678,78 @@ func resourceTencentCloudKubernetesScaleWorkerReadPostFillRequest1(ctx context.C
 	return nil
 }
 
-func resourceTencentCloudKubernetesScaleWorkerReadPreRequest1(ctx context.Context, req *cvm.DescribeInstancesRequest) error {
+func resourceTencentCloudKubernetesScaleWorkerReadPreRequest1(ctx context.Context, req *cvm.DescribeInstancesRequest) (resp *cvm.DescribeInstancesResponse, err error) {
+	logId := tccommon.GetLogId(ctx)
+	meta := tccommon.ProviderMetaFromContext(ctx)
 	ctxData := tccommon.DataFromContext(ctx)
 	instanceIds := ctxData.Get("instanceIds").([]*string)
-	req.InstanceIds = instanceIds
+	req.Limit = helper.Int64(0)
+	req.Offset = helper.Int64(100)
+	if len(instanceIds) <= 100 {
+		req.InstanceIds = instanceIds
+		resp, err = meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCvmV20170312Client().DescribeInstances(req)
+		log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, req.GetAction(), req.ToJsonString(), resp.ToJsonString())
+		if err != nil {
+			return nil, err
+		}
+	} else {
+		var (
+			tmpTotalCount  int64
+			tmpInstanceSet []*cvm.Instance
+		)
+		subSlices := spliteInstanceIds(instanceIds, 100)
+		for _, subsubSlice := range subSlices {
+			req.InstanceIds = subsubSlice
+			tmpResp, err := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCvmV20170312Client().DescribeInstances(req)
+			log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, req.GetAction(), req.ToJsonString(), tmpResp.ToJsonString())
+			if err != nil {
+				return nil, err
+			}
+
+			if tmpResp.Response.TotalCount != nil {
+				tmpTotalCount += *tmpResp.Response.TotalCount
+			}
+
+			if len(tmpResp.Response.InstanceSet) != 0 {
+				tmpInstanceSet = append(tmpInstanceSet, tmpResp.Response.InstanceSet...)
+			}
+		}
+
+		resp.Response.TotalCount = &tmpTotalCount
+		resp.Response.InstanceSet = tmpInstanceSet
+	}
+
+	return resp, nil
+}
+
+func resourceTencentCloudKubernetesScaleWorkerReadPostHandleResponse0(ctx context.Context, resp *tke.DescribeClustersResponseParams) error {
+	logId := tccommon.GetLogId(ctx)
+	d := tccommon.ResourceDataFromContext(ctx)
+	meta := tccommon.ProviderMetaFromContext(ctx)
+	service := TkeService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
+	respData1, err := service.DescribeKubernetesScaleWorkerById1(ctx)
+	if err != nil {
+		return err
+	}
+
+	if respData1 == nil {
+		d.SetId("")
+		log.Printf("[WARN]%s resource `kubernetes_scale_worker` [%s] not found, please check if it has been deleted.\n", logId, d.Id())
+		return nil
+	}
+
 	return nil
 }
+
+func spliteInstanceIds(slice []*string, size int) [][]*string {
+	var result [][]*string
+	for i := 0; i < len(slice); i += size {
+		end := i + size
+		if end > len(slice) {
+			end = len(slice)
+		}
+		result = append(result, slice[i:end])
+	}
+
+	return result
+}

tencentcloud/services/tke/resource_tc_kubernetes_scale_worker_extension.go

@@ -3438,15 +3438,11 @@ func (me *TkeService) DescribeKubernetesScaleWorkerById1(ctx context.Context) (r
 
 	ratelimit.Check(request.GetAction())
 
-	if err := resourceTencentCloudKubernetesScaleWorkerReadPreRequest1(ctx, request); err != nil {
+	response, err := resourceTencentCloudKubernetesScaleWorkerReadPreRequest1(ctx, request)
+	if err != nil {
 		return nil, err
 	}
 
-	response, err := me.client.UseCvmV20170312Client().DescribeInstances(request)
-	if err != nil {
-		errRet = err
-		return
-	}
 	log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), response.ToJsonString())
 
 	if err := resourceTencentCloudKubernetesScaleWorkerReadPostRequest1(ctx, request, response); err != nil {

tencentcloud/services/tke/service_tencentcloud_tke.go

@@ -124,7 +124,7 @@ The following arguments are supported:
 
 * `cluster_id` - (Required, String, ForceNew) ID of the cluster.
 * `worker_config` - (Required, List, ForceNew) Deploy the machine configuration information of the 'WORK' service, and create <=20 units for common users.
-* `create_result_output_file` - (Optional, String, ForceNew) Used to save results of CVMs creation error messages.
+* `create_result_output_file` - (Optional, String) Used to save results of CVMs creation error messages.
 * `data_disk` - (Optional, List, ForceNew) Configurations of tke data disk.
 * `desired_pod_num` - (Optional, Int, ForceNew) Indicate to set desired pod number in current node. Valid when the cluster enable customized pod cidr.
 * `docker_graph_path` - (Optional, String, ForceNew) Docker graph path. Default is `/var/lib/docker`.