Documentation ¶
Index ¶
- 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 ConsumerGroup
- type CreateConsumerGroupOrBatchDeleteConsumerGroupReq
- type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest
- type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse
- type CreateGroupResp
- type CreatePostPaidInstanceReq
- type CreatePostPaidInstanceReqEngine
- type CreatePostPaidInstanceReqEngineEnum
- type CreatePostPaidInstanceReqEngineVersion
- type CreatePostPaidInstanceReqEngineVersionEnum
- type CreatePostPaidInstanceReqProductId
- type CreatePostPaidInstanceReqProductIdEnum
- type CreatePostPaidInstanceReqStorageSpecCode
- type CreatePostPaidInstanceReqStorageSpecCodeEnum
- type CreatePostPaidInstanceRequest
- type CreatePostPaidInstanceResponse
- type CreateTopicOrBatchDeleteTopicReq
- type CreateTopicOrBatchDeleteTopicReqPermission
- type CreateTopicOrBatchDeleteTopicReqPermissionEnum
- type CreateTopicOrBatchDeleteTopicRequest
- type CreateTopicOrBatchDeleteTopicResponse
- type CreateTopicReq
- type CreateTopicReqPermission
- type CreateTopicReqPermissionEnum
- type CreateTopicResp
- type CreateUserRequest
- type CreateUserResponse
- type CreateUserResponseDefaultGroupPerm
- type CreateUserResponseDefaultGroupPermEnum
- type CreateUserResponseDefaultTopicPerm
- type CreateUserResponseDefaultTopicPermEnum
- type DeleteConsumerGroupRequest
- type DeleteConsumerGroupResponse
- type DeleteInstanceRequest
- type DeleteInstanceResponse
- 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 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 ListTopicAccessPolicyRequest
- type ListTopicAccessPolicyResponse
- type ListUserRequest
- type ListUserResponse
- type Message
- type MessagePropertyList
- type ResetConsumeOffsetReq
- type ResetConsumeOffsetRequest
- type ResetConsumeOffsetRequestEngine
- type ResetConsumeOffsetRequestEngineEnum
- type ResetConsumeOffsetRespQueues
- type ResetConsumeOffsetResponse
- type ShowConsumerListOrDetailsRequest
- type ShowConsumerListOrDetailsResponse
- type ShowGroupRequest
- type ShowGroupResponse
- type ShowInstanceRequest
- type ShowInstanceResp
- type ShowInstanceRespType
- type ShowInstanceRespTypeEnum
- type ShowInstanceResponse
- type ShowInstanceResponseType
- type ShowInstanceResponseTypeEnum
- type ShowOneTopicRequest
- type ShowOneTopicResponse
- type ShowOneTopicResponsePermission
- type ShowOneTopicResponsePermissionEnum
- type ShowTopicStatusRequest
- type ShowTopicStatusRespBrokers
- type ShowTopicStatusRespQueues
- type ShowTopicStatusResponse
- type ShowUserRequest
- type ShowUserResponse
- type ShowUserResponseDefaultGroupPerm
- type ShowUserResponseDefaultGroupPermEnum
- type ShowUserResponseDefaultTopicPerm
- type ShowUserResponseDefaultTopicPermEnum
- type TagEntity
- type TopicBrokers
- type UpdateConsumerGroupRequest
- type UpdateConsumerGroupResponse
- type UpdateInstanceReq
- type UpdateInstanceRequest
- type UpdateInstanceResponse
- 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BatchDeleteConsumerGroupReq ¶
type BatchDeleteConsumerGroupReq struct { // 待删除的消费组列表。 Groups *[]string `json:"groups,omitempty" xml:"groups"` }
func (BatchDeleteConsumerGroupReq) String ¶
func (o BatchDeleteConsumerGroupReq) String() string
type BatchDeleteConsumerGroupResp ¶
type BatchDeleteConsumerGroupResp struct { // 删除消费组的任务ID JobId *string `json:"job_id,omitempty" xml:"job_id"` }
func (BatchDeleteConsumerGroupResp) String ¶
func (o BatchDeleteConsumerGroupResp) String() string
type BatchDeleteInstanceReq ¶
type BatchDeleteInstanceReq struct { // 实例的ID列表。 Instances *[]string `json:"instances,omitempty" xml:"instances"` // 对实例的操作:delete Action BatchDeleteInstanceReqAction `json:"action" xml:"action"` // 参数值为RocketMQ,表示删除租户所有创建失败的RocketMQ实例。 AllFailure *BatchDeleteInstanceReqAllFailure `json:"all_failure,omitempty" xml:"all_failure"` }
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 { TRUE BatchDeleteInstanceReqAllFailure FALSE BatchDeleteInstanceReqAllFailure }
func GetBatchDeleteInstanceReqAllFailureEnum ¶
func GetBatchDeleteInstanceReqAllFailureEnum() BatchDeleteInstanceReqAllFailureEnum
type BatchDeleteInstanceRespResults ¶
type BatchDeleteInstanceRespResults struct { // 操作结果。 Result *BatchDeleteInstanceRespResultsResult `json:"result,omitempty" xml:"result"` // 实例ID。 Instance *string `json:"instance,omitempty" xml:"instance"` }
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" xml:"body"`
}
Request Object
func (BatchDeleteInstancesRequest) String ¶
func (o BatchDeleteInstancesRequest) String() string
type BatchDeleteInstancesResponse ¶
type BatchDeleteInstancesResponse struct { // 修改实例的结果。 Results *[]BatchDeleteInstanceRespResults `json:"results,omitempty" xml:"results"` HttpStatusCode int `json:"-"` }
Response Object
func (BatchDeleteInstancesResponse) String ¶
func (o BatchDeleteInstancesResponse) String() string
type BatchDeleteTopicReq ¶
type BatchDeleteTopicReq struct { // 主题列表,当批量删除主题时使用。 Topics *[]string `json:"topics,omitempty" xml:"topics"` }
func (BatchDeleteTopicReq) String ¶
func (o BatchDeleteTopicReq) String() string
type BatchDeleteTopicResp ¶
type BatchDeleteTopicResp struct { // 删除主题任务ID。 JobId *string `json:"job_id,omitempty" xml:"job_id"` }
func (BatchDeleteTopicResp) String ¶
func (o BatchDeleteTopicResp) String() string
type BatchUpdateConsumerGroupReq ¶
type BatchUpdateConsumerGroupReq struct { // 消费组列表,当批量删除消费组时使用。 Groups *[]ConsumerGroup `json:"groups,omitempty" xml:"groups"` }
func (BatchUpdateConsumerGroupReq) String ¶
func (o BatchUpdateConsumerGroupReq) String() string
type BatchUpdateConsumerGroupRequest ¶
type BatchUpdateConsumerGroupRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` Body *BatchUpdateConsumerGroupReq `json:"body,omitempty" xml:"body"` }
Request Object
func (BatchUpdateConsumerGroupRequest) String ¶
func (o BatchUpdateConsumerGroupRequest) String() string
type BatchUpdateConsumerGroupResponse ¶
type BatchUpdateConsumerGroupResponse struct { // 任务ID。 JobId *string `json:"job_id,omitempty" xml:"job_id"` HttpStatusCode int `json:"-"` }
Response Object
func (BatchUpdateConsumerGroupResponse) String ¶
func (o BatchUpdateConsumerGroupResponse) String() string
type ConsumerGroup ¶
type ConsumerGroup struct { // 是否启用。 Enabled *bool `json:"enabled,omitempty" xml:"enabled"` // 是否广播。 Broadcast *bool `json:"broadcast,omitempty" xml:"broadcast"` // 关联的代理列表。 Brokers *[]string `json:"brokers,omitempty" xml:"brokers"` // 消费组名称。 Name *string `json:"name,omitempty" xml:"name"` // 最大重试次数。 RetryMaxTime float32 `json:"retry_max_time,omitempty" xml:"retry_max_time"` // 是否重头消费。 FromBeginning *bool `json:"from_beginning,omitempty" xml:"from_beginning"` }
func (ConsumerGroup) String ¶
func (o ConsumerGroup) String() string
type CreateConsumerGroupOrBatchDeleteConsumerGroupReq ¶
type CreateConsumerGroupOrBatchDeleteConsumerGroupReq struct { // 待删除的消费组列表。 Groups *[]string `json:"groups,omitempty" xml:"groups"` // 是否启用。 Enabled *bool `json:"enabled,omitempty" xml:"enabled"` // 是否广播。 Broadcast *bool `json:"broadcast,omitempty" xml:"broadcast"` // 关联的代理列表。 Brokers *[]string `json:"brokers,omitempty" xml:"brokers"` // 消费组名称。 Name *string `json:"name,omitempty" xml:"name"` // 最大重试次数。 RetryMaxTime float32 `json:"retry_max_time,omitempty" xml:"retry_max_time"` // 是否重头消费。 FromBeginning *bool `json:"from_beginning,omitempty" xml:"from_beginning"` }
func (CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String ¶
func (o CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String() string
type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest ¶
type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 批量删除topic时使用,不配置则为创建接口。 Action *string `json:"action,omitempty" xml:"action"` Body *CreateConsumerGroupOrBatchDeleteConsumerGroupReq `json:"body,omitempty" xml:"body"` }
Request Object
func (CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) String ¶
func (o CreateConsumerGroupOrBatchDeleteConsumerGroupRequest) String() string
type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse ¶
type CreateConsumerGroupOrBatchDeleteConsumerGroupResponse struct { // 删除消费组的任务ID JobId *string `json:"job_id,omitempty" xml:"job_id"` // 创建成功的消费组名称。 Name *string `json:"name,omitempty" xml:"name"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateConsumerGroupOrBatchDeleteConsumerGroupResponse) String ¶
func (o CreateConsumerGroupOrBatchDeleteConsumerGroupResponse) String() string
type CreateGroupResp ¶
type CreateGroupResp struct { // 创建成功的消费组名称。 Name *string `json:"name,omitempty" xml:"name"` }
func (CreateGroupResp) String ¶
func (o CreateGroupResp) String() string
type CreatePostPaidInstanceReq ¶
type CreatePostPaidInstanceReq struct { // 实例名称。 由英文字符开头,只能由英文字母、数字、中划线、下划线组成,长度为4~64的字符。 Name string `json:"name" xml:"name"` // 实例的描述信息。 长度不超过1024的字符串。 > \\与\"在json报文中属于特殊字符,如果参数值中需要显示\\或者\"字符,请在字符前增加转义字符\\,比如\\\\或者\\\"。 Description *string `json:"description,omitempty" xml:"description"` // 消息引擎。取值填写为:reliability。 Engine CreatePostPaidInstanceReqEngine `json:"engine" xml:"engine"` // 消息引擎的版本。取值填写为:4.8.0。 EngineVersion CreatePostPaidInstanceReqEngineVersion `json:"engine_version" xml:"engine_version"` // 存储空间。 StorageSpace int32 `json:"storage_space" xml:"storage_space"` // 虚拟私有云ID。 获取方法如下: - 登录虚拟私有云服务的控制台界面,在虚拟私有云的详情页面查找VPC ID。 VpcId string `json:"vpc_id" xml:"vpc_id"` // 子网信息。 获取方法如下: - 登录虚拟私有云服务的控制台界面,单击VPC下的子网,进入子网详情页面,查找网络ID。 SubnetId string `json:"subnet_id" xml:"subnet_id"` // 指定实例所属的安全组。 获取方法如下: - 登录虚拟私有云服务的控制台界面,在安全组的详情页面查找安全组ID。 SecurityGroupId string `json:"security_group_id" xml:"security_group_id"` // 创建节点到指定且有资源的可用区ID。该参数不能为空数组或者数组的值为空, 请注意查看该可用区是否有资源。 创建RocketMQ实例,支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时,用逗号分隔开。 AvailableZones []string `json:"available_zones" xml:"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" xml:"product_id"` // 是否打开SSL加密访问。 - true:打开SSL加密访问。 - false:不打开SSL加密访问。 SslEnable *bool `json:"ssl_enable,omitempty" xml:"ssl_enable"` // 存储IO规格。 - dms.physical.storage.high.v2: 高IO类型磁盘 - dms.physical.storage.ultra.v2: 超高IO类型磁盘 StorageSpecCode CreatePostPaidInstanceReqStorageSpecCode `json:"storage_spec_code" xml:"storage_spec_code"` // 是否支持IPV6。 - true: 支持 - false:不支持 Ipv6Enable *bool `json:"ipv6_enable,omitempty" xml:"ipv6_enable"` // 是否开启公网访问功能。默认不开启公网。 - true:开启 - false:不开启 EnablePublicip *bool `json:"enable_publicip,omitempty" xml:"enable_publicip"` // 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 PublicipId *string `json:"publicip_id,omitempty" xml:"publicip_id"` // 代理个数 BrokerNum *int32 `json:"broker_num,omitempty" xml:"broker_num"` }
创建实例请求体。
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" xml:"body"`
}
Request Object
func (CreatePostPaidInstanceRequest) String ¶
func (o CreatePostPaidInstanceRequest) String() string
type CreatePostPaidInstanceResponse ¶
type CreatePostPaidInstanceResponse struct { // 实例ID。 InstanceId *string `json:"instance_id,omitempty" xml:"instance_id"` HttpStatusCode int `json:"-"` }
Response Object
func (CreatePostPaidInstanceResponse) String ¶
func (o CreatePostPaidInstanceResponse) String() string
type CreateTopicOrBatchDeleteTopicReq ¶
type CreateTopicOrBatchDeleteTopicReq struct { // 主题名称。 Name *string `json:"name,omitempty" xml:"name"` // 关联的代理。 Brokers *[]string `json:"brokers,omitempty" xml:"brokers"` // 队列数。 QueueNum float32 `json:"queue_num,omitempty" xml:"queue_num"` // 权限。 Permission *CreateTopicOrBatchDeleteTopicReqPermission `json:"permission,omitempty" xml:"permission"` // 主题列表,当批量删除主题时使用。 Topics *[]string `json:"topics,omitempty" xml:"topics"` }
func (CreateTopicOrBatchDeleteTopicReq) String ¶
func (o CreateTopicOrBatchDeleteTopicReq) String() string
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" xml:"instance_id"` // 批量删除topic时使用,不配置则为创建接口。 Action *string `json:"action,omitempty" xml:"action"` Body *CreateTopicOrBatchDeleteTopicReq `json:"body,omitempty" xml:"body"` }
Request Object
func (CreateTopicOrBatchDeleteTopicRequest) String ¶
func (o CreateTopicOrBatchDeleteTopicRequest) String() string
type CreateTopicOrBatchDeleteTopicResponse ¶
type CreateTopicOrBatchDeleteTopicResponse struct { // 主题名称。 Id *string `json:"id,omitempty" xml:"id"` // 删除主题任务ID。 JobId *string `json:"job_id,omitempty" xml:"job_id"` HttpStatusCode int `json:"-"` }
Response Object
func (CreateTopicOrBatchDeleteTopicResponse) String ¶
func (o CreateTopicOrBatchDeleteTopicResponse) String() string
type CreateTopicReq ¶
type CreateTopicReq struct { // 主题名称。 Name *string `json:"name,omitempty" xml:"name"` // 关联的代理。 Brokers *[]string `json:"brokers,omitempty" xml:"brokers"` // 队列数。 QueueNum float32 `json:"queue_num,omitempty" xml:"queue_num"` // 权限。 Permission *CreateTopicReqPermission `json:"permission,omitempty" xml:"permission"` }
func (CreateTopicReq) String ¶
func (o CreateTopicReq) String() string
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" xml:"id"` }
func (CreateTopicResp) String ¶
func (o CreateTopicResp) String() string
type CreateUserRequest ¶
type CreateUserRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` Body *User `json:"body,omitempty" xml:"body"` }
Request Object
func (CreateUserRequest) String ¶
func (o CreateUserRequest) String() string
type CreateUserResponse ¶
type CreateUserResponse struct { // 用户名。 AccessKey *string `json:"access_key,omitempty" xml:"access_key"` // 密钥。 SecretKey *string `json:"secret_key,omitempty" xml:"secret_key"` // IP白名单。 WhiteRemoteAddress *string `json:"white_remote_address,omitempty" xml:"white_remote_address"` // 是否为管理员。 Admin *bool `json:"admin,omitempty" xml:"admin"` // 默认的主题权限。 DefaultTopicPerm *CreateUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty" xml:"default_topic_perm"` // 默认的消费组权限。 DefaultGroupPerm *CreateUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty" xml:"default_group_perm"` // 特殊的主题权限。 TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty" xml:"topic_perms"` // 特殊的消费组权限。 GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty" xml:"group_perms"` HttpStatusCode int `json:"-"` }
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 { PUB CreateUserResponseDefaultGroupPerm SUB CreateUserResponseDefaultGroupPerm PUB_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 DeleteConsumerGroupRequest ¶
type DeleteConsumerGroupRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消费组名称。 Group string `json:"group" xml:"group"` }
Request Object
func (DeleteConsumerGroupRequest) String ¶
func (o DeleteConsumerGroupRequest) String() string
type DeleteConsumerGroupResponse ¶
type DeleteConsumerGroupResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteConsumerGroupResponse) String ¶
func (o DeleteConsumerGroupResponse) String() string
type DeleteInstanceRequest ¶
type DeleteInstanceRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` }
Request Object
func (DeleteInstanceRequest) String ¶
func (o DeleteInstanceRequest) String() string
type DeleteInstanceResponse ¶
type DeleteInstanceResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteInstanceResponse) String ¶
func (o DeleteInstanceResponse) String() string
type DeleteTopicRequest ¶
type DeleteTopicRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 主题名称。 Topic string `json:"topic" xml:"topic"` }
Request Object
func (DeleteTopicRequest) String ¶
func (o DeleteTopicRequest) String() string
type DeleteTopicResponse ¶
type DeleteTopicResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (DeleteTopicResponse) String ¶
func (o DeleteTopicResponse) String() string
type DeleteUserRequest ¶
type DeleteUserRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 用户名。 UserName string `json:"user_name" xml:"user_name"` }
Request Object
func (DeleteUserRequest) String ¶
func (o DeleteUserRequest) String() string
type DeleteUserResponse ¶
type DeleteUserResponse struct { // 信息。 Message *string `json:"message,omitempty" xml:"message"` HttpStatusCode int `json:"-"` }
Response Object
func (DeleteUserResponse) String ¶
func (o DeleteUserResponse) String() string
type ExportDlqMessageReq ¶
type ExportDlqMessageReq struct { // 主题名称。 Topic *string `json:"topic,omitempty" xml:"topic"` // 消息ID列表。 MsgIdList *[]string `json:"msg_id_list,omitempty" xml:"msg_id_list"` // 唯一Key列表。 UniqKeyList *[]string `json:"uniq_key_list,omitempty" xml:"uniq_key_list"` }
func (ExportDlqMessageReq) String ¶
func (o ExportDlqMessageReq) String() string
type ExportDlqMessageRequest ¶
type ExportDlqMessageRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` Body *ExportDlqMessageReq `json:"body,omitempty" xml:"body"` }
Request Object
func (ExportDlqMessageRequest) String ¶
func (o ExportDlqMessageRequest) String() string
type ExportDlqMessageResponse ¶
type ExportDlqMessageResponse struct { Body *[]Message `json:"body,omitempty" xml:"body"` HttpStatusCode int `json:"-"` }
Response Object
func (ExportDlqMessageResponse) String ¶
func (o ExportDlqMessageResponse) String() string
type ListAccessPolicyRespPolicies ¶
type ListAccessPolicyRespPolicies struct { // 秘钥。 AccessKey *string `json:"access_key,omitempty" xml:"access_key"` // IP白名单。 WhiteRemoteAddress *string `json:"white_remote_address,omitempty" xml:"white_remote_address"` // 是否为管理员。 Admin *bool `json:"admin,omitempty" xml:"admin"` // 权限。 Perm *string `json:"perm,omitempty" xml:"perm"` }
func (ListAccessPolicyRespPolicies) String ¶
func (o ListAccessPolicyRespPolicies) String() string
type ListAvailableZonesRequest ¶
type ListAvailableZonesRequest struct { }
Request Object
func (ListAvailableZonesRequest) String ¶
func (o ListAvailableZonesRequest) String() string
type ListAvailableZonesRespAvailableZones ¶
type ListAvailableZonesRespAvailableZones struct { // 是否售罄。 SoldOut *bool `json:"soldOut,omitempty" xml:"soldOut"` // 可用区ID。 Id *string `json:"id,omitempty" xml:"id"` // 可用区编码。 Code *string `json:"code,omitempty" xml:"code"` // 可用区名称。 Name *string `json:"name,omitempty" xml:"name"` // 可用区端口号。 Port *string `json:"port,omitempty" xml:"port"` // 分区上是否还有可用资源。 ResourceAvailability *string `json:"resource_availability,omitempty" xml:"resource_availability"` // 是否为默认可用区。 DefaultAz *bool `json:"default_az,omitempty" xml:"default_az"` // 剩余时间。 RemainTime *int64 `json:"remain_time,omitempty" xml:"remain_time"` // 是否支持IPv6。 Ipv6Enable *bool `json:"ipv6_enable,omitempty" xml:"ipv6_enable"` }
func (ListAvailableZonesRespAvailableZones) String ¶
func (o ListAvailableZonesRespAvailableZones) String() string
type ListAvailableZonesResponse ¶
type ListAvailableZonesResponse struct { // 区域ID。 RegionId *string `json:"region_id,omitempty" xml:"region_id"` // 可用区数组。 AvailableZones *[]ListAvailableZonesRespAvailableZones `json:"available_zones,omitempty" xml:"available_zones"` HttpStatusCode int `json:"-"` }
Response Object
func (ListAvailableZonesResponse) String ¶
func (o ListAvailableZonesResponse) String() string
type ListBrokersRequest ¶
type ListBrokersRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` }
Request Object
func (ListBrokersRequest) String ¶
func (o ListBrokersRequest) String() string
type ListBrokersRespBrokers ¶
type ListBrokersRespBrokers struct { // 全部代理ID。 Ids *[]float32 `json:"ids,omitempty" xml:"ids"` // 节点名称。 BrokerName *string `json:"broker_name,omitempty" xml:"broker_name"` }
func (ListBrokersRespBrokers) String ¶
func (o ListBrokersRespBrokers) String() string
type ListBrokersResponse ¶
type ListBrokersResponse struct { // 代理列表。 Brokers *[]ListBrokersRespBrokers `json:"brokers,omitempty" xml:"brokers"` HttpStatusCode int `json:"-"` }
Response Object
func (ListBrokersResponse) String ¶
func (o ListBrokersResponse) String() string
type ListConsumeGroupAccessPolicyRequest ¶
type ListConsumeGroupAccessPolicyRequest struct { // 消息引擎。 Engine ListConsumeGroupAccessPolicyRequestEngine `json:"engine" xml:"engine"` // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消费组。 GroupId string `json:"group_id" xml:"group_id"` // 偏移量,表示从此偏移量开始查询, offset大于等于0。 Offset *string `json:"offset,omitempty" xml:"offset"` // 查询数量。 Limit *string `json:"limit,omitempty" xml:"limit"` }
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" xml:"policies"` // 总用户个数。 Total float32 `json:"total,omitempty" xml:"total"` // 主题或消费组名称。 Name *string `json:"name,omitempty" xml:"name"` HttpStatusCode int `json:"-"` }
Response Object
func (ListConsumeGroupAccessPolicyResponse) String ¶
func (o ListConsumeGroupAccessPolicyResponse) String() string
type ListConsumerGroupOfTopicRequest ¶
type ListConsumerGroupOfTopicRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 主题名称。 Topic string `json:"topic" xml:"topic"` }
Request Object
func (ListConsumerGroupOfTopicRequest) String ¶
func (o ListConsumerGroupOfTopicRequest) String() string
type ListConsumerGroupOfTopicResponse ¶
type ListConsumerGroupOfTopicResponse struct { // 消费组列表。 Groups *[]string `json:"groups,omitempty" xml:"groups"` HttpStatusCode int `json:"-"` }
Response Object
func (ListConsumerGroupOfTopicResponse) String ¶
func (o ListConsumerGroupOfTopicResponse) String() string
type ListInstanceConsumerGroupsRequest ¶
type ListInstanceConsumerGroupsRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消费组名称。 Group *string `json:"group,omitempty" xml:"group"` // 查询数量。 Limit *int32 `json:"limit,omitempty" xml:"limit"` // 偏移量,表示从此偏移量开始查询, offset大于等于0。 Offset *int32 `json:"offset,omitempty" xml:"offset"` }
Request Object
func (ListInstanceConsumerGroupsRequest) String ¶
func (o ListInstanceConsumerGroupsRequest) String() string
type ListInstanceConsumerGroupsResponse ¶
type ListInstanceConsumerGroupsResponse struct { // 消费组总数。 Total float32 `json:"total,omitempty" xml:"total"` // 消费组列表。 Groups *[]ConsumerGroup `json:"groups,omitempty" xml:"groups"` // 最大可创建消费组数量。 Max float32 `json:"max,omitempty" xml:"max"` // 剩余可创建消费组数量。 Remaining float32 `json:"remaining,omitempty" xml:"remaining"` // 下个分页的offset。 NextOffset float32 `json:"next_offset,omitempty" xml:"next_offset"` // 上个分页的offset。 PreviousOffset float32 `json:"previous_offset,omitempty" xml:"previous_offset"` HttpStatusCode int `json:"-"` }
Response Object
func (ListInstanceConsumerGroupsResponse) String ¶
func (o ListInstanceConsumerGroupsResponse) String() string
type ListInstancesRequest ¶
type ListInstancesRequest struct { // 消息引擎:reliability。 Engine *string `json:"engine,omitempty" xml:"engine"` // 实例名称。 Name *string `json:"name,omitempty" xml:"name"` // 实例ID。 InstanceId *string `json:"instance_id,omitempty" xml:"instance_id"` // 实例状态。 Status *ListInstancesRequestStatus `json:"status,omitempty" xml:"status"` // 是否返回创建失败的实例数。 当参数值为“true”时,返回创建失败的实例数。参数值为“false”或者其他值,不返回创建失败的实例数。 IncludeFailure *ListInstancesRequestIncludeFailure `json:"include_failure,omitempty" xml:"include_failure"` // 是否按照实例名称进行精确匹配查询。 默认为“false”,表示模糊匹配实例名称查询。若参数值为“true”表示按照实例名称进行精确匹配查询。 ExactMatchName *ListInstancesRequestExactMatchName `json:"exact_match_name,omitempty" xml:"exact_match_name"` // 企业项目ID。 EnterpriseProjectId *string `json:"enterprise_project_id,omitempty" xml:"enterprise_project_id"` }
Request Object
func (ListInstancesRequest) String ¶
func (o ListInstancesRequest) String() string
type ListInstancesRequestExactMatchName ¶
type ListInstancesRequestExactMatchName struct {
// contains filtered or unexported fields
}
func (ListInstancesRequestExactMatchName) MarshalJSON ¶
func (c ListInstancesRequestExactMatchName) MarshalJSON() ([]byte, error)
func (*ListInstancesRequestExactMatchName) UnmarshalJSON ¶
func (c *ListInstancesRequestExactMatchName) UnmarshalJSON(b []byte) error
func (ListInstancesRequestExactMatchName) Value ¶ added in v0.0.90
func (c ListInstancesRequestExactMatchName) Value() string
type ListInstancesRequestExactMatchNameEnum ¶
type ListInstancesRequestExactMatchNameEnum struct { TRUE ListInstancesRequestExactMatchName FALSE ListInstancesRequestExactMatchName }
func GetListInstancesRequestExactMatchNameEnum ¶
func GetListInstancesRequestExactMatchNameEnum() ListInstancesRequestExactMatchNameEnum
type ListInstancesRequestIncludeFailure ¶
type ListInstancesRequestIncludeFailure struct {
// contains filtered or unexported fields
}
func (ListInstancesRequestIncludeFailure) MarshalJSON ¶
func (c ListInstancesRequestIncludeFailure) MarshalJSON() ([]byte, error)
func (*ListInstancesRequestIncludeFailure) UnmarshalJSON ¶
func (c *ListInstancesRequestIncludeFailure) UnmarshalJSON(b []byte) error
func (ListInstancesRequestIncludeFailure) Value ¶ added in v0.0.90
func (c ListInstancesRequestIncludeFailure) Value() string
type ListInstancesRequestIncludeFailureEnum ¶
type ListInstancesRequestIncludeFailureEnum struct { TRUE ListInstancesRequestIncludeFailure FALSE ListInstancesRequestIncludeFailure }
func GetListInstancesRequestIncludeFailureEnum ¶
func GetListInstancesRequestIncludeFailureEnum() ListInstancesRequestIncludeFailureEnum
type ListInstancesRequestStatus ¶
type ListInstancesRequestStatus struct {
// contains filtered or unexported fields
}
func (ListInstancesRequestStatus) MarshalJSON ¶
func (c ListInstancesRequestStatus) MarshalJSON() ([]byte, error)
func (*ListInstancesRequestStatus) UnmarshalJSON ¶
func (c *ListInstancesRequestStatus) UnmarshalJSON(b []byte) error
func (ListInstancesRequestStatus) Value ¶ added in v0.0.90
func (c ListInstancesRequestStatus) Value() string
type ListInstancesRequestStatusEnum ¶
type ListInstancesRequestStatusEnum struct { CREATING ListInstancesRequestStatus RUNNING ListInstancesRequestStatus FAULTY ListInstancesRequestStatus RESTARTING ListInstancesRequestStatus RESIZING ListInstancesRequestStatus RESIZING_FAILED ListInstancesRequestStatus FROZEN ListInstancesRequestStatus }
func GetListInstancesRequestStatusEnum ¶
func GetListInstancesRequestStatusEnum() ListInstancesRequestStatusEnum
type ListInstancesResponse ¶
type ListInstancesResponse struct { // 实例列表。 Instances *[]ShowInstanceResp `json:"instances,omitempty" xml:"instances"` // 实例数量。 InstanceNum *int32 `json:"instance_num,omitempty" xml:"instance_num"` HttpStatusCode int `json:"-"` }
Response Object
func (ListInstancesResponse) String ¶
func (o ListInstancesResponse) String() string
type ListMessageTraceRequest ¶
type ListMessageTraceRequest struct { // 消息引擎。 Engine ListMessageTraceRequestEngine `json:"engine" xml:"engine"` // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消息ID。 MsgId *string `json:"msg_id,omitempty" xml:"msg_id"` }
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" xml:"success"` // 轨迹类型 TraceType *ListMessageTraceRespTraceTraceType `json:"trace_type,omitempty" xml:"trace_type"` // 时间。 Timestamp float32 `json:"timestamp,omitempty" xml:"timestamp"` // 生产组或消费组。 GroupName *string `json:"group_name,omitempty" xml:"group_name"` // 耗时。 CostTime float32 `json:"cost_time,omitempty" xml:"cost_time"` // 请求ID。 RequestId *string `json:"request_id,omitempty" xml:"request_id"` // 消费状态。 ConsumeStatus float32 `json:"consume_status,omitempty" xml:"consume_status"` // 主题名称。 Topic *string `json:"topic,omitempty" xml:"topic"` // 消息ID。 MsgId *string `json:"msg_id,omitempty" xml:"msg_id"` // offset消息ID。 OffsetMsgId *string `json:"offset_msg_id,omitempty" xml:"offset_msg_id"` // 消息的标签。 Tags *string `json:"tags,omitempty" xml:"tags"` // 消息的keys。 Keys *string `json:"keys,omitempty" xml:"keys"` // 存储消息的主机IP。 StoreHost *string `json:"store_host,omitempty" xml:"store_host"` // 产生消息的主机IP。 ClientHost *string `json:"client_host,omitempty" xml:"client_host"` // 重试次数。 RetryTimes *string `json:"retry_times,omitempty" xml:"retry_times"` // 消息体长度。 BodyLength float32 `json:"body_length,omitempty" xml:"body_length"` // 消息类型。 MsgType *ListMessageTraceRespTraceMsgType `json:"msg_type,omitempty" xml:"msg_type"` // 事务状态。 TransactionState *ListMessageTraceRespTraceTransactionState `json:"transaction_state,omitempty" xml:"transaction_state"` // 事务ID。 TransactionId *string `json:"transaction_id,omitempty" xml:"transaction_id"` // 是否为事务回查的响应。 FromTransactionCheck *bool `json:"from_transaction_check,omitempty" xml:"from_transaction_check"` }
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" xml:"trace"` HttpStatusCode int `json:"-"` }
Response Object
func (ListMessageTraceResponse) String ¶
func (o ListMessageTraceResponse) String() string
type ListMessagesRequest ¶
type ListMessagesRequest struct { // 消息引擎。 Engine ListMessagesRequestEngine `json:"engine" xml:"engine"` // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 主题名称。 Topic string `json:"topic" xml:"topic"` // 查询数量。 Limit *string `json:"limit,omitempty" xml:"limit"` // 偏移量,表示从此偏移量开始查询, offset大于等于0。 Offset *string `json:"offset,omitempty" xml:"offset"` // 开始时间。 StartTime *string `json:"start_time,omitempty" xml:"start_time"` // 结束时间。 EndTime *string `json:"end_time,omitempty" xml:"end_time"` // 消息ID。 MsgId *string `json:"msg_id,omitempty" xml:"msg_id"` }
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" xml:"messages"` // 消息总数。 Total float32 `json:"total,omitempty" xml:"total"` HttpStatusCode int `json:"-"` }
Response Object
func (ListMessagesResponse) String ¶
func (o ListMessagesResponse) String() string
type ListTopicAccessPolicyRequest ¶
type ListTopicAccessPolicyRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 主题名称。 Topic string `json:"topic" xml:"topic"` // 偏移量,表示从此偏移量开始查询, offset大于等于0。 Offset *string `json:"offset,omitempty" xml:"offset"` // 查询数量。 Limit *string `json:"limit,omitempty" xml:"limit"` }
Request Object
func (ListTopicAccessPolicyRequest) String ¶
func (o ListTopicAccessPolicyRequest) String() string
type ListTopicAccessPolicyResponse ¶
type ListTopicAccessPolicyResponse struct { // 用户列表。 Policies *[]ListAccessPolicyRespPolicies `json:"policies,omitempty" xml:"policies"` // 总用户个数。 Total float32 `json:"total,omitempty" xml:"total"` // 主题或消费组名称。 Name *string `json:"name,omitempty" xml:"name"` HttpStatusCode int `json:"-"` }
Response Object
func (ListTopicAccessPolicyResponse) String ¶
func (o ListTopicAccessPolicyResponse) String() string
type ListUserRequest ¶
type ListUserRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 偏移量,表示从此偏移量开始查询, offset大于等于0。 Offset *string `json:"offset,omitempty" xml:"offset"` // 查询数量。 Limit *string `json:"limit,omitempty" xml:"limit"` }
Request Object
func (ListUserRequest) String ¶
func (o ListUserRequest) String() string
type ListUserResponse ¶
type ListUserResponse struct { // 用户列表。 Users *[]User `json:"users,omitempty" xml:"users"` // 总用户个数。 Total float32 `json:"total,omitempty" xml:"total"` HttpStatusCode int `json:"-"` }
Response Object
func (ListUserResponse) String ¶
func (o ListUserResponse) String() string
type Message ¶
type Message struct { // 消息ID。 MsgId *string `json:"msg_id,omitempty" xml:"msg_id"` // 实例ID。 InstanceId *string `json:"instance_id,omitempty" xml:"instance_id"` // 主题名称。 Topic *string `json:"topic,omitempty" xml:"topic"` // 存储消息的时间。 StoreTimestamp float32 `json:"store_timestamp,omitempty" xml:"store_timestamp"` // 产生消息的时间。 BornTimestamp float32 `json:"born_timestamp,omitempty" xml:"born_timestamp"` // 重试次数。 ReconsumeTimes *string `json:"reconsume_times,omitempty" xml:"reconsume_times"` // 消息体。 Body *string `json:"body,omitempty" xml:"body"` // 消息体校验和。 BodyCrc float32 `json:"body_crc,omitempty" xml:"body_crc"` // 存储大小。 StoreSize float32 `json:"store_size,omitempty" xml:"store_size"` // 消息属性列表。 PropertyList *[]MessagePropertyList `json:"property_list,omitempty" xml:"property_list"` // 产生消息的主机IP。 BornHost *string `json:"born_host,omitempty" xml:"born_host"` // 存储消息的主机IP。 StoreHost *string `json:"store_host,omitempty" xml:"store_host"` // 队列ID。 QueueId *string `json:"queue_id,omitempty" xml:"queue_id"` // 在队列中的偏移量。 QueueOffset *string `json:"queue_offset,omitempty" xml:"queue_offset"` }
消息。
type MessagePropertyList ¶
type MessagePropertyList struct { // 属性名称。 Name *string `json:"name,omitempty" xml:"name"` // 属性值。 Value *string `json:"value,omitempty" xml:"value"` }
func (MessagePropertyList) String ¶
func (o MessagePropertyList) String() string
type ResetConsumeOffsetReq ¶
type ResetConsumeOffsetReq struct { // 重置的主题。 Topic *string `json:"topic,omitempty" xml:"topic"` // 重置的时间。 Timestamp float32 `json:"timestamp,omitempty" xml:"timestamp"` }
func (ResetConsumeOffsetReq) String ¶
func (o ResetConsumeOffsetReq) String() string
type ResetConsumeOffsetRequest ¶
type ResetConsumeOffsetRequest struct { // 引擎类型:reliability。 Engine ResetConsumeOffsetRequestEngine `json:"engine" xml:"engine"` // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消费组名称。 GroupId string `json:"group_id" xml:"group_id"` Body *ResetConsumeOffsetReq `json:"body,omitempty" xml:"body"` }
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" xml:"broker_name"` // 队列ID。 QueueId *int32 `json:"queue_id,omitempty" xml:"queue_id"` // 重置消费进度。 TimestampOffset *int64 `json:"timestamp_offset,omitempty" xml:"timestamp_offset"` }
func (ResetConsumeOffsetRespQueues) String ¶
func (o ResetConsumeOffsetRespQueues) String() string
type ResetConsumeOffsetResponse ¶
type ResetConsumeOffsetResponse struct { // 重置的队列。 Queues *[]ResetConsumeOffsetRespQueues `json:"queues,omitempty" xml:"queues"` HttpStatusCode int `json:"-"` }
Response Object
func (ResetConsumeOffsetResponse) String ¶
func (o ResetConsumeOffsetResponse) String() string
type ShowConsumerListOrDetailsRequest ¶
type ShowConsumerListOrDetailsRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消费组名称。 Group string `json:"group" xml:"group"` // 待查询的topic,不指定时查询topic列表,指定时查询详情。 Topic *string `json:"topic,omitempty" xml:"topic"` }
Request Object
func (ShowConsumerListOrDetailsRequest) String ¶
func (o ShowConsumerListOrDetailsRequest) String() string
type ShowConsumerListOrDetailsResponse ¶
type ShowConsumerListOrDetailsResponse struct { // Topic列表。 Topics *[]string `json:"topics,omitempty" xml:"topics"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowConsumerListOrDetailsResponse) String ¶
func (o ShowConsumerListOrDetailsResponse) String() string
type ShowGroupRequest ¶
type ShowGroupRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消费组名称。 Group string `json:"group" xml:"group"` }
Request Object
func (ShowGroupRequest) String ¶
func (o ShowGroupRequest) String() string
type ShowGroupResponse ¶
type ShowGroupResponse struct { // 是否启用。 Enabled *bool `json:"enabled,omitempty" xml:"enabled"` // 是否广播。 Broadcast *bool `json:"broadcast,omitempty" xml:"broadcast"` // 关联的代理列表。 Brokers *[]string `json:"brokers,omitempty" xml:"brokers"` // 消费组名称。 Name *string `json:"name,omitempty" xml:"name"` // 最大重试次数。 RetryMaxTime float32 `json:"retry_max_time,omitempty" xml:"retry_max_time"` // 是否重头消费。 FromBeginning *bool `json:"from_beginning,omitempty" xml:"from_beginning"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowGroupResponse) String ¶
func (o ShowGroupResponse) String() string
type ShowInstanceRequest ¶
type ShowInstanceRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` }
Request Object
func (ShowInstanceRequest) String ¶
func (o ShowInstanceRequest) String() string
type ShowInstanceResp ¶
type ShowInstanceResp struct { // 实例名称。 Name *string `json:"name,omitempty" xml:"name"` // 引擎。 Engine *string `json:"engine,omitempty" xml:"engine"` // 状态。 Status *string `json:"status,omitempty" xml:"status"` // 消息描述。 Description *string `json:"description,omitempty" xml:"description"` // 实例类型:集群,cluster。 Type *ShowInstanceRespType `json:"type,omitempty" xml:"type"` // 实例规格。 Specification *string `json:"specification,omitempty" xml:"specification"` // 版本。 EngineVersion *string `json:"engine_version,omitempty" xml:"engine_version"` // 实例ID。 InstanceId *string `json:"instance_id,omitempty" xml:"instance_id"` // 付费模式,1表示按需计费,0表示包年/包月计费。 ChargingMode *int32 `json:"charging_mode,omitempty" xml:"charging_mode"` // 私有云ID。 VpcId *string `json:"vpc_id,omitempty" xml:"vpc_id"` // 私有云名称。 VpcName *string `json:"vpc_name,omitempty" xml:"vpc_name"` // 完成创建时间。 格式为时间戳,指从格林威治时间1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。 CreatedAt *string `json:"created_at,omitempty" xml:"created_at"` // 产品标识。 ProductId *string `json:"product_id,omitempty" xml:"product_id"` // 安全组ID。 SecurityGroupId *string `json:"security_group_id,omitempty" xml:"security_group_id"` // 租户安全组名称。 SecurityGroupName *string `json:"security_group_name,omitempty" xml:"security_group_name"` // 子网ID。 SubnetId *string `json:"subnet_id,omitempty" xml:"subnet_id"` // 子网名称。 SubnetName *string `json:"subnet_name,omitempty" xml:"subnet_name"` // 子网路由。 SubnetCidr *string `json:"subnet_cidr,omitempty" xml:"subnet_cidr"` // IO未售罄的可用区列表。 AvailableZones *[]string `json:"available_zones,omitempty" xml:"available_zones"` // 用户ID。 UserId *string `json:"user_id,omitempty" xml:"user_id"` // 用户名。 UserName *string `json:"user_name,omitempty" xml:"user_name"` // 维护时间窗开始时间,格式为HH:mm:ss。 MaintainBegin *string `json:"maintain_begin,omitempty" xml:"maintain_begin"` // 维护时间窗结束时间,格式为HH:mm:ss。 MaintainEnd *string `json:"maintain_end,omitempty" xml:"maintain_end"` // 是否开启消息收集功能。 EnableLogCollection *bool `json:"enable_log_collection,omitempty" xml:"enable_log_collection"` // 存储空间,单位:GB。 StorageSpace *int32 `json:"storage_space,omitempty" xml:"storage_space"` // 已用消息存储空间,单位:GB。 UsedStorageSpace *int32 `json:"used_storage_space,omitempty" xml:"used_storage_space"` // 是否开启公网。 EnablePublicip *bool `json:"enable_publicip,omitempty" xml:"enable_publicip"` // 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 PublicipId *string `json:"publicip_id,omitempty" xml:"publicip_id"` // 公网IP地址。 PublicipAddress *string `json:"publicip_address,omitempty" xml:"publicip_address"` // 是否开启SSL。 SslEnable *bool `json:"ssl_enable,omitempty" xml:"ssl_enable"` // 跨VPC访问信息。 CrossVpcInfo *string `json:"cross_vpc_info,omitempty" xml:"cross_vpc_info"` // 存储资源ID。 StorageResourceId *string `json:"storage_resource_id,omitempty" xml:"storage_resource_id"` // 存储规格代码。 StorageSpecCode *string `json:"storage_spec_code,omitempty" xml:"storage_spec_code"` // 服务类型。 ServiceType *string `json:"service_type,omitempty" xml:"service_type"` // 存储类型。 StorageType *string `json:"storage_type,omitempty" xml:"storage_type"` // 扩展时间。 ExtendTimes *int64 `json:"extend_times,omitempty" xml:"extend_times"` // 是否开启IPv6。 Ipv6Enable *bool `json:"ipv6_enable,omitempty" xml:"ipv6_enable"` // 实例支持的特性功能。 SupportFeatures *string `json:"support_features,omitempty" xml:"support_features"` // 是否开启磁盘加密。 DiskEncrypted *bool `json:"disk_encrypted,omitempty" xml:"disk_encrypted"` // 云监控版本。 CesVersion *string `json:"ces_version,omitempty" xml:"ces_version"` // 节点数。 NodeNum *int32 `json:"node_num,omitempty" xml:"node_num"` // 是否启用新规格计费。 NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty" xml:"new_spec_billing_enable"` // 是否开启访问控制列表。 EnableAcl *bool `json:"enable_acl,omitempty" xml:"enable_acl"` // 节点数。 BrokerNum *int32 `json:"broker_num,omitempty" xml:"broker_num"` // 元数据地址。 NamesrvAddress *string `json:"namesrv_address,omitempty" xml:"namesrv_address"` // 业务数据地址。 BrokerAddress *string `json:"broker_address,omitempty" xml:"broker_address"` // 公网元数据地址。 PublicNamesrvAddress *string `json:"public_namesrv_address,omitempty" xml:"public_namesrv_address"` // 公网业务数据地址。 PublicBrokerAddress *string `json:"public_broker_address,omitempty" xml:"public_broker_address"` // 标签列表。 Tags *[]TagEntity `json:"tags,omitempty" xml:"tags"` // 总存储空间。 TotalStorageSpace *int32 `json:"total_storage_space,omitempty" xml:"total_storage_space"` // 资源规格。 ResourceSpecCode *string `json:"resource_spec_code,omitempty" xml:"resource_spec_code"` }
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" xml:"name"` // 引擎。 Engine *string `json:"engine,omitempty" xml:"engine"` // 状态。 Status *string `json:"status,omitempty" xml:"status"` // 消息描述。 Description *string `json:"description,omitempty" xml:"description"` // 实例类型:集群,cluster。 Type *ShowInstanceResponseType `json:"type,omitempty" xml:"type"` // 实例规格。 Specification *string `json:"specification,omitempty" xml:"specification"` // 版本。 EngineVersion *string `json:"engine_version,omitempty" xml:"engine_version"` // 实例ID。 InstanceId *string `json:"instance_id,omitempty" xml:"instance_id"` // 付费模式,1表示按需计费,0表示包年/包月计费。 ChargingMode *int32 `json:"charging_mode,omitempty" xml:"charging_mode"` // 私有云ID。 VpcId *string `json:"vpc_id,omitempty" xml:"vpc_id"` // 私有云名称。 VpcName *string `json:"vpc_name,omitempty" xml:"vpc_name"` // 完成创建时间。 格式为时间戳,指从格林威治时间1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。 CreatedAt *string `json:"created_at,omitempty" xml:"created_at"` // 产品标识。 ProductId *string `json:"product_id,omitempty" xml:"product_id"` // 安全组ID。 SecurityGroupId *string `json:"security_group_id,omitempty" xml:"security_group_id"` // 租户安全组名称。 SecurityGroupName *string `json:"security_group_name,omitempty" xml:"security_group_name"` // 子网ID。 SubnetId *string `json:"subnet_id,omitempty" xml:"subnet_id"` // 子网名称。 SubnetName *string `json:"subnet_name,omitempty" xml:"subnet_name"` // 子网路由。 SubnetCidr *string `json:"subnet_cidr,omitempty" xml:"subnet_cidr"` // IO未售罄的可用区列表。 AvailableZones *[]string `json:"available_zones,omitempty" xml:"available_zones"` // 用户ID。 UserId *string `json:"user_id,omitempty" xml:"user_id"` // 用户名。 UserName *string `json:"user_name,omitempty" xml:"user_name"` // 维护时间窗开始时间,格式为HH:mm:ss。 MaintainBegin *string `json:"maintain_begin,omitempty" xml:"maintain_begin"` // 维护时间窗结束时间,格式为HH:mm:ss。 MaintainEnd *string `json:"maintain_end,omitempty" xml:"maintain_end"` // 是否开启消息收集功能。 EnableLogCollection *bool `json:"enable_log_collection,omitempty" xml:"enable_log_collection"` // 存储空间,单位:GB。 StorageSpace *int32 `json:"storage_space,omitempty" xml:"storage_space"` // 已用消息存储空间,单位:GB。 UsedStorageSpace *int32 `json:"used_storage_space,omitempty" xml:"used_storage_space"` // 是否开启公网。 EnablePublicip *bool `json:"enable_publicip,omitempty" xml:"enable_publicip"` // 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网访问功能(即enable_publicip为true),该字段为必选。 PublicipId *string `json:"publicip_id,omitempty" xml:"publicip_id"` // 公网IP地址。 PublicipAddress *string `json:"publicip_address,omitempty" xml:"publicip_address"` // 是否开启SSL。 SslEnable *bool `json:"ssl_enable,omitempty" xml:"ssl_enable"` // 跨VPC访问信息。 CrossVpcInfo *string `json:"cross_vpc_info,omitempty" xml:"cross_vpc_info"` // 存储资源ID。 StorageResourceId *string `json:"storage_resource_id,omitempty" xml:"storage_resource_id"` // 存储规格代码。 StorageSpecCode *string `json:"storage_spec_code,omitempty" xml:"storage_spec_code"` // 服务类型。 ServiceType *string `json:"service_type,omitempty" xml:"service_type"` // 存储类型。 StorageType *string `json:"storage_type,omitempty" xml:"storage_type"` // 扩展时间。 ExtendTimes *int64 `json:"extend_times,omitempty" xml:"extend_times"` // 是否开启IPv6。 Ipv6Enable *bool `json:"ipv6_enable,omitempty" xml:"ipv6_enable"` // 实例支持的特性功能。 SupportFeatures *string `json:"support_features,omitempty" xml:"support_features"` // 是否开启磁盘加密。 DiskEncrypted *bool `json:"disk_encrypted,omitempty" xml:"disk_encrypted"` // 云监控版本。 CesVersion *string `json:"ces_version,omitempty" xml:"ces_version"` // 节点数。 NodeNum *int32 `json:"node_num,omitempty" xml:"node_num"` // 是否启用新规格计费。 NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty" xml:"new_spec_billing_enable"` // 是否开启访问控制列表。 EnableAcl *bool `json:"enable_acl,omitempty" xml:"enable_acl"` // 节点数。 BrokerNum *int32 `json:"broker_num,omitempty" xml:"broker_num"` // 元数据地址。 NamesrvAddress *string `json:"namesrv_address,omitempty" xml:"namesrv_address"` // 业务数据地址。 BrokerAddress *string `json:"broker_address,omitempty" xml:"broker_address"` // 公网元数据地址。 PublicNamesrvAddress *string `json:"public_namesrv_address,omitempty" xml:"public_namesrv_address"` // 公网业务数据地址。 PublicBrokerAddress *string `json:"public_broker_address,omitempty" xml:"public_broker_address"` // 标签列表。 Tags *[]TagEntity `json:"tags,omitempty" xml:"tags"` // 总存储空间。 TotalStorageSpace *int32 `json:"total_storage_space,omitempty" xml:"total_storage_space"` // 资源规格。 ResourceSpecCode *string `json:"resource_spec_code,omitempty" xml:"resource_spec_code"` HttpStatusCode int `json:"-"` }
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" xml:"instance_id"` // 主题名称。 Topic string `json:"topic" xml:"topic"` }
Request Object
func (ShowOneTopicRequest) String ¶
func (o ShowOneTopicRequest) String() string
type ShowOneTopicResponse ¶
type ShowOneTopicResponse struct { // 总读队列个数。 TotalReadQueueNum float32 `json:"total_read_queue_num,omitempty" xml:"total_read_queue_num"` // 总写队列个数。 TotalWriteQueueNum float32 `json:"total_write_queue_num,omitempty" xml:"total_write_queue_num"` // 权限。 Permission *ShowOneTopicResponsePermission `json:"permission,omitempty" xml:"permission"` // 关联的代理。 Brokers *[]TopicBrokers `json:"brokers,omitempty" xml:"brokers"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowOneTopicResponse) String ¶
func (o ShowOneTopicResponse) String() string
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 ShowTopicStatusRequest ¶
type ShowTopicStatusRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 主题名称。 Topic string `json:"topic" xml:"topic"` }
Request Object
func (ShowTopicStatusRequest) String ¶
func (o ShowTopicStatusRequest) String() string
type ShowTopicStatusRespBrokers ¶
type ShowTopicStatusRespBrokers struct { // 队列列表。 Queues *[]ShowTopicStatusRespQueues `json:"queues,omitempty" xml:"queues"` // 节点名称。 BrokerName *string `json:"broker_name,omitempty" xml:"broker_name"` }
func (ShowTopicStatusRespBrokers) String ¶
func (o ShowTopicStatusRespBrokers) String() string
type ShowTopicStatusRespQueues ¶
type ShowTopicStatusRespQueues struct { // 队列ID。 Id *int32 `json:"id,omitempty" xml:"id"` // 最小偏移量。 MinOffset *int32 `json:"min_offset,omitempty" xml:"min_offset"` // 最大偏移量。 MaxOffset *int32 `json:"max_offset,omitempty" xml:"max_offset"` // 最后一条消息的时间。 LastMessageTime *int64 `json:"last_message_time,omitempty" xml:"last_message_time"` }
func (ShowTopicStatusRespQueues) String ¶
func (o ShowTopicStatusRespQueues) String() string
type ShowTopicStatusResponse ¶
type ShowTopicStatusResponse struct { // 代理。 Brokers *[]ShowTopicStatusRespBrokers `json:"brokers,omitempty" xml:"brokers"` HttpStatusCode int `json:"-"` }
Response Object
func (ShowTopicStatusResponse) String ¶
func (o ShowTopicStatusResponse) String() string
type ShowUserRequest ¶
type ShowUserRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 用户名。 UserName string `json:"user_name" xml:"user_name"` }
Request Object
func (ShowUserRequest) String ¶
func (o ShowUserRequest) String() string
type ShowUserResponse ¶
type ShowUserResponse struct { // 用户名。 AccessKey *string `json:"access_key,omitempty" xml:"access_key"` // 密钥。 SecretKey *string `json:"secret_key,omitempty" xml:"secret_key"` // IP白名单。 WhiteRemoteAddress *string `json:"white_remote_address,omitempty" xml:"white_remote_address"` // 是否为管理员。 Admin *bool `json:"admin,omitempty" xml:"admin"` // 默认的主题权限。 DefaultTopicPerm *ShowUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty" xml:"default_topic_perm"` // 默认的消费组权限。 DefaultGroupPerm *ShowUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty" xml:"default_group_perm"` // 特殊的主题权限。 TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty" xml:"topic_perms"` // 特殊的消费组权限。 GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty" xml:"group_perms"` HttpStatusCode int `json:"-"` }
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 { PUB ShowUserResponseDefaultGroupPerm SUB ShowUserResponseDefaultGroupPerm PUB_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 TagEntity ¶
type TagEntity struct { // 键。最大长度36个unicode字符。 key不能为空,不能为空字符串。 不能包含下列字符:非打印字符ASCII(0-31),“=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”。 Key *string `json:"key,omitempty" xml:"key"` // 值。每个值最大长度43个unicode字符。 value不能为空,可以空字符串。 不能包含下列字符:非打印字符ASCII(0-31), “=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”。 Value *string `json:"value,omitempty" xml:"value"` }
type TopicBrokers ¶
type TopicBrokers struct { // 代理名称。 BrokerName *string `json:"broker_name,omitempty" xml:"broker_name"` // 读队列个数。 ReadQueueNum float32 `json:"read_queue_num,omitempty" xml:"read_queue_num"` // 写队列个数。 WriteQueueNum float32 `json:"write_queue_num,omitempty" xml:"write_queue_num"` }
func (TopicBrokers) String ¶
func (o TopicBrokers) String() string
type UpdateConsumerGroupRequest ¶
type UpdateConsumerGroupRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 消费组名称。 Group string `json:"group" xml:"group"` Body *ConsumerGroup `json:"body,omitempty" xml:"body"` }
Request Object
func (UpdateConsumerGroupRequest) String ¶
func (o UpdateConsumerGroupRequest) String() string
type UpdateConsumerGroupResponse ¶
type UpdateConsumerGroupResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (UpdateConsumerGroupResponse) String ¶
func (o UpdateConsumerGroupResponse) String() string
type UpdateInstanceReq ¶
type UpdateInstanceReq struct { // 实例名称。 由英文字符开头,只能由英文字母、数字、中划线组成,长度为4~64的字符。 Name *string `json:"name,omitempty" xml:"name"` // 实例的描述信息。 长度不超过1024的字符串。 > \\与\"在json报文中属于特殊字符,如果参数值中需要显示\\或者\"字符,请在字符前增加转义字符\\,比如\\\\或者\\\"。 Description *string `json:"description,omitempty" xml:"description"` // 安全组ID。 SecurityGroupId *string `json:"security_group_id,omitempty" xml:"security_group_id"` // ACL访问控制。 RetentionPolicy *bool `json:"retention_policy,omitempty" xml:"retention_policy"` }
func (UpdateInstanceReq) String ¶
func (o UpdateInstanceReq) String() string
type UpdateInstanceRequest ¶
type UpdateInstanceRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` Body *UpdateInstanceReq `json:"body,omitempty" xml:"body"` }
Request Object
func (UpdateInstanceRequest) String ¶
func (o UpdateInstanceRequest) String() string
type UpdateInstanceResponse ¶
type UpdateInstanceResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (UpdateInstanceResponse) String ¶
func (o UpdateInstanceResponse) String() string
type UpdateTopicReq ¶
type UpdateTopicReq struct { // 总读队列个数。 ReadQueueNum float32 `json:"read_queue_num,omitempty" xml:"read_queue_num"` // 总写队列个数。 WriteQueueNum float32 `json:"write_queue_num,omitempty" xml:"write_queue_num"` // 权限。 Permission *UpdateTopicReqPermission `json:"permission,omitempty" xml:"permission"` }
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" xml:"instance_id"` // 主题名称。 Topic string `json:"topic" xml:"topic"` Body *UpdateTopicReq `json:"body,omitempty" xml:"body"` }
Request Object
func (UpdateTopicRequest) String ¶
func (o UpdateTopicRequest) String() string
type UpdateTopicResponse ¶
type UpdateTopicResponse struct {
HttpStatusCode int `json:"-"`
}
Response Object
func (UpdateTopicResponse) String ¶
func (o UpdateTopicResponse) String() string
type UpdateUserRequest ¶
type UpdateUserRequest struct { // 实例ID。 InstanceId string `json:"instance_id" xml:"instance_id"` // 用户名。 UserName string `json:"user_name" xml:"user_name"` Body *User `json:"body,omitempty" xml:"body"` }
Request Object
func (UpdateUserRequest) String ¶
func (o UpdateUserRequest) String() string
type UpdateUserResponse ¶
type UpdateUserResponse struct { // 用户名。 AccessKey *string `json:"access_key,omitempty" xml:"access_key"` // 密钥。 SecretKey *string `json:"secret_key,omitempty" xml:"secret_key"` // IP白名单。 WhiteRemoteAddress *string `json:"white_remote_address,omitempty" xml:"white_remote_address"` // 是否为管理员。 Admin *bool `json:"admin,omitempty" xml:"admin"` // 默认的主题权限。 DefaultTopicPerm *UpdateUserResponseDefaultTopicPerm `json:"default_topic_perm,omitempty" xml:"default_topic_perm"` // 默认的消费组权限。 DefaultGroupPerm *UpdateUserResponseDefaultGroupPerm `json:"default_group_perm,omitempty" xml:"default_group_perm"` // 特殊的主题权限。 TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty" xml:"topic_perms"` // 特殊的消费组权限。 GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty" xml:"group_perms"` HttpStatusCode int `json:"-"` }
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 { PUB UpdateUserResponseDefaultGroupPerm SUB UpdateUserResponseDefaultGroupPerm PUB_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 { // 用户名。 AccessKey *string `json:"access_key,omitempty" xml:"access_key"` // 密钥。 SecretKey *string `json:"secret_key,omitempty" xml:"secret_key"` // IP白名单。 WhiteRemoteAddress *string `json:"white_remote_address,omitempty" xml:"white_remote_address"` // 是否为管理员。 Admin *bool `json:"admin,omitempty" xml:"admin"` // 默认的主题权限。 DefaultTopicPerm *UserDefaultTopicPerm `json:"default_topic_perm,omitempty" xml:"default_topic_perm"` // 默认的消费组权限。 DefaultGroupPerm *UserDefaultGroupPerm `json:"default_group_perm,omitempty" xml:"default_group_perm"` // 特殊的主题权限。 TopicPerms *[]UserTopicPerms `json:"topic_perms,omitempty" xml:"topic_perms"` // 特殊的消费组权限。 GroupPerms *[]UserGroupPerms `json:"group_perms,omitempty" xml:"group_perms"` }
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 { PUB UserDefaultGroupPerm SUB UserDefaultGroupPerm PUB_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" xml:"name"` // 权限。 Perm *UserGroupPermsPerm `json:"perm,omitempty" xml:"perm"` }
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 { PUB UserGroupPermsPerm SUB UserGroupPermsPerm PUB_SUB UserGroupPermsPerm DENY UserGroupPermsPerm }
func GetUserGroupPermsPermEnum ¶
func GetUserGroupPermsPermEnum() UserGroupPermsPermEnum
type UserTopicPerms ¶
type UserTopicPerms struct { // 主题名称。 Name *string `json:"name,omitempty" xml:"name"` // 权限。 Perm *UserTopicPermsPerm `json:"perm,omitempty" xml:"perm"` }
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
Source Files ¶
- 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_consumer_group.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_post_paid_instance_req.go
- model_create_post_paid_instance_request.go
- model_create_post_paid_instance_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_delete_consumer_group_request.go
- model_delete_consumer_group_response.go
- model_delete_instance_request.go
- model_delete_instance_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_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_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_show_consumer_list_or_details_request.go
- model_show_consumer_list_or_details_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_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_tag_entity.go
- model_topic_brokers.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_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