model

package
v0.0.92 Latest Latest
Warning

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

Go to latest
Published: Jun 9, 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

type BatchDeleteConsumerGroupResp

type BatchDeleteConsumerGroupResp struct {

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

func (BatchDeleteConsumerGroupResp) String

type BatchDeleteInstanceReq

type BatchDeleteInstanceReq struct {

	// 实例的ID列表。
	Instances *[]string `json:"instances,omitempty"`

	// 对实例的操作:delete
	Action BatchDeleteInstanceReqAction `json:"action"`

	// 参数值为RocketMQ,表示删除租户所有创建失败的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

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

type BatchDeleteInstanceReqAllFailureEnum

type BatchDeleteInstanceReqAllFailureEnum struct {
	TRUE  BatchDeleteInstanceReqAllFailure
	FALSE 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

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

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

type BatchDeleteInstancesResponse

type BatchDeleteInstancesResponse struct {

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

Response Object

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

type BatchUpdateConsumerGroupRequest

type BatchUpdateConsumerGroupRequest struct {

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

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

Request Object

func (BatchUpdateConsumerGroupRequest) String

type BatchUpdateConsumerGroupResponse

type BatchUpdateConsumerGroupResponse struct {

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

Response Object

func (BatchUpdateConsumerGroupResponse) 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

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

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

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

创建实例请求体。

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

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

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

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 (*CreatePostPaidInstanceReqStorageSpecCode) UnmarshalJSON

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

func (CreatePostPaidInstanceReqStorageSpecCode) Value added in v0.0.90

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

type CreatePostPaidInstanceResponse

type CreatePostPaidInstanceResponse struct {

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

Response Object

func (CreatePostPaidInstanceResponse) 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

type CreateTopicOrBatchDeleteTopicReqPermission

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

func (CreateTopicOrBatchDeleteTopicReqPermission) MarshalJSON

func (*CreateTopicOrBatchDeleteTopicReqPermission) UnmarshalJSON

func (CreateTopicOrBatchDeleteTopicReqPermission) Value added in v0.0.90

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

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

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

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

type DeleteConsumerGroupRequest

type DeleteConsumerGroupRequest struct {

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

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

Request Object

func (DeleteConsumerGroupRequest) String

type DeleteConsumerGroupResponse

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

Response Object

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

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

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

	// 权限。
	Perm *string `json:"perm,omitempty"`
}

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

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

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

type ListConsumeGroupAccessPolicyRequestEngine

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

func (ListConsumeGroupAccessPolicyRequestEngine) MarshalJSON

func (*ListConsumeGroupAccessPolicyRequestEngine) UnmarshalJSON

func (ListConsumeGroupAccessPolicyRequestEngine) Value added in v0.0.90

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

type ListConsumerGroupOfTopicRequest

type ListConsumerGroupOfTopicRequest struct {

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

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

Request Object

func (ListConsumerGroupOfTopicRequest) String

type ListConsumerGroupOfTopicResponse

type ListConsumerGroupOfTopicResponse struct {

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

Response Object

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

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

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

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

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

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

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

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

type ListMessageTraceRespTraceTransactionState

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

func (ListMessageTraceRespTraceTransactionState) MarshalJSON

func (*ListMessageTraceRespTraceTransactionState) UnmarshalJSON

func (ListMessageTraceRespTraceTransactionState) Value added in v0.0.90

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

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

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

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

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

type ResetConsumeOffsetResponse

type ResetConsumeOffsetResponse struct {

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

Response Object

func (ResetConsumeOffsetResponse) 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

type ShowConsumerListOrDetailsResponse

type ShowConsumerListOrDetailsResponse struct {

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

Response Object

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

	// 是否重头消费。
	FromBeginning  *bool `json:"from_beginning,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表示按需计费,0表示包年/包月计费。
	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表示按需计费,0表示包年/包月计费。
	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

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

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

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

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

type UpdateConsumerGroupResponse

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

Response Object

func (UpdateConsumerGroupResponse) 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访问控制。
	RetentionPolicy *bool `json:"retention_policy,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

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL