model

package
v0.1.65 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type 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 

func (o BatchCreateOrDeleteRocketmqTagRequest) String() string

type BatchCreateOrDeleteRocketmqTagResponse added in v0.1.26 

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

BatchCreateOrDeleteRocketmqTagResponse Response Object

func (BatchCreateOrDeleteRocketmqTagResponse) String added in v0.1.26 

func (o BatchCreateOrDeleteRocketmqTagResponse) String() string

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 

func (c BatchCreateOrDeleteTagReqAction) Value() string

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 

func (o BatchDeleteConsumerGroupReq) String() string

type BatchDeleteConsumerGroupResp 

type BatchDeleteConsumerGroupResp struct {

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

func (BatchDeleteConsumerGroupResp) String 

func (o BatchDeleteConsumerGroupResp) String() 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 

func (c BatchDeleteInstanceReqAction) Value() string

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 

func (c BatchDeleteInstanceReqAllFailure) Value() string

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 

func (o BatchDeleteInstanceRespResults) String() 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 

func (c BatchDeleteInstanceRespResultsResult) Value() string

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 

func (o BatchDeleteInstancesRequest) String() string

type BatchDeleteInstancesResponse 

type BatchDeleteInstancesResponse struct {

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

BatchDeleteInstancesResponse Response Object

func (BatchDeleteInstancesResponse) String 

func (o BatchDeleteInstancesResponse) String() 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 

func (o BatchUpdateConsumerGroupReq) String() string

type BatchUpdateConsumerGroupRequest 

type BatchUpdateConsumerGroupRequest struct {

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

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

BatchUpdateConsumerGroupRequest Request Object

func (BatchUpdateConsumerGroupRequest) String 

func (o BatchUpdateConsumerGroupRequest) String() string

type BatchUpdateConsumerGroupResponse 

type BatchUpdateConsumerGroupResponse struct {

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

BatchUpdateConsumerGroupResponse Response Object

func (BatchUpdateConsumerGroupResponse) String 

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

	// 最大重试次数。
	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"`

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

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

func (CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String 

func (o CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String() 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 

func (o CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) String() 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 

func (o CreateConsumerGroupOrBatchDeleteConsumerGroupResponse) String() 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 

func (c CreateInstanceByEngineReqEngine) Value() string

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 

func (c CreateInstanceByEngineReqEngineVersion) Value() string

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 

func (c CreateInstanceByEngineReqProductId) Value() string

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 (c CreateInstanceByEngineReqStorageSpecCode) MarshalJSON() ([]byte, error)

func (*CreateInstanceByEngineReqStorageSpecCode) UnmarshalJSON added in v0.1.26 

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

func (CreateInstanceByEngineReqStorageSpecCode) Value added in v0.1.26 

func (c CreateInstanceByEngineReqStorageSpecCode) Value() string

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 

func (o CreateInstanceByEngineRequest) String() string

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 

func (c CreateInstanceByEngineRequestEngine) Value() string

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 

func (o CreateInstanceByEngineResponse) String() string

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 

func (c CreatePostPaidInstanceReqEngine) Value() string

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 

func (c CreatePostPaidInstanceReqEngineVersion) Value() string

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 

func (c CreatePostPaidInstanceReqProductId) Value() string

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 (c CreatePostPaidInstanceReqStorageSpecCode) MarshalJSON() ([]byte, error)

func (*CreatePostPaidInstanceReqStorageSpecCode) UnmarshalJSON 

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

func (CreatePostPaidInstanceReqStorageSpecCode) Value added in v0.0.90 

func (c CreatePostPaidInstanceReqStorageSpecCode) Value() string

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 

func (o CreatePostPaidInstanceRequest) String() string

type CreatePostPaidInstanceResponse 

type CreatePostPaidInstanceResponse struct {

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

CreatePostPaidInstanceResponse Response Object

func (CreatePostPaidInstanceResponse) String 

func (o CreatePostPaidInstanceResponse) String() string

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

	// 元数据json文件。
	Body map[string]interface{} `json:"body,omitempty"`
}

CreateRocketMqMigrationTaskRequest Request Object

func (CreateRocketMqMigrationTaskRequest) String added in v0.1.42 

func (o CreateRocketMqMigrationTaskRequest) String() string

type CreateRocketMqMigrationTaskRequestOverwrite added in v0.1.42 

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

func (CreateRocketMqMigrationTaskRequestOverwrite) MarshalJSON added in v0.1.42 

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

func (*CreateRocketMqMigrationTaskRequestOverwrite) UnmarshalJSON added in v0.1.42 

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

func (CreateRocketMqMigrationTaskRequestOverwrite) Value added in v0.1.42 

func (c CreateRocketMqMigrationTaskRequestOverwrite) Value() string

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 

func (c CreateRocketMqMigrationTaskRequestType) Value() string

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 

func (o CreateRocketMqMigrationTaskResponse) String() string

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

	// 消息类型。
	MessageType *CreateTopicOrBatchDeleteTopicReqMessageType `json:"message_type,omitempty"`

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

func (CreateTopicOrBatchDeleteTopicReq) String 

func (o CreateTopicOrBatchDeleteTopicReq) String() 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 (c CreateTopicOrBatchDeleteTopicReqMessageType) MarshalJSON() ([]byte, error)

func (*CreateTopicOrBatchDeleteTopicReqMessageType) UnmarshalJSON added in v0.1.53 

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

func (CreateTopicOrBatchDeleteTopicReqMessageType) Value added in v0.1.53 

func (c CreateTopicOrBatchDeleteTopicReqMessageType) Value() string

type CreateTopicOrBatchDeleteTopicReqMessageTypeEnum added in v0.1.53 

type CreateTopicOrBatchDeleteTopicReqMessageTypeEnum struct {
	NORMAL      CreateTopicOrBatchDeleteTopicReqMessageType
	FIFO        CreateTopicOrBatchDeleteTopicReqMessageType
	DELAY       CreateTopicOrBatchDeleteTopicReqMessageType
	TRANSACTION CreateTopicOrBatchDeleteTopicReqMessageType
}

func GetCreateTopicOrBatchDeleteTopicReqMessageTypeEnum added in v0.1.53 

func GetCreateTopicOrBatchDeleteTopicReqMessageTypeEnum() CreateTopicOrBatchDeleteTopicReqMessageTypeEnum

type CreateTopicOrBatchDeleteTopicReqPermission 

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

func (CreateTopicOrBatchDeleteTopicReqPermission) MarshalJSON 

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

func (*CreateTopicOrBatchDeleteTopicReqPermission) UnmarshalJSON 

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

func (CreateTopicOrBatchDeleteTopicReqPermission) Value added in v0.0.90 

func (c CreateTopicOrBatchDeleteTopicReqPermission) Value() string

type CreateTopicOrBatchDeleteTopicReqPermissionEnum 

type CreateTopicOrBatchDeleteTopicReqPermissionEnum struct {
	SUB CreateTopicOrBatchDeleteTopicReqPermission
	PUB CreateTopicOrBatchDeleteTopicReqPermission
	ALL CreateTopicOrBatchDeleteTopicReqPermission
}

func GetCreateTopicOrBatchDeleteTopicReqPermissionEnum 

func GetCreateTopicOrBatchDeleteTopicReqPermissionEnum() CreateTopicOrBatchDeleteTopicReqPermissionEnum

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 

func (o CreateTopicOrBatchDeleteTopicRequest) String() 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 

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

	// 消息类型。
	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 

func (c CreateTopicReqMessageType) Value() string

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 

func (c CreateUserResponseDefaultGroupPerm) Value() string

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 

func (c CreateUserResponseDefaultTopicPerm) Value() string

type CreateUserResponseDefaultTopicPermEnum 

type CreateUserResponseDefaultTopicPermEnum struct {
	PUB     CreateUserResponseDefaultTopicPerm
	SUB     CreateUserResponseDefaultTopicPerm
	PUB_SUB CreateUserResponseDefaultTopicPerm
	DENY    CreateUserResponseDefaultTopicPerm
}

func GetCreateUserResponseDefaultTopicPermEnum 

func GetCreateUserResponseDefaultTopicPermEnum() CreateUserResponseDefaultTopicPermEnum

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 

func (o DeadletterResendRespResendResults) String() string

type DeleteConsumerGroupRequest 

type DeleteConsumerGroupRequest struct {

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

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

DeleteConsumerGroupRequest Request Object

func (DeleteConsumerGroupRequest) String 

func (o DeleteConsumerGroupRequest) String() string

type DeleteConsumerGroupResponse 

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

DeleteConsumerGroupResponse Response Object

func (DeleteConsumerGroupResponse) String 

func (o DeleteConsumerGroupResponse) String() 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 

func (o DeleteRocketMqMigrationTaskRequest) String() string

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 

func (o DeleteRocketMqMigrationTaskResponse) String() string

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 

func (o ListAccessPolicyRespPolicies) String() 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 

func (o ListAvailableZonesRespAvailableZones) String() 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 

func (o ListAvailableZonesResponse) String() 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 

func (o ListConsumeGroupAccessPolicyRequest) String() string

type ListConsumeGroupAccessPolicyRequestEngine 

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

func (ListConsumeGroupAccessPolicyRequestEngine) MarshalJSON 

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

func (*ListConsumeGroupAccessPolicyRequestEngine) UnmarshalJSON 

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

func (ListConsumeGroupAccessPolicyRequestEngine) Value added in v0.0.90 

func (c ListConsumeGroupAccessPolicyRequestEngine) Value() string

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 

func (o ListConsumeGroupAccessPolicyResponse) String() 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 

func (o ListConsumerGroupOfTopicRequest) String() string

type ListConsumerGroupOfTopicResponse 

type ListConsumerGroupOfTopicResponse struct {

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

ListConsumerGroupOfTopicResponse Response Object

func (ListConsumerGroupOfTopicResponse) String 

func (o ListConsumerGroupOfTopicResponse) String() 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 

func (o ListInstanceConsumerGroupsRequest) String() 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 

func (o ListInstanceConsumerGroupsResponse) String() 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 

func (c ListInstancesRequestEngine) Value() string

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 

func (c ListInstancesRequestExactMatchName) Value() string

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 

func (c ListInstancesRequestIncludeFailure) Value() string

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 

func (c ListInstancesRequestStatus) Value() string

type ListInstancesRequestStatusEnum 

type ListInstancesRequestStatusEnum struct {
	CREATING        ListInstancesRequestStatus
	RUNNING         ListInstancesRequestStatus
	FAULTY          ListInstancesRequestStatus
	RESTARTING      ListInstancesRequestStatus
	RESIZING        ListInstancesRequestStatus
	RESIZING_FAILED ListInstancesRequestStatus
	FROZEN          ListInstancesRequestStatus
}

func GetListInstancesRequestStatusEnum 

func GetListInstancesRequestStatusEnum() ListInstancesRequestStatusEnum

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 

func (c ListMessageTraceRequestEngine) Value() string

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 

func (c ListMessageTraceRespTraceMsgType) Value() string

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 

func (c ListMessageTraceRespTraceTraceType) Value() string

type ListMessageTraceRespTraceTraceTypeEnum 

type ListMessageTraceRespTraceTraceTypeEnum struct {
	PUB             ListMessageTraceRespTraceTraceType
	SUB             ListMessageTraceRespTraceTraceType
	END_TRANSACTION ListMessageTraceRespTraceTraceType
}

func GetListMessageTraceRespTraceTraceTypeEnum 

func GetListMessageTraceRespTraceTraceTypeEnum() ListMessageTraceRespTraceTraceTypeEnum

type ListMessageTraceRespTraceTransactionState 

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

func (ListMessageTraceRespTraceTransactionState) MarshalJSON 

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

func (*ListMessageTraceRespTraceTransactionState) UnmarshalJSON 

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

func (ListMessageTraceRespTraceTransactionState) Value added in v0.0.90 

func (c ListMessageTraceRespTraceTransactionState) Value() string

type ListMessageTraceRespTraceTransactionStateEnum 

type ListMessageTraceRespTraceTransactionStateEnum struct {
	COMMIT_MESSAGE   ListMessageTraceRespTraceTransactionState
	ROLLBACK_MESSAGE ListMessageTraceRespTraceTransactionState
	UNKNOW           ListMessageTraceRespTraceTransactionState
}

func GetListMessageTraceRespTraceTransactionStateEnum 

func GetListMessageTraceRespTraceTransactionStateEnum() ListMessageTraceRespTraceTransactionStateEnum

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 

func (c ListMessagesRequestEngine) Value() string

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 

func (o ListRocketInstanceTopicsRequest) String() string

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 

func (o ListRocketInstanceTopicsResponse) String() string

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 

func (o ListRocketMqMigrationTaskRequest) String() string

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 

func (c ListRocketMqMigrationTaskRequestType) Value() string

type ListRocketMqMigrationTaskRequestTypeEnum added in v0.1.42 

type ListRocketMqMigrationTaskRequestTypeEnum struct {
	VHOST    ListRocketMqMigrationTaskRequestType
	EXCHANGE ListRocketMqMigrationTaskRequestType
	QUEUE    ListRocketMqMigrationTaskRequestType
	ALL      ListRocketMqMigrationTaskRequestType
}

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 

func (o ListRocketMqMigrationTaskResponse) String() string

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 

func (o ListTopicAccessPolicyRequest) String() 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 

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

	// 客户端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,omitempty"`

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

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 

func (c ResetConsumeOffsetRequestEngine) Value() string

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 

func (o ResetConsumeOffsetRespQueues) String() string

type ResetConsumeOffsetResponse 

type ResetConsumeOffsetResponse struct {

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

ResetConsumeOffsetResponse Response Object

func (ResetConsumeOffsetResponse) String 

func (o ResetConsumeOffsetResponse) String() string

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 

func (c SendDlqMessageRequestEngine) Value() string

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 

func (o ShowConsumerConnectionsRequest) String() string

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 

func (o ShowConsumerConnectionsResponse) String() string

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 

func (o ShowConsumerListOrDetailsRequest) String() 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 

func (o ShowConsumerListOrDetailsResponse) String() string

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

	// 消息类型。
	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 

func (c ShowOneTopicResponseMessageType) Value() string

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 

func (c ShowOneTopicResponsePermission) Value() string

type ShowOneTopicResponsePermissionEnum 

type ShowOneTopicResponsePermissionEnum struct {
	SUB ShowOneTopicResponsePermission
	PUB ShowOneTopicResponsePermission
	ALL ShowOneTopicResponsePermission
}

func GetShowOneTopicResponsePermissionEnum 

func GetShowOneTopicResponsePermissionEnum() ShowOneTopicResponsePermissionEnum

type ShowRocketmqProjectTagsRequest added in v0.1.26 

type ShowRocketmqProjectTagsRequest struct {
}

ShowRocketmqProjectTagsRequest Request Object

func (ShowRocketmqProjectTagsRequest) String added in v0.1.26 

func (o ShowRocketmqProjectTagsRequest) String() string

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 

func (o ShowRocketmqProjectTagsResponse) String() string

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 

func (o ShowTopicStatusRespBrokers) String() 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 

func (c ShowUserResponseDefaultGroupPerm) Value() string

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 

func (c ShowUserResponseDefaultTopicPerm) Value() string

type ShowUserResponseDefaultTopicPermEnum 

type ShowUserResponseDefaultTopicPermEnum struct {
	PUB     ShowUserResponseDefaultTopicPerm
	SUB     ShowUserResponseDefaultTopicPerm
	PUB_SUB ShowUserResponseDefaultTopicPerm
	DENY    ShowUserResponseDefaultTopicPerm
}

func GetShowUserResponseDefaultTopicPermEnum 

func GetShowUserResponseDefaultTopicPermEnum() ShowUserResponseDefaultTopicPermEnum

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值唯一。  [- 长度不超过36个字符。](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 长度为1~128个字符（中文也可以输入128个字符）。](tag:hws,hws_hk)  [- 不能包含“=”，“*”，“<”，“>”，“\\”，“,”，“|”，“/”](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @](tag:hws,hws_hk)  - 首尾字符不能为空格。
	Key *string `json:"key,omitempty"`

	// 标签值。  [- 不能为空。](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 长度不超过43个字符。](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 长度为0~255个字符（中文也可以输入128个字符）。](tag:hws,hws_hk)  [- 不能包含“=”，“*”，“<”，“>”，“\\”，“,”，“|”，“/”](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @](tag:hws,hws_hk)  - 首尾字符不能为空格。
	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"`

	// 消息类型。
	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"`

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

	// 最大重试次数。
	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 

func (o UpdateConsumerGroupRequest) String() string

type UpdateConsumerGroupResponse 

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

UpdateConsumerGroupResponse Response Object

func (UpdateConsumerGroupResponse) String 

func (o UpdateConsumerGroupResponse) String() 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 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 

func (c UpdateUserResponseDefaultGroupPerm) Value() string

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 

func (c UpdateUserResponseDefaultTopicPerm) Value() string

type UpdateUserResponseDefaultTopicPermEnum 

type UpdateUserResponseDefaultTopicPermEnum struct {
	PUB     UpdateUserResponseDefaultTopicPerm
	SUB     UpdateUserResponseDefaultTopicPerm
	PUB_SUB UpdateUserResponseDefaultTopicPerm
	DENY    UpdateUserResponseDefaultTopicPerm
}

func GetUpdateUserResponseDefaultTopicPermEnum 

func GetUpdateUserResponseDefaultTopicPermEnum() UpdateUserResponseDefaultTopicPermEnum

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 

func (o ValidateConsumedMessageRequest) String() string

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 

func (c ValidateConsumedMessageRequestEngine) Value() string

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 

func (o ValidateConsumedMessageResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.