Feat/support mps input output resource (#2199)

* add e2e.

* fix golangci-lint issues

* support mps input/output resource

* add changelog

* add e2e case

* adjust e2e case

Author: lyu571

.changelog/2199.txt

@@ -0,0 +1,11 @@
+```release-note:new-resource
+tencentcloud_mps_input
+```
+
+```release-note:new-resource
+tencentcloud_mps_output
+```
+
+```release-note:new-resource
+tencentcloud_mps_start_flow_operation
+```

tencentcloud/extension_mps.go

@@ -4,3 +4,13 @@ const (
 	WORKFLOW_STATUS_ENABLED  = "Enabled"
 	WORKFLOW_STATUS_DISABLED = "Disabled"
 )
+
+const (
+	PROTOCOL_RTP       = "RTP"
+	PROTOCOL_SRT       = "SRT"
+	PROTOCOL_RTMP      = "RTMP"
+	PROTOCOL_HLS       = "HLS"
+	PROTOCOL_RTMP_PULL = "RTMP_PULL"
+	PROTOCOL_RTSP_PULL = "RTSP_PULL"
+	PROTOCOL_HLS_PULL  = "HLS_PULL"
+)

tencentcloud/provider.go

@@ -1677,6 +1677,9 @@ Media Processing Service(MPS)
 	tencentcloud_mps_schedule
 	tencentcloud_mps_enable_schedule_config
 	tencentcloud_mps_flow
+	tencentcloud_mps_input
+	tencentcloud_mps_output
+	tencentcloud_mps_start_flow_operation
 	tencentcloud_mps_event
 	tencentcloud_mps_manage_task_operation
 	tencentcloud_mps_execute_function_operation
@@ -3264,6 +3267,8 @@ func Provider() *schema.Provider {
 			"tencentcloud_mps_workflow":                                        resourceTencentCloudMpsWorkflow(),
 			"tencentcloud_mps_enable_workflow_config":                          resourceTencentCloudMpsEnableWorkflowConfig(),
 			"tencentcloud_mps_flow":                                            resourceTencentCloudMpsFlow(),
+			"tencentcloud_mps_input":                                           resourceTencentCloudMpsInput(),
+			"tencentcloud_mps_output":                                          resourceTencentCloudMpsOutput(),
 			"tencentcloud_mps_start_flow_operation":                            resourceTencentCloudMpsStartFlowOperation(),
 			"tencentcloud_mps_event":                                           resourceTencentCloudMpsEvent(),
 			"tencentcloud_mps_execute_function_operation":                      resourceTencentCloudMpsExecuteFunctionOperation(),

tencentcloud/resource_tc_mps_flow.go

@@ -57,6 +57,57 @@ resource "tencentcloud_mps_flow" "flow_rtp" {
 }
 ```
 
+Create a mps RTP flow and start it
+
+Before you start a mps flow, you need to create a output first.
+
+```hcl
+resource "tencentcloud_mps_event" "event_rtp" {
+  event_name  = "your_event_name"
+  description = "tf test mps event description"
+}
+
+resource "tencentcloud_mps_flow" "flow_rtp" {
+  flow_name     = "your_flow_name"
+  max_bandwidth = 10000000
+  input_group {
+    input_name    = "test_inputname"
+    protocol      = "RTP"
+    description   = "input name Description"
+    allow_ip_list = ["0.0.0.0/0"]
+    rtp_settings {
+      fec          = "none"
+      idle_timeout = 1000
+    }
+  }
+  event_id = tencentcloud_mps_event.event_rtp.id
+}
+
+resource "tencentcloud_mps_output" "output" {
+  flow_id = tencentcloud_mps_flow.flow_rtp.id
+  output {
+    output_name   = "your_output_name"
+    description   = "tf mps output group"
+    protocol      = "RTP"
+    output_region = "ap-guangzhou"
+    rtp_settings {
+      destinations {
+        ip   = "203.205.141.84"
+        port = 65535
+      }
+      fec          = "none"
+      idle_timeout = 1000
+    }
+  }
+}
+
+resource "tencentcloud_mps_start_flow_operation" "operation" {
+  flow_id    = tencentcloud_mps_flow.flow_rtp.id
+  start      = true
+  depends_on = [tencentcloud_mps_output.output]
+}
+```
+
 Import
 
 mps flow can be imported using the id, e.g.
@@ -102,6 +153,7 @@ func resourceTencentCloudMpsFlow() *schema.Resource {
 
 			"input_group": {
 				Optional:    true,
+				Computed:    true,
 				Type:        schema.TypeList,
 				Description: "The input group for the flow.",
 				Elem: &schema.Resource{