代码拉取完成，页面将自动刷新
// Copyright (c) 2017-2025 Tencent. All Rights Reserved.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package v20210416
import (
"context"
"errors"
"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
tchttp "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/http"
"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile"
)
const APIVersion = "2021-04-16"
type Client struct {
common.Client
}
// Deprecated
func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error) {
cpf := profile.NewClientProfile()
client = &Client{}
client.Init(region).WithSecretId(secretId, secretKey).WithProfile(cpf)
return
}
func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error) {
client = &Client{}
client.Init(region).
WithCredential(credential).
WithProfile(clientProfile)
return
}
func NewCheckRuleRequest() (request *CheckRuleRequest) {
request = &CheckRuleRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "CheckRule")
return
}
func NewCheckRuleResponse() (response *CheckRuleResponse) {
response = &CheckRuleResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// CheckRule
// 检验规则
//
// 可能返回的错误码:
// FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INTERNALERROR_UNKNOWNINTERNALERROR = "InternalError.UnknownInternalError"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
// INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"
func (c *Client) CheckRule(request *CheckRuleRequest) (response *CheckRuleResponse, err error) {
return c.CheckRuleWithContext(context.Background(), request)
}
// CheckRule
// 检验规则
//
// 可能返回的错误码:
// FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INTERNALERROR_UNKNOWNINTERNALERROR = "InternalError.UnknownInternalError"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
// INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"
func (c *Client) CheckRuleWithContext(ctx context.Context, request *CheckRuleRequest) (response *CheckRuleResponse, err error) {
if request == nil {
request = NewCheckRuleRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "CheckRule")
if c.GetCredential() == nil {
return nil, errors.New("CheckRule require credential")
}
request.SetContext(ctx)
response = NewCheckRuleResponse()
err = c.Send(request, response)
return
}
func NewCheckTransformationRequest() (request *CheckTransformationRequest) {
request = &CheckTransformationRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "CheckTransformation")
return
}
func NewCheckTransformationResponse() (response *CheckTransformationResponse) {
response = &CheckTransformationResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// CheckTransformation
// 用于在ETL配置页面, 测试规则和数据.
//
// 可能返回的错误码:
// FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INTERNALERROR_UNKNOWNINTERNALERROR = "InternalError.UnknownInternalError"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
// INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"
func (c *Client) CheckTransformation(request *CheckTransformationRequest) (response *CheckTransformationResponse, err error) {
return c.CheckTransformationWithContext(context.Background(), request)
}
// CheckTransformation
// 用于在ETL配置页面, 测试规则和数据.
//
// 可能返回的错误码:
// FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INTERNALERROR_UNKNOWNINTERNALERROR = "InternalError.UnknownInternalError"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"
// INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"
func (c *Client) CheckTransformationWithContext(ctx context.Context, request *CheckTransformationRequest) (response *CheckTransformationResponse, err error) {
if request == nil {
request = NewCheckTransformationRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "CheckTransformation")
if c.GetCredential() == nil {
return nil, errors.New("CheckTransformation require credential")
}
request.SetContext(ctx)
response = NewCheckTransformationResponse()
err = c.Send(request, response)
return
}
func NewCreateConnectionRequest() (request *CreateConnectionRequest) {
request = &CreateConnectionRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "CreateConnection")
return
}
func NewCreateConnectionResponse() (response *CreateConnectionResponse) {
response = &CreateConnectionResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// CreateConnection
// 创建事件连接器
//
// 可能返回的错误码:
// FAILEDOPERATION = "FailedOperation"
// FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
// INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
// INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
// INVALIDPARAMETERVALUE_CONNECTIONNAME = "InvalidParameterValue.ConnectionName"
// INVALIDPARAMETERVALUE_DTSPARAMS = "InvalidParameterValue.DTSParams"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
// INVALIDPARAMETERVALUE_INVALIDAPIREQUESTCONFIG = "InvalidParameterValue.InvalidApiRequestConfig"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_CONNECTION = "LimitExceeded.Connection"
// LIMITEXCEEDED_ROUTEOVERLIMIT = "LimitExceeded.RouteOverLimit"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
// RESOURCEUNAVAILABLE_CONNECTION = "ResourceUnavailable.Connection"
// UNSUPPORTEDOPERATION = "UnsupportedOperation"
// UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"
// UNSUPPORTEDOPERATION_INVALIDENDPOINTTYPE = "UnsupportedOperation.InvalidEndpointType"
func (c *Client) CreateConnection(request *CreateConnectionRequest) (response *CreateConnectionResponse, err error) {
return c.CreateConnectionWithContext(context.Background(), request)
}
// CreateConnection
// 创建事件连接器
//
// 可能返回的错误码:
// FAILEDOPERATION = "FailedOperation"
// FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
// INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
// INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
// INVALIDPARAMETERVALUE_CONNECTIONNAME = "InvalidParameterValue.ConnectionName"
// INVALIDPARAMETERVALUE_DTSPARAMS = "InvalidParameterValue.DTSParams"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
// INVALIDPARAMETERVALUE_INVALIDAPIREQUESTCONFIG = "InvalidParameterValue.InvalidApiRequestConfig"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_CONNECTION = "LimitExceeded.Connection"
// LIMITEXCEEDED_ROUTEOVERLIMIT = "LimitExceeded.RouteOverLimit"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
// RESOURCEUNAVAILABLE_CONNECTION = "ResourceUnavailable.Connection"
// UNSUPPORTEDOPERATION = "UnsupportedOperation"
// UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"
// UNSUPPORTEDOPERATION_INVALIDENDPOINTTYPE = "UnsupportedOperation.InvalidEndpointType"
func (c *Client) CreateConnectionWithContext(ctx context.Context, request *CreateConnectionRequest) (response *CreateConnectionResponse, err error) {
if request == nil {
request = NewCreateConnectionRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "CreateConnection")
if c.GetCredential() == nil {
return nil, errors.New("CreateConnection require credential")
}
request.SetContext(ctx)
response = NewCreateConnectionResponse()
err = c.Send(request, response)
return
}
func NewCreateEventBusRequest() (request *CreateEventBusRequest) {
request = &CreateEventBusRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "CreateEventBus")
return
}
func NewCreateEventBusResponse() (response *CreateEventBusResponse) {
response = &CreateEventBusResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// CreateEventBus
// 用于创建事件集
//
// 可能返回的错误码:
// FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
// FAILEDOPERATION_TAGRESOURCE = "FailedOperation.TagResource"
// FAILEDOPERATION_TAGRESOURCEALLOCATEQUOTAS = "FailedOperation.TagResourceAllocateQuotas"
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
// INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
// INVALIDPARAMETERVALUE_LINKMODE = "InvalidParameterValue.LinkMode"
// INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"
// LIMITEXCEEDED_INSUFFICIENTBALANCE = "LimitExceeded.InsufficientBalance"
// OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"
// RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
// RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"
func (c *Client) CreateEventBus(request *CreateEventBusRequest) (response *CreateEventBusResponse, err error) {
return c.CreateEventBusWithContext(context.Background(), request)
}
// CreateEventBus
// 用于创建事件集
//
// 可能返回的错误码:
// FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
// FAILEDOPERATION_TAGRESOURCE = "FailedOperation.TagResource"
// FAILEDOPERATION_TAGRESOURCEALLOCATEQUOTAS = "FailedOperation.TagResourceAllocateQuotas"
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
// INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
// INVALIDPARAMETERVALUE_LINKMODE = "InvalidParameterValue.LinkMode"
// INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"
// LIMITEXCEEDED_INSUFFICIENTBALANCE = "LimitExceeded.InsufficientBalance"
// OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"
// RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
// RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"
func (c *Client) CreateEventBusWithContext(ctx context.Context, request *CreateEventBusRequest) (response *CreateEventBusResponse, err error) {
if request == nil {
request = NewCreateEventBusRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "CreateEventBus")
if c.GetCredential() == nil {
return nil, errors.New("CreateEventBus require credential")
}
request.SetContext(ctx)
response = NewCreateEventBusResponse()
err = c.Send(request, response)
return
}
func NewCreateRuleRequest() (request *CreateRuleRequest) {
request = &CreateRuleRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "CreateRule")
return
}
func NewCreateRuleResponse() (response *CreateRuleResponse) {
response = &CreateRuleResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// CreateRule
// 创建事件规则
//
// 可能返回的错误码:
// FAILEDOPERATION_TAGRESOURCE = "FailedOperation.TagResource"
// FAILEDOPERATION_TAGRESOURCEALLOCATEQUOTAS = "FailedOperation.TagResourceAllocateQuotas"
// INVALIDPARAMETERVALUE_DEADLETTERCONFIG = "InvalidParameterValue.DeadLetterConfig"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
// INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
// INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_RULE = "LimitExceeded.Rule"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
func (c *Client) CreateRule(request *CreateRuleRequest) (response *CreateRuleResponse, err error) {
return c.CreateRuleWithContext(context.Background(), request)
}
// CreateRule
// 创建事件规则
//
// 可能返回的错误码:
// FAILEDOPERATION_TAGRESOURCE = "FailedOperation.TagResource"
// FAILEDOPERATION_TAGRESOURCEALLOCATEQUOTAS = "FailedOperation.TagResourceAllocateQuotas"
// INVALIDPARAMETERVALUE_DEADLETTERCONFIG = "InvalidParameterValue.DeadLetterConfig"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
// INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
// INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_RULE = "LimitExceeded.Rule"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
func (c *Client) CreateRuleWithContext(ctx context.Context, request *CreateRuleRequest) (response *CreateRuleResponse, err error) {
if request == nil {
request = NewCreateRuleRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "CreateRule")
if c.GetCredential() == nil {
return nil, errors.New("CreateRule require credential")
}
request.SetContext(ctx)
response = NewCreateRuleResponse()
err = c.Send(request, response)
return
}
func NewCreateTargetRequest() (request *CreateTargetRequest) {
request = &CreateTargetRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "CreateTarget")
return
}
func NewCreateTargetResponse() (response *CreateTargetResponse) {
response = &CreateTargetResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// CreateTarget
// 创建事件目标
//
// 可能返回的错误码:
// FAILEDOPERATION = "FailedOperation"
// FAILEDOPERATION_ADDPRIVATELINK = "FailedOperation.AddPrivateLink"
// FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"
// FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"
// 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"
// INVALIDPARAMETERVALUE_CKAFKATARGETPARAMS = "InvalidParameterValue.CKafkaTargetParams"
// INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
// INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
// INVALIDPARAMETERVALUE_ELASTICSEARCHTARGETPARAMS = "InvalidParameterValue.ElasticSearchTargetParams"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
// INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"
// INVALIDPARAMETERVALUE_QUALIFIER = "InvalidParameterValue.Qualifier"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TARGETDESCRIPTION = "InvalidParameterValue.TargetDescription"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_CLUSTERPRIVATELINKEXCEEDED = "LimitExceeded.ClusterPrivateLinkExceeded"
// LIMITEXCEEDED_LOGSET = "LimitExceeded.Logset"
// LIMITEXCEEDED_TARGET = "LimitExceeded.Target"
// LIMITEXCEEDED_TRIGGER = "LimitExceeded.Trigger"
// LIMITEXCEEDED_USERPRIVATELINKEXCEEDED = "LimitExceeded.UserPrivateLinkExceeded"
// OPERATIONDENIED_ACCOUNTNOTEXISTS = "OperationDenied.AccountNotExists"
// OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
// OPERATIONDENIED_ESVERSIONUNSUPPORTED = "OperationDenied.ESVersionUnsupported"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_FUNCTION = "ResourceNotFound.Function"
// RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"
// RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
// RESOURCENOTFOUND_VERSION = "ResourceNotFound.Version"
// RESOURCEUNAVAILABLE_ESUNHEALTH = "ResourceUnavailable.ESUnhealth"
// RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"
func (c *Client) CreateTarget(request *CreateTargetRequest) (response *CreateTargetResponse, err error) {
return c.CreateTargetWithContext(context.Background(), request)
}
// CreateTarget
// 创建事件目标
//
// 可能返回的错误码:
// FAILEDOPERATION = "FailedOperation"
// FAILEDOPERATION_ADDPRIVATELINK = "FailedOperation.AddPrivateLink"
// FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"
// FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"
// 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"
// INVALIDPARAMETERVALUE_CKAFKATARGETPARAMS = "InvalidParameterValue.CKafkaTargetParams"
// INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
// INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
// INVALIDPARAMETERVALUE_ELASTICSEARCHTARGETPARAMS = "InvalidParameterValue.ElasticSearchTargetParams"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
// INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"
// INVALIDPARAMETERVALUE_QUALIFIER = "InvalidParameterValue.Qualifier"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TARGETDESCRIPTION = "InvalidParameterValue.TargetDescription"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// LIMITEXCEEDED_CLUSTERPRIVATELINKEXCEEDED = "LimitExceeded.ClusterPrivateLinkExceeded"
// LIMITEXCEEDED_LOGSET = "LimitExceeded.Logset"
// LIMITEXCEEDED_TARGET = "LimitExceeded.Target"
// LIMITEXCEEDED_TRIGGER = "LimitExceeded.Trigger"
// LIMITEXCEEDED_USERPRIVATELINKEXCEEDED = "LimitExceeded.UserPrivateLinkExceeded"
// OPERATIONDENIED_ACCOUNTNOTEXISTS = "OperationDenied.AccountNotExists"
// OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
// OPERATIONDENIED_ESVERSIONUNSUPPORTED = "OperationDenied.ESVersionUnsupported"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_FUNCTION = "ResourceNotFound.Function"
// RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"
// RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
// RESOURCENOTFOUND_VERSION = "ResourceNotFound.Version"
// RESOURCEUNAVAILABLE_ESUNHEALTH = "ResourceUnavailable.ESUnhealth"
// RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"
func (c *Client) CreateTargetWithContext(ctx context.Context, request *CreateTargetRequest) (response *CreateTargetResponse, err error) {
if request == nil {
request = NewCreateTargetRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "CreateTarget")
if c.GetCredential() == nil {
return nil, errors.New("CreateTarget require credential")
}
request.SetContext(ctx)
response = NewCreateTargetResponse()
err = c.Send(request, response)
return
}
func NewCreateTransformationRequest() (request *CreateTransformationRequest) {
request = &CreateTransformationRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "CreateTransformation")
return
}
func NewCreateTransformationResponse() (response *CreateTransformationResponse) {
response = &CreateTransformationResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// CreateTransformation
// 用于创建转换器
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
func (c *Client) CreateTransformation(request *CreateTransformationRequest) (response *CreateTransformationResponse, err error) {
return c.CreateTransformationWithContext(context.Background(), request)
}
// CreateTransformation
// 用于创建转换器
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
func (c *Client) CreateTransformationWithContext(ctx context.Context, request *CreateTransformationRequest) (response *CreateTransformationResponse, err error) {
if request == nil {
request = NewCreateTransformationRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "CreateTransformation")
if c.GetCredential() == nil {
return nil, errors.New("CreateTransformation require credential")
}
request.SetContext(ctx)
response = NewCreateTransformationResponse()
err = c.Send(request, response)
return
}
func NewDeleteConnectionRequest() (request *DeleteConnectionRequest) {
request = &DeleteConnectionRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "DeleteConnection")
return
}
func NewDeleteConnectionResponse() (response *DeleteConnectionResponse) {
response = &DeleteConnectionResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// DeleteConnection
// 删除事件连接器
//
// 可能返回的错误码:
// FAILEDOPERATION_DELETECONNECTION = "FailedOperation.DeleteConnection"
// FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
// INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
// INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_INVALIDAPI = "ResourceNotFound.InvalidApi"
// RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
// UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"
func (c *Client) DeleteConnection(request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error) {
return c.DeleteConnectionWithContext(context.Background(), request)
}
// DeleteConnection
// 删除事件连接器
//
// 可能返回的错误码:
// FAILEDOPERATION_DELETECONNECTION = "FailedOperation.DeleteConnection"
// FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"
// INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"
// INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_INVALIDAPI = "ResourceNotFound.InvalidApi"
// RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"
// UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"
func (c *Client) DeleteConnectionWithContext(ctx context.Context, request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error) {
if request == nil {
request = NewDeleteConnectionRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "DeleteConnection")
if c.GetCredential() == nil {
return nil, errors.New("DeleteConnection require credential")
}
request.SetContext(ctx)
response = NewDeleteConnectionResponse()
err = c.Send(request, response)
return
}
func NewDeleteEventBusRequest() (request *DeleteEventBusRequest) {
request = &DeleteEventBusRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "DeleteEventBus")
return
}
func NewDeleteEventBusResponse() (response *DeleteEventBusResponse) {
response = &DeleteEventBusResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// DeleteEventBus
// 删除事件集
//
// 可能返回的错误码:
// FAILEDOPERATION_UNTAGRESOURCE = "FailedOperation.UnTagResource"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
func (c *Client) DeleteEventBus(request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error) {
return c.DeleteEventBusWithContext(context.Background(), request)
}
// DeleteEventBus
// 删除事件集
//
// 可能返回的错误码:
// FAILEDOPERATION_UNTAGRESOURCE = "FailedOperation.UnTagResource"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
func (c *Client) DeleteEventBusWithContext(ctx context.Context, request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error) {
if request == nil {
request = NewDeleteEventBusRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "DeleteEventBus")
if c.GetCredential() == nil {
return nil, errors.New("DeleteEventBus require credential")
}
request.SetContext(ctx)
response = NewDeleteEventBusResponse()
err = c.Send(request, response)
return
}
func NewDeleteRuleRequest() (request *DeleteRuleRequest) {
request = &DeleteRuleRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "DeleteRule")
return
}
func NewDeleteRuleResponse() (response *DeleteRuleResponse) {
response = &DeleteRuleResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// DeleteRule
// 删除事件规则
//
// 可能返回的错误码:
// FAILEDOPERATION_DELETERULE = "FailedOperation.DeleteRule"
// FAILEDOPERATION_UNTAGRESOURCE = "FailedOperation.UnTagResource"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// RESOURCEINUSE_RULE = "ResourceInUse.Rule"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
func (c *Client) DeleteRule(request *DeleteRuleRequest) (response *DeleteRuleResponse, err error) {
return c.DeleteRuleWithContext(context.Background(), request)
}
// DeleteRule
// 删除事件规则
//
// 可能返回的错误码:
// FAILEDOPERATION_DELETERULE = "FailedOperation.DeleteRule"
// FAILEDOPERATION_UNTAGRESOURCE = "FailedOperation.UnTagResource"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// RESOURCEINUSE_RULE = "ResourceInUse.Rule"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"
func (c *Client) DeleteRuleWithContext(ctx context.Context, request *DeleteRuleRequest) (response *DeleteRuleResponse, err error) {
if request == nil {
request = NewDeleteRuleRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "DeleteRule")
if c.GetCredential() == nil {
return nil, errors.New("DeleteRule require credential")
}
request.SetContext(ctx)
response = NewDeleteRuleResponse()
err = c.Send(request, response)
return
}
func NewDeleteTargetRequest() (request *DeleteTargetRequest) {
request = &DeleteTargetRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "DeleteTarget")
return
}
func NewDeleteTargetResponse() (response *DeleteTargetResponse) {
response = &DeleteTargetResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// DeleteTarget
// 删除事件目标
//
// 可能返回的错误码:
// FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"
// FAILEDOPERATION_DELETEPRIVATELINK = "FailedOperation.DeletePrivateLink"
// FAILEDOPERATION_ESINTERNALERROR = "FailedOperation.ESInternalError"
// FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// OPERATIONDENIED_ESVERSIONUNSUPPORTED = "OperationDenied.ESVersionUnsupported"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_NETASSOCIATION = "ResourceNotFound.NetAssociation"
// RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
func (c *Client) DeleteTarget(request *DeleteTargetRequest) (response *DeleteTargetResponse, err error) {
return c.DeleteTargetWithContext(context.Background(), request)
}
// DeleteTarget
// 删除事件目标
//
// 可能返回的错误码:
// FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"
// FAILEDOPERATION_DELETEPRIVATELINK = "FailedOperation.DeletePrivateLink"
// FAILEDOPERATION_ESINTERNALERROR = "FailedOperation.ESInternalError"
// FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// OPERATIONDENIED_ESVERSIONUNSUPPORTED = "OperationDenied.ESVersionUnsupported"
// OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_NETASSOCIATION = "ResourceNotFound.NetAssociation"
// RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"
// RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
func (c *Client) DeleteTargetWithContext(ctx context.Context, request *DeleteTargetRequest) (response *DeleteTargetResponse, err error) {
if request == nil {
request = NewDeleteTargetRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "DeleteTarget")
if c.GetCredential() == nil {
return nil, errors.New("DeleteTarget require credential")
}
request.SetContext(ctx)
response = NewDeleteTargetResponse()
err = c.Send(request, response)
return
}
func NewDeleteTransformationRequest() (request *DeleteTransformationRequest) {
request = &DeleteTransformationRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "DeleteTransformation")
return
}
func NewDeleteTransformationResponse() (response *DeleteTransformationResponse) {
response = &DeleteTransformationResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// DeleteTransformation
// 用于删除转换器
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
// RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"
func (c *Client) DeleteTransformation(request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error) {
return c.DeleteTransformationWithContext(context.Background(), request)
}
// DeleteTransformation
// 用于删除转换器
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
// RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"
func (c *Client) DeleteTransformationWithContext(ctx context.Context, request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error) {
if request == nil {
request = NewDeleteTransformationRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "DeleteTransformation")
if c.GetCredential() == nil {
return nil, errors.New("DeleteTransformation require credential")
}
request.SetContext(ctx)
response = NewDeleteTransformationResponse()
err = c.Send(request, response)
return
}
func NewDescribeLogTagValueRequest() (request *DescribeLogTagValueRequest) {
request = &DescribeLogTagValueRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "DescribeLogTagValue")
return
}
func NewDescribeLogTagValueResponse() (response *DescribeLogTagValueResponse) {
response = &DescribeLogTagValueResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// DescribeLogTagValue
// 前置条件：需开启事件存储；事件查询维度值
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
// RESOURCENOTFOUND = "ResourceNotFound"
func (c *Client) DescribeLogTagValue(request *DescribeLogTagValueRequest) (response *DescribeLogTagValueResponse, err error) {
return c.DescribeLogTagValueWithContext(context.Background(), request)
}
// DescribeLogTagValue
// 前置条件：需开启事件存储；事件查询维度值
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
// RESOURCENOTFOUND = "ResourceNotFound"
func (c *Client) DescribeLogTagValueWithContext(ctx context.Context, request *DescribeLogTagValueRequest) (response *DescribeLogTagValueResponse, err error) {
if request == nil {
request = NewDescribeLogTagValueRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "DescribeLogTagValue")
if c.GetCredential() == nil {
return nil, errors.New("DescribeLogTagValue require credential")
}
request.SetContext(ctx)
response = NewDescribeLogTagValueResponse()
err = c.Send(request, response)
return
}
func NewGetEventBusRequest() (request *GetEventBusRequest) {
request = &GetEventBusRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "GetEventBus")
return
}
func NewGetEventBusResponse() (response *GetEventBusResponse) {
response = &GetEventBusResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// GetEventBus
// 获取事件集详情
//
// 可能返回的错误码:
// 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)
}
// 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 {
request = NewGetEventBusRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "GetEventBus")
if c.GetCredential() == nil {
return nil, errors.New("GetEventBus require credential")
}
request.SetContext(ctx)
response = NewGetEventBusResponse()
err = c.Send(request, response)
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()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "GetPlatformEventTemplate")
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{},
}
request.Init().WithApiInfo("eb", APIVersion, "GetRule")
return
}
func NewGetRuleResponse() (response *GetRuleResponse) {
response = &GetRuleResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// GetRule
// 获取事件规则详情
//
// 可能返回的错误码:
// 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) {
return c.GetRuleWithContext(context.Background(), request)
}
// GetRule
// 获取事件规则详情
//
// 可能返回的错误码:
// 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) {
if request == nil {
request = NewGetRuleRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "GetRule")
if c.GetCredential() == nil {
return nil, errors.New("GetRule require credential")
}
request.SetContext(ctx)
response = NewGetRuleResponse()
err = c.Send(request, response)
return
}
func NewGetTransformationRequest() (request *GetTransformationRequest) {
request = &GetTransformationRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "GetTransformation")
return
}
func NewGetTransformationResponse() (response *GetTransformationResponse) {
response = &GetTransformationResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// GetTransformation
// 用于获取转换器详情
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"
func (c *Client) GetTransformation(request *GetTransformationRequest) (response *GetTransformationResponse, err error) {
return c.GetTransformationWithContext(context.Background(), request)
}
// GetTransformation
// 用于获取转换器详情
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"
func (c *Client) GetTransformationWithContext(ctx context.Context, request *GetTransformationRequest) (response *GetTransformationResponse, err error) {
if request == nil {
request = NewGetTransformationRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "GetTransformation")
if c.GetCredential() == nil {
return nil, errors.New("GetTransformation require credential")
}
request.SetContext(ctx)
response = NewGetTransformationResponse()
err = c.Send(request, response)
return
}
func NewListConnectionsRequest() (request *ListConnectionsRequest) {
request = &ListConnectionsRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "ListConnections")
return
}
func NewListConnectionsResponse() (response *ListConnectionsResponse) {
response = &ListConnectionsResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// ListConnections
// 获取事件连接器列表
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
// 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)
}
// ListConnections
// 获取事件连接器列表
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
// 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 {
request = NewListConnectionsRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "ListConnections")
if c.GetCredential() == nil {
return nil, errors.New("ListConnections require credential")
}
request.SetContext(ctx)
response = NewListConnectionsResponse()
err = c.Send(request, response)
return
}
func NewListEventBusesRequest() (request *ListEventBusesRequest) {
request = &ListEventBusesRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "ListEventBuses")
return
}
func NewListEventBusesResponse() (response *ListEventBusesResponse) {
response = &ListEventBusesResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// ListEventBuses
// 获取事件集列表
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
// INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
// INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
// INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
// INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
// UNAUTHORIZEDOPERATION_CAM = "UnauthorizedOperation.CAM"
func (c *Client) ListEventBuses(request *ListEventBusesRequest) (response *ListEventBusesResponse, err error) {
return c.ListEventBusesWithContext(context.Background(), request)
}
// ListEventBuses
// 获取事件集列表
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
// INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
// INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
// INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
// INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"
// UNAUTHORIZEDOPERATION_CAM = "UnauthorizedOperation.CAM"
func (c *Client) ListEventBusesWithContext(ctx context.Context, request *ListEventBusesRequest) (response *ListEventBusesResponse, err error) {
if request == nil {
request = NewListEventBusesRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "ListEventBuses")
if c.GetCredential() == nil {
return nil, errors.New("ListEventBuses require credential")
}
request.SetContext(ctx)
response = NewListEventBusesResponse()
err = c.Send(request, response)
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()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "ListPlatformEventNames")
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()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "ListPlatformEventPatterns")
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()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "ListPlatformProducts")
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{},
}
request.Init().WithApiInfo("eb", APIVersion, "ListRules")
return
}
func NewListRulesResponse() (response *ListRulesResponse) {
response = &ListRulesResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// ListRules
// 获取事件规则列表
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
// 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)
}
// ListRules
// 获取事件规则列表
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"
// 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 {
request = NewListRulesRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "ListRules")
if c.GetCredential() == nil {
return nil, errors.New("ListRules require credential")
}
request.SetContext(ctx)
response = NewListRulesResponse()
err = c.Send(request, response)
return
}
func NewListTargetsRequest() (request *ListTargetsRequest) {
request = &ListTargetsRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "ListTargets")
return
}
func NewListTargetsResponse() (response *ListTargetsResponse) {
response = &ListTargetsResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// ListTargets
// 获取事件目标列表
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
// INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
// INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
// 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) {
return c.ListTargetsWithContext(context.Background(), request)
}
// ListTargets
// 获取事件目标列表
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"
// INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"
// INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"
// 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) {
if request == nil {
request = NewListTargetsRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "ListTargets")
if c.GetCredential() == nil {
return nil, errors.New("ListTargets require credential")
}
request.SetContext(ctx)
response = NewListTargetsResponse()
err = c.Send(request, response)
return
}
func NewPublishEventRequest() (request *PublishEventRequest) {
request = &PublishEventRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "PublishEvent")
return
}
func NewPublishEventResponse() (response *PublishEventResponse) {
response = &PublishEventResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// PublishEvent
// （已废弃）用于Event事件投递
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_INVALIDEVENT = "InvalidParameterValue.InvalidEvent"
// INVALIDPARAMETERVALUE_INVALIDEVENTBUS = "InvalidParameterValue.InvalidEventBus"
// LIMITEXCEEDED_RESOURCELIMIT = "LimitExceeded.ResourceLimit"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_EVENTBUSNOTFOUND = "ResourceNotFound.EventBusNotFound"
func (c *Client) PublishEvent(request *PublishEventRequest) (response *PublishEventResponse, err error) {
return c.PublishEventWithContext(context.Background(), request)
}
// PublishEvent
// （已废弃）用于Event事件投递
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_INVALIDEVENT = "InvalidParameterValue.InvalidEvent"
// INVALIDPARAMETERVALUE_INVALIDEVENTBUS = "InvalidParameterValue.InvalidEventBus"
// LIMITEXCEEDED_RESOURCELIMIT = "LimitExceeded.ResourceLimit"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_EVENTBUSNOTFOUND = "ResourceNotFound.EventBusNotFound"
func (c *Client) PublishEventWithContext(ctx context.Context, request *PublishEventRequest) (response *PublishEventResponse, err error) {
if request == nil {
request = NewPublishEventRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "PublishEvent")
if c.GetCredential() == nil {
return nil, errors.New("PublishEvent require credential")
}
request.SetContext(ctx)
response = NewPublishEventResponse()
err = c.Send(request, response)
return
}
func NewPutEventsRequest() (request *PutEventsRequest) {
request = &PutEventsRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "PutEvents")
return
}
func NewPutEventsResponse() (response *PutEventsResponse) {
response = &PutEventsResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// PutEvents
// 用于Event事件投递
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INTERNALERROR_UNKNOWNINTERNALERROR = "InternalError.UnknownInternalError"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_INVALIDEVENT = "InvalidParameterValue.InvalidEvent"
// INVALIDPARAMETERVALUE_INVALIDEVENTBUS = "InvalidParameterValue.InvalidEventBus"
// LIMITEXCEEDED_BANNEDACCOUNT = "LimitExceeded.BannedAccount"
// LIMITEXCEEDED_RESOURCELIMIT = "LimitExceeded.ResourceLimit"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_EVENTBUSNOTFOUND = "ResourceNotFound.EventBusNotFound"
func (c *Client) PutEvents(request *PutEventsRequest) (response *PutEventsResponse, err error) {
return c.PutEventsWithContext(context.Background(), request)
}
// PutEvents
// 用于Event事件投递
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INTERNALERROR_SYSTEM = "InternalError.System"
// INTERNALERROR_UNKNOWNINTERNALERROR = "InternalError.UnknownInternalError"
// INVALIDPARAMETER = "InvalidParameter"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_INVALIDEVENT = "InvalidParameterValue.InvalidEvent"
// INVALIDPARAMETERVALUE_INVALIDEVENTBUS = "InvalidParameterValue.InvalidEventBus"
// LIMITEXCEEDED_BANNEDACCOUNT = "LimitExceeded.BannedAccount"
// LIMITEXCEEDED_RESOURCELIMIT = "LimitExceeded.ResourceLimit"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_EVENTBUSNOTFOUND = "ResourceNotFound.EventBusNotFound"
func (c *Client) PutEventsWithContext(ctx context.Context, request *PutEventsRequest) (response *PutEventsResponse, err error) {
if request == nil {
request = NewPutEventsRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "PutEvents")
if c.GetCredential() == nil {
return nil, errors.New("PutEvents require credential")
}
request.SetContext(ctx)
response = NewPutEventsResponse()
err = c.Send(request, response)
return
}
func NewSearchLogRequest() (request *SearchLogRequest) {
request = &SearchLogRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "SearchLog")
return
}
func NewSearchLogResponse() (response *SearchLogResponse) {
response = &SearchLogResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// SearchLog
// 前置条件：开启事件存储；查询历史推送事件
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
// RESOURCENOTFOUND = "ResourceNotFound"
func (c *Client) SearchLog(request *SearchLogRequest) (response *SearchLogResponse, err error) {
return c.SearchLogWithContext(context.Background(), request)
}
// SearchLog
// 前置条件：开启事件存储；查询历史推送事件
//
// 可能返回的错误码:
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
// RESOURCENOTFOUND = "ResourceNotFound"
func (c *Client) SearchLogWithContext(ctx context.Context, request *SearchLogRequest) (response *SearchLogResponse, err error) {
if request == nil {
request = NewSearchLogRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "SearchLog")
if c.GetCredential() == nil {
return nil, errors.New("SearchLog require credential")
}
request.SetContext(ctx)
response = NewSearchLogResponse()
err = c.Send(request, response)
return
}
func NewUpdateConnectionRequest() (request *UpdateConnectionRequest) {
request = &UpdateConnectionRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "UpdateConnection")
return
}
func NewUpdateConnectionResponse() (response *UpdateConnectionResponse) {
response = &UpdateConnectionResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// UpdateConnection
// 更新事件连接器
//
// 可能返回的错误码:
// FAILEDOPERATION_UPDATECONNECTION = "FailedOperation.UpdateConnection"
// INVALIDPARAMETER_ENABLEAPIGATEWAY = "InvalidParameter.EnableAPIGateway"
// INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"
func (c *Client) UpdateConnection(request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error) {
return c.UpdateConnectionWithContext(context.Background(), request)
}
// UpdateConnection
// 更新事件连接器
//
// 可能返回的错误码:
// FAILEDOPERATION_UPDATECONNECTION = "FailedOperation.UpdateConnection"
// INVALIDPARAMETER_ENABLEAPIGATEWAY = "InvalidParameter.EnableAPIGateway"
// INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"
func (c *Client) UpdateConnectionWithContext(ctx context.Context, request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error) {
if request == nil {
request = NewUpdateConnectionRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "UpdateConnection")
if c.GetCredential() == nil {
return nil, errors.New("UpdateConnection require credential")
}
request.SetContext(ctx)
response = NewUpdateConnectionResponse()
err = c.Send(request, response)
return
}
func NewUpdateEventBusRequest() (request *UpdateEventBusRequest) {
request = &UpdateEventBusRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "UpdateEventBus")
return
}
func NewUpdateEventBusResponse() (response *UpdateEventBusResponse) {
response = &UpdateEventBusResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// UpdateEventBus
// 更新事件集
//
// 可能返回的错误码:
// FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
// INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
// OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
func (c *Client) UpdateEventBus(request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error) {
return c.UpdateEventBusWithContext(context.Background(), request)
}
// UpdateEventBus
// 更新事件集
//
// 可能返回的错误码:
// FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"
// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"
// INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"
// OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
func (c *Client) UpdateEventBusWithContext(ctx context.Context, request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error) {
if request == nil {
request = NewUpdateEventBusRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "UpdateEventBus")
if c.GetCredential() == nil {
return nil, errors.New("UpdateEventBus require credential")
}
request.SetContext(ctx)
response = NewUpdateEventBusResponse()
err = c.Send(request, response)
return
}
func NewUpdateRuleRequest() (request *UpdateRuleRequest) {
request = &UpdateRuleRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "UpdateRule")
return
}
func NewUpdateRuleResponse() (response *UpdateRuleResponse) {
response = &UpdateRuleResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// UpdateRule
// 更新事件规则
//
// 可能返回的错误码:
// FAILEDOPERATION_UPDATERULE = "FailedOperation.UpdateRule"
// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
func (c *Client) UpdateRule(request *UpdateRuleRequest) (response *UpdateRuleResponse, err error) {
return c.UpdateRuleWithContext(context.Background(), request)
}
// UpdateRule
// 更新事件规则
//
// 可能返回的错误码:
// FAILEDOPERATION_UPDATERULE = "FailedOperation.UpdateRule"
// INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"
// INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"
// INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
func (c *Client) UpdateRuleWithContext(ctx context.Context, request *UpdateRuleRequest) (response *UpdateRuleResponse, err error) {
if request == nil {
request = NewUpdateRuleRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "UpdateRule")
if c.GetCredential() == nil {
return nil, errors.New("UpdateRule require credential")
}
request.SetContext(ctx)
response = NewUpdateRuleResponse()
err = c.Send(request, response)
return
}
func NewUpdateTargetRequest() (request *UpdateTargetRequest) {
request = &UpdateTargetRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "UpdateTarget")
return
}
func NewUpdateTargetResponse() (response *UpdateTargetResponse) {
response = &UpdateTargetResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// UpdateTarget
// 更新事件目标
//
// 可能返回的错误码:
// AUTHFAILURE = "AuthFailure"
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
// INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
// INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
// INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
func (c *Client) UpdateTarget(request *UpdateTargetRequest) (response *UpdateTargetResponse, err error) {
return c.UpdateTargetWithContext(context.Background(), request)
}
// UpdateTarget
// 更新事件目标
//
// 可能返回的错误码:
// AUTHFAILURE = "AuthFailure"
// INTERNALERROR = "InternalError"
// INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"
// INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"
// INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"
// INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
// INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"
// INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"
// INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"
// INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
// INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"
// OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"
// RESOURCENOTFOUND = "ResourceNotFound"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
// RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"
// RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"
func (c *Client) UpdateTargetWithContext(ctx context.Context, request *UpdateTargetRequest) (response *UpdateTargetResponse, err error) {
if request == nil {
request = NewUpdateTargetRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "UpdateTarget")
if c.GetCredential() == nil {
return nil, errors.New("UpdateTarget require credential")
}
request.SetContext(ctx)
response = NewUpdateTargetResponse()
err = c.Send(request, response)
return
}
func NewUpdateTransformationRequest() (request *UpdateTransformationRequest) {
request = &UpdateTransformationRequest{
BaseRequest: &tchttp.BaseRequest{},
}
request.Init().WithApiInfo("eb", APIVersion, "UpdateTransformation")
return
}
func NewUpdateTransformationResponse() (response *UpdateTransformationResponse) {
response = &UpdateTransformationResponse{
BaseResponse: &tchttp.BaseResponse{},
}
return
}
// UpdateTransformation
// 用于更新转换器
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
func (c *Client) UpdateTransformation(request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error) {
return c.UpdateTransformationWithContext(context.Background(), request)
}
// UpdateTransformation
// 用于更新转换器
//
// 可能返回的错误码:
// INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
// RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
func (c *Client) UpdateTransformationWithContext(ctx context.Context, request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error) {
if request == nil {
request = NewUpdateTransformationRequest()
}
c.InitBaseRequest(&request.BaseRequest, "eb", APIVersion, "UpdateTransformation")
if c.GetCredential() == nil {
return nil, errors.New("UpdateTransformation require credential")
}
request.SetContext(ctx)
response = NewUpdateTransformationResponse()
err = c.Send(request, response)
return
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手