Skip to content

Commit 34bdb96

Browse files
author
mikatong
committed
support rocketmq 5.x
1 parent cb57737 commit 34bdb96

File tree

15 files changed

+2055
-5
lines changed

15 files changed

+2055
-5
lines changed

go.mod

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ require (
4242
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/clb v1.0.693
4343
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cloudaudit v1.0.544
4444
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cls v1.0.711
45-
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.743
45+
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.744
4646
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.624
4747
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cwp v1.0.589
4848
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cynosdb v1.0.692
@@ -88,6 +88,7 @@ require (
8888
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tem v1.0.578
8989
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo v1.0.730
9090
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke v1.0.691
91+
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.744
9192
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.732
9293
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tsf v1.0.674
9394
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/vod v1.0.199

go.sum

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -886,8 +886,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.736 h1:kDxU
886886
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.736/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
887887
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.737 h1:Y/mD9PJbMkjzJiuZsJnzUk31OPCXvch7WSFbs9kKRyw=
888888
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.737/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
889-
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.743 h1:P6Pql3W1aEtHK4l2W8L1ExcZ0pA/mlgr1c6K6ROkSCs=
890-
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.743/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
889+
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.744 h1:mnGB6/dYZWwiffjzCQgyCte/lg2PHWMX8Cln0y3TbcE=
890+
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.744/go.mod h1:7sCQWVkxcsR38nffDW057DRGk8mUjK1Ing/EFOK8s8Y=
891891
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.624 h1:nEZqsoqt1pEoaP9JjkHQy3/H00suCfzlHW1qOm2nYD8=
892892
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.624/go.mod h1:+TXSVyeKwt1IhZRqKPbTREteBcP+K07Q846/ilNzLWA=
893893
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cwp v1.0.589 h1:LZihgirMH0vsaGScYexxwY0fTss9vHaSZs/YOQUVESg=
@@ -992,6 +992,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo v1.0.730 h1:isKxaxm
992992
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo v1.0.730/go.mod h1:vA9wf067VO5kkEjUgViUw/VA0ALUXE/wbSI1baeuHpI=
993993
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke v1.0.691 h1:D+a7bZnjLoqPAAHSPCOmil4eigXnGPkR1R5G3ybT/+c=
994994
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke v1.0.691/go.mod h1:hsc/CPzbCRXqblCYuE1HuvP3G06OWA9zhAGI6AtEe5U=
995+
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.744 h1:ceQ0X5ALBhKqD07Ksa+XAO0PMwStqzhRfkfJUuUcWMI=
996+
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket v1.0.744/go.mod h1:6dgX5GULjOoROcb3gDWr7tOpMSh9dHwwi0Kl6ZngGtI=
995997
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.701 h1:k048M8hxerqIt9am5Hw9xJBmbJdPDxJd3Fzp2O1jlf0=
996998
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.701/go.mod h1:t8LNOPsOOP1JtkDcZLtDu7dyAp4mwffBKu4Q+5Oyl/o=
997999
github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse v1.0.732 h1:hC6bRxIBwjAEnqDsJh8tpY/SqcSfP84exN+cVvHwtd4=

tencentcloud/connectivity/client.go

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,7 @@ import (
8585
tem "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tem/v20210701"
8686
teo "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/teo/v20220901"
8787
tke "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tke/v20180525"
88+
trocket "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/trocket/v20230308"
8889
tse "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tse/v20201207"
8990
tsf "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/tsf/v20180326"
9091
vod "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/vod/v20180717"
@@ -178,6 +179,7 @@ type TencentCloudClient struct {
178179
ebConn *eb.Client
179180
dlcConn *dlc.Client
180181
wedataConn *wedata.Client
182+
trocketConn *trocket.Client
181183
}
182184

183185
// NewClientProfile returns a new ClientProfile
@@ -1259,6 +1261,20 @@ func (me *TencentCloudClient) UseWedataClient() *wedata.Client {
12591261
return me.wedataConn
12601262
}
12611263

1264+
// UseTrocketClient returns trocket client for service
1265+
func (me *TencentCloudClient) UseTrocketClient() *trocket.Client {
1266+
if me.trocketConn != nil {
1267+
return me.trocketConn
1268+
}
1269+
1270+
cpf := me.NewClientProfile(300)
1271+
cpf.Language = "zh-CN"
1272+
me.trocketConn, _ = trocket.NewClient(me.Credential, me.Region, cpf)
1273+
me.trocketConn.WithHttpTransport(&LogRoundTripper{})
1274+
1275+
return me.trocketConn
1276+
}
1277+
12621278
func getEnvDefault(key string, defVal int) int {
12631279
val, ex := os.LookupEnv(key)
12641280
if !ex {

tencentcloud/provider.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1447,6 +1447,7 @@ TDMQ for RocketMQ(trocket)
14471447
tencentcloud_tdmq_rocketmq_environment_role
14481448
tencentcloud_tdmq_send_rocketmq_message
14491449
tencentcloud_tdmq_rocketmq_vip_instance
1450+
tencentcloud_trocket_rocketmq_instance
14501451
14511452
TDMQ for RabbitMQ(trabbit)
14521453
Resource
@@ -2882,6 +2883,7 @@ func Provider() *schema.Provider {
28822883
"tencentcloud_tdmq_rocketmq_group": resourceTencentCloudTdmqRocketmqGroup(),
28832884
"tencentcloud_tdmq_rocketmq_environment_role": resourceTencentCloudTdmqRocketmqEnvironmentRole(),
28842885
"tencentcloud_tdmq_rocketmq_vip_instance": resourceTencentCloudTdmqRocketmqVipInstance(),
2886+
"tencentcloud_trocket_rocketmq_instance": resourceTencentCloudTrocketRocketmqInstance(),
28852887
"tencentcloud_dts_sync_job": resourceTencentCloudDtsSyncJob(),
28862888
"tencentcloud_dts_sync_config": resourceTencentCloudDtsSyncConfig(),
28872889
"tencentcloud_dts_sync_check_job_operation": resourceTencentCloudDtsSyncCheckJobOperation(),

0 commit comments

Comments
 (0)