model

package
v0.1.63 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 1

Documentation

Index

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 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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type DeleteSubscriptionTargetRequest

type DeleteSubscriptionTargetRequest struct {

	// 事件订阅ID
	SubscriptionId string `json:"subscription_id"`

	// 事件订阅目标ID
	TargetId string `json:"target_id"`
}

DeleteSubscriptionTargetRequest Request Object

func (DeleteSubscriptionTargetRequest) String

type DeleteSubscriptionTargetResponse

type DeleteSubscriptionTargetResponse struct {
	HttpStatusCode int `json:"-"`
}

DeleteSubscriptionTargetResponse Response Object

func (DeleteSubscriptionTargetResponse) 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 订阅的自定义事件目标参数列表

func (Detail) String added in v0.1.56

func (o Detail) String() string

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 ErrorInfo struct {

	// 错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 错误详情
	ErrorDetail *string `json:"error_detail,omitempty"`

	// 错误信息
	ErrorMsg *string `json:"error_msg,omitempty"`
}

func (ErrorInfo) String added in v0.1.52

func (o ErrorInfo) String() string

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

type RunOption added in v0.1.42

type RunOption struct {

	// 并发数
	ThreadNum *int32 `json:"thread_num,omitempty"`

	BatchWindow *BatchWindow `json:"batch_window,omitempty"`
}

func (RunOption) String added in v0.1.42

func (o RunOption) String() string

type ShowDetailOfChannelRequest

type ShowDetailOfChannelRequest struct {

	// 指定查询的事件通道ID
	ChannelId string `json:"channel_id"`
}

ShowDetailOfChannelRequest Request Object

func (ShowDetailOfChannelRequest) 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

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

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

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

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

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

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

type ShowDetailOfEventSourceResponseProviderType

type ShowDetailOfEventSourceResponseProviderType struct {
	// contains filtered or unexported fields
}

func (ShowDetailOfEventSourceResponseProviderType) MarshalJSON

func (*ShowDetailOfEventSourceResponseProviderType) UnmarshalJSON

func (ShowDetailOfEventSourceResponseProviderType) Value

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

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

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

type ShowDetailOfSubscriptionRequest

type ShowDetailOfSubscriptionRequest struct {

	// 事件订阅ID
	SubscriptionId string `json:"subscription_id"`
}

ShowDetailOfSubscriptionRequest Request Object

func (ShowDetailOfSubscriptionRequest) 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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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 订阅的事件目标转换规则

func (TransForm) String added in v0.1.28

func (o TransForm) String() string

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL