refactor: regenerate kubernetes_encryption_protection

Author: yhlooo

tencentcloud/services/tke/resource_tc_kubernetes_encryption_protection.go

@@ -0,0 +1,67 @@
+package tke
+
+import (
+	"context"
+	"fmt"
+	"time"
+
+	tke "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525"
+
+	tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"
+)
+
+func resourceTencentCloudKubernetesEncryptionProtectionCreatePostHandleResponse0(ctx context.Context, resp *tke.EnableEncryptionProtectionResponse) error {
+	d := tccommon.ResourceDataFromContext(ctx)
+	if d == nil {
+		return fmt.Errorf("resource data can not be nil")
+	}
+
+	var clusterId string
+	if v, ok := d.GetOk("cluster_id"); ok {
+		clusterId = v.(string)
+	}
+
+	meta := tccommon.ProviderMetaFromContext(ctx)
+	if meta == nil {
+		return fmt.Errorf("provider meta can not be nil")
+	}
+	service := TkeService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
+
+	conf := tccommon.BuildStateChangeConf(
+		[]string{},
+		[]string{"Opened"},
+		3*tccommon.ReadRetryTimeout,
+		time.Second,
+		service.TkeEncryptionProtectionStateRefreshFunc(clusterId, []string{}),
+	)
+
+	if _, e := conf.WaitForState(); e != nil {
+		return e
+	}
+	return nil
+}
+
+func resourceTencentCloudKubernetesEncryptionProtectionDeletePostHandleResponse0(ctx context.Context, resp *tke.DisableEncryptionProtectionResponse) error {
+	d := tccommon.ResourceDataFromContext(ctx)
+	if d == nil {
+		return fmt.Errorf("resource data can not be nil")
+	}
+	meta := tccommon.ProviderMetaFromContext(ctx)
+	if meta == nil {
+		return fmt.Errorf("provider meta can not be nil")
+	}
+	service := TkeService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
+
+	conf := tccommon.BuildStateChangeConf(
+		[]string{},
+		[]string{"Closed"},
+		3*tccommon.ReadRetryTimeout,
+		time.Second,
+		service.TkeEncryptionProtectionStateRefreshFunc(d.Id(), []string{}),
+	)
+
+	if _, e := conf.WaitForState(); e != nil {
+		return e
+	}
+	return nil
+}

tencentcloud/services/tke/resource_tc_kubernetes_encryption_protection_extension.go

@@ -2918,3 +2918,28 @@ func (me *TkeService) DescribeKubernetesClusterAttachmentById2(ctx context.Conte
 	}
 	return
 }
+
+func (me *TkeService) DescribeKubernetesEncryptionProtectionById(ctx context.Context, clusterId string) (ret *tke.DescribeEncryptionStatusResponseParams, errRet error) {
+	logId := tccommon.GetLogId(ctx)
+
+	request := tke.NewDescribeEncryptionStatusRequest()
+	request.ClusterId = &clusterId
+
+	defer func() {
+		if errRet != nil {
+			log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]\n", logId, request.GetAction(), request.ToJsonString(), errRet.Error())
+		}
+	}()
+
+	ratelimit.Check(request.GetAction())
+
+	response, err := me.client.UseTkeClient().DescribeEncryptionStatus(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())
+
+	ret = response.Response
+	return
+}