in providers/tencentcloud/mysql.go [29:102]
func (g *MysqlGenerator) InitResources() error {
args := g.GetArgs()
region := args["region"].(string)
credential := args["credential"].(common.Credential)
profile := NewTencentCloudClientProfile()
client, err := cdb.NewClient(&credential, region, profile)
if err != nil {
return err
}
request := cdb.NewDescribeDBInstancesRequest()
filters := make([]string, 0)
for _, filter := range g.Filter {
if filter.FieldPath == "id" && filter.IsApplicable("tencentcloud_mysql_instance") {
filters = append(filters, filter.AcceptableValues...)
}
}
for i := range filters {
request.InstanceIds = append(request.InstanceIds, &filters[i])
}
var offset uint64
var pageSize uint64 = 50
allInstances := make([]*cdb.InstanceInfo, 0)
for {
request.Offset = &offset
request.Limit = &pageSize
response, err := client.DescribeDBInstances(request)
if err != nil {
return err
}
allInstances = append(allInstances, response.Response.Items...)
if len(response.Response.Items) < int(pageSize) {
break
}
offset += pageSize
}
for _, instance := range allInstances {
if *instance.InstanceType == 1 {
resource := terraformutils.NewResource(
*instance.InstanceId,
*instance.InstanceName+"_"+*instance.InstanceId,
"tencentcloud_mysql_instance",
"tencentcloud",
map[string]string{
"force_delete": "false",
"prepaid_period": "1",
},
[]string{},
map[string]interface{}{},
)
g.Resources = append(g.Resources, resource)
} else if *instance.InstanceType == 3 {
resource := terraformutils.NewResource(
*instance.InstanceId,
*instance.InstanceName+"_"+*instance.InstanceId,
"tencentcloud_mysql_readonly_instance",
"tencentcloud",
map[string]string{
"force_delete": "false",
"prepaid_period": "1",
},
[]string{},
map[string]interface{}{},
)
g.Resources = append(g.Resources, resource)
}
}
return nil
}