model

package
v0.1.16 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2022 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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

Request Object

func (BatchDeleteInstancesRequest) String 

func (o BatchDeleteInstancesRequest) String() string

type BatchDeleteInstancesResponse 

type BatchDeleteInstancesResponse struct {

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

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

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

Response Object

func (BatchUpdateConsumerGroupResponse) String 

func (o BatchUpdateConsumerGroupResponse) String() string

type ConsumerGroup 

type ConsumerGroup struct {

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

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

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

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

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

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

func (ConsumerGroup) String 

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

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

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

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

func (CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String 

func (o CreateConsumerGroupOrBatchDeleteConsumerGroupReq) String() string

type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest 

type CreateConsumerGroupOrBatchDeleteConsumerGroupRequest struct {

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

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

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

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

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 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。该参数不能为空数组或者数组的值为空， 请注意查看该可用区是否有资源。  创建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"`

	// 是否支持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"`
}

创建实例请求体。

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

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

Response Object

func (CreatePostPaidInstanceResponse) String 

func (o CreatePostPaidInstanceResponse) String() string

type CreateTopicOrBatchDeleteTopicReq 

type CreateTopicOrBatchDeleteTopicReq struct {

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

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

	// 队列数。
	QueueNum float32 `json:"queue_num,omitempty"`

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

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

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

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

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

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

Response Object

func (CreateTopicOrBatchDeleteTopicResponse) String 

func (o CreateTopicOrBatchDeleteTopicResponse) String() string

type CreateTopicReq 

type CreateTopicReq struct {

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

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

	// 队列数。
	QueueNum float32 `json:"queue_num,omitempty"`

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

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

func (CreateTopicResp) String 

func (o CreateTopicResp) String() string

type CreateUserRequest 

type CreateUserRequest struct {

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

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

Request Object

func (CreateUserRequest) String 

func (o CreateUserRequest) String() string

type CreateUserResponse 

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

	// 默认的主题权限。
	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:"-"`
}

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

	// 消费组名称。
	Group string `json:"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"`
}

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

	// 主题名称。
	Topic string `json:"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"`

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

Request Object

func (DeleteUserRequest) String 

func (o DeleteUserRequest) String() string

type DeleteUserResponse 

type DeleteUserResponse struct {

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

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

Request Object

func (ExportDlqMessageRequest) String 

func (o ExportDlqMessageRequest) String() string

type ExportDlqMessageResponse 

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

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 {
}

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

Response Object

func (ListAvailableZonesResponse) String 

func (o ListAvailableZonesResponse) String() string

type ListBrokersRequest 

type ListBrokersRequest struct {

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

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

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

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

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

Request Object

func (ListConsumerGroupOfTopicRequest) String 

func (o ListConsumerGroupOfTopicRequest) String() string

type ListConsumerGroupOfTopicResponse 

type ListConsumerGroupOfTopicResponse struct {

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

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

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

Response Object

func (ListInstanceConsumerGroupsResponse) String 

func (o ListInstanceConsumerGroupsResponse) String() string

type ListInstancesRequest 

type ListInstancesRequest struct {

	// 消息引擎：reliability。
	Engine *string `json:"engine,omitempty"`

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

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

	// 实例状态。
	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"`
}

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

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

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,omitempty"`
}

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

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

	// 开始时间。
	StartTime *string `json:"start_time,omitempty"`

	// 结束时间。
	EndTime *string `json:"end_time,omitempty"`

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

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

Response Object

func (ListMessagesResponse) String 

func (o ListMessagesResponse) 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"`
}

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

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

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

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 *string `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 *string `json:"queue_id,omitempty"`

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

消息。

func (Message) String 

func (o Message) String() string

type MessagePropertyList 

type MessagePropertyList struct {

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

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

func (MessagePropertyList) String 

func (o MessagePropertyList) String() string

type ResetConsumeOffsetReq 

type ResetConsumeOffsetReq struct {

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

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

func (ResetConsumeOffsetReq) String 

func (o ResetConsumeOffsetReq) String() string

type ResetConsumeOffsetRequest 

type ResetConsumeOffsetRequest struct {

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

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

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

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

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

Response Object

func (ResetConsumeOffsetResponse) String 

func (o ResetConsumeOffsetResponse) String() string

type ShowConsumerListOrDetailsRequest 

type ShowConsumerListOrDetailsRequest struct {

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

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

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

Request Object

func (ShowConsumerListOrDetailsRequest) String 

func (o ShowConsumerListOrDetailsRequest) String() string

type ShowConsumerListOrDetailsResponse 

type ShowConsumerListOrDetailsResponse struct {

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

Response Object

func (ShowConsumerListOrDetailsResponse) String 

func (o ShowConsumerListOrDetailsResponse) String() string

type ShowGroupRequest 

type ShowGroupRequest struct {

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

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

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

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

Response Object

func (ShowGroupResponse) String 

func (o ShowGroupResponse) String() string

type ShowInstanceRequest 

type ShowInstanceRequest struct {

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

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,hws_hk,)[付费模式，1表示按需计费，0表示包年/包月计费。](tag:hws,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"`

	// 标签列表。
	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,hws_hk,)[付费模式，1表示按需计费，0表示包年/包月计费。](tag:hws,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"`

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

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

	// 资源规格。
	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`
	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"`

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

Request Object

func (ShowOneTopicRequest) String 

func (o ShowOneTopicRequest) String() string

type ShowOneTopicResponse 

type ShowOneTopicResponse struct {

	// 总读队列个数。
	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"`
	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"`

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

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 {

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

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

Request Object

func (ShowUserRequest) String 

func (o ShowUserRequest) String() string

type ShowUserResponse 

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

	// 默认的主题权限。
	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:"-"`
}

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

	// 值。每个值最大长度43个unicode字符。  value不能为空，可以空字符串。  不能包含下列字符：非打印字符ASCII(0-31), “=”,“*”,“<”,“>”,“\\”,“,”,“|”,“/”。
	Value *string `json:"value,omitempty"`
}

func (TagEntity) String 

func (o TagEntity) String() string

type TopicBrokers 

type TopicBrokers struct {

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

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

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

func (TopicBrokers) String 

func (o TopicBrokers) String() string

type UpdateConsumerGroupRequest 

type UpdateConsumerGroupRequest struct {

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

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

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

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

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

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

	// ACL访问控制。
	EnableAcl *bool `json:"enable_acl,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"`
}

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

	// 总写队列个数。
	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"`
}

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

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

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

Request Object

func (UpdateUserRequest) String 

func (o UpdateUserRequest) String() string

type UpdateUserResponse 

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

	// 默认的主题权限。
	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:"-"`
}

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

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

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

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

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

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

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

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

func (User) String 

func (o User) String() string

type UserDefaultGroupPerm 

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

func (UserDefaultGroupPerm) MarshalJSON 

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

func (*UserDefaultGroupPerm) UnmarshalJSON 

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

func (UserDefaultGroupPerm) Value added in v0.0.90 

func (c UserDefaultGroupPerm) Value() string

type UserDefaultGroupPermEnum 

type UserDefaultGroupPermEnum struct {
	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"`

	// 权限。
	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 {
	PUB     UserGroupPermsPerm
	SUB     UserGroupPermsPerm
	PUB_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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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