Documentation ¶
Index ¶
- Constants
- type APIGWParams
- type CheckRuleRequest
- type CheckRuleRequestParams
- type CheckRuleResponse
- type CheckRuleResponseParams
- type CheckTransformationRequest
- type CheckTransformationRequestParams
- type CheckTransformationResponse
- type CheckTransformationResponseParams
- type CkafkaDeliveryParams
- type CkafkaParams
- type CkafkaTargetParams
- type Client
- func (c *Client) CheckRule(request *CheckRuleRequest) (response *CheckRuleResponse, err error)
- func (c *Client) CheckRuleWithContext(ctx context.Context, request *CheckRuleRequest) (response *CheckRuleResponse, err error)
- func (c *Client) CheckTransformation(request *CheckTransformationRequest) (response *CheckTransformationResponse, err error)
- func (c *Client) CheckTransformationWithContext(ctx context.Context, request *CheckTransformationRequest) (response *CheckTransformationResponse, err error)
- func (c *Client) CreateConnection(request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)
- func (c *Client) CreateConnectionWithContext(ctx context.Context, request *CreateConnectionRequest) (response *CreateConnectionResponse, err error)
- func (c *Client) CreateEventBus(request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)
- func (c *Client) CreateEventBusWithContext(ctx context.Context, request *CreateEventBusRequest) (response *CreateEventBusResponse, err error)
- func (c *Client) CreateRule(request *CreateRuleRequest) (response *CreateRuleResponse, err error)
- func (c *Client) CreateRuleWithContext(ctx context.Context, request *CreateRuleRequest) (response *CreateRuleResponse, err error)
- func (c *Client) CreateTarget(request *CreateTargetRequest) (response *CreateTargetResponse, err error)
- func (c *Client) CreateTargetWithContext(ctx context.Context, request *CreateTargetRequest) (response *CreateTargetResponse, err error)
- func (c *Client) CreateTransformation(request *CreateTransformationRequest) (response *CreateTransformationResponse, err error)
- func (c *Client) CreateTransformationWithContext(ctx context.Context, request *CreateTransformationRequest) (response *CreateTransformationResponse, err error)
- func (c *Client) DeleteConnection(request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)
- func (c *Client) DeleteConnectionWithContext(ctx context.Context, request *DeleteConnectionRequest) (response *DeleteConnectionResponse, err error)
- func (c *Client) DeleteEventBus(request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)
- func (c *Client) DeleteEventBusWithContext(ctx context.Context, request *DeleteEventBusRequest) (response *DeleteEventBusResponse, err error)
- func (c *Client) DeleteRule(request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)
- func (c *Client) DeleteRuleWithContext(ctx context.Context, request *DeleteRuleRequest) (response *DeleteRuleResponse, err error)
- func (c *Client) DeleteTarget(request *DeleteTargetRequest) (response *DeleteTargetResponse, err error)
- func (c *Client) DeleteTargetWithContext(ctx context.Context, request *DeleteTargetRequest) (response *DeleteTargetResponse, err error)
- func (c *Client) DeleteTransformation(request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error)
- func (c *Client) DeleteTransformationWithContext(ctx context.Context, request *DeleteTransformationRequest) (response *DeleteTransformationResponse, err error)
- func (c *Client) DescribeLogTagValue(request *DescribeLogTagValueRequest) (response *DescribeLogTagValueResponse, err error)
- func (c *Client) DescribeLogTagValueWithContext(ctx context.Context, request *DescribeLogTagValueRequest) (response *DescribeLogTagValueResponse, err error)
- func (c *Client) GetEventBus(request *GetEventBusRequest) (response *GetEventBusResponse, err error)
- func (c *Client) GetEventBusWithContext(ctx context.Context, request *GetEventBusRequest) (response *GetEventBusResponse, err error)
- func (c *Client) GetPlatformEventTemplate(request *GetPlatformEventTemplateRequest) (response *GetPlatformEventTemplateResponse, err error)
- func (c *Client) GetPlatformEventTemplateWithContext(ctx context.Context, request *GetPlatformEventTemplateRequest) (response *GetPlatformEventTemplateResponse, err error)
- func (c *Client) GetRule(request *GetRuleRequest) (response *GetRuleResponse, err error)
- func (c *Client) GetRuleWithContext(ctx context.Context, request *GetRuleRequest) (response *GetRuleResponse, err error)
- func (c *Client) GetTransformation(request *GetTransformationRequest) (response *GetTransformationResponse, err error)
- func (c *Client) GetTransformationWithContext(ctx context.Context, request *GetTransformationRequest) (response *GetTransformationResponse, err error)
- func (c *Client) ListConnections(request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)
- func (c *Client) ListConnectionsWithContext(ctx context.Context, request *ListConnectionsRequest) (response *ListConnectionsResponse, err error)
- func (c *Client) ListEventBuses(request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)
- func (c *Client) ListEventBusesWithContext(ctx context.Context, request *ListEventBusesRequest) (response *ListEventBusesResponse, err error)
- func (c *Client) ListPlatformEventNames(request *ListPlatformEventNamesRequest) (response *ListPlatformEventNamesResponse, err error)
- func (c *Client) ListPlatformEventNamesWithContext(ctx context.Context, request *ListPlatformEventNamesRequest) (response *ListPlatformEventNamesResponse, err error)
- func (c *Client) ListPlatformEventPatterns(request *ListPlatformEventPatternsRequest) (response *ListPlatformEventPatternsResponse, err error)
- func (c *Client) ListPlatformEventPatternsWithContext(ctx context.Context, request *ListPlatformEventPatternsRequest) (response *ListPlatformEventPatternsResponse, err error)
- func (c *Client) ListPlatformProducts(request *ListPlatformProductsRequest) (response *ListPlatformProductsResponse, err error)
- func (c *Client) ListPlatformProductsWithContext(ctx context.Context, request *ListPlatformProductsRequest) (response *ListPlatformProductsResponse, err error)
- func (c *Client) ListRules(request *ListRulesRequest) (response *ListRulesResponse, err error)
- func (c *Client) ListRulesWithContext(ctx context.Context, request *ListRulesRequest) (response *ListRulesResponse, err error)
- func (c *Client) ListTargets(request *ListTargetsRequest) (response *ListTargetsResponse, err error)
- func (c *Client) ListTargetsWithContext(ctx context.Context, request *ListTargetsRequest) (response *ListTargetsResponse, err error)
- func (c *Client) PublishEvent(request *PublishEventRequest) (response *PublishEventResponse, err error)
- func (c *Client) PublishEventWithContext(ctx context.Context, request *PublishEventRequest) (response *PublishEventResponse, err error)
- func (c *Client) PutEvents(request *PutEventsRequest) (response *PutEventsResponse, err error)
- func (c *Client) PutEventsWithContext(ctx context.Context, request *PutEventsRequest) (response *PutEventsResponse, err error)
- func (c *Client) SearchLog(request *SearchLogRequest) (response *SearchLogResponse, err error)
- func (c *Client) SearchLogWithContext(ctx context.Context, request *SearchLogRequest) (response *SearchLogResponse, err error)
- func (c *Client) UpdateConnection(request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)
- func (c *Client) UpdateConnectionWithContext(ctx context.Context, request *UpdateConnectionRequest) (response *UpdateConnectionResponse, err error)
- func (c *Client) UpdateEventBus(request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)
- func (c *Client) UpdateEventBusWithContext(ctx context.Context, request *UpdateEventBusRequest) (response *UpdateEventBusResponse, err error)
- func (c *Client) UpdateRule(request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)
- func (c *Client) UpdateRuleWithContext(ctx context.Context, request *UpdateRuleRequest) (response *UpdateRuleResponse, err error)
- func (c *Client) UpdateTarget(request *UpdateTargetRequest) (response *UpdateTargetResponse, err error)
- func (c *Client) UpdateTargetWithContext(ctx context.Context, request *UpdateTargetRequest) (response *UpdateTargetResponse, err error)
- func (c *Client) UpdateTransformation(request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error)
- func (c *Client) UpdateTransformationWithContext(ctx context.Context, request *UpdateTransformationRequest) (response *UpdateTransformationResponse, err error)
- type Connection
- type ConnectionBrief
- type ConnectionDescription
- type CreateConnectionRequest
- type CreateConnectionRequestParams
- type CreateConnectionResponse
- type CreateConnectionResponseParams
- type CreateEventBusRequest
- type CreateEventBusRequestParams
- type CreateEventBusResponse
- type CreateEventBusResponseParams
- type CreateRuleRequest
- type CreateRuleRequestParams
- type CreateRuleResponse
- type CreateRuleResponseParams
- type CreateTargetRequest
- type CreateTargetRequestParams
- type CreateTargetResponse
- type CreateTargetResponseParams
- type CreateTransformationRequest
- type CreateTransformationRequestParams
- type CreateTransformationResponse
- type CreateTransformationResponseParams
- type DTSParams
- type DeadLetterConfig
- type DeleteConnectionRequest
- type DeleteConnectionRequestParams
- type DeleteConnectionResponse
- type DeleteConnectionResponseParams
- type DeleteEventBusRequest
- type DeleteEventBusRequestParams
- type DeleteEventBusResponse
- type DeleteEventBusResponseParams
- type DeleteRuleRequest
- type DeleteRuleRequestParams
- type DeleteRuleResponse
- type DeleteRuleResponseParams
- type DeleteTargetRequest
- type DeleteTargetRequestParams
- type DeleteTargetResponse
- type DeleteTargetResponseParams
- type DeleteTransformationRequest
- type DeleteTransformationRequestParams
- type DeleteTransformationResponse
- type DeleteTransformationResponseParams
- type DescribeLogTagValueRequest
- type DescribeLogTagValueRequestParams
- type DescribeLogTagValueResponse
- type DescribeLogTagValueResponseParams
- type ESTargetParams
- type EtlFilter
- type Event
- type EventBus
- type Extraction
- type Filter
- type GetEventBusRequest
- type GetEventBusRequestParams
- type GetEventBusResponse
- type GetEventBusResponseParams
- type GetPlatformEventTemplateRequest
- type GetPlatformEventTemplateRequestParams
- type GetPlatformEventTemplateResponse
- type GetPlatformEventTemplateResponseParams
- type GetRuleRequest
- type GetRuleRequestParams
- type GetRuleResponse
- type GetRuleResponseParams
- type GetTransformationRequest
- type GetTransformationRequestParams
- type GetTransformationResponse
- type GetTransformationResponseParams
- type ListConnectionsRequest
- type ListConnectionsRequestParams
- type ListConnectionsResponse
- type ListConnectionsResponseParams
- type ListEventBusesRequest
- type ListEventBusesRequestParams
- type ListEventBusesResponse
- type ListEventBusesResponseParams
- type ListPlatformEventNamesRequest
- type ListPlatformEventNamesRequestParams
- type ListPlatformEventNamesResponse
- type ListPlatformEventNamesResponseParams
- type ListPlatformEventPatternsRequest
- type ListPlatformEventPatternsRequestParams
- type ListPlatformEventPatternsResponse
- type ListPlatformEventPatternsResponseParams
- type ListPlatformProductsRequest
- type ListPlatformProductsRequestParams
- type ListPlatformProductsResponse
- type ListPlatformProductsResponseParams
- type ListRulesRequest
- type ListRulesRequestParams
- type ListRulesResponse
- type ListRulesResponseParams
- type ListTargetsRequest
- type ListTargetsRequestParams
- type ListTargetsResponse
- type ListTargetsResponseParams
- type LogFilter
- type LogFilters
- type OutputStructParam
- type PlatformEventDetail
- type PlatformEventSummary
- type PlatformProduct
- type PublishEventRequest
- type PublishEventRequestParams
- type PublishEventResponse
- type PublishEventResponseParams
- type PutEventsRequest
- type PutEventsRequestParams
- type PutEventsResponse
- type PutEventsResponseParams
- type RetryPolicy
- type Rule
- type SCFParams
- type SearchLogRequest
- type SearchLogRequestParams
- type SearchLogResponse
- type SearchLogResponseParams
- type SearchLogResult
- type TDMQParams
- type Tag
- type Target
- type TargetBrief
- type TargetDescription
- type TextParams
- type Transform
- type Transformation
- type UpdateConnectionRequest
- type UpdateConnectionRequestParams
- type UpdateConnectionResponse
- type UpdateConnectionResponseParams
- type UpdateEventBusRequest
- type UpdateEventBusRequestParams
- type UpdateEventBusResponse
- type UpdateEventBusResponseParams
- type UpdateRuleRequest
- type UpdateRuleRequestParams
- type UpdateRuleResponse
- type UpdateRuleResponseParams
- type UpdateTargetRequest
- type UpdateTargetRequestParams
- type UpdateTargetResponse
- type UpdateTargetResponseParams
- type UpdateTransformationRequest
- type UpdateTransformationRequestParams
- type UpdateTransformationResponse
- type UpdateTransformationResponseParams
Constants ¶
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" )
const APIVersion = "2021-04-16"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIGWParams ¶
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 CkafkaParams ¶
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 ¶
func NewClient ¶
func NewClient(credential common.CredentialIface, region string, clientProfile *profile.ClientProfile) (client *Client, err error)
func NewClientWithSecretId ¶
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 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 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 PlatformEventSummary ¶ added in v1.0.744
type PlatformProduct ¶ added in v1.0.744
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 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 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 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 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