model

package
v0.1.68 Latest Latest
Warning

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

 Go to latest Published: Nov 23, 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
	RESTARTING         ListInstancesRequestStatus
	DELETING           ListInstancesRequestStatus
	ERROR              ListInstancesRequestStatus
	CREATEFAILED       ListInstancesRequestStatus
	FREEZING           ListInstancesRequestStatus
	FROZEN             ListInstancesRequestStatus
	EXTENDING          ListInstancesRequestStatus
	SHRINKING          ListInstancesRequestStatus
	EXTENDEDFAILED     ListInstancesRequestStatus
	CONFIGURING        ListInstancesRequestStatus
	UPGRADING          ListInstancesRequestStatus
	UPGRADINGFAILED    ListInstancesRequestStatus
	ROLLBACK           ListInstancesRequestStatus
	ROLLBACKFAILED     ListInstancesRequestStatus
	VOLUMETYPECHANGING 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.