Skip to content

feat(mongodb): [123456789]mongodb urls #3124

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Feb 14, 2025
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .changelog/3124.txt
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
```release-note:new-data-source
tencentcloud_mongodb_instance_urls
```
4 changes: 2 additions & 2 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ require (
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/clb v1.0.1034
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cloudaudit v1.0.1033
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cls v1.0.1078
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1078
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1096
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.1053
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cwp v1.0.762
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cynosdb v1.0.1058
Expand All @@ -66,7 +66,7 @@ require (
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/lighthouse v1.0.729
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/live v1.0.777
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mariadb v1.0.672
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.949
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.1096
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/monitor v1.0.1066
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mps v1.0.853
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/organization v1.0.1038
Expand Down
4 changes: 4 additions & 0 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -937,6 +937,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1074 h1:rlV
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1074/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1078 h1:6dDx6ePLVKl39noLeqVO22A1xPoTRXcVkQ3rW9WlnXA=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1078/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1096 h1:DMokC7T0UF8wMfT1kD+mX3M+hc2C06gmFvQ9gsfRPmI=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.1096/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/controlcenter v1.0.993 h1:WlPgXldQCxt7qi5Xrc6j6zTrsXWzN5BcOGs7Irq7fwQ=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/controlcenter v1.0.993/go.mod h1:Z9U8zNtyuyKhjS0698wqsrG/kLx1TQ5CEixXBwVe7xY=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/csip v1.0.860 h1:F3esKBIT3HW9+7Gt8cVgf8X06VdGIczpgLBUECzSEzU=
Expand Down Expand Up @@ -983,6 +985,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mariadb v1.0.672 h1:sR3
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mariadb v1.0.672/go.mod h1:o3rBKhtfIJfw4BG22M0CQVLQAc0WqIsbyRI/EW52Ka0=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.949 h1:GZGGul+VBoU6Ont/8/S5Ot0wXVrSYBDtk79tFSdvWQ0=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.949/go.mod h1:75i/x1XqkqqqOgEBj31PdpnSeehsscgI5aj6aNgcsXE=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.1096 h1:cX2oVX7xaavobw7Qo5RNfyil4wLT9OMRikzyvCpnqzU=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb v1.0.1096/go.mod h1:YhKow73Lzn/iRvvDT0/XBnXsSypr29QZCDU6c4reVRg=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/monitor v1.0.1066 h1:NBQgNznZRuNQ7AEHPtjFRq588IFEIvClBVtHdR/Q7Wo=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/monitor v1.0.1066/go.mod h1:kgZ+YsYoqSplH7rlz1PwheZPZVU67tLpLXJDKLkM950=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mps v1.0.853 h1:abGpWsAtEuF2QIYKm2m9/hv9OqyHwWNLsd5+67z86BE=
Expand Down
1 change: 1 addition & 0 deletions tencentcloud/provider.go
Original file line number Diff line number Diff line change
Expand Up @@ -582,6 +582,7 @@ func Provider() *schema.Provider {
"tencentcloud_mongodb_instance_current_op": mongodb.DataSourceTencentCloudMongodbInstanceCurrentOp(),
"tencentcloud_mongodb_instance_params": mongodb.DataSourceTencentCloudMongodbInstanceParams(),
"tencentcloud_mongodb_instance_slow_log": mongodb.DataSourceTencentCloudMongodbInstanceSlowLog(),
"tencentcloud_mongodb_instance_urls": mongodb.DataSourceTencentCloudMongodbInstanceUrls(),
"tencentcloud_dayu_cc_https_policies": dayu.DataSourceTencentCloudDayuCCHttpsPolicies(),
"tencentcloud_dayu_cc_http_policies": dayu.DataSourceTencentCloudDayuCCHttpPolicies(),
"tencentcloud_dayu_ddos_policies": dayu.DataSourceTencentCloudDayuDdosPolicies(),
Expand Down
1 change: 1 addition & 0 deletions tencentcloud/provider.md
Original file line number Diff line number Diff line change
Expand Up @@ -718,6 +718,7 @@ TencentDB for MongoDB(mongodb)
tencentcloud_mongodb_instance_current_op
tencentcloud_mongodb_instance_params
tencentcloud_mongodb_instance_slow_log
tencentcloud_mongodb_instance_urls

Resource
tencentcloud_mongodb_instance
Expand Down
120 changes: 120 additions & 0 deletions tencentcloud/services/mongodb/data_source_tc_mongodb_instance_urls.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,120 @@
package mongodb

import (
"context"

"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
mongodb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mongodb/v20190725"

tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"
)

func DataSourceTencentCloudMongodbInstanceUrls() *schema.Resource {
return &schema.Resource{
Read: dataSourceTencentCloudMongodbInstanceUrlsRead,
Schema: map[string]*schema.Schema{
"instance_id": {
Type: schema.TypeString,
Required: true,
Description: "Instance id.",
},

"urls": {
Type: schema.TypeList,
Computed: true,
Description: "Example connection string access address in the form of an instance URI. Contains: URI type and connection string address.",
Elem: &schema.Resource{
Schema: map[string]*schema.Schema{
"url_type": {
Type: schema.TypeString,
Required: true,
Description: "Refers to the URI category, including:\n" +
" - CLUSTER_ALL: Refers to the main node connected to the library instance through this URI, which can be read and write;\n" +
" - CLUSTER_READ_READONLY: Refers to the read-only node connected to the instance through this URI;\n" +
" - CLUSTER_READ_SECONDARY: Refers to connecting the instance slave node through this URI;\n" +
" - CLUSTER_READ_SECONDARY_AND_READONLY: Refers to the read-only slave node connected to the instance through this URI;\n" +
" - CLUSTER_PRIMARY_AND_SECONDARY: This URI connects the instance master node and slave node;\n" +
" - MONGOS_ALL: means that each Mongos node is connected through this URI and can be read and write;\n" +
" - MONGOS_READ_READONLY: Refers to the read-only node connected to Mongos through this URI;\n" +
" - MONGOS_READ_SECONDARY: Refers to the slave node connected to Mongos through this URI;\n" +
" - MONGOS_READ_PRIMARY_AND_SECONDARY: refers to the connection between the master node and slave node of Mongos through this URI;\n" +
" - MONGOS_READ_SECONDARY_AND_READONLY: refers to the connection between Mongos slave node and read-only node through this URI.",
},
"address": {
Type: schema.TypeString,
Required: true,
Description: "Example connection string access address in the form of an instance URI.",
},
},
},
},

"result_output_file": {
Type: schema.TypeString,
Optional: true,
Description: "Used to save results.",
},
},
}
}

func dataSourceTencentCloudMongodbInstanceUrlsRead(d *schema.ResourceData, meta interface{}) error {
defer tccommon.LogElapsed("data_source.tencentcloud_mongodb_instance_urls.read")()
defer tccommon.InconsistentCheck(d, meta)()

logId := tccommon.GetLogId(nil)

Check failure on line 66 in tencentcloud/services/mongodb/data_source_tc_mongodb_instance_urls.go

View workflow job for this annotation

GitHub Actions / golangci-lint

SA1012: do not pass a nil Context, even if a function permits it; pass context.TODO if you are unsure about which Context to use (staticcheck)
ctx := tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta)

service := MongodbService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}

var (
instanceId string
)
if v, ok := d.GetOk("instance_id"); ok {
instanceId = v.(string)
}

var respData []*mongodb.DbURL
err := resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError {
result, e := service.DescribeMongodbInstanceUrls(ctx, instanceId)
if e != nil {
return tccommon.RetryError(e)
}
respData = result
return nil
})
if err != nil {
return err
}

urlsList := make([]map[string]interface{}, 0, len(respData))
if respData != nil {
for _, urls := range respData {
urlsMap := map[string]interface{}{}

if urls.URLType != nil {
urlsMap["url_type"] = urls.URLType
}

if urls.Address != nil {
urlsMap["address"] = urls.Address
}

urlsList = append(urlsList, urlsMap)
}

_ = d.Set("urls", urlsList)
}

d.SetId(instanceId)

output, ok := d.GetOk("result_output_file")
if ok && output.(string) != "" {
if e := tccommon.WriteToFile(output.(string), urlsList); e != nil {
return e
}
}

return nil
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,9 @@
Use this data source to query detailed information of mongodb instance urls

Example Usage

```hcl
data "tencentcloud_mongodb_instance_urls" "mongodb_instance_urls" {
instance_id = "cmgo-xxxxxx"
}
```
Original file line number Diff line number Diff line change
@@ -0,0 +1,34 @@
package mongodb_test

import (
"testing"

"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"

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

func TestAccTencentCloudMongodbInstanceUrlsDataSource_basic(t *testing.T) {
t.Parallel()
resource.Test(t, resource.TestCase{
PreCheck: func() {
tcacctest.AccPreCheck(t)
},
Providers: tcacctest.AccProviders,
Steps: []resource.TestStep{
{
Config: testAccMongodbInstanceUrlsDataSource,
Check: resource.ComposeTestCheckFunc(
tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_mongodb_instance_urls.mongodb_instance_urls"),
resource.TestCheckResourceAttrSet("data.tencentcloud_mongodb_instance_urls.mongodb_instance_urls", "urls.#"),
),
},
},
})
}

const testAccMongodbInstanceUrlsDataSource = testAccMongodbInstance + `
data "tencentcloud_mongodb_instance_urls" "mongodb_instance_urls" {
instance_id = tencentcloud_mongodb_instance.mongodb.id
}
`
27 changes: 27 additions & 0 deletions tencentcloud/services/mongodb/service_tencentcloud_mongodb.go
Original file line number Diff line number Diff line change
Expand Up @@ -977,3 +977,30 @@ func (me *MongodbService) DescribeMongodbInstanceParamValues(ctx context.Context

return
}

func (me *MongodbService) DescribeMongodbInstanceUrls(ctx context.Context, instanceId string) (ret []*mongodb.DbURL, errRet error) {
var (
logId = tccommon.GetLogId(ctx)
request = mongodb.NewDescribeDBInstanceURLRequest()
)

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())
}
}()

request.InstanceId = helper.String(instanceId)

ratelimit.Check(request.GetAction())

response, err := me.client.UseMongodbClient().DescribeDBInstanceURL(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.Urls
return
}
Loading
Loading