model

package
v0.1.115 Latest Latest
Warning

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

 Go to latest Published: Sep 23, 2024 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 

func (c ApiVersionsVersionsStatus) Value() string

type ApiVersionsVersionsStatusEnum added in v0.1.3 

type ApiVersionsVersionsStatusEnum struct {
	CURRENT    ApiVersionsVersionsStatus
	SUPPORTED  ApiVersionsVersionsStatus
	DEPRECATED ApiVersionsVersionsStatus
}

func GetApiVersionsVersionsStatusEnum added in v0.1.3 

func GetApiVersionsVersionsStatusEnum() ApiVersionsVersionsStatusEnum

type BatchWindow added in v0.1.42 

type BatchWindow struct {

	// 批量推送条数[1,10000]
	Count *int32 `json:"count,omitempty"`

	// 重试次数
	Time *int32 `json:"time,omitempty"`

	// 批量推送间隔[0,15]，单位秒
	Interval *int32 `json:"interval,omitempty"`
}

func (BatchWindow) String added in v0.1.42 

func (o BatchWindow) String() string

type CatalogTargetInfo 

type CatalogTargetInfo struct {

	// 事件目标分类ID
	Id *string `json:"id,omitempty"`

	// 事件目标分类名称
	Name *string `json:"name,omitempty"`

	// 事件目标分类名称展示说明
	Label *string `json:"label,omitempty"`

	// 事件目标分类描述
	Description *string `json:"description,omitempty"`

	// 提供方类型，OFFICIAL：官方云服务事件目标；CUSTOM：第三方事件目标
	ProviderType *CatalogTargetInfoProviderType `json:"provider_type,omitempty"`

	Parameters *[]interface{} `json:"parameters,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`
}

func (CatalogTargetInfo) String 

func (o CatalogTargetInfo) String() string

type CatalogTargetInfoProviderType 

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

func (CatalogTargetInfoProviderType) MarshalJSON 

func (c CatalogTargetInfoProviderType) MarshalJSON() ([]byte, error)

func (*CatalogTargetInfoProviderType) UnmarshalJSON 

func (c *CatalogTargetInfoProviderType) UnmarshalJSON(b []byte) error

func (CatalogTargetInfoProviderType) Value 

func (c CatalogTargetInfoProviderType) Value() string

type CatalogTargetInfoProviderTypeEnum 

type CatalogTargetInfoProviderTypeEnum struct {
	OFFICIAL CatalogTargetInfoProviderType
	CUSTOM   CatalogTargetInfoProviderType
}

func GetCatalogTargetInfoProviderTypeEnum 

func GetCatalogTargetInfoProviderTypeEnum() CatalogTargetInfoProviderTypeEnum

type ChannelCreateReq 

type ChannelCreateReq struct {

	// 通道名称，租户下唯一，由字母，数字，点，下划线和中划线组成，必须字母或数字开头，不能是default
	Name string `json:"name"`

	// 通道描述
	Description *string `json:"description,omitempty"`

	// 企业项目id
	EpsId *string `json:"eps_id,omitempty"`

	// 跨账号开关
	CrossAccount *bool `json:"cross_account,omitempty"`

	// 策略
	Policy map[string]ChannelCreateReqPolicy `json:"policy,omitempty"`
}

func (ChannelCreateReq) String 

func (o ChannelCreateReq) String() string

type ChannelCreateReqPolicy added in v0.1.71 

type ChannelCreateReqPolicy struct {

	// 固定值：allow_account_to_put_events
	Sid *string `json:"Sid,omitempty"`

	// 固定值：Allow
	Effect *string `json:"Effect,omitempty"`

	// domain白名单
	Principal map[string]ChannelCreateReqPrincipal `json:"Principal,omitempty"`

	// 固定值：eg:channels:putEvents
	Action *string `json:"Action,omitempty"`

	// 固定格式：urn:eg:cn-east-2:{project_id}:channel:{channel_name}
	Resource *string `json:"Resource,omitempty"`
}

func (ChannelCreateReqPolicy) String added in v0.1.71 

func (o ChannelCreateReqPolicy) String() string

type ChannelCreateReqPrincipal added in v0.1.71 

type ChannelCreateReqPrincipal struct {
	Iam *[]string `json:"IAM,omitempty"`
}

func (ChannelCreateReqPrincipal) String added in v0.1.71 

func (o ChannelCreateReqPrincipal) 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"`

	// 企业项目id
	EpsId *string `json:"eps_id,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"`

	// 企业项目id
	EpsId *string `json:"eps_id,omitempty"`

	// 跨账号开关
	CrossAccount *bool `json:"cross_account,omitempty"`

	// 策略
	Policy map[string]ChannelCreateReqPolicy `json:"policy,omitempty"`
}

func (ChannelUpdateReq) String 

func (o ChannelUpdateReq) String() string

type CheckPutEventsReq added in v0.1.28 

type CheckPutEventsReq struct {
	Sources *[]CheckPutEventsReqSources `json:"sources,omitempty"`
}

func (CheckPutEventsReq) String added in v0.1.28 

func (o CheckPutEventsReq) String() string

type CheckPutEventsReqSources added in v0.1.28 

type CheckPutEventsReqSources struct {

	// 事件通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 事件源名称
	SourceName *string `json:"source_name,omitempty"`
}

func (CheckPutEventsReqSources) String added in v0.1.28 

func (o CheckPutEventsReqSources) String() string

type CheckPutEventsRequest added in v0.1.28 

type CheckPutEventsRequest struct {
	Body *CheckPutEventsReq `json:"body,omitempty"`
}

CheckPutEventsRequest Request Object

func (CheckPutEventsRequest) String added in v0.1.28 

func (o CheckPutEventsRequest) String() string

type CheckPutEventsResponse added in v0.1.28 

type CheckPutEventsResponse struct {

	// 预校验发布事件失败的个数
	FailedCount *int32 `json:"failed_count,omitempty"`

	Sources *[]CheckPutEventsResult `json:"sources,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CheckPutEventsResponse Response Object

func (CheckPutEventsResponse) String added in v0.1.28 

func (o CheckPutEventsResponse) String() string

type CheckPutEventsResult added in v0.1.28 

type CheckPutEventsResult struct {

	// 事件通道id
	ChannelId *string `json:"channel_id,omitempty"`

	// 事件源名称
	SourceName *string `json:"source_name,omitempty"`

	// 发送事件是否成功检查结果
	CheckResult *bool `json:"check_result,omitempty"`

	// 发送事件是否成功检查明细
	CheckDetail *string `json:"check_detail,omitempty"`
}

func (CheckPutEventsResult) String added in v0.1.28 

func (o CheckPutEventsResult) String() string

type CloudEvents 

type CloudEvents struct {

	// 事件唯一标识串，同一个事件来源里必须唯一
	Id string `json:"id"`

	// 事件来源上下文标识串，source+id可以唯一确定一个事件。采用URI-Reference格式，参考https://tools.ietf.org/html/rfc3986#section-4.1
	Source string `json:"source"`

	// CloudEvents协议版本，格式为major.minor
	Specversion string `json:"specversion"`

	// 事件类型
	Type string `json:"type"`

	// 事件内容格式，采用MIME格式，遵循RFC2046，参考https://tools.ietf.org/html/rfc2046
	Datacontenttype *string `json:"datacontenttype,omitempty"`

	// 事件内容模型定义的URI，遵循RFC3986，参考https://tools.ietf.org/html/rfc3986#section-4.3
	Dataschema *string `json:"dataschema,omitempty"`

	// 事件的负载内容，采用datacontenttype字段指定的格式，内容字段遵循dataschema字段的描述
	Data *interface{} `json:"data,omitempty"`

	// 事件发生UTC日期时间，相同来源的事件格式相同，遵循RFC3339，格式需满足2018-04-05T17:31:00Z，参考https://tools.ietf.org/html/rfc3339
	Time *string `json:"time,omitempty"`

	// 事件发生的主题或对象，用以标识哪个具体对象发生了当前事件
	Subject *string `json:"subject,omitempty"`
}

CloudEvents CloudEvents事件格式定义，参考https://github.com/cloudevents/spec/blob/v1.0.1/spec.md

func (CloudEvents) String 

func (o CloudEvents) String() string

type ConnectionCreateReq added in v0.1.3 

type ConnectionCreateReq struct {

	// 目标连接名称，租户下唯一，由字母、数字、点、下划线和中划线组成，必须以字母或数字开头，不能为default
	Name string `json:"name"`

	// 目标连接描述
	Description *string `json:"description,omitempty"`

	// 待连接的VPC ID
	VpcId string `json:"vpc_id"`

	// 待连接的子网ID
	SubnetId string `json:"subnet_id"`

	Type *ConnectionType `json:"type,omitempty"`

	KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"`
}

func (ConnectionCreateReq) String added in v0.1.3 

func (o ConnectionCreateReq) String() string

type ConnectionInfo added in v0.1.3 

type ConnectionInfo struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 目标连接名称，租户下唯一，由小写字母、数字、点、下划线和中划线组成，必须以字母或数字开头，不能为default
	Name *string `json:"name,omitempty"`

	// 目标连接描述
	Description *string `json:"description,omitempty"`

	// 目标连接状态
	Status *ConnectionInfoStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	// 待连接的VPC ID
	VpcId *string `json:"vpc_id,omitempty"`

	// 待连接的子网ID
	SubnetId *string `json:"subnet_id,omitempty"`

	// 私网目标连接使用的用户委托名称
	Agency *string `json:"agency,omitempty"`

	Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"`

	Type *ConnectionType `json:"type,omitempty"`

	KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`
}

func (ConnectionInfo) String added in v0.1.3 

func (o ConnectionInfo) String() string

type ConnectionInfoFlavor added in v0.1.3 

type ConnectionInfoFlavor struct {

	// 规格名称
	Name *string `json:"name,omitempty"`

	// 并发规格类型
	ConcurrencyType *ConnectionInfoFlavorConcurrencyType `json:"concurrency_type,omitempty"`

	// 并发数
	Concurrency *int32 `json:"concurrency,omitempty"`

	// 带宽类型
	BandwidthType *ConnectionInfoFlavorBandwidthType `json:"bandwidth_type,omitempty"`
}

ConnectionInfoFlavor 规格

func (ConnectionInfoFlavor) String added in v0.1.3 

func (o ConnectionInfoFlavor) String() string

type ConnectionInfoFlavorBandwidthType added in v0.1.3 

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

func (ConnectionInfoFlavorBandwidthType) MarshalJSON added in v0.1.3 

func (c ConnectionInfoFlavorBandwidthType) MarshalJSON() ([]byte, error)

func (*ConnectionInfoFlavorBandwidthType) UnmarshalJSON added in v0.1.3 

func (c *ConnectionInfoFlavorBandwidthType) UnmarshalJSON(b []byte) error

func (ConnectionInfoFlavorBandwidthType) Value added in v0.1.3 

func (c ConnectionInfoFlavorBandwidthType) Value() string

type ConnectionInfoFlavorBandwidthTypeEnum added in v0.1.3 

type ConnectionInfoFlavorBandwidthTypeEnum struct {
	SHARED    ConnectionInfoFlavorBandwidthType
	EXCLUSIVE ConnectionInfoFlavorBandwidthType
}

func GetConnectionInfoFlavorBandwidthTypeEnum added in v0.1.3 

func GetConnectionInfoFlavorBandwidthTypeEnum() ConnectionInfoFlavorBandwidthTypeEnum

type ConnectionInfoFlavorConcurrencyType added in v0.1.3 

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

func (ConnectionInfoFlavorConcurrencyType) MarshalJSON added in v0.1.3 

func (c ConnectionInfoFlavorConcurrencyType) MarshalJSON() ([]byte, error)

func (*ConnectionInfoFlavorConcurrencyType) UnmarshalJSON added in v0.1.3 

func (c *ConnectionInfoFlavorConcurrencyType) UnmarshalJSON(b []byte) error

func (ConnectionInfoFlavorConcurrencyType) Value added in v0.1.3 

func (c ConnectionInfoFlavorConcurrencyType) Value() string

type ConnectionInfoFlavorConcurrencyTypeEnum added in v0.1.3 

type ConnectionInfoFlavorConcurrencyTypeEnum struct {
	SHARED    ConnectionInfoFlavorConcurrencyType
	EXCLUSIVE ConnectionInfoFlavorConcurrencyType
}

func GetConnectionInfoFlavorConcurrencyTypeEnum added in v0.1.3 

func GetConnectionInfoFlavorConcurrencyTypeEnum() ConnectionInfoFlavorConcurrencyTypeEnum

type ConnectionInfoStatus added in v0.1.3 

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

func (ConnectionInfoStatus) MarshalJSON added in v0.1.3 

func (c ConnectionInfoStatus) MarshalJSON() ([]byte, error)

func (*ConnectionInfoStatus) UnmarshalJSON added in v0.1.3 

func (c *ConnectionInfoStatus) UnmarshalJSON(b []byte) error

func (ConnectionInfoStatus) Value added in v0.1.3 

func (c ConnectionInfoStatus) Value() string

type ConnectionInfoStatusEnum added in v0.1.3 

type ConnectionInfoStatusEnum struct {
	CREATING      ConnectionInfoStatus
	CREATED       ConnectionInfoStatus
	CREATE_FAILED ConnectionInfoStatus
}

func GetConnectionInfoStatusEnum added in v0.1.3 

func GetConnectionInfoStatusEnum() ConnectionInfoStatusEnum

type ConnectionType added in v0.1.42 

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

ConnectionType 目标连接类型。目前支持webhook：http连接；kafka：华为云官方kafka实例

func (ConnectionType) MarshalJSON added in v0.1.42 

func (c ConnectionType) MarshalJSON() ([]byte, error)

func (*ConnectionType) UnmarshalJSON added in v0.1.42 

func (c *ConnectionType) UnmarshalJSON(b []byte) error

func (ConnectionType) Value added in v0.1.42 

func (c ConnectionType) Value() string

type ConnectionTypeEnum added in v0.1.42 

type ConnectionTypeEnum struct {
	WEBHOOK ConnectionType
	KAFKA   ConnectionType
}

func GetConnectionTypeEnum added in v0.1.42 

func GetConnectionTypeEnum() ConnectionTypeEnum

type ConnectionUpdateReq added in v0.1.3 

type ConnectionUpdateReq struct {

	// 目标连接描述
	Description *string `json:"description,omitempty"`
}

func (ConnectionUpdateReq) String added in v0.1.3 

func (o ConnectionUpdateReq) String() string

type CreateAgenciesRequest added in v0.1.3 

type CreateAgenciesRequest struct {
	Body *AgencyCreateReq `json:"body,omitempty"`
}

CreateAgenciesRequest Request Object

func (CreateAgenciesRequest) String added in v0.1.3 

func (o CreateAgenciesRequest) String() string

type CreateAgenciesResponse added in v0.1.3 

type CreateAgenciesResponse struct {

	// 服务委托授权记录。
	Agencies       *[]string `json:"agencies,omitempty"`
	HttpStatusCode int       `json:"-"`
}

CreateAgenciesResponse Response Object

func (CreateAgenciesResponse) String added in v0.1.3 

func (o CreateAgenciesResponse) String() string

type CreateChannelRequest 

type CreateChannelRequest struct {

	// 创建通道时所使用的企业项目id
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

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

	// 企业项目id
	EpsId *string `json:"eps_id,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateChannelResponse Response Object

func (CreateChannelResponse) String 

func (o CreateChannelResponse) String() string

type CreateChannelResponseProviderType 

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

func (CreateChannelResponseProviderType) MarshalJSON 

func (c CreateChannelResponseProviderType) MarshalJSON() ([]byte, error)

func (*CreateChannelResponseProviderType) UnmarshalJSON 

func (c *CreateChannelResponseProviderType) UnmarshalJSON(b []byte) error

func (CreateChannelResponseProviderType) Value 

func (c CreateChannelResponseProviderType) Value() string

type CreateChannelResponseProviderTypeEnum 

type CreateChannelResponseProviderTypeEnum struct {
	OFFICIAL CreateChannelResponseProviderType
	CUSTOM   CreateChannelResponseProviderType
	PARTNER  CreateChannelResponseProviderType
}

func GetCreateChannelResponseProviderTypeEnum 

func GetCreateChannelResponseProviderTypeEnum() CreateChannelResponseProviderTypeEnum

type CreateConnectionRequest added in v0.1.3 

type CreateConnectionRequest struct {
	Body *ConnectionCreateReq `json:"body,omitempty"`
}

CreateConnectionRequest Request Object

func (CreateConnectionRequest) String added in v0.1.3 

func (o CreateConnectionRequest) String() string

type CreateConnectionResponse added in v0.1.3 

type CreateConnectionResponse struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 目标连接名称，租户下唯一，由小写字母、数字、点、下划线和中划线组成，必须以字母或数字开头，不能为default
	Name *string `json:"name,omitempty"`

	// 目标连接描述
	Description *string `json:"description,omitempty"`

	// 目标连接状态
	Status *CreateConnectionResponseStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	// 待连接的VPC ID
	VpcId *string `json:"vpc_id,omitempty"`

	// 待连接的子网ID
	SubnetId *string `json:"subnet_id,omitempty"`

	// 私网目标连接使用的用户委托名称
	Agency *string `json:"agency,omitempty"`

	Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"`

	Type *ConnectionType `json:"type,omitempty"`

	KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateConnectionResponse Response Object

func (CreateConnectionResponse) String added in v0.1.3 

func (o CreateConnectionResponse) String() string

type CreateConnectionResponseStatus added in v0.1.3 

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

func (CreateConnectionResponseStatus) MarshalJSON added in v0.1.3 

func (c CreateConnectionResponseStatus) MarshalJSON() ([]byte, error)

func (*CreateConnectionResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *CreateConnectionResponseStatus) UnmarshalJSON(b []byte) error

func (CreateConnectionResponseStatus) Value added in v0.1.3 

func (c CreateConnectionResponseStatus) Value() string

type CreateConnectionResponseStatusEnum added in v0.1.3 

type CreateConnectionResponseStatusEnum struct {
	CREATING      CreateConnectionResponseStatus
	CREATED       CreateConnectionResponseStatus
	CREATE_FAILED CreateConnectionResponseStatus
}

func GetCreateConnectionResponseStatusEnum added in v0.1.3 

func GetCreateConnectionResponseStatusEnum() CreateConnectionResponseStatusEnum

type CreateEndpointRequest added in v0.1.3 

type CreateEndpointRequest struct {
	Body *EndpointCreateReq `json:"body,omitempty"`
}

CreateEndpointRequest Request Object

func (CreateEndpointRequest) String added in v0.1.3 

func (o CreateEndpointRequest) String() string

type CreateEndpointResponse added in v0.1.3 

type CreateEndpointResponse struct {

	// 访问端点ID
	Id *string `json:"id,omitempty"`

	// 用户指定的访问端点名称
	Name *string `json:"name,omitempty"`

	// 访问端点所在的VPC的ID
	VpcId *string `json:"vpc_id,omitempty"`

	// 访问端点所在的子网的ID
	SubnetId *string `json:"subnet_id,omitempty"`

	// 访问域名
	Domain *string `json:"domain,omitempty"`

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

	// 访问端点状态
	Status *CreateEndpointResponseStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	// 访问端点类型
	Type *CreateEndpointResponseType `json:"type,omitempty"`

	// 是否可更新
	Scalable *bool `json:"scalable,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	// 访问端点终端节点列表
	Endpoints *[]EndpointConnection `json:"endpoints,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateEndpointResponse Response Object

func (CreateEndpointResponse) String added in v0.1.3 

func (o CreateEndpointResponse) String() string

type CreateEndpointResponseStatus added in v0.1.3 

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

func (CreateEndpointResponseStatus) MarshalJSON added in v0.1.3 

func (c CreateEndpointResponseStatus) MarshalJSON() ([]byte, error)

func (*CreateEndpointResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *CreateEndpointResponseStatus) UnmarshalJSON(b []byte) error

func (CreateEndpointResponseStatus) Value added in v0.1.3 

func (c CreateEndpointResponseStatus) Value() string

type CreateEndpointResponseStatusEnum added in v0.1.3 

type CreateEndpointResponseStatusEnum struct {
	CREATED       CreateEndpointResponseStatus
	CREATING      CreateEndpointResponseStatus
	CREATE_FAILED CreateEndpointResponseStatus
	DELETE_FAILED CreateEndpointResponseStatus
}

func GetCreateEndpointResponseStatusEnum added in v0.1.3 

func GetCreateEndpointResponseStatusEnum() CreateEndpointResponseStatusEnum

type CreateEndpointResponseType added in v0.1.3 

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

func (CreateEndpointResponseType) MarshalJSON added in v0.1.3 

func (c CreateEndpointResponseType) MarshalJSON() ([]byte, error)

func (*CreateEndpointResponseType) UnmarshalJSON added in v0.1.3 

func (c *CreateEndpointResponseType) UnmarshalJSON(b []byte) error

func (CreateEndpointResponseType) Value added in v0.1.3 

func (c CreateEndpointResponseType) Value() string

type CreateEndpointResponseTypeEnum added in v0.1.3 

type CreateEndpointResponseTypeEnum struct {
	PRIVATE CreateEndpointResponseType
	PUBLIC  CreateEndpointResponseType
}

func GetCreateEndpointResponseTypeEnum added in v0.1.3 

func GetCreateEndpointResponseTypeEnum() CreateEndpointResponseTypeEnum

type CreateEventSourceRequest 

type CreateEventSourceRequest struct {
	Body *CustomizeSourceCreateReq `json:"body,omitempty"`
}

CreateEventSourceRequest Request Object

func (CreateEventSourceRequest) String 

func (o CreateEventSourceRequest) String() string

type CreateEventSourceResponse 

type CreateEventSourceResponse struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 事件源名称
	Name *string `json:"name,omitempty"`

	// 事件源名称展示
	Label *string `json:"label,omitempty"`

	// 事件源描述
	Description *string `json:"description,omitempty"`

	// 事件源提供方类型，OFFICIAL：官方云服务事件源；CUSTOM：用户创建的自定义事件源；PARTNER：伙伴事件源
	ProviderType *CreateEventSourceResponseProviderType `json:"provider_type,omitempty"`

	// 事件源提供的事件类型列表，只有官方云服务事件源提供事件类型
	EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	// 事件源归属的事件通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 事件源归属的事件通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 事件源类型
	Type *string `json:"type,omitempty"`

	// json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等
	Detail *interface{} `json:"detail,omitempty"`

	// 自定义事件源状态
	Status *CreateEventSourceResponseStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateEventSourceResponse Response Object

func (CreateEventSourceResponse) String 

func (o CreateEventSourceResponse) String() string

type CreateEventSourceResponseProviderType 

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

func (CreateEventSourceResponseProviderType) MarshalJSON 

func (c CreateEventSourceResponseProviderType) MarshalJSON() ([]byte, error)

func (*CreateEventSourceResponseProviderType) UnmarshalJSON 

func (c *CreateEventSourceResponseProviderType) UnmarshalJSON(b []byte) error

func (CreateEventSourceResponseProviderType) Value 

func (c CreateEventSourceResponseProviderType) Value() string

type CreateEventSourceResponseProviderTypeEnum 

type CreateEventSourceResponseProviderTypeEnum struct {
	OFFICIAL CreateEventSourceResponseProviderType
	CUSTOM   CreateEventSourceResponseProviderType
	PARTNER  CreateEventSourceResponseProviderType
}

func GetCreateEventSourceResponseProviderTypeEnum 

func GetCreateEventSourceResponseProviderTypeEnum() CreateEventSourceResponseProviderTypeEnum

type CreateEventSourceResponseStatus added in v0.1.3 

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

func (CreateEventSourceResponseStatus) MarshalJSON added in v0.1.3 

func (c CreateEventSourceResponseStatus) MarshalJSON() ([]byte, error)

func (*CreateEventSourceResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *CreateEventSourceResponseStatus) UnmarshalJSON(b []byte) error

func (CreateEventSourceResponseStatus) Value added in v0.1.3 

func (c CreateEventSourceResponseStatus) Value() string

type CreateEventSourceResponseStatusEnum added in v0.1.3 

type CreateEventSourceResponseStatusEnum struct {
	CREATE_FAILED CreateEventSourceResponseStatus
	RUNNING       CreateEventSourceResponseStatus
	ERROR         CreateEventSourceResponseStatus
}

func GetCreateEventSourceResponseStatusEnum added in v0.1.3 

func GetCreateEventSourceResponseStatusEnum() CreateEventSourceResponseStatusEnum

type CreateEventStreamingRequest added in v0.1.42 

type CreateEventStreamingRequest struct {
	Body *EventStreamingCreateReq `json:"body,omitempty"`
}

CreateEventStreamingRequest Request Object

func (CreateEventStreamingRequest) String added in v0.1.42 

func (o CreateEventStreamingRequest) String() string

type CreateEventStreamingResponse added in v0.1.42 

type CreateEventStreamingResponse struct {

	// 事件流ID
	EventStreamingID *string `json:"eventStreamingID,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateEventStreamingResponse Response Object

func (CreateEventStreamingResponse) String added in v0.1.42 

func (o CreateEventStreamingResponse) String() string

type CreateSubscriptionRequest 

type CreateSubscriptionRequest struct {
	Body *SubscriptionCreateReq `json:"body,omitempty"`
}

CreateSubscriptionRequest Request Object

func (CreateSubscriptionRequest) String 

func (o CreateSubscriptionRequest) String() string

type CreateSubscriptionResponse 

type CreateSubscriptionResponse struct {

	// 订阅ID
	Id *string `json:"id,omitempty"`

	// 订阅名称
	Name *string `json:"name,omitempty"`

	// 订阅描述
	Description *string `json:"description,omitempty"`

	// 类型
	Type *CreateSubscriptionResponseType `json:"type,omitempty"`

	// 状态
	Status *CreateSubscriptionResponseStatus `json:"status,omitempty"`

	// 通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 标签信息
	Used *[]SubscriptionUsedInfo `json:"used,omitempty"`

	// 订阅源列表
	Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"`

	// 订阅目标列表
	Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateSubscriptionResponse Response Object

func (CreateSubscriptionResponse) String 

func (o CreateSubscriptionResponse) String() string

type CreateSubscriptionResponseStatus 

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

func (CreateSubscriptionResponseStatus) MarshalJSON 

func (c CreateSubscriptionResponseStatus) MarshalJSON() ([]byte, error)

func (*CreateSubscriptionResponseStatus) UnmarshalJSON 

func (c *CreateSubscriptionResponseStatus) UnmarshalJSON(b []byte) error

func (CreateSubscriptionResponseStatus) Value 

func (c CreateSubscriptionResponseStatus) Value() string

type CreateSubscriptionResponseStatusEnum 

type CreateSubscriptionResponseStatusEnum struct {
	CREATED  CreateSubscriptionResponseStatus
	ENABLED  CreateSubscriptionResponseStatus
	DISABLED CreateSubscriptionResponseStatus
	FROZEN   CreateSubscriptionResponseStatus
	ERROR    CreateSubscriptionResponseStatus
}

func GetCreateSubscriptionResponseStatusEnum 

func GetCreateSubscriptionResponseStatusEnum() CreateSubscriptionResponseStatusEnum

type CreateSubscriptionResponseType 

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

func (CreateSubscriptionResponseType) MarshalJSON 

func (c CreateSubscriptionResponseType) MarshalJSON() ([]byte, error)

func (*CreateSubscriptionResponseType) UnmarshalJSON 

func (c *CreateSubscriptionResponseType) UnmarshalJSON(b []byte) error

func (CreateSubscriptionResponseType) Value 

func (c CreateSubscriptionResponseType) Value() string

type CreateSubscriptionResponseTypeEnum 

type CreateSubscriptionResponseTypeEnum struct {
	EVENT     CreateSubscriptionResponseType
	SCHEDULED CreateSubscriptionResponseType
}

func GetCreateSubscriptionResponseTypeEnum 

func GetCreateSubscriptionResponseTypeEnum() CreateSubscriptionResponseTypeEnum

type CreateSubscriptionTargetRequest 

type CreateSubscriptionTargetRequest struct {

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

	Body *SubscriptionTarget `json:"body,omitempty"`
}

CreateSubscriptionTargetRequest Request Object

func (CreateSubscriptionTargetRequest) String 

func (o CreateSubscriptionTargetRequest) String() string

type CreateSubscriptionTargetResponse 

type CreateSubscriptionTargetResponse struct {

	// 订阅目标ID
	Id *string `json:"id,omitempty"`

	// 订阅的事件目标名称
	Name *string `json:"name,omitempty"`

	// 订阅的事件目标的提供方类型
	ProviderType *string `json:"provider_type,omitempty"`

	// 订阅的事件目标使用的目标链接ID
	ConnectionId *string `json:"connection_id,omitempty"`

	// 订阅的事件目标参数列表
	Detail *interface{} `json:"detail,omitempty"`

	Transform *TransForm `json:"transform,omitempty"`

	DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateSubscriptionTargetResponse Response Object

func (CreateSubscriptionTargetResponse) String 

func (o CreateSubscriptionTargetResponse) String() string

type CustomizeSourceCreateReq 

type CustomizeSourceCreateReq struct {

	// 自定义事件源名称，租户下唯一，由小写字母、数字、点、下划线和中划线组成，必须以字母或数字开头，且不能以hc.开头
	Name string `json:"name"`

	// 事件源描述
	Description *string `json:"description,omitempty"`

	// 指导事件源归属的事件通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 事件源类型
	Type *CustomizeSourceCreateReqType `json:"type,omitempty"`

	// json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等
	Detail *interface{} `json:"detail,omitempty"`
}

func (CustomizeSourceCreateReq) String 

func (o CustomizeSourceCreateReq) String() string

type CustomizeSourceCreateReqType added in v0.1.3 

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

func (CustomizeSourceCreateReqType) MarshalJSON added in v0.1.3 

func (c CustomizeSourceCreateReqType) MarshalJSON() ([]byte, error)

func (*CustomizeSourceCreateReqType) UnmarshalJSON added in v0.1.3 

func (c *CustomizeSourceCreateReqType) UnmarshalJSON(b []byte) error

func (CustomizeSourceCreateReqType) Value added in v0.1.3 

func (c CustomizeSourceCreateReqType) Value() string

type CustomizeSourceCreateReqTypeEnum added in v0.1.3 

type CustomizeSourceCreateReqTypeEnum struct {
	APPLICATION CustomizeSourceCreateReqType
	RABBITMQ    CustomizeSourceCreateReqType
	ROCKETMQ    CustomizeSourceCreateReqType
}

func GetCustomizeSourceCreateReqTypeEnum added in v0.1.3 

func GetCustomizeSourceCreateReqTypeEnum() CustomizeSourceCreateReqTypeEnum

type CustomizeSourceInfo added in v0.1.3 

type CustomizeSourceInfo struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 事件源名称
	Name *string `json:"name,omitempty"`

	// 事件源名称展示
	Label *string `json:"label,omitempty"`

	// 事件源描述
	Description *string `json:"description,omitempty"`

	// 事件源提供方类型，OFFICIAL：官方云服务事件源；CUSTOM：用户创建的自定义事件源；PARTNER：伙伴事件源
	ProviderType *CustomizeSourceInfoProviderType `json:"provider_type,omitempty"`

	// 事件源提供的事件类型列表，只有官方云服务事件源提供事件类型
	EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	// 事件源归属的事件通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 事件源归属的事件通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 事件源类型
	Type *string `json:"type,omitempty"`

	// json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等
	Detail *interface{} `json:"detail,omitempty"`

	// 自定义事件源状态
	Status *CustomizeSourceInfoStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`
}

func (CustomizeSourceInfo) String added in v0.1.3 

func (o CustomizeSourceInfo) String() string

type CustomizeSourceInfoEventTypes added in v0.1.3 

type CustomizeSourceInfoEventTypes struct {

	// 事件类型名称
	Name *string `json:"name,omitempty"`

	// 事件类型描述
	Description *string `json:"description,omitempty"`
}

func (CustomizeSourceInfoEventTypes) String added in v0.1.3 

func (o CustomizeSourceInfoEventTypes) String() string

type CustomizeSourceInfoProviderType added in v0.1.3 

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

func (CustomizeSourceInfoProviderType) MarshalJSON added in v0.1.3 

func (c CustomizeSourceInfoProviderType) MarshalJSON() ([]byte, error)

func (*CustomizeSourceInfoProviderType) UnmarshalJSON added in v0.1.3 

func (c *CustomizeSourceInfoProviderType) UnmarshalJSON(b []byte) error

func (CustomizeSourceInfoProviderType) Value added in v0.1.3 

func (c CustomizeSourceInfoProviderType) Value() string

type CustomizeSourceInfoProviderTypeEnum added in v0.1.3 

type CustomizeSourceInfoProviderTypeEnum struct {
	OFFICIAL CustomizeSourceInfoProviderType
	CUSTOM   CustomizeSourceInfoProviderType
	PARTNER  CustomizeSourceInfoProviderType
}

func GetCustomizeSourceInfoProviderTypeEnum added in v0.1.3 

func GetCustomizeSourceInfoProviderTypeEnum() CustomizeSourceInfoProviderTypeEnum

type CustomizeSourceInfoStatus added in v0.1.3 

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

func (CustomizeSourceInfoStatus) MarshalJSON added in v0.1.3 

func (c CustomizeSourceInfoStatus) MarshalJSON() ([]byte, error)

func (*CustomizeSourceInfoStatus) UnmarshalJSON added in v0.1.3 

func (c *CustomizeSourceInfoStatus) UnmarshalJSON(b []byte) error

func (CustomizeSourceInfoStatus) Value added in v0.1.3 

func (c CustomizeSourceInfoStatus) Value() string

type CustomizeSourceInfoStatusEnum added in v0.1.3 

type CustomizeSourceInfoStatusEnum struct {
	CREATE_FAILED CustomizeSourceInfoStatus
	RUNNING       CustomizeSourceInfoStatus
	ERROR         CustomizeSourceInfoStatus
}

func GetCustomizeSourceInfoStatusEnum added in v0.1.3 

func GetCustomizeSourceInfoStatusEnum() CustomizeSourceInfoStatusEnum

type CustomizeSourceUpdateReq 

type CustomizeSourceUpdateReq struct {

	// 事件源描述
	Description *string `json:"description,omitempty"`

	// json格式封装消息实例更新信息：如RabbitMQ实例的虚拟主机vhost字段、队列queue字段、用户密码
	Detail *interface{} `json:"detail,omitempty"`
}

func (CustomizeSourceUpdateReq) String 

func (o CustomizeSourceUpdateReq) String() string

type DeadLetterQueue added in v0.1.52 

type DeadLetterQueue struct {

	// 队列类型
	Type DeadLetterQueueType `json:"type"`

	// 实例id
	InstanceId string `json:"instance_id"`

	// 目标连接id
	ConnectionId string `json:"connection_id"`

	// 主题
	Topic string `json:"topic"`
}

DeadLetterQueue 订阅的死信参数列表

func (DeadLetterQueue) String added in v0.1.52 

func (o DeadLetterQueue) String() string

type DeadLetterQueueType added in v0.1.52 

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

func (DeadLetterQueueType) MarshalJSON added in v0.1.52 

func (c DeadLetterQueueType) MarshalJSON() ([]byte, error)

func (*DeadLetterQueueType) UnmarshalJSON added in v0.1.52 

func (c *DeadLetterQueueType) UnmarshalJSON(b []byte) error

func (DeadLetterQueueType) Value added in v0.1.52 

func (c DeadLetterQueueType) Value() string

type DeadLetterQueueTypeEnum added in v0.1.52 

type DeadLetterQueueTypeEnum struct {
	KAFKA DeadLetterQueueType
}

func GetDeadLetterQueueTypeEnum added in v0.1.52 

func GetDeadLetterQueueTypeEnum() DeadLetterQueueTypeEnum

type DeleteChannelRequest 

type DeleteChannelRequest struct {

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

	// 企业项目id
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`
}

DeleteChannelRequest Request Object

func (DeleteChannelRequest) String 

func (o DeleteChannelRequest) String() string

type DeleteChannelResponse 

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

DeleteChannelResponse Response Object

func (DeleteChannelResponse) String 

func (o DeleteChannelResponse) String() string

type DeleteConnectionRequest added in v0.1.3 

type DeleteConnectionRequest struct {

	// 指定查询的目标连接ID
	ConnectionId string `json:"connection_id"`
}

DeleteConnectionRequest Request Object

func (DeleteConnectionRequest) String added in v0.1.3 

func (o DeleteConnectionRequest) String() string

type DeleteConnectionResponse added in v0.1.3 

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

DeleteConnectionResponse Response Object

func (DeleteConnectionResponse) String added in v0.1.3 

func (o DeleteConnectionResponse) String() string

type DeleteEndpointRequest added in v0.1.3 

type DeleteEndpointRequest struct {

	// 指定查询访问端点的id
	EndpointId string `json:"endpoint_id"`
}

DeleteEndpointRequest Request Object

func (DeleteEndpointRequest) String added in v0.1.3 

func (o DeleteEndpointRequest) String() string

type DeleteEndpointResponse added in v0.1.3 

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

DeleteEndpointResponse Response Object

func (DeleteEndpointResponse) String added in v0.1.3 

func (o DeleteEndpointResponse) String() string

type DeleteEventSourceRequest 

type DeleteEventSourceRequest struct {

	// 指定查询的事件源ID
	SourceId string `json:"source_id"`
}

DeleteEventSourceRequest Request Object

func (DeleteEventSourceRequest) String 

func (o DeleteEventSourceRequest) String() string

type DeleteEventSourceResponse 

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

DeleteEventSourceResponse Response Object

func (DeleteEventSourceResponse) String 

func (o DeleteEventSourceResponse) String() string

type DeleteEventStreamingRequest added in v0.1.42 

type DeleteEventStreamingRequest struct {

	// 事件流ID
	EventstreamingId string `json:"eventstreaming_id"`
}

DeleteEventStreamingRequest Request Object

func (DeleteEventStreamingRequest) String added in v0.1.42 

func (o DeleteEventStreamingRequest) String() string

type DeleteEventStreamingResponse added in v0.1.42 

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

DeleteEventStreamingResponse Response Object

func (DeleteEventStreamingResponse) String added in v0.1.42 

func (o DeleteEventStreamingResponse) String() string

type DeleteSubscriptionRequest 

type DeleteSubscriptionRequest struct {

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

DeleteSubscriptionRequest Request Object

func (DeleteSubscriptionRequest) String 

func (o DeleteSubscriptionRequest) String() string

type DeleteSubscriptionResponse 

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

DeleteSubscriptionResponse Response Object

func (DeleteSubscriptionResponse) String 

func (o DeleteSubscriptionResponse) String() string

type DeleteSubscriptionTargetRequest 

type DeleteSubscriptionTargetRequest struct {

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

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

DeleteSubscriptionTargetRequest Request Object

func (DeleteSubscriptionTargetRequest) String 

func (o DeleteSubscriptionTargetRequest) String() string

type DeleteSubscriptionTargetResponse 

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

DeleteSubscriptionTargetResponse Response Object

func (DeleteSubscriptionTargetResponse) String 

func (o DeleteSubscriptionTargetResponse) String() string

type DeliverDetail added in v0.1.42 

type DeliverDetail struct {

	// 投递时间   格式 yyyy/mm/dd xx:yy:zz
	DeliverTime *string `json:"deliverTime,omitempty"`

	// 投递状态     SUCCESS Or  FAILED
	DeliverStatus *string `json:"deliverStatus,omitempty"`

	// 投递耗时，单位ms
	DeliverConsuming *string `json:"deliverConsuming,omitempty"`

	// 投递响应码
	DeliverRspCode *string `json:"deliverRspCode,omitempty"`
}

DeliverDetail 投递详情

func (DeliverDetail) String added in v0.1.42 

func (o DeliverDetail) String() string

type DeliverItem added in v0.1.42 

type DeliverItem struct {

	// 订阅ID，全局唯一
	SubscriptionId *string `json:"subscriptionId,omitempty"`

	// 订阅名称
	SubscriptionName *string `json:"subscriptionName,omitempty"`

	// 成功目标个数
	SuccessCounts *int32 `json:"successCounts,omitempty"`

	// 失败目标个数
	FailCounts *int32 `json:"failCounts,omitempty"`

	// 共投递次数
	AllDeliverTimes *int32 `json:"allDeliverTimes,omitempty"`

	// 投递详情
	DeliverTargetList *[]DeliverTarget `json:"deliverTargetList,omitempty"`
}

func (DeliverItem) String added in v0.1.42 

func (o DeliverItem) String() string

type DeliverTarget added in v0.1.42 

type DeliverTarget struct {

	// 投递目标ID，即事件目标ID
	DeliverTargetId *string `json:"deliverTargetId,omitempty"`

	// 投递目标名称，及事件目标名称
	DeliverTargetName *string `json:"deliverTargetName,omitempty"`

	// 投递状态         SUCCESS Or  FAILED
	DeliverStatus *string `json:"deliverStatus,omitempty"`

	// 考虑展示的个数    例如限制只展示最新三条
	DeliverDetailList *[]DeliverDetail `json:"deliverDetailList,omitempty"`
}

func (DeliverTarget) String added in v0.1.42 

func (o DeliverTarget) String() string

type EgTargetDetail added in v0.1.71 

type EgTargetDetail struct {

	// 目标项目id
	TargetProjectId string `json:"target_project_id"`

	// 目标通道id
	TargetChannelId string `json:"target_channel_id"`

	// 目标region
	TargetRegion string `json:"target_region"`

	// 跨region开关
	CrossRegion *bool `json:"cross_region,omitempty"`

	// 跨账号开关
	CrossAccount *bool `json:"cross_account,omitempty"`

	// 委托名称
	AgencyName string `json:"agency_name"`
}

func (EgTargetDetail) String added in v0.1.71 

func (o EgTargetDetail) 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 *interface{} `json:"filter,omitempty"`
}

EventStreamingCreateReqRuleConfig 事件规则，包括过滤规则和转换规则

func (EventStreamingCreateReqRuleConfig) String added in v0.1.42 

func (o EventStreamingCreateReqRuleConfig) String() string

type EventStreamingDetail added in v0.1.42 

type EventStreamingDetail struct {

	// 事件流名称，租户下唯一，由字母、数字、点、下划线和中划线组成，必须字母或数字开头
	Name string `json:"name"`

	// 事件流描述
	Description *string `json:"description,omitempty"`

	Source *EventStreamingSource `json:"source"`

	Sink *EventStreamingSink `json:"sink"`

	RuleConfig *EventStreamingCreateReqRuleConfig `json:"rule_config,omitempty"`

	Option *RunOption `json:"option,omitempty"`

	// 事件流状态
	Status *EventStreamingDetailStatus `json:"status,omitempty"`

	// 事件流ID
	Id *string `json:"id,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`
}

func (EventStreamingDetail) String added in v0.1.42 

func (o EventStreamingDetail) String() string

type EventStreamingDetailStatus added in v0.1.42 

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

func (EventStreamingDetailStatus) MarshalJSON added in v0.1.42 

func (c EventStreamingDetailStatus) MarshalJSON() ([]byte, error)

func (*EventStreamingDetailStatus) UnmarshalJSON added in v0.1.42 

func (c *EventStreamingDetailStatus) UnmarshalJSON(b []byte) error

func (EventStreamingDetailStatus) Value added in v0.1.42 

func (c EventStreamingDetailStatus) Value() string

type EventStreamingDetailStatusEnum added in v0.1.42 

type EventStreamingDetailStatusEnum struct {
	CREATED EventStreamingDetailStatus
	RUNNING EventStreamingDetailStatus
	ERROR   EventStreamingDetailStatus
	STOPPED EventStreamingDetailStatus
}

func GetEventStreamingDetailStatusEnum added in v0.1.42 

func GetEventStreamingDetailStatusEnum() EventStreamingDetailStatusEnum

type EventStreamingOperateReq added in v0.1.42 

type EventStreamingOperateReq struct {

	// 操作类型
	Operation *EventStreamingOperateReqOperation `json:"operation,omitempty"`
}

func (EventStreamingOperateReq) String added in v0.1.42 

func (o EventStreamingOperateReq) String() string

type EventStreamingOperateReqOperation added in v0.1.42 

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

func (EventStreamingOperateReqOperation) MarshalJSON added in v0.1.42 

func (c EventStreamingOperateReqOperation) MarshalJSON() ([]byte, error)

func (*EventStreamingOperateReqOperation) UnmarshalJSON added in v0.1.42 

func (c *EventStreamingOperateReqOperation) UnmarshalJSON(b []byte) error

func (EventStreamingOperateReqOperation) Value added in v0.1.42 

func (c EventStreamingOperateReqOperation) Value() string

type EventStreamingOperateReqOperationEnum added in v0.1.42 

type EventStreamingOperateReqOperationEnum struct {
	START EventStreamingOperateReqOperation
	PAUSE EventStreamingOperateReqOperation
}

func GetEventStreamingOperateReqOperationEnum added in v0.1.42 

func GetEventStreamingOperateReqOperationEnum() EventStreamingOperateReqOperationEnum

type EventStreamingSink added in v0.1.42 

type EventStreamingSink struct {
	SinkFg *SinkFgParameters `json:"sink_fg,omitempty"`

	SinkKafka *SinkKafkaParameters `json:"sink_kafka,omitempty"`

	// 事件目标类型名称
	Name *EventStreamingSinkName `json:"name,omitempty"`
}

EventStreamingSink 事件目标，一个事件流中只有一个事件目标，sink_fg、sink_kafka值能选择其中一个参数

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_FUNCTION_GRAPH EventStreamingSinkName
	HC_KAFKA          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"`

	SourceMobileRocketmq *SourceMobileMqParameters `json:"source_mobile_rocketmq,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 KafkaConnectionDetail added in v0.1.42 

type KafkaConnectionDetail struct {

	// kafka实例id。
	InstanceId string `json:"instance_id"`

	// kafka连接地址。
	Addr string `json:"addr"`

	// 安全协议。
	SecurityProtocol *string `json:"security_protocol,omitempty"`

	// kafka实例是否开启了SASL_SSL。
	SaslSsl bool `json:"sasl_ssl"`

	// kafka实例用户名。实例开启了SASL_SSL时必填
	Username *string `json:"username,omitempty"`

	// kafka实例密码。实例开启了SASL_SSL时必填
	Password *string `json:"password,omitempty"`

	// 收到Server端确认信号个数，表示procuder需要收到多少个这样的确认信号，算消息发送成功。acks参数代表了数据备份的可用性。支持选项： acks=0：表示producer不需要等待任何确认收到的信息，副本将立即加到socket buffer并认为已经发送。没有任何保障可以保证此种情况下server已经成功接收数据，同时重试配置不会发生作用（因为客户端不知道是否失败）回馈的offset会总是设置为-1。 acks=1：这意味着至少要等待leader已经成功将数据写入本地log，但是并没有等待所有follower是否成功写入。如果follower没有成功备份数据，而此时leader又无法提供服务，则消息会丢失。 acks=all：这意味着leader需要等待ISR中所有备份都成功写入日志，只有任何一个备份存活，数据都不会丢失。min.insync.replicas指定必须确认写入才能被认为成功的副本的最小数量。
	Acks *KafkaConnectionDetailAcks `json:"acks,omitempty"`
}

func (KafkaConnectionDetail) String added in v0.1.42 

func (o KafkaConnectionDetail) String() string

type KafkaConnectionDetailAcks added in v0.1.42 

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

func (KafkaConnectionDetailAcks) MarshalJSON added in v0.1.42 

func (c KafkaConnectionDetailAcks) MarshalJSON() ([]byte, error)

func (*KafkaConnectionDetailAcks) UnmarshalJSON added in v0.1.42 

func (c *KafkaConnectionDetailAcks) UnmarshalJSON(b []byte) error

func (KafkaConnectionDetailAcks) Value added in v0.1.42 

func (c KafkaConnectionDetailAcks) Value() string

type KafkaConnectionDetailAcksEnum added in v0.1.42 

type KafkaConnectionDetailAcksEnum struct {
	E_0 KafkaConnectionDetailAcks
	E_1 KafkaConnectionDetailAcks
	ALL KafkaConnectionDetailAcks
}

func GetKafkaConnectionDetailAcksEnum added in v0.1.42 

func GetKafkaConnectionDetailAcksEnum() KafkaConnectionDetailAcksEnum

type KafkaTargetDetail added in v0.1.42 

type KafkaTargetDetail struct {

	// 主题
	Topic string `json:"topic"`

	KeyTransform *KafkaTargetDetailKeyTransform `json:"keyTransform,omitempty"`
}

KafkaTargetDetail 订阅的kafka事件目标参数列表，该字段序列化后总长度不超过1024字节

func (KafkaTargetDetail) String added in v0.1.42 

func (o KafkaTargetDetail) String() string

type KafkaTargetDetailKeyTransform added in v0.1.42 

type KafkaTargetDetailKeyTransform struct {

	// 键值规则类型
	Type *KafkaTargetDetailKeyTransformType `json:"type,omitempty"`

	// 键值规则，键值规则为VARIABLE，CONSTANT时必填
	Value *string `json:"value,omitempty"`

	// 键值规则模板，键值规则为VARIABLE时必填
	Template *string `json:"template,omitempty"`
}

KafkaTargetDetailKeyTransform 键值规则

func (KafkaTargetDetailKeyTransform) String added in v0.1.42 

func (o KafkaTargetDetailKeyTransform) String() string

type KafkaTargetDetailKeyTransformType added in v0.1.42 

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

func (KafkaTargetDetailKeyTransformType) MarshalJSON added in v0.1.42 

func (c KafkaTargetDetailKeyTransformType) MarshalJSON() ([]byte, error)

func (*KafkaTargetDetailKeyTransformType) UnmarshalJSON added in v0.1.42 

func (c *KafkaTargetDetailKeyTransformType) UnmarshalJSON(b []byte) error

func (KafkaTargetDetailKeyTransformType) Value added in v0.1.42 

func (c KafkaTargetDetailKeyTransformType) Value() string

type KafkaTargetDetailKeyTransformTypeEnum added in v0.1.42 

type KafkaTargetDetailKeyTransformTypeEnum struct {
	NONE     KafkaTargetDetailKeyTransformType
	VARIABLE KafkaTargetDetailKeyTransformType
	CONSTANT KafkaTargetDetailKeyTransformType
}

func GetKafkaTargetDetailKeyTransformTypeEnum added in v0.1.42 

func GetKafkaTargetDetailKeyTransformTypeEnum() KafkaTargetDetailKeyTransformTypeEnum

type ListAgenciesRequest added in v0.1.3 

type ListAgenciesRequest struct {

	// 服务委托授权场景类型
	Type ListAgenciesRequestType `json:"type"`
}

ListAgenciesRequest Request Object

func (ListAgenciesRequest) String added in v0.1.3 

func (o ListAgenciesRequest) String() string

type ListAgenciesRequestType added in v0.1.3 

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

func (ListAgenciesRequestType) MarshalJSON added in v0.1.3 

func (c ListAgenciesRequestType) MarshalJSON() ([]byte, error)

func (*ListAgenciesRequestType) UnmarshalJSON added in v0.1.3 

func (c *ListAgenciesRequestType) UnmarshalJSON(b []byte) error

func (ListAgenciesRequestType) Value added in v0.1.3 

func (c ListAgenciesRequestType) Value() string

type ListAgenciesRequestTypeEnum added in v0.1.3 

type ListAgenciesRequestTypeEnum struct {
	TARGET_CONNECTION      ListAgenciesRequestType
	CUSTOM_SOURCE_RABBITMQ ListAgenciesRequestType
	EG_RESTORE_AGENCY      ListAgenciesRequestType
}

func GetListAgenciesRequestTypeEnum added in v0.1.3 

func GetListAgenciesRequestTypeEnum() ListAgenciesRequestTypeEnum

type ListAgenciesResponse added in v0.1.3 

type ListAgenciesResponse struct {

	// 服务委托授权记录。
	Agencies       *[]string `json:"agencies,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ListAgenciesResponse Response Object

func (ListAgenciesResponse) String added in v0.1.3 

func (o ListAgenciesResponse) String() string

type ListApiVersionsRequest added in v0.1.3 

type ListApiVersionsRequest struct {
}

ListApiVersionsRequest Request Object

func (ListApiVersionsRequest) String added in v0.1.3 

func (o ListApiVersionsRequest) String() string

type ListApiVersionsResponse added in v0.1.3 

type ListApiVersionsResponse struct {

	// 版本定义
	Versions       *[]ApiVersionsVersions `json:"versions,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

ListApiVersionsResponse Response Object

func (ListApiVersionsResponse) String added in v0.1.3 

func (o ListApiVersionsResponse) String() string

type ListChannelsRequest 

type ListChannelsRequest struct {

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`

	// 指定查询提供方的类型
	ProviderType *ListChannelsRequestProviderType `json:"provider_type,omitempty"`

	// 指定查询的事件通道名称，精准匹配
	Name *string `json:"name,omitempty"`

	// 指定查询的事件通道名称，模糊匹配
	FuzzyName *string `json:"fuzzy_name,omitempty"`

	// 指定查询的企业项目id，精确匹配
	EpsId *string `json:"eps_id,omitempty"`
}

ListChannelsRequest Request Object

func (ListChannelsRequest) String 

func (o ListChannelsRequest) String() string

type ListChannelsRequestProviderType 

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

func (ListChannelsRequestProviderType) MarshalJSON 

func (c ListChannelsRequestProviderType) MarshalJSON() ([]byte, error)

func (*ListChannelsRequestProviderType) UnmarshalJSON 

func (c *ListChannelsRequestProviderType) UnmarshalJSON(b []byte) error

func (ListChannelsRequestProviderType) Value 

func (c ListChannelsRequestProviderType) Value() string

type ListChannelsRequestProviderTypeEnum 

type ListChannelsRequestProviderTypeEnum struct {
	OFFICIAL ListChannelsRequestProviderType
	CUSTOM   ListChannelsRequestProviderType
	PARTNER  ListChannelsRequestProviderType
}

func GetListChannelsRequestProviderTypeEnum 

func GetListChannelsRequestProviderTypeEnum() ListChannelsRequestProviderTypeEnum

type ListChannelsResponse 

type ListChannelsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]ChannelInfo `json:"items,omitempty"`
	HttpStatusCode int            `json:"-"`
}

ListChannelsResponse Response Object

func (ListChannelsResponse) String 

func (o ListChannelsResponse) String() string

type ListConnectionsRequest added in v0.1.3 

type ListConnectionsRequest struct {

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`

	// 指定查询的目标连接名称，精准匹配
	Name *string `json:"name,omitempty"`

	// 指定查询的目标连接名称，模糊匹配
	FuzzyName *string `json:"fuzzy_name,omitempty"`

	// 指定查询的目标连接，队列的实例id
	InstanceId *string `json:"instance_id,omitempty"`
}

ListConnectionsRequest Request Object

func (ListConnectionsRequest) String added in v0.1.3 

func (o ListConnectionsRequest) String() string

type ListConnectionsResponse added in v0.1.3 

type ListConnectionsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]ConnectionInfo `json:"items,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ListConnectionsResponse Response Object

func (ListConnectionsResponse) String added in v0.1.3 

func (o ListConnectionsResponse) String() string

type ListEndpointsRequest added in v0.1.3 

type ListEndpointsRequest struct {

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`

	// 指定查询访问端点的类型
	Type *ListEndpointsRequestType `json:"type,omitempty"`

	// 指定查询访问端点的名称
	Name *string `json:"name,omitempty"`

	// 指定查询访问端点的vpcId
	VpcId *string `json:"vpc_id,omitempty"`

	// 指定查询访问端点的名称,模糊查询
	FuzzyName *string `json:"fuzzy_name,omitempty"`

	// 指定查询访问端点的SubnetId
	SubnetId *string `json:"subnet_id,omitempty"`
}

ListEndpointsRequest Request Object

func (ListEndpointsRequest) String added in v0.1.3 

func (o ListEndpointsRequest) String() string

type ListEndpointsRequestType added in v0.1.3 

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

func (ListEndpointsRequestType) MarshalJSON added in v0.1.3 

func (c ListEndpointsRequestType) MarshalJSON() ([]byte, error)

func (*ListEndpointsRequestType) UnmarshalJSON added in v0.1.3 

func (c *ListEndpointsRequestType) UnmarshalJSON(b []byte) error

func (ListEndpointsRequestType) Value added in v0.1.3 

func (c ListEndpointsRequestType) Value() string

type ListEndpointsRequestTypeEnum added in v0.1.3 

type ListEndpointsRequestTypeEnum struct {
	PRIVATE ListEndpointsRequestType
	PUBLIC  ListEndpointsRequestType
}

func GetListEndpointsRequestTypeEnum added in v0.1.3 

func GetListEndpointsRequestTypeEnum() ListEndpointsRequestTypeEnum

type ListEndpointsResponse added in v0.1.3 

type ListEndpointsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items *[]EndpointInfo `json:"items,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListEndpointsResponse Response Object

func (ListEndpointsResponse) String added in v0.1.3 

func (o ListEndpointsResponse) String() string

type ListEventSourcesRequest 

type ListEventSourcesRequest struct {

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

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`

	// 指定查询提供方的类型
	ProviderType *ListEventSourcesRequestProviderType `json:"provider_type,omitempty"`

	// 指定查询的事件源名称，精准匹配
	Name *string `json:"name,omitempty"`

	// 指定查询的事件源名称，模糊匹配
	FuzzyName *string `json:"fuzzy_name,omitempty"`

	// 指定查询的事件源标签，模糊匹配
	FuzzyLabel *string `json:"fuzzy_label,omitempty"`
}

ListEventSourcesRequest Request Object

func (ListEventSourcesRequest) String 

func (o ListEventSourcesRequest) String() string

type ListEventSourcesRequestProviderType 

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

func (ListEventSourcesRequestProviderType) MarshalJSON 

func (c ListEventSourcesRequestProviderType) MarshalJSON() ([]byte, error)

func (*ListEventSourcesRequestProviderType) UnmarshalJSON 

func (c *ListEventSourcesRequestProviderType) UnmarshalJSON(b []byte) error

func (ListEventSourcesRequestProviderType) Value 

func (c ListEventSourcesRequestProviderType) Value() string

type ListEventSourcesRequestProviderTypeEnum 

type ListEventSourcesRequestProviderTypeEnum struct {
	OFFICIAL ListEventSourcesRequestProviderType
	CUSTOM   ListEventSourcesRequestProviderType
	PARTNER  ListEventSourcesRequestProviderType
}

func GetListEventSourcesRequestProviderTypeEnum 

func GetListEventSourcesRequestProviderTypeEnum() ListEventSourcesRequestProviderTypeEnum

type ListEventSourcesResponse 

type ListEventSourcesResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]CustomizeSourceInfo `json:"items,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

ListEventSourcesResponse Response Object

func (ListEventSourcesResponse) String 

func (o ListEventSourcesResponse) String() string

type ListEventStreamingRequest added in v0.1.42 

type ListEventStreamingRequest struct {

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询的事件订阅名称，精准匹配
	Name *string `json:"name,omitempty"`

	// 指定查询的事件流名称，模糊匹配
	FuzzyName *string `json:"fuzzy_name,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 {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items *[]EventStreamingDetail `json:"items,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListEventStreamingResponse Response Object

func (ListEventStreamingResponse) String added in v0.1.42 

func (o ListEventStreamingResponse) String() string

type ListEventTargetRequest 

type ListEventTargetRequest struct {

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`

	// 指定查询的事件目标标签，模糊匹配
	FuzzyLabel *string `json:"fuzzy_label,omitempty"`

	// 事件目标支持方式：事件订阅：SUBSCRIPTION、事件流：FLOW
	SupportTypes *[]ListEventTargetRequestSupportTypes `json:"support_types,omitempty"`
}

ListEventTargetRequest Request Object

func (ListEventTargetRequest) String 

func (o ListEventTargetRequest) String() string

type ListEventTargetRequestSupportTypes added in v0.1.42 

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

func (ListEventTargetRequestSupportTypes) MarshalJSON added in v0.1.42 

func (c ListEventTargetRequestSupportTypes) MarshalJSON() ([]byte, error)

func (*ListEventTargetRequestSupportTypes) UnmarshalJSON added in v0.1.42 

func (c *ListEventTargetRequestSupportTypes) UnmarshalJSON(b []byte) error

func (ListEventTargetRequestSupportTypes) Value added in v0.1.42 

func (c ListEventTargetRequestSupportTypes) Value() string

type ListEventTargetRequestSupportTypesEnum added in v0.1.42 

type ListEventTargetRequestSupportTypesEnum struct {
	SUBSCRIPTION ListEventTargetRequestSupportTypes
	FLOW         ListEventTargetRequestSupportTypes
}

func GetListEventTargetRequestSupportTypesEnum added in v0.1.42 

func GetListEventTargetRequestSupportTypesEnum() ListEventTargetRequestSupportTypesEnum

type ListEventTargetResponse 

type ListEventTargetResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]CatalogTargetInfo `json:"items,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

ListEventTargetResponse Response Object

func (ListEventTargetResponse) String 

func (o ListEventTargetResponse) String() string

type ListObsBucketsRequest added in v0.1.28 

type ListObsBucketsRequest struct {

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`
}

ListObsBucketsRequest Request Object

func (ListObsBucketsRequest) String added in v0.1.28 

func (o ListObsBucketsRequest) String() string

type ListObsBucketsResponse added in v0.1.28 

type ListObsBucketsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]ObsBucketInfo `json:"items,omitempty"`
	HttpStatusCode int              `json:"-"`
}

ListObsBucketsResponse Response Object

func (ListObsBucketsResponse) String added in v0.1.28 

func (o ListObsBucketsResponse) String() string

type ListPubMetricsRequest added in v0.1.28 

type ListPubMetricsRequest struct {

	// 指标数据统计方式
	Filter *ListPubMetricsRequestFilter `json:"filter,omitempty"`

	// 指标数据统计周期，单位minute。
	Period *int32 `json:"period,omitempty"`

	// 获取指标数据起始时间
	StartTime int64 `json:"start_time"`

	// 获取指标数据结束时间
	EndTime *int64 `json:"end_time,omitempty"`

	// 事件通道id
	ChannelId string `json:"channel_id"`

	// 事件目标类型/事件通道类型
	ProviderType *ListPubMetricsRequestProviderType `json:"provider_type,omitempty"`

	// 事件源名称
	SourceName *string `json:"source_name,omitempty"`
}

ListPubMetricsRequest Request Object

func (ListPubMetricsRequest) String added in v0.1.28 

func (o ListPubMetricsRequest) String() string

type ListPubMetricsRequestFilter added in v0.1.28 

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

func (ListPubMetricsRequestFilter) MarshalJSON added in v0.1.28 

func (c ListPubMetricsRequestFilter) MarshalJSON() ([]byte, error)

func (*ListPubMetricsRequestFilter) UnmarshalJSON added in v0.1.28 

func (c *ListPubMetricsRequestFilter) UnmarshalJSON(b []byte) error

func (ListPubMetricsRequestFilter) Value added in v0.1.28 

func (c ListPubMetricsRequestFilter) Value() string

type ListPubMetricsRequestFilterEnum added in v0.1.28 

type ListPubMetricsRequestFilterEnum struct {
	AVG ListPubMetricsRequestFilter
	MIN ListPubMetricsRequestFilter
	MAX ListPubMetricsRequestFilter
}

func GetListPubMetricsRequestFilterEnum added in v0.1.28 

func GetListPubMetricsRequestFilterEnum() ListPubMetricsRequestFilterEnum

type ListPubMetricsRequestProviderType added in v0.1.28 

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

func (ListPubMetricsRequestProviderType) MarshalJSON added in v0.1.28 

func (c ListPubMetricsRequestProviderType) MarshalJSON() ([]byte, error)

func (*ListPubMetricsRequestProviderType) UnmarshalJSON added in v0.1.28 

func (c *ListPubMetricsRequestProviderType) UnmarshalJSON(b []byte) error

func (ListPubMetricsRequestProviderType) Value added in v0.1.28 

func (c ListPubMetricsRequestProviderType) Value() string

type ListPubMetricsRequestProviderTypeEnum added in v0.1.28 

type ListPubMetricsRequestProviderTypeEnum struct {
	OFFICIAL ListPubMetricsRequestProviderType
	CUSTOM   ListPubMetricsRequestProviderType
}

func GetListPubMetricsRequestProviderTypeEnum added in v0.1.28 

func GetListPubMetricsRequestProviderTypeEnum() ListPubMetricsRequestProviderTypeEnum

type ListPubMetricsResponse added in v0.1.28 

type ListPubMetricsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 指标列表
	Result         *[]EventPubMetricsItem `json:"result,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

ListPubMetricsResponse Response Object

func (ListPubMetricsResponse) String added in v0.1.28 

func (o ListPubMetricsResponse) String() string

type ListQuotasRequest 

type ListQuotasRequest struct {

	// 指定查询资源类型的配额
	Type *ListQuotasRequestType `json:"type,omitempty"`
}

ListQuotasRequest Request Object

func (ListQuotasRequest) String 

func (o ListQuotasRequest) String() string

type ListQuotasRequestType 

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

func (ListQuotasRequestType) MarshalJSON 

func (c ListQuotasRequestType) MarshalJSON() ([]byte, error)

func (*ListQuotasRequestType) UnmarshalJSON 

func (c *ListQuotasRequestType) UnmarshalJSON(b []byte) error

func (ListQuotasRequestType) Value 

func (c ListQuotasRequestType) Value() string

type ListQuotasRequestTypeEnum 

type ListQuotasRequestTypeEnum struct {
	CHANNEL              ListQuotasRequestType
	CHANNEL_SUBSCRIPTION ListQuotasRequestType
	SOURCE               ListQuotasRequestType
	SUBSCRIPTION         ListQuotasRequestType
	SUBSCRIPTION_TARGET  ListQuotasRequestType
	SCHEMA               ListQuotasRequestType
	SCHEMA_VERSION       ListQuotasRequestType
	CONNECTION           ListQuotasRequestType
	PRIVATE_ENDPOINT     ListQuotasRequestType
	SOURCE_RABBITMQ      ListQuotasRequestType
	SOURCE_ROCKETMQ      ListQuotasRequestType
}

func GetListQuotasRequestTypeEnum 

func GetListQuotasRequestTypeEnum() ListQuotasRequestTypeEnum

type ListQuotasResponse 

type ListQuotasResponse struct {
	Quotas         *QuotaResourceResp `json:"quotas,omitempty"`
	HttpStatusCode int                `json:"-"`
}

ListQuotasResponse Response Object

func (ListQuotasResponse) String 

func (o ListQuotasResponse) String() string

type ListSubMetricsRequest added in v0.1.28 

type ListSubMetricsRequest struct {

	// 指标数据统计方式
	Filter *ListSubMetricsRequestFilter `json:"filter,omitempty"`

	// 指标数据统计周期，单位minute。
	Period *int32 `json:"period,omitempty"`

	// 获取指标数据起始时间
	StartTime int64 `json:"start_time"`

	// 获取指标数据结束时间
	EndTime *int64 `json:"end_time,omitempty"`

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

	// 事件目标类型/事件通道类型
	ProviderType *ListSubMetricsRequestProviderType `json:"provider_type,omitempty"`

	// 事件目标id
	TargetId *string `json:"target_id,omitempty"`
}

ListSubMetricsRequest Request Object

func (ListSubMetricsRequest) String added in v0.1.28 

func (o ListSubMetricsRequest) String() string

type ListSubMetricsRequestFilter added in v0.1.28 

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

func (ListSubMetricsRequestFilter) MarshalJSON added in v0.1.28 

func (c ListSubMetricsRequestFilter) MarshalJSON() ([]byte, error)

func (*ListSubMetricsRequestFilter) UnmarshalJSON added in v0.1.28 

func (c *ListSubMetricsRequestFilter) UnmarshalJSON(b []byte) error

func (ListSubMetricsRequestFilter) Value added in v0.1.28 

func (c ListSubMetricsRequestFilter) Value() string

type ListSubMetricsRequestFilterEnum added in v0.1.28 

type ListSubMetricsRequestFilterEnum struct {
	AVG ListSubMetricsRequestFilter
	MIN ListSubMetricsRequestFilter
	MAX ListSubMetricsRequestFilter
}

func GetListSubMetricsRequestFilterEnum added in v0.1.28 

func GetListSubMetricsRequestFilterEnum() ListSubMetricsRequestFilterEnum

type ListSubMetricsRequestProviderType added in v0.1.28 

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

func (ListSubMetricsRequestProviderType) MarshalJSON added in v0.1.28 

func (c ListSubMetricsRequestProviderType) MarshalJSON() ([]byte, error)

func (*ListSubMetricsRequestProviderType) UnmarshalJSON added in v0.1.28 

func (c *ListSubMetricsRequestProviderType) UnmarshalJSON(b []byte) error

func (ListSubMetricsRequestProviderType) Value added in v0.1.28 

func (c ListSubMetricsRequestProviderType) Value() string

type ListSubMetricsRequestProviderTypeEnum added in v0.1.28 

type ListSubMetricsRequestProviderTypeEnum struct {
	OFFICIAL ListSubMetricsRequestProviderType
	CUSTOM   ListSubMetricsRequestProviderType
}

func GetListSubMetricsRequestProviderTypeEnum added in v0.1.28 

func GetListSubMetricsRequestProviderTypeEnum() ListSubMetricsRequestProviderTypeEnum

type ListSubMetricsResponse added in v0.1.28 

type ListSubMetricsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 指标数据列表
	Result         *[]EventSubMetricsItem `json:"result,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

ListSubMetricsResponse Response Object

func (ListSubMetricsResponse) String added in v0.1.28 

func (o ListSubMetricsResponse) String() string

type ListSubscriptionsRequest 

type ListSubscriptionsRequest struct {

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

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`

	// 指定查询的事件订阅名称，精准匹配
	Name *string `json:"name,omitempty"`

	// 指定查询的事件订阅名称，模糊匹配
	FuzzyName *string `json:"fuzzy_name,omitempty"`

	// 目标连接 id
	ConnectionId *string `json:"connection_id,omitempty"`
}

ListSubscriptionsRequest Request Object

func (ListSubscriptionsRequest) String 

func (o ListSubscriptionsRequest) String() string

type ListSubscriptionsResponse 

type ListSubscriptionsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]SubscriptionInfo `json:"items,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

ListSubscriptionsResponse Response Object

func (ListSubscriptionsResponse) String 

func (o ListSubscriptionsResponse) String() string

type ListTracedEventsRequest added in v0.1.42 

type ListTracedEventsRequest struct {

	// 查询数据起始时间
	StartTime int64 `json:"start_time"`

	// 查询数据结束时间
	EndTime int64 `json:"end_time"`

	// 指定查询事件的Id
	EventId *string `json:"event_id,omitempty"`

	// 事件源名称
	SourceName *string `json:"source_name,omitempty"`

	// 指定查询的事件类型，精准匹配
	EventType *string `json:"event_type,omitempty"`

	// 事件订阅名称
	SubscriptionName *string `json:"subscription_name,omitempty"`

	// 每页显示的条目数量，不能小于0
	Limit *string `json:"limit,omitempty"`

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 通道ID
	ChannelId string `json:"channel_id"`
}

ListTracedEventsRequest Request Object

func (ListTracedEventsRequest) String added in v0.1.42 

func (o ListTracedEventsRequest) String() string

type ListTracedEventsRespResult added in v0.1.42 

type ListTracedEventsRespResult struct {
	SubscriptionName *string `json:"subscription_name,omitempty"`

	SourceName *string `json:"source_name,omitempty"`

	SourceProvider *string `json:"source_provider,omitempty"`

	EventType *string `json:"event_type,omitempty"`

	EventId *string `json:"event_id,omitempty"`

	EventReceivedTime *int32 `json:"event_received_time,omitempty"`
}

func (ListTracedEventsRespResult) String added in v0.1.42 

func (o ListTracedEventsRespResult) String() string

type ListTracedEventsResponse added in v0.1.42 

type ListTracedEventsResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 事件追踪列表
	Result *[]ListTracedEventsRespResult `json:"result,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListTracedEventsResponse Response Object

func (ListTracedEventsResponse) String added in v0.1.42 

func (o ListTracedEventsResponse) String() string

type ListTriggersRequest added in v0.1.3 

type ListTriggersRequest struct {

	// 目标函数的urn
	FuncUrn string `json:"func_urn"`

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`
}

ListTriggersRequest Request Object

func (ListTriggersRequest) String added in v0.1.3 

func (o ListTriggersRequest) String() string

type ListTriggersResponse added in v0.1.3 

type ListTriggersResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]SubscriptionInfo `json:"items,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

ListTriggersResponse Response Object

func (ListTriggersResponse) String added in v0.1.3 

func (o ListTriggersResponse) String() string

type ListWorkflowTriggersRequest added in v0.1.28 

type ListWorkflowTriggersRequest struct {

	// 目标函数流的id
	WorkflowId string `json:"workflow_id"`

	// 偏移量，表示从此偏移量开始查询，偏移量不能小于0
	Offset *int32 `json:"offset,omitempty"`

	// 每页显示的条目数量，不能小于1或大于1000
	Limit *int32 `json:"limit,omitempty"`

	// 指定查询排序
	Sort *string `json:"sort,omitempty"`
}

ListWorkflowTriggersRequest Request Object

func (ListWorkflowTriggersRequest) String added in v0.1.28 

func (o ListWorkflowTriggersRequest) String() string

type ListWorkflowTriggersResponse added in v0.1.28 

type ListWorkflowTriggersResponse struct {

	// 总数
	Total *int32 `json:"total,omitempty"`

	// 本页数量
	Size *int32 `json:"size,omitempty"`

	// 对象列表
	Items          *[]SubscriptionInfo `json:"items,omitempty"`
	HttpStatusCode int                 `json:"-"`
}

ListWorkflowTriggersResponse Response Object

func (ListWorkflowTriggersResponse) String added in v0.1.28 

func (o ListWorkflowTriggersResponse) String() string

type ObsBucketInfo added in v0.1.28 

type ObsBucketInfo struct {

	// 响应头
	ResponseHeaders *interface{} `json:"responseHeaders,omitempty"`

	// 请求头
	OriginalHeaders *interface{} `json:"originalHeaders,omitempty"`

	// 状态
	StatusCode *int32 `json:"statusCode,omitempty"`

	// 桶名称
	BucketName *string `json:"bucketName,omitempty"`

	Owner *ObsBucketInfoOwner `json:"owner,omitempty"`

	// 桶的创建时间
	CreationDate *string `json:"creationDate,omitempty"`

	// 桶的位置信息
	Location *string `json:"location,omitempty"`

	// 对象的存储类型
	StorageClass *interface{} `json:"storageClass,omitempty"`

	// 桶元数据
	Metadata *interface{} `json:"metadata,omitempty"`

	// 桶ACL
	Acl *interface{} `json:"acl,omitempty"`

	// 桶的存储类型
	BucketStorageClass *interface{} `json:"bucketStorageClass,omitempty"`

	// 桶类型
	BucketType *string `json:"bucketType,omitempty"`

	// 请求id
	RequestId *string `json:"requestId,omitempty"`
}

func (ObsBucketInfo) String added in v0.1.28 

func (o ObsBucketInfo) String() string

type ObsBucketInfoOwner added in v0.1.28 

type ObsBucketInfoOwner struct {

	// 显示名称
	DisplayName *string `json:"displayName,omitempty"`

	// 用户的DomainID，即帐号ID
	Id *string `json:"id,omitempty"`
}

ObsBucketInfoOwner 桶拥有者信息

func (ObsBucketInfoOwner) String added in v0.1.28 

func (o ObsBucketInfoOwner) String() string

type OperateSubscriptionRequest 

type OperateSubscriptionRequest struct {
	Body *SubscriptionOperateReq `json:"body,omitempty"`
}

OperateSubscriptionRequest Request Object

func (OperateSubscriptionRequest) String 

func (o OperateSubscriptionRequest) String() string

type OperateSubscriptionResponse 

type OperateSubscriptionResponse struct {

	// 操作失败的订阅个数
	FailedCount *int32 `json:"failed_count,omitempty"`

	// 事件列表
	Events *[]SubscriptionOperateRespEvents `json:"events,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

OperateSubscriptionResponse Response Object

func (OperateSubscriptionResponse) String 

func (o OperateSubscriptionResponse) String() string

type PutEventsReq 

type PutEventsReq struct {
	Events *[]CloudEvents `json:"events,omitempty"`
}

func (PutEventsReq) String 

func (o PutEventsReq) String() string

type PutEventsRequest 

type PutEventsRequest struct {

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

	Body *PutEventsReq `json:"body,omitempty"`
}

PutEventsRequest Request Object

func (PutEventsRequest) String 

func (o PutEventsRequest) String() string

type PutEventsRespEvents 

type PutEventsRespEvents struct {

	// 发布失败的错误码
	ErrorCode *string `json:"error_code,omitempty"`

	// 发布失败的原因
	ErrorMsg *string `json:"error_msg,omitempty"`

	// 事件唯一标识串
	EventId *string `json:"event_id,omitempty"`
}

func (PutEventsRespEvents) String 

func (o PutEventsRespEvents) String() string

type PutEventsResponse 

type PutEventsResponse struct {

	// 发布失败的事件个数
	FailedCount *int32 `json:"failed_count,omitempty"`

	// 事件列表
	Events *[]PutEventsRespEvents `json:"events,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

PutEventsResponse Response Object

func (PutEventsResponse) String 

func (o PutEventsResponse) String() string

type PutOfficialEventsRequest added in v0.1.42 

type PutOfficialEventsRequest struct {

	// 事件源名称
	SourceName string `json:"source_name"`

	Body *PutEventsReq `json:"body,omitempty"`
}

PutOfficialEventsRequest Request Object

func (PutOfficialEventsRequest) String added in v0.1.42 

func (o PutOfficialEventsRequest) String() string

type PutOfficialEventsResponse added in v0.1.42 

type PutOfficialEventsResponse struct {

	// 发布失败的事件个数
	FailedCount *int32 `json:"failed_count,omitempty"`

	// 事件列表
	Events *[]PutEventsRespEvents `json:"events,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

PutOfficialEventsResponse Response Object

func (PutOfficialEventsResponse) String added in v0.1.42 

func (o PutOfficialEventsResponse) String() string

type QuotaItemInfo 

type QuotaItemInfo struct {

	// 名称
	Name *string `json:"name,omitempty"`

	// 配额类型
	Type *QuotaItemInfoType `json:"type,omitempty"`

	// 配额最大值
	Max *int32 `json:"max,omitempty"`

	// 配额最小值
	Min *int32 `json:"min,omitempty"`

	// 当前租户的配额
	Quota *int32 `json:"quota,omitempty"`

	// 当前租户已使用的配额
	Used *int32 `json:"used,omitempty"`
}

func (QuotaItemInfo) String 

func (o QuotaItemInfo) String() string

type QuotaItemInfoType 

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

func (QuotaItemInfoType) MarshalJSON 

func (c QuotaItemInfoType) MarshalJSON() ([]byte, error)

func (*QuotaItemInfoType) UnmarshalJSON 

func (c *QuotaItemInfoType) UnmarshalJSON(b []byte) error

func (QuotaItemInfoType) Value 

func (c QuotaItemInfoType) Value() string

type QuotaItemInfoTypeEnum 

type QuotaItemInfoTypeEnum struct {
	CHANNEL              QuotaItemInfoType
	CHANNEL_SUBSCRIPTION QuotaItemInfoType
	SOURCE               QuotaItemInfoType
	SUBSCRIPTION         QuotaItemInfoType
	SUBSCRIPTION_TARGET  QuotaItemInfoType
	SCHEMA               QuotaItemInfoType
	SCHEMA_VERSION       QuotaItemInfoType
	CONNECTION           QuotaItemInfoType
	PRIVATE_ENDPOINT     QuotaItemInfoType
	SOURCE_RABBITMQ      QuotaItemInfoType
	SOURCE_ROCKETMQ      QuotaItemInfoType
}

func GetQuotaItemInfoTypeEnum 

func GetQuotaItemInfoTypeEnum() QuotaItemInfoTypeEnum

type QuotaResourceResp 

type QuotaResourceResp struct {

	// 错误描述
	Resources *[]QuotaItemInfo `json:"resources,omitempty"`
}

func (QuotaResourceResp) String 

func (o QuotaResourceResp) String() string

type ResumeEventStreamingRequest added in v0.1.42 

type ResumeEventStreamingRequest struct {

	// 事件流ID
	EventstreamingId string `json:"eventstreaming_id"`

	Body *EventStreamingOperateReq `json:"body,omitempty"`
}

ResumeEventStreamingRequest Request Object

func (ResumeEventStreamingRequest) String added in v0.1.42 

func (o ResumeEventStreamingRequest) String() string

type ResumeEventStreamingResponse added in v0.1.42 

type ResumeEventStreamingResponse struct {

	// 事件流ID
	EventStreamingID *string `json:"eventStreamingID,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ResumeEventStreamingResponse Response Object

func (ResumeEventStreamingResponse) String added in v0.1.42 

func (o ResumeEventStreamingResponse) String() string

type RunOption added in v0.1.42 

type RunOption struct {

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

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

func (RunOption) String added in v0.1.42 

func (o RunOption) String() string

type ShowDetailOfChannelRequest 

type ShowDetailOfChannelRequest struct {

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

	// 企业项目id
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`
}

ShowDetailOfChannelRequest Request Object

func (ShowDetailOfChannelRequest) String 

func (o ShowDetailOfChannelRequest) String() string

type ShowDetailOfChannelResponse 

type ShowDetailOfChannelResponse struct {

	// 通道ID
	Id *string `json:"id,omitempty"`

	// 通道名称
	Name *string `json:"name,omitempty"`

	// 通道描述
	Description *string `json:"description,omitempty"`

	// 通道提供方类型，OFFICIAL：官方事件通道；CUSTOM：自定义事件通道；PARTNER：伙伴事件通道
	ProviderType *ShowDetailOfChannelResponseProviderType `json:"provider_type,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	// 企业项目id
	EpsId          *string `json:"eps_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowDetailOfChannelResponse Response Object

func (ShowDetailOfChannelResponse) String 

func (o ShowDetailOfChannelResponse) String() string

type ShowDetailOfChannelResponseProviderType 

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

func (ShowDetailOfChannelResponseProviderType) MarshalJSON 

func (c ShowDetailOfChannelResponseProviderType) MarshalJSON() ([]byte, error)

func (*ShowDetailOfChannelResponseProviderType) UnmarshalJSON 

func (c *ShowDetailOfChannelResponseProviderType) UnmarshalJSON(b []byte) error

func (ShowDetailOfChannelResponseProviderType) Value 

func (c ShowDetailOfChannelResponseProviderType) Value() string

type ShowDetailOfChannelResponseProviderTypeEnum 

type ShowDetailOfChannelResponseProviderTypeEnum struct {
	OFFICIAL ShowDetailOfChannelResponseProviderType
	CUSTOM   ShowDetailOfChannelResponseProviderType
	PARTNER  ShowDetailOfChannelResponseProviderType
}

func GetShowDetailOfChannelResponseProviderTypeEnum 

func GetShowDetailOfChannelResponseProviderTypeEnum() ShowDetailOfChannelResponseProviderTypeEnum

type ShowDetailOfConnectionRequest added in v0.1.3 

type ShowDetailOfConnectionRequest struct {

	// 指定查询的目标连接ID
	ConnectionId string `json:"connection_id"`
}

ShowDetailOfConnectionRequest Request Object

func (ShowDetailOfConnectionRequest) String added in v0.1.3 

func (o ShowDetailOfConnectionRequest) String() string

type ShowDetailOfConnectionResponse added in v0.1.3 

type ShowDetailOfConnectionResponse struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 目标连接名称，租户下唯一，由小写字母、数字、点、下划线和中划线组成，必须以字母或数字开头，不能为default
	Name *string `json:"name,omitempty"`

	// 目标连接描述
	Description *string `json:"description,omitempty"`

	// 目标连接状态
	Status *ShowDetailOfConnectionResponseStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	// 待连接的VPC ID
	VpcId *string `json:"vpc_id,omitempty"`

	// 待连接的子网ID
	SubnetId *string `json:"subnet_id,omitempty"`

	// 私网目标连接使用的用户委托名称
	Agency *string `json:"agency,omitempty"`

	Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"`

	Type *ConnectionType `json:"type,omitempty"`

	KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime    *string `json:"updated_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowDetailOfConnectionResponse Response Object

func (ShowDetailOfConnectionResponse) String added in v0.1.3 

func (o ShowDetailOfConnectionResponse) String() string

type ShowDetailOfConnectionResponseStatus added in v0.1.3 

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

func (ShowDetailOfConnectionResponseStatus) MarshalJSON added in v0.1.3 

func (c ShowDetailOfConnectionResponseStatus) MarshalJSON() ([]byte, error)

func (*ShowDetailOfConnectionResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *ShowDetailOfConnectionResponseStatus) UnmarshalJSON(b []byte) error

func (ShowDetailOfConnectionResponseStatus) Value added in v0.1.3 

func (c ShowDetailOfConnectionResponseStatus) Value() string

type ShowDetailOfConnectionResponseStatusEnum added in v0.1.3 

type ShowDetailOfConnectionResponseStatusEnum struct {
	CREATING      ShowDetailOfConnectionResponseStatus
	CREATED       ShowDetailOfConnectionResponseStatus
	CREATE_FAILED ShowDetailOfConnectionResponseStatus
}

func GetShowDetailOfConnectionResponseStatusEnum added in v0.1.3 

func GetShowDetailOfConnectionResponseStatusEnum() ShowDetailOfConnectionResponseStatusEnum

type ShowDetailOfEventRequest added in v0.1.42 

type ShowDetailOfEventRequest struct {

	// 追踪事件的uniqueId
	TraceId string `json:"trace_id"`

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

ShowDetailOfEventRequest Request Object

func (ShowDetailOfEventRequest) String added in v0.1.42 

func (o ShowDetailOfEventRequest) String() string

type ShowDetailOfEventResponse added in v0.1.42 

type ShowDetailOfEventResponse struct {
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowDetailOfEventResponse Response Object

func (ShowDetailOfEventResponse) String added in v0.1.42 

func (o ShowDetailOfEventResponse) String() string

type ShowDetailOfEventSourceRequest 

type ShowDetailOfEventSourceRequest struct {

	// 指定查询的事件源ID
	SourceId string `json:"source_id"`
}

ShowDetailOfEventSourceRequest Request Object

func (ShowDetailOfEventSourceRequest) String 

func (o ShowDetailOfEventSourceRequest) String() string

type ShowDetailOfEventSourceResponse 

type ShowDetailOfEventSourceResponse struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 事件源名称
	Name *string `json:"name,omitempty"`

	// 事件源名称展示
	Label *string `json:"label,omitempty"`

	// 事件源描述
	Description *string `json:"description,omitempty"`

	// 事件源提供方类型，OFFICIAL：官方云服务事件源；CUSTOM：用户创建的自定义事件源；PARTNER：伙伴事件源
	ProviderType *ShowDetailOfEventSourceResponseProviderType `json:"provider_type,omitempty"`

	// 事件源提供的事件类型列表，只有官方云服务事件源提供事件类型
	EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	// 事件源归属的事件通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 事件源归属的事件通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 事件源类型
	Type *string `json:"type,omitempty"`

	// json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等
	Detail *interface{} `json:"detail,omitempty"`

	// 自定义事件源状态
	Status *ShowDetailOfEventSourceResponseStatus `json:"status,omitempty"`

	ErrorInfo      *ErrorInfo `json:"error_info,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ShowDetailOfEventSourceResponse Response Object

func (ShowDetailOfEventSourceResponse) String 

func (o ShowDetailOfEventSourceResponse) String() string

type ShowDetailOfEventSourceResponseProviderType 

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

func (ShowDetailOfEventSourceResponseProviderType) MarshalJSON 

func (c ShowDetailOfEventSourceResponseProviderType) MarshalJSON() ([]byte, error)

func (*ShowDetailOfEventSourceResponseProviderType) UnmarshalJSON 

func (c *ShowDetailOfEventSourceResponseProviderType) UnmarshalJSON(b []byte) error

func (ShowDetailOfEventSourceResponseProviderType) Value 

func (c ShowDetailOfEventSourceResponseProviderType) Value() string

type ShowDetailOfEventSourceResponseProviderTypeEnum 

type ShowDetailOfEventSourceResponseProviderTypeEnum struct {
	OFFICIAL ShowDetailOfEventSourceResponseProviderType
	CUSTOM   ShowDetailOfEventSourceResponseProviderType
	PARTNER  ShowDetailOfEventSourceResponseProviderType
}

func GetShowDetailOfEventSourceResponseProviderTypeEnum 

func GetShowDetailOfEventSourceResponseProviderTypeEnum() ShowDetailOfEventSourceResponseProviderTypeEnum

type ShowDetailOfEventSourceResponseStatus added in v0.1.3 

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

func (ShowDetailOfEventSourceResponseStatus) MarshalJSON added in v0.1.3 

func (c ShowDetailOfEventSourceResponseStatus) MarshalJSON() ([]byte, error)

func (*ShowDetailOfEventSourceResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *ShowDetailOfEventSourceResponseStatus) UnmarshalJSON(b []byte) error

func (ShowDetailOfEventSourceResponseStatus) Value added in v0.1.3 

func (c ShowDetailOfEventSourceResponseStatus) Value() string

type ShowDetailOfEventSourceResponseStatusEnum added in v0.1.3 

type ShowDetailOfEventSourceResponseStatusEnum struct {
	CREATE_FAILED ShowDetailOfEventSourceResponseStatus
	RUNNING       ShowDetailOfEventSourceResponseStatus
	ERROR         ShowDetailOfEventSourceResponseStatus
}

func GetShowDetailOfEventSourceResponseStatusEnum added in v0.1.3 

func GetShowDetailOfEventSourceResponseStatusEnum() ShowDetailOfEventSourceResponseStatusEnum

type ShowDetailOfEventTraceRequest added in v0.1.42 

type ShowDetailOfEventTraceRequest struct {

	// 事件唯一标识
	TraceId string `json:"trace_id"`

	// 通道id
	ChannelId string `json:"channel_id"`
}

ShowDetailOfEventTraceRequest Request Object

func (ShowDetailOfEventTraceRequest) String added in v0.1.42 

func (o ShowDetailOfEventTraceRequest) String() string

type ShowDetailOfEventTraceResponse added in v0.1.42 

type ShowDetailOfEventTraceResponse struct {

	// 事件ID
	EventId *string `json:"eventId,omitempty"`

	// 事件源
	EventSource *string `json:"eventSource,omitempty"`

	// 事件类型
	EventType *string `json:"eventType,omitempty"`

	// 接收时间
	ReceiveTime *string `json:"receiveTime,omitempty"`

	// 通道ID
	ChannelId *string `json:"channelId,omitempty"`

	// 通道名称
	ChannelName *string `json:"channelName,omitempty"`

	// 事件投递列表
	DeliverList    *[]DeliverItem `json:"deliverList,omitempty"`
	HttpStatusCode int            `json:"-"`
}

ShowDetailOfEventTraceResponse Response Object

func (ShowDetailOfEventTraceResponse) String added in v0.1.42 

func (o ShowDetailOfEventTraceResponse) String() string

type ShowDetailOfSubscriptionRequest 

type ShowDetailOfSubscriptionRequest struct {

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

ShowDetailOfSubscriptionRequest Request Object

func (ShowDetailOfSubscriptionRequest) String 

func (o ShowDetailOfSubscriptionRequest) String() string

type ShowDetailOfSubscriptionResponse 

type ShowDetailOfSubscriptionResponse struct {

	// 订阅ID
	Id *string `json:"id,omitempty"`

	// 订阅名称
	Name *string `json:"name,omitempty"`

	// 订阅描述
	Description *string `json:"description,omitempty"`

	// 类型
	Type *ShowDetailOfSubscriptionResponseType `json:"type,omitempty"`

	// 状态
	Status *ShowDetailOfSubscriptionResponseStatus `json:"status,omitempty"`

	// 通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 标签信息
	Used *[]SubscriptionUsedInfo `json:"used,omitempty"`

	// 订阅源列表
	Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"`

	// 订阅目标列表
	Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime    *string `json:"updated_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowDetailOfSubscriptionResponse Response Object

func (ShowDetailOfSubscriptionResponse) String 

func (o ShowDetailOfSubscriptionResponse) String() string

type ShowDetailOfSubscriptionResponseStatus 

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

func (ShowDetailOfSubscriptionResponseStatus) MarshalJSON 

func (c ShowDetailOfSubscriptionResponseStatus) MarshalJSON() ([]byte, error)

func (*ShowDetailOfSubscriptionResponseStatus) UnmarshalJSON 

func (c *ShowDetailOfSubscriptionResponseStatus) UnmarshalJSON(b []byte) error

func (ShowDetailOfSubscriptionResponseStatus) Value 

func (c ShowDetailOfSubscriptionResponseStatus) Value() string

type ShowDetailOfSubscriptionResponseStatusEnum 

type ShowDetailOfSubscriptionResponseStatusEnum struct {
	CREATED  ShowDetailOfSubscriptionResponseStatus
	ENABLED  ShowDetailOfSubscriptionResponseStatus
	DISABLED ShowDetailOfSubscriptionResponseStatus
	FROZEN   ShowDetailOfSubscriptionResponseStatus
	ERROR    ShowDetailOfSubscriptionResponseStatus
}

func GetShowDetailOfSubscriptionResponseStatusEnum 

func GetShowDetailOfSubscriptionResponseStatusEnum() ShowDetailOfSubscriptionResponseStatusEnum

type ShowDetailOfSubscriptionResponseType 

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

func (ShowDetailOfSubscriptionResponseType) MarshalJSON 

func (c ShowDetailOfSubscriptionResponseType) MarshalJSON() ([]byte, error)

func (*ShowDetailOfSubscriptionResponseType) UnmarshalJSON 

func (c *ShowDetailOfSubscriptionResponseType) UnmarshalJSON(b []byte) error

func (ShowDetailOfSubscriptionResponseType) Value 

func (c ShowDetailOfSubscriptionResponseType) Value() string

type ShowDetailOfSubscriptionResponseTypeEnum 

type ShowDetailOfSubscriptionResponseTypeEnum struct {
	EVENT     ShowDetailOfSubscriptionResponseType
	SCHEDULED ShowDetailOfSubscriptionResponseType
}

func GetShowDetailOfSubscriptionResponseTypeEnum 

func GetShowDetailOfSubscriptionResponseTypeEnum() ShowDetailOfSubscriptionResponseTypeEnum

type ShowDetailOfSubscriptionTargetRequest 

type ShowDetailOfSubscriptionTargetRequest struct {

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

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

ShowDetailOfSubscriptionTargetRequest Request Object

func (ShowDetailOfSubscriptionTargetRequest) String 

func (o ShowDetailOfSubscriptionTargetRequest) String() string

type ShowDetailOfSubscriptionTargetResponse 

type ShowDetailOfSubscriptionTargetResponse struct {

	// 订阅目标ID
	Id *string `json:"id,omitempty"`

	// 订阅的事件目标名称
	Name *string `json:"name,omitempty"`

	// 订阅的事件目标的提供方类型
	ProviderType *string `json:"provider_type,omitempty"`

	// 订阅的事件目标使用的目标链接ID
	ConnectionId *string `json:"connection_id,omitempty"`

	// 订阅的事件目标参数列表
	Detail *interface{} `json:"detail,omitempty"`

	Transform *TransForm `json:"transform,omitempty"`

	DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime    *string `json:"updated_time,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowDetailOfSubscriptionTargetResponse Response Object

func (ShowDetailOfSubscriptionTargetResponse) String 

func (o ShowDetailOfSubscriptionTargetResponse) String() string

type ShowEventStreamingRequest added in v0.1.42 

type ShowEventStreamingRequest struct {

	// 事件流ID
	EventstreamingId string `json:"eventstreaming_id"`
}

ShowEventStreamingRequest Request Object

func (ShowEventStreamingRequest) String added in v0.1.42 

func (o ShowEventStreamingRequest) String() string

type ShowEventStreamingResponse added in v0.1.42 

type ShowEventStreamingResponse struct {

	// 事件流名称，租户下唯一，由字母、数字、点、下划线和中划线组成，必须字母或数字开头
	Name string `json:"name"`

	// 事件流描述
	Description *string `json:"description,omitempty"`

	Source *EventStreamingSource `json:"source"`

	Sink *EventStreamingSink `json:"sink"`

	RuleConfig *EventStreamingCreateReqRuleConfig `json:"rule_config,omitempty"`

	Option *RunOption `json:"option,omitempty"`

	// 事件流状态
	Status *ShowEventStreamingResponseStatus `json:"status,omitempty"`

	// 事件流ID
	Id *string `json:"id,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ShowEventStreamingResponse Response Object

func (ShowEventStreamingResponse) String added in v0.1.42 

func (o ShowEventStreamingResponse) String() string

type ShowEventStreamingResponseStatus added in v0.1.42 

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

func (ShowEventStreamingResponseStatus) MarshalJSON added in v0.1.42 

func (c ShowEventStreamingResponseStatus) MarshalJSON() ([]byte, error)

func (*ShowEventStreamingResponseStatus) UnmarshalJSON added in v0.1.42 

func (c *ShowEventStreamingResponseStatus) UnmarshalJSON(b []byte) error

func (ShowEventStreamingResponseStatus) Value added in v0.1.42 

func (c ShowEventStreamingResponseStatus) Value() string

type ShowEventStreamingResponseStatusEnum added in v0.1.42 

type ShowEventStreamingResponseStatusEnum struct {
	CREATED ShowEventStreamingResponseStatus
	RUNNING ShowEventStreamingResponseStatus
	ERROR   ShowEventStreamingResponseStatus
	STOPPED ShowEventStreamingResponseStatus
}

func GetShowEventStreamingResponseStatusEnum added in v0.1.42 

func GetShowEventStreamingResponseStatusEnum() ShowEventStreamingResponseStatusEnum

type SinkFgParameters added in v0.1.42 

type SinkFgParameters struct {

	// 函数执行方式,同步/异步
	InvokeType *SinkFgParametersInvokeType `json:"invoke_type,omitempty"`

	// 函数链接
	Urn *string `json:"urn,omitempty"`

	// 租户委托
	Agency *string `json:"agency,omitempty"`
}

func (SinkFgParameters) String added in v0.1.42 

func (o SinkFgParameters) String() string

type SinkFgParametersInvokeType added in v0.1.42 

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

func (SinkFgParametersInvokeType) MarshalJSON added in v0.1.42 

func (c SinkFgParametersInvokeType) MarshalJSON() ([]byte, error)

func (*SinkFgParametersInvokeType) UnmarshalJSON added in v0.1.42 

func (c *SinkFgParametersInvokeType) UnmarshalJSON(b []byte) error

func (SinkFgParametersInvokeType) Value added in v0.1.42 

func (c SinkFgParametersInvokeType) Value() string

type SinkFgParametersInvokeTypeEnum added in v0.1.42 

type SinkFgParametersInvokeTypeEnum struct {
	SYNCASYNC SinkFgParametersInvokeType
}

func GetSinkFgParametersInvokeTypeEnum added in v0.1.42 

func GetSinkFgParametersInvokeTypeEnum() SinkFgParametersInvokeTypeEnum

type SinkKafkaParameters added in v0.1.71 

type SinkKafkaParameters struct {

	// topic名称
	Topic string `json:"topic"`

	// key的转换规则
	KeyTransform *[]TransForm `json:"keyTransform,omitempty"`

	// 目标连接id
	ConnectionId string `json:"connectionId"`
}

func (SinkKafkaParameters) String added in v0.1.71 

func (o SinkKafkaParameters) String() string

type SmnTargetDetail added in v0.1.52 

type SmnTargetDetail struct {

	// 主题urn
	Urn string `json:"urn"`

	// 委托名称
	AgencyName string `json:"agency_name"`

	SubjectTransform *SmnTargetDetailSubjectTransform `json:"subject_transform,omitempty"`
}

SmnTargetDetail 订阅的SMN事件目标参数列表，该字段序列化后总长度不超过1024字节

func (SmnTargetDetail) String added in v0.1.52 

func (o SmnTargetDetail) String() string

type SmnTargetDetailSubjectTransform added in v0.1.52 

type SmnTargetDetailSubjectTransform struct {

	// 标题规则类型
	Type SmnTargetDetailSubjectTransformType `json:"type"`

	// 标题规则
	Value string `json:"value"`

	// 标题规则模板，键值规则为VARIABLE时必填
	Template *string `json:"template,omitempty"`
}

SmnTargetDetailSubjectTransform 标题规则

func (SmnTargetDetailSubjectTransform) String added in v0.1.52 

func (o SmnTargetDetailSubjectTransform) String() string

type SmnTargetDetailSubjectTransformType added in v0.1.52 

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

func (SmnTargetDetailSubjectTransformType) MarshalJSON added in v0.1.52 

func (c SmnTargetDetailSubjectTransformType) MarshalJSON() ([]byte, error)

func (*SmnTargetDetailSubjectTransformType) UnmarshalJSON added in v0.1.52 

func (c *SmnTargetDetailSubjectTransformType) UnmarshalJSON(b []byte) error

func (SmnTargetDetailSubjectTransformType) Value added in v0.1.52 

func (c SmnTargetDetailSubjectTransformType) Value() string

type SmnTargetDetailSubjectTransformTypeEnum added in v0.1.52 

type SmnTargetDetailSubjectTransformTypeEnum struct {
	VARIABLE SmnTargetDetailSubjectTransformType
	CONSTANT SmnTargetDetailSubjectTransformType
}

func GetSmnTargetDetailSubjectTransformTypeEnum added in v0.1.52 

func GetSmnTargetDetailSubjectTransformTypeEnum() SmnTargetDetailSubjectTransformTypeEnum

type SourceKafkaMqParameters added in v0.1.42 

type SourceKafkaMqParameters struct {

	// kafka连接地址
	Addr *string `json:"addr,omitempty"`

	// kafka消费组
	Group string `json:"group"`

	// kafka实例名称
	InstanceName *string `json:"instance_name,omitempty"`

	// 安全协议
	SecurityProtocol *string `json:"security_protocol,omitempty"`

	// kafka实例ID
	InstanceId *string `json:"instance_id,omitempty"`

	// kafka topic名称
	Topic string `json:"topic"`

	// 消费点位
	SeekTo *SourceKafkaMqParametersSeekTo `json:"seek_to,omitempty"`

	// SASL_SSL是否开启
	EnableSaslSsl *bool `json:"enable_sasl_ssl,omitempty"`

	// SASL认证机制
	SaslMechanism *SourceKafkaMqParametersSaslMechanism `json:"sasl_mechanism,omitempty"`

	// SASL证书地址，配置的obs地址
	SslCertificateUrl *string `json:"ssl_certificate_url,omitempty"`

	// SASL证书密码
	SslCertificatePwd *string `json:"ssl_certificate_pwd,omitempty"`

	// 用户名
	UserName *string `json:"user_name,omitempty"`

	// 用户密码
	Password *string `json:"password,omitempty"`
}

func (SourceKafkaMqParameters) String added in v0.1.42 

func (o SourceKafkaMqParameters) String() string

type SourceKafkaMqParametersSaslMechanism added in v0.1.52 

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

func (SourceKafkaMqParametersSaslMechanism) MarshalJSON added in v0.1.52 

func (c SourceKafkaMqParametersSaslMechanism) MarshalJSON() ([]byte, error)

func (*SourceKafkaMqParametersSaslMechanism) UnmarshalJSON added in v0.1.52 

func (c *SourceKafkaMqParametersSaslMechanism) UnmarshalJSON(b []byte) error

func (SourceKafkaMqParametersSaslMechanism) Value added in v0.1.52 

func (c SourceKafkaMqParametersSaslMechanism) Value() string

type SourceKafkaMqParametersSaslMechanismEnum added in v0.1.52 

type SourceKafkaMqParametersSaslMechanismEnum struct {
	SCRAM_SHA_512 SourceKafkaMqParametersSaslMechanism
	PLAIN         SourceKafkaMqParametersSaslMechanism
}

func GetSourceKafkaMqParametersSaslMechanismEnum added in v0.1.52 

func GetSourceKafkaMqParametersSaslMechanismEnum() SourceKafkaMqParametersSaslMechanismEnum

type SourceKafkaMqParametersSeekTo added in v0.1.52 

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

func (SourceKafkaMqParametersSeekTo) MarshalJSON added in v0.1.52 

func (c SourceKafkaMqParametersSeekTo) MarshalJSON() ([]byte, error)

func (*SourceKafkaMqParametersSeekTo) UnmarshalJSON added in v0.1.52 

func (c *SourceKafkaMqParametersSeekTo) UnmarshalJSON(b []byte) error

func (SourceKafkaMqParametersSeekTo) Value added in v0.1.52 

func (c SourceKafkaMqParametersSeekTo) Value() string

type SourceKafkaMqParametersSeekToEnum added in v0.1.52 

type SourceKafkaMqParametersSeekToEnum struct {
	LATEST   SourceKafkaMqParametersSeekTo
	EARLIEST SourceKafkaMqParametersSeekTo
}

func GetSourceKafkaMqParametersSeekToEnum added in v0.1.52 

func GetSourceKafkaMqParametersSeekToEnum() SourceKafkaMqParametersSeekToEnum

type SourceMobileMqParameters added in v0.1.71 

type SourceMobileMqParameters struct {

	// 消费组id
	GroupId string `json:"group_id"`

	// 实例id
	InstanceId string `json:"instance_id"`

	// topic
	Topic string `json:"topic"`

	// 标签
	Tag *string `json:"tag,omitempty"`

	// 鉴权认证
	AuthenticationRequired *bool `json:"authentication_required,omitempty"`

	// 保存消息轨迹
	MsgTraceSwitch *bool `json:"msg_trace_switch,omitempty"`

	// AccessKey
	AccessKey *string `json:"access_key,omitempty"`

	// SecretKey
	SecretKey *string `json:"secret_key,omitempty"`

	// 订阅方式
	MessageModel SourceMobileMqParametersMessageModel `json:"message_model"`

	// 接入点类型
	AddrType SourceMobileMqParametersAddrType `json:"addr_type"`

	// 地址
	Addr string `json:"addr"`

	// 依赖SDK
	SdkUrl string `json:"sdk_url"`

	// 消费超时时间
	ConsumeTimeout int32 `json:"consume_timeout"`

	// 消息类型
	MessageType SourceMobileMqParametersMessageType `json:"message_type"`

	// 失败重试的等待时间
	SuspendTime *int32 `json:"suspend_time,omitempty"`

	// 最大重试次数
	MaxReconsumerTimes *int32 `json:"max_reconsumer_times,omitempty"`

	// 消费线程数
	ConsumerThreadNums *int32 `json:"consumer_thread_nums,omitempty"`

	// 批量消费最大消息数
	ConsumerBatchMaxSize *int32 `json:"consumer_batch_max_size,omitempty"`

	// 批量消费最大等待时长，单位：秒
	ConsumerMaxWait *int32 `json:"consumer_max_wait,omitempty"`

	// 虚拟私有云
	VpcId *string `json:"vpc_id,omitempty"`

	// 子网
	SubnetId *string `json:"subnet_id,omitempty"`
}

SourceMobileMqParameters 事件流移动云rockectMq事件源参数

func (SourceMobileMqParameters) String added in v0.1.71 

func (o SourceMobileMqParameters) String() string

type SourceMobileMqParametersAddrType added in v0.1.71 

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

func (SourceMobileMqParametersAddrType) MarshalJSON added in v0.1.71 

func (c SourceMobileMqParametersAddrType) MarshalJSON() ([]byte, error)

func (*SourceMobileMqParametersAddrType) UnmarshalJSON added in v0.1.71 

func (c *SourceMobileMqParametersAddrType) UnmarshalJSON(b []byte) error

func (SourceMobileMqParametersAddrType) Value added in v0.1.71 

func (c SourceMobileMqParametersAddrType) Value() string

type SourceMobileMqParametersAddrTypeEnum added in v0.1.71 

type SourceMobileMqParametersAddrTypeEnum struct {
	PUBLIC  SourceMobileMqParametersAddrType
	PRIVATE SourceMobileMqParametersAddrType
}

func GetSourceMobileMqParametersAddrTypeEnum added in v0.1.71 

func GetSourceMobileMqParametersAddrTypeEnum() SourceMobileMqParametersAddrTypeEnum

type SourceMobileMqParametersMessageModel added in v0.1.71 

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

func (SourceMobileMqParametersMessageModel) MarshalJSON added in v0.1.71 

func (c SourceMobileMqParametersMessageModel) MarshalJSON() ([]byte, error)

func (*SourceMobileMqParametersMessageModel) UnmarshalJSON added in v0.1.71 

func (c *SourceMobileMqParametersMessageModel) UnmarshalJSON(b []byte) error

func (SourceMobileMqParametersMessageModel) Value added in v0.1.71 

func (c SourceMobileMqParametersMessageModel) Value() string

type SourceMobileMqParametersMessageModelEnum added in v0.1.71 

type SourceMobileMqParametersMessageModelEnum struct {
	CLUSTERING   SourceMobileMqParametersMessageModel
	BROADCASTING SourceMobileMqParametersMessageModel
}

func GetSourceMobileMqParametersMessageModelEnum added in v0.1.71 

func GetSourceMobileMqParametersMessageModelEnum() SourceMobileMqParametersMessageModelEnum

type SourceMobileMqParametersMessageType added in v0.1.71 

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

func (SourceMobileMqParametersMessageType) MarshalJSON added in v0.1.71 

func (c SourceMobileMqParametersMessageType) MarshalJSON() ([]byte, error)

func (*SourceMobileMqParametersMessageType) UnmarshalJSON added in v0.1.71 

func (c *SourceMobileMqParametersMessageType) UnmarshalJSON(b []byte) error

func (SourceMobileMqParametersMessageType) Value added in v0.1.71 

func (c SourceMobileMqParametersMessageType) Value() string

type SourceMobileMqParametersMessageTypeEnum added in v0.1.71 

type SourceMobileMqParametersMessageTypeEnum struct {
	NORMAL SourceMobileMqParametersMessageType
}

func GetSourceMobileMqParametersMessageTypeEnum added in v0.1.71 

func GetSourceMobileMqParametersMessageTypeEnum() SourceMobileMqParametersMessageTypeEnum

type SubscriptionCreateReq 

type SubscriptionCreateReq struct {

	// 订阅名称，租户下唯一，由字母、数字、点、下划线和中划线组成，必须字母或数字开头
	Name string `json:"name"`

	// 订阅描述
	Description *string `json:"description,omitempty"`

	// 所属事件通道ID
	ChannelId string `json:"channel_id"`

	// 订阅的事件源列表， 当前仅支持订阅一个事件源
	Sources []SubscriptionSource `json:"sources"`

	// 事件目标列表，至少订阅一个事件目标
	Targets []SubscriptionTarget `json:"targets"`
}

func (SubscriptionCreateReq) String 

func (o SubscriptionCreateReq) String() string

type SubscriptionInfo 

type SubscriptionInfo struct {

	// 订阅ID
	Id *string `json:"id,omitempty"`

	// 订阅名称
	Name *string `json:"name,omitempty"`

	// 订阅描述
	Description *string `json:"description,omitempty"`

	// 类型
	Type *SubscriptionInfoType `json:"type,omitempty"`

	// 状态
	Status *SubscriptionInfoStatus `json:"status,omitempty"`

	// 通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 标签信息
	Used *[]SubscriptionUsedInfo `json:"used,omitempty"`

	// 订阅源列表
	Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"`

	// 订阅目标列表
	Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`
}

func (SubscriptionInfo) String 

func (o SubscriptionInfo) String() string

type SubscriptionInfoStatus 

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

func (SubscriptionInfoStatus) MarshalJSON 

func (c SubscriptionInfoStatus) MarshalJSON() ([]byte, error)

func (*SubscriptionInfoStatus) UnmarshalJSON 

func (c *SubscriptionInfoStatus) UnmarshalJSON(b []byte) error

func (SubscriptionInfoStatus) Value 

func (c SubscriptionInfoStatus) Value() string

type SubscriptionInfoStatusEnum 

type SubscriptionInfoStatusEnum struct {
	CREATED  SubscriptionInfoStatus
	ENABLED  SubscriptionInfoStatus
	DISABLED SubscriptionInfoStatus
	FROZEN   SubscriptionInfoStatus
	ERROR    SubscriptionInfoStatus
}

func GetSubscriptionInfoStatusEnum 

func GetSubscriptionInfoStatusEnum() SubscriptionInfoStatusEnum

type SubscriptionInfoType 

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

func (SubscriptionInfoType) MarshalJSON 

func (c SubscriptionInfoType) MarshalJSON() ([]byte, error)

func (*SubscriptionInfoType) UnmarshalJSON 

func (c *SubscriptionInfoType) UnmarshalJSON(b []byte) error

func (SubscriptionInfoType) Value 

func (c SubscriptionInfoType) Value() string

type SubscriptionInfoTypeEnum 

type SubscriptionInfoTypeEnum struct {
	EVENT     SubscriptionInfoType
	SCHEDULED SubscriptionInfoType
}

func GetSubscriptionInfoTypeEnum 

func GetSubscriptionInfoTypeEnum() SubscriptionInfoTypeEnum

type SubscriptionOperateReq 

type SubscriptionOperateReq struct {

	// 订阅对象ID列表，单次批量操作最多支持10个订阅
	SubscriptionIds *[]string `json:"subscription_ids,omitempty"`

	// 操作类型
	Operation *SubscriptionOperateReqOperation `json:"operation,omitempty"`
}

SubscriptionOperateReq 订阅批量操作请求

func (SubscriptionOperateReq) String 

func (o SubscriptionOperateReq) String() string

type SubscriptionOperateReqOperation 

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

func (SubscriptionOperateReqOperation) MarshalJSON 

func (c SubscriptionOperateReqOperation) MarshalJSON() ([]byte, error)

func (*SubscriptionOperateReqOperation) UnmarshalJSON 

func (c *SubscriptionOperateReqOperation) UnmarshalJSON(b []byte) error

func (SubscriptionOperateReqOperation) Value 

func (c SubscriptionOperateReqOperation) Value() string

type SubscriptionOperateReqOperationEnum 

type SubscriptionOperateReqOperationEnum struct {
	DISABLE SubscriptionOperateReqOperation
	ENABLE  SubscriptionOperateReqOperation
}

func GetSubscriptionOperateReqOperationEnum 

func GetSubscriptionOperateReqOperationEnum() SubscriptionOperateReqOperationEnum

type SubscriptionOperateRespEvents 

type SubscriptionOperateRespEvents struct {

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

	// 失败的原因
	ErrorMsg *string `json:"error_msg,omitempty"`

	// 订阅ID
	SubscriptionId *string `json:"subscription_id,omitempty"`
}

func (SubscriptionOperateRespEvents) String 

func (o SubscriptionOperateRespEvents) String() string

type SubscriptionSource 

type SubscriptionSource struct {

	// 订阅源ID，需保证全局唯一。指定ID的订阅源存在时则进行更新，否则进行创建；未指定时由系统自动生成。由小写字母、数字、中划线组成，必须字母或数字开头。
	Id *string `json:"id,omitempty"`

	// 订阅的事件源名称
	Name string `json:"name"`

	// 订阅的事件源的提供方类型
	ProviderType SubscriptionSourceProviderType `json:"provider_type"`

	// 订阅的事件源参数列表, 该字段序列化后总长度不超过1024字节
	Detail *interface{} `json:"detail,omitempty"`

	// 订阅事件源的匹配过滤规则, 该字段序列化后总长度不超过2048字节
	Filter *interface{} `json:"filter"`
}

func (SubscriptionSource) String 

func (o SubscriptionSource) String() string

type SubscriptionSourceInfo 

type SubscriptionSourceInfo struct {

	// 订阅源ID
	Id *string `json:"id,omitempty"`

	// 订阅的事件源名称
	Name *string `json:"name,omitempty"`

	// 订阅的事件源的提供方类型
	ProviderType *string `json:"provider_type,omitempty"`

	// 订阅的事件源参数列表
	Detail *interface{} `json:"detail,omitempty"`

	// 订阅事件源的匹配过滤规则
	Filter *interface{} `json:"filter,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`
}

func (SubscriptionSourceInfo) String 

func (o SubscriptionSourceInfo) String() string

type SubscriptionSourceProviderType 

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

func (SubscriptionSourceProviderType) MarshalJSON 

func (c SubscriptionSourceProviderType) MarshalJSON() ([]byte, error)

func (*SubscriptionSourceProviderType) UnmarshalJSON 

func (c *SubscriptionSourceProviderType) UnmarshalJSON(b []byte) error

func (SubscriptionSourceProviderType) Value 

func (c SubscriptionSourceProviderType) Value() string

type SubscriptionSourceProviderTypeEnum 

type SubscriptionSourceProviderTypeEnum struct {
	CUSTOM   SubscriptionSourceProviderType
	OFFICIAL SubscriptionSourceProviderType
	PARTNER  SubscriptionSourceProviderType
}

func GetSubscriptionSourceProviderTypeEnum 

func GetSubscriptionSourceProviderTypeEnum() SubscriptionSourceProviderTypeEnum

type SubscriptionTarget 

type SubscriptionTarget struct {

	// 订阅目标ID，需保证全局唯一，由小写字母、数字、中划线组成，必须字母或数字开头。 更新订阅场景时，指定ID的订阅目标存在时则进行更新，否则进行创建； 创建订阅目标场景时，指定ID作为待创建的订阅目标对象ID，未指定时由系统自动生成。 更新订阅目标时，此字段忽略；
	Id *string `json:"id,omitempty"`

	// 订阅的事件目标名称
	Name string `json:"name"`

	// 订阅的事件目标的提供方类型
	ProviderType SubscriptionTargetProviderType `json:"provider_type"`

	// 订阅的事件目标使用的目标链接ID
	ConnectionId *string `json:"connection_id,omitempty"`

	// 订阅的事件目标参数列表，该字段序列化后总长度不超过1024字节，函数(urn、invoke_type、agency_name)、函数流（workflow_id、agency_name）、webhook（url）订阅目标必填，其中函数、函数流委托名称必填
	Detail *interface{} `json:"detail,omitempty"`

	KafkaDetail *KafkaTargetDetail `json:"kafka_detail,omitempty"`

	SmnDetail *SmnTargetDetail `json:"smn_detail,omitempty"`

	EgDetail *EgTargetDetail `json:"eg_detail,omitempty"`

	Transform *TransForm `json:"transform"`

	DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"`
}

func (SubscriptionTarget) String 

func (o SubscriptionTarget) String() string

type SubscriptionTargetInfo 

type SubscriptionTargetInfo struct {

	// 订阅目标ID
	Id *string `json:"id,omitempty"`

	// 订阅的事件目标名称
	Name *string `json:"name,omitempty"`

	// 订阅的事件目标的提供方类型
	ProviderType *string `json:"provider_type,omitempty"`

	// 订阅的事件目标使用的目标链接ID
	ConnectionId *string `json:"connection_id,omitempty"`

	// 订阅的事件目标参数列表
	Detail *interface{} `json:"detail,omitempty"`

	Transform *TransForm `json:"transform,omitempty"`

	DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`
}

func (SubscriptionTargetInfo) String 

func (o SubscriptionTargetInfo) String() string

type SubscriptionTargetProviderType 

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

func (SubscriptionTargetProviderType) MarshalJSON 

func (c SubscriptionTargetProviderType) MarshalJSON() ([]byte, error)

func (*SubscriptionTargetProviderType) UnmarshalJSON 

func (c *SubscriptionTargetProviderType) UnmarshalJSON(b []byte) error

func (SubscriptionTargetProviderType) Value 

func (c SubscriptionTargetProviderType) Value() string

type SubscriptionTargetProviderTypeEnum 

type SubscriptionTargetProviderTypeEnum struct {
	CUSTOM   SubscriptionTargetProviderType
	OFFICIAL SubscriptionTargetProviderType
}

func GetSubscriptionTargetProviderTypeEnum 

func GetSubscriptionTargetProviderTypeEnum() SubscriptionTargetProviderTypeEnum

type SubscriptionUpdateReq 

type SubscriptionUpdateReq struct {

	// 订阅描述
	Description *string `json:"description,omitempty"`

	// 订阅事件源列表，字段存在则代表全量更新订阅源
	Sources *[]SubscriptionSource `json:"sources,omitempty"`

	// 订阅事件目标列表，字段存在则代表全量更新订阅目标
	Targets *[]SubscriptionTarget `json:"targets,omitempty"`
}

SubscriptionUpdateReq 更新订阅，全量更新订阅源和目标

func (SubscriptionUpdateReq) String 

func (o SubscriptionUpdateReq) String() string

type SubscriptionUsedInfo added in v0.1.28 

type SubscriptionUsedInfo struct {

	// 关联资源ID
	ResourceId *string `json:"resource_id,omitempty"`

	// 管理租户账号
	Owner *string `json:"owner,omitempty"`

	// 描述
	Description *string `json:"description,omitempty"`
}

func (SubscriptionUsedInfo) String added in v0.1.28 

func (o SubscriptionUsedInfo) String() string

type TransForm added in v0.1.28 

type TransForm struct {

	// 转换规则类型
	Type TransFormType `json:"type"`

	// 常量类型规则时，字段为常量内容定义； 变量类型规则时，为变量定义，内容必须为JsonObject字符串。 变量最多支持100个，且不支持嵌套结构定义； 变量名由字母、数字、点、下划线和中划线组成，必须字母或数字开头不能以HC.开头，长度不超过64个字符； 变量值表达式支持常量或JsonPath表达式，字符串长度不超过1024个字符。
	Value *string `json:"value,omitempty"`

	// 变量类型规则时，规则内容的模板定义，支持对已定义变量的引用。
	Template *string `json:"template,omitempty"`
}

TransForm 订阅的事件目标转换规则

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

	// 企业项目id
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

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

	// 企业项目id
	EpsId *string `json:"eps_id,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateChannelResponse Response Object

func (UpdateChannelResponse) String 

func (o UpdateChannelResponse) String() string

type UpdateChannelResponseProviderType 

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

func (UpdateChannelResponseProviderType) MarshalJSON 

func (c UpdateChannelResponseProviderType) MarshalJSON() ([]byte, error)

func (*UpdateChannelResponseProviderType) UnmarshalJSON 

func (c *UpdateChannelResponseProviderType) UnmarshalJSON(b []byte) error

func (UpdateChannelResponseProviderType) Value 

func (c UpdateChannelResponseProviderType) Value() string

type UpdateChannelResponseProviderTypeEnum 

type UpdateChannelResponseProviderTypeEnum struct {
	OFFICIAL UpdateChannelResponseProviderType
	CUSTOM   UpdateChannelResponseProviderType
	PARTNER  UpdateChannelResponseProviderType
}

func GetUpdateChannelResponseProviderTypeEnum 

func GetUpdateChannelResponseProviderTypeEnum() UpdateChannelResponseProviderTypeEnum

type UpdateConnectionRequest added in v0.1.3 

type UpdateConnectionRequest struct {

	// 指定查询的目标连接ID
	ConnectionId string `json:"connection_id"`

	Body *ConnectionUpdateReq `json:"body,omitempty"`
}

UpdateConnectionRequest Request Object

func (UpdateConnectionRequest) String added in v0.1.3 

func (o UpdateConnectionRequest) String() string

type UpdateConnectionResponse added in v0.1.3 

type UpdateConnectionResponse struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 目标连接名称，租户下唯一，由小写字母、数字、点、下划线和中划线组成，必须以字母或数字开头，不能为default
	Name *string `json:"name,omitempty"`

	// 目标连接描述
	Description *string `json:"description,omitempty"`

	// 目标连接状态
	Status *UpdateConnectionResponseStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	// 待连接的VPC ID
	VpcId *string `json:"vpc_id,omitempty"`

	// 待连接的子网ID
	SubnetId *string `json:"subnet_id,omitempty"`

	// 私网目标连接使用的用户委托名称
	Agency *string `json:"agency,omitempty"`

	Flavor *ConnectionInfoFlavor `json:"flavor,omitempty"`

	Type *ConnectionType `json:"type,omitempty"`

	KafkaDetail *KafkaConnectionDetail `json:"kafka_detail,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateConnectionResponse Response Object

func (UpdateConnectionResponse) String added in v0.1.3 

func (o UpdateConnectionResponse) String() string

type UpdateConnectionResponseStatus added in v0.1.3 

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

func (UpdateConnectionResponseStatus) MarshalJSON added in v0.1.3 

func (c UpdateConnectionResponseStatus) MarshalJSON() ([]byte, error)

func (*UpdateConnectionResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *UpdateConnectionResponseStatus) UnmarshalJSON(b []byte) error

func (UpdateConnectionResponseStatus) Value added in v0.1.3 

func (c UpdateConnectionResponseStatus) Value() string

type UpdateConnectionResponseStatusEnum added in v0.1.3 

type UpdateConnectionResponseStatusEnum struct {
	CREATING      UpdateConnectionResponseStatus
	CREATED       UpdateConnectionResponseStatus
	CREATE_FAILED UpdateConnectionResponseStatus
}

func GetUpdateConnectionResponseStatusEnum added in v0.1.3 

func GetUpdateConnectionResponseStatusEnum() UpdateConnectionResponseStatusEnum

type UpdateEndpointRequest added in v0.1.3 

type UpdateEndpointRequest struct {

	// 指定查询访问端点的id
	EndpointId string `json:"endpoint_id"`

	Body *EndpointUpdateReq `json:"body,omitempty"`
}

UpdateEndpointRequest Request Object

func (UpdateEndpointRequest) String added in v0.1.3 

func (o UpdateEndpointRequest) String() string

type UpdateEndpointResponse added in v0.1.3 

type UpdateEndpointResponse struct {

	// 访问端点ID
	Id *string `json:"id,omitempty"`

	// 用户指定的访问端点名称
	Name *string `json:"name,omitempty"`

	// 访问端点所在的VPC的ID
	VpcId *string `json:"vpc_id,omitempty"`

	// 访问端点所在的子网的ID
	SubnetId *string `json:"subnet_id,omitempty"`

	// 访问域名
	Domain *string `json:"domain,omitempty"`

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

	// 访问端点状态
	Status *UpdateEndpointResponseStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	// 访问端点类型
	Type *UpdateEndpointResponseType `json:"type,omitempty"`

	// 是否可更新
	Scalable *bool `json:"scalable,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	// 访问端点终端节点列表
	Endpoints      *[]EndpointConnection `json:"endpoints,omitempty"`
	HttpStatusCode int                   `json:"-"`
}

UpdateEndpointResponse Response Object

func (UpdateEndpointResponse) String added in v0.1.3 

func (o UpdateEndpointResponse) String() string

type UpdateEndpointResponseStatus added in v0.1.3 

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

func (UpdateEndpointResponseStatus) MarshalJSON added in v0.1.3 

func (c UpdateEndpointResponseStatus) MarshalJSON() ([]byte, error)

func (*UpdateEndpointResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *UpdateEndpointResponseStatus) UnmarshalJSON(b []byte) error

func (UpdateEndpointResponseStatus) Value added in v0.1.3 

func (c UpdateEndpointResponseStatus) Value() string

type UpdateEndpointResponseStatusEnum added in v0.1.3 

type UpdateEndpointResponseStatusEnum struct {
	CREATED       UpdateEndpointResponseStatus
	CREATING      UpdateEndpointResponseStatus
	CREATE_FAILED UpdateEndpointResponseStatus
	DELETE_FAILED UpdateEndpointResponseStatus
}

func GetUpdateEndpointResponseStatusEnum added in v0.1.3 

func GetUpdateEndpointResponseStatusEnum() UpdateEndpointResponseStatusEnum

type UpdateEndpointResponseType added in v0.1.3 

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

func (UpdateEndpointResponseType) MarshalJSON added in v0.1.3 

func (c UpdateEndpointResponseType) MarshalJSON() ([]byte, error)

func (*UpdateEndpointResponseType) UnmarshalJSON added in v0.1.3 

func (c *UpdateEndpointResponseType) UnmarshalJSON(b []byte) error

func (UpdateEndpointResponseType) Value added in v0.1.3 

func (c UpdateEndpointResponseType) Value() string

type UpdateEndpointResponseTypeEnum added in v0.1.3 

type UpdateEndpointResponseTypeEnum struct {
	PRIVATE UpdateEndpointResponseType
	PUBLIC  UpdateEndpointResponseType
}

func GetUpdateEndpointResponseTypeEnum added in v0.1.3 

func GetUpdateEndpointResponseTypeEnum() UpdateEndpointResponseTypeEnum

type UpdateEventSourceRequest 

type UpdateEventSourceRequest struct {

	// 指定查询的事件源ID
	SourceId string `json:"source_id"`

	Body *CustomizeSourceUpdateReq `json:"body,omitempty"`
}

UpdateEventSourceRequest Request Object

func (UpdateEventSourceRequest) String 

func (o UpdateEventSourceRequest) String() string

type UpdateEventSourceResponse 

type UpdateEventSourceResponse struct {

	// 事件源ID
	Id *string `json:"id,omitempty"`

	// 事件源名称
	Name *string `json:"name,omitempty"`

	// 事件源名称展示
	Label *string `json:"label,omitempty"`

	// 事件源描述
	Description *string `json:"description,omitempty"`

	// 事件源提供方类型，OFFICIAL：官方云服务事件源；CUSTOM：用户创建的自定义事件源；PARTNER：伙伴事件源
	ProviderType *UpdateEventSourceResponseProviderType `json:"provider_type,omitempty"`

	// 事件源提供的事件类型列表，只有官方云服务事件源提供事件类型
	EventTypes *[]CustomizeSourceInfoEventTypes `json:"event_types,omitempty"`

	// 创建UTC时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新UTC时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	// 事件源归属的事件通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 事件源归属的事件通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 事件源类型
	Type *string `json:"type,omitempty"`

	// json格式封装消息实例链接信息：如RabbitMQ实例的instance_id字段、虚拟主机vhost字段、队列queue字段、用户名、密码等
	Detail *interface{} `json:"detail,omitempty"`

	// 自定义事件源状态
	Status *UpdateEventSourceResponseStatus `json:"status,omitempty"`

	ErrorInfo *ErrorInfo `json:"error_info,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateEventSourceResponse Response Object

func (UpdateEventSourceResponse) String 

func (o UpdateEventSourceResponse) String() string

type UpdateEventSourceResponseProviderType 

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

func (UpdateEventSourceResponseProviderType) MarshalJSON 

func (c UpdateEventSourceResponseProviderType) MarshalJSON() ([]byte, error)

func (*UpdateEventSourceResponseProviderType) UnmarshalJSON 

func (c *UpdateEventSourceResponseProviderType) UnmarshalJSON(b []byte) error

func (UpdateEventSourceResponseProviderType) Value 

func (c UpdateEventSourceResponseProviderType) Value() string

type UpdateEventSourceResponseProviderTypeEnum 

type UpdateEventSourceResponseProviderTypeEnum struct {
	OFFICIAL UpdateEventSourceResponseProviderType
	CUSTOM   UpdateEventSourceResponseProviderType
	PARTNER  UpdateEventSourceResponseProviderType
}

func GetUpdateEventSourceResponseProviderTypeEnum 

func GetUpdateEventSourceResponseProviderTypeEnum() UpdateEventSourceResponseProviderTypeEnum

type UpdateEventSourceResponseStatus added in v0.1.3 

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

func (UpdateEventSourceResponseStatus) MarshalJSON added in v0.1.3 

func (c UpdateEventSourceResponseStatus) MarshalJSON() ([]byte, error)

func (*UpdateEventSourceResponseStatus) UnmarshalJSON added in v0.1.3 

func (c *UpdateEventSourceResponseStatus) UnmarshalJSON(b []byte) error

func (UpdateEventSourceResponseStatus) Value added in v0.1.3 

func (c UpdateEventSourceResponseStatus) Value() string

type UpdateEventSourceResponseStatusEnum added in v0.1.3 

type UpdateEventSourceResponseStatusEnum struct {
	CREATE_FAILED UpdateEventSourceResponseStatus
	RUNNING       UpdateEventSourceResponseStatus
	ERROR         UpdateEventSourceResponseStatus
}

func GetUpdateEventSourceResponseStatusEnum added in v0.1.3 

func GetUpdateEventSourceResponseStatusEnum() UpdateEventSourceResponseStatusEnum

type UpdateEventStreamingRequest added in v0.1.42 

type UpdateEventStreamingRequest struct {

	// 事件流ID
	EventstreamingId string `json:"eventstreaming_id"`

	Body *EventStreamingUpdateReq `json:"body,omitempty"`
}

UpdateEventStreamingRequest Request Object

func (UpdateEventStreamingRequest) String added in v0.1.42 

func (o UpdateEventStreamingRequest) String() string

type UpdateEventStreamingResponse added in v0.1.42 

type UpdateEventStreamingResponse struct {

	// 事件流ID
	EventStreamingID *string `json:"eventStreamingID,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateEventStreamingResponse Response Object

func (UpdateEventStreamingResponse) String added in v0.1.42 

func (o UpdateEventStreamingResponse) String() string

type UpdateSubscriptionRequest 

type UpdateSubscriptionRequest struct {

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

	Body *SubscriptionUpdateReq `json:"body,omitempty"`
}

UpdateSubscriptionRequest Request Object

func (UpdateSubscriptionRequest) String 

func (o UpdateSubscriptionRequest) String() string

type UpdateSubscriptionResponse 

type UpdateSubscriptionResponse struct {

	// 订阅ID
	Id *string `json:"id,omitempty"`

	// 订阅名称
	Name *string `json:"name,omitempty"`

	// 订阅描述
	Description *string `json:"description,omitempty"`

	// 类型
	Type *UpdateSubscriptionResponseType `json:"type,omitempty"`

	// 状态
	Status *UpdateSubscriptionResponseStatus `json:"status,omitempty"`

	// 通道ID
	ChannelId *string `json:"channel_id,omitempty"`

	// 通道名称
	ChannelName *string `json:"channel_name,omitempty"`

	// 标签信息
	Used *[]SubscriptionUsedInfo `json:"used,omitempty"`

	// 订阅源列表
	Sources *[]SubscriptionSourceInfo `json:"sources,omitempty"`

	// 订阅目标列表
	Targets *[]SubscriptionTargetInfo `json:"targets,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateSubscriptionResponse Response Object

func (UpdateSubscriptionResponse) String 

func (o UpdateSubscriptionResponse) String() string

type UpdateSubscriptionResponseStatus 

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

func (UpdateSubscriptionResponseStatus) MarshalJSON 

func (c UpdateSubscriptionResponseStatus) MarshalJSON() ([]byte, error)

func (*UpdateSubscriptionResponseStatus) UnmarshalJSON 

func (c *UpdateSubscriptionResponseStatus) UnmarshalJSON(b []byte) error

func (UpdateSubscriptionResponseStatus) Value 

func (c UpdateSubscriptionResponseStatus) Value() string

type UpdateSubscriptionResponseStatusEnum 

type UpdateSubscriptionResponseStatusEnum struct {
	CREATED  UpdateSubscriptionResponseStatus
	ENABLED  UpdateSubscriptionResponseStatus
	DISABLED UpdateSubscriptionResponseStatus
	FROZEN   UpdateSubscriptionResponseStatus
	ERROR    UpdateSubscriptionResponseStatus
}

func GetUpdateSubscriptionResponseStatusEnum 

func GetUpdateSubscriptionResponseStatusEnum() UpdateSubscriptionResponseStatusEnum

type UpdateSubscriptionResponseType 

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

func (UpdateSubscriptionResponseType) MarshalJSON 

func (c UpdateSubscriptionResponseType) MarshalJSON() ([]byte, error)

func (*UpdateSubscriptionResponseType) UnmarshalJSON 

func (c *UpdateSubscriptionResponseType) UnmarshalJSON(b []byte) error

func (UpdateSubscriptionResponseType) Value 

func (c UpdateSubscriptionResponseType) Value() string

type UpdateSubscriptionResponseTypeEnum 

type UpdateSubscriptionResponseTypeEnum struct {
	EVENT     UpdateSubscriptionResponseType
	SCHEDULED UpdateSubscriptionResponseType
}

func GetUpdateSubscriptionResponseTypeEnum 

func GetUpdateSubscriptionResponseTypeEnum() UpdateSubscriptionResponseTypeEnum

type UpdateSubscriptionSourceRequest 

type UpdateSubscriptionSourceRequest struct {

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

	// 事件订阅源ID
	SourceId string `json:"source_id"`

	Body *SubscriptionSource `json:"body,omitempty"`
}

UpdateSubscriptionSourceRequest Request Object

func (UpdateSubscriptionSourceRequest) String 

func (o UpdateSubscriptionSourceRequest) String() string

type UpdateSubscriptionSourceResponse 

type UpdateSubscriptionSourceResponse struct {

	// 订阅源ID
	Id *string `json:"id,omitempty"`

	// 订阅的事件源名称
	Name *string `json:"name,omitempty"`

	// 订阅的事件源的提供方类型
	ProviderType *string `json:"provider_type,omitempty"`

	// 订阅的事件源参数列表
	Detail *interface{} `json:"detail,omitempty"`

	// 订阅事件源的匹配过滤规则
	Filter *interface{} `json:"filter,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateSubscriptionSourceResponse Response Object

func (UpdateSubscriptionSourceResponse) String 

func (o UpdateSubscriptionSourceResponse) String() string

type UpdateSubscriptionTargetRequest 

type UpdateSubscriptionTargetRequest struct {

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

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

	Body *SubscriptionTarget `json:"body,omitempty"`
}

UpdateSubscriptionTargetRequest Request Object

func (UpdateSubscriptionTargetRequest) String 

func (o UpdateSubscriptionTargetRequest) String() string

type UpdateSubscriptionTargetResponse 

type UpdateSubscriptionTargetResponse struct {

	// 订阅目标ID
	Id *string `json:"id,omitempty"`

	// 订阅的事件目标名称
	Name *string `json:"name,omitempty"`

	// 订阅的事件目标的提供方类型
	ProviderType *string `json:"provider_type,omitempty"`

	// 订阅的事件目标使用的目标链接ID
	ConnectionId *string `json:"connection_id,omitempty"`

	// 订阅的事件目标参数列表
	Detail *interface{} `json:"detail,omitempty"`

	Transform *TransForm `json:"transform,omitempty"`

	DeadLetterQueue *DeadLetterQueue `json:"dead_letter_queue,omitempty"`

	// 创建时间
	CreatedTime *string `json:"created_time,omitempty"`

	// 更新时间
	UpdatedTime *string `json:"updated_time,omitempty"`

	XRequestId     *string `json:"X-Request-Id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateSubscriptionTargetResponse Response Object

func (UpdateSubscriptionTargetResponse) String 

func (o UpdateSubscriptionTargetResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.