diff --git a/.changelog/2153.txt b/.changelog/2153.txt
new file mode 100644
index 0000000000..e75b73df23
--- /dev/null
+++ b/.changelog/2153.txt
@@ -0,0 +1,3 @@
+```release-note:new-resource
+tencentcloud_trocket_rocketmq_role
+```
\ No newline at end of file
diff --git a/go.mod b/go.mod
index b95286e976..be94d05f99 100644
--- a/go.mod
+++ b/go.mod
@@ -42,7 +42,7 @@ require (
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/clb v1.0.693
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cloudaudit v1.0.544
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cls v1.0.711
- github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.755
+ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.756
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.624
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cwp v1.0.589
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cynosdb v1.0.692
@@ -88,7 +88,7 @@ require (
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tem v1.0.578
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo v1.0.730
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke v1.0.691
- github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.746
+ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.756
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.755
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tsf v1.0.674
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/vod v1.0.199
diff --git a/go.sum b/go.sum
index e55eaef189..94619f6f2c 100644
--- a/go.sum
+++ b/go.sum
@@ -854,17 +854,16 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.725/go.mod
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.726/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.729/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.730/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.732/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.734/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.736/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.745/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.746/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.748/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.750/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.751/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.754/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.755 h1:mAhmX5bEBbLoLfeQu7y6ygeWFle4Kb4Z5e+sp8QyZcA=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.755/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.756 h1:TpeGo45T48N5OJ6LekUdMt3sjYJi4jis4x5jFo8Vz8A=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.756/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.624 h1:nEZqsoqt1pEoaP9JjkHQy3/H00suCfzlHW1qOm2nYD8=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.624/go.mod h1:+TXSVyeKwt1IhZRqKPbTREteBcP+K07Q846/ilNzLWA=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cwp v1.0.589 h1:LZihgirMH0vsaGScYexxwY0fTss9vHaSZs/YOQUVESg=
@@ -955,10 +954,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo v1.0.730 h1:isKxaxm
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo v1.0.730/go.mod h1:vA9wf067VO5kkEjUgViUw/VA0ALUXE/wbSI1baeuHpI=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke v1.0.691 h1:D+a7bZnjLoqPAAHSPCOmil4eigXnGPkR1R5G3ybT/+c=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke v1.0.691/go.mod h1:hsc/CPzbCRXqblCYuE1HuvP3G06OWA9zhAGI6AtEe5U=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.746 h1:ZHfhs8xTWUtKHwDJQNd8mGzV2hFifwKOWYDJTbPrOSM=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.746/go.mod h1:NS1bkjH/+dhwCFvluZd+uq8h8hbnOHJaFDbkQe0YTm4=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.732 h1:hC6bRxIBwjAEnqDsJh8tpY/SqcSfP84exN+cVvHwtd4=
-github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.732/go.mod h1:jF0O9bIPZ/oQ+m3qeEfWHLbtsJFKNaiqvdSNGP7AQCI=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.756 h1:89M6uA8Y/FC1b88TFxvRManGW+i62Isqg1lW8HjHDvU=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.756/go.mod h1:AJAItBOTaarpDpUF7pNp0tuz2Y6H2oFuMcyKouPs1IE=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.755 h1:DbYmGORd2zBnry69k6BR9hzEczrOmbNScE92POutYOY=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.755/go.mod h1:o+ABiUSkJQowYQjJsLBHBJsxy4BosjGVuRAsXas+VlY=
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tsf v1.0.674 h1:VsMV1/vsgVzespG7jUzraZS/AbAUllVQjmtVAlA9W/M=
diff --git a/tencentcloud/provider.go b/tencentcloud/provider.go
index 404134572f..21b3462795 100644
--- a/tencentcloud/provider.go
+++ b/tencentcloud/provider.go
@@ -1451,6 +1451,7 @@ TDMQ for RocketMQ(trocket)
tencentcloud_trocket_rocketmq_instance
tencentcloud_trocket_rocketmq_topic
tencentcloud_trocket_rocketmq_consumer_group
+ tencentcloud_trocket_rocketmq_role
TDMQ for RabbitMQ(trabbit)
Resource
@@ -2933,6 +2934,7 @@ func Provider() *schema.Provider {
"tencentcloud_trocket_rocketmq_instance": resourceTencentCloudTrocketRocketmqInstance(),
"tencentcloud_trocket_rocketmq_topic": resourceTencentCloudTrocketRocketmqTopic(),
"tencentcloud_trocket_rocketmq_consumer_group": resourceTencentCloudTrocketRocketmqConsumerGroup(),
+ "tencentcloud_trocket_rocketmq_role": resourceTencentCloudTrocketRocketmqRole(),
"tencentcloud_dts_sync_job": resourceTencentCloudDtsSyncJob(),
"tencentcloud_dts_sync_config": resourceTencentCloudDtsSyncConfig(),
"tencentcloud_dts_sync_check_job_operation": resourceTencentCloudDtsSyncCheckJobOperation(),
diff --git a/tencentcloud/resource_tc_trocket_rocketmq_role.go b/tencentcloud/resource_tc_trocket_rocketmq_role.go
new file mode 100644
index 0000000000..3422a4a7fd
--- /dev/null
+++ b/tencentcloud/resource_tc_trocket_rocketmq_role.go
@@ -0,0 +1,293 @@
+/*
+Provides a resource to create a trocket rocketmq_role
+
+Example Usage
+
+```hcl
+resource "tencentcloud_trocket_rocketmq_instance" "rocketmq_instance" {
+ instance_type = "EXPERIMENT"
+ name = "test_role"
+ sku_code = "experiment_500"
+ remark = "test"
+ vpc_id = "vpc-xxxxx"
+ subnet_id = "subnet-xxxxx"
+ tags = {
+ tag_key = "rocketmq"
+ tag_value = "5.x"
+ }
+}
+
+resource "tencentcloud_trocket_rocketmq_role" "rocketmq_role" {
+ instance_id = tencentcloud_trocket_rocketmq_instance.rocketmq_instance.id
+ role = "test_role"
+ remark = "test for terraform"
+ perm_write = false
+ perm_read = true
+}
+```
+
+Import
+
+trocket rocketmq_role can be imported using the id, e.g.
+
+```
+terraform import tencentcloud_trocket_rocketmq_role.rocketmq_role instanceId#role
+```
+*/
+package tencentcloud
+
+import (
+ "context"
+ "fmt"
+ "log"
+ "strings"
+
+ "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+ "github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+ trocket "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308"
+ "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func resourceTencentCloudTrocketRocketmqRole() *schema.Resource {
+ return &schema.Resource{
+ Create: resourceTencentCloudTrocketRocketmqRoleCreate,
+ Read: resourceTencentCloudTrocketRocketmqRoleRead,
+ Update: resourceTencentCloudTrocketRocketmqRoleUpdate,
+ Delete: resourceTencentCloudTrocketRocketmqRoleDelete,
+ Importer: &schema.ResourceImporter{
+ State: schema.ImportStatePassthrough,
+ },
+ Schema: map[string]*schema.Schema{
+ "instance_id": {
+ Required: true,
+ Type: schema.TypeString,
+ ForceNew: true,
+ Description: "ID of instance.",
+ },
+
+ "role": {
+ Required: true,
+ Type: schema.TypeString,
+ ForceNew: true,
+ Description: "Name of role.",
+ },
+
+ "remark": {
+ Required: true,
+ Type: schema.TypeString,
+ Description: "remark.",
+ },
+
+ "perm_write": {
+ Required: true,
+ Type: schema.TypeBool,
+ Description: "Whether to enable production permission.",
+ },
+
+ "perm_read": {
+ Required: true,
+ Type: schema.TypeBool,
+ Description: "Whether to enable consumption permission.",
+ },
+
+ "created_time": {
+ Computed: true,
+ Type: schema.TypeInt,
+ Description: "Created time.",
+ },
+
+ "modified_time": {
+ Computed: true,
+ Type: schema.TypeInt,
+ Description: "Modified time.",
+ },
+ },
+ }
+}
+
+func resourceTencentCloudTrocketRocketmqRoleCreate(d *schema.ResourceData, meta interface{}) error {
+ defer logElapsed("resource.tencentcloud_trocket_rocketmq_role.create")()
+ defer inconsistentCheck(d, meta)()
+
+ logId := getLogId(contextNil)
+
+ var (
+ request = trocket.NewCreateRoleRequest()
+ response = trocket.NewCreateRoleResponse()
+ instanceId string
+ role string
+ )
+ if v, ok := d.GetOk("instance_id"); ok {
+ instanceId = v.(string)
+ request.InstanceId = helper.String(v.(string))
+ }
+
+ if v, ok := d.GetOk("role"); ok {
+ request.Role = helper.String(v.(string))
+ }
+
+ if v, ok := d.GetOk("remark"); ok {
+ request.Remark = helper.String(v.(string))
+ }
+
+ if v, ok := d.GetOkExists("perm_write"); ok {
+ request.PermWrite = helper.Bool(v.(bool))
+ }
+
+ if v, ok := d.GetOkExists("perm_read"); ok {
+ request.PermRead = helper.Bool(v.(bool))
+ }
+
+ err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+ result, e := meta.(*TencentCloudClient).apiV3Conn.UseTrocketClient().CreateRole(request)
+ if e != nil {
+ return retryError(e)
+ } else {
+ log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString())
+ }
+ response = result
+ return nil
+ })
+ if err != nil {
+ log.Printf("[CRITAL]%s create trocket rocketmqRole failed, reason:%+v", logId, err)
+ return err
+ }
+
+ role = *response.Response.Role
+ d.SetId(instanceId + FILED_SP + role)
+
+ return resourceTencentCloudTrocketRocketmqRoleRead(d, meta)
+}
+
+func resourceTencentCloudTrocketRocketmqRoleRead(d *schema.ResourceData, meta interface{}) error {
+ defer logElapsed("resource.tencentcloud_trocket_rocketmq_role.read")()
+ defer inconsistentCheck(d, meta)()
+
+ logId := getLogId(contextNil)
+
+ ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+ service := TrocketService{client: meta.(*TencentCloudClient).apiV3Conn}
+
+ idSplit := strings.Split(d.Id(), FILED_SP)
+ if len(idSplit) != 2 {
+ return fmt.Errorf("id is broken,%s", d.Id())
+ }
+ instanceId := idSplit[0]
+ role := idSplit[1]
+
+ rocketmqRole, err := service.DescribeTrocketRocketmqRoleById(ctx, instanceId, role)
+ if err != nil {
+ return err
+ }
+
+ if rocketmqRole == nil {
+ d.SetId("")
+ log.Printf("[WARN]%s resource `TrocketRocketmqRole` [%s] not found, please check if it has been deleted.\n", logId, d.Id())
+ return nil
+ }
+
+ _ = d.Set("instance_id", instanceId)
+ _ = d.Set("role", role)
+
+ if rocketmqRole.Remark != nil {
+ _ = d.Set("remark", rocketmqRole.Remark)
+ }
+
+ if rocketmqRole.PermWrite != nil {
+ _ = d.Set("perm_write", rocketmqRole.PermWrite)
+ }
+
+ if rocketmqRole.PermRead != nil {
+ _ = d.Set("perm_read", rocketmqRole.PermRead)
+ }
+
+ if rocketmqRole.CreatedTime != nil {
+ _ = d.Set("created_time", rocketmqRole.CreatedTime)
+ }
+
+ if rocketmqRole.ModifiedTime != nil {
+ _ = d.Set("modified_time", rocketmqRole.ModifiedTime)
+ }
+
+ return nil
+}
+
+func resourceTencentCloudTrocketRocketmqRoleUpdate(d *schema.ResourceData, meta interface{}) error {
+ defer logElapsed("resource.tencentcloud_trocket_rocketmq_role.update")()
+ defer inconsistentCheck(d, meta)()
+
+ logId := getLogId(contextNil)
+
+ request := trocket.NewModifyRoleRequest()
+
+ idSplit := strings.Split(d.Id(), FILED_SP)
+ if len(idSplit) != 2 {
+ return fmt.Errorf("id is broken,%s", d.Id())
+ }
+ instanceId := idSplit[0]
+ role := idSplit[1]
+
+ request.InstanceId = &instanceId
+ request.Role = &role
+
+ mutableArgs := []string{"remark", "perm_write", "perm_read"}
+ needChange := false
+
+ for _, v := range mutableArgs {
+ if d.HasChange(v) {
+ needChange = true
+ }
+ }
+
+ if needChange {
+ if v, ok := d.GetOk("remark"); ok {
+ request.Remark = helper.String(v.(string))
+ }
+
+ if v, ok := d.GetOkExists("perm_write"); ok {
+ request.PermWrite = helper.Bool(v.(bool))
+ }
+
+ if v, ok := d.GetOkExists("perm_read"); ok {
+ request.PermRead = helper.Bool(v.(bool))
+ }
+
+ err := resource.Retry(writeRetryTimeout, func() *resource.RetryError {
+ result, e := meta.(*TencentCloudClient).apiV3Conn.UseTrocketClient().ModifyRole(request)
+ if e != nil {
+ return retryError(e)
+ } else {
+ log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString())
+ }
+ return nil
+ })
+ if err != nil {
+ log.Printf("[CRITAL]%s update trocket rocketmqRole failed, reason:%+v", logId, err)
+ return err
+ }
+ }
+ return resourceTencentCloudTrocketRocketmqRoleRead(d, meta)
+}
+
+func resourceTencentCloudTrocketRocketmqRoleDelete(d *schema.ResourceData, meta interface{}) error {
+ defer logElapsed("resource.tencentcloud_trocket_rocketmq_role.delete")()
+ defer inconsistentCheck(d, meta)()
+
+ logId := getLogId(contextNil)
+ ctx := context.WithValue(context.TODO(), logIdKey, logId)
+
+ service := TrocketService{client: meta.(*TencentCloudClient).apiV3Conn}
+ idSplit := strings.Split(d.Id(), FILED_SP)
+ if len(idSplit) != 2 {
+ return fmt.Errorf("id is broken,%s", d.Id())
+ }
+ instanceId := idSplit[0]
+ role := idSplit[1]
+
+ if err := service.DeleteTrocketRocketmqRoleById(ctx, instanceId, role); err != nil {
+ return err
+ }
+
+ return nil
+}
diff --git a/tencentcloud/resource_tc_trocket_rocketmq_role_test.go b/tencentcloud/resource_tc_trocket_rocketmq_role_test.go
new file mode 100644
index 0000000000..9c59775611
--- /dev/null
+++ b/tencentcloud/resource_tc_trocket_rocketmq_role_test.go
@@ -0,0 +1,92 @@
+package tencentcloud
+
+import (
+ "testing"
+
+ "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+func TestAccTencentCloudTrocketRocketmqRoleResource_basic(t *testing.T) {
+ t.Parallel()
+ resource.Test(t, resource.TestCase{
+ PreCheck: func() {
+ testAccPreCheck(t)
+ },
+ Providers: testAccProviders,
+ Steps: []resource.TestStep{
+ {
+ Config: testAccTrocketRocketmqRole,
+ Check: resource.ComposeTestCheckFunc(
+ resource.TestCheckResourceAttrSet("tencentcloud_trocket_rocketmq_role.rocketmq_role", "id"),
+ resource.TestCheckResourceAttr("tencentcloud_trocket_rocketmq_role.rocketmq_role", "remark", "test for terraform"),
+ resource.TestCheckResourceAttr("tencentcloud_trocket_rocketmq_role.rocketmq_role", "perm_write", "false"),
+ resource.TestCheckResourceAttr("tencentcloud_trocket_rocketmq_role.rocketmq_role", "perm_read", "true"),
+ ),
+ },
+ {
+ Config: testAccTrocketRocketmqRoleUpdate,
+ Check: resource.ComposeTestCheckFunc(
+ resource.TestCheckResourceAttrSet("tencentcloud_trocket_rocketmq_role.rocketmq_role", "id"),
+ resource.TestCheckResourceAttr("tencentcloud_trocket_rocketmq_role.rocketmq_role", "remark", "test terraform"),
+ resource.TestCheckResourceAttr("tencentcloud_trocket_rocketmq_role.rocketmq_role", "perm_write", "true"),
+ resource.TestCheckResourceAttr("tencentcloud_trocket_rocketmq_role.rocketmq_role", "perm_read", "true"),
+ ),
+ },
+ {
+ ResourceName: "tencentcloud_trocket_rocketmq_role.rocketmq_role",
+ ImportState: true,
+ ImportStateVerify: true,
+ },
+ },
+ })
+}
+
+const testAccTrocketRocketmqRole = `
+
+resource "tencentcloud_trocket_rocketmq_instance" "rocketmq_instance" {
+ instance_type = "EXPERIMENT"
+ name = "test_role"
+ sku_code = "experiment_500"
+ remark = "test"
+ vpc_id = "vpc-3a9fo1k9"
+ subnet_id = "subnet-8nby1yxg"
+ tags = {
+ tag_key = "rocketmq"
+ tag_value = "5.x"
+ }
+}
+
+resource "tencentcloud_trocket_rocketmq_role" "rocketmq_role" {
+ instance_id = tencentcloud_trocket_rocketmq_instance.rocketmq_instance.id
+ role = "test_role"
+ remark = "test for terraform"
+ perm_write = false
+ perm_read = true
+}
+
+`
+
+const testAccTrocketRocketmqRoleUpdate = `
+
+resource "tencentcloud_trocket_rocketmq_instance" "rocketmq_instance" {
+ instance_type = "EXPERIMENT"
+ name = "test_role"
+ sku_code = "experiment_500"
+ remark = "test"
+ vpc_id = "vpc-3a9fo1k9"
+ subnet_id = "subnet-8nby1yxg"
+ tags = {
+ tag_key = "rocketmq"
+ tag_value = "5.x"
+ }
+}
+
+resource "tencentcloud_trocket_rocketmq_role" "rocketmq_role" {
+ instance_id = tencentcloud_trocket_rocketmq_instance.rocketmq_instance.id
+ role = "test_role"
+ remark = "test terraform"
+ perm_write = true
+ perm_read = true
+}
+
+`
diff --git a/tencentcloud/service_tencentcloud_trocket.go b/tencentcloud/service_tencentcloud_trocket.go
index 25bfd29d5a..03568f13c0 100644
--- a/tencentcloud/service_tencentcloud_trocket.go
+++ b/tencentcloud/service_tencentcloud_trocket.go
@@ -211,3 +211,80 @@ func (me *TrocketService) DeleteTrocketRocketmqConsumerGroupById(ctx context.Con
return
}
+
+func (me *TrocketService) DescribeTrocketRocketmqRoleById(ctx context.Context, instanceId string, role string) (rocketmqRole *trocket.RoleItem, errRet error) {
+ logId := getLogId(ctx)
+
+ request := trocket.NewDescribeRoleListRequest()
+ request.InstanceId = &instanceId
+ filter := &trocket.Filter{
+ Name: helper.String("RoleName"),
+ Values: []*string{&role},
+ }
+ request.Filters = []*trocket.Filter{filter}
+
+ 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())
+
+ var (
+ offset int64 = 0
+ limit int64 = 100
+ )
+ instances := make([]*trocket.RoleItem, 0)
+ for {
+ request.Offset = &offset
+ request.Limit = &limit
+ response, err := me.client.UseTrocketClient().DescribeRoleList(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 response == nil || len(response.Response.Data) < 1 {
+ break
+ }
+ instances = append(instances, response.Response.Data...)
+ if len(response.Response.Data) < int(limit) {
+ break
+ }
+
+ offset += limit
+ }
+
+ if len(instances) < 1 {
+ return
+ }
+ rocketmqRole = instances[0]
+ return
+}
+
+func (me *TrocketService) DeleteTrocketRocketmqRoleById(ctx context.Context, instanceId string, role string) (errRet error) {
+ logId := getLogId(ctx)
+
+ request := trocket.NewDeleteRoleRequest()
+ request.InstanceId = &instanceId
+ request.Role = &role
+
+ 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.UseTrocketClient().DeleteRole(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())
+
+ return
+}
diff --git a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/http/request.go b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/http/request.go
index 55f9d1240b..d2493e3b5b 100644
--- a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/http/request.go
+++ b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/http/request.go
@@ -265,7 +265,7 @@ func CompleteCommonParams(request Request, region string, requestClient string)
params["Action"] = request.GetAction()
params["Timestamp"] = strconv.FormatInt(time.Now().Unix(), 10)
params["Nonce"] = strconv.Itoa(rand.Int())
- params["RequestClient"] = "SDK_GO_1.0.755"
+ params["RequestClient"] = "SDK_GO_1.0.756"
if requestClient != "" {
params["RequestClient"] += ": " + requestClient
}
diff --git a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/client.go b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/client.go
index d9d3f5fb80..0e9f7d2465 100644
--- a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/client.go
+++ b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/client.go
@@ -145,6 +145,62 @@ func (c *Client) CreateInstanceWithContext(ctx context.Context, request *CreateI
return
}
+func NewCreateRoleRequest() (request *CreateRoleRequest) {
+ request = &CreateRoleRequest{
+ BaseRequest: &tchttp.BaseRequest{},
+ }
+
+ request.Init().WithApiInfo("trocket", APIVersion, "CreateRole")
+
+
+ return
+}
+
+func NewCreateRoleResponse() (response *CreateRoleResponse) {
+ response = &CreateRoleResponse{
+ BaseResponse: &tchttp.BaseResponse{},
+ }
+ return
+}
+
+// CreateRole
+// 添加角色
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+// FAILEDOPERATION_INSTANCENOTREADY = "FailedOperation.InstanceNotReady"
+// OPERATIONDENIED = "OperationDenied"
+// RESOURCEINUSE = "ResourceInUse"
+// UNSUPPORTEDOPERATION_RESOURCEALREADYEXISTS = "UnsupportedOperation.ResourceAlreadyExists"
+func (c *Client) CreateRole(request *CreateRoleRequest) (response *CreateRoleResponse, err error) {
+ return c.CreateRoleWithContext(context.Background(), request)
+}
+
+// CreateRole
+// 添加角色
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+// FAILEDOPERATION_INSTANCENOTREADY = "FailedOperation.InstanceNotReady"
+// OPERATIONDENIED = "OperationDenied"
+// RESOURCEINUSE = "ResourceInUse"
+// UNSUPPORTEDOPERATION_RESOURCEALREADYEXISTS = "UnsupportedOperation.ResourceAlreadyExists"
+func (c *Client) CreateRoleWithContext(ctx context.Context, request *CreateRoleRequest) (response *CreateRoleResponse, err error) {
+ if request == nil {
+ request = NewCreateRoleRequest()
+ }
+
+ if c.GetCredential() == nil {
+ return nil, errors.New("CreateRole require credential")
+ }
+
+ request.SetContext(ctx)
+
+ response = NewCreateRoleResponse()
+ err = c.Send(request, response)
+ return
+}
+
func NewCreateTopicRequest() (request *CreateTopicRequest) {
request = &CreateTopicRequest{
BaseRequest: &tchttp.BaseRequest{},
@@ -305,6 +361,56 @@ func (c *Client) DeleteInstanceWithContext(ctx context.Context, request *DeleteI
return
}
+func NewDeleteRoleRequest() (request *DeleteRoleRequest) {
+ request = &DeleteRoleRequest{
+ BaseRequest: &tchttp.BaseRequest{},
+ }
+
+ request.Init().WithApiInfo("trocket", APIVersion, "DeleteRole")
+
+
+ return
+}
+
+func NewDeleteRoleResponse() (response *DeleteRoleResponse) {
+ response = &DeleteRoleResponse{
+ BaseResponse: &tchttp.BaseResponse{},
+ }
+ return
+}
+
+// DeleteRole
+// 删除角色
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
+func (c *Client) DeleteRole(request *DeleteRoleRequest) (response *DeleteRoleResponse, err error) {
+ return c.DeleteRoleWithContext(context.Background(), request)
+}
+
+// DeleteRole
+// 删除角色
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
+func (c *Client) DeleteRoleWithContext(ctx context.Context, request *DeleteRoleRequest) (response *DeleteRoleResponse, err error) {
+ if request == nil {
+ request = NewDeleteRoleRequest()
+ }
+
+ if c.GetCredential() == nil {
+ return nil, errors.New("DeleteRole require credential")
+ }
+
+ request.SetContext(ctx)
+
+ response = NewDeleteRoleResponse()
+ err = c.Send(request, response)
+ return
+}
+
func NewDeleteTopicRequest() (request *DeleteTopicRequest) {
request = &DeleteTopicRequest{
BaseRequest: &tchttp.BaseRequest{},
@@ -521,6 +627,62 @@ func (c *Client) DescribeInstanceListWithContext(ctx context.Context, request *D
return
}
+func NewDescribeRoleListRequest() (request *DescribeRoleListRequest) {
+ request = &DescribeRoleListRequest{
+ BaseRequest: &tchttp.BaseRequest{},
+ }
+
+ request.Init().WithApiInfo("trocket", APIVersion, "DescribeRoleList")
+
+
+ return
+}
+
+func NewDescribeRoleListResponse() (response *DescribeRoleListResponse) {
+ response = &DescribeRoleListResponse{
+ BaseResponse: &tchttp.BaseResponse{},
+ }
+ return
+}
+
+// DescribeRoleList
+// 查询角色列表，Filter参数使用说明如下：
+//
+//
+//
+// 1. RoleName，角色名称模糊搜索
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+func (c *Client) DescribeRoleList(request *DescribeRoleListRequest) (response *DescribeRoleListResponse, err error) {
+ return c.DescribeRoleListWithContext(context.Background(), request)
+}
+
+// DescribeRoleList
+// 查询角色列表，Filter参数使用说明如下：
+//
+//
+//
+// 1. RoleName，角色名称模糊搜索
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+func (c *Client) DescribeRoleListWithContext(ctx context.Context, request *DescribeRoleListRequest) (response *DescribeRoleListResponse, err error) {
+ if request == nil {
+ request = NewDescribeRoleListRequest()
+ }
+
+ if c.GetCredential() == nil {
+ return nil, errors.New("DescribeRoleList require credential")
+ }
+
+ request.SetContext(ctx)
+
+ response = NewDescribeRoleListResponse()
+ err = c.Send(request, response)
+ return
+}
+
func NewDescribeTopicRequest() (request *DescribeTopicRequest) {
request = &DescribeTopicRequest{
BaseRequest: &tchttp.BaseRequest{},
@@ -787,6 +949,54 @@ func (c *Client) ModifyInstanceWithContext(ctx context.Context, request *ModifyI
return
}
+func NewModifyRoleRequest() (request *ModifyRoleRequest) {
+ request = &ModifyRoleRequest{
+ BaseRequest: &tchttp.BaseRequest{},
+ }
+
+ request.Init().WithApiInfo("trocket", APIVersion, "ModifyRole")
+
+
+ return
+}
+
+func NewModifyRoleResponse() (response *ModifyRoleResponse) {
+ response = &ModifyRoleResponse{
+ BaseResponse: &tchttp.BaseResponse{},
+ }
+ return
+}
+
+// ModifyRole
+// 修改角色
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+func (c *Client) ModifyRole(request *ModifyRoleRequest) (response *ModifyRoleResponse, err error) {
+ return c.ModifyRoleWithContext(context.Background(), request)
+}
+
+// ModifyRole
+// 修改角色
+//
+// 可能返回的错误码:
+// FAILEDOPERATION = "FailedOperation"
+func (c *Client) ModifyRoleWithContext(ctx context.Context, request *ModifyRoleRequest) (response *ModifyRoleResponse, err error) {
+ if request == nil {
+ request = NewModifyRoleRequest()
+ }
+
+ if c.GetCredential() == nil {
+ return nil, errors.New("ModifyRole require credential")
+ }
+
+ request.SetContext(ctx)
+
+ response = NewModifyRoleResponse()
+ err = c.Send(request, response)
+ return
+}
+
func NewModifyTopicRequest() (request *ModifyTopicRequest) {
request = &ModifyTopicRequest{
BaseRequest: &tchttp.BaseRequest{},
diff --git a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/errors.go b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/errors.go
index 98d0ec4105..c7cbdccf01 100644
--- a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/errors.go
+++ b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/errors.go
@@ -38,6 +38,9 @@ const (
// 实例不存在。
RESOURCENOTFOUND_INSTANCE = "ResourceNotFound.Instance"
+ // 角色不存在，请检查后重试。
+ RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
+
// 主题不存在，请检查后重试。
RESOURCENOTFOUND_TOPIC = "ResourceNotFound.Topic"
diff --git a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/models.go b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/models.go
index 26f36c2802..fd6d4d9e32 100644
--- a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/models.go
+++ b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308/models.go
@@ -255,6 +255,91 @@ func (r *CreateInstanceResponse) FromJsonString(s string) error {
return json.Unmarshal([]byte(s), &r)
}
+// Predefined struct for user
+type CreateRoleRequestParams struct {
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 角色名称
+ Role *string `json:"Role,omitnil" name:"Role"`
+
+ // 备注
+ Remark *string `json:"Remark,omitnil" name:"Remark"`
+
+ // 是否开启生产权限
+ PermWrite *bool `json:"PermWrite,omitnil" name:"PermWrite"`
+
+ // 是否开启消费权限
+ PermRead *bool `json:"PermRead,omitnil" name:"PermRead"`
+}
+
+type CreateRoleRequest struct {
+ *tchttp.BaseRequest
+
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 角色名称
+ Role *string `json:"Role,omitnil" name:"Role"`
+
+ // 备注
+ Remark *string `json:"Remark,omitnil" name:"Remark"`
+
+ // 是否开启生产权限
+ PermWrite *bool `json:"PermWrite,omitnil" name:"PermWrite"`
+
+ // 是否开启消费权限
+ PermRead *bool `json:"PermRead,omitnil" name:"PermRead"`
+}
+
+func (r *CreateRoleRequest) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *CreateRoleRequest) FromJsonString(s string) error {
+ f := make(map[string]interface{})
+ if err := json.Unmarshal([]byte(s), &f); err != nil {
+ return err
+ }
+ delete(f, "InstanceId")
+ delete(f, "Role")
+ delete(f, "Remark")
+ delete(f, "PermWrite")
+ delete(f, "PermRead")
+ if len(f) > 0 {
+ return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "CreateRoleRequest has unknown keys!", "")
+ }
+ return json.Unmarshal([]byte(s), &r)
+}
+
+// Predefined struct for user
+type CreateRoleResponseParams struct {
+ // 角色名
+ Role *string `json:"Role,omitnil" name:"Role"`
+
+ // 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
+ RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
+}
+
+type CreateRoleResponse struct {
+ *tchttp.BaseResponse
+ Response *CreateRoleResponseParams `json:"Response"`
+}
+
+func (r *CreateRoleResponse) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *CreateRoleResponse) FromJsonString(s string) error {
+ return json.Unmarshal([]byte(s), &r)
+}
+
// Predefined struct for user
type CreateTopicRequestParams struct {
// 实例ID
@@ -468,6 +553,67 @@ func (r *DeleteInstanceResponse) FromJsonString(s string) error {
return json.Unmarshal([]byte(s), &r)
}
+// Predefined struct for user
+type DeleteRoleRequestParams struct {
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 角色名称
+ Role *string `json:"Role,omitnil" name:"Role"`
+}
+
+type DeleteRoleRequest struct {
+ *tchttp.BaseRequest
+
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 角色名称
+ Role *string `json:"Role,omitnil" name:"Role"`
+}
+
+func (r *DeleteRoleRequest) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *DeleteRoleRequest) FromJsonString(s string) error {
+ f := make(map[string]interface{})
+ if err := json.Unmarshal([]byte(s), &f); err != nil {
+ return err
+ }
+ delete(f, "InstanceId")
+ delete(f, "Role")
+ if len(f) > 0 {
+ return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "DeleteRoleRequest has unknown keys!", "")
+ }
+ return json.Unmarshal([]byte(s), &r)
+}
+
+// Predefined struct for user
+type DeleteRoleResponseParams struct {
+ // 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
+ RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
+}
+
+type DeleteRoleResponse struct {
+ *tchttp.BaseResponse
+ Response *DeleteRoleResponseParams `json:"Response"`
+}
+
+func (r *DeleteRoleResponse) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *DeleteRoleResponse) FromJsonString(s string) error {
+ return json.Unmarshal([]byte(s), &r)
+}
+
// Predefined struct for user
type DeleteTopicRequestParams struct {
// 实例ID
@@ -830,6 +976,88 @@ func (r *DescribeInstanceResponse) FromJsonString(s string) error {
return json.Unmarshal([]byte(s), &r)
}
+// Predefined struct for user
+type DescribeRoleListRequestParams struct {
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 查询起始位置
+ Offset *int64 `json:"Offset,omitnil" name:"Offset"`
+
+ // 查询结果限制数量
+ Limit *int64 `json:"Limit,omitnil" name:"Limit"`
+
+ // 查询条件列表
+ Filters []*Filter `json:"Filters,omitnil" name:"Filters"`
+}
+
+type DescribeRoleListRequest struct {
+ *tchttp.BaseRequest
+
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 查询起始位置
+ Offset *int64 `json:"Offset,omitnil" name:"Offset"`
+
+ // 查询结果限制数量
+ Limit *int64 `json:"Limit,omitnil" name:"Limit"`
+
+ // 查询条件列表
+ Filters []*Filter `json:"Filters,omitnil" name:"Filters"`
+}
+
+func (r *DescribeRoleListRequest) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *DescribeRoleListRequest) FromJsonString(s string) error {
+ f := make(map[string]interface{})
+ if err := json.Unmarshal([]byte(s), &f); err != nil {
+ return err
+ }
+ delete(f, "InstanceId")
+ delete(f, "Offset")
+ delete(f, "Limit")
+ delete(f, "Filters")
+ if len(f) > 0 {
+ return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "DescribeRoleListRequest has unknown keys!", "")
+ }
+ return json.Unmarshal([]byte(s), &r)
+}
+
+// Predefined struct for user
+type DescribeRoleListResponseParams struct {
+ // 查询总数
+ // 注意：此字段可能返回 null，表示取不到有效值。
+ TotalCount *int64 `json:"TotalCount,omitnil" name:"TotalCount"`
+
+ // 角色信息列表
+ Data []*RoleItem `json:"Data,omitnil" name:"Data"`
+
+ // 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
+ RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
+}
+
+type DescribeRoleListResponse struct {
+ *tchttp.BaseResponse
+ Response *DescribeRoleListResponseParams `json:"Response"`
+}
+
+func (r *DescribeRoleListResponse) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *DescribeRoleListResponse) FromJsonString(s string) error {
+ return json.Unmarshal([]byte(s), &r)
+}
+
// Predefined struct for user
type DescribeTopicListRequestParams struct {
// 实例ID
@@ -1402,6 +1630,88 @@ func (r *ModifyInstanceResponse) FromJsonString(s string) error {
return json.Unmarshal([]byte(s), &r)
}
+// Predefined struct for user
+type ModifyRoleRequestParams struct {
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 角色名称
+ Role *string `json:"Role,omitnil" name:"Role"`
+
+ // 是否开启消费
+ PermRead *bool `json:"PermRead,omitnil" name:"PermRead"`
+
+ // 是否开启生产
+ PermWrite *bool `json:"PermWrite,omitnil" name:"PermWrite"`
+
+ // 备注
+ Remark *string `json:"Remark,omitnil" name:"Remark"`
+}
+
+type ModifyRoleRequest struct {
+ *tchttp.BaseRequest
+
+ // 实例ID
+ InstanceId *string `json:"InstanceId,omitnil" name:"InstanceId"`
+
+ // 角色名称
+ Role *string `json:"Role,omitnil" name:"Role"`
+
+ // 是否开启消费
+ PermRead *bool `json:"PermRead,omitnil" name:"PermRead"`
+
+ // 是否开启生产
+ PermWrite *bool `json:"PermWrite,omitnil" name:"PermWrite"`
+
+ // 备注
+ Remark *string `json:"Remark,omitnil" name:"Remark"`
+}
+
+func (r *ModifyRoleRequest) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *ModifyRoleRequest) FromJsonString(s string) error {
+ f := make(map[string]interface{})
+ if err := json.Unmarshal([]byte(s), &f); err != nil {
+ return err
+ }
+ delete(f, "InstanceId")
+ delete(f, "Role")
+ delete(f, "PermRead")
+ delete(f, "PermWrite")
+ delete(f, "Remark")
+ if len(f) > 0 {
+ return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "ModifyRoleRequest has unknown keys!", "")
+ }
+ return json.Unmarshal([]byte(s), &r)
+}
+
+// Predefined struct for user
+type ModifyRoleResponseParams struct {
+ // 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
+ RequestId *string `json:"RequestId,omitnil" name:"RequestId"`
+}
+
+type ModifyRoleResponse struct {
+ *tchttp.BaseResponse
+ Response *ModifyRoleResponseParams `json:"Response"`
+}
+
+func (r *ModifyRoleResponse) ToJsonString() string {
+ b, _ := json.Marshal(r)
+ return string(b)
+}
+
+// FromJsonString It is highly **NOT** recommended to use this function
+// because it has no param check, nor strict type check
+func (r *ModifyRoleResponse) FromJsonString(s string) error {
+ return json.Unmarshal([]byte(s), &r)
+}
+
// Predefined struct for user
type ModifyTopicRequestParams struct {
// 实例ID
@@ -1477,6 +1787,32 @@ func (r *ModifyTopicResponse) FromJsonString(s string) error {
return json.Unmarshal([]byte(s), &r)
}
+type RoleItem struct {
+ // 角色名称
+ RoleName *string `json:"RoleName,omitnil" name:"RoleName"`
+
+ // Access Key
+ AccessKey *string `json:"AccessKey,omitnil" name:"AccessKey"`
+
+ // Secret Key
+ SecretKey *string `json:"SecretKey,omitnil" name:"SecretKey"`
+
+ // 是否开启消费
+ PermRead *bool `json:"PermRead,omitnil" name:"PermRead"`
+
+ // 是否开启生产
+ PermWrite *bool `json:"PermWrite,omitnil" name:"PermWrite"`
+
+ // 备注信息
+ Remark *string `json:"Remark,omitnil" name:"Remark"`
+
+ // 创建时间，秒为单位
+ CreatedTime *int64 `json:"CreatedTime,omitnil" name:"CreatedTime"`
+
+ // 修改时间，秒为单位
+ ModifiedTime *int64 `json:"ModifiedTime,omitnil" name:"ModifiedTime"`
+}
+
type SubscriptionData struct {
// 实例ID
// 注意：此字段可能返回 null，表示取不到有效值。
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 3d27fb1364..c16a96305c 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -1094,7 +1094,7 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cloudaudit/v20190319
# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cls v1.0.711
## explicit; go 1.14
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cls/v20201016
-# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.755
+# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.756
## explicit; go 1.14
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/errors
@@ -1237,7 +1237,7 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo/v20220901
# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke v1.0.691
## explicit; go 1.14
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525
-# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.746
+# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.756
## explicit; go 1.14
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308
# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.755
diff --git a/website/docs/r/trocket_rocketmq_role.html.markdown b/website/docs/r/trocket_rocketmq_role.html.markdown
new file mode 100644
index 0000000000..858cd7ef35
--- /dev/null
+++ b/website/docs/r/trocket_rocketmq_role.html.markdown
@@ -0,0 +1,65 @@
+---
+subcategory: "TDMQ for RocketMQ(trocket)"
+layout: "tencentcloud"
+page_title: "TencentCloud: tencentcloud_trocket_rocketmq_role"
+sidebar_current: "docs-tencentcloud-resource-trocket_rocketmq_role"
+description: |-
+ Provides a resource to create a trocket rocketmq_role
+---
+
+# tencentcloud_trocket_rocketmq_role
+
+Provides a resource to create a trocket rocketmq_role
+
+## Example Usage
+
+```hcl
+resource "tencentcloud_trocket_rocketmq_instance" "rocketmq_instance" {
+ instance_type = "EXPERIMENT"
+ name = "test_role"
+ sku_code = "experiment_500"
+ remark = "test"
+ vpc_id = "vpc-xxxxx"
+ subnet_id = "subnet-xxxxx"
+ tags = {
+ tag_key = "rocketmq"
+ tag_value = "5.x"
+ }
+}
+
+resource "tencentcloud_trocket_rocketmq_role" "rocketmq_role" {
+ instance_id = tencentcloud_trocket_rocketmq_instance.rocketmq_instance.id
+ role = "test_role"
+ remark = "test for terraform"
+ perm_write = false
+ perm_read = true
+}
+```
+
+## Argument Reference
+
+The following arguments are supported:
+
+* `instance_id` - (Required, String, ForceNew) ID of instance.
+* `perm_read` - (Required, Bool) Whether to enable consumption permission.
+* `perm_write` - (Required, Bool) Whether to enable production permission.
+* `remark` - (Required, String) remark.
+* `role` - (Required, String, ForceNew) Name of role.
+
+## Attributes Reference
+
+In addition to all arguments above, the following attributes are exported:
+
+* `id` - ID of the resource.
+* `created_time` - Created time.
+* `modified_time` - Modified time.
+
+
+## Import
+
+trocket rocketmq_role can be imported using the id, e.g.
+
+```
+terraform import tencentcloud_trocket_rocketmq_role.rocketmq_role instanceId#role
+```
+
diff --git a/website/tencentcloud.erb b/website/tencentcloud.erb
index 04fc646b3c..c6b278dd18 100644
--- a/website/tencentcloud.erb
+++ b/website/tencentcloud.erb
@@ -2777,6 +2777,9 @@
tencentcloud_trocket_rocketmq_instance
+
+ tencentcloud_trocket_rocketmq_role
+
tencentcloud_trocket_rocketmq_topic