diff --git a/.changelog/2180.txt b/.changelog/2180.txt new file mode 100644 index 0000000000..5f5971c7d2 --- /dev/null +++ b/.changelog/2180.txt @@ -0,0 +1,11 @@ +```release-note:new-data-source +tencentcloud_eb_platform_event_names +``` + +```release-note:new-data-source +tencentcloud_eb_platform_event_patterns +``` + +```release-note:new-data-source +tencentcloud_eb_platform_products +``` \ No newline at end of file diff --git a/go.mod b/go.mod index 7c15057ea0..43180529d0 100644 --- a/go.mod +++ b/go.mod @@ -55,7 +55,7 @@ require ( github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dnspod v1.0.539 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/domain v1.0.414 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dts v1.0.628 - github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.715 + github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.760 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/emr v1.0.725 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/es v1.0.699 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/gaap v1.0.514 diff --git a/go.sum b/go.sum index 1c5eae565e..21779d55cb 100644 --- a/go.sum +++ b/go.sum @@ -906,6 +906,8 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dts v1.0.628 h1:cnhe9uh github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dts v1.0.628/go.mod h1:JxTXEld643DHk5HeQe4xIvuuoxsCmbTjgmE64Mtrdxw= github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.715 h1:k9wDdxbFD29m2T6B1j5qnpWjVUUVP02vmTZB/m4AVaI= github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.715/go.mod h1:JoFrUxweQaDBzl5jvphkz8uIxvm+pugI25kY8aUdIAo= +github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.760 h1:IKP2LFgJwbnP4IyQQw0k2gdVrd8H8e8X8TL/cIuCHEk= +github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.760/go.mod h1:pSQXTeuC6BahiUIfssVqvL1/BoXccLkyD7nJ+tKgygw= github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/emr v1.0.725 h1:r2klzw/HohGsw/piykh3QW5Ft8+7kl0y5KlgNQ8TdAc= github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/emr v1.0.725/go.mod h1:SW2tOlPfjXsCTKU2fYwG5Ydt8w2ZmrK8p3WBgm7sTTE= github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/es v1.0.699 h1:7lFObucmWErYOh+5/AzpgerUAFoO72XqhXrAzFltTIo= diff --git a/tencentcloud/data_source_tc_eb_platform_event_names.go b/tencentcloud/data_source_tc_eb_platform_event_names.go new file mode 100644 index 0000000000..48677d35d2 --- /dev/null +++ b/tencentcloud/data_source_tc_eb_platform_event_names.go @@ -0,0 +1,120 @@ +/* +Use this data source to query detailed information of eb platform_event_names + +Example Usage + +```hcl +data "tencentcloud_eb_platform_event_names" "platform_event_names" { + product_type = "" +} +``` +*/ +package tencentcloud + +import ( + "context" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema" + eb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416" + "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper" +) + +func dataSourceTencentCloudEbPlatformEventNames() *schema.Resource { + return &schema.Resource{ + Read: dataSourceTencentCloudEbPlateformRead, + Schema: map[string]*schema.Schema{ + "product_type": { + Required: true, + Type: schema.TypeString, + Description: "Platform product event type.", + }, + + "event_names": { + Computed: true, + Type: schema.TypeList, + Description: "Platform product list.", + Elem: &schema.Resource{ + Schema: map[string]*schema.Schema{ + "event_name": { + Type: schema.TypeString, + Computed: true, + Description: "Event name.Note: This field may return null, indicating that no valid value can be obtained.", + }, + "event_type": { + Type: schema.TypeString, + Computed: true, + Description: "Event type.Note: This field may return null, indicating that no valid value can be obtained.", + }, + }, + }, + }, + + "result_output_file": { + Type: schema.TypeString, + Optional: true, + Description: "Used to save results.", + }, + }, + } +} + +func dataSourceTencentCloudEbPlateformRead(d *schema.ResourceData, meta interface{}) error { + defer logElapsed("data_source.tencentcloud_eb_platform_event_names.read")() + defer inconsistentCheck(d, meta)() + + logId := getLogId(contextNil) + ctx := context.WithValue(context.TODO(), logIdKey, logId) + + var productType string + paramMap := make(map[string]interface{}) + if v, ok := d.GetOk("product_type"); ok { + productType = v.(string) + paramMap["ProductType"] = helper.String(v.(string)) + } + + service := EbService{client: meta.(*TencentCloudClient).apiV3Conn} + + var eventNames []*eb.PlatformEventDetail + err := resource.Retry(readRetryTimeout, func() *resource.RetryError { + result, e := service.DescribeEbPlateformByFilter(ctx, paramMap) + if e != nil { + return retryError(e) + } + eventNames = result + return nil + }) + if err != nil { + return err + } + + ids := make([]string, 0, len(eventNames)) + tmpList := make([]map[string]interface{}, 0, len(eventNames)) + if eventNames != nil { + for _, platformEventDetail := range eventNames { + platformEventDetailMap := map[string]interface{}{} + + if platformEventDetail.EventName != nil { + platformEventDetailMap["event_name"] = platformEventDetail.EventName + } + + if platformEventDetail.EventType != nil { + platformEventDetailMap["event_type"] = platformEventDetail.EventType + ids = append(ids, *platformEventDetail.EventType) + } + + tmpList = append(tmpList, platformEventDetailMap) + } + + _ = d.Set("event_names", tmpList) + } + + d.SetId(helper.DataResourceIdsHash(append(ids, productType))) + output, ok := d.GetOk("result_output_file") + if ok && output.(string) != "" { + if e := writeToFile(output.(string), tmpList); e != nil { + return e + } + } + return nil +} diff --git a/tencentcloud/data_source_tc_eb_platform_event_names_test.go b/tencentcloud/data_source_tc_eb_platform_event_names_test.go new file mode 100644 index 0000000000..9302d211fa --- /dev/null +++ b/tencentcloud/data_source_tc_eb_platform_event_names_test.go @@ -0,0 +1,35 @@ +package tencentcloud + +import ( + "testing" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" +) + +// go test -test.run TestAccTencentCloudEbPlatformEventNamesDataSource_basic -v +func TestAccTencentCloudEbPlatformEventNamesDataSource_basic(t *testing.T) { + t.Parallel() + resource.Test(t, resource.TestCase{ + PreCheck: func() { + testAccStepSetRegion(t, "ap-chongqing") + testAccPreCheck(t) + }, + Providers: testAccProviders, + Steps: []resource.TestStep{ + { + Config: testAccEbPlatformEventNamesDataSource, + Check: resource.ComposeTestCheckFunc( + testAccCheckTencentCloudDataSourceID("data.tencentcloud_eb_platform_event_names.platform_event_names"), + ), + }, + }, + }) +} + +const testAccEbPlatformEventNamesDataSource = ` + +data "tencentcloud_eb_platform_event_names" "platform_event_names" { + product_type = "eb_platform_test" +} + +` diff --git a/tencentcloud/data_source_tc_eb_platform_event_patterns.go b/tencentcloud/data_source_tc_eb_platform_event_patterns.go new file mode 100644 index 0000000000..2108f84d28 --- /dev/null +++ b/tencentcloud/data_source_tc_eb_platform_event_patterns.go @@ -0,0 +1,122 @@ +/* +Use this data source to query detailed information of eb platform_event_patterns + +Example Usage + +```hcl +data "tencentcloud_eb_platform_event_patterns" "platform_event_patterns" { + product_type = "" +} +``` +*/ +package tencentcloud + +import ( + "context" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema" + eb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416" + "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper" +) + +func dataSourceTencentCloudEbPlatformEventPatterns() *schema.Resource { + return &schema.Resource{ + Read: dataSourceTencentCloudEbPlatformEventPatternsRead, + Schema: map[string]*schema.Schema{ + "product_type": { + Required: true, + Type: schema.TypeString, + Description: "Platform product type.", + }, + + "event_patterns": { + Computed: true, + Type: schema.TypeList, + Description: "Platform product event matching rules.", + Elem: &schema.Resource{ + Schema: map[string]*schema.Schema{ + "event_name": { + Type: schema.TypeString, + Computed: true, + Description: "Platform event name.Note: This field may return null, indicating that no valid value can be obtained.", + }, + "event_pattern": { + Type: schema.TypeString, + Computed: true, + Description: "Platform event matching rules.Note: This field may return null, indicating that no valid value can be obtained.", + }, + }, + }, + }, + + "result_output_file": { + Type: schema.TypeString, + Optional: true, + Description: "Used to save results.", + }, + }, + } +} + +func dataSourceTencentCloudEbPlatformEventPatternsRead(d *schema.ResourceData, meta interface{}) error { + defer logElapsed("data_source.tencentcloud_eb_platform_event_patterns.read")() + defer inconsistentCheck(d, meta)() + + logId := getLogId(contextNil) + + ctx := context.WithValue(context.TODO(), logIdKey, logId) + + var productType string + paramMap := make(map[string]interface{}) + if v, ok := d.GetOk("product_type"); ok { + productType = v.(string) + paramMap["ProductType"] = helper.String(v.(string)) + } + + service := EbService{client: meta.(*TencentCloudClient).apiV3Conn} + + var eventPatterns []*eb.PlatformEventSummary + + err := resource.Retry(readRetryTimeout, func() *resource.RetryError { + result, e := service.DescribeEbPlatformEventPatternsByFilter(ctx, paramMap) + if e != nil { + return retryError(e) + } + eventPatterns = result + return nil + }) + if err != nil { + return err + } + + ids := make([]string, 0, len(eventPatterns)) + tmpList := make([]map[string]interface{}, 0, len(eventPatterns)) + + if eventPatterns != nil { + for _, platformEventSummary := range eventPatterns { + platformEventSummaryMap := map[string]interface{}{} + + if platformEventSummary.EventName != nil { + platformEventSummaryMap["event_name"] = platformEventSummary.EventName + } + + if platformEventSummary.EventPattern != nil { + platformEventSummaryMap["event_pattern"] = platformEventSummary.EventPattern + ids = append(ids, *platformEventSummary.EventPattern) + } + tmpList = append(tmpList, platformEventSummaryMap) + } + + _ = d.Set("event_patterns", tmpList) + } + + d.SetId(helper.DataResourceIdsHash(append(ids, productType))) + output, ok := d.GetOk("result_output_file") + if ok && output.(string) != "" { + if e := writeToFile(output.(string), tmpList); e != nil { + return e + } + } + return nil +} diff --git a/tencentcloud/data_source_tc_eb_platform_event_patterns_test.go b/tencentcloud/data_source_tc_eb_platform_event_patterns_test.go new file mode 100644 index 0000000000..8d0ef1a4a8 --- /dev/null +++ b/tencentcloud/data_source_tc_eb_platform_event_patterns_test.go @@ -0,0 +1,35 @@ +package tencentcloud + +import ( + "testing" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" +) + +// go test -test.run TestAccTencentCloudEbPlatformEventPatternsDataSource_basic -v +func TestAccTencentCloudEbPlatformEventPatternsDataSource_basic(t *testing.T) { + t.Parallel() + resource.Test(t, resource.TestCase{ + PreCheck: func() { + testAccStepSetRegion(t, "ap-chongqing") + testAccPreCheck(t) + }, + Providers: testAccProviders, + Steps: []resource.TestStep{ + { + Config: testAccEbPlatformEventPatternsDataSource, + Check: resource.ComposeTestCheckFunc( + testAccCheckTencentCloudDataSourceID("data.tencentcloud_eb_platform_event_patterns.platform_event_patterns"), + ), + }, + }, + }) +} + +const testAccEbPlatformEventPatternsDataSource = ` + +data "tencentcloud_eb_platform_event_patterns" "platform_event_patterns" { + product_type = "eb_platform_test" + } + +` diff --git a/tencentcloud/data_source_tc_eb_platform_products.go b/tencentcloud/data_source_tc_eb_platform_products.go new file mode 100644 index 0000000000..f02a0442f5 --- /dev/null +++ b/tencentcloud/data_source_tc_eb_platform_products.go @@ -0,0 +1,109 @@ +/* +Use this data source to query detailed information of eb platform_products + +Example Usage + +```hcl +data "tencentcloud_eb_platform_products" "platform_products" { +} +``` +*/ +package tencentcloud + +import ( + "context" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema" + eb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416" + "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper" +) + +func dataSourceTencentCloudEbPlatformProducts() *schema.Resource { + return &schema.Resource{ + Read: dataSourceTencentCloudEbPlatformProductsRead, + Schema: map[string]*schema.Schema{ + "platform_products": { + Computed: true, + Type: schema.TypeList, + Description: "Platform product list.", + Elem: &schema.Resource{ + Schema: map[string]*schema.Schema{ + "product_name": { + Type: schema.TypeString, + Computed: true, + Description: "Platform product name.", + }, + "product_type": { + Type: schema.TypeString, + Computed: true, + Description: "Platform product type.", + }, + }, + }, + }, + + "result_output_file": { + Type: schema.TypeString, + Optional: true, + Description: "Used to save results.", + }, + }, + } +} + +func dataSourceTencentCloudEbPlatformProductsRead(d *schema.ResourceData, meta interface{}) error { + defer logElapsed("data_source.tencentcloud_eb_platform_products.read")() + defer inconsistentCheck(d, meta)() + + logId := getLogId(contextNil) + + ctx := context.WithValue(context.TODO(), logIdKey, logId) + + paramMap := make(map[string]interface{}) + service := EbService{client: meta.(*TencentCloudClient).apiV3Conn} + + var platformProducts []*eb.PlatformProduct + err := resource.Retry(readRetryTimeout, func() *resource.RetryError { + result, e := service.DescribeEbPlatformProductsByFilter(ctx, paramMap) + if e != nil { + return retryError(e) + } + platformProducts = result + return nil + }) + if err != nil { + return err + } + + ids := make([]string, 0, len(platformProducts)) + tmpList := make([]map[string]interface{}, 0, len(platformProducts)) + + if platformProducts != nil { + for _, platformProduct := range platformProducts { + platformProductMap := map[string]interface{}{} + + if platformProduct.ProductName != nil { + platformProductMap["product_name"] = platformProduct.ProductName + } + + if platformProduct.ProductType != nil { + platformProductMap["product_type"] = platformProduct.ProductType + } + + ids = append(ids, *platformProduct.ProductName) + tmpList = append(tmpList, platformProductMap) + } + + _ = d.Set("platform_products", tmpList) + } + + d.SetId(helper.DataResourceIdsHash(ids)) + output, ok := d.GetOk("result_output_file") + if ok && output.(string) != "" { + if e := writeToFile(output.(string), tmpList); e != nil { + return e + } + } + return nil +} diff --git a/tencentcloud/data_source_tc_eb_platform_products_test.go b/tencentcloud/data_source_tc_eb_platform_products_test.go new file mode 100644 index 0000000000..40e451b1bd --- /dev/null +++ b/tencentcloud/data_source_tc_eb_platform_products_test.go @@ -0,0 +1,36 @@ +package tencentcloud + +import ( + "testing" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" +) + +// go test -test.run TestAccTencentCloudEbPlatformProductsDataSource_basic -v +func TestAccTencentCloudEbPlatformProductsDataSource_basic(t *testing.T) { + t.Parallel() + resource.Test(t, resource.TestCase{ + PreCheck: func() { + testAccStepSetRegion(t, "ap-chongqing") + testAccPreCheck(t) + }, + Providers: testAccProviders, + Steps: []resource.TestStep{ + { + Config: testAccEbPlatformProductsDataSource, + Check: resource.ComposeTestCheckFunc( + testAccCheckTencentCloudDataSourceID("data.tencentcloud_eb_platform_products.platform_products"), + resource.TestCheckResourceAttrSet("data.tencentcloud_eb_platform_products.platform_products", "platform_products.#"), + resource.TestCheckResourceAttr("data.tencentcloud_eb_platform_products.platform_products", "platform_products.0.product_type", "eb_platform_test"), + ), + }, + }, + }) +} + +const testAccEbPlatformProductsDataSource = ` + +data "tencentcloud_eb_platform_products" "platform_products" { +} + +` diff --git a/tencentcloud/provider.go b/tencentcloud/provider.go index 4f1d4207d8..5d8dee3518 100644 --- a/tencentcloud/provider.go +++ b/tencentcloud/provider.go @@ -1656,6 +1656,9 @@ EventBridge(EB) Data Source tencentcloud_eb_bus tencentcloud_eb_event_rules + tencentcloud_eb_platform_event_names + tencentcloud_eb_platform_event_patterns + tencentcloud_eb_platform_products Resource tencentcloud_eb_event_transform @@ -2375,6 +2378,9 @@ func Provider() *schema.Provider { "tencentcloud_eb_search": dataSourceTencentCloudEbSearch(), "tencentcloud_eb_bus": dataSourceTencentCloudEbBus(), "tencentcloud_eb_event_rules": dataSourceTencentCloudEbEventRules(), + "tencentcloud_eb_platform_event_names": dataSourceTencentCloudEbPlatformEventNames(), + "tencentcloud_eb_platform_event_patterns": dataSourceTencentCloudEbPlatformEventPatterns(), + "tencentcloud_eb_platform_products": dataSourceTencentCloudEbPlatformProducts(), "tencentcloud_wedata_rule_templates": dataSourceTencentCloudWedataRuleTemplates(), "tencentcloud_private_dns_records": dataSourceTencentCloudPrivateDnsRecords(), "tencentcloud_waf_ciphers": dataSourceTencentCloudWafCiphers(), diff --git a/tencentcloud/service_tencentcloud_eb.go b/tencentcloud/service_tencentcloud_eb.go index 91098cb97e..6e7c25adb7 100644 --- a/tencentcloud/service_tencentcloud_eb.go +++ b/tencentcloud/service_tencentcloud_eb.go @@ -529,3 +529,102 @@ func (me *EbService) DescribeEbEventRulesByFilter(ctx context.Context, param map return } + +func (me *EbService) DescribeEbPlateformByFilter(ctx context.Context, param map[string]interface{}) (plateform []*eb.PlatformEventDetail, errRet error) { + var ( + logId = getLogId(ctx) + request = eb.NewListPlatformEventNamesRequest() + ) + + 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 == "ProductType" { + request.ProductType = v.(*string) + } + } + + ratelimit.Check(request.GetAction()) + response, err := me.client.UseEbClient().ListPlatformEventNames(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 len(response.Response.EventNames) < 1 { + return + } + + plateform = response.Response.EventNames + + return +} + +func (me *EbService) DescribeEbPlatformEventPatternsByFilter(ctx context.Context, param map[string]interface{}) (platformEventPatterns []*eb.PlatformEventSummary, errRet error) { + var ( + logId = getLogId(ctx) + request = eb.NewListPlatformEventPatternsRequest() + ) + + 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 == "ProductType" { + request.ProductType = v.(*string) + } + } + + ratelimit.Check(request.GetAction()) + response, err := me.client.UseEbClient().ListPlatformEventPatterns(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 len(response.Response.EventPatterns) < 1 { + return + } + + platformEventPatterns = response.Response.EventPatterns + + return +} + +func (me *EbService) DescribeEbPlatformProductsByFilter(ctx context.Context, param map[string]interface{}) (platformProducts []*eb.PlatformProduct, errRet error) { + var ( + logId = getLogId(ctx) + request = eb.NewListPlatformProductsRequest() + ) + + 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.UseEbClient().ListPlatformProducts(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 len(response.Response.PlatformProducts) < 1 { + return + } + + platformProducts = response.Response.PlatformProducts + + return +} diff --git a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/client.go b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/client.go index c2d317fc64..ae87a961f2 100644 --- a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/client.go +++ b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/client.go @@ -436,6 +436,7 @@ func NewCreateTargetResponse() (response *CreateTargetResponse) { // FAILEDOPERATION_ESINTERNALERROR = "FailedOperation.ESInternalError" // FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed" // FAILEDOPERATION_ESTEMPLATECONFLICT = "FailedOperation.ESTemplateConflict" +// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload" // INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams" // INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount" // INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout" @@ -487,6 +488,7 @@ func (c *Client) CreateTarget(request *CreateTargetRequest) (response *CreateTar // FAILEDOPERATION_ESINTERNALERROR = "FailedOperation.ESInternalError" // FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed" // FAILEDOPERATION_ESTEMPLATECONFLICT = "FailedOperation.ESTemplateConflict" +// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload" // INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams" // INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount" // INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout" @@ -986,6 +988,7 @@ func NewGetEventBusResponse() (response *GetEventBusResponse) { // // 可能返回的错误码: // INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" func (c *Client) GetEventBus(request *GetEventBusRequest) (response *GetEventBusResponse, err error) { return c.GetEventBusWithContext(context.Background(), request) @@ -996,6 +999,7 @@ func (c *Client) GetEventBus(request *GetEventBusRequest) (response *GetEventBus // // 可能返回的错误码: // INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" func (c *Client) GetEventBusWithContext(ctx context.Context, request *GetEventBusRequest) (response *GetEventBusResponse, err error) { if request == nil { @@ -1013,6 +1017,56 @@ func (c *Client) GetEventBusWithContext(ctx context.Context, request *GetEventBu return } +func NewGetPlatformEventTemplateRequest() (request *GetPlatformEventTemplateRequest) { + request = &GetPlatformEventTemplateRequest{ + BaseRequest: &tchttp.BaseRequest{}, + } + + request.Init().WithApiInfo("eb", APIVersion, "GetPlatformEventTemplate") + + + return +} + +func NewGetPlatformEventTemplateResponse() (response *GetPlatformEventTemplateResponse) { + response = &GetPlatformEventTemplateResponse{ + BaseResponse: &tchttp.BaseResponse{}, + } + return +} + +// GetPlatformEventTemplate +// 获取平台产品事件模板 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action" +func (c *Client) GetPlatformEventTemplate(request *GetPlatformEventTemplateRequest) (response *GetPlatformEventTemplateResponse, err error) { + return c.GetPlatformEventTemplateWithContext(context.Background(), request) +} + +// GetPlatformEventTemplate +// 获取平台产品事件模板 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action" +func (c *Client) GetPlatformEventTemplateWithContext(ctx context.Context, request *GetPlatformEventTemplateRequest) (response *GetPlatformEventTemplateResponse, err error) { + if request == nil { + request = NewGetPlatformEventTemplateRequest() + } + + if c.GetCredential() == nil { + return nil, errors.New("GetPlatformEventTemplate require credential") + } + + request.SetContext(ctx) + + response = NewGetPlatformEventTemplateResponse() + err = c.Send(request, response) + return +} + func NewGetRuleRequest() (request *GetRuleRequest) { request = &GetRuleRequest{ BaseRequest: &tchttp.BaseRequest{}, @@ -1038,6 +1092,7 @@ func NewGetRuleResponse() (response *GetRuleResponse) { // INTERNALERROR = "InternalError" // INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId" // INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" // RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule" func (c *Client) GetRule(request *GetRuleRequest) (response *GetRuleResponse, err error) { @@ -1051,6 +1106,7 @@ func (c *Client) GetRule(request *GetRuleRequest) (response *GetRuleResponse, er // INTERNALERROR = "InternalError" // INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId" // INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" // RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule" func (c *Client) GetRuleWithContext(ctx context.Context, request *GetRuleRequest) (response *GetRuleResponse, err error) { @@ -1150,6 +1206,7 @@ func NewListConnectionsResponse() (response *ListConnectionsResponse) { // INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset" // INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order" // INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" func (c *Client) ListConnections(request *ListConnectionsRequest) (response *ListConnectionsResponse, err error) { return c.ListConnectionsWithContext(context.Background(), request) @@ -1164,6 +1221,7 @@ func (c *Client) ListConnections(request *ListConnectionsRequest) (response *Lis // INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset" // INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order" // INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" func (c *Client) ListConnectionsWithContext(ctx context.Context, request *ListConnectionsRequest) (response *ListConnectionsResponse, err error) { if request == nil { @@ -1241,6 +1299,154 @@ func (c *Client) ListEventBusesWithContext(ctx context.Context, request *ListEve return } +func NewListPlatformEventNamesRequest() (request *ListPlatformEventNamesRequest) { + request = &ListPlatformEventNamesRequest{ + BaseRequest: &tchttp.BaseRequest{}, + } + + request.Init().WithApiInfo("eb", APIVersion, "ListPlatformEventNames") + + + return +} + +func NewListPlatformEventNamesResponse() (response *ListPlatformEventNamesResponse) { + response = &ListPlatformEventNamesResponse{ + BaseResponse: &tchttp.BaseResponse{}, + } + return +} + +// ListPlatformEventNames +// 获取平台产品事件名称 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +func (c *Client) ListPlatformEventNames(request *ListPlatformEventNamesRequest) (response *ListPlatformEventNamesResponse, err error) { + return c.ListPlatformEventNamesWithContext(context.Background(), request) +} + +// ListPlatformEventNames +// 获取平台产品事件名称 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +func (c *Client) ListPlatformEventNamesWithContext(ctx context.Context, request *ListPlatformEventNamesRequest) (response *ListPlatformEventNamesResponse, err error) { + if request == nil { + request = NewListPlatformEventNamesRequest() + } + + if c.GetCredential() == nil { + return nil, errors.New("ListPlatformEventNames require credential") + } + + request.SetContext(ctx) + + response = NewListPlatformEventNamesResponse() + err = c.Send(request, response) + return +} + +func NewListPlatformEventPatternsRequest() (request *ListPlatformEventPatternsRequest) { + request = &ListPlatformEventPatternsRequest{ + BaseRequest: &tchttp.BaseRequest{}, + } + + request.Init().WithApiInfo("eb", APIVersion, "ListPlatformEventPatterns") + + + return +} + +func NewListPlatformEventPatternsResponse() (response *ListPlatformEventPatternsResponse) { + response = &ListPlatformEventPatternsResponse{ + BaseResponse: &tchttp.BaseResponse{}, + } + return +} + +// ListPlatformEventPatterns +// 获取平台产品事件匹配规则 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action" +func (c *Client) ListPlatformEventPatterns(request *ListPlatformEventPatternsRequest) (response *ListPlatformEventPatternsResponse, err error) { + return c.ListPlatformEventPatternsWithContext(context.Background(), request) +} + +// ListPlatformEventPatterns +// 获取平台产品事件匹配规则 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action" +func (c *Client) ListPlatformEventPatternsWithContext(ctx context.Context, request *ListPlatformEventPatternsRequest) (response *ListPlatformEventPatternsResponse, err error) { + if request == nil { + request = NewListPlatformEventPatternsRequest() + } + + if c.GetCredential() == nil { + return nil, errors.New("ListPlatformEventPatterns require credential") + } + + request.SetContext(ctx) + + response = NewListPlatformEventPatternsResponse() + err = c.Send(request, response) + return +} + +func NewListPlatformProductsRequest() (request *ListPlatformProductsRequest) { + request = &ListPlatformProductsRequest{ + BaseRequest: &tchttp.BaseRequest{}, + } + + request.Init().WithApiInfo("eb", APIVersion, "ListPlatformProducts") + + + return +} + +func NewListPlatformProductsResponse() (response *ListPlatformProductsResponse) { + response = &ListPlatformProductsResponse{ + BaseResponse: &tchttp.BaseResponse{}, + } + return +} + +// ListPlatformProducts +// 获取平台产品列表 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action" +func (c *Client) ListPlatformProducts(request *ListPlatformProductsRequest) (response *ListPlatformProductsResponse, err error) { + return c.ListPlatformProductsWithContext(context.Background(), request) +} + +// ListPlatformProducts +// 获取平台产品列表 +// +// 可能返回的错误码: +// INTERNALERROR = "InternalError" +// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action" +func (c *Client) ListPlatformProductsWithContext(ctx context.Context, request *ListPlatformProductsRequest) (response *ListPlatformProductsResponse, err error) { + if request == nil { + request = NewListPlatformProductsRequest() + } + + if c.GetCredential() == nil { + return nil, errors.New("ListPlatformProducts require credential") + } + + request.SetContext(ctx) + + response = NewListPlatformProductsResponse() + err = c.Send(request, response) + return +} + func NewListRulesRequest() (request *ListRulesRequest) { request = &ListRulesRequest{ BaseRequest: &tchttp.BaseRequest{}, @@ -1268,6 +1474,7 @@ func NewListRulesResponse() (response *ListRulesResponse) { // INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit" // INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order" // INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" func (c *Client) ListRules(request *ListRulesRequest) (response *ListRulesResponse, err error) { return c.ListRulesWithContext(context.Background(), request) @@ -1282,6 +1489,7 @@ func (c *Client) ListRules(request *ListRulesRequest) (response *ListRulesRespon // INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit" // INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order" // INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" func (c *Client) ListRulesWithContext(ctx context.Context, request *ListRulesRequest) (response *ListRulesResponse, err error) { if request == nil { @@ -1328,6 +1536,7 @@ func NewListTargetsResponse() (response *ListTargetsResponse) { // INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy" // INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId" // INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" // RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule" func (c *Client) ListTargets(request *ListTargetsRequest) (response *ListTargetsResponse, err error) { @@ -1345,6 +1554,7 @@ func (c *Client) ListTargets(request *ListTargetsRequest) (response *ListTargets // INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy" // INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId" // INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId" +// RESOURCENOTFOUND = "ResourceNotFound" // RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus" // RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule" func (c *Client) ListTargetsWithContext(ctx context.Context, request *ListTargetsRequest) (response *ListTargetsResponse, err error) { @@ -1626,6 +1836,7 @@ func NewUpdateEventBusResponse() (response *UpdateEventBusResponse) { // // 可能返回的错误码: // FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService" +// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload" // INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description" // INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName" // INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig" @@ -1641,6 +1852,7 @@ func (c *Client) UpdateEventBus(request *UpdateEventBusRequest) (response *Updat // // 可能返回的错误码: // FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService" +// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload" // INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description" // INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName" // INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig" diff --git a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/models.go b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/models.go index f267dd47c4..44e9602918 100644 --- a/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/models.go +++ b/vendor/github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416/models.go @@ -15,27 +15,36 @@ package v20210416 import ( - "encoding/json" tcerr "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/errors" tchttp "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/http" + "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/json" ) type APIGWParams struct { // HTTPS - Protocol *string `json:"Protocol,omitempty" name:"Protocol"` + Protocol *string `json:"Protocol,omitnil" name:"Protocol"` // POST - Method *string `json:"Method,omitempty" name:"Method"` + Method *string `json:"Method,omitnil" name:"Method"` } // Predefined struct for user type CheckRuleRequestParams struct { + // Event信息 + Event *string `json:"Event,omitnil" name:"Event"` + // EventPattern信息 + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` } type CheckRuleRequest struct { *tchttp.BaseRequest + // Event信息 + Event *string `json:"Event,omitnil" name:"Event"` + + // EventPattern信息 + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` } func (r *CheckRuleRequest) ToJsonString() string { @@ -50,7 +59,8 @@ func (r *CheckRuleRequest) FromJsonString(s string) error { if err := json.Unmarshal([]byte(s), &f); err != nil { return err } - + delete(f, "Event") + delete(f, "EventPattern") if len(f) > 0 { return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "CheckRuleRequest has unknown keys!", "") } @@ -60,7 +70,7 @@ func (r *CheckRuleRequest) FromJsonString(s string) error { // Predefined struct for user type CheckRuleResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type CheckRuleResponse struct { @@ -82,20 +92,20 @@ func (r *CheckRuleResponse) FromJsonString(s string) error { // Predefined struct for user type CheckTransformationRequestParams struct { // 待处理的json字符串 - Input *string `json:"Input,omitempty" name:"Input"` + Input *string `json:"Input,omitnil" name:"Input"` // 一个转换规则列表 - Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"` + Transformations []*Transformation `json:"Transformations,omitnil" name:"Transformations"` } type CheckTransformationRequest struct { *tchttp.BaseRequest // 待处理的json字符串 - Input *string `json:"Input,omitempty" name:"Input"` + Input *string `json:"Input,omitnil" name:"Input"` // 一个转换规则列表 - Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"` + Transformations []*Transformation `json:"Transformations,omitnil" name:"Transformations"` } func (r *CheckTransformationRequest) ToJsonString() string { @@ -121,10 +131,10 @@ func (r *CheckTransformationRequest) FromJsonString(s string) error { // Predefined struct for user type CheckTransformationResponseParams struct { // 经过Transformations处理之后的数据 - Output *string `json:"Output,omitempty" name:"Output"` + Output *string `json:"Output,omitnil" name:"Output"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type CheckTransformationResponse struct { @@ -145,128 +155,128 @@ func (r *CheckTransformationResponse) FromJsonString(s string) error { type CkafkaDeliveryParams struct { // ckafka topic name - TopicName *string `json:"TopicName,omitempty" name:"TopicName"` + TopicName *string `json:"TopicName,omitnil" name:"TopicName"` // ckafka资源qcs六段式 - ResourceDescription *string `json:"ResourceDescription,omitempty" name:"ResourceDescription"` + ResourceDescription *string `json:"ResourceDescription,omitnil" name:"ResourceDescription"` } type CkafkaParams struct { // kafka offset - Offset *string `json:"Offset,omitempty" name:"Offset"` + Offset *string `json:"Offset,omitnil" name:"Offset"` // ckafka topic - TopicName *string `json:"TopicName,omitempty" name:"TopicName"` + TopicName *string `json:"TopicName,omitnil" name:"TopicName"` } type CkafkaTargetParams struct { // 要投递到的ckafka topic - TopicName *string `json:"TopicName,omitempty" name:"TopicName"` + TopicName *string `json:"TopicName,omitnil" name:"TopicName"` // 重试策略 - RetryPolicy *RetryPolicy `json:"RetryPolicy,omitempty" name:"RetryPolicy"` + RetryPolicy *RetryPolicy `json:"RetryPolicy,omitnil" name:"RetryPolicy"` } type Connection struct { // 状态 - Status *string `json:"Status,omitempty" name:"Status"` + Status *string `json:"Status,omitnil" name:"Status"` // 更新时间 - ModTime *string `json:"ModTime,omitempty" name:"ModTime"` + ModTime *string `json:"ModTime,omitnil" name:"ModTime"` // 使能开关 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 创建时间 - AddTime *string `json:"AddTime,omitempty" name:"AddTime"` + AddTime *string `json:"AddTime,omitnil" name:"AddTime"` // 连接器ID - ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"` + ConnectionId *string `json:"ConnectionId,omitnil" name:"ConnectionId"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 连接器描述 - ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitempty" name:"ConnectionDescription"` + ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitnil" name:"ConnectionDescription"` // 连接器名称 - ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"` + ConnectionName *string `json:"ConnectionName,omitnil" name:"ConnectionName"` // 类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` } type ConnectionBrief struct { // 连接器类型 // 注意:此字段可能返回 null,表示取不到有效值。 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 连接器状态 // 注意:此字段可能返回 null,表示取不到有效值。 - Status *string `json:"Status,omitempty" name:"Status"` + Status *string `json:"Status,omitnil" name:"Status"` } type ConnectionDescription struct { // 资源qcs六段式,更多参考 [资源六段式](https://cloud.tencent.com/document/product/598/10606) - ResourceDescription *string `json:"ResourceDescription,omitempty" name:"ResourceDescription"` + ResourceDescription *string `json:"ResourceDescription,omitnil" name:"ResourceDescription"` // apigw参数 // 注意:此字段可能返回 null,表示取不到有效值。 - APIGWParams *APIGWParams `json:"APIGWParams,omitempty" name:"APIGWParams"` + APIGWParams *APIGWParams `json:"APIGWParams,omitnil" name:"APIGWParams"` // ckafka参数 // 注意:此字段可能返回 null,表示取不到有效值。 - CkafkaParams *CkafkaParams `json:"CkafkaParams,omitempty" name:"CkafkaParams"` + CkafkaParams *CkafkaParams `json:"CkafkaParams,omitnil" name:"CkafkaParams"` // data transfer service (DTS)参数 // 注意:此字段可能返回 null,表示取不到有效值。 - DTSParams *DTSParams `json:"DTSParams,omitempty" name:"DTSParams"` + DTSParams *DTSParams `json:"DTSParams,omitnil" name:"DTSParams"` } // Predefined struct for user type CreateConnectionRequestParams struct { // 连接器描述 - ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitempty" name:"ConnectionDescription"` + ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitnil" name:"ConnectionDescription"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 连接器名称 - ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"` + ConnectionName *string `json:"ConnectionName,omitnil" name:"ConnectionName"` // 描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 使能开关 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` } type CreateConnectionRequest struct { *tchttp.BaseRequest // 连接器描述 - ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitempty" name:"ConnectionDescription"` + ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitnil" name:"ConnectionDescription"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 连接器名称 - ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"` + ConnectionName *string `json:"ConnectionName,omitnil" name:"ConnectionName"` // 描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 使能开关 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` } func (r *CreateConnectionRequest) ToJsonString() string { @@ -296,10 +306,10 @@ func (r *CreateConnectionRequest) FromJsonString(s string) error { // Predefined struct for user type CreateConnectionResponseParams struct { // 连接器ID - ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"` + ConnectionId *string `json:"ConnectionId,omitnil" name:"ConnectionId"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type CreateConnectionResponse struct { @@ -321,32 +331,32 @@ func (r *CreateConnectionResponse) FromJsonString(s string) error { // Predefined struct for user type CreateEventBusRequestParams struct { // 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"` + EventBusName *string `json:"EventBusName,omitnil" name:"EventBusName"` // 事件集描述,不限字符类型,200字符描述以内 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // EB存储时长 - SaveDays *int64 `json:"SaveDays,omitempty" name:"SaveDays"` + SaveDays *int64 `json:"SaveDays,omitnil" name:"SaveDays"` // EB是否开启存储 - EnableStore *bool `json:"EnableStore,omitempty" name:"EnableStore"` + EnableStore *bool `json:"EnableStore,omitnil" name:"EnableStore"` } type CreateEventBusRequest struct { *tchttp.BaseRequest // 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"` + EventBusName *string `json:"EventBusName,omitnil" name:"EventBusName"` // 事件集描述,不限字符类型,200字符描述以内 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // EB存储时长 - SaveDays *int64 `json:"SaveDays,omitempty" name:"SaveDays"` + SaveDays *int64 `json:"SaveDays,omitnil" name:"SaveDays"` // EB是否开启存储 - EnableStore *bool `json:"EnableStore,omitempty" name:"EnableStore"` + EnableStore *bool `json:"EnableStore,omitnil" name:"EnableStore"` } func (r *CreateEventBusRequest) ToJsonString() string { @@ -374,10 +384,10 @@ func (r *CreateEventBusRequest) FromJsonString(s string) error { // Predefined struct for user type CreateEventBusResponseParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type CreateEventBusResponse struct { @@ -399,38 +409,38 @@ func (r *CreateEventBusResponse) FromJsonString(s string) error { // Predefined struct for user type CreateRuleRequestParams struct { // 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084) - EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"` + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` // 事件集ID。 - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - RuleName *string `json:"RuleName,omitempty" name:"RuleName"` + RuleName *string `json:"RuleName,omitnil" name:"RuleName"` // 使能开关。 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 事件集描述,不限字符类型,200字符描述以内 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` } type CreateRuleRequest struct { *tchttp.BaseRequest // 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084) - EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"` + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` // 事件集ID。 - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - RuleName *string `json:"RuleName,omitempty" name:"RuleName"` + RuleName *string `json:"RuleName,omitnil" name:"RuleName"` // 使能开关。 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 事件集描述,不限字符类型,200字符描述以内 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` } func (r *CreateRuleRequest) ToJsonString() string { @@ -459,10 +469,10 @@ func (r *CreateRuleRequest) FromJsonString(s string) error { // Predefined struct for user type CreateRuleResponseParams struct { // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type CreateRuleResponse struct { @@ -484,32 +494,32 @@ func (r *CreateRuleResponse) FromJsonString(s string) error { // Predefined struct for user type CreateTargetRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 目标类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 目标描述 - TargetDescription *TargetDescription `json:"TargetDescription,omitempty" name:"TargetDescription"` + TargetDescription *TargetDescription `json:"TargetDescription,omitnil" name:"TargetDescription"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } type CreateTargetRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 目标类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 目标描述 - TargetDescription *TargetDescription `json:"TargetDescription,omitempty" name:"TargetDescription"` + TargetDescription *TargetDescription `json:"TargetDescription,omitnil" name:"TargetDescription"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } func (r *CreateTargetRequest) ToJsonString() string { @@ -537,10 +547,10 @@ func (r *CreateTargetRequest) FromJsonString(s string) error { // Predefined struct for user type CreateTargetResponseParams struct { // 目标ID - TargetId *string `json:"TargetId,omitempty" name:"TargetId"` + TargetId *string `json:"TargetId,omitnil" name:"TargetId"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type CreateTargetResponse struct { @@ -562,26 +572,26 @@ func (r *CreateTargetResponse) FromJsonString(s string) error { // Predefined struct for user type CreateTransformationRequestParams struct { // 事件总线 id - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则id - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 一个转换规则列表,当前仅限定一个 - Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"` + Transformations []*Transformation `json:"Transformations,omitnil" name:"Transformations"` } type CreateTransformationRequest struct { *tchttp.BaseRequest // 事件总线 id - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则id - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 一个转换规则列表,当前仅限定一个 - Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"` + Transformations []*Transformation `json:"Transformations,omitnil" name:"Transformations"` } func (r *CreateTransformationRequest) ToJsonString() string { @@ -608,10 +618,10 @@ func (r *CreateTransformationRequest) FromJsonString(s string) error { // Predefined struct for user type CreateTransformationResponseParams struct { // 生成的转换器id - TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"` + TransformationId *string `json:"TransformationId,omitnil" name:"TransformationId"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type CreateTransformationResponse struct { @@ -636,30 +646,30 @@ type DTSParams struct { type DeadLetterConfig struct { // 支持dlq、丢弃、忽略错误继续传递三种模式, 分别对应: DLQ,DROP,IGNORE_ERROR - DisposeMethod *string `json:"DisposeMethod,omitempty" name:"DisposeMethod"` + DisposeMethod *string `json:"DisposeMethod,omitnil" name:"DisposeMethod"` // 设置了DLQ方式后,此选项必填. 错误消息会被投递到对应的kafka topic中 // 注意:此字段可能返回 null,表示取不到有效值。 - CkafkaDeliveryParams *CkafkaDeliveryParams `json:"CkafkaDeliveryParams,omitempty" name:"CkafkaDeliveryParams"` + CkafkaDeliveryParams *CkafkaDeliveryParams `json:"CkafkaDeliveryParams,omitnil" name:"CkafkaDeliveryParams"` } // Predefined struct for user type DeleteConnectionRequestParams struct { // 连接器ID - ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"` + ConnectionId *string `json:"ConnectionId,omitnil" name:"ConnectionId"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } type DeleteConnectionRequest struct { *tchttp.BaseRequest // 连接器ID - ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"` + ConnectionId *string `json:"ConnectionId,omitnil" name:"ConnectionId"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } func (r *DeleteConnectionRequest) ToJsonString() string { @@ -685,7 +695,7 @@ func (r *DeleteConnectionRequest) FromJsonString(s string) error { // Predefined struct for user type DeleteConnectionResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type DeleteConnectionResponse struct { @@ -707,14 +717,14 @@ func (r *DeleteConnectionResponse) FromJsonString(s string) error { // Predefined struct for user type DeleteEventBusRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } type DeleteEventBusRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } func (r *DeleteEventBusRequest) ToJsonString() string { @@ -739,7 +749,7 @@ func (r *DeleteEventBusRequest) FromJsonString(s string) error { // Predefined struct for user type DeleteEventBusResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type DeleteEventBusResponse struct { @@ -761,20 +771,20 @@ func (r *DeleteEventBusResponse) FromJsonString(s string) error { // Predefined struct for user type DeleteRuleRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } type DeleteRuleRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } func (r *DeleteRuleRequest) ToJsonString() string { @@ -800,7 +810,7 @@ func (r *DeleteRuleRequest) FromJsonString(s string) error { // Predefined struct for user type DeleteRuleResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type DeleteRuleResponse struct { @@ -822,26 +832,26 @@ func (r *DeleteRuleResponse) FromJsonString(s string) error { // Predefined struct for user type DeleteTargetRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件目标ID - TargetId *string `json:"TargetId,omitempty" name:"TargetId"` + TargetId *string `json:"TargetId,omitnil" name:"TargetId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } type DeleteTargetRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件目标ID - TargetId *string `json:"TargetId,omitempty" name:"TargetId"` + TargetId *string `json:"TargetId,omitnil" name:"TargetId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } func (r *DeleteTargetRequest) ToJsonString() string { @@ -868,7 +878,7 @@ func (r *DeleteTargetRequest) FromJsonString(s string) error { // Predefined struct for user type DeleteTargetResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type DeleteTargetResponse struct { @@ -890,26 +900,26 @@ func (r *DeleteTargetResponse) FromJsonString(s string) error { // Predefined struct for user type DeleteTransformationRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 转换器id - TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"` + TransformationId *string `json:"TransformationId,omitnil" name:"TransformationId"` } type DeleteTransformationRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 转换器id - TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"` + TransformationId *string `json:"TransformationId,omitnil" name:"TransformationId"` } func (r *DeleteTransformationRequest) ToJsonString() string { @@ -936,7 +946,7 @@ func (r *DeleteTransformationRequest) FromJsonString(s string) error { // Predefined struct for user type DeleteTransformationResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type DeleteTransformationResponse struct { @@ -958,50 +968,50 @@ func (r *DeleteTransformationResponse) FromJsonString(s string) error { // Predefined struct for user type DescribeLogTagValueRequestParams struct { // 起始时间 - StartTime *int64 `json:"StartTime,omitempty" name:"StartTime"` + StartTime *int64 `json:"StartTime,omitnil" name:"StartTime"` // 结束时间 - EndTime *int64 `json:"EndTime,omitempty" name:"EndTime"` + EndTime *int64 `json:"EndTime,omitnil" name:"EndTime"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 聚合字段 - GroupField *string `json:"GroupField,omitempty" name:"GroupField"` + GroupField *string `json:"GroupField,omitnil" name:"GroupField"` // 页数 - Page *int64 `json:"Page,omitempty" name:"Page"` + Page *int64 `json:"Page,omitnil" name:"Page"` // 每页数据大小 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 筛选条件 - Filter []*LogFilter `json:"Filter,omitempty" name:"Filter"` + Filter []*LogFilter `json:"Filter,omitnil" name:"Filter"` } type DescribeLogTagValueRequest struct { *tchttp.BaseRequest // 起始时间 - StartTime *int64 `json:"StartTime,omitempty" name:"StartTime"` + StartTime *int64 `json:"StartTime,omitnil" name:"StartTime"` // 结束时间 - EndTime *int64 `json:"EndTime,omitempty" name:"EndTime"` + EndTime *int64 `json:"EndTime,omitnil" name:"EndTime"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 聚合字段 - GroupField *string `json:"GroupField,omitempty" name:"GroupField"` + GroupField *string `json:"GroupField,omitnil" name:"GroupField"` // 页数 - Page *int64 `json:"Page,omitempty" name:"Page"` + Page *int64 `json:"Page,omitnil" name:"Page"` // 每页数据大小 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 筛选条件 - Filter []*LogFilter `json:"Filter,omitempty" name:"Filter"` + Filter []*LogFilter `json:"Filter,omitnil" name:"Filter"` } func (r *DescribeLogTagValueRequest) ToJsonString() string { @@ -1033,10 +1043,10 @@ func (r *DescribeLogTagValueRequest) FromJsonString(s string) error { type DescribeLogTagValueResponseParams struct { // 索引检索维度值 // 注意:此字段可能返回 null,表示取不到有效值。 - Results []*string `json:"Results,omitempty" name:"Results"` + Results []*string `json:"Results,omitnil" name:"Results"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type DescribeLogTagValueResponse struct { @@ -1057,110 +1067,110 @@ func (r *DescribeLogTagValueResponse) FromJsonString(s string) error { type ESTargetParams struct { // 网络连接类型 - NetMode *string `json:"NetMode,omitempty" name:"NetMode"` + NetMode *string `json:"NetMode,omitnil" name:"NetMode"` // 索引前缀 - IndexPrefix *string `json:"IndexPrefix,omitempty" name:"IndexPrefix"` + IndexPrefix *string `json:"IndexPrefix,omitnil" name:"IndexPrefix"` // es日志轮换粒度 - RotationInterval *string `json:"RotationInterval,omitempty" name:"RotationInterval"` + RotationInterval *string `json:"RotationInterval,omitnil" name:"RotationInterval"` // DTS事件配置 - OutputMode *string `json:"OutputMode,omitempty" name:"OutputMode"` + OutputMode *string `json:"OutputMode,omitnil" name:"OutputMode"` // DTS索引配置 - IndexSuffixMode *string `json:"IndexSuffixMode,omitempty" name:"IndexSuffixMode"` + IndexSuffixMode *string `json:"IndexSuffixMode,omitnil" name:"IndexSuffixMode"` // es模版类型 - IndexTemplateType *string `json:"IndexTemplateType,omitempty" name:"IndexTemplateType"` + IndexTemplateType *string `json:"IndexTemplateType,omitnil" name:"IndexTemplateType"` } type EtlFilter struct { // 语法Rule规则保持一致 - Filter *string `json:"Filter,omitempty" name:"Filter"` + Filter *string `json:"Filter,omitnil" name:"Filter"` } type Event struct { // 事件源的信息,新产品上报必须符合EB的规范 - Source *string `json:"Source,omitempty" name:"Source"` + Source *string `json:"Source,omitnil" name:"Source"` // 事件数据,内容由创建事件的系统来控制,当前datacontenttype仅支持application/json;charset=utf-8,所以该字段是json字符串 - Data *string `json:"Data,omitempty" name:"Data"` + Data *string `json:"Data,omitnil" name:"Data"` // 事件类型,可自定义,选填。云服务默认写 COS:Created:PostObject,用“:”分割类型字段 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 事件来源详细描述,可自定义,选填。云服务默认为标准qcs资源表示语法:qcs::dts:ap-guangzhou:appid/uin:xxx - Subject *string `json:"Subject,omitempty" name:"Subject"` + Subject *string `json:"Subject,omitnil" name:"Subject"` // 事件发生的毫秒时间戳, // time.Now().UnixNano()/1e6 - Time *int64 `json:"Time,omitempty" name:"Time"` + Time *int64 `json:"Time,omitnil" name:"Time"` } type EventBus struct { // 更新时间 - ModTime *string `json:"ModTime,omitempty" name:"ModTime"` + ModTime *string `json:"ModTime,omitnil" name:"ModTime"` // 事件集描述,不限字符类型,200字符描述以内 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 创建时间 - AddTime *string `json:"AddTime,omitempty" name:"AddTime"` + AddTime *string `json:"AddTime,omitnil" name:"AddTime"` // 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"` + EventBusName *string `json:"EventBusName,omitnil" name:"EventBusName"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件集类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 计费模式 // 注意:此字段可能返回 null,表示取不到有效值。 - PayMode *string `json:"PayMode,omitempty" name:"PayMode"` + PayMode *string `json:"PayMode,omitnil" name:"PayMode"` // 连接器基础信息 // 注意:此字段可能返回 null,表示取不到有效值。 - ConnectionBriefs []*ConnectionBrief `json:"ConnectionBriefs,omitempty" name:"ConnectionBriefs"` + ConnectionBriefs []*ConnectionBrief `json:"ConnectionBriefs,omitnil" name:"ConnectionBriefs"` // 目标简要信息 // 注意:此字段可能返回 null,表示取不到有效值。 - TargetBriefs []*TargetBrief `json:"TargetBriefs,omitempty" name:"TargetBriefs"` + TargetBriefs []*TargetBrief `json:"TargetBriefs,omitnil" name:"TargetBriefs"` } type Extraction struct { // JsonPath, 不指定则使用默认值$. - ExtractionInputPath *string `json:"ExtractionInputPath,omitempty" name:"ExtractionInputPath"` + ExtractionInputPath *string `json:"ExtractionInputPath,omitnil" name:"ExtractionInputPath"` // 取值: TEXT/JSON - Format *string `json:"Format,omitempty" name:"Format"` + Format *string `json:"Format,omitnil" name:"Format"` // 仅在Text需要传递 // 注意:此字段可能返回 null,表示取不到有效值。 - TextParams *TextParams `json:"TextParams,omitempty" name:"TextParams"` + TextParams *TextParams `json:"TextParams,omitnil" name:"TextParams"` } type Filter struct { // 一个或者多个过滤值。 - Values []*string `json:"Values,omitempty" name:"Values"` + Values []*string `json:"Values,omitnil" name:"Values"` // 过滤键的名称。 - Name *string `json:"Name,omitempty" name:"Name"` + Name *string `json:"Name,omitnil" name:"Name"` } // Predefined struct for user type GetEventBusRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } type GetEventBusRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } func (r *GetEventBusRequest) ToJsonString() string { @@ -1185,50 +1195,50 @@ func (r *GetEventBusRequest) FromJsonString(s string) error { // Predefined struct for user type GetEventBusResponseParams struct { // 更新时间 - ModTime *string `json:"ModTime,omitempty" name:"ModTime"` + ModTime *string `json:"ModTime,omitnil" name:"ModTime"` // 事件集描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 日志主题ID - ClsTopicId *string `json:"ClsTopicId,omitempty" name:"ClsTopicId"` + ClsTopicId *string `json:"ClsTopicId,omitnil" name:"ClsTopicId"` // 创建时间 - AddTime *string `json:"AddTime,omitempty" name:"AddTime"` + AddTime *string `json:"AddTime,omitnil" name:"AddTime"` // 日志集ID - ClsLogsetId *string `json:"ClsLogsetId,omitempty" name:"ClsLogsetId"` + ClsLogsetId *string `json:"ClsLogsetId,omitnil" name:"ClsLogsetId"` // 事件集名称 - EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"` + EventBusName *string `json:"EventBusName,omitnil" name:"EventBusName"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // (已废弃)事件集类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 计费模式 - PayMode *string `json:"PayMode,omitempty" name:"PayMode"` + PayMode *string `json:"PayMode,omitnil" name:"PayMode"` // EB日志存储时长 // 注意:此字段可能返回 null,表示取不到有效值。 - SaveDays *int64 `json:"SaveDays,omitempty" name:"SaveDays"` + SaveDays *int64 `json:"SaveDays,omitnil" name:"SaveDays"` // EB日志主题ID // 注意:此字段可能返回 null,表示取不到有效值。 - LogTopicId *string `json:"LogTopicId,omitempty" name:"LogTopicId"` + LogTopicId *string `json:"LogTopicId,omitnil" name:"LogTopicId"` // 是否开启存储 // 注意:此字段可能返回 null,表示取不到有效值。 - EnableStore *bool `json:"EnableStore,omitempty" name:"EnableStore"` + EnableStore *bool `json:"EnableStore,omitnil" name:"EnableStore"` // 消息序列,是否有序 // 注意:此字段可能返回 null,表示取不到有效值。 - LinkMode *string `json:"LinkMode,omitempty" name:"LinkMode"` + LinkMode *string `json:"LinkMode,omitnil" name:"LinkMode"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type GetEventBusResponse struct { @@ -1247,23 +1257,80 @@ func (r *GetEventBusResponse) FromJsonString(s string) error { return json.Unmarshal([]byte(s), &r) } +// Predefined struct for user +type GetPlatformEventTemplateRequestParams struct { + // 平台产品事件类型 + EventType *string `json:"EventType,omitnil" name:"EventType"` +} + +type GetPlatformEventTemplateRequest struct { + *tchttp.BaseRequest + + // 平台产品事件类型 + EventType *string `json:"EventType,omitnil" name:"EventType"` +} + +func (r *GetPlatformEventTemplateRequest) 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 *GetPlatformEventTemplateRequest) FromJsonString(s string) error { + f := make(map[string]interface{}) + if err := json.Unmarshal([]byte(s), &f); err != nil { + return err + } + delete(f, "EventType") + if len(f) > 0 { + return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "GetPlatformEventTemplateRequest has unknown keys!", "") + } + return json.Unmarshal([]byte(s), &r) +} + +// Predefined struct for user +type GetPlatformEventTemplateResponseParams struct { + // 平台产品事件模板 + EventTemplate *string `json:"EventTemplate,omitnil" name:"EventTemplate"` + + // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` +} + +type GetPlatformEventTemplateResponse struct { + *tchttp.BaseResponse + Response *GetPlatformEventTemplateResponseParams `json:"Response"` +} + +func (r *GetPlatformEventTemplateResponse) 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 *GetPlatformEventTemplateResponse) FromJsonString(s string) error { + return json.Unmarshal([]byte(s), &r) +} + // Predefined struct for user type GetRuleRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } type GetRuleRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` } func (r *GetRuleRequest) ToJsonString() string { @@ -1289,34 +1356,34 @@ func (r *GetRuleRequest) FromJsonString(s string) error { // Predefined struct for user type GetRuleResponseParams struct { // 事件集id - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件规则id - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 事件规则名称 - RuleName *string `json:"RuleName,omitempty" name:"RuleName"` + RuleName *string `json:"RuleName,omitnil" name:"RuleName"` // 事件规则状态 - Status *string `json:"Status,omitempty" name:"Status"` + Status *string `json:"Status,omitnil" name:"Status"` // 使能开关 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 事件规则描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 事件模式 - EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"` + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` // 创建时间 - AddTime *string `json:"AddTime,omitempty" name:"AddTime"` + AddTime *string `json:"AddTime,omitnil" name:"AddTime"` // 更新时间 - ModTime *string `json:"ModTime,omitempty" name:"ModTime"` + ModTime *string `json:"ModTime,omitnil" name:"ModTime"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type GetRuleResponse struct { @@ -1338,26 +1405,26 @@ func (r *GetRuleResponse) FromJsonString(s string) error { // Predefined struct for user type GetTransformationRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 转换器id - TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"` + TransformationId *string `json:"TransformationId,omitnil" name:"TransformationId"` } type GetTransformationRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 转换器id - TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"` + TransformationId *string `json:"TransformationId,omitnil" name:"TransformationId"` } func (r *GetTransformationRequest) ToJsonString() string { @@ -1384,10 +1451,10 @@ func (r *GetTransformationRequest) FromJsonString(s string) error { // Predefined struct for user type GetTransformationResponseParams struct { // 转换规则列表 - Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"` + Transformations []*Transformation `json:"Transformations,omitnil" name:"Transformations"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type GetTransformationResponse struct { @@ -1409,38 +1476,38 @@ func (r *GetTransformationResponse) FromJsonString(s string) error { // Predefined struct for user type ListConnectionsRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 根据哪个字段进行返回结果排序,目前支持如下以下字段:AddTime, ModTime - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 以升序还是降序的方式返回结果,可选值 ASC 和 DESC - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` // 偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` } type ListConnectionsRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 根据哪个字段进行返回结果排序,目前支持如下以下字段:AddTime, ModTime - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 以升序还是降序的方式返回结果,可选值 ASC 和 DESC - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` // 偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` } func (r *ListConnectionsRequest) ToJsonString() string { @@ -1469,13 +1536,13 @@ func (r *ListConnectionsRequest) FromJsonString(s string) error { // Predefined struct for user type ListConnectionsResponseParams struct { // 连接器信息 - Connections []*Connection `json:"Connections,omitempty" name:"Connections"` + Connections []*Connection `json:"Connections,omitnil" name:"Connections"` // 连接器总数 - TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"` + TotalCount *int64 `json:"TotalCount,omitnil" name:"TotalCount"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type ListConnectionsResponse struct { @@ -1497,38 +1564,38 @@ func (r *ListConnectionsResponse) FromJsonString(s string) error { // Predefined struct for user type ListEventBusesRequestParams struct { // 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间) - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序) - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` // 过滤条件,详见下表:实例过滤条件表。每次请求的Filters的上限为10,Filter.Values的上限为5。 - Filters []*Filter `json:"Filters,omitempty" name:"Filters"` + Filters []*Filter `json:"Filters,omitnil" name:"Filters"` // 分页偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` } type ListEventBusesRequest struct { *tchttp.BaseRequest // 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间) - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序) - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` // 过滤条件,详见下表:实例过滤条件表。每次请求的Filters的上限为10,Filter.Values的上限为5。 - Filters []*Filter `json:"Filters,omitempty" name:"Filters"` + Filters []*Filter `json:"Filters,omitnil" name:"Filters"` // 分页偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` } func (r *ListEventBusesRequest) ToJsonString() string { @@ -1557,13 +1624,13 @@ func (r *ListEventBusesRequest) FromJsonString(s string) error { // Predefined struct for user type ListEventBusesResponseParams struct { // 事件集信息 - EventBuses []*EventBus `json:"EventBuses,omitempty" name:"EventBuses"` + EventBuses []*EventBus `json:"EventBuses,omitnil" name:"EventBuses"` // 事件集总数 - TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"` + TotalCount *int64 `json:"TotalCount,omitnil" name:"TotalCount"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type ListEventBusesResponse struct { @@ -1582,41 +1649,209 @@ func (r *ListEventBusesResponse) FromJsonString(s string) error { return json.Unmarshal([]byte(s), &r) } +// Predefined struct for user +type ListPlatformEventNamesRequestParams struct { + // 平台产品类型 + ProductType *string `json:"ProductType,omitnil" name:"ProductType"` +} + +type ListPlatformEventNamesRequest struct { + *tchttp.BaseRequest + + // 平台产品类型 + ProductType *string `json:"ProductType,omitnil" name:"ProductType"` +} + +func (r *ListPlatformEventNamesRequest) 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 *ListPlatformEventNamesRequest) FromJsonString(s string) error { + f := make(map[string]interface{}) + if err := json.Unmarshal([]byte(s), &f); err != nil { + return err + } + delete(f, "ProductType") + if len(f) > 0 { + return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "ListPlatformEventNamesRequest has unknown keys!", "") + } + return json.Unmarshal([]byte(s), &r) +} + +// Predefined struct for user +type ListPlatformEventNamesResponseParams struct { + // 平台产品列表 + EventNames []*PlatformEventDetail `json:"EventNames,omitnil" name:"EventNames"` + + // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` +} + +type ListPlatformEventNamesResponse struct { + *tchttp.BaseResponse + Response *ListPlatformEventNamesResponseParams `json:"Response"` +} + +func (r *ListPlatformEventNamesResponse) 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 *ListPlatformEventNamesResponse) FromJsonString(s string) error { + return json.Unmarshal([]byte(s), &r) +} + +// Predefined struct for user +type ListPlatformEventPatternsRequestParams struct { + // 平台产品类型 + ProductType *string `json:"ProductType,omitnil" name:"ProductType"` +} + +type ListPlatformEventPatternsRequest struct { + *tchttp.BaseRequest + + // 平台产品类型 + ProductType *string `json:"ProductType,omitnil" name:"ProductType"` +} + +func (r *ListPlatformEventPatternsRequest) 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 *ListPlatformEventPatternsRequest) FromJsonString(s string) error { + f := make(map[string]interface{}) + if err := json.Unmarshal([]byte(s), &f); err != nil { + return err + } + delete(f, "ProductType") + if len(f) > 0 { + return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "ListPlatformEventPatternsRequest has unknown keys!", "") + } + return json.Unmarshal([]byte(s), &r) +} + +// Predefined struct for user +type ListPlatformEventPatternsResponseParams struct { + // 平台产品事件匹配规则 + EventPatterns []*PlatformEventSummary `json:"EventPatterns,omitnil" name:"EventPatterns"` + + // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` +} + +type ListPlatformEventPatternsResponse struct { + *tchttp.BaseResponse + Response *ListPlatformEventPatternsResponseParams `json:"Response"` +} + +func (r *ListPlatformEventPatternsResponse) 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 *ListPlatformEventPatternsResponse) FromJsonString(s string) error { + return json.Unmarshal([]byte(s), &r) +} + +// Predefined struct for user +type ListPlatformProductsRequestParams struct { + +} + +type ListPlatformProductsRequest struct { + *tchttp.BaseRequest + +} + +func (r *ListPlatformProductsRequest) 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 *ListPlatformProductsRequest) FromJsonString(s string) error { + f := make(map[string]interface{}) + if err := json.Unmarshal([]byte(s), &f); err != nil { + return err + } + + if len(f) > 0 { + return tcerr.NewTencentCloudSDKError("ClientError.BuildRequestError", "ListPlatformProductsRequest has unknown keys!", "") + } + return json.Unmarshal([]byte(s), &r) +} + +// Predefined struct for user +type ListPlatformProductsResponseParams struct { + // 平台产品列表 + PlatformProducts []*PlatformProduct `json:"PlatformProducts,omitnil" name:"PlatformProducts"` + + // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` +} + +type ListPlatformProductsResponse struct { + *tchttp.BaseResponse + Response *ListPlatformProductsResponseParams `json:"Response"` +} + +func (r *ListPlatformProductsResponse) 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 *ListPlatformProductsResponse) FromJsonString(s string) error { + return json.Unmarshal([]byte(s), &r) +} + // Predefined struct for user type ListRulesRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间) - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 分页偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` // 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序) - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` } type ListRulesRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间) - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 分页偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` // 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序) - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` } func (r *ListRulesRequest) ToJsonString() string { @@ -1645,13 +1880,13 @@ func (r *ListRulesRequest) FromJsonString(s string) error { // Predefined struct for user type ListRulesResponseParams struct { // 事件规则信息 - Rules []*Rule `json:"Rules,omitempty" name:"Rules"` + Rules []*Rule `json:"Rules,omitnil" name:"Rules"` // 事件规则总数 - TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"` + TotalCount *int64 `json:"TotalCount,omitnil" name:"TotalCount"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type ListRulesResponse struct { @@ -1673,44 +1908,44 @@ func (r *ListRulesResponse) FromJsonString(s string) error { // Predefined struct for user type ListTargetsRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间) - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 分页偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` // 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序) - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` } type ListTargetsRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间) - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 返回数量,默认为20,最大值为100。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 分页偏移量,默认为0。 - Offset *int64 `json:"Offset,omitempty" name:"Offset"` + Offset *int64 `json:"Offset,omitnil" name:"Offset"` // 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序) - Order *string `json:"Order,omitempty" name:"Order"` + Order *string `json:"Order,omitnil" name:"Order"` } func (r *ListTargetsRequest) ToJsonString() string { @@ -1740,13 +1975,13 @@ func (r *ListTargetsRequest) FromJsonString(s string) error { // Predefined struct for user type ListTargetsResponseParams struct { // 目标总数 - TotalCount *int64 `json:"TotalCount,omitempty" name:"TotalCount"` + TotalCount *int64 `json:"TotalCount,omitnil" name:"TotalCount"` // 目标信息 - Targets []*Target `json:"Targets,omitempty" name:"Targets"` + Targets []*Target `json:"Targets,omitnil" name:"Targets"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type ListTargetsResponse struct { @@ -1767,60 +2002,88 @@ func (r *ListTargetsResponse) FromJsonString(s string) error { type LogFilter struct { // 过滤字段名称 - Key *string `json:"Key,omitempty" name:"Key"` + Key *string `json:"Key,omitnil" name:"Key"` // 运算符,全等 eq,不等 neq,相似 like,排除相似 not like, 小于 lt,小于且等于 lte,大于 gt,大于且等于 gte,在范围内 range,不在范围内 norange - Operator *string `json:"Operator,omitempty" name:"Operator"` + Operator *string `json:"Operator,omitnil" name:"Operator"` // 过滤值,范围运算需要同时输入两个值,以英文逗号分隔 - Value *string `json:"Value,omitempty" name:"Value"` + Value *string `json:"Value,omitnil" name:"Value"` // 该层级filters逻辑关系,取值 "AND" 或 "OR" - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // LogFilters数组 - Filters []*LogFilters `json:"Filters,omitempty" name:"Filters"` + Filters []*LogFilters `json:"Filters,omitnil" name:"Filters"` } type LogFilters struct { // 过滤字段名称 - Key *string `json:"Key,omitempty" name:"Key"` + Key *string `json:"Key,omitnil" name:"Key"` // 运算符, 全等 eq,不等 neq,相似 like,排除相似 not like, 小于 lt,小于且等于 lte,大于 gt,大于且等于 gte,在范围内 range,不在范围内 norange - Operator *string `json:"Operator,omitempty" name:"Operator"` + Operator *string `json:"Operator,omitnil" name:"Operator"` // 过滤值,范围运算需要同时输入两个值,以英文逗号分隔 - Value *string `json:"Value,omitempty" name:"Value"` + Value *string `json:"Value,omitnil" name:"Value"` } type OutputStructParam struct { // 对应输出json中的key - Key *string `json:"Key,omitempty" name:"Key"` + Key *string `json:"Key,omitnil" name:"Key"` // 可以填json-path也可以支持常量或者内置关键字date类型 - Value *string `json:"Value,omitempty" name:"Value"` + Value *string `json:"Value,omitnil" name:"Value"` // value的数据类型, 可选值: STRING, NUMBER,BOOLEAN,NULL,SYS_VARIABLE,JSONPATH - ValueType *string `json:"ValueType,omitempty" name:"ValueType"` + ValueType *string `json:"ValueType,omitnil" name:"ValueType"` +} + +type PlatformEventDetail struct { + // 事件名称 + // 注意:此字段可能返回 null,表示取不到有效值。 + EventName *string `json:"EventName,omitnil" name:"EventName"` + + // 事件类型 + // 注意:此字段可能返回 null,表示取不到有效值。 + EventType *string `json:"EventType,omitnil" name:"EventType"` +} + +type PlatformEventSummary struct { + // 平台事件名称 + // 注意:此字段可能返回 null,表示取不到有效值。 + EventName *string `json:"EventName,omitnil" name:"EventName"` + + // 平台事件匹配规则 + // 注意:此字段可能返回 null,表示取不到有效值。 + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` +} + +type PlatformProduct struct { + // 平台产品名称 + ProductName *string `json:"ProductName,omitnil" name:"ProductName"` + + // 平台产品类型 + ProductType *string `json:"ProductType,omitnil" name:"ProductType"` } // Predefined struct for user type PublishEventRequestParams struct { // 事件列表 - EventList []*Event `json:"EventList,omitempty" name:"EventList"` + EventList []*Event `json:"EventList,omitnil" name:"EventList"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } type PublishEventRequest struct { *tchttp.BaseRequest // 事件列表 - EventList []*Event `json:"EventList,omitempty" name:"EventList"` + EventList []*Event `json:"EventList,omitnil" name:"EventList"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } func (r *PublishEventRequest) ToJsonString() string { @@ -1846,7 +2109,7 @@ func (r *PublishEventRequest) FromJsonString(s string) error { // Predefined struct for user type PublishEventResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type PublishEventResponse struct { @@ -1868,20 +2131,20 @@ func (r *PublishEventResponse) FromJsonString(s string) error { // Predefined struct for user type PutEventsRequestParams struct { // 事件列表 - EventList []*Event `json:"EventList,omitempty" name:"EventList"` + EventList []*Event `json:"EventList,omitnil" name:"EventList"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } type PutEventsRequest struct { *tchttp.BaseRequest // 事件列表 - EventList []*Event `json:"EventList,omitempty" name:"EventList"` + EventList []*Event `json:"EventList,omitnil" name:"EventList"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` } func (r *PutEventsRequest) ToJsonString() string { @@ -1907,7 +2170,7 @@ func (r *PutEventsRequest) FromJsonString(s string) error { // Predefined struct for user type PutEventsResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type PutEventsResponse struct { @@ -1928,110 +2191,110 @@ func (r *PutEventsResponse) FromJsonString(s string) error { type RetryPolicy struct { // 重试间隔 单位:秒 - RetryInterval *uint64 `json:"RetryInterval,omitempty" name:"RetryInterval"` + RetryInterval *uint64 `json:"RetryInterval,omitnil" name:"RetryInterval"` // 最大重试次数 - MaxRetryAttempts *uint64 `json:"MaxRetryAttempts,omitempty" name:"MaxRetryAttempts"` + MaxRetryAttempts *uint64 `json:"MaxRetryAttempts,omitnil" name:"MaxRetryAttempts"` } type Rule struct { // 状态 - Status *string `json:"Status,omitempty" name:"Status"` + Status *string `json:"Status,omitnil" name:"Status"` // 修改时间 - ModTime *string `json:"ModTime,omitempty" name:"ModTime"` + ModTime *string `json:"ModTime,omitnil" name:"ModTime"` // 使能开关 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 创建时间 - AddTime *string `json:"AddTime,omitempty" name:"AddTime"` + AddTime *string `json:"AddTime,omitnil" name:"AddTime"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则名称 - RuleName *string `json:"RuleName,omitempty" name:"RuleName"` + RuleName *string `json:"RuleName,omitnil" name:"RuleName"` // Target 简要信息 // 注意:此字段可能返回 null,表示取不到有效值。 - Targets []*TargetBrief `json:"Targets,omitempty" name:"Targets"` + Targets []*TargetBrief `json:"Targets,omitnil" name:"Targets"` // rule设置的dlq规则. 可能为null // 注意:此字段可能返回 null,表示取不到有效值。 - DeadLetterConfig *DeadLetterConfig `json:"DeadLetterConfig,omitempty" name:"DeadLetterConfig"` + DeadLetterConfig *DeadLetterConfig `json:"DeadLetterConfig,omitnil" name:"DeadLetterConfig"` } type SCFParams struct { // 批量投递最长等待时间 - BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"` + BatchTimeout *int64 `json:"BatchTimeout,omitnil" name:"BatchTimeout"` // 批量投递最大事件条数 - BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"` + BatchEventCount *int64 `json:"BatchEventCount,omitnil" name:"BatchEventCount"` // 开启批量投递使能 - EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"` + EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil" name:"EnableBatchDelivery"` } // Predefined struct for user type SearchLogRequestParams struct { // 起始时间unix 毫秒时间戳 - StartTime *int64 `json:"StartTime,omitempty" name:"StartTime"` + StartTime *int64 `json:"StartTime,omitnil" name:"StartTime"` // 结束时间unix 毫秒时间戳 - EndTime *int64 `json:"EndTime,omitempty" name:"EndTime"` + EndTime *int64 `json:"EndTime,omitnil" name:"EndTime"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 页码 - Page *int64 `json:"Page,omitempty" name:"Page"` + Page *int64 `json:"Page,omitnil" name:"Page"` // 每页数据大小 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 筛选条件 - Filter []*LogFilter `json:"Filter,omitempty" name:"Filter"` + Filter []*LogFilter `json:"Filter,omitnil" name:"Filter"` // 排序数组 - OrderFields []*string `json:"OrderFields,omitempty" name:"OrderFields"` + OrderFields []*string `json:"OrderFields,omitnil" name:"OrderFields"` // 排序方式,asc 从旧到新,desc 从新到旧 - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` } type SearchLogRequest struct { *tchttp.BaseRequest // 起始时间unix 毫秒时间戳 - StartTime *int64 `json:"StartTime,omitempty" name:"StartTime"` + StartTime *int64 `json:"StartTime,omitnil" name:"StartTime"` // 结束时间unix 毫秒时间戳 - EndTime *int64 `json:"EndTime,omitempty" name:"EndTime"` + EndTime *int64 `json:"EndTime,omitnil" name:"EndTime"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 页码 - Page *int64 `json:"Page,omitempty" name:"Page"` + Page *int64 `json:"Page,omitnil" name:"Page"` // 每页数据大小 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 筛选条件 - Filter []*LogFilter `json:"Filter,omitempty" name:"Filter"` + Filter []*LogFilter `json:"Filter,omitnil" name:"Filter"` // 排序数组 - OrderFields []*string `json:"OrderFields,omitempty" name:"OrderFields"` + OrderFields []*string `json:"OrderFields,omitnil" name:"OrderFields"` // 排序方式,asc 从旧到新,desc 从新到旧 - OrderBy *string `json:"OrderBy,omitempty" name:"OrderBy"` + OrderBy *string `json:"OrderBy,omitnil" name:"OrderBy"` } func (r *SearchLogRequest) ToJsonString() string { @@ -2064,22 +2327,22 @@ func (r *SearchLogRequest) FromJsonString(s string) error { type SearchLogResponseParams struct { // 日志总数 // 注意:此字段可能返回 null,表示取不到有效值。 - Total *int64 `json:"Total,omitempty" name:"Total"` + Total *int64 `json:"Total,omitnil" name:"Total"` // 每页日志条数 // 注意:此字段可能返回 null,表示取不到有效值。 - Limit *int64 `json:"Limit,omitempty" name:"Limit"` + Limit *int64 `json:"Limit,omitnil" name:"Limit"` // 页码 // 注意:此字段可能返回 null,表示取不到有效值。 - Page *int64 `json:"Page,omitempty" name:"Page"` + Page *int64 `json:"Page,omitnil" name:"Page"` // 日志检索结果 // 注意:此字段可能返回 null,表示取不到有效值。 - Results []*SearchLogResult `json:"Results,omitempty" name:"Results"` + Results []*SearchLogResult `json:"Results,omitnil" name:"Results"` // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type SearchLogResponse struct { @@ -2101,152 +2364,152 @@ func (r *SearchLogResponse) FromJsonString(s string) error { type SearchLogResult struct { // 单条日志上报时间 // 注意:此字段可能返回 null,表示取不到有效值。 - Timestamp *string `json:"Timestamp,omitempty" name:"Timestamp"` + Timestamp *string `json:"Timestamp,omitnil" name:"Timestamp"` // 日志内容详情 // 注意:此字段可能返回 null,表示取不到有效值。 - Message *string `json:"Message,omitempty" name:"Message"` + Message *string `json:"Message,omitnil" name:"Message"` // 事件来源 // 注意:此字段可能返回 null,表示取不到有效值。 - Source *string `json:"Source,omitempty" name:"Source"` + Source *string `json:"Source,omitnil" name:"Source"` // 事件类型 // 注意:此字段可能返回 null,表示取不到有效值。 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 事件匹配规则 // 注意:此字段可能返回 null,表示取不到有效值。 - RuleIds *string `json:"RuleIds,omitempty" name:"RuleIds"` + RuleIds *string `json:"RuleIds,omitnil" name:"RuleIds"` // 实例ID // 注意:此字段可能返回 null,表示取不到有效值。 - Subject *string `json:"Subject,omitempty" name:"Subject"` + Subject *string `json:"Subject,omitnil" name:"Subject"` // 地域 // 注意:此字段可能返回 null,表示取不到有效值。 - Region *string `json:"Region,omitempty" name:"Region"` + Region *string `json:"Region,omitnil" name:"Region"` // 事件状态 // 注意:此字段可能返回 null,表示取不到有效值。 - Status *string `json:"Status,omitempty" name:"Status"` + Status *string `json:"Status,omitnil" name:"Status"` } type Target struct { // 目标类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 目标ID - TargetId *string `json:"TargetId,omitempty" name:"TargetId"` + TargetId *string `json:"TargetId,omitnil" name:"TargetId"` // 目标描述 - TargetDescription *TargetDescription `json:"TargetDescription,omitempty" name:"TargetDescription"` + TargetDescription *TargetDescription `json:"TargetDescription,omitnil" name:"TargetDescription"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 开启批量投递使能 // 注意:此字段可能返回 null,表示取不到有效值。 - EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"` + EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil" name:"EnableBatchDelivery"` // 批量投递最长等待时间 // 注意:此字段可能返回 null,表示取不到有效值。 - BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"` + BatchTimeout *int64 `json:"BatchTimeout,omitnil" name:"BatchTimeout"` // 批量投递最大事件条数 // 注意:此字段可能返回 null,表示取不到有效值。 - BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"` + BatchEventCount *int64 `json:"BatchEventCount,omitnil" name:"BatchEventCount"` } type TargetBrief struct { // 目标ID - TargetId *string `json:"TargetId,omitempty" name:"TargetId"` + TargetId *string `json:"TargetId,omitnil" name:"TargetId"` // 目标类型 - Type *string `json:"Type,omitempty" name:"Type"` + Type *string `json:"Type,omitnil" name:"Type"` } type TargetDescription struct { // QCS资源六段式,更多参考 [资源六段式](https://cloud.tencent.com/document/product/598/10606) - ResourceDescription *string `json:"ResourceDescription,omitempty" name:"ResourceDescription"` + ResourceDescription *string `json:"ResourceDescription,omitnil" name:"ResourceDescription"` // 云函数参数 - SCFParams *SCFParams `json:"SCFParams,omitempty" name:"SCFParams"` + SCFParams *SCFParams `json:"SCFParams,omitnil" name:"SCFParams"` // Ckafka参数 - CkafkaTargetParams *CkafkaTargetParams `json:"CkafkaTargetParams,omitempty" name:"CkafkaTargetParams"` + CkafkaTargetParams *CkafkaTargetParams `json:"CkafkaTargetParams,omitnil" name:"CkafkaTargetParams"` // ElasticSearch参数 - ESTargetParams *ESTargetParams `json:"ESTargetParams,omitempty" name:"ESTargetParams"` + ESTargetParams *ESTargetParams `json:"ESTargetParams,omitnil" name:"ESTargetParams"` } type TextParams struct { // 逗号、| 、制表符、空格、换行符、%、#,限制长度为 1。 // 注意:此字段可能返回 null,表示取不到有效值。 - Separator *string `json:"Separator,omitempty" name:"Separator"` + Separator *string `json:"Separator,omitnil" name:"Separator"` // 填写正则表达式:长度128 // 注意:此字段可能返回 null,表示取不到有效值。 - Regex *string `json:"Regex,omitempty" name:"Regex"` + Regex *string `json:"Regex,omitnil" name:"Regex"` } type Transform struct { // 描述如何数据转换 - OutputStructs []*OutputStructParam `json:"OutputStructs,omitempty" name:"OutputStructs"` + OutputStructs []*OutputStructParam `json:"OutputStructs,omitnil" name:"OutputStructs"` } type Transformation struct { // 描述如何提取数据 // 注意:此字段可能返回 null,表示取不到有效值。 - Extraction *Extraction `json:"Extraction,omitempty" name:"Extraction"` + Extraction *Extraction `json:"Extraction,omitnil" name:"Extraction"` // 描述如何过滤数据 // 注意:此字段可能返回 null,表示取不到有效值。 - EtlFilter *EtlFilter `json:"EtlFilter,omitempty" name:"EtlFilter"` + EtlFilter *EtlFilter `json:"EtlFilter,omitnil" name:"EtlFilter"` // 描述如何数据转换 // 注意:此字段可能返回 null,表示取不到有效值。 - Transform *Transform `json:"Transform,omitempty" name:"Transform"` + Transform *Transform `json:"Transform,omitnil" name:"Transform"` } // Predefined struct for user type UpdateConnectionRequestParams struct { // 连接器ID - ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"` + ConnectionId *string `json:"ConnectionId,omitnil" name:"ConnectionId"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 使能开关 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 连接器名称 - ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"` + ConnectionName *string `json:"ConnectionName,omitnil" name:"ConnectionName"` } type UpdateConnectionRequest struct { *tchttp.BaseRequest // 连接器ID - ConnectionId *string `json:"ConnectionId,omitempty" name:"ConnectionId"` + ConnectionId *string `json:"ConnectionId,omitnil" name:"ConnectionId"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 使能开关 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 描述 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 连接器名称 - ConnectionName *string `json:"ConnectionName,omitempty" name:"ConnectionName"` + ConnectionName *string `json:"ConnectionName,omitnil" name:"ConnectionName"` } func (r *UpdateConnectionRequest) ToJsonString() string { @@ -2275,7 +2538,7 @@ func (r *UpdateConnectionRequest) FromJsonString(s string) error { // Predefined struct for user type UpdateConnectionResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type UpdateConnectionResponse struct { @@ -2297,44 +2560,44 @@ func (r *UpdateConnectionResponse) FromJsonString(s string) error { // Predefined struct for user type UpdateEventBusRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件集描述,不限字符类型,200字符描述以内 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"` + EventBusName *string `json:"EventBusName,omitnil" name:"EventBusName"` // EB日志存储时长 - SaveDays *int64 `json:"SaveDays,omitempty" name:"SaveDays"` + SaveDays *int64 `json:"SaveDays,omitnil" name:"SaveDays"` // EB日志主题ID - LogTopicId *string `json:"LogTopicId,omitempty" name:"LogTopicId"` + LogTopicId *string `json:"LogTopicId,omitnil" name:"LogTopicId"` // 是否开启存储 - EnableStore *bool `json:"EnableStore,omitempty" name:"EnableStore"` + EnableStore *bool `json:"EnableStore,omitnil" name:"EnableStore"` } type UpdateEventBusRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件集描述,不限字符类型,200字符描述以内 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - EventBusName *string `json:"EventBusName,omitempty" name:"EventBusName"` + EventBusName *string `json:"EventBusName,omitnil" name:"EventBusName"` // EB日志存储时长 - SaveDays *int64 `json:"SaveDays,omitempty" name:"SaveDays"` + SaveDays *int64 `json:"SaveDays,omitnil" name:"SaveDays"` // EB日志主题ID - LogTopicId *string `json:"LogTopicId,omitempty" name:"LogTopicId"` + LogTopicId *string `json:"LogTopicId,omitnil" name:"LogTopicId"` // 是否开启存储 - EnableStore *bool `json:"EnableStore,omitempty" name:"EnableStore"` + EnableStore *bool `json:"EnableStore,omitnil" name:"EnableStore"` } func (r *UpdateEventBusRequest) ToJsonString() string { @@ -2364,7 +2627,7 @@ func (r *UpdateEventBusRequest) FromJsonString(s string) error { // Predefined struct for user type UpdateEventBusResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type UpdateEventBusResponse struct { @@ -2386,44 +2649,44 @@ func (r *UpdateEventBusResponse) FromJsonString(s string) error { // Predefined struct for user type UpdateRuleRequestParams struct { // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 使能开关。 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 规则描述,不限字符类型,200字符描述以内。 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084) - EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"` + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` // 事件规则名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - RuleName *string `json:"RuleName,omitempty" name:"RuleName"` + RuleName *string `json:"RuleName,omitnil" name:"RuleName"` } type UpdateRuleRequest struct { *tchttp.BaseRequest // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 使能开关。 - Enable *bool `json:"Enable,omitempty" name:"Enable"` + Enable *bool `json:"Enable,omitnil" name:"Enable"` // 规则描述,不限字符类型,200字符描述以内。 - Description *string `json:"Description,omitempty" name:"Description"` + Description *string `json:"Description,omitnil" name:"Description"` // 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084) - EventPattern *string `json:"EventPattern,omitempty" name:"EventPattern"` + EventPattern *string `json:"EventPattern,omitnil" name:"EventPattern"` // 事件规则名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符 - RuleName *string `json:"RuleName,omitempty" name:"RuleName"` + RuleName *string `json:"RuleName,omitnil" name:"RuleName"` } func (r *UpdateRuleRequest) ToJsonString() string { @@ -2453,7 +2716,7 @@ func (r *UpdateRuleRequest) FromJsonString(s string) error { // Predefined struct for user type UpdateRuleResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type UpdateRuleResponse struct { @@ -2475,44 +2738,44 @@ func (r *UpdateRuleResponse) FromJsonString(s string) error { // Predefined struct for user type UpdateTargetRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 事件目标ID - TargetId *string `json:"TargetId,omitempty" name:"TargetId"` + TargetId *string `json:"TargetId,omitnil" name:"TargetId"` // 开启批量投递使能 - EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"` + EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil" name:"EnableBatchDelivery"` // 批量投递最长等待时间 - BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"` + BatchTimeout *int64 `json:"BatchTimeout,omitnil" name:"BatchTimeout"` // 批量投递最大事件条数 - BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"` + BatchEventCount *int64 `json:"BatchEventCount,omitnil" name:"BatchEventCount"` } type UpdateTargetRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 事件规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 事件目标ID - TargetId *string `json:"TargetId,omitempty" name:"TargetId"` + TargetId *string `json:"TargetId,omitnil" name:"TargetId"` // 开启批量投递使能 - EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitempty" name:"EnableBatchDelivery"` + EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil" name:"EnableBatchDelivery"` // 批量投递最长等待时间 - BatchTimeout *int64 `json:"BatchTimeout,omitempty" name:"BatchTimeout"` + BatchTimeout *int64 `json:"BatchTimeout,omitnil" name:"BatchTimeout"` // 批量投递最大事件条数 - BatchEventCount *int64 `json:"BatchEventCount,omitempty" name:"BatchEventCount"` + BatchEventCount *int64 `json:"BatchEventCount,omitnil" name:"BatchEventCount"` } func (r *UpdateTargetRequest) ToJsonString() string { @@ -2542,7 +2805,7 @@ func (r *UpdateTargetRequest) FromJsonString(s string) error { // Predefined struct for user type UpdateTargetResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type UpdateTargetResponse struct { @@ -2564,32 +2827,32 @@ func (r *UpdateTargetResponse) FromJsonString(s string) error { // Predefined struct for user type UpdateTransformationRequestParams struct { // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 转换器id - TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"` + TransformationId *string `json:"TransformationId,omitnil" name:"TransformationId"` // 一个转换规则列表,当前仅限定一个 - Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"` + Transformations []*Transformation `json:"Transformations,omitnil" name:"Transformations"` } type UpdateTransformationRequest struct { *tchttp.BaseRequest // 事件集ID - EventBusId *string `json:"EventBusId,omitempty" name:"EventBusId"` + EventBusId *string `json:"EventBusId,omitnil" name:"EventBusId"` // 规则ID - RuleId *string `json:"RuleId,omitempty" name:"RuleId"` + RuleId *string `json:"RuleId,omitnil" name:"RuleId"` // 转换器id - TransformationId *string `json:"TransformationId,omitempty" name:"TransformationId"` + TransformationId *string `json:"TransformationId,omitnil" name:"TransformationId"` // 一个转换规则列表,当前仅限定一个 - Transformations []*Transformation `json:"Transformations,omitempty" name:"Transformations"` + Transformations []*Transformation `json:"Transformations,omitnil" name:"Transformations"` } func (r *UpdateTransformationRequest) ToJsonString() string { @@ -2617,7 +2880,7 @@ func (r *UpdateTransformationRequest) FromJsonString(s string) error { // Predefined struct for user type UpdateTransformationResponseParams struct { // 唯一请求 ID,每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 - RequestId *string `json:"RequestId,omitempty" name:"RequestId"` + RequestId *string `json:"RequestId,omitnil" name:"RequestId"` } type UpdateTransformationResponse struct { diff --git a/vendor/modules.txt b/vendor/modules.txt index a32e7e7783..96908e40ce 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -1138,7 +1138,7 @@ github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/domain/v20180808 # github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dts v1.0.628 ## explicit; go 1.14 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/dts/v20211206 -# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.715 +# github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb v1.0.760 ## explicit; go 1.14 github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/eb/v20210416 # github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/emr v1.0.725 diff --git a/website/docs/d/eb_platform_event_names.html.markdown b/website/docs/d/eb_platform_event_names.html.markdown new file mode 100644 index 0000000000..fe687378b6 --- /dev/null +++ b/website/docs/d/eb_platform_event_names.html.markdown @@ -0,0 +1,37 @@ +--- +subcategory: "EventBridge(EB)" +layout: "tencentcloud" +page_title: "TencentCloud: tencentcloud_eb_platform_event_names" +sidebar_current: "docs-tencentcloud-datasource-eb_platform_event_names" +description: |- + Use this data source to query detailed information of eb platform_event_names +--- + +# tencentcloud_eb_platform_event_names + +Use this data source to query detailed information of eb platform_event_names + +## Example Usage + +```hcl +data "tencentcloud_eb_platform_event_names" "platform_event_names" { + product_type = "" +} +``` + +## Argument Reference + +The following arguments are supported: + +* `product_type` - (Required, String) Platform product event type. +* `result_output_file` - (Optional, String) Used to save results. + +## Attributes Reference + +In addition to all arguments above, the following attributes are exported: + +* `event_names` - Platform product list. + * `event_name` - Event name.Note: This field may return null, indicating that no valid value can be obtained. + * `event_type` - Event type.Note: This field may return null, indicating that no valid value can be obtained. + + diff --git a/website/docs/d/eb_platform_event_patterns.html.markdown b/website/docs/d/eb_platform_event_patterns.html.markdown new file mode 100644 index 0000000000..eb3b682f7a --- /dev/null +++ b/website/docs/d/eb_platform_event_patterns.html.markdown @@ -0,0 +1,37 @@ +--- +subcategory: "EventBridge(EB)" +layout: "tencentcloud" +page_title: "TencentCloud: tencentcloud_eb_platform_event_patterns" +sidebar_current: "docs-tencentcloud-datasource-eb_platform_event_patterns" +description: |- + Use this data source to query detailed information of eb platform_event_patterns +--- + +# tencentcloud_eb_platform_event_patterns + +Use this data source to query detailed information of eb platform_event_patterns + +## Example Usage + +```hcl +data "tencentcloud_eb_platform_event_patterns" "platform_event_patterns" { + product_type = "" +} +``` + +## Argument Reference + +The following arguments are supported: + +* `product_type` - (Required, String) Platform product type. +* `result_output_file` - (Optional, String) Used to save results. + +## Attributes Reference + +In addition to all arguments above, the following attributes are exported: + +* `event_patterns` - Platform product event matching rules. + * `event_name` - Platform event name.Note: This field may return null, indicating that no valid value can be obtained. + * `event_pattern` - Platform event matching rules.Note: This field may return null, indicating that no valid value can be obtained. + + diff --git a/website/docs/d/eb_platform_products.html.markdown b/website/docs/d/eb_platform_products.html.markdown new file mode 100644 index 0000000000..f109052052 --- /dev/null +++ b/website/docs/d/eb_platform_products.html.markdown @@ -0,0 +1,35 @@ +--- +subcategory: "EventBridge(EB)" +layout: "tencentcloud" +page_title: "TencentCloud: tencentcloud_eb_platform_products" +sidebar_current: "docs-tencentcloud-datasource-eb_platform_products" +description: |- + Use this data source to query detailed information of eb platform_products +--- + +# tencentcloud_eb_platform_products + +Use this data source to query detailed information of eb platform_products + +## Example Usage + +```hcl +data "tencentcloud_eb_platform_products" "platform_products" { +} +``` + +## Argument Reference + +The following arguments are supported: + +* `result_output_file` - (Optional, String) Used to save results. + +## Attributes Reference + +In addition to all arguments above, the following attributes are exported: + +* `platform_products` - Platform product list. + * `product_name` - Platform product name. + * `product_type` - Platform product type. + + diff --git a/website/tencentcloud.erb b/website/tencentcloud.erb index 8d8d70cf7c..7f404f8db7 100644 --- a/website/tencentcloud.erb +++ b/website/tencentcloud.erb @@ -1856,6 +1856,15 @@