model

package
v0.1.87 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2024 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"`
}

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列表。  批量删除实例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 CreateConnectorReq 

type CreateConnectorReq struct {

	// 部署Smart Connect的规格，基准带宽，表示单位时间内传送的最大数据量。请保持和当前实例规格一致。仅老规格实例需要填写。 取值范围：   - 100MB   - 300MB   - 600MB   - 1200MB
	Specification *CreateConnectorReqSpecification `json:"specification,omitempty"`

	// Smart Connect节点数量。不能小于2个。 如果不填，默认是2个。
	NodeCnt *string `json:"node_cnt,omitempty"`

	// 转储节点规格编码。仅老规格实例需要填写。
	SpecCode *string `json:"spec_code,omitempty"`
}

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 CreateConnectorTaskRequest added in v0.1.84 

type CreateConnectorTaskRequest struct {

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

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

CreateConnectorTaskRequest Request Object

func (CreateConnectorTaskRequest) String added in v0.1.84 

func (o CreateConnectorTaskRequest) String() string

type CreateConnectorTaskResponse added in v0.1.84 

type CreateConnectorTaskResponse struct {

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

	// SmartConnect任务配置的Topic。
	Topics *string `json:"topics,omitempty"`

	// SmartConnect任务的源端类型。
	SourceType *string `json:"source_type,omitempty"`

	SourceTask *SmartConnectTaskRespSourceConfig `json:"source_task,omitempty"`

	// SmartConnect任务的目标端类型。
	SinkType *string `json:"sink_type,omitempty"`

	SinkTask *SmartConnectTaskRespSinkConfig `json:"sink_task,omitempty"`

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

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

	// SmartConnect任务的创建时间。
	CreateTime     *int64 `json:"create_time,omitempty"`
	HttpStatusCode int    `json:"-"`
}

CreateConnectorTaskResponse Response Object

func (CreateConnectorTaskResponse) String added in v0.1.84 

func (o CreateConnectorTaskResponse) 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,dt)   - 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,ctc,dt,g42,hk_g42)[900000](tag:tm,hk_tm,hws_eu)GB。   - Kafka实例规格为c6.12u24g.cluster时，存储空间取值范围300GB ~ [1500000](tag:hws,hws_hk,ocb,hws_ocb,ctc,dt,g42,hk_g42)[900000](tag:tm,hk_tm,hws_eu)GB。   - Kafka实例规格为c6.16u32g.cluster时，存储空间取值范围300GB ~ [1500000](tag:hws,hws_hk,ocb,hws_ocb,ctc,dt,g42,hk_g42)[900000](tag:tm,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)获取。](tag:hws,hws_hk,ctc,cmcc,hws_eu,g42,hk_g42,tm,hk_tm,ocb,hws_ocb,dt) [产品ID可以从[查询产品规格列表](ListProducts.xml)获取。](tag:hk_sbc,sbc)
	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。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm。
	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:dt,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名称，长度为3-200，以字母开头且只支持大小写字母、中横线、下划线、点以及数字。
	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,dt,hws_ocb,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,ctc,sbc,hk_sbc,hws_eu,g42,tm,hk_g42,hk_tm)[1-720](tag:ocb,dt,hws_ocb)，单位小时。
	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名称。
	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 {

	// 用户名。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	User *string `json:"user,omitempty"`

	// 客户端ID。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置。   - 是，表示对全部用户限流。此时不能同时设置用户名。   - 否，表示对特定用户限流。此时需要设置用户名。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置。   - 是，表示对全部客户端限流。此时不能设置客户端ID。   - 否，表示对特定客户端限流。此时需要设置客户端ID。
	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 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,dt,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:hws,hws_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,dt,ocb,hws_ocb) [此参数无需设置](tag: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,cmcc,hws_eu,g42,hk_g42,tm,hk_tm,ocb,hws_ocb,dt) [产品ID可以从[查询产品规格列表](ListProducts.xml)获取。](tag:hk_sbc,sbc) [创建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: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。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm。
	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,dt,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"`

	// 是否开启ipv6。仅在虚拟私有云支持ipv6时生效。
	Ipv6Enable *bool `json:"ipv6_enable,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:dt,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 CreateSmartConnectTaskReq added in v0.1.84 

type CreateSmartConnectTaskReq struct {

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

	// 是否稍后再启动任务。如需要创建任务后立即启动，请填false；如希望稍后在任务列表中手动开启任务，请填true。
	StartLater *bool `json:"start_later,omitempty"`

	// SmartConnect任务配置的Topic。
	Topics *string `json:"topics,omitempty"`

	// SmartConnect任务配置的Topic正则表达式。
	TopicsRegex *string `json:"topics_regex,omitempty"`

	// SmartConnect任务的源端类型。
	SourceType *CreateSmartConnectTaskReqSourceType `json:"source_type,omitempty"`

	SourceTask *SmartConnectTaskReqSourceConfig `json:"source_task,omitempty"`

	// SmartConnect任务的目标端类型。
	SinkType *CreateSmartConnectTaskReqSinkType `json:"sink_type,omitempty"`

	SinkTask *SmartConnectTaskReqSinkConfig `json:"sink_task,omitempty"`
}

func (CreateSmartConnectTaskReq) String added in v0.1.84 

func (o CreateSmartConnectTaskReq) String() string

type CreateSmartConnectTaskReqSinkType added in v0.1.84 

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

func (CreateSmartConnectTaskReqSinkType) MarshalJSON added in v0.1.84 

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

func (*CreateSmartConnectTaskReqSinkType) UnmarshalJSON added in v0.1.84 

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

func (CreateSmartConnectTaskReqSinkType) Value added in v0.1.84 

func (c CreateSmartConnectTaskReqSinkType) Value() string

type CreateSmartConnectTaskReqSinkTypeEnum added in v0.1.84 

type CreateSmartConnectTaskReqSinkTypeEnum struct {
	REDIS_REPLICATOR_SINK CreateSmartConnectTaskReqSinkType
	OBS_SINK              CreateSmartConnectTaskReqSinkType
	NONE                  CreateSmartConnectTaskReqSinkType
}

func GetCreateSmartConnectTaskReqSinkTypeEnum added in v0.1.84 

func GetCreateSmartConnectTaskReqSinkTypeEnum() CreateSmartConnectTaskReqSinkTypeEnum

type CreateSmartConnectTaskReqSourceType added in v0.1.84 

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

func (CreateSmartConnectTaskReqSourceType) MarshalJSON added in v0.1.84 

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

func (*CreateSmartConnectTaskReqSourceType) UnmarshalJSON added in v0.1.84 

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

func (CreateSmartConnectTaskReqSourceType) Value added in v0.1.84 

func (c CreateSmartConnectTaskReqSourceType) Value() string

type CreateSmartConnectTaskReqSourceTypeEnum added in v0.1.84 

type CreateSmartConnectTaskReqSourceTypeEnum struct {
	REDIS_REPLICATOR_SOURCE CreateSmartConnectTaskReqSourceType
	KAFKA_REPLICATOR_SOURCE CreateSmartConnectTaskReqSourceType
	NONE                    CreateSmartConnectTaskReqSourceType
}

func GetCreateSmartConnectTaskReqSourceTypeEnum added in v0.1.84 

func GetCreateSmartConnectTaskReqSourceTypeEnum() CreateSmartConnectTaskReqSourceTypeEnum

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

	Body *interface{} `json:"body,omitempty"`
}

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 DeleteConnectorTaskRequest added in v0.1.84 

type DeleteConnectorTaskRequest struct {

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

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

DeleteConnectorTaskRequest Request Object

func (DeleteConnectorTaskRequest) String added in v0.1.84 

func (o DeleteConnectorTaskRequest) String() string

type DeleteConnectorTaskResponse added in v0.1.84 

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

DeleteConnectorTaskResponse Response Object

func (DeleteConnectorTaskResponse) String added in v0.1.84 

func (o DeleteConnectorTaskResponse) 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 {

	// 用户名。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	User *string `json:"user,omitempty"`

	// 客户端ID。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置。   - 是，表示对全部用户限流。此时不能同时设置用户名。   - 否，表示对特定用户限流。此时需要设置用户名。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置。   - 是，表示对全部客户端限流。此时不能设置客户端ID。   - 否，表示对特定客户端限流。此时需要设置客户端ID。
	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 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 *int64 `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 ListConnectorTasksRequest added in v0.1.84 

type ListConnectorTasksRequest struct {

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

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

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

ListConnectorTasksRequest Request Object

func (ListConnectorTasksRequest) String added in v0.1.84 

func (o ListConnectorTasksRequest) String() string

type ListConnectorTasksResponse added in v0.1.84 

type ListConnectorTasksResponse struct {

	// Smart Connector任务详情。
	Tasks *[]SmartConnectTaskEntity `json:"tasks,omitempty"`

	// Smart Connector任务数。
	TotalNumber *int32 `json:"total_number,omitempty"`

	// Smart Connector最大任务数。
	MaxTasks *int32 `json:"max_tasks,omitempty"`

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

ListConnectorTasksResponse Response Object

func (ListConnectorTasksResponse) String added in v0.1.84 

func (o ListConnectorTasksResponse) 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,hcs)[计费模式。hourly：按需类型。](tag:dt,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
	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和2.7。
	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 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"`

	// 生产消息的时间。 格式为Unix时间戳。单位为毫秒。
	Timestamp *int64 `json:"timestamp,omitempty"`

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

	// 消息偏移量。
	MessageOffset *int64 `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 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"`

	// 是否作为定时任务执行。若非定时执行，则is_schedule 和execute_at字段可为空；若为定时执行，is_schedule为true，execute_at字段非空。
	IsSchedule *bool `json:"is_schedule,omitempty"`

	// 定时时间，格式为Unix时间戳，单位为毫秒
	ExecuteAt *int64 `json:"execute_at,omitempty"`
}

func (PartitionReassignRequest) String added in v0.1.24 

func (o PartitionReassignRequest) String() string

type PauseConnectorTaskRequest added in v0.1.84 

type PauseConnectorTaskRequest struct {

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

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

PauseConnectorTaskRequest Request Object

func (PauseConnectorTaskRequest) String added in v0.1.84 

func (o PauseConnectorTaskRequest) String() string

type PauseConnectorTaskResponse added in v0.1.84 

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

PauseConnectorTaskResponse Response Object

func (PauseConnectorTaskResponse) String added in v0.1.84 

func (o PauseConnectorTaskResponse) 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 {

	// 用户名。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	User *string `json:"user,omitempty"`

	// 客户端ID。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置。   - 是，表示对全部用户限流。此时不能同时设置用户名。   - 否，表示对特定用户限流。此时需要设置用户名。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置。   - 是，表示对全部客户端限流。此时不能设置客户端ID。   - 否，表示对特定客户端限流。此时需要设置客户端ID。
	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,omitempty"`

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

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

	// 重置消费进度到指定时间，格式为unix时间戳，单位为毫秒。 - 如果传入timestamp早于当前最早的timestamp，则重置到最早的timestamp。 - 如果晚于最晚的timestamp，则重置到最晚的timestamp。  **message_offset、timestamp二者必选其一。**
	Timestamp *int64 `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 ResetMessageOffsetWithEngineRequest added in v0.1.76 

type ResetMessageOffsetWithEngineRequest struct {

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

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

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

ResetMessageOffsetWithEngineRequest Request Object

func (ResetMessageOffsetWithEngineRequest) String added in v0.1.76 

func (o ResetMessageOffsetWithEngineRequest) String() string

type ResetMessageOffsetWithEngineResponse added in v0.1.76 

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

ResetMessageOffsetWithEngineResponse Response Object

func (ResetMessageOffsetWithEngineResponse) String added in v0.1.76 

func (o ResetMessageOffsetWithEngineResponse) 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 {

	// 用户新密码。  重置用户密码时，为必选参数；  不能与名称或倒序的名称相同。 复杂度要求： - 输入长度为8到32位的字符串。 - 必须包含如下四种字符中的三种组合：   - 小写字母   - 大写字母   - 数字   - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）和空格，并且不能以-开头
	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)获取。](tag:hws,hws_hk,ctc,cmcc,hws_eu,g42,hk_g42,tm,hk_tm,ocb,hws_ocb,dt) [产品ID可以从[查询产品规格列表](ListProducts.xml)获取。](tag:hk_sbc,sbc)
	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 RestartConnectorTaskRequest added in v0.1.84 

type RestartConnectorTaskRequest struct {

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

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

RestartConnectorTaskRequest Request Object

func (RestartConnectorTaskRequest) String added in v0.1.84 

func (o RestartConnectorTaskRequest) String() string

type RestartConnectorTaskResponse added in v0.1.84 

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

RestartConnectorTaskResponse Response Object

func (RestartConnectorTaskResponse) String added in v0.1.84 

func (o RestartConnectorTaskResponse) 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 ResumeConnectorTaskRequest added in v0.1.84 

type ResumeConnectorTaskRequest struct {

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

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

ResumeConnectorTaskRequest Request Object

func (ResumeConnectorTaskRequest) String added in v0.1.84 

func (o ResumeConnectorTaskRequest) String() string

type ResumeConnectorTaskResponse added in v0.1.84 

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

ResumeConnectorTaskResponse Response Object

func (ResumeConnectorTaskResponse) String added in v0.1.84 

func (o ResumeConnectorTaskResponse) String() string

type SendKafkaMessageRequest added in v0.1.73 

type SendKafkaMessageRequest struct {

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

	// 动作ID，生产消息对应的action_id为send。
	ActionId string `json:"action_id"`

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

SendKafkaMessageRequest Request Object

func (SendKafkaMessageRequest) String added in v0.1.73 

func (o SendKafkaMessageRequest) String() string

type SendKafkaMessageRequestBody added in v0.1.73 

type SendKafkaMessageRequestBody struct {

	// Kafka的topic
	Topic string `json:"topic"`

	// 消息内容
	Body string `json:"body"`

	// topic的分区信息等
	PropertyList []SendKafkaMessageRequestBodyPropertyList `json:"property_list"`
}

SendKafkaMessageRequestBody Kafka生产消息请求体

func (SendKafkaMessageRequestBody) String added in v0.1.73 

func (o SendKafkaMessageRequestBody) String() string

type SendKafkaMessageRequestBodyPropertyList added in v0.1.85 

type SendKafkaMessageRequestBodyPropertyList struct {

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

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

func (SendKafkaMessageRequestBodyPropertyList) String added in v0.1.85 

func (o SendKafkaMessageRequestBodyPropertyList) String() string

type SendKafkaMessageResponse added in v0.1.73 

type SendKafkaMessageResponse struct {

	// Kafka的topic
	Topic *string `json:"topic,omitempty"`

	// 消息内容
	Body *string `json:"body,omitempty"`

	// topic的分区信息等
	PropertyList   *[]interface{} `json:"property_list,omitempty"`
	HttpStatusCode int            `json:"-"`
}

SendKafkaMessageResponse Response Object

func (SendKafkaMessageResponse) String added in v0.1.73 

func (o SendKafkaMessageResponse) 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 ShowConnectorTaskRequest added in v0.1.84 

type ShowConnectorTaskRequest struct {

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

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

ShowConnectorTaskRequest Request Object

func (ShowConnectorTaskRequest) String added in v0.1.84 

func (o ShowConnectorTaskRequest) String() string

type ShowConnectorTaskResponse added in v0.1.84 

type ShowConnectorTaskResponse struct {

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

	// SmartConnect任务配置的Topic。
	Topics *string `json:"topics,omitempty"`

	// SmartConnect任务的源端类型。
	SourceType *string `json:"source_type,omitempty"`

	SourceTask *SmartConnectTaskRespSourceConfig `json:"source_task,omitempty"`

	// SmartConnect任务的目标端类型。
	SinkType *string `json:"sink_type,omitempty"`

	SinkTask *SmartConnectTaskRespSinkConfig `json:"sink_task,omitempty"`

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

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

	// SmartConnect任务的创建时间。
	CreateTime     *int64 `json:"create_time,omitempty"`
	HttpStatusCode int    `json:"-"`
}

ShowConnectorTaskResponse Response Object

func (ShowConnectorTaskResponse) String added in v0.1.84 

func (o ShowConnectorTaskResponse) 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 *int64 `json:"lag,omitempty"`

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

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

	// 最大消息位置（LEO）。
	MessageLogEndOffset *int64 `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和2.7。
	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,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:dt,g42,tm,hk_g42,hk_tm,hcs)
	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"`

	// connector节点数量。
	ConnectorNodeNum *int32 `json:"connector_node_num,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:dt,g42,tm,hk_g42,hk_tm,hcs)
	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"`

	// connector节点数量。
	ConnectorNodeNum *int32 `json:"connector_node_num,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 *int64 `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 *int64 `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 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 SmartConnectTaskEntity added in v0.1.84 

type SmartConnectTaskEntity struct {

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

	// SmartConnect任务配置的Topic。
	Topics *string `json:"topics,omitempty"`

	// SmartConnect任务的源端类型。
	SourceType *string `json:"source_type,omitempty"`

	SourceTask *SmartConnectTaskRespSourceConfig `json:"source_task,omitempty"`

	// SmartConnect任务的目标端类型。
	SinkType *string `json:"sink_type,omitempty"`

	SinkTask *SmartConnectTaskRespSinkConfig `json:"sink_task,omitempty"`

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

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

	// SmartConnect任务的创建时间。
	CreateTime *int64 `json:"create_time,omitempty"`
}

func (SmartConnectTaskEntity) String added in v0.1.84 

func (o SmartConnectTaskEntity) String() string

type SmartConnectTaskReqSinkConfig added in v0.1.84 

type SmartConnectTaskReqSinkConfig struct {

	// Redis实例地址。（仅目标端类型为Redis时需要填写）
	RedisAddress *string `json:"redis_address,omitempty"`

	// Redis实例类型。（仅目标端类型为Redis时需要填写）
	RedisType *string `json:"redis_type,omitempty"`

	// DCS实例ID。（仅目标端类型为Redis时需要填写）
	DcsInstanceId *string `json:"dcs_instance_id,omitempty"`

	// Redis密码。（仅目标端类型为Redis时需要填写）
	RedisPassword *string `json:"redis_password,omitempty"`

	// 转储启动偏移量，latest为获取最新的数据，earliest为获取最早的数据。（仅目标端类型为OBS时需要填写）
	ConsumerStrategy *string `json:"consumer_strategy,omitempty"`

	// 转储文件格式。当前只支持TEXT。（仅目标端类型为OBS时需要填写）
	DestinationFileType *string `json:"destination_file_type,omitempty"`

	// 数据转储周期（秒），默认配置为300秒。（仅目标端类型为OBS时需要填写）
	DeliverTimeInterval *int32 `json:"deliver_time_interval,omitempty"`

	// AK，访问密钥ID。（仅目标端类型为OBS时需要填写）
	AccessKey *string `json:"access_key,omitempty"`

	// SK，与访问密钥ID结合使用的密钥。（仅目标端类型为OBS时需要填写）
	SecretKey *string `json:"secret_key,omitempty"`

	// 转储地址，即存储Topic数据的OBS桶的名称。（仅目标端类型为OBS时需要填写）
	ObsBucketName *string `json:"obs_bucket_name,omitempty"`

	// 转储目录，即OBS中存储Topic的目录，多级目录可以用“/”进行分隔。（仅目标端类型为OBS时需要填写）
	ObsPath *string `json:"obs_path,omitempty"`

	// 时间目录格式。（仅目标端类型为OBS时需要填写）   - yyyy：年   - yyyy/MM：年/月   - yyyy/MM/dd：年/月/日   - yyyy/MM/dd/HH：年/月/日/时   - yyyy/MM/dd/HH/mm：年/月/日/时/分
	PartitionFormat *string `json:"partition_format,omitempty"`

	//  记录分行符，用于分隔写入转储文件的用户数据。（仅目标端类型为OBS时需要填写）   取值范围：   - 逗号“,”   - 分号“;”   - 竖线“|”   - 换行符“\\n”   - NULL
	RecordDelimiter *string `json:"record_delimiter,omitempty"`

	// 是否转储Key，开启表示转储Key，关闭表示不转储Key。（仅目标端类型为OBS时需要填写）
	StoreKeys *bool `json:"store_keys,omitempty"`
}

func (SmartConnectTaskReqSinkConfig) String added in v0.1.84 

func (o SmartConnectTaskReqSinkConfig) String() string

type SmartConnectTaskReqSourceConfig added in v0.1.84 

type SmartConnectTaskReqSourceConfig struct {

	// Redis实例地址。（仅源端类型为Redis时需要填写）
	RedisAddress *string `json:"redis_address,omitempty"`

	// Redis实例类型。（仅源端类型为Redis时需要填写）
	RedisType *string `json:"redis_type,omitempty"`

	// DCS实例ID。（仅源端类型为Redis时需要填写）
	DcsInstanceId *string `json:"dcs_instance_id,omitempty"`

	// Redis密码。（仅源端类型为Redis时需要填写）
	RedisPassword *string `json:"redis_password,omitempty"`

	// 同步类型，“RDB_ONLY”为全量同步，“CUSTOM_OFFSET”为全量同步+增量同步。（仅源端类型为Redis时需要填写）
	SyncMode *string `json:"sync_mode,omitempty"`

	// 全量同步重试间隔时间，单位：毫秒。（仅源端类型为Redis时需要填写）
	FullSyncWaitMs *int32 `json:"full_sync_wait_ms,omitempty"`

	// 全量同步最大重试次数。（仅源端类型为Redis时需要填写）
	FullSyncMaxRetry *int32 `json:"full_sync_max_retry,omitempty"`

	// 限速，单位为KB/s。-1表示不限速。（仅源端类型为Redis时需要填写）
	Ratelimit *int32 `json:"ratelimit,omitempty"`

	// 当前Kafka实例别名。（仅源端类型为Kafka时需要填写）
	CurrentClusterName *string `json:"current_cluster_name,omitempty"`

	// 对端Kafka实例别名。（仅源端类型为Kafka时需要填写）
	ClusterName *string `json:"cluster_name,omitempty"`

	// 对端Kafka开启SASL_SSL时设置的用户名，或者创建SASL_SSL用户时设置的用户名。（仅源端类型为Kafka且对端Kafka认证方式为“SASL_SSL”时需要填写）
	UserName *string `json:"user_name,omitempty"`

	// 对端Kafka开启SASL_SSL时设置的密码，或者创建SASL_SSL用户时设置的密码。（仅源端类型为Kafka且对端Kafka认证方式为“SASL_SSL”时需要填写）
	Password *string `json:"password,omitempty"`

	// 对端Kafka认证机制。（仅源端类型为Kafka且“认证方式”为“SASL_SSL”时需要填写）
	SaslMechanism *string `json:"sasl_mechanism,omitempty"`

	// 对端Kafka实例ID。（仅源端类型为Kafka时需要填写，instance_id和bootstrap_servers仅需要填写其中一个）
	InstanceId *string `json:"instance_id,omitempty"`

	// 对端Kafka实例地址。（仅源端类型为Kafka时需要填写，instance_id和bootstrap_servers仅需要填写其中一个）
	BootstrapServers *string `json:"bootstrap_servers,omitempty"`

	// 对端Kafka认证方式。（仅源端类型为Kafka需要填写） 支持以下两种认证方式：   - SASL_SSL：表示实例已开启SASL_SSL。   - PLAINTEXT：表示实例未开启SASL_SSL。
	SecurityProtocol *string `json:"security_protocol,omitempty"`

	// 同步方向；pull为把对端Kafka实例数据复制到当前Kafka实例中，push为把当前Kafka实例数据复制到对端Kafka实例中，two-way为对两端Kafka实例数据进行双向复制。（仅源端类型为Kafka时需要填写）
	Direction *string `json:"direction,omitempty"`

	// 是否同步消费进度。（仅源端类型为Kafka时需要填写）
	SyncConsumerOffsetsEnabled *bool `json:"sync_consumer_offsets_enabled,omitempty"`

	// 在对端实例中自动创建Topic时，指定Topic的副本数，此参数值不能超过对端实例的代理数。如果对端实例中设置了“default.replication.factor”，此参数的优先级高于“default.replication.factor”。（仅源端类型为Kafka时需要填写）
	ReplicationFactor *int32 `json:"replication_factor,omitempty"`

	// 数据复制的任务数。默认值为2，建议保持默认值。如果“同步方式”为“双向”，实际任务数=设置的任务数*2。（仅源端类型为Kafka时需要填写）
	TaskNum *int32 `json:"task_num,omitempty"`

	// 是否重命名Topic，在目标Topic名称前添加源端Kafka实例的别名，形成目标Topic新的名称。（仅源端类型为Kafka时需要填写）
	RenameTopicEnable *bool `json:"rename_topic_enable,omitempty"`

	// 目标Topic接收复制的消息，此消息header中包含消息来源。两端实例数据双向复制时，请开启“添加来源header”，防止循环复制。（仅源端类型为Kafka时需要填写）
	ProvenanceHeaderEnabled *bool `json:"provenance_header_enabled,omitempty"`

	// 启动偏移量，latest为获取最新的数据，earliest为获取最早的数据。（仅源端类型为Kafka时需要填写）
	ConsumerStrategy *string `json:"consumer_strategy,omitempty"`

	// 复制消息所使用的压缩算法。（仅源端类型为Kafka时需要填写） - none - gzip - snappy - lz4 - zstd
	CompressionType *string `json:"compression_type,omitempty"`

	// topic映射，用于自定义目标端Topic名称。不能同时设置“重命名Topic”和“topic映射”。topic映射请按照“源端topic:目的端topic”的格式填写，如涉及多个topic映射，请用“,”分隔开，例如：topic-sc-1:topic-sc-2,topic-sc-3:topic-sc-4。（仅源端类型为Kafka时需要填写）
	TopicsMapping *string `json:"topics_mapping,omitempty"`
}

func (SmartConnectTaskReqSourceConfig) String added in v0.1.84 

func (o SmartConnectTaskReqSourceConfig) String() string

type SmartConnectTaskRespSinkConfig added in v0.1.84 

type SmartConnectTaskRespSinkConfig struct {

	// Redis实例地址。（仅目标端类型为Redis时会显示）
	RedisAddress *string `json:"redis_address,omitempty"`

	// Redis实例类型。（仅目标端类型为Redis时会显示）
	RedisType *string `json:"redis_type,omitempty"`

	// DCS实例ID。（仅目标端类型为Redis时会显示）
	DcsInstanceId *string `json:"dcs_instance_id,omitempty"`

	// 目标数据库，默认为-1。（仅目标端类型为Redis时会显示）
	TargetDb *int32 `json:"target_db,omitempty"`

	// 转储启动偏移量，latest为获取最新的数据，earliest为获取最早的数据。（仅目标端类型为OBS时会显示）
	ConsumerStrategy *string `json:"consumer_strategy,omitempty"`

	// 转储文件格式。当前只支持TEXT。（仅目标端类型为OBS时会显示）
	DestinationFileType *string `json:"destination_file_type,omitempty"`

	// 记数据转储周期（秒）。（仅目标端类型为OBS时会显示）
	DeliverTimeInterval *int32 `json:"deliver_time_interval,omitempty"`

	// 转储地址。（仅目标端类型为OBS时会显示）
	ObsBucketName *string `json:"obs_bucket_name,omitempty"`

	// 转储目录。（仅目标端类型为OBS时会显示）
	ObsPath *string `json:"obs_path,omitempty"`

	// 时间目录格式。（仅目标端类型为OBS时会显示）
	PartitionFormat *string `json:"partition_format,omitempty"`

	// 记录分行符。（仅目标端类型为OBS时会显示）
	RecordDelimiter *string `json:"record_delimiter,omitempty"`

	// 存储Key。（仅目标端类型为OBS时会显示）
	StoreKeys *bool `json:"store_keys,omitempty"`

	// 每个传输文件多大后就开始上传，单位为byte；默认值5242880。（仅目标端类型为OBS时会显示）
	ObsPartSize *int32 `json:"obs_part_size,omitempty"`

	// flush_size。（仅目标端类型为OBS时会显示）
	FlushSize *int32 `json:"flush_size,omitempty"`

	// 时区。（仅目标端类型为OBS时会显示）
	Timezone *string `json:"timezone,omitempty"`

	// connector类，默认为\"com.huawei.dms.connector.obs.OBSSinkConnector\"。（仅目标端类型为OBS时会显示）
	ConnectorClass *string `json:"connector_class,omitempty"`

	// storage类，默认为com.huawei.dms.connector.obs.storage.OBSStorage\"。（仅目标端类型为OBS时会显示）
	StorageClass *string `json:"storage_class,omitempty"`

	// format类，默认为\"com.huawei.dms.connector.obs.format.bytearray.ByteArrayFormat\"。（仅目标端类型为OBS时会显示）
	FormatClass *string `json:"format_class,omitempty"`

	// schema_generator类，默认为\"io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator\"。（仅目标端类型为OBS时会显示）
	SchemaGeneratorClass *string `json:"schema_generator_class,omitempty"`

	// partitioner类，默认\"io.confluent.connect.storage.partitioner.TimeBasedPartitioner\"。（仅目标端类型为OBS时会显示）
	PartitionerClass *string `json:"partitioner_class,omitempty"`

	// value_converter，默认为\"org.apache.kafka.connect.converters.ByteArrayConverter\"。（仅目标端类型为OBS时会显示）
	ValueConverter *string `json:"value_converter,omitempty"`

	// key_converter，默认为\"org.apache.kafka.connect.converters.ByteArrayConverter\"。（仅目标端类型为OBS时会显示）
	KeyConverter *string `json:"key_converter,omitempty"`

	// kv_delimiter，默认为\":\"。（仅目标端类型为OBS时会显示）
	KvDelimiter *string `json:"kv_delimiter,omitempty"`
}

func (SmartConnectTaskRespSinkConfig) String added in v0.1.84 

func (o SmartConnectTaskRespSinkConfig) String() string

type SmartConnectTaskRespSourceConfig added in v0.1.84 

type SmartConnectTaskRespSourceConfig struct {

	// Redis实例地址。（仅源端类型为Redis时会显示）
	RedisAddress *string `json:"redis_address,omitempty"`

	// Redis实例类型。（仅源端类型为Redis时会显示）
	RedisType *string `json:"redis_type,omitempty"`

	// DCS实例ID。（仅源端类型为Redis时会显示）
	DcsInstanceId *string `json:"dcs_instance_id,omitempty"`

	// 同步类型，“RDB_ONLY”为全量同步，“CUSTOM_OFFSET”为全量同步+增量同步。（仅源端类型为Redis时会显示）
	SyncMode *string `json:"sync_mode,omitempty"`

	// 全量同步重试间隔时间，单位：毫秒。（仅源端类型为Redis时会显示）
	FullSyncWaitMs *int32 `json:"full_sync_wait_ms,omitempty"`

	// 全量同步最大重试次数。（仅源端类型为Redis时会显示）
	FullSyncMaxRetry *int32 `json:"full_sync_max_retry,omitempty"`

	// 限速，单位为KB/s。-1表示不限速（仅源端类型为Redis时会显示）
	Ratelimit *int32 `json:"ratelimit,omitempty"`

	// 当前Kafka实例别名。（仅源端类型为Kafka时会显示）
	CurrentClusterName *string `json:"current_cluster_name,omitempty"`

	// 对端Kafka实例别名。（仅源端类型为Kafka时会显示）
	ClusterName *string `json:"cluster_name,omitempty"`

	// 对端Kafka用户名。（仅源端类型为Kafka时会显示）
	UserName *string `json:"user_name,omitempty"`

	// 对端Kafka认证机制。（仅源端类型为Kafka时会显示）
	SaslMechanism *string `json:"sasl_mechanism,omitempty"`

	// 对端Kafka实例ID。（仅源端类型为Kafka时会显示）
	InstanceId *string `json:"instance_id,omitempty"`

	// 对端Kafka实例地址。（仅源端类型为Kafka时会显示）
	BootstrapServers *string `json:"bootstrap_servers,omitempty"`

	// 对端Kafka认证方式。（仅源端类型为Kafka时会显示）
	SecurityProtocol *string `json:"security_protocol,omitempty"`

	// 同步方向。（仅源端类型为Kafka时会显示）
	Direction *string `json:"direction,omitempty"`

	// 是否同步消费进度。（仅源端类型为Kafka时会显示）
	SyncConsumerOffsetsEnabled *bool `json:"sync_consumer_offsets_enabled,omitempty"`

	// 副本数。（仅源端类型为Kafka时会显示）
	ReplicationFactor *int32 `json:"replication_factor,omitempty"`

	// 任务数。（仅源端类型为Kafka时会显示）
	TaskNum *int32 `json:"task_num,omitempty"`

	// 是否重命名Topic。（仅源端类型为Kafka时会显示）
	RenameTopicEnable *bool `json:"rename_topic_enable,omitempty"`

	// 是否添加来源header。（仅源端类型为Kafka时会显示）
	ProvenanceHeaderEnabled *bool `json:"provenance_header_enabled,omitempty"`

	// 启动偏移量，latest为获取最新的数据，earliest为获取最早的数据。（仅源端类型为Kafka时会显示）
	ConsumerStrategy *string `json:"consumer_strategy,omitempty"`

	// 压缩算法。（仅源端类型为Kafka时会显示）
	CompressionType *string `json:"compression_type,omitempty"`

	// topic映射。（仅源端类型为Kafka时会显示）
	TopicsMapping *string `json:"topics_mapping,omitempty"`
}

func (SmartConnectTaskRespSourceConfig) String added in v0.1.84 

func (o SmartConnectTaskRespSourceConfig) String() string

type TagEntity added in v0.0.66 

type TagEntity struct {

	// 标签键。  - 不能为空。  - 对于同一个实例，Key值唯一。  [- 长度不超过36个字符。](tag:cmcc,hk_tm,hws_eu,hws_ocb,ocb,tm)  [- 长度为1~128个字符（中文也可以输入128个字符）。](tag:hws,hws_hk,ctc,hk_sbc,sbc,dt,g42,hk_g42)  [- 不能包含“=”，“*”，“<”，“>”，“\\”，“,”，“|”，“/”](tag:cmcc,hk_tm,hws_eu,hws_ocb,ocb,tm)  [- 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @](tag:hws,hws_hk,ctc,hk_sbc,sbc,dt,g42,hk_g42)  - 首尾字符不能为空格。
	Key *string `json:"key,omitempty"`

	// 标签值。  [- 不能为空。](tag:cmcc,hk_tm,hws_eu,hws_ocb,ocb,tm)  [- 长度不超过43个字符。](tag:cmcc,hk_tm,hws_eu,hws_ocb,ocb,tm)  [- 长度为0~255个字符（中文也可以输入255个字符）。](tag:hws,hws_hk,ctc,hk_sbc,sbc,dt,g42,hk_g42)  [- 不能包含“=”，“*”，“<”，“>”，“\\”，“,”，“|”，“/”](tag:cmcc,hk_tm,hws_eu,hws_ocb,ocb,tm)  [- 由任意语种字母、数字、空格和字符组成，字符仅支持_ . : = + - @](tag:hws,hws_hk,ctc,hk_sbc,sbc,dt,g42,hk_g42)  - 首尾字符不能为空格。
	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。
	MaintainBegin *string `json:"maintain_begin,omitempty"`

	// 维护时间窗结束时间，格式为HH:mm:ss。
	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"`

	// 增加分区时指定broker列表
	NewPartitionBrokers *[]int32 `json:"new_partition_brokers,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 {

	// 用户名。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	User *string `json:"user,omitempty"`

	// 客户端ID。  不对全部用户/客户端限流时，用户名和客户端ID不能同时为空。
	Client *string `json:"client,omitempty"`

	// 是否使用用户默认设置。   - 是，表示对全部用户限流。此时不能同时设置用户名。   - 否，表示对特定用户限流。此时需要设置用户名。
	UserDefault *bool `json:"user-default,omitempty"`

	// 是否使用客户端默认设置。   - 是，表示对全部客户端限流。此时不能设置客户端ID。   - 否，表示对特定客户端限流。此时需要设置客户端ID。
	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 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.