feat/oceanus (#2442)

* feat/oceanus

* feat/oceanus

* feat/oceanus

* feat/oceanus

Author: SevenEarth

.changelog/2442.txt

@@ -0,0 +1,3 @@
+```release-note:new-data-source
+tencentcloud_oceanus_job_events
+```

go.mod

@@ -46,7 +46,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.825
+	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.829
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cvm v1.0.624
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cwp v1.0.762
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cynosdb v1.0.692
@@ -109,7 +109,7 @@ require (
 	github.com/hashicorp/go-uuid v1.0.3
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cdwpg v1.0.772
 	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dasb v1.0.798
-	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/oceanus v1.0.810
+	github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/oceanus v1.0.829
 	github.com/wI2L/jsondiff v0.3.0
 	k8s.io/apimachinery v0.22.4
 )

go.sum

@@ -933,6 +933,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.824 h1:jRLj
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.824/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.825 h1:ijG2TLksawrFMdBpfFa5N/HjBZLGRPwmCgg0JFfFl6E=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.825/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.829 h1:5Wx+X/EmjEU6T9WHjc/vBPvW97OUe3Bi8BGdQBD8pJM=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common v1.0.829/go.mod h1:r5r4xbfxSaeR04b166HGsBa/R4U3SueirEUpXGuw+Q0=
 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.762 h1:2egy69SP/wPsmnfozcQVZ6tUY6F6N/TpEe/7xtXrc/8=
@@ -981,6 +983,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mps v1.0.777 h1:SoH/Kkq
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/mps v1.0.777/go.mod h1:sBmwqD3GkczHFiArdYpHPp9QriIbzNtO99DueYVyGwE=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/oceanus v1.0.810 h1:P9eQ4I/cFcLnNGH8tjZsFVNTpJ4iizI5RBEkNfyKbDg=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/oceanus v1.0.810/go.mod h1:jWIMZDz6D+bwcfc1n4idP3S1581bOqRPaXjU4wllnZ8=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/oceanus v1.0.829 h1:+7Qwa1c6sgbBreu18IDYGmGGaoFwQVen3hmPQlALR4E=
+github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/oceanus v1.0.829/go.mod h1:ftIGeNWJScZOiWWEmJWRww65CMxsj26Vscc8A0yAObM=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/organization v1.0.770 h1:Ksu947uY/fafnlILemfMuyKqL/RxHh9dfVowWX8paeQ=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/organization v1.0.770/go.mod h1:Ew8jug2Kq03q9Kkjzov7IMYgugGLEw3FGYPofuRqzKw=
 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/postgres v1.0.814 h1:1XlGrQHRBJv419m64yWRNRWVUTvqBi3Go4ahndnZz9w=

tencentcloud/provider.go

@@ -311,6 +311,7 @@ func Provider() *schema.Provider {
 			"tencentcloud_oceanus_tree_resources":                       oceanus.DataSourceTencentCloudOceanusTreeResources(),
 			"tencentcloud_oceanus_job_submission_log":                   oceanus.DataSourceTencentCloudOceanusJobSubmissionLog(),
 			"tencentcloud_oceanus_check_savepoint":                      oceanus.DataSourceTencentCloudOceanusCheckSavepoint(),
+			"tencentcloud_oceanus_job_events":                           oceanus.DataSourceTencentCloudOceanusJobEvents(),
 			"tencentcloud_vpn_customer_gateways":                        vpn.DataSourceTencentCloudVpnCustomerGateways(),
 			"tencentcloud_vpn_gateways":                                 vpn.DataSourceTencentCloudVpnGateways(),
 			"tencentcloud_vpn_gateway_routes":                           vpn.DataSourceTencentCloudVpnGatewayRoutes(),

tencentcloud/services/oceanus/data_source_tc_oceanus_job_events.go

@@ -0,0 +1,201 @@
+package oceanus
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	oceanus "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/oceanus/v20190422"
+	tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func DataSourceTencentCloudOceanusJobEvents() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceTencentCloudOceanusJobEventsRead,
+		Schema: map[string]*schema.Schema{
+			"job_id": {
+				Required:    true,
+				Type:        schema.TypeString,
+				Description: "Job ID.",
+			},
+			"start_timestamp": {
+				Required:    true,
+				Type:        schema.TypeInt,
+				Description: "Filter condition:Start Unix timestamp (seconds).",
+			},
+			"end_timestamp": {
+				Required:    true,
+				Type:        schema.TypeInt,
+				Description: "Filter condition:End Unix timestamp (seconds).",
+			},
+			"types": {
+				Optional:    true,
+				Type:        schema.TypeSet,
+				Elem:        &schema.Schema{Type: schema.TypeString},
+				Description: "Event types. If not passed, data of all types will be returned.",
+			},
+			"work_space_id": {
+				Required:    true,
+				Type:        schema.TypeString,
+				Description: "Workspace SerialId.",
+			},
+			// Computed
+			"running_order_ids": {
+				Computed:    true,
+				Type:        schema.TypeSet,
+				Elem:        &schema.Schema{Type: schema.TypeInt},
+				Description: "Array of running instance IDs.",
+			},
+			"events": {
+				Computed:    true,
+				Type:        schema.TypeList,
+				Description: "List of events within the specified range for this jobNote: This field may return null, indicating that no valid values can be obtained.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"type": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "Internally defined event type.",
+						},
+						"description": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "Description text of the event type.",
+						},
+						"timestamp": {
+							Type:        schema.TypeInt,
+							Computed:    true,
+							Description: "Unix timestamp (seconds) when the event occurred.",
+						},
+						"running_order_id": {
+							Type:        schema.TypeInt,
+							Computed:    true,
+							Description: "Running ID when the event occurredNote: This field may return null, indicating that no valid values can be obtained.",
+						},
+						"message": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "Some optional explanations of the eventNote: This field may return null, indicating that no valid values can be obtained.",
+						},
+						"solution_link": {
+							Type:        schema.TypeString,
+							Computed:    true,
+							Description: "Troubleshooting manual link for the abnormal eventNote: This field may return null, indicating that no valid values can be obtained.",
+						},
+					},
+				},
+			},
+			"result_output_file": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Used to save results.",
+			},
+		},
+	}
+}
+
+func dataSourceTencentCloudOceanusJobEventsRead(d *schema.ResourceData, meta interface{}) error {
+	defer tccommon.LogElapsed("data_source.tencentcloud_oceanus_job_events.read")()
+	defer tccommon.InconsistentCheck(d, meta)()
+
+	var (
+		logId     = tccommon.GetLogId(tccommon.ContextNil)
+		ctx       = context.WithValue(context.TODO(), tccommon.LogIdKey, logId)
+		service   = OceanusService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
+		JobEvents *oceanus.DescribeJobEventsResponseParams
+		jobId     string
+	)
+
+	paramMap := make(map[string]interface{})
+	if v, ok := d.GetOk("job_id"); ok {
+		paramMap["JobId"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOkExists("start_timestamp"); ok {
+		paramMap["StartTimestamp"] = helper.IntUint64(v.(int))
+	}
+
+	if v, ok := d.GetOkExists("end_timestamp"); ok {
+		paramMap["EndTimestamp"] = helper.IntUint64(v.(int))
+	}
+
+	if v, ok := d.GetOk("types"); ok {
+		typesSet := v.(*schema.Set).List()
+		paramMap["Types"] = helper.InterfacesStringsPoint(typesSet)
+	}
+
+	if v, ok := d.GetOk("work_space_id"); ok {
+		paramMap["WorkSpaceId"] = helper.String(v.(string))
+	}
+
+	err := resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError {
+		result, e := service.DescribeOceanusJobEventsByFilter(ctx, paramMap)
+		if e != nil {
+			return tccommon.RetryError(e)
+		}
+
+		if result == nil {
+			e = fmt.Errorf("oceanus Job events not exists")
+			return resource.NonRetryableError(e)
+		}
+
+		JobEvents = result
+		return nil
+	})
+
+	if err != nil {
+		return err
+	}
+
+	if JobEvents.RunningOrderIds != nil {
+		_ = d.Set("running_order_ids", JobEvents.RunningOrderIds)
+	}
+
+	if JobEvents.Events != nil {
+		tmpList := make([]map[string]interface{}, 0, len(JobEvents.Events))
+
+		for _, jobEvent := range JobEvents.Events {
+			jobEventMap := map[string]interface{}{}
+
+			if jobEvent.Type != nil {
+				jobEventMap["type"] = jobEvent.Type
+			}
+
+			if jobEvent.Description != nil {
+				jobEventMap["description"] = jobEvent.Description
+			}
+
+			if jobEvent.Timestamp != nil {
+				jobEventMap["timestamp"] = jobEvent.Timestamp
+			}
+
+			if jobEvent.RunningOrderId != nil {
+				jobEventMap["running_order_id"] = jobEvent.RunningOrderId
+			}
+
+			if jobEvent.Message != nil {
+				jobEventMap["message"] = jobEvent.Message
+			}
+
+			if jobEvent.SolutionLink != nil {
+				jobEventMap["solution_link"] = jobEvent.SolutionLink
+			}
+
+			tmpList = append(tmpList, jobEventMap)
+		}
+
+		_ = d.Set("events", tmpList)
+	}
+
+	d.SetId(jobId)
+	output, ok := d.GetOk("result_output_file")
+	if ok && output.(string) != "" {
+		if e := tccommon.WriteToFile(output.(string), d); e != nil {
+			return e
+		}
+	}
+
+	return nil
+}

tencentcloud/services/oceanus/data_source_tc_oceanus_job_events.md

@@ -0,0 +1,13 @@
+Use this data source to query detailed information of oceanus job_events
+
+Example Usage
+
+```hcl
+data "tencentcloud_oceanus_job_events" "example" {
+	job_id          = "cql-6w8eab6f"
+	start_timestamp = 1630932161
+	end_timestamp   = 1631232466
+	types           = ["1", "2"]
+	work_space_id   = "space-6w8eab6f"
+}
+```

tencentcloud/services/oceanus/data_source_tc_oceanus_job_events_test.go

@@ -0,0 +1,41 @@
+package oceanus
+
+import (
+	"testing"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	tcacctest "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/acctest"
+)
+
+// go test -i; go test -test.run TestAccTencentCloudNeedFixOceanusJobEventsDataSource_basic -v
+func TestAccTencentCloudNeedFixOceanusJobEventsDataSource_basic(t *testing.T) {
+	t.Parallel()
+	resource.Test(t, resource.TestCase{
+		PreCheck: func() {
+			tcacctest.AccPreCheck(t)
+		},
+		Providers: tcacctest.AccProviders,
+		Steps: []resource.TestStep{
+			{
+				Config: testAccOceanusJobEventsDataSource,
+				Check: resource.ComposeTestCheckFunc(
+					tcacctest.AccCheckTencentCloudDataSourceID("data.tencentcloud_oceanus_job_events.example"),
+					resource.TestCheckResourceAttr("data.tencentcloud_oceanus_job_events.example", "job_id", "cql-6w8eab6f"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_oceanus_job_events.example", "start_timestamp"),
+					resource.TestCheckResourceAttrSet("data.tencentcloud_oceanus_job_events.example", "end_timestamp"),
+					resource.TestCheckResourceAttr("data.tencentcloud_oceanus_job_events.example", "work_space_id", "space-6w8eab6f"),
+				),
+			},
+		},
+	})
+}
+
+const testAccOceanusJobEventsDataSource = `
+data "tencentcloud_oceanus_job_events" "example" {
+  job_id          = "cql-6w8eab6f"
+  start_timestamp = 1630932161
+  end_timestamp   = 1631232466
+  types           = ["1", "2"]
+  work_space_id   = "space-6w8eab6f"
+}
+`

tencentcloud/services/oceanus/service_tencentcloud_oceanus.go

@@ -849,3 +849,55 @@ func (me *OceanusService) DeleteOceanusFolderById(ctx context.Context, workSpace
 
 	return
 }
+
+func (me *OceanusService) DescribeOceanusJobEventsByFilter(ctx context.Context, param map[string]interface{}) (JobEvents *oceanus.DescribeJobEventsResponseParams, errRet error) {
+	var (
+		logId   = tccommon.GetLogId(ctx)
+		request = oceanus.NewDescribeJobEventsRequest()
+	)
+
+	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())
+		}
+	}()
+
+	for k, v := range param {
+		if k == "JobId" {
+			request.JobId = v.(*string)
+		}
+
+		if k == "StartTimestamp" {
+			request.StartTimestamp = v.(*uint64)
+		}
+
+		if k == "EndTimestamp" {
+			request.EndTimestamp = v.(*uint64)
+		}
+
+		if k == "Types" {
+			request.Types = v.([]*string)
+		}
+
+		if k == "WorkSpaceId" {
+			request.WorkSpaceId = v.(*string)
+		}
+	}
+
+	ratelimit.Check(request.GetAction())
+
+	response, err := me.client.UseOceanusClient().DescribeJobEvents(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 {
+		return
+	}
+
+	JobEvents = response.Response
+	return
+}