Skip to content

Commit

Permalink
feat(DMS): create rocketmq instance with new api and add api descript…
Browse files Browse the repository at this point in the history
…ion (#4038)
  • Loading branch information
346010762 authored Jan 19, 2024
1 parent d6e0c48 commit 802a19e
Showing 1 changed file with 12 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,17 @@ type dmsError struct {
ErrorMsg string `json:"error_msg"`
}

// API: RocketMQ POST /v2/{engine}/{project_id}/instances
// API: RocketMQ PUT /v2/{project_id}/instances/{instance_id}
// API: RocketMQ GET /v2/{project_id}/instances/{instance_id}
// API: RocketMQ DELETE /v2/{project_id}/instances/{instance_id}
// API: RocketMQ POST /v2/{project_id}/rocketmq/{instance_id}/tags/action
// API: RocketMQ GET /v2/{project_id}/kafka/{instance_id}/tags
// API: RocketMQ POST /v2/{project_id}/instances/{instance_id}/crossvpc/modify
// API: BSS GET /v2/orders/customer-orders/details/{order_id}
// API: BSS POST /v2/orders/subscriptions/resources/autorenew/{instance_id}
// API: BSS DELETE /v2/orders/subscriptions/resources/autorenew/{instance_id}
// API: BSS POST /v2/orders/subscriptions/resources/unsubscribe
func ResourceDmsRocketMQInstance() *schema.Resource {
return &schema.Resource{
CreateContext: resourceDmsRocketMQInstanceCreate,
Expand Down Expand Up @@ -287,7 +298,7 @@ func resourceDmsRocketMQInstanceCreate(ctx context.Context, d *schema.ResourceDa

// createRocketmqInstance: create DMS rocketmq instance
var (
createRocketmqInstanceHttpUrl = "v2/{project_id}/instances"
createRocketmqInstanceHttpUrl = "v2/reliability/{project_id}/instances"
createRocketmqInstanceProduct = "dmsv2"
)
createRocketmqInstanceClient, err := cfg.NewServiceClient(createRocketmqInstanceProduct, region)
Expand Down

0 comments on commit 802a19e

Please sign in to comment.