kafka

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Sep 26, 2025 License: MPL-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCtyunKafkaInstance 

func NewCtyunKafkaInstance() resource.Resource

func NewCtyunKafkaInstances 

func NewCtyunKafkaInstances() datasource.DataSource

func NewCtyunKafkaSpecs 

func NewCtyunKafkaSpecs() datasource.DataSource

Types

type CtyunKafkaInstanceConfig 

type CtyunKafkaInstanceConfig struct {
	ID                  types.String `tfsdk:"id"`
	Name                types.String `tfsdk:"name"`
	MasterOrderID       types.String `tfsdk:"master_order_id"`
	RegionID            types.String `tfsdk:"region_id"`
	ProjectID           types.String `tfsdk:"project_id"`             /*  企业项目ID(默认值：0)。您可以通过 <a href="https://www.ctyun.cn/document/10017248/10017965">查看企业项目资源</a> 获取企业项目ID。  */
	InstanceName        types.String `tfsdk:"instance_name"`          /*  实例名称。<br>规则：长度4~40个字符，大小写字母开头，只能包含大小写字母、数字及分隔符(-)，大小写字母或数字结尾，实例名称不可重复。  */
	EngineVersion       types.String `tfsdk:"engine_version"`         /*  实例的引擎版本，默认为3.6。<li>2.8：2.8.x的引擎版本<li>3.6：3.6.x的引擎版本  */
	SpecName            types.String `tfsdk:"spec_name"`              /*  实例的规格类型，资源池所具备的规格可通过查询产品规格接口获取，默认可选如下：<br>计算增强型的规格可选为：<li>kafka.2u4g.cluster<li>kafka.4u8g.cluster<li>kafka.8u16g.cluster<li>kafka.12u24g.cluster<li>kafka.16u32g.cluster<li>kafka.24u48g.cluster<li>kafka.32u64g.cluster<li>kafka.48u96g.cluster<li>kafka.64u128g.cluster <br>海光-计算增强型的规格可选为：<li>kafka.hg.2u4g.cluster<li>kafka.hg.4u8g.cluster<li>kafka.hg.8u16g.cluster<li>kafka.hg.16u32g.cluster<li>kafka.hg.32u64g.cluster <br>鲲鹏-计算增强型的规格可选为：<li>kafka.kp.2u4g.cluster<li>kafka.kp.4u8g.cluster<li>kafka.kp.8u16g.cluster<li>kafka.kp.16u32g.cluster<li>kafka.kp.32u64g.cluster  */
	NodeNum             types.Int32  `tfsdk:"node_num"`               /*  节点数。单机版为1个，集群版3~50个。  */
	ZoneList            types.Set    `tfsdk:"zone_list"`              /*  实例所在可用区信息。只能填一个（单可用区）或三个（多可用区），可用区信息可调用<a href="https://eop.ctyun.cn/ebp/ctapiDocument/search?sid=25&api=5855&data=87&isNormal=1&vid=81">资源池可用区查询</a>API接口查询。  */
	DiskType            types.String `tfsdk:"disk_type"`              /*  磁盘类型，资源池所具备的磁盘类型可通过查询产品规格接口获取，默认取值：<li>SAS：高IO<li>SSD：超高IO<li>FAST-SSD：极速型SSD  */
	DiskSize            types.Int32  `tfsdk:"disk_size"`              /*  单个节点的磁盘存储空间，单位为GB，存储空间取值范围100GB ~ 10000，并且为100的倍数。实例总存储空间为diskSize * nodeNum。  */
	VpcID               types.String `tfsdk:"vpc_id"`                 /*  VPC网络ID。获取方法如下：<li>方法一：登录网络控制台界面，在虚拟私有云的详情页面查找VPC ID。<li>方法二：您可以通过 <a href="https://eop.ctyun.cn/ebp/ctapiDocument/search?sid=18&api=4814&data=94&vid=88">查询VPC列表</a> vpcID字段获取。  */
	SubnetID            types.String `tfsdk:"subnet_id"`              /*  VPC子网ID。获取方法如下：<li>方法一：登录网络控制台界面，单击VPC下的子网，进入子网详情页面，查找子网ID。<li>方法二：您可以通过 <a href="https://eop.ctyun.cn/ebp/ctapiDocument/search?sid=18&api=8659&data=94&vid=88">查询子网列表</a> subnetID字段获取。  */
	SecurityGroupID     types.String `tfsdk:"security_group_id"`      /*  安全组ID。获取方法如下：<li>方法一：登录网络控制台界面，在安全组的详情页面查找安全组ID。<li>方法二：您可以通过 <a href="https://eop.ctyun.cn/ebp/searchCtapi/ctApiDebug?product=18&api=4817&vid=88">查询用户安全组列表</a> id字段获取。  */
	EnableIpv6          types.Bool   `tfsdk:"enable_ipv6"`            /*  是否启用IPv6，默认为false。<li>true：启用IPv6。<li>false：不启用IPv6，默认值。  */
	PlainPort           types.Int32  `tfsdk:"plain_port"`             /*  公共接入点(PLAINTEXT)端口，范围在8000到9100之间，默认为8090。  */
	SaslPort            types.Int32  `tfsdk:"sasl_port"`              /*  安全接入点(SASL_PLAINTEXT)端口，范围在8000到9100之间，默认为8092。  */
	SslPort             types.Int32  `tfsdk:"ssl_port"`               /*  SSL接入点(SASL_SSL)端口，范围在8000到9100之间，默认为8098。  */
	HttpPort            types.Int32  `tfsdk:"http_port"`              /*  HTTP接入点端口，范围在8000到9100之间，默认为8082。  */
	RetentionHours      types.Int32  `tfsdk:"retention_hours"`        /*  实例消息保留时长，默认为72小时，可选1~10000小时。  */
	CycleType           types.String `tfsdk:"cycle_type"`             /*  按需: on_demand, 包月：month */
	CycleCount          types.Int32  `tfsdk:"cycle_count"`            /*  付费周期，单位为月，取值：1~6,12,24,36。  */
	AutoRenew           types.Bool   `tfsdk:"auto_renew"`             /*  过期是否自动续订。，默认为false。<li>true：自动续订。<li>false：不自动续订，默认值。  */
	AutoRenewCycleCount types.Int32  `tfsdk:"auto_renew_cycle_count"` /*  自动续订时间长，当autoRenewStatus为true时必填，取值：1~6。  */
}

type CtyunKafkaInstancesConfig 

type CtyunKafkaInstancesConfig struct {
	RegionID     types.String               `tfsdk:"region_id"`
	PageNo       types.Int32                `tfsdk:"page_no"`
	PageSize     types.Int32                `tfsdk:"page_size"`
	InstanceName types.String               `tfsdk:"instance_name"`
	InstanceID   types.String               `tfsdk:"instance_id"`
	ProjectID    types.String               `tfsdk:"project_id"`
	Instances    []CtyunKafkaInstancesModel `tfsdk:"instances"`
}

type CtyunKafkaInstancesModel 

type CtyunKafkaInstancesModel struct {
	ID            types.String `tfsdk:"id"`
	Status        types.Int32  `tfsdk:"status"`
	StatusDesc    types.String `tfsdk:"status_desc"`
	ProjectID     types.String `tfsdk:"project_id"`
	InstanceName  types.String `tfsdk:"instance_name"`
	EngineVersion types.String `tfsdk:"engine_version"`
	SpecName      types.String `tfsdk:"spec_name"`
	NodeNum       types.Int32  `tfsdk:"node_num"`
	DiskType      types.String `tfsdk:"disk_type"`
	DiskSize      types.Int32  `tfsdk:"disk_size"`
	VpcID         types.String `tfsdk:"vpc_id"`
	SubnetID      types.String `tfsdk:"subnet_id"`
	EnableIpv6    types.Bool   `tfsdk:"enable_ipv6"`
}

type CtyunKafkaSpecsConfig 

type CtyunKafkaSpecsConfig struct {
	RegionID types.String           `tfsdk:"region_id"`
	Specs    []CtyunKafkaSpecsModel `tfsdk:"specs"`
}

type CtyunKafkaSpecsModel 

type CtyunKafkaSpecsModel struct {
	ProdId   types.String         `tfsdk:"prod_id"`
	ProdName types.String         `tfsdk:"prod_name"`
	ProdCode types.String         `tfsdk:"prod_code"`
	Sku      []CtyunKafkaSpecsSku `tfsdk:"sku"`
}

type CtyunKafkaSpecsSku 

type CtyunKafkaSpecsSku struct {
	ProdId   types.String               `tfsdk:"prod_id"`
	ProdName types.String               `tfsdk:"prod_name"`
	ProdCode types.String               `tfsdk:"prod_code"`
	ResItem  CtyunKafkaSpecsSkuResItem  `tfsdk:"res_item"`
	DiskItem CtyunKafkaSpecsSkuDiskItem `tfsdk:"disk_item"`
}

type CtyunKafkaSpecsSkuDiskItem 

type CtyunKafkaSpecsSkuDiskItem struct {
	ResType  types.String `tfsdk:"res_type"`
	ResName  types.String `tfsdk:"res_name"`
	ResItems []string     `tfsdk:"res_items"`
}

type CtyunKafkaSpecsSkuResItem 

type CtyunKafkaSpecsSkuResItem struct {
	ResType  types.String                        `tfsdk:"res_type"`
	ResName  types.String                        `tfsdk:"res_name"`
	ResItems []CtyunKafkaSpecsSkuResItemResItems `tfsdk:"res_items"`
}

type CtyunKafkaSpecsSkuResItemResItems 

type CtyunKafkaSpecsSkuResItemResItems struct {
	CpuArch  types.String                            `tfsdk:"cpu_arch"`
	HostType types.String                            `tfsdk:"host_type"`
	Spec     []CtyunKafkaSpecsSkuResItemResItemsSpec `tfsdk:"spec"`
}

type CtyunKafkaSpecsSkuResItemResItemsSpec 

type CtyunKafkaSpecsSkuResItemResItemsSpec struct {
	SpecName     types.String `tfsdk:"spec_name"`
	Description  types.String `tfsdk:"description"`
	Tps          types.Int32  `tfsdk:"tps"`
	MaxPartition types.Int32  `tfsdk:"max_partition"`
	Flow         types.Int32  `tfsdk:"flow"`
	Cpu          types.Int32  `tfsdk:"cpu"`
	Memory       types.Int32  `tfsdk:"memory"`
}

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.