model

package
v0.0.24-beta Latest Latest
Warning

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

 Go to latest Published: Dec 7, 2020 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 BatchCreateOrDeleteInstanceTagRequest 

type BatchCreateOrDeleteInstanceTagRequest struct {
	ProjectId  string                     `json:"project_id"`
	InstanceId string                     `json:"instance_id"`
	Body       *BatchCreateOrDeleteTagReq `json:"body,omitempty"`
}

Request Object

func (BatchCreateOrDeleteInstanceTagRequest) String 

func (o BatchCreateOrDeleteInstanceTagRequest) String() string

type BatchCreateOrDeleteInstanceTagResponse 

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

Response Object

func (BatchCreateOrDeleteInstanceTagResponse) String 

func (o BatchCreateOrDeleteInstanceTagResponse) String() string

type BatchCreateOrDeleteTagReq 

type BatchCreateOrDeleteTagReq struct {
	// 操作标识（仅支持小写）: - create（创建） - delete（删除）
	Action *BatchCreateOrDeleteTagReqAction `json:"action,omitempty"`
	// 标签列表。
	Tags *[]CreatePostPaidInstanceReqTags `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

type BatchCreateOrDeleteTagReqActionEnum 

type BatchCreateOrDeleteTagReqActionEnum struct {
	CREATE BatchCreateOrDeleteTagReqAction
	DELETE BatchCreateOrDeleteTagReqAction
}

func GetBatchCreateOrDeleteTagReqActionEnum 

func GetBatchCreateOrDeleteTagReqActionEnum() BatchCreateOrDeleteTagReqActionEnum

type BatchDeleteInstanceTopicReq 

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

func (BatchDeleteInstanceTopicReq) String 

func (o BatchDeleteInstanceTopicReq) String() string

type BatchDeleteInstanceTopicRequest 

type BatchDeleteInstanceTopicRequest struct {
	ProjectId  string                       `json:"project_id"`
	InstanceId string                       `json:"instance_id"`
	Body       *BatchDeleteInstanceTopicReq `json:"body,omitempty"`
}

Request Object

func (BatchDeleteInstanceTopicRequest) String 

func (o BatchDeleteInstanceTopicRequest) String() string

type BatchDeleteInstanceTopicRespTopics 

type BatchDeleteInstanceTopicRespTopics struct {
	// Topic名称。
	Id *string `json:"id,omitempty"`
	// topic名称。
	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:"-"`
}

Response Object

func (BatchDeleteInstanceTopicResponse) String 

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

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

type BatchRestartOrDeleteInstanceReqAllFailureEnum 

type BatchRestartOrDeleteInstanceReqAllFailureEnum struct {
	TRUE  BatchRestartOrDeleteInstanceReqAllFailure
	FALSE BatchRestartOrDeleteInstanceReqAllFailure
	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 {
	ProjectId string                           `json:"project_id"`
	Body      *BatchRestartOrDeleteInstanceReq `json:"body,omitempty"`
}

Request Object

func (BatchRestartOrDeleteInstancesRequest) String 

func (o BatchRestartOrDeleteInstancesRequest) String() string

type BatchRestartOrDeleteInstancesResponse 

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

Response Object

func (BatchRestartOrDeleteInstancesResponse) String 

func (o BatchRestartOrDeleteInstancesResponse) String() string

type CreateConnectorReq 

type CreateConnectorReq struct {
	// 部署connector的规格，基准带宽，表示单位时间内传送的最大数据量，单位Byte/秒。  取值范围：   - 100MB   - 300MB   - 600MB   - 1200MB  可以不填，则默认跟当前实例的规格是一致。  第一阶段实现先不填，保持和当前实例规格一致，后面再扩展可以选择不同的规格。
	Specification *CreateConnectorReqSpecification `json:"specification,omitempty"`
	// 转储节点数量。不能小于2个。 默认是2个。
	NodeCnt *string `json:"node_cnt,omitempty"`
	// 转储节点规格编码。
	SpecCode string `json:"spec_code"`
}

func (CreateConnectorReq) String 

func (o CreateConnectorReq) String() string

type CreateConnectorReqSpecification 

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

func (CreateConnectorReqSpecification) MarshalJSON 

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

func (*CreateConnectorReqSpecification) UnmarshalJSON 

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

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 {
	ProjectId  string              `json:"project_id"`
	InstanceId string              `json:"instance_id"`
	Body       *CreateConnectorReq `json:"body,omitempty"`
}

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

Response Object

func (CreateConnectorResponse) String 

func (o CreateConnectorResponse) String() string

type CreateInstanceTopicReq 

type CreateInstanceTopicReq struct {
	// topic名称，长度为4-64，以字母开头且只支持大小写字母、中横线、下划线以及数字。
	Name string `json:"name"`
	// 副本数，配置数据的可靠性。 取值范围：1-3。
	Replication *int32 `json:"replication,omitempty"`
	// 是否使用同步落盘。默认值为false。同步落盘会导致性能降低。
	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`
	// topic分区数，设置消费的并发数。 取值范围：1-20。
	Partition *int32 `json:"partition,omitempty"`
	// 是否开启同步复制，开启后，客户端生产消息时相应的也要设置acks=-1，否则不生效，默认关闭。
	SyncReplication *bool `json:"sync_replication,omitempty"`
	// 消息老化时间。默认值为72。取值范围1~168，单位小时。
	RetentionTime *int32 `json:"retention_time,omitempty"`
}

func (CreateInstanceTopicReq) String 

func (o CreateInstanceTopicReq) String() string

type CreateInstanceTopicRequest 

type CreateInstanceTopicRequest struct {
	ProjectId  string                  `json:"project_id"`
	InstanceId string                  `json:"instance_id"`
	Body       *CreateInstanceTopicReq `json:"body,omitempty"`
}

Request Object

func (CreateInstanceTopicRequest) String 

func (o CreateInstanceTopicRequest) String() string

type CreateInstanceTopicResponse 

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

Response Object

func (CreateInstanceTopicResponse) String 

func (o CreateInstanceTopicResponse) String() string

type CreatePartitionReq 

type CreatePartitionReq struct {
	// 期望调整分区后的数量，必须大于当前分区数量，小于等于20。
	Partition *int32 `json:"partition,omitempty"`
}

func (CreatePartitionReq) String 

func (o CreatePartitionReq) String() string

type CreatePartitionRequest 

type CreatePartitionRequest struct {
	ProjectId  string              `json:"project_id"`
	InstanceId string              `json:"instance_id"`
	Topic      string              `json:"topic"`
	Body       *CreatePartitionReq `json:"body,omitempty"`
}

Request Object

func (CreatePartitionRequest) String 

func (o CreatePartitionRequest) String() string

type CreatePartitionResponse 

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

Response Object

func (CreatePartitionResponse) String 

func (o CreatePartitionResponse) String() string

type CreatePostPaidInstanceReq 

type CreatePostPaidInstanceReq struct {
	// 实例名称。  由英文字符开头，只能由英文字母、数字、中划线、下划线组成，长度为4~64的字符。
	Name string `json:"name"`
	// 实例的描述信息。  长度不超过1024的字符串。  > \\与\"在json报文中属于特殊字符，如果参数值中需要显示\\或者\"字符，请在字符前增加转义字符\\，比如\\\\或者\\\"。
	Description *string `json:"description,omitempty"`
	// 消息引擎。取值填写为：kafka。
	Engine CreatePostPaidInstanceReqEngine `json:"engine"`
	// 消息引擎的版本。取值填写为：1.1.0和2.3.0。
	EngineVersion CreatePostPaidInstanceReqEngineVersion `json:"engine_version"`
	// Kafka实例的基准带宽，表示单位时间内传送的最大数据量，单位MB。 取值范围：   - 100MB   - 300MB   - 600MB   - 1200MB
	Specification CreatePostPaidInstanceReqSpecification `json:"specification"`
	// 消息存储空间，单位GB。   - Kafka实例规格为100MB时，存储空间取值范围600GB ~ 90000GB。   - Kafka实例规格为300MB时，存储空间取值范围1200GB ~ 90000GB。   - Kafka实例规格为600MB时，存储空间取值范围2400GB ~ 90000GB。   - Kafka实例规格为1200MB，存储空间取值范围4800GB ~ 90000GB。
	StorageSpace int32 `json:"storage_space"`
	// Kafka实例的最大分区数量。   - 参数specification为100MB时，取值300   - 参数specification为300MB时，取值900   - 参数specification为600MB时，取值1800   - 参数specification为1200MB时，取值1800
	PartitionNum CreatePostPaidInstanceReqPartitionNum `json:"partition_num"`
	// 当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。  获取方法如下： - 方法1：登录虚拟私有云服务的控制台界面，在虚拟私有云的详情页面查找VPC ID。 - 方法2：通过虚拟私有云服务的API接口查询，具体操作可参考[查询VPC列表](https://support.huaweicloud.com/api-vpc/vpc_api01_0003.html)。
	VpcId string `json:"vpc_id"`
	// 指定实例所属的安全组。  获取方法如下： - 方法1：登录虚拟私有云服务的控制台界面，在安全组的详情页面查找安全组ID。 - 方法2：通过虚拟私有云服务的API接口查询，具体操作可参考[查询安全组列表](https://support.huaweicloud.com/api-vpc/vpc_sg01_0002.html)。
	SecurityGroupId string `json:"security_group_id"`
	// 子网信息。  获取方法如下： - 方法1：登录虚拟私有云服务的控制台界面，单击VPC下的子网，进入子网详情页面，查找网络ID。 - 方法2：通过虚拟私有云服务的API接口查询，具体操作可参考[查询子网列表](https://support.huaweicloud.com/api-vpc/vpc_subnet01_0003.html)。
	SubnetId string `json:"subnet_id"`
	// 创建节点到指定且有资源的可用区ID。该参数不能为空数组或者数组的值为空，详情请参考[查询可用区信息](https://support.huaweicloud.com/api-kafka/ListAvailableZones.html)查询得到。在查询时，请注意查看该可用区是否有资源。  创建Kafka实例，支持节点部署在1个或3个及3个以上的可用区。在为节点指定可用区时，用逗号分隔开。
	AvailableZones []string `json:"available_zones"`
	// 产品标识。  获取方法，请参考查询[产品规格列表](https://support.huaweicloud.com/api-kafka/ListProducts.html)。
	ProductId string `json:"product_id"`
	// 表示登录Kafka Manager的用户名。只能由英文字母、数字、中划线组成，长度为4~64的字符。
	KafkaManagerUser string `json:"kafka_manager_user"`
	// 表示登录Kafka Manager的密码。  复杂度要求：   - 输入长度为8到32位的字符串。   - 必须包含如下四种字符中的两种组合：       - 小写字母       - 大写字母       - 数字       - 特殊字符包括（`~!@#$%^&*()-_=+\\|[{}]:'\",<.>/?）
	KafkaManagerPassword string `json:"kafka_manager_password"`
	// 维护时间窗开始时间，格式为HH:mm。 - 维护时间窗开始和结束时间必须为指定的时间段，可参考[查询维护时间窗时间段](https://support.huaweicloud.com/api-kafka/ShowMaintainWindows.html)获取。 - 开始时间必须为22:00、02:00、06:00、10:00、14:00和18:00。 - 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00。
	MaintainBegin *string `json:"maintain_begin,omitempty"`
	// 维护时间窗结束时间，格式为HH:mm。 - 维护时间窗开始和结束时间必须为指定的时间段，可参考[查询维护时间窗时间段](https://support.huaweicloud.com/api-kafka/ShowMaintainWindows.html)获取。 - 结束时间在开始时间基础上加四个小时，即当开始时间为22:00时，结束时间为02:00。 - 该参数不能单独为空，若该值为空，则开始时间也为空，系统分配一个默认结束时间06:00。
	MaintainEnd *string `json:"maintain_end,omitempty"`
	// 是否开启公网访问功能。默认不开启公网。 - true：开启 - false：不开启
	EnablePublicip *bool `json:"enable_publicip,omitempty"`
	// 表示公网带宽，单位是Mbit/s。 取值范围： - Kafka实例规格为100MB时，公网带宽取值范围3到900，且必须为实例节点个数的倍数。 - Kafka实例规格为300MB时，公网带宽取值范围3到900，且必须为实例节点个数的倍数。 - Kafka实例规格为600MB时，公网带宽取值范围4到1200，且必须为实例节点个数的倍数。 - Kafka实例规格为1200MB时，公网带宽取值范围8到2400，且必须为实例节点个数的倍数。
	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`
	// 实例绑定的弹性IP地址的ID。  如果开启了公网访问功能（即enable_publicip为true），该字段为必选。
	PublicipId *string `json:"publicip_id,omitempty"`
	// 是否打开SSL加密访问。 - true：打开SSL加密访问。 - false：不打开SSL加密访问。
	SslEnable *bool `json:"ssl_enable,omitempty"`
	// 磁盘的容量到达容量阈值后，对于消息的处理策略。  取值如下： - produce_reject：表示拒绝消息写入。 - time_base：表示自动删除最老消息。
	RetentionPolicy *CreatePostPaidInstanceReqRetentionPolicy `json:"retention_policy,omitempty"`
	// 是否开启消息转储功能。  默认不开启消息转储。
	ConnectorEnable *bool `json:"connector_enable,omitempty"`
	// 是否打开kafka自动创建topic功能。 - true：开启 - false：关闭  当您选择开启，表示生产或消费一个未创建的Topic时，会自动创建一个包含3个分区和3个副本的Topic。
	EnableAutoTopic *bool `json:"enable_auto_topic,omitempty"`
	// 存储IO规格。如何选择磁盘类型请参考[磁盘类型及性能介绍](https://support.huaweicloud.com/productdesc-evs/zh-cn_topic_0044524691.html)。 取值范围：   - 参数specification为100MB时，取值dms.physical.storage.high或者dms.physical.storage.ultra   - 参数specification为300MB时，取值dms.physical.storage.high或者dms.physical.storage.ultra   - 参数specification为600MB时，取值dms.physical.storage.ultra   - 参数specification为1200MB时，取值dms.physical.storage.ultra存储IO规格。如何选择磁盘类型请参考磁盘类型及性能介绍。
	StorageSpecCode CreatePostPaidInstanceReqStorageSpecCode `json:"storage_spec_code"`
	// 企业项目ID。若为企业项目账号，该参数必填。
	EnterpriseProjectId *string `json:"enterprise_project_id,omitempty"`
	// 标签列表。
	Tags *[]CreatePostPaidInstanceReqTags `json:"tags,omitempty"`
}

创建实例请求体。

func (CreatePostPaidInstanceReq) String 

func (o CreatePostPaidInstanceReq) String() string

type CreatePostPaidInstanceReqEngine 

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

func (CreatePostPaidInstanceReqEngine) MarshalJSON 

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

func (*CreatePostPaidInstanceReqEngine) UnmarshalJSON 

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

type CreatePostPaidInstanceReqEngineEnum 

type CreatePostPaidInstanceReqEngineEnum struct {
	KAFKA CreatePostPaidInstanceReqEngine
}

func GetCreatePostPaidInstanceReqEngineEnum 

func GetCreatePostPaidInstanceReqEngineEnum() CreatePostPaidInstanceReqEngineEnum

type CreatePostPaidInstanceReqEngineVersion 

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

func (CreatePostPaidInstanceReqEngineVersion) MarshalJSON 

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

func (*CreatePostPaidInstanceReqEngineVersion) UnmarshalJSON 

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

type CreatePostPaidInstanceReqEngineVersionEnum 

type CreatePostPaidInstanceReqEngineVersionEnum struct {
	E_1_1_0 CreatePostPaidInstanceReqEngineVersion
	E_2_3_0 CreatePostPaidInstanceReqEngineVersion
}

func GetCreatePostPaidInstanceReqEngineVersionEnum 

func GetCreatePostPaidInstanceReqEngineVersionEnum() CreatePostPaidInstanceReqEngineVersionEnum

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

type CreatePostPaidInstanceReqPartitionNumEnum 

type CreatePostPaidInstanceReqPartitionNumEnum struct {
	E_300  CreatePostPaidInstanceReqPartitionNum
	E_900  CreatePostPaidInstanceReqPartitionNum
	E_1800 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

type CreatePostPaidInstanceReqRetentionPolicyEnum 

type CreatePostPaidInstanceReqRetentionPolicyEnum struct {
	TIME_BASE      CreatePostPaidInstanceReqRetentionPolicy
	PRODUCE_REJECT CreatePostPaidInstanceReqRetentionPolicy
}

func GetCreatePostPaidInstanceReqRetentionPolicyEnum 

func GetCreatePostPaidInstanceReqRetentionPolicyEnum() CreatePostPaidInstanceReqRetentionPolicyEnum

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

type CreatePostPaidInstanceReqSpecificationEnum 

type CreatePostPaidInstanceReqSpecificationEnum struct {
	E_100_MB  CreatePostPaidInstanceReqSpecification
	E_300_MB  CreatePostPaidInstanceReqSpecification
	E_600_MB  CreatePostPaidInstanceReqSpecification
	E_1200_MB 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

type CreatePostPaidInstanceReqStorageSpecCodeEnum 

type CreatePostPaidInstanceReqStorageSpecCodeEnum struct {
	DMS_PHYSICAL_STORAGE_NORMAL CreatePostPaidInstanceReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_HIGH   CreatePostPaidInstanceReqStorageSpecCode
	DMS_PHYSICAL_STORAGE_ULTRA  CreatePostPaidInstanceReqStorageSpecCode
}

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum 

func GetCreatePostPaidInstanceReqStorageSpecCodeEnum() CreatePostPaidInstanceReqStorageSpecCodeEnum

type CreatePostPaidInstanceReqTags 

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

func (CreatePostPaidInstanceReqTags) String 

func (o CreatePostPaidInstanceReqTags) String() string

type CreatePostPaidInstanceRequest 

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

Request Object

func (CreatePostPaidInstanceRequest) String 

func (o CreatePostPaidInstanceRequest) String() string

type CreatePostPaidInstanceResponse 

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

Response Object

func (CreatePostPaidInstanceResponse) String 

func (o CreatePostPaidInstanceResponse) String() string

type CreateSinkTaskReq 

type CreateSinkTaskReq struct {
	// 源数据类型，目前只支持BLOB。
	SourceType CreateSinkTaskReqSourceType `json:"source_type"`
	// 转储任务名称。
	TaskName string `json:"task_name"`
	// 转存的目标类型，当前只支持OBS。
	DestinationType          CreateSinkTaskReqDestinationType `json:"destination_type"`
	ObsDestinationDescriptor *ObsDestinationDescriptor        `json:"obs_destination_descriptor"`
}

func (CreateSinkTaskReq) String 

func (o CreateSinkTaskReq) String() string

type CreateSinkTaskReqDestinationType 

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

func (CreateSinkTaskReqDestinationType) MarshalJSON 

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

func (*CreateSinkTaskReqDestinationType) UnmarshalJSON 

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

type CreateSinkTaskReqDestinationTypeEnum 

type CreateSinkTaskReqDestinationTypeEnum struct {
	OBS CreateSinkTaskReqDestinationType
}

func GetCreateSinkTaskReqDestinationTypeEnum 

func GetCreateSinkTaskReqDestinationTypeEnum() CreateSinkTaskReqDestinationTypeEnum

type CreateSinkTaskReqSourceType 

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

func (CreateSinkTaskReqSourceType) MarshalJSON 

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

func (*CreateSinkTaskReqSourceType) UnmarshalJSON 

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

type CreateSinkTaskReqSourceTypeEnum 

type CreateSinkTaskReqSourceTypeEnum struct {
	BLOB CreateSinkTaskReqSourceType
}

func GetCreateSinkTaskReqSourceTypeEnum 

func GetCreateSinkTaskReqSourceTypeEnum() CreateSinkTaskReqSourceTypeEnum

type CreateSinkTaskRequest 

type CreateSinkTaskRequest struct {
	ProjectId   string             `json:"project_id"`
	ConnectorId string             `json:"connector_id"`
	Body        *CreateSinkTaskReq `json:"body,omitempty"`
}

Request Object

func (CreateSinkTaskRequest) String 

func (o CreateSinkTaskRequest) String() string

type CreateSinkTaskResponse 

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

Response Object

func (CreateSinkTaskResponse) String 

func (o CreateSinkTaskResponse) String() string

type DeleteBackgroundTaskRequest 

type DeleteBackgroundTaskRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
	TaskId     string `json:"task_id"`
}

Request Object

func (DeleteBackgroundTaskRequest) String 

func (o DeleteBackgroundTaskRequest) String() string

type DeleteBackgroundTaskResponse 

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

Response Object

func (DeleteBackgroundTaskResponse) String 

func (o DeleteBackgroundTaskResponse) String() string

type DeleteInstanceRequest 

type DeleteInstanceRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

Request Object

func (DeleteInstanceRequest) String 

func (o DeleteInstanceRequest) String() string

type DeleteInstanceResponse 

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

Response Object

func (DeleteInstanceResponse) String 

func (o DeleteInstanceResponse) String() string

type DeleteSinkTaskRequest 

type DeleteSinkTaskRequest struct {
	ProjectId   string `json:"project_id"`
	ConnectorId string `json:"connector_id"`
	TaskId      string `json:"task_id"`
}

Request Object

func (DeleteSinkTaskRequest) String 

func (o DeleteSinkTaskRequest) String() string

type DeleteSinkTaskResponse 

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

Response Object

func (DeleteSinkTaskResponse) String 

func (o DeleteSinkTaskResponse) String() string

type ListAvailableZonesRequest 

type ListAvailableZonesRequest struct {
}

Request Object

func (ListAvailableZonesRequest) String 

func (o ListAvailableZonesRequest) String() string

type ListAvailableZonesRespAvailableZones 

type ListAvailableZonesRespAvailableZones struct {
	// 是否售罄。
	SoldOut *bool `json:"soldOut,omitempty"`
	// 可用区ID。
	Id *string `json:"id,omitempty"`
	// 可用区编码。
	Code *string `json:"code,omitempty"`
	// 可用区名称。
	Name *string `json:"name,omitempty"`
	// 可用区端口号。
	Port *string `json:"port,omitempty"`
	// 分区上是否还有可用资源。
	ResourceAvailability *string `json:"resource_availability,omitempty"`
	// 是否为默认可用区。
	DefaultAz *bool `json:"default_az,omitempty"`
	// 是否支持IPv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`
}

func (ListAvailableZonesRespAvailableZones) String 

func (o ListAvailableZonesRespAvailableZones) String() string

type ListAvailableZonesResponse 

type ListAvailableZonesResponse struct {
	// 区域ID。
	RegionId *string `json:"region_id,omitempty"`
	// 可用区数组。
	AvailableZones *[]ListAvailableZonesRespAvailableZones `json:"available_zones,omitempty"`
	HttpStatusCode int                                     `json:"-"`
}

Response Object

func (ListAvailableZonesResponse) String 

func (o ListAvailableZonesResponse) String() string

type ListBackgroundTasksRequest 

type ListBackgroundTasksRequest struct {
	ProjectId  string  `json:"project_id"`
	InstanceId string  `json:"instance_id"`
	Start      *int32  `json:"start,omitempty"`
	Limit      *int32  `json:"limit,omitempty"`
	BeginTime  *string `json:"begin_time,omitempty"`
	EndTime    *string `json:"end_time,omitempty"`
}

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

Response Object

func (ListBackgroundTasksResponse) String 

func (o ListBackgroundTasksResponse) String() string

type ListInstanceTopicsRequest 

type ListInstanceTopicsRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

Request Object

func (ListInstanceTopicsRequest) String 

func (o ListInstanceTopicsRequest) String() string

type ListInstanceTopicsRespTopics 

type ListInstanceTopicsRespTopics struct {
	// 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"`
}

func (ListInstanceTopicsRespTopics) String 

func (o ListInstanceTopicsRespTopics) String() string

type ListInstanceTopicsResponse 

type ListInstanceTopicsResponse struct {
	// topic总数。
	Count *int32 `json:"count,omitempty"`
	// 分页查询的大小。
	Size *int32 `json:"size,omitempty"`
	// Topic列表。
	Topics         *[]ListInstanceTopicsRespTopics `json:"topics,omitempty"`
	HttpStatusCode int                             `json:"-"`
}

Response Object

func (ListInstanceTopicsResponse) String 

func (o ListInstanceTopicsResponse) String() string

type ListInstancesRequest 

type ListInstancesRequest struct {
	ProjectId           string                              `json:"project_id"`
	Engine              ListInstancesRequestEngine          `json:"engine"`
	Name                *string                             `json:"name,omitempty"`
	InstanceId          *string                             `json:"instance_id,omitempty"`
	Status              *ListInstancesRequestStatus         `json:"status,omitempty"`
	IncludeFailure      *ListInstancesRequestIncludeFailure `json:"include_failure,omitempty"`
	ExactMatchName      *ListInstancesRequestExactMatchName `json:"exact_match_name,omitempty"`
	EnterpriseProjectId *string                             `json:"enterprise_project_id,omitempty"`
}

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

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

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

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

type ListInstancesRequestStatusEnum 

type ListInstancesRequestStatusEnum struct {
	CREATING        ListInstancesRequestStatus
	RUNNING         ListInstancesRequestStatus
	FAULTY          ListInstancesRequestStatus
	RESTARTING      ListInstancesRequestStatus
	RESIZING        ListInstancesRequestStatus
	RESIZING_FAILED ListInstancesRequestStatus
	FROZEN          ListInstancesRequestStatus
}

func GetListInstancesRequestStatusEnum 

func GetListInstancesRequestStatusEnum() ListInstancesRequestStatusEnum

type ListInstancesRespInstances 

type ListInstancesRespInstances struct {
	// 实例名称。
	Name *string `json:"name,omitempty"`
	// 引擎。
	Engine *string `json:"engine,omitempty"`
	// 版本。
	EngineVersion *string `json:"engine_version,omitempty"`
	// 实例规格。
	Specification *string `json:"specification,omitempty"`
	// 消息存储空间，单位：GB。
	StorageSpace *int32 `json:"storage_space,omitempty"`
	// Kafka实例的最大topic数。
	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"`
	// 实例的状态。详细状态说明见[实例状态说明](https://support.huaweicloud.com/api-kafka/kafka-api-180514012.html)。
	Status *string `json:"status,omitempty"`
	// 实例ID。
	InstanceId *string `json:"instance_id,omitempty"`
	// 资源规格标识。   - dms.instance.kafka.cluster.c3.mini：Kafka实例的基准带宽为100MB。   - dms.instance.kafka.cluster.c3.small.2：Kafka实例的基准带宽为300MB。   - dms.instance.kafka.cluster.c3.middle.2：Kafka实例的基准带宽为600MB。   - dms.instance.kafka.cluster.c3.high.2：Kafka实例的基准带宽为1200MB。
	ResourceSpecCode *string `json:"resource_spec_code,omitempty"`
	// 付费模式，1表示按需计费，0表示包年/包月计费。
	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"`
	// 用户ID。
	UserId *string `json:"user_id,omitempty"`
	// 用户名。
	UserName *string `json:"user_name,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实例的KafkaManager连接地址。
	ManagementConnectAddress *string `json:"management_connect_address,omitempty"`
	// 是否开启安全认证。 - true：开启 - false：未开启
	SslEnable *bool `json:"ssl_enable,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 *ListInstancesRespInstancesType `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 *ListInstancesRespInstancesRetentionPolicy `json:"retention_policy,omitempty"`
	// Kafka公网开启状态。
	KafkaPublicStatus *string `json:"kafka_public_status,omitempty"`
	// 公网带宽。
	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`
	// 登录Kafka Manager的用户名。
	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`
	// 是否开启消息收集功能。
	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`
	// 跨VPC访问信息。
	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`
	// 是否开启ipv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`
	// IPv6的连接地址。
	Ipv6ConnectAddresses *[]string `json:"ipv6_connect_addresses,omitempty"`
	// 是否开启转储。
	ConnectorEnable *bool `json:"connector_enable,omitempty"`
	// 转储任务ID。
	ConnectorId *string `json:"connector_id,omitempty"`
	// 是否开启Kafka rest功能。
	RestEnable *bool `json:"rest_enable,omitempty"`
	// Kafka rest地址。
	RestConnectAddress *string `json:"rest_connect_address,omitempty"`
	// 是否开启消息查询功能。
	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"`
	// 租户侧连接地址。
	PodConnectAddress *string `json:"pod_connect_address,omitempty"`
	// 是否开启磁盘加密。
	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`
	// Kafka实例私有连接地址。
	KafkaPrivateConnectAddress *string `json:"kafka_private_connect_address,omitempty"`
	// 云监控版本。
	CesVersion *string `json:"ces_version,omitempty"`
}

func (ListInstancesRespInstances) String 

func (o ListInstancesRespInstances) String() string

type ListInstancesRespInstancesRetentionPolicy 

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

func (ListInstancesRespInstancesRetentionPolicy) MarshalJSON 

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

func (*ListInstancesRespInstancesRetentionPolicy) UnmarshalJSON 

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

type ListInstancesRespInstancesRetentionPolicyEnum 

type ListInstancesRespInstancesRetentionPolicyEnum struct {
	TIME_BASE      ListInstancesRespInstancesRetentionPolicy
	PRODUCE_REJECT ListInstancesRespInstancesRetentionPolicy
}

func GetListInstancesRespInstancesRetentionPolicyEnum 

func GetListInstancesRespInstancesRetentionPolicyEnum() ListInstancesRespInstancesRetentionPolicyEnum

type ListInstancesRespInstancesType 

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

func (ListInstancesRespInstancesType) MarshalJSON 

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

func (*ListInstancesRespInstancesType) UnmarshalJSON 

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

type ListInstancesRespInstancesTypeEnum 

type ListInstancesRespInstancesTypeEnum struct {
	SINGLE  ListInstancesRespInstancesType
	CLUSTER ListInstancesRespInstancesType
}

func GetListInstancesRespInstancesTypeEnum 

func GetListInstancesRespInstancesTypeEnum() ListInstancesRespInstancesTypeEnum

type ListInstancesResponse 

type ListInstancesResponse struct {
	// 实例列表
	Instances *[]ListInstancesRespInstances `json:"instances,omitempty"`
	// 实例数量。
	InstanceNum    *int32 `json:"instance_num,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListInstancesResponse) String 

func (o ListInstancesResponse) String() string

type ListProductsRequest 

type ListProductsRequest struct {
	Engine ListProductsRequestEngine `json:"engine"`
}

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

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实例的最大Topic数。
	PartitionNum *string `json:"partition_num,omitempty"`
	// 产品ID。
	ProductId *string `json:"product_id,omitempty"`
	// 规格ID。
	SpecCode *string `json:"spec_code,omitempty"`
	// IO信息。
	Io *[]ListProductsRespIo `json:"io,omitempty"`
	// Kafka实例的基准带宽。
	Bandwidth *string `json:"bandwidth,omitempty"`
	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`
	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`
	// 该产品规格对应的虚拟机规格。
	EcsFlavorId *string `json:"ecs_flavor_id,omitempty"`
	// 实例规格架构类型。当前仅支持X86。
	ArchType *string `json:"arch_type,omitempty"`
}

func (ListProductsRespDetail) String 

func (o ListProductsRespDetail) String() string

type ListProductsRespHourly 

type ListProductsRespHourly struct {
	// 消息引擎的名称，该字段显示为kafka。
	Name *string `json:"name,omitempty"`
	// 消息引擎的版本，当前仅支持1.1.0和2.3.0。
	Version *string `json:"version,omitempty"`
	// 产品规格列表。
	Values *[]ListProductsRespValues `json:"values,omitempty"`
}

func (ListProductsRespHourly) String 

func (o ListProductsRespHourly) String() string

type ListProductsRespIo 

type ListProductsRespIo struct {
	// IO类型。
	IoType *string `json:"io_type,omitempty"`
	// IO规格。
	StorageSpecCode *string `json:"storage_spec_code,omitempty"`
	// IO未售罄的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`
	// IO已售罄的不可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`
	// 磁盘类型。
	VolumeType *string `json:"volume_type,omitempty"`
}

func (ListProductsRespIo) String 

func (o ListProductsRespIo) String() string

type ListProductsRespValues 

type ListProductsRespValues struct {
	// 规格详情。
	Detail *[]ListProductsRespDetail `json:"detail,omitempty"`
	// 实例类型。
	Name *string `json:"name,omitempty"`
	// 资源售罄的可用区列表。
	UnavailableZones *[]string `json:"unavailable_zones,omitempty"`
	// 有可用资源的可用区列表。
	AvailableZones *[]string `json:"available_zones,omitempty"`
}

func (ListProductsRespValues) String 

func (o ListProductsRespValues) String() string

type ListProductsResponse 

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

Response Object

func (ListProductsResponse) String 

func (o ListProductsResponse) String() string

type ListSinkTasksRequest 

type ListSinkTasksRequest struct {
	ProjectId   string `json:"project_id"`
	ConnectorId string `json:"connector_id"`
}

Request Object

func (ListSinkTasksRequest) String 

func (o ListSinkTasksRequest) String() string

type ListSinkTasksRespTasks 

type ListSinkTasksRespTasks struct {
	// 任务ID。
	TaskId *string `json:"task_id,omitempty"`
	// 转储任务名称。
	TaskName *string `json:"task_name,omitempty"`
	// 转储任务类型。
	DestinationType *string `json:"destination_type,omitempty"`
	// 转储任务创建时间戳。
	CreateTime *string `json:"create_time,omitempty"`
	// 转储任务状态。
	Status *string `json:"status,omitempty"`
	// 返回任务转存的topics列表或者正则表达式。
	Topics *string `json:"topics,omitempty"`
}

func (ListSinkTasksRespTasks) String 

func (o ListSinkTasksRespTasks) String() string

type ListSinkTasksResponse 

type ListSinkTasksResponse struct {
	// 转储任务列表。
	Tasks *[]ListSinkTasksRespTasks `json:"tasks,omitempty"`
	// 转储任务总数。
	TotalNumber *int32 `json:"total_number,omitempty"`
	// 总的支持任务个数。
	MaxTasks *int32 `json:"max_tasks,omitempty"`
	// 任务总数的配额。
	QuotaTasks     *int32 `json:"quota_tasks,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ListSinkTasksResponse) String 

func (o ListSinkTasksResponse) String() string

type ObsDestinationDescriptor 

type ObsDestinationDescriptor struct {
	// 转存的topic列表名称，支持多个topic同时放置，以逗号“,”分隔。同时支持正则表达式。 例如topic1,topic2。
	Topics string `json:"topics"`
	// 转存topic的正则表达式，与topics必须二选一，不能同时都设置或者“.*”。
	TopicsRegex *string `json:"topics_regex,omitempty"`
	// 转储启动偏移量：   - latest: 从Topic最后端开始消费。   - earliest: 从Topic最前端消息开始消费。  默认是latest。
	ConsumerStrategy ObsDestinationDescriptorConsumerStrategy `json:"consumer_strategy"`
	// 转储文件格式。当前只支持text。
	DestinationFileType ObsDestinationDescriptorDestinationFileType `json:"destination_file_type"`
	// 访问密钥AK。
	AccessKey string `json:"access_key"`
	// 访问密钥SK。
	SecretKey string `json:"secret_key"`
	// 存储该通道数据的OBS桶名称。
	ObsBucketName string `json:"obs_bucket_name"`
	// 存储在obs的路径，默认可以不填。 取值范围：英文字母、数字、下划线和斜杠，最大长度为50个字符。 默认配置为空。
	ObsPath *string `json:"obs_path,omitempty"`
	// 将转储文件的生成时间使用“yyyy/MM/dd/HH/mm”格式生成分区字符串，用来定义写到OBS的Object文件所在的目录层次结构。   - N/A：置空，不使用日期时间目录。   - yyyy：年   - yyyy/MM：年/月   - yyyy/MM/dd：年/月/日   - yyyy/MM/dd/HH：年/月/日/时   - yyyy/MM/dd/HH/mm：年/月/日/时/分，例如：2017/11/10/14/49，目录结构就是“2017 > 11 > 10 > 14 > 49”，“2017”表示最外层文件夹。  默认值：空 > 数据转储成功后，存储的目录结构为“obs_bucket_path/file_prefix/partition_format”。默认时间是GMT+8 时间
	PartitionFormat *string `json:"partition_format,omitempty"`
	// 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围：   - 逗号“,”   - 分号“;”   - 竖线“|”   - 换行符“\\n”   - NULL  默认值：换行符“\\n”。
	RecordDelimiter *string `json:"record_delimiter,omitempty"`
	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。 取值范围：30～900 单位：秒。 > 使用OBS通道转储流式数据时该参数为必选配置。
	DeliverTimeInterval string `json:"deliver_time_interval"`
}

转存目标的描述。

func (ObsDestinationDescriptor) String 

func (o ObsDestinationDescriptor) String() string

type ObsDestinationDescriptorConsumerStrategy 

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

func (ObsDestinationDescriptorConsumerStrategy) MarshalJSON 

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

func (*ObsDestinationDescriptorConsumerStrategy) UnmarshalJSON 

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

type ObsDestinationDescriptorConsumerStrategyEnum 

type ObsDestinationDescriptorConsumerStrategyEnum struct {
	LATEST   ObsDestinationDescriptorConsumerStrategy
	EARLIEST ObsDestinationDescriptorConsumerStrategy
}

func GetObsDestinationDescriptorConsumerStrategyEnum 

func GetObsDestinationDescriptorConsumerStrategyEnum() ObsDestinationDescriptorConsumerStrategyEnum

type ObsDestinationDescriptorDestinationFileType 

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

func (ObsDestinationDescriptorDestinationFileType) MarshalJSON 

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

func (*ObsDestinationDescriptorDestinationFileType) UnmarshalJSON 

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

type ObsDestinationDescriptorDestinationFileTypeEnum 

type ObsDestinationDescriptorDestinationFileTypeEnum struct {
	TEXT ObsDestinationDescriptorDestinationFileType
}

func GetObsDestinationDescriptorDestinationFileTypeEnum 

func GetObsDestinationDescriptorDestinationFileTypeEnum() ObsDestinationDescriptorDestinationFileTypeEnum

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 {
	ProjectId  string                   `json:"project_id"`
	InstanceId string                   `json:"instance_id"`
	Body       *ResetManagerPasswordReq `json:"body,omitempty"`
}

Request Object

func (ResetManagerPasswordRequest) String 

func (o ResetManagerPasswordRequest) String() string

type ResetManagerPasswordResponse 

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

Response Object

func (ResetManagerPasswordResponse) String 

func (o ResetManagerPasswordResponse) String() string

type ResetMessageOffsetReq 

type ResetMessageOffsetReq struct {
	// topic名称。
	Topic string `json:"topic"`
	// 分区编号，默认值为-1，若传入值为-1，则重置所有分区。
	Partition *int32 `json:"partition,omitempty"`
	// 重置的消费进度到指定偏移量。 如果传入offset小于当前最小的offset，则重置到最小的offset。 如果大于最大的offset，则重置到最大的offset。 message_offset、timestamp二者必选其一。
	MessageOffset *int32 `json:"message_offset,omitempty"`
	// 重置的消费进度到指定时间，格式为unix时间戳。 如果传入timestamp早于当前最早的timestamp，则重置到最早的timestamp。 如果晚于最晚的timestamp，则重置到最晚的timestamp。 message_offset、timestamp二者必选其一。
	Timestamp *int32 `json:"timestamp,omitempty"`
}

func (ResetMessageOffsetReq) String 

func (o ResetMessageOffsetReq) String() string

type ResetMessageOffsetRequest 

type ResetMessageOffsetRequest struct {
	ProjectId  string                 `json:"project_id"`
	InstanceId string                 `json:"instance_id"`
	Group      string                 `json:"group"`
	Body       *ResetMessageOffsetReq `json:"body,omitempty"`
}

Request Object

func (ResetMessageOffsetRequest) String 

func (o ResetMessageOffsetRequest) String() string

type ResetMessageOffsetResponse 

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

Response Object

func (ResetMessageOffsetResponse) String 

func (o ResetMessageOffsetResponse) String() string

type ResetPasswordReq 

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

func (ResetPasswordReq) String 

func (o ResetPasswordReq) String() string

type ResetPasswordRequest 

type ResetPasswordRequest struct {
	ProjectId  string            `json:"project_id"`
	InstanceId string            `json:"instance_id"`
	Body       *ResetPasswordReq `json:"body,omitempty"`
}

Request Object

func (ResetPasswordRequest) String 

func (o ResetPasswordRequest) String() string

type ResetPasswordResponse 

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

Response Object

func (ResetPasswordResponse) String 

func (o ResetPasswordResponse) String() string

type ResetReplicaReq 

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

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

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 ResizeInstanceReq 

type ResizeInstanceReq struct {
	// 规格变更后的规格ID。  若只扩展磁盘大小，则规格ID保持和原实例不变。  规格ID请参考[查询实例的扩容规格列表](https://support.huaweicloud.com/api-kafka/ShowInstanceExtendProductInfo.html)接口。
	NewSpecCode *string `json:"new_spec_code,omitempty"`
	// 规格变更后的消息存储空间，单位：GB。  若扩展实例基准带宽，则new_storage_space不能低于基准带宽规定的最小磁盘大小。  磁盘空间大小请参考[查询实例的扩容规格列表](https://support.huaweicloud.com/api-kafka/ShowInstanceExtendProductInfo.html)接口。
	NewStorageSpace *int32 `json:"new_storage_space,omitempty"`
}

func (ResizeInstanceReq) String 

func (o ResizeInstanceReq) String() string

type ResizeInstanceRequest 

type ResizeInstanceRequest struct {
	ProjectId  string             `json:"project_id"`
	InstanceId string             `json:"instance_id"`
	Body       *ResizeInstanceReq `json:"body,omitempty"`
}

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

Response Object

func (ResizeInstanceResponse) String 

func (o ResizeInstanceResponse) String() string

type RestartManagerRequest 

type RestartManagerRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

Request Object

func (RestartManagerRequest) String 

func (o RestartManagerRequest) String() string

type RestartManagerResponse 

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

Response Object

func (RestartManagerResponse) String 

func (o RestartManagerResponse) String() string

type ShowBackgroundTaskRequest 

type ShowBackgroundTaskRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
	TaskId     string `json:"task_id"`
}

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

Response Object

func (ShowBackgroundTaskResponse) String 

func (o ShowBackgroundTaskResponse) String() string

type ShowCesHierarchyRequest 

type ShowCesHierarchyRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

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         *[]string `json:"groups,omitempty"`
	HttpStatusCode int       `json:"-"`
}

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

子维度信息。

func (ShowCeshierarchyRespChildren) String 

func (o ShowCeshierarchyRespChildren) String() string

type ShowCeshierarchyRespDimensions 

type ShowCeshierarchyRespDimensions struct {
	// 监控维度名称。
	Name *string `json:"name,omitempty"`
	// 监控指标名称。请参考[支持的监控指标](https://support.huaweicloud.com/usermanual-kafka/kafka-ug-180413002.html)。
	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 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 ShowClusterRequest 

type ShowClusterRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

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

集群基本信息。

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 *string `json:"register_time,omitempty"`
	// Kafka实例节点的连通性是否正常。
	IsHealth *bool `json:"is_health,omitempty"`
}

节点。

func (ShowClusterRespClusterBrokers) String 

func (o ShowClusterRespClusterBrokers) String() string

type ShowClusterResponse 

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

Response Object

func (ShowClusterResponse) String 

func (o ShowClusterResponse) String() string

type ShowCoordinatorsRequest 

type ShowCoordinatorsRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

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

协调器信息。

func (ShowCoordinatorsRespCoordinators) String 

func (o ShowCoordinatorsRespCoordinators) String() string

type ShowCoordinatorsResponse 

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

Response Object

func (ShowCoordinatorsResponse) String 

func (o ShowCoordinatorsResponse) String() string

type ShowGroupsRequest 

type ShowGroupsRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
	Group      string `json:"group"`
}

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

消费组信息。

func (ShowGroupsRespGroup) String 

func (o ShowGroupsRespGroup) String() string

type ShowGroupsRespGroupAssignment 

type ShowGroupsRespGroupAssignment struct {
	// topic名称。
	Topic *string `json:"topic,omitempty"`
	// 分区列表。
	Partitions *[]string `json:"partitions,omitempty"`
}

func (ShowGroupsRespGroupAssignment) String 

func (o ShowGroupsRespGroupAssignment) String() string

type ShowGroupsRespGroupGroupMessageOffsets 

type ShowGroupsRespGroupGroupMessageOffsets struct {
	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`
	// 剩余可消费消息数，即消息堆积数。
	Lag *int32 `json:"lag,omitempty"`
	// topic名称。
	Topic *string `json:"topic,omitempty"`
	// 当前消费进度。
	MessageCurrentOffset *int32 `json:"message_current_offset,omitempty"`
	// 最大消息位置（LEO）。
	MessageLogEndOffset *int32 `json:"message_log_end_offset,omitempty"`
}

func (ShowGroupsRespGroupGroupMessageOffsets) String 

func (o ShowGroupsRespGroupGroupMessageOffsets) String() string

type ShowGroupsRespGroupMembers 

type ShowGroupsRespGroupMembers struct {
	// 消费组consumer地址。
	Host *string `json:"host,omitempty"`
	// consumer分配到的分区信息。
	Assignment *[]ShowGroupsRespGroupAssignment `json:"assignment,omitempty"`
	// 消费组consumer的ID。
	MemberId *string `json:"member_id,omitempty"`
	// 客户端ID。
	ClientId *string `json:"client_id,omitempty"`
}

func (ShowGroupsRespGroupMembers) String 

func (o ShowGroupsRespGroupMembers) String() string

type ShowGroupsResponse 

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

Response Object

func (ShowGroupsResponse) String 

func (o ShowGroupsResponse) String() string

type ShowInstanceExtendProductInfoRequest 

type ShowInstanceExtendProductInfoRequest struct {
	ProjectId  string                                     `json:"project_id"`
	InstanceId string                                     `json:"instance_id"`
	Type       ShowInstanceExtendProductInfoRequestType   `json:"type"`
	Engine     ShowInstanceExtendProductInfoRequestEngine `json:"engine"`
}

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

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

type ShowInstanceExtendProductInfoRequestTypeEnum 

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

func GetShowInstanceExtendProductInfoRequestTypeEnum 

func GetShowInstanceExtendProductInfoRequestTypeEnum() ShowInstanceExtendProductInfoRequestTypeEnum

type ShowInstanceExtendProductInfoResponse 

type ShowInstanceExtendProductInfoResponse struct {
	// 表示按需付费的产品列表。
	Hourly *[]ListProductsRespHourly `json:"hourly,omitempty"`
	// 表示包年包月的产品列表。当前暂不支持通过API创建包年包月的Kafka实例。
	Monthly        *[]ListProductsRespHourly `json:"monthly,omitempty"`
	HttpStatusCode int                       `json:"-"`
}

Response Object

func (ShowInstanceExtendProductInfoResponse) String 

func (o ShowInstanceExtendProductInfoResponse) String() string

type ShowInstanceRequest 

type ShowInstanceRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowInstanceRequest) String 

func (o ShowInstanceRequest) String() string

type ShowInstanceResponse 

type ShowInstanceResponse struct {
	// 实例名称。
	Name *string `json:"name,omitempty"`
	// 引擎。
	Engine *string `json:"engine,omitempty"`
	// 版本。
	EngineVersion *string `json:"engine_version,omitempty"`
	// 实例规格。
	Specification *string `json:"specification,omitempty"`
	// 消息存储空间，单位：GB。
	StorageSpace *int32 `json:"storage_space,omitempty"`
	// Kafka实例的最大topic数。
	PartitionNum *int32 `json:"partition_num,omitempty"`
	// 已使用的消息存储空间，单位：GB。
	UsedStorageSpace *int32 `json:"used_storage_space,omitempty"`
	// 实例连接IP地址。
	ConnectAddress *string `json:"connect_address,omitempty"`
	// 实例连接端口。
	Port *int32 `json:"port,omitempty"`
	// 实例的状态。详细状态说明见[实例状态说明](https://support.huaweicloud.com/api-kafka/kafka-api-180514012.html)。
	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表示包年/包月计费。
	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"`
	// 用户ID。
	UserId *string `json:"user_id,omitempty"`
	// 用户名。
	UserName *string `json:"user_name,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实例的KafkaManager连接地址。
	ManagementConnectAddress *string `json:"management_connect_address,omitempty"`
	// 是否开启安全认证。 - true：开启 - false：未开启
	SslEnable *bool `json:"ssl_enable,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"`
	// 公网带宽。
	PublicBandwidth *int32 `json:"public_bandwidth,omitempty"`
	// 登录Kafka Manager的用户名。
	KafkaManagerUser *string `json:"kafka_manager_user,omitempty"`
	// 是否开启消息收集功能。
	EnableLogCollection *bool `json:"enable_log_collection,omitempty"`
	// 跨VPC访问信息。
	CrossVpcInfo *string `json:"cross_vpc_info,omitempty"`
	// 是否开启ipv6。
	Ipv6Enable *bool `json:"ipv6_enable,omitempty"`
	// IPv6的连接地址。
	Ipv6ConnectAddresses *[]string `json:"ipv6_connect_addresses,omitempty"`
	// 是否开启转储。
	ConnectorEnable *bool `json:"connector_enable,omitempty"`
	// 转储任务ID。
	ConnectorId *string `json:"connector_id,omitempty"`
	// 是否开启Kafka rest功能。
	RestEnable *bool `json:"rest_enable,omitempty"`
	// Kafka rest连接地址。
	RestConnectAddress *string `json:"rest_connect_address,omitempty"`
	// 是否开启消息查询功能。
	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"`
	// 租户侧连接地址。
	PodConnectAddress *string `json:"pod_connect_address,omitempty"`
	// 是否开启磁盘加密。
	DiskEncrypted *bool `json:"disk_encrypted,omitempty"`
	// Kafka实例私有连接地址。
	KafkaPrivateConnectAddress *string `json:"kafka_private_connect_address,omitempty"`
	// 云监控版本。
	CesVersion     *string `json:"ces_version,omitempty"`
	HttpStatusCode int     `json:"-"`
}

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

type ShowInstanceResponseRetentionPolicyEnum 

type ShowInstanceResponseRetentionPolicyEnum struct {
	TIME_BASE      ShowInstanceResponseRetentionPolicy
	PRODUCE_REJECT ShowInstanceResponseRetentionPolicy
}

func GetShowInstanceResponseRetentionPolicyEnum 

func GetShowInstanceResponseRetentionPolicyEnum() ShowInstanceResponseRetentionPolicyEnum

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

type ShowInstanceResponseTypeEnum 

type ShowInstanceResponseTypeEnum struct {
	SINGLE  ShowInstanceResponseType
	CLUSTER ShowInstanceResponseType
}

func GetShowInstanceResponseTypeEnum 

func GetShowInstanceResponseTypeEnum() ShowInstanceResponseTypeEnum

type ShowInstanceTagsRequest 

type ShowInstanceTagsRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
}

Request Object

func (ShowInstanceTagsRequest) String 

func (o ShowInstanceTagsRequest) String() string

type ShowInstanceTagsResponse 

type ShowInstanceTagsResponse struct {
	// 标签列表
	Tags           *[]CreatePostPaidInstanceReqTags `json:"tags,omitempty"`
	HttpStatusCode int                              `json:"-"`
}

Response Object

func (ShowInstanceTagsResponse) String 

func (o ShowInstanceTagsResponse) String() string

type ShowInstanceTopicDetailRequest 

type ShowInstanceTopicDetailRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
	Topic      string `json:"topic"`
}

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"`
	// 分区上次写入消息的时间。
	LastUpdateTimestamp *int32 `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"`
	// 该副本当前日志大小。
	Size *int32 `json:"size,omitempty"`
	// 该副本当前落后hw的消息数。
	Lag *int32 `json:"lag,omitempty"`
}

func (ShowInstanceTopicDetailRespReplicas) String 

func (o ShowInstanceTopicDetailRespReplicas) String() string

type ShowInstanceTopicDetailResponse 

type ShowInstanceTopicDetailResponse struct {
	// topic名称。
	Topic *string `json:"topic,omitempty"`
	// 分区列表。
	Partitions *[]ShowInstanceTopicDetailRespPartitions `json:"partitions,omitempty"`
	// 订阅该topic的消费组名称列表。
	GroupSubscribed *[]string `json:"group_subscribed,omitempty"`
	HttpStatusCode  int       `json:"-"`
}

Response Object

func (ShowInstanceTopicDetailResponse) String 

func (o ShowInstanceTopicDetailResponse) String() string

type ShowMaintainWindowsRequest 

type ShowMaintainWindowsRequest struct {
}

Request Object

func (ShowMaintainWindowsRequest) String 

func (o ShowMaintainWindowsRequest) String() string

type ShowMaintainWindowsResponse 

type ShowMaintainWindowsResponse struct {
	// 支持的维护时间窗列表。
	MaintainWindows *[]ShowMaintainWindowsRespMaintainWindows `json:"maintain_windows,omitempty"`
	HttpStatusCode  int                                       `json:"-"`
}

Response Object

func (ShowMaintainWindowsResponse) String 

func (o ShowMaintainWindowsResponse) String() string

type ShowMessagesRequest 

type ShowMessagesRequest struct {
	ProjectId  string  `json:"project_id"`
	InstanceId string  `json:"instance_id"`
	Topic      string  `json:"topic"`
	StartTime  *string `json:"start_time,omitempty"`
	EndTime    *string `json:"end_time,omitempty"`
	Limit      *int32  `json:"limit,omitempty"`
	Offset     *int32  `json:"offset,omitempty"`
	Partition  *string `json:"partition,omitempty"`
}

Request Object

func (ShowMessagesRequest) String 

func (o ShowMessagesRequest) String() string

type ShowMessagesRespMessages 

type ShowMessagesRespMessages struct {
	// topic名称。
	Topic *string `json:"topic,omitempty"`
	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`
	// 消息编号。
	MessageOffset *int32 `json:"message_offset,omitempty"`
	// 消息大小，单位字节。
	Size *int32 `json:"size,omitempty"`
}

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

Response Object

func (ShowMessagesResponse) String 

func (o ShowMessagesResponse) String() string

type ShowPartitionBeginningMessageRequest 

type ShowPartitionBeginningMessageRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
	Topic      string `json:"topic"`
	Partition  int32  `json:"partition"`
}

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"`
	// 最新消息位置。
	MessageOffset  *int32 `json:"message_offset,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowPartitionBeginningMessageResponse) String 

func (o ShowPartitionBeginningMessageResponse) String() string

type ShowPartitionEndMessageRequest 

type ShowPartitionEndMessageRequest struct {
	ProjectId  string `json:"project_id"`
	InstanceId string `json:"instance_id"`
	Topic      string `json:"topic"`
	Partition  int32  `json:"partition"`
}

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"`
	// 最新消息位置。
	MessageOffset  *int32 `json:"message_offset,omitempty"`
	HttpStatusCode int    `json:"-"`
}

Response Object

func (ShowPartitionEndMessageResponse) String 

func (o ShowPartitionEndMessageResponse) String() string

type ShowPartitionMessageRequest 

type ShowPartitionMessageRequest struct {
	ProjectId     string `json:"project_id"`
	InstanceId    string `json:"instance_id"`
	Topic         string `json:"topic"`
	Partition     int32  `json:"partition"`
	MessageOffset string `json:"message_offset"`
}

Request Object

func (ShowPartitionMessageRequest) String 

func (o ShowPartitionMessageRequest) String() string

type ShowPartitionMessageRespMessage 

type ShowPartitionMessageRespMessage struct {
	// 消息的key。
	Key *string `json:"key,omitempty"`
	// 消息内容。
	Value *string `json:"value,omitempty"`
	// Topic名称。
	Topic *string `json:"topic,omitempty"`
	// 分区编号。
	Partition *int32 `json:"partition,omitempty"`
	// 消息位置。
	MessageOffset *int32 `json:"message_offset,omitempty"`
	// 消息大小，单位字节。
	Size *int32 `json:"size,omitempty"`
}

消息体。

func (ShowPartitionMessageRespMessage) String 

func (o ShowPartitionMessageRespMessage) String() string

type ShowPartitionMessageResponse 

type ShowPartitionMessageResponse struct {
	// 消息列表。
	Message        *[]ShowPartitionMessageRespMessage `json:"message,omitempty"`
	HttpStatusCode int                                `json:"-"`
}

Response Object

func (ShowPartitionMessageResponse) String 

func (o ShowPartitionMessageResponse) String() string

type ShowProjectTagsRequest 

type ShowProjectTagsRequest struct {
	ProjectId string `json:"project_id"`
}

Request Object

func (ShowProjectTagsRequest) String 

func (o ShowProjectTagsRequest) String() string

type ShowProjectTagsRespTags 

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

func (ShowProjectTagsRespTags) String 

func (o ShowProjectTagsRespTags) String() string

type ShowProjectTagsResponse 

type ShowProjectTagsResponse struct {
	// 标签列表
	Tags           *[]ShowProjectTagsRespTags `json:"tags,omitempty"`
	HttpStatusCode int                        `json:"-"`
}

Response Object

func (ShowProjectTagsResponse) String 

func (o ShowProjectTagsResponse) String() string

type ShowSinkTaskDetailRequest 

type ShowSinkTaskDetailRequest struct {
	ProjectId   string `json:"project_id"`
	ConnectorId string `json:"connector_id"`
	TaskId      string `json:"task_id"`
}

Request Object

func (ShowSinkTaskDetailRequest) String 

func (o ShowSinkTaskDetailRequest) String() string

type ShowSinkTaskDetailRespObsDestinationDescriptor 

type ShowSinkTaskDetailRespObsDestinationDescriptor struct {
	// 消费启动策略：  - latest：从Topic最后端开始消费。  - earliest: 从Topic最前端消息开始消费。  默认是latest。
	ConsumerStrategy *string `json:"consumer_strategy,omitempty"`
	// 转储文件格式。目前只支持text格式。
	DestinationFileType *string `json:"destination_file_type,omitempty"`
	// 存储该通道数据的OBS桶名称。
	ObsBucketName *string `json:"obs_bucket_name,omitempty"`
	// 存储在obs的路径。
	ObsPath *string `json:"obs_path,omitempty"`
	// 将转储文件的生成时间使用“yyyy/MM/dd/HH/mm”格式生成分区字符串，用来定义写到OBS的Object文件所在的目录层次结构。   - N/A：置空，不使用日期时间目录。   - yyyy：年   - yyyy/MM：年/月   - yyyy/MM/dd：年/月/日   - yyyy/MM/dd/HH：年/月/日/时   - yyyy/MM/dd/HH/mm：年/月/日/时/分，例如：2017/11/10/14/49，目录结构就是“2017 > 11 > 10 > 14 > 49”，“2017”表示最外层文件夹。  默认值：空 > 数据转储成功后，存储的目录结构为“obs_bucket_path/file_prefix/partition_format”。默认时间是GMT+8 时间
	PartitionFormat *string `json:"partition_format,omitempty"`
	// 转储文件的记录分隔符，用于分隔写入转储文件的用户数据。 取值范围：   - 逗号“,”   - 分号“;”   - 竖线“|”   - 换行符“\\n”   - NULL  默认值：换行符“\\n”。
	RecordDelimiter *string `json:"record_delimiter,omitempty"`
	// 根据用户配置的时间，周期性的将数据导入OBS，若某个时间段内无数据，则此时间段不会生成打包文件。 取值范围：30～900 缺省值：300 单位：秒。 > 使用OBS通道转储流式数据时该参数为必选配置。
	DeliverTimeInterval *string `json:"deliver_time_interval,omitempty"`
	// 每个传输文件多大后就开始上传，单位为byte。 默认值5242880。
	ObsPartSize *string `json:"obs_part_size,omitempty"`
}

转存目标的描述。

func (ShowSinkTaskDetailRespObsDestinationDescriptor) String 

func (o ShowSinkTaskDetailRespObsDestinationDescriptor) String() string

type ShowSinkTaskDetailResponse 

type ShowSinkTaskDetailResponse struct {
	// 转储任务名称。
	TaskName *string `json:"task_name,omitempty"`
	// 转储任务类型。
	DestinationType *string `json:"destination_type,omitempty"`
	// 转储任务创建时间戳。
	CreateTime *string `json:"create_time,omitempty"`
	// 转储任务状态。
	Status *string `json:"status,omitempty"`
	// 返回任务转存的topics列表或者正则表达式。
	Topics                   *string                                         `json:"topics,omitempty"`
	ObsDestinationDescriptor *ShowSinkTaskDetailRespObsDestinationDescriptor `json:"obs_destination_descriptor,omitempty"`
	HttpStatusCode           int                                             `json:"-"`
}

Response Object

func (ShowSinkTaskDetailResponse) String 

func (o ShowSinkTaskDetailResponse) 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 {
	ProjectId  string                            `json:"project_id"`
	InstanceId string                            `json:"instance_id"`
	Body       *UpdateInstanceAutoCreateTopicReq `json:"body,omitempty"`
}

Request Object

func (UpdateInstanceAutoCreateTopicRequest) String 

func (o UpdateInstanceAutoCreateTopicRequest) String() string

type UpdateInstanceAutoCreateTopicResponse 

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

Response Object

func (UpdateInstanceAutoCreateTopicResponse) String 

func (o UpdateInstanceAutoCreateTopicResponse) 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 {
	ProjectId  string                       `json:"project_id"`
	InstanceId string                       `json:"instance_id"`
	Body       *UpdateInstanceCrossVpcIpReq `json:"body,omitempty"`
}

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 *string `json:"success,omitempty"`
	// listeners IP。
	Ip *string `json:"ip,omitempty"`
}

修改broker跨VPC访问的结果。

func (UpdateInstanceCrossVpcIpRespResults) String 

func (o UpdateInstanceCrossVpcIpRespResults) String() string

type UpdateInstanceCrossVpcIpResponse 

type UpdateInstanceCrossVpcIpResponse struct {
	// 修改跨VPC访问结果。
	Success *string `json:"success,omitempty"`
	// 修改broker跨VPC访问的结果列表。
	Results        *[]UpdateInstanceCrossVpcIpRespResults `json:"results,omitempty"`
	HttpStatusCode int                                    `json:"-"`
}

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。   - 维护时间窗开始和结束时间必须为指定的时间段，可参考查[询维护时间窗时间段](https://support.huaweicloud.com/api-kafka/ShowMaintainWindows.html)。   - 开始时间必须为22:00:00、02:00:00、06:00:00、10:00:00、14:00:00和18:00:00。   - 该参数不能单独为空，若该值为空，则结束时间也为空。系统分配一个默认开始时间02:00:00。
	MaintainBegin *string `json:"maintain_begin,omitempty"`
	// 维护时间窗结束时间，格式为HH:mm:ss。   - 维护时间窗开始和结束时间必须为指定的时间段，可参考查[询维护时间窗时间段](https://support.huaweicloud.com/api-kafka/ShowMaintainWindows.html)。   - 结束时间在开始时间基础上加四个小时，即当开始时间为22:00:00时，结束时间为02:00:00。   - 该参数不能单独为空，若该值为空，则开始时间也为空。系统分配一个默认结束时间06:00:00。
	MaintainEnd *string `json:"maintain_end,omitempty"`
	// 安全组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

type UpdateInstanceReqRetentionPolicyEnum 

type UpdateInstanceReqRetentionPolicyEnum struct {
	PRODUCE_REJECT UpdateInstanceReqRetentionPolicy
	TIME_BASE      UpdateInstanceReqRetentionPolicy
}

func GetUpdateInstanceReqRetentionPolicyEnum 

func GetUpdateInstanceReqRetentionPolicyEnum() UpdateInstanceReqRetentionPolicyEnum

type UpdateInstanceRequest 

type UpdateInstanceRequest struct {
	ProjectId  string             `json:"project_id"`
	InstanceId string             `json:"instance_id"`
	Body       *UpdateInstanceReq `json:"body,omitempty"`
}

Request Object

func (UpdateInstanceRequest) String 

func (o UpdateInstanceRequest) String() string

type UpdateInstanceResponse 

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

Response Object

func (UpdateInstanceResponse) String 

func (o UpdateInstanceResponse) String() string

type UpdateInstanceTopicReq 

type UpdateInstanceTopicReq struct {
	// 修改的topic列表。
	Topics *[]UpdateInstanceTopicReqTopics `json:"topics,omitempty"`
}

修改的topic列表。

func (UpdateInstanceTopicReq) String 

func (o UpdateInstanceTopicReq) String() string

type UpdateInstanceTopicReqTopics 

type UpdateInstanceTopicReqTopics struct {
	// topic名称
	Id *string `json:"id,omitempty"`
	// 老化时间，单位小时。
	RetentionTime *string `json:"retention_time,omitempty"`
	// 是否同步复制。
	SyncReplication *bool `json:"sync_replication,omitempty"`
	// 是否同步落盘。
	SyncMessageFlush *bool `json:"sync_message_flush,omitempty"`
}

修改的topic。

func (UpdateInstanceTopicReqTopics) String 

func (o UpdateInstanceTopicReqTopics) String() string

type UpdateInstanceTopicRequest 

type UpdateInstanceTopicRequest struct {
	ProjectId  string                  `json:"project_id"`
	InstanceId string                  `json:"instance_id"`
	Body       *UpdateInstanceTopicReq `json:"body,omitempty"`
}

Request Object

func (UpdateInstanceTopicRequest) String 

func (o UpdateInstanceTopicRequest) String() string

type UpdateInstanceTopicResponse 

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

Response Object

func (UpdateInstanceTopicResponse) String 

func (o UpdateInstanceTopicResponse) String() string

type UpdateSinkTaskQuotaReq 

type UpdateSinkTaskQuotaReq struct {
	// 转储任务的总个数。
	SinkMaxTasks string `json:"sink_max_tasks"`
}

func (UpdateSinkTaskQuotaReq) String 

func (o UpdateSinkTaskQuotaReq) String() string

type UpdateSinkTaskQuotaRequest 

type UpdateSinkTaskQuotaRequest struct {
	ProjectId   string                  `json:"project_id"`
	ConnectorId string                  `json:"connector_id"`
	Body        *UpdateSinkTaskQuotaReq `json:"body,omitempty"`
}

Request Object

func (UpdateSinkTaskQuotaRequest) String 

func (o UpdateSinkTaskQuotaRequest) String() string

type UpdateSinkTaskQuotaResponse 

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

Response Object

func (UpdateSinkTaskQuotaResponse) String 

func (o UpdateSinkTaskQuotaResponse) String() string

type UpdateTopicReplicaRequest 

type UpdateTopicReplicaRequest struct {
	ProjectId  string           `json:"project_id"`
	InstanceId string           `json:"instance_id"`
	Topic      string           `json:"topic"`
	Body       *ResetReplicaReq `json:"body,omitempty"`
}

Request Object

func (UpdateTopicReplicaRequest) String 

func (o UpdateTopicReplicaRequest) String() string

type UpdateTopicReplicaResponse 

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

Response Object

func (UpdateTopicReplicaResponse) String 

func (o UpdateTopicReplicaResponse) 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.