Documentation ¶
Index ¶
- type BatchCreateOrDeleteRocketmqTagRequest
- type BatchCreateOrDeleteRocketmqTagResponse
- type BatchCreateOrDeleteTagReq
- type BatchCreateOrDeleteTagReqAction
- type BatchCreateOrDeleteTagReqActionEnum
- type BatchDeleteConsumerGroupReq
- type BatchDeleteConsumerGroupResp
- type BatchDeleteInstanceReq
- type BatchDeleteInstanceReqAction
- type BatchDeleteInstanceReqActionEnum
- type BatchDeleteInstanceReqAllFailure
- type BatchDeleteInstanceReqAllFailureEnum
- type BatchDeleteInstanceRespResults
- type BatchDeleteInstanceRespResultsResult
- type BatchDeleteInstanceRespResultsResultEnum
- type BatchDeleteInstancesRequest
- type BatchDeleteInstancesResponse
- type BatchDeleteTopicReq
- type BatchDeleteTopicResp
- type BatchUpdateConsumerGroupReq
- type BatchUpdateConsumerGroupRequest
- type BatchUpdateConsumerGroupResponse
- type Brokers
- type BssParam
- type BssParamChargingMode
- type BssParamChargingModeEnum
- type BssParamPeriodType
- type BssParamPeriodTypeEnum
- type ClientData
- type ConsumerDetailResp
- type ConsumerGroup
- type ConsumerList
- type CreateConsumerGroupOrBatchDeleteConsumerGroupReq
- type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest
- type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse
- type CreateGroupResp
- type CreateInstanceByEngineReq
- type CreateInstanceByEngineReqEngine
- type CreateInstanceByEngineReqEngineEnum
- type CreateInstanceByEngineReqEngineVersion
- type CreateInstanceByEngineReqEngineVersionEnum
- type CreateInstanceByEngineReqProductId
- type CreateInstanceByEngineReqProductIdEnum
- type CreateInstanceByEngineReqStorageSpecCode
- type CreateInstanceByEngineReqStorageSpecCodeEnum
- type CreateInstanceByEngineRequest
- type CreateInstanceByEngineRequestEngine
- type CreateInstanceByEngineRequestEngineEnum
- type CreateInstanceByEngineResponse
- type CreatePostPaidInstanceReq
- type CreatePostPaidInstanceReqEngine
- type CreatePostPaidInstanceReqEngineEnum
- type CreatePostPaidInstanceReqEngineVersion
- type CreatePostPaidInstanceReqEngineVersionEnum
- type CreatePostPaidInstanceReqProductId
- type CreatePostPaidInstanceReqProductIdEnum
- type CreatePostPaidInstanceReqStorageSpecCode
- type CreatePostPaidInstanceReqStorageSpecCodeEnum
- type CreatePostPaidInstanceRequest
- type CreatePostPaidInstanceResponse
- type CreateRocketMqMigrationTaskReq
- type CreateRocketMqMigrationTaskRequest
- type CreateRocketMqMigrationTaskRequestOverwrite
- type CreateRocketMqMigrationTaskRequestOverwriteEnum
- type CreateRocketMqMigrationTaskRequestType
- type CreateRocketMqMigrationTaskRequestTypeEnum
- type CreateRocketMqMigrationTaskResponse
- type CreateTopicOrBatchDeleteTopicReq
- type CreateTopicOrBatchDeleteTopicReqMessageType
- type CreateTopicOrBatchDeleteTopicReqMessageTypeEnum
- type CreateTopicOrBatchDeleteTopicReqPermission
- type CreateTopicOrBatchDeleteTopicReqPermissionEnum
- type CreateTopicOrBatchDeleteTopicRequest
- type CreateTopicOrBatchDeleteTopicResponse
- type CreateTopicReq
- type CreateTopicReqMessageType
- type CreateTopicReqMessageTypeEnum
- type CreateTopicReqPermission
- type CreateTopicReqPermissionEnum
- type CreateTopicResp
- type CreateUserRequest
- type CreateUserResponse
- type CreateUserResponseDefaultGroupPerm
- type CreateUserResponseDefaultGroupPermEnum
- type CreateUserResponseDefaultTopicPerm
- type CreateUserResponseDefaultTopicPermEnum
- type DeadletterResendReq
- type DeadletterResendRespResendResults
- type DeleteConsumerGroupRequest
- type DeleteConsumerGroupResponse
- type DeleteInstanceRequest
- type DeleteInstanceResponse
- type DeleteRocketMqMigrationTaskRequest
- type DeleteRocketMqMigrationTaskResponse
- type DeleteTopicRequest
- type DeleteTopicResponse
- type DeleteUserRequest
- type DeleteUserResponse
- type ExportDlqMessageReq
- type ExportDlqMessageRequest
- type ExportDlqMessageResponse
- type ListAccessPolicyRespPolicies
- type ListAvailableZonesRequest
- type ListAvailableZonesRespAvailableZones
- type ListAvailableZonesResponse
- type ListBrokersRequest
- type ListBrokersRespBrokers
- type ListBrokersResponse
- type ListConsumeGroupAccessPolicyRequest
- type ListConsumeGroupAccessPolicyRequestEngine
- type ListConsumeGroupAccessPolicyRequestEngineEnum
- type ListConsumeGroupAccessPolicyResponse
- type ListConsumerGroupOfTopicRequest
- type ListConsumerGroupOfTopicResponse
- type ListInstanceConsumerGroupsRequest
- type ListInstanceConsumerGroupsResponse
- type ListInstancesRequest
- type ListInstancesRequestEngine
- type ListInstancesRequestEngineEnum
- type ListInstancesRequestExactMatchName
- type ListInstancesRequestExactMatchNameEnum
- type ListInstancesRequestIncludeFailure
- type ListInstancesRequestIncludeFailureEnum
- type ListInstancesRequestStatus
- type ListInstancesRequestStatusEnum
- type ListInstancesResponse
- type ListMessageTraceRequest
- type ListMessageTraceRequestEngine
- type ListMessageTraceRequestEngineEnum
- type ListMessageTraceRespTrace
- type ListMessageTraceRespTraceMsgType
- type ListMessageTraceRespTraceMsgTypeEnum
- type ListMessageTraceRespTraceTraceType
- type ListMessageTraceRespTraceTraceTypeEnum
- type ListMessageTraceRespTraceTransactionState
- type ListMessageTraceRespTraceTransactionStateEnum
- type ListMessageTraceResponse
- type ListMessagesRequest
- type ListMessagesRequestEngine
- type ListMessagesRequestEngineEnum
- type ListMessagesResponse
- type ListRocketInstanceTopicsRequest
- type ListRocketInstanceTopicsResponse
- type ListRocketMqMigrationTaskRequest
- type ListRocketMqMigrationTaskRequestType
- type ListRocketMqMigrationTaskRequestTypeEnum
- type ListRocketMqMigrationTaskResponse
- type ListTopicAccessPolicyRequest
- type ListTopicAccessPolicyResponse
- type ListUserRequest
- type ListUserResponse
- type Message
- type MessagePropertyList
- type MetadataDeleteReq
- type MetadataTask
- type MigrationRabbitBindingMetadata
- type MigrationRabbitExchangeMetadata
- type MigrationRabbitQueueMetadata
- type MigrationRabbitVhostMetadata
- type MigrationRocketMqSubscriptionGroup
- type MigrationRocketMqTopicConfig
- type ModifyConfigReq
- type Queue
- type ResendReq
- type ResetConsumeOffsetReq
- type ResetConsumeOffsetRequest
- type ResetConsumeOffsetRequestEngine
- type ResetConsumeOffsetRequestEngineEnum
- type ResetConsumeOffsetRespQueues
- type ResetConsumeOffsetResponse
- type ResizeEngineInstanceReq
- type ResizeInstanceRequest
- type ResizeInstanceResponse
- type RocketMqConfigReq
- type RocketMqConfigReqName
- type RocketMqConfigReqNameEnum
- type RocketMqConfigResp
- type RocketMqExtendProductInfoEntity
- type RocketMqExtendProductIosEntity
- type RocketMqExtendProductPropertiesEntity
- type RocketMqProductSupportFeaturesEntity
- type SendDlqMessageRequest
- type SendDlqMessageRequestEngine
- type SendDlqMessageRequestEngineEnum
- type SendDlqMessageResponse
- type ShowConsumerConnectionsRequest
- type ShowConsumerConnectionsResponse
- type ShowConsumerListOrDetailsRequest
- type ShowConsumerListOrDetailsResponse
- type ShowEngineInstanceExtendProductInfoRequest
- type ShowEngineInstanceExtendProductInfoRequestType
- type ShowEngineInstanceExtendProductInfoRequestTypeEnum
- type ShowEngineInstanceExtendProductInfoResponse
- type ShowGroupRequest
- type ShowGroupResponse
- type ShowInstanceRequest
- type ShowInstanceResp
- type ShowInstanceRespType
- type ShowInstanceRespTypeEnum
- type ShowInstanceResponse
- type ShowInstanceResponseType
- type ShowInstanceResponseTypeEnum
- type ShowOneTopicRequest
- type ShowOneTopicResponse
- type ShowOneTopicResponseMessageType
- type ShowOneTopicResponseMessageTypeEnum
- type ShowOneTopicResponsePermission
- type ShowOneTopicResponsePermissionEnum
- type ShowRocketMqConfigsRequest
- type ShowRocketMqConfigsResponse
- type ShowRocketmqProjectTagsRequest
- type ShowRocketmqProjectTagsResponse
- type ShowRocketmqTagsRequest
- type ShowRocketmqTagsResponse
- type ShowTopicStatusRequest
- type ShowTopicStatusRespBrokers
- type ShowTopicStatusRespQueues
- type ShowTopicStatusResponse
- type ShowUserRequest
- type ShowUserResponse
- type ShowUserResponseDefaultGroupPerm
- type ShowUserResponseDefaultGroupPermEnum
- type ShowUserResponseDefaultTopicPerm
- type ShowUserResponseDefaultTopicPermEnum
- type Subscription
- type TagEntity
- type TagMultyValueEntity
- type Topic
- type TopicBrokers
- type TopicMessageType
- type TopicMessageTypeEnum
- type TopicPermission
- type TopicPermissionEnum
- type UpdateConsumerGroup
- type UpdateConsumerGroupRequest
- type UpdateConsumerGroupResponse
- type UpdateInstanceReq
- type UpdateInstanceRequest
- type UpdateInstanceResponse
- type UpdateRocketMqConfigsRequest
- type UpdateRocketMqConfigsResponse
- type UpdateTopicReq
- type UpdateTopicReqPermission
- type UpdateTopicReqPermissionEnum
- type UpdateTopicRequest
- type UpdateTopicResponse
- type UpdateUserRequest
- type UpdateUserResponse
- type UpdateUserResponseDefaultGroupPerm
- type UpdateUserResponseDefaultGroupPermEnum
- type UpdateUserResponseDefaultTopicPerm
- type UpdateUserResponseDefaultTopicPermEnum
- type User
- type UserDefaultGroupPerm
- type UserDefaultGroupPermEnum
- type UserDefaultTopicPerm
- type UserDefaultTopicPermEnum
- type UserGroupPerms
- type UserGroupPermsPerm
- type UserGroupPermsPermEnum
- type UserTopicPerms
- type UserTopicPermsPerm
- type UserTopicPermsPermEnum
- type ValidateConsumedMessageRequest
- type ValidateConsumedMessageRequestEngine
- type ValidateConsumedMessageRequestEngineEnum
- type ValidateConsumedMessageResponse
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 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 表示包周期计费模式的相关参数。 如果为空,则默认计费模式为按需计费;否则是包周期方式。
type BssParamChargingMode ¶ added in v0.1.26
type BssParamChargingMode struct {
// contains filtered or unexported fields
}
func (BssParamChargingMode) MarshalJSON ¶ added in v0.1.26
func (c BssParamChargingMode) MarshalJSON() ([]byte, error)
func (*BssParamChargingMode) UnmarshalJSON ¶ added in v0.1.26
func (c *BssParamChargingMode) UnmarshalJSON(b []byte) error
func (BssParamChargingMode) Value ¶ added in v0.1.26
func (c BssParamChargingMode) Value() string
type BssParamChargingModeEnum ¶ added in v0.1.26
type BssParamChargingModeEnum struct { PRE_PAID BssParamChargingMode POST_PAID BssParamChargingMode }
func GetBssParamChargingModeEnum ¶ added in v0.1.26
func GetBssParamChargingModeEnum() BssParamChargingModeEnum
type BssParamPeriodType ¶ added in v0.1.26
type BssParamPeriodType struct {
// contains filtered or unexported fields
}
func (BssParamPeriodType) MarshalJSON ¶ added in v0.1.26
func (c BssParamPeriodType) MarshalJSON() ([]byte, error)
func (*BssParamPeriodType) UnmarshalJSON ¶ added in v0.1.26
func (c *BssParamPeriodType) UnmarshalJSON(b []byte) error
func (BssParamPeriodType) Value ¶ added in v0.1.26
func (c BssParamPeriodType) Value() string
type BssParamPeriodTypeEnum ¶ added in v0.1.26
type BssParamPeriodTypeEnum struct { MONTH BssParamPeriodType YEAR BssParamPeriodType }
func GetBssParamPeriodTypeEnum ¶ added in v0.1.26
func GetBssParamPeriodTypeEnum() BssParamPeriodTypeEnum
type ClientData ¶ added in v0.1.37
type ClientData struct { // 客户端语言 Language *string `json:"language,omitempty"` // 客户端版本 Version *string `json:"version,omitempty"` // 客户端ID ClientId *string `json:"client_id,omitempty"` // 客户端地址 ClientAddr *string `json:"client_addr,omitempty"` // 订阅关系列表 Subscriptions *[]Subscription `json:"subscriptions,omitempty"` }
func (ClientData) String ¶ added in v0.1.37
func (o ClientData) String() string
type ConsumerDetailResp ¶ added in v0.1.37
type ConsumerDetailResp struct { // 消费堆积总数 Lag *int64 `json:"lag,omitempty"` // 消息总数 MaxOffset *int64 `json:"max_offset,omitempty"` // 已消费消息数 ConsumerOffset *int64 `json:"consumer_offset,omitempty"` // Topic关联代理(当查询topic消费“详情”才显示此参数)。 Brokers *[]Brokers `json:"brokers,omitempty"` }
func (ConsumerDetailResp) String ¶ added in v0.1.37
func (o ConsumerDetailResp) String() string
type ConsumerGroup ¶
type ConsumerGroup struct { // 是否可以消费。 Enabled *bool `json:"enabled,omitempty"` // 是否广播。 Broadcast *bool `json:"broadcast,omitempty"` // 关联的代理列表。 Brokers *[]string `json:"brokers,omitempty"` // 消费组名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。 Name *string `json:"name,omitempty"` // 消费组描述,长度0~200个字符。 GroupDesc *string `json:"group_desc,omitempty"` // 最大重试次数,取值范围为1~16。 RetryMaxTime float32 `json:"retry_max_time,omitempty"` // 是否重头消费。 FromBeginning *bool `json:"from_beginning,omitempty"` }
func (ConsumerGroup) String ¶
func (o ConsumerGroup) String() string
type ConsumerList ¶ added in v0.1.37
type ConsumerList struct { // Topic列表(当查询topic消费“列表”时才显示此参数)。 Topics *[]string `json:"topics,omitempty"` // Topic总数(当查询topic消费“列表”时才显示此参数)。 Total *int32 `json:"total,omitempty"` }
func (ConsumerList) String ¶ added in v0.1.37
func (o ConsumerList) String() string
type CreateConsumerGroupOrBatchDeleteConsumerGroupReq ¶
type CreateConsumerGroupOrBatchDeleteConsumerGroupReq struct { // 待删除的消费组列表。 Groups *[]string `json:"groups,omitempty"` // 是否可以消费。 Enabled *bool `json:"enabled,omitempty"` // 是否广播。 Broadcast *bool `json:"broadcast,omitempty"` // 关联的代理列表。 Brokers *[]string `json:"brokers,omitempty"` // 消费组名称,只能由英文字母、数字、百分号、竖线、中划线、下划线组成,长度3~64个字符。 Name *string `json:"name,omitempty"` // 消费组描述,长度0~200个字符。 GroupDesc *string `json:"group_desc,omitempty"` // 最大重试次数,取值范围为1~16。 RetryMaxTime float32 `json:"retry_max_time,omitempty"` // 是否重头消费。 FromBeginning *bool `json:"from_beginning,omitempty"` }
func (CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String ¶
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 CreateRocketMqMigrationTaskReq ¶ added in v0.1.72
type CreateRocketMqMigrationTaskReq struct { // RocketMQ topic 元数据,键为topic名,值为topic配置,迁移任务类型为自建RocketMQ上云(rocketmq)时必填。 TopicConfigTable map[string]MigrationRocketMqTopicConfig `json:"topicConfigTable,omitempty"` // RocketMQ消费组元数据,键为消费组名,值为消费组配置,迁移任务类型为自建RocketMQ上云(rocketmq)时必填。 SubscriptionGroupTable map[string]MigrationRocketMqSubscriptionGroup `json:"subscriptionGroupTable,omitempty"` // RabbitMQ vhost元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。 Vhosts *[]MigrationRabbitVhostMetadata `json:"vhosts,omitempty"` // RabbitMQ队列元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。 Queues *[]MigrationRabbitQueueMetadata `json:"queues,omitempty"` // RabbitMQ交换机元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。 Exchanges *[]MigrationRabbitExchangeMetadata `json:"exchanges,omitempty"` // RabbitMQ binding元数据列表,迁移任务类型为自建RabbitMQ上云(rabbitToRocket)时必填。 Bindings *[]MigrationRabbitBindingMetadata `json:"bindings,omitempty"` }
func (CreateRocketMqMigrationTaskReq) String ¶ added in v0.1.72
func (o CreateRocketMqMigrationTaskReq) 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"` Body *CreateRocketMqMigrationTaskReq `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"` // 消息类型(RocketMQ实例5.x版本才包含此参数)。 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"` // 消息类型(RocketMQ实例5.x版本才包含此参数)。 MessageType *CreateTopicReqMessageType `json:"message_type,omitempty"` }
func (CreateTopicReq) String ¶
func (o CreateTopicReq) String() string
type CreateTopicReqMessageType ¶ added in v0.1.53
type CreateTopicReqMessageType struct {
// contains filtered or unexported fields
}
func (CreateTopicReqMessageType) MarshalJSON ¶ added in v0.1.53
func (c CreateTopicReqMessageType) MarshalJSON() ([]byte, error)
func (*CreateTopicReqMessageType) UnmarshalJSON ¶ added in v0.1.53
func (c *CreateTopicReqMessageType) UnmarshalJSON(b []byte) error
func (CreateTopicReqMessageType) Value ¶ added in v0.1.53
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 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 消息。
type MessagePropertyList ¶
type MessagePropertyList struct { // 属性名称。 Name *string `json:"name,omitempty"` // 属性值。 Value *string `json:"value,omitempty"` }
func (MessagePropertyList) String ¶
func (o MessagePropertyList) String() string
type MetadataDeleteReq ¶ added in v0.1.42
type MetadataDeleteReq struct { // 需要删除的任务列表。 TaskIds []string `json:"task_ids"` }
func (MetadataDeleteReq) String ¶ added in v0.1.42
func (o MetadataDeleteReq) String() string
type MetadataTask ¶ added in v0.1.42
type MetadataTask struct { // 元数据迁移任务ID。 Id *string `json:"id,omitempty"` // 元数据迁移任务名称。 Name *string `json:"name,omitempty"` // 元数据迁移任务开始时间。 StartDate *string `json:"start_date,omitempty"` // 元数据迁移任务状态。 Status *string `json:"status,omitempty"` // 元数据迁移类型。 Type *string `json:"type,omitempty"` }
MetadataTask 元数据迁移任务。
func (MetadataTask) String ¶ added in v0.1.42
func (o MetadataTask) String() string
type MigrationRabbitBindingMetadata ¶ added in v0.1.72
type MigrationRabbitBindingMetadata struct { // vhost名称。 Vhost *string `json:"vhost,omitempty"` // 消息的来源。 Source *string `json:"source,omitempty"` // 消息的目标。 Destination *string `json:"destination,omitempty"` // 目标的类型。 DestinationType *string `json:"destination_type,omitempty"` // 路由键。 RoutingKey *string `json:"routing_key,omitempty"` }
MigrationRabbitBindingMetadata RocketMQ元数据迁移,RabbitMQ binding元数据。
func (MigrationRabbitBindingMetadata) String ¶ added in v0.1.72
func (o MigrationRabbitBindingMetadata) String() string
type MigrationRabbitExchangeMetadata ¶ added in v0.1.72
type MigrationRabbitExchangeMetadata struct { // vhost名称。 Vhost *string `json:"vhost,omitempty"` // 交换机名称。 Name *string `json:"name,omitempty"` // 交换机类型。 Type *string `json:"type,omitempty"` // 是否持久化。 Durable *bool `json:"durable,omitempty"` }
MigrationRabbitExchangeMetadata RocketMQ元数据迁移,RabbitMQ交换机元数据。
func (MigrationRabbitExchangeMetadata) String ¶ added in v0.1.72
func (o MigrationRabbitExchangeMetadata) String() string
type MigrationRabbitQueueMetadata ¶ added in v0.1.72
type MigrationRabbitQueueMetadata struct { // vhost名称。 Vhost *string `json:"vhost,omitempty"` // 队列名称。 Name *string `json:"name,omitempty"` // 是否持久化。 Durable *bool `json:"durable,omitempty"` }
MigrationRabbitQueueMetadata RocketMQ元数据迁移,RabbitMQ队列元数据。
func (MigrationRabbitQueueMetadata) String ¶ added in v0.1.72
func (o MigrationRabbitQueueMetadata) String() string
type MigrationRabbitVhostMetadata ¶ added in v0.1.72
type MigrationRabbitVhostMetadata struct { // vhost名称。 Name *string `json:"name,omitempty"` }
MigrationRabbitVhostMetadata RocketMQ元数据迁移,RabbitMQ vhost元数据。
func (MigrationRabbitVhostMetadata) String ¶ added in v0.1.72
func (o MigrationRabbitVhostMetadata) String() string
type MigrationRocketMqSubscriptionGroup ¶ added in v0.1.72
type MigrationRocketMqSubscriptionGroup struct { // 消费组名。 GroupName *string `json:"groupName,omitempty"` // 是否允许以广播模式消费。 ConsumeBroadcastEnable *bool `json:"consumeBroadcastEnable,omitempty"` // 是否允许消费。 ConsumeEnable *bool `json:"consumeEnable,omitempty"` // 是否从最小偏移量开始消费。 ConsumeFromMinEnable *bool `json:"consumeFromMinEnable,omitempty"` // 消费者ID变化时是否通知。 NotifyConsumerIdsChangedEnable *bool `json:"notifyConsumerIdsChangedEnable,omitempty"` // 消费最大重试次数。 RetryMaxTimes *int32 `json:"retryMaxTimes,omitempty"` // 重试队列个数。 RetryQueueNums *int32 `json:"retryQueueNums,omitempty"` // 慢消费时选择的broker节点ID。 WhichBrokerWhenConsumeSlow *int64 `json:"whichBrokerWhenConsumeSlow,omitempty"` }
MigrationRocketMqSubscriptionGroup RocketMQ元数据迁移,RocketMQ消费组元数据。
func (MigrationRocketMqSubscriptionGroup) String ¶ added in v0.1.72
func (o MigrationRocketMqSubscriptionGroup) String() string
type MigrationRocketMqTopicConfig ¶ added in v0.1.72
type MigrationRocketMqTopicConfig struct { // topic名称。 TopicName *string `json:"topicName,omitempty"` // 是否有序消息。 Order *bool `json:"order,omitempty"` // topic权限。 Perm *int32 `json:"perm,omitempty"` // 读队列个数。 ReadQueueNums *int32 `json:"readQueueNums,omitempty"` // 写队列个数。 WriteQueueNums *int32 `json:"writeQueueNums,omitempty"` // topic过滤类型。 - SINGLE_TAG:单标签 - MULTI_TAG:多标签 TopicFilterType *string `json:"topicFilterType,omitempty"` // topic系统标志位。 TopicSysFlag *int32 `json:"topicSysFlag,omitempty"` }
MigrationRocketMqTopicConfig RocketMQ元数据迁移,RocketMQ topic元数据。
func (MigrationRocketMqTopicConfig) String ¶ added in v0.1.72
func (o MigrationRocketMqTopicConfig) String() string
type ModifyConfigReq ¶ added in v0.1.71
type ModifyConfigReq struct { // RocketMQ配置。 RocketmqConfigs *[]RocketMqConfigReq `json:"rocketmq_configs,omitempty"` }
func (ModifyConfigReq) String ¶ added in v0.1.71
func (o ModifyConfigReq) String() string
type Queue ¶ added in v0.1.37
type Queue struct { // 队列ID Id *int32 `json:"id,omitempty"` // 队列消费堆积总数 Lag *int64 `json:"lag,omitempty"` // 队列消息总数 BrokerOffset *int64 `json:"broker_offset,omitempty"` // 已消费消息数 ConsumerOffset *int64 `json:"consumer_offset,omitempty"` // 最新消费消息的存储时间,unix毫秒时间戳格式 LastMessageTime *int64 `json:"last_message_time,omitempty"` }
type ResendReq ¶ added in v0.1.42
type ResetConsumeOffsetReq ¶
type ResetConsumeOffsetReq struct { // 重置的主题。 Topic string `json:"topic"` // 重置的时间。 Timestamp float32 `json:"timestamp"` }
func (ResetConsumeOffsetReq) String ¶
func (o ResetConsumeOffsetReq) String() string
type ResetConsumeOffsetRequest ¶
type ResetConsumeOffsetRequest struct { // 引擎类型:reliability。 Engine ResetConsumeOffsetRequestEngine `json:"engine"` // 实例ID。 InstanceId string `json:"instance_id"` // 消费组名称。 GroupId string `json:"group_id"` Body *ResetConsumeOffsetReq `json:"body,omitempty"` }
ResetConsumeOffsetRequest Request Object
func (ResetConsumeOffsetRequest) String ¶
func (o ResetConsumeOffsetRequest) String() string
type ResetConsumeOffsetRequestEngine ¶
type ResetConsumeOffsetRequestEngine struct {
// contains filtered or unexported fields
}
func (ResetConsumeOffsetRequestEngine) MarshalJSON ¶
func (c ResetConsumeOffsetRequestEngine) MarshalJSON() ([]byte, error)
func (*ResetConsumeOffsetRequestEngine) UnmarshalJSON ¶
func (c *ResetConsumeOffsetRequestEngine) UnmarshalJSON(b []byte) error
func (ResetConsumeOffsetRequestEngine) Value ¶ added in v0.0.90
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 ResizeEngineInstanceReq ¶ added in v0.1.70
type ResizeEngineInstanceReq struct { // 变更类型 取值范围: - storage:存储空间扩容,代理数量不变。 - horizontal:代理数量扩容,每个broker的存储空间不变。 - vertical:垂直扩容,broker的底层虚机规格变更,代理数量和存储空间不变。 OperType string `json:"oper_type"` // 当oper_type类型是storage或horizontal时,该参数有效且必填,实例存储空间 = 代理数量 * 每个broker的存储空间。 - 当oper_type类型是storage时,代理数量不变,每个broker存储空间最少扩容100GB。 - 当oper_type类型是horizontal时,每个broker的存储空间不变。 NewStorageSpace *int32 `json:"new_storage_space,omitempty"` // 当oper_type类型是vertical时,该参数才有效且必填。 NewProductId *string `json:"new_product_id,omitempty"` // 代理数量 当oper_type参数为horizontal时,该参数必填。 NewBrokerNum *int32 `json:"new_broker_num,omitempty"` }
ResizeEngineInstanceReq 变更类型 取值范围: - storage:存储空间扩容,代理数量不变。 - horizontal:代理数量扩容,每个broker的存储空间不变。 - vertical:垂直扩缩容,broker的底层虚机规格变更,代理数量和存储空间不变。
func (ResizeEngineInstanceReq) String ¶ added in v0.1.70
func (o ResizeEngineInstanceReq) String() string
type ResizeInstanceRequest ¶ added in v0.1.70
type ResizeInstanceRequest struct { // 消息引擎的类型。支持的类型为rocketmq。 Engine string `json:"engine"` // 实例ID。 InstanceId string `json:"instance_id"` Body *ResizeEngineInstanceReq `json:"body,omitempty"` }
ResizeInstanceRequest Request Object
func (ResizeInstanceRequest) String ¶ added in v0.1.70
func (o ResizeInstanceRequest) String() string
type ResizeInstanceResponse ¶ added in v0.1.70
type ResizeInstanceResponse struct { // 规格变更任务ID。 JobId *string `json:"job_id,omitempty"` HttpStatusCode int `json:"-"` }
ResizeInstanceResponse Response Object
func (ResizeInstanceResponse) String ¶ added in v0.1.70
func (o ResizeInstanceResponse) String() string
type RocketMqConfigReq ¶ added in v0.1.71
type RocketMqConfigReq struct { // RocketMQ配置名称 Name *RocketMqConfigReqName `json:"name,omitempty"` // RocketMQ配置目标值 Value *string `json:"value,omitempty"` }
func (RocketMqConfigReq) String ¶ added in v0.1.71
func (o RocketMqConfigReq) String() string
type RocketMqConfigReqName ¶ added in v0.1.71
type RocketMqConfigReqName struct {
// contains filtered or unexported fields
}
func (RocketMqConfigReqName) MarshalJSON ¶ added in v0.1.71
func (c RocketMqConfigReqName) MarshalJSON() ([]byte, error)
func (*RocketMqConfigReqName) UnmarshalJSON ¶ added in v0.1.71
func (c *RocketMqConfigReqName) UnmarshalJSON(b []byte) error
func (RocketMqConfigReqName) Value ¶ added in v0.1.71
func (c RocketMqConfigReqName) Value() string
type RocketMqConfigReqNameEnum ¶ added in v0.1.71
type RocketMqConfigReqNameEnum struct {
FILE_RESERVED_TIME RocketMqConfigReqName
}
func GetRocketMqConfigReqNameEnum ¶ added in v0.1.71
func GetRocketMqConfigReqNameEnum() RocketMqConfigReqNameEnum
type RocketMqConfigResp ¶ added in v0.1.71
type RocketMqConfigResp struct { // RocketMQ配置名称 Name *string `json:"name,omitempty"` // RocketMQ配置当前值 Value *string `json:"value,omitempty"` // RocketMQ配置的类型 ConfigType *string `json:"config_type,omitempty"` // RocketMQ配置的默认值 DefaultValue *string `json:"default_value,omitempty"` // RocketMQ配置取值的范围 ValidValues *string `json:"valid_values,omitempty"` // RocketMQ配置值的类型 ValueType *string `json:"value_type,omitempty"` }
func (RocketMqConfigResp) String ¶ added in v0.1.71
func (o RocketMqConfigResp) String() string
type RocketMqExtendProductInfoEntity ¶ added in v0.1.70
type RocketMqExtendProductInfoEntity struct { // 实例类型 Type *string `json:"type,omitempty"` // 产品ID ProductId *string `json:"product_id,omitempty"` // 该产品使用的ECS规格 EcsFlavorId *string `json:"ecs_flavor_id,omitempty"` // 账单计费类型。 BillingCode *string `json:"billing_code,omitempty"` // 支持的CPU架构类型 ArchTypes *[]string `json:"arch_types,omitempty"` // 支持的计费模式类型 ChargingMode *[]string `json:"charging_mode,omitempty"` // 磁盘IO信息 Ios *[]RocketMqExtendProductIosEntity `json:"ios,omitempty"` Properties *RocketMqExtendProductPropertiesEntity `json:"properties,omitempty"` // 有可用资源的可用区列表 AvailableZones *[]string `json:"available_zones,omitempty"` UnavailableZones *[]string `json:"unavailable_zones,omitempty"` // 支持的特性功能 SupportFeatures *[]RocketMqProductSupportFeaturesEntity `json:"support_features,omitempty"` // 是否为擎天实例。 QingtianIncompatible *bool `json:"qingtian_incompatible,omitempty"` }
func (RocketMqExtendProductInfoEntity) String ¶ added in v0.1.70
func (o RocketMqExtendProductInfoEntity) String() string
type RocketMqExtendProductIosEntity ¶ added in v0.1.70
type RocketMqExtendProductIosEntity struct { // 存储IO规格 IoSpec *string `json:"io_spec,omitempty"` // 有可用资源的可用区列表 AvailableZones *[]string `json:"available_zones,omitempty"` // IO类型 Type *string `json:"type,omitempty"` UnavailableZones *[]string `json:"unavailable_zones,omitempty"` }
RocketMqExtendProductIosEntity 磁盘IO信息
func (RocketMqExtendProductIosEntity) String ¶ added in v0.1.70
func (o RocketMqExtendProductIosEntity) String() string
type RocketMqExtendProductPropertiesEntity ¶ added in v0.1.70
type RocketMqExtendProductPropertiesEntity struct { // Broker的最大个数。 MaxBroker *string `json:"max_broker,omitempty"` // 每个节点最多能创建的Topic个数。 MaxTopicPerBroker *string `json:"max_topic_per_broker,omitempty"` // 每个节点的最大消费者数。 MaxConsumerPerBroker *string `json:"max_consumer_per_broker,omitempty"` // 每个节点的最大存储。单位为GB MaxStoragePerNode *string `json:"max_storage_per_node,omitempty"` // Broker的最小个数。 MinBroker *string `json:"min_broker,omitempty"` // 消息引擎版本。 EngineVersions *string `json:"engine_versions,omitempty"` // 每个节点的最小存储。单位为GB MinStoragePerNode *string `json:"min_storage_per_node,omitempty"` // product_id的别名 ProductAlias *string `json:"product_alias,omitempty"` }
RocketMqExtendProductPropertiesEntity 功能特性的键值对。
func (RocketMqExtendProductPropertiesEntity) String ¶ added in v0.1.70
func (o RocketMqExtendProductPropertiesEntity) String() string
type RocketMqProductSupportFeaturesEntity ¶ added in v0.1.70
type RocketMqProductSupportFeaturesEntity struct { // 特性名称 Name *string `json:"name,omitempty"` // 功能特性的键值对 Properties map[string]string `json:"properties,omitempty"` }
RocketMqProductSupportFeaturesEntity 支持的特性功能。
func (RocketMqProductSupportFeaturesEntity) String ¶ added in v0.1.70
func (o RocketMqProductSupportFeaturesEntity) 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 ShowEngineInstanceExtendProductInfoRequest ¶ added in v0.1.70
type ShowEngineInstanceExtendProductInfoRequest struct { // 消息引擎的类型。支持的类型为rocketmq。 Engine string `json:"engine"` // 实例ID。 InstanceId string `json:"instance_id"` // 产品的类型。 advanced:专享版 Type *ShowEngineInstanceExtendProductInfoRequestType `json:"type,omitempty"` }
ShowEngineInstanceExtendProductInfoRequest Request Object
func (ShowEngineInstanceExtendProductInfoRequest) String ¶ added in v0.1.70
func (o ShowEngineInstanceExtendProductInfoRequest) String() string
type ShowEngineInstanceExtendProductInfoRequestType ¶ added in v0.1.70
type ShowEngineInstanceExtendProductInfoRequestType struct {
// contains filtered or unexported fields
}
func (ShowEngineInstanceExtendProductInfoRequestType) MarshalJSON ¶ added in v0.1.70
func (c ShowEngineInstanceExtendProductInfoRequestType) MarshalJSON() ([]byte, error)
func (*ShowEngineInstanceExtendProductInfoRequestType) UnmarshalJSON ¶ added in v0.1.70
func (c *ShowEngineInstanceExtendProductInfoRequestType) UnmarshalJSON(b []byte) error
func (ShowEngineInstanceExtendProductInfoRequestType) Value ¶ added in v0.1.70
func (c ShowEngineInstanceExtendProductInfoRequestType) Value() string
type ShowEngineInstanceExtendProductInfoRequestTypeEnum ¶ added in v0.1.70
type ShowEngineInstanceExtendProductInfoRequestTypeEnum struct {
ADVANCED ShowEngineInstanceExtendProductInfoRequestType
}
func GetShowEngineInstanceExtendProductInfoRequestTypeEnum ¶ added in v0.1.70
func GetShowEngineInstanceExtendProductInfoRequestTypeEnum() ShowEngineInstanceExtendProductInfoRequestTypeEnum
type ShowEngineInstanceExtendProductInfoResponse ¶ added in v0.1.70
type ShowEngineInstanceExtendProductInfoResponse struct { // 消息引擎类型 Engine *string `json:"engine,omitempty"` // 消息引擎支持的版本 Versions *[]string `json:"versions,omitempty"` // 规格变更的产品信息 Products *[]RocketMqExtendProductInfoEntity `json:"products,omitempty"` HttpStatusCode int `json:"-"` }
ShowEngineInstanceExtendProductInfoResponse Response Object
func (ShowEngineInstanceExtendProductInfoResponse) String ¶ added in v0.1.70
func (o ShowEngineInstanceExtendProductInfoResponse) 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"` // 消息类型(RocketMQ实例5.x版本才包含此参数)。 MessageType *ShowOneTopicResponseMessageType `json:"message_type,omitempty"` HttpStatusCode int `json:"-"` }
ShowOneTopicResponse Response Object
func (ShowOneTopicResponse) String ¶
func (o ShowOneTopicResponse) String() string
type ShowOneTopicResponseMessageType ¶ added in v0.1.53
type ShowOneTopicResponseMessageType struct {
// contains filtered or unexported fields
}
func (ShowOneTopicResponseMessageType) MarshalJSON ¶ added in v0.1.53
func (c ShowOneTopicResponseMessageType) MarshalJSON() ([]byte, error)
func (*ShowOneTopicResponseMessageType) UnmarshalJSON ¶ added in v0.1.53
func (c *ShowOneTopicResponseMessageType) UnmarshalJSON(b []byte) error
func (ShowOneTopicResponseMessageType) Value ¶ added in v0.1.53
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 ShowRocketMqConfigsRequest ¶ added in v0.1.71
type ShowRocketMqConfigsRequest struct { // 实例ID。 InstanceId string `json:"instance_id"` }
ShowRocketMqConfigsRequest Request Object
func (ShowRocketMqConfigsRequest) String ¶ added in v0.1.71
func (o ShowRocketMqConfigsRequest) String() string
type ShowRocketMqConfigsResponse ¶ added in v0.1.71
type ShowRocketMqConfigsResponse struct { // RocketMQ配置。 RocketmqConfigs *[]RocketMqConfigResp `json:"rocketmq_configs,omitempty"` HttpStatusCode int `json:"-"` }
ShowRocketMqConfigsResponse Response Object
func (ShowRocketMqConfigsResponse) String ¶ added in v0.1.71
func (o ShowRocketMqConfigsResponse) String() string
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值唯一。 - 长度为1~128个字符(中文也可以输入128个字符)。 - 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ - 首尾字符不能为空格。 Key *string `json:"key,omitempty"` // 标签值。 - 长度为0~255个字符(中文也可以输入128个字符)。 - 由任意语种字母、数字、空格和字符组成,字符仅支持_ . : = + - @ - 首尾字符不能为空格。 Value *string `json:"value,omitempty"` }
type TagMultyValueEntity ¶ added in v0.1.26
type TagMultyValueEntity struct { // 标签键。 Key *string `json:"key,omitempty"` // 标签值。 Values *[]string `json:"values,omitempty"` }
func (TagMultyValueEntity) String ¶ added in v0.1.26
func (o TagMultyValueEntity) String() string
type Topic ¶ added in v0.1.22
type Topic struct { // topic名称。 Name *string `json:"name,omitempty"` // 总读队列个数。 TotalReadQueueNum float32 `json:"total_read_queue_num,omitempty"` // 总写队列个数。 TotalWriteQueueNum float32 `json:"total_write_queue_num,omitempty"` // 权限。 Permission *TopicPermission `json:"permission,omitempty"` // 关联的代理。 Brokers *[]TopicBrokers `json:"brokers,omitempty"` // 消息类型(RocketMQ实例5.x版本才包含此参数)。 MessageType *TopicMessageType `json:"message_type,omitempty"` }
type TopicBrokers ¶
type TopicBrokers struct { // 代理名称。 BrokerName *string `json:"broker_name,omitempty"` // 读队列个数。 ReadQueueNum float32 `json:"read_queue_num,omitempty"` // 写队列个数。 WriteQueueNum float32 `json:"write_queue_num,omitempty"` }
func (TopicBrokers) String ¶
func (o TopicBrokers) String() string
type TopicMessageType ¶ added in v0.1.53
type TopicMessageType struct {
// contains filtered or unexported fields
}
func (TopicMessageType) MarshalJSON ¶ added in v0.1.53
func (c TopicMessageType) MarshalJSON() ([]byte, error)
func (*TopicMessageType) UnmarshalJSON ¶ added in v0.1.53
func (c *TopicMessageType) UnmarshalJSON(b []byte) error
func (TopicMessageType) Value ¶ added in v0.1.53
func (c TopicMessageType) Value() string
type TopicMessageTypeEnum ¶ added in v0.1.53
type TopicMessageTypeEnum struct { NORMAL TopicMessageType FIFO TopicMessageType DELAY TopicMessageType TRANSACTION TopicMessageType }
func GetTopicMessageTypeEnum ¶ added in v0.1.53
func GetTopicMessageTypeEnum() TopicMessageTypeEnum
type TopicPermission ¶ added in v0.1.22
type TopicPermission struct {
// contains filtered or unexported fields
}
func (TopicPermission) MarshalJSON ¶ added in v0.1.22
func (c TopicPermission) MarshalJSON() ([]byte, error)
func (*TopicPermission) UnmarshalJSON ¶ added in v0.1.22
func (c *TopicPermission) UnmarshalJSON(b []byte) error
func (TopicPermission) Value ¶ added in v0.1.22
func (c TopicPermission) Value() string
type TopicPermissionEnum ¶ added in v0.1.22
type TopicPermissionEnum struct { SUB TopicPermission PUB TopicPermission ALL TopicPermission }
func GetTopicPermissionEnum ¶ added in v0.1.22
func GetTopicPermissionEnum() TopicPermissionEnum
type UpdateConsumerGroup ¶ added in v0.1.60
type UpdateConsumerGroup struct { // 是否可以消费。 Enabled bool `json:"enabled"` // 是否广播。 Broadcast bool `json:"broadcast"` // 关联的代理列表。 Brokers *[]string `json:"brokers,omitempty"` // 待修改参数的消费组(消费组名称不支持修改)。 Name *string `json:"name,omitempty"` // 最大重试次数,取值范围为1~16。 RetryMaxTime float32 `json:"retry_max_time"` // 是否重头消费。 FromBeginning *bool `json:"from_beginning,omitempty"` }
func (UpdateConsumerGroup) String ¶ added in v0.1.60
func (o UpdateConsumerGroup) String() string
type UpdateConsumerGroupRequest ¶
type UpdateConsumerGroupRequest struct { // 实例ID。 InstanceId string `json:"instance_id"` // 消费组名称。 Group string `json:"group"` Body *UpdateConsumerGroup `json:"body,omitempty"` }
UpdateConsumerGroupRequest Request Object
func (UpdateConsumerGroupRequest) String ¶
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 UpdateRocketMqConfigsRequest ¶ added in v0.1.71
type UpdateRocketMqConfigsRequest struct { // 实例ID。 InstanceId string `json:"instance_id"` Body *ModifyConfigReq `json:"body,omitempty"` }
UpdateRocketMqConfigsRequest Request Object
func (UpdateRocketMqConfigsRequest) String ¶ added in v0.1.71
func (o UpdateRocketMqConfigsRequest) String() string
type UpdateRocketMqConfigsResponse ¶ added in v0.1.71
type UpdateRocketMqConfigsResponse struct {
HttpStatusCode int `json:"-"`
}
UpdateRocketMqConfigsResponse Response Object
func (UpdateRocketMqConfigsResponse) String ¶ added in v0.1.71
func (o UpdateRocketMqConfigsResponse) 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"` }
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 ¶
- model_batch_create_or_delete_rocketmq_tag_request.go
- model_batch_create_or_delete_rocketmq_tag_response.go
- model_batch_create_or_delete_tag_req.go
- model_batch_delete_consumer_group_req.go
- model_batch_delete_consumer_group_resp.go
- model_batch_delete_instance_req.go
- model_batch_delete_instance_resp_results.go
- model_batch_delete_instances_request.go
- model_batch_delete_instances_response.go
- model_batch_delete_topic_req.go
- model_batch_delete_topic_resp.go
- model_batch_update_consumer_group_req.go
- model_batch_update_consumer_group_request.go
- model_batch_update_consumer_group_response.go
- model_brokers.go
- model_bss_param.go
- model_client_data.go
- model_consumer_detail_resp.go
- model_consumer_group.go
- model_consumer_list.go
- model_create_consumer_group_or_batch_delete_consumer_group_req.go
- model_create_consumer_group_or_batch_delete_consumer_group_request.go
- model_create_consumer_group_or_batch_delete_consumer_group_response.go
- model_create_group_resp.go
- model_create_instance_by_engine_req.go
- model_create_instance_by_engine_request.go
- model_create_instance_by_engine_response.go
- model_create_post_paid_instance_req.go
- model_create_post_paid_instance_request.go
- model_create_post_paid_instance_response.go
- model_create_rocket_mq_migration_task_req.go
- model_create_rocket_mq_migration_task_request.go
- model_create_rocket_mq_migration_task_response.go
- model_create_topic_or_batch_delete_topic_req.go
- model_create_topic_or_batch_delete_topic_request.go
- model_create_topic_or_batch_delete_topic_response.go
- model_create_topic_req.go
- model_create_topic_resp.go
- model_create_user_request.go
- model_create_user_response.go
- model_deadletter_resend_req.go
- model_deadletter_resend_resp_resend_results.go
- model_delete_consumer_group_request.go
- model_delete_consumer_group_response.go
- model_delete_instance_request.go
- model_delete_instance_response.go
- model_delete_rocket_mq_migration_task_request.go
- model_delete_rocket_mq_migration_task_response.go
- model_delete_topic_request.go
- model_delete_topic_response.go
- model_delete_user_request.go
- model_delete_user_response.go
- model_export_dlq_message_req.go
- model_export_dlq_message_request.go
- model_export_dlq_message_response.go
- model_list_access_policy_resp_policies.go
- model_list_available_zones_request.go
- model_list_available_zones_resp_available_zones.go
- model_list_available_zones_response.go
- model_list_brokers_request.go
- model_list_brokers_resp_brokers.go
- model_list_brokers_response.go
- model_list_consume_group_access_policy_request.go
- model_list_consume_group_access_policy_response.go
- model_list_consumer_group_of_topic_request.go
- model_list_consumer_group_of_topic_response.go
- model_list_instance_consumer_groups_request.go
- model_list_instance_consumer_groups_response.go
- model_list_instances_request.go
- model_list_instances_response.go
- model_list_message_trace_request.go
- model_list_message_trace_resp_trace.go
- model_list_message_trace_response.go
- model_list_messages_request.go
- model_list_messages_response.go
- model_list_rocket_instance_topics_request.go
- model_list_rocket_instance_topics_response.go
- model_list_rocket_mq_migration_task_request.go
- model_list_rocket_mq_migration_task_response.go
- model_list_topic_access_policy_request.go
- model_list_topic_access_policy_response.go
- model_list_user_request.go
- model_list_user_response.go
- model_message.go
- model_message_property_list.go
- model_metadata_delete_req.go
- model_metadata_task.go
- model_migration_rabbit_binding_metadata.go
- model_migration_rabbit_exchange_metadata.go
- model_migration_rabbit_queue_metadata.go
- model_migration_rabbit_vhost_metadata.go
- model_migration_rocket_mq_subscription_group.go
- model_migration_rocket_mq_topic_config.go
- model_modify_config_req.go
- model_queue.go
- model_resend_req.go
- model_reset_consume_offset_req.go
- model_reset_consume_offset_request.go
- model_reset_consume_offset_resp_queues.go
- model_reset_consume_offset_response.go
- model_resize_engine_instance_req.go
- model_resize_instance_request.go
- model_resize_instance_response.go
- model_rocket_mq_config_req.go
- model_rocket_mq_config_resp.go
- model_rocket_mq_extend_product_info_entity.go
- model_rocket_mq_extend_product_ios_entity.go
- model_rocket_mq_extend_product_properties_entity.go
- model_rocket_mq_product_support_features_entity.go
- model_send_dlq_message_request.go
- model_send_dlq_message_response.go
- model_show_consumer_connections_request.go
- model_show_consumer_connections_response.go
- model_show_consumer_list_or_details_request.go
- model_show_consumer_list_or_details_response.go
- model_show_engine_instance_extend_product_info_request.go
- model_show_engine_instance_extend_product_info_response.go
- model_show_group_request.go
- model_show_group_response.go
- model_show_instance_request.go
- model_show_instance_resp.go
- model_show_instance_response.go
- model_show_one_topic_request.go
- model_show_one_topic_response.go
- model_show_rocket_mq_configs_request.go
- model_show_rocket_mq_configs_response.go
- model_show_rocketmq_project_tags_request.go
- model_show_rocketmq_project_tags_response.go
- model_show_rocketmq_tags_request.go
- model_show_rocketmq_tags_response.go
- model_show_topic_status_request.go
- model_show_topic_status_resp_brokers.go
- model_show_topic_status_resp_queues.go
- model_show_topic_status_response.go
- model_show_user_request.go
- model_show_user_response.go
- model_subscription.go
- model_tag_entity.go
- model_tag_multy_value_entity.go
- model_topic.go
- model_topic_brokers.go
- model_update_consumer_group.go
- model_update_consumer_group_request.go
- model_update_consumer_group_response.go
- model_update_instance_req.go
- model_update_instance_request.go
- model_update_instance_response.go
- model_update_rocket_mq_configs_request.go
- model_update_rocket_mq_configs_response.go
- model_update_topic_req.go
- model_update_topic_request.go
- model_update_topic_response.go
- model_update_user_request.go
- model_update_user_response.go
- model_user.go
- model_user_group_perms.go
- model_user_topic_perms.go
- model_validate_consumed_message_request.go
- model_validate_consumed_message_response.go