v20210416

package
v1.0.926 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 21, 2024 License: Apache-2.0 Imports: 7 Imported by: 2

Documentation

Index

Constants

View Source
const (

	// CAM签名/鉴权错误。
	AUTHFAILURE = "AuthFailure"

	// 操作失败。
	FAILEDOPERATION = "FailedOperation"

	// 添加私有链接失败。
	FAILEDOPERATION_ADDPRIVATELINK = "FailedOperation.AddPrivateLink"

	// 用户鉴权错误。
	FAILEDOPERATION_AUTHENTICATEUSERFAILED = "FailedOperation.AuthenticateUserFailed"

	// 投递目标创建失败,请检查函数状态。
	FAILEDOPERATION_CREATETRIGGER = "FailedOperation.CreateTrigger"

	// 删除连接器失败,请检查资源状态。
	FAILEDOPERATION_DELETECONNECTION = "FailedOperation.DeleteConnection"

	// 删除私有链接失败。
	FAILEDOPERATION_DELETEPRIVATELINK = "FailedOperation.DeletePrivateLink"

	// 规则删除失败,请检查资源信息,确认是资源否存在或状态正常。
	FAILEDOPERATION_DELETERULE = "FailedOperation.DeleteRule"

	// ES集群内部错误。
	FAILEDOPERATION_ESINTERNALERROR = "FailedOperation.ESInternalError"

	// ES集群操作失败。
	FAILEDOPERATION_ESREQUESTFAILED = "FailedOperation.ESRequestFailed"

	// ES索引模板冲突错误。
	FAILEDOPERATION_ESTEMPLATECONFLICT = "FailedOperation.ESTemplateConflict"

	// 规则与事件不匹配,请修正后再试。
	FAILEDOPERATION_ERRORFILTER = "FailedOperation.ErrorFilter"

	// 注册CLS服务失败。
	FAILEDOPERATION_REGISTERCLSSERVICE = "FailedOperation.RegisterCLSService"

	// ServiceError操作失败,请检查资源信息。
	FAILEDOPERATION_SERVICEERROR = "FailedOperation.ServiceError"

	// 标签绑定操作失败。
	FAILEDOPERATION_TAGRESOURCE = "FailedOperation.TagResource"

	// 申请标签配额失败。
	FAILEDOPERATION_TAGRESOURCEALLOCATEQUOTAS = "FailedOperation.TagResourceAllocateQuotas"

	// 标签解绑操作失败。
	FAILEDOPERATION_UNTAGRESOURCE = "FailedOperation.UnTagResource"

	// 连接器更新失败,请检查资源信息,确认是资源否存在或状态正常。
	FAILEDOPERATION_UPDATECONNECTION = "FailedOperation.UpdateConnection"

	// 规则更新失败,请检查资源信息,确认是资源否存在或状态正常。
	FAILEDOPERATION_UPDATERULE = "FailedOperation.UpdateRule"

	// 内部错误。
	INTERNALERROR = "InternalError"

	// 服务处理出错,请稍后重试。若无法解决,请联系智能客服或提交工单。
	INTERNALERROR_OSSEXCEPTION = "InternalError.OssException"

	// 服务处理出错,请稍后重试。若无法解决,请联系智能客服或提交工单。
	INTERNALERROR_SYSTEM = "InternalError.System"

	// 未知错误。
	INTERNALERROR_UNKNOWNINTERNALERROR = "InternalError.UnknownInternalError"

	// 参数错误。
	INVALIDPARAMETER = "InvalidParameter"

	// APIGateway连接器不支持开启或关闭操作,请修正后重试。
	INVALIDPARAMETER_ENABLEAPIGATEWAY = "InvalidParameter.EnableAPIGateway"

	// Payload与规范不符,请修正后再试。
	INVALIDPARAMETER_PAYLOAD = "InvalidParameter.Payload"

	// AMPParams取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_AMPPARAMS = "InvalidParameterValue.AMPParams"

	// Action 操作参数取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"

	// BatchEventCount取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_BATCHEVENTCOUNT = "InvalidParameterValue.BatchEventCount"

	// BatchTimeout取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_BATCHTIMEOUT = "InvalidParameterValue.BatchTimeout"

	// Ckafka 目标配置参数取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_CKAFKATARGETPARAMS = "InvalidParameterValue.CKafkaTargetParams"

	// CallbackType取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_CALLBACKTYPE = "InvalidParameterValue.CallbackType"

	// CallbackWeComURL取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_CALLBACKWECOMURL = "InvalidParameterValue.CallbackWeComURL"

	// ConnectionDescription取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_CONNECTIONDESCRIPTION = "InvalidParameterValue.ConnectionDescription"

	// ConnectionId取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_CONNECTIONID = "InvalidParameterValue.ConnectionId"

	// ConnectionName取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_CONNECTIONNAME = "InvalidParameterValue.ConnectionName"

	// DTSParams取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_DTSPARAMS = "InvalidParameterValue.DTSParams"

	// 死信队列配置参数取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_DEADLETTERCONFIG = "InvalidParameterValue.DeadLetterConfig"

	// Description取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_DESCRIPTION = "InvalidParameterValue.Description"

	// ES目标参数错误。
	INVALIDPARAMETERVALUE_ELASTICSEARCHTARGETPARAMS = "InvalidParameterValue.ElasticSearchTargetParams"

	// EventBusId取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"

	// EventBusName取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_EVENTBUSNAME = "InvalidParameterValue.EventBusName"

	// EventPattern取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_EVENTPATTERN = "InvalidParameterValue.EventPattern"

	// 链路追踪配置参数取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_EVENTTRACECONFIG = "InvalidParameterValue.EventTraceConfig"

	// Filters取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_FILTERS = "InvalidParameterValue.Filters"

	// InvalidApiRequestConfig取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_INVALIDAPIREQUESTCONFIG = "InvalidParameterValue.InvalidApiRequestConfig"

	// 事件格式非法,请修正后再试。
	INVALIDPARAMETERVALUE_INVALIDEVENT = "InvalidParameterValue.InvalidEvent"

	// 非法的事件集,请检查后重试。
	INVALIDPARAMETERVALUE_INVALIDEVENTBUS = "InvalidParameterValue.InvalidEventBus"

	// 事件模式格式错误,请修正后再试。
	INVALIDPARAMETERVALUE_INVALIDFILTERRULE = "InvalidParameterValue.InvalidFilterRule"

	// 非法的匹配规则,请检查后重试。
	INVALIDPARAMETERVALUE_INVALIDPATTERN = "InvalidParameterValue.InvalidPattern"

	// Limit取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_LIMIT = "InvalidParameterValue.Limit"

	// LinkMode取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_LINKMODE = "InvalidParameterValue.LinkMode"

	// NoticeReceiverChannel取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_NOTICERECEIVERCHANNEL = "InvalidParameterValue.NoticeReceiverChannel"

	// NoticeReceiverTimeWindow取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_NOTICERECEIVERTIMEWINDOW = "InvalidParameterValue.NoticeReceiverTimeWindow"

	// NoticeReceiverUserIds取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_NOTICERECEIVERUSERIDS = "InvalidParameterValue.NoticeReceiverUserIds"

	// NoticeReceiverUserType取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_NOTICERECEIVERUSERTYPE = "InvalidParameterValue.NoticeReceiverUserType"

	// Offset取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_OFFSET = "InvalidParameterValue.Offset"

	// Order取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_ORDER = "InvalidParameterValue.Order"

	// OrderBy取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_ORDERBY = "InvalidParameterValue.OrderBy"

	// Qualifier取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_QUALIFIER = "InvalidParameterValue.Qualifier"

	// RuleId取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"

	// RuleName取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_RULENAME = "InvalidParameterValue.RuleName"

	// 标签参数错误。
	INVALIDPARAMETERVALUE_TAGS = "InvalidParameterValue.Tags"

	// TargetDescription取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_TARGETDESCRIPTION = "InvalidParameterValue.TargetDescription"

	// TargetId取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_TARGETID = "InvalidParameterValue.TargetId"

	// 数据转换配置参数取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"

	// 数据转换任务创建失败,配置参数取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"

	// Type取值与规范不符,请修正后再试。
	INVALIDPARAMETERVALUE_TYPE = "InvalidParameterValue.Type"

	// 事件投递失败,因欠费或违规等原因,账号已被禁用,请联系官网账户端客服处理。
	LIMITEXCEEDED_BANNEDACCOUNT = "LimitExceeded.BannedAccount"

	// 集群私有链接超限。
	LIMITEXCEEDED_CLUSTERPRIVATELINKEXCEEDED = "LimitExceeded.ClusterPrivateLinkExceeded"

	// Connection数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_CONNECTION = "LimitExceeded.Connection"

	// EventBus数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_EVENTBUS = "LimitExceeded.EventBus"

	// 资源创建失败,可冻结余额不足,请充值后重新创建。
	LIMITEXCEEDED_INSUFFICIENTBALANCE = "LimitExceeded.InsufficientBalance"

	// Logset数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_LOGSET = "LimitExceeded.Logset"

	// ResourceLimit数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_RESOURCELIMIT = "LimitExceeded.ResourceLimit"

	// RouteOverLimit数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_ROUTEOVERLIMIT = "LimitExceeded.RouteOverLimit"

	// Rule数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_RULE = "LimitExceeded.Rule"

	// Target数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_TARGET = "LimitExceeded.Target"

	// 投递目标创建失败,函数触发器数量达到限制,可提交工单申请提升限制。
	LIMITEXCEEDED_TRIGGER = "LimitExceeded.Trigger"

	// 用户私有链接超限。
	LIMITEXCEEDED_USERPRIVATELINKEXCEEDED = "LimitExceeded.UserPrivateLinkExceeded"

	// 投递目标创建失败,检测到当前账号不存在,请确认您的账号状态。
	OPERATIONDENIED_ACCOUNTNOTEXISTS = "OperationDenied.AccountNotExists"

	// 不允许在自定义事件集上创建基于EB默认日志集的CLS事件目标。
	OPERATIONDENIED_DEFAULTCLSRESOURCEUNSUPPORTED = "OperationDenied.DefaultCLSResourceUnsupported"

	// 不支持操作当前ES版本。
	OPERATIONDENIED_ESVERSIONUNSUPPORTED = "OperationDenied.ESVersionUnsupported"

	// 技术架构升级,该资源临时锁定中,预计持续3~5分钟,事件推送流程无影响。
	OPERATIONDENIED_EVENTBUSRESOURCEISLOCKED = "OperationDenied.EventBusResourceIsLocked"

	// 操作失败,该资源不可修改或删除。
	OPERATIONDENIED_RESOURCEIMMUTABLE = "OperationDenied.ResourceImmutable"

	// 当前用户账号类型暂不支持操作,请提交工单处理。
	OPERATIONDENIED_UNSUPPORTEDOPERATION = "OperationDenied.UnsupportedOperation"

	// 同一个地域下,云服务默认事件集不允许重复创建。
	RESOURCEINUSE_DEFAULTEVENTBUS = "ResourceInUse.DefaultEventBus"

	// 无法删除,因事件集下存在规则、连接器或归档,请删除所有规则、连接器和归档后重试。
	RESOURCEINUSE_EVENTBUS = "ResourceInUse.EventBus"

	// 规则下有目标,无法删除,请删除所有目标后重试。
	RESOURCEINUSE_RULE = "ResourceInUse.Rule"

	// 资源不存在。
	RESOURCENOTFOUND = "ResourceNotFound"

	// 未找到指定的Connection,请创建后再试。
	RESOURCENOTFOUND_CONNECTION = "ResourceNotFound.Connection"

	// 未找到指定事件集,请创建后再试。
	RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

	// 事件集不存在或未配置规则,请检查后再试。
	RESOURCENOTFOUND_EVENTBUSNOTFOUND = "ResourceNotFound.EventBusNotFound"

	// 未找到指定的Function,请创建后再试。
	RESOURCENOTFOUND_FUNCTION = "ResourceNotFound.Function"

	// 连接器删除失败,未找到指定 API 。
	RESOURCENOTFOUND_INVALIDAPI = "ResourceNotFound.InvalidApi"

	// 连接器操作失败,未找到指定 API 网关服务。
	RESOURCENOTFOUND_INVALIDSERVICE = "ResourceNotFound.InvalidService"

	// 投递目标创建失败,未找到指定的命名空间,请创建后再试。
	RESOURCENOTFOUND_NAMESPACE = "ResourceNotFound.Namespace"

	// 未找到网络资源关联记录。
	RESOURCENOTFOUND_NETASSOCIATION = "ResourceNotFound.NetAssociation"

	// 未找到privatelink记录。
	RESOURCENOTFOUND_PRIVATELINKRESOURCE = "ResourceNotFound.PrivateLinkResource"

	// 未找到指定的服务角色,请创建后再试。
	RESOURCENOTFOUND_ROLE = "ResourceNotFound.Role"

	// 未找到指定的Rule,请创建后再试。
	RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

	// 未找到指定标签。
	RESOURCENOTFOUND_TAG = "ResourceNotFound.Tag"

	// 未找到指定的Target,请创建后再试。
	RESOURCENOTFOUND_TARGET = "ResourceNotFound.Target"

	// 未找到指定的转换任务,请创建后再试。
	RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

	// 投递目标创建失败,未找到指定的服务版本,请创建后再试。
	RESOURCENOTFOUND_VERSION = "ResourceNotFound.Version"

	// 连接器创建失败,当前资源不可用。
	RESOURCEUNAVAILABLE_CONNECTION = "ResourceUnavailable.Connection"

	// ES集群状态异常。
	RESOURCEUNAVAILABLE_ESUNHEALTH = "ResourceUnavailable.ESUnhealth"

	// 投递目标创建失败,当前资源不可用。
	RESOURCEUNAVAILABLE_TARGET = "ResourceUnavailable.Target"

	// 当前账号缺少 EB 操作权限,请登录 CAM 控制台进行授权。
	UNAUTHORIZEDOPERATION_CAM = "UnauthorizedOperation.CAM"

	// 操作不支持。
	UNSUPPORTEDOPERATION = "UnsupportedOperation"

	// 连接器操作失败,接口不支持当前操作。
	UNSUPPORTEDOPERATION_INVALIDACTION = "UnsupportedOperation.InvalidAction"

	// 连接器创建失败,不支持当前后端服务类型。
	UNSUPPORTEDOPERATION_INVALIDENDPOINTTYPE = "UnsupportedOperation.InvalidEndpointType"
)
View Source
const APIVersion = "2021-04-16"

Variables

This section is empty.

Functions

This section is empty.

Types

type APIGWParams

type APIGWParams struct {
	// HTTPS
	Protocol *string `json:"Protocol,omitnil,omitempty" name:"Protocol"`

	// POST
	Method *string `json:"Method,omitnil,omitempty" name:"Method"`
}

type CheckRuleRequest

type CheckRuleRequest struct {
	*tchttp.BaseRequest

	// Event信息
	Event *string `json:"Event,omitnil,omitempty" name:"Event"`

	// EventPattern信息
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`
}

func NewCheckRuleRequest

func NewCheckRuleRequest() (request *CheckRuleRequest)

func (*CheckRuleRequest) FromJsonString

func (r *CheckRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckRuleRequest) ToJsonString

func (r *CheckRuleRequest) ToJsonString() string

type CheckRuleRequestParams added in v1.0.426

type CheckRuleRequestParams struct {
	// Event信息
	Event *string `json:"Event,omitnil,omitempty" name:"Event"`

	// EventPattern信息
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`
}

Predefined struct for user

type CheckRuleResponse

type CheckRuleResponse struct {
	*tchttp.BaseResponse
	Response *CheckRuleResponseParams `json:"Response"`
}

func NewCheckRuleResponse

func NewCheckRuleResponse() (response *CheckRuleResponse)

func (*CheckRuleResponse) FromJsonString

func (r *CheckRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckRuleResponse) ToJsonString

func (r *CheckRuleResponse) ToJsonString() string

type CheckRuleResponseParams added in v1.0.426

type CheckRuleResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CheckTransformationRequest

type CheckTransformationRequest struct {
	*tchttp.BaseRequest

	// 待处理的json字符串
	Input *string `json:"Input,omitnil,omitempty" name:"Input"`

	// 一个转换规则列表
	Transformations []*Transformation `json:"Transformations,omitnil,omitempty" name:"Transformations"`
}

func NewCheckTransformationRequest

func NewCheckTransformationRequest() (request *CheckTransformationRequest)

func (*CheckTransformationRequest) FromJsonString

func (r *CheckTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckTransformationRequest) ToJsonString

func (r *CheckTransformationRequest) ToJsonString() string

type CheckTransformationRequestParams added in v1.0.426

type CheckTransformationRequestParams struct {
	// 待处理的json字符串
	Input *string `json:"Input,omitnil,omitempty" name:"Input"`

	// 一个转换规则列表
	Transformations []*Transformation `json:"Transformations,omitnil,omitempty" name:"Transformations"`
}

Predefined struct for user

type CheckTransformationResponse

type CheckTransformationResponse struct {
	*tchttp.BaseResponse
	Response *CheckTransformationResponseParams `json:"Response"`
}

func NewCheckTransformationResponse

func NewCheckTransformationResponse() (response *CheckTransformationResponse)

func (*CheckTransformationResponse) FromJsonString

func (r *CheckTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CheckTransformationResponse) ToJsonString

func (r *CheckTransformationResponse) ToJsonString() string

type CheckTransformationResponseParams added in v1.0.426

type CheckTransformationResponseParams struct {
	// 经过Transformations处理之后的数据
	Output *string `json:"Output,omitnil,omitempty" name:"Output"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CkafkaDeliveryParams

type CkafkaDeliveryParams struct {
	// ckafka topic name
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// ckafka资源qcs六段式
	ResourceDescription *string `json:"ResourceDescription,omitnil,omitempty" name:"ResourceDescription"`
}

type CkafkaParams

type CkafkaParams struct {
	// kafka offset
	Offset *string `json:"Offset,omitnil,omitempty" name:"Offset"`

	// ckafka  topic
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`
}

type CkafkaTargetParams

type CkafkaTargetParams struct {
	// 要投递到的ckafka topic
	TopicName *string `json:"TopicName,omitnil,omitempty" name:"TopicName"`

	// 重试策略
	RetryPolicy *RetryPolicy `json:"RetryPolicy,omitnil,omitempty" name:"RetryPolicy"`
}

type Client

type Client struct {
	common.Client
}

func NewClient

func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)

func NewClientWithSecretId

func NewClientWithSecretId(secretId, secretKey, region string) (client *Client, err error)

Deprecated

func (*Client) CheckRule

func (c *Client) CheckRule(request *CheckRuleRequest) (response *CheckRuleResponse, err error)

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 (*Client) CheckRuleWithContext

func (c *Client) CheckRuleWithContext(ctx context.Context, request *CheckRuleRequest) (response *CheckRuleResponse, err error)

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 (*Client) CheckTransformation

func (c *Client) CheckTransformation(request *CheckTransformationRequest) (response *CheckTransformationResponse, err error)

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 (*Client) CheckTransformationWithContext

func (c *Client) CheckTransformationWithContext(ctx context.Context, request *CheckTransformationRequest) (response *CheckTransformationResponse, err error)

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 (*Client) CreateConnection

func (c *Client) CreateConnection(request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)

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 (*Client) CreateConnectionWithContext

func (c *Client) CreateConnectionWithContext(ctx context.Context, request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)

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 (*Client) CreateEventBus

func (c *Client) CreateEventBus(request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)

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 (*Client) CreateEventBusWithContext

func (c *Client) CreateEventBusWithContext(ctx context.Context, request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)

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 (*Client) CreateRule

func (c *Client) CreateRule(request *CreateRuleRequest) (response *CreateRuleResponse, err error)

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 (*Client) CreateRuleWithContext

func (c *Client) CreateRuleWithContext(ctx context.Context, request *CreateRuleRequest) (response *CreateRuleResponse, err error)

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 (*Client) CreateTarget

func (c *Client) CreateTarget(request *CreateTargetRequest) (response *CreateTargetResponse, err error)

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 (*Client) CreateTargetWithContext

func (c *Client) CreateTargetWithContext(ctx context.Context, request *CreateTargetRequest) (response *CreateTargetResponse, err error)

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 (*Client) CreateTransformation

func (c *Client) CreateTransformation(request *CreateTransformationRequest) (response *CreateTransformationResponse, err error)

CreateTransformation 用于创建转换器

可能返回的错误码:

INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) CreateTransformationWithContext

func (c *Client) CreateTransformationWithContext(ctx context.Context, request *CreateTransformationRequest) (response *CreateTransformationResponse, err error)

CreateTransformation 用于创建转换器

可能返回的错误码:

INVALIDPARAMETERVALUE_TRANSFORMATIONS = "InvalidParameterValue.Transformations"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) DeleteConnection

func (c *Client) DeleteConnection(request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)

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 (*Client) DeleteConnectionWithContext

func (c *Client) DeleteConnectionWithContext(ctx context.Context, request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)

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 (*Client) DeleteEventBus

func (c *Client) DeleteEventBus(request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)

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 (*Client) DeleteEventBusWithContext

func (c *Client) DeleteEventBusWithContext(ctx context.Context, request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)

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 (*Client) DeleteRule

func (c *Client) DeleteRule(request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)

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 (*Client) DeleteRuleWithContext

func (c *Client) DeleteRuleWithContext(ctx context.Context, request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)

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 (*Client) DeleteTarget

func (c *Client) DeleteTarget(request *DeleteTargetRequest) (response *DeleteTargetResponse, err error)

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 (*Client) DeleteTargetWithContext

func (c *Client) DeleteTargetWithContext(ctx context.Context, request *DeleteTargetRequest) (response *DeleteTargetResponse, err error)

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 (*Client) DeleteTransformation

func (c *Client) DeleteTransformation(request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error)

DeleteTransformation 用于删除转换器

可能返回的错误码:

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) DeleteTransformationWithContext

func (c *Client) DeleteTransformationWithContext(ctx context.Context, request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error)

DeleteTransformation 用于删除转换器

可能返回的错误码:

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) DescribeLogTagValue added in v1.0.624

func (c *Client) DescribeLogTagValue(request *DescribeLogTagValueRequest) (response *DescribeLogTagValueResponse, err error)

DescribeLogTagValue 前置条件:需开启事件存储;事件查询维度值

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) DescribeLogTagValueWithContext added in v1.0.624

func (c *Client) DescribeLogTagValueWithContext(ctx context.Context, request *DescribeLogTagValueRequest) (response *DescribeLogTagValueResponse, err error)

DescribeLogTagValue 前置条件:需开启事件存储;事件查询维度值

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) GetEventBus

func (c *Client) GetEventBus(request *GetEventBusRequest) (response *GetEventBusResponse, err error)

GetEventBus 获取事件集详情

可能返回的错误码:

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) GetEventBusWithContext

func (c *Client) GetEventBusWithContext(ctx context.Context, request *GetEventBusRequest) (response *GetEventBusResponse, err error)

GetEventBus 获取事件集详情

可能返回的错误码:

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) GetPlatformEventTemplate added in v1.0.744

func (c *Client) GetPlatformEventTemplate(request *GetPlatformEventTemplateRequest) (response *GetPlatformEventTemplateResponse, err error)

GetPlatformEventTemplate 获取平台产品事件模板

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"

func (*Client) GetPlatformEventTemplateWithContext added in v1.0.744

func (c *Client) GetPlatformEventTemplateWithContext(ctx context.Context, request *GetPlatformEventTemplateRequest) (response *GetPlatformEventTemplateResponse, err error)

GetPlatformEventTemplate 获取平台产品事件模板

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"

func (*Client) GetRule

func (c *Client) GetRule(request *GetRuleRequest) (response *GetRuleResponse, err error)

GetRule 获取事件规则详情

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) GetRuleWithContext

func (c *Client) GetRuleWithContext(ctx context.Context, request *GetRuleRequest) (response *GetRuleResponse, err error)

GetRule 获取事件规则详情

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"
RESOURCENOTFOUND_RULE = "ResourceNotFound.Rule"

func (*Client) GetTransformation

func (c *Client) GetTransformation(request *GetTransformationRequest) (response *GetTransformationResponse, err error)

GetTransformation 用于获取转换器详情

可能返回的错误码:

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) GetTransformationWithContext

func (c *Client) GetTransformationWithContext(ctx context.Context, request *GetTransformationRequest) (response *GetTransformationResponse, err error)

GetTransformation 用于获取转换器详情

可能返回的错误码:

INVALIDPARAMETERVALUE_EVENTBUSID = "InvalidParameterValue.EventBusId"
INVALIDPARAMETERVALUE_RULEID = "InvalidParameterValue.RuleId"
INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND = "ResourceNotFound"
RESOURCENOTFOUND_TRANSFORMATION = "ResourceNotFound.Transformation"

func (*Client) ListConnections

func (c *Client) ListConnections(request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)

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 (*Client) ListConnectionsWithContext

func (c *Client) ListConnectionsWithContext(ctx context.Context, request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)

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 (*Client) ListEventBuses

func (c *Client) ListEventBuses(request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)

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 (*Client) ListEventBusesWithContext

func (c *Client) ListEventBusesWithContext(ctx context.Context, request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)

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 (*Client) ListPlatformEventNames added in v1.0.744

func (c *Client) ListPlatformEventNames(request *ListPlatformEventNamesRequest) (response *ListPlatformEventNamesResponse, err error)

ListPlatformEventNames 获取平台产品事件名称

可能返回的错误码:

INTERNALERROR = "InternalError"

func (*Client) ListPlatformEventNamesWithContext added in v1.0.744

func (c *Client) ListPlatformEventNamesWithContext(ctx context.Context, request *ListPlatformEventNamesRequest) (response *ListPlatformEventNamesResponse, err error)

ListPlatformEventNames 获取平台产品事件名称

可能返回的错误码:

INTERNALERROR = "InternalError"

func (*Client) ListPlatformEventPatterns added in v1.0.744

func (c *Client) ListPlatformEventPatterns(request *ListPlatformEventPatternsRequest) (response *ListPlatformEventPatternsResponse, err error)

ListPlatformEventPatterns 获取平台产品事件匹配规则

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"

func (*Client) ListPlatformEventPatternsWithContext added in v1.0.744

func (c *Client) ListPlatformEventPatternsWithContext(ctx context.Context, request *ListPlatformEventPatternsRequest) (response *ListPlatformEventPatternsResponse, err error)

ListPlatformEventPatterns 获取平台产品事件匹配规则

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"

func (*Client) ListPlatformProducts added in v1.0.744

func (c *Client) ListPlatformProducts(request *ListPlatformProductsRequest) (response *ListPlatformProductsResponse, err error)

ListPlatformProducts 获取平台产品列表

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"

func (*Client) ListPlatformProductsWithContext added in v1.0.744

func (c *Client) ListPlatformProductsWithContext(ctx context.Context, request *ListPlatformProductsRequest) (response *ListPlatformProductsResponse, err error)

ListPlatformProducts 获取平台产品列表

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"

func (*Client) ListRules

func (c *Client) ListRules(request *ListRulesRequest) (response *ListRulesResponse, err error)

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 (*Client) ListRulesWithContext

func (c *Client) ListRulesWithContext(ctx context.Context, request *ListRulesRequest) (response *ListRulesResponse, err error)

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 (*Client) ListTargets

func (c *Client) ListTargets(request *ListTargetsRequest) (response *ListTargetsResponse, err error)

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 (*Client) ListTargetsWithContext

func (c *Client) ListTargetsWithContext(ctx context.Context, request *ListTargetsRequest) (response *ListTargetsResponse, err error)

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 (*Client) PublishEvent

func (c *Client) PublishEvent(request *PublishEventRequest) (response *PublishEventResponse, err error)

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 (*Client) PublishEventWithContext

func (c *Client) PublishEventWithContext(ctx context.Context, request *PublishEventRequest) (response *PublishEventResponse, err error)

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 (*Client) PutEvents added in v1.0.334

func (c *Client) PutEvents(request *PutEventsRequest) (response *PutEventsResponse, err error)

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 (*Client) PutEventsWithContext added in v1.0.334

func (c *Client) PutEventsWithContext(ctx context.Context, request *PutEventsRequest) (response *PutEventsResponse, err error)

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 (*Client) SearchLog added in v1.0.624

func (c *Client) SearchLog(request *SearchLogRequest) (response *SearchLogResponse, err error)

SearchLog 前置条件:开启事件存储;查询历史推送事件

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) SearchLogWithContext added in v1.0.624

func (c *Client) SearchLogWithContext(ctx context.Context, request *SearchLogRequest) (response *SearchLogResponse, err error)

SearchLog 前置条件:开启事件存储;查询历史推送事件

可能返回的错误码:

INTERNALERROR = "InternalError"
INVALIDPARAMETERVALUE_ACTION = "InvalidParameterValue.Action"
RESOURCENOTFOUND = "ResourceNotFound"

func (*Client) UpdateConnection

func (c *Client) UpdateConnection(request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)

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 (*Client) UpdateConnectionWithContext

func (c *Client) UpdateConnectionWithContext(ctx context.Context, request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)

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 (*Client) UpdateEventBus

func (c *Client) UpdateEventBus(request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)

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 (*Client) UpdateEventBusWithContext

func (c *Client) UpdateEventBusWithContext(ctx context.Context, request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)

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 (*Client) UpdateRule

func (c *Client) UpdateRule(request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)

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 (*Client) UpdateRuleWithContext

func (c *Client) UpdateRuleWithContext(ctx context.Context, request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)

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 (*Client) UpdateTarget

func (c *Client) UpdateTarget(request *UpdateTargetRequest) (response *UpdateTargetResponse, err error)

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 (*Client) UpdateTargetWithContext

func (c *Client) UpdateTargetWithContext(ctx context.Context, request *UpdateTargetRequest) (response *UpdateTargetResponse, err error)

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 (*Client) UpdateTransformation

func (c *Client) UpdateTransformation(request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error)

UpdateTransformation 用于更新转换器

可能返回的错误码:

INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

func (*Client) UpdateTransformationWithContext

func (c *Client) UpdateTransformationWithContext(ctx context.Context, request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error)

UpdateTransformation 用于更新转换器

可能返回的错误码:

INVALIDPARAMETERVALUE_TRANSFORMATIONID = "InvalidParameterValue.TransformationID"
RESOURCENOTFOUND_EVENTBUS = "ResourceNotFound.EventBus"

type Connection

type Connection struct {
	// 状态
	Status *string `json:"Status,omitnil,omitempty" name:"Status"`

	// 更新时间
	ModTime *string `json:"ModTime,omitnil,omitempty" name:"ModTime"`

	// 使能开关
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 创建时间
	AddTime *string `json:"AddTime,omitnil,omitempty" name:"AddTime"`

	// 连接器ID
	ConnectionId *string `json:"ConnectionId,omitnil,omitempty" name:"ConnectionId"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 连接器描述
	ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitnil,omitempty" name:"ConnectionDescription"`

	// 连接器名称
	ConnectionName *string `json:"ConnectionName,omitnil,omitempty" name:"ConnectionName"`

	// 类型
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`
}

type ConnectionBrief added in v1.0.604

type ConnectionBrief struct {
	// 连接器类型
	// 注意:此字段可能返回 null,表示取不到有效值。
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 连接器状态
	// 注意:此字段可能返回 null,表示取不到有效值。
	Status *string `json:"Status,omitnil,omitempty" name:"Status"`
}

type ConnectionDescription

type ConnectionDescription struct {
	// 资源qcs六段式,更多参考 [资源六段式](https://cloud.tencent.com/document/product/598/10606)
	ResourceDescription *string `json:"ResourceDescription,omitnil,omitempty" name:"ResourceDescription"`

	// apigw参数
	// 注意:此字段可能返回 null,表示取不到有效值。
	APIGWParams *APIGWParams `json:"APIGWParams,omitnil,omitempty" name:"APIGWParams"`

	// ckafka参数
	// 注意:此字段可能返回 null,表示取不到有效值。
	CkafkaParams *CkafkaParams `json:"CkafkaParams,omitnil,omitempty" name:"CkafkaParams"`

	// data transfer service (DTS)参数
	// 注意:此字段可能返回 null,表示取不到有效值。
	DTSParams *DTSParams `json:"DTSParams,omitnil,omitempty" name:"DTSParams"`

	// tdmq参数
	// 注意:此字段可能返回 null,表示取不到有效值。
	TDMQParams *TDMQParams `json:"TDMQParams,omitnil,omitempty" name:"TDMQParams"`
}

type CreateConnectionRequest

type CreateConnectionRequest struct {
	*tchttp.BaseRequest

	// 连接器描述
	ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitnil,omitempty" name:"ConnectionDescription"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 连接器名称
	ConnectionName *string `json:"ConnectionName,omitnil,omitempty" name:"ConnectionName"`

	// 描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 使能开关
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 连接器类型,目前支持以下类型:apigw/ckafka/dts/tdmq
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`
}

func NewCreateConnectionRequest

func NewCreateConnectionRequest() (request *CreateConnectionRequest)

func (*CreateConnectionRequest) FromJsonString

func (r *CreateConnectionRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateConnectionRequest) ToJsonString

func (r *CreateConnectionRequest) ToJsonString() string

type CreateConnectionRequestParams added in v1.0.426

type CreateConnectionRequestParams struct {
	// 连接器描述
	ConnectionDescription *ConnectionDescription `json:"ConnectionDescription,omitnil,omitempty" name:"ConnectionDescription"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 连接器名称
	ConnectionName *string `json:"ConnectionName,omitnil,omitempty" name:"ConnectionName"`

	// 描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 使能开关
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 连接器类型,目前支持以下类型:apigw/ckafka/dts/tdmq
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`
}

Predefined struct for user

type CreateConnectionResponse

type CreateConnectionResponse struct {
	*tchttp.BaseResponse
	Response *CreateConnectionResponseParams `json:"Response"`
}

func NewCreateConnectionResponse

func NewCreateConnectionResponse() (response *CreateConnectionResponse)

func (*CreateConnectionResponse) FromJsonString

func (r *CreateConnectionResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateConnectionResponse) ToJsonString

func (r *CreateConnectionResponse) ToJsonString() string

type CreateConnectionResponseParams added in v1.0.426

type CreateConnectionResponseParams struct {
	// 连接器ID
	ConnectionId *string `json:"ConnectionId,omitnil,omitempty" name:"ConnectionId"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateEventBusRequest

type CreateEventBusRequest struct {
	*tchttp.BaseRequest

	// 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	EventBusName *string `json:"EventBusName,omitnil,omitempty" name:"EventBusName"`

	// 事件集描述,不限字符类型,200字符描述以内
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// EB存储时长
	SaveDays *int64 `json:"SaveDays,omitnil,omitempty" name:"SaveDays"`

	// EB是否开启存储
	EnableStore *bool `json:"EnableStore,omitnil,omitempty" name:"EnableStore"`
}

func NewCreateEventBusRequest

func NewCreateEventBusRequest() (request *CreateEventBusRequest)

func (*CreateEventBusRequest) FromJsonString

func (r *CreateEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEventBusRequest) ToJsonString

func (r *CreateEventBusRequest) ToJsonString() string

type CreateEventBusRequestParams added in v1.0.426

type CreateEventBusRequestParams struct {
	// 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	EventBusName *string `json:"EventBusName,omitnil,omitempty" name:"EventBusName"`

	// 事件集描述,不限字符类型,200字符描述以内
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// EB存储时长
	SaveDays *int64 `json:"SaveDays,omitnil,omitempty" name:"SaveDays"`

	// EB是否开启存储
	EnableStore *bool `json:"EnableStore,omitnil,omitempty" name:"EnableStore"`
}

Predefined struct for user

type CreateEventBusResponse

type CreateEventBusResponse struct {
	*tchttp.BaseResponse
	Response *CreateEventBusResponseParams `json:"Response"`
}

func NewCreateEventBusResponse

func NewCreateEventBusResponse() (response *CreateEventBusResponse)

func (*CreateEventBusResponse) FromJsonString

func (r *CreateEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateEventBusResponse) ToJsonString

func (r *CreateEventBusResponse) ToJsonString() string

type CreateEventBusResponseParams added in v1.0.426

type CreateEventBusResponseParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateRuleRequest

type CreateRuleRequest struct {
	*tchttp.BaseRequest

	// 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084)
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`

	// 事件集ID。
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	RuleName *string `json:"RuleName,omitnil,omitempty" name:"RuleName"`

	// 使能开关。
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 事件集描述,不限字符类型,200字符描述以内
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`
}

func NewCreateRuleRequest

func NewCreateRuleRequest() (request *CreateRuleRequest)

func (*CreateRuleRequest) FromJsonString

func (r *CreateRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRuleRequest) ToJsonString

func (r *CreateRuleRequest) ToJsonString() string

type CreateRuleRequestParams added in v1.0.426

type CreateRuleRequestParams struct {
	// 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084)
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`

	// 事件集ID。
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	RuleName *string `json:"RuleName,omitnil,omitempty" name:"RuleName"`

	// 使能开关。
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 事件集描述,不限字符类型,200字符描述以内
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`
}

Predefined struct for user

type CreateRuleResponse

type CreateRuleResponse struct {
	*tchttp.BaseResponse
	Response *CreateRuleResponseParams `json:"Response"`
}

func NewCreateRuleResponse

func NewCreateRuleResponse() (response *CreateRuleResponse)

func (*CreateRuleResponse) FromJsonString

func (r *CreateRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateRuleResponse) ToJsonString

func (r *CreateRuleResponse) ToJsonString() string

type CreateRuleResponseParams added in v1.0.426

type CreateRuleResponseParams struct {
	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateTargetRequest

type CreateTargetRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 目标类型;取值范围:scf(云函数)/cls(日志服务)/amp(消息推送)/ckafka(消息推送)/es(大数据elastic-search)
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 目标描述;scf类型示例:
	// {"ResourceDescription":"qcs::scf:ap-guangzhou:uin/2252646423:namespace/default/function/john-test-0326/$LATEST"};
	// cls类型示例:
	// {"ResourceDescription":"qcs::cls:ap-guangzhou:uin/12323442323:topic/7103f705-6c38-4b64-ac9d-428af0f2e732"}
	// ckafka类型示例:
	// {"ResourceDescription":"qcs::ckafka:ap-guangzhou:uin/1500000688:ckafkaId/uin/1500000688/ckafka-018q1nwj","CkafkaTargetParams":{"TopicName":"alert","RetryPolicy":{"RetryInterval":60,"MaxRetryAttempts":360}}}
	// amp类型-邮件/短信示例:
	// {"ResourceDescription":"qcs::eb-amp:ap-guangzhou:uin/100012505002:","AMPParams":{"NotificationTemplateId":10181,"Lang":"cn","NoticeReceivers":[{"UserType":"User","UserIds":["9424525"],"TimeWindow":{"From":"09:30:00","To":"23:30:00"},"Channels":["Email","SMS"]}]}}
	// es类型示例:
	// {"ResourceDescription":"qcs::es:ap-guangzhou:uin/1500000688:instance/es-7cplmhsd","ESTargetParams":{"EsVersion":"7.14.2","UserName":"elastic","Password":"xxxxx","NetMode":"privateLink","IndexPrefix":"auto-test","IndexSuffixMode":"default","RotationInterval":"none","IndexTemplateType":"","OutputMode":"default"}}
	TargetDescription *TargetDescription `json:"TargetDescription,omitnil,omitempty" name:"TargetDescription"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

func NewCreateTargetRequest

func NewCreateTargetRequest() (request *CreateTargetRequest)

func (*CreateTargetRequest) FromJsonString

func (r *CreateTargetRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTargetRequest) ToJsonString

func (r *CreateTargetRequest) ToJsonString() string

type CreateTargetRequestParams added in v1.0.426

type CreateTargetRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 目标类型;取值范围:scf(云函数)/cls(日志服务)/amp(消息推送)/ckafka(消息推送)/es(大数据elastic-search)
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 目标描述;scf类型示例:
	// {"ResourceDescription":"qcs::scf:ap-guangzhou:uin/2252646423:namespace/default/function/john-test-0326/$LATEST"};
	// cls类型示例:
	// {"ResourceDescription":"qcs::cls:ap-guangzhou:uin/12323442323:topic/7103f705-6c38-4b64-ac9d-428af0f2e732"}
	// ckafka类型示例:
	// {"ResourceDescription":"qcs::ckafka:ap-guangzhou:uin/1500000688:ckafkaId/uin/1500000688/ckafka-018q1nwj","CkafkaTargetParams":{"TopicName":"alert","RetryPolicy":{"RetryInterval":60,"MaxRetryAttempts":360}}}
	// amp类型-邮件/短信示例:
	// {"ResourceDescription":"qcs::eb-amp:ap-guangzhou:uin/100012505002:","AMPParams":{"NotificationTemplateId":10181,"Lang":"cn","NoticeReceivers":[{"UserType":"User","UserIds":["9424525"],"TimeWindow":{"From":"09:30:00","To":"23:30:00"},"Channels":["Email","SMS"]}]}}
	// es类型示例:
	// {"ResourceDescription":"qcs::es:ap-guangzhou:uin/1500000688:instance/es-7cplmhsd","ESTargetParams":{"EsVersion":"7.14.2","UserName":"elastic","Password":"xxxxx","NetMode":"privateLink","IndexPrefix":"auto-test","IndexSuffixMode":"default","RotationInterval":"none","IndexTemplateType":"","OutputMode":"default"}}
	TargetDescription *TargetDescription `json:"TargetDescription,omitnil,omitempty" name:"TargetDescription"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

Predefined struct for user

type CreateTargetResponse

type CreateTargetResponse struct {
	*tchttp.BaseResponse
	Response *CreateTargetResponseParams `json:"Response"`
}

func NewCreateTargetResponse

func NewCreateTargetResponse() (response *CreateTargetResponse)

func (*CreateTargetResponse) FromJsonString

func (r *CreateTargetResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTargetResponse) ToJsonString

func (r *CreateTargetResponse) ToJsonString() string

type CreateTargetResponseParams added in v1.0.426

type CreateTargetResponseParams struct {
	// 目标ID
	TargetId *string `json:"TargetId,omitnil,omitempty" name:"TargetId"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type CreateTransformationRequest

type CreateTransformationRequest struct {
	*tchttp.BaseRequest

	// 事件总线 id
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则id
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 一个转换规则列表,当前仅限定一个;示例如下:[{"Extraction":{"ExtractionInputPath":"$.data.payload","Format":"JSON"},"EtlFilter":{"Filter":"{\"source\":\"ckafka.cloud.tencent\"}"},"Transform":{"OutputStructs":[{"Key":"op","Value":"$.op","ValueType":"JSONPATH"},{"Key":"table","Value":"$.source.table","ValueType":"JSONPATH"},{"Key":"id","Value":"$.after.id","ValueType":"JSONPATH"},{"Key":"app_id","Value":"$.after.app_id","ValueType":"JSONPATH"},{"Key":"spu_id","Value":"$.after.spu_id","ValueType":"JSONPATH"}]}}]
	Transformations []*Transformation `json:"Transformations,omitnil,omitempty" name:"Transformations"`
}

func NewCreateTransformationRequest

func NewCreateTransformationRequest() (request *CreateTransformationRequest)

func (*CreateTransformationRequest) FromJsonString

func (r *CreateTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTransformationRequest) ToJsonString

func (r *CreateTransformationRequest) ToJsonString() string

type CreateTransformationRequestParams added in v1.0.426

type CreateTransformationRequestParams struct {
	// 事件总线 id
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则id
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 一个转换规则列表,当前仅限定一个;示例如下:[{"Extraction":{"ExtractionInputPath":"$.data.payload","Format":"JSON"},"EtlFilter":{"Filter":"{\"source\":\"ckafka.cloud.tencent\"}"},"Transform":{"OutputStructs":[{"Key":"op","Value":"$.op","ValueType":"JSONPATH"},{"Key":"table","Value":"$.source.table","ValueType":"JSONPATH"},{"Key":"id","Value":"$.after.id","ValueType":"JSONPATH"},{"Key":"app_id","Value":"$.after.app_id","ValueType":"JSONPATH"},{"Key":"spu_id","Value":"$.after.spu_id","ValueType":"JSONPATH"}]}}]
	Transformations []*Transformation `json:"Transformations,omitnil,omitempty" name:"Transformations"`
}

Predefined struct for user

type CreateTransformationResponse

type CreateTransformationResponse struct {
	*tchttp.BaseResponse
	Response *CreateTransformationResponseParams `json:"Response"`
}

func NewCreateTransformationResponse

func NewCreateTransformationResponse() (response *CreateTransformationResponse)

func (*CreateTransformationResponse) FromJsonString

func (r *CreateTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*CreateTransformationResponse) ToJsonString

func (r *CreateTransformationResponse) ToJsonString() string

type CreateTransformationResponseParams added in v1.0.426

type CreateTransformationResponseParams struct {
	// 生成的转换器id
	TransformationId *string `json:"TransformationId,omitnil,omitempty" name:"TransformationId"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DTSParams added in v1.0.604

type DTSParams struct {
	// Consumer Group Name
	ConsumerGroupName *string `json:"ConsumerGroupName,omitnil,omitempty" name:"ConsumerGroupName"`

	// 账户名
	Account *string `json:"Account,omitnil,omitempty" name:"Account"`

	// 密码
	// 注意:此字段可能返回 null,表示取不到有效值。
	Password *string `json:"Password,omitnil,omitempty" name:"Password"`
}

type DeadLetterConfig

type DeadLetterConfig struct {
	// 支持dlq、丢弃、忽略错误继续传递三种模式, 分别对应: DLQ,DROP,IGNORE_ERROR
	DisposeMethod *string `json:"DisposeMethod,omitnil,omitempty" name:"DisposeMethod"`

	// 设置了DLQ方式后,此选项必填. 错误消息会被投递到对应的kafka topic中
	// 注意:此字段可能返回 null,表示取不到有效值。
	CkafkaDeliveryParams *CkafkaDeliveryParams `json:"CkafkaDeliveryParams,omitnil,omitempty" name:"CkafkaDeliveryParams"`
}

type DeleteConnectionRequest

type DeleteConnectionRequest struct {
	*tchttp.BaseRequest

	// 连接器ID
	ConnectionId *string `json:"ConnectionId,omitnil,omitempty" name:"ConnectionId"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

func NewDeleteConnectionRequest

func NewDeleteConnectionRequest() (request *DeleteConnectionRequest)

func (*DeleteConnectionRequest) FromJsonString

func (r *DeleteConnectionRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteConnectionRequest) ToJsonString

func (r *DeleteConnectionRequest) ToJsonString() string

type DeleteConnectionRequestParams added in v1.0.426

type DeleteConnectionRequestParams struct {
	// 连接器ID
	ConnectionId *string `json:"ConnectionId,omitnil,omitempty" name:"ConnectionId"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

Predefined struct for user

type DeleteConnectionResponse

type DeleteConnectionResponse struct {
	*tchttp.BaseResponse
	Response *DeleteConnectionResponseParams `json:"Response"`
}

func NewDeleteConnectionResponse

func NewDeleteConnectionResponse() (response *DeleteConnectionResponse)

func (*DeleteConnectionResponse) FromJsonString

func (r *DeleteConnectionResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteConnectionResponse) ToJsonString

func (r *DeleteConnectionResponse) ToJsonString() string

type DeleteConnectionResponseParams added in v1.0.426

type DeleteConnectionResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteEventBusRequest

type DeleteEventBusRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

func NewDeleteEventBusRequest

func NewDeleteEventBusRequest() (request *DeleteEventBusRequest)

func (*DeleteEventBusRequest) FromJsonString

func (r *DeleteEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEventBusRequest) ToJsonString

func (r *DeleteEventBusRequest) ToJsonString() string

type DeleteEventBusRequestParams added in v1.0.426

type DeleteEventBusRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

Predefined struct for user

type DeleteEventBusResponse

type DeleteEventBusResponse struct {
	*tchttp.BaseResponse
	Response *DeleteEventBusResponseParams `json:"Response"`
}

func NewDeleteEventBusResponse

func NewDeleteEventBusResponse() (response *DeleteEventBusResponse)

func (*DeleteEventBusResponse) FromJsonString

func (r *DeleteEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteEventBusResponse) ToJsonString

func (r *DeleteEventBusResponse) ToJsonString() string

type DeleteEventBusResponseParams added in v1.0.426

type DeleteEventBusResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteRuleRequest

type DeleteRuleRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

func NewDeleteRuleRequest

func NewDeleteRuleRequest() (request *DeleteRuleRequest)

func (*DeleteRuleRequest) FromJsonString

func (r *DeleteRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRuleRequest) ToJsonString

func (r *DeleteRuleRequest) ToJsonString() string

type DeleteRuleRequestParams added in v1.0.426

type DeleteRuleRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

Predefined struct for user

type DeleteRuleResponse

type DeleteRuleResponse struct {
	*tchttp.BaseResponse
	Response *DeleteRuleResponseParams `json:"Response"`
}

func NewDeleteRuleResponse

func NewDeleteRuleResponse() (response *DeleteRuleResponse)

func (*DeleteRuleResponse) FromJsonString

func (r *DeleteRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteRuleResponse) ToJsonString

func (r *DeleteRuleResponse) ToJsonString() string

type DeleteRuleResponseParams added in v1.0.426

type DeleteRuleResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteTargetRequest

type DeleteTargetRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件目标ID
	TargetId *string `json:"TargetId,omitnil,omitempty" name:"TargetId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

func NewDeleteTargetRequest

func NewDeleteTargetRequest() (request *DeleteTargetRequest)

func (*DeleteTargetRequest) FromJsonString

func (r *DeleteTargetRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTargetRequest) ToJsonString

func (r *DeleteTargetRequest) ToJsonString() string

type DeleteTargetRequestParams added in v1.0.426

type DeleteTargetRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件目标ID
	TargetId *string `json:"TargetId,omitnil,omitempty" name:"TargetId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

Predefined struct for user

type DeleteTargetResponse

type DeleteTargetResponse struct {
	*tchttp.BaseResponse
	Response *DeleteTargetResponseParams `json:"Response"`
}

func NewDeleteTargetResponse

func NewDeleteTargetResponse() (response *DeleteTargetResponse)

func (*DeleteTargetResponse) FromJsonString

func (r *DeleteTargetResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTargetResponse) ToJsonString

func (r *DeleteTargetResponse) ToJsonString() string

type DeleteTargetResponseParams added in v1.0.426

type DeleteTargetResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DeleteTransformationRequest

type DeleteTransformationRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 转换器id
	TransformationId *string `json:"TransformationId,omitnil,omitempty" name:"TransformationId"`
}

func NewDeleteTransformationRequest

func NewDeleteTransformationRequest() (request *DeleteTransformationRequest)

func (*DeleteTransformationRequest) FromJsonString

func (r *DeleteTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTransformationRequest) ToJsonString

func (r *DeleteTransformationRequest) ToJsonString() string

type DeleteTransformationRequestParams added in v1.0.426

type DeleteTransformationRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 转换器id
	TransformationId *string `json:"TransformationId,omitnil,omitempty" name:"TransformationId"`
}

Predefined struct for user

type DeleteTransformationResponse

type DeleteTransformationResponse struct {
	*tchttp.BaseResponse
	Response *DeleteTransformationResponseParams `json:"Response"`
}

func NewDeleteTransformationResponse

func NewDeleteTransformationResponse() (response *DeleteTransformationResponse)

func (*DeleteTransformationResponse) FromJsonString

func (r *DeleteTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DeleteTransformationResponse) ToJsonString

func (r *DeleteTransformationResponse) ToJsonString() string

type DeleteTransformationResponseParams added in v1.0.426

type DeleteTransformationResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type DescribeLogTagValueRequest added in v1.0.624

type DescribeLogTagValueRequest struct {
	*tchttp.BaseRequest

	// 起始时间
	StartTime *int64 `json:"StartTime,omitnil,omitempty" name:"StartTime"`

	// 结束时间
	EndTime *int64 `json:"EndTime,omitnil,omitempty" name:"EndTime"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 聚合字段,取值范围如下:Source(事件源),RuleIds(命中规则),Subject(实例ID),Region(地域)
	GroupField *string `json:"GroupField,omitnil,omitempty" name:"GroupField"`

	// 页数
	Page *int64 `json:"Page,omitnil,omitempty" name:"Page"`

	// 每页数据大小
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 筛选条件
	Filter []*LogFilter `json:"Filter,omitnil,omitempty" name:"Filter"`
}

func NewDescribeLogTagValueRequest added in v1.0.624

func NewDescribeLogTagValueRequest() (request *DescribeLogTagValueRequest)

func (*DescribeLogTagValueRequest) FromJsonString added in v1.0.624

func (r *DescribeLogTagValueRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeLogTagValueRequest) ToJsonString added in v1.0.624

func (r *DescribeLogTagValueRequest) ToJsonString() string

type DescribeLogTagValueRequestParams added in v1.0.624

type DescribeLogTagValueRequestParams struct {
	// 起始时间
	StartTime *int64 `json:"StartTime,omitnil,omitempty" name:"StartTime"`

	// 结束时间
	EndTime *int64 `json:"EndTime,omitnil,omitempty" name:"EndTime"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 聚合字段,取值范围如下:Source(事件源),RuleIds(命中规则),Subject(实例ID),Region(地域)
	GroupField *string `json:"GroupField,omitnil,omitempty" name:"GroupField"`

	// 页数
	Page *int64 `json:"Page,omitnil,omitempty" name:"Page"`

	// 每页数据大小
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 筛选条件
	Filter []*LogFilter `json:"Filter,omitnil,omitempty" name:"Filter"`
}

Predefined struct for user

type DescribeLogTagValueResponse added in v1.0.624

type DescribeLogTagValueResponse struct {
	*tchttp.BaseResponse
	Response *DescribeLogTagValueResponseParams `json:"Response"`
}

func NewDescribeLogTagValueResponse added in v1.0.624

func NewDescribeLogTagValueResponse() (response *DescribeLogTagValueResponse)

func (*DescribeLogTagValueResponse) FromJsonString added in v1.0.624

func (r *DescribeLogTagValueResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*DescribeLogTagValueResponse) ToJsonString added in v1.0.624

func (r *DescribeLogTagValueResponse) ToJsonString() string

type DescribeLogTagValueResponseParams added in v1.0.624

type DescribeLogTagValueResponseParams struct {
	// 事件查询维度值结果
	// 注意:此字段可能返回 null,表示取不到有效值。
	Results []*string `json:"Results,omitnil,omitempty" name:"Results"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ESTargetParams added in v1.0.432

type ESTargetParams struct {
	// 网络连接类型
	NetMode *string `json:"NetMode,omitnil,omitempty" name:"NetMode"`

	// 索引前缀
	IndexPrefix *string `json:"IndexPrefix,omitnil,omitempty" name:"IndexPrefix"`

	// es日志轮换粒度
	RotationInterval *string `json:"RotationInterval,omitnil,omitempty" name:"RotationInterval"`

	// DTS事件配置
	OutputMode *string `json:"OutputMode,omitnil,omitempty" name:"OutputMode"`

	// DTS索引配置
	IndexSuffixMode *string `json:"IndexSuffixMode,omitnil,omitempty" name:"IndexSuffixMode"`

	// es模版类型
	IndexTemplateType *string `json:"IndexTemplateType,omitnil,omitempty" name:"IndexTemplateType"`
}

type EtlFilter

type EtlFilter struct {
	// 语法Rule规则保持一致
	Filter *string `json:"Filter,omitnil,omitempty" name:"Filter"`
}

type Event

type Event struct {
	// 事件源的信息,新产品上报必须符合EB的规范
	Source *string `json:"Source,omitnil,omitempty" name:"Source"`

	// 事件数据,内容由创建事件的系统来控制,当前datacontenttype仅支持application/json;charset=utf-8,所以该字段是json字符串
	Data *string `json:"Data,omitnil,omitempty" name:"Data"`

	// 事件类型,可自定义,选填。云服务默认写 COS:Created:PostObject,用“:”分割类型字段
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 事件来源详细描述,可自定义,选填。云服务默认为标准qcs资源表示语法:qcs::dts:ap-guangzhou:appid/uin:xxx
	Subject *string `json:"Subject,omitnil,omitempty" name:"Subject"`

	// 事件发生的毫秒时间戳,
	// time.Now().UnixNano()/1e6
	Time *int64 `json:"Time,omitnil,omitempty" name:"Time"`

	// 事件的地域信息,没有则默认是EB所在的地域信息
	Region *string `json:"Region,omitnil,omitempty" name:"Region"`

	// 用于描述事件状态,非必须,默认是""
	Status *string `json:"Status,omitnil,omitempty" name:"Status"`

	// 事件的唯一id,用户侧主动上传则需要保证风格一致
	Id *string `json:"Id,omitnil,omitempty" name:"Id"`

	// 标签列表
	TagList []*Tag `json:"TagList,omitnil,omitempty" name:"TagList"`
}

type EventBus

type EventBus struct {
	// 更新时间
	ModTime *string `json:"ModTime,omitnil,omitempty" name:"ModTime"`

	// 事件集描述,不限字符类型,200字符描述以内
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 创建时间
	AddTime *string `json:"AddTime,omitnil,omitempty" name:"AddTime"`

	// 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	EventBusName *string `json:"EventBusName,omitnil,omitempty" name:"EventBusName"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件集类型
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 计费模式
	// 注意:此字段可能返回 null,表示取不到有效值。
	PayMode *string `json:"PayMode,omitnil,omitempty" name:"PayMode"`

	// 连接器基础信息
	// 注意:此字段可能返回 null,表示取不到有效值。
	ConnectionBriefs []*ConnectionBrief `json:"ConnectionBriefs,omitnil,omitempty" name:"ConnectionBriefs"`

	// 目标简要信息
	// 注意:此字段可能返回 null,表示取不到有效值。
	TargetBriefs []*TargetBrief `json:"TargetBriefs,omitnil,omitempty" name:"TargetBriefs"`
}

type Extraction

type Extraction struct {
	// JsonPath, 不指定则使用默认值$.
	ExtractionInputPath *string `json:"ExtractionInputPath,omitnil,omitempty" name:"ExtractionInputPath"`

	// 取值: TEXT/JSON
	Format *string `json:"Format,omitnil,omitempty" name:"Format"`

	// 仅在Text需要传递
	// 注意:此字段可能返回 null,表示取不到有效值。
	TextParams *TextParams `json:"TextParams,omitnil,omitempty" name:"TextParams"`
}

type Filter

type Filter struct {
	// 一个或者多个过滤值。
	Values []*string `json:"Values,omitnil,omitempty" name:"Values"`

	// 过滤键的名称。EventBusName(事件集名称)/EventBusId(事件集Id)/Type(事件集类型:Cloud(云服务);Platform(平台型);Custom(自定义))/TagKey(标签键)
	Name *string `json:"Name,omitnil,omitempty" name:"Name"`
}

type GetEventBusRequest

type GetEventBusRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

func NewGetEventBusRequest

func NewGetEventBusRequest() (request *GetEventBusRequest)

func (*GetEventBusRequest) FromJsonString

func (r *GetEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetEventBusRequest) ToJsonString

func (r *GetEventBusRequest) ToJsonString() string

type GetEventBusRequestParams added in v1.0.426

type GetEventBusRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

Predefined struct for user

type GetEventBusResponse

type GetEventBusResponse struct {
	*tchttp.BaseResponse
	Response *GetEventBusResponseParams `json:"Response"`
}

func NewGetEventBusResponse

func NewGetEventBusResponse() (response *GetEventBusResponse)

func (*GetEventBusResponse) FromJsonString

func (r *GetEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetEventBusResponse) ToJsonString

func (r *GetEventBusResponse) ToJsonString() string

type GetEventBusResponseParams added in v1.0.426

type GetEventBusResponseParams struct {
	// 更新时间
	ModTime *string `json:"ModTime,omitnil,omitempty" name:"ModTime"`

	// 事件集描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 日志主题ID
	ClsTopicId *string `json:"ClsTopicId,omitnil,omitempty" name:"ClsTopicId"`

	// 创建时间
	AddTime *string `json:"AddTime,omitnil,omitempty" name:"AddTime"`

	// 日志集ID
	ClsLogsetId *string `json:"ClsLogsetId,omitnil,omitempty" name:"ClsLogsetId"`

	// 事件集名称
	EventBusName *string `json:"EventBusName,omitnil,omitempty" name:"EventBusName"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// (已废弃)事件集类型
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 计费模式
	PayMode *string `json:"PayMode,omitnil,omitempty" name:"PayMode"`

	// EB日志存储时长
	// 注意:此字段可能返回 null,表示取不到有效值。
	SaveDays *int64 `json:"SaveDays,omitnil,omitempty" name:"SaveDays"`

	// EB日志主题ID
	// 注意:此字段可能返回 null,表示取不到有效值。
	LogTopicId *string `json:"LogTopicId,omitnil,omitempty" name:"LogTopicId"`

	// 是否开启存储
	// 注意:此字段可能返回 null,表示取不到有效值。
	EnableStore *bool `json:"EnableStore,omitnil,omitempty" name:"EnableStore"`

	// 消息序列,是否有序
	// 注意:此字段可能返回 null,表示取不到有效值。
	LinkMode *string `json:"LinkMode,omitnil,omitempty" name:"LinkMode"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type GetPlatformEventTemplateRequest added in v1.0.744

type GetPlatformEventTemplateRequest struct {
	*tchttp.BaseRequest

	// 平台产品事件类型
	EventType *string `json:"EventType,omitnil,omitempty" name:"EventType"`
}

func NewGetPlatformEventTemplateRequest added in v1.0.744

func NewGetPlatformEventTemplateRequest() (request *GetPlatformEventTemplateRequest)

func (*GetPlatformEventTemplateRequest) FromJsonString added in v1.0.744

func (r *GetPlatformEventTemplateRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetPlatformEventTemplateRequest) ToJsonString added in v1.0.744

func (r *GetPlatformEventTemplateRequest) ToJsonString() string

type GetPlatformEventTemplateRequestParams added in v1.0.744

type GetPlatformEventTemplateRequestParams struct {
	// 平台产品事件类型
	EventType *string `json:"EventType,omitnil,omitempty" name:"EventType"`
}

Predefined struct for user

type GetPlatformEventTemplateResponse added in v1.0.744

type GetPlatformEventTemplateResponse struct {
	*tchttp.BaseResponse
	Response *GetPlatformEventTemplateResponseParams `json:"Response"`
}

func NewGetPlatformEventTemplateResponse added in v1.0.744

func NewGetPlatformEventTemplateResponse() (response *GetPlatformEventTemplateResponse)

func (*GetPlatformEventTemplateResponse) FromJsonString added in v1.0.744

func (r *GetPlatformEventTemplateResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetPlatformEventTemplateResponse) ToJsonString added in v1.0.744

func (r *GetPlatformEventTemplateResponse) ToJsonString() string

type GetPlatformEventTemplateResponseParams added in v1.0.744

type GetPlatformEventTemplateResponseParams struct {
	// 平台产品事件模板
	EventTemplate *string `json:"EventTemplate,omitnil,omitempty" name:"EventTemplate"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type GetRuleRequest

type GetRuleRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

func NewGetRuleRequest

func NewGetRuleRequest() (request *GetRuleRequest)

func (*GetRuleRequest) FromJsonString

func (r *GetRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetRuleRequest) ToJsonString

func (r *GetRuleRequest) ToJsonString() string

type GetRuleRequestParams added in v1.0.426

type GetRuleRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`
}

Predefined struct for user

type GetRuleResponse

type GetRuleResponse struct {
	*tchttp.BaseResponse
	Response *GetRuleResponseParams `json:"Response"`
}

func NewGetRuleResponse

func NewGetRuleResponse() (response *GetRuleResponse)

func (*GetRuleResponse) FromJsonString

func (r *GetRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetRuleResponse) ToJsonString

func (r *GetRuleResponse) ToJsonString() string

type GetRuleResponseParams added in v1.0.426

type GetRuleResponseParams struct {
	// 事件集id
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件规则id
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 事件规则名称
	RuleName *string `json:"RuleName,omitnil,omitempty" name:"RuleName"`

	// 事件规则状态
	Status *string `json:"Status,omitnil,omitempty" name:"Status"`

	// 使能开关
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 事件规则描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 事件模式
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`

	// 创建时间
	AddTime *string `json:"AddTime,omitnil,omitempty" name:"AddTime"`

	// 更新时间
	ModTime *string `json:"ModTime,omitnil,omitempty" name:"ModTime"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type GetTransformationRequest

type GetTransformationRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 转换器id
	TransformationId *string `json:"TransformationId,omitnil,omitempty" name:"TransformationId"`
}

func NewGetTransformationRequest

func NewGetTransformationRequest() (request *GetTransformationRequest)

func (*GetTransformationRequest) FromJsonString

func (r *GetTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetTransformationRequest) ToJsonString

func (r *GetTransformationRequest) ToJsonString() string

type GetTransformationRequestParams added in v1.0.426

type GetTransformationRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 转换器id
	TransformationId *string `json:"TransformationId,omitnil,omitempty" name:"TransformationId"`
}

Predefined struct for user

type GetTransformationResponse

type GetTransformationResponse struct {
	*tchttp.BaseResponse
	Response *GetTransformationResponseParams `json:"Response"`
}

func NewGetTransformationResponse

func NewGetTransformationResponse() (response *GetTransformationResponse)

func (*GetTransformationResponse) FromJsonString

func (r *GetTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*GetTransformationResponse) ToJsonString

func (r *GetTransformationResponse) ToJsonString() string

type GetTransformationResponseParams added in v1.0.426

type GetTransformationResponseParams struct {
	// 转换规则列表
	Transformations []*Transformation `json:"Transformations,omitnil,omitempty" name:"Transformations"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListConnectionsRequest

type ListConnectionsRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 根据哪个字段进行返回结果排序,目前支持如下以下字段:AddTime, ModTime
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 以升序还是降序的方式返回结果,可选值 ASC 和 DESC
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`

	// 偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`
}

func NewListConnectionsRequest

func NewListConnectionsRequest() (request *ListConnectionsRequest)

func (*ListConnectionsRequest) FromJsonString

func (r *ListConnectionsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListConnectionsRequest) ToJsonString

func (r *ListConnectionsRequest) ToJsonString() string

type ListConnectionsRequestParams added in v1.0.426

type ListConnectionsRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 根据哪个字段进行返回结果排序,目前支持如下以下字段:AddTime, ModTime
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 以升序还是降序的方式返回结果,可选值 ASC 和 DESC
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`

	// 偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`
}

Predefined struct for user

type ListConnectionsResponse

type ListConnectionsResponse struct {
	*tchttp.BaseResponse
	Response *ListConnectionsResponseParams `json:"Response"`
}

func NewListConnectionsResponse

func NewListConnectionsResponse() (response *ListConnectionsResponse)

func (*ListConnectionsResponse) FromJsonString

func (r *ListConnectionsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListConnectionsResponse) ToJsonString

func (r *ListConnectionsResponse) ToJsonString() string

type ListConnectionsResponseParams added in v1.0.426

type ListConnectionsResponseParams struct {
	// 连接器信息
	Connections []*Connection `json:"Connections,omitnil,omitempty" name:"Connections"`

	// 连接器总数
	TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListEventBusesRequest

type ListEventBusesRequest struct {
	*tchttp.BaseRequest

	// 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间)
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序)
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`

	// 过滤字段范围: EventBusName(事件集名称)/EventBusId(事件集Id)/Type(事件集类型:Cloud(云服务);Platform(平台型);Custom(自定义))/TagKey(标签键)。每次请求的Filters的上限为10,Filter.Values的上限为5。[{"Name":"Type","Values":["Cloud","Platform"]}]
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`

	// 分页偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`
}

func NewListEventBusesRequest

func NewListEventBusesRequest() (request *ListEventBusesRequest)

func (*ListEventBusesRequest) FromJsonString

func (r *ListEventBusesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListEventBusesRequest) ToJsonString

func (r *ListEventBusesRequest) ToJsonString() string

type ListEventBusesRequestParams added in v1.0.426

type ListEventBusesRequestParams struct {
	// 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间)
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序)
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`

	// 过滤字段范围: EventBusName(事件集名称)/EventBusId(事件集Id)/Type(事件集类型:Cloud(云服务);Platform(平台型);Custom(自定义))/TagKey(标签键)。每次请求的Filters的上限为10,Filter.Values的上限为5。[{"Name":"Type","Values":["Cloud","Platform"]}]
	Filters []*Filter `json:"Filters,omitnil,omitempty" name:"Filters"`

	// 分页偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`
}

Predefined struct for user

type ListEventBusesResponse

type ListEventBusesResponse struct {
	*tchttp.BaseResponse
	Response *ListEventBusesResponseParams `json:"Response"`
}

func NewListEventBusesResponse

func NewListEventBusesResponse() (response *ListEventBusesResponse)

func (*ListEventBusesResponse) FromJsonString

func (r *ListEventBusesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListEventBusesResponse) ToJsonString

func (r *ListEventBusesResponse) ToJsonString() string

type ListEventBusesResponseParams added in v1.0.426

type ListEventBusesResponseParams struct {
	// 事件集信息
	EventBuses []*EventBus `json:"EventBuses,omitnil,omitempty" name:"EventBuses"`

	// 事件集总数
	TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListPlatformEventNamesRequest added in v1.0.744

type ListPlatformEventNamesRequest struct {
	*tchttp.BaseRequest

	// 平台产品类型
	ProductType *string `json:"ProductType,omitnil,omitempty" name:"ProductType"`
}

func NewListPlatformEventNamesRequest added in v1.0.744

func NewListPlatformEventNamesRequest() (request *ListPlatformEventNamesRequest)

func (*ListPlatformEventNamesRequest) FromJsonString added in v1.0.744

func (r *ListPlatformEventNamesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListPlatformEventNamesRequest) ToJsonString added in v1.0.744

func (r *ListPlatformEventNamesRequest) ToJsonString() string

type ListPlatformEventNamesRequestParams added in v1.0.744

type ListPlatformEventNamesRequestParams struct {
	// 平台产品类型
	ProductType *string `json:"ProductType,omitnil,omitempty" name:"ProductType"`
}

Predefined struct for user

type ListPlatformEventNamesResponse added in v1.0.744

type ListPlatformEventNamesResponse struct {
	*tchttp.BaseResponse
	Response *ListPlatformEventNamesResponseParams `json:"Response"`
}

func NewListPlatformEventNamesResponse added in v1.0.744

func NewListPlatformEventNamesResponse() (response *ListPlatformEventNamesResponse)

func (*ListPlatformEventNamesResponse) FromJsonString added in v1.0.744

func (r *ListPlatformEventNamesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListPlatformEventNamesResponse) ToJsonString added in v1.0.744

func (r *ListPlatformEventNamesResponse) ToJsonString() string

type ListPlatformEventNamesResponseParams added in v1.0.744

type ListPlatformEventNamesResponseParams struct {
	// 平台产品列表
	EventNames []*PlatformEventDetail `json:"EventNames,omitnil,omitempty" name:"EventNames"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListPlatformEventPatternsRequest added in v1.0.744

type ListPlatformEventPatternsRequest struct {
	*tchttp.BaseRequest

	// 平台产品类型
	ProductType *string `json:"ProductType,omitnil,omitempty" name:"ProductType"`
}

func NewListPlatformEventPatternsRequest added in v1.0.744

func NewListPlatformEventPatternsRequest() (request *ListPlatformEventPatternsRequest)

func (*ListPlatformEventPatternsRequest) FromJsonString added in v1.0.744

func (r *ListPlatformEventPatternsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListPlatformEventPatternsRequest) ToJsonString added in v1.0.744

func (r *ListPlatformEventPatternsRequest) ToJsonString() string

type ListPlatformEventPatternsRequestParams added in v1.0.744

type ListPlatformEventPatternsRequestParams struct {
	// 平台产品类型
	ProductType *string `json:"ProductType,omitnil,omitempty" name:"ProductType"`
}

Predefined struct for user

type ListPlatformEventPatternsResponse added in v1.0.744

type ListPlatformEventPatternsResponse struct {
	*tchttp.BaseResponse
	Response *ListPlatformEventPatternsResponseParams `json:"Response"`
}

func NewListPlatformEventPatternsResponse added in v1.0.744

func NewListPlatformEventPatternsResponse() (response *ListPlatformEventPatternsResponse)

func (*ListPlatformEventPatternsResponse) FromJsonString added in v1.0.744

func (r *ListPlatformEventPatternsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListPlatformEventPatternsResponse) ToJsonString added in v1.0.744

func (r *ListPlatformEventPatternsResponse) ToJsonString() string

type ListPlatformEventPatternsResponseParams added in v1.0.744

type ListPlatformEventPatternsResponseParams struct {
	// 平台产品事件匹配规则
	EventPatterns []*PlatformEventSummary `json:"EventPatterns,omitnil,omitempty" name:"EventPatterns"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListPlatformProductsRequest added in v1.0.744

type ListPlatformProductsRequest struct {
	*tchttp.BaseRequest
}

func NewListPlatformProductsRequest added in v1.0.744

func NewListPlatformProductsRequest() (request *ListPlatformProductsRequest)

func (*ListPlatformProductsRequest) FromJsonString added in v1.0.744

func (r *ListPlatformProductsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListPlatformProductsRequest) ToJsonString added in v1.0.744

func (r *ListPlatformProductsRequest) ToJsonString() string

type ListPlatformProductsRequestParams added in v1.0.744

type ListPlatformProductsRequestParams struct {
}

Predefined struct for user

type ListPlatformProductsResponse added in v1.0.744

type ListPlatformProductsResponse struct {
	*tchttp.BaseResponse
	Response *ListPlatformProductsResponseParams `json:"Response"`
}

func NewListPlatformProductsResponse added in v1.0.744

func NewListPlatformProductsResponse() (response *ListPlatformProductsResponse)

func (*ListPlatformProductsResponse) FromJsonString added in v1.0.744

func (r *ListPlatformProductsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListPlatformProductsResponse) ToJsonString added in v1.0.744

func (r *ListPlatformProductsResponse) ToJsonString() string

type ListPlatformProductsResponseParams added in v1.0.744

type ListPlatformProductsResponseParams struct {
	// 平台产品列表
	PlatformProducts []*PlatformProduct `json:"PlatformProducts,omitnil,omitempty" name:"PlatformProducts"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListRulesRequest

type ListRulesRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间)
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 分页偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序)
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`
}

func NewListRulesRequest

func NewListRulesRequest() (request *ListRulesRequest)

func (*ListRulesRequest) FromJsonString

func (r *ListRulesRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListRulesRequest) ToJsonString

func (r *ListRulesRequest) ToJsonString() string

type ListRulesRequestParams added in v1.0.426

type ListRulesRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间)
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 分页偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序)
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`
}

Predefined struct for user

type ListRulesResponse

type ListRulesResponse struct {
	*tchttp.BaseResponse
	Response *ListRulesResponseParams `json:"Response"`
}

func NewListRulesResponse

func NewListRulesResponse() (response *ListRulesResponse)

func (*ListRulesResponse) FromJsonString

func (r *ListRulesResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListRulesResponse) ToJsonString

func (r *ListRulesResponse) ToJsonString() string

type ListRulesResponseParams added in v1.0.426

type ListRulesResponseParams struct {
	// 事件规则信息
	Rules []*Rule `json:"Rules,omitnil,omitempty" name:"Rules"`

	// 事件规则总数
	TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type ListTargetsRequest

type ListTargetsRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间)
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 分页偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序)
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`
}

func NewListTargetsRequest

func NewListTargetsRequest() (request *ListTargetsRequest)

func (*ListTargetsRequest) FromJsonString

func (r *ListTargetsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListTargetsRequest) ToJsonString

func (r *ListTargetsRequest) ToJsonString() string

type ListTargetsRequestParams added in v1.0.426

type ListTargetsRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 根据哪个字段进行返回结果排序,支持以下字段:AddTime(创建时间), ModTime(修改时间)
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 返回数量,默认为20,最大值为100。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 分页偏移量,默认为0。
	Offset *int64 `json:"Offset,omitnil,omitempty" name:"Offset"`

	// 以升序还是降序的方式返回结果,可选值 ASC(升序) 和 DESC(降序)
	Order *string `json:"Order,omitnil,omitempty" name:"Order"`
}

Predefined struct for user

type ListTargetsResponse

type ListTargetsResponse struct {
	*tchttp.BaseResponse
	Response *ListTargetsResponseParams `json:"Response"`
}

func NewListTargetsResponse

func NewListTargetsResponse() (response *ListTargetsResponse)

func (*ListTargetsResponse) FromJsonString

func (r *ListTargetsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*ListTargetsResponse) ToJsonString

func (r *ListTargetsResponse) ToJsonString() string

type ListTargetsResponseParams added in v1.0.426

type ListTargetsResponseParams struct {
	// 目标总数
	TotalCount *int64 `json:"TotalCount,omitnil,omitempty" name:"TotalCount"`

	// 目标信息
	Targets []*Target `json:"Targets,omitnil,omitempty" name:"Targets"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type LogFilter added in v1.0.624

type LogFilter struct {
	// 过滤字段名称
	Key *string `json:"Key,omitnil,omitempty" name:"Key"`

	// 运算符,全等 eq,不等 neq,相似 like,排除相似 not like,  小于 lt,小于且等于 lte,大于 gt,大于且等于 gte,在范围内 range,不在范围内 norange
	Operator *string `json:"Operator,omitnil,omitempty" name:"Operator"`

	// 过滤值,范围运算需要同时输入两个值,以英文逗号分隔
	Value *string `json:"Value,omitnil,omitempty" name:"Value"`

	// 该层级filters逻辑关系,取值 "AND" 或 "OR"
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// LogFilters数组
	Filters []*LogFilters `json:"Filters,omitnil,omitempty" name:"Filters"`
}

type LogFilters added in v1.0.624

type LogFilters struct {
	// 过滤字段名称,取值范围如下:region(地域),type(事件类型),source(事件源),status(事件状态)
	Key *string `json:"Key,omitnil,omitempty" name:"Key"`

	// 运算符, 全等 eq,不等 neq,相似 like,排除相似 not like,  小于 lt,小于且等于 lte,大于 gt,大于且等于 gte,在范围内 range,不在范围内 norange
	Operator *string `json:"Operator,omitnil,omitempty" name:"Operator"`

	// 过滤值,范围运算需要同时输入两个值,以英文逗号分隔
	Value *string `json:"Value,omitnil,omitempty" name:"Value"`
}

type OutputStructParam

type OutputStructParam struct {
	// 对应输出json中的key
	Key *string `json:"Key,omitnil,omitempty" name:"Key"`

	// 可以填json-path也可以支持常量或者内置关键字date类型
	Value *string `json:"Value,omitnil,omitempty" name:"Value"`

	// value的数据类型, 可选值: STRING, NUMBER,BOOLEAN,NULL,SYS_VARIABLE,JSONPATH
	ValueType *string `json:"ValueType,omitnil,omitempty" name:"ValueType"`
}

type PlatformEventDetail added in v1.0.744

type PlatformEventDetail struct {
	// 事件名称
	// 注意:此字段可能返回 null,表示取不到有效值。
	EventName *string `json:"EventName,omitnil,omitempty" name:"EventName"`

	// 事件类型
	// 注意:此字段可能返回 null,表示取不到有效值。
	EventType *string `json:"EventType,omitnil,omitempty" name:"EventType"`
}

type PlatformEventSummary added in v1.0.744

type PlatformEventSummary struct {
	// 平台事件名称
	// 注意:此字段可能返回 null,表示取不到有效值。
	EventName *string `json:"EventName,omitnil,omitempty" name:"EventName"`

	// 平台事件匹配规则
	// 注意:此字段可能返回 null,表示取不到有效值。
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`
}

type PlatformProduct added in v1.0.744

type PlatformProduct struct {
	// 平台产品名称
	ProductName *string `json:"ProductName,omitnil,omitempty" name:"ProductName"`

	// 平台产品类型
	ProductType *string `json:"ProductType,omitnil,omitempty" name:"ProductType"`
}

type PublishEventRequest

type PublishEventRequest struct {
	*tchttp.BaseRequest

	// 事件列表
	EventList []*Event `json:"EventList,omitnil,omitempty" name:"EventList"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

func NewPublishEventRequest

func NewPublishEventRequest() (request *PublishEventRequest)

func (*PublishEventRequest) FromJsonString

func (r *PublishEventRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*PublishEventRequest) ToJsonString

func (r *PublishEventRequest) ToJsonString() string

type PublishEventRequestParams added in v1.0.426

type PublishEventRequestParams struct {
	// 事件列表
	EventList []*Event `json:"EventList,omitnil,omitempty" name:"EventList"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

Predefined struct for user

type PublishEventResponse

type PublishEventResponse struct {
	*tchttp.BaseResponse
	Response *PublishEventResponseParams `json:"Response"`
}

func NewPublishEventResponse

func NewPublishEventResponse() (response *PublishEventResponse)

func (*PublishEventResponse) FromJsonString

func (r *PublishEventResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*PublishEventResponse) ToJsonString

func (r *PublishEventResponse) ToJsonString() string

type PublishEventResponseParams added in v1.0.426

type PublishEventResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type PutEventsRequest added in v1.0.334

type PutEventsRequest struct {
	*tchttp.BaseRequest

	// 事件列表
	EventList []*Event `json:"EventList,omitnil,omitempty" name:"EventList"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

func NewPutEventsRequest added in v1.0.334

func NewPutEventsRequest() (request *PutEventsRequest)

func (*PutEventsRequest) FromJsonString added in v1.0.334

func (r *PutEventsRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*PutEventsRequest) ToJsonString added in v1.0.334

func (r *PutEventsRequest) ToJsonString() string

type PutEventsRequestParams added in v1.0.426

type PutEventsRequestParams struct {
	// 事件列表
	EventList []*Event `json:"EventList,omitnil,omitempty" name:"EventList"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`
}

Predefined struct for user

type PutEventsResponse added in v1.0.334

type PutEventsResponse struct {
	*tchttp.BaseResponse
	Response *PutEventsResponseParams `json:"Response"`
}

func NewPutEventsResponse added in v1.0.334

func NewPutEventsResponse() (response *PutEventsResponse)

func (*PutEventsResponse) FromJsonString added in v1.0.334

func (r *PutEventsResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*PutEventsResponse) ToJsonString added in v1.0.334

func (r *PutEventsResponse) ToJsonString() string

type PutEventsResponseParams added in v1.0.426

type PutEventsResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type RetryPolicy

type RetryPolicy struct {
	// 重试间隔 单位:秒
	RetryInterval *uint64 `json:"RetryInterval,omitnil,omitempty" name:"RetryInterval"`

	// 最大重试次数
	MaxRetryAttempts *uint64 `json:"MaxRetryAttempts,omitnil,omitempty" name:"MaxRetryAttempts"`
}

type Rule

type Rule struct {
	// 状态
	Status *string `json:"Status,omitnil,omitempty" name:"Status"`

	// 修改时间
	ModTime *string `json:"ModTime,omitnil,omitempty" name:"ModTime"`

	// 使能开关
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 创建时间
	AddTime *string `json:"AddTime,omitnil,omitempty" name:"AddTime"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则名称
	RuleName *string `json:"RuleName,omitnil,omitempty" name:"RuleName"`

	// Target 简要信息
	// 注意:此字段可能返回 null,表示取不到有效值。
	Targets []*TargetBrief `json:"Targets,omitnil,omitempty" name:"Targets"`

	// rule设置的dlq规则. 可能为null
	// 注意:此字段可能返回 null,表示取不到有效值。
	DeadLetterConfig *DeadLetterConfig `json:"DeadLetterConfig,omitnil,omitempty" name:"DeadLetterConfig"`
}

type SCFParams

type SCFParams struct {
	// 批量投递最长等待时间
	BatchTimeout *int64 `json:"BatchTimeout,omitnil,omitempty" name:"BatchTimeout"`

	// 批量投递最大事件条数
	BatchEventCount *int64 `json:"BatchEventCount,omitnil,omitempty" name:"BatchEventCount"`

	// 开启批量投递使能
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil,omitempty" name:"EnableBatchDelivery"`
}

type SearchLogRequest added in v1.0.624

type SearchLogRequest struct {
	*tchttp.BaseRequest

	// 起始时间unix 毫秒时间戳
	StartTime *int64 `json:"StartTime,omitnil,omitempty" name:"StartTime"`

	// 结束时间unix 毫秒时间戳
	EndTime *int64 `json:"EndTime,omitnil,omitempty" name:"EndTime"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 页码
	Page *int64 `json:"Page,omitnil,omitempty" name:"Page"`

	// 每页数据大小
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 事件查询筛选条件;示例如下:[{"key":"host","operator":"eq","value":"106.53.106.243"},{"type":"AND","filters":[{"key":"region","operator":"like","value":"*guangzhou*"},{"key":"type","operator":"eq","value":"cvm:ErrorEvent:GuestReboot"}]},{"type":"OR","filters":[{"key":"field1","operator":"like","value":"*access*"},{"key":"field2","operator":"eq","value":"custorm"}]}]
	Filter []*LogFilter `json:"Filter,omitnil,omitempty" name:"Filter"`

	// 事件查询结果排序,["timestamp","subject"]
	OrderFields []*string `json:"OrderFields,omitnil,omitempty" name:"OrderFields"`

	// 排序方式,asc 从旧到新,desc 从新到旧
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`
}

func NewSearchLogRequest added in v1.0.624

func NewSearchLogRequest() (request *SearchLogRequest)

func (*SearchLogRequest) FromJsonString added in v1.0.624

func (r *SearchLogRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SearchLogRequest) ToJsonString added in v1.0.624

func (r *SearchLogRequest) ToJsonString() string

type SearchLogRequestParams added in v1.0.624

type SearchLogRequestParams struct {
	// 起始时间unix 毫秒时间戳
	StartTime *int64 `json:"StartTime,omitnil,omitempty" name:"StartTime"`

	// 结束时间unix 毫秒时间戳
	EndTime *int64 `json:"EndTime,omitnil,omitempty" name:"EndTime"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 页码
	Page *int64 `json:"Page,omitnil,omitempty" name:"Page"`

	// 每页数据大小
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 事件查询筛选条件;示例如下:[{"key":"host","operator":"eq","value":"106.53.106.243"},{"type":"AND","filters":[{"key":"region","operator":"like","value":"*guangzhou*"},{"key":"type","operator":"eq","value":"cvm:ErrorEvent:GuestReboot"}]},{"type":"OR","filters":[{"key":"field1","operator":"like","value":"*access*"},{"key":"field2","operator":"eq","value":"custorm"}]}]
	Filter []*LogFilter `json:"Filter,omitnil,omitempty" name:"Filter"`

	// 事件查询结果排序,["timestamp","subject"]
	OrderFields []*string `json:"OrderFields,omitnil,omitempty" name:"OrderFields"`

	// 排序方式,asc 从旧到新,desc 从新到旧
	OrderBy *string `json:"OrderBy,omitnil,omitempty" name:"OrderBy"`
}

Predefined struct for user

type SearchLogResponse added in v1.0.624

type SearchLogResponse struct {
	*tchttp.BaseResponse
	Response *SearchLogResponseParams `json:"Response"`
}

func NewSearchLogResponse added in v1.0.624

func NewSearchLogResponse() (response *SearchLogResponse)

func (*SearchLogResponse) FromJsonString added in v1.0.624

func (r *SearchLogResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*SearchLogResponse) ToJsonString added in v1.0.624

func (r *SearchLogResponse) ToJsonString() string

type SearchLogResponseParams added in v1.0.624

type SearchLogResponseParams struct {
	// 事件总数
	// 注意:此字段可能返回 null,表示取不到有效值。
	Total *int64 `json:"Total,omitnil,omitempty" name:"Total"`

	// 每页事件条数
	// 注意:此字段可能返回 null,表示取不到有效值。
	Limit *int64 `json:"Limit,omitnil,omitempty" name:"Limit"`

	// 页码
	// 注意:此字段可能返回 null,表示取不到有效值。
	Page *int64 `json:"Page,omitnil,omitempty" name:"Page"`

	// 事件查询结果
	// 注意:此字段可能返回 null,表示取不到有效值。
	Results []*SearchLogResult `json:"Results,omitnil,omitempty" name:"Results"`

	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type SearchLogResult added in v1.0.624

type SearchLogResult struct {
	// 单条日志上报时间
	// 注意:此字段可能返回 null,表示取不到有效值。
	Timestamp *string `json:"Timestamp,omitnil,omitempty" name:"Timestamp"`

	// 日志内容详情
	// 注意:此字段可能返回 null,表示取不到有效值。
	Message *string `json:"Message,omitnil,omitempty" name:"Message"`

	// 事件来源
	// 注意:此字段可能返回 null,表示取不到有效值。
	Source *string `json:"Source,omitnil,omitempty" name:"Source"`

	// 事件类型
	// 注意:此字段可能返回 null,表示取不到有效值。
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 事件匹配规则
	// 注意:此字段可能返回 null,表示取不到有效值。
	RuleIds *string `json:"RuleIds,omitnil,omitempty" name:"RuleIds"`

	// 实例ID
	// 注意:此字段可能返回 null,表示取不到有效值。
	Subject *string `json:"Subject,omitnil,omitempty" name:"Subject"`

	// 地域
	// 注意:此字段可能返回 null,表示取不到有效值。
	Region *string `json:"Region,omitnil,omitempty" name:"Region"`

	// 事件状态
	// 注意:此字段可能返回 null,表示取不到有效值。
	Status *string `json:"Status,omitnil,omitempty" name:"Status"`
}

type TDMQParams added in v1.0.803

type TDMQParams struct {
	// 集群类型
	// 注意:此字段可能返回 null,表示取不到有效值。
	ClusterType *string `json:"ClusterType,omitnil,omitempty" name:"ClusterType"`

	// 集群支撑网接入点
	// 注意:此字段可能返回 null,表示取不到有效值。
	ClusterEndPoint *string `json:"ClusterEndPoint,omitnil,omitempty" name:"ClusterEndPoint"`
}

type Tag added in v1.0.903

type Tag struct {
	// 标签名称
	Key *string `json:"Key,omitnil,omitempty" name:"Key"`

	// 标签值
	Value *string `json:"Value,omitnil,omitempty" name:"Value"`
}

type Target

type Target struct {
	// 目标类型
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 目标ID
	TargetId *string `json:"TargetId,omitnil,omitempty" name:"TargetId"`

	// 目标描述
	TargetDescription *TargetDescription `json:"TargetDescription,omitnil,omitempty" name:"TargetDescription"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 开启批量投递使能
	// 注意:此字段可能返回 null,表示取不到有效值。
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil,omitempty" name:"EnableBatchDelivery"`

	// 批量投递最长等待时间
	// 注意:此字段可能返回 null,表示取不到有效值。
	BatchTimeout *int64 `json:"BatchTimeout,omitnil,omitempty" name:"BatchTimeout"`

	// 批量投递最大事件条数
	// 注意:此字段可能返回 null,表示取不到有效值。
	BatchEventCount *int64 `json:"BatchEventCount,omitnil,omitempty" name:"BatchEventCount"`
}

type TargetBrief

type TargetBrief struct {
	// 目标ID
	TargetId *string `json:"TargetId,omitnil,omitempty" name:"TargetId"`

	// 目标类型
	Type *string `json:"Type,omitnil,omitempty" name:"Type"`
}

type TargetDescription

type TargetDescription struct {
	// QCS资源六段式,更多参考 [资源六段式](https://cloud.tencent.com/document/product/598/10606);scf资源六段式示例[qcs::scf:ap-guangzhou:uin/123:namespace/test(函数命名空间)/function/test(函数名)/$LATEST(函数版本)] amp资源六段式示例[qcs::eb-amp:ap-guangzhou:uin/123:] ckafka资源六段式示例[qcs::ckafka:ap-guangzhou:uin/123:ckafkaId/uin/123/ckafka-123(ckafka实例Id)] cls资源六段式示例[qcs::cls:ap-guangzhou:uin/123:topic/122332442(topicId)] es资源六段式示例[qcs::es:ap-guangzhou:appid/123/uin/456:instance/es-7cplmhsd(es实例Id)]
	ResourceDescription *string `json:"ResourceDescription,omitnil,omitempty" name:"ResourceDescription"`

	// 云函数参数
	SCFParams *SCFParams `json:"SCFParams,omitnil,omitempty" name:"SCFParams"`

	// Ckafka参数
	CkafkaTargetParams *CkafkaTargetParams `json:"CkafkaTargetParams,omitnil,omitempty" name:"CkafkaTargetParams"`

	// ElasticSearch参数
	ESTargetParams *ESTargetParams `json:"ESTargetParams,omitnil,omitempty" name:"ESTargetParams"`
}

type TextParams

type TextParams struct {
	// 逗号、| 、制表符、空格、换行符、%、#,限制长度为 1。
	// 注意:此字段可能返回 null,表示取不到有效值。
	Separator *string `json:"Separator,omitnil,omitempty" name:"Separator"`

	// 填写正则表达式:长度128
	// 注意:此字段可能返回 null,表示取不到有效值。
	Regex *string `json:"Regex,omitnil,omitempty" name:"Regex"`
}

type Transform

type Transform struct {
	// 描述如何数据转换
	OutputStructs []*OutputStructParam `json:"OutputStructs,omitnil,omitempty" name:"OutputStructs"`
}

type Transformation

type Transformation struct {
	// 描述如何提取数据,{"ExtractionInputPath":"$.data.payload","Format":"JSON"}
	// 注意:此字段可能返回 null,表示取不到有效值。
	Extraction *Extraction `json:"Extraction,omitnil,omitempty" name:"Extraction"`

	// 描述如何过滤数据;{"Filter":"{\"source\":\"ckafka.cloud.tencent\"}"}
	// 注意:此字段可能返回 null,表示取不到有效值。
	EtlFilter *EtlFilter `json:"EtlFilter,omitnil,omitempty" name:"EtlFilter"`

	// 描述如何数据转换;"OutputStructs":[{"Key":"op","Value":"$.op","ValueType":"JSONPATH"}]
	// 注意:此字段可能返回 null,表示取不到有效值。
	Transform *Transform `json:"Transform,omitnil,omitempty" name:"Transform"`
}

type UpdateConnectionRequest

type UpdateConnectionRequest struct {
	*tchttp.BaseRequest

	// 连接器ID
	ConnectionId *string `json:"ConnectionId,omitnil,omitempty" name:"ConnectionId"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 使能开关
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 连接器名称
	ConnectionName *string `json:"ConnectionName,omitnil,omitempty" name:"ConnectionName"`
}

func NewUpdateConnectionRequest

func NewUpdateConnectionRequest() (request *UpdateConnectionRequest)

func (*UpdateConnectionRequest) FromJsonString

func (r *UpdateConnectionRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateConnectionRequest) ToJsonString

func (r *UpdateConnectionRequest) ToJsonString() string

type UpdateConnectionRequestParams added in v1.0.426

type UpdateConnectionRequestParams struct {
	// 连接器ID
	ConnectionId *string `json:"ConnectionId,omitnil,omitempty" name:"ConnectionId"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 使能开关
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 描述
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 连接器名称
	ConnectionName *string `json:"ConnectionName,omitnil,omitempty" name:"ConnectionName"`
}

Predefined struct for user

type UpdateConnectionResponse

type UpdateConnectionResponse struct {
	*tchttp.BaseResponse
	Response *UpdateConnectionResponseParams `json:"Response"`
}

func NewUpdateConnectionResponse

func NewUpdateConnectionResponse() (response *UpdateConnectionResponse)

func (*UpdateConnectionResponse) FromJsonString

func (r *UpdateConnectionResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateConnectionResponse) ToJsonString

func (r *UpdateConnectionResponse) ToJsonString() string

type UpdateConnectionResponseParams added in v1.0.426

type UpdateConnectionResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateEventBusRequest

type UpdateEventBusRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件集描述,不限字符类型,200字符描述以内
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	EventBusName *string `json:"EventBusName,omitnil,omitempty" name:"EventBusName"`

	// EB日志存储时长
	SaveDays *int64 `json:"SaveDays,omitnil,omitempty" name:"SaveDays"`

	// EB日志主题ID
	LogTopicId *string `json:"LogTopicId,omitnil,omitempty" name:"LogTopicId"`

	// 是否开启存储
	EnableStore *bool `json:"EnableStore,omitnil,omitempty" name:"EnableStore"`
}

func NewUpdateEventBusRequest

func NewUpdateEventBusRequest() (request *UpdateEventBusRequest)

func (*UpdateEventBusRequest) FromJsonString

func (r *UpdateEventBusRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateEventBusRequest) ToJsonString

func (r *UpdateEventBusRequest) ToJsonString() string

type UpdateEventBusRequestParams added in v1.0.426

type UpdateEventBusRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件集描述,不限字符类型,200字符描述以内
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 事件集名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	EventBusName *string `json:"EventBusName,omitnil,omitempty" name:"EventBusName"`

	// EB日志存储时长
	SaveDays *int64 `json:"SaveDays,omitnil,omitempty" name:"SaveDays"`

	// EB日志主题ID
	LogTopicId *string `json:"LogTopicId,omitnil,omitempty" name:"LogTopicId"`

	// 是否开启存储
	EnableStore *bool `json:"EnableStore,omitnil,omitempty" name:"EnableStore"`
}

Predefined struct for user

type UpdateEventBusResponse

type UpdateEventBusResponse struct {
	*tchttp.BaseResponse
	Response *UpdateEventBusResponseParams `json:"Response"`
}

func NewUpdateEventBusResponse

func NewUpdateEventBusResponse() (response *UpdateEventBusResponse)

func (*UpdateEventBusResponse) FromJsonString

func (r *UpdateEventBusResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateEventBusResponse) ToJsonString

func (r *UpdateEventBusResponse) ToJsonString() string

type UpdateEventBusResponseParams added in v1.0.426

type UpdateEventBusResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateRuleRequest

type UpdateRuleRequest struct {
	*tchttp.BaseRequest

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 使能开关。
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 规则描述,不限字符类型,200字符描述以内。
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084)
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`

	// 事件规则名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	RuleName *string `json:"RuleName,omitnil,omitempty" name:"RuleName"`
}

func NewUpdateRuleRequest

func NewUpdateRuleRequest() (request *UpdateRuleRequest)

func (*UpdateRuleRequest) FromJsonString

func (r *UpdateRuleRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateRuleRequest) ToJsonString

func (r *UpdateRuleRequest) ToJsonString() string

type UpdateRuleRequestParams added in v1.0.426

type UpdateRuleRequestParams struct {
	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 使能开关。
	Enable *bool `json:"Enable,omitnil,omitempty" name:"Enable"`

	// 规则描述,不限字符类型,200字符描述以内。
	Description *string `json:"Description,omitnil,omitempty" name:"Description"`

	// 参考:[事件模式](https://cloud.tencent.com/document/product/1359/56084)
	EventPattern *string `json:"EventPattern,omitnil,omitempty" name:"EventPattern"`

	// 事件规则名称,只能包含字母、数字、下划线、连字符,以字母开头,以数字或字母结尾,2~60个字符
	RuleName *string `json:"RuleName,omitnil,omitempty" name:"RuleName"`
}

Predefined struct for user

type UpdateRuleResponse

type UpdateRuleResponse struct {
	*tchttp.BaseResponse
	Response *UpdateRuleResponseParams `json:"Response"`
}

func NewUpdateRuleResponse

func NewUpdateRuleResponse() (response *UpdateRuleResponse)

func (*UpdateRuleResponse) FromJsonString

func (r *UpdateRuleResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateRuleResponse) ToJsonString

func (r *UpdateRuleResponse) ToJsonString() string

type UpdateRuleResponseParams added in v1.0.426

type UpdateRuleResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateTargetRequest

type UpdateTargetRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 事件目标ID
	TargetId *string `json:"TargetId,omitnil,omitempty" name:"TargetId"`

	// 开启批量投递使能
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil,omitempty" name:"EnableBatchDelivery"`

	// 批量投递最长等待时间
	BatchTimeout *int64 `json:"BatchTimeout,omitnil,omitempty" name:"BatchTimeout"`

	// 批量投递最大事件条数
	BatchEventCount *int64 `json:"BatchEventCount,omitnil,omitempty" name:"BatchEventCount"`
}

func NewUpdateTargetRequest

func NewUpdateTargetRequest() (request *UpdateTargetRequest)

func (*UpdateTargetRequest) FromJsonString

func (r *UpdateTargetRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTargetRequest) ToJsonString

func (r *UpdateTargetRequest) ToJsonString() string

type UpdateTargetRequestParams added in v1.0.426

type UpdateTargetRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 事件规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 事件目标ID
	TargetId *string `json:"TargetId,omitnil,omitempty" name:"TargetId"`

	// 开启批量投递使能
	EnableBatchDelivery *bool `json:"EnableBatchDelivery,omitnil,omitempty" name:"EnableBatchDelivery"`

	// 批量投递最长等待时间
	BatchTimeout *int64 `json:"BatchTimeout,omitnil,omitempty" name:"BatchTimeout"`

	// 批量投递最大事件条数
	BatchEventCount *int64 `json:"BatchEventCount,omitnil,omitempty" name:"BatchEventCount"`
}

Predefined struct for user

type UpdateTargetResponse

type UpdateTargetResponse struct {
	*tchttp.BaseResponse
	Response *UpdateTargetResponseParams `json:"Response"`
}

func NewUpdateTargetResponse

func NewUpdateTargetResponse() (response *UpdateTargetResponse)

func (*UpdateTargetResponse) FromJsonString

func (r *UpdateTargetResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTargetResponse) ToJsonString

func (r *UpdateTargetResponse) ToJsonString() string

type UpdateTargetResponseParams added in v1.0.426

type UpdateTargetResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

type UpdateTransformationRequest

type UpdateTransformationRequest struct {
	*tchttp.BaseRequest

	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 转换器id
	TransformationId *string `json:"TransformationId,omitnil,omitempty" name:"TransformationId"`

	// 一个转换规则列表,当前仅限定一个
	Transformations []*Transformation `json:"Transformations,omitnil,omitempty" name:"Transformations"`
}

func NewUpdateTransformationRequest

func NewUpdateTransformationRequest() (request *UpdateTransformationRequest)

func (*UpdateTransformationRequest) FromJsonString

func (r *UpdateTransformationRequest) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTransformationRequest) ToJsonString

func (r *UpdateTransformationRequest) ToJsonString() string

type UpdateTransformationRequestParams added in v1.0.426

type UpdateTransformationRequestParams struct {
	// 事件集ID
	EventBusId *string `json:"EventBusId,omitnil,omitempty" name:"EventBusId"`

	// 规则ID
	RuleId *string `json:"RuleId,omitnil,omitempty" name:"RuleId"`

	// 转换器id
	TransformationId *string `json:"TransformationId,omitnil,omitempty" name:"TransformationId"`

	// 一个转换规则列表,当前仅限定一个
	Transformations []*Transformation `json:"Transformations,omitnil,omitempty" name:"Transformations"`
}

Predefined struct for user

type UpdateTransformationResponse

type UpdateTransformationResponse struct {
	*tchttp.BaseResponse
	Response *UpdateTransformationResponseParams `json:"Response"`
}

func NewUpdateTransformationResponse

func NewUpdateTransformationResponse() (response *UpdateTransformationResponse)

func (*UpdateTransformationResponse) FromJsonString

func (r *UpdateTransformationResponse) FromJsonString(s string) error

FromJsonString It is highly **NOT** recommended to use this function because it has no param check, nor strict type check

func (*UpdateTransformationResponse) ToJsonString

func (r *UpdateTransformationResponse) ToJsonString() string

type UpdateTransformationResponseParams added in v1.0.426

type UpdateTransformationResponseParams struct {
	// 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。
	RequestId *string `json:"RequestId,omitnil,omitempty" name:"RequestId"`
}

Predefined struct for user

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL