Documentation ¶
Index ¶
- type AgencyCreateReq
- type AgencyCreateReqType
- type AgencyCreateReqTypeEnum
- type ApiVersionsLinks
- type ApiVersionsVersions
- type ApiVersionsVersionsStatus
- type ApiVersionsVersionsStatusEnum
- type BatchWindow
- type CatalogTargetInfo
- type CatalogTargetInfoProviderType
- type CatalogTargetInfoProviderTypeEnum
- type ChannelCreateReq
- type ChannelInfo
- type ChannelInfoProviderType
- type ChannelInfoProviderTypeEnum
- type ChannelUpdateReq
- type CheckPutEventsReq
- type CheckPutEventsReqSources
- type CheckPutEventsRequest
- type CheckPutEventsResponse
- type CheckPutEventsResult
- type CloudEvents
- type ConnectionCreateReq
- type ConnectionInfo
- type ConnectionInfoFlavor
- type ConnectionInfoFlavorBandwidthType
- type ConnectionInfoFlavorBandwidthTypeEnum
- type ConnectionInfoFlavorConcurrencyType
- type ConnectionInfoFlavorConcurrencyTypeEnum
- type ConnectionInfoStatus
- type ConnectionInfoStatusEnum
- type ConnectionType
- type ConnectionTypeEnum
- type ConnectionUpdateReq
- type CreateAgenciesRequest
- type CreateAgenciesResponse
- type CreateChannelRequest
- type CreateChannelResponse
- type CreateChannelResponseProviderType
- type CreateChannelResponseProviderTypeEnum
- type CreateConnectionRequest
- type CreateConnectionResponse
- type CreateConnectionResponseStatus
- type CreateConnectionResponseStatusEnum
- type CreateEndpointRequest
- type CreateEndpointResponse
- type CreateEndpointResponseStatus
- type CreateEndpointResponseStatusEnum
- type CreateEndpointResponseType
- type CreateEndpointResponseTypeEnum
- type CreateEventSourceRequest
- type CreateEventSourceResponse
- type CreateEventSourceResponseProviderType
- type CreateEventSourceResponseProviderTypeEnum
- type CreateEventSourceResponseStatus
- type CreateEventSourceResponseStatusEnum
- type CreateEventStreamingRequest
- type CreateEventStreamingResponse
- type CreateSubscriptionRequest
- type CreateSubscriptionResponse
- type CreateSubscriptionResponseStatus
- type CreateSubscriptionResponseStatusEnum
- type CreateSubscriptionResponseType
- type CreateSubscriptionResponseTypeEnum
- type CreateSubscriptionTargetRequest
- type CreateSubscriptionTargetResponse
- type CustomizeSourceCreateReq
- type CustomizeSourceCreateReqType
- type CustomizeSourceCreateReqTypeEnum
- type CustomizeSourceInfo
- type CustomizeSourceInfoEventTypes
- type CustomizeSourceInfoProviderType
- type CustomizeSourceInfoProviderTypeEnum
- type CustomizeSourceInfoStatus
- type CustomizeSourceInfoStatusEnum
- type CustomizeSourceUpdateReq
- type DeadLetterQueue
- type DeadLetterQueueType
- type DeadLetterQueueTypeEnum
- type DeleteChannelRequest
- type DeleteChannelResponse
- type DeleteConnectionRequest
- type DeleteConnectionResponse
- type DeleteEndpointRequest
- type DeleteEndpointResponse
- type DeleteEventSourceRequest
- type DeleteEventSourceResponse
- type DeleteEventStreamingRequest
- type DeleteEventStreamingResponse
- type DeleteSubscriptionRequest
- type DeleteSubscriptionResponse
- type DeleteSubscriptionTargetRequest
- type DeleteSubscriptionTargetResponse
- type DeliverDetail
- type DeliverItem
- type DeliverTarget
- type Detail
- type EndpointConnection
- type EndpointCreateReq
- type EndpointInfo
- type EndpointInfoStatus
- type EndpointInfoStatusEnum
- type EndpointInfoType
- type EndpointInfoTypeEnum
- type EndpointUpdateReq
- type ErrorInfo
- type EventPubMetricsItem
- type EventStreamingCreateReq
- type EventStreamingCreateReqRuleConfig
- type EventStreamingDetail
- type EventStreamingDetailStatus
- type EventStreamingDetailStatusEnum
- type EventStreamingOperateReq
- type EventStreamingOperateReqOperation
- type EventStreamingOperateReqOperationEnum
- type EventStreamingSink
- type EventStreamingSinkName
- type EventStreamingSinkNameEnum
- type EventStreamingSource
- type EventStreamingSourceName
- type EventStreamingSourceNameEnum
- type EventStreamingUpdateReq
- type EventSubMetricsItem
- type HeaderParameter
- type InvocationHttpParameters
- type KafkaConnectionDetail
- type KafkaConnectionDetailAcks
- type KafkaConnectionDetailAcksEnum
- type KafkaTargetDetail
- type KafkaTargetDetailKeyTransform
- type KafkaTargetDetailKeyTransformType
- type KafkaTargetDetailKeyTransformTypeEnum
- type ListAgenciesRequest
- type ListAgenciesRequestType
- type ListAgenciesRequestTypeEnum
- type ListAgenciesResponse
- type ListApiVersionsRequest
- type ListApiVersionsResponse
- type ListChannelsRequest
- type ListChannelsRequestProviderType
- type ListChannelsRequestProviderTypeEnum
- type ListChannelsResponse
- type ListConnectionsRequest
- type ListConnectionsResponse
- type ListEndpointsRequest
- type ListEndpointsRequestType
- type ListEndpointsRequestTypeEnum
- type ListEndpointsResponse
- type ListEventSourcesRequest
- type ListEventSourcesRequestProviderType
- type ListEventSourcesRequestProviderTypeEnum
- type ListEventSourcesResponse
- type ListEventStreamingRequest
- type ListEventStreamingResponse
- type ListEventTargetRequest
- type ListEventTargetRequestSupportTypes
- type ListEventTargetRequestSupportTypesEnum
- type ListEventTargetResponse
- type ListObsBucketsRequest
- type ListObsBucketsResponse
- type ListPubMetricsRequest
- type ListPubMetricsRequestFilter
- type ListPubMetricsRequestFilterEnum
- type ListPubMetricsRequestProviderType
- type ListPubMetricsRequestProviderTypeEnum
- type ListPubMetricsResponse
- type ListQuotasRequest
- type ListQuotasRequestType
- type ListQuotasRequestTypeEnum
- type ListQuotasResponse
- type ListSubMetricsRequest
- type ListSubMetricsRequestFilter
- type ListSubMetricsRequestFilterEnum
- type ListSubMetricsRequestProviderType
- type ListSubMetricsRequestProviderTypeEnum
- type ListSubMetricsResponse
- type ListSubscriptionsRequest
- type ListSubscriptionsResponse
- type ListTracedEventsRequest
- type ListTracedEventsRespResult
- type ListTracedEventsResponse
- type ListTriggersRequest
- type ListTriggersResponse
- type ListWorkflowTriggersRequest
- type ListWorkflowTriggersResponse
- type ObsBucketInfo
- type ObsBucketInfoOwner
- type OperateSubscriptionRequest
- type OperateSubscriptionResponse
- type PutEventsReq
- type PutEventsRequest
- type PutEventsRespEvents
- type PutEventsResponse
- type PutOfficialEventsRequest
- type PutOfficialEventsResponse
- type QuotaItemInfo
- type QuotaItemInfoType
- type QuotaItemInfoTypeEnum
- type QuotaResourceResp
- type ResumeEventStreamingRequest
- type ResumeEventStreamingResponse
- type RunOption
- type ShowDetailOfChannelRequest
- type ShowDetailOfChannelResponse
- type ShowDetailOfChannelResponseProviderType
- type ShowDetailOfChannelResponseProviderTypeEnum
- type ShowDetailOfConnectionRequest
- type ShowDetailOfConnectionResponse
- type ShowDetailOfConnectionResponseStatus
- type ShowDetailOfConnectionResponseStatusEnum
- type ShowDetailOfEventRequest
- type ShowDetailOfEventResponse
- type ShowDetailOfEventSourceRequest
- type ShowDetailOfEventSourceResponse
- type ShowDetailOfEventSourceResponseProviderType
- type ShowDetailOfEventSourceResponseProviderTypeEnum
- type ShowDetailOfEventSourceResponseStatus
- type ShowDetailOfEventSourceResponseStatusEnum
- type ShowDetailOfEventTraceRequest
- type ShowDetailOfEventTraceResponse
- type ShowDetailOfSubscriptionRequest
- type ShowDetailOfSubscriptionResponse
- type ShowDetailOfSubscriptionResponseStatus
- type ShowDetailOfSubscriptionResponseStatusEnum
- type ShowDetailOfSubscriptionResponseType
- type ShowDetailOfSubscriptionResponseTypeEnum
- type ShowDetailOfSubscriptionTargetRequest
- type ShowDetailOfSubscriptionTargetResponse
- type ShowEventStreamingRequest
- type ShowEventStreamingResponse
- type ShowEventStreamingResponseStatus
- type ShowEventStreamingResponseStatusEnum
- type SinkFgParameters
- type SinkFgParametersInvokeType
- type SinkFgParametersInvokeTypeEnum
- type SmnTargetDetail
- type SmnTargetDetailSubjectTransform
- type SmnTargetDetailSubjectTransformType
- type SmnTargetDetailSubjectTransformTypeEnum
- type SourceKafkaMqParameters
- type SourceKafkaMqParametersSaslMechanism
- type SourceKafkaMqParametersSaslMechanismEnum
- type SourceKafkaMqParametersSeekTo
- type SourceKafkaMqParametersSeekToEnum
- type SubscriptionCreateReq
- type SubscriptionInfo
- type SubscriptionInfoStatus
- type SubscriptionInfoStatusEnum
- type SubscriptionInfoType
- type SubscriptionInfoTypeEnum
- type SubscriptionOperateReq
- type SubscriptionOperateReqOperation
- type SubscriptionOperateReqOperationEnum
- type SubscriptionOperateRespEvents
- type SubscriptionSource
- type SubscriptionSourceInfo
- type SubscriptionSourceProviderType
- type SubscriptionSourceProviderTypeEnum
- type SubscriptionTarget
- type SubscriptionTargetInfo
- type SubscriptionTargetProviderType
- type SubscriptionTargetProviderTypeEnum
- type SubscriptionUpdateReq
- type SubscriptionUsedInfo
- type TransForm
- type TransFormType
- type TransFormTypeEnum
- type UpdateChannelRequest
- type UpdateChannelResponse
- type UpdateChannelResponseProviderType
- type UpdateChannelResponseProviderTypeEnum
- type UpdateConnectionRequest
- type UpdateConnectionResponse
- type UpdateConnectionResponseStatus
- type UpdateConnectionResponseStatusEnum
- type UpdateEndpointRequest
- type UpdateEndpointResponse
- type UpdateEndpointResponseStatus
- type UpdateEndpointResponseStatusEnum
- type UpdateEndpointResponseType
- type UpdateEndpointResponseTypeEnum
- type UpdateEventSourceRequest
- type UpdateEventSourceResponse
- type UpdateEventSourceResponseProviderType
- type UpdateEventSourceResponseProviderTypeEnum
- type UpdateEventSourceResponseStatus
- type UpdateEventSourceResponseStatusEnum
- type UpdateEventStreamingRequest
- type UpdateEventStreamingResponse
- type UpdateSubscriptionRequest
- type UpdateSubscriptionResponse
- type UpdateSubscriptionResponseStatus
- type UpdateSubscriptionResponseStatusEnum
- type UpdateSubscriptionResponseType
- type UpdateSubscriptionResponseTypeEnum
- type UpdateSubscriptionSourceRequest
- type UpdateSubscriptionSourceResponse
- type UpdateSubscriptionTargetRequest
- type UpdateSubscriptionTargetResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgencyCreateReq ¶ added in v0.1.3
type AgencyCreateReq struct { // 服务委托应用场景类型 Type AgencyCreateReqType `json:"type"` }
AgencyCreateReq 服务委托创建请求
func (AgencyCreateReq) String ¶ added in v0.1.3
func (o AgencyCreateReq) String() string
type AgencyCreateReqType ¶ added in v0.1.3
type AgencyCreateReqType struct {
// contains filtered or unexported fields
}
func (AgencyCreateReqType) MarshalJSON ¶ added in v0.1.3
func (c AgencyCreateReqType) MarshalJSON() ([]byte, error)
func (*AgencyCreateReqType) UnmarshalJSON ¶ added in v0.1.3
func (c *AgencyCreateReqType) UnmarshalJSON(b []byte) error
func (AgencyCreateReqType) Value ¶ added in v0.1.3
func (c AgencyCreateReqType) Value() string
type AgencyCreateReqTypeEnum ¶ added in v0.1.3
type AgencyCreateReqTypeEnum struct { TARGET_CONNECTION AgencyCreateReqType CUSTOM_SOURCE_RABBITMQ AgencyCreateReqType EG_RESTORE_AGENCY AgencyCreateReqType }
func GetAgencyCreateReqTypeEnum ¶ added in v0.1.3
func GetAgencyCreateReqTypeEnum() AgencyCreateReqTypeEnum
type ApiVersionsLinks ¶ added in v0.1.3
type ApiVersionsLinks struct { // href属性 Href *string `json:"href,omitempty"` // rel属性 Rel *string `json:"rel,omitempty"` }
func (ApiVersionsLinks) String ¶ added in v0.1.3
func (o ApiVersionsLinks) String() string
type ApiVersionsVersions ¶ added in v0.1.3
type ApiVersionsVersions struct { // 版本号,如v1 Id *string `json:"id,omitempty"` // url地址 Links *[]ApiVersionsLinks `json:"links,omitempty"` // 若该版本API支持微版本,则为支持的最大微版本号,如果不支持微版本,则为空 Version *string `json:"version,omitempty"` // 若该版本API支持微版本,则为支持的最小微版本号,如果不支持微版本,则为空 MinVersion *string `json:"min_version,omitempty"` // 版本状态,支持CURRENT:推荐版本;SUPPORTED:老版本,仍支持使用;DEPRECATED:废弃版本,后续会删除 Status *ApiVersionsVersionsStatus `json:"status,omitempty"` // 版本发布UTC时间 Updated *string `json:"updated,omitempty"` }
func (ApiVersionsVersions) String ¶ added in v0.1.3
func (o ApiVersionsVersions) String() string
type ApiVersionsVersionsStatus ¶ added in v0.1.3
type ApiVersionsVersionsStatus struct {
// contains filtered or unexported fields
}
func (ApiVersionsVersionsStatus) MarshalJSON ¶ added in v0.1.3
func (c ApiVersionsVersionsStatus) MarshalJSON() ([]byte, error)
func (*ApiVersionsVersionsStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *ApiVersionsVersionsStatus) UnmarshalJSON(b []byte) error
func (ApiVersionsVersionsStatus) Value ¶ added in v0.1.3
func (c ApiVersionsVersionsStatus) Value() string
type ApiVersionsVersionsStatusEnum ¶ added in v0.1.3
type ApiVersionsVersionsStatusEnum struct { CURRENT ApiVersionsVersionsStatus SUPPORTED ApiVersionsVersionsStatus DEPRECATED ApiVersionsVersionsStatus }
func GetApiVersionsVersionsStatusEnum ¶ added in v0.1.3
func GetApiVersionsVersionsStatusEnum() ApiVersionsVersionsStatusEnum
type BatchWindow ¶ added in v0.1.42
type BatchWindow struct { // 批量推送条数[1,10000] Count *int32 `json:"count,omitempty"` // 重试次数 Time *int32 `json:"time,omitempty"` // 批量推送间隔[0,15](时间:秒) Interval *int32 `json:"interval,omitempty"` }
func (BatchWindow) String ¶ added in v0.1.42
func (o BatchWindow) String() string
type CatalogTargetInfo ¶
type CatalogTargetInfo struct { // 事件目标分类ID Id *string `json:"id,omitempty"` // 事件目标分类名称 Name *string `json:"name,omitempty"` // 事件目标分类名称展示说明 Label *string `json:"label,omitempty"` // 事件目标分类描述 Description *string `json:"description,omitempty"` // 提供方类型,OFFICIAL:官方云服务事件目标;CUSTOM:第三方事件目标 ProviderType *CatalogTargetInfoProviderType `json:"provider_type,omitempty"` Parameters *[]interface{} `json:"parameters,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` }
func (CatalogTargetInfo) String ¶
func (o CatalogTargetInfo) String() string
type CatalogTargetInfoProviderType ¶
type CatalogTargetInfoProviderType struct {
// contains filtered or unexported fields
}
func (CatalogTargetInfoProviderType) MarshalJSON ¶
func (c CatalogTargetInfoProviderType) MarshalJSON() ([]byte, error)
func (*CatalogTargetInfoProviderType) UnmarshalJSON ¶
func (c *CatalogTargetInfoProviderType) UnmarshalJSON(b []byte) error
func (CatalogTargetInfoProviderType) Value ¶
func (c CatalogTargetInfoProviderType) Value() string
type CatalogTargetInfoProviderTypeEnum ¶
type CatalogTargetInfoProviderTypeEnum struct { OFFICIAL CatalogTargetInfoProviderType CUSTOM CatalogTargetInfoProviderType }
func GetCatalogTargetInfoProviderTypeEnum ¶
func GetCatalogTargetInfoProviderTypeEnum() CatalogTargetInfoProviderTypeEnum
type ChannelCreateReq ¶
type ChannelCreateReq struct { // 通道名称,租户下唯一,由字母,数字,点,下划线和中划线组成,必须字母或数字开头,不能是default Name string `json:"name"` // 通道描述 Description *string `json:"description,omitempty"` }
func (ChannelCreateReq) String ¶
func (o ChannelCreateReq) String() string
type ChannelInfo ¶
type ChannelInfo struct { // 通道ID Id *string `json:"id,omitempty"` // 通道名称 Name *string `json:"name,omitempty"` // 通道描述 Description *string `json:"description,omitempty"` // 通道提供方类型,OFFICIAL:官方事件通道;CUSTOM:自定义事件通道;PARTNER:伙伴事件通道 ProviderType *ChannelInfoProviderType `json:"provider_type,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` }
func (ChannelInfo) String ¶
func (o ChannelInfo) String() string
type ChannelInfoProviderType ¶
type ChannelInfoProviderType struct {
// contains filtered or unexported fields
}
func (ChannelInfoProviderType) MarshalJSON ¶
func (c ChannelInfoProviderType) MarshalJSON() ([]byte, error)
func (*ChannelInfoProviderType) UnmarshalJSON ¶
func (c *ChannelInfoProviderType) UnmarshalJSON(b []byte) error
func (ChannelInfoProviderType) Value ¶
func (c ChannelInfoProviderType) Value() string
type ChannelInfoProviderTypeEnum ¶
type ChannelInfoProviderTypeEnum struct { OFFICIAL ChannelInfoProviderType CUSTOM ChannelInfoProviderType PARTNER ChannelInfoProviderType }
func GetChannelInfoProviderTypeEnum ¶
func GetChannelInfoProviderTypeEnum() ChannelInfoProviderTypeEnum
type ChannelUpdateReq ¶
type ChannelUpdateReq struct { // 通道描述 Description *string `json:"description,omitempty"` }
func (ChannelUpdateReq) String ¶
func (o ChannelUpdateReq) String() string
type CheckPutEventsReq ¶ added in v0.1.28
type CheckPutEventsReq struct {
Sources *[]CheckPutEventsReqSources `json:"sources,omitempty"`
}
func (CheckPutEventsReq) String ¶ added in v0.1.28
func (o CheckPutEventsReq) String() string
type CheckPutEventsReqSources ¶ added in v0.1.28
type CheckPutEventsReqSources struct { // 事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 事件源名称 SourceName *string `json:"source_name,omitempty"` }
func (CheckPutEventsReqSources) String ¶ added in v0.1.28
func (o CheckPutEventsReqSources) String() string
type CheckPutEventsRequest ¶ added in v0.1.28
type CheckPutEventsRequest struct {
Body *CheckPutEventsReq `json:"body,omitempty"`
}
CheckPutEventsRequest Request Object
func (CheckPutEventsRequest) String ¶ added in v0.1.28
func (o CheckPutEventsRequest) String() string
type CheckPutEventsResponse ¶ added in v0.1.28
type CheckPutEventsResponse struct { // 预校验发布事件失败的个数 FailedCount *int32 `json:"failed_count,omitempty"` Sources *[]CheckPutEventsResult `json:"sources,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CheckPutEventsResponse Response Object
func (CheckPutEventsResponse) String ¶ added in v0.1.28
func (o CheckPutEventsResponse) String() string
type CheckPutEventsResult ¶ added in v0.1.28
type CheckPutEventsResult struct { // 事件通道id ChannelId *string `json:"channel_id,omitempty"` // 事件源名称 SourceName *string `json:"source_name,omitempty"` // 发送事件是否成功检查结果 CheckResult *bool `json:"check_result,omitempty"` // 发送事件是否成功检查明细 CheckDetail *string `json:"check_detail,omitempty"` }
func (CheckPutEventsResult) String ¶ added in v0.1.28
func (o CheckPutEventsResult) String() string
type CloudEvents ¶
type CloudEvents struct { // 事件唯一标识串,同一个事件来源里必须唯一 Id string `json:"id"` // 事件来源上下文标识串,source+id可以唯一确定一个事件。采用URI-Reference格式,参考https://tools.ietf.org/html/rfc3986#section-4.1 Source string `json:"source"` // CloudEvents协议版本,格式为major.minor Specversion string `json:"specversion"` // 事件类型 Type string `json:"type"` // 事件内容格式,采用MIME格式,遵循RFC2046,参考https://tools.ietf.org/html/rfc2046 Datacontenttype *string `json:"datacontenttype,omitempty"` // 事件内容模型定义的URI,遵循RFC3986,参考https://tools.ietf.org/html/rfc3986#section-4.3 Dataschema *string `json:"dataschema,omitempty"` // 事件的负载内容,采用datacontenttype字段指定的格式,内容字段遵循dataschema字段的描述 Data *interface{} `json:"data,omitempty"` // 事件发生UTC日期时间,相同来源的事件格式相同,遵循RFC3339,格式需满足2018-04-05T17:31:00Z,参考https://tools.ietf.org/html/rfc3339 Time *string `json:"time,omitempty"` // 事件发生的主题或对象,用以标识哪个具体对象发生了当前事件 Subject *string `json:"subject,omitempty"` }
CloudEvents CloudEvents事件格式定义,参考https://github.com/cloudevents/spec/blob/v1.0.1/spec.md
func (CloudEvents) String ¶
func (o CloudEvents) String() string
type ConnectionCreateReq ¶ added in v0.1.3
type ConnectionCreateReq struct { // 目标连接名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default Name string `json:"name"` // 目标连接描述 Description *string `json:"description,omitempty"` // 待连接的VPC ID VpcId string `json:"vpc_id"` // 待连接的子网ID SubnetId string `json:"subnet_id"` Type *ConnectionType `json:"type,omitempty"` KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"` }
func (ConnectionCreateReq) String ¶ added in v0.1.3
func (o ConnectionCreateReq) String() string
type ConnectionInfo ¶ added in v0.1.3
type ConnectionInfo struct { // 事件源ID Id *string `json:"id,omitempty"` // 目标连接名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default Name *string `json:"name,omitempty"` // 目标连接描述 Description *string `json:"description,omitempty"` // 目标连接状态 Status *ConnectionInfoStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` // 待连接的VPC ID VpcId *string `json:"vpc_id,omitempty"` // 待连接的子网ID SubnetId *string `json:"subnet_id,omitempty"` // 私网目标连接使用的用户委托名称 Agency *string `json:"agency,omitempty"` Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"` Type *ConnectionType `json:"type,omitempty"` KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` }
func (ConnectionInfo) String ¶ added in v0.1.3
func (o ConnectionInfo) String() string
type ConnectionInfoFlavor ¶ added in v0.1.3
type ConnectionInfoFlavor struct { // 规格名称 Name *string `json:"name,omitempty"` // 并发规格类型 ConcurrencyType *ConnectionInfoFlavorConcurrencyType `json:"concurrency_type,omitempty"` // 并发数 Concurrency *int32 `json:"concurrency,omitempty"` // 带宽类型 BandwidthType *ConnectionInfoFlavorBandwidthType `json:"bandwidth_type,omitempty"` }
ConnectionInfoFlavor 规格
func (ConnectionInfoFlavor) String ¶ added in v0.1.3
func (o ConnectionInfoFlavor) String() string
type ConnectionInfoFlavorBandwidthType ¶ added in v0.1.3
type ConnectionInfoFlavorBandwidthType struct {
// contains filtered or unexported fields
}
func (ConnectionInfoFlavorBandwidthType) MarshalJSON ¶ added in v0.1.3
func (c ConnectionInfoFlavorBandwidthType) MarshalJSON() ([]byte, error)
func (*ConnectionInfoFlavorBandwidthType) UnmarshalJSON ¶ added in v0.1.3
func (c *ConnectionInfoFlavorBandwidthType) UnmarshalJSON(b []byte) error
func (ConnectionInfoFlavorBandwidthType) Value ¶ added in v0.1.3
func (c ConnectionInfoFlavorBandwidthType) Value() string
type ConnectionInfoFlavorBandwidthTypeEnum ¶ added in v0.1.3
type ConnectionInfoFlavorBandwidthTypeEnum struct { SHARED ConnectionInfoFlavorBandwidthType EXCLUSIVE ConnectionInfoFlavorBandwidthType }
func GetConnectionInfoFlavorBandwidthTypeEnum ¶ added in v0.1.3
func GetConnectionInfoFlavorBandwidthTypeEnum() ConnectionInfoFlavorBandwidthTypeEnum
type ConnectionInfoFlavorConcurrencyType ¶ added in v0.1.3
type ConnectionInfoFlavorConcurrencyType struct {
// contains filtered or unexported fields
}
func (ConnectionInfoFlavorConcurrencyType) MarshalJSON ¶ added in v0.1.3
func (c ConnectionInfoFlavorConcurrencyType) MarshalJSON() ([]byte, error)
func (*ConnectionInfoFlavorConcurrencyType) UnmarshalJSON ¶ added in v0.1.3
func (c *ConnectionInfoFlavorConcurrencyType) UnmarshalJSON(b []byte) error
func (ConnectionInfoFlavorConcurrencyType) Value ¶ added in v0.1.3
func (c ConnectionInfoFlavorConcurrencyType) Value() string
type ConnectionInfoFlavorConcurrencyTypeEnum ¶ added in v0.1.3
type ConnectionInfoFlavorConcurrencyTypeEnum struct { SHARED ConnectionInfoFlavorConcurrencyType EXCLUSIVE ConnectionInfoFlavorConcurrencyType }
func GetConnectionInfoFlavorConcurrencyTypeEnum ¶ added in v0.1.3
func GetConnectionInfoFlavorConcurrencyTypeEnum() ConnectionInfoFlavorConcurrencyTypeEnum
type ConnectionInfoStatus ¶ added in v0.1.3
type ConnectionInfoStatus struct {
// contains filtered or unexported fields
}
func (ConnectionInfoStatus) MarshalJSON ¶ added in v0.1.3
func (c ConnectionInfoStatus) MarshalJSON() ([]byte, error)
func (*ConnectionInfoStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *ConnectionInfoStatus) UnmarshalJSON(b []byte) error
func (ConnectionInfoStatus) Value ¶ added in v0.1.3
func (c ConnectionInfoStatus) Value() string
type ConnectionInfoStatusEnum ¶ added in v0.1.3
type ConnectionInfoStatusEnum struct { CREATING ConnectionInfoStatus CREATED ConnectionInfoStatus CREATE_FAILED ConnectionInfoStatus }
func GetConnectionInfoStatusEnum ¶ added in v0.1.3
func GetConnectionInfoStatusEnum() ConnectionInfoStatusEnum
type ConnectionType ¶ added in v0.1.42
type ConnectionType struct {
// contains filtered or unexported fields
}
ConnectionType 目标连接类型。目前支持webhook:http连接;kafka:华为云官方kafka实例
func (ConnectionType) MarshalJSON ¶ added in v0.1.42
func (c ConnectionType) MarshalJSON() ([]byte, error)
func (*ConnectionType) UnmarshalJSON ¶ added in v0.1.42
func (c *ConnectionType) UnmarshalJSON(b []byte) error
func (ConnectionType) Value ¶ added in v0.1.42
func (c ConnectionType) Value() string
type ConnectionTypeEnum ¶ added in v0.1.42
type ConnectionTypeEnum struct { WEBHOOK ConnectionType KAFKA ConnectionType }
func GetConnectionTypeEnum ¶ added in v0.1.42
func GetConnectionTypeEnum() ConnectionTypeEnum
type ConnectionUpdateReq ¶ added in v0.1.3
type ConnectionUpdateReq struct { // 目标连接描述 Description *string `json:"description,omitempty"` }
func (ConnectionUpdateReq) String ¶ added in v0.1.3
func (o ConnectionUpdateReq) String() string
type CreateAgenciesRequest ¶ added in v0.1.3
type CreateAgenciesRequest struct {
Body *AgencyCreateReq `json:"body,omitempty"`
}
CreateAgenciesRequest Request Object
func (CreateAgenciesRequest) String ¶ added in v0.1.3
func (o CreateAgenciesRequest) String() string
type CreateAgenciesResponse ¶ added in v0.1.3
type CreateAgenciesResponse struct { // 服务委托授权记录。 Agencies *[]string `json:"agencies,omitempty"` HttpStatusCode int `json:"-"` }
CreateAgenciesResponse Response Object
func (CreateAgenciesResponse) String ¶ added in v0.1.3
func (o CreateAgenciesResponse) String() string
type CreateChannelRequest ¶
type CreateChannelRequest struct {
Body *ChannelCreateReq `json:"body,omitempty"`
}
CreateChannelRequest Request Object
func (CreateChannelRequest) String ¶
func (o CreateChannelRequest) String() string
type CreateChannelResponse ¶
type CreateChannelResponse struct { // 通道ID Id *string `json:"id,omitempty"` // 通道名称 Name *string `json:"name,omitempty"` // 通道描述 Description *string `json:"description,omitempty"` // 通道提供方类型,OFFICIAL:官方事件通道;CUSTOM:自定义事件通道;PARTNER:伙伴事件通道 ProviderType *CreateChannelResponseProviderType `json:"provider_type,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CreateChannelResponse Response Object
func (CreateChannelResponse) String ¶
func (o CreateChannelResponse) String() string
type CreateChannelResponseProviderType ¶
type CreateChannelResponseProviderType struct {
// contains filtered or unexported fields
}
func (CreateChannelResponseProviderType) MarshalJSON ¶
func (c CreateChannelResponseProviderType) MarshalJSON() ([]byte, error)
func (*CreateChannelResponseProviderType) UnmarshalJSON ¶
func (c *CreateChannelResponseProviderType) UnmarshalJSON(b []byte) error
func (CreateChannelResponseProviderType) Value ¶
func (c CreateChannelResponseProviderType) Value() string
type CreateChannelResponseProviderTypeEnum ¶
type CreateChannelResponseProviderTypeEnum struct { OFFICIAL CreateChannelResponseProviderType CUSTOM CreateChannelResponseProviderType PARTNER CreateChannelResponseProviderType }
func GetCreateChannelResponseProviderTypeEnum ¶
func GetCreateChannelResponseProviderTypeEnum() CreateChannelResponseProviderTypeEnum
type CreateConnectionRequest ¶ added in v0.1.3
type CreateConnectionRequest struct {
Body *ConnectionCreateReq `json:"body,omitempty"`
}
CreateConnectionRequest Request Object
func (CreateConnectionRequest) String ¶ added in v0.1.3
func (o CreateConnectionRequest) String() string
type CreateConnectionResponse ¶ added in v0.1.3
type CreateConnectionResponse struct { // 事件源ID Id *string `json:"id,omitempty"` // 目标连接名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default Name *string `json:"name,omitempty"` // 目标连接描述 Description *string `json:"description,omitempty"` // 目标连接状态 Status *CreateConnectionResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` // 待连接的VPC ID VpcId *string `json:"vpc_id,omitempty"` // 待连接的子网ID SubnetId *string `json:"subnet_id,omitempty"` // 私网目标连接使用的用户委托名称 Agency *string `json:"agency,omitempty"` Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"` Type *ConnectionType `json:"type,omitempty"` KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CreateConnectionResponse Response Object
func (CreateConnectionResponse) String ¶ added in v0.1.3
func (o CreateConnectionResponse) String() string
type CreateConnectionResponseStatus ¶ added in v0.1.3
type CreateConnectionResponseStatus struct {
// contains filtered or unexported fields
}
func (CreateConnectionResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c CreateConnectionResponseStatus) MarshalJSON() ([]byte, error)
func (*CreateConnectionResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *CreateConnectionResponseStatus) UnmarshalJSON(b []byte) error
func (CreateConnectionResponseStatus) Value ¶ added in v0.1.3
func (c CreateConnectionResponseStatus) Value() string
type CreateConnectionResponseStatusEnum ¶ added in v0.1.3
type CreateConnectionResponseStatusEnum struct { CREATING CreateConnectionResponseStatus CREATED CreateConnectionResponseStatus CREATE_FAILED CreateConnectionResponseStatus }
func GetCreateConnectionResponseStatusEnum ¶ added in v0.1.3
func GetCreateConnectionResponseStatusEnum() CreateConnectionResponseStatusEnum
type CreateEndpointRequest ¶ added in v0.1.3
type CreateEndpointRequest struct {
Body *EndpointCreateReq `json:"body,omitempty"`
}
CreateEndpointRequest Request Object
func (CreateEndpointRequest) String ¶ added in v0.1.3
func (o CreateEndpointRequest) String() string
type CreateEndpointResponse ¶ added in v0.1.3
type CreateEndpointResponse struct { // 访问端点ID Id *string `json:"id,omitempty"` // 用户指定的访问端点名称 Name *string `json:"name,omitempty"` // 访问端点所在的VPC的ID VpcId *string `json:"vpc_id,omitempty"` // 访问端点所在的子网的ID SubnetId *string `json:"subnet_id,omitempty"` // 访问域名 Domain *string `json:"domain,omitempty"` // 描述 Description *string `json:"description,omitempty"` // 访问端点状态 Status *CreateEndpointResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` // 访问端点类型 Type *CreateEndpointResponseType `json:"type,omitempty"` // 是否可更新 Scalable *bool `json:"scalable,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` // 访问端点终端节点列表 Endpoints *[]EndpointConnection `json:"endpoints,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CreateEndpointResponse Response Object
func (CreateEndpointResponse) String ¶ added in v0.1.3
func (o CreateEndpointResponse) String() string
type CreateEndpointResponseStatus ¶ added in v0.1.3
type CreateEndpointResponseStatus struct {
// contains filtered or unexported fields
}
func (CreateEndpointResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c CreateEndpointResponseStatus) MarshalJSON() ([]byte, error)
func (*CreateEndpointResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *CreateEndpointResponseStatus) UnmarshalJSON(b []byte) error
func (CreateEndpointResponseStatus) Value ¶ added in v0.1.3
func (c CreateEndpointResponseStatus) Value() string
type CreateEndpointResponseStatusEnum ¶ added in v0.1.3
type CreateEndpointResponseStatusEnum struct { CREATED CreateEndpointResponseStatus CREATING CreateEndpointResponseStatus CREATE_FAILED CreateEndpointResponseStatus DELETE_FAILED CreateEndpointResponseStatus }
func GetCreateEndpointResponseStatusEnum ¶ added in v0.1.3
func GetCreateEndpointResponseStatusEnum() CreateEndpointResponseStatusEnum
type CreateEndpointResponseType ¶ added in v0.1.3
type CreateEndpointResponseType struct {
// contains filtered or unexported fields
}
func (CreateEndpointResponseType) MarshalJSON ¶ added in v0.1.3
func (c CreateEndpointResponseType) MarshalJSON() ([]byte, error)
func (*CreateEndpointResponseType) UnmarshalJSON ¶ added in v0.1.3
func (c *CreateEndpointResponseType) UnmarshalJSON(b []byte) error
func (CreateEndpointResponseType) Value ¶ added in v0.1.3
func (c CreateEndpointResponseType) Value() string
type CreateEndpointResponseTypeEnum ¶ added in v0.1.3
type CreateEndpointResponseTypeEnum struct { PRIVATE CreateEndpointResponseType PUBLIC CreateEndpointResponseType }
func GetCreateEndpointResponseTypeEnum ¶ added in v0.1.3
func GetCreateEndpointResponseTypeEnum() CreateEndpointResponseTypeEnum
type CreateEventSourceRequest ¶
type CreateEventSourceRequest struct {
Body *CustomizeSourceCreateReq `json:"body,omitempty"`
}
CreateEventSourceRequest Request Object
func (CreateEventSourceRequest) String ¶
func (o CreateEventSourceRequest) String() string
type CreateEventSourceResponse ¶
type CreateEventSourceResponse struct { // 事件源ID Id *string `json:"id,omitempty"` // 事件源名称 Name *string `json:"name,omitempty"` // 事件源名称展示 Label *string `json:"label,omitempty"` // 事件源描述 Description *string `json:"description,omitempty"` // 事件源提供方类型,OFFICIAL:官方云服务事件源;CUSTOM:用户创建的自定义事件源;PARTNER:伙伴事件源 ProviderType *CreateEventSourceResponseProviderType `json:"provider_type,omitempty"` // 事件源提供的事件类型列表,只有官方云服务事件源提供事件类型 EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` // 事件源归属的事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 事件源归属的事件通道名称 ChannelName *string `json:"channel_name,omitempty"` // 事件源类型 Type *string `json:"type,omitempty"` // json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等 Detail *interface{} `json:"detail,omitempty"` // 自定义事件源状态 Status *CreateEventSourceResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CreateEventSourceResponse Response Object
func (CreateEventSourceResponse) String ¶
func (o CreateEventSourceResponse) String() string
type CreateEventSourceResponseProviderType ¶
type CreateEventSourceResponseProviderType struct {
// contains filtered or unexported fields
}
func (CreateEventSourceResponseProviderType) MarshalJSON ¶
func (c CreateEventSourceResponseProviderType) MarshalJSON() ([]byte, error)
func (*CreateEventSourceResponseProviderType) UnmarshalJSON ¶
func (c *CreateEventSourceResponseProviderType) UnmarshalJSON(b []byte) error
func (CreateEventSourceResponseProviderType) Value ¶
func (c CreateEventSourceResponseProviderType) Value() string
type CreateEventSourceResponseProviderTypeEnum ¶
type CreateEventSourceResponseProviderTypeEnum struct { OFFICIAL CreateEventSourceResponseProviderType CUSTOM CreateEventSourceResponseProviderType PARTNER CreateEventSourceResponseProviderType }
func GetCreateEventSourceResponseProviderTypeEnum ¶
func GetCreateEventSourceResponseProviderTypeEnum() CreateEventSourceResponseProviderTypeEnum
type CreateEventSourceResponseStatus ¶ added in v0.1.3
type CreateEventSourceResponseStatus struct {
// contains filtered or unexported fields
}
func (CreateEventSourceResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c CreateEventSourceResponseStatus) MarshalJSON() ([]byte, error)
func (*CreateEventSourceResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *CreateEventSourceResponseStatus) UnmarshalJSON(b []byte) error
func (CreateEventSourceResponseStatus) Value ¶ added in v0.1.3
func (c CreateEventSourceResponseStatus) Value() string
type CreateEventSourceResponseStatusEnum ¶ added in v0.1.3
type CreateEventSourceResponseStatusEnum struct { CREATE_FAILED CreateEventSourceResponseStatus RUNNING CreateEventSourceResponseStatus ERROR CreateEventSourceResponseStatus }
func GetCreateEventSourceResponseStatusEnum ¶ added in v0.1.3
func GetCreateEventSourceResponseStatusEnum() CreateEventSourceResponseStatusEnum
type CreateEventStreamingRequest ¶ added in v0.1.42
type CreateEventStreamingRequest struct {
Body *EventStreamingCreateReq `json:"body,omitempty"`
}
CreateEventStreamingRequest Request Object
func (CreateEventStreamingRequest) String ¶ added in v0.1.42
func (o CreateEventStreamingRequest) String() string
type CreateEventStreamingResponse ¶ added in v0.1.42
type CreateEventStreamingResponse struct { // 事件流ID EventStreamingID *string `json:"eventStreamingID,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CreateEventStreamingResponse Response Object
func (CreateEventStreamingResponse) String ¶ added in v0.1.42
func (o CreateEventStreamingResponse) String() string
type CreateSubscriptionRequest ¶
type CreateSubscriptionRequest struct {
Body *SubscriptionCreateReq `json:"body,omitempty"`
}
CreateSubscriptionRequest Request Object
func (CreateSubscriptionRequest) String ¶
func (o CreateSubscriptionRequest) String() string
type CreateSubscriptionResponse ¶
type CreateSubscriptionResponse struct { // 订阅ID Id *string `json:"id,omitempty"` // 订阅名称 Name *string `json:"name,omitempty"` // 订阅描述 Description *string `json:"description,omitempty"` // 类型 Type *CreateSubscriptionResponseType `json:"type,omitempty"` // 状态 Status *CreateSubscriptionResponseStatus `json:"status,omitempty"` // 通道ID ChannelId *string `json:"channel_id,omitempty"` // 通道名称 ChannelName *string `json:"channel_name,omitempty"` // 标签信息 Used *[]SubscriptionUsedInfo `json:"used,omitempty"` // 订阅源列表 Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"` // 订阅目标列表 Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CreateSubscriptionResponse Response Object
func (CreateSubscriptionResponse) String ¶
func (o CreateSubscriptionResponse) String() string
type CreateSubscriptionResponseStatus ¶
type CreateSubscriptionResponseStatus struct {
// contains filtered or unexported fields
}
func (CreateSubscriptionResponseStatus) MarshalJSON ¶
func (c CreateSubscriptionResponseStatus) MarshalJSON() ([]byte, error)
func (*CreateSubscriptionResponseStatus) UnmarshalJSON ¶
func (c *CreateSubscriptionResponseStatus) UnmarshalJSON(b []byte) error
func (CreateSubscriptionResponseStatus) Value ¶
func (c CreateSubscriptionResponseStatus) Value() string
type CreateSubscriptionResponseStatusEnum ¶
type CreateSubscriptionResponseStatusEnum struct { CREATED CreateSubscriptionResponseStatus ENABLED CreateSubscriptionResponseStatus DISABLED CreateSubscriptionResponseStatus FROZEN CreateSubscriptionResponseStatus ERROR CreateSubscriptionResponseStatus }
func GetCreateSubscriptionResponseStatusEnum ¶
func GetCreateSubscriptionResponseStatusEnum() CreateSubscriptionResponseStatusEnum
type CreateSubscriptionResponseType ¶
type CreateSubscriptionResponseType struct {
// contains filtered or unexported fields
}
func (CreateSubscriptionResponseType) MarshalJSON ¶
func (c CreateSubscriptionResponseType) MarshalJSON() ([]byte, error)
func (*CreateSubscriptionResponseType) UnmarshalJSON ¶
func (c *CreateSubscriptionResponseType) UnmarshalJSON(b []byte) error
func (CreateSubscriptionResponseType) Value ¶
func (c CreateSubscriptionResponseType) Value() string
type CreateSubscriptionResponseTypeEnum ¶
type CreateSubscriptionResponseTypeEnum struct { EVENT CreateSubscriptionResponseType SCHEDULED CreateSubscriptionResponseType }
func GetCreateSubscriptionResponseTypeEnum ¶
func GetCreateSubscriptionResponseTypeEnum() CreateSubscriptionResponseTypeEnum
type CreateSubscriptionTargetRequest ¶
type CreateSubscriptionTargetRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` Body *SubscriptionTarget `json:"body,omitempty"` }
CreateSubscriptionTargetRequest Request Object
func (CreateSubscriptionTargetRequest) String ¶
func (o CreateSubscriptionTargetRequest) String() string
type CreateSubscriptionTargetResponse ¶
type CreateSubscriptionTargetResponse struct { // 订阅目标ID Id *string `json:"id,omitempty"` // 订阅的事件目标名称 Name *string `json:"name,omitempty"` // 订阅的事件目标的提供方类型 ProviderType *string `json:"provider_type,omitempty"` // 订阅的事件目标使用的目标链接ID ConnectionId *string `json:"connection_id,omitempty"` // 订阅的事件目标参数列表 Detail *interface{} `json:"detail,omitempty"` Transform *TransForm `json:"transform,omitempty"` DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
CreateSubscriptionTargetResponse Response Object
func (CreateSubscriptionTargetResponse) String ¶
func (o CreateSubscriptionTargetResponse) String() string
type CustomizeSourceCreateReq ¶
type CustomizeSourceCreateReq struct { // 自定义事件源名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,且不能以hc.开头 Name string `json:"name"` // 事件源描述 Description *string `json:"description,omitempty"` // 指导事件源归属的事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 事件源类型 Type *CustomizeSourceCreateReqType `json:"type,omitempty"` // json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等 Detail *interface{} `json:"detail,omitempty"` }
func (CustomizeSourceCreateReq) String ¶
func (o CustomizeSourceCreateReq) String() string
type CustomizeSourceCreateReqType ¶ added in v0.1.3
type CustomizeSourceCreateReqType struct {
// contains filtered or unexported fields
}
func (CustomizeSourceCreateReqType) MarshalJSON ¶ added in v0.1.3
func (c CustomizeSourceCreateReqType) MarshalJSON() ([]byte, error)
func (*CustomizeSourceCreateReqType) UnmarshalJSON ¶ added in v0.1.3
func (c *CustomizeSourceCreateReqType) UnmarshalJSON(b []byte) error
func (CustomizeSourceCreateReqType) Value ¶ added in v0.1.3
func (c CustomizeSourceCreateReqType) Value() string
type CustomizeSourceCreateReqTypeEnum ¶ added in v0.1.3
type CustomizeSourceCreateReqTypeEnum struct { APPLICATION CustomizeSourceCreateReqType RABBITMQ CustomizeSourceCreateReqType ROCKETMQ CustomizeSourceCreateReqType }
func GetCustomizeSourceCreateReqTypeEnum ¶ added in v0.1.3
func GetCustomizeSourceCreateReqTypeEnum() CustomizeSourceCreateReqTypeEnum
type CustomizeSourceInfo ¶ added in v0.1.3
type CustomizeSourceInfo struct { // 事件源ID Id *string `json:"id,omitempty"` // 事件源名称 Name *string `json:"name,omitempty"` // 事件源名称展示 Label *string `json:"label,omitempty"` // 事件源描述 Description *string `json:"description,omitempty"` // 事件源提供方类型,OFFICIAL:官方云服务事件源;CUSTOM:用户创建的自定义事件源;PARTNER:伙伴事件源 ProviderType *CustomizeSourceInfoProviderType `json:"provider_type,omitempty"` // 事件源提供的事件类型列表,只有官方云服务事件源提供事件类型 EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` // 事件源归属的事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 事件源归属的事件通道名称 ChannelName *string `json:"channel_name,omitempty"` // 事件源类型 Type *string `json:"type,omitempty"` // json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等 Detail *interface{} `json:"detail,omitempty"` // 自定义事件源状态 Status *CustomizeSourceInfoStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` }
func (CustomizeSourceInfo) String ¶ added in v0.1.3
func (o CustomizeSourceInfo) String() string
type CustomizeSourceInfoEventTypes ¶ added in v0.1.3
type CustomizeSourceInfoEventTypes struct { // 事件类型名称 Name *string `json:"name,omitempty"` // 事件类型描述 Description *string `json:"description,omitempty"` }
func (CustomizeSourceInfoEventTypes) String ¶ added in v0.1.3
func (o CustomizeSourceInfoEventTypes) String() string
type CustomizeSourceInfoProviderType ¶ added in v0.1.3
type CustomizeSourceInfoProviderType struct {
// contains filtered or unexported fields
}
func (CustomizeSourceInfoProviderType) MarshalJSON ¶ added in v0.1.3
func (c CustomizeSourceInfoProviderType) MarshalJSON() ([]byte, error)
func (*CustomizeSourceInfoProviderType) UnmarshalJSON ¶ added in v0.1.3
func (c *CustomizeSourceInfoProviderType) UnmarshalJSON(b []byte) error
func (CustomizeSourceInfoProviderType) Value ¶ added in v0.1.3
func (c CustomizeSourceInfoProviderType) Value() string
type CustomizeSourceInfoProviderTypeEnum ¶ added in v0.1.3
type CustomizeSourceInfoProviderTypeEnum struct { OFFICIAL CustomizeSourceInfoProviderType CUSTOM CustomizeSourceInfoProviderType PARTNER CustomizeSourceInfoProviderType }
func GetCustomizeSourceInfoProviderTypeEnum ¶ added in v0.1.3
func GetCustomizeSourceInfoProviderTypeEnum() CustomizeSourceInfoProviderTypeEnum
type CustomizeSourceInfoStatus ¶ added in v0.1.3
type CustomizeSourceInfoStatus struct {
// contains filtered or unexported fields
}
func (CustomizeSourceInfoStatus) MarshalJSON ¶ added in v0.1.3
func (c CustomizeSourceInfoStatus) MarshalJSON() ([]byte, error)
func (*CustomizeSourceInfoStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *CustomizeSourceInfoStatus) UnmarshalJSON(b []byte) error
func (CustomizeSourceInfoStatus) Value ¶ added in v0.1.3
func (c CustomizeSourceInfoStatus) Value() string
type CustomizeSourceInfoStatusEnum ¶ added in v0.1.3
type CustomizeSourceInfoStatusEnum struct { CREATE_FAILED CustomizeSourceInfoStatus RUNNING CustomizeSourceInfoStatus ERROR CustomizeSourceInfoStatus }
func GetCustomizeSourceInfoStatusEnum ¶ added in v0.1.3
func GetCustomizeSourceInfoStatusEnum() CustomizeSourceInfoStatusEnum
type CustomizeSourceUpdateReq ¶
type CustomizeSourceUpdateReq struct { // 事件源描述 Description *string `json:"description,omitempty"` // json格式封装消息实例更新信息:如RabbitMQ实例的虚拟主机vhost字段、队列queue字段、用户密码 Detail *interface{} `json:"detail,omitempty"` }
func (CustomizeSourceUpdateReq) String ¶
func (o CustomizeSourceUpdateReq) String() string
type DeadLetterQueue ¶ added in v0.1.52
type DeadLetterQueue struct { // 队列类型 Type DeadLetterQueueType `json:"type"` // 实例id InstanceId string `json:"instance_id"` // 目标连接id ConnectionId string `json:"connection_id"` // 主题 Topic string `json:"topic"` }
DeadLetterQueue 订阅的死信参数列表
func (DeadLetterQueue) String ¶ added in v0.1.52
func (o DeadLetterQueue) String() string
type DeadLetterQueueType ¶ added in v0.1.52
type DeadLetterQueueType struct {
// contains filtered or unexported fields
}
func (DeadLetterQueueType) MarshalJSON ¶ added in v0.1.52
func (c DeadLetterQueueType) MarshalJSON() ([]byte, error)
func (*DeadLetterQueueType) UnmarshalJSON ¶ added in v0.1.52
func (c *DeadLetterQueueType) UnmarshalJSON(b []byte) error
func (DeadLetterQueueType) Value ¶ added in v0.1.52
func (c DeadLetterQueueType) Value() string
type DeadLetterQueueTypeEnum ¶ added in v0.1.52
type DeadLetterQueueTypeEnum struct {
KAFKA DeadLetterQueueType
}
func GetDeadLetterQueueTypeEnum ¶ added in v0.1.52
func GetDeadLetterQueueTypeEnum() DeadLetterQueueTypeEnum
type DeleteChannelRequest ¶
type DeleteChannelRequest struct { // 指定查询的事件通道ID ChannelId string `json:"channel_id"` }
DeleteChannelRequest Request Object
func (DeleteChannelRequest) String ¶
func (o DeleteChannelRequest) String() string
type DeleteChannelResponse ¶
type DeleteChannelResponse struct {
HttpStatusCode int `json:"-"`
}
DeleteChannelResponse Response Object
func (DeleteChannelResponse) String ¶
func (o DeleteChannelResponse) String() string
type DeleteConnectionRequest ¶ added in v0.1.3
type DeleteConnectionRequest struct { // 指定查询的目标连接ID ConnectionId string `json:"connection_id"` }
DeleteConnectionRequest Request Object
func (DeleteConnectionRequest) String ¶ added in v0.1.3
func (o DeleteConnectionRequest) String() string
type DeleteConnectionResponse ¶ added in v0.1.3
type DeleteConnectionResponse struct {
HttpStatusCode int `json:"-"`
}
DeleteConnectionResponse Response Object
func (DeleteConnectionResponse) String ¶ added in v0.1.3
func (o DeleteConnectionResponse) String() string
type DeleteEndpointRequest ¶ added in v0.1.3
type DeleteEndpointRequest struct { // 指定查询访问端点的id EndpointId string `json:"endpoint_id"` }
DeleteEndpointRequest Request Object
func (DeleteEndpointRequest) String ¶ added in v0.1.3
func (o DeleteEndpointRequest) String() string
type DeleteEndpointResponse ¶ added in v0.1.3
type DeleteEndpointResponse struct {
HttpStatusCode int `json:"-"`
}
DeleteEndpointResponse Response Object
func (DeleteEndpointResponse) String ¶ added in v0.1.3
func (o DeleteEndpointResponse) String() string
type DeleteEventSourceRequest ¶
type DeleteEventSourceRequest struct { // 指定查询的事件源ID SourceId string `json:"source_id"` }
DeleteEventSourceRequest Request Object
func (DeleteEventSourceRequest) String ¶
func (o DeleteEventSourceRequest) String() string
type DeleteEventSourceResponse ¶
type DeleteEventSourceResponse struct {
HttpStatusCode int `json:"-"`
}
DeleteEventSourceResponse Response Object
func (DeleteEventSourceResponse) String ¶
func (o DeleteEventSourceResponse) String() string
type DeleteEventStreamingRequest ¶ added in v0.1.42
type DeleteEventStreamingRequest struct { // 事件流ID EventstreamingId string `json:"eventstreaming_id"` }
DeleteEventStreamingRequest Request Object
func (DeleteEventStreamingRequest) String ¶ added in v0.1.42
func (o DeleteEventStreamingRequest) String() string
type DeleteEventStreamingResponse ¶ added in v0.1.42
type DeleteEventStreamingResponse struct { // 事件流ID EventStreamingID *string `json:"eventStreamingID,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
DeleteEventStreamingResponse Response Object
func (DeleteEventStreamingResponse) String ¶ added in v0.1.42
func (o DeleteEventStreamingResponse) String() string
type DeleteSubscriptionRequest ¶
type DeleteSubscriptionRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` }
DeleteSubscriptionRequest Request Object
func (DeleteSubscriptionRequest) String ¶
func (o DeleteSubscriptionRequest) String() string
type DeleteSubscriptionResponse ¶
type DeleteSubscriptionResponse struct {
HttpStatusCode int `json:"-"`
}
DeleteSubscriptionResponse Response Object
func (DeleteSubscriptionResponse) String ¶
func (o DeleteSubscriptionResponse) String() string
type DeleteSubscriptionTargetRequest ¶
type DeleteSubscriptionTargetRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` // 事件订阅目标ID TargetId string `json:"target_id"` }
DeleteSubscriptionTargetRequest Request Object
func (DeleteSubscriptionTargetRequest) String ¶
func (o DeleteSubscriptionTargetRequest) String() string
type DeleteSubscriptionTargetResponse ¶
type DeleteSubscriptionTargetResponse struct {
HttpStatusCode int `json:"-"`
}
DeleteSubscriptionTargetResponse Response Object
func (DeleteSubscriptionTargetResponse) String ¶
func (o DeleteSubscriptionTargetResponse) String() string
type DeliverDetail ¶ added in v0.1.42
type DeliverDetail struct { // 投递时间 格式 yyyy/mm/dd xx:yy:zz DeliverTime *string `json:"deliverTime,omitempty"` // 投递状态 SUCCESS Or FAILED DeliverStatus *string `json:"deliverStatus,omitempty"` // 投递耗时,单位ms DeliverConsuming *string `json:"deliverConsuming,omitempty"` // 投递响应码 DeliverRspCode *string `json:"deliverRspCode,omitempty"` }
DeliverDetail 投递详情
func (DeliverDetail) String ¶ added in v0.1.42
func (o DeliverDetail) String() string
type DeliverItem ¶ added in v0.1.42
type DeliverItem struct { // 订阅ID,全局唯一 SubscriptionId *string `json:"subscriptionId,omitempty"` // 订阅名称 SubscriptionName *string `json:"subscriptionName,omitempty"` // 成功目标个数 SuccessCounts *int32 `json:"successCounts,omitempty"` // 失败目标个数 FailCounts *int32 `json:"failCounts,omitempty"` // 共投递次数 AllDeliverTimes *int32 `json:"allDeliverTimes,omitempty"` // 投递详情 DeliverTargetList *[]DeliverTarget `json:"deliverTargetList,omitempty"` }
func (DeliverItem) String ¶ added in v0.1.42
func (o DeliverItem) String() string
type DeliverTarget ¶ added in v0.1.42
type DeliverTarget struct { // 投递目标ID,即事件目标ID DeliverTargetId *string `json:"deliverTargetId,omitempty"` // 投递目标名称,及事件目标名称 DeliverTargetName *string `json:"deliverTargetName,omitempty"` // 投递状态 SUCCESS Or FAILED DeliverStatus *string `json:"deliverStatus,omitempty"` // 考虑展示的个数 例如限制只展示最新三条 DeliverDetailList *[]DeliverDetail `json:"deliverDetailList,omitempty"` }
func (DeliverTarget) String ¶ added in v0.1.42
func (o DeliverTarget) String() string
type Detail ¶ added in v0.1.56
type Detail struct { // 自定义目标url Url *string `json:"url,omitempty"` // 委托名称 AgencyName *string `json:"agency_name,omitempty"` InvocationHttpParameters *InvocationHttpParameters `json:"invocation_http_parameters,omitempty"` }
Detail 订阅的自定义事件目标参数列表
type EndpointConnection ¶ added in v0.1.3
type EndpointConnection struct { // 访问端点的服务ID EndpointServiceId *string `json:"endpoint_service_id,omitempty"` // 访问端点的服务名称 EndpointServiceName *string `json:"endpoint_service_name,omitempty"` // 访问端点的终端节点的报文ID MarkerId *string `json:"marker_id,omitempty"` // 访问端点的终端节点ID Id *string `json:"id,omitempty"` // 访问端点的终端节点IP Ip *string `json:"ip,omitempty"` // 访问端点的终端节点创建时间 CreatedTime *string `json:"created_time,omitempty"` }
func (EndpointConnection) String ¶ added in v0.1.3
func (o EndpointConnection) String() string
type EndpointCreateReq ¶ added in v0.1.3
type EndpointCreateReq struct { // endpoint名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须以字母或数字开头 Name string `json:"name"` // 访问端点所在的VPC的ID VpcId string `json:"vpc_id"` // 访问端点所在的子网的ID SubnetId string `json:"subnet_id"` // 描述 Description *string `json:"description,omitempty"` }
func (EndpointCreateReq) String ¶ added in v0.1.3
func (o EndpointCreateReq) String() string
type EndpointInfo ¶ added in v0.1.3
type EndpointInfo struct { // 访问端点ID Id *string `json:"id,omitempty"` // 用户指定的访问端点名称 Name *string `json:"name,omitempty"` // 访问端点所在的VPC的ID VpcId *string `json:"vpc_id,omitempty"` // 访问端点所在的子网的ID SubnetId *string `json:"subnet_id,omitempty"` // 访问域名 Domain *string `json:"domain,omitempty"` // 描述 Description *string `json:"description,omitempty"` // 访问端点状态 Status *EndpointInfoStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` // 访问端点类型 Type *EndpointInfoType `json:"type,omitempty"` // 是否可更新 Scalable *bool `json:"scalable,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` // 访问端点终端节点列表 Endpoints *[]EndpointConnection `json:"endpoints,omitempty"` }
func (EndpointInfo) String ¶ added in v0.1.3
func (o EndpointInfo) String() string
type EndpointInfoStatus ¶ added in v0.1.3
type EndpointInfoStatus struct {
// contains filtered or unexported fields
}
func (EndpointInfoStatus) MarshalJSON ¶ added in v0.1.3
func (c EndpointInfoStatus) MarshalJSON() ([]byte, error)
func (*EndpointInfoStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *EndpointInfoStatus) UnmarshalJSON(b []byte) error
func (EndpointInfoStatus) Value ¶ added in v0.1.3
func (c EndpointInfoStatus) Value() string
type EndpointInfoStatusEnum ¶ added in v0.1.3
type EndpointInfoStatusEnum struct { CREATED EndpointInfoStatus CREATING EndpointInfoStatus CREATE_FAILED EndpointInfoStatus DELETE_FAILED EndpointInfoStatus }
func GetEndpointInfoStatusEnum ¶ added in v0.1.3
func GetEndpointInfoStatusEnum() EndpointInfoStatusEnum
type EndpointInfoType ¶ added in v0.1.3
type EndpointInfoType struct {
// contains filtered or unexported fields
}
func (EndpointInfoType) MarshalJSON ¶ added in v0.1.3
func (c EndpointInfoType) MarshalJSON() ([]byte, error)
func (*EndpointInfoType) UnmarshalJSON ¶ added in v0.1.3
func (c *EndpointInfoType) UnmarshalJSON(b []byte) error
func (EndpointInfoType) Value ¶ added in v0.1.3
func (c EndpointInfoType) Value() string
type EndpointInfoTypeEnum ¶ added in v0.1.3
type EndpointInfoTypeEnum struct { PRIVATE EndpointInfoType PUBLIC EndpointInfoType }
func GetEndpointInfoTypeEnum ¶ added in v0.1.3
func GetEndpointInfoTypeEnum() EndpointInfoTypeEnum
type EndpointUpdateReq ¶ added in v0.1.3
type EndpointUpdateReq struct { // 描述 Description *string `json:"description,omitempty"` }
func (EndpointUpdateReq) String ¶ added in v0.1.3
func (o EndpointUpdateReq) String() string
type ErrorInfo ¶ added in v0.1.52
type EventPubMetricsItem ¶ added in v0.1.28
type EventPubMetricsItem struct { // 事件大小 EventSize *int64 `json:"event_size,omitempty"` // 时间戳 Timestamp *int64 `json:"timestamp,omitempty"` // 调用数 Num *int64 `json:"num,omitempty"` // 调用成功数 SuccessNum *int64 `json:"success_num,omitempty"` // 处理时间 ProcessTime *int64 `json:"process_time,omitempty"` // 调用时间 InvokeTime *int64 `json:"invoke_time,omitempty"` }
EventPubMetricsItem 事件通道监控指标数据
func (EventPubMetricsItem) String ¶ added in v0.1.28
func (o EventPubMetricsItem) String() string
type EventStreamingCreateReq ¶ added in v0.1.42
type EventStreamingCreateReq struct { // 事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 Name string `json:"name"` // 事件流描述 Description *string `json:"description,omitempty"` Source *EventStreamingSource `json:"source"` Sink *EventStreamingSink `json:"sink"` RuleConfig *EventStreamingCreateReqRuleConfig `json:"rule_config,omitempty"` Option *RunOption `json:"option,omitempty"` }
func (EventStreamingCreateReq) String ¶ added in v0.1.42
func (o EventStreamingCreateReq) String() string
type EventStreamingCreateReqRuleConfig ¶ added in v0.1.42
type EventStreamingCreateReqRuleConfig struct { Transform *TransForm `json:"transform,omitempty"` // 过滤规则 Filter *string `json:"filter,omitempty"` }
EventStreamingCreateReqRuleConfig 事件规则,包括过滤规则和转换规则
func (EventStreamingCreateReqRuleConfig) String ¶ added in v0.1.42
func (o EventStreamingCreateReqRuleConfig) String() string
type EventStreamingDetail ¶ added in v0.1.42
type EventStreamingDetail struct { // 事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 Name string `json:"name"` // 事件流描述 Description *string `json:"description,omitempty"` Source *EventStreamingSource `json:"source"` Sink *EventStreamingSink `json:"sink"` RuleConfig *EventStreamingCreateReqRuleConfig `json:"rule_config,omitempty"` Option *RunOption `json:"option,omitempty"` // 事件流状态 Status *EventStreamingDetailStatus `json:"status,omitempty"` // 事件流ID StreamingId *string `json:"streaming_id,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` }
func (EventStreamingDetail) String ¶ added in v0.1.42
func (o EventStreamingDetail) String() string
type EventStreamingDetailStatus ¶ added in v0.1.42
type EventStreamingDetailStatus struct {
// contains filtered or unexported fields
}
func (EventStreamingDetailStatus) MarshalJSON ¶ added in v0.1.42
func (c EventStreamingDetailStatus) MarshalJSON() ([]byte, error)
func (*EventStreamingDetailStatus) UnmarshalJSON ¶ added in v0.1.42
func (c *EventStreamingDetailStatus) UnmarshalJSON(b []byte) error
func (EventStreamingDetailStatus) Value ¶ added in v0.1.42
func (c EventStreamingDetailStatus) Value() string
type EventStreamingDetailStatusEnum ¶ added in v0.1.42
type EventStreamingDetailStatusEnum struct { CREATED EventStreamingDetailStatus RUNNING EventStreamingDetailStatus ERROR EventStreamingDetailStatus STOPPED EventStreamingDetailStatus }
func GetEventStreamingDetailStatusEnum ¶ added in v0.1.42
func GetEventStreamingDetailStatusEnum() EventStreamingDetailStatusEnum
type EventStreamingOperateReq ¶ added in v0.1.42
type EventStreamingOperateReq struct { // 操作类型 Operation *EventStreamingOperateReqOperation `json:"operation,omitempty"` }
func (EventStreamingOperateReq) String ¶ added in v0.1.42
func (o EventStreamingOperateReq) String() string
type EventStreamingOperateReqOperation ¶ added in v0.1.42
type EventStreamingOperateReqOperation struct {
// contains filtered or unexported fields
}
func (EventStreamingOperateReqOperation) MarshalJSON ¶ added in v0.1.42
func (c EventStreamingOperateReqOperation) MarshalJSON() ([]byte, error)
func (*EventStreamingOperateReqOperation) UnmarshalJSON ¶ added in v0.1.42
func (c *EventStreamingOperateReqOperation) UnmarshalJSON(b []byte) error
func (EventStreamingOperateReqOperation) Value ¶ added in v0.1.42
func (c EventStreamingOperateReqOperation) Value() string
type EventStreamingOperateReqOperationEnum ¶ added in v0.1.42
type EventStreamingOperateReqOperationEnum struct { START EventStreamingOperateReqOperation PAUSE EventStreamingOperateReqOperation }
func GetEventStreamingOperateReqOperationEnum ¶ added in v0.1.42
func GetEventStreamingOperateReqOperationEnum() EventStreamingOperateReqOperationEnum
type EventStreamingSink ¶ added in v0.1.42
type EventStreamingSink struct { SinkFg *SinkFgParameters `json:"sink_fg,omitempty"` // 事件目标类型名称 Name *EventStreamingSinkName `json:"name,omitempty"` }
EventStreamingSink 事件目标,一个事件流中只有一个
func (EventStreamingSink) String ¶ added in v0.1.42
func (o EventStreamingSink) String() string
type EventStreamingSinkName ¶ added in v0.1.42
type EventStreamingSinkName struct {
// contains filtered or unexported fields
}
func (EventStreamingSinkName) MarshalJSON ¶ added in v0.1.42
func (c EventStreamingSinkName) MarshalJSON() ([]byte, error)
func (*EventStreamingSinkName) UnmarshalJSON ¶ added in v0.1.42
func (c *EventStreamingSinkName) UnmarshalJSON(b []byte) error
func (EventStreamingSinkName) Value ¶ added in v0.1.42
func (c EventStreamingSinkName) Value() string
type EventStreamingSinkNameEnum ¶ added in v0.1.42
type EventStreamingSinkNameEnum struct {
HC_FG EventStreamingSinkName
}
func GetEventStreamingSinkNameEnum ¶ added in v0.1.42
func GetEventStreamingSinkNameEnum() EventStreamingSinkNameEnum
type EventStreamingSource ¶ added in v0.1.42
type EventStreamingSource struct { SourceKafka *SourceKafkaMqParameters `json:"source_kafka,omitempty"` // 事件源类型名称 Name *EventStreamingSourceName `json:"name,omitempty"` }
EventStreamingSource 事件源,一个事件流中事件源只有一个
func (EventStreamingSource) String ¶ added in v0.1.42
func (o EventStreamingSource) String() string
type EventStreamingSourceName ¶ added in v0.1.42
type EventStreamingSourceName struct {
// contains filtered or unexported fields
}
func (EventStreamingSourceName) MarshalJSON ¶ added in v0.1.42
func (c EventStreamingSourceName) MarshalJSON() ([]byte, error)
func (*EventStreamingSourceName) UnmarshalJSON ¶ added in v0.1.42
func (c *EventStreamingSourceName) UnmarshalJSON(b []byte) error
func (EventStreamingSourceName) Value ¶ added in v0.1.42
func (c EventStreamingSourceName) Value() string
type EventStreamingSourceNameEnum ¶ added in v0.1.42
type EventStreamingSourceNameEnum struct {
HC_DMS EventStreamingSourceName
}
func GetEventStreamingSourceNameEnum ¶ added in v0.1.42
func GetEventStreamingSourceNameEnum() EventStreamingSourceNameEnum
type EventStreamingUpdateReq ¶ added in v0.1.42
type EventStreamingUpdateReq struct { // 事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 Name string `json:"name"` // 事件流描述 Description *string `json:"description,omitempty"` Source *EventStreamingSource `json:"source"` Sink *EventStreamingSink `json:"sink"` RuleConfig *EventStreamingCreateReqRuleConfig `json:"rule_config,omitempty"` Option *RunOption `json:"option,omitempty"` }
func (EventStreamingUpdateReq) String ¶ added in v0.1.42
func (o EventStreamingUpdateReq) String() string
type EventSubMetricsItem ¶ added in v0.1.28
type EventSubMetricsItem struct { // 失败数 FailNum *int64 `json:"fail_num,omitempty"` // 重试成功数 RetrySuccessNum *int64 `json:"retry_success_num,omitempty"` // 重试失败数 RetryFailNum *int64 `json:"retry_fail_num,omitempty"` // 重试数 RetryTimes *int32 `json:"retry_times,omitempty"` // 时间戳 Timestamp *int64 `json:"timestamp,omitempty"` // 调用数 Num *int64 `json:"num,omitempty"` // 调用成功数 SuccessNum *int64 `json:"success_num,omitempty"` // 处理时间 ProcessTime *int64 `json:"process_time,omitempty"` // 调用时间 InvokeTime *int64 `json:"invoke_time,omitempty"` }
EventSubMetricsItem 事件订阅监控指标数据
func (EventSubMetricsItem) String ¶ added in v0.1.28
func (o EventSubMetricsItem) String() string
type HeaderParameter ¶ added in v0.1.56
type HeaderParameter struct { // 是否加密 IsValueSecret *bool `json:"is_value_secret,omitempty"` // header的key值 Key *string `json:"key,omitempty"` // deader的value值 Value *string `json:"value,omitempty"` }
func (HeaderParameter) String ¶ added in v0.1.56
func (o HeaderParameter) String() string
type InvocationHttpParameters ¶ added in v0.1.56
type InvocationHttpParameters struct { // 对象列表 HeaderParameters *[]HeaderParameter `json:"header_parameters,omitempty"` }
func (InvocationHttpParameters) String ¶ added in v0.1.56
func (o InvocationHttpParameters) String() string
type KafkaConnectionDetail ¶ added in v0.1.42
type KafkaConnectionDetail struct { // kafka实例id。 InstanceId string `json:"instance_id"` // kafka连接地址。 Addr string `json:"addr"` // kafka实例是否开启了SASL_SSL。 SaslSsl bool `json:"sasl_ssl"` // kafka实例用户名。实例开启了SASL_SSL时必填 Username *string `json:"username,omitempty"` // kafka实例密码。实例开启了SASL_SSL时必填 Password *string `json:"password,omitempty"` // 收到Server端确认信号个数,表示procuder需要收到多少个这样的确认信号,算消息发送成功。acks参数代表了数据备份的可用性。支持选项: acks=0:表示producer不需要等待任何确认收到的信息,副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据,同时重试配置不会发生作用(因为客户端不知道是否失败)回馈的offset会总是设置为-1。 acks=1:这意味着至少要等待leader已经成功将数据写入本地log,但是并没有等待所有follower是否成功写入。如果follower没有成功备份数据,而此时leader又无法提供服务,则消息会丢失。 acks=all:这意味着leader需要等待ISR中所有备份都成功写入日志,只有任何一个备份存活,数据都不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。 Acks *KafkaConnectionDetailAcks `json:"acks,omitempty"` }
func (KafkaConnectionDetail) String ¶ added in v0.1.42
func (o KafkaConnectionDetail) String() string
type KafkaConnectionDetailAcks ¶ added in v0.1.42
type KafkaConnectionDetailAcks struct {
// contains filtered or unexported fields
}
func (KafkaConnectionDetailAcks) MarshalJSON ¶ added in v0.1.42
func (c KafkaConnectionDetailAcks) MarshalJSON() ([]byte, error)
func (*KafkaConnectionDetailAcks) UnmarshalJSON ¶ added in v0.1.42
func (c *KafkaConnectionDetailAcks) UnmarshalJSON(b []byte) error
func (KafkaConnectionDetailAcks) Value ¶ added in v0.1.42
func (c KafkaConnectionDetailAcks) Value() string
type KafkaConnectionDetailAcksEnum ¶ added in v0.1.42
type KafkaConnectionDetailAcksEnum struct { E_0 KafkaConnectionDetailAcks E_1 KafkaConnectionDetailAcks ALL KafkaConnectionDetailAcks }
func GetKafkaConnectionDetailAcksEnum ¶ added in v0.1.42
func GetKafkaConnectionDetailAcksEnum() KafkaConnectionDetailAcksEnum
type KafkaTargetDetail ¶ added in v0.1.42
type KafkaTargetDetail struct { // 主题 Topic string `json:"topic"` KeyTransform *KafkaTargetDetailKeyTransform `json:"keyTransform,omitempty"` }
KafkaTargetDetail 订阅的kafka事件目标参数列表,该字段序列化后总长度不超过1024字节
func (KafkaTargetDetail) String ¶ added in v0.1.42
func (o KafkaTargetDetail) String() string
type KafkaTargetDetailKeyTransform ¶ added in v0.1.42
type KafkaTargetDetailKeyTransform struct { // 键值规则类型 Type *KafkaTargetDetailKeyTransformType `json:"type,omitempty"` // 键值规则,键值规则为VARIABLE,CONSTANT时必填 Value *string `json:"value,omitempty"` // 键值规则模板,键值规则为VARIABLE时必填 Template *string `json:"template,omitempty"` }
KafkaTargetDetailKeyTransform 键值规则
func (KafkaTargetDetailKeyTransform) String ¶ added in v0.1.42
func (o KafkaTargetDetailKeyTransform) String() string
type KafkaTargetDetailKeyTransformType ¶ added in v0.1.42
type KafkaTargetDetailKeyTransformType struct {
// contains filtered or unexported fields
}
func (KafkaTargetDetailKeyTransformType) MarshalJSON ¶ added in v0.1.42
func (c KafkaTargetDetailKeyTransformType) MarshalJSON() ([]byte, error)
func (*KafkaTargetDetailKeyTransformType) UnmarshalJSON ¶ added in v0.1.42
func (c *KafkaTargetDetailKeyTransformType) UnmarshalJSON(b []byte) error
func (KafkaTargetDetailKeyTransformType) Value ¶ added in v0.1.42
func (c KafkaTargetDetailKeyTransformType) Value() string
type KafkaTargetDetailKeyTransformTypeEnum ¶ added in v0.1.42
type KafkaTargetDetailKeyTransformTypeEnum struct { NONE KafkaTargetDetailKeyTransformType VARIABLE KafkaTargetDetailKeyTransformType CONSTANT KafkaTargetDetailKeyTransformType }
func GetKafkaTargetDetailKeyTransformTypeEnum ¶ added in v0.1.42
func GetKafkaTargetDetailKeyTransformTypeEnum() KafkaTargetDetailKeyTransformTypeEnum
type ListAgenciesRequest ¶ added in v0.1.3
type ListAgenciesRequest struct { // 服务委托授权场景类型 Type ListAgenciesRequestType `json:"type"` }
ListAgenciesRequest Request Object
func (ListAgenciesRequest) String ¶ added in v0.1.3
func (o ListAgenciesRequest) String() string
type ListAgenciesRequestType ¶ added in v0.1.3
type ListAgenciesRequestType struct {
// contains filtered or unexported fields
}
func (ListAgenciesRequestType) MarshalJSON ¶ added in v0.1.3
func (c ListAgenciesRequestType) MarshalJSON() ([]byte, error)
func (*ListAgenciesRequestType) UnmarshalJSON ¶ added in v0.1.3
func (c *ListAgenciesRequestType) UnmarshalJSON(b []byte) error
func (ListAgenciesRequestType) Value ¶ added in v0.1.3
func (c ListAgenciesRequestType) Value() string
type ListAgenciesRequestTypeEnum ¶ added in v0.1.3
type ListAgenciesRequestTypeEnum struct { TARGET_CONNECTION ListAgenciesRequestType CUSTOM_SOURCE_RABBITMQ ListAgenciesRequestType EG_RESTORE_AGENCY ListAgenciesRequestType }
func GetListAgenciesRequestTypeEnum ¶ added in v0.1.3
func GetListAgenciesRequestTypeEnum() ListAgenciesRequestTypeEnum
type ListAgenciesResponse ¶ added in v0.1.3
type ListAgenciesResponse struct { // 服务委托授权记录。 Agencies *[]string `json:"agencies,omitempty"` HttpStatusCode int `json:"-"` }
ListAgenciesResponse Response Object
func (ListAgenciesResponse) String ¶ added in v0.1.3
func (o ListAgenciesResponse) String() string
type ListApiVersionsRequest ¶ added in v0.1.3
type ListApiVersionsRequest struct { }
ListApiVersionsRequest Request Object
func (ListApiVersionsRequest) String ¶ added in v0.1.3
func (o ListApiVersionsRequest) String() string
type ListApiVersionsResponse ¶ added in v0.1.3
type ListApiVersionsResponse struct { // 版本定义 Versions *[]ApiVersionsVersions `json:"versions,omitempty"` HttpStatusCode int `json:"-"` }
ListApiVersionsResponse Response Object
func (ListApiVersionsResponse) String ¶ added in v0.1.3
func (o ListApiVersionsResponse) String() string
type ListChannelsRequest ¶
type ListChannelsRequest struct { // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` // 指定查询提供方的类型 ProviderType *ListChannelsRequestProviderType `json:"provider_type,omitempty"` // 指定查询的事件通道名称,精准匹配 Name *string `json:"name,omitempty"` // 指定查询的事件通道名称,模糊匹配 FuzzyName *string `json:"fuzzy_name,omitempty"` }
ListChannelsRequest Request Object
func (ListChannelsRequest) String ¶
func (o ListChannelsRequest) String() string
type ListChannelsRequestProviderType ¶
type ListChannelsRequestProviderType struct {
// contains filtered or unexported fields
}
func (ListChannelsRequestProviderType) MarshalJSON ¶
func (c ListChannelsRequestProviderType) MarshalJSON() ([]byte, error)
func (*ListChannelsRequestProviderType) UnmarshalJSON ¶
func (c *ListChannelsRequestProviderType) UnmarshalJSON(b []byte) error
func (ListChannelsRequestProviderType) Value ¶
func (c ListChannelsRequestProviderType) Value() string
type ListChannelsRequestProviderTypeEnum ¶
type ListChannelsRequestProviderTypeEnum struct { OFFICIAL ListChannelsRequestProviderType CUSTOM ListChannelsRequestProviderType PARTNER ListChannelsRequestProviderType }
func GetListChannelsRequestProviderTypeEnum ¶
func GetListChannelsRequestProviderTypeEnum() ListChannelsRequestProviderTypeEnum
type ListChannelsResponse ¶
type ListChannelsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]ChannelInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListChannelsResponse Response Object
func (ListChannelsResponse) String ¶
func (o ListChannelsResponse) String() string
type ListConnectionsRequest ¶ added in v0.1.3
type ListConnectionsRequest struct { // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` // 指定查询的目标连接名称,精准匹配 Name *string `json:"name,omitempty"` // 指定查询的目标连接名称,模糊匹配 FuzzyName *string `json:"fuzzy_name,omitempty"` // 指定查询的目标连接,队列的实例id InstanceId *string `json:"instance_id,omitempty"` }
ListConnectionsRequest Request Object
func (ListConnectionsRequest) String ¶ added in v0.1.3
func (o ListConnectionsRequest) String() string
type ListConnectionsResponse ¶ added in v0.1.3
type ListConnectionsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]ConnectionInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListConnectionsResponse Response Object
func (ListConnectionsResponse) String ¶ added in v0.1.3
func (o ListConnectionsResponse) String() string
type ListEndpointsRequest ¶ added in v0.1.3
type ListEndpointsRequest struct { // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` // 指定查询访问端点的类型 Type *ListEndpointsRequestType `json:"type,omitempty"` // 指定查询访问端点的名称 Name *string `json:"name,omitempty"` // 指定查询访问端点的vpcId VpcId *string `json:"vpc_id,omitempty"` // 指定查询访问端点的名称,模糊查询 FuzzyName *string `json:"fuzzy_name,omitempty"` // 指定查询访问端点的SubnetId SubnetId *string `json:"subnet_id,omitempty"` }
ListEndpointsRequest Request Object
func (ListEndpointsRequest) String ¶ added in v0.1.3
func (o ListEndpointsRequest) String() string
type ListEndpointsRequestType ¶ added in v0.1.3
type ListEndpointsRequestType struct {
// contains filtered or unexported fields
}
func (ListEndpointsRequestType) MarshalJSON ¶ added in v0.1.3
func (c ListEndpointsRequestType) MarshalJSON() ([]byte, error)
func (*ListEndpointsRequestType) UnmarshalJSON ¶ added in v0.1.3
func (c *ListEndpointsRequestType) UnmarshalJSON(b []byte) error
func (ListEndpointsRequestType) Value ¶ added in v0.1.3
func (c ListEndpointsRequestType) Value() string
type ListEndpointsRequestTypeEnum ¶ added in v0.1.3
type ListEndpointsRequestTypeEnum struct { PRIVATE ListEndpointsRequestType PUBLIC ListEndpointsRequestType }
func GetListEndpointsRequestTypeEnum ¶ added in v0.1.3
func GetListEndpointsRequestTypeEnum() ListEndpointsRequestTypeEnum
type ListEndpointsResponse ¶ added in v0.1.3
type ListEndpointsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]EndpointInfo `json:"items,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
ListEndpointsResponse Response Object
func (ListEndpointsResponse) String ¶ added in v0.1.3
func (o ListEndpointsResponse) String() string
type ListEventSourcesRequest ¶
type ListEventSourcesRequest struct { // 指定查询的事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` // 指定查询提供方的类型 ProviderType *ListEventSourcesRequestProviderType `json:"provider_type,omitempty"` // 指定查询的事件源名称,精准匹配 Name *string `json:"name,omitempty"` // 指定查询的事件源名称,模糊匹配 FuzzyName *string `json:"fuzzy_name,omitempty"` // 指定查询的事件源标签,模糊匹配 FuzzyLabel *string `json:"fuzzy_label,omitempty"` }
ListEventSourcesRequest Request Object
func (ListEventSourcesRequest) String ¶
func (o ListEventSourcesRequest) String() string
type ListEventSourcesRequestProviderType ¶
type ListEventSourcesRequestProviderType struct {
// contains filtered or unexported fields
}
func (ListEventSourcesRequestProviderType) MarshalJSON ¶
func (c ListEventSourcesRequestProviderType) MarshalJSON() ([]byte, error)
func (*ListEventSourcesRequestProviderType) UnmarshalJSON ¶
func (c *ListEventSourcesRequestProviderType) UnmarshalJSON(b []byte) error
func (ListEventSourcesRequestProviderType) Value ¶
func (c ListEventSourcesRequestProviderType) Value() string
type ListEventSourcesRequestProviderTypeEnum ¶
type ListEventSourcesRequestProviderTypeEnum struct { OFFICIAL ListEventSourcesRequestProviderType CUSTOM ListEventSourcesRequestProviderType PARTNER ListEventSourcesRequestProviderType }
func GetListEventSourcesRequestProviderTypeEnum ¶
func GetListEventSourcesRequestProviderTypeEnum() ListEventSourcesRequestProviderTypeEnum
type ListEventSourcesResponse ¶
type ListEventSourcesResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]CustomizeSourceInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListEventSourcesResponse Response Object
func (ListEventSourcesResponse) String ¶
func (o ListEventSourcesResponse) String() string
type ListEventStreamingRequest ¶ added in v0.1.42
type ListEventStreamingRequest struct { // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` }
ListEventStreamingRequest Request Object
func (ListEventStreamingRequest) String ¶ added in v0.1.42
func (o ListEventStreamingRequest) String() string
type ListEventStreamingResponse ¶ added in v0.1.42
type ListEventStreamingResponse struct { Body *[]EventStreamingDetail `json:"body,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
ListEventStreamingResponse Response Object
func (ListEventStreamingResponse) String ¶ added in v0.1.42
func (o ListEventStreamingResponse) String() string
type ListEventTargetRequest ¶
type ListEventTargetRequest struct { // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` // 指定查询的事件目标标签,模糊匹配 FuzzyLabel *string `json:"fuzzy_label,omitempty"` // 事件目标支持方式:事件订阅:SUBSCRIPTION、事件流:FLOW SupportTypes *[]ListEventTargetRequestSupportTypes `json:"support_types,omitempty"` }
ListEventTargetRequest Request Object
func (ListEventTargetRequest) String ¶
func (o ListEventTargetRequest) String() string
type ListEventTargetRequestSupportTypes ¶ added in v0.1.42
type ListEventTargetRequestSupportTypes struct {
// contains filtered or unexported fields
}
func (ListEventTargetRequestSupportTypes) MarshalJSON ¶ added in v0.1.42
func (c ListEventTargetRequestSupportTypes) MarshalJSON() ([]byte, error)
func (*ListEventTargetRequestSupportTypes) UnmarshalJSON ¶ added in v0.1.42
func (c *ListEventTargetRequestSupportTypes) UnmarshalJSON(b []byte) error
func (ListEventTargetRequestSupportTypes) Value ¶ added in v0.1.42
func (c ListEventTargetRequestSupportTypes) Value() string
type ListEventTargetRequestSupportTypesEnum ¶ added in v0.1.42
type ListEventTargetRequestSupportTypesEnum struct { SUBSCRIPTION ListEventTargetRequestSupportTypes FLOW ListEventTargetRequestSupportTypes }
func GetListEventTargetRequestSupportTypesEnum ¶ added in v0.1.42
func GetListEventTargetRequestSupportTypesEnum() ListEventTargetRequestSupportTypesEnum
type ListEventTargetResponse ¶
type ListEventTargetResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]CatalogTargetInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListEventTargetResponse Response Object
func (ListEventTargetResponse) String ¶
func (o ListEventTargetResponse) String() string
type ListObsBucketsRequest ¶ added in v0.1.28
type ListObsBucketsRequest struct { // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` }
ListObsBucketsRequest Request Object
func (ListObsBucketsRequest) String ¶ added in v0.1.28
func (o ListObsBucketsRequest) String() string
type ListObsBucketsResponse ¶ added in v0.1.28
type ListObsBucketsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]ObsBucketInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListObsBucketsResponse Response Object
func (ListObsBucketsResponse) String ¶ added in v0.1.28
func (o ListObsBucketsResponse) String() string
type ListPubMetricsRequest ¶ added in v0.1.28
type ListPubMetricsRequest struct { // 指标数据统计方式 Filter *ListPubMetricsRequestFilter `json:"filter,omitempty"` // 指标数据统计周期(单位minute) Period *int32 `json:"period,omitempty"` // 获取指标数据起始时间 StartTime int64 `json:"start_time"` // 获取指标数据结束时间 EndTime *int64 `json:"end_time,omitempty"` // 事件通道id ChannelId string `json:"channel_id"` // 事件目标类型/事件通道类型 ProviderType *ListPubMetricsRequestProviderType `json:"provider_type,omitempty"` // 事件源名称 SourceName *string `json:"source_name,omitempty"` }
ListPubMetricsRequest Request Object
func (ListPubMetricsRequest) String ¶ added in v0.1.28
func (o ListPubMetricsRequest) String() string
type ListPubMetricsRequestFilter ¶ added in v0.1.28
type ListPubMetricsRequestFilter struct {
// contains filtered or unexported fields
}
func (ListPubMetricsRequestFilter) MarshalJSON ¶ added in v0.1.28
func (c ListPubMetricsRequestFilter) MarshalJSON() ([]byte, error)
func (*ListPubMetricsRequestFilter) UnmarshalJSON ¶ added in v0.1.28
func (c *ListPubMetricsRequestFilter) UnmarshalJSON(b []byte) error
func (ListPubMetricsRequestFilter) Value ¶ added in v0.1.28
func (c ListPubMetricsRequestFilter) Value() string
type ListPubMetricsRequestFilterEnum ¶ added in v0.1.28
type ListPubMetricsRequestFilterEnum struct { AVG ListPubMetricsRequestFilter MIN ListPubMetricsRequestFilter MAX ListPubMetricsRequestFilter }
func GetListPubMetricsRequestFilterEnum ¶ added in v0.1.28
func GetListPubMetricsRequestFilterEnum() ListPubMetricsRequestFilterEnum
type ListPubMetricsRequestProviderType ¶ added in v0.1.28
type ListPubMetricsRequestProviderType struct {
// contains filtered or unexported fields
}
func (ListPubMetricsRequestProviderType) MarshalJSON ¶ added in v0.1.28
func (c ListPubMetricsRequestProviderType) MarshalJSON() ([]byte, error)
func (*ListPubMetricsRequestProviderType) UnmarshalJSON ¶ added in v0.1.28
func (c *ListPubMetricsRequestProviderType) UnmarshalJSON(b []byte) error
func (ListPubMetricsRequestProviderType) Value ¶ added in v0.1.28
func (c ListPubMetricsRequestProviderType) Value() string
type ListPubMetricsRequestProviderTypeEnum ¶ added in v0.1.28
type ListPubMetricsRequestProviderTypeEnum struct { OFFICIAL ListPubMetricsRequestProviderType CUSTOM ListPubMetricsRequestProviderType }
func GetListPubMetricsRequestProviderTypeEnum ¶ added in v0.1.28
func GetListPubMetricsRequestProviderTypeEnum() ListPubMetricsRequestProviderTypeEnum
type ListPubMetricsResponse ¶ added in v0.1.28
type ListPubMetricsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 指标列表 Result *[]EventPubMetricsItem `json:"result,omitempty"` HttpStatusCode int `json:"-"` }
ListPubMetricsResponse Response Object
func (ListPubMetricsResponse) String ¶ added in v0.1.28
func (o ListPubMetricsResponse) String() string
type ListQuotasRequest ¶
type ListQuotasRequest struct { // 指定查询资源类型的配额 Type *ListQuotasRequestType `json:"type,omitempty"` }
ListQuotasRequest Request Object
func (ListQuotasRequest) String ¶
func (o ListQuotasRequest) String() string
type ListQuotasRequestType ¶
type ListQuotasRequestType struct {
// contains filtered or unexported fields
}
func (ListQuotasRequestType) MarshalJSON ¶
func (c ListQuotasRequestType) MarshalJSON() ([]byte, error)
func (*ListQuotasRequestType) UnmarshalJSON ¶
func (c *ListQuotasRequestType) UnmarshalJSON(b []byte) error
func (ListQuotasRequestType) Value ¶
func (c ListQuotasRequestType) Value() string
type ListQuotasRequestTypeEnum ¶
type ListQuotasRequestTypeEnum struct { CHANNEL ListQuotasRequestType CHANNEL_SUBSCRIPTION ListQuotasRequestType SOURCE ListQuotasRequestType SUBSCRIPTION ListQuotasRequestType SUBSCRIPTION_TARGET ListQuotasRequestType SCHEMA ListQuotasRequestType SCHEMA_VERSION ListQuotasRequestType CONNECTION ListQuotasRequestType PRIVATE_ENDPOINT ListQuotasRequestType SOURCE_RABBITMQ ListQuotasRequestType SOURCE_ROCKETMQ ListQuotasRequestType }
func GetListQuotasRequestTypeEnum ¶
func GetListQuotasRequestTypeEnum() ListQuotasRequestTypeEnum
type ListQuotasResponse ¶
type ListQuotasResponse struct { Quotas *QuotaResourceResp `json:"quotas,omitempty"` HttpStatusCode int `json:"-"` }
ListQuotasResponse Response Object
func (ListQuotasResponse) String ¶
func (o ListQuotasResponse) String() string
type ListSubMetricsRequest ¶ added in v0.1.28
type ListSubMetricsRequest struct { // 指标数据统计方式 Filter *ListSubMetricsRequestFilter `json:"filter,omitempty"` // 指标数据统计周期(单位minute) Period *int32 `json:"period,omitempty"` // 获取指标数据起始时间 StartTime int64 `json:"start_time"` // 获取指标数据结束时间 EndTime *int64 `json:"end_time,omitempty"` // 事件订阅id SubscriptionId string `json:"subscription_id"` // 事件目标类型/事件通道类型 ProviderType *ListSubMetricsRequestProviderType `json:"provider_type,omitempty"` // 事件目标id TargetId *string `json:"target_id,omitempty"` }
ListSubMetricsRequest Request Object
func (ListSubMetricsRequest) String ¶ added in v0.1.28
func (o ListSubMetricsRequest) String() string
type ListSubMetricsRequestFilter ¶ added in v0.1.28
type ListSubMetricsRequestFilter struct {
// contains filtered or unexported fields
}
func (ListSubMetricsRequestFilter) MarshalJSON ¶ added in v0.1.28
func (c ListSubMetricsRequestFilter) MarshalJSON() ([]byte, error)
func (*ListSubMetricsRequestFilter) UnmarshalJSON ¶ added in v0.1.28
func (c *ListSubMetricsRequestFilter) UnmarshalJSON(b []byte) error
func (ListSubMetricsRequestFilter) Value ¶ added in v0.1.28
func (c ListSubMetricsRequestFilter) Value() string
type ListSubMetricsRequestFilterEnum ¶ added in v0.1.28
type ListSubMetricsRequestFilterEnum struct { AVG ListSubMetricsRequestFilter MIN ListSubMetricsRequestFilter MAX ListSubMetricsRequestFilter }
func GetListSubMetricsRequestFilterEnum ¶ added in v0.1.28
func GetListSubMetricsRequestFilterEnum() ListSubMetricsRequestFilterEnum
type ListSubMetricsRequestProviderType ¶ added in v0.1.28
type ListSubMetricsRequestProviderType struct {
// contains filtered or unexported fields
}
func (ListSubMetricsRequestProviderType) MarshalJSON ¶ added in v0.1.28
func (c ListSubMetricsRequestProviderType) MarshalJSON() ([]byte, error)
func (*ListSubMetricsRequestProviderType) UnmarshalJSON ¶ added in v0.1.28
func (c *ListSubMetricsRequestProviderType) UnmarshalJSON(b []byte) error
func (ListSubMetricsRequestProviderType) Value ¶ added in v0.1.28
func (c ListSubMetricsRequestProviderType) Value() string
type ListSubMetricsRequestProviderTypeEnum ¶ added in v0.1.28
type ListSubMetricsRequestProviderTypeEnum struct { OFFICIAL ListSubMetricsRequestProviderType CUSTOM ListSubMetricsRequestProviderType }
func GetListSubMetricsRequestProviderTypeEnum ¶ added in v0.1.28
func GetListSubMetricsRequestProviderTypeEnum() ListSubMetricsRequestProviderTypeEnum
type ListSubMetricsResponse ¶ added in v0.1.28
type ListSubMetricsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 指标数据列表 Result *[]EventSubMetricsItem `json:"result,omitempty"` HttpStatusCode int `json:"-"` }
ListSubMetricsResponse Response Object
func (ListSubMetricsResponse) String ¶ added in v0.1.28
func (o ListSubMetricsResponse) String() string
type ListSubscriptionsRequest ¶
type ListSubscriptionsRequest struct { // 指定查询的事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` // 指定查询的事件订阅名称,精准匹配 Name *string `json:"name,omitempty"` // 指定查询的事件订阅名称,模糊匹配 FuzzyName *string `json:"fuzzy_name,omitempty"` // 目标连接 id ConnectionId *string `json:"connection_id,omitempty"` }
ListSubscriptionsRequest Request Object
func (ListSubscriptionsRequest) String ¶
func (o ListSubscriptionsRequest) String() string
type ListSubscriptionsResponse ¶
type ListSubscriptionsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]SubscriptionInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListSubscriptionsResponse Response Object
func (ListSubscriptionsResponse) String ¶
func (o ListSubscriptionsResponse) String() string
type ListTracedEventsRequest ¶ added in v0.1.42
type ListTracedEventsRequest struct { // 查询数据起始时间 StartTime int64 `json:"start_time"` // 查询数据结束时间 EndTime int64 `json:"end_time"` // 指定查询事件的Id EventId *string `json:"event_id,omitempty"` // 事件源名称 SourceName *string `json:"source_name,omitempty"` // 指定查询的事件类型,精准匹配 EventType *string `json:"event_type,omitempty"` // 事件订阅名称 SubscriptionName *string `json:"subscription_name,omitempty"` // 每页显示的条目数量,不能小于0 Limit *string `json:"limit,omitempty"` // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 通道ID ChannelId string `json:"channel_id"` }
ListTracedEventsRequest Request Object
func (ListTracedEventsRequest) String ¶ added in v0.1.42
func (o ListTracedEventsRequest) String() string
type ListTracedEventsRespResult ¶ added in v0.1.42
type ListTracedEventsRespResult struct { SubscriptionName *string `json:"subscription_name,omitempty"` SourceName *string `json:"source_name,omitempty"` SourceProvider *string `json:"source_provider,omitempty"` EventType *string `json:"event_type,omitempty"` EventId *string `json:"event_id,omitempty"` EventReceivedTime *int32 `json:"event_received_time,omitempty"` }
func (ListTracedEventsRespResult) String ¶ added in v0.1.42
func (o ListTracedEventsRespResult) String() string
type ListTracedEventsResponse ¶ added in v0.1.42
type ListTracedEventsResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 事件追踪列表 Result *[]ListTracedEventsRespResult `json:"result,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
ListTracedEventsResponse Response Object
func (ListTracedEventsResponse) String ¶ added in v0.1.42
func (o ListTracedEventsResponse) String() string
type ListTriggersRequest ¶ added in v0.1.3
type ListTriggersRequest struct { // 目标函数的urn FuncUrn string `json:"func_urn"` // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` }
ListTriggersRequest Request Object
func (ListTriggersRequest) String ¶ added in v0.1.3
func (o ListTriggersRequest) String() string
type ListTriggersResponse ¶ added in v0.1.3
type ListTriggersResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]SubscriptionInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListTriggersResponse Response Object
func (ListTriggersResponse) String ¶ added in v0.1.3
func (o ListTriggersResponse) String() string
type ListWorkflowTriggersRequest ¶ added in v0.1.28
type ListWorkflowTriggersRequest struct { // 目标函数流的id WorkflowId string `json:"workflow_id"` // 偏移量,表示从此偏移量开始查询,偏移量不能小于0 Offset *int32 `json:"offset,omitempty"` // 每页显示的条目数量,不能小于1或大于1000 Limit *int32 `json:"limit,omitempty"` // 指定查询排序 Sort *string `json:"sort,omitempty"` }
ListWorkflowTriggersRequest Request Object
func (ListWorkflowTriggersRequest) String ¶ added in v0.1.28
func (o ListWorkflowTriggersRequest) String() string
type ListWorkflowTriggersResponse ¶ added in v0.1.28
type ListWorkflowTriggersResponse struct { // 总数 Total *int32 `json:"total,omitempty"` // 本页数量 Size *int32 `json:"size,omitempty"` // 对象列表 Items *[]SubscriptionInfo `json:"items,omitempty"` HttpStatusCode int `json:"-"` }
ListWorkflowTriggersResponse Response Object
func (ListWorkflowTriggersResponse) String ¶ added in v0.1.28
func (o ListWorkflowTriggersResponse) String() string
type ObsBucketInfo ¶ added in v0.1.28
type ObsBucketInfo struct { // 响应头 ResponseHeaders *interface{} `json:"responseHeaders,omitempty"` // 请求头 OriginalHeaders *interface{} `json:"originalHeaders,omitempty"` // 状态 StatusCode *int32 `json:"statusCode,omitempty"` // 桶名称 BucketName *string `json:"bucketName,omitempty"` Owner *ObsBucketInfoOwner `json:"owner,omitempty"` // 桶的创建时间 CreationDate *string `json:"creationDate,omitempty"` // 桶的位置信息 Location *string `json:"location,omitempty"` // 对象的存储类型 StorageClass *interface{} `json:"storageClass,omitempty"` // 桶元数据 Metadata *interface{} `json:"metadata,omitempty"` // 桶ACL Acl *interface{} `json:"acl,omitempty"` // 桶的存储类型 BucketStorageClass *interface{} `json:"bucketStorageClass,omitempty"` // 桶类型 BucketType *string `json:"bucketType,omitempty"` // 请求id RequestId *string `json:"requestId,omitempty"` }
func (ObsBucketInfo) String ¶ added in v0.1.28
func (o ObsBucketInfo) String() string
type ObsBucketInfoOwner ¶ added in v0.1.28
type ObsBucketInfoOwner struct { // 显示名称 DisplayName *string `json:"displayName,omitempty"` // 用户的DomainID(帐号ID) Id *string `json:"id,omitempty"` }
ObsBucketInfoOwner 桶拥有者信息
func (ObsBucketInfoOwner) String ¶ added in v0.1.28
func (o ObsBucketInfoOwner) String() string
type OperateSubscriptionRequest ¶
type OperateSubscriptionRequest struct {
Body *SubscriptionOperateReq `json:"body,omitempty"`
}
OperateSubscriptionRequest Request Object
func (OperateSubscriptionRequest) String ¶
func (o OperateSubscriptionRequest) String() string
type OperateSubscriptionResponse ¶
type OperateSubscriptionResponse struct { // 操作失败的订阅个数 FailedCount *int32 `json:"failed_count,omitempty"` // 事件列表 Events *[]SubscriptionOperateRespEvents `json:"events,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
OperateSubscriptionResponse Response Object
func (OperateSubscriptionResponse) String ¶
func (o OperateSubscriptionResponse) String() string
type PutEventsReq ¶
type PutEventsReq struct {
Events *[]CloudEvents `json:"events,omitempty"`
}
func (PutEventsReq) String ¶
func (o PutEventsReq) String() string
type PutEventsRequest ¶
type PutEventsRequest struct { // 指定查询的事件通道ID ChannelId string `json:"channel_id"` Body *PutEventsReq `json:"body,omitempty"` }
PutEventsRequest Request Object
func (PutEventsRequest) String ¶
func (o PutEventsRequest) String() string
type PutEventsRespEvents ¶
type PutEventsRespEvents struct { // 发布失败的错误码 ErrorCode *string `json:"error_code,omitempty"` // 发布失败的原因 ErrorMsg *string `json:"error_msg,omitempty"` // 事件唯一标识串 EventId *string `json:"event_id,omitempty"` }
func (PutEventsRespEvents) String ¶
func (o PutEventsRespEvents) String() string
type PutEventsResponse ¶
type PutEventsResponse struct { // 发布失败的事件个数 FailedCount *int32 `json:"failed_count,omitempty"` // 事件列表 Events *[]PutEventsRespEvents `json:"events,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
PutEventsResponse Response Object
func (PutEventsResponse) String ¶
func (o PutEventsResponse) String() string
type PutOfficialEventsRequest ¶ added in v0.1.42
type PutOfficialEventsRequest struct { // 事件源名称 SourceName string `json:"source_name"` Body *PutEventsReq `json:"body,omitempty"` }
PutOfficialEventsRequest Request Object
func (PutOfficialEventsRequest) String ¶ added in v0.1.42
func (o PutOfficialEventsRequest) String() string
type PutOfficialEventsResponse ¶ added in v0.1.42
type PutOfficialEventsResponse struct { // 发布失败的事件个数 FailedCount *int32 `json:"failed_count,omitempty"` // 事件列表 Events *[]PutEventsRespEvents `json:"events,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
PutOfficialEventsResponse Response Object
func (PutOfficialEventsResponse) String ¶ added in v0.1.42
func (o PutOfficialEventsResponse) String() string
type QuotaItemInfo ¶
type QuotaItemInfo struct { // 名称 Name *string `json:"name,omitempty"` // 配额类型 Type *QuotaItemInfoType `json:"type,omitempty"` // 配额最大值 Max *int32 `json:"max,omitempty"` // 配额最小值 Min *int32 `json:"min,omitempty"` // 当前租户的配额 Quota *int32 `json:"quota,omitempty"` // 当前租户已使用的配额 Used *int32 `json:"used,omitempty"` }
func (QuotaItemInfo) String ¶
func (o QuotaItemInfo) String() string
type QuotaItemInfoType ¶
type QuotaItemInfoType struct {
// contains filtered or unexported fields
}
func (QuotaItemInfoType) MarshalJSON ¶
func (c QuotaItemInfoType) MarshalJSON() ([]byte, error)
func (*QuotaItemInfoType) UnmarshalJSON ¶
func (c *QuotaItemInfoType) UnmarshalJSON(b []byte) error
func (QuotaItemInfoType) Value ¶
func (c QuotaItemInfoType) Value() string
type QuotaItemInfoTypeEnum ¶
type QuotaItemInfoTypeEnum struct { CHANNEL QuotaItemInfoType CHANNEL_SUBSCRIPTION QuotaItemInfoType SOURCE QuotaItemInfoType SUBSCRIPTION QuotaItemInfoType SUBSCRIPTION_TARGET QuotaItemInfoType SCHEMA QuotaItemInfoType SCHEMA_VERSION QuotaItemInfoType CONNECTION QuotaItemInfoType PRIVATE_ENDPOINT QuotaItemInfoType SOURCE_RABBITMQ QuotaItemInfoType SOURCE_ROCKETMQ QuotaItemInfoType }
func GetQuotaItemInfoTypeEnum ¶
func GetQuotaItemInfoTypeEnum() QuotaItemInfoTypeEnum
type QuotaResourceResp ¶
type QuotaResourceResp struct { // 错误描述 Resources *[]QuotaItemInfo `json:"resources,omitempty"` }
func (QuotaResourceResp) String ¶
func (o QuotaResourceResp) String() string
type ResumeEventStreamingRequest ¶ added in v0.1.42
type ResumeEventStreamingRequest struct { // 事件流ID EventstreamingId string `json:"eventstreaming_id"` Body *EventStreamingOperateReq `json:"body,omitempty"` }
ResumeEventStreamingRequest Request Object
func (ResumeEventStreamingRequest) String ¶ added in v0.1.42
func (o ResumeEventStreamingRequest) String() string
type ResumeEventStreamingResponse ¶ added in v0.1.42
type ResumeEventStreamingResponse struct { // 事件流ID EventStreamingID *string `json:"eventStreamingID,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
ResumeEventStreamingResponse Response Object
func (ResumeEventStreamingResponse) String ¶ added in v0.1.42
func (o ResumeEventStreamingResponse) String() string
type RunOption ¶ added in v0.1.42
type RunOption struct { // 并发数 ThreadNum *int32 `json:"thread_num,omitempty"` BatchWindow *BatchWindow `json:"batch_window,omitempty"` }
type ShowDetailOfChannelRequest ¶
type ShowDetailOfChannelRequest struct { // 指定查询的事件通道ID ChannelId string `json:"channel_id"` }
ShowDetailOfChannelRequest Request Object
func (ShowDetailOfChannelRequest) String ¶
func (o ShowDetailOfChannelRequest) String() string
type ShowDetailOfChannelResponse ¶
type ShowDetailOfChannelResponse struct { // 通道ID Id *string `json:"id,omitempty"` // 通道名称 Name *string `json:"name,omitempty"` // 通道描述 Description *string `json:"description,omitempty"` // 通道提供方类型,OFFICIAL:官方事件通道;CUSTOM:自定义事件通道;PARTNER:伙伴事件通道 ProviderType *ShowDetailOfChannelResponseProviderType `json:"provider_type,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` HttpStatusCode int `json:"-"` }
ShowDetailOfChannelResponse Response Object
func (ShowDetailOfChannelResponse) String ¶
func (o ShowDetailOfChannelResponse) String() string
type ShowDetailOfChannelResponseProviderType ¶
type ShowDetailOfChannelResponseProviderType struct {
// contains filtered or unexported fields
}
func (ShowDetailOfChannelResponseProviderType) MarshalJSON ¶
func (c ShowDetailOfChannelResponseProviderType) MarshalJSON() ([]byte, error)
func (*ShowDetailOfChannelResponseProviderType) UnmarshalJSON ¶
func (c *ShowDetailOfChannelResponseProviderType) UnmarshalJSON(b []byte) error
func (ShowDetailOfChannelResponseProviderType) Value ¶
func (c ShowDetailOfChannelResponseProviderType) Value() string
type ShowDetailOfChannelResponseProviderTypeEnum ¶
type ShowDetailOfChannelResponseProviderTypeEnum struct { OFFICIAL ShowDetailOfChannelResponseProviderType CUSTOM ShowDetailOfChannelResponseProviderType PARTNER ShowDetailOfChannelResponseProviderType }
func GetShowDetailOfChannelResponseProviderTypeEnum ¶
func GetShowDetailOfChannelResponseProviderTypeEnum() ShowDetailOfChannelResponseProviderTypeEnum
type ShowDetailOfConnectionRequest ¶ added in v0.1.3
type ShowDetailOfConnectionRequest struct { // 指定查询的目标连接ID ConnectionId string `json:"connection_id"` }
ShowDetailOfConnectionRequest Request Object
func (ShowDetailOfConnectionRequest) String ¶ added in v0.1.3
func (o ShowDetailOfConnectionRequest) String() string
type ShowDetailOfConnectionResponse ¶ added in v0.1.3
type ShowDetailOfConnectionResponse struct { // 事件源ID Id *string `json:"id,omitempty"` // 目标连接名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default Name *string `json:"name,omitempty"` // 目标连接描述 Description *string `json:"description,omitempty"` // 目标连接状态 Status *ShowDetailOfConnectionResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` // 待连接的VPC ID VpcId *string `json:"vpc_id,omitempty"` // 待连接的子网ID SubnetId *string `json:"subnet_id,omitempty"` // 私网目标连接使用的用户委托名称 Agency *string `json:"agency,omitempty"` Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"` Type *ConnectionType `json:"type,omitempty"` KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` HttpStatusCode int `json:"-"` }
ShowDetailOfConnectionResponse Response Object
func (ShowDetailOfConnectionResponse) String ¶ added in v0.1.3
func (o ShowDetailOfConnectionResponse) String() string
type ShowDetailOfConnectionResponseStatus ¶ added in v0.1.3
type ShowDetailOfConnectionResponseStatus struct {
// contains filtered or unexported fields
}
func (ShowDetailOfConnectionResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c ShowDetailOfConnectionResponseStatus) MarshalJSON() ([]byte, error)
func (*ShowDetailOfConnectionResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *ShowDetailOfConnectionResponseStatus) UnmarshalJSON(b []byte) error
func (ShowDetailOfConnectionResponseStatus) Value ¶ added in v0.1.3
func (c ShowDetailOfConnectionResponseStatus) Value() string
type ShowDetailOfConnectionResponseStatusEnum ¶ added in v0.1.3
type ShowDetailOfConnectionResponseStatusEnum struct { CREATING ShowDetailOfConnectionResponseStatus CREATED ShowDetailOfConnectionResponseStatus CREATE_FAILED ShowDetailOfConnectionResponseStatus }
func GetShowDetailOfConnectionResponseStatusEnum ¶ added in v0.1.3
func GetShowDetailOfConnectionResponseStatusEnum() ShowDetailOfConnectionResponseStatusEnum
type ShowDetailOfEventRequest ¶ added in v0.1.42
type ShowDetailOfEventRequest struct { // 追踪事件的uniqueId TraceId string `json:"trace_id"` }
ShowDetailOfEventRequest Request Object
func (ShowDetailOfEventRequest) String ¶ added in v0.1.42
func (o ShowDetailOfEventRequest) String() string
type ShowDetailOfEventResponse ¶ added in v0.1.42
type ShowDetailOfEventResponse struct { Body *string `json:"body,omitempty"` HttpStatusCode int `json:"-"` }
ShowDetailOfEventResponse Response Object
func (ShowDetailOfEventResponse) String ¶ added in v0.1.42
func (o ShowDetailOfEventResponse) String() string
type ShowDetailOfEventSourceRequest ¶
type ShowDetailOfEventSourceRequest struct { // 指定查询的事件源ID SourceId string `json:"source_id"` }
ShowDetailOfEventSourceRequest Request Object
func (ShowDetailOfEventSourceRequest) String ¶
func (o ShowDetailOfEventSourceRequest) String() string
type ShowDetailOfEventSourceResponse ¶
type ShowDetailOfEventSourceResponse struct { // 事件源ID Id *string `json:"id,omitempty"` // 事件源名称 Name *string `json:"name,omitempty"` // 事件源名称展示 Label *string `json:"label,omitempty"` // 事件源描述 Description *string `json:"description,omitempty"` // 事件源提供方类型,OFFICIAL:官方云服务事件源;CUSTOM:用户创建的自定义事件源;PARTNER:伙伴事件源 ProviderType *ShowDetailOfEventSourceResponseProviderType `json:"provider_type,omitempty"` // 事件源提供的事件类型列表,只有官方云服务事件源提供事件类型 EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` // 事件源归属的事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 事件源归属的事件通道名称 ChannelName *string `json:"channel_name,omitempty"` // 事件源类型 Type *string `json:"type,omitempty"` // json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等 Detail *interface{} `json:"detail,omitempty"` // 自定义事件源状态 Status *ShowDetailOfEventSourceResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` HttpStatusCode int `json:"-"` }
ShowDetailOfEventSourceResponse Response Object
func (ShowDetailOfEventSourceResponse) String ¶
func (o ShowDetailOfEventSourceResponse) String() string
type ShowDetailOfEventSourceResponseProviderType ¶
type ShowDetailOfEventSourceResponseProviderType struct {
// contains filtered or unexported fields
}
func (ShowDetailOfEventSourceResponseProviderType) MarshalJSON ¶
func (c ShowDetailOfEventSourceResponseProviderType) MarshalJSON() ([]byte, error)
func (*ShowDetailOfEventSourceResponseProviderType) UnmarshalJSON ¶
func (c *ShowDetailOfEventSourceResponseProviderType) UnmarshalJSON(b []byte) error
func (ShowDetailOfEventSourceResponseProviderType) Value ¶
func (c ShowDetailOfEventSourceResponseProviderType) Value() string
type ShowDetailOfEventSourceResponseProviderTypeEnum ¶
type ShowDetailOfEventSourceResponseProviderTypeEnum struct { OFFICIAL ShowDetailOfEventSourceResponseProviderType CUSTOM ShowDetailOfEventSourceResponseProviderType PARTNER ShowDetailOfEventSourceResponseProviderType }
func GetShowDetailOfEventSourceResponseProviderTypeEnum ¶
func GetShowDetailOfEventSourceResponseProviderTypeEnum() ShowDetailOfEventSourceResponseProviderTypeEnum
type ShowDetailOfEventSourceResponseStatus ¶ added in v0.1.3
type ShowDetailOfEventSourceResponseStatus struct {
// contains filtered or unexported fields
}
func (ShowDetailOfEventSourceResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c ShowDetailOfEventSourceResponseStatus) MarshalJSON() ([]byte, error)
func (*ShowDetailOfEventSourceResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *ShowDetailOfEventSourceResponseStatus) UnmarshalJSON(b []byte) error
func (ShowDetailOfEventSourceResponseStatus) Value ¶ added in v0.1.3
func (c ShowDetailOfEventSourceResponseStatus) Value() string
type ShowDetailOfEventSourceResponseStatusEnum ¶ added in v0.1.3
type ShowDetailOfEventSourceResponseStatusEnum struct { CREATE_FAILED ShowDetailOfEventSourceResponseStatus RUNNING ShowDetailOfEventSourceResponseStatus ERROR ShowDetailOfEventSourceResponseStatus }
func GetShowDetailOfEventSourceResponseStatusEnum ¶ added in v0.1.3
func GetShowDetailOfEventSourceResponseStatusEnum() ShowDetailOfEventSourceResponseStatusEnum
type ShowDetailOfEventTraceRequest ¶ added in v0.1.42
type ShowDetailOfEventTraceRequest struct { // 事件唯一标识 TraceId string `json:"trace_id"` // 通道id ChannelId string `json:"channel_id"` }
ShowDetailOfEventTraceRequest Request Object
func (ShowDetailOfEventTraceRequest) String ¶ added in v0.1.42
func (o ShowDetailOfEventTraceRequest) String() string
type ShowDetailOfEventTraceResponse ¶ added in v0.1.42
type ShowDetailOfEventTraceResponse struct { // 事件ID EventId *string `json:"eventId,omitempty"` // 事件源 EventSource *string `json:"eventSource,omitempty"` // 事件类型 EventType *string `json:"eventType,omitempty"` // 接收时间 ReceiveTime *string `json:"receiveTime,omitempty"` // 通道ID ChannelId *string `json:"channelId,omitempty"` // 通道名称 ChannelName *string `json:"channelName,omitempty"` // 事件投递列表 DeliverList *[]DeliverItem `json:"deliverList,omitempty"` HttpStatusCode int `json:"-"` }
ShowDetailOfEventTraceResponse Response Object
func (ShowDetailOfEventTraceResponse) String ¶ added in v0.1.42
func (o ShowDetailOfEventTraceResponse) String() string
type ShowDetailOfSubscriptionRequest ¶
type ShowDetailOfSubscriptionRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` }
ShowDetailOfSubscriptionRequest Request Object
func (ShowDetailOfSubscriptionRequest) String ¶
func (o ShowDetailOfSubscriptionRequest) String() string
type ShowDetailOfSubscriptionResponse ¶
type ShowDetailOfSubscriptionResponse struct { // 订阅ID Id *string `json:"id,omitempty"` // 订阅名称 Name *string `json:"name,omitempty"` // 订阅描述 Description *string `json:"description,omitempty"` // 类型 Type *ShowDetailOfSubscriptionResponseType `json:"type,omitempty"` // 状态 Status *ShowDetailOfSubscriptionResponseStatus `json:"status,omitempty"` // 通道ID ChannelId *string `json:"channel_id,omitempty"` // 通道名称 ChannelName *string `json:"channel_name,omitempty"` // 标签信息 Used *[]SubscriptionUsedInfo `json:"used,omitempty"` // 订阅源列表 Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"` // 订阅目标列表 Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` HttpStatusCode int `json:"-"` }
ShowDetailOfSubscriptionResponse Response Object
func (ShowDetailOfSubscriptionResponse) String ¶
func (o ShowDetailOfSubscriptionResponse) String() string
type ShowDetailOfSubscriptionResponseStatus ¶
type ShowDetailOfSubscriptionResponseStatus struct {
// contains filtered or unexported fields
}
func (ShowDetailOfSubscriptionResponseStatus) MarshalJSON ¶
func (c ShowDetailOfSubscriptionResponseStatus) MarshalJSON() ([]byte, error)
func (*ShowDetailOfSubscriptionResponseStatus) UnmarshalJSON ¶
func (c *ShowDetailOfSubscriptionResponseStatus) UnmarshalJSON(b []byte) error
func (ShowDetailOfSubscriptionResponseStatus) Value ¶
func (c ShowDetailOfSubscriptionResponseStatus) Value() string
type ShowDetailOfSubscriptionResponseStatusEnum ¶
type ShowDetailOfSubscriptionResponseStatusEnum struct { CREATED ShowDetailOfSubscriptionResponseStatus ENABLED ShowDetailOfSubscriptionResponseStatus DISABLED ShowDetailOfSubscriptionResponseStatus FROZEN ShowDetailOfSubscriptionResponseStatus ERROR ShowDetailOfSubscriptionResponseStatus }
func GetShowDetailOfSubscriptionResponseStatusEnum ¶
func GetShowDetailOfSubscriptionResponseStatusEnum() ShowDetailOfSubscriptionResponseStatusEnum
type ShowDetailOfSubscriptionResponseType ¶
type ShowDetailOfSubscriptionResponseType struct {
// contains filtered or unexported fields
}
func (ShowDetailOfSubscriptionResponseType) MarshalJSON ¶
func (c ShowDetailOfSubscriptionResponseType) MarshalJSON() ([]byte, error)
func (*ShowDetailOfSubscriptionResponseType) UnmarshalJSON ¶
func (c *ShowDetailOfSubscriptionResponseType) UnmarshalJSON(b []byte) error
func (ShowDetailOfSubscriptionResponseType) Value ¶
func (c ShowDetailOfSubscriptionResponseType) Value() string
type ShowDetailOfSubscriptionResponseTypeEnum ¶
type ShowDetailOfSubscriptionResponseTypeEnum struct { EVENT ShowDetailOfSubscriptionResponseType SCHEDULED ShowDetailOfSubscriptionResponseType }
func GetShowDetailOfSubscriptionResponseTypeEnum ¶
func GetShowDetailOfSubscriptionResponseTypeEnum() ShowDetailOfSubscriptionResponseTypeEnum
type ShowDetailOfSubscriptionTargetRequest ¶
type ShowDetailOfSubscriptionTargetRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` // 事件订阅目标ID TargetId string `json:"target_id"` }
ShowDetailOfSubscriptionTargetRequest Request Object
func (ShowDetailOfSubscriptionTargetRequest) String ¶
func (o ShowDetailOfSubscriptionTargetRequest) String() string
type ShowDetailOfSubscriptionTargetResponse ¶
type ShowDetailOfSubscriptionTargetResponse struct { // 订阅目标ID Id *string `json:"id,omitempty"` // 订阅的事件目标名称 Name *string `json:"name,omitempty"` // 订阅的事件目标的提供方类型 ProviderType *string `json:"provider_type,omitempty"` // 订阅的事件目标使用的目标链接ID ConnectionId *string `json:"connection_id,omitempty"` // 订阅的事件目标参数列表 Detail *interface{} `json:"detail,omitempty"` Transform *TransForm `json:"transform,omitempty"` DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` HttpStatusCode int `json:"-"` }
ShowDetailOfSubscriptionTargetResponse Response Object
func (ShowDetailOfSubscriptionTargetResponse) String ¶
func (o ShowDetailOfSubscriptionTargetResponse) String() string
type ShowEventStreamingRequest ¶ added in v0.1.42
type ShowEventStreamingRequest struct { // 事件流ID EventstreamingId string `json:"eventstreaming_id"` }
ShowEventStreamingRequest Request Object
func (ShowEventStreamingRequest) String ¶ added in v0.1.42
func (o ShowEventStreamingRequest) String() string
type ShowEventStreamingResponse ¶ added in v0.1.42
type ShowEventStreamingResponse struct { // 事件流名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 Name string `json:"name"` // 事件流描述 Description *string `json:"description,omitempty"` Source *EventStreamingSource `json:"source"` Sink *EventStreamingSink `json:"sink"` RuleConfig *EventStreamingCreateReqRuleConfig `json:"rule_config,omitempty"` Option *RunOption `json:"option,omitempty"` // 事件流状态 Status *ShowEventStreamingResponseStatus `json:"status,omitempty"` // 事件流ID StreamingId *string `json:"streaming_id,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
ShowEventStreamingResponse Response Object
func (ShowEventStreamingResponse) String ¶ added in v0.1.42
func (o ShowEventStreamingResponse) String() string
type ShowEventStreamingResponseStatus ¶ added in v0.1.42
type ShowEventStreamingResponseStatus struct {
// contains filtered or unexported fields
}
func (ShowEventStreamingResponseStatus) MarshalJSON ¶ added in v0.1.42
func (c ShowEventStreamingResponseStatus) MarshalJSON() ([]byte, error)
func (*ShowEventStreamingResponseStatus) UnmarshalJSON ¶ added in v0.1.42
func (c *ShowEventStreamingResponseStatus) UnmarshalJSON(b []byte) error
func (ShowEventStreamingResponseStatus) Value ¶ added in v0.1.42
func (c ShowEventStreamingResponseStatus) Value() string
type ShowEventStreamingResponseStatusEnum ¶ added in v0.1.42
type ShowEventStreamingResponseStatusEnum struct { CREATED ShowEventStreamingResponseStatus RUNNING ShowEventStreamingResponseStatus ERROR ShowEventStreamingResponseStatus STOPPED ShowEventStreamingResponseStatus }
func GetShowEventStreamingResponseStatusEnum ¶ added in v0.1.42
func GetShowEventStreamingResponseStatusEnum() ShowEventStreamingResponseStatusEnum
type SinkFgParameters ¶ added in v0.1.42
type SinkFgParameters struct { // 函数执行方式,同步/异步 InvokeType *SinkFgParametersInvokeType `json:"invoke_type,omitempty"` // 函数链接 Urn *string `json:"urn,omitempty"` // 租户委托 Agency *string `json:"agency,omitempty"` }
func (SinkFgParameters) String ¶ added in v0.1.42
func (o SinkFgParameters) String() string
type SinkFgParametersInvokeType ¶ added in v0.1.42
type SinkFgParametersInvokeType struct {
// contains filtered or unexported fields
}
func (SinkFgParametersInvokeType) MarshalJSON ¶ added in v0.1.42
func (c SinkFgParametersInvokeType) MarshalJSON() ([]byte, error)
func (*SinkFgParametersInvokeType) UnmarshalJSON ¶ added in v0.1.42
func (c *SinkFgParametersInvokeType) UnmarshalJSON(b []byte) error
func (SinkFgParametersInvokeType) Value ¶ added in v0.1.42
func (c SinkFgParametersInvokeType) Value() string
type SinkFgParametersInvokeTypeEnum ¶ added in v0.1.42
type SinkFgParametersInvokeTypeEnum struct {
SYNCASYNC SinkFgParametersInvokeType
}
func GetSinkFgParametersInvokeTypeEnum ¶ added in v0.1.42
func GetSinkFgParametersInvokeTypeEnum() SinkFgParametersInvokeTypeEnum
type SmnTargetDetail ¶ added in v0.1.52
type SmnTargetDetail struct { // 主题urn Urn string `json:"urn"` // 委托名称 AgencyName string `json:"agency_name"` SubjectTransform *SmnTargetDetailSubjectTransform `json:"subject_transform,omitempty"` }
SmnTargetDetail 订阅的SMN事件目标参数列表,该字段序列化后总长度不超过1024字节
func (SmnTargetDetail) String ¶ added in v0.1.52
func (o SmnTargetDetail) String() string
type SmnTargetDetailSubjectTransform ¶ added in v0.1.52
type SmnTargetDetailSubjectTransform struct { // 标题规则类型 Type SmnTargetDetailSubjectTransformType `json:"type"` // 标题规则 Value string `json:"value"` // 标题规则模板,键值规则为VARIABLE时必填 Template *string `json:"template,omitempty"` }
SmnTargetDetailSubjectTransform 标题规则
func (SmnTargetDetailSubjectTransform) String ¶ added in v0.1.52
func (o SmnTargetDetailSubjectTransform) String() string
type SmnTargetDetailSubjectTransformType ¶ added in v0.1.52
type SmnTargetDetailSubjectTransformType struct {
// contains filtered or unexported fields
}
func (SmnTargetDetailSubjectTransformType) MarshalJSON ¶ added in v0.1.52
func (c SmnTargetDetailSubjectTransformType) MarshalJSON() ([]byte, error)
func (*SmnTargetDetailSubjectTransformType) UnmarshalJSON ¶ added in v0.1.52
func (c *SmnTargetDetailSubjectTransformType) UnmarshalJSON(b []byte) error
func (SmnTargetDetailSubjectTransformType) Value ¶ added in v0.1.52
func (c SmnTargetDetailSubjectTransformType) Value() string
type SmnTargetDetailSubjectTransformTypeEnum ¶ added in v0.1.52
type SmnTargetDetailSubjectTransformTypeEnum struct { VARIABLE SmnTargetDetailSubjectTransformType CONSTANT SmnTargetDetailSubjectTransformType }
func GetSmnTargetDetailSubjectTransformTypeEnum ¶ added in v0.1.52
func GetSmnTargetDetailSubjectTransformTypeEnum() SmnTargetDetailSubjectTransformTypeEnum
type SourceKafkaMqParameters ¶ added in v0.1.42
type SourceKafkaMqParameters struct { // kafka消费组 Group string `json:"group"` // kafka实例名称 InstanceName *string `json:"instance_name,omitempty"` // kafka实例ID InstanceId *string `json:"instance_id,omitempty"` // kafka topic名称 Topic string `json:"topic"` // 消费点位 SeekTo *SourceKafkaMqParametersSeekTo `json:"seek_to,omitempty"` // SASL_SSL是否开启 EnableSaslSsl *bool `json:"enable_sasl_ssl,omitempty"` // SASL认证机制 SaslMechanism *SourceKafkaMqParametersSaslMechanism `json:"sasl_mechanism,omitempty"` // SASL证书地址,配置的obs地址 SslCertificateUrl *string `json:"ssl_certificate_url,omitempty"` // SASL证书密码 SslCertificatePwd *string `json:"ssl_certificate_pwd,omitempty"` // 用户名 UserName *string `json:"user_name,omitempty"` // 用户密码 Password *string `json:"password,omitempty"` }
func (SourceKafkaMqParameters) String ¶ added in v0.1.42
func (o SourceKafkaMqParameters) String() string
type SourceKafkaMqParametersSaslMechanism ¶ added in v0.1.52
type SourceKafkaMqParametersSaslMechanism struct {
// contains filtered or unexported fields
}
func (SourceKafkaMqParametersSaslMechanism) MarshalJSON ¶ added in v0.1.52
func (c SourceKafkaMqParametersSaslMechanism) MarshalJSON() ([]byte, error)
func (*SourceKafkaMqParametersSaslMechanism) UnmarshalJSON ¶ added in v0.1.52
func (c *SourceKafkaMqParametersSaslMechanism) UnmarshalJSON(b []byte) error
func (SourceKafkaMqParametersSaslMechanism) Value ¶ added in v0.1.52
func (c SourceKafkaMqParametersSaslMechanism) Value() string
type SourceKafkaMqParametersSaslMechanismEnum ¶ added in v0.1.52
type SourceKafkaMqParametersSaslMechanismEnum struct { SCRAM_SHA_512 SourceKafkaMqParametersSaslMechanism PLAIN SourceKafkaMqParametersSaslMechanism }
func GetSourceKafkaMqParametersSaslMechanismEnum ¶ added in v0.1.52
func GetSourceKafkaMqParametersSaslMechanismEnum() SourceKafkaMqParametersSaslMechanismEnum
type SourceKafkaMqParametersSeekTo ¶ added in v0.1.52
type SourceKafkaMqParametersSeekTo struct {
// contains filtered or unexported fields
}
func (SourceKafkaMqParametersSeekTo) MarshalJSON ¶ added in v0.1.52
func (c SourceKafkaMqParametersSeekTo) MarshalJSON() ([]byte, error)
func (*SourceKafkaMqParametersSeekTo) UnmarshalJSON ¶ added in v0.1.52
func (c *SourceKafkaMqParametersSeekTo) UnmarshalJSON(b []byte) error
func (SourceKafkaMqParametersSeekTo) Value ¶ added in v0.1.52
func (c SourceKafkaMqParametersSeekTo) Value() string
type SourceKafkaMqParametersSeekToEnum ¶ added in v0.1.52
type SourceKafkaMqParametersSeekToEnum struct { LATEST SourceKafkaMqParametersSeekTo EARLIEST SourceKafkaMqParametersSeekTo }
func GetSourceKafkaMqParametersSeekToEnum ¶ added in v0.1.52
func GetSourceKafkaMqParametersSeekToEnum() SourceKafkaMqParametersSeekToEnum
type SubscriptionCreateReq ¶
type SubscriptionCreateReq struct { // 订阅名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 Name string `json:"name"` // 订阅描述 Description *string `json:"description,omitempty"` // 所属事件通道ID ChannelId string `json:"channel_id"` // 订阅的事件源列表, 当前仅支持订阅一个事件源 Sources []SubscriptionSource `json:"sources"` // 事件目标列表,至少订阅一个事件目标 Targets []SubscriptionTarget `json:"targets"` }
func (SubscriptionCreateReq) String ¶
func (o SubscriptionCreateReq) String() string
type SubscriptionInfo ¶
type SubscriptionInfo struct { // 订阅ID Id *string `json:"id,omitempty"` // 订阅名称 Name *string `json:"name,omitempty"` // 订阅描述 Description *string `json:"description,omitempty"` // 类型 Type *SubscriptionInfoType `json:"type,omitempty"` // 状态 Status *SubscriptionInfoStatus `json:"status,omitempty"` // 通道ID ChannelId *string `json:"channel_id,omitempty"` // 通道名称 ChannelName *string `json:"channel_name,omitempty"` // 标签信息 Used *[]SubscriptionUsedInfo `json:"used,omitempty"` // 订阅源列表 Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"` // 订阅目标列表 Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` }
func (SubscriptionInfo) String ¶
func (o SubscriptionInfo) String() string
type SubscriptionInfoStatus ¶
type SubscriptionInfoStatus struct {
// contains filtered or unexported fields
}
func (SubscriptionInfoStatus) MarshalJSON ¶
func (c SubscriptionInfoStatus) MarshalJSON() ([]byte, error)
func (*SubscriptionInfoStatus) UnmarshalJSON ¶
func (c *SubscriptionInfoStatus) UnmarshalJSON(b []byte) error
func (SubscriptionInfoStatus) Value ¶
func (c SubscriptionInfoStatus) Value() string
type SubscriptionInfoStatusEnum ¶
type SubscriptionInfoStatusEnum struct { CREATED SubscriptionInfoStatus ENABLED SubscriptionInfoStatus DISABLED SubscriptionInfoStatus FROZEN SubscriptionInfoStatus ERROR SubscriptionInfoStatus }
func GetSubscriptionInfoStatusEnum ¶
func GetSubscriptionInfoStatusEnum() SubscriptionInfoStatusEnum
type SubscriptionInfoType ¶
type SubscriptionInfoType struct {
// contains filtered or unexported fields
}
func (SubscriptionInfoType) MarshalJSON ¶
func (c SubscriptionInfoType) MarshalJSON() ([]byte, error)
func (*SubscriptionInfoType) UnmarshalJSON ¶
func (c *SubscriptionInfoType) UnmarshalJSON(b []byte) error
func (SubscriptionInfoType) Value ¶
func (c SubscriptionInfoType) Value() string
type SubscriptionInfoTypeEnum ¶
type SubscriptionInfoTypeEnum struct { EVENT SubscriptionInfoType SCHEDULED SubscriptionInfoType }
func GetSubscriptionInfoTypeEnum ¶
func GetSubscriptionInfoTypeEnum() SubscriptionInfoTypeEnum
type SubscriptionOperateReq ¶
type SubscriptionOperateReq struct { // 订阅对象ID列表,单次批量操作最多支持10个订阅 SubscriptionIds *[]string `json:"subscription_ids,omitempty"` // 操作类型 Operation *SubscriptionOperateReqOperation `json:"operation,omitempty"` }
SubscriptionOperateReq 订阅批量操作请求
func (SubscriptionOperateReq) String ¶
func (o SubscriptionOperateReq) String() string
type SubscriptionOperateReqOperation ¶
type SubscriptionOperateReqOperation struct {
// contains filtered or unexported fields
}
func (SubscriptionOperateReqOperation) MarshalJSON ¶
func (c SubscriptionOperateReqOperation) MarshalJSON() ([]byte, error)
func (*SubscriptionOperateReqOperation) UnmarshalJSON ¶
func (c *SubscriptionOperateReqOperation) UnmarshalJSON(b []byte) error
func (SubscriptionOperateReqOperation) Value ¶
func (c SubscriptionOperateReqOperation) Value() string
type SubscriptionOperateReqOperationEnum ¶
type SubscriptionOperateReqOperationEnum struct { DISABLE SubscriptionOperateReqOperation ENABLE SubscriptionOperateReqOperation }
func GetSubscriptionOperateReqOperationEnum ¶
func GetSubscriptionOperateReqOperationEnum() SubscriptionOperateReqOperationEnum
type SubscriptionOperateRespEvents ¶
type SubscriptionOperateRespEvents struct { // 失败的错误码 ErrorCode *string `json:"error_code,omitempty"` // 失败的原因 ErrorMsg *string `json:"error_msg,omitempty"` // 订阅ID SubscriptionId *string `json:"subscription_id,omitempty"` }
func (SubscriptionOperateRespEvents) String ¶
func (o SubscriptionOperateRespEvents) String() string
type SubscriptionSource ¶
type SubscriptionSource struct { // 订阅源ID,需保证全局唯一。指定ID的订阅源存在时则进行更新,否则进行创建;未指定时由系统自动生成。由小写字母、数字、中划线组成,必须字母或数字开头。 Id *string `json:"id,omitempty"` // 订阅的事件源名称 Name string `json:"name"` // 订阅的事件源的提供方类型 ProviderType SubscriptionSourceProviderType `json:"provider_type"` // 订阅的事件源参数列表, 该字段序列化后总长度不超过1024字节 Detail *interface{} `json:"detail,omitempty"` // 订阅事件源的匹配过滤规则, 该字段序列化后总长度不超过2048字节 Filter *interface{} `json:"filter"` }
func (SubscriptionSource) String ¶
func (o SubscriptionSource) String() string
type SubscriptionSourceInfo ¶
type SubscriptionSourceInfo struct { // 订阅源ID Id *string `json:"id,omitempty"` // 订阅的事件源名称 Name *string `json:"name,omitempty"` // 订阅的事件源的提供方类型 ProviderType *string `json:"provider_type,omitempty"` // 订阅的事件源参数列表 Detail *interface{} `json:"detail,omitempty"` // 订阅事件源的匹配过滤规则 Filter *interface{} `json:"filter,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` }
func (SubscriptionSourceInfo) String ¶
func (o SubscriptionSourceInfo) String() string
type SubscriptionSourceProviderType ¶
type SubscriptionSourceProviderType struct {
// contains filtered or unexported fields
}
func (SubscriptionSourceProviderType) MarshalJSON ¶
func (c SubscriptionSourceProviderType) MarshalJSON() ([]byte, error)
func (*SubscriptionSourceProviderType) UnmarshalJSON ¶
func (c *SubscriptionSourceProviderType) UnmarshalJSON(b []byte) error
func (SubscriptionSourceProviderType) Value ¶
func (c SubscriptionSourceProviderType) Value() string
type SubscriptionSourceProviderTypeEnum ¶
type SubscriptionSourceProviderTypeEnum struct { CUSTOM SubscriptionSourceProviderType OFFICIAL SubscriptionSourceProviderType PARTNER SubscriptionSourceProviderType }
func GetSubscriptionSourceProviderTypeEnum ¶
func GetSubscriptionSourceProviderTypeEnum() SubscriptionSourceProviderTypeEnum
type SubscriptionTarget ¶
type SubscriptionTarget struct { // 订阅目标ID,需保证全局唯一,由小写字母、数字、中划线组成,必须字母或数字开头。 更新订阅场景时,指定ID的订阅目标存在时则进行更新,否则进行创建; 创建订阅目标场景时,指定ID作为待创建的订阅目标对象ID,未指定时由系统自动生成。 更新订阅目标时,此字段忽略; Id *string `json:"id,omitempty"` // 订阅的事件目标名称 Name string `json:"name"` // 订阅的事件目标的提供方类型 ProviderType SubscriptionTargetProviderType `json:"provider_type"` // 订阅的事件目标使用的目标链接ID ConnectionId *string `json:"connection_id,omitempty"` Detail *Detail `json:"detail,omitempty"` KafkaDetail *KafkaTargetDetail `json:"kafka_detail,omitempty"` SmnDetail *SmnTargetDetail `json:"smn_detail,omitempty"` Transform *TransForm `json:"transform"` DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"` }
func (SubscriptionTarget) String ¶
func (o SubscriptionTarget) String() string
type SubscriptionTargetInfo ¶
type SubscriptionTargetInfo struct { // 订阅目标ID Id *string `json:"id,omitempty"` // 订阅的事件目标名称 Name *string `json:"name,omitempty"` // 订阅的事件目标的提供方类型 ProviderType *string `json:"provider_type,omitempty"` // 订阅的事件目标使用的目标链接ID ConnectionId *string `json:"connection_id,omitempty"` // 订阅的事件目标参数列表 Detail *interface{} `json:"detail,omitempty"` Transform *TransForm `json:"transform,omitempty"` DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` }
func (SubscriptionTargetInfo) String ¶
func (o SubscriptionTargetInfo) String() string
type SubscriptionTargetProviderType ¶
type SubscriptionTargetProviderType struct {
// contains filtered or unexported fields
}
func (SubscriptionTargetProviderType) MarshalJSON ¶
func (c SubscriptionTargetProviderType) MarshalJSON() ([]byte, error)
func (*SubscriptionTargetProviderType) UnmarshalJSON ¶
func (c *SubscriptionTargetProviderType) UnmarshalJSON(b []byte) error
func (SubscriptionTargetProviderType) Value ¶
func (c SubscriptionTargetProviderType) Value() string
type SubscriptionTargetProviderTypeEnum ¶
type SubscriptionTargetProviderTypeEnum struct { CUSTOM SubscriptionTargetProviderType OFFICIAL SubscriptionTargetProviderType }
func GetSubscriptionTargetProviderTypeEnum ¶
func GetSubscriptionTargetProviderTypeEnum() SubscriptionTargetProviderTypeEnum
type SubscriptionUpdateReq ¶
type SubscriptionUpdateReq struct { // 订阅描述 Description *string `json:"description,omitempty"` // 订阅事件源列表,字段存在则代表全量更新订阅源 Sources *[]SubscriptionSource `json:"sources,omitempty"` // 订阅事件目标列表,字段存在则代表全量更新订阅目标 Targets *[]SubscriptionTarget `json:"targets,omitempty"` }
SubscriptionUpdateReq 更新订阅,全量更新订阅源和目标
func (SubscriptionUpdateReq) String ¶
func (o SubscriptionUpdateReq) String() string
type SubscriptionUsedInfo ¶ added in v0.1.28
type SubscriptionUsedInfo struct { // 关联资源ID ResourceId *string `json:"resource_id,omitempty"` // 管理租户账号 Owner *string `json:"owner,omitempty"` // 描述 Description *string `json:"description,omitempty"` }
func (SubscriptionUsedInfo) String ¶ added in v0.1.28
func (o SubscriptionUsedInfo) String() string
type TransForm ¶ added in v0.1.28
type TransForm struct { // 转换规则类型 Type TransFormType `json:"type"` // 常量类型规则时,字段为常量内容定义; 变量类型规则时,为变量定义,内容必须为JsonObject字符串。 变量最多支持100个,且不支持嵌套结构定义; 变量名由字母、数字、点、下划线和中划线组成,必须字母或数字开头不能以HC.开头,长度不超过64个字符; 变量值表达式支持常量或JsonPath表达式,字符串长度不超过1024个字符。 Value *string `json:"value,omitempty"` // 变量类型规则时,规则内容的模板定义,支持对已定义变量的引用。 Template *string `json:"template,omitempty"` }
TransForm 订阅的事件目标转换规则
type TransFormType ¶ added in v0.1.28
type TransFormType struct {
// contains filtered or unexported fields
}
func (TransFormType) MarshalJSON ¶ added in v0.1.28
func (c TransFormType) MarshalJSON() ([]byte, error)
func (*TransFormType) UnmarshalJSON ¶ added in v0.1.28
func (c *TransFormType) UnmarshalJSON(b []byte) error
func (TransFormType) Value ¶ added in v0.1.28
func (c TransFormType) Value() string
type TransFormTypeEnum ¶ added in v0.1.28
type TransFormTypeEnum struct { ORIGINAL TransFormType CONSTANT TransFormType VARIABLE TransFormType }
func GetTransFormTypeEnum ¶ added in v0.1.28
func GetTransFormTypeEnum() TransFormTypeEnum
type UpdateChannelRequest ¶
type UpdateChannelRequest struct { // 指定查询的事件通道ID ChannelId string `json:"channel_id"` Body *ChannelUpdateReq `json:"body,omitempty"` }
UpdateChannelRequest Request Object
func (UpdateChannelRequest) String ¶
func (o UpdateChannelRequest) String() string
type UpdateChannelResponse ¶
type UpdateChannelResponse struct { // 通道ID Id *string `json:"id,omitempty"` // 通道名称 Name *string `json:"name,omitempty"` // 通道描述 Description *string `json:"description,omitempty"` // 通道提供方类型,OFFICIAL:官方事件通道;CUSTOM:自定义事件通道;PARTNER:伙伴事件通道 ProviderType *UpdateChannelResponseProviderType `json:"provider_type,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
UpdateChannelResponse Response Object
func (UpdateChannelResponse) String ¶
func (o UpdateChannelResponse) String() string
type UpdateChannelResponseProviderType ¶
type UpdateChannelResponseProviderType struct {
// contains filtered or unexported fields
}
func (UpdateChannelResponseProviderType) MarshalJSON ¶
func (c UpdateChannelResponseProviderType) MarshalJSON() ([]byte, error)
func (*UpdateChannelResponseProviderType) UnmarshalJSON ¶
func (c *UpdateChannelResponseProviderType) UnmarshalJSON(b []byte) error
func (UpdateChannelResponseProviderType) Value ¶
func (c UpdateChannelResponseProviderType) Value() string
type UpdateChannelResponseProviderTypeEnum ¶
type UpdateChannelResponseProviderTypeEnum struct { OFFICIAL UpdateChannelResponseProviderType CUSTOM UpdateChannelResponseProviderType PARTNER UpdateChannelResponseProviderType }
func GetUpdateChannelResponseProviderTypeEnum ¶
func GetUpdateChannelResponseProviderTypeEnum() UpdateChannelResponseProviderTypeEnum
type UpdateConnectionRequest ¶ added in v0.1.3
type UpdateConnectionRequest struct { // 指定查询的目标连接ID ConnectionId string `json:"connection_id"` Body *ConnectionUpdateReq `json:"body,omitempty"` }
UpdateConnectionRequest Request Object
func (UpdateConnectionRequest) String ¶ added in v0.1.3
func (o UpdateConnectionRequest) String() string
type UpdateConnectionResponse ¶ added in v0.1.3
type UpdateConnectionResponse struct { // 事件源ID Id *string `json:"id,omitempty"` // 目标连接名称,租户下唯一,由小写字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default Name *string `json:"name,omitempty"` // 目标连接描述 Description *string `json:"description,omitempty"` // 目标连接状态 Status *UpdateConnectionResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` // 待连接的VPC ID VpcId *string `json:"vpc_id,omitempty"` // 待连接的子网ID SubnetId *string `json:"subnet_id,omitempty"` // 私网目标连接使用的用户委托名称 Agency *string `json:"agency,omitempty"` Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"` Type *ConnectionType `json:"type,omitempty"` KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
UpdateConnectionResponse Response Object
func (UpdateConnectionResponse) String ¶ added in v0.1.3
func (o UpdateConnectionResponse) String() string
type UpdateConnectionResponseStatus ¶ added in v0.1.3
type UpdateConnectionResponseStatus struct {
// contains filtered or unexported fields
}
func (UpdateConnectionResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c UpdateConnectionResponseStatus) MarshalJSON() ([]byte, error)
func (*UpdateConnectionResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *UpdateConnectionResponseStatus) UnmarshalJSON(b []byte) error
func (UpdateConnectionResponseStatus) Value ¶ added in v0.1.3
func (c UpdateConnectionResponseStatus) Value() string
type UpdateConnectionResponseStatusEnum ¶ added in v0.1.3
type UpdateConnectionResponseStatusEnum struct { CREATING UpdateConnectionResponseStatus CREATED UpdateConnectionResponseStatus CREATE_FAILED UpdateConnectionResponseStatus }
func GetUpdateConnectionResponseStatusEnum ¶ added in v0.1.3
func GetUpdateConnectionResponseStatusEnum() UpdateConnectionResponseStatusEnum
type UpdateEndpointRequest ¶ added in v0.1.3
type UpdateEndpointRequest struct { // 指定查询访问端点的id EndpointId string `json:"endpoint_id"` Body *EndpointUpdateReq `json:"body,omitempty"` }
UpdateEndpointRequest Request Object
func (UpdateEndpointRequest) String ¶ added in v0.1.3
func (o UpdateEndpointRequest) String() string
type UpdateEndpointResponse ¶ added in v0.1.3
type UpdateEndpointResponse struct { // 访问端点ID Id *string `json:"id,omitempty"` // 用户指定的访问端点名称 Name *string `json:"name,omitempty"` // 访问端点所在的VPC的ID VpcId *string `json:"vpc_id,omitempty"` // 访问端点所在的子网的ID SubnetId *string `json:"subnet_id,omitempty"` // 访问域名 Domain *string `json:"domain,omitempty"` // 描述 Description *string `json:"description,omitempty"` // 访问端点状态 Status *UpdateEndpointResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` // 访问端点类型 Type *UpdateEndpointResponseType `json:"type,omitempty"` // 是否可更新 Scalable *bool `json:"scalable,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` // 访问端点终端节点列表 Endpoints *[]EndpointConnection `json:"endpoints,omitempty"` HttpStatusCode int `json:"-"` }
UpdateEndpointResponse Response Object
func (UpdateEndpointResponse) String ¶ added in v0.1.3
func (o UpdateEndpointResponse) String() string
type UpdateEndpointResponseStatus ¶ added in v0.1.3
type UpdateEndpointResponseStatus struct {
// contains filtered or unexported fields
}
func (UpdateEndpointResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c UpdateEndpointResponseStatus) MarshalJSON() ([]byte, error)
func (*UpdateEndpointResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *UpdateEndpointResponseStatus) UnmarshalJSON(b []byte) error
func (UpdateEndpointResponseStatus) Value ¶ added in v0.1.3
func (c UpdateEndpointResponseStatus) Value() string
type UpdateEndpointResponseStatusEnum ¶ added in v0.1.3
type UpdateEndpointResponseStatusEnum struct { CREATED UpdateEndpointResponseStatus CREATING UpdateEndpointResponseStatus CREATE_FAILED UpdateEndpointResponseStatus DELETE_FAILED UpdateEndpointResponseStatus }
func GetUpdateEndpointResponseStatusEnum ¶ added in v0.1.3
func GetUpdateEndpointResponseStatusEnum() UpdateEndpointResponseStatusEnum
type UpdateEndpointResponseType ¶ added in v0.1.3
type UpdateEndpointResponseType struct {
// contains filtered or unexported fields
}
func (UpdateEndpointResponseType) MarshalJSON ¶ added in v0.1.3
func (c UpdateEndpointResponseType) MarshalJSON() ([]byte, error)
func (*UpdateEndpointResponseType) UnmarshalJSON ¶ added in v0.1.3
func (c *UpdateEndpointResponseType) UnmarshalJSON(b []byte) error
func (UpdateEndpointResponseType) Value ¶ added in v0.1.3
func (c UpdateEndpointResponseType) Value() string
type UpdateEndpointResponseTypeEnum ¶ added in v0.1.3
type UpdateEndpointResponseTypeEnum struct { PRIVATE UpdateEndpointResponseType PUBLIC UpdateEndpointResponseType }
func GetUpdateEndpointResponseTypeEnum ¶ added in v0.1.3
func GetUpdateEndpointResponseTypeEnum() UpdateEndpointResponseTypeEnum
type UpdateEventSourceRequest ¶
type UpdateEventSourceRequest struct { // 指定查询的事件源ID SourceId string `json:"source_id"` Body *CustomizeSourceUpdateReq `json:"body,omitempty"` }
UpdateEventSourceRequest Request Object
func (UpdateEventSourceRequest) String ¶
func (o UpdateEventSourceRequest) String() string
type UpdateEventSourceResponse ¶
type UpdateEventSourceResponse struct { // 事件源ID Id *string `json:"id,omitempty"` // 事件源名称 Name *string `json:"name,omitempty"` // 事件源名称展示 Label *string `json:"label,omitempty"` // 事件源描述 Description *string `json:"description,omitempty"` // 事件源提供方类型,OFFICIAL:官方云服务事件源;CUSTOM:用户创建的自定义事件源;PARTNER:伙伴事件源 ProviderType *UpdateEventSourceResponseProviderType `json:"provider_type,omitempty"` // 事件源提供的事件类型列表,只有官方云服务事件源提供事件类型 EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"` // 创建UTC时间 CreatedTime *string `json:"created_time,omitempty"` // 更新UTC时间 UpdatedTime *string `json:"updated_time,omitempty"` // 事件源归属的事件通道ID ChannelId *string `json:"channel_id,omitempty"` // 事件源归属的事件通道名称 ChannelName *string `json:"channel_name,omitempty"` // 事件源类型 Type *string `json:"type,omitempty"` // json格式封装消息实例链接信息:如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等 Detail *interface{} `json:"detail,omitempty"` // 自定义事件源状态 Status *UpdateEventSourceResponseStatus `json:"status,omitempty"` ErrorInfo *ErrorInfo `json:"error_info,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
UpdateEventSourceResponse Response Object
func (UpdateEventSourceResponse) String ¶
func (o UpdateEventSourceResponse) String() string
type UpdateEventSourceResponseProviderType ¶
type UpdateEventSourceResponseProviderType struct {
// contains filtered or unexported fields
}
func (UpdateEventSourceResponseProviderType) MarshalJSON ¶
func (c UpdateEventSourceResponseProviderType) MarshalJSON() ([]byte, error)
func (*UpdateEventSourceResponseProviderType) UnmarshalJSON ¶
func (c *UpdateEventSourceResponseProviderType) UnmarshalJSON(b []byte) error
func (UpdateEventSourceResponseProviderType) Value ¶
func (c UpdateEventSourceResponseProviderType) Value() string
type UpdateEventSourceResponseProviderTypeEnum ¶
type UpdateEventSourceResponseProviderTypeEnum struct { OFFICIAL UpdateEventSourceResponseProviderType CUSTOM UpdateEventSourceResponseProviderType PARTNER UpdateEventSourceResponseProviderType }
func GetUpdateEventSourceResponseProviderTypeEnum ¶
func GetUpdateEventSourceResponseProviderTypeEnum() UpdateEventSourceResponseProviderTypeEnum
type UpdateEventSourceResponseStatus ¶ added in v0.1.3
type UpdateEventSourceResponseStatus struct {
// contains filtered or unexported fields
}
func (UpdateEventSourceResponseStatus) MarshalJSON ¶ added in v0.1.3
func (c UpdateEventSourceResponseStatus) MarshalJSON() ([]byte, error)
func (*UpdateEventSourceResponseStatus) UnmarshalJSON ¶ added in v0.1.3
func (c *UpdateEventSourceResponseStatus) UnmarshalJSON(b []byte) error
func (UpdateEventSourceResponseStatus) Value ¶ added in v0.1.3
func (c UpdateEventSourceResponseStatus) Value() string
type UpdateEventSourceResponseStatusEnum ¶ added in v0.1.3
type UpdateEventSourceResponseStatusEnum struct { CREATE_FAILED UpdateEventSourceResponseStatus RUNNING UpdateEventSourceResponseStatus ERROR UpdateEventSourceResponseStatus }
func GetUpdateEventSourceResponseStatusEnum ¶ added in v0.1.3
func GetUpdateEventSourceResponseStatusEnum() UpdateEventSourceResponseStatusEnum
type UpdateEventStreamingRequest ¶ added in v0.1.42
type UpdateEventStreamingRequest struct { // 事件流ID EventstreamingId string `json:"eventstreaming_id"` Body *EventStreamingUpdateReq `json:"body,omitempty"` }
UpdateEventStreamingRequest Request Object
func (UpdateEventStreamingRequest) String ¶ added in v0.1.42
func (o UpdateEventStreamingRequest) String() string
type UpdateEventStreamingResponse ¶ added in v0.1.42
type UpdateEventStreamingResponse struct { // 事件流ID EventStreamingID *string `json:"eventStreamingID,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
UpdateEventStreamingResponse Response Object
func (UpdateEventStreamingResponse) String ¶ added in v0.1.42
func (o UpdateEventStreamingResponse) String() string
type UpdateSubscriptionRequest ¶
type UpdateSubscriptionRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` Body *SubscriptionUpdateReq `json:"body,omitempty"` }
UpdateSubscriptionRequest Request Object
func (UpdateSubscriptionRequest) String ¶
func (o UpdateSubscriptionRequest) String() string
type UpdateSubscriptionResponse ¶
type UpdateSubscriptionResponse struct { // 订阅ID Id *string `json:"id,omitempty"` // 订阅名称 Name *string `json:"name,omitempty"` // 订阅描述 Description *string `json:"description,omitempty"` // 类型 Type *UpdateSubscriptionResponseType `json:"type,omitempty"` // 状态 Status *UpdateSubscriptionResponseStatus `json:"status,omitempty"` // 通道ID ChannelId *string `json:"channel_id,omitempty"` // 通道名称 ChannelName *string `json:"channel_name,omitempty"` // 标签信息 Used *[]SubscriptionUsedInfo `json:"used,omitempty"` // 订阅源列表 Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"` // 订阅目标列表 Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
UpdateSubscriptionResponse Response Object
func (UpdateSubscriptionResponse) String ¶
func (o UpdateSubscriptionResponse) String() string
type UpdateSubscriptionResponseStatus ¶
type UpdateSubscriptionResponseStatus struct {
// contains filtered or unexported fields
}
func (UpdateSubscriptionResponseStatus) MarshalJSON ¶
func (c UpdateSubscriptionResponseStatus) MarshalJSON() ([]byte, error)
func (*UpdateSubscriptionResponseStatus) UnmarshalJSON ¶
func (c *UpdateSubscriptionResponseStatus) UnmarshalJSON(b []byte) error
func (UpdateSubscriptionResponseStatus) Value ¶
func (c UpdateSubscriptionResponseStatus) Value() string
type UpdateSubscriptionResponseStatusEnum ¶
type UpdateSubscriptionResponseStatusEnum struct { CREATED UpdateSubscriptionResponseStatus ENABLED UpdateSubscriptionResponseStatus DISABLED UpdateSubscriptionResponseStatus FROZEN UpdateSubscriptionResponseStatus ERROR UpdateSubscriptionResponseStatus }
func GetUpdateSubscriptionResponseStatusEnum ¶
func GetUpdateSubscriptionResponseStatusEnum() UpdateSubscriptionResponseStatusEnum
type UpdateSubscriptionResponseType ¶
type UpdateSubscriptionResponseType struct {
// contains filtered or unexported fields
}
func (UpdateSubscriptionResponseType) MarshalJSON ¶
func (c UpdateSubscriptionResponseType) MarshalJSON() ([]byte, error)
func (*UpdateSubscriptionResponseType) UnmarshalJSON ¶
func (c *UpdateSubscriptionResponseType) UnmarshalJSON(b []byte) error
func (UpdateSubscriptionResponseType) Value ¶
func (c UpdateSubscriptionResponseType) Value() string
type UpdateSubscriptionResponseTypeEnum ¶
type UpdateSubscriptionResponseTypeEnum struct { EVENT UpdateSubscriptionResponseType SCHEDULED UpdateSubscriptionResponseType }
func GetUpdateSubscriptionResponseTypeEnum ¶
func GetUpdateSubscriptionResponseTypeEnum() UpdateSubscriptionResponseTypeEnum
type UpdateSubscriptionSourceRequest ¶
type UpdateSubscriptionSourceRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` // 事件订阅源ID SourceId string `json:"source_id"` Body *SubscriptionSource `json:"body,omitempty"` }
UpdateSubscriptionSourceRequest Request Object
func (UpdateSubscriptionSourceRequest) String ¶
func (o UpdateSubscriptionSourceRequest) String() string
type UpdateSubscriptionSourceResponse ¶
type UpdateSubscriptionSourceResponse struct { // 订阅源ID Id *string `json:"id,omitempty"` // 订阅的事件源名称 Name *string `json:"name,omitempty"` // 订阅的事件源的提供方类型 ProviderType *string `json:"provider_type,omitempty"` // 订阅的事件源参数列表 Detail *interface{} `json:"detail,omitempty"` // 订阅事件源的匹配过滤规则 Filter *interface{} `json:"filter,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
UpdateSubscriptionSourceResponse Response Object
func (UpdateSubscriptionSourceResponse) String ¶
func (o UpdateSubscriptionSourceResponse) String() string
type UpdateSubscriptionTargetRequest ¶
type UpdateSubscriptionTargetRequest struct { // 事件订阅ID SubscriptionId string `json:"subscription_id"` // 事件订阅目标ID TargetId string `json:"target_id"` Body *SubscriptionTarget `json:"body,omitempty"` }
UpdateSubscriptionTargetRequest Request Object
func (UpdateSubscriptionTargetRequest) String ¶
func (o UpdateSubscriptionTargetRequest) String() string
type UpdateSubscriptionTargetResponse ¶
type UpdateSubscriptionTargetResponse struct { // 订阅目标ID Id *string `json:"id,omitempty"` // 订阅的事件目标名称 Name *string `json:"name,omitempty"` // 订阅的事件目标的提供方类型 ProviderType *string `json:"provider_type,omitempty"` // 订阅的事件目标使用的目标链接ID ConnectionId *string `json:"connection_id,omitempty"` // 订阅的事件目标参数列表 Detail *interface{} `json:"detail,omitempty"` Transform *TransForm `json:"transform,omitempty"` DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"` // 创建时间 CreatedTime *string `json:"created_time,omitempty"` // 更新时间 UpdatedTime *string `json:"updated_time,omitempty"` XRequestId *string `json:"X-Request-Id,omitempty"` HttpStatusCode int `json:"-"` }
UpdateSubscriptionTargetResponse Response Object
func (UpdateSubscriptionTargetResponse) String ¶
func (o UpdateSubscriptionTargetResponse) String() string
Source Files ¶
- model_agency_create_req.go
- model_api_versions_links.go
- model_api_versions_versions.go
- model_batch_window.go
- model_catalog_target_info.go
- model_channel_create_req.go
- model_channel_info.go
- model_channel_update_req.go
- model_check_put_events_req.go
- model_check_put_events_req_sources.go
- model_check_put_events_request.go
- model_check_put_events_response.go
- model_check_put_events_result.go
- model_cloud_events.go
- model_connection_create_req.go
- model_connection_info.go
- model_connection_info_flavor.go
- model_connection_type.go
- model_connection_update_req.go
- model_create_agencies_request.go
- model_create_agencies_response.go
- model_create_channel_request.go
- model_create_channel_response.go
- model_create_connection_request.go
- model_create_connection_response.go
- model_create_endpoint_request.go
- model_create_endpoint_response.go
- model_create_event_source_request.go
- model_create_event_source_response.go
- model_create_event_streaming_request.go
- model_create_event_streaming_response.go
- model_create_subscription_request.go
- model_create_subscription_response.go
- model_create_subscription_target_request.go
- model_create_subscription_target_response.go
- model_customize_source_create_req.go
- model_customize_source_info.go
- model_customize_source_info_event_types.go
- model_customize_source_update_req.go
- model_dead_letter_queue.go
- model_delete_channel_request.go
- model_delete_channel_response.go
- model_delete_connection_request.go
- model_delete_connection_response.go
- model_delete_endpoint_request.go
- model_delete_endpoint_response.go
- model_delete_event_source_request.go
- model_delete_event_source_response.go
- model_delete_event_streaming_request.go
- model_delete_event_streaming_response.go
- model_delete_subscription_request.go
- model_delete_subscription_response.go
- model_delete_subscription_target_request.go
- model_delete_subscription_target_response.go
- model_deliver_detail.go
- model_deliver_item.go
- model_deliver_target.go
- model_detail.go
- model_endpoint_connection.go
- model_endpoint_create_req.go
- model_endpoint_info.go
- model_endpoint_update_req.go
- model_error_info.go
- model_event_pub_metrics_item.go
- model_event_streaming_create_req.go
- model_event_streaming_create_req_rule_config.go
- model_event_streaming_detail.go
- model_event_streaming_operate_req.go
- model_event_streaming_sink.go
- model_event_streaming_source.go
- model_event_streaming_update_req.go
- model_event_sub_metrics_item.go
- model_header_parameter.go
- model_invocation_http_parameters.go
- model_kafka_connection_detail.go
- model_kafka_target_detail.go
- model_kafka_target_detail_key_transform.go
- model_list_agencies_request.go
- model_list_agencies_response.go
- model_list_api_versions_request.go
- model_list_api_versions_response.go
- model_list_channels_request.go
- model_list_channels_response.go
- model_list_connections_request.go
- model_list_connections_response.go
- model_list_endpoints_request.go
- model_list_endpoints_response.go
- model_list_event_sources_request.go
- model_list_event_sources_response.go
- model_list_event_streaming_request.go
- model_list_event_streaming_response.go
- model_list_event_target_request.go
- model_list_event_target_response.go
- model_list_obs_buckets_request.go
- model_list_obs_buckets_response.go
- model_list_pub_metrics_request.go
- model_list_pub_metrics_response.go
- model_list_quotas_request.go
- model_list_quotas_response.go
- model_list_sub_metrics_request.go
- model_list_sub_metrics_response.go
- model_list_subscriptions_request.go
- model_list_subscriptions_response.go
- model_list_traced_events_request.go
- model_list_traced_events_resp_result.go
- model_list_traced_events_response.go
- model_list_triggers_request.go
- model_list_triggers_response.go
- model_list_workflow_triggers_request.go
- model_list_workflow_triggers_response.go
- model_obs_bucket_info.go
- model_obs_bucket_info_owner.go
- model_operate_subscription_request.go
- model_operate_subscription_response.go
- model_put_events_req.go
- model_put_events_request.go
- model_put_events_resp_events.go
- model_put_events_response.go
- model_put_official_events_request.go
- model_put_official_events_response.go
- model_quota_item_info.go
- model_quota_resource_resp.go
- model_resume_event_streaming_request.go
- model_resume_event_streaming_response.go
- model_run_option.go
- model_show_detail_of_channel_request.go
- model_show_detail_of_channel_response.go
- model_show_detail_of_connection_request.go
- model_show_detail_of_connection_response.go
- model_show_detail_of_event_request.go
- model_show_detail_of_event_response.go
- model_show_detail_of_event_source_request.go
- model_show_detail_of_event_source_response.go
- model_show_detail_of_event_trace_request.go
- model_show_detail_of_event_trace_response.go
- model_show_detail_of_subscription_request.go
- model_show_detail_of_subscription_response.go
- model_show_detail_of_subscription_target_request.go
- model_show_detail_of_subscription_target_response.go
- model_show_event_streaming_request.go
- model_show_event_streaming_response.go
- model_sink_fg_parameters.go
- model_smn_target_detail.go
- model_smn_target_detail_subject_transform.go
- model_source_kafka_mq_parameters.go
- model_subscription_create_req.go
- model_subscription_info.go
- model_subscription_operate_req.go
- model_subscription_operate_resp_events.go
- model_subscription_source.go
- model_subscription_source_info.go
- model_subscription_target.go
- model_subscription_target_info.go
- model_subscription_update_req.go
- model_subscription_used_info.go
- model_trans_form.go
- model_update_channel_request.go
- model_update_channel_response.go
- model_update_connection_request.go
- model_update_connection_response.go
- model_update_endpoint_request.go
- model_update_endpoint_response.go
- model_update_event_source_request.go
- model_update_event_source_response.go
- model_update_event_streaming_request.go
- model_update_event_streaming_response.go
- model_update_subscription_request.go
- model_update_subscription_response.go
- model_update_subscription_source_request.go
- model_update_subscription_source_response.go
- model_update_subscription_target_request.go
- model_update_subscription_target_response.go