feat(cdwpg): [122485020]cdwpg datasource

.changelog/3232.txt

@@ -0,0 +1,11 @@
+```release-note:new-data-source
+tencentcloud_cdwpg_instances
+```
+
+```release-note:new-data-source
+tencentcloud_cdwpg_log
+```
+
+```release-note:new-data-source
+tencentcloud_cdwpg_nodes
+```

go.mod

@@ -109,7 +109,7 @@ require (
 	github.com/hashicorp/go-uuid v1.0.3
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdc v1.0.970
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwdoris v1.0.993
-	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg v1.0.772
+	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg v1.0.1126
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/controlcenter v1.0.993
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/csip v1.0.860
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dasb v1.0.970

go.sum

@@ -848,6 +848,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwdoris v1.0.993 h1:b4
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwdoris v1.0.993/go.mod h1:uH80xTlhZC7HR4OjsUo/ZgD5h5MYo45WyW/msUFkXqU=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg v1.0.772 h1:tn8b0VAqKV4cglYrubtwONiHfXhoyZSmYMmgL/oX/RU=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg v1.0.772/go.mod h1:vkWjnf7Qvtesn0efpiaVj5mIQsQhomkA2keE2yskfmg=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg v1.0.1126 h1:DnjwVXbDFcdreCDn6US+UoP6pEeMHcWNlz74fWaNffQ=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg v1.0.1126/go.mod h1:xLd4uvQefvY5QwslyD2ZGPbk1gYArk7W653yxc9nyII=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cfs v1.0.627 h1:nChNdoCUWQZciiJj3gRCWoHBO/8LituLQOdCRREIrS4=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cfs v1.0.627/go.mod h1:lr3IyWgJk4rLWr0vVd8J1Tfs5O+wNcwSZ9ciMhGUrlI=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cfw v1.0.1018 h1:t9pWssFNmbTerWeZAASeJyMxj7V+Xfb6VnPPMHDpkDU=
@@ -931,6 +933,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1108/go.mod
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1111/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1115/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1122/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1126 h1:HHWE825wxwoEEZVB9CLgPpXOiFy6hZXJMcCjCAOckAU=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1126/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1128 h1:NGnqDc8FQL0YdiCHgTO4Wkso6ToD8rE3JW9VOzoPBNA=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1128/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/controlcenter v1.0.993 h1:WlPgXldQCxt7qi5Xrc6j6zTrsXWzN5BcOGs7Irq7fwQ=

tencentcloud/connectivity/client.go

@@ -234,6 +234,7 @@ type TencentCloudClient struct {
 	monitor20180724Conn         *monitor.Client
 	cdcv20201214Conn            *cdc.Client
 	mqttv20240516Conn           *mqtt.Client
+	cdwpgv20201230Conn          *cdwpg.Client
 }
 
 // NewClientProfile returns a new ClientProfile
@@ -2046,3 +2047,15 @@ func (me *TencentCloudClient) UseMqttV20240516Client() *mqtt.Client {
 
 	return me.mqttv20240516Conn
 }
+
+// UseCdwpgV20201230Client return CDWPG client for service
+func (me *TencentCloudClient) UseCdwpgV20201230Client() *cdwpg.Client {
+	if me.cdwpgv20201230Conn != nil {
+		return me.cdwpgv20201230Conn
+	}
+	cpf := me.NewClientProfile(300)
+	me.cdwpgv20201230Conn, _ = cdwpg.NewClient(me.Credential, me.Region, cpf)
+	me.cdwpgv20201230Conn.WithHttpTransport(&LogRoundTripper{})
+
+	return me.cdwpgv20201230Conn
+}

tencentcloud/provider.go

@@ -1171,7 +1171,11 @@ func Provider() *schema.Provider {
 			"tencentcloud_cdc_dedicated_cluster_orders":                 cdc.DataSourceTencentCloudCdcDedicatedClusterOrders(),
 			"tencentcloud_cdc_dedicated_clusters":                       cdc.DataSourceTencentCloudCdcDedicatedClusters(),
 			"tencentcloud_cdwdoris_instances":                           cdwdoris.DataSourceTencentCloudCdwdorisInstances(),
-			"tencentcloud_lite_hbase_instances":                         emr.DataSourceTencentCloudLiteHbaseInstances()},
+			"tencentcloud_lite_hbase_instances":                         emr.DataSourceTencentCloudLiteHbaseInstances(),
+			"tencentcloud_cdwpg_instances":                              cdwpg.DataSourceTencentCloudCdwpgInstances(),
+			"tencentcloud_cdwpg_log":                                    cdwpg.DataSourceTencentCloudCdwpgLog(),
+			"tencentcloud_cdwpg_nodes":                                  cdwpg.DataSourceTencentCloudCdwpgNodes(),
+		},
 
 		ResourcesMap: map[string]*schema.Resource{
 			"tencentcloud_project":                                                                  project.ResourceTencentCloudProject(),

tencentcloud/provider.md

@@ -2244,6 +2244,11 @@ tencentcloud_bi_embed_token_apply
 tencentcloud_bi_embed_interval_apply
 
 CDWPG
+Data Source
+tencentcloud_cdwpg_instances
+tencentcloud_cdwpg_log
+tencentcloud_cdwpg_nodes
+
 Resource
 tencentcloud_cdwpg_instance
 

tencentcloud/services/cdwpg/data_source_tc_cdwpg_instances.go

@@ -0,0 +1,273 @@
+package cdwpg
+
+import (
+	"context"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	cdwpg "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg/v20201230"
+
+	tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func DataSourceTencentCloudCdwpgInstances() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceTencentCloudCdwpgInstancesRead,
+		Schema: map[string]*schema.Schema{
+			"search_instance_id": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Search instance id.",
+			},
+
+			"search_instance_name": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Search instance name.",
+			},
+
+			"search_tags": {
+				Type:        schema.TypeSet,
+				Optional:    true,
+				Description: "Search tags.",
+				Elem: &schema.Schema{
+					Type: schema.TypeString,
+				},
+			},
+
+			"instances_list": {
+				Type:        schema.TypeList,
+				Computed:    true,
+				Description: "Instances list.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"id": {
+							Type:        schema.TypeInt,
+							Optional:    true,
+							Description: "id.",
+						},
+						"instance_id": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Instance id.",
+						},
+						"instance_name": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Instance name.",
+						},
+						"version": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Version.",
+						},
+						"region": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Region.",
+						},
+						"region_id": {
+							Type:        schema.TypeInt,
+							Optional:    true,
+							Description: "Region id.",
+						},
+						"region_desc": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Region description.",
+						},
+						"zone": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Zone.",
+						},
+						"zone_id": {
+							Type:        schema.TypeInt,
+							Optional:    true,
+							Description: "Zone id.",
+						},
+						"zone_desc": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Zone description.",
+						},
+						"vpc_id": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Vpc id.",
+						},
+						"subnet_id": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Subnet id.",
+						},
+						"create_time": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Create time, such as 2022-09-05 20:00:01.",
+						},
+						"expire_time": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Expire time, such as 2022-09-05 20:00:01.",
+						},
+						"access_info": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Access information.",
+						},
+						"pay_mode": {
+							Type:        schema.TypeString,
+							Optional:    true,
+							Description: "Pay mode.",
+						},
+						"renew_flag": {
+							Type:        schema.TypeBool,
+							Optional:    true,
+							Description: "Renew flag.",
+						},
+					},
+				},
+			},
+
+			"result_output_file": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Used to save results.",
+			},
+		},
+	}
+}
+
+func dataSourceTencentCloudCdwpgInstancesRead(d *schema.ResourceData, meta interface{}) error {
+	defer tccommon.LogElapsed("data_source.tencentcloud_cdwpg_instances.read")()
+	defer tccommon.InconsistentCheck(d, meta)()
+
+	logId := tccommon.GetLogId(nil)
+	ctx := tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta)
+
+	service := CdwpgService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
+
+	paramMap := make(map[string]interface{})
+	if v, ok := d.GetOk("search_instance_id"); ok {
+		paramMap["SearchInstanceId"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("search_instance_name"); ok {
+		paramMap["SearchInstanceName"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("search_tags"); ok {
+		searchTagsList := []*string{}
+		searchTagsSet := v.(*schema.Set).List()
+		for i := range searchTagsSet {
+			searchTags := searchTagsSet[i].(string)
+			searchTagsList = append(searchTagsList, helper.String(searchTags))
+		}
+		paramMap["SearchTags"] = searchTagsList
+	}
+
+	var instances []*cdwpg.InstanceSimpleInfoNew
+	err := resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError {
+		result, e := service.DescribeCdwpgInstancesByFilter(ctx, paramMap)
+		if e != nil {
+			return tccommon.RetryError(e)
+		}
+		instances = result
+		return nil
+	})
+	if err != nil {
+		return err
+	}
+
+	ids := make([]string, 0, len(instances))
+	instancesList := make([]map[string]interface{}, 0, len(instances))
+	for _, instance := range instances {
+		instancesListMap := map[string]interface{}{}
+
+		if instance.ID != nil {
+			instancesListMap["id"] = instance.ID
+		}
+
+		if instance.InstanceId != nil {
+			ids = append(ids, *instance.InstanceId)
+			instancesListMap["instance_id"] = instance.InstanceId
+		}
+
+		if instance.InstanceName != nil {
+			instancesListMap["instance_name"] = instance.InstanceName
+		}
+
+		if instance.Version != nil {
+			instancesListMap["version"] = instance.Version
+		}
+
+		if instance.Region != nil {
+			instancesListMap["region"] = instance.Region
+		}
+
+		if instance.RegionId != nil {
+			instancesListMap["region_id"] = instance.RegionId
+		}
+
+		if instance.RegionDesc != nil {
+			instancesListMap["region_desc"] = instance.RegionDesc
+		}
+
+		if instance.Zone != nil {
+			instancesListMap["zone"] = instance.Zone
+		}
+
+		if instance.ZoneId != nil {
+			instancesListMap["zone_id"] = instance.ZoneId
+		}
+
+		if instance.ZoneDesc != nil {
+			instancesListMap["zone_desc"] = instance.ZoneDesc
+		}
+
+		if instance.VpcId != nil {
+			instancesListMap["vpc_id"] = instance.VpcId
+		}
+
+		if instance.SubnetId != nil {
+			instancesListMap["subnet_id"] = instance.SubnetId
+		}
+
+		if instance.CreateTime != nil {
+			instancesListMap["create_time"] = instance.CreateTime
+		}
+
+		if instance.ExpireTime != nil {
+			instancesListMap["expire_time"] = instance.ExpireTime
+		}
+
+		if instance.AccessInfo != nil {
+			instancesListMap["access_info"] = instance.AccessInfo
+		}
+
+		if instance.PayMode != nil {
+			instancesListMap["pay_mode"] = instance.PayMode
+		}
+
+		if instance.RenewFlag != nil {
+			instancesListMap["renew_flag"] = instance.RenewFlag
+		}
+
+		instancesList = append(instancesList, instancesListMap)
+	}
+
+	_ = d.Set("instances_list", instancesList)
+
+	d.SetId(helper.DataResourceIdsHash(ids))
+
+	output, ok := d.GetOk("result_output_file")
+	if ok && output.(string) != "" {
+		if e := tccommon.WriteToFile(output.(string), d); e != nil {
+			return e
+		}
+	}
+
+	return nil
+}

tencentcloud/services/cdwpg/data_source_tc_cdwpg_instances.md

@@ -0,0 +1,8 @@
+Use this data source to query detailed information of cdwpg cdwpg_instances
+
+Example Usage
+
+```hcl
+data "tencentcloud_cdwpg_instances" "cdwpg_instances" {
+}
+```