model

package
v0.1.78 Latest Latest
Warning

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

Go to latest
Published: Jan 18, 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 BatchCreateOrDeleteRocketmqTagRequest added in v0.1.26

type BatchCreateOrDeleteRocketmqTagRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

BatchCreateOrDeleteRocketmqTagRequest Request Object

func (BatchCreateOrDeleteRocketmqTagRequest) String added in v0.1.26

type BatchCreateOrDeleteRocketmqTagResponse added in v0.1.26

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

BatchCreateOrDeleteRocketmqTagResponse Response Object

func (BatchCreateOrDeleteRocketmqTagResponse) String added in v0.1.26

type BatchCreateOrDeleteTagReq added in v0.1.26

type BatchCreateOrDeleteTagReq struct {

	// 操作标识(仅支持小写): - create(创建) - delete(删除)
	Action *BatchCreateOrDeleteTagReqAction `json:"action,omitempty"`

	// 标签列表。
	Tags *[]TagEntity `json:"tags,omitempty"`
}

func (BatchCreateOrDeleteTagReq) String added in v0.1.26

func (o BatchCreateOrDeleteTagReq) String() string

type BatchCreateOrDeleteTagReqAction added in v0.1.26

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

func (BatchCreateOrDeleteTagReqAction) MarshalJSON added in v0.1.26

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

func (*BatchCreateOrDeleteTagReqAction) UnmarshalJSON added in v0.1.26

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

func (BatchCreateOrDeleteTagReqAction) Value added in v0.1.26

type BatchCreateOrDeleteTagReqActionEnum added in v0.1.26

type BatchCreateOrDeleteTagReqActionEnum struct {
	CREATE BatchCreateOrDeleteTagReqAction
	DELETE BatchCreateOrDeleteTagReqAction
}

func GetBatchCreateOrDeleteTagReqActionEnum added in v0.1.26

func GetBatchCreateOrDeleteTagReqActionEnum() BatchCreateOrDeleteTagReqActionEnum

type BatchDeleteConsumerGroupReq

type BatchDeleteConsumerGroupReq struct {

	// 待删除的消费组列表。
	Groups *[]string `json:"groups,omitempty"`
}

func (BatchDeleteConsumerGroupReq) String

type BatchDeleteConsumerGroupResp

type BatchDeleteConsumerGroupResp struct {

	// 删除消费组的任务ID
	JobId *string `json:"job_id,omitempty"`
}

func (BatchDeleteConsumerGroupResp) String

type BatchDeleteInstanceReq

type BatchDeleteInstanceReq struct {

	// 实例的ID列表。
	Instances *[]string `json:"instances,omitempty"`

	// 对实例的操作:delete
	Action BatchDeleteInstanceReqAction `json:"action"`

	// 参数值为reliability,表示删除租户所有创建失败的RocketMQ实例。
	AllFailure *BatchDeleteInstanceReqAllFailure `json:"all_failure,omitempty"`
}

func (BatchDeleteInstanceReq) String

func (o BatchDeleteInstanceReq) String() string

type BatchDeleteInstanceReqAction

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

func (BatchDeleteInstanceReqAction) MarshalJSON

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

func (*BatchDeleteInstanceReqAction) UnmarshalJSON

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

func (BatchDeleteInstanceReqAction) Value added in v0.0.90

type BatchDeleteInstanceReqActionEnum

type BatchDeleteInstanceReqActionEnum struct {
	DELETE BatchDeleteInstanceReqAction
}

func GetBatchDeleteInstanceReqActionEnum

func GetBatchDeleteInstanceReqActionEnum() BatchDeleteInstanceReqActionEnum

type BatchDeleteInstanceReqAllFailure

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

func (BatchDeleteInstanceReqAllFailure) MarshalJSON

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

func (*BatchDeleteInstanceReqAllFailure) UnmarshalJSON

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

func (BatchDeleteInstanceReqAllFailure) Value added in v0.0.90

type BatchDeleteInstanceReqAllFailureEnum

type BatchDeleteInstanceReqAllFailureEnum struct {
	RELIABILITY BatchDeleteInstanceReqAllFailure
}

func GetBatchDeleteInstanceReqAllFailureEnum

func GetBatchDeleteInstanceReqAllFailureEnum() BatchDeleteInstanceReqAllFailureEnum

type BatchDeleteInstanceRespResults

type BatchDeleteInstanceRespResults struct {

	// 操作结果。
	Result *BatchDeleteInstanceRespResultsResult `json:"result,omitempty"`

	// 实例ID。
	Instance *string `json:"instance,omitempty"`
}

func (BatchDeleteInstanceRespResults) String

type BatchDeleteInstanceRespResultsResult

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

func (BatchDeleteInstanceRespResultsResult) MarshalJSON

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

func (*BatchDeleteInstanceRespResultsResult) UnmarshalJSON

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

func (BatchDeleteInstanceRespResultsResult) Value added in v0.0.90

type BatchDeleteInstanceRespResultsResultEnum

type BatchDeleteInstanceRespResultsResultEnum struct {
	SUCCESS BatchDeleteInstanceRespResultsResult
	FAILED  BatchDeleteInstanceRespResultsResult
}

func GetBatchDeleteInstanceRespResultsResultEnum

func GetBatchDeleteInstanceRespResultsResultEnum() BatchDeleteInstanceRespResultsResultEnum

type BatchDeleteInstancesRequest

type BatchDeleteInstancesRequest struct {
	Body *BatchDeleteInstanceReq `json:"body,omitempty"`
}

BatchDeleteInstancesRequest Request Object

func (BatchDeleteInstancesRequest) String

type BatchDeleteInstancesResponse

type BatchDeleteInstancesResponse struct {

	// 修改实例的结果。
	Results        *[]BatchDeleteInstanceRespResults `json:"results,omitempty"`
	HttpStatusCode int                               `json:"-"`
}

BatchDeleteInstancesResponse Response Object

func (BatchDeleteInstancesResponse) String

type BatchDeleteTopicReq

type BatchDeleteTopicReq struct {

	// 主题列表,当批量删除主题时使用。
	Topics *[]string `json:"topics,omitempty"`
}

func (BatchDeleteTopicReq) String

func (o BatchDeleteTopicReq) String() string

type BatchDeleteTopicResp

type BatchDeleteTopicResp struct {

	// 删除主题任务ID。
	JobId *string `json:"job_id,omitempty"`
}

func (BatchDeleteTopicResp) String

func (o BatchDeleteTopicResp) String() string

type BatchUpdateConsumerGroupReq

type BatchUpdateConsumerGroupReq struct {

	// 消费组列表,当批量删除消费组时使用。
	Groups *[]ConsumerGroup `json:"groups,omitempty"`
}

func (BatchUpdateConsumerGroupReq) String

type BatchUpdateConsumerGroupRequest

type BatchUpdateConsumerGroupRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

BatchUpdateConsumerGroupRequest Request Object

func (BatchUpdateConsumerGroupRequest) String

type BatchUpdateConsumerGroupResponse

type BatchUpdateConsumerGroupResponse struct {

	// 任务ID。
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

BatchUpdateConsumerGroupResponse Response Object

func (BatchUpdateConsumerGroupResponse) String

type Brokers added in v0.1.37

type Brokers struct {

	// Topic关联代理名称
	BrokerName *string `json:"broker_name,omitempty"`

	// 关联代理的队列详情
	Queues *[]Queue `json:"queues,omitempty"`
}

func (Brokers) String added in v0.1.37

func (o Brokers) String() string

type BssParam added in v0.1.26

type BssParam struct {

	// 是否自动续订。  取值范围:   - true: 自动续订。   - false: 不自动续订。  默认不自动续订。
	IsAutoRenew *bool `json:"is_auto_renew,omitempty"`

	// 计费模式。  功能说明:付费方式。  取值范围:   - prePaid:预付费,即包年包月;   - postPaid:后付费,即按需付费;  默认为postPaid。
	ChargingMode *BssParamChargingMode `json:"charging_mode,omitempty"`

	// 下单订购后,是否自动从客户的账户中支付,而不需要客户手动去进行支付。  取值范围:   - true:是(自动支付)   - false:否(需要客户手动支付)  默认为手动支付。
	IsAutoPay *bool `json:"is_auto_pay,omitempty"`

	// 订购周期类型。  取值范围:   - month:月   - year:年  **chargingMode为prePaid时生效且为必选值。**
	PeriodType *BssParamPeriodType `json:"period_type,omitempty"`

	// 订购周期数。  取值范围:   - periodType=month(周期类型为月)时,取值为[1,9];  - periodType=year(周期类型为年)时,取值为[1,3];  **chargingMode为prePaid时生效且为必选值。**
	PeriodNum *int32 `json:"period_num,omitempty"`
}

BssParam 表示包周期计费模式的相关参数。 如果为空,则默认计费模式为按需计费;否则是包周期方式。

func (BssParam) String added in v0.1.26

func (o BssParam) String() string

type BssParamChargingMode added in v0.1.26

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

func (BssParamChargingMode) MarshalJSON added in v0.1.26

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

func (*BssParamChargingMode) UnmarshalJSON added in v0.1.26

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

func (BssParamChargingMode) Value added in v0.1.26

func (c BssParamChargingMode) Value() string

type BssParamChargingModeEnum added in v0.1.26

type BssParamChargingModeEnum struct {
	PRE_PAID  BssParamChargingMode
	POST_PAID BssParamChargingMode
}

func GetBssParamChargingModeEnum added in v0.1.26

func GetBssParamChargingModeEnum() BssParamChargingModeEnum

type BssParamPeriodType added in v0.1.26

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

func (BssParamPeriodType) MarshalJSON added in v0.1.26

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

func (*BssParamPeriodType) UnmarshalJSON added in v0.1.26

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

func (BssParamPeriodType) Value added in v0.1.26

func (c BssParamPeriodType) Value() string

type BssParamPeriodTypeEnum added in v0.1.26

type BssParamPeriodTypeEnum struct {
	MONTH BssParamPeriodType
	YEAR  BssParamPeriodType
}

func GetBssParamPeriodTypeEnum added in v0.1.26

func GetBssParamPeriodTypeEnum() BssParamPeriodTypeEnum

type ClientData added in v0.1.37

type ClientData struct {

	// 客户端语言
	Language *string `json:"language,omitempty"`

	// 客户端版本
	Version *string `json:"version,omitempty"`

	// 客户端ID
	ClientId *string `json:"client_id,omitempty"`

	// 客户端地址
	ClientAddr *string `json:"client_addr,omitempty"`

	// 订阅关系列表
	Subscriptions *[]Subscription `json:"subscriptions,omitempty"`
}

func (ClientData) String added in v0.1.37

func (o ClientData) String() string

type ConsumerDetailResp added in v0.1.37

type ConsumerDetailResp struct {

	// 消费堆积总数
	Lag *int64 `json:"lag,omitempty"`

	// 消息总数
	MaxOffset *int64 `json:"max_offset,omitempty"`

	// 已消费消息数
	ConsumerOffset *int64 `json:"consumer_offset,omitempty"`

	// Topic关联代理(当查询topic消费“详情”才显示此参数)。
	Brokers *[]Brokers `json:"brokers,omitempty"`
}

func (ConsumerDetailResp) String added in v0.1.37

func (o ConsumerDetailResp) String() string

type ConsumerGroup

type ConsumerGroup struct {

	// 是否可以消费。
	Enabled *bool `json:"enabled,omitempty"`

	// 是否广播。
	Broadcast *bool `json:"broadcast,omitempty"`

	// 关联的代理列表。
	Brokers *[]string `json:"brokers,omitempty"`

	// 消费组名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。
	Name *string `json:"name,omitempty"`

	// 消费组描述,长度0~200个字符。
	GroupDesc *string `json:"group_desc,omitempty"`

	// 最大重试次数,取值范围为1~16。
	RetryMaxTime float32 `json:"retry_max_time,omitempty"`

	// 是否重头消费。
	FromBeginning *bool `json:"from_beginning,omitempty"`
}

func (ConsumerGroup) String

func (o ConsumerGroup) String() string

type ConsumerList added in v0.1.37

type ConsumerList struct {

	// Topic列表(当查询topic消费“列表”时才显示此参数)。
	Topics *[]string `json:"topics,omitempty"`

	// Topic总数(当查询topic消费“列表”时才显示此参数)。
	Total *int32 `json:"total,omitempty"`
}

func (ConsumerList) String added in v0.1.37

func (o ConsumerList) String() string

type CreateConsumerGroupOrBatchDeleteConsumerGroupReq

type CreateConsumerGroupOrBatchDeleteConsumerGroupReq struct {

	// 待删除的消费组列表。
	Groups *[]string `json:"groups,omitempty"`

	// 是否可以消费。
	Enabled *bool `json:"enabled,omitempty"`

	// 是否广播。
	Broadcast *bool `json:"broadcast,omitempty"`

	// 关联的代理列表。
	Brokers *[]string `json:"brokers,omitempty"`

	// 消费组名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。
	Name *string `json:"name,omitempty"`

	// 消费组描述,长度0~200个字符。
	GroupDesc *string `json:"group_desc,omitempty"`

	// 最大重试次数,取值范围为1~16。
	RetryMaxTime float32 `json:"retry_max_time,omitempty"`

	// 是否重头消费。
	FromBeginning *bool `json:"from_beginning,omitempty"`
}

func (CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String

type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest

type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 批量删除消费组时使用,不配置则为创建接口。
	Action *string `json:"action,omitempty"`

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

CreateConsumerGroupOrBatchDeleteConsumerGroupRequest Request Object

func (CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) String

type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse

type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse struct {

	// 删除消费组的任务ID
	JobId *string `json:"job_id,omitempty"`

	// 创建成功的消费组名称。
	Name           *string `json:"name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateConsumerGroupOrBatchDeleteConsumerGroupResponse Response Object

func (CreateConsumerGroupOrBatchDeleteConsumerGroupResponse) String

type CreateGroupResp

type CreateGroupResp struct {

	// 创建成功的消费组名称。
	Name *string `json:"name,omitempty"`
}

func (CreateGroupResp) String

func (o CreateGroupResp) String() string

type CreateInstanceByEngineReq added in v0.1.26

type CreateInstanceByEngineReq struct {

	// 实例名称。  由英文字符开头,只能由英文字母、数字、中划线、下划线组成,长度为4~64的字符。
	Name string `json:"name"`

	// 实例的描述信息。  长度不超过1024的字符串。  > \\与\"在json报文中属于特殊字符,如果参数值中需要显示\\或者\"字符,请在字符前增加转义字符\\,比如\\\\或者\\\"。
	Description *string `json:"description,omitempty"`

	// 消息引擎。取值填写为:reliability。
	Engine CreateInstanceByEngineReqEngine `json:"engine"`

	// 消息引擎的版本。取值填写为:4.8.0。
	EngineVersion CreateInstanceByEngineReqEngineVersion `json:"engine_version"`

	// 存储空间。
	StorageSpace int32 `json:"storage_space"`

	// 虚拟私有云ID。  获取方法如下:登录虚拟私有云服务的控制台界面,在虚拟私有云的详情页面查找VPC ID。
	VpcId string `json:"vpc_id"`

	// 子网信息。  获取方法如下:登录虚拟私有云服务的控制台界面,单击VPC下的子网,进入子网详情页面,查找网络ID。
	SubnetId string `json:"subnet_id"`

	// 指定实例所属的安全组。  获取方法如下:登录虚拟私有云服务的控制台界面,在安全组的详情页面查找安全组ID。
	SecurityGroupId string `json:"security_group_id"`

	// 创建节点到指定且有资源的可用区ID。请参考[查询可用区信息](ListAvailableZones.xml)获取可用区ID。  该参数不能为空数组或者数组的值为空, 请注意查看该可用区是否有资源。  创建RocketMQ实例,支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时,用逗号分隔开。
	AvailableZones []string `json:"available_zones"`

	// RocketMQ实例规格。   - c6.4u8g.cluster.small:单个代理最大Topic数2000,单个代理最大消费组数2000   - c6.4u8g.cluster:单个代理最大Topic数4000,单个代理最大消费组数4000   - c6.8u16g.cluster:单个代理最大Topic数8000,单个代理最大消费组数8000   - c6.12u24g.cluster:单个代理最大Topic数12000,单个代理最大消费组数12000   - c6.16u32g.cluster:单个代理最大Topic数16000,单个代理最大消费组数16000
	ProductId CreateInstanceByEngineReqProductId `json:"product_id"`

	// 是否打开SSL加密访问。 - true:打开SSL加密访问。 - false:不打开SSL加密访问。
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 存储IO规格。   - dms.physical.storage.high.v2: 高IO类型磁盘   - dms.physical.storage.ultra.v2: 超高IO类型磁盘
	StorageSpecCode CreateInstanceByEngineReqStorageSpecCode `json:"storage_spec_code"`

	// 企业项目ID。若为企业项目账号,该参数必填。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 是否开启访问控制列表。
	EnableAcl *bool `json:"enable_acl,omitempty"`

	// 是否支持IPv6。   - true: 支持   - false:不支持
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	// 是否开启公网访问功能。默认不开启公网。 - true:开启 - false:不开启
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// 实例绑定的弹性IP地址的ID。  以英文逗号隔开多个弹性IP地址的ID。  如果开启了公网访问功能(即enable_publicip为true),该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 代理个数
	BrokerNum int32 `json:"broker_num"`

	BssParam *BssParam `json:"bss_param,omitempty"`
}

CreateInstanceByEngineReq 创建实例请求体。

func (CreateInstanceByEngineReq) String added in v0.1.26

func (o CreateInstanceByEngineReq) String() string

type CreateInstanceByEngineReqEngine added in v0.1.26

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

func (CreateInstanceByEngineReqEngine) MarshalJSON added in v0.1.26

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

func (*CreateInstanceByEngineReqEngine) UnmarshalJSON added in v0.1.26

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

func (CreateInstanceByEngineReqEngine) Value added in v0.1.26

type CreateInstanceByEngineReqEngineEnum added in v0.1.26

type CreateInstanceByEngineReqEngineEnum struct {
	RELIABILITY CreateInstanceByEngineReqEngine
}

func GetCreateInstanceByEngineReqEngineEnum added in v0.1.26

func GetCreateInstanceByEngineReqEngineEnum() CreateInstanceByEngineReqEngineEnum

type CreateInstanceByEngineReqEngineVersion added in v0.1.26

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

func (CreateInstanceByEngineReqEngineVersion) MarshalJSON added in v0.1.26

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

func (*CreateInstanceByEngineReqEngineVersion) UnmarshalJSON added in v0.1.26

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

func (CreateInstanceByEngineReqEngineVersion) Value added in v0.1.26

type CreateInstanceByEngineReqEngineVersionEnum added in v0.1.26

type CreateInstanceByEngineReqEngineVersionEnum struct {
	E_4_8_0 CreateInstanceByEngineReqEngineVersion
}

func GetCreateInstanceByEngineReqEngineVersionEnum added in v0.1.26

func GetCreateInstanceByEngineReqEngineVersionEnum() CreateInstanceByEngineReqEngineVersionEnum

type CreateInstanceByEngineReqProductId added in v0.1.26

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

func (CreateInstanceByEngineReqProductId) MarshalJSON added in v0.1.26

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

func (*CreateInstanceByEngineReqProductId) UnmarshalJSON added in v0.1.26

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

func (CreateInstanceByEngineReqProductId) Value added in v0.1.26

type CreateInstanceByEngineReqProductIdEnum added in v0.1.26

type CreateInstanceByEngineReqProductIdEnum struct {
	C6_4U8G_CLUSTER_SMALL CreateInstanceByEngineReqProductId
	C6_4U8G_CLUSTER       CreateInstanceByEngineReqProductId
	C6_8U16G_CLUSTER      CreateInstanceByEngineReqProductId
	C6_12U24G_CLUSTER     CreateInstanceByEngineReqProductId
	C6_16U32G_CLUSTER     CreateInstanceByEngineReqProductId
}

func GetCreateInstanceByEngineReqProductIdEnum added in v0.1.26

func GetCreateInstanceByEngineReqProductIdEnum() CreateInstanceByEngineReqProductIdEnum

type CreateInstanceByEngineReqStorageSpecCode added in v0.1.26

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

func (CreateInstanceByEngineReqStorageSpecCode) MarshalJSON added in v0.1.26

func (*CreateInstanceByEngineReqStorageSpecCode) UnmarshalJSON added in v0.1.26

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

func (CreateInstanceByEngineReqStorageSpecCode) Value added in v0.1.26

type CreateInstanceByEngineReqStorageSpecCodeEnum added in v0.1.26

type CreateInstanceByEngineReqStorageSpecCodeEnum struct {
	DMS_PHYSICAL_STORAGE_HIGH_V2  CreateInstanceByEngineReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_ULTRA_V2 CreateInstanceByEngineReqStorageSpecCode
}

func GetCreateInstanceByEngineReqStorageSpecCodeEnum added in v0.1.26

func GetCreateInstanceByEngineReqStorageSpecCodeEnum() CreateInstanceByEngineReqStorageSpecCodeEnum

type CreateInstanceByEngineRequest added in v0.1.26

type CreateInstanceByEngineRequest struct {

	// 消息引擎。
	Engine CreateInstanceByEngineRequestEngine `json:"engine"`

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

CreateInstanceByEngineRequest Request Object

func (CreateInstanceByEngineRequest) String added in v0.1.26

type CreateInstanceByEngineRequestEngine added in v0.1.26

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

func (CreateInstanceByEngineRequestEngine) MarshalJSON added in v0.1.26

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

func (*CreateInstanceByEngineRequestEngine) UnmarshalJSON added in v0.1.26

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

func (CreateInstanceByEngineRequestEngine) Value added in v0.1.26

type CreateInstanceByEngineRequestEngineEnum added in v0.1.26

type CreateInstanceByEngineRequestEngineEnum struct {
	RELIABILITY CreateInstanceByEngineRequestEngine
}

func GetCreateInstanceByEngineRequestEngineEnum added in v0.1.26

func GetCreateInstanceByEngineRequestEngineEnum() CreateInstanceByEngineRequestEngineEnum

type CreateInstanceByEngineResponse added in v0.1.26

type CreateInstanceByEngineResponse struct {

	// 实例ID。
	InstanceId     *string `json:"instance_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateInstanceByEngineResponse Response Object

func (CreateInstanceByEngineResponse) String added in v0.1.26

type CreatePostPaidInstanceReq

type CreatePostPaidInstanceReq struct {

	// 实例名称。  由英文字符开头,只能由英文字母、数字、中划线、下划线组成,长度为4~64的字符。
	Name string `json:"name"`

	// 实例的描述信息。  长度不超过1024的字符串。  > \\与\"在json报文中属于特殊字符,如果参数值中需要显示\\或者\"字符,请在字符前增加转义字符\\,比如\\\\或者\\\"。
	Description *string `json:"description,omitempty"`

	// 消息引擎。取值填写为:reliability。
	Engine CreatePostPaidInstanceReqEngine `json:"engine"`

	// 消息引擎的版本。取值填写为:4.8.0。
	EngineVersion CreatePostPaidInstanceReqEngineVersion `json:"engine_version"`

	// 存储空间。
	StorageSpace int32 `json:"storage_space"`

	// 虚拟私有云ID。  获取方法如下:登录虚拟私有云服务的控制台界面,在虚拟私有云的详情页面查找VPC ID。
	VpcId string `json:"vpc_id"`

	// 子网信息。  获取方法如下:登录虚拟私有云服务的控制台界面,单击VPC下的子网,进入子网详情页面,查找网络ID。
	SubnetId string `json:"subnet_id"`

	// 指定实例所属的安全组。  获取方法如下:登录虚拟私有云服务的控制台界面,在安全组的详情页面查找安全组ID。
	SecurityGroupId string `json:"security_group_id"`

	// 创建节点到指定且有资源的可用区ID。请参考[查询可用区信息](ListAvailableZones.xml)获取可用区ID。 该参数不能为空数组或者数组的值为空, 请注意查看该可用区是否有资源。  创建RocketMQ实例,支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时,用逗号分隔开。
	AvailableZones []string `json:"available_zones"`

	// RocketMQ实例规格。   - c6.4u8g.cluster:单个代理最大Topic数4000,单个代理最大消费组数4000   - c6.8u16g.cluster:单个代理最大Topic数8000,单个代理最大消费组数8000   - c6.12u24g.cluster:单个代理最大Topic数12000,单个代理最大消费组数12000   - c6.16u32g.cluster:单个代理最大Topic数16000,单个代理最大消费组数16000
	ProductId CreatePostPaidInstanceReqProductId `json:"product_id"`

	// 是否打开SSL加密访问。 - true:打开SSL加密访问。 - false:不打开SSL加密访问。
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 存储IO规格。   - dms.physical.storage.high.v2: 高IO类型磁盘   - dms.physical.storage.ultra.v2: 超高IO类型磁盘
	StorageSpecCode CreatePostPaidInstanceReqStorageSpecCode `json:"storage_spec_code"`

	// 企业项目ID。若为企业项目账号,该参数必填。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 是否开启访问控制列表。
	EnableAcl *bool `json:"enable_acl,omitempty"`

	// 是否支持IPv6。   - true: 支持   - false:不支持
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	// 是否开启公网访问功能。默认不开启公网。 - true:开启 - false:不开启
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// 实例绑定的弹性IP地址的ID。  以英文逗号隔开多个弹性IP地址的ID。  如果开启了公网访问功能(即enable_publicip为true),该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 代理个数
	BrokerNum int32 `json:"broker_num"`
}

CreatePostPaidInstanceReq 创建实例请求体。

func (CreatePostPaidInstanceReq) String

func (o CreatePostPaidInstanceReq) String() string

type CreatePostPaidInstanceReqEngine

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

func (CreatePostPaidInstanceReqEngine) MarshalJSON

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

func (*CreatePostPaidInstanceReqEngine) UnmarshalJSON

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

func (CreatePostPaidInstanceReqEngine) Value added in v0.0.90

type CreatePostPaidInstanceReqEngineEnum

type CreatePostPaidInstanceReqEngineEnum struct {
	RELIABILITY CreatePostPaidInstanceReqEngine
}

func GetCreatePostPaidInstanceReqEngineEnum

func GetCreatePostPaidInstanceReqEngineEnum() CreatePostPaidInstanceReqEngineEnum

type CreatePostPaidInstanceReqEngineVersion

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

func (CreatePostPaidInstanceReqEngineVersion) MarshalJSON

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

func (*CreatePostPaidInstanceReqEngineVersion) UnmarshalJSON

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

func (CreatePostPaidInstanceReqEngineVersion) Value added in v0.0.90

type CreatePostPaidInstanceReqEngineVersionEnum

type CreatePostPaidInstanceReqEngineVersionEnum struct {
	E_4_8_0 CreatePostPaidInstanceReqEngineVersion
}

func GetCreatePostPaidInstanceReqEngineVersionEnum

func GetCreatePostPaidInstanceReqEngineVersionEnum() CreatePostPaidInstanceReqEngineVersionEnum

type CreatePostPaidInstanceReqProductId

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

func (CreatePostPaidInstanceReqProductId) MarshalJSON

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

func (*CreatePostPaidInstanceReqProductId) UnmarshalJSON

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

func (CreatePostPaidInstanceReqProductId) Value added in v0.0.90

type CreatePostPaidInstanceReqProductIdEnum

type CreatePostPaidInstanceReqProductIdEnum struct {
	C6_4U8G_CLUSTER   CreatePostPaidInstanceReqProductId
	C6_8U16G_CLUSTER  CreatePostPaidInstanceReqProductId
	C6_12U24G_CLUSTER CreatePostPaidInstanceReqProductId
	C6_16U32G_CLUSTER CreatePostPaidInstanceReqProductId
}

func GetCreatePostPaidInstanceReqProductIdEnum

func GetCreatePostPaidInstanceReqProductIdEnum() CreatePostPaidInstanceReqProductIdEnum

type CreatePostPaidInstanceReqStorageSpecCode

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

func (CreatePostPaidInstanceReqStorageSpecCode) MarshalJSON

func (*CreatePostPaidInstanceReqStorageSpecCode) UnmarshalJSON

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

func (CreatePostPaidInstanceReqStorageSpecCode) Value added in v0.0.90

type CreatePostPaidInstanceReqStorageSpecCodeEnum

type CreatePostPaidInstanceReqStorageSpecCodeEnum struct {
	DMS_PHYSICAL_STORAGE_HIGH_V2  CreatePostPaidInstanceReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_ULTRA_V2 CreatePostPaidInstanceReqStorageSpecCode
}

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum() CreatePostPaidInstanceReqStorageSpecCodeEnum

type CreatePostPaidInstanceRequest

type CreatePostPaidInstanceRequest struct {
	Body *CreatePostPaidInstanceReq `json:"body,omitempty"`
}

CreatePostPaidInstanceRequest Request Object

func (CreatePostPaidInstanceRequest) String

type CreatePostPaidInstanceResponse

type CreatePostPaidInstanceResponse struct {

	// 实例ID。
	InstanceId     *string `json:"instance_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreatePostPaidInstanceResponse Response Object

func (CreatePostPaidInstanceResponse) String

type CreateRocketMqMigrationTaskReq added in v0.1.72

type CreateRocketMqMigrationTaskReq struct {

	// RocketMQ topic 元数据,键为topic名,值为topic配置,迁移任务类型为自建RocketMQ上云(rocketmq)时必填。
	TopicConfigTable map[string]MigrationRocketMqTopicConfig `json:"topicConfigTable,omitempty"`

	// RocketMQ消费组元数据,键为消费组名,值为消费组配置,迁移任务类型为自建RocketMQ上云(rocketmq)时必填。
	SubscriptionGroupTable map[string]MigrationRocketMqSubscriptionGroup `json:"subscriptionGroupTable,omitempty"`

	// RabbitMQ vhost元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。
	Vhosts *[]MigrationRabbitVhostMetadata `json:"vhosts,omitempty"`

	// RabbitMQ队列元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。
	Queues *[]MigrationRabbitQueueMetadata `json:"queues,omitempty"`

	// RabbitMQ交换机元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。
	Exchanges *[]MigrationRabbitExchangeMetadata `json:"exchanges,omitempty"`

	// RabbitMQ binding元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。
	Bindings *[]MigrationRabbitBindingMetadata `json:"bindings,omitempty"`
}

func (CreateRocketMqMigrationTaskReq) String added in v0.1.72

type CreateRocketMqMigrationTaskRequest added in v0.1.42

type CreateRocketMqMigrationTaskRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// true开启同名覆盖,会对已有的同名元数据的配置进行修改,false时当topic或group已存在则会报错。
	Overwrite CreateRocketMqMigrationTaskRequestOverwrite `json:"overwrite"`

	// 迁移任务名称,名称规则参考创建实例
	Name string `json:"name"`

	// 迁移任务类型,分为自建RocketMQ上云(rocketmq)、自建RabbitMQ上云(rabbitToRocket)
	Type CreateRocketMqMigrationTaskRequestType `json:"type"`

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

CreateRocketMqMigrationTaskRequest Request Object

func (CreateRocketMqMigrationTaskRequest) String added in v0.1.42

type CreateRocketMqMigrationTaskRequestOverwrite added in v0.1.42

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

func (CreateRocketMqMigrationTaskRequestOverwrite) MarshalJSON added in v0.1.42

func (*CreateRocketMqMigrationTaskRequestOverwrite) UnmarshalJSON added in v0.1.42

func (CreateRocketMqMigrationTaskRequestOverwrite) Value added in v0.1.42

type CreateRocketMqMigrationTaskRequestOverwriteEnum added in v0.1.42

type CreateRocketMqMigrationTaskRequestOverwriteEnum struct {
	TRUE  CreateRocketMqMigrationTaskRequestOverwrite
	FALSE CreateRocketMqMigrationTaskRequestOverwrite
}

func GetCreateRocketMqMigrationTaskRequestOverwriteEnum added in v0.1.42

func GetCreateRocketMqMigrationTaskRequestOverwriteEnum() CreateRocketMqMigrationTaskRequestOverwriteEnum

type CreateRocketMqMigrationTaskRequestType added in v0.1.42

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

func (CreateRocketMqMigrationTaskRequestType) MarshalJSON added in v0.1.42

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

func (*CreateRocketMqMigrationTaskRequestType) UnmarshalJSON added in v0.1.42

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

func (CreateRocketMqMigrationTaskRequestType) Value added in v0.1.42

type CreateRocketMqMigrationTaskRequestTypeEnum added in v0.1.42

type CreateRocketMqMigrationTaskRequestTypeEnum struct {
	ROCKETMQ         CreateRocketMqMigrationTaskRequestType
	RABBIT_TO_ROCKET CreateRocketMqMigrationTaskRequestType
}

func GetCreateRocketMqMigrationTaskRequestTypeEnum added in v0.1.42

func GetCreateRocketMqMigrationTaskRequestTypeEnum() CreateRocketMqMigrationTaskRequestTypeEnum

type CreateRocketMqMigrationTaskResponse added in v0.1.42

type CreateRocketMqMigrationTaskResponse struct {

	// 任务ID
	TaskId         *string `json:"task_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateRocketMqMigrationTaskResponse Response Object

func (CreateRocketMqMigrationTaskResponse) String added in v0.1.42

type CreateTopicOrBatchDeleteTopicReq

type CreateTopicOrBatchDeleteTopicReq struct {

	// 主题名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。
	Name *string `json:"name,omitempty"`

	// 关联的代理。
	Brokers *[]string `json:"brokers,omitempty"`

	// 队列数,范围1~50。
	QueueNum float32 `json:"queue_num,omitempty"`

	// 权限。
	Permission *CreateTopicOrBatchDeleteTopicReqPermission `json:"permission,omitempty"`

	// 消息类型(RocketMQ实例5.x版本才包含此参数)。
	MessageType *CreateTopicOrBatchDeleteTopicReqMessageType `json:"message_type,omitempty"`

	// 主题列表,当批量删除主题时使用。
	Topics *[]string `json:"topics,omitempty"`
}

func (CreateTopicOrBatchDeleteTopicReq) String

type CreateTopicOrBatchDeleteTopicReqMessageType added in v0.1.53

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

func (CreateTopicOrBatchDeleteTopicReqMessageType) MarshalJSON added in v0.1.53

func (*CreateTopicOrBatchDeleteTopicReqMessageType) UnmarshalJSON added in v0.1.53

func (CreateTopicOrBatchDeleteTopicReqMessageType) Value added in v0.1.53

type CreateTopicOrBatchDeleteTopicReqPermission

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

func (CreateTopicOrBatchDeleteTopicReqPermission) MarshalJSON

func (*CreateTopicOrBatchDeleteTopicReqPermission) UnmarshalJSON

func (CreateTopicOrBatchDeleteTopicReqPermission) Value added in v0.0.90

type CreateTopicOrBatchDeleteTopicRequest

type CreateTopicOrBatchDeleteTopicRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 批量删除topic时使用,不配置则为创建接口。
	Action *string `json:"action,omitempty"`

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

CreateTopicOrBatchDeleteTopicRequest Request Object

func (CreateTopicOrBatchDeleteTopicRequest) String

type CreateTopicOrBatchDeleteTopicResponse

type CreateTopicOrBatchDeleteTopicResponse struct {

	// 主题名称。
	Id *string `json:"id,omitempty"`

	// 删除主题任务ID。
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateTopicOrBatchDeleteTopicResponse Response Object

func (CreateTopicOrBatchDeleteTopicResponse) String

type CreateTopicReq

type CreateTopicReq struct {

	// 主题名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。
	Name *string `json:"name,omitempty"`

	// 关联的代理。
	Brokers *[]string `json:"brokers,omitempty"`

	// 队列数,范围1~50。
	QueueNum float32 `json:"queue_num,omitempty"`

	// 权限。
	Permission *CreateTopicReqPermission `json:"permission,omitempty"`

	// 消息类型(RocketMQ实例5.x版本才包含此参数)。
	MessageType *CreateTopicReqMessageType `json:"message_type,omitempty"`
}

func (CreateTopicReq) String

func (o CreateTopicReq) String() string

type CreateTopicReqMessageType added in v0.1.53

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

func (CreateTopicReqMessageType) MarshalJSON added in v0.1.53

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

func (*CreateTopicReqMessageType) UnmarshalJSON added in v0.1.53

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

func (CreateTopicReqMessageType) Value added in v0.1.53

type CreateTopicReqMessageTypeEnum added in v0.1.53

type CreateTopicReqMessageTypeEnum struct {
	NORMAL      CreateTopicReqMessageType
	FIFO        CreateTopicReqMessageType
	DELAY       CreateTopicReqMessageType
	TRANSACTION CreateTopicReqMessageType
}

func GetCreateTopicReqMessageTypeEnum added in v0.1.53

func GetCreateTopicReqMessageTypeEnum() CreateTopicReqMessageTypeEnum

type CreateTopicReqPermission

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

func (CreateTopicReqPermission) MarshalJSON

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

func (*CreateTopicReqPermission) UnmarshalJSON

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

func (CreateTopicReqPermission) Value added in v0.0.90

func (c CreateTopicReqPermission) Value() string

type CreateTopicReqPermissionEnum

type CreateTopicReqPermissionEnum struct {
	SUB CreateTopicReqPermission
	PUB CreateTopicReqPermission
	ALL CreateTopicReqPermission
}

func GetCreateTopicReqPermissionEnum

func GetCreateTopicReqPermissionEnum() CreateTopicReqPermissionEnum

type CreateTopicResp

type CreateTopicResp struct {

	// 主题名称。
	Id *string `json:"id,omitempty"`
}

func (CreateTopicResp) String

func (o CreateTopicResp) String() string

type CreateUserRequest

type CreateUserRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

CreateUserRequest Request Object

func (CreateUserRequest) String

func (o CreateUserRequest) String() string

type CreateUserResponse

type CreateUserResponse struct {

	// 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。
	AccessKey *string `json:"access_key,omitempty"`

	// 密钥。 8-32个字符。 至少包含以下字符中的3种:   - 大写字母   - 小写字母   - 数字   - 特殊字符`~!@#$%^&*()-_=+\\\\|[{}];:\\'\\\",<.>/?密钥。 不能与名称或倒序的名称相同。
	SecretKey *string `json:"secret_key,omitempty"`

	// IP白名单。
	WhiteRemoteAddress *string `json:"white_remote_address,omitempty"`

	// 是否为管理员。
	Admin *bool `json:"admin,omitempty"`

	// 默认的主题权限。
	DefaultTopicPerm *CreateUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty"`

	// 默认的消费组权限。
	DefaultGroupPerm *CreateUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty"`

	// 特殊的主题权限。
	TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"`

	// 特殊的消费组权限。
	GroupPerms     *[]UserGroupPerms `json:"group_perms,omitempty"`
	HttpStatusCode int               `json:"-"`
}

CreateUserResponse Response Object

func (CreateUserResponse) String

func (o CreateUserResponse) String() string

type CreateUserResponseDefaultGroupPerm

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

func (CreateUserResponseDefaultGroupPerm) MarshalJSON

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

func (*CreateUserResponseDefaultGroupPerm) UnmarshalJSON

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

func (CreateUserResponseDefaultGroupPerm) Value added in v0.0.90

type CreateUserResponseDefaultGroupPermEnum

type CreateUserResponseDefaultGroupPermEnum struct {
	SUB  CreateUserResponseDefaultGroupPerm
	DENY CreateUserResponseDefaultGroupPerm
}

func GetCreateUserResponseDefaultGroupPermEnum

func GetCreateUserResponseDefaultGroupPermEnum() CreateUserResponseDefaultGroupPermEnum

type CreateUserResponseDefaultTopicPerm

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

func (CreateUserResponseDefaultTopicPerm) MarshalJSON

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

func (*CreateUserResponseDefaultTopicPerm) UnmarshalJSON

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

func (CreateUserResponseDefaultTopicPerm) Value added in v0.0.90

type DeadletterResendReq added in v0.1.42

type DeadletterResendReq struct {

	// topic。
	Topic *string `json:"topic,omitempty"`

	// 消息列表。
	MsgIdList *[]string `json:"msg_id_list,omitempty"`
}

func (DeadletterResendReq) String added in v0.1.42

func (o DeadletterResendReq) String() string

type DeadletterResendRespResendResults added in v0.1.42

type DeadletterResendRespResendResults struct {

	// 消息ID。
	MsgId *string `json:"msg_id,omitempty"`

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

	// 错误信息。
	ErrorMessage *string `json:"error_message,omitempty"`
}

func (DeadletterResendRespResendResults) String added in v0.1.42

type DeleteConsumerGroupRequest

type DeleteConsumerGroupRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 消费组名称。
	Group string `json:"group"`
}

DeleteConsumerGroupRequest Request Object

func (DeleteConsumerGroupRequest) String

type DeleteConsumerGroupResponse

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

DeleteConsumerGroupResponse Response Object

func (DeleteConsumerGroupResponse) String

type DeleteInstanceRequest

type DeleteInstanceRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`
}

DeleteInstanceRequest Request Object

func (DeleteInstanceRequest) String

func (o DeleteInstanceRequest) String() string

type DeleteInstanceResponse

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

DeleteInstanceResponse Response Object

func (DeleteInstanceResponse) String

func (o DeleteInstanceResponse) String() string

type DeleteRocketMqMigrationTaskRequest added in v0.1.42

type DeleteRocketMqMigrationTaskRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

DeleteRocketMqMigrationTaskRequest Request Object

func (DeleteRocketMqMigrationTaskRequest) String added in v0.1.42

type DeleteRocketMqMigrationTaskResponse added in v0.1.42

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

DeleteRocketMqMigrationTaskResponse Response Object

func (DeleteRocketMqMigrationTaskResponse) String added in v0.1.42

type DeleteTopicRequest

type DeleteTopicRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 主题名称。
	Topic string `json:"topic"`
}

DeleteTopicRequest Request Object

func (DeleteTopicRequest) String

func (o DeleteTopicRequest) String() string

type DeleteTopicResponse

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

DeleteTopicResponse Response Object

func (DeleteTopicResponse) String

func (o DeleteTopicResponse) String() string

type DeleteUserRequest

type DeleteUserRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 用户名。
	UserName string `json:"user_name"`
}

DeleteUserRequest Request Object

func (DeleteUserRequest) String

func (o DeleteUserRequest) String() string

type DeleteUserResponse

type DeleteUserResponse struct {

	// 信息。
	Message        *string `json:"message,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteUserResponse Response Object

func (DeleteUserResponse) String

func (o DeleteUserResponse) String() string

type ExportDlqMessageReq

type ExportDlqMessageReq struct {

	// 主题名称。
	Topic *string `json:"topic,omitempty"`

	// 消息ID列表。
	MsgIdList *[]string `json:"msg_id_list,omitempty"`

	// 唯一Key列表。
	UniqKeyList *[]string `json:"uniq_key_list,omitempty"`
}

func (ExportDlqMessageReq) String

func (o ExportDlqMessageReq) String() string

type ExportDlqMessageRequest

type ExportDlqMessageRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

ExportDlqMessageRequest Request Object

func (ExportDlqMessageRequest) String

func (o ExportDlqMessageRequest) String() string

type ExportDlqMessageResponse

type ExportDlqMessageResponse struct {
	Body           *[]Message `json:"body,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ExportDlqMessageResponse Response Object

func (ExportDlqMessageResponse) String

func (o ExportDlqMessageResponse) String() string

type ListAccessPolicyRespPolicies

type ListAccessPolicyRespPolicies struct {

	// 用户名。
	AccessKey *string `json:"access_key,omitempty"`

	// 密钥。
	SecretKey *string `json:"secret_key,omitempty"`

	// IP白名单。
	WhiteRemoteAddress *string `json:"white_remote_address,omitempty"`

	// 是否为管理员。
	Admin *bool `json:"admin,omitempty"`

	// 权限。
	Perm *string `json:"perm,omitempty"`
}

func (ListAccessPolicyRespPolicies) String

type ListAvailableZonesRequest

type ListAvailableZonesRequest struct {
}

ListAvailableZonesRequest Request Object

func (ListAvailableZonesRequest) String

func (o ListAvailableZonesRequest) String() string

type ListAvailableZonesRespAvailableZones

type ListAvailableZonesRespAvailableZones struct {

	// 是否售罄。
	SoldOut *bool `json:"soldOut,omitempty"`

	// 可用区ID。
	Id *string `json:"id,omitempty"`

	// 可用区编码。
	Code *string `json:"code,omitempty"`

	// 可用区名称。
	Name *string `json:"name,omitempty"`

	// 可用区端口号。
	Port *string `json:"port,omitempty"`

	// 分区上是否还有可用资源。
	ResourceAvailability *string `json:"resource_availability,omitempty"`

	// 是否为默认可用区。
	DefaultAz *bool `json:"default_az,omitempty"`

	// 剩余时间。
	RemainTime *int64 `json:"remain_time,omitempty"`

	// 是否支持IPv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`
}

func (ListAvailableZonesRespAvailableZones) String

type ListAvailableZonesResponse

type ListAvailableZonesResponse struct {

	// 区域ID。
	RegionId *string `json:"region_id,omitempty"`

	// 可用区数组。
	AvailableZones *[]ListAvailableZonesRespAvailableZones `json:"available_zones,omitempty"`
	HttpStatusCode int                                     `json:"-"`
}

ListAvailableZonesResponse Response Object

func (ListAvailableZonesResponse) String

type ListBrokersRequest

type ListBrokersRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`
}

ListBrokersRequest Request Object

func (ListBrokersRequest) String

func (o ListBrokersRequest) String() string

type ListBrokersRespBrokers

type ListBrokersRespBrokers struct {

	// 全部代理ID。
	Ids *[]float32 `json:"ids,omitempty"`

	// 节点名称。
	BrokerName *string `json:"broker_name,omitempty"`
}

func (ListBrokersRespBrokers) String

func (o ListBrokersRespBrokers) String() string

type ListBrokersResponse

type ListBrokersResponse struct {

	// 代理列表。
	Brokers        *[]ListBrokersRespBrokers `json:"brokers,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

ListBrokersResponse Response Object

func (ListBrokersResponse) String

func (o ListBrokersResponse) String() string

type ListConsumeGroupAccessPolicyRequest

type ListConsumeGroupAccessPolicyRequest struct {

	// 消息引擎。
	Engine ListConsumeGroupAccessPolicyRequestEngine `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *string `json:"offset,omitempty"`

	// 查询数量。
	Limit *string `json:"limit,omitempty"`
}

ListConsumeGroupAccessPolicyRequest Request Object

func (ListConsumeGroupAccessPolicyRequest) String

type ListConsumeGroupAccessPolicyRequestEngine

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

func (ListConsumeGroupAccessPolicyRequestEngine) MarshalJSON

func (*ListConsumeGroupAccessPolicyRequestEngine) UnmarshalJSON

func (ListConsumeGroupAccessPolicyRequestEngine) Value added in v0.0.90

type ListConsumeGroupAccessPolicyRequestEngineEnum

type ListConsumeGroupAccessPolicyRequestEngineEnum struct {
	RELIABILITY ListConsumeGroupAccessPolicyRequestEngine
}

func GetListConsumeGroupAccessPolicyRequestEngineEnum

func GetListConsumeGroupAccessPolicyRequestEngineEnum() ListConsumeGroupAccessPolicyRequestEngineEnum

type ListConsumeGroupAccessPolicyResponse

type ListConsumeGroupAccessPolicyResponse struct {

	// 用户列表。
	Policies *[]ListAccessPolicyRespPolicies `json:"policies,omitempty"`

	// 总用户个数。
	Total float32 `json:"total,omitempty"`

	// 主题或消费组名称。
	Name           *string `json:"name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListConsumeGroupAccessPolicyResponse Response Object

func (ListConsumeGroupAccessPolicyResponse) String

type ListConsumerGroupOfTopicRequest

type ListConsumerGroupOfTopicRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 主题名称。
	Topic string `json:"topic"`

	// 当次查询返回的最大个数,默认值为10,取值范围为1~50。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量,表示从此偏移量开始查询,offset大于等于0。
	Offset *int32 `json:"offset,omitempty"`
}

ListConsumerGroupOfTopicRequest Request Object

func (ListConsumerGroupOfTopicRequest) String

type ListConsumerGroupOfTopicResponse

type ListConsumerGroupOfTopicResponse struct {

	// 消费组列表。
	Groups         *[]string `json:"groups,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ListConsumerGroupOfTopicResponse Response Object

func (ListConsumerGroupOfTopicResponse) String

type ListInstanceConsumerGroupsRequest

type ListInstanceConsumerGroupsRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 消费组名称。
	Group *string `json:"group,omitempty"`

	// 查询数量。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *int32 `json:"offset,omitempty"`
}

ListInstanceConsumerGroupsRequest Request Object

func (ListInstanceConsumerGroupsRequest) String

type ListInstanceConsumerGroupsResponse

type ListInstanceConsumerGroupsResponse struct {

	// 消费组总数。
	Total float32 `json:"total,omitempty"`

	// 消费组列表。
	Groups *[]ConsumerGroup `json:"groups,omitempty"`

	// 最大可创建消费组数量。
	Max float32 `json:"max,omitempty"`

	// 剩余可创建消费组数量。
	Remaining float32 `json:"remaining,omitempty"`

	// 下个分页的offset。
	NextOffset float32 `json:"next_offset,omitempty"`

	// 上个分页的offset。
	PreviousOffset float32 `json:"previous_offset,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListInstanceConsumerGroupsResponse Response Object

func (ListInstanceConsumerGroupsResponse) String

type ListInstancesRequest

type ListInstancesRequest struct {

	// 消息引擎。
	Engine *ListInstancesRequestEngine `json:"engine,omitempty"`

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

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

	// 实例状态,详细状态说明请参考[实例状态说明](hrm-api-0010.xml)。
	Status *ListInstancesRequestStatus `json:"status,omitempty"`

	// 是否返回创建失败的实例数。  当参数值为“true”时,返回创建失败的实例数。参数值为“false”或者其他值,不返回创建失败的实例数。
	IncludeFailure *ListInstancesRequestIncludeFailure `json:"include_failure,omitempty"`

	// 是否按照实例名称进行精确匹配查询。  默认为“false”,表示模糊匹配实例名称查询。若参数值为“true”表示按照实例名称进行精确匹配查询。
	ExactMatchName *ListInstancesRequestExactMatchName `json:"exact_match_name,omitempty"`

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

	// 当次查询返回的最大个数,默认值为10,取值范围为1~50。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *int32 `json:"offset,omitempty"`
}

ListInstancesRequest Request Object

func (ListInstancesRequest) String

func (o ListInstancesRequest) String() string

type ListInstancesRequestEngine added in v0.1.50

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

func (ListInstancesRequestEngine) MarshalJSON added in v0.1.50

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

func (*ListInstancesRequestEngine) UnmarshalJSON added in v0.1.50

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

func (ListInstancesRequestEngine) Value added in v0.1.50

type ListInstancesRequestEngineEnum added in v0.1.50

type ListInstancesRequestEngineEnum struct {
	RELIABILITY ListInstancesRequestEngine
}

func GetListInstancesRequestEngineEnum added in v0.1.50

func GetListInstancesRequestEngineEnum() ListInstancesRequestEngineEnum

type ListInstancesRequestExactMatchName

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

func (ListInstancesRequestExactMatchName) MarshalJSON

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

func (*ListInstancesRequestExactMatchName) UnmarshalJSON

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

func (ListInstancesRequestExactMatchName) Value added in v0.0.90

type ListInstancesRequestExactMatchNameEnum

type ListInstancesRequestExactMatchNameEnum struct {
	TRUE  ListInstancesRequestExactMatchName
	FALSE ListInstancesRequestExactMatchName
}

func GetListInstancesRequestExactMatchNameEnum

func GetListInstancesRequestExactMatchNameEnum() ListInstancesRequestExactMatchNameEnum

type ListInstancesRequestIncludeFailure

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

func (ListInstancesRequestIncludeFailure) MarshalJSON

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

func (*ListInstancesRequestIncludeFailure) UnmarshalJSON

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

func (ListInstancesRequestIncludeFailure) Value added in v0.0.90

type ListInstancesRequestIncludeFailureEnum

type ListInstancesRequestIncludeFailureEnum struct {
	TRUE  ListInstancesRequestIncludeFailure
	FALSE ListInstancesRequestIncludeFailure
}

func GetListInstancesRequestIncludeFailureEnum

func GetListInstancesRequestIncludeFailureEnum() ListInstancesRequestIncludeFailureEnum

type ListInstancesRequestStatus

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

func (ListInstancesRequestStatus) MarshalJSON

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

func (*ListInstancesRequestStatus) UnmarshalJSON

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

func (ListInstancesRequestStatus) Value added in v0.0.90

type ListInstancesResponse

type ListInstancesResponse struct {

	// 实例列表。
	Instances *[]ShowInstanceResp `json:"instances,omitempty"`

	// 实例数量。
	InstanceNum    *int32 `json:"instance_num,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListInstancesResponse Response Object

func (ListInstancesResponse) String

func (o ListInstancesResponse) String() string

type ListMessageTraceRequest

type ListMessageTraceRequest struct {

	// 消息引擎。
	Engine ListMessageTraceRequestEngine `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 消息ID。
	MsgId string `json:"msg_id"`
}

ListMessageTraceRequest Request Object

func (ListMessageTraceRequest) String

func (o ListMessageTraceRequest) String() string

type ListMessageTraceRequestEngine

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

func (ListMessageTraceRequestEngine) MarshalJSON

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

func (*ListMessageTraceRequestEngine) UnmarshalJSON

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

func (ListMessageTraceRequestEngine) Value added in v0.0.90

type ListMessageTraceRequestEngineEnum

type ListMessageTraceRequestEngineEnum struct {
	RELIABILITY ListMessageTraceRequestEngine
}

func GetListMessageTraceRequestEngineEnum

func GetListMessageTraceRequestEngineEnum() ListMessageTraceRequestEngineEnum

type ListMessageTraceRespTrace

type ListMessageTraceRespTrace struct {

	// 是否成功。
	Success *bool `json:"success,omitempty"`

	// 轨迹类型
	TraceType *ListMessageTraceRespTraceTraceType `json:"trace_type,omitempty"`

	// 时间。
	Timestamp float32 `json:"timestamp,omitempty"`

	// 生产组或消费组。
	GroupName *string `json:"group_name,omitempty"`

	// 耗时。
	CostTime float32 `json:"cost_time,omitempty"`

	// 请求ID。
	RequestId *string `json:"request_id,omitempty"`

	// 消费状态。
	ConsumeStatus float32 `json:"consume_status,omitempty"`

	// 主题名称。
	Topic *string `json:"topic,omitempty"`

	// 消息ID。
	MsgId *string `json:"msg_id,omitempty"`

	// offset消息ID。
	OffsetMsgId *string `json:"offset_msg_id,omitempty"`

	// 消息的标签。
	Tags *string `json:"tags,omitempty"`

	// 消息的keys。
	Keys *string `json:"keys,omitempty"`

	// 存储消息的主机IP。
	StoreHost *string `json:"store_host,omitempty"`

	// 产生消息的主机IP。
	ClientHost *string `json:"client_host,omitempty"`

	// 重试次数。
	RetryTimes *string `json:"retry_times,omitempty"`

	// 消息体长度。
	BodyLength float32 `json:"body_length,omitempty"`

	// 消息类型。
	MsgType *ListMessageTraceRespTraceMsgType `json:"msg_type,omitempty"`

	// 事务状态。
	TransactionState *ListMessageTraceRespTraceTransactionState `json:"transaction_state,omitempty"`

	// 事务ID。
	TransactionId *string `json:"transaction_id,omitempty"`

	// 是否为事务回查的响应。
	FromTransactionCheck *bool `json:"from_transaction_check,omitempty"`
}

func (ListMessageTraceRespTrace) String

func (o ListMessageTraceRespTrace) String() string

type ListMessageTraceRespTraceMsgType

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

func (ListMessageTraceRespTraceMsgType) MarshalJSON

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

func (*ListMessageTraceRespTraceMsgType) UnmarshalJSON

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

func (ListMessageTraceRespTraceMsgType) Value added in v0.0.90

type ListMessageTraceRespTraceMsgTypeEnum

type ListMessageTraceRespTraceMsgTypeEnum struct {
	NORMAL_MSG       ListMessageTraceRespTraceMsgType
	TRANS_MSG_HALF   ListMessageTraceRespTraceMsgType
	TRANS_MSG_COMMIT ListMessageTraceRespTraceMsgType
	DELAY_MSG        ListMessageTraceRespTraceMsgType
}

func GetListMessageTraceRespTraceMsgTypeEnum

func GetListMessageTraceRespTraceMsgTypeEnum() ListMessageTraceRespTraceMsgTypeEnum

type ListMessageTraceRespTraceTraceType

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

func (ListMessageTraceRespTraceTraceType) MarshalJSON

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

func (*ListMessageTraceRespTraceTraceType) UnmarshalJSON

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

func (ListMessageTraceRespTraceTraceType) Value added in v0.0.90

type ListMessageTraceRespTraceTransactionState

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

func (ListMessageTraceRespTraceTransactionState) MarshalJSON

func (*ListMessageTraceRespTraceTransactionState) UnmarshalJSON

func (ListMessageTraceRespTraceTransactionState) Value added in v0.0.90

type ListMessageTraceResponse

type ListMessageTraceResponse struct {

	// 消息轨迹列表。
	Trace          *[]ListMessageTraceRespTrace `json:"trace,omitempty"`
	HttpStatusCode int                          `json:"-"`
}

ListMessageTraceResponse Response Object

func (ListMessageTraceResponse) String

func (o ListMessageTraceResponse) String() string

type ListMessagesRequest

type ListMessagesRequest struct {

	// 消息引擎。
	Engine ListMessagesRequestEngine `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 主题名称。
	Topic string `json:"topic"`

	// 查询数量。
	Limit *string `json:"limit,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *string `json:"offset,omitempty"`

	// 消息的key
	Key *string `json:"key,omitempty"`

	// 开始时间(不通过msg_id精确查询消息时,此参数必填)。
	StartTime *string `json:"start_time,omitempty"`

	// 结束时间(不通过msg_id精确查询消息时,此参数必填)。
	EndTime *string `json:"end_time,omitempty"`

	// 消息ID。
	MsgId *string `json:"msg_id,omitempty"`
}

ListMessagesRequest Request Object

func (ListMessagesRequest) String

func (o ListMessagesRequest) String() string

type ListMessagesRequestEngine

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

func (ListMessagesRequestEngine) MarshalJSON

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

func (*ListMessagesRequestEngine) UnmarshalJSON

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

func (ListMessagesRequestEngine) Value added in v0.0.90

type ListMessagesRequestEngineEnum

type ListMessagesRequestEngineEnum struct {
	RELIABILITY ListMessagesRequestEngine
}

func GetListMessagesRequestEngineEnum

func GetListMessagesRequestEngineEnum() ListMessagesRequestEngineEnum

type ListMessagesResponse

type ListMessagesResponse struct {

	// 消息列表。
	Messages *[]Message `json:"messages,omitempty"`

	// 消息总数。
	Total          float32 `json:"total,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListMessagesResponse Response Object

func (ListMessagesResponse) String

func (o ListMessagesResponse) String() string

type ListRocketInstanceTopicsRequest added in v0.1.22

type ListRocketInstanceTopicsRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 查询数量,取值范围为1~50。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *int32 `json:"offset,omitempty"`
}

ListRocketInstanceTopicsRequest Request Object

func (ListRocketInstanceTopicsRequest) String added in v0.1.22

type ListRocketInstanceTopicsResponse added in v0.1.22

type ListRocketInstanceTopicsResponse struct {

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

	// 最大可创建topic数量。
	Max *int32 `json:"max,omitempty"`

	// 剩余可创建topic数量。
	Remaining *int32 `json:"remaining,omitempty"`

	// 下个分页的offset。
	NextOffset *int32 `json:"next_offset,omitempty"`

	// 上个分页的offset。
	PreviousOffset *int32 `json:"previous_offset,omitempty"`

	// topic列表。
	Topics         *[]Topic `json:"topics,omitempty"`
	HttpStatusCode int      `json:"-"`
}

ListRocketInstanceTopicsResponse Response Object

func (ListRocketInstanceTopicsResponse) String added in v0.1.22

type ListRocketMqMigrationTaskRequest added in v0.1.42

type ListRocketMqMigrationTaskRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 任务ID
	Id *string `json:"id,omitempty"`

	// 查询类型
	Type *ListRocketMqMigrationTaskRequestType `json:"type,omitempty"`

	// 当前页,从1开始
	Offset *string `json:"offset,omitempty"`

	// 当前页大小
	Limit *string `json:"limit,omitempty"`

	// - 查询vhost列表时,该字段可为空。 - 查询exchange列表时,该字段为exchange所属vhost名称。 - 查询queue列表时,该字段为queue所属vhost-所属exchange,例vhost1-exchange1。
	Name *string `json:"name,omitempty"`
}

ListRocketMqMigrationTaskRequest Request Object

func (ListRocketMqMigrationTaskRequest) String added in v0.1.42

type ListRocketMqMigrationTaskRequestType added in v0.1.42

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

func (ListRocketMqMigrationTaskRequestType) MarshalJSON added in v0.1.42

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

func (*ListRocketMqMigrationTaskRequestType) UnmarshalJSON added in v0.1.42

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

func (ListRocketMqMigrationTaskRequestType) Value added in v0.1.42

type ListRocketMqMigrationTaskRequestTypeEnum added in v0.1.42

func GetListRocketMqMigrationTaskRequestTypeEnum added in v0.1.42

func GetListRocketMqMigrationTaskRequestTypeEnum() ListRocketMqMigrationTaskRequestTypeEnum

type ListRocketMqMigrationTaskResponse added in v0.1.42

type ListRocketMqMigrationTaskResponse struct {

	// 元数据迁移任务总数。
	Total *int32 `json:"total,omitempty"`

	// 元数据迁移任务列表。
	Task           *[]MetadataTask `json:"task,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ListRocketMqMigrationTaskResponse Response Object

func (ListRocketMqMigrationTaskResponse) String added in v0.1.42

type ListTopicAccessPolicyRequest

type ListTopicAccessPolicyRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 主题名称。
	Topic string `json:"topic"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *string `json:"offset,omitempty"`

	// 查询数量。
	Limit *string `json:"limit,omitempty"`
}

ListTopicAccessPolicyRequest Request Object

func (ListTopicAccessPolicyRequest) String

type ListTopicAccessPolicyResponse

type ListTopicAccessPolicyResponse struct {

	// 用户列表。
	Policies *[]ListAccessPolicyRespPolicies `json:"policies,omitempty"`

	// 总用户个数。
	Total float32 `json:"total,omitempty"`

	// 主题或消费组名称。
	Name           *string `json:"name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListTopicAccessPolicyResponse Response Object

func (ListTopicAccessPolicyResponse) String

type ListUserRequest

type ListUserRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *string `json:"offset,omitempty"`

	// 查询数量。
	Limit *string `json:"limit,omitempty"`
}

ListUserRequest Request Object

func (ListUserRequest) String

func (o ListUserRequest) String() string

type ListUserResponse

type ListUserResponse struct {

	// 用户列表。
	Users *[]User `json:"users,omitempty"`

	// 总用户个数。
	Total          float32 `json:"total,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ListUserResponse Response Object

func (ListUserResponse) String

func (o ListUserResponse) String() string

type Message

type Message struct {

	// 消息ID。
	MsgId *string `json:"msg_id,omitempty"`

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

	// 主题名称。
	Topic *string `json:"topic,omitempty"`

	// 存储消息的时间。
	StoreTimestamp float32 `json:"store_timestamp,omitempty"`

	// 产生消息的时间。
	BornTimestamp float32 `json:"born_timestamp,omitempty"`

	// 重试次数。
	ReconsumeTimes *int32 `json:"reconsume_times,omitempty"`

	// 消息体。
	Body *string `json:"body,omitempty"`

	// 消息体校验和。
	BodyCrc float32 `json:"body_crc,omitempty"`

	// 存储大小。
	StoreSize float32 `json:"store_size,omitempty"`

	// 消息属性列表。
	PropertyList *[]MessagePropertyList `json:"property_list,omitempty"`

	// 产生消息的主机IP。
	BornHost *string `json:"born_host,omitempty"`

	// 存储消息的主机IP。
	StoreHost *string `json:"store_host,omitempty"`

	// 队列ID。
	QueueId *int32 `json:"queue_id,omitempty"`

	// 在队列中的偏移量。
	QueueOffset *int32 `json:"queue_offset,omitempty"`
}

Message 消息。

func (Message) String

func (o Message) String() string

type MessagePropertyList

type MessagePropertyList struct {

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

	// 属性值。
	Value *string `json:"value,omitempty"`
}

func (MessagePropertyList) String

func (o MessagePropertyList) String() string

type MetadataDeleteReq added in v0.1.42

type MetadataDeleteReq struct {

	// 需要删除的任务列表。
	TaskIds []string `json:"task_ids"`
}

func (MetadataDeleteReq) String added in v0.1.42

func (o MetadataDeleteReq) String() string

type MetadataTask added in v0.1.42

type MetadataTask struct {

	// 元数据迁移任务ID。
	Id *string `json:"id,omitempty"`

	// 元数据迁移任务名称。
	Name *string `json:"name,omitempty"`

	// 元数据迁移任务开始时间。
	StartDate *string `json:"start_date,omitempty"`

	// 元数据迁移任务状态。
	Status *string `json:"status,omitempty"`

	// 元数据迁移类型。
	Type *string `json:"type,omitempty"`
}

MetadataTask 元数据迁移任务。

func (MetadataTask) String added in v0.1.42

func (o MetadataTask) String() string

type MigrationRabbitBindingMetadata added in v0.1.72

type MigrationRabbitBindingMetadata struct {

	// vhost名称。
	Vhost *string `json:"vhost,omitempty"`

	// 消息的来源。
	Source *string `json:"source,omitempty"`

	// 消息的目标。
	Destination *string `json:"destination,omitempty"`

	// 目标的类型。
	DestinationType *string `json:"destination_type,omitempty"`

	// 路由键。
	RoutingKey *string `json:"routing_key,omitempty"`
}

MigrationRabbitBindingMetadata RocketMQ元数据迁移,RabbitMQ binding元数据。

func (MigrationRabbitBindingMetadata) String added in v0.1.72

type MigrationRabbitExchangeMetadata added in v0.1.72

type MigrationRabbitExchangeMetadata struct {

	// vhost名称。
	Vhost *string `json:"vhost,omitempty"`

	// 交换机名称。
	Name *string `json:"name,omitempty"`

	// 交换机类型。
	Type *string `json:"type,omitempty"`

	// 是否持久化。
	Durable *bool `json:"durable,omitempty"`
}

MigrationRabbitExchangeMetadata RocketMQ元数据迁移,RabbitMQ交换机元数据。

func (MigrationRabbitExchangeMetadata) String added in v0.1.72

type MigrationRabbitQueueMetadata added in v0.1.72

type MigrationRabbitQueueMetadata struct {

	// vhost名称。
	Vhost *string `json:"vhost,omitempty"`

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

	// 是否持久化。
	Durable *bool `json:"durable,omitempty"`
}

MigrationRabbitQueueMetadata RocketMQ元数据迁移,RabbitMQ队列元数据。

func (MigrationRabbitQueueMetadata) String added in v0.1.72

type MigrationRabbitVhostMetadata added in v0.1.72

type MigrationRabbitVhostMetadata struct {

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

MigrationRabbitVhostMetadata RocketMQ元数据迁移,RabbitMQ vhost元数据。

func (MigrationRabbitVhostMetadata) String added in v0.1.72

type MigrationRocketMqSubscriptionGroup added in v0.1.72

type MigrationRocketMqSubscriptionGroup struct {

	// 消费组名。
	GroupName *string `json:"groupName,omitempty"`

	// 是否允许以广播模式消费。
	ConsumeBroadcastEnable *bool `json:"consumeBroadcastEnable,omitempty"`

	// 是否允许消费。
	ConsumeEnable *bool `json:"consumeEnable,omitempty"`

	// 是否从最小偏移量开始消费。
	ConsumeFromMinEnable *bool `json:"consumeFromMinEnable,omitempty"`

	// 消费者ID变化时是否通知。
	NotifyConsumerIdsChangedEnable *bool `json:"notifyConsumerIdsChangedEnable,omitempty"`

	// 消费最大重试次数。
	RetryMaxTimes *int32 `json:"retryMaxTimes,omitempty"`

	// 重试队列个数。
	RetryQueueNums *int32 `json:"retryQueueNums,omitempty"`

	// 慢消费时选择的broker节点ID。
	WhichBrokerWhenConsumeSlow *int64 `json:"whichBrokerWhenConsumeSlow,omitempty"`
}

MigrationRocketMqSubscriptionGroup RocketMQ元数据迁移,RocketMQ消费组元数据。

func (MigrationRocketMqSubscriptionGroup) String added in v0.1.72

type MigrationRocketMqTopicConfig added in v0.1.72

type MigrationRocketMqTopicConfig struct {

	// topic名称。
	TopicName *string `json:"topicName,omitempty"`

	// 是否有序消息。
	Order *bool `json:"order,omitempty"`

	// topic权限。
	Perm *int32 `json:"perm,omitempty"`

	// 读队列个数。
	ReadQueueNums *int32 `json:"readQueueNums,omitempty"`

	// 写队列个数。
	WriteQueueNums *int32 `json:"writeQueueNums,omitempty"`

	// topic过滤类型。   - SINGLE_TAG:单标签   - MULTI_TAG:多标签
	TopicFilterType *string `json:"topicFilterType,omitempty"`

	// topic系统标志位。
	TopicSysFlag *int32 `json:"topicSysFlag,omitempty"`
}

MigrationRocketMqTopicConfig RocketMQ元数据迁移,RocketMQ topic元数据。

func (MigrationRocketMqTopicConfig) String added in v0.1.72

type ModifyConfigReq added in v0.1.71

type ModifyConfigReq struct {

	// RocketMQ配置。
	RocketmqConfigs *[]RocketMqConfigReq `json:"rocketmq_configs,omitempty"`
}

func (ModifyConfigReq) String added in v0.1.71

func (o ModifyConfigReq) String() string

type Queue added in v0.1.37

type Queue struct {

	// 队列ID
	Id *int32 `json:"id,omitempty"`

	// 队列消费堆积总数
	Lag *int64 `json:"lag,omitempty"`

	// 队列消息总数
	BrokerOffset *int64 `json:"broker_offset,omitempty"`

	// 已消费消息数
	ConsumerOffset *int64 `json:"consumer_offset,omitempty"`

	// 最新消费消息的存储时间,unix毫秒时间戳格式
	LastMessageTime *int64 `json:"last_message_time,omitempty"`
}

func (Queue) String added in v0.1.37

func (o Queue) String() string

type ResendReq added in v0.1.42

type ResendReq struct {

	// Group ID。
	Group *string `json:"group,omitempty"`

	// 消息所属topic。
	Topic *string `json:"topic,omitempty"`

	// 客户端ID。
	ClientId *string `json:"client_id,omitempty"`

	// 消息列表。
	MsgIdList *[]string `json:"msg_id_list,omitempty"`
}

func (ResendReq) String added in v0.1.42

func (o ResendReq) String() string

type ResetConsumeOffsetReq

type ResetConsumeOffsetReq struct {

	// 重置的主题。
	Topic string `json:"topic"`

	// 重置的时间。
	Timestamp float32 `json:"timestamp"`
}

func (ResetConsumeOffsetReq) String

func (o ResetConsumeOffsetReq) String() string

type ResetConsumeOffsetRequest

type ResetConsumeOffsetRequest struct {

	// 引擎类型:reliability。
	Engine ResetConsumeOffsetRequestEngine `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 消费组名称。
	GroupId string `json:"group_id"`

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

ResetConsumeOffsetRequest Request Object

func (ResetConsumeOffsetRequest) String

func (o ResetConsumeOffsetRequest) String() string

type ResetConsumeOffsetRequestEngine

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

func (ResetConsumeOffsetRequestEngine) MarshalJSON

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

func (*ResetConsumeOffsetRequestEngine) UnmarshalJSON

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

func (ResetConsumeOffsetRequestEngine) Value added in v0.0.90

type ResetConsumeOffsetRequestEngineEnum

type ResetConsumeOffsetRequestEngineEnum struct {
	RELIABILITY ResetConsumeOffsetRequestEngine
}

func GetResetConsumeOffsetRequestEngineEnum

func GetResetConsumeOffsetRequestEngineEnum() ResetConsumeOffsetRequestEngineEnum

type ResetConsumeOffsetRespQueues

type ResetConsumeOffsetRespQueues struct {

	// 队列所在的broker。
	BrokerName *string `json:"broker_name,omitempty"`

	// 队列ID。
	QueueId *int32 `json:"queue_id,omitempty"`

	// 重置消费进度。
	TimestampOffset *int64 `json:"timestamp_offset,omitempty"`
}

func (ResetConsumeOffsetRespQueues) String

type ResetConsumeOffsetResponse

type ResetConsumeOffsetResponse struct {

	// 重置的队列。
	Queues         *[]ResetConsumeOffsetRespQueues `json:"queues,omitempty"`
	HttpStatusCode int                             `json:"-"`
}

ResetConsumeOffsetResponse Response Object

func (ResetConsumeOffsetResponse) String

type ResizeEngineInstanceReq added in v0.1.70

type ResizeEngineInstanceReq struct {

	// 变更类型  取值范围: - storage:存储空间扩容,代理数量不变。 - horizontal:代理数量扩容,每个broker的存储空间不变。 - vertical:垂直扩容,broker的底层虚机规格变更,代理数量和存储空间不变。
	OperType string `json:"oper_type"`

	// 当oper_type类型是storage或horizontal时,该参数有效且必填,实例存储空间 = 代理数量 * 每个broker的存储空间。  - 当oper_type类型是storage时,代理数量不变,每个broker存储空间最少扩容100GB。  - 当oper_type类型是horizontal时,每个broker的存储空间不变。
	NewStorageSpace *int32 `json:"new_storage_space,omitempty"`

	// 当oper_type类型是vertical时,该参数才有效且必填。
	NewProductId *string `json:"new_product_id,omitempty"`

	// 代理数量  当oper_type参数为horizontal时,该参数必填。
	NewBrokerNum *int32 `json:"new_broker_num,omitempty"`

	// 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 当oper_type参数为horizontal且开启了公网访问时,此参数必填。
	PublicipId *string `json:"publicip_id,omitempty"`
}

ResizeEngineInstanceReq 变更类型 取值范围: - storage:存储空间扩容,代理数量不变。 - horizontal:代理数量扩容,每个broker的存储空间不变。 - vertical:垂直扩缩容,broker的底层虚机规格变更,代理数量和存储空间不变。

func (ResizeEngineInstanceReq) String added in v0.1.70

func (o ResizeEngineInstanceReq) String() string

type ResizeInstanceRequest added in v0.1.70

type ResizeInstanceRequest struct {

	// 消息引擎的类型。支持的类型为rocketmq。
	Engine string `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

ResizeInstanceRequest Request Object

func (ResizeInstanceRequest) String added in v0.1.70

func (o ResizeInstanceRequest) String() string

type ResizeInstanceResponse added in v0.1.70

type ResizeInstanceResponse struct {

	// 规格变更任务ID。
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

ResizeInstanceResponse Response Object

func (ResizeInstanceResponse) String added in v0.1.70

func (o ResizeInstanceResponse) String() string

type RocketMqConfigReq added in v0.1.71

type RocketMqConfigReq struct {

	// RocketMQ配置名称
	Name *RocketMqConfigReqName `json:"name,omitempty"`

	// RocketMQ配置目标值
	Value *string `json:"value,omitempty"`
}

func (RocketMqConfigReq) String added in v0.1.71

func (o RocketMqConfigReq) String() string

type RocketMqConfigReqName added in v0.1.71

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

func (RocketMqConfigReqName) MarshalJSON added in v0.1.71

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

func (*RocketMqConfigReqName) UnmarshalJSON added in v0.1.71

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

func (RocketMqConfigReqName) Value added in v0.1.71

func (c RocketMqConfigReqName) Value() string

type RocketMqConfigReqNameEnum added in v0.1.71

type RocketMqConfigReqNameEnum struct {
	FILE_RESERVED_TIME RocketMqConfigReqName
}

func GetRocketMqConfigReqNameEnum added in v0.1.71

func GetRocketMqConfigReqNameEnum() RocketMqConfigReqNameEnum

type RocketMqConfigResp added in v0.1.71

type RocketMqConfigResp struct {

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

	// RocketMQ配置当前值
	Value *string `json:"value,omitempty"`

	// RocketMQ配置的类型
	ConfigType *string `json:"config_type,omitempty"`

	// RocketMQ配置的默认值
	DefaultValue *string `json:"default_value,omitempty"`

	// RocketMQ配置取值的范围
	ValidValues *string `json:"valid_values,omitempty"`

	// RocketMQ配置值的类型
	ValueType *string `json:"value_type,omitempty"`
}

func (RocketMqConfigResp) String added in v0.1.71

func (o RocketMqConfigResp) String() string

type RocketMqExtendProductInfoEntity added in v0.1.70

type RocketMqExtendProductInfoEntity struct {

	// 实例类型
	Type *string `json:"type,omitempty"`

	// 产品ID
	ProductId *string `json:"product_id,omitempty"`

	// 该产品使用的ECS规格
	EcsFlavorId *string `json:"ecs_flavor_id,omitempty"`

	// 账单计费类型。
	BillingCode *string `json:"billing_code,omitempty"`

	// 支持的CPU架构类型
	ArchTypes *[]string `json:"arch_types,omitempty"`

	// 支持的计费模式类型
	ChargingMode *[]string `json:"charging_mode,omitempty"`

	// 磁盘IO信息
	Ios *[]RocketMqExtendProductIosEntity `json:"ios,omitempty"`

	Properties *RocketMqExtendProductPropertiesEntity `json:"properties,omitempty"`

	// 有可用资源的可用区列表
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 资源售罄的可用区列表
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	// 支持的特性功能
	SupportFeatures *[]RocketMqProductSupportFeaturesEntity `json:"support_features,omitempty"`

	// 是否为擎天实例。
	QingtianIncompatible *bool `json:"qingtian_incompatible,omitempty"`
}

func (RocketMqExtendProductInfoEntity) String added in v0.1.70

type RocketMqExtendProductIosEntity added in v0.1.70

type RocketMqExtendProductIosEntity struct {

	// 存储IO规格
	IoSpec *string `json:"io_spec,omitempty"`

	// 有可用资源的可用区列表
	AvailableZones *[]string `json:"available_zones,omitempty"`

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

	// 资源售罄的可用区列表
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`
}

RocketMqExtendProductIosEntity 磁盘IO信息

func (RocketMqExtendProductIosEntity) String added in v0.1.70

type RocketMqExtendProductPropertiesEntity added in v0.1.70

type RocketMqExtendProductPropertiesEntity struct {

	// Broker的最大个数。
	MaxBroker *string `json:"max_broker,omitempty"`

	// 每个节点最多能创建的Topic个数。
	MaxTopicPerBroker *string `json:"max_topic_per_broker,omitempty"`

	// 每个节点的最大消费者数。
	MaxConsumerPerBroker *string `json:"max_consumer_per_broker,omitempty"`

	// 每个节点的最大存储。单位为GB
	MaxStoragePerNode *string `json:"max_storage_per_node,omitempty"`

	// Broker的最小个数。
	MinBroker *string `json:"min_broker,omitempty"`

	// 消息引擎版本。
	EngineVersions *string `json:"engine_versions,omitempty"`

	// 每个节点的最小存储。单位为GB
	MinStoragePerNode *string `json:"min_storage_per_node,omitempty"`

	// product_id的别名
	ProductAlias *string `json:"product_alias,omitempty"`
}

RocketMqExtendProductPropertiesEntity 功能特性的键值对。

func (RocketMqExtendProductPropertiesEntity) String added in v0.1.70

type RocketMqProductSupportFeaturesEntity added in v0.1.70

type RocketMqProductSupportFeaturesEntity struct {

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

	// 功能特性的键值对
	Properties map[string]string `json:"properties,omitempty"`
}

RocketMqProductSupportFeaturesEntity 支持的特性功能。

func (RocketMqProductSupportFeaturesEntity) String added in v0.1.70

type SendDlqMessageRequest added in v0.1.43

type SendDlqMessageRequest struct {

	// 消息引擎。
	Engine SendDlqMessageRequestEngine `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

SendDlqMessageRequest Request Object

func (SendDlqMessageRequest) String added in v0.1.43

func (o SendDlqMessageRequest) String() string

type SendDlqMessageRequestEngine added in v0.1.44

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

func (SendDlqMessageRequestEngine) MarshalJSON added in v0.1.44

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

func (*SendDlqMessageRequestEngine) UnmarshalJSON added in v0.1.44

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

func (SendDlqMessageRequestEngine) Value added in v0.1.44

type SendDlqMessageRequestEngineEnum added in v0.1.44

type SendDlqMessageRequestEngineEnum struct {
	RELIABILITY SendDlqMessageRequestEngine
}

func GetSendDlqMessageRequestEngineEnum added in v0.1.44

func GetSendDlqMessageRequestEngineEnum() SendDlqMessageRequestEngineEnum

type SendDlqMessageResponse added in v0.1.43

type SendDlqMessageResponse struct {

	// 重发死信消息结果。
	ResendResults  *[]DeadletterResendRespResendResults `json:"resend_results,omitempty"`
	HttpStatusCode int                                  `json:"-"`
}

SendDlqMessageResponse Response Object

func (SendDlqMessageResponse) String added in v0.1.43

func (o SendDlqMessageResponse) String() string

type ShowConsumerConnectionsRequest added in v0.1.37

type ShowConsumerConnectionsRequest struct {

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

	// 消费组名称
	Group string `json:"group"`

	// 查询数量,取值范围为1~50。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *int32 `json:"offset,omitempty"`

	// 是否查询消费者详细列表,参数为“true”则表示查询详细列表,否则表示查询简易列表。
	IsDetail *bool `json:"is_detail,omitempty"`
}

ShowConsumerConnectionsRequest Request Object

func (ShowConsumerConnectionsRequest) String added in v0.1.37

type ShowConsumerConnectionsResponse added in v0.1.37

type ShowConsumerConnectionsResponse struct {

	// 消费组名称
	GroupName *string `json:"group_name,omitempty"`

	// 消费组是否在线
	Online *bool `json:"online,omitempty"`

	// 订阅关系是否一致
	SubscriptionConsistency *bool `json:"subscription_consistency,omitempty"`

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

	// 下个分页的offset
	NextOffset *int32 `json:"next_offset,omitempty"`

	// 上个分页的offset
	PreviousOffset *int32 `json:"previous_offset,omitempty"`

	// 消费者订阅详情列表
	Clients        *[]ClientData `json:"clients,omitempty"`
	HttpStatusCode int           `json:"-"`
}

ShowConsumerConnectionsResponse Response Object

func (ShowConsumerConnectionsResponse) String added in v0.1.37

type ShowConsumerListOrDetailsRequest

type ShowConsumerListOrDetailsRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 消费组名称。
	Group string `json:"group"`

	// 待查询的topic,不指定时查询topic列表,指定时查询详情。
	Topic *string `json:"topic,omitempty"`

	// 当次查询返回的最大个数,默认值为10,取值范围为1~50。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量,表示从此偏移量开始查询, offset大于等于0。
	Offset *int32 `json:"offset,omitempty"`
}

ShowConsumerListOrDetailsRequest Request Object

func (ShowConsumerListOrDetailsRequest) String

type ShowConsumerListOrDetailsResponse

type ShowConsumerListOrDetailsResponse struct {

	// Topic列表(当查询topic消费“列表”时才显示此参数)。
	Topics *[]string `json:"topics,omitempty"`

	// Topic总数(当查询topic消费“列表”时才显示此参数)。
	Total *int32 `json:"total,omitempty"`

	// 消费堆积总数
	Lag *int64 `json:"lag,omitempty"`

	// 消息总数
	MaxOffset *int64 `json:"max_offset,omitempty"`

	// 已消费消息数
	ConsumerOffset *int64 `json:"consumer_offset,omitempty"`

	// Topic关联代理(当查询topic消费“详情”才显示此参数)。
	Brokers        *[]Brokers `json:"brokers,omitempty"`
	HttpStatusCode int        `json:"-"`
}

ShowConsumerListOrDetailsResponse Response Object

func (ShowConsumerListOrDetailsResponse) String

type ShowEngineInstanceExtendProductInfoRequest added in v0.1.70

type ShowEngineInstanceExtendProductInfoRequest struct {

	// 消息引擎的类型。支持的类型为rocketmq。
	Engine string `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 产品的类型。 advanced:专享版
	Type *ShowEngineInstanceExtendProductInfoRequestType `json:"type,omitempty"`
}

ShowEngineInstanceExtendProductInfoRequest Request Object

func (ShowEngineInstanceExtendProductInfoRequest) String added in v0.1.70

type ShowEngineInstanceExtendProductInfoRequestType added in v0.1.70

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

func (ShowEngineInstanceExtendProductInfoRequestType) MarshalJSON added in v0.1.70

func (*ShowEngineInstanceExtendProductInfoRequestType) UnmarshalJSON added in v0.1.70

func (ShowEngineInstanceExtendProductInfoRequestType) Value added in v0.1.70

type ShowEngineInstanceExtendProductInfoRequestTypeEnum added in v0.1.70

type ShowEngineInstanceExtendProductInfoRequestTypeEnum struct {
	ADVANCED ShowEngineInstanceExtendProductInfoRequestType
}

func GetShowEngineInstanceExtendProductInfoRequestTypeEnum added in v0.1.70

func GetShowEngineInstanceExtendProductInfoRequestTypeEnum() ShowEngineInstanceExtendProductInfoRequestTypeEnum

type ShowEngineInstanceExtendProductInfoResponse added in v0.1.70

type ShowEngineInstanceExtendProductInfoResponse struct {

	// 消息引擎类型
	Engine *string `json:"engine,omitempty"`

	// 消息引擎支持的版本
	Versions *[]string `json:"versions,omitempty"`

	// 规格变更的产品信息
	Products       *[]RocketMqExtendProductInfoEntity `json:"products,omitempty"`
	HttpStatusCode int                                `json:"-"`
}

ShowEngineInstanceExtendProductInfoResponse Response Object

func (ShowEngineInstanceExtendProductInfoResponse) String added in v0.1.70

type ShowGroupRequest

type ShowGroupRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 消费组名称。
	Group string `json:"group"`
}

ShowGroupRequest Request Object

func (ShowGroupRequest) String

func (o ShowGroupRequest) String() string

type ShowGroupResponse

type ShowGroupResponse struct {

	// 是否可以消费。
	Enabled *bool `json:"enabled,omitempty"`

	// 是否广播。
	Broadcast *bool `json:"broadcast,omitempty"`

	// 关联的代理列表。
	Brokers *[]string `json:"brokers,omitempty"`

	// 消费组名称。
	Name *string `json:"name,omitempty"`

	// 消费组描述。
	GroupDesc *string `json:"group_desc,omitempty"`

	// 最大重试次数。
	RetryMaxTime float32 `json:"retry_max_time,omitempty"`

	// 应用id。
	AppId *string `json:"app_id,omitempty"`

	// 应用名称。
	AppName *string `json:"app_name,omitempty"`

	// 权限。
	Permissions    *[]string `json:"permissions,omitempty"`
	HttpStatusCode int       `json:"-"`
}

ShowGroupResponse Response Object

func (ShowGroupResponse) String

func (o ShowGroupResponse) String() string

type ShowInstanceRequest

type ShowInstanceRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`
}

ShowInstanceRequest Request Object

func (ShowInstanceRequest) String

func (o ShowInstanceRequest) String() string

type ShowInstanceResp

type ShowInstanceResp struct {

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

	// 引擎。
	Engine *string `json:"engine,omitempty"`

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

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

	// 实例类型:集群,cluster。
	Type *ShowInstanceRespType `json:"type,omitempty"`

	// 实例规格。
	Specification *string `json:"specification,omitempty"`

	// 版本。
	EngineVersion *string `json:"engine_version,omitempty"`

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

	// [付费模式,1表示按需计费。](tag:hws_eu,g42,hk_g42,tm,hk_tm)[付费模式,1表示按需计费,0表示包年/包月计费。](tag:hws,hws_eu,hws_hk,ctc) [计费模式,参数暂未使用。](tag:ocb,hws_ocb)
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 私有云ID。
	VpcId *string `json:"vpc_id,omitempty"`

	// 私有云名称。
	VpcName *string `json:"vpc_name,omitempty"`

	// 完成创建时间。  格式为时间戳,指从格林威治时间1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。
	CreatedAt *string `json:"created_at,omitempty"`

	// 产品标识。
	ProductId *string `json:"product_id,omitempty"`

	// 安全组ID。
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// 租户安全组名称。
	SecurityGroupName *string `json:"security_group_name,omitempty"`

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

	// 子网名称。
	SubnetName *string `json:"subnet_name,omitempty"`

	// 子网路由。
	SubnetCidr *string `json:"subnet_cidr,omitempty"`

	// IO未售罄的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 用户ID。
	UserId *string `json:"user_id,omitempty"`

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

	// 维护时间窗开始时间,格式为HH:mm:ss。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间,格式为HH:mm:ss。
	MaintainEnd *string `json:"maintain_end,omitempty"`

	// 是否开启消息收集功能。
	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`

	// 存储空间,单位:GB。
	StorageSpace *int32 `json:"storage_space,omitempty"`

	// 已用消息存储空间,单位:GB。
	UsedStorageSpace *int32 `json:"used_storage_space,omitempty"`

	// 是否开启公网。
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 公网IP地址。
	PublicipAddress *string `json:"publicip_address,omitempty"`

	// 是否开启SSL。
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 跨VPC访问信息。
	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`

	// 存储资源ID。
	StorageResourceId *string `json:"storage_resource_id,omitempty"`

	// 存储规格代码。
	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	// 服务类型。
	ServiceType *string `json:"service_type,omitempty"`

	// 存储类型。
	StorageType *string `json:"storage_type,omitempty"`

	// 扩展时间。
	ExtendTimes *int64 `json:"extend_times,omitempty"`

	// 是否开启IPv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	// 实例支持的特性功能。
	SupportFeatures *string `json:"support_features,omitempty"`

	// 是否开启磁盘加密。
	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`

	// 云监控版本。
	CesVersion *string `json:"ces_version,omitempty"`

	// 节点数。
	NodeNum *int32 `json:"node_num,omitempty"`

	// 是否启用新规格计费。
	NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty"`

	// 是否开启访问控制列表。
	EnableAcl *bool `json:"enable_acl,omitempty"`

	// 节点数。
	BrokerNum *int32 `json:"broker_num,omitempty"`

	// 元数据地址。
	NamesrvAddress *string `json:"namesrv_address,omitempty"`

	// 业务数据地址。
	BrokerAddress *string `json:"broker_address,omitempty"`

	// 公网元数据地址。
	PublicNamesrvAddress *string `json:"public_namesrv_address,omitempty"`

	// 公网业务数据地址。
	PublicBrokerAddress *string `json:"public_broker_address,omitempty"`

	// grpc连接地址。
	GrpcAddress *string `json:"grpc_address,omitempty"`

	// 公网grpc连接地址。
	PublicGrpcAddress *string `json:"public_grpc_address,omitempty"`

	// 标签列表。
	Tags *[]TagEntity `json:"tags,omitempty"`

	// 总存储空间。
	TotalStorageSpace *int32 `json:"total_storage_space,omitempty"`

	// 资源规格。
	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`
}

func (ShowInstanceResp) String

func (o ShowInstanceResp) String() string

type ShowInstanceRespType

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

func (ShowInstanceRespType) MarshalJSON

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

func (*ShowInstanceRespType) UnmarshalJSON

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

func (ShowInstanceRespType) Value added in v0.0.90

func (c ShowInstanceRespType) Value() string

type ShowInstanceRespTypeEnum

type ShowInstanceRespTypeEnum struct {
	SINGLE  ShowInstanceRespType
	CLUSTER ShowInstanceRespType
}

func GetShowInstanceRespTypeEnum

func GetShowInstanceRespTypeEnum() ShowInstanceRespTypeEnum

type ShowInstanceResponse

type ShowInstanceResponse struct {

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

	// 引擎。
	Engine *string `json:"engine,omitempty"`

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

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

	// 实例类型:集群,cluster。
	Type *ShowInstanceResponseType `json:"type,omitempty"`

	// 实例规格。
	Specification *string `json:"specification,omitempty"`

	// 版本。
	EngineVersion *string `json:"engine_version,omitempty"`

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

	// [付费模式,1表示按需计费。](tag:hws_eu,g42,hk_g42,tm,hk_tm)[付费模式,1表示按需计费,0表示包年/包月计费。](tag:hws,hws_eu,hws_hk,ctc) [计费模式,参数暂未使用。](tag:ocb,hws_ocb)
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// 私有云ID。
	VpcId *string `json:"vpc_id,omitempty"`

	// 私有云名称。
	VpcName *string `json:"vpc_name,omitempty"`

	// 完成创建时间。  格式为时间戳,指从格林威治时间1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。
	CreatedAt *string `json:"created_at,omitempty"`

	// 产品标识。
	ProductId *string `json:"product_id,omitempty"`

	// 安全组ID。
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// 租户安全组名称。
	SecurityGroupName *string `json:"security_group_name,omitempty"`

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

	// 子网名称。
	SubnetName *string `json:"subnet_name,omitempty"`

	// 子网路由。
	SubnetCidr *string `json:"subnet_cidr,omitempty"`

	// IO未售罄的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 用户ID。
	UserId *string `json:"user_id,omitempty"`

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

	// 维护时间窗开始时间,格式为HH:mm:ss。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间,格式为HH:mm:ss。
	MaintainEnd *string `json:"maintain_end,omitempty"`

	// 是否开启消息收集功能。
	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`

	// 存储空间,单位:GB。
	StorageSpace *int32 `json:"storage_space,omitempty"`

	// 已用消息存储空间,单位:GB。
	UsedStorageSpace *int32 `json:"used_storage_space,omitempty"`

	// 是否开启公网。
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 公网IP地址。
	PublicipAddress *string `json:"publicip_address,omitempty"`

	// 是否开启SSL。
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 跨VPC访问信息。
	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`

	// 存储资源ID。
	StorageResourceId *string `json:"storage_resource_id,omitempty"`

	// 存储规格代码。
	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	// 服务类型。
	ServiceType *string `json:"service_type,omitempty"`

	// 存储类型。
	StorageType *string `json:"storage_type,omitempty"`

	// 扩展时间。
	ExtendTimes *int64 `json:"extend_times,omitempty"`

	// 是否开启IPv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	// 实例支持的特性功能。
	SupportFeatures *string `json:"support_features,omitempty"`

	// 是否开启磁盘加密。
	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`

	// 云监控版本。
	CesVersion *string `json:"ces_version,omitempty"`

	// 节点数。
	NodeNum *int32 `json:"node_num,omitempty"`

	// 是否启用新规格计费。
	NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty"`

	// 是否开启访问控制列表。
	EnableAcl *bool `json:"enable_acl,omitempty"`

	// 节点数。
	BrokerNum *int32 `json:"broker_num,omitempty"`

	// 元数据地址。
	NamesrvAddress *string `json:"namesrv_address,omitempty"`

	// 业务数据地址。
	BrokerAddress *string `json:"broker_address,omitempty"`

	// 公网元数据地址。
	PublicNamesrvAddress *string `json:"public_namesrv_address,omitempty"`

	// 公网业务数据地址。
	PublicBrokerAddress *string `json:"public_broker_address,omitempty"`

	// grpc连接地址。
	GrpcAddress *string `json:"grpc_address,omitempty"`

	// 公网grpc连接地址。
	PublicGrpcAddress *string `json:"public_grpc_address,omitempty"`

	// 标签列表。
	Tags *[]TagEntity `json:"tags,omitempty"`

	// 总存储空间。
	TotalStorageSpace *int32 `json:"total_storage_space,omitempty"`

	// 资源规格。
	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`
	HttpStatusCode   int     `json:"-"`
}

ShowInstanceResponse Response Object

func (ShowInstanceResponse) String

func (o ShowInstanceResponse) String() string

type ShowInstanceResponseType

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

func (ShowInstanceResponseType) MarshalJSON

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

func (*ShowInstanceResponseType) UnmarshalJSON

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

func (ShowInstanceResponseType) Value added in v0.0.90

func (c ShowInstanceResponseType) Value() string

type ShowInstanceResponseTypeEnum

type ShowInstanceResponseTypeEnum struct {
	SINGLE  ShowInstanceResponseType
	CLUSTER ShowInstanceResponseType
}

func GetShowInstanceResponseTypeEnum

func GetShowInstanceResponseTypeEnum() ShowInstanceResponseTypeEnum

type ShowOneTopicRequest

type ShowOneTopicRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 主题名称。
	Topic string `json:"topic"`
}

ShowOneTopicRequest Request Object

func (ShowOneTopicRequest) String

func (o ShowOneTopicRequest) String() string

type ShowOneTopicResponse

type ShowOneTopicResponse struct {

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

	// 总读队列个数。
	TotalReadQueueNum float32 `json:"total_read_queue_num,omitempty"`

	// 总写队列个数。
	TotalWriteQueueNum float32 `json:"total_write_queue_num,omitempty"`

	// 权限。
	Permission *ShowOneTopicResponsePermission `json:"permission,omitempty"`

	// 关联的代理。
	Brokers *[]TopicBrokers `json:"brokers,omitempty"`

	// 消息类型(RocketMQ实例5.x版本才包含此参数)。
	MessageType    *ShowOneTopicResponseMessageType `json:"message_type,omitempty"`
	HttpStatusCode int                              `json:"-"`
}

ShowOneTopicResponse Response Object

func (ShowOneTopicResponse) String

func (o ShowOneTopicResponse) String() string

type ShowOneTopicResponseMessageType added in v0.1.53

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

func (ShowOneTopicResponseMessageType) MarshalJSON added in v0.1.53

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

func (*ShowOneTopicResponseMessageType) UnmarshalJSON added in v0.1.53

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

func (ShowOneTopicResponseMessageType) Value added in v0.1.53

type ShowOneTopicResponseMessageTypeEnum added in v0.1.53

type ShowOneTopicResponseMessageTypeEnum struct {
	NORMAL      ShowOneTopicResponseMessageType
	FIFO        ShowOneTopicResponseMessageType
	DELAY       ShowOneTopicResponseMessageType
	TRANSACTION ShowOneTopicResponseMessageType
}

func GetShowOneTopicResponseMessageTypeEnum added in v0.1.53

func GetShowOneTopicResponseMessageTypeEnum() ShowOneTopicResponseMessageTypeEnum

type ShowOneTopicResponsePermission

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

func (ShowOneTopicResponsePermission) MarshalJSON

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

func (*ShowOneTopicResponsePermission) UnmarshalJSON

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

func (ShowOneTopicResponsePermission) Value added in v0.0.90

type ShowRocketMqConfigsRequest added in v0.1.71

type ShowRocketMqConfigsRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`
}

ShowRocketMqConfigsRequest Request Object

func (ShowRocketMqConfigsRequest) String added in v0.1.71

type ShowRocketMqConfigsResponse added in v0.1.71

type ShowRocketMqConfigsResponse struct {

	// RocketMQ配置。
	RocketmqConfigs *[]RocketMqConfigResp `json:"rocketmq_configs,omitempty"`
	HttpStatusCode  int                   `json:"-"`
}

ShowRocketMqConfigsResponse Response Object

func (ShowRocketMqConfigsResponse) String added in v0.1.71

type ShowRocketmqProjectTagsRequest added in v0.1.26

type ShowRocketmqProjectTagsRequest struct {
}

ShowRocketmqProjectTagsRequest Request Object

func (ShowRocketmqProjectTagsRequest) String added in v0.1.26

type ShowRocketmqProjectTagsResponse added in v0.1.26

type ShowRocketmqProjectTagsResponse struct {

	// 标签列表
	Tags           *[]TagMultyValueEntity `json:"tags,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

ShowRocketmqProjectTagsResponse Response Object

func (ShowRocketmqProjectTagsResponse) String added in v0.1.26

type ShowRocketmqTagsRequest added in v0.1.26

type ShowRocketmqTagsRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`
}

ShowRocketmqTagsRequest Request Object

func (ShowRocketmqTagsRequest) String added in v0.1.26

func (o ShowRocketmqTagsRequest) String() string

type ShowRocketmqTagsResponse added in v0.1.26

type ShowRocketmqTagsResponse struct {

	// 标签列表
	Tags           *[]TagEntity `json:"tags,omitempty"`
	HttpStatusCode int          `json:"-"`
}

ShowRocketmqTagsResponse Response Object

func (ShowRocketmqTagsResponse) String added in v0.1.26

func (o ShowRocketmqTagsResponse) String() string

type ShowTopicStatusRequest

type ShowTopicStatusRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 主题名称。
	Topic string `json:"topic"`
}

ShowTopicStatusRequest Request Object

func (ShowTopicStatusRequest) String

func (o ShowTopicStatusRequest) String() string

type ShowTopicStatusRespBrokers

type ShowTopicStatusRespBrokers struct {

	// 队列列表。
	Queues *[]ShowTopicStatusRespQueues `json:"queues,omitempty"`

	// 节点名称。
	BrokerName *string `json:"broker_name,omitempty"`
}

func (ShowTopicStatusRespBrokers) String

type ShowTopicStatusRespQueues

type ShowTopicStatusRespQueues struct {

	// 队列ID。
	Id *int32 `json:"id,omitempty"`

	// 最小偏移量。
	MinOffset *int32 `json:"min_offset,omitempty"`

	// 最大偏移量。
	MaxOffset *int32 `json:"max_offset,omitempty"`

	// 最后一条消息的时间。
	LastMessageTime *int64 `json:"last_message_time,omitempty"`
}

func (ShowTopicStatusRespQueues) String

func (o ShowTopicStatusRespQueues) String() string

type ShowTopicStatusResponse

type ShowTopicStatusResponse struct {

	// 最大偏移量。
	MaxOffset *int32 `json:"max_offset,omitempty"`

	// 最小偏移量。
	MinOffset *int32 `json:"min_offset,omitempty"`

	// 代理。
	Brokers        *[]ShowTopicStatusRespBrokers `json:"brokers,omitempty"`
	HttpStatusCode int                           `json:"-"`
}

ShowTopicStatusResponse Response Object

func (ShowTopicStatusResponse) String

func (o ShowTopicStatusResponse) String() string

type ShowUserRequest

type ShowUserRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 用户名。
	UserName string `json:"user_name"`
}

ShowUserRequest Request Object

func (ShowUserRequest) String

func (o ShowUserRequest) String() string

type ShowUserResponse

type ShowUserResponse struct {

	// 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。
	AccessKey *string `json:"access_key,omitempty"`

	// 密钥。 8-32个字符。 至少包含以下字符中的3种:   - 大写字母   - 小写字母   - 数字   - 特殊字符`~!@#$%^&*()-_=+\\\\|[{}];:\\'\\\",<.>/?密钥。 不能与名称或倒序的名称相同。
	SecretKey *string `json:"secret_key,omitempty"`

	// IP白名单。
	WhiteRemoteAddress *string `json:"white_remote_address,omitempty"`

	// 是否为管理员。
	Admin *bool `json:"admin,omitempty"`

	// 默认的主题权限。
	DefaultTopicPerm *ShowUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty"`

	// 默认的消费组权限。
	DefaultGroupPerm *ShowUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty"`

	// 特殊的主题权限。
	TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"`

	// 特殊的消费组权限。
	GroupPerms     *[]UserGroupPerms `json:"group_perms,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ShowUserResponse Response Object

func (ShowUserResponse) String

func (o ShowUserResponse) String() string

type ShowUserResponseDefaultGroupPerm

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

func (ShowUserResponseDefaultGroupPerm) MarshalJSON

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

func (*ShowUserResponseDefaultGroupPerm) UnmarshalJSON

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

func (ShowUserResponseDefaultGroupPerm) Value added in v0.0.90

type ShowUserResponseDefaultGroupPermEnum

type ShowUserResponseDefaultGroupPermEnum struct {
	SUB  ShowUserResponseDefaultGroupPerm
	DENY ShowUserResponseDefaultGroupPerm
}

func GetShowUserResponseDefaultGroupPermEnum

func GetShowUserResponseDefaultGroupPermEnum() ShowUserResponseDefaultGroupPermEnum

type ShowUserResponseDefaultTopicPerm

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

func (ShowUserResponseDefaultTopicPerm) MarshalJSON

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

func (*ShowUserResponseDefaultTopicPerm) UnmarshalJSON

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

func (ShowUserResponseDefaultTopicPerm) Value added in v0.0.90

type Subscription added in v0.1.37

type Subscription struct {

	// 订阅的topic名称
	Topic *string `json:"topic,omitempty"`

	// 订阅类型,取值如下:TAG和SQL92
	Type *string `json:"type,omitempty"`

	// 订阅tag字符
	Expression *string `json:"expression,omitempty"`
}

func (Subscription) String added in v0.1.37

func (o Subscription) String() string

type TagEntity

type TagEntity struct {

	// 标签键。  - 不能为空。  - 对于同一个实例,Key值唯一。  - 长度为1~128个字符(中文也可以输入128个字符)。  - 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @  - 首尾字符不能为空格。
	Key *string `json:"key,omitempty"`

	// 标签值。  - 长度为0~255个字符(中文也可以输入255个字符)。  - 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @  - 首尾字符不能为空格。
	Value *string `json:"value,omitempty"`
}

func (TagEntity) String

func (o TagEntity) String() string

type TagMultyValueEntity added in v0.1.26

type TagMultyValueEntity struct {

	// 标签键。
	Key *string `json:"key,omitempty"`

	// 标签值。
	Values *[]string `json:"values,omitempty"`
}

func (TagMultyValueEntity) String added in v0.1.26

func (o TagMultyValueEntity) String() string

type Topic added in v0.1.22

type Topic struct {

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

	// 总读队列个数。
	TotalReadQueueNum float32 `json:"total_read_queue_num,omitempty"`

	// 总写队列个数。
	TotalWriteQueueNum float32 `json:"total_write_queue_num,omitempty"`

	// 权限。
	Permission *TopicPermission `json:"permission,omitempty"`

	// 关联的代理。
	Brokers *[]TopicBrokers `json:"brokers,omitempty"`

	// 消息类型(RocketMQ实例5.x版本才包含此参数)。
	MessageType *TopicMessageType `json:"message_type,omitempty"`
}

func (Topic) String added in v0.1.22

func (o Topic) String() string

type TopicBrokers

type TopicBrokers struct {

	// 代理名称。
	BrokerName *string `json:"broker_name,omitempty"`

	// 读队列个数。
	ReadQueueNum float32 `json:"read_queue_num,omitempty"`

	// 写队列个数。
	WriteQueueNum float32 `json:"write_queue_num,omitempty"`
}

func (TopicBrokers) String

func (o TopicBrokers) String() string

type TopicMessageType added in v0.1.53

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

func (TopicMessageType) MarshalJSON added in v0.1.53

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

func (*TopicMessageType) UnmarshalJSON added in v0.1.53

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

func (TopicMessageType) Value added in v0.1.53

func (c TopicMessageType) Value() string

type TopicMessageTypeEnum added in v0.1.53

type TopicMessageTypeEnum struct {
	NORMAL      TopicMessageType
	FIFO        TopicMessageType
	DELAY       TopicMessageType
	TRANSACTION TopicMessageType
}

func GetTopicMessageTypeEnum added in v0.1.53

func GetTopicMessageTypeEnum() TopicMessageTypeEnum

type TopicPermission added in v0.1.22

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

func (TopicPermission) MarshalJSON added in v0.1.22

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

func (*TopicPermission) UnmarshalJSON added in v0.1.22

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

func (TopicPermission) Value added in v0.1.22

func (c TopicPermission) Value() string

type TopicPermissionEnum added in v0.1.22

type TopicPermissionEnum struct {
	SUB TopicPermission
	PUB TopicPermission
	ALL TopicPermission
}

func GetTopicPermissionEnum added in v0.1.22

func GetTopicPermissionEnum() TopicPermissionEnum

type UpdateConsumerGroup added in v0.1.60

type UpdateConsumerGroup struct {

	// 是否可以消费。
	Enabled bool `json:"enabled"`

	// 是否广播。
	Broadcast bool `json:"broadcast"`

	// 关联的代理列表。
	Brokers *[]string `json:"brokers,omitempty"`

	// 待修改参数的消费组(消费组名称不支持修改)。
	Name *string `json:"name,omitempty"`

	// 最大重试次数,取值范围为1~16。
	RetryMaxTime float32 `json:"retry_max_time"`

	// 是否重头消费。
	FromBeginning *bool `json:"from_beginning,omitempty"`
}

func (UpdateConsumerGroup) String added in v0.1.60

func (o UpdateConsumerGroup) String() string

type UpdateConsumerGroupRequest

type UpdateConsumerGroupRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 消费组名称。
	Group string `json:"group"`

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

UpdateConsumerGroupRequest Request Object

func (UpdateConsumerGroupRequest) String

type UpdateConsumerGroupResponse

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

UpdateConsumerGroupResponse Response Object

func (UpdateConsumerGroupResponse) String

type UpdateInstanceReq

type UpdateInstanceReq struct {

	// 实例名称。  由英文字符开头,只能由英文字母、数字、中划线组成,长度为4~64的字符。
	Name *string `json:"name,omitempty"`

	// 实例的描述信息。  长度不超过1024的字符串。  > \\与\"在json报文中属于特殊字符,如果参数值中需要显示\\或者\"字符,请在字符前增加转义字符\\,比如\\\\或者\\\"。
	Description *string `json:"description,omitempty"`

	// 安全组ID。  获取方法如下:登录虚拟私有云服务的控制台界面,在安全组的详情页面查找安全组ID。
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// ACL访问控制。
	EnableAcl *bool `json:"enable_acl,omitempty"`

	// 是否开启公网。
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// 实例绑定的弹性IP地址的ID。  以英文逗号隔开多个弹性IP地址的ID。  如果开启了公网访问功能(即enable_publicip为true),该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`
}

func (UpdateInstanceReq) String

func (o UpdateInstanceReq) String() string

type UpdateInstanceRequest

type UpdateInstanceRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

UpdateInstanceRequest Request Object

func (UpdateInstanceRequest) String

func (o UpdateInstanceRequest) String() string

type UpdateInstanceResponse

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

UpdateInstanceResponse Response Object

func (UpdateInstanceResponse) String

func (o UpdateInstanceResponse) String() string

type UpdateRocketMqConfigsRequest added in v0.1.71

type UpdateRocketMqConfigsRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

UpdateRocketMqConfigsRequest Request Object

func (UpdateRocketMqConfigsRequest) String added in v0.1.71

type UpdateRocketMqConfigsResponse added in v0.1.71

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

UpdateRocketMqConfigsResponse Response Object

func (UpdateRocketMqConfigsResponse) String added in v0.1.71

type UpdateTopicReq

type UpdateTopicReq struct {

	// 总读队列个数。
	ReadQueueNum float32 `json:"read_queue_num,omitempty"`

	// 总写队列个数。
	WriteQueueNum float32 `json:"write_queue_num,omitempty"`

	// 权限。
	Permission *UpdateTopicReqPermission `json:"permission,omitempty"`
}

func (UpdateTopicReq) String

func (o UpdateTopicReq) String() string

type UpdateTopicReqPermission

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

func (UpdateTopicReqPermission) MarshalJSON

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

func (*UpdateTopicReqPermission) UnmarshalJSON

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

func (UpdateTopicReqPermission) Value added in v0.0.90

func (c UpdateTopicReqPermission) Value() string

type UpdateTopicReqPermissionEnum

type UpdateTopicReqPermissionEnum struct {
	SUB UpdateTopicReqPermission
	PUB UpdateTopicReqPermission
	ALL UpdateTopicReqPermission
}

func GetUpdateTopicReqPermissionEnum

func GetUpdateTopicReqPermissionEnum() UpdateTopicReqPermissionEnum

type UpdateTopicRequest

type UpdateTopicRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 主题名称。
	Topic string `json:"topic"`

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

UpdateTopicRequest Request Object

func (UpdateTopicRequest) String

func (o UpdateTopicRequest) String() string

type UpdateTopicResponse

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

UpdateTopicResponse Response Object

func (UpdateTopicResponse) String

func (o UpdateTopicResponse) String() string

type UpdateUserRequest

type UpdateUserRequest struct {

	// 实例ID。
	InstanceId string `json:"instance_id"`

	// 用户名。
	UserName string `json:"user_name"`

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

UpdateUserRequest Request Object

func (UpdateUserRequest) String

func (o UpdateUserRequest) String() string

type UpdateUserResponse

type UpdateUserResponse struct {

	// 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。
	AccessKey *string `json:"access_key,omitempty"`

	// 密钥。 8-32个字符。 至少包含以下字符中的3种:   - 大写字母   - 小写字母   - 数字   - 特殊字符`~!@#$%^&*()-_=+\\\\|[{}];:\\'\\\",<.>/?密钥。 不能与名称或倒序的名称相同。
	SecretKey *string `json:"secret_key,omitempty"`

	// IP白名单。
	WhiteRemoteAddress *string `json:"white_remote_address,omitempty"`

	// 是否为管理员。
	Admin *bool `json:"admin,omitempty"`

	// 默认的主题权限。
	DefaultTopicPerm *UpdateUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty"`

	// 默认的消费组权限。
	DefaultGroupPerm *UpdateUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty"`

	// 特殊的主题权限。
	TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"`

	// 特殊的消费组权限。
	GroupPerms     *[]UserGroupPerms `json:"group_perms,omitempty"`
	HttpStatusCode int               `json:"-"`
}

UpdateUserResponse Response Object

func (UpdateUserResponse) String

func (o UpdateUserResponse) String() string

type UpdateUserResponseDefaultGroupPerm

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

func (UpdateUserResponseDefaultGroupPerm) MarshalJSON

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

func (*UpdateUserResponseDefaultGroupPerm) UnmarshalJSON

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

func (UpdateUserResponseDefaultGroupPerm) Value added in v0.0.90

type UpdateUserResponseDefaultGroupPermEnum

type UpdateUserResponseDefaultGroupPermEnum struct {
	SUB  UpdateUserResponseDefaultGroupPerm
	DENY UpdateUserResponseDefaultGroupPerm
}

func GetUpdateUserResponseDefaultGroupPermEnum

func GetUpdateUserResponseDefaultGroupPermEnum() UpdateUserResponseDefaultGroupPermEnum

type UpdateUserResponseDefaultTopicPerm

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

func (UpdateUserResponseDefaultTopicPerm) MarshalJSON

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

func (*UpdateUserResponseDefaultTopicPerm) UnmarshalJSON

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

func (UpdateUserResponseDefaultTopicPerm) Value added in v0.0.90

type User

type User struct {

	// 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。
	AccessKey *string `json:"access_key,omitempty"`

	// 密钥。 8-32个字符。 至少包含以下字符中的3种:   - 大写字母   - 小写字母   - 数字   - 特殊字符`~!@#$%^&*()-_=+\\\\|[{}];:\\'\\\",<.>/?密钥。 不能与名称或倒序的名称相同。
	SecretKey *string `json:"secret_key,omitempty"`

	// IP白名单。
	WhiteRemoteAddress *string `json:"white_remote_address,omitempty"`

	// 是否为管理员。
	Admin *bool `json:"admin,omitempty"`

	// 默认的主题权限。
	DefaultTopicPerm *UserDefaultTopicPerm `json:"default_topic_perm,omitempty"`

	// 默认的消费组权限。
	DefaultGroupPerm *UserDefaultGroupPerm `json:"default_group_perm,omitempty"`

	// 特殊的主题权限。
	TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty"`

	// 特殊的消费组权限。
	GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty"`
}

func (User) String

func (o User) String() string

type UserDefaultGroupPerm

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

func (UserDefaultGroupPerm) MarshalJSON

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

func (*UserDefaultGroupPerm) UnmarshalJSON

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

func (UserDefaultGroupPerm) Value added in v0.0.90

func (c UserDefaultGroupPerm) Value() string

type UserDefaultGroupPermEnum

type UserDefaultGroupPermEnum struct {
	SUB  UserDefaultGroupPerm
	DENY UserDefaultGroupPerm
}

func GetUserDefaultGroupPermEnum

func GetUserDefaultGroupPermEnum() UserDefaultGroupPermEnum

type UserDefaultTopicPerm

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

func (UserDefaultTopicPerm) MarshalJSON

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

func (*UserDefaultTopicPerm) UnmarshalJSON

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

func (UserDefaultTopicPerm) Value added in v0.0.90

func (c UserDefaultTopicPerm) Value() string

type UserDefaultTopicPermEnum

type UserDefaultTopicPermEnum struct {
	PUB     UserDefaultTopicPerm
	SUB     UserDefaultTopicPerm
	PUB_SUB UserDefaultTopicPerm
	DENY    UserDefaultTopicPerm
}

func GetUserDefaultTopicPermEnum

func GetUserDefaultTopicPermEnum() UserDefaultTopicPermEnum

type UserGroupPerms

type UserGroupPerms struct {

	// 消费组名称。
	Name *string `json:"name,omitempty"`

	// 权限。
	Perm *UserGroupPermsPerm `json:"perm,omitempty"`
}

func (UserGroupPerms) String

func (o UserGroupPerms) String() string

type UserGroupPermsPerm

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

func (UserGroupPermsPerm) MarshalJSON

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

func (*UserGroupPermsPerm) UnmarshalJSON

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

func (UserGroupPermsPerm) Value added in v0.0.90

func (c UserGroupPermsPerm) Value() string

type UserGroupPermsPermEnum

type UserGroupPermsPermEnum struct {
	SUB  UserGroupPermsPerm
	DENY UserGroupPermsPerm
}

func GetUserGroupPermsPermEnum

func GetUserGroupPermsPermEnum() UserGroupPermsPermEnum

type UserTopicPerms

type UserTopicPerms struct {

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

	// 权限。
	Perm *UserTopicPermsPerm `json:"perm,omitempty"`
}

func (UserTopicPerms) String

func (o UserTopicPerms) String() string

type UserTopicPermsPerm

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

func (UserTopicPermsPerm) MarshalJSON

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

func (*UserTopicPermsPerm) UnmarshalJSON

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

func (UserTopicPermsPerm) Value added in v0.0.90

func (c UserTopicPermsPerm) Value() string

type UserTopicPermsPermEnum

type UserTopicPermsPermEnum struct {
	PUB     UserTopicPermsPerm
	SUB     UserTopicPermsPerm
	PUB_SUB UserTopicPermsPerm
	DENY    UserTopicPermsPerm
}

func GetUserTopicPermsPermEnum

func GetUserTopicPermsPermEnum() UserTopicPermsPermEnum

type ValidateConsumedMessageRequest added in v0.1.43

type ValidateConsumedMessageRequest struct {

	// 消息引擎。
	Engine ValidateConsumedMessageRequestEngine `json:"engine"`

	// 实例ID。
	InstanceId string `json:"instance_id"`

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

ValidateConsumedMessageRequest Request Object

func (ValidateConsumedMessageRequest) String added in v0.1.43

type ValidateConsumedMessageRequestEngine added in v0.1.50

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

func (ValidateConsumedMessageRequestEngine) MarshalJSON added in v0.1.50

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

func (*ValidateConsumedMessageRequestEngine) UnmarshalJSON added in v0.1.50

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

func (ValidateConsumedMessageRequestEngine) Value added in v0.1.50

type ValidateConsumedMessageRequestEngineEnum added in v0.1.50

type ValidateConsumedMessageRequestEngineEnum struct {
	RELIABILITY ValidateConsumedMessageRequestEngine
}

func GetValidateConsumedMessageRequestEngineEnum added in v0.1.50

func GetValidateConsumedMessageRequestEngineEnum() ValidateConsumedMessageRequestEngineEnum

type ValidateConsumedMessageResponse added in v0.1.43

type ValidateConsumedMessageResponse struct {

	// 消费验证结果。
	ResendResults  *[]DeadletterResendRespResendResults `json:"resend_results,omitempty"`
	HttpStatusCode int                                  `json:"-"`
}

ValidateConsumedMessageResponse Response Object

func (ValidateConsumedMessageResponse) String added in v0.1.43

Source Files

Jump to

Keyboard shortcuts

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