model

package
v0.1.70 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2023 License: Apache-2.0, BSD-2-Clause, BSD-3-Clause Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AccessPolicyEntity added in v0.0.66 

type AccessPolicyEntity struct {

	// 用户名称。
	UserName *string `json:"user_name,omitempty"`

	// 权限类型。 - all：拥有发布、订阅权限; - pub：拥有发布权限; - sub：拥有订阅权限。
	AccessPolicy *AccessPolicyEntityAccessPolicy `json:"access_policy,omitempty"`
}

AccessPolicyEntity 权限实体。

func (AccessPolicyEntity) String added in v0.0.66 

func (o AccessPolicyEntity) String() string

type AccessPolicyEntityAccessPolicy added in v0.0.66 

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

func (AccessPolicyEntityAccessPolicy) MarshalJSON added in v0.0.66 

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

func (*AccessPolicyEntityAccessPolicy) UnmarshalJSON added in v0.0.66 

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

func (AccessPolicyEntityAccessPolicy) Value added in v0.0.90 

func (c AccessPolicyEntityAccessPolicy) Value() string

type AccessPolicyEntityAccessPolicyEnum added in v0.0.66 

type AccessPolicyEntityAccessPolicyEnum struct {
	ALL AccessPolicyEntityAccessPolicy
	PUB AccessPolicyEntityAccessPolicy
	SUB AccessPolicyEntityAccessPolicy
}

func GetAccessPolicyEntityAccessPolicyEnum added in v0.0.66 

func GetAccessPolicyEntityAccessPolicyEnum() AccessPolicyEntityAccessPolicyEnum

type AccessPolicyTopicEntity added in v0.0.66 

type AccessPolicyTopicEntity struct {

	// topic名称。
	Name string `json:"name"`

	// 权限列表。
	Policies []AccessPolicyEntity `json:"policies"`
}

AccessPolicyTopicEntity 权限实体。

func (AccessPolicyTopicEntity) String added in v0.0.66 

func (o AccessPolicyTopicEntity) String() string

type BatchCreateOrDeleteKafkaTagRequest 

type BatchCreateOrDeleteKafkaTagRequest struct {

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

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

BatchCreateOrDeleteKafkaTagRequest Request Object

func (BatchCreateOrDeleteKafkaTagRequest) String 

func (o BatchCreateOrDeleteKafkaTagRequest) String() string

type BatchCreateOrDeleteKafkaTagResponse 

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

BatchCreateOrDeleteKafkaTagResponse Response Object

func (BatchCreateOrDeleteKafkaTagResponse) String 

func (o BatchCreateOrDeleteKafkaTagResponse) String() string

type BatchCreateOrDeleteTagReq 

type BatchCreateOrDeleteTagReq struct {

	// 操作标识（仅支持小写）: - create（创建） - delete（删除）
	Action *BatchCreateOrDeleteTagReqAction `json:"action,omitempty"`

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

func (BatchCreateOrDeleteTagReq) String 

func (o BatchCreateOrDeleteTagReq) String() string

type BatchCreateOrDeleteTagReqAction 

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

func (BatchCreateOrDeleteTagReqAction) MarshalJSON 

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

func (*BatchCreateOrDeleteTagReqAction) UnmarshalJSON 

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

func (BatchCreateOrDeleteTagReqAction) Value added in v0.0.90 

func (c BatchCreateOrDeleteTagReqAction) Value() string

type BatchCreateOrDeleteTagReqActionEnum 

type BatchCreateOrDeleteTagReqActionEnum struct {
	CREATE BatchCreateOrDeleteTagReqAction
	DELETE BatchCreateOrDeleteTagReqAction
}

func GetBatchCreateOrDeleteTagReqActionEnum 

func GetBatchCreateOrDeleteTagReqActionEnum() BatchCreateOrDeleteTagReqActionEnum

type BatchDeleteGroupReq added in v0.1.36 

type BatchDeleteGroupReq struct {

	// 所有需要删除的消费组ID。
	GroupIds *[]string `json:"group_ids,omitempty"`
}

func (BatchDeleteGroupReq) String added in v0.1.36 

func (o BatchDeleteGroupReq) String() string

type BatchDeleteGroupRequest added in v0.1.36 

type BatchDeleteGroupRequest struct {

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

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

BatchDeleteGroupRequest Request Object

func (BatchDeleteGroupRequest) String added in v0.1.36 

func (o BatchDeleteGroupRequest) String() string

type BatchDeleteGroupRespFailedGroups added in v0.1.36 

type BatchDeleteGroupRespFailedGroups struct {

	// 删除失败的消费组ID。
	GroupId *string `json:"group_id,omitempty"`

	// 删除失败的原因。
	ErrorMessage *string `json:"error_message,omitempty"`
}

func (BatchDeleteGroupRespFailedGroups) String added in v0.1.36 

func (o BatchDeleteGroupRespFailedGroups) String() string

type BatchDeleteGroupResponse added in v0.1.36 

type BatchDeleteGroupResponse struct {

	// 删除失败的消费组列表。
	FailedGroups *[]BatchDeleteGroupRespFailedGroups `json:"failed_groups,omitempty"`

	// 删除失败的个数
	Total          *int32 `json:"total,omitempty"`
	HttpStatusCode int    `json:"-"`
}

BatchDeleteGroupResponse Response Object

func (BatchDeleteGroupResponse) String added in v0.1.36 

func (o BatchDeleteGroupResponse) String() string

type BatchDeleteInstanceTopicReq 

type BatchDeleteInstanceTopicReq struct {

	// 待删除的topic列表。
	Topics *[]string `json:"topics,omitempty"`
}

func (BatchDeleteInstanceTopicReq) String 

func (o BatchDeleteInstanceTopicReq) String() string

type BatchDeleteInstanceTopicRequest 

type BatchDeleteInstanceTopicRequest struct {

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

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

BatchDeleteInstanceTopicRequest Request Object

func (BatchDeleteInstanceTopicRequest) String 

func (o BatchDeleteInstanceTopicRequest) String() string

type BatchDeleteInstanceTopicRespTopics 

type BatchDeleteInstanceTopicRespTopics struct {

	// Topic名称。
	Id *string `json:"id,omitempty"`

	// 是否删除成功。
	Success *bool `json:"success,omitempty"`
}

func (BatchDeleteInstanceTopicRespTopics) String 

func (o BatchDeleteInstanceTopicRespTopics) String() string

type BatchDeleteInstanceTopicResponse 

type BatchDeleteInstanceTopicResponse struct {

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

BatchDeleteInstanceTopicResponse Response Object

func (BatchDeleteInstanceTopicResponse) String 

func (o BatchDeleteInstanceTopicResponse) String() string

type BatchDeleteInstanceUsersReq 

type BatchDeleteInstanceUsersReq struct {

	// 删除类型。当前只支持delete。
	Action *BatchDeleteInstanceUsersReqAction `json:"action,omitempty"`

	// 用户列表。
	Users *[]string `json:"users,omitempty"`
}

func (BatchDeleteInstanceUsersReq) String 

func (o BatchDeleteInstanceUsersReq) String() string

type BatchDeleteInstanceUsersReqAction 

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

func (BatchDeleteInstanceUsersReqAction) MarshalJSON 

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

func (*BatchDeleteInstanceUsersReqAction) UnmarshalJSON 

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

func (BatchDeleteInstanceUsersReqAction) Value added in v0.0.90 

func (c BatchDeleteInstanceUsersReqAction) Value() string

type BatchDeleteInstanceUsersReqActionEnum 

type BatchDeleteInstanceUsersReqActionEnum struct {
	DELETE BatchDeleteInstanceUsersReqAction
}

func GetBatchDeleteInstanceUsersReqActionEnum 

func GetBatchDeleteInstanceUsersReqActionEnum() BatchDeleteInstanceUsersReqActionEnum

type BatchDeleteInstanceUsersRequest 

type BatchDeleteInstanceUsersRequest struct {

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

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

BatchDeleteInstanceUsersRequest Request Object

func (BatchDeleteInstanceUsersRequest) String 

func (o BatchDeleteInstanceUsersRequest) String() string

type BatchDeleteInstanceUsersResponse 

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

BatchDeleteInstanceUsersResponse Response Object

func (BatchDeleteInstanceUsersResponse) String 

func (o BatchDeleteInstanceUsersResponse) String() string

type BatchRestartOrDeleteInstanceReq 

type BatchRestartOrDeleteInstanceReq struct {

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

	// 对实例的操作：restart、delete
	Action BatchRestartOrDeleteInstanceReqAction `json:"action"`

	// 参数值为kafka，表示删除租户所有创建失败的Kafka实例。
	AllFailure *BatchRestartOrDeleteInstanceReqAllFailure `json:"all_failure,omitempty"`
}

func (BatchRestartOrDeleteInstanceReq) String 

func (o BatchRestartOrDeleteInstanceReq) String() string

type BatchRestartOrDeleteInstanceReqAction 

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

func (BatchRestartOrDeleteInstanceReqAction) MarshalJSON 

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

func (*BatchRestartOrDeleteInstanceReqAction) UnmarshalJSON 

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

func (BatchRestartOrDeleteInstanceReqAction) Value added in v0.0.90 

func (c BatchRestartOrDeleteInstanceReqAction) Value() string

type BatchRestartOrDeleteInstanceReqActionEnum 

type BatchRestartOrDeleteInstanceReqActionEnum struct {
	RESTART BatchRestartOrDeleteInstanceReqAction
	DELETE  BatchRestartOrDeleteInstanceReqAction
}

func GetBatchRestartOrDeleteInstanceReqActionEnum 

func GetBatchRestartOrDeleteInstanceReqActionEnum() BatchRestartOrDeleteInstanceReqActionEnum

type BatchRestartOrDeleteInstanceReqAllFailure 

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

func (BatchRestartOrDeleteInstanceReqAllFailure) MarshalJSON 

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

func (*BatchRestartOrDeleteInstanceReqAllFailure) UnmarshalJSON 

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

func (BatchRestartOrDeleteInstanceReqAllFailure) Value added in v0.0.90 

func (c BatchRestartOrDeleteInstanceReqAllFailure) Value() string

type BatchRestartOrDeleteInstanceReqAllFailureEnum 

type BatchRestartOrDeleteInstanceReqAllFailureEnum struct {
	KAFKA BatchRestartOrDeleteInstanceReqAllFailure
}

func GetBatchRestartOrDeleteInstanceReqAllFailureEnum 

func GetBatchRestartOrDeleteInstanceReqAllFailureEnum() BatchRestartOrDeleteInstanceReqAllFailureEnum

type BatchRestartOrDeleteInstanceRespResults 

type BatchRestartOrDeleteInstanceRespResults struct {

	// 操作结果。   - success: 操作成功   - failed: 操作失败
	Result *string `json:"result,omitempty"`

	// 实例ID。
	Instance *string `json:"instance,omitempty"`
}

func (BatchRestartOrDeleteInstanceRespResults) String 

func (o BatchRestartOrDeleteInstanceRespResults) String() string

type BatchRestartOrDeleteInstancesRequest 

type BatchRestartOrDeleteInstancesRequest struct {
	Body *BatchRestartOrDeleteInstanceReq `json:"body,omitempty"`
}

BatchRestartOrDeleteInstancesRequest Request Object

func (BatchRestartOrDeleteInstancesRequest) String 

func (o BatchRestartOrDeleteInstancesRequest) String() string

type BatchRestartOrDeleteInstancesResponse 

type BatchRestartOrDeleteInstancesResponse struct {

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

BatchRestartOrDeleteInstancesResponse Response Object

func (BatchRestartOrDeleteInstancesResponse) String 

func (o BatchRestartOrDeleteInstancesResponse) String() string

type BssParam added in v0.1.24 

type BssParam struct {

	// 是否自动续订。  取值范围：   - true: 自动续订。   - false: 不自动续订。  默认不自动续订。
	IsAutoRenew *bool `json:"is_auto_renew,omitempty"`

	// 计费模式。  功能说明：付费方式。  取值范围：   - prePaid：预付费，即包年包月；   - postPaid：后付费，即按需付费；  默认为postPaid。
	ChargingMode *BssParamChargingMode `json:"charging_mode,omitempty"`

	// 下单订购后，是否自动从客户的账户中支付，而不需要客户手动去进行支付。  取值范围：   - true：是（自动支付）   - false：否（需要客户手动支付）  默认为手动支付。
	IsAutoPay *bool `json:"is_auto_pay,omitempty"`

	// 订购周期类型。  取值范围：   - month：月   - year：年  **chargingMode为prePaid时生效且为必选值。**
	PeriodType *BssParamPeriodType `json:"period_type,omitempty"`

	// 订购周期数。  取值范围：   - periodType=month（周期类型为月）时，取值为[1，9]；  - periodType=year（周期类型为年）时，取值为[1，3]；  **chargingMode为prePaid时生效且为必选值。**
	PeriodNum *int32 `json:"period_num,omitempty"`
}

BssParam 表示包周期计费模式的相关参数。 如果为空，则默认计费模式为按需计费；否则是包周期方式。

func (BssParam) String added in v0.1.24 

func (o BssParam) String() string

type BssParamChargingMode added in v0.1.24 

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

func (BssParamChargingMode) MarshalJSON added in v0.1.24 

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

func (*BssParamChargingMode) UnmarshalJSON added in v0.1.24 

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

func (BssParamChargingMode) Value added in v0.1.24 

func (c BssParamChargingMode) Value() string

type BssParamChargingModeEnum added in v0.1.24 

type BssParamChargingModeEnum struct {
	PRE_PAID  BssParamChargingMode
	POST_PAID BssParamChargingMode
}

func GetBssParamChargingModeEnum added in v0.1.24 

func GetBssParamChargingModeEnum() BssParamChargingModeEnum

type BssParamPeriodType added in v0.1.24 

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

func (BssParamPeriodType) MarshalJSON added in v0.1.24 

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

func (*BssParamPeriodType) UnmarshalJSON added in v0.1.24 

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

func (BssParamPeriodType) Value added in v0.1.24 

func (c BssParamPeriodType) Value() string

type BssParamPeriodTypeEnum added in v0.1.24 

type BssParamPeriodTypeEnum struct {
	MONTH BssParamPeriodType
	YEAR  BssParamPeriodType
}

func GetBssParamPeriodTypeEnum added in v0.1.24 

func GetBssParamPeriodTypeEnum() BssParamPeriodTypeEnum

type CloseKafkaManagerRequest added in v0.1.41 

type CloseKafkaManagerRequest struct {

	// 实例id
	InstanceId string `json:"instance_id"`
}

CloseKafkaManagerRequest Request Object

func (CloseKafkaManagerRequest) String added in v0.1.41 

func (o CloseKafkaManagerRequest) String() string

type CloseKafkaManagerResponse added in v0.1.41 

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

CloseKafkaManagerResponse Response Object

func (CloseKafkaManagerResponse) String added in v0.1.41 

func (o CloseKafkaManagerResponse) String() string

type ConnectorOrderRequestBody added in v0.1.41 

type ConnectorOrderRequestBody struct {

	// 需要关闭connector的实例id，和请求路径上的一致。
	InstanceId string `json:"instance_id"`

	// 提交关闭connector订单后前端跳转的页面
	Url *string `json:"url,omitempty"`
}

func (ConnectorOrderRequestBody) String added in v0.1.41 

func (o ConnectorOrderRequestBody) String() string

type CreateConnectorReq 

type CreateConnectorReq struct {

	// 部署connector的规格，基准带宽，表示单位时间内传送的最大数据量，单位Byte/秒。  取值范围：   - 100MB   - 300MB   - 600MB   - 1200MB  可以不填，则默认跟当前实例的规格是一致。  第一阶段实现先不填，保持和当前实例规格一致，后面再扩展可以选择不同的规格。
	Specification *CreateConnectorReqSpecification `json:"specification,omitempty"`

	// 转储节点数量。不能小于2个。 默认是2个。
	NodeCnt *string `json:"node_cnt,omitempty"`

	// 转储节点规格编码。
	SpecCode string `json:"spec_code"`
}

func (CreateConnectorReq) String 

func (o CreateConnectorReq) String() string

type CreateConnectorReqSpecification 

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

func (CreateConnectorReqSpecification) MarshalJSON 

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

func (*CreateConnectorReqSpecification) UnmarshalJSON 

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

func (CreateConnectorReqSpecification) Value added in v0.0.90 

func (c CreateConnectorReqSpecification) Value() string

type CreateConnectorReqSpecificationEnum 

type CreateConnectorReqSpecificationEnum struct {
	E_100_MB  CreateConnectorReqSpecification
	E_300_MB  CreateConnectorReqSpecification
	E_600_MB  CreateConnectorReqSpecification
	E_1200_MB CreateConnectorReqSpecification
}

func GetCreateConnectorReqSpecificationEnum 

func GetCreateConnectorReqSpecificationEnum() CreateConnectorReqSpecificationEnum

type CreateConnectorRequest 

type CreateConnectorRequest struct {

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

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

CreateConnectorRequest Request Object

func (CreateConnectorRequest) String 

func (o CreateConnectorRequest) String() string

type CreateConnectorResponse 

type CreateConnectorResponse struct {

	// 任务ID。
	JobId *string `json:"job_id,omitempty"`

	// 实例转储ID。
	ConnectorId    *string `json:"connector_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateConnectorResponse Response Object

func (CreateConnectorResponse) String 

func (o CreateConnectorResponse) String() string

type CreateDeleteConnectorOrderRequest added in v0.1.41 

type CreateDeleteConnectorOrderRequest struct {

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

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

CreateDeleteConnectorOrderRequest Request Object

func (CreateDeleteConnectorOrderRequest) String added in v0.1.41 

func (o CreateDeleteConnectorOrderRequest) String() string

type CreateDeleteConnectorOrderResponse added in v0.1.41 

type CreateDeleteConnectorOrderResponse struct {

	// 返回cbc生成的订单id。
	OrderId        *string `json:"order_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateDeleteConnectorOrderResponse Response Object

func (CreateDeleteConnectorOrderResponse) String added in v0.1.41 

func (o CreateDeleteConnectorOrderResponse) String() string

type CreateGroupReq added in v0.1.41 

type CreateGroupReq struct {

	// 消费组名称
	GroupName string `json:"group_name"`

	// 消费组描述
	GroupDesc *string `json:"group_desc,omitempty"`
}

func (CreateGroupReq) String added in v0.1.41 

func (o CreateGroupReq) String() string

type CreateGroupResp added in v0.1.41 

type CreateGroupResp struct {
}

CreateGroupResp 创建结果

func (CreateGroupResp) String added in v0.1.41 

func (o CreateGroupResp) String() string

type CreateInstanceByEngineReq added in v0.1.24 

type CreateInstanceByEngineReq struct {

	// 实例名称。  由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。
	Name string `json:"name"`

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

	// 消息引擎。取值填写为：kafka。
	Engine CreateInstanceByEngineReqEngine `json:"engine"`

	// 消息引擎的版本。取值填写为：   - 1.1.0   [- 2.3.0](tag:g42,tm,hk_g42,ctc,hk_tm)   - 2.7
	EngineVersion string `json:"engine_version"`

	// 代理个数。
	BrokerNum int32 `json:"broker_num"`

	// 消息存储空间，单位GB。   - Kafka实例规格为c6.2u4g.cluster时，存储空间取值范围300GB ~ 300000GB。   - Kafka实例规格为c6.4u8g.cluster时，存储空间取值范围300GB ~ 600000GB。   - Kafka实例规格为c6.8u16g.cluster时，存储空间取值范围300GB ~ [1500000](tag:hws,hws_hk,ocb,hws_ocb)[900000](tag:g42,tm,hk_g42,ctc,hk_tm,hws_eu)GB。   - Kafka实例规格为c6.12u24g.cluster时，存储空间取值范围300GB ~ [1500000](tag:hws,hws_hk,ocb,hws_ocb)[900000](tag:g42,tm,hk_g42,ctc,hk_tm,hws_eu)GB。   - Kafka实例规格为c6.16u32g.cluster时，存储空间取值范围300GB ~ [1500000](tag:hws,hws_hk,ocb,hws_ocb)[900000](tag:g42,tm,hk_g42,ctc,hk_tm,hws_eu)GB。
	StorageSpace int32 `json:"storage_space"`

	// 当ssl_enable为true时，该参数必选，ssl_enable为false时，该参数无效。  认证用户名，只能由英文字母开头且由英文字母、数字、中划线、下划线组成，长度为4~64的字符。
	AccessUser *string `json:"access_user,omitempty"`

	// 当ssl_enable为true时，该参数必选，ssl_enable为false时，该参数无效。  实例的认证密码。  复杂度要求： - 输入长度为8到32位的字符串。 - 必须包含如下四种字符中的两种组合：   - 小写字母   - 大写字母   - 数字   - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）
	Password *string `json:"password,omitempty"`

	// 虚拟私有云ID。  获取方法如下：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。
	VpcId string `json:"vpc_id"`

	// 指定实例所属的安全组。  获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。
	SecurityGroupId string `json:"security_group_id"`

	// 子网信息。  获取方法如下：登录虚拟私有云服务的控制台界面，单击VPC下的子网，进入子网详情页面，查找网络ID。
	SubnetId string `json:"subnet_id"`

	// 创建节点到指定且有资源的可用区ID。请参考[查询可用区信息](ListAvailableZones.xml)获取可用区ID。  该参数不能为空数组或者数组的值为空。  创建Kafka实例，支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时，用逗号分隔开。
	AvailableZones []string `json:"available_zones"`

	// 产品ID。  产品ID可以从[查询产品规格列表](ListEngineProducts.xml)获取。
	ProductId string `json:"product_id"`

	// 表示登录Kafka Manager的用户名。只能由英文字母、数字、中划线组成，长度为4~64的字符。
	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`

	// 表示登录Kafka Manager的密码。  复杂度要求：   - 输入长度为8到32位的字符串。   - 必须包含如下四种字符中的两种组合：       - 小写字母       - 大写字母       - 数字       - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）
	KafkaManagerPassword *string `json:"kafka_manager_password,omitempty"`

	// 维护时间窗开始时间，格式为HH:mm。 - 维护时间窗开始和结束时间必须为指定的时间段。 - 开始时间必须为22:00、02:00、06:00、10:00、14:00和18:00。 - 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm。 - 维护时间窗开始和结束时间必须为指定的时间段。 - 结束时间在开始时间基础上加四个小时，即当开始时间为22:00时，结束时间为02:00。 - 该参数不能单独为空，若该值为空，则开始时间也为空，系统分配一个默认结束时间06:00。
	MaintainEnd *string `json:"maintain_end,omitempty"`

	// 是否开启公网访问功能。默认不开启公网。 - true：开启 - false：不开启
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// 实例绑定的弹性IP地址的ID。  以英文逗号隔开多个弹性IP地址的ID。  如果开启了公网访问功能（即enable_publicip为true），该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 是否打开SSL加密访问。  实例创建后将不支持动态开启和关闭。  - true：打开SSL加密访问。 - false：不打开SSL加密访问。
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 开启SASL后使用的安全协议，如果开启了SASL认证功能（即ssl_enable=true），该字段为必选。  若该字段值为空，默认开启SASL_SSL认证机制。  实例创建后将不支持动态开启和关闭。  - SASL_SSL: 采用SSL证书进行加密传输，支持帐号密码认证，安全性更高。 - SASL_PLAINTEXT: 明文传输，支持帐号密码认证，性能更好，仅支持SCRAM-SHA-512机制。
	KafkaSecurityProtocol *string `json:"kafka_security_protocol,omitempty"`

	// 开启SASL后使用的认证机制，如果开启了SASL认证功能（即ssl_enable=true），该字段为必选。  若该字段值为空，默认开启PLAIN认证机制。  选择其一进行SASL认证即可，支持同时开启两种认证机制。 取值如下： - PLAIN: 简单的用户名密码校验。 - SCRAM-SHA-512: 用户凭证校验，安全性比PLAIN机制更高。
	SaslEnabledMechanisms *[]CreateInstanceByEngineReqSaslEnabledMechanisms `json:"sasl_enabled_mechanisms,omitempty"`

	// 磁盘的容量到达容量阈值后，对于消息的处理策略。  取值如下： - produce_reject：表示拒绝消息写入。 - time_base：表示自动删除最老消息。
	RetentionPolicy *CreateInstanceByEngineReqRetentionPolicy `json:"retention_policy,omitempty"`

	// 是否开启磁盘加密。
	DiskEncryptedEnable *bool `json:"disk_encrypted_enable,omitempty"`

	// 磁盘加密key，未开启磁盘加密时为空
	DiskEncryptedKey *string `json:"disk_encrypted_key,omitempty"`

	// 是否开启消息转储功能。  默认不开启消息转储。
	ConnectorEnable *bool `json:"connector_enable,omitempty"`

	// 是否打开kafka自动创建topic功能。 - true：开启 - false：关闭  当您选择开启，表示生产或消费一个未创建的Topic时，会自动创建一个包含3个分区和3个副本的Topic。  默认是false关闭。
	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`

	// 存储IO规格。  取值范围：   - dms.physical.storage.high.v2：使用高IO的磁盘类型。   - dms.physical.storage.ultra.v2：使用超高IO的磁盘类型。  如何选择磁盘类型请参考《云硬盘 [产品介绍](tag:hws,hws_hk,hws_eu,cmcc)[用户指南](tag:otc,g42,hk_g42,ctc,tm,hk_tm,sbc,ocb,hws_ocb)》的“磁盘类型及性能介绍”。
	StorageSpecCode CreateInstanceByEngineReqStorageSpecCode `json:"storage_spec_code"`

	// 企业项目ID。若为企业项目帐号，该参数必填。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

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

	// CPU架构。当前只支持X86架构。  取值范围：   - X86
	ArchType *string `json:"arch_type,omitempty"`

	// VPC内网明文访问。
	VpcClientPlain *bool `json:"vpc_client_plain,omitempty"`

	BssParam *BssParam `json:"bss_param,omitempty"`
}

CreateInstanceByEngineReq 创建实例请求体。

func (CreateInstanceByEngineReq) String added in v0.1.24 

func (o CreateInstanceByEngineReq) String() string

type CreateInstanceByEngineReqEngine added in v0.1.24 

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

func (CreateInstanceByEngineReqEngine) MarshalJSON added in v0.1.24 

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

func (*CreateInstanceByEngineReqEngine) UnmarshalJSON added in v0.1.24 

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

func (CreateInstanceByEngineReqEngine) Value added in v0.1.24 

func (c CreateInstanceByEngineReqEngine) Value() string

type CreateInstanceByEngineReqEngineEnum added in v0.1.24 

type CreateInstanceByEngineReqEngineEnum struct {
	KAFKA CreateInstanceByEngineReqEngine
}

func GetCreateInstanceByEngineReqEngineEnum added in v0.1.24 

func GetCreateInstanceByEngineReqEngineEnum() CreateInstanceByEngineReqEngineEnum

type CreateInstanceByEngineReqRetentionPolicy added in v0.1.24 

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

func (CreateInstanceByEngineReqRetentionPolicy) MarshalJSON added in v0.1.24 

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

func (*CreateInstanceByEngineReqRetentionPolicy) UnmarshalJSON added in v0.1.24 

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

func (CreateInstanceByEngineReqRetentionPolicy) Value added in v0.1.24 

func (c CreateInstanceByEngineReqRetentionPolicy) Value() string

type CreateInstanceByEngineReqRetentionPolicyEnum added in v0.1.24 

type CreateInstanceByEngineReqRetentionPolicyEnum struct {
	TIME_BASE      CreateInstanceByEngineReqRetentionPolicy
	PRODUCE_REJECT CreateInstanceByEngineReqRetentionPolicy
}

func GetCreateInstanceByEngineReqRetentionPolicyEnum added in v0.1.24 

func GetCreateInstanceByEngineReqRetentionPolicyEnum() CreateInstanceByEngineReqRetentionPolicyEnum

type CreateInstanceByEngineReqSaslEnabledMechanisms added in v0.1.38 

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

func (CreateInstanceByEngineReqSaslEnabledMechanisms) MarshalJSON added in v0.1.38 

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

func (*CreateInstanceByEngineReqSaslEnabledMechanisms) UnmarshalJSON added in v0.1.38 

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

func (CreateInstanceByEngineReqSaslEnabledMechanisms) Value added in v0.1.38 

func (c CreateInstanceByEngineReqSaslEnabledMechanisms) Value() string

type CreateInstanceByEngineReqSaslEnabledMechanismsEnum added in v0.1.38 

type CreateInstanceByEngineReqSaslEnabledMechanismsEnum struct {
	PLAIN         CreateInstanceByEngineReqSaslEnabledMechanisms
	SCRAM_SHA_512 CreateInstanceByEngineReqSaslEnabledMechanisms
}

func GetCreateInstanceByEngineReqSaslEnabledMechanismsEnum added in v0.1.38 

func GetCreateInstanceByEngineReqSaslEnabledMechanismsEnum() CreateInstanceByEngineReqSaslEnabledMechanismsEnum

type CreateInstanceByEngineReqStorageSpecCode added in v0.1.24 

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

func (CreateInstanceByEngineReqStorageSpecCode) MarshalJSON added in v0.1.24 

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

func (*CreateInstanceByEngineReqStorageSpecCode) UnmarshalJSON added in v0.1.24 

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

func (CreateInstanceByEngineReqStorageSpecCode) Value added in v0.1.24 

func (c CreateInstanceByEngineReqStorageSpecCode) Value() string

type CreateInstanceByEngineReqStorageSpecCodeEnum added in v0.1.24 

type CreateInstanceByEngineReqStorageSpecCodeEnum struct {
	DMS_PHYSICAL_STORAGE_HIGH_V2  CreateInstanceByEngineReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_ULTRA_V2 CreateInstanceByEngineReqStorageSpecCode
}

func GetCreateInstanceByEngineReqStorageSpecCodeEnum added in v0.1.24 

func GetCreateInstanceByEngineReqStorageSpecCodeEnum() CreateInstanceByEngineReqStorageSpecCodeEnum

type CreateInstanceByEngineRequest added in v0.1.24 

type CreateInstanceByEngineRequest struct {

	// 消息引擎。
	Engine CreateInstanceByEngineRequestEngine `json:"engine"`

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

CreateInstanceByEngineRequest Request Object

func (CreateInstanceByEngineRequest) String added in v0.1.24 

func (o CreateInstanceByEngineRequest) String() string

type CreateInstanceByEngineRequestEngine added in v0.1.24 

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

func (CreateInstanceByEngineRequestEngine) MarshalJSON added in v0.1.24 

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

func (*CreateInstanceByEngineRequestEngine) UnmarshalJSON added in v0.1.24 

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

func (CreateInstanceByEngineRequestEngine) Value added in v0.1.24 

func (c CreateInstanceByEngineRequestEngine) Value() string

type CreateInstanceByEngineRequestEngineEnum added in v0.1.24 

type CreateInstanceByEngineRequestEngineEnum struct {
	KAFKA CreateInstanceByEngineRequestEngine
}

func GetCreateInstanceByEngineRequestEngineEnum added in v0.1.24 

func GetCreateInstanceByEngineRequestEngineEnum() CreateInstanceByEngineRequestEngineEnum

type CreateInstanceByEngineResponse added in v0.1.24 

type CreateInstanceByEngineResponse struct {

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

CreateInstanceByEngineResponse Response Object

func (CreateInstanceByEngineResponse) String added in v0.1.24 

func (o CreateInstanceByEngineResponse) String() string

type CreateInstanceTopicReq 

type CreateInstanceTopicReq struct {

	// topic名称，长度为4-64，以字母开头且只支持大小写字母、中横线、下划线、点以及数字。
	Id string `json:"id"`

	// 副本数，配置数据的可靠性。 取值范围：1-3。
	Replication *int32 `json:"replication,omitempty"`

	// 是否使用同步落盘。默认值为false。同步落盘会导致性能降低。
	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`

	// topic分区数，设置消费的并发数。 取值范围：[1-100](tag:hws,hws_hk,otc,hws_ocb,ctc,sbc,hk_sbc,g42,tm,hk_g42,hk_tm)[1-20](tag:cmcc)。
	Partition *int32 `json:"partition,omitempty"`

	// 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效，默认关闭。
	SyncReplication *bool `json:"sync_replication,omitempty"`

	// 消息老化时间。默认值为72。 取值范围[1~168](tag:hws,hws_hk,hws_ocb,ctc,sbc,hk_sbc,hws_eu,g42,tm,hk_g42,hk_tm)[1-720](tag:ocb,otc)，单位小时。
	RetentionTime *int32 `json:"retention_time,omitempty"`

	// topic配置
	TopicOtherConfigs *[]CreateInstanceTopicReqTopicOtherConfigs `json:"topic_other_configs,omitempty"`

	// topic描述
	TopicDesc *string `json:"topic_desc,omitempty"`
}

func (CreateInstanceTopicReq) String 

func (o CreateInstanceTopicReq) String() string

type CreateInstanceTopicReqTopicOtherConfigs added in v0.1.49 

type CreateInstanceTopicReqTopicOtherConfigs struct {

	// 配置名称
	Name *string `json:"name,omitempty"`

	// 配置值
	Value *string `json:"value,omitempty"`
}

func (CreateInstanceTopicReqTopicOtherConfigs) String added in v0.1.49 

func (o CreateInstanceTopicReqTopicOtherConfigs) String() string

type CreateInstanceTopicRequest 

type CreateInstanceTopicRequest struct {

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

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

CreateInstanceTopicRequest Request Object

func (CreateInstanceTopicRequest) String 

func (o CreateInstanceTopicRequest) String() string

type CreateInstanceTopicResponse 

type CreateInstanceTopicResponse struct {

	// topic名称。
	Id *string `json:"id,omitempty"`

	// topic名称。
	Name           *string `json:"name,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateInstanceTopicResponse Response Object

func (CreateInstanceTopicResponse) String 

func (o CreateInstanceTopicResponse) String() string

type CreateInstanceUserReq 

type CreateInstanceUserReq struct {

	// 用户名称。
	UserName *string `json:"user_name,omitempty"`

	// 用户描述。
	UserDesc *string `json:"user_desc,omitempty"`

	// 用户密码。  密码不能和用户名相同。 复杂度要求： - 输入长度为8到32位的字符串。 - 必须包含如下四种字符中的两种组合：   - 小写字母   - 大写字母   - 数字   - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）
	UserPasswd *string `json:"user_passwd,omitempty"`
}

func (CreateInstanceUserReq) String 

func (o CreateInstanceUserReq) String() string

type CreateInstanceUserRequest 

type CreateInstanceUserRequest struct {

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

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

CreateInstanceUserRequest Request Object

func (CreateInstanceUserRequest) String 

func (o CreateInstanceUserRequest) String() string

type CreateInstanceUserResponse 

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

CreateInstanceUserResponse Response Object

func (CreateInstanceUserResponse) String 

func (o CreateInstanceUserResponse) String() string

type CreateKafkaConsumerGroupRequest added in v0.1.41 

type CreateKafkaConsumerGroupRequest struct {

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

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

CreateKafkaConsumerGroupRequest Request Object

func (CreateKafkaConsumerGroupRequest) String added in v0.1.41 

func (o CreateKafkaConsumerGroupRequest) String() string

type CreateKafkaConsumerGroupResponse added in v0.1.41 

type CreateKafkaConsumerGroupResponse struct {

	// 创建结果
	Body           *string `json:"body,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateKafkaConsumerGroupResponse Response Object

func (CreateKafkaConsumerGroupResponse) String added in v0.1.41 

func (o CreateKafkaConsumerGroupResponse) String() string

type CreateKafkaUserClientQuotaTaskReq added in v0.1.68 

type CreateKafkaUserClientQuotaTaskReq struct {

	// 用户名
	User *string `json:"user,omitempty"`

	// 客户端ID
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置（是则表示对全部用户限流）。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置（是则表示对全部客户端限流）。
	ClientDefault *bool `json:"client-default,omitempty"`

	// 生产上限速率（单位为B/s）
	ProducerByteRate *int64 `json:"producer-byte-rate,omitempty"`

	// 消费上限速率（单位为B/s）
	ConsumerByteRate *int64 `json:"consumer-byte-rate,omitempty"`
}

CreateKafkaUserClientQuotaTaskReq 客户端流控配置

func (CreateKafkaUserClientQuotaTaskReq) String added in v0.1.68 

func (o CreateKafkaUserClientQuotaTaskReq) String() string

type CreateKafkaUserClientQuotaTaskRequest added in v0.1.68 

type CreateKafkaUserClientQuotaTaskRequest struct {

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

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

CreateKafkaUserClientQuotaTaskRequest Request Object

func (CreateKafkaUserClientQuotaTaskRequest) String added in v0.1.68 

func (o CreateKafkaUserClientQuotaTaskRequest) String() string

type CreateKafkaUserClientQuotaTaskResponse added in v0.1.68 

type CreateKafkaUserClientQuotaTaskResponse struct {

	// 创建流控配置的任务ID
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

CreateKafkaUserClientQuotaTaskResponse Response Object

func (CreateKafkaUserClientQuotaTaskResponse) String added in v0.1.68 

func (o CreateKafkaUserClientQuotaTaskResponse) String() string

type CreatePartitionReq 

type CreatePartitionReq struct {

	// 期望调整分区后的数量，必须大于当前分区数量，小于等于 [100](tag:hws,hws_hk,otc,hws_ocb,ctc,sbc,hk_sbc,g42,tm,hk_g42,hk_tm)[20](tag:cmcc)。
	Partition *int32 `json:"partition,omitempty"`
}

func (CreatePartitionReq) String 

func (o CreatePartitionReq) String() string

type CreatePartitionRequest 

type CreatePartitionRequest struct {

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

	// Topic名称。
	Topic string `json:"topic"`

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

CreatePartitionRequest Request Object

func (CreatePartitionRequest) String 

func (o CreatePartitionRequest) String() string

type CreatePartitionResponse 

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

CreatePartitionResponse Response Object

func (CreatePartitionResponse) String 

func (o CreatePartitionResponse) String() string

type CreatePostPaidInstanceReq 

type CreatePostPaidInstanceReq struct {

	// 实例名称。  由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。
	Name string `json:"name"`

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

	// 消息引擎。取值填写为：kafka。
	Engine CreatePostPaidInstanceReqEngine `json:"engine"`

	// 消息引擎的版本。取值填写为：   - 1.1.0   [- 2.3.0](tag:ocb,hws_ocb,sbc,hk_sbc,cmcc,hws_eu,otc,ctc,g42,hk_g42,tm,hk_tm)   - 2.7
	EngineVersion string `json:"engine_version"`

	//  [新规格实例：Kafka实例业务TPS规格，取值范围：   - c6.2u4g.cluster   - c6.4u8g.cluster   - c6.8u16g.cluster   - c6.12u24g.cluster   - c6.16u32g.cluster  老规格实例：](tag:hc,hk) Kafka实例的基准带宽，表示单位时间内传送的最大数据量，单位MB。取值范围：   - 100MB   - 300MB   - 600MB   - 1200MB  注：此参数无需设置，其取值实际是由产品ID（product_id）决定。
	Specification *CreatePostPaidInstanceReqSpecification `json:"specification,omitempty"`

	// 代理个数。 [取值范围:  - 老规格实例此参数无需设置  - 新规格必须设置，取值范围：3 ~ 30。](tag:hws,hws_hk,g42,tm,hk_g42,hk_tm,ctc) [此参数无需设置](tag:otc,ocb,hws_ocb,sbc,hk_sbc,cmcc)
	BrokerNum *int32 `json:"broker_num,omitempty"`

	// 消息存储空间，单位GB。   - Kafka实例规格为100MB时，存储空间取值范围600GB ~ 90000GB。   - Kafka实例规格为300MB时，存储空间取值范围1200GB ~ 90000GB。   - Kafka实例规格为600MB时，存储空间取值范围2400GB ~ 90000GB。   - Kafka实例规格为1200MB，存储空间取值范围4800GB ~ 90000GB   [- Kafka实例规格为c6.2u4g.cluster时，存储空间取值范围300GB ~ 300000GB。   - Kafka实例规格为c6.4u8g.cluster时，存储空间取值范围300GB ~ 600000GB。   - Kafka实例规格为c6.8u16g.cluster时，存储空间取值范围300GB ~ 900000GB。   - Kafka实例规格为c6.12u24g.cluster时，存储空间取值范围300GB ~ 900000GB。   - Kafka实例规格为c6.16u32g.cluster时，存储空间取值范围300GB ~ 900000GB。](tag:hc,hk)
	StorageSpace int32 `json:"storage_space"`

	// Kafka实例的最大分区数量。   - 参数specification为100MB时，取值300   - 参数specification为300MB时，取值900   - 参数specification为600MB时，取值1800   - 参数specification为1200MB时，取值1800    [新规格实例此参数无需设置，每种规格对应的分区数上限参考：https://support.huaweicloud.com/productdesc-kafka/Kafka-specification.html](tag:hws)   [新规格实例此参数无需设置，每种规格对应的分区数上限参考：https://support.huaweicloud.com/intl/zh-cn/productdesc-kafka/Kafka-specification.html](tag:hws_hk)
	PartitionNum *CreatePostPaidInstanceReqPartitionNum `json:"partition_num,omitempty"`

	// 当ssl_enable为true时，该参数必选，ssl_enable为false时，该参数无效。  认证用户名，只能由英文字母、数字、中划线组成，长度为4~64的字符。
	AccessUser *string `json:"access_user,omitempty"`

	// 当ssl_enable为true时，该参数必选，ssl_enable为false时，该参数无效。  实例的认证密码。  复杂度要求： - 输入长度为8到32位的字符串。 - 必须包含如下四种字符中的两种组合：   - 小写字母   - 大写字母   - 数字   - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）
	Password *string `json:"password,omitempty"`

	// 虚拟私有云ID。  获取方法如下：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。
	VpcId string `json:"vpc_id"`

	// 指定实例所属的安全组。  获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。
	SecurityGroupId string `json:"security_group_id"`

	// 子网信息。  获取方法如下：登录虚拟私有云服务的控制台界面，单击VPC下的子网，进入子网详情页面，查找网络ID。
	SubnetId string `json:"subnet_id"`

	// 创建节点到指定且有资源的可用区ID。请参考[查询可用区信息](ListAvailableZones.xml)获取可用区ID。  该参数不能为空数组或者数组的值为空。 创建Kafka实例，支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时，用逗号分隔开。
	AvailableZones []string `json:"available_zones"`

	// 产品ID。  [产品ID可以从[查询产品规格列表](ListEngineProducts.xml)获取。](tag:hws,hws_hk,ctc,sbc,hk_sbc,cmcc,hws_eu,g42,tm,hk_g42,hk_tm,ocb,hws_ocb)  [创建kafka实例,支持的产品规格有: (product_id/specification/partition_num/storage_space)  00300-30308-0--0/100MB/300/600;  00300-30310-0--0/300MB/900/1200;  00300-30312-0--0/600MB/1800/2400;  00300-30314-0--0/1200MB/1800/4800](tag:otc,dt)
	ProductId string `json:"product_id"`

	// 表示登录Kafka Manager的用户名。只能由英文字母、数字、中划线组成，长度为4~64的字符。
	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`

	// 表示登录Kafka Manager的密码。  复杂度要求：   - 输入长度为8到32位的字符串。   - 必须包含如下四种字符中的两种组合：       - 小写字母       - 大写字母       - 数字       - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）
	KafkaManagerPassword *string `json:"kafka_manager_password,omitempty"`

	// 维护时间窗开始时间，格式为HH:mm。 - 维护时间窗开始和结束时间必须为指定的时间段。 - 开始时间必须为22:00、02:00、06:00、10:00、14:00和18:00。 - 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm。 - 维护时间窗开始和结束时间必须为指定的时间段。 - 结束时间在开始时间基础上加四个小时，即当开始时间为22:00时，结束时间为02:00。 - 该参数不能单独为空，若该值为空，则开始时间也为空，系统分配一个默认结束时间06:00。
	MaintainEnd *string `json:"maintain_end,omitempty"`

	// 是否开启公网访问功能。默认不开启公网。 - true：开启 - false：不开启
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// 表示公网带宽，单位是Mbit/s。  [取值范围：  - Kafka实例规格为100MB时，公网带宽取值范围3到900，且必须为实例节点个数的倍数。  - Kafka实例规格为300MB时，公网带宽取值范围3到900，且必须为实例节点个数的倍数。  - Kafka实例规格为600MB时，公网带宽取值范围4到1200，且必须为实例节点个数的倍数。  - Kafka实例规格为1200MB时，公网带宽取值范围8到2400，且必须为实例节点个数的倍数。](tag:hws,hws_hk,otc,ocb,hws_ocb,ctc,sbc,hk_sbc,cmcc,g42,tm,hk_g42,hk_tm)   [老规格实例取值范围：  - Kafka实例规格为100MB时，公网带宽取值范围3到900，且必须为实例节点个数的倍数。  - Kafka实例规格为300MB时，公网带宽取值范围3到900，且必须为实例节点个数的倍数。  - Kafka实例规格为600MB时，公网带宽取值范围4到1200，且必须为实例节点个数的倍数。  - Kafka实例规格为1200MB时，公网带宽取值范围8到2400，且必须为实例节点个数的倍数。   新规格实例取值范围：  - Kafka实例规格为c6.2u4g.cluster时，公网带宽取值范围3到250，且必须为实例节点个数的倍数。  - Kafka实例规格为c6.4u8g.cluster时，公网带宽取值范围3到500，且必须为实例节点个数的倍数。  - Kafka实例规格为c6.8u16g.cluster时，公网带宽取值范围4到1000，且必须为实例节点个数的倍数。  - Kafka实例规格为c6.12u24g.cluster时，公网带宽取值范围8到1500，且必须为实例节点个数的倍数。  - Kafka实例规格为c6.16u32g.cluster时，公网带宽取值范围8到2000，且必须为实例节点个数的倍数。](tag:hc,hk)
	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`

	// 实例绑定的弹性IP地址的ID。  以英文逗号隔开多个弹性IP地址的ID。  如果开启了公网访问功能（即enable_publicip为true），该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 是否打开SSL加密访问。  实例创建后将不支持动态开启和关闭。  - true：打开SSL加密访问。 - false：不打开SSL加密访问。
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 开启SASL后使用的安全协议，如果开启了SASL认证功能（即ssl_enable=true），该字段为必选。  若该字段值为空，默认开启SASL_SSL认证机制。  实例创建后将不支持动态开启和关闭。  - SASL_SSL: 采用SSL证书进行加密传输，支持帐号密码认证，安全性更高。 - SASL_PLAINTEXT: 明文传输，支持帐号密码认证，性能更好，仅支持SCRAM-SHA-512机制。
	KafkaSecurityProtocol *string `json:"kafka_security_protocol,omitempty"`

	// 开启SASL后使用的认证机制，如果开启了SASL认证功能（即ssl_enable=true），该字段为必选。  若该字段值为空，默认开启PLAIN认证机制。  选择其一进行SASL认证即可，支持同时开启两种认证机制。 取值如下： - PLAIN: 简单的用户名密码校验。 - SCRAM-SHA-512: 用户凭证校验，安全性比PLAIN机制更高。
	SaslEnabledMechanisms *[]CreatePostPaidInstanceReqSaslEnabledMechanisms `json:"sasl_enabled_mechanisms,omitempty"`

	// 磁盘的容量到达容量阈值后，对于消息的处理策略。  取值如下： - produce_reject：表示拒绝消息写入。 - time_base：表示自动删除最老消息。
	RetentionPolicy *CreatePostPaidInstanceReqRetentionPolicy `json:"retention_policy,omitempty"`

	// 是否开启磁盘加密。
	DiskEncryptedEnable *bool `json:"disk_encrypted_enable,omitempty"`

	// 磁盘加密key，未开启磁盘加密时为空
	DiskEncryptedKey *string `json:"disk_encrypted_key,omitempty"`

	// 是否开启消息转储功能。  默认不开启消息转储。
	ConnectorEnable *bool `json:"connector_enable,omitempty"`

	// 是否打开kafka自动创建topic功能。 - true：开启 - false：关闭  当您选择开启，表示生产或消费一个未创建的Topic时，会自动创建一个包含3个分区和3个副本的Topic。  默认是false关闭。
	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`

	// 存储IO规格。 [新老规格的实例的存储IO规格不相同，创建实例请选择对应的存储IO规格。 新规格实例取值范围：   - dms.physical.storage.high.v2：使用高IO的磁盘类型。   - dms.physical.storage.ultra.v2：使用超高IO的磁盘类型。  老规格实例取值范围：](tag:hc,hk)   - 参数specification为100MB/300MB时，取值dms.physical.storage.high或者dms.physical.storage.ultra   - 参数specification为600MB/1200MB时，取值dms.physical.storage.ultra  如何选择磁盘类型请参考《云硬盘 [产品介绍](tag:hws,hws_hk,hws_eu,cmcc)[用户指南](tag:otc,g42,hk_g42,ctc,tm,hk_tm,sbc,ocb,hws_ocb)》的“磁盘类型及性能介绍”。
	StorageSpecCode CreatePostPaidInstanceReqStorageSpecCode `json:"storage_spec_code"`

	// 企业项目ID。若为企业项目帐号，该参数必填。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

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

CreatePostPaidInstanceReq 创建实例请求体。

func (CreatePostPaidInstanceReq) String 

func (o CreatePostPaidInstanceReq) String() string

type CreatePostPaidInstanceReqEngine 

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

func (CreatePostPaidInstanceReqEngine) MarshalJSON 

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

func (*CreatePostPaidInstanceReqEngine) UnmarshalJSON 

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

func (CreatePostPaidInstanceReqEngine) Value added in v0.0.90 

func (c CreatePostPaidInstanceReqEngine) Value() string

type CreatePostPaidInstanceReqEngineEnum 

type CreatePostPaidInstanceReqEngineEnum struct {
	KAFKA CreatePostPaidInstanceReqEngine
}

func GetCreatePostPaidInstanceReqEngineEnum 

func GetCreatePostPaidInstanceReqEngineEnum() CreatePostPaidInstanceReqEngineEnum

type CreatePostPaidInstanceReqPartitionNum 

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

func (CreatePostPaidInstanceReqPartitionNum) MarshalJSON 

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

func (*CreatePostPaidInstanceReqPartitionNum) UnmarshalJSON 

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

func (CreatePostPaidInstanceReqPartitionNum) Value added in v0.0.90 

func (c CreatePostPaidInstanceReqPartitionNum) Value() int32

type CreatePostPaidInstanceReqPartitionNumEnum 

type CreatePostPaidInstanceReqPartitionNumEnum struct {
	E_250  CreatePostPaidInstanceReqPartitionNum
	E_300  CreatePostPaidInstanceReqPartitionNum
	E_500  CreatePostPaidInstanceReqPartitionNum
	E_900  CreatePostPaidInstanceReqPartitionNum
	E_1000 CreatePostPaidInstanceReqPartitionNum
	E_1500 CreatePostPaidInstanceReqPartitionNum
	E_1800 CreatePostPaidInstanceReqPartitionNum
	E_2000 CreatePostPaidInstanceReqPartitionNum
}

func GetCreatePostPaidInstanceReqPartitionNumEnum 

func GetCreatePostPaidInstanceReqPartitionNumEnum() CreatePostPaidInstanceReqPartitionNumEnum

type CreatePostPaidInstanceReqRetentionPolicy 

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

func (CreatePostPaidInstanceReqRetentionPolicy) MarshalJSON 

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

func (*CreatePostPaidInstanceReqRetentionPolicy) UnmarshalJSON 

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

func (CreatePostPaidInstanceReqRetentionPolicy) Value added in v0.0.90 

func (c CreatePostPaidInstanceReqRetentionPolicy) Value() string

type CreatePostPaidInstanceReqRetentionPolicyEnum 

type CreatePostPaidInstanceReqRetentionPolicyEnum struct {
	TIME_BASE      CreatePostPaidInstanceReqRetentionPolicy
	PRODUCE_REJECT CreatePostPaidInstanceReqRetentionPolicy
}

func GetCreatePostPaidInstanceReqRetentionPolicyEnum 

func GetCreatePostPaidInstanceReqRetentionPolicyEnum() CreatePostPaidInstanceReqRetentionPolicyEnum

type CreatePostPaidInstanceReqSaslEnabledMechanisms added in v0.1.18 

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

func (CreatePostPaidInstanceReqSaslEnabledMechanisms) MarshalJSON added in v0.1.18 

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

func (*CreatePostPaidInstanceReqSaslEnabledMechanisms) UnmarshalJSON added in v0.1.18 

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

func (CreatePostPaidInstanceReqSaslEnabledMechanisms) Value added in v0.1.18 

func (c CreatePostPaidInstanceReqSaslEnabledMechanisms) Value() string

type CreatePostPaidInstanceReqSaslEnabledMechanismsEnum added in v0.1.18 

type CreatePostPaidInstanceReqSaslEnabledMechanismsEnum struct {
	PLAIN         CreatePostPaidInstanceReqSaslEnabledMechanisms
	SCRAM_SHA_512 CreatePostPaidInstanceReqSaslEnabledMechanisms
}

func GetCreatePostPaidInstanceReqSaslEnabledMechanismsEnum added in v0.1.18 

func GetCreatePostPaidInstanceReqSaslEnabledMechanismsEnum() CreatePostPaidInstanceReqSaslEnabledMechanismsEnum

type CreatePostPaidInstanceReqSpecification 

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

func (CreatePostPaidInstanceReqSpecification) MarshalJSON 

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

func (*CreatePostPaidInstanceReqSpecification) UnmarshalJSON 

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

func (CreatePostPaidInstanceReqSpecification) Value added in v0.0.90 

func (c CreatePostPaidInstanceReqSpecification) Value() string

type CreatePostPaidInstanceReqSpecificationEnum 

type CreatePostPaidInstanceReqSpecificationEnum struct {
	E_100_MB          CreatePostPaidInstanceReqSpecification
	E_300_MB          CreatePostPaidInstanceReqSpecification
	E_600_MB          CreatePostPaidInstanceReqSpecification
	E_1200_MB         CreatePostPaidInstanceReqSpecification
	C6_2U4G_CLUSTER   CreatePostPaidInstanceReqSpecification
	C6_4U8G_CLUSTER   CreatePostPaidInstanceReqSpecification
	C6_8U16G_CLUSTER  CreatePostPaidInstanceReqSpecification
	C6_12U24G_CLUSTER CreatePostPaidInstanceReqSpecification
	C6_16U32G_CLUSTER CreatePostPaidInstanceReqSpecification
}

func GetCreatePostPaidInstanceReqSpecificationEnum 

func GetCreatePostPaidInstanceReqSpecificationEnum() CreatePostPaidInstanceReqSpecificationEnum

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
	DMS_PHYSICAL_STORAGE_NORMAL   CreatePostPaidInstanceReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_HIGH     CreatePostPaidInstanceReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_ULTRA    CreatePostPaidInstanceReqStorageSpecCode
}

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum 

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum() CreatePostPaidInstanceReqStorageSpecCodeEnum

type CreatePostPaidInstanceRequest 

type CreatePostPaidInstanceRequest struct {
	Body *CreatePostPaidInstanceReq `json:"body,omitempty"`
}

CreatePostPaidInstanceRequest Request Object

func (CreatePostPaidInstanceRequest) String 

func (o CreatePostPaidInstanceRequest) String() string

type CreatePostPaidInstanceResponse 

type CreatePostPaidInstanceResponse struct {

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

CreatePostPaidInstanceResponse Response Object

func (CreatePostPaidInstanceResponse) String 

func (o CreatePostPaidInstanceResponse) String() string

type CreateReassignmentTaskRequest added in v0.1.24 

type CreateReassignmentTaskRequest struct {

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

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

CreateReassignmentTaskRequest Request Object

func (CreateReassignmentTaskRequest) String added in v0.1.24 

func (o CreateReassignmentTaskRequest) String() string

type CreateReassignmentTaskResponse added in v0.1.24 

type CreateReassignmentTaskResponse struct {

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

CreateReassignmentTaskResponse Response Object

func (CreateReassignmentTaskResponse) String added in v0.1.24 

func (o CreateReassignmentTaskResponse) String() string

type CreateSinkTaskReq 

type CreateSinkTaskReq struct {

	// 源数据类型，目前只支持BLOB。
	SourceType CreateSinkTaskReqSourceType `json:"source_type"`

	// 转储任务名称。
	TaskName string `json:"task_name"`

	// 转存的目标类型，当前只支持OBS。
	DestinationType CreateSinkTaskReqDestinationType `json:"destination_type"`

	ObsDestinationDescriptor *ObsDestinationDescriptor `json:"obs_destination_descriptor"`
}

func (CreateSinkTaskReq) String 

func (o CreateSinkTaskReq) String() string

type CreateSinkTaskReqDestinationType 

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

func (CreateSinkTaskReqDestinationType) MarshalJSON 

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

func (*CreateSinkTaskReqDestinationType) UnmarshalJSON 

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

func (CreateSinkTaskReqDestinationType) Value added in v0.0.90 

func (c CreateSinkTaskReqDestinationType) Value() string

type CreateSinkTaskReqDestinationTypeEnum 

type CreateSinkTaskReqDestinationTypeEnum struct {
	OBS CreateSinkTaskReqDestinationType
}

func GetCreateSinkTaskReqDestinationTypeEnum 

func GetCreateSinkTaskReqDestinationTypeEnum() CreateSinkTaskReqDestinationTypeEnum

type CreateSinkTaskReqSourceType 

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

func (CreateSinkTaskReqSourceType) MarshalJSON 

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

func (*CreateSinkTaskReqSourceType) UnmarshalJSON 

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

func (CreateSinkTaskReqSourceType) Value added in v0.0.90 

func (c CreateSinkTaskReqSourceType) Value() string

type CreateSinkTaskReqSourceTypeEnum 

type CreateSinkTaskReqSourceTypeEnum struct {
	BLOB CreateSinkTaskReqSourceType
}

func GetCreateSinkTaskReqSourceTypeEnum 

func GetCreateSinkTaskReqSourceTypeEnum() CreateSinkTaskReqSourceTypeEnum

type CreateSinkTaskRequest 

type CreateSinkTaskRequest struct {

	// 实例转储ID。  请参考[查询实例](ShowInstance.xml)返回的数据。
	ConnectorId string `json:"connector_id"`

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

CreateSinkTaskRequest Request Object

func (CreateSinkTaskRequest) String 

func (o CreateSinkTaskRequest) String() string

type CreateSinkTaskResponse 

type CreateSinkTaskResponse struct {

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

CreateSinkTaskResponse Response Object

func (CreateSinkTaskResponse) String 

func (o CreateSinkTaskResponse) String() string

type DeleteBackgroundTaskRequest 

type DeleteBackgroundTaskRequest struct {

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

	// 任务ID。
	TaskId string `json:"task_id"`
}

DeleteBackgroundTaskRequest Request Object

func (DeleteBackgroundTaskRequest) String 

func (o DeleteBackgroundTaskRequest) String() string

type DeleteBackgroundTaskResponse 

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

DeleteBackgroundTaskResponse Response Object

func (DeleteBackgroundTaskResponse) String 

func (o DeleteBackgroundTaskResponse) String() string

type DeleteConnectorRequest added in v0.1.41 

type DeleteConnectorRequest struct {

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

DeleteConnectorRequest Request Object

func (DeleteConnectorRequest) String added in v0.1.41 

func (o DeleteConnectorRequest) String() string

type DeleteConnectorResponse added in v0.1.41 

type DeleteConnectorResponse struct {

	// 返回异步执行删除任务的job id。
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteConnectorResponse Response Object

func (DeleteConnectorResponse) String added in v0.1.41 

func (o DeleteConnectorResponse) String() string

type DeleteInstanceRequest 

type DeleteInstanceRequest struct {

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

DeleteInstanceRequest Request Object

func (DeleteInstanceRequest) String 

func (o DeleteInstanceRequest) String() string

type DeleteInstanceResponse 

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

DeleteInstanceResponse Response Object

func (DeleteInstanceResponse) String 

func (o DeleteInstanceResponse) String() string

type DeleteKafkaUserClientQuotaTaskReq added in v0.1.68 

type DeleteKafkaUserClientQuotaTaskReq struct {

	// 用户名
	User *string `json:"user,omitempty"`

	// 客户端ID
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置（是则表示对全部用户限流）。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置（是则表示对全部客户端限流）。
	ClientDefault *bool `json:"client-default,omitempty"`
}

DeleteKafkaUserClientQuotaTaskReq 要删除的客户端流控配置

func (DeleteKafkaUserClientQuotaTaskReq) String added in v0.1.68 

func (o DeleteKafkaUserClientQuotaTaskReq) String() string

type DeleteKafkaUserClientQuotaTaskRequest added in v0.1.68 

type DeleteKafkaUserClientQuotaTaskRequest struct {

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

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

DeleteKafkaUserClientQuotaTaskRequest Request Object

func (DeleteKafkaUserClientQuotaTaskRequest) String added in v0.1.68 

func (o DeleteKafkaUserClientQuotaTaskRequest) String() string

type DeleteKafkaUserClientQuotaTaskResponse added in v0.1.68 

type DeleteKafkaUserClientQuotaTaskResponse struct {

	// 删除流控配置的任务ID
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

DeleteKafkaUserClientQuotaTaskResponse Response Object

func (DeleteKafkaUserClientQuotaTaskResponse) String added in v0.1.68 

func (o DeleteKafkaUserClientQuotaTaskResponse) String() string

type DeleteSinkTaskRequest 

type DeleteSinkTaskRequest struct {

	// 实例转储ID。  请参考[查询实例](ShowInstance.xml)返回的数据。
	ConnectorId string `json:"connector_id"`

	// 转储任务ID。
	TaskId string `json:"task_id"`
}

DeleteSinkTaskRequest Request Object

func (DeleteSinkTaskRequest) String 

func (o DeleteSinkTaskRequest) String() string

type DeleteSinkTaskResponse 

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

DeleteSinkTaskResponse Response Object

func (DeleteSinkTaskResponse) String 

func (o DeleteSinkTaskResponse) String() string

type DiskusageEntity added in v0.0.66 

type DiskusageEntity struct {

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

	// 磁盘容量。
	DataDiskSize *string `json:"data_disk_size,omitempty"`

	// 已使用的磁盘容量。
	DataDiskUse *string `json:"data_disk_use,omitempty"`

	// 剩余可用的磁盘容量。
	DataDiskFree *string `json:"data_disk_free,omitempty"`

	// 消息标签。
	DataDiskUsePercentage *string `json:"data_disk_use_percentage,omitempty"`

	// 消息标签。
	Status *string `json:"status,omitempty"`

	// topic磁盘容量使用列表。
	TopicList *[]DiskusageTopicEntity `json:"topic_list,omitempty"`
}

func (DiskusageEntity) String added in v0.0.66 

func (o DiskusageEntity) String() string

type DiskusageTopicEntity added in v0.0.66 

type DiskusageTopicEntity struct {

	// 磁盘使用量。
	Size *string `json:"size,omitempty"`

	// topic名称。
	TopicName *string `json:"topic_name,omitempty"`

	// 分区。
	TopicPartition *string `json:"topic_partition,omitempty"`

	// 磁盘使用量的占比。
	Percentage *float64 `json:"percentage,omitempty"`
}

func (DiskusageTopicEntity) String added in v0.0.66 

func (o DiskusageTopicEntity) String() string

type ExtendProductInfoEntity added in v0.1.24 

type ExtendProductInfoEntity struct {

	// 实例类型。
	Type *string `json:"type,omitempty"`

	// 产品ID。
	ProductId *string `json:"product_id,omitempty"`

	// 该产品使用的ECS规格。
	EcsFlavorId *string `json:"ecs_flavor_id,omitempty"`

	// 支持的CPU架构类型。
	ArchTypes *[]string `json:"arch_types,omitempty"`

	// 支持的计费模式类型。
	ChargingMode *[]string `json:"charging_mode,omitempty"`

	// 磁盘IO信息。
	Ios *[]ExtendProductIosEntity `json:"ios,omitempty"`

	// 支持的特性功能。
	SupportFeatures *[]ExtendProductSupportFeaturesEntity `json:"support_features,omitempty"`

	Properties *ExtendProductPropertiesEntity `json:"properties,omitempty"`

	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`
}

func (ExtendProductInfoEntity) String added in v0.1.24 

func (o ExtendProductInfoEntity) String() string

type ExtendProductIosEntity added in v0.1.24 

type ExtendProductIosEntity struct {

	// 存储IO规格。
	IoSpec *string `json:"io_spec,omitempty"`

	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// IO类型。
	Type *string `json:"type,omitempty"`

	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`
}

ExtendProductIosEntity 磁盘IO信息。

func (ExtendProductIosEntity) String added in v0.1.24 

func (o ExtendProductIosEntity) String() string

type ExtendProductPropertiesEntity added in v0.1.24 

type ExtendProductPropertiesEntity struct {

	// 每个Broker的最大分区数。
	MaxPartitionPerBroker *string `json:"max_partition_per_broker,omitempty"`

	// Broker的最大个数。
	MaxBroker *string `json:"max_broker,omitempty"`

	// 每个节点的最大存储。单位为GB。
	MaxStoragePerNode *string `json:"max_storage_per_node,omitempty"`

	// 每个Broker的最大消费者数。
	MaxConsumerPerBroker *string `json:"max_consumer_per_broker,omitempty"`

	// Broker的最小个数。
	MinBroker *string `json:"min_broker,omitempty"`

	// 每个Broker的最大带宽。
	MaxBandwidthPerBroker *string `json:"max_bandwidth_per_broker,omitempty"`

	// 每个节点的最小存储。单位为GB。
	MinStoragePerNode *string `json:"min_storage_per_node,omitempty"`

	// 每个Broker的最大TPS。
	MaxTpsPerBroker *string `json:"max_tps_per_broker,omitempty"`

	// product_id的别名。
	ProductAlias *string `json:"product_alias,omitempty"`
}

ExtendProductPropertiesEntity 产品规格属性描述。

func (ExtendProductPropertiesEntity) String added in v0.1.24 

func (o ExtendProductPropertiesEntity) String() string

type ExtendProductSupportFeaturesEntity added in v0.1.24 

type ExtendProductSupportFeaturesEntity struct {

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

	// 功能特性的键值对。
	Properties map[string]string `json:"properties,omitempty"`
}

ExtendProductSupportFeaturesEntity 支持的特性功能。

func (ExtendProductSupportFeaturesEntity) String added in v0.1.24 

func (o ExtendProductSupportFeaturesEntity) String() string

type GroupInfoSimple added in v0.1.28 

type GroupInfoSimple struct {

	// 创建时间。
	CreatedAt *int64 `json:"createdAt,omitempty"`

	// 消费组ID。
	GroupId *string `json:"group_id,omitempty"`

	// 消费组状态。包含以下状态： - Dead：消费组内没有任何成员，且没有任何元数据。 - Empty：消费组内没有任何成员，存在元数据。 - PreparingRebalance：准备开启rebalance。 - CompletingRebalance：所有成员加入group。 - Stable：消费组内成员可正常消费。
	State *string `json:"state,omitempty"`

	// 协调器编号。
	CoordinatorId *int32 `json:"coordinator_id,omitempty"`

	// 消费组描述。
	GroupDesc *string `json:"group_desc,omitempty"`

	// 堆积数。
	Lag *int32 `json:"lag,omitempty"`
}

func (GroupInfoSimple) String added in v0.1.28 

func (o GroupInfoSimple) String() string

type InstanceConfig added in v0.1.65 

type InstanceConfig struct {

	// 配置名称。
	Name *string `json:"name,omitempty"`

	// 有效值。
	ValidValues *string `json:"valid_values,omitempty"`

	// 默认值。
	DefaultValue *string `json:"default_value,omitempty"`

	// 配置类型：static/dynamic。
	ConfigType *InstanceConfigConfigType `json:"config_type,omitempty"`

	// 配置当前值。
	Value *string `json:"value,omitempty"`

	// 值类型。
	ValueType *string `json:"value_type,omitempty"`
}

func (InstanceConfig) String added in v0.1.65 

func (o InstanceConfig) String() string

type InstanceConfigConfigType added in v0.1.65 

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

func (InstanceConfigConfigType) MarshalJSON added in v0.1.65 

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

func (*InstanceConfigConfigType) UnmarshalJSON added in v0.1.65 

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

func (InstanceConfigConfigType) Value added in v0.1.65 

func (c InstanceConfigConfigType) Value() string

type InstanceConfigConfigTypeEnum added in v0.1.65 

type InstanceConfigConfigTypeEnum struct {
	STATIC  InstanceConfigConfigType
	DYNAMIC InstanceConfigConfigType
}

func GetInstanceConfigConfigTypeEnum added in v0.1.65 

func GetInstanceConfigConfigTypeEnum() InstanceConfigConfigTypeEnum

type KafkaTopicPartitionResponsePartitions added in v0.1.49 

type KafkaTopicPartitionResponsePartitions struct {

	// 分区ID
	Partition *int32 `json:"partition,omitempty"`

	// 起始偏移量
	StartOffset *int64 `json:"start_offset,omitempty"`

	// 最后偏移量
	LastOffset *int64 `json:"last_offset,omitempty"`

	// 分区消息数
	MessageCount *int64 `json:"message_count,omitempty"`

	// 最近更新时间
	LastUpdateTime *int64 `json:"last_update_time,omitempty"`
}

func (KafkaTopicPartitionResponsePartitions) String added in v0.1.49 

func (o KafkaTopicPartitionResponsePartitions) String() string

type KafkaTopicProducerResponseProducers added in v0.1.49 

type KafkaTopicProducerResponseProducers struct {

	// 生产者地址
	ProducerAddress *string `json:"producer_address,omitempty"`

	// broker地址
	BrokerAddress *string `json:"broker_address,omitempty"`

	// 加入时间
	JoinTime *int64 `json:"join_time,omitempty"`
}

func (KafkaTopicProducerResponseProducers) String added in v0.1.49 

func (o KafkaTopicProducerResponseProducers) String() string

type ListAvailableZonesRequest 

type ListAvailableZonesRequest struct {
}

ListAvailableZonesRequest Request Object

func (ListAvailableZonesRequest) String 

func (o ListAvailableZonesRequest) String() string

type ListAvailableZonesRespAvailableZones 

type ListAvailableZonesRespAvailableZones struct {

	// 是否售罄。
	SoldOut *bool `json:"soldOut,omitempty"`

	// 可用区ID。
	Id *string `json:"id,omitempty"`

	// 可用区编码。
	Code *string `json:"code,omitempty"`

	// 可用区名称。
	Name *string `json:"name,omitempty"`

	// 可用区端口号。
	Port *string `json:"port,omitempty"`

	// 可用区上是否还有可用资源。
	ResourceAvailability *string `json:"resource_availability,omitempty"`

	// 是否为默认可用区。
	DefaultAz *bool `json:"default_az,omitempty"`

	// 剩余时间。
	RemainTime *int64 `json:"remain_time,omitempty"`

	// 是否支持IPv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`
}

func (ListAvailableZonesRespAvailableZones) String 

func (o ListAvailableZonesRespAvailableZones) String() string

type ListAvailableZonesResponse 

type ListAvailableZonesResponse struct {

	// 区域ID。
	RegionId *string `json:"region_id,omitempty"`

	// 可用区数组。
	AvailableZones *[]ListAvailableZonesRespAvailableZones `json:"available_zones,omitempty"`
	HttpStatusCode int                                     `json:"-"`
}

ListAvailableZonesResponse Response Object

func (ListAvailableZonesResponse) String 

func (o ListAvailableZonesResponse) String() string

type ListBackgroundTasksRequest 

type ListBackgroundTasksRequest struct {

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

	// 开启查询的任务编号。
	Start *int32 `json:"start,omitempty"`

	// 查询的任务个数。
	Limit *int32 `json:"limit,omitempty"`

	// 查询任务的最小时间，格式为YYYYMMDDHHmmss。
	BeginTime *string `json:"begin_time,omitempty"`

	// 查询任务的最大时间，格式为YYYYMMDDHHmmss。
	EndTime *string `json:"end_time,omitempty"`
}

ListBackgroundTasksRequest Request Object

func (ListBackgroundTasksRequest) String 

func (o ListBackgroundTasksRequest) String() string

type ListBackgroundTasksRespTasks 

type ListBackgroundTasksRespTasks struct {

	// 任务ID。
	Id *string `json:"id,omitempty"`

	// 任务名称。
	Name *string `json:"name,omitempty"`

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

	// 用户ID。
	UserId *string `json:"user_id,omitempty"`

	// 任务参数。
	Params *string `json:"params,omitempty"`

	// 任务状态。
	Status *string `json:"status,omitempty"`

	// 启动时间。
	CreatedAt *string `json:"created_at,omitempty"`

	// 结束时间。
	UpdatedAt *string `json:"updated_at,omitempty"`
}

func (ListBackgroundTasksRespTasks) String 

func (o ListBackgroundTasksRespTasks) String() string

type ListBackgroundTasksResponse 

type ListBackgroundTasksResponse struct {

	// 任务数量。
	TaskCount *string `json:"task_count,omitempty"`

	// 任务列表。
	Tasks          *[]ListBackgroundTasksRespTasks `json:"tasks,omitempty"`
	HttpStatusCode int                             `json:"-"`
}

ListBackgroundTasksResponse Response Object

func (ListBackgroundTasksResponse) String 

func (o ListBackgroundTasksResponse) String() string

type ListEngineIosEntity added in v0.0.76 

type ListEngineIosEntity struct {

	// 磁盘IO编码。
	IoSpec *string `json:"io_spec,omitempty"`

	// 磁盘类型。
	Type *string `json:"type,omitempty"`

	// 可用区。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 不可用区。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`
}

ListEngineIosEntity 支持的磁盘IO类型信息。

func (ListEngineIosEntity) String added in v0.0.76 

func (o ListEngineIosEntity) String() string

type ListEngineProductsEntity added in v0.0.76 

type ListEngineProductsEntity struct {

	// 产品类型。当前产品类型有单机和集群。
	Type *string `json:"type,omitempty"`

	// 产品ID。
	ProductId *string `json:"product_id,omitempty"`

	// 底层资源类型。
	EcsFlavorId *string `json:"ecs_flavor_id,omitempty"`

	// 账单计费类型。
	BillingCode *string `json:"billing_code,omitempty"`

	// CPU架构。
	ArchTypes *[]string `json:"arch_types,omitempty"`

	// [计费模式。monthly：包年/包月类型。hourly：按需类型。](tag:hws,hws_hk,ctc,sbc,hk_sbc,cmcc,hws_eu)[暂未使用。](tag:hws_ocb,ocb)[计费模式。hourly：按需类型。](tag:otc,g42,tm,hk_g42,hk_tm)
	ChargingMode *[]string `json:"charging_mode,omitempty"`

	// 支持的磁盘IO类型列表。
	Ios *[]ListEngineIosEntity `json:"ios,omitempty"`

	// 当前规格实例支持的功能特性列表。
	SupportFeatures *[]ListEngineSupportFeaturesEntity `json:"support_features,omitempty"`

	Properties *ListEnginePropertiesEntity `json:"properties,omitempty"`
}

ListEngineProductsEntity 产品规格的详细信息。

func (ListEngineProductsEntity) String added in v0.0.76 

func (o ListEngineProductsEntity) String() string

type ListEngineProductsRequest added in v0.0.76 

type ListEngineProductsRequest struct {

	// 消息引擎的类型。
	Engine ListEngineProductsRequestEngine `json:"engine"`

	// 产品ID。
	ProductId *string `json:"product_id,omitempty"`
}

ListEngineProductsRequest Request Object

func (ListEngineProductsRequest) String added in v0.0.76 

func (o ListEngineProductsRequest) String() string

type ListEngineProductsRequestEngine added in v0.0.76 

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

func (ListEngineProductsRequestEngine) MarshalJSON added in v0.0.76 

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

func (*ListEngineProductsRequestEngine) UnmarshalJSON added in v0.0.76 

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

func (ListEngineProductsRequestEngine) Value added in v0.0.90 

func (c ListEngineProductsRequestEngine) Value() string

type ListEngineProductsRequestEngineEnum added in v0.0.76 

type ListEngineProductsRequestEngineEnum struct {
	KAFKA ListEngineProductsRequestEngine
}

func GetListEngineProductsRequestEngineEnum added in v0.0.76 

func GetListEngineProductsRequestEngineEnum() ListEngineProductsRequestEngineEnum

type ListEngineProductsResponse added in v0.0.76 

type ListEngineProductsResponse struct {

	// 分布式消息服务的产品类型。
	Engine *string `json:"engine,omitempty"`

	// 支持的产品版本类型。
	Versions *[]string `json:"versions,omitempty"`

	// 产品规格的详细信息。
	Products       *[]ListEngineProductsEntity `json:"products,omitempty"`
	HttpStatusCode int                         `json:"-"`
}

ListEngineProductsResponse Response Object

func (ListEngineProductsResponse) String added in v0.0.76 

func (o ListEngineProductsResponse) String() string

type ListEnginePropertiesEntity added in v0.0.76 

type ListEnginePropertiesEntity struct {

	// 每个Broker的最大分区数。
	MaxPartitionPerBroker *string `json:"max_partition_per_broker,omitempty"`

	// Broker的最大个数。
	MaxBroker *string `json:"max_broker,omitempty"`

	// 每个节点的最大存储。单位为GB。
	MaxStoragePerNode *string `json:"max_storage_per_node,omitempty"`

	// 每个Broker的最大消费者数。
	MaxConsumerPerBroker *string `json:"max_consumer_per_broker,omitempty"`

	// Broker的最小个数。
	MinBroker *string `json:"min_broker,omitempty"`

	// 每个Broker的最大带宽。
	MaxBandwidthPerBroker *string `json:"max_bandwidth_per_broker,omitempty"`

	// 每个节点的最小存储。单位为GB。
	MinStoragePerNode *string `json:"min_storage_per_node,omitempty"`

	// 每个Broker的最大TPS。
	MaxTpsPerBroker *string `json:"max_tps_per_broker,omitempty"`

	// product_id的别名。
	ProductAlias *string `json:"product_alias,omitempty"`
}

ListEnginePropertiesEntity 当前规格实例的属性。

func (ListEnginePropertiesEntity) String added in v0.0.76 

func (o ListEnginePropertiesEntity) String() string

type ListEngineSupportFeaturesEntity added in v0.0.76 

type ListEngineSupportFeaturesEntity struct {

	// 功能名称。
	Name *string `json:"name,omitempty"`

	Properties *ListEngineSupportFeaturesPropertiesEntity `json:"properties,omitempty"`
}

ListEngineSupportFeaturesEntity 实例支持的功能特性。

func (ListEngineSupportFeaturesEntity) String added in v0.0.76 

func (o ListEngineSupportFeaturesEntity) String() string

type ListEngineSupportFeaturesPropertiesEntity added in v0.0.76 

type ListEngineSupportFeaturesPropertiesEntity struct {

	// 转储功能的最大任务数。
	MaxTask *string `json:"max_task,omitempty"`

	// 转储功能的最小任务数。
	MinTask *string `json:"min_task,omitempty"`

	// 转储功能的最大节点数。
	MaxNode *string `json:"max_node,omitempty"`

	// 转储功能的最小节点数。
	MinNode *string `json:"min_node,omitempty"`
}

ListEngineSupportFeaturesPropertiesEntity 实例支持的功能属性描述。

func (ListEngineSupportFeaturesPropertiesEntity) String added in v0.0.76 

func (o ListEngineSupportFeaturesPropertiesEntity) String() string

type ListInstanceConsumerGroupsRequest added in v0.1.2 

type ListInstanceConsumerGroupsRequest struct {

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

	// 偏移量，表示从此偏移量开始查询， offset大于等于0。
	Offset *string `json:"offset,omitempty"`

	// 当次查询返回的最大消费组ID个数，默认值为10，取值范围为1~50。
	Limit *string `json:"limit,omitempty"`

	// 消费组名过滤查询，过滤方式为字段包含过滤。
	Group *string `json:"group,omitempty"`
}

ListInstanceConsumerGroupsRequest Request Object

func (ListInstanceConsumerGroupsRequest) String added in v0.1.2 

func (o ListInstanceConsumerGroupsRequest) String() string

type ListInstanceConsumerGroupsResponse added in v0.1.2 

type ListInstanceConsumerGroupsResponse struct {

	// 所有的消费组。
	Groups *[]GroupInfoSimple `json:"groups,omitempty"`

	// 所有的消费组总数。
	Total          *int32 `json:"total,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListInstanceConsumerGroupsResponse Response Object

func (ListInstanceConsumerGroupsResponse) String added in v0.1.2 

func (o ListInstanceConsumerGroupsResponse) String() string

type ListInstanceTopicsRequest 

type ListInstanceTopicsRequest struct {

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

	// 偏移量，表示从此偏移量开始查询， offset大于等于0。
	Offset *string `json:"offset,omitempty"`

	// 当次查询返回的最大实例个数，默认值为10，取值范围为1~50。
	Limit *string `json:"limit,omitempty"`
}

ListInstanceTopicsRequest Request Object

func (ListInstanceTopicsRequest) String 

func (o ListInstanceTopicsRequest) String() string

type ListInstanceTopicsResponse 

type ListInstanceTopicsResponse struct {

	// topic总数。
	Total *int32 `json:"total,omitempty"`

	// 分页查询的大小。
	Size *int32 `json:"size,omitempty"`

	// 剩余分区数。
	RemainPartitions *int32 `json:"remain_partitions,omitempty"`

	// 分区总数。
	MaxPartitions *int32 `json:"max_partitions,omitempty"`

	// 单个topic最大占用分区数。
	TopicMaxPartitions *int32 `json:"topic_max_partitions,omitempty"`

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

ListInstanceTopicsResponse Response Object

func (ListInstanceTopicsResponse) String 

func (o ListInstanceTopicsResponse) String() string

type ListInstancesRequest 

type ListInstancesRequest struct {

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

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

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

	// 实例状态。 详细状态说明请参考[实例状态说明](kafka-api-180514012.xml)。
	Status *ListInstancesRequestStatus `json:"status,omitempty"`

	// 是否返回创建失败的实例数。  当参数值为“true”时，返回创建失败的实例数。参数值为“false”或者其他值，不返回创建失败的实例数。
	IncludeFailure *ListInstancesRequestIncludeFailure `json:"include_failure,omitempty"`

	// 是否按照实例名称进行精确匹配查询。  默认为“false”，表示模糊匹配实例名称查询。若参数值为“true”表示按照实例名称进行精确匹配查询。
	ExactMatchName *ListInstancesRequestExactMatchName `json:"exact_match_name,omitempty"`

	// 企业项目ID。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 偏移量，表示从此偏移量开始查询， offset大于等于0。
	Offset *string `json:"offset,omitempty"`

	// 当次查询返回的最大实例个数，默认值为10，取值范围为1~50。
	Limit *string `json:"limit,omitempty"`
}

ListInstancesRequest Request Object

func (ListInstancesRequest) String 

func (o ListInstancesRequest) String() string

type ListInstancesRequestEngine added in v0.1.49 

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

func (ListInstancesRequestEngine) MarshalJSON added in v0.1.49 

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

func (*ListInstancesRequestEngine) UnmarshalJSON added in v0.1.49 

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

func (ListInstancesRequestEngine) Value added in v0.1.49 

func (c ListInstancesRequestEngine) Value() string

type ListInstancesRequestEngineEnum added in v0.1.49 

type ListInstancesRequestEngineEnum struct {
	KAFKA ListInstancesRequestEngine
}

func GetListInstancesRequestEngineEnum added in v0.1.49 

func GetListInstancesRequestEngineEnum() ListInstancesRequestEngineEnum

type ListInstancesRequestExactMatchName 

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

func (ListInstancesRequestExactMatchName) MarshalJSON 

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

func (*ListInstancesRequestExactMatchName) UnmarshalJSON 

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

func (ListInstancesRequestExactMatchName) Value added in v0.0.90 

func (c ListInstancesRequestExactMatchName) Value() string

type ListInstancesRequestExactMatchNameEnum 

type ListInstancesRequestExactMatchNameEnum struct {
	TRUE  ListInstancesRequestExactMatchName
	FALSE ListInstancesRequestExactMatchName
}

func GetListInstancesRequestExactMatchNameEnum 

func GetListInstancesRequestExactMatchNameEnum() ListInstancesRequestExactMatchNameEnum

type ListInstancesRequestIncludeFailure 

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

func (ListInstancesRequestIncludeFailure) MarshalJSON 

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

func (*ListInstancesRequestIncludeFailure) UnmarshalJSON 

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

func (ListInstancesRequestIncludeFailure) Value added in v0.0.90 

func (c ListInstancesRequestIncludeFailure) Value() string

type ListInstancesRequestIncludeFailureEnum 

type ListInstancesRequestIncludeFailureEnum struct {
	TRUE  ListInstancesRequestIncludeFailure
	FALSE ListInstancesRequestIncludeFailure
}

func GetListInstancesRequestIncludeFailureEnum 

func GetListInstancesRequestIncludeFailureEnum() ListInstancesRequestIncludeFailureEnum

type ListInstancesRequestStatus 

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

func (ListInstancesRequestStatus) MarshalJSON 

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

func (*ListInstancesRequestStatus) UnmarshalJSON 

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

func (ListInstancesRequestStatus) Value added in v0.0.90 

func (c ListInstancesRequestStatus) Value() string

type ListInstancesRequestStatusEnum 

type ListInstancesRequestStatusEnum struct {
	CREATING           ListInstancesRequestStatus
	RUNNING            ListInstancesRequestStatus
	RESTARTING         ListInstancesRequestStatus
	DELETING           ListInstancesRequestStatus
	ERROR              ListInstancesRequestStatus
	CREATEFAILED       ListInstancesRequestStatus
	FREEZING           ListInstancesRequestStatus
	FROZEN             ListInstancesRequestStatus
	EXTENDING          ListInstancesRequestStatus
	SHRINKING          ListInstancesRequestStatus
	EXTENDEDFAILED     ListInstancesRequestStatus
	CONFIGURING        ListInstancesRequestStatus
	UPGRADING          ListInstancesRequestStatus
	UPGRADINGFAILED    ListInstancesRequestStatus
	ROLLBACK           ListInstancesRequestStatus
	ROLLBACKFAILED     ListInstancesRequestStatus
	VOLUMETYPECHANGING ListInstancesRequestStatus
}

func GetListInstancesRequestStatusEnum 

func GetListInstancesRequestStatusEnum() ListInstancesRequestStatusEnum

type ListInstancesResponse 

type ListInstancesResponse struct {

	// 实例列表
	Instances *[]ShowInstanceResp `json:"instances,omitempty"`

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

ListInstancesResponse Response Object

func (ListInstancesResponse) String 

func (o ListInstancesResponse) String() string

type ListProductsRequest 

type ListProductsRequest struct {

	// 消息引擎的类型。当前只支持kafka类型。
	Engine ListProductsRequestEngine `json:"engine"`
}

ListProductsRequest Request Object

func (ListProductsRequest) String 

func (o ListProductsRequest) String() string

type ListProductsRequestEngine added in v0.1.49 

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

func (ListProductsRequestEngine) MarshalJSON added in v0.1.49 

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

func (*ListProductsRequestEngine) UnmarshalJSON added in v0.1.49 

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

func (ListProductsRequestEngine) Value added in v0.1.49 

func (c ListProductsRequestEngine) Value() string

type ListProductsRequestEngineEnum added in v0.1.49 

type ListProductsRequestEngineEnum struct {
	KAFKA ListProductsRequestEngine
}

func GetListProductsRequestEngineEnum added in v0.1.49 

func GetListProductsRequestEngineEnum() ListProductsRequestEngineEnum

type ListProductsRespDetail 

type ListProductsRespDetail struct {

	// 单位时间内的消息量最大值。
	Tps *string `json:"tps,omitempty"`

	// 消息存储空间。
	Storage *string `json:"storage,omitempty"`

	// Kafka实例的分区数量。
	PartitionNum *string `json:"partition_num,omitempty"`

	// 产品ID。
	ProductId *string `json:"product_id,omitempty"`

	// 规格ID。
	SpecCode *string `json:"spec_code,omitempty"`

	// IO信息。
	Io *[]ListProductsRespIo `json:"io,omitempty"`

	// Kafka实例的基准带宽。
	Bandwidth *string `json:"bandwidth,omitempty"`

	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 该产品规格对应的虚拟机规格。
	EcsFlavorId *string `json:"ecs_flavor_id,omitempty"`

	// 实例规格架构类型。当前仅支持X86。
	ArchType *string `json:"arch_type,omitempty"`
}

func (ListProductsRespDetail) String 

func (o ListProductsRespDetail) String() string

type ListProductsRespHourly 

type ListProductsRespHourly struct {

	// 消息引擎的名称，该字段显示为kafka。
	Name *string `json:"name,omitempty"`

	// 消息引擎的版本，当前仅支持1.1.0和2.3.0。
	Version *string `json:"version,omitempty"`

	// 产品规格列表。
	Values *[]ListProductsRespValues `json:"values,omitempty"`
}

func (ListProductsRespHourly) String 

func (o ListProductsRespHourly) String() string

type ListProductsRespIo 

type ListProductsRespIo struct {

	// IO类型。
	IoType *string `json:"io_type,omitempty"`

	// IO规格。
	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	// IO未售罄的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// IO已售罄的不可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	// 磁盘类型。
	VolumeType *string `json:"volume_type,omitempty"`
}

func (ListProductsRespIo) String 

func (o ListProductsRespIo) String() string

type ListProductsRespValues 

type ListProductsRespValues struct {

	// 规格详情。
	Detail *[]ListProductsRespDetail `json:"detail,omitempty"`

	// 实例类型。
	Name *string `json:"name,omitempty"`

	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`
}

func (ListProductsRespValues) String 

func (o ListProductsRespValues) String() string

type ListProductsResponse 

type ListProductsResponse struct {

	// 表示按需付费的产品列表。
	Hourly *[]ListProductsRespHourly `json:"Hourly,omitempty"`

	// 表示包年包月的产品列表。当前暂不支持通过API创建包年包月的Kafka实例。
	Monthly        *[]ListProductsRespHourly `json:"Monthly,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

ListProductsResponse Response Object

func (ListProductsResponse) String 

func (o ListProductsResponse) String() string

type ListSinkTasksRequest 

type ListSinkTasksRequest struct {

	// 实例转储ID。  请参考[查询实例](ShowInstance.xml)返回的数据。
	ConnectorId string `json:"connector_id"`
}

ListSinkTasksRequest Request Object

func (ListSinkTasksRequest) String 

func (o ListSinkTasksRequest) String() string

type ListSinkTasksRespTasks 

type ListSinkTasksRespTasks struct {

	// 任务ID。
	TaskId *string `json:"task_id,omitempty"`

	// 转储任务名称。
	TaskName *string `json:"task_name,omitempty"`

	// 转储任务类型。
	DestinationType *string `json:"destination_type,omitempty"`

	// 转储任务创建时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 转储任务状态。
	Status *string `json:"status,omitempty"`

	// 返回任务转存的topics列表或者正则表达式。
	Topics *string `json:"topics,omitempty"`
}

func (ListSinkTasksRespTasks) String 

func (o ListSinkTasksRespTasks) String() string

type ListSinkTasksResponse 

type ListSinkTasksResponse struct {

	// 转储任务列表。
	Tasks *[]ListSinkTasksRespTasks `json:"tasks,omitempty"`

	// 转储任务总数。
	TotalNumber *int32 `json:"total_number,omitempty"`

	// 总的支持任务个数。
	MaxTasks *int32 `json:"max_tasks,omitempty"`

	// 任务总数的配额。
	QuotaTasks     *int32 `json:"quota_tasks,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ListSinkTasksResponse Response Object

func (ListSinkTasksResponse) String 

func (o ListSinkTasksResponse) String() string

type ListTopicPartitionsRequest added in v0.1.49 

type ListTopicPartitionsRequest struct {

	// 实例id
	InstanceId string `json:"instance_id"`

	// 主题
	Topic string `json:"topic"`

	// 偏移量，表示查询该偏移量后面的记录
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制
	Limit *int32 `json:"limit,omitempty"`
}

ListTopicPartitionsRequest Request Object

func (ListTopicPartitionsRequest) String added in v0.1.49 

func (o ListTopicPartitionsRequest) String() string

type ListTopicPartitionsResponse added in v0.1.49 

type ListTopicPartitionsResponse struct {

	// 总条数
	Total *int32 `json:"total,omitempty"`

	// 分区数组
	Partitions     *[]KafkaTopicPartitionResponsePartitions `json:"partitions,omitempty"`
	HttpStatusCode int                                      `json:"-"`
}

ListTopicPartitionsResponse Response Object

func (ListTopicPartitionsResponse) String added in v0.1.49 

func (o ListTopicPartitionsResponse) String() string

type ListTopicProducersRequest added in v0.1.49 

type ListTopicProducersRequest struct {

	// 实例id
	InstanceId string `json:"instance_id"`

	// 主题
	Topic string `json:"topic"`

	// 偏移量，表示查询该偏移量后面的记录
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制
	Limit *int32 `json:"limit,omitempty"`
}

ListTopicProducersRequest Request Object

func (ListTopicProducersRequest) String added in v0.1.49 

func (o ListTopicProducersRequest) String() string

type ListTopicProducersResponse added in v0.1.49 

type ListTopicProducersResponse struct {

	// 总条数
	Total *int32 `json:"total,omitempty"`

	// 生产者列表
	Producers      *[]KafkaTopicProducerResponseProducers `json:"producers,omitempty"`
	HttpStatusCode int                                    `json:"-"`
}

ListTopicProducersResponse Response Object

func (ListTopicProducersResponse) String added in v0.1.49 

func (o ListTopicProducersResponse) String() string

type MaintainWindowsEntity 

type MaintainWindowsEntity struct {

	// 是否为默认时间段。
	Default *bool `json:"default,omitempty"`

	// 维护时间窗结束时间。
	End *string `json:"end,omitempty"`

	// 维护时间窗开始时间。
	Begin *string `json:"begin,omitempty"`

	// 序号。
	Seq *int32 `json:"seq,omitempty"`
}

func (MaintainWindowsEntity) String 

func (o MaintainWindowsEntity) String() string

type MessagesEntity added in v0.0.66 

type MessagesEntity struct {

	// topic名称。
	Topic *string `json:"topic,omitempty"`

	// 消息所在的分区。
	Partition *int32 `json:"partition,omitempty"`

	// 消息key。
	Key *string `json:"key,omitempty"`

	// 消息内容。
	Value *string `json:"value,omitempty"`

	// 消息大小。
	Size *int32 `json:"size,omitempty"`

	// topic名称。
	Timestamp *int64 `json:"timestamp,omitempty"`

	// 大数据标识。
	HugeMessage *bool `json:"huge_message,omitempty"`

	// 消息偏移量。
	MessageOffset *int32 `json:"message_offset,omitempty"`

	// 消息ID。
	MessageId *string `json:"message_id,omitempty"`

	// 应用ID。
	AppId *string `json:"app_id,omitempty"`

	// 消息标签。
	Tag *string `json:"tag,omitempty"`
}

func (MessagesEntity) String added in v0.0.66 

func (o MessagesEntity) String() string

type ModifyInstanceConfig added in v0.1.65 

type ModifyInstanceConfig struct {

	// 修改的配置名称。
	Name *string `json:"name,omitempty"`

	// 配置的修改值。
	Value *string `json:"value,omitempty"`
}

func (ModifyInstanceConfig) String added in v0.1.65 

func (o ModifyInstanceConfig) String() string

type ModifyInstanceConfigsReq added in v0.1.65 

type ModifyInstanceConfigsReq struct {

	// kafka待修改配置列表。
	KafkaConfigs *[]ModifyInstanceConfig `json:"kafka_configs,omitempty"`
}

func (ModifyInstanceConfigsReq) String added in v0.1.65 

func (o ModifyInstanceConfigsReq) String() string

type ModifyInstanceConfigsRequest added in v0.1.65 

type ModifyInstanceConfigsRequest struct {

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

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

ModifyInstanceConfigsRequest Request Object

func (ModifyInstanceConfigsRequest) String added in v0.1.65 

func (o ModifyInstanceConfigsRequest) String() string

type ModifyInstanceConfigsResponse added in v0.1.65 

type ModifyInstanceConfigsResponse struct {

	// 配置修改任务ID。
	JobId *string `json:"job_id,omitempty"`

	// 本次修改动态配置参数个数。
	DynamicConfig *int32 `json:"dynamic_config,omitempty"`

	// 本次修改静态配置参数个数。
	StaticConfig   *int32 `json:"static_config,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ModifyInstanceConfigsResponse Response Object

func (ModifyInstanceConfigsResponse) String added in v0.1.65 

func (o ModifyInstanceConfigsResponse) String() string

type ObsDestinationDescriptor 

type ObsDestinationDescriptor struct {

	// 转存的topic列表名称，支持多个topic同时放置，以逗号“,”分隔。同时支持正则表达式。 例如topic1,topic2。
	Topics string `json:"topics"`

	// 转存topic的正则表达式，与topics必须二选一，不能同时都设置或者“.*”。
	TopicsRegex *string `json:"topics_regex,omitempty"`

	// 转储启动偏移量：   - latest: 从Topic最后端开始消费。   - earliest: 从Topic最前端消息开始消费。  默认是latest。
	ConsumerStrategy ObsDestinationDescriptorConsumerStrategy `json:"consumer_strategy"`

	// 转储文件格式。当前只支持text。
	DestinationFileType ObsDestinationDescriptorDestinationFileType `json:"destination_file_type"`

	// 访问密钥AK。
	AccessKey string `json:"access_key"`

	// 访问密钥SK。
	SecretKey string `json:"secret_key"`

	// 存储该通道数据的OBS桶名称。
	ObsBucketName string `json:"obs_bucket_name"`

	// 存储在obs的路径，默认可以不填。 取值范围：英文字母、数字、下划线、中划线和斜杠，最大长度为64个字符。 默认配置为空。
	ObsPath *string `json:"obs_path,omitempty"`

	// 将转储文件的生成时间使用“yyyy/MM/dd/HH/mm”格式生成分区字符串，用来定义写到OBS的Object文件所在的目录层次结构。   - N/A：置空，不使用日期时间目录。   - yyyy：年   - yyyy/MM：年/月   - yyyy/MM/dd：年/月/日   - yyyy/MM/dd/HH：年/月/日/时   - yyyy/MM/dd/HH/mm：年/月/日/时/分，例如：2017/11/10/14/49，目录结构就是“2017 > 11 > 10 > 14 > 49”，“2017”表示最外层文件夹。  默认值：空 > 数据转储成功后，存储的目录结构为“obs_bucket_path/file_prefix/partition_format”。默认时间是GMT+8 时间
	PartitionFormat *string `json:"partition_format,omitempty"`

	// 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围：   - 逗号“,”   - 分号“;”   - 竖线“|”   - 换行符“\\n”   - NULL  默认值：换行符“\\n”。
	RecordDelimiter *string `json:"record_delimiter,omitempty"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。 取值范围：30～900 单位：秒。 > 使用OBS通道转储流式数据时该参数为必选配置。
	DeliverTimeInterval int32 `json:"deliver_time_interval"`
}

ObsDestinationDescriptor 转存目标的描述。

func (ObsDestinationDescriptor) String 

func (o ObsDestinationDescriptor) String() string

type ObsDestinationDescriptorConsumerStrategy 

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

func (ObsDestinationDescriptorConsumerStrategy) MarshalJSON 

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

func (*ObsDestinationDescriptorConsumerStrategy) UnmarshalJSON 

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

func (ObsDestinationDescriptorConsumerStrategy) Value added in v0.0.90 

func (c ObsDestinationDescriptorConsumerStrategy) Value() string

type ObsDestinationDescriptorConsumerStrategyEnum 

type ObsDestinationDescriptorConsumerStrategyEnum struct {
	LATEST   ObsDestinationDescriptorConsumerStrategy
	EARLIEST ObsDestinationDescriptorConsumerStrategy
}

func GetObsDestinationDescriptorConsumerStrategyEnum 

func GetObsDestinationDescriptorConsumerStrategyEnum() ObsDestinationDescriptorConsumerStrategyEnum

type ObsDestinationDescriptorDestinationFileType 

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

func (ObsDestinationDescriptorDestinationFileType) MarshalJSON 

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

func (*ObsDestinationDescriptorDestinationFileType) UnmarshalJSON 

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

func (ObsDestinationDescriptorDestinationFileType) Value added in v0.0.90 

func (c ObsDestinationDescriptorDestinationFileType) Value() string

type ObsDestinationDescriptorDestinationFileTypeEnum 

type ObsDestinationDescriptorDestinationFileTypeEnum struct {
	TEXT ObsDestinationDescriptorDestinationFileType
}

func GetObsDestinationDescriptorDestinationFileTypeEnum 

func GetObsDestinationDescriptorDestinationFileTypeEnum() ObsDestinationDescriptorDestinationFileTypeEnum

type PartitionReassignEntity added in v0.1.24 

type PartitionReassignEntity struct {

	// topic名称
	Topic string `json:"topic"`

	// 分区重平衡到的broker列表，自动生成分配方案时需指定该参数。
	Brokers *[]int32 `json:"brokers,omitempty"`

	// 副本因子，自动生成分配方案时可指定。
	ReplicationFactor *int32 `json:"replication_factor,omitempty"`

	// 手动指定的分配方案。brokers参数与该参数不能同时为空。
	Assignment *[]TopicAssignment `json:"assignment,omitempty"`
}

func (PartitionReassignEntity) String added in v0.1.24 

func (o PartitionReassignEntity) String() string

type PartitionReassignRequest added in v0.1.24 

type PartitionReassignRequest struct {

	// 重平衡分配方案。
	Reassignments []PartitionReassignEntity `json:"reassignments"`

	// 重平衡门限值。
	Throttle *int32 `json:"throttle,omitempty"`
}

func (PartitionReassignRequest) String added in v0.1.24 

func (o PartitionReassignRequest) String() string

type PolicyEntity added in v0.0.66 

type PolicyEntity struct {

	// 是否为创建topic时所选择的用户。
	Owner *bool `json:"owner,omitempty"`

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

	// 权限类型。 - all：拥有发布、订阅权限; - pub：拥有发布权限; - sub：拥有订阅权限。
	AccessPolicy *PolicyEntityAccessPolicy `json:"access_policy,omitempty"`
}

func (PolicyEntity) String added in v0.0.66 

func (o PolicyEntity) String() string

type PolicyEntityAccessPolicy added in v0.0.66 

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

func (PolicyEntityAccessPolicy) MarshalJSON added in v0.0.66 

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

func (*PolicyEntityAccessPolicy) UnmarshalJSON added in v0.0.66 

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

func (PolicyEntityAccessPolicy) Value added in v0.0.90 

func (c PolicyEntityAccessPolicy) Value() string

type PolicyEntityAccessPolicyEnum added in v0.0.66 

type PolicyEntityAccessPolicyEnum struct {
	ALL PolicyEntityAccessPolicy
	PUB PolicyEntityAccessPolicy
	SUB PolicyEntityAccessPolicy
}

func GetPolicyEntityAccessPolicyEnum added in v0.0.66 

func GetPolicyEntityAccessPolicyEnum() PolicyEntityAccessPolicyEnum

type Quota added in v0.1.68 

type Quota struct {

	// 用户名
	User *string `json:"user,omitempty"`

	// 客户端ID
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置（是则表示对全部用户限流）。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置（是则表示对全部客户端限流）。
	ClientDefault *bool `json:"client-default,omitempty"`

	// 生产上限速率（单位为B/s）
	ProducerByteRate *int64 `json:"producer-byte-rate,omitempty"`

	// 消费上限速率（单位为B/s）
	ConsumerByteRate *int64 `json:"consumer-byte-rate,omitempty"`
}

Quota 客户端流控配置

func (Quota) String added in v0.1.68 

func (o Quota) String() string

type ResetManagerPasswordReq 

type ResetManagerPasswordReq struct {

	// 8-32个字符。 至少包含以下字符中的3种：   - 大写字母   - 小写字母   - 数字   - 特殊字符`~!@#$%^&*()-_=+\\\\|[{}];:\\'\\\",<.>/?  和空格，并且不能以-开头。
	NewPassword *string `json:"new_password,omitempty"`
}

func (ResetManagerPasswordReq) String 

func (o ResetManagerPasswordReq) String() string

type ResetManagerPasswordRequest 

type ResetManagerPasswordRequest struct {

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

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

ResetManagerPasswordRequest Request Object

func (ResetManagerPasswordRequest) String 

func (o ResetManagerPasswordRequest) String() string

type ResetManagerPasswordResponse 

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

ResetManagerPasswordResponse Response Object

func (ResetManagerPasswordResponse) String 

func (o ResetManagerPasswordResponse) String() string

type ResetMessageOffsetReq 

type ResetMessageOffsetReq struct {

	// topic名称。
	Topic string `json:"topic"`

	// 分区编号，默认值为-1，若传入值为-1，则重置所有分区。
	Partition *int32 `json:"partition,omitempty"`

	// 重置消费进度到指定偏移量。 - 如果传入offset小于当前最小的offset，则重置到最小的offset。 - 如果大于最大的offset，则重置到最大的offset。  **message_offset、timestamp二者必选其一。**
	MessageOffset *int32 `json:"message_offset,omitempty"`

	// 重置消费进度到指定时间，格式为unix时间戳，单位为毫秒。 - 如果传入timestamp早于当前最早的timestamp，则重置到最早的timestamp。 - 如果晚于最晚的timestamp，则重置到最晚的timestamp。  **message_offset、timestamp二者必选其一。**
	Timestamp *int32 `json:"timestamp,omitempty"`
}

func (ResetMessageOffsetReq) String 

func (o ResetMessageOffsetReq) String() string

type ResetMessageOffsetRequest 

type ResetMessageOffsetRequest struct {

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

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

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

ResetMessageOffsetRequest Request Object

func (ResetMessageOffsetRequest) String 

func (o ResetMessageOffsetRequest) String() string

type ResetMessageOffsetResponse 

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

ResetMessageOffsetResponse Response Object

func (ResetMessageOffsetResponse) String 

func (o ResetMessageOffsetResponse) String() string

type ResetPasswordReq 

type ResetPasswordReq struct {

	// 8-32个字符。 至少包含以下字符中的3种：   - 大写字母   - 小写字母   - 数字   - 特殊字符`~!@#$%^&*()-_=+\\\\|[{}];:\\'\\\",<.>/?  和空格，并且不能以-开头。
	NewPassword string `json:"new_password"`
}

func (ResetPasswordReq) String 

func (o ResetPasswordReq) String() string

type ResetPasswordRequest 

type ResetPasswordRequest struct {

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

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

ResetPasswordRequest Request Object

func (ResetPasswordRequest) String 

func (o ResetPasswordRequest) String() string

type ResetPasswordResponse 

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

ResetPasswordResponse Response Object

func (ResetPasswordResponse) String 

func (o ResetPasswordResponse) String() string

type ResetReplicaReq 

type ResetReplicaReq struct {

	// 期望调整的分区副本分配情况。
	Partitions *[]ResetReplicaReqPartitions `json:"partitions,omitempty"`
}

ResetReplicaReq 期望调整的分区副本分配情况。

func (ResetReplicaReq) String 

func (o ResetReplicaReq) String() string

type ResetReplicaReqPartitions 

type ResetReplicaReqPartitions struct {

	// 分区ID。
	Partition *int32 `json:"partition,omitempty"`

	// 副本期望所在的broker ID。其中Array首位为leader副本，所有分区需要有同样数量的副本，副本数不能大于总broker的数量。
	Replicas *[]int32 `json:"replicas,omitempty"`
}

func (ResetReplicaReqPartitions) String 

func (o ResetReplicaReqPartitions) String() string

type ResetUserPasswrodReq 

type ResetUserPasswrodReq struct {

	// 用户新密码。
	NewPassword *string `json:"new_password,omitempty"`
}

func (ResetUserPasswrodReq) String 

func (o ResetUserPasswrodReq) String() string

type ResetUserPasswrodRequest 

type ResetUserPasswrodRequest struct {

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

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

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

ResetUserPasswrodRequest Request Object

func (ResetUserPasswrodRequest) String 

func (o ResetUserPasswrodRequest) String() string

type ResetUserPasswrodResponse 

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

ResetUserPasswrodResponse Response Object

func (ResetUserPasswrodResponse) String 

func (o ResetUserPasswrodResponse) String() string

type ResizeEngineInstanceReq added in v0.1.24 

type ResizeEngineInstanceReq struct {

	// 变更类型。  取值范围：   - storage：存储空间扩容，代理数量不变。    - horizontal：代理数量扩容，每个broker的存储空间不变。    - vertical：垂直扩容，broker的底层虚机规格变更，代理数量和存储空间不变。
	OperType string `json:"oper_type"`

	// 扩容后的存储空间。  当oper_type类型是storage或horizontal时，该参数有效且必填。  实例存储空间 = 代理数量 * 每个broker的存储空间。  当oper_type类型是storage时，代理数量不变，每个broker存储空间最少扩容100GB。  当oper_type类型是horizontal时，每个broker的存储空间不变。
	NewStorageSpace *int32 `json:"new_storage_space,omitempty"`

	// 当oper_type参数为horizontal时，该参数有效。  取值范围：最多支持30个broker。
	NewBrokerNum *int32 `json:"new_broker_num,omitempty"`

	// 垂直扩容时的新产品ID。  当oper_type类型是vertical时，该参数才有效且必填。  产品ID可以从[查询产品规格列表](ListEngineProducts.xml)获取。
	NewProductId *string `json:"new_product_id,omitempty"`

	// 实例绑定的弹性IP地址的ID。  以英文逗号隔开多个弹性IP地址的ID。  当oper_type类型是horizontal时，该参数必填。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 指定的内网IP地址，仅支持指定IPv4。  指定的IP数量只能小于等于新增节点数量。  当指定IP小于节点数量时，未指定的节点随机分配内网IP地址。
	TenantIps *[]string `json:"tenant_ips,omitempty"`

	// 实例扩容时新节点使用备用子网的id  当实例扩容使用备用子网，则传入此值  需要联系客服添加白名单才能传入此值
	SecondTenantSubnetId *string `json:"second_tenant_subnet_id,omitempty"`
}

ResizeEngineInstanceReq 实例规格变更请求体。

func (ResizeEngineInstanceReq) String added in v0.1.24 

func (o ResizeEngineInstanceReq) String() string

type ResizeEngineInstanceRequest added in v0.1.24 

type ResizeEngineInstanceRequest struct {

	// 消息引擎。
	Engine ResizeEngineInstanceRequestEngine `json:"engine"`

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

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

ResizeEngineInstanceRequest Request Object

func (ResizeEngineInstanceRequest) String added in v0.1.24 

func (o ResizeEngineInstanceRequest) String() string

type ResizeEngineInstanceRequestEngine added in v0.1.49 

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

func (ResizeEngineInstanceRequestEngine) MarshalJSON added in v0.1.49 

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

func (*ResizeEngineInstanceRequestEngine) UnmarshalJSON added in v0.1.49 

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

func (ResizeEngineInstanceRequestEngine) Value added in v0.1.49 

func (c ResizeEngineInstanceRequestEngine) Value() string

type ResizeEngineInstanceRequestEngineEnum added in v0.1.49 

type ResizeEngineInstanceRequestEngineEnum struct {
	KAFKA ResizeEngineInstanceRequestEngine
}

func GetResizeEngineInstanceRequestEngineEnum added in v0.1.49 

func GetResizeEngineInstanceRequestEngineEnum() ResizeEngineInstanceRequestEngineEnum

type ResizeEngineInstanceResponse added in v0.1.24 

type ResizeEngineInstanceResponse struct {

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

ResizeEngineInstanceResponse Response Object

func (ResizeEngineInstanceResponse) String added in v0.1.24 

func (o ResizeEngineInstanceResponse) String() string

type ResizeInstanceReq 

type ResizeInstanceReq struct {

	// 规格变更后的规格ID。 若只扩展磁盘大小，则规格ID保持和原实例不变。
	NewSpecCode *string `json:"new_spec_code,omitempty"`

	// 规格变更后的消息存储空间，单位：GB。 若扩展实例基准带宽，则new_storage_space不能低于基准带宽规定的最小磁盘大小。
	NewStorageSpace *int32 `json:"new_storage_space,omitempty"`

	// 扩容类型, 新规格支持扩容类型：\"horizontal\"、\"vertical\"、\"node\"、\"storage\"四种类型。
	OperType *string `json:"oper_type,omitempty"`

	// 扩容后集群节点数。
	NewBrokerNum *int32 `json:"new_broker_num,omitempty"`

	// 新规格变更后的产品ID。 涉及垂直扩容场景，需指定该项。 产品ID可以从[查询产品规格列表](ListEngineProducts.xml)获取。
	NewProductId *string `json:"new_product_id,omitempty"`

	// 实例绑定的弹性IP地址的ID。 以英文逗号隔开多个弹性IP地址的ID。 如果开启了公网再进行扩容，需要填写此参数。
	PublicipId *string `json:"publicip_id,omitempty"`

	// 创建节点可以手动指定实例节点的内网IP地址，仅支持指定IPv4地址。  指定内网地址数量必须小于等于购买的节点数量。  当小于购买的节点数量时,未指定的节点则随机分配。
	TenantIps *[]string `json:"tenant_ips,omitempty"`

	// 实例扩容时新节点使用备用子网的id。  当实例扩容使用备用子网，则传入此值。  需要联系客服添加白名单才能传入此值。
	SecondTenantSubnetId *string `json:"second_tenant_subnet_id,omitempty"`
}

func (ResizeInstanceReq) String 

func (o ResizeInstanceReq) String() string

type ResizeInstanceRequest 

type ResizeInstanceRequest struct {

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

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

ResizeInstanceRequest Request Object

func (ResizeInstanceRequest) String 

func (o ResizeInstanceRequest) String() string

type ResizeInstanceResponse 

type ResizeInstanceResponse struct {

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

ResizeInstanceResponse Response Object

func (ResizeInstanceResponse) String 

func (o ResizeInstanceResponse) String() string

type RestartManagerRequest 

type RestartManagerRequest struct {

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

RestartManagerRequest Request Object

func (RestartManagerRequest) String 

func (o RestartManagerRequest) String() string

type RestartManagerResponse 

type RestartManagerResponse struct {

	// 执行结果。
	Result *string `json:"result,omitempty"`

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

RestartManagerResponse Response Object

func (RestartManagerResponse) String 

func (o RestartManagerResponse) String() string

type ShowBackgroundTaskRequest 

type ShowBackgroundTaskRequest struct {

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

	// 任务ID。
	TaskId string `json:"task_id"`
}

ShowBackgroundTaskRequest Request Object

func (ShowBackgroundTaskRequest) String 

func (o ShowBackgroundTaskRequest) String() string

type ShowBackgroundTaskResponse 

type ShowBackgroundTaskResponse struct {

	// 任务数量。
	TaskCount *string `json:"task_count,omitempty"`

	// 任务列表。
	Tasks          *[]ListBackgroundTasksRespTasks `json:"tasks,omitempty"`
	HttpStatusCode int                             `json:"-"`
}

ShowBackgroundTaskResponse Response Object

func (ShowBackgroundTaskResponse) String 

func (o ShowBackgroundTaskResponse) String() string

type ShowCesHierarchyRequest 

type ShowCesHierarchyRequest struct {

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

ShowCesHierarchyRequest Request Object

func (ShowCesHierarchyRequest) String 

func (o ShowCesHierarchyRequest) String() string

type ShowCesHierarchyResponse 

type ShowCesHierarchyResponse struct {

	// 监控维度。
	Dimensions *[]ShowCeshierarchyRespDimensions `json:"dimensions,omitempty"`

	// 实例信息。
	InstanceIds *[]ShowCeshierarchyRespInstanceIds `json:"instance_ids,omitempty"`

	// 节点信息。
	Nodes *[]ShowCeshierarchyRespNodes `json:"nodes,omitempty"`

	// 队列信息。
	Queues *[]ShowCeshierarchyRespQueues `json:"queues,omitempty"`

	// 消费组信息。
	Groups         *[]ShowCeshierarchyRespGroups `json:"groups,omitempty"`
	HttpStatusCode int                           `json:"-"`
}

ShowCesHierarchyResponse Response Object

func (ShowCesHierarchyResponse) String 

func (o ShowCesHierarchyResponse) String() string

type ShowCeshierarchyRespChildren 

type ShowCeshierarchyRespChildren struct {

	// 子维度名称。
	Name *string `json:"name,omitempty"`

	// 监控指标名称列表。
	Metrics *[]string `json:"metrics,omitempty"`

	// 监控查询使用的key。
	KeyName *[]string `json:"key_name,omitempty"`

	// 监控维度路由。
	DimRouter *[]string `json:"dim_router,omitempty"`
}

ShowCeshierarchyRespChildren 子维度信息。

func (ShowCeshierarchyRespChildren) String 

func (o ShowCeshierarchyRespChildren) String() string

type ShowCeshierarchyRespDimensions 

type ShowCeshierarchyRespDimensions struct {

	// 监控维度名称。
	Name *string `json:"name,omitempty"`

	// 监控指标名称。
	Metrics *[]string `json:"metrics,omitempty"`

	// 监控查询使用的key。
	KeyName *[]string `json:"key_name,omitempty"`

	// 监控维度路由。
	DimRouter *[]string `json:"dim_router,omitempty"`

	// 子维度列表。
	Children *[]ShowCeshierarchyRespChildren `json:"children,omitempty"`
}

func (ShowCeshierarchyRespDimensions) String 

func (o ShowCeshierarchyRespDimensions) String() string

type ShowCeshierarchyRespGroups 

type ShowCeshierarchyRespGroups struct {

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

	// topic信息。
	Queues *[]ShowCeshierarchyRespQueues1 `json:"queues,omitempty"`
}

func (ShowCeshierarchyRespGroups) String 

func (o ShowCeshierarchyRespGroups) String() string

type ShowCeshierarchyRespInstanceIds 

type ShowCeshierarchyRespInstanceIds struct {

	// 实例ID。
	Name *string `json:"name,omitempty"`
}

func (ShowCeshierarchyRespInstanceIds) String 

func (o ShowCeshierarchyRespInstanceIds) String() string

type ShowCeshierarchyRespNodes 

type ShowCeshierarchyRespNodes struct {

	// 节点名称。
	Name *string `json:"name,omitempty"`
}

func (ShowCeshierarchyRespNodes) String 

func (o ShowCeshierarchyRespNodes) String() string

type ShowCeshierarchyRespPartitions 

type ShowCeshierarchyRespPartitions struct {

	// 分区名称。
	Name *string `json:"name,omitempty"`
}

func (ShowCeshierarchyRespPartitions) String 

func (o ShowCeshierarchyRespPartitions) String() string

type ShowCeshierarchyRespQueues 

type ShowCeshierarchyRespQueues struct {

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

	// 分区列表。
	Partitions *[]ShowCeshierarchyRespPartitions `json:"partitions,omitempty"`
}

func (ShowCeshierarchyRespQueues) String 

func (o ShowCeshierarchyRespQueues) String() string

type ShowCeshierarchyRespQueues1 

type ShowCeshierarchyRespQueues1 struct {

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

	// 分区信息。
	Partitions *[]ShowCeshierarchyRespPartitions `json:"partitions,omitempty"`
}

func (ShowCeshierarchyRespQueues1) String 

func (o ShowCeshierarchyRespQueues1) String() string

type ShowClusterRequest 

type ShowClusterRequest struct {

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

ShowClusterRequest Request Object

func (ShowClusterRequest) String 

func (o ShowClusterRequest) String() string

type ShowClusterRespCluster 

type ShowClusterRespCluster struct {

	// 控制器ID。
	Controller *string `json:"controller,omitempty"`

	// 节点列表。
	Brokers *[]ShowClusterRespClusterBrokers `json:"brokers,omitempty"`

	// 主题数量。
	TopicsCount *int32 `json:"topics_count,omitempty"`

	// 分区数量。
	PartitionsCount *int32 `json:"partitions_count,omitempty"`

	// 在线分区数量。
	OnlinePartitionsCount *int32 `json:"online_partitions_count,omitempty"`

	// 副本数量。
	ReplicasCount *int32 `json:"replicas_count,omitempty"`

	// ISR（In-Sync Replicas） 副本总数。
	IsrReplicasCount *int32 `json:"isr_replicas_count,omitempty"`

	// 消费组数量。
	ConsumersCount *int32 `json:"consumers_count,omitempty"`
}

ShowClusterRespCluster 集群基本信息。

func (ShowClusterRespCluster) String 

func (o ShowClusterRespCluster) String() string

type ShowClusterRespClusterBrokers 

type ShowClusterRespClusterBrokers struct {

	// 节点IP。
	Host *string `json:"host,omitempty"`

	// 端口号。
	Port *int32 `json:"port,omitempty"`

	// 节点ID。
	BrokerId *string `json:"broker_id,omitempty"`

	// 是否为contoller节点。
	IsController *bool `json:"is_controller,omitempty"`

	// 服务端版本。
	Version *string `json:"version,omitempty"`

	// broker注册时间，为unix时间戳格式。
	RegisterTime *int64 `json:"register_time,omitempty"`

	// Kafka实例节点的连通性是否正常。
	IsHealth *bool `json:"is_health,omitempty"`
}

ShowClusterRespClusterBrokers 节点。

func (ShowClusterRespClusterBrokers) String 

func (o ShowClusterRespClusterBrokers) String() string

type ShowClusterResponse 

type ShowClusterResponse struct {
	Cluster        *ShowClusterRespCluster `json:"cluster,omitempty"`
	HttpStatusCode int                     `json:"-"`
}

ShowClusterResponse Response Object

func (ShowClusterResponse) String 

func (o ShowClusterResponse) String() string

type ShowCoordinatorsRequest 

type ShowCoordinatorsRequest struct {

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

ShowCoordinatorsRequest Request Object

func (ShowCoordinatorsRequest) String 

func (o ShowCoordinatorsRequest) String() string

type ShowCoordinatorsRespCoordinators 

type ShowCoordinatorsRespCoordinators struct {

	// 消费组ID。
	GroupId *string `json:"group_id,omitempty"`

	// 对应协调器的broker id。
	Id *int32 `json:"id,omitempty"`

	// 对应协调器的地址。
	Host *string `json:"host,omitempty"`

	// 端口号。
	Port *int32 `json:"port,omitempty"`
}

ShowCoordinatorsRespCoordinators 协调器信息。

func (ShowCoordinatorsRespCoordinators) String 

func (o ShowCoordinatorsRespCoordinators) String() string

type ShowCoordinatorsResponse 

type ShowCoordinatorsResponse struct {

	// 所有消费组对应的协调器列表。
	Coordinators   *[]ShowCoordinatorsRespCoordinators `json:"coordinators,omitempty"`
	HttpStatusCode int                                 `json:"-"`
}

ShowCoordinatorsResponse Response Object

func (ShowCoordinatorsResponse) String 

func (o ShowCoordinatorsResponse) String() string

type ShowEngineInstanceExtendProductInfoRequest added in v0.1.24 

type ShowEngineInstanceExtendProductInfoRequest struct {

	// 消息引擎。
	Engine ShowEngineInstanceExtendProductInfoRequestEngine `json:"engine"`

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

	// 产品的类型。 - advanced: 专享版
	Type ShowEngineInstanceExtendProductInfoRequestType `json:"type"`
}

ShowEngineInstanceExtendProductInfoRequest Request Object

func (ShowEngineInstanceExtendProductInfoRequest) String added in v0.1.24 

func (o ShowEngineInstanceExtendProductInfoRequest) String() string

type ShowEngineInstanceExtendProductInfoRequestEngine added in v0.1.24 

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

func (ShowEngineInstanceExtendProductInfoRequestEngine) MarshalJSON added in v0.1.24 

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

func (*ShowEngineInstanceExtendProductInfoRequestEngine) UnmarshalJSON added in v0.1.24 

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

func (ShowEngineInstanceExtendProductInfoRequestEngine) Value added in v0.1.24 

func (c ShowEngineInstanceExtendProductInfoRequestEngine) Value() string

type ShowEngineInstanceExtendProductInfoRequestEngineEnum added in v0.1.24 

type ShowEngineInstanceExtendProductInfoRequestEngineEnum struct {
	KAFKA ShowEngineInstanceExtendProductInfoRequestEngine
}

func GetShowEngineInstanceExtendProductInfoRequestEngineEnum added in v0.1.24 

func GetShowEngineInstanceExtendProductInfoRequestEngineEnum() ShowEngineInstanceExtendProductInfoRequestEngineEnum

type ShowEngineInstanceExtendProductInfoRequestType added in v0.1.24 

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

func (ShowEngineInstanceExtendProductInfoRequestType) MarshalJSON added in v0.1.24 

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

func (*ShowEngineInstanceExtendProductInfoRequestType) UnmarshalJSON added in v0.1.24 

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

func (ShowEngineInstanceExtendProductInfoRequestType) Value added in v0.1.24 

func (c ShowEngineInstanceExtendProductInfoRequestType) Value() string

type ShowEngineInstanceExtendProductInfoRequestTypeEnum added in v0.1.24 

type ShowEngineInstanceExtendProductInfoRequestTypeEnum struct {
	ADVANCED ShowEngineInstanceExtendProductInfoRequestType
}

func GetShowEngineInstanceExtendProductInfoRequestTypeEnum added in v0.1.24 

func GetShowEngineInstanceExtendProductInfoRequestTypeEnum() ShowEngineInstanceExtendProductInfoRequestTypeEnum

type ShowEngineInstanceExtendProductInfoResponse added in v0.1.24 

type ShowEngineInstanceExtendProductInfoResponse struct {

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

	// 消息引擎支持的版本。
	Versions *[]string `json:"versions,omitempty"`

	// 规格变更的产品信息。
	Products       *[]ExtendProductInfoEntity `json:"products,omitempty"`
	HttpStatusCode int                        `json:"-"`
}

ShowEngineInstanceExtendProductInfoResponse Response Object

func (ShowEngineInstanceExtendProductInfoResponse) String added in v0.1.24 

func (o ShowEngineInstanceExtendProductInfoResponse) String() string

type ShowGroupsRequest 

type ShowGroupsRequest struct {

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

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

ShowGroupsRequest Request Object

func (ShowGroupsRequest) String 

func (o ShowGroupsRequest) String() string

type ShowGroupsRespGroup 

type ShowGroupsRespGroup struct {

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

	// 消费组状态。包含以下状态： - Dead：消费组内没有任何成员，且没有任何元数据。 - Empty：消费组内没有任何成员，存在元数据。 - PreparingRebalance：准备开启rebalance。 - CompletingRebalance：所有成员加入group。 - Stable：消费组内成员可正常消费。
	State *string `json:"state,omitempty"`

	// 协调器编号。
	CoordinatorId *int32 `json:"coordinator_id,omitempty"`

	// 消费者列表。
	Members *[]ShowGroupsRespGroupMembers `json:"members,omitempty"`

	// 消费进度。
	GroupMessageOffsets *[]ShowGroupsRespGroupGroupMessageOffsets `json:"group_message_offsets,omitempty"`

	// 分区分配策略。
	AssignmentStrategy *string `json:"assignment_strategy,omitempty"`
}

ShowGroupsRespGroup 消费组信息。

func (ShowGroupsRespGroup) String 

func (o ShowGroupsRespGroup) String() string

type ShowGroupsRespGroupAssignment 

type ShowGroupsRespGroupAssignment struct {

	// topic名称。
	Topic *string `json:"topic,omitempty"`

	// 分区列表。
	Partitions *[]int32 `json:"partitions,omitempty"`
}

func (ShowGroupsRespGroupAssignment) String 

func (o ShowGroupsRespGroupAssignment) String() string

type ShowGroupsRespGroupGroupMessageOffsets 

type ShowGroupsRespGroupGroupMessageOffsets struct {

	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`

	// 剩余可消费消息数，即消息堆积数。
	Lag *int32 `json:"lag,omitempty"`

	// topic名称。
	Topic *string `json:"topic,omitempty"`

	// 当前消费进度。
	MessageCurrentOffset *int32 `json:"message_current_offset,omitempty"`

	// 最大消息位置（LEO）。
	MessageLogEndOffset *int32 `json:"message_log_end_offset,omitempty"`
}

func (ShowGroupsRespGroupGroupMessageOffsets) String 

func (o ShowGroupsRespGroupGroupMessageOffsets) String() string

type ShowGroupsRespGroupMembers 

type ShowGroupsRespGroupMembers struct {

	// 消费组consumer地址。
	Host *string `json:"host,omitempty"`

	// consumer分配到的分区信息。
	Assignment *[]ShowGroupsRespGroupAssignment `json:"assignment,omitempty"`

	// 消费组consumer的ID。
	MemberId *string `json:"member_id,omitempty"`

	// 客户端ID。
	ClientId *string `json:"client_id,omitempty"`
}

func (ShowGroupsRespGroupMembers) String 

func (o ShowGroupsRespGroupMembers) String() string

type ShowGroupsResponse 

type ShowGroupsResponse struct {
	Group          *ShowGroupsRespGroup `json:"group,omitempty"`
	HttpStatusCode int                  `json:"-"`
}

ShowGroupsResponse Response Object

func (ShowGroupsResponse) String 

func (o ShowGroupsResponse) String() string

type ShowInstanceConfigsRequest added in v0.1.65 

type ShowInstanceConfigsRequest struct {

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

ShowInstanceConfigsRequest Request Object

func (ShowInstanceConfigsRequest) String added in v0.1.65 

func (o ShowInstanceConfigsRequest) String() string

type ShowInstanceConfigsResponse added in v0.1.65 

type ShowInstanceConfigsResponse struct {

	// kafka配置列表。
	KafkaConfigs   *[]InstanceConfig `json:"kafka_configs,omitempty"`
	HttpStatusCode int               `json:"-"`
}

ShowInstanceConfigsResponse Response Object

func (ShowInstanceConfigsResponse) String added in v0.1.65 

func (o ShowInstanceConfigsResponse) String() string

type ShowInstanceExtendProductInfoRequest 

type ShowInstanceExtendProductInfoRequest struct {

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

	// [产品的类型。 - advanced: 专享版 - platinum: 铂金版 - dec: 专属云版 - exp: 体验版](tag:hws,hws_hk,ctc,sbc,hk_sbc,cmcc,hws_eu)
	Type ShowInstanceExtendProductInfoRequestType `json:"type"`

	// 消息引擎的类型。当前支持的类型为kafka。
	Engine ShowInstanceExtendProductInfoRequestEngine `json:"engine"`
}

ShowInstanceExtendProductInfoRequest Request Object

func (ShowInstanceExtendProductInfoRequest) String 

func (o ShowInstanceExtendProductInfoRequest) String() string

type ShowInstanceExtendProductInfoRequestEngine added in v0.0.103 

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

func (ShowInstanceExtendProductInfoRequestEngine) MarshalJSON added in v0.0.103 

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

func (*ShowInstanceExtendProductInfoRequestEngine) UnmarshalJSON added in v0.0.103 

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

func (ShowInstanceExtendProductInfoRequestEngine) Value added in v0.0.103 

func (c ShowInstanceExtendProductInfoRequestEngine) Value() string

type ShowInstanceExtendProductInfoRequestEngineEnum added in v0.0.103 

type ShowInstanceExtendProductInfoRequestEngineEnum struct {
	KAFKA ShowInstanceExtendProductInfoRequestEngine
}

func GetShowInstanceExtendProductInfoRequestEngineEnum added in v0.0.103 

func GetShowInstanceExtendProductInfoRequestEngineEnum() ShowInstanceExtendProductInfoRequestEngineEnum

type ShowInstanceExtendProductInfoRequestType 

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

func (ShowInstanceExtendProductInfoRequestType) MarshalJSON 

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

func (*ShowInstanceExtendProductInfoRequestType) UnmarshalJSON 

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

func (ShowInstanceExtendProductInfoRequestType) Value added in v0.0.90 

func (c ShowInstanceExtendProductInfoRequestType) Value() string

type ShowInstanceExtendProductInfoRequestTypeEnum 

type ShowInstanceExtendProductInfoRequestTypeEnum struct {
	ADVANCED ShowInstanceExtendProductInfoRequestType
	PLATINUM ShowInstanceExtendProductInfoRequestType
	DEC      ShowInstanceExtendProductInfoRequestType
	EXP      ShowInstanceExtendProductInfoRequestType
}

func GetShowInstanceExtendProductInfoRequestTypeEnum 

func GetShowInstanceExtendProductInfoRequestTypeEnum() ShowInstanceExtendProductInfoRequestTypeEnum

type ShowInstanceExtendProductInfoRespDetail added in v0.1.11 

type ShowInstanceExtendProductInfoRespDetail struct {

	// 单位时间内的消息量最大值。
	Tps *string `json:"tps,omitempty"`

	// 消息存储空间。
	Storage *string `json:"storage,omitempty"`

	// Kafka实例的分区数量。
	PartitionNum *string `json:"partition_num,omitempty"`

	// 产品ID。
	ProductId *string `json:"product_id,omitempty"`

	// 规格ID。
	SpecCode *string `json:"spec_code,omitempty"`

	// IO信息。
	Io *[]ListProductsRespIo `json:"io,omitempty"`

	// Kafka实例的基准带宽。
	Bandwidth *string `json:"bandwidth,omitempty"`

	// Kafka实例最大消费组数参考值。
	RecommendMaxConsGroups *string `json:"recommend_max_consGroups,omitempty"`

	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 该产品规格对应的虚拟机规格。
	EcsFlavorId *string `json:"ecs_flavor_id,omitempty"`

	// 实例规格架构类型。当前仅支持X86。
	ArchType *string `json:"arch_type,omitempty"`
}

func (ShowInstanceExtendProductInfoRespDetail) String added in v0.1.11 

func (o ShowInstanceExtendProductInfoRespDetail) String() string

type ShowInstanceExtendProductInfoRespHourly added in v0.1.11 

type ShowInstanceExtendProductInfoRespHourly struct {

	// 消息引擎的名称，该字段显示为kafka。
	Name *string `json:"name,omitempty"`

	// 消息引擎的版本，当前仅支持1.1.0和2.3.0。
	Version *string `json:"version,omitempty"`

	// 产品规格列表。
	Values *[]ShowInstanceExtendProductInfoRespValues `json:"values,omitempty"`
}

func (ShowInstanceExtendProductInfoRespHourly) String added in v0.1.11 

func (o ShowInstanceExtendProductInfoRespHourly) String() string

type ShowInstanceExtendProductInfoRespValues added in v0.1.11 

type ShowInstanceExtendProductInfoRespValues struct {

	// 规格详情。
	Detail *[]ShowInstanceExtendProductInfoRespDetail `json:"detail,omitempty"`

	// 实例类型。
	Name *string `json:"name,omitempty"`

	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`

	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`
}

func (ShowInstanceExtendProductInfoRespValues) String added in v0.1.11 

func (o ShowInstanceExtendProductInfoRespValues) String() string

type ShowInstanceExtendProductInfoResponse 

type ShowInstanceExtendProductInfoResponse struct {

	// 表示[按需付费的](tag:hws,hws_hk,hws_ocb,ctc,sbc,hk_sbc,cmcc,g42,tm,hk_g42,hk_tm)产品列表。
	Hourly *[]ShowInstanceExtendProductInfoRespHourly `json:"hourly,omitempty"`

	// 表示包年包月的产品列表。当前暂不支持通过API创建包年包月的Kafka实例。
	Monthly        *[]ShowInstanceExtendProductInfoRespHourly `json:"monthly,omitempty"`
	HttpStatusCode int                                        `json:"-"`
}

ShowInstanceExtendProductInfoResponse Response Object

func (ShowInstanceExtendProductInfoResponse) String 

func (o ShowInstanceExtendProductInfoResponse) String() string

type ShowInstanceMessagesRequest 

type ShowInstanceMessagesRequest struct {

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

	// Topic名称。  Topic名称必现以字母开头且只支持大小写字母、中横线、下划线以及数字。
	Topic string `json:"topic"`

	// 是否按照时间排序。
	Asc *bool `json:"asc,omitempty"`

	// 开始时间。  Unix毫秒时间戳。  查询消息偏移量时，为必选参数。
	StartTime *string `json:"start_time,omitempty"`

	// 结束时间。  Unix毫秒时间戳。  查询消息偏移量时，为必选参数。
	EndTime *string `json:"end_time,omitempty"`

	// 每一页显示的message数量。
	Limit *string `json:"limit,omitempty"`

	// 页数。
	Offset *string `json:"offset,omitempty"`

	// 是否下载。
	Download *bool `json:"download,omitempty"`

	// 消息偏移量。  **查询消息内容时，为必选参数。**  若start_time、end_time参数不为空，该参数无效。
	MessageOffset *string `json:"message_offset,omitempty"`

	// 分区。  **查询消息内容时，为必选参数。**  若start_time、end_time参数不为空，该参数无效。
	Partition *string `json:"partition,omitempty"`

	// 关键词。 取值范围为0~50。
	Keyword *string `json:"keyword,omitempty"`
}

ShowInstanceMessagesRequest Request Object

func (ShowInstanceMessagesRequest) String 

func (o ShowInstanceMessagesRequest) String() string

type ShowInstanceMessagesResponse 

type ShowInstanceMessagesResponse struct {

	// 消息列表。
	Messages *[]MessagesEntity `json:"messages,omitempty"`

	// 消息总条数。
	Total *int64 `json:"total,omitempty"`

	// 每页消息条数。
	Size           *int64 `json:"size,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowInstanceMessagesResponse Response Object

func (ShowInstanceMessagesResponse) String 

func (o ShowInstanceMessagesResponse) String() string

type ShowInstanceRequest 

type ShowInstanceRequest struct {

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

ShowInstanceRequest Request Object

func (ShowInstanceRequest) String 

func (o ShowInstanceRequest) String() string

type ShowInstanceResp added in v0.0.66 

type ShowInstanceResp struct {

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

	// 引擎。
	Engine *string `json:"engine,omitempty"`

	// 版本。
	EngineVersion *string `json:"engine_version,omitempty"`

	// 实例描述。
	Description *string `json:"description,omitempty"`

	// 实例规格。
	Specification *string `json:"specification,omitempty"`

	// 消息存储空间，单位：GB。
	StorageSpace *int32 `json:"storage_space,omitempty"`

	// Kafka实例的分区数量。
	PartitionNum *string `json:"partition_num,omitempty"`

	// 已使用的消息存储空间，单位：GB。
	UsedStorageSpace *int32 `json:"used_storage_space,omitempty"`

	// 实例连接IP地址。
	ConnectAddress *string `json:"connect_address,omitempty"`

	// 实例连接端口。
	Port *int32 `json:"port,omitempty"`

	// 实例的状态。详细状态说明请参考[实例状态说明](kafka-api-180514012.xml)。
	Status *string `json:"status,omitempty"`

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

	// 资源规格标识。   - dms.instance.kafka.cluster.c3.mini：Kafka实例的基准带宽为100MByte/秒。   - dms.instance.kafka.cluster.c3.small.2：Kafka实例的基准带宽为300MByte/秒。   - dms.instance.kafka.cluster.c3.middle.2：Kafka实例的基准带宽为600MByte/秒。   - dms.instance.kafka.cluster.c3.high.2：Kafka实例的基准带宽为1200MByte/秒。
	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`

	// [付费模式，1表示按需计费，0表示包年/包月计费。](tag:hws,hws_hk,ctc,sbc,hk_sbc,cmcc,hws_eu)[付费模式，暂未使用。](tag:hws_ocb,ocb) [付费模式，1表示按需计费。](tag:otc,dt,g42,tm,hk_g42,hk_tm)
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// VPC ID。
	VpcId *string `json:"vpc_id,omitempty"`

	// VPC的名称。
	VpcName *string `json:"vpc_name,omitempty"`

	// 完成创建时间。  格式为时间戳，指从格林威治时间 1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。
	CreatedAt *string `json:"created_at,omitempty"`

	// 子网名称。
	SubnetName *string `json:"subnet_name,omitempty"`

	// 子网网段。
	SubnetCidr *string `json:"subnet_cidr,omitempty"`

	// 用户ID。
	UserId *string `json:"user_id,omitempty"`

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

	// 实例访问用户名。
	AccessUser *string `json:"access_user,omitempty"`

	// 订单ID，只有在包周期计费时才会有order_id值，其他计费方式order_id值为空。
	OrderId *string `json:"order_id,omitempty"`

	// 维护时间窗开始时间，格式为HH:mm:ss。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm:ss。
	MaintainEnd *string `json:"maintain_end,omitempty"`

	// 实例是否开启公网访问功能。 - true：开启 - false：未开启
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// Kafka实例的Kafka Manager连接地址。
	ManagementConnectAddress *string `json:"management_connect_address,omitempty"`

	// 是否开启安全认证。 - true：开启 - false：未开启
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 开启SASL后使用的安全协议。 - SASL_SSL: 采用SSL证书进行加密传输，支持帐号密码认证，安全性更高。 - SASL_PLAINTEXT: 明文传输，支持帐号密码认证，性能更好，仅支持SCRAM-SHA-512机制。
	KafkaSecurityProtocol *string `json:"kafka_security_protocol,omitempty"`

	// 开启SASL后使用的认证机制。 - PLAIN: 简单的用户名密码校验。 - SCRAM-SHA-512: 用户凭证校验，安全性比PLAIN机制更高。
	SaslEnabledMechanisms *[]ShowInstanceRespSaslEnabledMechanisms `json:"sasl_enabled_mechanisms,omitempty"`

	// 是否开启双向认证。
	SslTwoWayEnable *bool `json:"ssl_two_way_enable,omitempty"`

	// 是否能够证书替换。
	CertReplaced *bool `json:"cert_replaced,omitempty"`

	// 公网访问Kafka Manager连接地址。
	PublicManagementConnectAddress *string `json:"public_management_connect_address,omitempty"`

	// 企业项目ID。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 实例扩容时用于区分老实例与新实例。 - true：新创建的实例，允许磁盘动态扩容不需要重启。 - false：老实例
	IsLogicalVolume *bool `json:"is_logical_volume,omitempty"`

	// 实例扩容磁盘次数，如果超过20次则无法扩容磁盘。
	ExtendTimes *int32 `json:"extend_times,omitempty"`

	// 是否打开kafka自动创建topic功能。   - true：开启   - false：关闭
	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`

	// 实例类型：集群，cluster。
	Type *ShowInstanceRespType `json:"type,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"`

	// 实例节点所在的可用区，返回“可用区ID”。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 总共消息存储空间，单位：GB。
	TotalStorageSpace *int32 `json:"total_storage_space,omitempty"`

	// 实例公网连接IP地址。当实例开启了公网访问，实例才包含该参数。
	PublicConnectAddress *string `json:"public_connect_address,omitempty"`

	// 存储资源ID。
	StorageResourceId *string `json:"storage_resource_id,omitempty"`

	// IO规格。
	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	// 服务类型。
	ServiceType *string `json:"service_type,omitempty"`

	// 存储类型。
	StorageType *string `json:"storage_type,omitempty"`

	// 消息老化策略。
	RetentionPolicy *ShowInstanceRespRetentionPolicy `json:"retention_policy,omitempty"`

	// Kafka公网开启状态。
	KafkaPublicStatus *string `json:"kafka_public_status,omitempty"`

	// kafka公网访问带宽。
	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`

	// 是否已开启kafka manager
	KafkaManagerEnable *bool `json:"kafka_manager_enable,omitempty"`

	// 登录Kafka Manager的用户名。
	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`

	// 是否开启消息收集功能。
	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`

	// 跨VPC访问信息。
	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`

	// 是否开启ipv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	// IPv6的连接地址。
	Ipv6ConnectAddresses *[]string `json:"ipv6_connect_addresses,omitempty"`

	// 是否开启转储。新规格产品暂不支持开启转储。
	ConnectorEnable *bool `json:"connector_enable,omitempty"`

	// 转储任务ID。
	ConnectorId *string `json:"connector_id,omitempty"`

	// 是否开启Kafka rest功能。
	RestEnable *bool `json:"rest_enable,omitempty"`

	// Kafka rest连接地址。
	RestConnectAddress *string `json:"rest_connect_address,omitempty"`

	// kafka公网访问带宽。待删除版本。
	PublicBoundwidth *int32 `json:"public_boundwidth,omitempty"`

	// 是否开启消息查询功能。
	MessageQueryInstEnable *bool `json:"message_query_inst_enable,omitempty"`

	// 是否开启VPC明文访问。
	VpcClientPlain *bool `json:"vpc_client_plain,omitempty"`

	// Kafka实例支持的特性功能。
	SupportFeatures *string `json:"support_features,omitempty"`

	// 是否开启消息轨迹功能。
	TraceEnable *bool `json:"trace_enable,omitempty"`

	// 是否开启代理。
	AgentEnable *bool `json:"agent_enable,omitempty"`

	// 租户侧连接地址。
	PodConnectAddress *string `json:"pod_connect_address,omitempty"`

	// 是否开启磁盘加密。
	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`

	// 磁盘加密key，未开启磁盘加密时为空。
	DiskEncryptedKey *string `json:"disk_encrypted_key,omitempty"`

	// Kafka实例私有连接地址。
	KafkaPrivateConnectAddress *string `json:"kafka_private_connect_address,omitempty"`

	// 云监控版本。
	CesVersion *string `json:"ces_version,omitempty"`

	// 区分实例什么时候开启的公网访问：true,actived,closed,false。
	PublicAccessEnabled *string `json:"public_access_enabled,omitempty"`

	// 节点数。
	NodeNum *int32 `json:"node_num,omitempty"`

	// 是否开启访问控制。
	EnableAcl *bool `json:"enable_acl,omitempty"`

	// 是否启用新规格计费。
	NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty"`

	// 节点数量。
	BrokerNum *int32 `json:"broker_num,omitempty"`

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

	// 是否为容灾实例。
	DrEnable *bool `json:"dr_enable,omitempty"`
}

func (ShowInstanceResp) String added in v0.0.66 

func (o ShowInstanceResp) String() string

type ShowInstanceRespRetentionPolicy added in v0.0.66 

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

func (ShowInstanceRespRetentionPolicy) MarshalJSON added in v0.0.66 

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

func (*ShowInstanceRespRetentionPolicy) UnmarshalJSON added in v0.0.66 

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

func (ShowInstanceRespRetentionPolicy) Value added in v0.0.90 

func (c ShowInstanceRespRetentionPolicy) Value() string

type ShowInstanceRespRetentionPolicyEnum added in v0.0.66 

type ShowInstanceRespRetentionPolicyEnum struct {
	TIME_BASE      ShowInstanceRespRetentionPolicy
	PRODUCE_REJECT ShowInstanceRespRetentionPolicy
}

func GetShowInstanceRespRetentionPolicyEnum added in v0.0.66 

func GetShowInstanceRespRetentionPolicyEnum() ShowInstanceRespRetentionPolicyEnum

type ShowInstanceRespSaslEnabledMechanisms added in v0.1.38 

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

func (ShowInstanceRespSaslEnabledMechanisms) MarshalJSON added in v0.1.38 

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

func (*ShowInstanceRespSaslEnabledMechanisms) UnmarshalJSON added in v0.1.38 

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

func (ShowInstanceRespSaslEnabledMechanisms) Value added in v0.1.38 

func (c ShowInstanceRespSaslEnabledMechanisms) Value() string

type ShowInstanceRespSaslEnabledMechanismsEnum added in v0.1.38 

type ShowInstanceRespSaslEnabledMechanismsEnum struct {
	PLAIN         ShowInstanceRespSaslEnabledMechanisms
	SCRAM_SHA_512 ShowInstanceRespSaslEnabledMechanisms
}

func GetShowInstanceRespSaslEnabledMechanismsEnum added in v0.1.38 

func GetShowInstanceRespSaslEnabledMechanismsEnum() ShowInstanceRespSaslEnabledMechanismsEnum

type ShowInstanceRespType added in v0.0.66 

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

func (ShowInstanceRespType) MarshalJSON added in v0.0.66 

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

func (*ShowInstanceRespType) UnmarshalJSON added in v0.0.66 

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

func (ShowInstanceRespType) Value added in v0.0.90 

func (c ShowInstanceRespType) Value() string

type ShowInstanceRespTypeEnum added in v0.0.66 

type ShowInstanceRespTypeEnum struct {
	SINGLE  ShowInstanceRespType
	CLUSTER ShowInstanceRespType
}

func GetShowInstanceRespTypeEnum added in v0.0.66 

func GetShowInstanceRespTypeEnum() ShowInstanceRespTypeEnum

type ShowInstanceResponse 

type ShowInstanceResponse struct {

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

	// 引擎。
	Engine *string `json:"engine,omitempty"`

	// 版本。
	EngineVersion *string `json:"engine_version,omitempty"`

	// 实例描述。
	Description *string `json:"description,omitempty"`

	// 实例规格。
	Specification *string `json:"specification,omitempty"`

	// 消息存储空间，单位：GB。
	StorageSpace *int32 `json:"storage_space,omitempty"`

	// Kafka实例的分区数量。
	PartitionNum *string `json:"partition_num,omitempty"`

	// 已使用的消息存储空间，单位：GB。
	UsedStorageSpace *int32 `json:"used_storage_space,omitempty"`

	// 实例连接IP地址。
	ConnectAddress *string `json:"connect_address,omitempty"`

	// 实例连接端口。
	Port *int32 `json:"port,omitempty"`

	// 实例的状态。详细状态说明请参考[实例状态说明](kafka-api-180514012.xml)。
	Status *string `json:"status,omitempty"`

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

	// 资源规格标识。   - dms.instance.kafka.cluster.c3.mini：Kafka实例的基准带宽为100MByte/秒。   - dms.instance.kafka.cluster.c3.small.2：Kafka实例的基准带宽为300MByte/秒。   - dms.instance.kafka.cluster.c3.middle.2：Kafka实例的基准带宽为600MByte/秒。   - dms.instance.kafka.cluster.c3.high.2：Kafka实例的基准带宽为1200MByte/秒。
	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`

	// [付费模式，1表示按需计费，0表示包年/包月计费。](tag:hws,hws_hk,ctc,sbc,hk_sbc,cmcc,hws_eu)[付费模式，暂未使用。](tag:hws_ocb,ocb) [付费模式，1表示按需计费。](tag:otc,dt,g42,tm,hk_g42,hk_tm)
	ChargingMode *int32 `json:"charging_mode,omitempty"`

	// VPC ID。
	VpcId *string `json:"vpc_id,omitempty"`

	// VPC的名称。
	VpcName *string `json:"vpc_name,omitempty"`

	// 完成创建时间。  格式为时间戳，指从格林威治时间 1970年01月01日00时00分00秒起至指定时间的偏差总毫秒数。
	CreatedAt *string `json:"created_at,omitempty"`

	// 子网名称。
	SubnetName *string `json:"subnet_name,omitempty"`

	// 子网网段。
	SubnetCidr *string `json:"subnet_cidr,omitempty"`

	// 用户ID。
	UserId *string `json:"user_id,omitempty"`

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

	// 实例访问用户名。
	AccessUser *string `json:"access_user,omitempty"`

	// 订单ID，只有在包周期计费时才会有order_id值，其他计费方式order_id值为空。
	OrderId *string `json:"order_id,omitempty"`

	// 维护时间窗开始时间，格式为HH:mm:ss。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm:ss。
	MaintainEnd *string `json:"maintain_end,omitempty"`

	// 实例是否开启公网访问功能。 - true：开启 - false：未开启
	EnablePublicip *bool `json:"enable_publicip,omitempty"`

	// Kafka实例的Kafka Manager连接地址。
	ManagementConnectAddress *string `json:"management_connect_address,omitempty"`

	// 是否开启安全认证。 - true：开启 - false：未开启
	SslEnable *bool `json:"ssl_enable,omitempty"`

	// 开启SASL后使用的安全协议。 - SASL_SSL: 采用SSL证书进行加密传输，支持帐号密码认证，安全性更高。 - SASL_PLAINTEXT: 明文传输，支持帐号密码认证，性能更好，仅支持SCRAM-SHA-512机制。
	KafkaSecurityProtocol *string `json:"kafka_security_protocol,omitempty"`

	// 开启SASL后使用的认证机制。 - PLAIN: 简单的用户名密码校验。 - SCRAM-SHA-512: 用户凭证校验，安全性比PLAIN机制更高。
	SaslEnabledMechanisms *[]ShowInstanceResponseSaslEnabledMechanisms `json:"sasl_enabled_mechanisms,omitempty"`

	// 是否开启双向认证。
	SslTwoWayEnable *bool `json:"ssl_two_way_enable,omitempty"`

	// 是否能够证书替换。
	CertReplaced *bool `json:"cert_replaced,omitempty"`

	// 公网访问Kafka Manager连接地址。
	PublicManagementConnectAddress *string `json:"public_management_connect_address,omitempty"`

	// 企业项目ID。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`

	// 实例扩容时用于区分老实例与新实例。 - true：新创建的实例，允许磁盘动态扩容不需要重启。 - false：老实例
	IsLogicalVolume *bool `json:"is_logical_volume,omitempty"`

	// 实例扩容磁盘次数，如果超过20次则无法扩容磁盘。
	ExtendTimes *int32 `json:"extend_times,omitempty"`

	// 是否打开kafka自动创建topic功能。   - true：开启   - false：关闭
	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`

	// 实例类型：集群，cluster。
	Type *ShowInstanceResponseType `json:"type,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"`

	// 实例节点所在的可用区，返回“可用区ID”。
	AvailableZones *[]string `json:"available_zones,omitempty"`

	// 总共消息存储空间，单位：GB。
	TotalStorageSpace *int32 `json:"total_storage_space,omitempty"`

	// 实例公网连接IP地址。当实例开启了公网访问，实例才包含该参数。
	PublicConnectAddress *string `json:"public_connect_address,omitempty"`

	// 存储资源ID。
	StorageResourceId *string `json:"storage_resource_id,omitempty"`

	// IO规格。
	StorageSpecCode *string `json:"storage_spec_code,omitempty"`

	// 服务类型。
	ServiceType *string `json:"service_type,omitempty"`

	// 存储类型。
	StorageType *string `json:"storage_type,omitempty"`

	// 消息老化策略。
	RetentionPolicy *ShowInstanceResponseRetentionPolicy `json:"retention_policy,omitempty"`

	// Kafka公网开启状态。
	KafkaPublicStatus *string `json:"kafka_public_status,omitempty"`

	// kafka公网访问带宽。
	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`

	// 是否已开启kafka manager
	KafkaManagerEnable *bool `json:"kafka_manager_enable,omitempty"`

	// 登录Kafka Manager的用户名。
	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`

	// 是否开启消息收集功能。
	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`

	// 跨VPC访问信息。
	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`

	// 是否开启ipv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`

	// IPv6的连接地址。
	Ipv6ConnectAddresses *[]string `json:"ipv6_connect_addresses,omitempty"`

	// 是否开启转储。新规格产品暂不支持开启转储。
	ConnectorEnable *bool `json:"connector_enable,omitempty"`

	// 转储任务ID。
	ConnectorId *string `json:"connector_id,omitempty"`

	// 是否开启Kafka rest功能。
	RestEnable *bool `json:"rest_enable,omitempty"`

	// Kafka rest连接地址。
	RestConnectAddress *string `json:"rest_connect_address,omitempty"`

	// kafka公网访问带宽。待删除版本。
	PublicBoundwidth *int32 `json:"public_boundwidth,omitempty"`

	// 是否开启消息查询功能。
	MessageQueryInstEnable *bool `json:"message_query_inst_enable,omitempty"`

	// 是否开启VPC明文访问。
	VpcClientPlain *bool `json:"vpc_client_plain,omitempty"`

	// Kafka实例支持的特性功能。
	SupportFeatures *string `json:"support_features,omitempty"`

	// 是否开启消息轨迹功能。
	TraceEnable *bool `json:"trace_enable,omitempty"`

	// 是否开启代理。
	AgentEnable *bool `json:"agent_enable,omitempty"`

	// 租户侧连接地址。
	PodConnectAddress *string `json:"pod_connect_address,omitempty"`

	// 是否开启磁盘加密。
	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`

	// 磁盘加密key，未开启磁盘加密时为空。
	DiskEncryptedKey *string `json:"disk_encrypted_key,omitempty"`

	// Kafka实例私有连接地址。
	KafkaPrivateConnectAddress *string `json:"kafka_private_connect_address,omitempty"`

	// 云监控版本。
	CesVersion *string `json:"ces_version,omitempty"`

	// 区分实例什么时候开启的公网访问：true,actived,closed,false。
	PublicAccessEnabled *string `json:"public_access_enabled,omitempty"`

	// 节点数。
	NodeNum *int32 `json:"node_num,omitempty"`

	// 是否开启访问控制。
	EnableAcl *bool `json:"enable_acl,omitempty"`

	// 是否启用新规格计费。
	NewSpecBillingEnable *bool `json:"new_spec_billing_enable,omitempty"`

	// 节点数量。
	BrokerNum *int32 `json:"broker_num,omitempty"`

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

	// 是否为容灾实例。
	DrEnable       *bool `json:"dr_enable,omitempty"`
	HttpStatusCode int   `json:"-"`
}

ShowInstanceResponse Response Object

func (ShowInstanceResponse) String 

func (o ShowInstanceResponse) String() string

type ShowInstanceResponseRetentionPolicy 

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

func (ShowInstanceResponseRetentionPolicy) MarshalJSON 

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

func (*ShowInstanceResponseRetentionPolicy) UnmarshalJSON 

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

func (ShowInstanceResponseRetentionPolicy) Value added in v0.0.90 

func (c ShowInstanceResponseRetentionPolicy) Value() string

type ShowInstanceResponseRetentionPolicyEnum 

type ShowInstanceResponseRetentionPolicyEnum struct {
	TIME_BASE      ShowInstanceResponseRetentionPolicy
	PRODUCE_REJECT ShowInstanceResponseRetentionPolicy
}

func GetShowInstanceResponseRetentionPolicyEnum 

func GetShowInstanceResponseRetentionPolicyEnum() ShowInstanceResponseRetentionPolicyEnum

type ShowInstanceResponseSaslEnabledMechanisms added in v0.1.38 

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

func (ShowInstanceResponseSaslEnabledMechanisms) MarshalJSON added in v0.1.38 

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

func (*ShowInstanceResponseSaslEnabledMechanisms) UnmarshalJSON added in v0.1.38 

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

func (ShowInstanceResponseSaslEnabledMechanisms) Value added in v0.1.38 

func (c ShowInstanceResponseSaslEnabledMechanisms) Value() string

type ShowInstanceResponseSaslEnabledMechanismsEnum added in v0.1.38 

type ShowInstanceResponseSaslEnabledMechanismsEnum struct {
	PLAIN         ShowInstanceResponseSaslEnabledMechanisms
	SCRAM_SHA_512 ShowInstanceResponseSaslEnabledMechanisms
}

func GetShowInstanceResponseSaslEnabledMechanismsEnum added in v0.1.38 

func GetShowInstanceResponseSaslEnabledMechanismsEnum() ShowInstanceResponseSaslEnabledMechanismsEnum

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 ShowInstanceTopicDetailRequest 

type ShowInstanceTopicDetailRequest struct {

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

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

ShowInstanceTopicDetailRequest Request Object

func (ShowInstanceTopicDetailRequest) String 

func (o ShowInstanceTopicDetailRequest) String() string

type ShowInstanceTopicDetailRespPartitions 

type ShowInstanceTopicDetailRespPartitions struct {

	// 分区ID。
	Partition *int32 `json:"partition,omitempty"`

	// leader副本所在节点的id。
	Leader *int32 `json:"leader,omitempty"`

	// 分区leader副本的LEO（Log End Offset）。
	Leo *int32 `json:"leo,omitempty"`

	// 分区高水位（HW，High Watermark）。
	Hw *int32 `json:"hw,omitempty"`

	// 分区leader副本的LSO（Log Start Offset）。
	Lso *int32 `json:"lso,omitempty"`

	// 分区上次写入消息的时间。  格式为Unix时间戳。  单位：毫秒。
	LastUpdateTimestamp *int64 `json:"last_update_timestamp,omitempty"`

	// 副本列表。
	Replicas *[]ShowInstanceTopicDetailRespReplicas `json:"replicas,omitempty"`
}

func (ShowInstanceTopicDetailRespPartitions) String 

func (o ShowInstanceTopicDetailRespPartitions) String() string

type ShowInstanceTopicDetailRespReplicas 

type ShowInstanceTopicDetailRespReplicas struct {

	// 副本所在的节点ID。
	Broker *int32 `json:"broker,omitempty"`

	// 该副本是否为leader。
	Leader *bool `json:"leader,omitempty"`

	// 该副本是否在ISR副本中。
	InSync *bool `json:"in_sync,omitempty"`

	// 该副本当前日志大小。单位：Byte。
	Size *int32 `json:"size,omitempty"`

	// 该副本当前落后hw的消息数。
	Lag *int32 `json:"lag,omitempty"`
}

func (ShowInstanceTopicDetailRespReplicas) String 

func (o ShowInstanceTopicDetailRespReplicas) String() string

type ShowInstanceTopicDetailResponse 

type ShowInstanceTopicDetailResponse struct {

	// topic名称。
	Topic *string `json:"topic,omitempty"`

	// 分区列表。
	Partitions *[]ShowInstanceTopicDetailRespPartitions `json:"partitions,omitempty"`

	// 订阅该topic的消费组名称列表。
	GroupSubscribed *[]string `json:"group_subscribed,omitempty"`
	HttpStatusCode  int       `json:"-"`
}

ShowInstanceTopicDetailResponse Response Object

func (ShowInstanceTopicDetailResponse) String 

func (o ShowInstanceTopicDetailResponse) String() string

type ShowInstanceUsersEntity added in v0.0.66 

type ShowInstanceUsersEntity struct {

	// 用户名称。  由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。
	UserName *string `json:"user_name,omitempty"`

	// 用户描述。
	UserDesc *string `json:"user_desc,omitempty"`

	// 用户角色。
	Role *string `json:"role,omitempty"`

	// 是否为默认应用。
	DefaultApp *bool `json:"default_app,omitempty"`

	// 创建时间。
	CreatedTime *int64 `json:"created_time,omitempty"`
}

func (ShowInstanceUsersEntity) String added in v0.0.66 

func (o ShowInstanceUsersEntity) String() string

type ShowInstanceUsersRequest 

type ShowInstanceUsersRequest struct {

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

ShowInstanceUsersRequest Request Object

func (ShowInstanceUsersRequest) String 

func (o ShowInstanceUsersRequest) String() string

type ShowInstanceUsersResponse 

type ShowInstanceUsersResponse struct {

	// 用户列表。
	Users          *[]ShowInstanceUsersEntity `json:"users,omitempty"`
	HttpStatusCode int                        `json:"-"`
}

ShowInstanceUsersResponse Response Object

func (ShowInstanceUsersResponse) String 

func (o ShowInstanceUsersResponse) String() string

type ShowKafkaProjectTagsRequest 

type ShowKafkaProjectTagsRequest struct {
}

ShowKafkaProjectTagsRequest Request Object

func (ShowKafkaProjectTagsRequest) String 

func (o ShowKafkaProjectTagsRequest) String() string

type ShowKafkaProjectTagsResponse 

type ShowKafkaProjectTagsResponse struct {

	// 标签列表
	Tags           *[]TagMultyValueEntity `json:"tags,omitempty"`
	HttpStatusCode int                    `json:"-"`
}

ShowKafkaProjectTagsResponse Response Object

func (ShowKafkaProjectTagsResponse) String 

func (o ShowKafkaProjectTagsResponse) String() string

type ShowKafkaTagsRequest 

type ShowKafkaTagsRequest struct {

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

ShowKafkaTagsRequest Request Object

func (ShowKafkaTagsRequest) String 

func (o ShowKafkaTagsRequest) String() string

type ShowKafkaTagsResponse 

type ShowKafkaTagsResponse struct {

	// 标签列表
	Tags           *[]TagEntity `json:"tags,omitempty"`
	HttpStatusCode int          `json:"-"`
}

ShowKafkaTagsResponse Response Object

func (ShowKafkaTagsResponse) String 

func (o ShowKafkaTagsResponse) String() string

type ShowKafkaTopicPartitionDiskusageRequest 

type ShowKafkaTopicPartitionDiskusageRequest struct {

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

	// 占用磁盘大小，默认值1G (1K，1M，1G)。
	MinSize *string `json:"minSize,omitempty"`

	// 占用磁盘大小，查询top N。
	Top *string `json:"top,omitempty"`

	// 占用磁盘大小，查询大于占比的分区。
	Percentage *string `json:"percentage,omitempty"`
}

ShowKafkaTopicPartitionDiskusageRequest Request Object

func (ShowKafkaTopicPartitionDiskusageRequest) String 

func (o ShowKafkaTopicPartitionDiskusageRequest) String() string

type ShowKafkaTopicPartitionDiskusageResponse 

type ShowKafkaTopicPartitionDiskusageResponse struct {

	// Broker列表。
	BrokerList     *[]DiskusageEntity `json:"broker_list,omitempty"`
	HttpStatusCode int                `json:"-"`
}

ShowKafkaTopicPartitionDiskusageResponse Response Object

func (ShowKafkaTopicPartitionDiskusageResponse) String 

func (o ShowKafkaTopicPartitionDiskusageResponse) String() string

type ShowKafkaUserClientQuotaRequest added in v0.1.68 

type ShowKafkaUserClientQuotaRequest struct {

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

	// 偏移量，表示查询该偏移量后面的记录
	Offset *int32 `json:"offset,omitempty"`

	// 查询返回记录的数量限制
	Limit *int32 `json:"limit,omitempty"`
}

ShowKafkaUserClientQuotaRequest Request Object

func (ShowKafkaUserClientQuotaRequest) String added in v0.1.68 

func (o ShowKafkaUserClientQuotaRequest) String() string

type ShowKafkaUserClientQuotaResponse added in v0.1.68 

type ShowKafkaUserClientQuotaResponse struct {

	// 客户端流控配置列表。
	Quotas *[]Quota `json:"quotas,omitempty"`

	// 客户端流控配置数目。
	Count          *int32 `json:"count,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowKafkaUserClientQuotaResponse Response Object

func (ShowKafkaUserClientQuotaResponse) String added in v0.1.68 

func (o ShowKafkaUserClientQuotaResponse) String() string

type ShowMaintainWindowsRequest 

type ShowMaintainWindowsRequest struct {
}

ShowMaintainWindowsRequest Request Object

func (ShowMaintainWindowsRequest) String 

func (o ShowMaintainWindowsRequest) String() string

type ShowMaintainWindowsResponse 

type ShowMaintainWindowsResponse struct {

	// 支持的维护时间窗列表。
	MaintainWindows *[]MaintainWindowsEntity `json:"maintain_windows,omitempty"`
	HttpStatusCode  int                      `json:"-"`
}

ShowMaintainWindowsResponse Response Object

func (ShowMaintainWindowsResponse) String 

func (o ShowMaintainWindowsResponse) String() string

type ShowMessagesRequest 

type ShowMessagesRequest struct {

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

	// Topic名称。  Topic名称必现以字母开头且只支持大小写字母、中横线、下划线以及数字。
	Topic string `json:"topic"`

	// 查询起始时间，为unix时间戳格式，默认值为0。
	StartTime *string `json:"start_time,omitempty"`

	// 查询结束时间，为unix时间戳格式，默认值为系统当前时间。
	EndTime *string `json:"end_time,omitempty"`

	// 单页返回消息数，默认值为10。
	Limit *int32 `json:"limit,omitempty"`

	// 偏移量，表示从此偏移量开始查询， offset大于等于0。
	Offset *int32 `json:"offset,omitempty"`

	// 分区编号，默认值为-1，若传入值为-1，则查询所有分区。
	Partition *string `json:"partition,omitempty"`
}

ShowMessagesRequest Request Object

func (ShowMessagesRequest) String 

func (o ShowMessagesRequest) String() string

type ShowMessagesRespMessages 

type ShowMessagesRespMessages struct {

	// topic名称。
	Topic *string `json:"topic,omitempty"`

	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`

	// 消息编号。
	MessageOffset *int32 `json:"message_offset,omitempty"`

	// 消息大小，单位字节。
	Size *int32 `json:"size,omitempty"`

	// 生产消息的时间。 格式为Unix时间戳。单位为毫秒。
	Timestamp *int64 `json:"timestamp,omitempty"`
}

func (ShowMessagesRespMessages) String 

func (o ShowMessagesRespMessages) String() string

type ShowMessagesResponse 

type ShowMessagesResponse struct {

	// 消息列表。
	Messages *[]ShowMessagesRespMessages `json:"messages,omitempty"`

	// 消息总数。
	MessagesCount *int32 `json:"messages_count,omitempty"`

	// 总页数。
	OffsetsCount *int32 `json:"offsets_count,omitempty"`

	// 当前页数。
	Offset         *int32 `json:"offset,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowMessagesResponse Response Object

func (ShowMessagesResponse) String 

func (o ShowMessagesResponse) String() string

type ShowPartitionBeginningMessageRequest 

type ShowPartitionBeginningMessageRequest struct {

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

	// Topic名称。  Topic名称必现以字母开头且只支持大小写字母、中横线、下划线以及数字。
	Topic string `json:"topic"`

	// 分区编号。
	Partition int32 `json:"partition"`
}

ShowPartitionBeginningMessageRequest Request Object

func (ShowPartitionBeginningMessageRequest) String 

func (o ShowPartitionBeginningMessageRequest) String() string

type ShowPartitionBeginningMessageResponse 

type ShowPartitionBeginningMessageResponse struct {

	// Topic名称。
	Topic *string `json:"topic,omitempty"`

	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`

	// 最新消息位置。
	Offset *int32 `json:"offset,omitempty"`

	// 生产消息的时间。 格式为Unix时间戳。单位为毫秒。
	Timestamp      *int64 `json:"timestamp,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowPartitionBeginningMessageResponse Response Object

func (ShowPartitionBeginningMessageResponse) String 

func (o ShowPartitionBeginningMessageResponse) String() string

type ShowPartitionEndMessageRequest 

type ShowPartitionEndMessageRequest struct {

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

	// Topic名称。  Topic名称必现以字母开头且只支持大小写字母、中横线、下划线以及数字。
	Topic string `json:"topic"`

	// 分区编号。
	Partition int32 `json:"partition"`
}

ShowPartitionEndMessageRequest Request Object

func (ShowPartitionEndMessageRequest) String 

func (o ShowPartitionEndMessageRequest) String() string

type ShowPartitionEndMessageResponse 

type ShowPartitionEndMessageResponse struct {

	// Topic名称。
	Topic *string `json:"topic,omitempty"`

	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`

	// 最新消息位置。
	Offset *int32 `json:"offset,omitempty"`

	// 生产消息的时间。 格式为Unix时间戳。单位为毫秒。
	Timestamp      *int64 `json:"timestamp,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowPartitionEndMessageResponse Response Object

func (ShowPartitionEndMessageResponse) String 

func (o ShowPartitionEndMessageResponse) String() string

type ShowPartitionMessageEntity added in v0.0.66 

type ShowPartitionMessageEntity struct {

	// 消息的key。
	Key *string `json:"key,omitempty"`

	// 消息内容。
	Value *string `json:"value,omitempty"`

	// Topic名称。
	Topic *string `json:"topic,omitempty"`

	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`

	// 消息位置。
	MessageOffset *int64 `json:"message_offset,omitempty"`

	// 消息大小，单位字节。
	Size *int32 `json:"size,omitempty"`

	// 生产消息的时间。 格式为Unix时间戳。单位为毫秒。
	Timestamp *int64 `json:"timestamp,omitempty"`
}

ShowPartitionMessageEntity 消息体。

func (ShowPartitionMessageEntity) String added in v0.0.66 

func (o ShowPartitionMessageEntity) String() string

type ShowPartitionMessageRequest 

type ShowPartitionMessageRequest struct {

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

	// Topic名称。  Topic名称必现以字母开头且只支持大小写字母、中横线、下划线以及数字。
	Topic string `json:"topic"`

	// 分区编号。
	Partition int32 `json:"partition"`

	// 消息位置。
	MessageOffset string `json:"message_offset"`
}

ShowPartitionMessageRequest Request Object

func (ShowPartitionMessageRequest) String 

func (o ShowPartitionMessageRequest) String() string

type ShowPartitionMessageResponse 

type ShowPartitionMessageResponse struct {

	// 消息列表。
	Message        *[]ShowPartitionMessageEntity `json:"message,omitempty"`
	HttpStatusCode int                           `json:"-"`
}

ShowPartitionMessageResponse Response Object

func (ShowPartitionMessageResponse) String 

func (o ShowPartitionMessageResponse) String() string

type ShowSinkTaskDetailRequest 

type ShowSinkTaskDetailRequest struct {

	// 实例转储ID。  请参考[查询实例](ShowInstance.xml)返回的数据。
	ConnectorId string `json:"connector_id"`

	// 转储任务ID。
	TaskId string `json:"task_id"`

	// 是否包含topic信息。默认是false。
	TopicInfo *ShowSinkTaskDetailRequestTopicInfo `json:"topic-info,omitempty"`
}

ShowSinkTaskDetailRequest Request Object

func (ShowSinkTaskDetailRequest) String 

func (o ShowSinkTaskDetailRequest) String() string

type ShowSinkTaskDetailRequestTopicInfo added in v0.0.66 

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

func (ShowSinkTaskDetailRequestTopicInfo) MarshalJSON added in v0.0.66 

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

func (*ShowSinkTaskDetailRequestTopicInfo) UnmarshalJSON added in v0.0.66 

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

func (ShowSinkTaskDetailRequestTopicInfo) Value added in v0.0.90 

func (c ShowSinkTaskDetailRequestTopicInfo) Value() string

type ShowSinkTaskDetailRequestTopicInfoEnum added in v0.0.66 

type ShowSinkTaskDetailRequestTopicInfoEnum struct {
	TRUE  ShowSinkTaskDetailRequestTopicInfo
	FALSE ShowSinkTaskDetailRequestTopicInfo
}

func GetShowSinkTaskDetailRequestTopicInfoEnum added in v0.0.66 

func GetShowSinkTaskDetailRequestTopicInfoEnum() ShowSinkTaskDetailRequestTopicInfoEnum

type ShowSinkTaskDetailRespObsDestinationDescriptor 

type ShowSinkTaskDetailRespObsDestinationDescriptor struct {

	// 消费启动策略：  - latest：从Topic最后端开始消费。  - earliest: 从Topic最前端消息开始消费。  默认是latest。
	ConsumerStrategy *string `json:"consumer_strategy,omitempty"`

	// 转储文件格式。目前只支持text格式。
	DestinationFileType *string `json:"destination_file_type,omitempty"`

	// 存储该通道数据的OBS桶名称。
	ObsBucketName *string `json:"obs_bucket_name,omitempty"`

	// 存储在obs的路径。
	ObsPath *string `json:"obs_path,omitempty"`

	// 将转储文件的生成时间使用“yyyy/MM/dd/HH/mm”格式生成分区字符串，用来定义写到OBS的Object文件所在的目录层次结构。   - N/A：置空，不使用日期时间目录。   - yyyy：年   - yyyy/MM：年/月   - yyyy/MM/dd：年/月/日   - yyyy/MM/dd/HH：年/月/日/时   - yyyy/MM/dd/HH/mm：年/月/日/时/分，例如：2017/11/10/14/49，目录结构就是“2017 > 11 > 10 > 14 > 49”，“2017”表示最外层文件夹。  默认值：空 > 数据转储成功后，存储的目录结构为“obs_bucket_path/file_prefix/partition_format”。默认时间是GMT+8 时间
	PartitionFormat *string `json:"partition_format,omitempty"`

	// 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围：   - 逗号“,”   - 分号“;”   - 竖线“|”   - 换行符“\\n”   - NULL  默认值：换行符“\\n”。
	RecordDelimiter *string `json:"record_delimiter,omitempty"`

	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。 取值范围：30～900 缺省值：300 单位：秒。 > 使用OBS通道转储流式数据时该参数为必选配置。
	DeliverTimeInterval *int32 `json:"deliver_time_interval,omitempty"`

	// 每个传输文件多大后就开始上传，单位为byte。 默认值5242880。
	ObsPartSize *int64 `json:"obs_part_size,omitempty"`
}

ShowSinkTaskDetailRespObsDestinationDescriptor 转存目标的描述。

func (ShowSinkTaskDetailRespObsDestinationDescriptor) String 

func (o ShowSinkTaskDetailRespObsDestinationDescriptor) String() string

type ShowSinkTaskDetailRespPartitions added in v0.0.66 

type ShowSinkTaskDetailRespPartitions struct {

	// 分区ID。
	PartitionId *string `json:"partition_id,omitempty"`

	// 运行状态。
	Status *string `json:"status,omitempty"`

	// 已转储的消息偏移量。
	LastTransferOffset *string `json:"last_transfer_offset,omitempty"`

	// 消息偏移量。
	LogEndOffset *string `json:"log_end_offset,omitempty"`

	// 积压的消息数。
	Lag *string `json:"lag,omitempty"`
}

func (ShowSinkTaskDetailRespPartitions) String added in v0.0.66 

func (o ShowSinkTaskDetailRespPartitions) String() string

type ShowSinkTaskDetailRespTopicsInfo added in v0.0.66 

type ShowSinkTaskDetailRespTopicsInfo struct {

	// topic名称。
	Topic *string `json:"topic,omitempty"`

	// 分区列表。
	Partitions *[]ShowSinkTaskDetailRespPartitions `json:"partitions,omitempty"`
}

func (ShowSinkTaskDetailRespTopicsInfo) String added in v0.0.66 

func (o ShowSinkTaskDetailRespTopicsInfo) String() string

type ShowSinkTaskDetailResponse 

type ShowSinkTaskDetailResponse struct {

	// 转储任务名称。
	TaskName *string `json:"task_name,omitempty"`

	// 转储任务类型。
	DestinationType *string `json:"destination_type,omitempty"`

	// 转储任务创建时间戳。
	CreateTime *int64 `json:"create_time,omitempty"`

	// 转储任务状态。
	Status *string `json:"status,omitempty"`

	// 返回任务转存的topics列表或者正则表达式。
	Topics *string `json:"topics,omitempty"`

	ObsDestinationDescriptor *ShowSinkTaskDetailRespObsDestinationDescriptor `json:"obs_destination_descriptor,omitempty"`

	// topic信息。
	TopicsInfo     *[]ShowSinkTaskDetailRespTopicsInfo `json:"topics_info,omitempty"`
	HttpStatusCode int                                 `json:"-"`
}

ShowSinkTaskDetailResponse Response Object

func (ShowSinkTaskDetailResponse) String 

func (o ShowSinkTaskDetailResponse) String() string

type ShowTopicAccessPolicyRequest 

type ShowTopicAccessPolicyRequest struct {

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

	// Topic名称。
	TopicName string `json:"topic_name"`
}

ShowTopicAccessPolicyRequest Request Object

func (ShowTopicAccessPolicyRequest) String 

func (o ShowTopicAccessPolicyRequest) String() string

type ShowTopicAccessPolicyResponse 

type ShowTopicAccessPolicyResponse struct {

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

	// topic类型。
	TopicType *int32 `json:"topic_type,omitempty"`

	// 权限列表。
	Policies       *[]PolicyEntity `json:"policies,omitempty"`
	HttpStatusCode int             `json:"-"`
}

ShowTopicAccessPolicyResponse Response Object

func (ShowTopicAccessPolicyResponse) String 

func (o ShowTopicAccessPolicyResponse) String() string

type TagEntity added in v0.0.66 

type TagEntity struct {

	// 标签键。  - 不能为空。  - 对于同一个实例，Key值唯一。  [- 长度不超过36个字符。](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 长度为1~128个字符（中文也可以输入128个字符）。](tag:hws,hws_hk)  [- 不能包含“=”，“*”，“<”，“>”，“\\”，“,”，“|”，“/”](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @](tag:hws,hws_hk)  - 首尾字符不能为空格。
	Key *string `json:"key,omitempty"`

	// 标签值。  [- 不能为空。](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 长度不超过43个字符。](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 长度为0~255个字符（中文也可以输入128个字符）。](tag:hws,hws_hk)  [- 不能包含“=”，“*”，“<”，“>”，“\\”，“,”，“|”，“/”](tag:cmcc,ctc,g42,hk_g42,hk_tm,hws_eu,hws_ocb,ocb,tm,otc)  [- 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @](tag:hws,hws_hk)  - 首尾字符不能为空格。
	Value *string `json:"value,omitempty"`
}

func (TagEntity) String added in v0.0.66 

func (o TagEntity) String() string

type TagMultyValueEntity added in v0.0.66 

type TagMultyValueEntity struct {

	// 标签键。
	Key *string `json:"key,omitempty"`

	// 标签值。
	Values *[]string `json:"values,omitempty"`
}

func (TagMultyValueEntity) String added in v0.0.66 

func (o TagMultyValueEntity) String() string

type TopicAssignment added in v0.1.24 

type TopicAssignment struct {

	// 手动指定分配方案时的分区号。
	Partition *int32 `json:"partition,omitempty"`

	// 手动指定某个分区将要分配的broker列表
	PartitionBrokers *[]int32 `json:"partition_brokers,omitempty"`
}

func (TopicAssignment) String added in v0.1.24 

func (o TopicAssignment) String() string

type TopicEntity added in v0.0.66 

type TopicEntity struct {

	// 是否为默认策略。
	PoliciesOnly *bool `json:"policiesOnly,omitempty"`

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

	// 副本数，配置数据的可靠性。
	Replication *int32 `json:"replication,omitempty"`

	// topic分区数，设置消费的并发数。
	Partition *int32 `json:"partition,omitempty"`

	// 消息老化时间。
	RetentionTime *int32 `json:"retention_time,omitempty"`

	// 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效，默认关闭。
	SyncReplication *bool `json:"sync_replication,omitempty"`

	// 是否使用同步落盘。默认值为false。同步落盘会导致性能降低。
	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`

	// 扩展配置。
	ExternalConfigs *interface{} `json:"external_configs,omitempty"`

	// topic类型(0:普通Topic 1:系统(内部)Topic)。
	TopicType *int32 `json:"topic_type,omitempty"`

	// topic其他配置
	TopicOtherConfigs *[]TopicEntityTopicOtherConfigs `json:"topic_other_configs,omitempty"`

	// topic描述
	TopicDesc *string `json:"topic_desc,omitempty"`

	// topic创建时间
	CreatedAt *int64 `json:"created_at,omitempty"`
}

func (TopicEntity) String added in v0.0.66 

func (o TopicEntity) String() string

type TopicEntityTopicOtherConfigs added in v0.1.49 

type TopicEntityTopicOtherConfigs struct {

	// 配置名称
	Name *string `json:"name,omitempty"`

	// 配置有效值
	ValidValues *string `json:"valid_values,omitempty"`

	// 配置默认值
	DefaultValue *string `json:"default_value,omitempty"`

	// 配置类型：dynamic/static
	ConfigType *string `json:"config_type,omitempty"`

	// 配置值
	Value *string `json:"value,omitempty"`

	// 配置值类型
	ValueType *string `json:"value_type,omitempty"`
}

func (TopicEntityTopicOtherConfigs) String added in v0.1.49 

func (o TopicEntityTopicOtherConfigs) String() string

type UpdateInstanceAutoCreateTopicReq 

type UpdateInstanceAutoCreateTopicReq struct {

	// 是否开启自动创建topic功能。
	EnableAutoTopic bool `json:"enable_auto_topic"`
}

func (UpdateInstanceAutoCreateTopicReq) String 

func (o UpdateInstanceAutoCreateTopicReq) String() string

type UpdateInstanceAutoCreateTopicRequest 

type UpdateInstanceAutoCreateTopicRequest struct {

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

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

UpdateInstanceAutoCreateTopicRequest Request Object

func (UpdateInstanceAutoCreateTopicRequest) String 

func (o UpdateInstanceAutoCreateTopicRequest) String() string

type UpdateInstanceAutoCreateTopicResponse 

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

UpdateInstanceAutoCreateTopicResponse Response Object

func (UpdateInstanceAutoCreateTopicResponse) String 

func (o UpdateInstanceAutoCreateTopicResponse) String() string

type UpdateInstanceConsumerGroupRequest added in v0.1.59 

type UpdateInstanceConsumerGroupRequest struct {

	// 消息中间件类型。
	Engine string `json:"engine"`

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

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

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

UpdateInstanceConsumerGroupRequest Request Object

func (UpdateInstanceConsumerGroupRequest) String added in v0.1.59 

func (o UpdateInstanceConsumerGroupRequest) String() string

type UpdateInstanceConsumerGroupResponse added in v0.1.59 

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

UpdateInstanceConsumerGroupResponse Response Object

func (UpdateInstanceConsumerGroupResponse) String added in v0.1.59 

func (o UpdateInstanceConsumerGroupResponse) String() string

type UpdateInstanceCrossVpcIpReq 

type UpdateInstanceCrossVpcIpReq struct {

	// 用户自定义的advertised_ip_contents键值对。  键是listeners IP。  值是advertised.listeners IP，或者域名。  > IP修改未修改项也需填上。
	AdvertisedIpContents map[string]string `json:"advertised_ip_contents"`
}

func (UpdateInstanceCrossVpcIpReq) String 

func (o UpdateInstanceCrossVpcIpReq) String() string

type UpdateInstanceCrossVpcIpRequest 

type UpdateInstanceCrossVpcIpRequest struct {

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

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

UpdateInstanceCrossVpcIpRequest Request Object

func (UpdateInstanceCrossVpcIpRequest) String 

func (o UpdateInstanceCrossVpcIpRequest) String() string

type UpdateInstanceCrossVpcIpRespResults 

type UpdateInstanceCrossVpcIpRespResults struct {

	// advertised.listeners IP/域名。
	AdvertisedIp *string `json:"advertised_ip,omitempty"`

	// 修改broker跨VPC访问的状态。
	Success *bool `json:"success,omitempty"`

	// listeners IP。
	Ip *string `json:"ip,omitempty"`
}

UpdateInstanceCrossVpcIpRespResults 修改broker跨VPC访问的结果。

func (UpdateInstanceCrossVpcIpRespResults) String 

func (o UpdateInstanceCrossVpcIpRespResults) String() string

type UpdateInstanceCrossVpcIpResponse 

type UpdateInstanceCrossVpcIpResponse struct {

	// 修改跨VPC访问结果。
	Success *bool `json:"success,omitempty"`

	// 修改broker跨VPC访问的结果列表。
	Results        *[]UpdateInstanceCrossVpcIpRespResults `json:"results,omitempty"`
	HttpStatusCode int                                    `json:"-"`
}

UpdateInstanceCrossVpcIpResponse Response Object

func (UpdateInstanceCrossVpcIpResponse) String 

func (o UpdateInstanceCrossVpcIpResponse) String() string

type UpdateInstanceReq 

type UpdateInstanceReq struct {

	// 实例名称。  由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。
	Name *string `json:"name,omitempty"`

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

	// 维护时间窗开始时间，格式为HH:mm:ss。   - 维护时间窗开始和结束时间必须为指定的时间段。   - 开始时间必须为22:00:00、02:00:00、06:00:00、10:00:00、14:00:00和18:00:00。   - 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00:00。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm:ss。   - 维护时间窗开始和结束时间必须为指定的时间段。   - 结束时间在开始时间基础上加四个小时，即当开始时间为22:00:00时，结束时间为02:00:00。   - 该参数不能单独为空，若该值为空，则开始时间也为空。系统分配一个默认结束时间06:00:00。
	MaintainEnd *string `json:"maintain_end,omitempty"`

	// 安全组ID。  获取方法如下：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。
	SecurityGroupId *string `json:"security_group_id,omitempty"`

	// 容量阈值策略。  支持两种策略模式： - produce_reject: 生产受限 - time_base: 自动删除
	RetentionPolicy *UpdateInstanceReqRetentionPolicy `json:"retention_policy,omitempty"`

	// 企业项目。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`
}

func (UpdateInstanceReq) String 

func (o UpdateInstanceReq) String() string

type UpdateInstanceReqRetentionPolicy 

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

func (UpdateInstanceReqRetentionPolicy) MarshalJSON 

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

func (*UpdateInstanceReqRetentionPolicy) UnmarshalJSON 

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

func (UpdateInstanceReqRetentionPolicy) Value added in v0.0.90 

func (c UpdateInstanceReqRetentionPolicy) Value() string

type UpdateInstanceReqRetentionPolicyEnum 

type UpdateInstanceReqRetentionPolicyEnum struct {
	PRODUCE_REJECT UpdateInstanceReqRetentionPolicy
	TIME_BASE      UpdateInstanceReqRetentionPolicy
}

func GetUpdateInstanceReqRetentionPolicyEnum 

func GetUpdateInstanceReqRetentionPolicyEnum() UpdateInstanceReqRetentionPolicyEnum

type UpdateInstanceRequest 

type UpdateInstanceRequest struct {

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

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

UpdateInstanceRequest Request Object

func (UpdateInstanceRequest) String 

func (o UpdateInstanceRequest) String() string

type UpdateInstanceResponse 

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

UpdateInstanceResponse Response Object

func (UpdateInstanceResponse) String 

func (o UpdateInstanceResponse) String() string

type UpdateInstanceTopicReq 

type UpdateInstanceTopicReq struct {

	// 修改的topic列表。
	Topics *[]UpdateInstanceTopicReqTopics `json:"topics,omitempty"`
}

UpdateInstanceTopicReq 修改的topic列表。

func (UpdateInstanceTopicReq) String 

func (o UpdateInstanceTopicReq) String() string

type UpdateInstanceTopicReqTopics 

type UpdateInstanceTopicReqTopics struct {

	// topic名称，不支持修改。
	Id string `json:"id"`

	// 老化时间，单位小时。
	RetentionTime *int32 `json:"retention_time,omitempty"`

	// 是否同步复制。
	SyncReplication *bool `json:"sync_replication,omitempty"`

	// 是否同步落盘。
	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`

	// 分区数。
	NewPartitionNumbers *int32 `json:"new_partition_numbers,omitempty"`

	// topic配置
	TopicOtherConfigs *[]CreateInstanceTopicReqTopicOtherConfigs `json:"topic_other_configs,omitempty"`

	// topic描述
	TopicDesc *string `json:"topic_desc,omitempty"`
}

UpdateInstanceTopicReqTopics 修改的topic。

func (UpdateInstanceTopicReqTopics) String 

func (o UpdateInstanceTopicReqTopics) String() string

type UpdateInstanceTopicRequest 

type UpdateInstanceTopicRequest struct {

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

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

UpdateInstanceTopicRequest Request Object

func (UpdateInstanceTopicRequest) String 

func (o UpdateInstanceTopicRequest) String() string

type UpdateInstanceTopicResponse 

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

UpdateInstanceTopicResponse Response Object

func (UpdateInstanceTopicResponse) String 

func (o UpdateInstanceTopicResponse) String() string

type UpdateInstanceUserRequest added in v0.1.59 

type UpdateInstanceUserRequest struct {

	// 消息中间件。
	Engine string `json:"engine"`

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

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

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

UpdateInstanceUserRequest Request Object

func (UpdateInstanceUserRequest) String added in v0.1.59 

func (o UpdateInstanceUserRequest) String() string

type UpdateInstanceUserResponse added in v0.1.59 

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

UpdateInstanceUserResponse Response Object

func (UpdateInstanceUserResponse) String added in v0.1.59 

func (o UpdateInstanceUserResponse) String() string

type UpdateKafkaUserClientQuotaTaskReq added in v0.1.68 

type UpdateKafkaUserClientQuotaTaskReq struct {

	// 用户名
	User *string `json:"user,omitempty"`

	// 客户端ID
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置（是则表示对全部用户限流）。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置（是则表示对全部客户端限流）。
	ClientDefault *bool `json:"client-default,omitempty"`

	// 生产上限速率（单位为B/s）
	ProducerByteRate *int64 `json:"producer-byte-rate,omitempty"`

	// 消费上限速率（单位为B/s）
	ConsumerByteRate *int64 `json:"consumer-byte-rate,omitempty"`
}

UpdateKafkaUserClientQuotaTaskReq 客户端流控配置

func (UpdateKafkaUserClientQuotaTaskReq) String added in v0.1.68 

func (o UpdateKafkaUserClientQuotaTaskReq) String() string

type UpdateKafkaUserClientQuotaTaskRequest added in v0.1.68 

type UpdateKafkaUserClientQuotaTaskRequest struct {

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

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

UpdateKafkaUserClientQuotaTaskRequest Request Object

func (UpdateKafkaUserClientQuotaTaskRequest) String added in v0.1.68 

func (o UpdateKafkaUserClientQuotaTaskRequest) String() string

type UpdateKafkaUserClientQuotaTaskResponse added in v0.1.68 

type UpdateKafkaUserClientQuotaTaskResponse struct {

	// 修改流控配置的任务ID
	JobId          *string `json:"job_id,omitempty"`
	HttpStatusCode int     `json:"-"`
}

UpdateKafkaUserClientQuotaTaskResponse Response Object

func (UpdateKafkaUserClientQuotaTaskResponse) String added in v0.1.68 

func (o UpdateKafkaUserClientQuotaTaskResponse) String() string

type UpdateSinkTaskQuotaReq 

type UpdateSinkTaskQuotaReq struct {

	// 转储任务的总个数。
	SinkMaxTasks int32 `json:"sink_max_tasks"`
}

func (UpdateSinkTaskQuotaReq) String 

func (o UpdateSinkTaskQuotaReq) String() string

type UpdateSinkTaskQuotaRequest 

type UpdateSinkTaskQuotaRequest struct {

	// 实例转储ID。  请参考[查询实例](ShowInstance.xml)返回的数据。
	ConnectorId string `json:"connector_id"`

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

UpdateSinkTaskQuotaRequest Request Object

func (UpdateSinkTaskQuotaRequest) String 

func (o UpdateSinkTaskQuotaRequest) String() string

type UpdateSinkTaskQuotaResponse 

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

UpdateSinkTaskQuotaResponse Response Object

func (UpdateSinkTaskQuotaResponse) String 

func (o UpdateSinkTaskQuotaResponse) String() string

type UpdateTopicAccessPolicyReq 

type UpdateTopicAccessPolicyReq struct {

	// topic列表。
	Topics []AccessPolicyTopicEntity `json:"topics"`
}

func (UpdateTopicAccessPolicyReq) String 

func (o UpdateTopicAccessPolicyReq) String() string

type UpdateTopicAccessPolicyRequest 

type UpdateTopicAccessPolicyRequest struct {

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

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

UpdateTopicAccessPolicyRequest Request Object

func (UpdateTopicAccessPolicyRequest) String 

func (o UpdateTopicAccessPolicyRequest) String() string

type UpdateTopicAccessPolicyResponse 

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

UpdateTopicAccessPolicyResponse Response Object

func (UpdateTopicAccessPolicyResponse) String 

func (o UpdateTopicAccessPolicyResponse) String() string

type UpdateTopicReplicaRequest 

type UpdateTopicReplicaRequest struct {

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

	// Topic名称。
	Topic string `json:"topic"`

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

UpdateTopicReplicaRequest Request Object

func (UpdateTopicReplicaRequest) String 

func (o UpdateTopicReplicaRequest) String() string

type UpdateTopicReplicaResponse 

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

UpdateTopicReplicaResponse Response Object

func (UpdateTopicReplicaResponse) String 

func (o UpdateTopicReplicaResponse) String() string

type UpdateUserReq added in v0.1.59 

type UpdateUserReq struct {

	// 用户新密码。  不能与名称或倒序的名称相同。 复杂度要求： - 输入长度为8到32位的字符串。 - 必须包含如下四种字符中的三种组合：   - 小写字母   - 大写字母   - 数字   - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）
	NewPassword *string `json:"new_password,omitempty"`

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

	// 用户描述。
	UserDesc *string `json:"user_desc,omitempty"`
}

func (UpdateUserReq) String added in v0.1.59 

func (o UpdateUserReq) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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