dms

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Jul 28, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PkgVersion added in v0.0.2 

func PkgVersion() (semver.Version, error)

PkgVersion uses reflection to determine the version of the current package. If a version cannot be determined, v1 will be assumed. The second return value is always nil.

Types

type GetFlavorsArgs 

type GetFlavorsArgs struct {
	// Specifies the type of CPU architecture, e.g. **X86**.
	ArchType *string `pulumi:"archType"`
	// Specifies the list of availability zones with available resources.
	AvailabilityZones []string `pulumi:"availabilityZones"`
	// Specifies the flavor billing mode.
	// The valid valus are **prePaid** and **postPaid**.
	ChargingMode *string `pulumi:"chargingMode"`
	// Specifies the DMS flvaor ID, e.g. **c6.2u4g.cluster**.
	FlavorId *string `pulumi:"flavorId"`
	// Specifies the region in which to obtain the dms kafka flavors.
	// If omitted, the provider-level region will be used.
	Region *string `pulumi:"region"`
	// Specifies the disk IO encoding.
	// + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O.
	// + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.
	StorageSpecCode *string `pulumi:"storageSpecCode"`
	// Specifies flavor type. The valid values are **single** and **cluster**.
	Type *string `pulumi:"type"`
}

A collection of arguments for invoking getFlavors.

type GetFlavorsFlavor 

type GetFlavorsFlavor struct {
	// The list of supported CPU architectures.
	ArchTypes []string `pulumi:"archTypes"`
	// The list of supported billing modes.
	ChargingModes []string `pulumi:"chargingModes"`
	// The flavor ID.
	Id string `pulumi:"id"`
	// The list of supported disk IO types.
	// The object structure is documented below.
	Ios []GetFlavorsFlavorIo `pulumi:"ios"`
	// The function property details.
	// The object structure is documented below.
	Properties []GetFlavorsFlavorProperty `pulumi:"properties"`
	// The list of features supported by the current specification.
	// The object structure is documented below.
	SupportFeatures []GetFlavorsFlavorSupportFeature `pulumi:"supportFeatures"`
	// Specifies flavor type. The valid values are **single** and **cluster**.
	Type string `pulumi:"type"`
	// The underlying VM specification.
	VmSpecification string `pulumi:"vmSpecification"`
}

type GetFlavorsFlavorArgs 

type GetFlavorsFlavorArgs struct {
	// The list of supported CPU architectures.
	ArchTypes pulumi.StringArrayInput `pulumi:"archTypes"`
	// The list of supported billing modes.
	ChargingModes pulumi.StringArrayInput `pulumi:"chargingModes"`
	// The flavor ID.
	Id pulumi.StringInput `pulumi:"id"`
	// The list of supported disk IO types.
	// The object structure is documented below.
	Ios GetFlavorsFlavorIoArrayInput `pulumi:"ios"`
	// The function property details.
	// The object structure is documented below.
	Properties GetFlavorsFlavorPropertyArrayInput `pulumi:"properties"`
	// The list of features supported by the current specification.
	// The object structure is documented below.
	SupportFeatures GetFlavorsFlavorSupportFeatureArrayInput `pulumi:"supportFeatures"`
	// Specifies flavor type. The valid values are **single** and **cluster**.
	Type pulumi.StringInput `pulumi:"type"`
	// The underlying VM specification.
	VmSpecification pulumi.StringInput `pulumi:"vmSpecification"`
}

func (GetFlavorsFlavorArgs) ElementType 

func (GetFlavorsFlavorArgs) ElementType() reflect.Type

func (GetFlavorsFlavorArgs) ToGetFlavorsFlavorOutput 

func (i GetFlavorsFlavorArgs) ToGetFlavorsFlavorOutput() GetFlavorsFlavorOutput

func (GetFlavorsFlavorArgs) ToGetFlavorsFlavorOutputWithContext 

func (i GetFlavorsFlavorArgs) ToGetFlavorsFlavorOutputWithContext(ctx context.Context) GetFlavorsFlavorOutput

type GetFlavorsFlavorArray 

type GetFlavorsFlavorArray []GetFlavorsFlavorInput

func (GetFlavorsFlavorArray) ElementType 

func (GetFlavorsFlavorArray) ElementType() reflect.Type

func (GetFlavorsFlavorArray) ToGetFlavorsFlavorArrayOutput 

func (i GetFlavorsFlavorArray) ToGetFlavorsFlavorArrayOutput() GetFlavorsFlavorArrayOutput

func (GetFlavorsFlavorArray) ToGetFlavorsFlavorArrayOutputWithContext 

func (i GetFlavorsFlavorArray) ToGetFlavorsFlavorArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorArrayOutput

type GetFlavorsFlavorArrayInput 

type GetFlavorsFlavorArrayInput interface {
	pulumi.Input

	ToGetFlavorsFlavorArrayOutput() GetFlavorsFlavorArrayOutput
	ToGetFlavorsFlavorArrayOutputWithContext(context.Context) GetFlavorsFlavorArrayOutput
}

GetFlavorsFlavorArrayInput is an input type that accepts GetFlavorsFlavorArray and GetFlavorsFlavorArrayOutput values. You can construct a concrete instance of `GetFlavorsFlavorArrayInput` via: 

GetFlavorsFlavorArray{ GetFlavorsFlavorArgs{...} }

type GetFlavorsFlavorArrayOutput 

type GetFlavorsFlavorArrayOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorArrayOutput) ElementType 

func (GetFlavorsFlavorArrayOutput) ElementType() reflect.Type

func (GetFlavorsFlavorArrayOutput) Index 

func (o GetFlavorsFlavorArrayOutput) Index(i pulumi.IntInput) GetFlavorsFlavorOutput

func (GetFlavorsFlavorArrayOutput) ToGetFlavorsFlavorArrayOutput 

func (o GetFlavorsFlavorArrayOutput) ToGetFlavorsFlavorArrayOutput() GetFlavorsFlavorArrayOutput

func (GetFlavorsFlavorArrayOutput) ToGetFlavorsFlavorArrayOutputWithContext 

func (o GetFlavorsFlavorArrayOutput) ToGetFlavorsFlavorArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorArrayOutput

type GetFlavorsFlavorInput 

type GetFlavorsFlavorInput interface {
	pulumi.Input

	ToGetFlavorsFlavorOutput() GetFlavorsFlavorOutput
	ToGetFlavorsFlavorOutputWithContext(context.Context) GetFlavorsFlavorOutput
}

GetFlavorsFlavorInput is an input type that accepts GetFlavorsFlavorArgs and GetFlavorsFlavorOutput values. You can construct a concrete instance of `GetFlavorsFlavorInput` via: 

GetFlavorsFlavorArgs{...}

type GetFlavorsFlavorIo 

type GetFlavorsFlavorIo struct {
	// Specifies the list of availability zones with available resources.
	AvailabilityZones []string `pulumi:"availabilityZones"`
	// Specifies the disk IO encoding.
	// + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O.
	// + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.
	StorageSpecCode string `pulumi:"storageSpecCode"`
	// Specifies flavor type. The valid values are **single** and **cluster**.
	Type string `pulumi:"type"`
	// The list of unavailability zones with available resources.
	UnavailabilityZones []string `pulumi:"unavailabilityZones"`
}

type GetFlavorsFlavorIoArgs 

type GetFlavorsFlavorIoArgs struct {
	// Specifies the list of availability zones with available resources.
	AvailabilityZones pulumi.StringArrayInput `pulumi:"availabilityZones"`
	// Specifies the disk IO encoding.
	// + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O.
	// + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.
	StorageSpecCode pulumi.StringInput `pulumi:"storageSpecCode"`
	// Specifies flavor type. The valid values are **single** and **cluster**.
	Type pulumi.StringInput `pulumi:"type"`
	// The list of unavailability zones with available resources.
	UnavailabilityZones pulumi.StringArrayInput `pulumi:"unavailabilityZones"`
}

func (GetFlavorsFlavorIoArgs) ElementType 

func (GetFlavorsFlavorIoArgs) ElementType() reflect.Type

func (GetFlavorsFlavorIoArgs) ToGetFlavorsFlavorIoOutput 

func (i GetFlavorsFlavorIoArgs) ToGetFlavorsFlavorIoOutput() GetFlavorsFlavorIoOutput

func (GetFlavorsFlavorIoArgs) ToGetFlavorsFlavorIoOutputWithContext 

func (i GetFlavorsFlavorIoArgs) ToGetFlavorsFlavorIoOutputWithContext(ctx context.Context) GetFlavorsFlavorIoOutput

type GetFlavorsFlavorIoArray 

type GetFlavorsFlavorIoArray []GetFlavorsFlavorIoInput

func (GetFlavorsFlavorIoArray) ElementType 

func (GetFlavorsFlavorIoArray) ElementType() reflect.Type

func (GetFlavorsFlavorIoArray) ToGetFlavorsFlavorIoArrayOutput 

func (i GetFlavorsFlavorIoArray) ToGetFlavorsFlavorIoArrayOutput() GetFlavorsFlavorIoArrayOutput

func (GetFlavorsFlavorIoArray) ToGetFlavorsFlavorIoArrayOutputWithContext 

func (i GetFlavorsFlavorIoArray) ToGetFlavorsFlavorIoArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorIoArrayOutput

type GetFlavorsFlavorIoArrayInput 

type GetFlavorsFlavorIoArrayInput interface {
	pulumi.Input

	ToGetFlavorsFlavorIoArrayOutput() GetFlavorsFlavorIoArrayOutput
	ToGetFlavorsFlavorIoArrayOutputWithContext(context.Context) GetFlavorsFlavorIoArrayOutput
}

GetFlavorsFlavorIoArrayInput is an input type that accepts GetFlavorsFlavorIoArray and GetFlavorsFlavorIoArrayOutput values. You can construct a concrete instance of `GetFlavorsFlavorIoArrayInput` via: 

GetFlavorsFlavorIoArray{ GetFlavorsFlavorIoArgs{...} }

type GetFlavorsFlavorIoArrayOutput 

type GetFlavorsFlavorIoArrayOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorIoArrayOutput) ElementType 

func (GetFlavorsFlavorIoArrayOutput) ElementType() reflect.Type

func (GetFlavorsFlavorIoArrayOutput) Index 

func (o GetFlavorsFlavorIoArrayOutput) Index(i pulumi.IntInput) GetFlavorsFlavorIoOutput

func (GetFlavorsFlavorIoArrayOutput) ToGetFlavorsFlavorIoArrayOutput 

func (o GetFlavorsFlavorIoArrayOutput) ToGetFlavorsFlavorIoArrayOutput() GetFlavorsFlavorIoArrayOutput

func (GetFlavorsFlavorIoArrayOutput) ToGetFlavorsFlavorIoArrayOutputWithContext 

func (o GetFlavorsFlavorIoArrayOutput) ToGetFlavorsFlavorIoArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorIoArrayOutput

type GetFlavorsFlavorIoInput 

type GetFlavorsFlavorIoInput interface {
	pulumi.Input

	ToGetFlavorsFlavorIoOutput() GetFlavorsFlavorIoOutput
	ToGetFlavorsFlavorIoOutputWithContext(context.Context) GetFlavorsFlavorIoOutput
}

GetFlavorsFlavorIoInput is an input type that accepts GetFlavorsFlavorIoArgs and GetFlavorsFlavorIoOutput values. You can construct a concrete instance of `GetFlavorsFlavorIoInput` via: 

GetFlavorsFlavorIoArgs{...}

type GetFlavorsFlavorIoOutput 

type GetFlavorsFlavorIoOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorIoOutput) AvailabilityZones 

func (o GetFlavorsFlavorIoOutput) AvailabilityZones() pulumi.StringArrayOutput

Specifies the list of availability zones with available resources.

func (GetFlavorsFlavorIoOutput) ElementType 

func (GetFlavorsFlavorIoOutput) ElementType() reflect.Type

func (GetFlavorsFlavorIoOutput) StorageSpecCode 

func (o GetFlavorsFlavorIoOutput) StorageSpecCode() pulumi.StringOutput

Specifies the disk IO encoding. + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O. + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.

func (GetFlavorsFlavorIoOutput) ToGetFlavorsFlavorIoOutput 

func (o GetFlavorsFlavorIoOutput) ToGetFlavorsFlavorIoOutput() GetFlavorsFlavorIoOutput

func (GetFlavorsFlavorIoOutput) ToGetFlavorsFlavorIoOutputWithContext 

func (o GetFlavorsFlavorIoOutput) ToGetFlavorsFlavorIoOutputWithContext(ctx context.Context) GetFlavorsFlavorIoOutput

func (GetFlavorsFlavorIoOutput) Type 

func (o GetFlavorsFlavorIoOutput) Type() pulumi.StringOutput

Specifies flavor type. The valid values are **single** and **cluster**.

func (GetFlavorsFlavorIoOutput) UnavailabilityZones 

func (o GetFlavorsFlavorIoOutput) UnavailabilityZones() pulumi.StringArrayOutput

The list of unavailability zones with available resources.

type GetFlavorsFlavorOutput 

type GetFlavorsFlavorOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorOutput) ArchTypes 

func (o GetFlavorsFlavorOutput) ArchTypes() pulumi.StringArrayOutput

The list of supported CPU architectures.

func (GetFlavorsFlavorOutput) ChargingModes 

func (o GetFlavorsFlavorOutput) ChargingModes() pulumi.StringArrayOutput

The list of supported billing modes.

func (GetFlavorsFlavorOutput) ElementType 

func (GetFlavorsFlavorOutput) ElementType() reflect.Type

func (GetFlavorsFlavorOutput) Id 

func (o GetFlavorsFlavorOutput) Id() pulumi.StringOutput

The flavor ID.

func (GetFlavorsFlavorOutput) Ios 

func (o GetFlavorsFlavorOutput) Ios() GetFlavorsFlavorIoArrayOutput

The list of supported disk IO types. The object structure is documented below.

func (GetFlavorsFlavorOutput) Properties 

func (o GetFlavorsFlavorOutput) Properties() GetFlavorsFlavorPropertyArrayOutput

The function property details. The object structure is documented below.

func (GetFlavorsFlavorOutput) SupportFeatures 

func (o GetFlavorsFlavorOutput) SupportFeatures() GetFlavorsFlavorSupportFeatureArrayOutput

The list of features supported by the current specification. The object structure is documented below.

func (GetFlavorsFlavorOutput) ToGetFlavorsFlavorOutput 

func (o GetFlavorsFlavorOutput) ToGetFlavorsFlavorOutput() GetFlavorsFlavorOutput

func (GetFlavorsFlavorOutput) ToGetFlavorsFlavorOutputWithContext 

func (o GetFlavorsFlavorOutput) ToGetFlavorsFlavorOutputWithContext(ctx context.Context) GetFlavorsFlavorOutput

func (GetFlavorsFlavorOutput) Type 

func (o GetFlavorsFlavorOutput) Type() pulumi.StringOutput

Specifies flavor type. The valid values are **single** and **cluster**.

func (GetFlavorsFlavorOutput) VmSpecification 

func (o GetFlavorsFlavorOutput) VmSpecification() pulumi.StringOutput

The underlying VM specification.

type GetFlavorsFlavorProperty 

type GetFlavorsFlavorProperty struct {
	// The flavor ID alias.
	FlavorAlias string `pulumi:"flavorAlias"`
	// The maximum bandwidth per broker.
	MaxBandwidthPerBroker int `pulumi:"maxBandwidthPerBroker"`
	// The maximum number of brokers.
	MaxBroker int `pulumi:"maxBroker"`
	// The maximum number of consumers per broker.
	MaxConsumerPerBroker int `pulumi:"maxConsumerPerBroker"`
	// The maximum number of partitions per broker.
	MaxPartitionPerBroker int `pulumi:"maxPartitionPerBroker"`
	// The maximum storage per node. The unit is GB.
	MaxStoragePerNode int `pulumi:"maxStoragePerNode"`
	// The maximum TPS per broker.
	MaxTpsPerBroker int `pulumi:"maxTpsPerBroker"`
	// The minimum number of brokers.
	MinBroker int `pulumi:"minBroker"`
	// The minimum storage per node. The unit is GB.
	MinStoragePerNode int `pulumi:"minStoragePerNode"`
}

type GetFlavorsFlavorPropertyArgs 

type GetFlavorsFlavorPropertyArgs struct {
	// The flavor ID alias.
	FlavorAlias pulumi.StringInput `pulumi:"flavorAlias"`
	// The maximum bandwidth per broker.
	MaxBandwidthPerBroker pulumi.IntInput `pulumi:"maxBandwidthPerBroker"`
	// The maximum number of brokers.
	MaxBroker pulumi.IntInput `pulumi:"maxBroker"`
	// The maximum number of consumers per broker.
	MaxConsumerPerBroker pulumi.IntInput `pulumi:"maxConsumerPerBroker"`
	// The maximum number of partitions per broker.
	MaxPartitionPerBroker pulumi.IntInput `pulumi:"maxPartitionPerBroker"`
	// The maximum storage per node. The unit is GB.
	MaxStoragePerNode pulumi.IntInput `pulumi:"maxStoragePerNode"`
	// The maximum TPS per broker.
	MaxTpsPerBroker pulumi.IntInput `pulumi:"maxTpsPerBroker"`
	// The minimum number of brokers.
	MinBroker pulumi.IntInput `pulumi:"minBroker"`
	// The minimum storage per node. The unit is GB.
	MinStoragePerNode pulumi.IntInput `pulumi:"minStoragePerNode"`
}

func (GetFlavorsFlavorPropertyArgs) ElementType 

func (GetFlavorsFlavorPropertyArgs) ElementType() reflect.Type

func (GetFlavorsFlavorPropertyArgs) ToGetFlavorsFlavorPropertyOutput 

func (i GetFlavorsFlavorPropertyArgs) ToGetFlavorsFlavorPropertyOutput() GetFlavorsFlavorPropertyOutput

func (GetFlavorsFlavorPropertyArgs) ToGetFlavorsFlavorPropertyOutputWithContext 

func (i GetFlavorsFlavorPropertyArgs) ToGetFlavorsFlavorPropertyOutputWithContext(ctx context.Context) GetFlavorsFlavorPropertyOutput

type GetFlavorsFlavorPropertyArray 

type GetFlavorsFlavorPropertyArray []GetFlavorsFlavorPropertyInput

func (GetFlavorsFlavorPropertyArray) ElementType 

func (GetFlavorsFlavorPropertyArray) ElementType() reflect.Type

func (GetFlavorsFlavorPropertyArray) ToGetFlavorsFlavorPropertyArrayOutput 

func (i GetFlavorsFlavorPropertyArray) ToGetFlavorsFlavorPropertyArrayOutput() GetFlavorsFlavorPropertyArrayOutput

func (GetFlavorsFlavorPropertyArray) ToGetFlavorsFlavorPropertyArrayOutputWithContext 

func (i GetFlavorsFlavorPropertyArray) ToGetFlavorsFlavorPropertyArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorPropertyArrayOutput

type GetFlavorsFlavorPropertyArrayInput 

type GetFlavorsFlavorPropertyArrayInput interface {
	pulumi.Input

	ToGetFlavorsFlavorPropertyArrayOutput() GetFlavorsFlavorPropertyArrayOutput
	ToGetFlavorsFlavorPropertyArrayOutputWithContext(context.Context) GetFlavorsFlavorPropertyArrayOutput
}

GetFlavorsFlavorPropertyArrayInput is an input type that accepts GetFlavorsFlavorPropertyArray and GetFlavorsFlavorPropertyArrayOutput values. You can construct a concrete instance of `GetFlavorsFlavorPropertyArrayInput` via: 

GetFlavorsFlavorPropertyArray{ GetFlavorsFlavorPropertyArgs{...} }

type GetFlavorsFlavorPropertyArrayOutput 

type GetFlavorsFlavorPropertyArrayOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorPropertyArrayOutput) ElementType 

func (GetFlavorsFlavorPropertyArrayOutput) ElementType() reflect.Type

func (GetFlavorsFlavorPropertyArrayOutput) Index 

func (o GetFlavorsFlavorPropertyArrayOutput) Index(i pulumi.IntInput) GetFlavorsFlavorPropertyOutput

func (GetFlavorsFlavorPropertyArrayOutput) ToGetFlavorsFlavorPropertyArrayOutput 

func (o GetFlavorsFlavorPropertyArrayOutput) ToGetFlavorsFlavorPropertyArrayOutput() GetFlavorsFlavorPropertyArrayOutput

func (GetFlavorsFlavorPropertyArrayOutput) ToGetFlavorsFlavorPropertyArrayOutputWithContext 

func (o GetFlavorsFlavorPropertyArrayOutput) ToGetFlavorsFlavorPropertyArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorPropertyArrayOutput

type GetFlavorsFlavorPropertyInput 

type GetFlavorsFlavorPropertyInput interface {
	pulumi.Input

	ToGetFlavorsFlavorPropertyOutput() GetFlavorsFlavorPropertyOutput
	ToGetFlavorsFlavorPropertyOutputWithContext(context.Context) GetFlavorsFlavorPropertyOutput
}

GetFlavorsFlavorPropertyInput is an input type that accepts GetFlavorsFlavorPropertyArgs and GetFlavorsFlavorPropertyOutput values. You can construct a concrete instance of `GetFlavorsFlavorPropertyInput` via: 

GetFlavorsFlavorPropertyArgs{...}

type GetFlavorsFlavorPropertyOutput 

type GetFlavorsFlavorPropertyOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorPropertyOutput) ElementType 

func (GetFlavorsFlavorPropertyOutput) ElementType() reflect.Type

func (GetFlavorsFlavorPropertyOutput) FlavorAlias 

func (o GetFlavorsFlavorPropertyOutput) FlavorAlias() pulumi.StringOutput

The flavor ID alias.

func (GetFlavorsFlavorPropertyOutput) MaxBandwidthPerBroker 

func (o GetFlavorsFlavorPropertyOutput) MaxBandwidthPerBroker() pulumi.IntOutput

The maximum bandwidth per broker.

func (GetFlavorsFlavorPropertyOutput) MaxBroker 

func (o GetFlavorsFlavorPropertyOutput) MaxBroker() pulumi.IntOutput

The maximum number of brokers.

func (GetFlavorsFlavorPropertyOutput) MaxConsumerPerBroker 

func (o GetFlavorsFlavorPropertyOutput) MaxConsumerPerBroker() pulumi.IntOutput

The maximum number of consumers per broker.

func (GetFlavorsFlavorPropertyOutput) MaxPartitionPerBroker 

func (o GetFlavorsFlavorPropertyOutput) MaxPartitionPerBroker() pulumi.IntOutput

The maximum number of partitions per broker.

func (GetFlavorsFlavorPropertyOutput) MaxStoragePerNode 

func (o GetFlavorsFlavorPropertyOutput) MaxStoragePerNode() pulumi.IntOutput

The maximum storage per node. The unit is GB.

func (GetFlavorsFlavorPropertyOutput) MaxTpsPerBroker 

func (o GetFlavorsFlavorPropertyOutput) MaxTpsPerBroker() pulumi.IntOutput

The maximum TPS per broker.

func (GetFlavorsFlavorPropertyOutput) MinBroker 

func (o GetFlavorsFlavorPropertyOutput) MinBroker() pulumi.IntOutput

The minimum number of brokers.

func (GetFlavorsFlavorPropertyOutput) MinStoragePerNode 

func (o GetFlavorsFlavorPropertyOutput) MinStoragePerNode() pulumi.IntOutput

The minimum storage per node. The unit is GB.

func (GetFlavorsFlavorPropertyOutput) ToGetFlavorsFlavorPropertyOutput 

func (o GetFlavorsFlavorPropertyOutput) ToGetFlavorsFlavorPropertyOutput() GetFlavorsFlavorPropertyOutput

func (GetFlavorsFlavorPropertyOutput) ToGetFlavorsFlavorPropertyOutputWithContext 

func (o GetFlavorsFlavorPropertyOutput) ToGetFlavorsFlavorPropertyOutputWithContext(ctx context.Context) GetFlavorsFlavorPropertyOutput

type GetFlavorsFlavorSupportFeature 

type GetFlavorsFlavorSupportFeature struct {
	// The function name, e.g. **connector_obs**.
	Name string `pulumi:"name"`
	// The function property details.
	// The object structure is documented below.
	Properties []GetFlavorsFlavorSupportFeatureProperty `pulumi:"properties"`
}

type GetFlavorsFlavorSupportFeatureArgs 

type GetFlavorsFlavorSupportFeatureArgs struct {
	// The function name, e.g. **connector_obs**.
	Name pulumi.StringInput `pulumi:"name"`
	// The function property details.
	// The object structure is documented below.
	Properties GetFlavorsFlavorSupportFeaturePropertyArrayInput `pulumi:"properties"`
}

func (GetFlavorsFlavorSupportFeatureArgs) ElementType 

func (GetFlavorsFlavorSupportFeatureArgs) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeatureArgs) ToGetFlavorsFlavorSupportFeatureOutput 

func (i GetFlavorsFlavorSupportFeatureArgs) ToGetFlavorsFlavorSupportFeatureOutput() GetFlavorsFlavorSupportFeatureOutput

func (GetFlavorsFlavorSupportFeatureArgs) ToGetFlavorsFlavorSupportFeatureOutputWithContext 

func (i GetFlavorsFlavorSupportFeatureArgs) ToGetFlavorsFlavorSupportFeatureOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeatureOutput

type GetFlavorsFlavorSupportFeatureArray 

type GetFlavorsFlavorSupportFeatureArray []GetFlavorsFlavorSupportFeatureInput

func (GetFlavorsFlavorSupportFeatureArray) ElementType 

func (GetFlavorsFlavorSupportFeatureArray) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeatureArray) ToGetFlavorsFlavorSupportFeatureArrayOutput 

func (i GetFlavorsFlavorSupportFeatureArray) ToGetFlavorsFlavorSupportFeatureArrayOutput() GetFlavorsFlavorSupportFeatureArrayOutput

func (GetFlavorsFlavorSupportFeatureArray) ToGetFlavorsFlavorSupportFeatureArrayOutputWithContext 

func (i GetFlavorsFlavorSupportFeatureArray) ToGetFlavorsFlavorSupportFeatureArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeatureArrayOutput

type GetFlavorsFlavorSupportFeatureArrayInput 

type GetFlavorsFlavorSupportFeatureArrayInput interface {
	pulumi.Input

	ToGetFlavorsFlavorSupportFeatureArrayOutput() GetFlavorsFlavorSupportFeatureArrayOutput
	ToGetFlavorsFlavorSupportFeatureArrayOutputWithContext(context.Context) GetFlavorsFlavorSupportFeatureArrayOutput
}

GetFlavorsFlavorSupportFeatureArrayInput is an input type that accepts GetFlavorsFlavorSupportFeatureArray and GetFlavorsFlavorSupportFeatureArrayOutput values. You can construct a concrete instance of `GetFlavorsFlavorSupportFeatureArrayInput` via: 

GetFlavorsFlavorSupportFeatureArray{ GetFlavorsFlavorSupportFeatureArgs{...} }

type GetFlavorsFlavorSupportFeatureArrayOutput 

type GetFlavorsFlavorSupportFeatureArrayOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorSupportFeatureArrayOutput) ElementType 

func (GetFlavorsFlavorSupportFeatureArrayOutput) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeatureArrayOutput) Index 

func (o GetFlavorsFlavorSupportFeatureArrayOutput) Index(i pulumi.IntInput) GetFlavorsFlavorSupportFeatureOutput

func (GetFlavorsFlavorSupportFeatureArrayOutput) ToGetFlavorsFlavorSupportFeatureArrayOutput 

func (o GetFlavorsFlavorSupportFeatureArrayOutput) ToGetFlavorsFlavorSupportFeatureArrayOutput() GetFlavorsFlavorSupportFeatureArrayOutput

func (GetFlavorsFlavorSupportFeatureArrayOutput) ToGetFlavorsFlavorSupportFeatureArrayOutputWithContext 

func (o GetFlavorsFlavorSupportFeatureArrayOutput) ToGetFlavorsFlavorSupportFeatureArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeatureArrayOutput

type GetFlavorsFlavorSupportFeatureInput 

type GetFlavorsFlavorSupportFeatureInput interface {
	pulumi.Input

	ToGetFlavorsFlavorSupportFeatureOutput() GetFlavorsFlavorSupportFeatureOutput
	ToGetFlavorsFlavorSupportFeatureOutputWithContext(context.Context) GetFlavorsFlavorSupportFeatureOutput
}

GetFlavorsFlavorSupportFeatureInput is an input type that accepts GetFlavorsFlavorSupportFeatureArgs and GetFlavorsFlavorSupportFeatureOutput values. You can construct a concrete instance of `GetFlavorsFlavorSupportFeatureInput` via: 

GetFlavorsFlavorSupportFeatureArgs{...}

type GetFlavorsFlavorSupportFeatureOutput 

type GetFlavorsFlavorSupportFeatureOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorSupportFeatureOutput) ElementType 

func (GetFlavorsFlavorSupportFeatureOutput) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeatureOutput) Name 

func (o GetFlavorsFlavorSupportFeatureOutput) Name() pulumi.StringOutput

The function name, e.g. **connector_obs**.

func (GetFlavorsFlavorSupportFeatureOutput) Properties 

func (o GetFlavorsFlavorSupportFeatureOutput) Properties() GetFlavorsFlavorSupportFeaturePropertyArrayOutput

The function property details. The object structure is documented below.

func (GetFlavorsFlavorSupportFeatureOutput) ToGetFlavorsFlavorSupportFeatureOutput 

func (o GetFlavorsFlavorSupportFeatureOutput) ToGetFlavorsFlavorSupportFeatureOutput() GetFlavorsFlavorSupportFeatureOutput

func (GetFlavorsFlavorSupportFeatureOutput) ToGetFlavorsFlavorSupportFeatureOutputWithContext 

func (o GetFlavorsFlavorSupportFeatureOutput) ToGetFlavorsFlavorSupportFeatureOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeatureOutput

type GetFlavorsFlavorSupportFeatureProperty 

type GetFlavorsFlavorSupportFeatureProperty struct {
	// The maximum number of nodes for the dump function.
	MaxNode int `pulumi:"maxNode"`
	// The maximum number of tasks for the dump function.
	MaxTask int `pulumi:"maxTask"`
	// The minimum number of nodes for the dump function.
	MinNode int `pulumi:"minNode"`
	// The minimum number of tasks for the dump function.
	MinTask int `pulumi:"minTask"`
}

type GetFlavorsFlavorSupportFeaturePropertyArgs 

type GetFlavorsFlavorSupportFeaturePropertyArgs struct {
	// The maximum number of nodes for the dump function.
	MaxNode pulumi.IntInput `pulumi:"maxNode"`
	// The maximum number of tasks for the dump function.
	MaxTask pulumi.IntInput `pulumi:"maxTask"`
	// The minimum number of nodes for the dump function.
	MinNode pulumi.IntInput `pulumi:"minNode"`
	// The minimum number of tasks for the dump function.
	MinTask pulumi.IntInput `pulumi:"minTask"`
}

func (GetFlavorsFlavorSupportFeaturePropertyArgs) ElementType 

func (GetFlavorsFlavorSupportFeaturePropertyArgs) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeaturePropertyArgs) ToGetFlavorsFlavorSupportFeaturePropertyOutput 

func (i GetFlavorsFlavorSupportFeaturePropertyArgs) ToGetFlavorsFlavorSupportFeaturePropertyOutput() GetFlavorsFlavorSupportFeaturePropertyOutput

func (GetFlavorsFlavorSupportFeaturePropertyArgs) ToGetFlavorsFlavorSupportFeaturePropertyOutputWithContext 

func (i GetFlavorsFlavorSupportFeaturePropertyArgs) ToGetFlavorsFlavorSupportFeaturePropertyOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeaturePropertyOutput

type GetFlavorsFlavorSupportFeaturePropertyArray 

type GetFlavorsFlavorSupportFeaturePropertyArray []GetFlavorsFlavorSupportFeaturePropertyInput

func (GetFlavorsFlavorSupportFeaturePropertyArray) ElementType 

func (GetFlavorsFlavorSupportFeaturePropertyArray) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeaturePropertyArray) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutput 

func (i GetFlavorsFlavorSupportFeaturePropertyArray) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutput() GetFlavorsFlavorSupportFeaturePropertyArrayOutput

func (GetFlavorsFlavorSupportFeaturePropertyArray) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutputWithContext 

func (i GetFlavorsFlavorSupportFeaturePropertyArray) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeaturePropertyArrayOutput

type GetFlavorsFlavorSupportFeaturePropertyArrayInput 

type GetFlavorsFlavorSupportFeaturePropertyArrayInput interface {
	pulumi.Input

	ToGetFlavorsFlavorSupportFeaturePropertyArrayOutput() GetFlavorsFlavorSupportFeaturePropertyArrayOutput
	ToGetFlavorsFlavorSupportFeaturePropertyArrayOutputWithContext(context.Context) GetFlavorsFlavorSupportFeaturePropertyArrayOutput
}

GetFlavorsFlavorSupportFeaturePropertyArrayInput is an input type that accepts GetFlavorsFlavorSupportFeaturePropertyArray and GetFlavorsFlavorSupportFeaturePropertyArrayOutput values. You can construct a concrete instance of `GetFlavorsFlavorSupportFeaturePropertyArrayInput` via: 

GetFlavorsFlavorSupportFeaturePropertyArray{ GetFlavorsFlavorSupportFeaturePropertyArgs{...} }

type GetFlavorsFlavorSupportFeaturePropertyArrayOutput 

type GetFlavorsFlavorSupportFeaturePropertyArrayOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorSupportFeaturePropertyArrayOutput) ElementType 

func (GetFlavorsFlavorSupportFeaturePropertyArrayOutput) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeaturePropertyArrayOutput) Index 

func (o GetFlavorsFlavorSupportFeaturePropertyArrayOutput) Index(i pulumi.IntInput) GetFlavorsFlavorSupportFeaturePropertyOutput

func (GetFlavorsFlavorSupportFeaturePropertyArrayOutput) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutput 

func (o GetFlavorsFlavorSupportFeaturePropertyArrayOutput) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutput() GetFlavorsFlavorSupportFeaturePropertyArrayOutput

func (GetFlavorsFlavorSupportFeaturePropertyArrayOutput) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutputWithContext 

func (o GetFlavorsFlavorSupportFeaturePropertyArrayOutput) ToGetFlavorsFlavorSupportFeaturePropertyArrayOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeaturePropertyArrayOutput

type GetFlavorsFlavorSupportFeaturePropertyInput 

type GetFlavorsFlavorSupportFeaturePropertyInput interface {
	pulumi.Input

	ToGetFlavorsFlavorSupportFeaturePropertyOutput() GetFlavorsFlavorSupportFeaturePropertyOutput
	ToGetFlavorsFlavorSupportFeaturePropertyOutputWithContext(context.Context) GetFlavorsFlavorSupportFeaturePropertyOutput
}

GetFlavorsFlavorSupportFeaturePropertyInput is an input type that accepts GetFlavorsFlavorSupportFeaturePropertyArgs and GetFlavorsFlavorSupportFeaturePropertyOutput values. You can construct a concrete instance of `GetFlavorsFlavorSupportFeaturePropertyInput` via: 

GetFlavorsFlavorSupportFeaturePropertyArgs{...}

type GetFlavorsFlavorSupportFeaturePropertyOutput 

type GetFlavorsFlavorSupportFeaturePropertyOutput struct{ *pulumi.OutputState }

func (GetFlavorsFlavorSupportFeaturePropertyOutput) ElementType 

func (GetFlavorsFlavorSupportFeaturePropertyOutput) ElementType() reflect.Type

func (GetFlavorsFlavorSupportFeaturePropertyOutput) MaxNode 

func (o GetFlavorsFlavorSupportFeaturePropertyOutput) MaxNode() pulumi.IntOutput

The maximum number of nodes for the dump function.

func (GetFlavorsFlavorSupportFeaturePropertyOutput) MaxTask 

func (o GetFlavorsFlavorSupportFeaturePropertyOutput) MaxTask() pulumi.IntOutput

The maximum number of tasks for the dump function.

func (GetFlavorsFlavorSupportFeaturePropertyOutput) MinNode 

func (o GetFlavorsFlavorSupportFeaturePropertyOutput) MinNode() pulumi.IntOutput

The minimum number of nodes for the dump function.

func (GetFlavorsFlavorSupportFeaturePropertyOutput) MinTask 

func (o GetFlavorsFlavorSupportFeaturePropertyOutput) MinTask() pulumi.IntOutput

The minimum number of tasks for the dump function.

func (GetFlavorsFlavorSupportFeaturePropertyOutput) ToGetFlavorsFlavorSupportFeaturePropertyOutput 

func (o GetFlavorsFlavorSupportFeaturePropertyOutput) ToGetFlavorsFlavorSupportFeaturePropertyOutput() GetFlavorsFlavorSupportFeaturePropertyOutput

func (GetFlavorsFlavorSupportFeaturePropertyOutput) ToGetFlavorsFlavorSupportFeaturePropertyOutputWithContext 

func (o GetFlavorsFlavorSupportFeaturePropertyOutput) ToGetFlavorsFlavorSupportFeaturePropertyOutputWithContext(ctx context.Context) GetFlavorsFlavorSupportFeaturePropertyOutput

type GetFlavorsOutputArgs 

type GetFlavorsOutputArgs struct {
	// Specifies the type of CPU architecture, e.g. **X86**.
	ArchType pulumi.StringPtrInput `pulumi:"archType"`
	// Specifies the list of availability zones with available resources.
	AvailabilityZones pulumi.StringArrayInput `pulumi:"availabilityZones"`
	// Specifies the flavor billing mode.
	// The valid valus are **prePaid** and **postPaid**.
	ChargingMode pulumi.StringPtrInput `pulumi:"chargingMode"`
	// Specifies the DMS flvaor ID, e.g. **c6.2u4g.cluster**.
	FlavorId pulumi.StringPtrInput `pulumi:"flavorId"`
	// Specifies the region in which to obtain the dms kafka flavors.
	// If omitted, the provider-level region will be used.
	Region pulumi.StringPtrInput `pulumi:"region"`
	// Specifies the disk IO encoding.
	// + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O.
	// + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.
	StorageSpecCode pulumi.StringPtrInput `pulumi:"storageSpecCode"`
	// Specifies flavor type. The valid values are **single** and **cluster**.
	Type pulumi.StringPtrInput `pulumi:"type"`
}

A collection of arguments for invoking getFlavors.

func (GetFlavorsOutputArgs) ElementType 

func (GetFlavorsOutputArgs) ElementType() reflect.Type

type GetFlavorsResult 

type GetFlavorsResult struct {
	ArchType *string `pulumi:"archType"`
	// The list of availability zones with available resources.
	AvailabilityZones []string `pulumi:"availabilityZones"`
	ChargingMode      *string  `pulumi:"chargingMode"`
	FlavorId          *string  `pulumi:"flavorId"`
	// The list of flavor details.
	// The object structure is documented below.
	Flavors []GetFlavorsFlavor `pulumi:"flavors"`
	// The provider-assigned unique ID for this managed resource.
	Id     string  `pulumi:"id"`
	Region *string `pulumi:"region"`
	// The disk IO encoding.
	StorageSpecCode *string `pulumi:"storageSpecCode"`
	// The disk type.
	Type *string `pulumi:"type"`
	// The supported flavor versions.
	Versions []string `pulumi:"versions"`
}

A collection of values returned by getFlavors.

func GetFlavors 

func GetFlavors(ctx *pulumi.Context, args *GetFlavorsArgs, opts ...pulumi.InvokeOption) (*GetFlavorsResult, error)

Use this data source to get the list of available flavor details within HuaweiCloud.

## Example Usage ### Query the list of kafka flavors for cluster type

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Dms.GetFlavors(ctx, &dms.GetFlavorsArgs{
			Type: pulumi.StringRef("cluster"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Query the kafka flavor details of the specified ID

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Dms.GetFlavors(ctx, &dms.GetFlavorsArgs{
			FlavorId: pulumi.StringRef("c6.2u4g.cluster"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetFlavorsResultOutput 

type GetFlavorsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getFlavors.

func GetFlavorsOutput 

func GetFlavorsOutput(ctx *pulumi.Context, args GetFlavorsOutputArgs, opts ...pulumi.InvokeOption) GetFlavorsResultOutput

func (GetFlavorsResultOutput) ArchType 

func (o GetFlavorsResultOutput) ArchType() pulumi.StringPtrOutput

func (GetFlavorsResultOutput) AvailabilityZones 

func (o GetFlavorsResultOutput) AvailabilityZones() pulumi.StringArrayOutput

The list of availability zones with available resources.

func (GetFlavorsResultOutput) ChargingMode 

func (o GetFlavorsResultOutput) ChargingMode() pulumi.StringPtrOutput

func (GetFlavorsResultOutput) ElementType 

func (GetFlavorsResultOutput) ElementType() reflect.Type

func (GetFlavorsResultOutput) FlavorId 

func (o GetFlavorsResultOutput) FlavorId() pulumi.StringPtrOutput

func (GetFlavorsResultOutput) Flavors 

func (o GetFlavorsResultOutput) Flavors() GetFlavorsFlavorArrayOutput

The list of flavor details. The object structure is documented below.

func (GetFlavorsResultOutput) Id 

func (o GetFlavorsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetFlavorsResultOutput) Region 

func (o GetFlavorsResultOutput) Region() pulumi.StringPtrOutput

func (GetFlavorsResultOutput) StorageSpecCode 

func (o GetFlavorsResultOutput) StorageSpecCode() pulumi.StringPtrOutput

The disk IO encoding.

func (GetFlavorsResultOutput) ToGetFlavorsResultOutput 

func (o GetFlavorsResultOutput) ToGetFlavorsResultOutput() GetFlavorsResultOutput

func (GetFlavorsResultOutput) ToGetFlavorsResultOutputWithContext 

func (o GetFlavorsResultOutput) ToGetFlavorsResultOutputWithContext(ctx context.Context) GetFlavorsResultOutput

func (GetFlavorsResultOutput) Type 

func (o GetFlavorsResultOutput) Type() pulumi.StringPtrOutput

The disk type.

func (GetFlavorsResultOutput) Versions 

func (o GetFlavorsResultOutput) Versions() pulumi.StringArrayOutput

The supported flavor versions.

type GetInstancesArgs 

type GetInstancesArgs struct {
	// Specifies the enterprise project ID to which all instances of the list
	// belong.
	EnterpriseProjectId *string `pulumi:"enterpriseProjectId"`
	// Specifies whether to match the instance name fuzzily, the default is a exact
	// match (`flase`).
	FuzzyMatch *bool `pulumi:"fuzzyMatch"`
	// Specifies whether the query results contain instances that failed to create.
	IncludeFailure *bool `pulumi:"includeFailure"`
	// Specifies the kafka instance ID to match exactly.
	InstanceId *string `pulumi:"instanceId"`
	// Specifies the kafka instance name for data-source queries.
	Name *string `pulumi:"name"`
	// The region in which to query the kafka instance list.
	// If omitted, the provider-level region will be used.
	Region *string `pulumi:"region"`
	// Specifies the kafka instance status for data-source queries.
	Status *string `pulumi:"status"`
}

A collection of arguments for invoking getInstances.

type GetInstancesInstance 

type GetInstancesInstance struct {
	// The access username.
	AccessUser string `pulumi:"accessUser"`
	// The list of AZ names.
	AvailabilityZones []string `pulumi:"availabilityZones"`
	// The IP address for instance connection.
	ConnectAddress string `pulumi:"connectAddress"`
	// Indicates the Access information of cross-VPC. The structure is documented below.
	CrossVpcAccesses []GetInstancesInstanceCrossVpcAccess `pulumi:"crossVpcAccesses"`
	// The instance description.
	Description string `pulumi:"description"`
	// Whether to dumping is enabled.
	Dumping bool `pulumi:"dumping"`
	// Whether to enable automatic topic creation.
	EnableAutoTopic bool `pulumi:"enableAutoTopic"`
	// Whether public access to the instance is enabled.
	EnablePublicIp bool `pulumi:"enablePublicIp"`
	// The kafka engine version.
	EngineVersion string `pulumi:"engineVersion"`
	// Specifies the enterprise project ID to which all instances of the list
	// belong.
	EnterpriseProjectId string `pulumi:"enterpriseProjectId"`
	// The instance ID.
	Id string `pulumi:"id"`
	// The time at which a maintenance time window starts, the format is `HH:mm`.
	MaintainBegin string `pulumi:"maintainBegin"`
	// The time at which a maintenance time window ends, the format is `HH:mm`.
	MaintainEnd string `pulumi:"maintainEnd"`
	// The connection address of the Kafka manager of an instance.
	ManagementConnectAddress string `pulumi:"managementConnectAddress"`
	// The username for logging in to the Kafka Manager.
	ManagerUser string `pulumi:"managerUser"`
	// Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.
	ManegementConnectAddress string `pulumi:"manegementConnectAddress"`
	// Specifies the kafka instance name for data-source queries.
	Name string `pulumi:"name"`
	// The subnet ID to which the instance belongs.
	NetworkId string `pulumi:"networkId"`
	// The maximum number of topics in the DMS kafka instance.
	PartitionNum int `pulumi:"partitionNum"`
	// The port number.
	Port int `pulumi:"port"`
	// The product ID used by the instance.
	ProductId string `pulumi:"productId"`
	// The instance public access address.
	// The format of each connection address is `{IP address}:{port}`.
	PublicConnAddresses string `pulumi:"publicConnAddresses"`
	// The IDs of the elastic IP address (EIP).
	PublicIpIds []string `pulumi:"publicIpIds"`
	// The resource specifications identifier.
	ResourceSpecCode string `pulumi:"resourceSpecCode"`
	// The action to be taken when the memory usage reaches the disk capacity threshold.
	RetentionPolicy string `pulumi:"retentionPolicy"`
	// The security group ID associated with the instance.
	SecurityGroupId string `pulumi:"securityGroupId"`
	// Whether the Kafka SASL_SSL is enabled.
	SslEnable bool `pulumi:"sslEnable"`
	// Specifies the kafka instance status for data-source queries.
	Status string `pulumi:"status"`
	// The message storage capacity, in GB unit.
	StorageSpace int `pulumi:"storageSpace"`
	// The storage I/O specification.
	StorageSpecCode string `pulumi:"storageSpecCode"`
	// The key/value pairs to associate with the instance.
	Tags map[string]string `pulumi:"tags"`
	// The instance type.
	Type string `pulumi:"type"`
	// The used message storage space, in GB unit.
	UsedStorageSpace int `pulumi:"usedStorageSpace"`
	// The user ID who created the instance.
	UserId string `pulumi:"userId"`
	// The username who created the instance.
	UserName string `pulumi:"userName"`
	// The VPC ID to which the instance belongs.
	VpcId string `pulumi:"vpcId"`
}

type GetInstancesInstanceArgs 

type GetInstancesInstanceArgs struct {
	// The access username.
	AccessUser pulumi.StringInput `pulumi:"accessUser"`
	// The list of AZ names.
	AvailabilityZones pulumi.StringArrayInput `pulumi:"availabilityZones"`
	// The IP address for instance connection.
	ConnectAddress pulumi.StringInput `pulumi:"connectAddress"`
	// Indicates the Access information of cross-VPC. The structure is documented below.
	CrossVpcAccesses GetInstancesInstanceCrossVpcAccessArrayInput `pulumi:"crossVpcAccesses"`
	// The instance description.
	Description pulumi.StringInput `pulumi:"description"`
	// Whether to dumping is enabled.
	Dumping pulumi.BoolInput `pulumi:"dumping"`
	// Whether to enable automatic topic creation.
	EnableAutoTopic pulumi.BoolInput `pulumi:"enableAutoTopic"`
	// Whether public access to the instance is enabled.
	EnablePublicIp pulumi.BoolInput `pulumi:"enablePublicIp"`
	// The kafka engine version.
	EngineVersion pulumi.StringInput `pulumi:"engineVersion"`
	// Specifies the enterprise project ID to which all instances of the list
	// belong.
	EnterpriseProjectId pulumi.StringInput `pulumi:"enterpriseProjectId"`
	// The instance ID.
	Id pulumi.StringInput `pulumi:"id"`
	// The time at which a maintenance time window starts, the format is `HH:mm`.
	MaintainBegin pulumi.StringInput `pulumi:"maintainBegin"`
	// The time at which a maintenance time window ends, the format is `HH:mm`.
	MaintainEnd pulumi.StringInput `pulumi:"maintainEnd"`
	// The connection address of the Kafka manager of an instance.
	ManagementConnectAddress pulumi.StringInput `pulumi:"managementConnectAddress"`
	// The username for logging in to the Kafka Manager.
	ManagerUser pulumi.StringInput `pulumi:"managerUser"`
	// Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.
	ManegementConnectAddress pulumi.StringInput `pulumi:"manegementConnectAddress"`
	// Specifies the kafka instance name for data-source queries.
	Name pulumi.StringInput `pulumi:"name"`
	// The subnet ID to which the instance belongs.
	NetworkId pulumi.StringInput `pulumi:"networkId"`
	// The maximum number of topics in the DMS kafka instance.
	PartitionNum pulumi.IntInput `pulumi:"partitionNum"`
	// The port number.
	Port pulumi.IntInput `pulumi:"port"`
	// The product ID used by the instance.
	ProductId pulumi.StringInput `pulumi:"productId"`
	// The instance public access address.
	// The format of each connection address is `{IP address}:{port}`.
	PublicConnAddresses pulumi.StringInput `pulumi:"publicConnAddresses"`
	// The IDs of the elastic IP address (EIP).
	PublicIpIds pulumi.StringArrayInput `pulumi:"publicIpIds"`
	// The resource specifications identifier.
	ResourceSpecCode pulumi.StringInput `pulumi:"resourceSpecCode"`
	// The action to be taken when the memory usage reaches the disk capacity threshold.
	RetentionPolicy pulumi.StringInput `pulumi:"retentionPolicy"`
	// The security group ID associated with the instance.
	SecurityGroupId pulumi.StringInput `pulumi:"securityGroupId"`
	// Whether the Kafka SASL_SSL is enabled.
	SslEnable pulumi.BoolInput `pulumi:"sslEnable"`
	// Specifies the kafka instance status for data-source queries.
	Status pulumi.StringInput `pulumi:"status"`
	// The message storage capacity, in GB unit.
	StorageSpace pulumi.IntInput `pulumi:"storageSpace"`
	// The storage I/O specification.
	StorageSpecCode pulumi.StringInput `pulumi:"storageSpecCode"`
	// The key/value pairs to associate with the instance.
	Tags pulumi.StringMapInput `pulumi:"tags"`
	// The instance type.
	Type pulumi.StringInput `pulumi:"type"`
	// The used message storage space, in GB unit.
	UsedStorageSpace pulumi.IntInput `pulumi:"usedStorageSpace"`
	// The user ID who created the instance.
	UserId pulumi.StringInput `pulumi:"userId"`
	// The username who created the instance.
	UserName pulumi.StringInput `pulumi:"userName"`
	// The VPC ID to which the instance belongs.
	VpcId pulumi.StringInput `pulumi:"vpcId"`
}

func (GetInstancesInstanceArgs) ElementType 

func (GetInstancesInstanceArgs) ElementType() reflect.Type

func (GetInstancesInstanceArgs) ToGetInstancesInstanceOutput 

func (i GetInstancesInstanceArgs) ToGetInstancesInstanceOutput() GetInstancesInstanceOutput

func (GetInstancesInstanceArgs) ToGetInstancesInstanceOutputWithContext 

func (i GetInstancesInstanceArgs) ToGetInstancesInstanceOutputWithContext(ctx context.Context) GetInstancesInstanceOutput

type GetInstancesInstanceArray 

type GetInstancesInstanceArray []GetInstancesInstanceInput

func (GetInstancesInstanceArray) ElementType 

func (GetInstancesInstanceArray) ElementType() reflect.Type

func (GetInstancesInstanceArray) ToGetInstancesInstanceArrayOutput 

func (i GetInstancesInstanceArray) ToGetInstancesInstanceArrayOutput() GetInstancesInstanceArrayOutput

func (GetInstancesInstanceArray) ToGetInstancesInstanceArrayOutputWithContext 

func (i GetInstancesInstanceArray) ToGetInstancesInstanceArrayOutputWithContext(ctx context.Context) GetInstancesInstanceArrayOutput

type GetInstancesInstanceArrayInput 

type GetInstancesInstanceArrayInput interface {
	pulumi.Input

	ToGetInstancesInstanceArrayOutput() GetInstancesInstanceArrayOutput
	ToGetInstancesInstanceArrayOutputWithContext(context.Context) GetInstancesInstanceArrayOutput
}

GetInstancesInstanceArrayInput is an input type that accepts GetInstancesInstanceArray and GetInstancesInstanceArrayOutput values. You can construct a concrete instance of `GetInstancesInstanceArrayInput` via: 

GetInstancesInstanceArray{ GetInstancesInstanceArgs{...} }

type GetInstancesInstanceArrayOutput 

type GetInstancesInstanceArrayOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceArrayOutput) ElementType 

func (GetInstancesInstanceArrayOutput) ElementType() reflect.Type

func (GetInstancesInstanceArrayOutput) Index 

func (o GetInstancesInstanceArrayOutput) Index(i pulumi.IntInput) GetInstancesInstanceOutput

func (GetInstancesInstanceArrayOutput) ToGetInstancesInstanceArrayOutput 

func (o GetInstancesInstanceArrayOutput) ToGetInstancesInstanceArrayOutput() GetInstancesInstanceArrayOutput

func (GetInstancesInstanceArrayOutput) ToGetInstancesInstanceArrayOutputWithContext 

func (o GetInstancesInstanceArrayOutput) ToGetInstancesInstanceArrayOutputWithContext(ctx context.Context) GetInstancesInstanceArrayOutput

type GetInstancesInstanceCrossVpcAccess 

type GetInstancesInstanceCrossVpcAccess struct {
	// The advertised IP Address.
	AdvertisedIp string `pulumi:"advertisedIp"`
	// Deprecated: typo in lisenter_ip, please use "listener_ip" instead.
	LisenterIp string `pulumi:"lisenterIp"`
	// The listener IP address.
	ListenerIp string `pulumi:"listenerIp"`
	// The port number.
	Port int `pulumi:"port"`
	// The port ID associated with the address.
	PortId string `pulumi:"portId"`
}

type GetInstancesInstanceCrossVpcAccessArgs 

type GetInstancesInstanceCrossVpcAccessArgs struct {
	// The advertised IP Address.
	AdvertisedIp pulumi.StringInput `pulumi:"advertisedIp"`
	// Deprecated: typo in lisenter_ip, please use "listener_ip" instead.
	LisenterIp pulumi.StringInput `pulumi:"lisenterIp"`
	// The listener IP address.
	ListenerIp pulumi.StringInput `pulumi:"listenerIp"`
	// The port number.
	Port pulumi.IntInput `pulumi:"port"`
	// The port ID associated with the address.
	PortId pulumi.StringInput `pulumi:"portId"`
}

func (GetInstancesInstanceCrossVpcAccessArgs) ElementType 

func (GetInstancesInstanceCrossVpcAccessArgs) ElementType() reflect.Type

func (GetInstancesInstanceCrossVpcAccessArgs) ToGetInstancesInstanceCrossVpcAccessOutput 

func (i GetInstancesInstanceCrossVpcAccessArgs) ToGetInstancesInstanceCrossVpcAccessOutput() GetInstancesInstanceCrossVpcAccessOutput

func (GetInstancesInstanceCrossVpcAccessArgs) ToGetInstancesInstanceCrossVpcAccessOutputWithContext 

func (i GetInstancesInstanceCrossVpcAccessArgs) ToGetInstancesInstanceCrossVpcAccessOutputWithContext(ctx context.Context) GetInstancesInstanceCrossVpcAccessOutput

type GetInstancesInstanceCrossVpcAccessArray 

type GetInstancesInstanceCrossVpcAccessArray []GetInstancesInstanceCrossVpcAccessInput

func (GetInstancesInstanceCrossVpcAccessArray) ElementType 

func (GetInstancesInstanceCrossVpcAccessArray) ElementType() reflect.Type

func (GetInstancesInstanceCrossVpcAccessArray) ToGetInstancesInstanceCrossVpcAccessArrayOutput 

func (i GetInstancesInstanceCrossVpcAccessArray) ToGetInstancesInstanceCrossVpcAccessArrayOutput() GetInstancesInstanceCrossVpcAccessArrayOutput

func (GetInstancesInstanceCrossVpcAccessArray) ToGetInstancesInstanceCrossVpcAccessArrayOutputWithContext 

func (i GetInstancesInstanceCrossVpcAccessArray) ToGetInstancesInstanceCrossVpcAccessArrayOutputWithContext(ctx context.Context) GetInstancesInstanceCrossVpcAccessArrayOutput

type GetInstancesInstanceCrossVpcAccessArrayInput 

type GetInstancesInstanceCrossVpcAccessArrayInput interface {
	pulumi.Input

	ToGetInstancesInstanceCrossVpcAccessArrayOutput() GetInstancesInstanceCrossVpcAccessArrayOutput
	ToGetInstancesInstanceCrossVpcAccessArrayOutputWithContext(context.Context) GetInstancesInstanceCrossVpcAccessArrayOutput
}

GetInstancesInstanceCrossVpcAccessArrayInput is an input type that accepts GetInstancesInstanceCrossVpcAccessArray and GetInstancesInstanceCrossVpcAccessArrayOutput values. You can construct a concrete instance of `GetInstancesInstanceCrossVpcAccessArrayInput` via: 

GetInstancesInstanceCrossVpcAccessArray{ GetInstancesInstanceCrossVpcAccessArgs{...} }

type GetInstancesInstanceCrossVpcAccessArrayOutput 

type GetInstancesInstanceCrossVpcAccessArrayOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceCrossVpcAccessArrayOutput) ElementType 

func (GetInstancesInstanceCrossVpcAccessArrayOutput) ElementType() reflect.Type

func (GetInstancesInstanceCrossVpcAccessArrayOutput) Index 

func (o GetInstancesInstanceCrossVpcAccessArrayOutput) Index(i pulumi.IntInput) GetInstancesInstanceCrossVpcAccessOutput

func (GetInstancesInstanceCrossVpcAccessArrayOutput) ToGetInstancesInstanceCrossVpcAccessArrayOutput 

func (o GetInstancesInstanceCrossVpcAccessArrayOutput) ToGetInstancesInstanceCrossVpcAccessArrayOutput() GetInstancesInstanceCrossVpcAccessArrayOutput

func (GetInstancesInstanceCrossVpcAccessArrayOutput) ToGetInstancesInstanceCrossVpcAccessArrayOutputWithContext 

func (o GetInstancesInstanceCrossVpcAccessArrayOutput) ToGetInstancesInstanceCrossVpcAccessArrayOutputWithContext(ctx context.Context) GetInstancesInstanceCrossVpcAccessArrayOutput

type GetInstancesInstanceCrossVpcAccessInput 

type GetInstancesInstanceCrossVpcAccessInput interface {
	pulumi.Input

	ToGetInstancesInstanceCrossVpcAccessOutput() GetInstancesInstanceCrossVpcAccessOutput
	ToGetInstancesInstanceCrossVpcAccessOutputWithContext(context.Context) GetInstancesInstanceCrossVpcAccessOutput
}

GetInstancesInstanceCrossVpcAccessInput is an input type that accepts GetInstancesInstanceCrossVpcAccessArgs and GetInstancesInstanceCrossVpcAccessOutput values. You can construct a concrete instance of `GetInstancesInstanceCrossVpcAccessInput` via: 

GetInstancesInstanceCrossVpcAccessArgs{...}

type GetInstancesInstanceCrossVpcAccessOutput 

type GetInstancesInstanceCrossVpcAccessOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceCrossVpcAccessOutput) AdvertisedIp 

func (o GetInstancesInstanceCrossVpcAccessOutput) AdvertisedIp() pulumi.StringOutput

The advertised IP Address.

func (GetInstancesInstanceCrossVpcAccessOutput) ElementType 

func (GetInstancesInstanceCrossVpcAccessOutput) ElementType() reflect.Type

func (GetInstancesInstanceCrossVpcAccessOutput) LisenterIp deprecated 

func (o GetInstancesInstanceCrossVpcAccessOutput) LisenterIp() pulumi.StringOutput

Deprecated: typo in lisenter_ip, please use "listener_ip" instead.

func (GetInstancesInstanceCrossVpcAccessOutput) ListenerIp added in v0.0.8 

func (o GetInstancesInstanceCrossVpcAccessOutput) ListenerIp() pulumi.StringOutput

The listener IP address.

func (GetInstancesInstanceCrossVpcAccessOutput) Port 

func (o GetInstancesInstanceCrossVpcAccessOutput) Port() pulumi.IntOutput

The port number.

func (GetInstancesInstanceCrossVpcAccessOutput) PortId 

func (o GetInstancesInstanceCrossVpcAccessOutput) PortId() pulumi.StringOutput

The port ID associated with the address.

func (GetInstancesInstanceCrossVpcAccessOutput) ToGetInstancesInstanceCrossVpcAccessOutput 

func (o GetInstancesInstanceCrossVpcAccessOutput) ToGetInstancesInstanceCrossVpcAccessOutput() GetInstancesInstanceCrossVpcAccessOutput

func (GetInstancesInstanceCrossVpcAccessOutput) ToGetInstancesInstanceCrossVpcAccessOutputWithContext 

func (o GetInstancesInstanceCrossVpcAccessOutput) ToGetInstancesInstanceCrossVpcAccessOutputWithContext(ctx context.Context) GetInstancesInstanceCrossVpcAccessOutput

type GetInstancesInstanceInput 

type GetInstancesInstanceInput interface {
	pulumi.Input

	ToGetInstancesInstanceOutput() GetInstancesInstanceOutput
	ToGetInstancesInstanceOutputWithContext(context.Context) GetInstancesInstanceOutput
}

GetInstancesInstanceInput is an input type that accepts GetInstancesInstanceArgs and GetInstancesInstanceOutput values. You can construct a concrete instance of `GetInstancesInstanceInput` via: 

GetInstancesInstanceArgs{...}

type GetInstancesInstanceOutput 

type GetInstancesInstanceOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceOutput) AccessUser 

func (o GetInstancesInstanceOutput) AccessUser() pulumi.StringOutput

The access username.

func (GetInstancesInstanceOutput) AvailabilityZones 

func (o GetInstancesInstanceOutput) AvailabilityZones() pulumi.StringArrayOutput

The list of AZ names.

func (GetInstancesInstanceOutput) ConnectAddress 

func (o GetInstancesInstanceOutput) ConnectAddress() pulumi.StringOutput

The IP address for instance connection.

func (GetInstancesInstanceOutput) CrossVpcAccesses 

func (o GetInstancesInstanceOutput) CrossVpcAccesses() GetInstancesInstanceCrossVpcAccessArrayOutput

Indicates the Access information of cross-VPC. The structure is documented below.

func (GetInstancesInstanceOutput) Description 

func (o GetInstancesInstanceOutput) Description() pulumi.StringOutput

The instance description.

func (GetInstancesInstanceOutput) Dumping 

func (o GetInstancesInstanceOutput) Dumping() pulumi.BoolOutput

Whether to dumping is enabled.

func (GetInstancesInstanceOutput) ElementType 

func (GetInstancesInstanceOutput) ElementType() reflect.Type

func (GetInstancesInstanceOutput) EnableAutoTopic 

func (o GetInstancesInstanceOutput) EnableAutoTopic() pulumi.BoolOutput

Whether to enable automatic topic creation.

func (GetInstancesInstanceOutput) EnablePublicIp 

func (o GetInstancesInstanceOutput) EnablePublicIp() pulumi.BoolOutput

Whether public access to the instance is enabled.

func (GetInstancesInstanceOutput) EngineVersion 

func (o GetInstancesInstanceOutput) EngineVersion() pulumi.StringOutput

The kafka engine version.

func (GetInstancesInstanceOutput) EnterpriseProjectId 

func (o GetInstancesInstanceOutput) EnterpriseProjectId() pulumi.StringOutput

Specifies the enterprise project ID to which all instances of the list belong.

func (GetInstancesInstanceOutput) Id 

func (o GetInstancesInstanceOutput) Id() pulumi.StringOutput

The instance ID.

func (GetInstancesInstanceOutput) MaintainBegin 

func (o GetInstancesInstanceOutput) MaintainBegin() pulumi.StringOutput

The time at which a maintenance time window starts, the format is `HH:mm`.

func (GetInstancesInstanceOutput) MaintainEnd 

func (o GetInstancesInstanceOutput) MaintainEnd() pulumi.StringOutput

The time at which a maintenance time window ends, the format is `HH:mm`.

func (GetInstancesInstanceOutput) ManagementConnectAddress added in v0.0.8 

func (o GetInstancesInstanceOutput) ManagementConnectAddress() pulumi.StringOutput

The connection address of the Kafka manager of an instance.

func (GetInstancesInstanceOutput) ManagerUser 

func (o GetInstancesInstanceOutput) ManagerUser() pulumi.StringOutput

The username for logging in to the Kafka Manager.

func (GetInstancesInstanceOutput) ManegementConnectAddress deprecated 

func (o GetInstancesInstanceOutput) ManegementConnectAddress() pulumi.StringOutput

Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.

func (GetInstancesInstanceOutput) Name 

func (o GetInstancesInstanceOutput) Name() pulumi.StringOutput

Specifies the kafka instance name for data-source queries.

func (GetInstancesInstanceOutput) NetworkId 

func (o GetInstancesInstanceOutput) NetworkId() pulumi.StringOutput

The subnet ID to which the instance belongs.

func (GetInstancesInstanceOutput) PartitionNum 

func (o GetInstancesInstanceOutput) PartitionNum() pulumi.IntOutput

The maximum number of topics in the DMS kafka instance.

func (GetInstancesInstanceOutput) Port 

func (o GetInstancesInstanceOutput) Port() pulumi.IntOutput

The port number.

func (GetInstancesInstanceOutput) ProductId 

func (o GetInstancesInstanceOutput) ProductId() pulumi.StringOutput

The product ID used by the instance.

func (GetInstancesInstanceOutput) PublicConnAddresses 

func (o GetInstancesInstanceOutput) PublicConnAddresses() pulumi.StringOutput

The instance public access address. The format of each connection address is `{IP address}:{port}`.

func (GetInstancesInstanceOutput) PublicIpIds 

func (o GetInstancesInstanceOutput) PublicIpIds() pulumi.StringArrayOutput

The IDs of the elastic IP address (EIP).

func (GetInstancesInstanceOutput) ResourceSpecCode 

func (o GetInstancesInstanceOutput) ResourceSpecCode() pulumi.StringOutput

The resource specifications identifier.

func (GetInstancesInstanceOutput) RetentionPolicy 

func (o GetInstancesInstanceOutput) RetentionPolicy() pulumi.StringOutput

The action to be taken when the memory usage reaches the disk capacity threshold.

func (GetInstancesInstanceOutput) SecurityGroupId 

func (o GetInstancesInstanceOutput) SecurityGroupId() pulumi.StringOutput

The security group ID associated with the instance.

func (GetInstancesInstanceOutput) SslEnable 

func (o GetInstancesInstanceOutput) SslEnable() pulumi.BoolOutput

Whether the Kafka SASL_SSL is enabled.

func (GetInstancesInstanceOutput) Status 

func (o GetInstancesInstanceOutput) Status() pulumi.StringOutput

Specifies the kafka instance status for data-source queries.

func (GetInstancesInstanceOutput) StorageSpace 

func (o GetInstancesInstanceOutput) StorageSpace() pulumi.IntOutput

The message storage capacity, in GB unit.

func (GetInstancesInstanceOutput) StorageSpecCode 

func (o GetInstancesInstanceOutput) StorageSpecCode() pulumi.StringOutput

The storage I/O specification.

func (GetInstancesInstanceOutput) Tags 

func (o GetInstancesInstanceOutput) Tags() pulumi.StringMapOutput

The key/value pairs to associate with the instance.

func (GetInstancesInstanceOutput) ToGetInstancesInstanceOutput 

func (o GetInstancesInstanceOutput) ToGetInstancesInstanceOutput() GetInstancesInstanceOutput

func (GetInstancesInstanceOutput) ToGetInstancesInstanceOutputWithContext 

func (o GetInstancesInstanceOutput) ToGetInstancesInstanceOutputWithContext(ctx context.Context) GetInstancesInstanceOutput

func (GetInstancesInstanceOutput) Type 

func (o GetInstancesInstanceOutput) Type() pulumi.StringOutput

The instance type.

func (GetInstancesInstanceOutput) UsedStorageSpace 

func (o GetInstancesInstanceOutput) UsedStorageSpace() pulumi.IntOutput

The used message storage space, in GB unit.

func (GetInstancesInstanceOutput) UserId 

func (o GetInstancesInstanceOutput) UserId() pulumi.StringOutput

The user ID who created the instance.

func (GetInstancesInstanceOutput) UserName 

func (o GetInstancesInstanceOutput) UserName() pulumi.StringOutput

The username who created the instance.

func (GetInstancesInstanceOutput) VpcId 

func (o GetInstancesInstanceOutput) VpcId() pulumi.StringOutput

The VPC ID to which the instance belongs.

type GetInstancesOutputArgs 

type GetInstancesOutputArgs struct {
	// Specifies the enterprise project ID to which all instances of the list
	// belong.
	EnterpriseProjectId pulumi.StringPtrInput `pulumi:"enterpriseProjectId"`
	// Specifies whether to match the instance name fuzzily, the default is a exact
	// match (`flase`).
	FuzzyMatch pulumi.BoolPtrInput `pulumi:"fuzzyMatch"`
	// Specifies whether the query results contain instances that failed to create.
	IncludeFailure pulumi.BoolPtrInput `pulumi:"includeFailure"`
	// Specifies the kafka instance ID to match exactly.
	InstanceId pulumi.StringPtrInput `pulumi:"instanceId"`
	// Specifies the kafka instance name for data-source queries.
	Name pulumi.StringPtrInput `pulumi:"name"`
	// The region in which to query the kafka instance list.
	// If omitted, the provider-level region will be used.
	Region pulumi.StringPtrInput `pulumi:"region"`
	// Specifies the kafka instance status for data-source queries.
	Status pulumi.StringPtrInput `pulumi:"status"`
}

A collection of arguments for invoking getInstances.

func (GetInstancesOutputArgs) ElementType 

func (GetInstancesOutputArgs) ElementType() reflect.Type

type GetInstancesResult 

type GetInstancesResult struct {
	// The enterprise project ID to which the instance belongs.
	EnterpriseProjectId *string `pulumi:"enterpriseProjectId"`
	FuzzyMatch          *bool   `pulumi:"fuzzyMatch"`
	// The provider-assigned unique ID for this managed resource.
	Id             string  `pulumi:"id"`
	IncludeFailure *bool   `pulumi:"includeFailure"`
	InstanceId     *string `pulumi:"instanceId"`
	// The result of the query's list of kafka instances. The structure is documented below.
	Instances []GetInstancesInstance `pulumi:"instances"`
	// The instance name.
	Name   *string `pulumi:"name"`
	Region *string `pulumi:"region"`
	// The instance status.
	Status *string `pulumi:"status"`
}

A collection of values returned by getInstances.

func GetInstances 

func GetInstances(ctx *pulumi.Context, args *GetInstancesArgs, opts ...pulumi.InvokeOption) (*GetInstancesResult, error)

Use this data source to query the available instances within HuaweiCloud DMS service.

## Example Usage ### Query all instances with the keyword in the name

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		keyword := cfg.RequireObject("keyword")
		_, err := Dms.GetInstances(ctx, &dms.GetInstancesArgs{
			Name:       pulumi.StringRef(keyword),
			FuzzyMatch: pulumi.BoolRef(true),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Query the instance with the specified name

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		instanceName := cfg.RequireObject("instanceName")
		_, err := Dms.GetInstances(ctx, &dms.GetInstancesArgs{
			Name: pulumi.StringRef(instanceName),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetInstancesResultOutput 

type GetInstancesResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getInstances.

func GetInstancesOutput 

func GetInstancesOutput(ctx *pulumi.Context, args GetInstancesOutputArgs, opts ...pulumi.InvokeOption) GetInstancesResultOutput

func (GetInstancesResultOutput) ElementType 

func (GetInstancesResultOutput) ElementType() reflect.Type

func (GetInstancesResultOutput) EnterpriseProjectId 

func (o GetInstancesResultOutput) EnterpriseProjectId() pulumi.StringPtrOutput

The enterprise project ID to which the instance belongs.

func (GetInstancesResultOutput) FuzzyMatch 

func (o GetInstancesResultOutput) FuzzyMatch() pulumi.BoolPtrOutput

func (GetInstancesResultOutput) Id 

func (o GetInstancesResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetInstancesResultOutput) IncludeFailure 

func (o GetInstancesResultOutput) IncludeFailure() pulumi.BoolPtrOutput

func (GetInstancesResultOutput) InstanceId 

func (o GetInstancesResultOutput) InstanceId() pulumi.StringPtrOutput

func (GetInstancesResultOutput) Instances 

func (o GetInstancesResultOutput) Instances() GetInstancesInstanceArrayOutput

The result of the query's list of kafka instances. The structure is documented below.

func (GetInstancesResultOutput) Name 

func (o GetInstancesResultOutput) Name() pulumi.StringPtrOutput

The instance name.

func (GetInstancesResultOutput) Region 

func (o GetInstancesResultOutput) Region() pulumi.StringPtrOutput

func (GetInstancesResultOutput) Status 

func (o GetInstancesResultOutput) Status() pulumi.StringPtrOutput

The instance status.

func (GetInstancesResultOutput) ToGetInstancesResultOutput 

func (o GetInstancesResultOutput) ToGetInstancesResultOutput() GetInstancesResultOutput

func (GetInstancesResultOutput) ToGetInstancesResultOutputWithContext 

func (o GetInstancesResultOutput) ToGetInstancesResultOutputWithContext(ctx context.Context) GetInstancesResultOutput

type GetMaintainwindowArgs 

type GetMaintainwindowArgs struct {
	// Indicates the time at which a maintenance time window starts.
	Begin *string `pulumi:"begin"`
	// Indicates whether a maintenance time window is set to the default time segment.
	Default *bool `pulumi:"default"`
	// Indicates the time at which a maintenance time window ends.
	End *string `pulumi:"end"`
	// The region in which to obtain the dms maintainwindows. If omitted, the provider-level
	// region will be used.
	Region *string `pulumi:"region"`
	// Indicates the sequential number of a maintenance time window.
	Seq *int `pulumi:"seq"`
}

A collection of arguments for invoking getMaintainwindow.

type GetMaintainwindowOutputArgs 

type GetMaintainwindowOutputArgs struct {
	// Indicates the time at which a maintenance time window starts.
	Begin pulumi.StringPtrInput `pulumi:"begin"`
	// Indicates whether a maintenance time window is set to the default time segment.
	Default pulumi.BoolPtrInput `pulumi:"default"`
	// Indicates the time at which a maintenance time window ends.
	End pulumi.StringPtrInput `pulumi:"end"`
	// The region in which to obtain the dms maintainwindows. If omitted, the provider-level
	// region will be used.
	Region pulumi.StringPtrInput `pulumi:"region"`
	// Indicates the sequential number of a maintenance time window.
	Seq pulumi.IntPtrInput `pulumi:"seq"`
}

A collection of arguments for invoking getMaintainwindow.

func (GetMaintainwindowOutputArgs) ElementType 

func (GetMaintainwindowOutputArgs) ElementType() reflect.Type

type GetMaintainwindowResult 

type GetMaintainwindowResult struct {
	Begin   string `pulumi:"begin"`
	Default bool   `pulumi:"default"`
	End     string `pulumi:"end"`
	// The provider-assigned unique ID for this managed resource.
	Id     string `pulumi:"id"`
	Region string `pulumi:"region"`
	Seq    int    `pulumi:"seq"`
}

A collection of values returned by getMaintainwindow.

func GetMaintainwindow 

func GetMaintainwindow(ctx *pulumi.Context, args *GetMaintainwindowArgs, opts ...pulumi.InvokeOption) (*GetMaintainwindowResult, error)

Use this data source to get the ID of an available HuaweiCloud dms maintainwindow.

## Example Usage

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Dms.GetMaintainwindow(ctx, &dms.GetMaintainwindowArgs{
			Seq: pulumi.IntRef(1),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetMaintainwindowResultOutput 

type GetMaintainwindowResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getMaintainwindow.

func GetMaintainwindowOutput 

func GetMaintainwindowOutput(ctx *pulumi.Context, args GetMaintainwindowOutputArgs, opts ...pulumi.InvokeOption) GetMaintainwindowResultOutput

func (GetMaintainwindowResultOutput) Begin 

func (o GetMaintainwindowResultOutput) Begin() pulumi.StringOutput

func (GetMaintainwindowResultOutput) Default 

func (o GetMaintainwindowResultOutput) Default() pulumi.BoolOutput

func (GetMaintainwindowResultOutput) ElementType 

func (GetMaintainwindowResultOutput) ElementType() reflect.Type

func (GetMaintainwindowResultOutput) End 

func (o GetMaintainwindowResultOutput) End() pulumi.StringOutput

func (GetMaintainwindowResultOutput) Id 

func (o GetMaintainwindowResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetMaintainwindowResultOutput) Region 

func (o GetMaintainwindowResultOutput) Region() pulumi.StringOutput

func (GetMaintainwindowResultOutput) Seq 

func (o GetMaintainwindowResultOutput) Seq() pulumi.IntOutput

func (GetMaintainwindowResultOutput) ToGetMaintainwindowResultOutput 

func (o GetMaintainwindowResultOutput) ToGetMaintainwindowResultOutput() GetMaintainwindowResultOutput

func (GetMaintainwindowResultOutput) ToGetMaintainwindowResultOutputWithContext 

func (o GetMaintainwindowResultOutput) ToGetMaintainwindowResultOutputWithContext(ctx context.Context) GetMaintainwindowResultOutput

type GetProductArgs 

type GetProductArgs struct {
	// Indicates the list of availability zones with available resources.
	AvailabilityZones []string `pulumi:"availabilityZones"`
	// Indicates the baseline bandwidth of a DMS instance.
	// The valid values are **100MB**, **300MB**, **600MB** and **1200MB**.
	Bandwidth *string `pulumi:"bandwidth"`
	// Indicates the name of a message engine. The valid values are **kafka**, **rabbitmq**.
	Engine string `pulumi:"engine"`
	// Indicates an instance type. The valid values are **single** and **cluster**.
	InstanceType string `pulumi:"instanceType"`
	// Deprecated: io_type has deprecated, please use storage_spec_code
	IoType *string `pulumi:"ioType"`
	// Indicates the number of nodes in a cluster.
	NodeNum *string `pulumi:"nodeNum"`
	// Indicates the maximum number of topics that can be created for a Kafka instance.
	// The valid values are **300**, **900** and **1800**.
	PartitionNum *string `pulumi:"partitionNum"`
	// The region in which to obtain the dms products. If omitted, the provider-level region
	// will be used.
	Region *string `pulumi:"region"`
	// Indicates the storage capacity of the resource.
	// The default value is the storage capacity of the product.
	Storage *string `pulumi:"storage"`
	// Indicates an I/O specification.
	// The valid values are **dms.physical.storage.high** and **dms.physical.storage.ultra**.
	StorageSpecCode *string `pulumi:"storageSpecCode"`
	// Indicates the version of a message engine.
	Version *string `pulumi:"version"`
	// Indicates underlying VM specification, such as **c6.large.2**.
	VmSpecification *string `pulumi:"vmSpecification"`
}

A collection of arguments for invoking getProduct.

type GetProductOutputArgs 

type GetProductOutputArgs struct {
	// Indicates the list of availability zones with available resources.
	AvailabilityZones pulumi.StringArrayInput `pulumi:"availabilityZones"`
	// Indicates the baseline bandwidth of a DMS instance.
	// The valid values are **100MB**, **300MB**, **600MB** and **1200MB**.
	Bandwidth pulumi.StringPtrInput `pulumi:"bandwidth"`
	// Indicates the name of a message engine. The valid values are **kafka**, **rabbitmq**.
	Engine pulumi.StringInput `pulumi:"engine"`
	// Indicates an instance type. The valid values are **single** and **cluster**.
	InstanceType pulumi.StringInput `pulumi:"instanceType"`
	// Deprecated: io_type has deprecated, please use storage_spec_code
	IoType pulumi.StringPtrInput `pulumi:"ioType"`
	// Indicates the number of nodes in a cluster.
	NodeNum pulumi.StringPtrInput `pulumi:"nodeNum"`
	// Indicates the maximum number of topics that can be created for a Kafka instance.
	// The valid values are **300**, **900** and **1800**.
	PartitionNum pulumi.StringPtrInput `pulumi:"partitionNum"`
	// The region in which to obtain the dms products. If omitted, the provider-level region
	// will be used.
	Region pulumi.StringPtrInput `pulumi:"region"`
	// Indicates the storage capacity of the resource.
	// The default value is the storage capacity of the product.
	Storage pulumi.StringPtrInput `pulumi:"storage"`
	// Indicates an I/O specification.
	// The valid values are **dms.physical.storage.high** and **dms.physical.storage.ultra**.
	StorageSpecCode pulumi.StringPtrInput `pulumi:"storageSpecCode"`
	// Indicates the version of a message engine.
	Version pulumi.StringPtrInput `pulumi:"version"`
	// Indicates underlying VM specification, such as **c6.large.2**.
	VmSpecification pulumi.StringPtrInput `pulumi:"vmSpecification"`
}

A collection of arguments for invoking getProduct.

func (GetProductOutputArgs) ElementType 

func (GetProductOutputArgs) ElementType() reflect.Type

type GetProductResult 

type GetProductResult struct {
	AvailabilityZones []string `pulumi:"availabilityZones"`
	Bandwidth         string   `pulumi:"bandwidth"`
	Engine            string   `pulumi:"engine"`
	// The provider-assigned unique ID for this managed resource.
	Id           string `pulumi:"id"`
	InstanceType string `pulumi:"instanceType"`
	// Deprecated: io_type has deprecated, please use storage_spec_code
	IoType          string `pulumi:"ioType"`
	NodeNum         string `pulumi:"nodeNum"`
	PartitionNum    string `pulumi:"partitionNum"`
	Region          string `pulumi:"region"`
	Storage         string `pulumi:"storage"`
	StorageSpecCode string `pulumi:"storageSpecCode"`
	// The available I/O specifications.
	StorageSpecCodes []string `pulumi:"storageSpecCodes"`
	Version          string   `pulumi:"version"`
	VmSpecification  string   `pulumi:"vmSpecification"`
}

A collection of values returned by getProduct.

func GetProduct 

func GetProduct(ctx *pulumi.Context, args *GetProductArgs, opts ...pulumi.InvokeOption) (*GetProductResult, error)

Use this data source to get the ID of an available HuaweiCloud DMS product.

## Example Usage ### Filter DMS kafka product list by I/O specification

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Dms.GetProduct(ctx, &dms.GetProductArgs{
			Engine:          "kafka",
			InstanceType:    "cluster",
			PartitionNum:    pulumi.StringRef("300"),
			Storage:         pulumi.StringRef("600"),
			StorageSpecCode: pulumi.StringRef("dms.physical.storage.high"),
			Version:         pulumi.StringRef("1.1.0"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

``` ### Filter DMS kafka product list by underlying VM specification

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Dms.GetProduct(ctx, &dms.GetProductArgs{
			Engine:          "kafka",
			InstanceType:    "cluster",
			Version:         pulumi.StringRef("2.3.0"),
			VmSpecification: pulumi.StringRef("c6.large.2"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetProductResultOutput 

type GetProductResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getProduct.

func GetProductOutput 

func GetProductOutput(ctx *pulumi.Context, args GetProductOutputArgs, opts ...pulumi.InvokeOption) GetProductResultOutput

func (GetProductResultOutput) AvailabilityZones 

func (o GetProductResultOutput) AvailabilityZones() pulumi.StringArrayOutput

func (GetProductResultOutput) Bandwidth 

func (o GetProductResultOutput) Bandwidth() pulumi.StringOutput

func (GetProductResultOutput) ElementType 

func (GetProductResultOutput) ElementType() reflect.Type

func (GetProductResultOutput) Engine 

func (o GetProductResultOutput) Engine() pulumi.StringOutput

func (GetProductResultOutput) Id 

func (o GetProductResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetProductResultOutput) InstanceType 

func (o GetProductResultOutput) InstanceType() pulumi.StringOutput

func (GetProductResultOutput) IoType deprecated 

func (o GetProductResultOutput) IoType() pulumi.StringOutput

Deprecated: io_type has deprecated, please use storage_spec_code

func (GetProductResultOutput) NodeNum 

func (o GetProductResultOutput) NodeNum() pulumi.StringOutput

func (GetProductResultOutput) PartitionNum 

func (o GetProductResultOutput) PartitionNum() pulumi.StringOutput

func (GetProductResultOutput) Region 

func (o GetProductResultOutput) Region() pulumi.StringOutput

func (GetProductResultOutput) Storage 

func (o GetProductResultOutput) Storage() pulumi.StringOutput

func (GetProductResultOutput) StorageSpecCode 

func (o GetProductResultOutput) StorageSpecCode() pulumi.StringOutput

func (GetProductResultOutput) StorageSpecCodes 

func (o GetProductResultOutput) StorageSpecCodes() pulumi.StringArrayOutput

The available I/O specifications.

func (GetProductResultOutput) ToGetProductResultOutput 

func (o GetProductResultOutput) ToGetProductResultOutput() GetProductResultOutput

func (GetProductResultOutput) ToGetProductResultOutputWithContext 

func (o GetProductResultOutput) ToGetProductResultOutputWithContext(ctx context.Context) GetProductResultOutput

func (GetProductResultOutput) Version 

func (o GetProductResultOutput) Version() pulumi.StringOutput

func (GetProductResultOutput) VmSpecification 

func (o GetProductResultOutput) VmSpecification() pulumi.StringOutput

type KafkaInstance 

type KafkaInstance struct {
	pulumi.CustomResourceState

	// Specifies the username of SASL_SSL user. A username consists of 4
	// to 64 characters and supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.
	AccessUser pulumi.StringPtrOutput `pulumi:"accessUser"`
	// Specifies whether auto renew is enabled. Valid values are "true" and "false".
	AutoRenew pulumi.StringPtrOutput `pulumi:"autoRenew"`
	// The names of the AZ where the Kafka instances reside.
	// The parameter value can not be left blank or an empty array. Changing this creates a new instance resource.
	AvailabilityZones pulumi.StringArrayOutput `pulumi:"availabilityZones"`
	// Deprecated: available_zones has deprecated, please use "availability_zones" instead.
	AvailableZones pulumi.StringArrayOutput `pulumi:"availableZones"`
	// Deprecated: The bandwidth has been deprecated. If you need to change the bandwidth, please update the product_id.
	Bandwidth pulumi.StringOutput `pulumi:"bandwidth"`
	// Specifies the broker numbers.
	// It is required when creating an instance with `flavorId`.
	BrokerNum pulumi.IntOutput `pulumi:"brokerNum"`
	// Specifies the charging mode of the instance. Valid values are *prePaid*
	// and *postPaid*, defaults to *postPaid*. Changing this creates a new resource.
	ChargingMode pulumi.StringOutput `pulumi:"chargingMode"`
	// Indicates the IP address of the DMS Kafka instance.
	ConnectAddress pulumi.StringOutput `pulumi:"connectAddress"`
	// Specifies the cross-VPC access information.
	// The object structure is documented below.
	CrossVpcAccesses KafkaInstanceCrossVpcAccessArrayOutput `pulumi:"crossVpcAccesses"`
	// Specifies the description of the DMS Kafka instance. It is a character string
	// containing not more than 1,024 characters.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Specifies whether to enable message dumping.
	// Changing this creates a new instance resource.
	Dumping pulumi.BoolOutput `pulumi:"dumping"`
	// Specifies whether to enable automatic topic creation. If automatic
	// topic creation is enabled, a topic will be automatically created with 3 partitions and 3 replicas when a message is
	// produced to or consumed from a topic that does not exist.
	// The default value is false.
	// Changing this creates a new instance resource.
	EnableAutoTopic pulumi.BoolOutput `pulumi:"enableAutoTopic"`
	// Indicates whether public access to the DMS Kafka instance is enabled.
	EnablePublicIp pulumi.BoolOutput `pulumi:"enablePublicIp"`
	// Indicates the message engine.
	Engine pulumi.StringOutput `pulumi:"engine"`
	// Specifies the version of the Kafka engine,
	// such as 1.1.0, 2.3.0, 2.7 or other supported versions. Changing this creates a new instance resource.
	EngineVersion pulumi.StringOutput `pulumi:"engineVersion"`
	// Specifies the enterprise project ID of the Kafka instance.
	EnterpriseProjectId pulumi.StringOutput `pulumi:"enterpriseProjectId"`
	// Specifies the Kafka [flavor ID](https://support.huaweicloud.com/intl/en-us/productdesc-kafka/Kafka-specification.html),
	// e.g. **c6.2u4g.cluster**. This parameter and `productId` are alternative.
	FlavorId pulumi.StringPtrOutput `pulumi:"flavorId"`
	// Specifies the time at which a maintenance time window starts. Format: HH:mm. The
	// start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time
	// window. The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also
	// blank. In this case, the system automatically allocates the default start time 02:00.
	MaintainBegin pulumi.StringOutput `pulumi:"maintainBegin"`
	// Specifies the time at which a maintenance time window ends. Format: HH:mm. The
	// start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time
	// window. The end time is four hours later than the start time. For example, if the start time is 22:00, the end time is
	// 02:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainEnd` is left blank, parameter
	// `maintainBegin` is also blank. In this case, the system automatically allocates the default end time 06:00.
	MaintainEnd pulumi.StringOutput `pulumi:"maintainEnd"`
	// Indicates the Kafka Manager connection address of a Kafka instance.
	ManagementConnectAddress pulumi.StringOutput `pulumi:"managementConnectAddress"`
	// Specifies the password for logging in to the Kafka Manager. The
	// password must meet the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of
	// the following character types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_
	// =+\\|[{}]:'",<.>/?). Changing this creates a new instance resource.
	ManagerPassword pulumi.StringOutput `pulumi:"managerPassword"`
	// Specifies the username for logging in to the Kafka Manager. The username
	// consists of 4 to 64 characters and can contain letters, digits, hyphens (-), and underscores (_). Changing this
	// creates a new instance resource.
	ManagerUser pulumi.StringOutput `pulumi:"managerUser"`
	// Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.
	ManegementConnectAddress pulumi.StringOutput `pulumi:"manegementConnectAddress"`
	// Specifies the name of the DMS Kafka instance. An instance name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	Name pulumi.StringOutput `pulumi:"name"`
	// Specifies the ID of a subnet. Changing this creates a new instance
	// resource.
	NetworkId pulumi.StringOutput `pulumi:"networkId"`
	// Indicates the number of partitions in Kafka instance.
	PartitionNum pulumi.IntOutput `pulumi:"partitionNum"`
	// Specifies the password of SASL_SSL user. A password must meet the
	// following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following character
	// types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?).
	// Changing this creates a new instance resource.
	Password pulumi.StringPtrOutput `pulumi:"password"`
	// Specifies the charging period of the instance. If `periodUnit` is set to *month*
	// , the value ranges from 1 to 9. If `periodUnit` is set to *year*, the value ranges from 1 to 3. This parameter is
	// mandatory if `chargingMode` is set to *prePaid*. Changing this creates a new resource.
	Period pulumi.IntPtrOutput `pulumi:"period"`
	// Specifies the charging period unit of the instance.
	// Valid values are *month* and *year*. This parameter is mandatory if `chargingMode` is set to *prePaid*.
	// Changing this creates a new resource.
	PeriodUnit pulumi.StringPtrOutput `pulumi:"periodUnit"`
	// The port number.
	Port pulumi.IntOutput `pulumi:"port"`
	// Specifies a product ID, which includes bandwidth, partition, broker and default
	// storage capacity.
	ProductId pulumi.StringPtrOutput `pulumi:"productId"`
	// Specifies the IDs of the elastic IP address (EIP)
	// bound to the DMS Kafka instance. Changing this creates a new instance resource.
	// + If the instance is created with `flavorId`, the total number of public IPs is equal to `brokerNum`.
	// + If the instance is created with `productId`, the total number of public IPs must provide as follows:
	PublicIpIds pulumi.StringArrayOutput `pulumi:"publicIpIds"`
	// The region in which to create the DMS Kafka instances. If omitted, the
	// provider-level region will be used. Changing this creates a new instance resource.
	Region pulumi.StringOutput `pulumi:"region"`
	// Indicates a resource specifications identifier.
	ResourceSpecCode pulumi.StringOutput `pulumi:"resourceSpecCode"`
	// Specifies the action to be taken when the memory usage reaches the disk
	// capacity threshold. The valid values are as follows:
	// + **time_base**: Automatically delete the earliest messages.
	// + **produce_reject**: Stop producing new messages.
	RetentionPolicy pulumi.StringOutput `pulumi:"retentionPolicy"`
	// Specifies the ID of a security group.
	SecurityGroupId pulumi.StringOutput `pulumi:"securityGroupId"`
	// Indicates whether the Kafka SASL_SSL is enabled.
	SslEnable pulumi.BoolOutput `pulumi:"sslEnable"`
	// Indicates the status of the DMS Kafka instance.
	Status pulumi.StringOutput `pulumi:"status"`
	// Specifies the message storage capacity, the unit is GB.
	// The storage spaces corresponding to the product IDs are as follows:
	// + **c6.2u4g.cluster** (100MB bandwidth): `300` to `300,000` GB
	// + **c6.4u8g.cluster** (300MB bandwidth): `300` to `600,000` GB
	// + **c6.8u16g.cluster** (600MB bandwidth): `300` to `900,000` GB
	// + **c6.12u12g.cluster**: `300` to `900,000` GB
	// + **c6.16u32g.cluster** (1,200MB bandwidth): `300` to `900,000` GB
	StorageSpace pulumi.IntOutput `pulumi:"storageSpace"`
	// Specifies the storage I/O specification.
	// If the instance is created with `flavorId`, the valid values are as follows:
	// + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O.
	// + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.
	StorageSpecCode pulumi.StringOutput `pulumi:"storageSpecCode"`
	// The key/value pairs to associate with the DMS Kafka instance.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// Indicates the DMS Kafka instance type.
	Type pulumi.StringOutput `pulumi:"type"`
	// Indicates the used message storage space. Unit: GB
	UsedStorageSpace pulumi.IntOutput `pulumi:"usedStorageSpace"`
	// Indicates the ID of the user who created the DMS Kafka instance
	UserId pulumi.StringOutput `pulumi:"userId"`
	// Indicates the name of the user who created the DMS Kafka instance
	UserName pulumi.StringOutput `pulumi:"userName"`
	// Specifies the ID of a VPC. Changing this creates a new instance resource.
	VpcId pulumi.StringOutput `pulumi:"vpcId"`
}

Manage DMS Kafka instance resources within HuaweiCloud.

## Example Usage ### Create a Kafka instance using flavor ID

```go package main

import ( 

"fmt"

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		vpcId := cfg.RequireObject("vpcId")
		subnetId := cfg.RequireObject("subnetId")
		securityGroupId := cfg.RequireObject("securityGroupId")
		availabilityZones := []string{
			"your_availability_zones_a",
			"your_availability_zones_b",
			"your_availability_zones_c",
		}
		if param := cfg.GetBool("availabilityZones"); param != nil {
			availabilityZones = param
		}
		flavorId := "your_flavor_id, such: c6.2u4g.cluster"
		if param := cfg.Get("flavorId"); param != "" {
			flavorId = param
		}
		storageSpecCode := "your_storage_spec_code, such: dms.physical.storage.ultra.v2"
		if param := cfg.Get("storageSpecCode"); param != "" {
			storageSpecCode = param
		}
		testFlavors, err := Dms.GetFlavors(ctx, &dms.GetFlavorsArgs{
			Type:              pulumi.StringRef("cluster"),
			FlavorId:          pulumi.StringRef(flavorId),
			AvailabilityZones: availabilityZones,
			StorageSpecCode:   pulumi.StringRef(storageSpecCode),
		}, nil)
		if err != nil {
			return err
		}
		_, err = Dms.NewKafkaInstance(ctx, "testKafkaInstance", &Dms.KafkaInstanceArgs{
			VpcId:             pulumi.Any(vpcId),
			NetworkId:         pulumi.Any(subnetId),
			SecurityGroupId:   pulumi.Any(securityGroupId),
			FlavorId:          pulumi.String(testFlavors.FlavorId),
			StorageSpecCode:   pulumi.String(testFlavors.Flavors[0].Ios[0].StorageSpecCode),
			AvailabilityZones: pulumi.Any(availabilityZones),
			EngineVersion:     pulumi.String("2.7"),
			StorageSpace:      pulumi.Int(600),
			BrokerNum:         pulumi.Int(3),
			AccessUser:        pulumi.String("user"),
			Password:          pulumi.String(fmt.Sprintf("Kafka_%v^&_Test", "%")),
			ManagerUser:       pulumi.String("kafka_manager"),
			ManagerPassword:   pulumi.String("Kafka_Test^&*("),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

DMS Kafka instance can be imported using the instance id, e.g.

```sh 

$ pulumi import huaweicloud:Dms/kafkaInstance:KafkaInstance huaweicloud_dms_kafka_instance.instance_1 8d3c7938-dc47-4937-a30f-c80de381c5e3

``` 

Note that the imported state may not be identical to your resource definition, due to some attributes missing from the API response, security or some other reason. The missing attributes include`password`, `manager_password` and `public_ip_ids`. It is generally recommended running `terraform plan` after importing a DMS Kafka instance. You can then decide if changes should be applied to the instance, or the resource definition should be updated to align with the instance. Also you can ignore changes as below. resource "huaweicloud_dms_kafka_instance" "instance_1" {

...

lifecycle {

ignore_changes = [

password, manager_password,

]

} }

func GetKafkaInstance 

func GetKafkaInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaInstanceState, opts ...pulumi.ResourceOption) (*KafkaInstance, error)

GetKafkaInstance gets an existing KafkaInstance resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaInstance 

func NewKafkaInstance(ctx *pulumi.Context,
	name string, args *KafkaInstanceArgs, opts ...pulumi.ResourceOption) (*KafkaInstance, error)

NewKafkaInstance registers a new resource with the given unique name, arguments, and options.

func (*KafkaInstance) ElementType 

func (*KafkaInstance) ElementType() reflect.Type

func (*KafkaInstance) ToKafkaInstanceOutput 

func (i *KafkaInstance) ToKafkaInstanceOutput() KafkaInstanceOutput

func (*KafkaInstance) ToKafkaInstanceOutputWithContext 

func (i *KafkaInstance) ToKafkaInstanceOutputWithContext(ctx context.Context) KafkaInstanceOutput

type KafkaInstanceArgs 

type KafkaInstanceArgs struct {
	// Specifies the username of SASL_SSL user. A username consists of 4
	// to 64 characters and supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.
	AccessUser pulumi.StringPtrInput
	// Specifies whether auto renew is enabled. Valid values are "true" and "false".
	AutoRenew pulumi.StringPtrInput
	// The names of the AZ where the Kafka instances reside.
	// The parameter value can not be left blank or an empty array. Changing this creates a new instance resource.
	AvailabilityZones pulumi.StringArrayInput
	// Deprecated: available_zones has deprecated, please use "availability_zones" instead.
	AvailableZones pulumi.StringArrayInput
	// Deprecated: The bandwidth has been deprecated. If you need to change the bandwidth, please update the product_id.
	Bandwidth pulumi.StringPtrInput
	// Specifies the broker numbers.
	// It is required when creating an instance with `flavorId`.
	BrokerNum pulumi.IntPtrInput
	// Specifies the charging mode of the instance. Valid values are *prePaid*
	// and *postPaid*, defaults to *postPaid*. Changing this creates a new resource.
	ChargingMode pulumi.StringPtrInput
	// Specifies the cross-VPC access information.
	// The object structure is documented below.
	CrossVpcAccesses KafkaInstanceCrossVpcAccessArrayInput
	// Specifies the description of the DMS Kafka instance. It is a character string
	// containing not more than 1,024 characters.
	Description pulumi.StringPtrInput
	// Specifies whether to enable message dumping.
	// Changing this creates a new instance resource.
	Dumping pulumi.BoolPtrInput
	// Specifies whether to enable automatic topic creation. If automatic
	// topic creation is enabled, a topic will be automatically created with 3 partitions and 3 replicas when a message is
	// produced to or consumed from a topic that does not exist.
	// The default value is false.
	// Changing this creates a new instance resource.
	EnableAutoTopic pulumi.BoolPtrInput
	// Specifies the version of the Kafka engine,
	// such as 1.1.0, 2.3.0, 2.7 or other supported versions. Changing this creates a new instance resource.
	EngineVersion pulumi.StringInput
	// Specifies the enterprise project ID of the Kafka instance.
	EnterpriseProjectId pulumi.StringPtrInput
	// Specifies the Kafka [flavor ID](https://support.huaweicloud.com/intl/en-us/productdesc-kafka/Kafka-specification.html),
	// e.g. **c6.2u4g.cluster**. This parameter and `productId` are alternative.
	FlavorId pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window starts. Format: HH:mm. The
	// start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time
	// window. The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also
	// blank. In this case, the system automatically allocates the default start time 02:00.
	MaintainBegin pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window ends. Format: HH:mm. The
	// start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time
	// window. The end time is four hours later than the start time. For example, if the start time is 22:00, the end time is
	// 02:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainEnd` is left blank, parameter
	// `maintainBegin` is also blank. In this case, the system automatically allocates the default end time 06:00.
	MaintainEnd pulumi.StringPtrInput
	// Specifies the password for logging in to the Kafka Manager. The
	// password must meet the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of
	// the following character types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_
	// =+\\|[{}]:'",<.>/?). Changing this creates a new instance resource.
	ManagerPassword pulumi.StringInput
	// Specifies the username for logging in to the Kafka Manager. The username
	// consists of 4 to 64 characters and can contain letters, digits, hyphens (-), and underscores (_). Changing this
	// creates a new instance resource.
	ManagerUser pulumi.StringInput
	// Specifies the name of the DMS Kafka instance. An instance name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	Name pulumi.StringPtrInput
	// Specifies the ID of a subnet. Changing this creates a new instance
	// resource.
	NetworkId pulumi.StringInput
	// Specifies the password of SASL_SSL user. A password must meet the
	// following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following character
	// types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?).
	// Changing this creates a new instance resource.
	Password pulumi.StringPtrInput
	// Specifies the charging period of the instance. If `periodUnit` is set to *month*
	// , the value ranges from 1 to 9. If `periodUnit` is set to *year*, the value ranges from 1 to 3. This parameter is
	// mandatory if `chargingMode` is set to *prePaid*. Changing this creates a new resource.
	Period pulumi.IntPtrInput
	// Specifies the charging period unit of the instance.
	// Valid values are *month* and *year*. This parameter is mandatory if `chargingMode` is set to *prePaid*.
	// Changing this creates a new resource.
	PeriodUnit pulumi.StringPtrInput
	// Specifies a product ID, which includes bandwidth, partition, broker and default
	// storage capacity.
	ProductId pulumi.StringPtrInput
	// Specifies the IDs of the elastic IP address (EIP)
	// bound to the DMS Kafka instance. Changing this creates a new instance resource.
	// + If the instance is created with `flavorId`, the total number of public IPs is equal to `brokerNum`.
	// + If the instance is created with `productId`, the total number of public IPs must provide as follows:
	PublicIpIds pulumi.StringArrayInput
	// The region in which to create the DMS Kafka instances. If omitted, the
	// provider-level region will be used. Changing this creates a new instance resource.
	Region pulumi.StringPtrInput
	// Specifies the action to be taken when the memory usage reaches the disk
	// capacity threshold. The valid values are as follows:
	// + **time_base**: Automatically delete the earliest messages.
	// + **produce_reject**: Stop producing new messages.
	RetentionPolicy pulumi.StringPtrInput
	// Specifies the ID of a security group.
	SecurityGroupId pulumi.StringInput
	// Specifies the message storage capacity, the unit is GB.
	// The storage spaces corresponding to the product IDs are as follows:
	// + **c6.2u4g.cluster** (100MB bandwidth): `300` to `300,000` GB
	// + **c6.4u8g.cluster** (300MB bandwidth): `300` to `600,000` GB
	// + **c6.8u16g.cluster** (600MB bandwidth): `300` to `900,000` GB
	// + **c6.12u12g.cluster**: `300` to `900,000` GB
	// + **c6.16u32g.cluster** (1,200MB bandwidth): `300` to `900,000` GB
	StorageSpace pulumi.IntPtrInput
	// Specifies the storage I/O specification.
	// If the instance is created with `flavorId`, the valid values are as follows:
	// + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O.
	// + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.
	StorageSpecCode pulumi.StringInput
	// The key/value pairs to associate with the DMS Kafka instance.
	Tags pulumi.StringMapInput
	// Specifies the ID of a VPC. Changing this creates a new instance resource.
	VpcId pulumi.StringInput
}

The set of arguments for constructing a KafkaInstance resource.

func (KafkaInstanceArgs) ElementType 

func (KafkaInstanceArgs) ElementType() reflect.Type

type KafkaInstanceArray 

type KafkaInstanceArray []KafkaInstanceInput

func (KafkaInstanceArray) ElementType 

func (KafkaInstanceArray) ElementType() reflect.Type

func (KafkaInstanceArray) ToKafkaInstanceArrayOutput 

func (i KafkaInstanceArray) ToKafkaInstanceArrayOutput() KafkaInstanceArrayOutput

func (KafkaInstanceArray) ToKafkaInstanceArrayOutputWithContext 

func (i KafkaInstanceArray) ToKafkaInstanceArrayOutputWithContext(ctx context.Context) KafkaInstanceArrayOutput

type KafkaInstanceArrayInput 

type KafkaInstanceArrayInput interface {
	pulumi.Input

	ToKafkaInstanceArrayOutput() KafkaInstanceArrayOutput
	ToKafkaInstanceArrayOutputWithContext(context.Context) KafkaInstanceArrayOutput
}

KafkaInstanceArrayInput is an input type that accepts KafkaInstanceArray and KafkaInstanceArrayOutput values. You can construct a concrete instance of `KafkaInstanceArrayInput` via: 

KafkaInstanceArray{ KafkaInstanceArgs{...} }

type KafkaInstanceArrayOutput 

type KafkaInstanceArrayOutput struct{ *pulumi.OutputState }

func (KafkaInstanceArrayOutput) ElementType 

func (KafkaInstanceArrayOutput) ElementType() reflect.Type

func (KafkaInstanceArrayOutput) Index 

func (o KafkaInstanceArrayOutput) Index(i pulumi.IntInput) KafkaInstanceOutput

func (KafkaInstanceArrayOutput) ToKafkaInstanceArrayOutput 

func (o KafkaInstanceArrayOutput) ToKafkaInstanceArrayOutput() KafkaInstanceArrayOutput

func (KafkaInstanceArrayOutput) ToKafkaInstanceArrayOutputWithContext 

func (o KafkaInstanceArrayOutput) ToKafkaInstanceArrayOutputWithContext(ctx context.Context) KafkaInstanceArrayOutput

type KafkaInstanceCrossVpcAccess 

type KafkaInstanceCrossVpcAccess struct {
	// The advertised IP Address or domain name.
	AdvertisedIp *string `pulumi:"advertisedIp"`
	// Deprecated: typo in lisenter_ip, please use "listener_ip" instead.
	LisenterIp *string `pulumi:"lisenterIp"`
	// The listener IP address.
	ListenerIp *string `pulumi:"listenerIp"`
	// The port number.
	Port *int `pulumi:"port"`
	// The port ID associated with the address.
	PortId *string `pulumi:"portId"`
}

type KafkaInstanceCrossVpcAccessArgs 

type KafkaInstanceCrossVpcAccessArgs struct {
	// The advertised IP Address or domain name.
	AdvertisedIp pulumi.StringPtrInput `pulumi:"advertisedIp"`
	// Deprecated: typo in lisenter_ip, please use "listener_ip" instead.
	LisenterIp pulumi.StringPtrInput `pulumi:"lisenterIp"`
	// The listener IP address.
	ListenerIp pulumi.StringPtrInput `pulumi:"listenerIp"`
	// The port number.
	Port pulumi.IntPtrInput `pulumi:"port"`
	// The port ID associated with the address.
	PortId pulumi.StringPtrInput `pulumi:"portId"`
}

func (KafkaInstanceCrossVpcAccessArgs) ElementType 

func (KafkaInstanceCrossVpcAccessArgs) ElementType() reflect.Type

func (KafkaInstanceCrossVpcAccessArgs) ToKafkaInstanceCrossVpcAccessOutput 

func (i KafkaInstanceCrossVpcAccessArgs) ToKafkaInstanceCrossVpcAccessOutput() KafkaInstanceCrossVpcAccessOutput

func (KafkaInstanceCrossVpcAccessArgs) ToKafkaInstanceCrossVpcAccessOutputWithContext 

func (i KafkaInstanceCrossVpcAccessArgs) ToKafkaInstanceCrossVpcAccessOutputWithContext(ctx context.Context) KafkaInstanceCrossVpcAccessOutput

type KafkaInstanceCrossVpcAccessArray 

type KafkaInstanceCrossVpcAccessArray []KafkaInstanceCrossVpcAccessInput

func (KafkaInstanceCrossVpcAccessArray) ElementType 

func (KafkaInstanceCrossVpcAccessArray) ElementType() reflect.Type

func (KafkaInstanceCrossVpcAccessArray) ToKafkaInstanceCrossVpcAccessArrayOutput 

func (i KafkaInstanceCrossVpcAccessArray) ToKafkaInstanceCrossVpcAccessArrayOutput() KafkaInstanceCrossVpcAccessArrayOutput

func (KafkaInstanceCrossVpcAccessArray) ToKafkaInstanceCrossVpcAccessArrayOutputWithContext 

func (i KafkaInstanceCrossVpcAccessArray) ToKafkaInstanceCrossVpcAccessArrayOutputWithContext(ctx context.Context) KafkaInstanceCrossVpcAccessArrayOutput

type KafkaInstanceCrossVpcAccessArrayInput 

type KafkaInstanceCrossVpcAccessArrayInput interface {
	pulumi.Input

	ToKafkaInstanceCrossVpcAccessArrayOutput() KafkaInstanceCrossVpcAccessArrayOutput
	ToKafkaInstanceCrossVpcAccessArrayOutputWithContext(context.Context) KafkaInstanceCrossVpcAccessArrayOutput
}

KafkaInstanceCrossVpcAccessArrayInput is an input type that accepts KafkaInstanceCrossVpcAccessArray and KafkaInstanceCrossVpcAccessArrayOutput values. You can construct a concrete instance of `KafkaInstanceCrossVpcAccessArrayInput` via: 

KafkaInstanceCrossVpcAccessArray{ KafkaInstanceCrossVpcAccessArgs{...} }

type KafkaInstanceCrossVpcAccessArrayOutput 

type KafkaInstanceCrossVpcAccessArrayOutput struct{ *pulumi.OutputState }

func (KafkaInstanceCrossVpcAccessArrayOutput) ElementType 

func (KafkaInstanceCrossVpcAccessArrayOutput) ElementType() reflect.Type

func (KafkaInstanceCrossVpcAccessArrayOutput) Index 

func (o KafkaInstanceCrossVpcAccessArrayOutput) Index(i pulumi.IntInput) KafkaInstanceCrossVpcAccessOutput

func (KafkaInstanceCrossVpcAccessArrayOutput) ToKafkaInstanceCrossVpcAccessArrayOutput 

func (o KafkaInstanceCrossVpcAccessArrayOutput) ToKafkaInstanceCrossVpcAccessArrayOutput() KafkaInstanceCrossVpcAccessArrayOutput

func (KafkaInstanceCrossVpcAccessArrayOutput) ToKafkaInstanceCrossVpcAccessArrayOutputWithContext 

func (o KafkaInstanceCrossVpcAccessArrayOutput) ToKafkaInstanceCrossVpcAccessArrayOutputWithContext(ctx context.Context) KafkaInstanceCrossVpcAccessArrayOutput

type KafkaInstanceCrossVpcAccessInput 

type KafkaInstanceCrossVpcAccessInput interface {
	pulumi.Input

	ToKafkaInstanceCrossVpcAccessOutput() KafkaInstanceCrossVpcAccessOutput
	ToKafkaInstanceCrossVpcAccessOutputWithContext(context.Context) KafkaInstanceCrossVpcAccessOutput
}

KafkaInstanceCrossVpcAccessInput is an input type that accepts KafkaInstanceCrossVpcAccessArgs and KafkaInstanceCrossVpcAccessOutput values. You can construct a concrete instance of `KafkaInstanceCrossVpcAccessInput` via: 

KafkaInstanceCrossVpcAccessArgs{...}

type KafkaInstanceCrossVpcAccessOutput 

type KafkaInstanceCrossVpcAccessOutput struct{ *pulumi.OutputState }

func (KafkaInstanceCrossVpcAccessOutput) AdvertisedIp 

func (o KafkaInstanceCrossVpcAccessOutput) AdvertisedIp() pulumi.StringPtrOutput

The advertised IP Address or domain name.

func (KafkaInstanceCrossVpcAccessOutput) ElementType 

func (KafkaInstanceCrossVpcAccessOutput) ElementType() reflect.Type

func (KafkaInstanceCrossVpcAccessOutput) LisenterIp deprecated 

func (o KafkaInstanceCrossVpcAccessOutput) LisenterIp() pulumi.StringPtrOutput

Deprecated: typo in lisenter_ip, please use "listener_ip" instead.

func (KafkaInstanceCrossVpcAccessOutput) ListenerIp added in v0.0.8 

func (o KafkaInstanceCrossVpcAccessOutput) ListenerIp() pulumi.StringPtrOutput

The listener IP address.

func (KafkaInstanceCrossVpcAccessOutput) Port 

func (o KafkaInstanceCrossVpcAccessOutput) Port() pulumi.IntPtrOutput

The port number.

func (KafkaInstanceCrossVpcAccessOutput) PortId 

func (o KafkaInstanceCrossVpcAccessOutput) PortId() pulumi.StringPtrOutput

The port ID associated with the address.

func (KafkaInstanceCrossVpcAccessOutput) ToKafkaInstanceCrossVpcAccessOutput 

func (o KafkaInstanceCrossVpcAccessOutput) ToKafkaInstanceCrossVpcAccessOutput() KafkaInstanceCrossVpcAccessOutput

func (KafkaInstanceCrossVpcAccessOutput) ToKafkaInstanceCrossVpcAccessOutputWithContext 

func (o KafkaInstanceCrossVpcAccessOutput) ToKafkaInstanceCrossVpcAccessOutputWithContext(ctx context.Context) KafkaInstanceCrossVpcAccessOutput

type KafkaInstanceInput 

type KafkaInstanceInput interface {
	pulumi.Input

	ToKafkaInstanceOutput() KafkaInstanceOutput
	ToKafkaInstanceOutputWithContext(ctx context.Context) KafkaInstanceOutput
}

type KafkaInstanceMap 

type KafkaInstanceMap map[string]KafkaInstanceInput

func (KafkaInstanceMap) ElementType 

func (KafkaInstanceMap) ElementType() reflect.Type

func (KafkaInstanceMap) ToKafkaInstanceMapOutput 

func (i KafkaInstanceMap) ToKafkaInstanceMapOutput() KafkaInstanceMapOutput

func (KafkaInstanceMap) ToKafkaInstanceMapOutputWithContext 

func (i KafkaInstanceMap) ToKafkaInstanceMapOutputWithContext(ctx context.Context) KafkaInstanceMapOutput

type KafkaInstanceMapInput 

type KafkaInstanceMapInput interface {
	pulumi.Input

	ToKafkaInstanceMapOutput() KafkaInstanceMapOutput
	ToKafkaInstanceMapOutputWithContext(context.Context) KafkaInstanceMapOutput
}

KafkaInstanceMapInput is an input type that accepts KafkaInstanceMap and KafkaInstanceMapOutput values. You can construct a concrete instance of `KafkaInstanceMapInput` via: 

KafkaInstanceMap{ "key": KafkaInstanceArgs{...} }

type KafkaInstanceMapOutput 

type KafkaInstanceMapOutput struct{ *pulumi.OutputState }

func (KafkaInstanceMapOutput) ElementType 

func (KafkaInstanceMapOutput) ElementType() reflect.Type

func (KafkaInstanceMapOutput) MapIndex 

func (o KafkaInstanceMapOutput) MapIndex(k pulumi.StringInput) KafkaInstanceOutput

func (KafkaInstanceMapOutput) ToKafkaInstanceMapOutput 

func (o KafkaInstanceMapOutput) ToKafkaInstanceMapOutput() KafkaInstanceMapOutput

func (KafkaInstanceMapOutput) ToKafkaInstanceMapOutputWithContext 

func (o KafkaInstanceMapOutput) ToKafkaInstanceMapOutputWithContext(ctx context.Context) KafkaInstanceMapOutput

type KafkaInstanceOutput 

type KafkaInstanceOutput struct{ *pulumi.OutputState }

func (KafkaInstanceOutput) AccessUser 

func (o KafkaInstanceOutput) AccessUser() pulumi.StringPtrOutput

Specifies the username of SASL_SSL user. A username consists of 4 to 64 characters and supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.

func (KafkaInstanceOutput) AutoRenew added in v0.0.8 

func (o KafkaInstanceOutput) AutoRenew() pulumi.StringPtrOutput

Specifies whether auto renew is enabled. Valid values are "true" and "false".

func (KafkaInstanceOutput) AvailabilityZones 

func (o KafkaInstanceOutput) AvailabilityZones() pulumi.StringArrayOutput

The names of the AZ where the Kafka instances reside. The parameter value can not be left blank or an empty array. Changing this creates a new instance resource.

func (KafkaInstanceOutput) AvailableZones deprecated 

func (o KafkaInstanceOutput) AvailableZones() pulumi.StringArrayOutput

Deprecated: available_zones has deprecated, please use "availability_zones" instead.

func (KafkaInstanceOutput) Bandwidth deprecated 

func (o KafkaInstanceOutput) Bandwidth() pulumi.StringOutput

Deprecated: The bandwidth has been deprecated. If you need to change the bandwidth, please update the product_id.

func (KafkaInstanceOutput) BrokerNum 

func (o KafkaInstanceOutput) BrokerNum() pulumi.IntOutput

Specifies the broker numbers. It is required when creating an instance with `flavorId`.

func (KafkaInstanceOutput) ChargingMode added in v0.0.8 

func (o KafkaInstanceOutput) ChargingMode() pulumi.StringOutput

Specifies the charging mode of the instance. Valid values are *prePaid* and *postPaid*, defaults to *postPaid*. Changing this creates a new resource.

func (KafkaInstanceOutput) ConnectAddress 

func (o KafkaInstanceOutput) ConnectAddress() pulumi.StringOutput

Indicates the IP address of the DMS Kafka instance.

func (KafkaInstanceOutput) CrossVpcAccesses 

func (o KafkaInstanceOutput) CrossVpcAccesses() KafkaInstanceCrossVpcAccessArrayOutput

Specifies the cross-VPC access information. The object structure is documented below.

func (KafkaInstanceOutput) Description 

func (o KafkaInstanceOutput) Description() pulumi.StringPtrOutput

Specifies the description of the DMS Kafka instance. It is a character string containing not more than 1,024 characters.

func (KafkaInstanceOutput) Dumping 

func (o KafkaInstanceOutput) Dumping() pulumi.BoolOutput

Specifies whether to enable message dumping. Changing this creates a new instance resource.

func (KafkaInstanceOutput) ElementType 

func (KafkaInstanceOutput) ElementType() reflect.Type

func (KafkaInstanceOutput) EnableAutoTopic 

func (o KafkaInstanceOutput) EnableAutoTopic() pulumi.BoolOutput

Specifies whether to enable automatic topic creation. If automatic topic creation is enabled, a topic will be automatically created with 3 partitions and 3 replicas when a message is produced to or consumed from a topic that does not exist. The default value is false. Changing this creates a new instance resource.

func (KafkaInstanceOutput) EnablePublicIp 

func (o KafkaInstanceOutput) EnablePublicIp() pulumi.BoolOutput

Indicates whether public access to the DMS Kafka instance is enabled.

func (KafkaInstanceOutput) Engine 

func (o KafkaInstanceOutput) Engine() pulumi.StringOutput

Indicates the message engine.

func (KafkaInstanceOutput) EngineVersion 

func (o KafkaInstanceOutput) EngineVersion() pulumi.StringOutput

Specifies the version of the Kafka engine, such as 1.1.0, 2.3.0, 2.7 or other supported versions. Changing this creates a new instance resource.

func (KafkaInstanceOutput) EnterpriseProjectId 

func (o KafkaInstanceOutput) EnterpriseProjectId() pulumi.StringOutput

Specifies the enterprise project ID of the Kafka instance.

func (KafkaInstanceOutput) FlavorId 

func (o KafkaInstanceOutput) FlavorId() pulumi.StringPtrOutput

Specifies the Kafka [flavor ID](https://support.huaweicloud.com/intl/en-us/productdesc-kafka/Kafka-specification.html), e.g. **c6.2u4g.cluster**. This parameter and `productId` are alternative.

func (KafkaInstanceOutput) MaintainBegin 

func (o KafkaInstanceOutput) MaintainBegin() pulumi.StringOutput

Specifies the time at which a maintenance time window starts. Format: HH:mm. The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time window. The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin` and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also blank. In this case, the system automatically allocates the default start time 02:00.

func (KafkaInstanceOutput) MaintainEnd 

func (o KafkaInstanceOutput) MaintainEnd() pulumi.StringOutput

Specifies the time at which a maintenance time window ends. Format: HH:mm. The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time window. The end time is four hours later than the start time. For example, if the start time is 22:00, the end time is 02:00. Parameters `maintainBegin` and `maintainEnd` must be set in pairs. If parameter `maintainEnd` is left blank, parameter `maintainBegin` is also blank. In this case, the system automatically allocates the default end time 06:00.

func (KafkaInstanceOutput) ManagementConnectAddress added in v0.0.8 

func (o KafkaInstanceOutput) ManagementConnectAddress() pulumi.StringOutput

Indicates the Kafka Manager connection address of a Kafka instance.

func (KafkaInstanceOutput) ManagerPassword 

func (o KafkaInstanceOutput) ManagerPassword() pulumi.StringOutput

Specifies the password for logging in to the Kafka Manager. The password must meet the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following character types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_ =+\\|[{}]:'",<.>/?). Changing this creates a new instance resource.

func (KafkaInstanceOutput) ManagerUser 

func (o KafkaInstanceOutput) ManagerUser() pulumi.StringOutput

Specifies the username for logging in to the Kafka Manager. The username consists of 4 to 64 characters and can contain letters, digits, hyphens (-), and underscores (_). Changing this creates a new instance resource.

func (KafkaInstanceOutput) ManegementConnectAddress deprecated 

func (o KafkaInstanceOutput) ManegementConnectAddress() pulumi.StringOutput

Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.

func (KafkaInstanceOutput) Name 

func (o KafkaInstanceOutput) Name() pulumi.StringOutput

Specifies the name of the DMS Kafka instance. An instance name starts with a letter, consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).

func (KafkaInstanceOutput) NetworkId 

func (o KafkaInstanceOutput) NetworkId() pulumi.StringOutput

Specifies the ID of a subnet. Changing this creates a new instance resource.

func (KafkaInstanceOutput) PartitionNum 

func (o KafkaInstanceOutput) PartitionNum() pulumi.IntOutput

Indicates the number of partitions in Kafka instance.

func (KafkaInstanceOutput) Password 

func (o KafkaInstanceOutput) Password() pulumi.StringPtrOutput

Specifies the password of SASL_SSL user. A password must meet the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following character types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?). Changing this creates a new instance resource.

func (KafkaInstanceOutput) Period added in v0.0.8 

func (o KafkaInstanceOutput) Period() pulumi.IntPtrOutput

Specifies the charging period of the instance. If `periodUnit` is set to *month* , the value ranges from 1 to 9. If `periodUnit` is set to *year*, the value ranges from 1 to 3. This parameter is mandatory if `chargingMode` is set to *prePaid*. Changing this creates a new resource.

func (KafkaInstanceOutput) PeriodUnit added in v0.0.8 

func (o KafkaInstanceOutput) PeriodUnit() pulumi.StringPtrOutput

Specifies the charging period unit of the instance. Valid values are *month* and *year*. This parameter is mandatory if `chargingMode` is set to *prePaid*. Changing this creates a new resource.

func (KafkaInstanceOutput) Port 

func (o KafkaInstanceOutput) Port() pulumi.IntOutput

The port number.

func (KafkaInstanceOutput) ProductId 

func (o KafkaInstanceOutput) ProductId() pulumi.StringPtrOutput

Specifies a product ID, which includes bandwidth, partition, broker and default storage capacity.

func (KafkaInstanceOutput) PublicIpIds 

func (o KafkaInstanceOutput) PublicIpIds() pulumi.StringArrayOutput

Specifies the IDs of the elastic IP address (EIP) bound to the DMS Kafka instance. Changing this creates a new instance resource. + If the instance is created with `flavorId`, the total number of public IPs is equal to `brokerNum`. + If the instance is created with `productId`, the total number of public IPs must provide as follows:

func (KafkaInstanceOutput) Region 

func (o KafkaInstanceOutput) Region() pulumi.StringOutput

The region in which to create the DMS Kafka instances. If omitted, the provider-level region will be used. Changing this creates a new instance resource.

func (KafkaInstanceOutput) ResourceSpecCode 

func (o KafkaInstanceOutput) ResourceSpecCode() pulumi.StringOutput

Indicates a resource specifications identifier.

func (KafkaInstanceOutput) RetentionPolicy 

func (o KafkaInstanceOutput) RetentionPolicy() pulumi.StringOutput

Specifies the action to be taken when the memory usage reaches the disk capacity threshold. The valid values are as follows: + **time_base**: Automatically delete the earliest messages. + **produce_reject**: Stop producing new messages.

func (KafkaInstanceOutput) SecurityGroupId 

func (o KafkaInstanceOutput) SecurityGroupId() pulumi.StringOutput

Specifies the ID of a security group.

func (KafkaInstanceOutput) SslEnable 

func (o KafkaInstanceOutput) SslEnable() pulumi.BoolOutput

Indicates whether the Kafka SASL_SSL is enabled.

func (KafkaInstanceOutput) Status 

func (o KafkaInstanceOutput) Status() pulumi.StringOutput

Indicates the status of the DMS Kafka instance.

func (KafkaInstanceOutput) StorageSpace 

func (o KafkaInstanceOutput) StorageSpace() pulumi.IntOutput

Specifies the message storage capacity, the unit is GB. The storage spaces corresponding to the product IDs are as follows: + **c6.2u4g.cluster** (100MB bandwidth): `300` to `300,000` GB + **c6.4u8g.cluster** (300MB bandwidth): `300` to `600,000` GB + **c6.8u16g.cluster** (600MB bandwidth): `300` to `900,000` GB + **c6.12u12g.cluster**: `300` to `900,000` GB + **c6.16u32g.cluster** (1,200MB bandwidth): `300` to `900,000` GB

func (KafkaInstanceOutput) StorageSpecCode 

func (o KafkaInstanceOutput) StorageSpecCode() pulumi.StringOutput

Specifies the storage I/O specification. If the instance is created with `flavorId`, the valid values are as follows: + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O. + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.

func (KafkaInstanceOutput) Tags 

func (o KafkaInstanceOutput) Tags() pulumi.StringMapOutput

The key/value pairs to associate with the DMS Kafka instance.

func (KafkaInstanceOutput) ToKafkaInstanceOutput 

func (o KafkaInstanceOutput) ToKafkaInstanceOutput() KafkaInstanceOutput

func (KafkaInstanceOutput) ToKafkaInstanceOutputWithContext 

func (o KafkaInstanceOutput) ToKafkaInstanceOutputWithContext(ctx context.Context) KafkaInstanceOutput

func (KafkaInstanceOutput) Type 

func (o KafkaInstanceOutput) Type() pulumi.StringOutput

Indicates the DMS Kafka instance type.

func (KafkaInstanceOutput) UsedStorageSpace 

func (o KafkaInstanceOutput) UsedStorageSpace() pulumi.IntOutput

Indicates the used message storage space. Unit: GB

func (KafkaInstanceOutput) UserId 

func (o KafkaInstanceOutput) UserId() pulumi.StringOutput

Indicates the ID of the user who created the DMS Kafka instance

func (KafkaInstanceOutput) UserName 

func (o KafkaInstanceOutput) UserName() pulumi.StringOutput

Indicates the name of the user who created the DMS Kafka instance

func (KafkaInstanceOutput) VpcId 

func (o KafkaInstanceOutput) VpcId() pulumi.StringOutput

Specifies the ID of a VPC. Changing this creates a new instance resource.

type KafkaInstanceState 

type KafkaInstanceState struct {
	// Specifies the username of SASL_SSL user. A username consists of 4
	// to 64 characters and supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.
	AccessUser pulumi.StringPtrInput
	// Specifies whether auto renew is enabled. Valid values are "true" and "false".
	AutoRenew pulumi.StringPtrInput
	// The names of the AZ where the Kafka instances reside.
	// The parameter value can not be left blank or an empty array. Changing this creates a new instance resource.
	AvailabilityZones pulumi.StringArrayInput
	// Deprecated: available_zones has deprecated, please use "availability_zones" instead.
	AvailableZones pulumi.StringArrayInput
	// Deprecated: The bandwidth has been deprecated. If you need to change the bandwidth, please update the product_id.
	Bandwidth pulumi.StringPtrInput
	// Specifies the broker numbers.
	// It is required when creating an instance with `flavorId`.
	BrokerNum pulumi.IntPtrInput
	// Specifies the charging mode of the instance. Valid values are *prePaid*
	// and *postPaid*, defaults to *postPaid*. Changing this creates a new resource.
	ChargingMode pulumi.StringPtrInput
	// Indicates the IP address of the DMS Kafka instance.
	ConnectAddress pulumi.StringPtrInput
	// Specifies the cross-VPC access information.
	// The object structure is documented below.
	CrossVpcAccesses KafkaInstanceCrossVpcAccessArrayInput
	// Specifies the description of the DMS Kafka instance. It is a character string
	// containing not more than 1,024 characters.
	Description pulumi.StringPtrInput
	// Specifies whether to enable message dumping.
	// Changing this creates a new instance resource.
	Dumping pulumi.BoolPtrInput
	// Specifies whether to enable automatic topic creation. If automatic
	// topic creation is enabled, a topic will be automatically created with 3 partitions and 3 replicas when a message is
	// produced to or consumed from a topic that does not exist.
	// The default value is false.
	// Changing this creates a new instance resource.
	EnableAutoTopic pulumi.BoolPtrInput
	// Indicates whether public access to the DMS Kafka instance is enabled.
	EnablePublicIp pulumi.BoolPtrInput
	// Indicates the message engine.
	Engine pulumi.StringPtrInput
	// Specifies the version of the Kafka engine,
	// such as 1.1.0, 2.3.0, 2.7 or other supported versions. Changing this creates a new instance resource.
	EngineVersion pulumi.StringPtrInput
	// Specifies the enterprise project ID of the Kafka instance.
	EnterpriseProjectId pulumi.StringPtrInput
	// Specifies the Kafka [flavor ID](https://support.huaweicloud.com/intl/en-us/productdesc-kafka/Kafka-specification.html),
	// e.g. **c6.2u4g.cluster**. This parameter and `productId` are alternative.
	FlavorId pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window starts. Format: HH:mm. The
	// start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time
	// window. The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also
	// blank. In this case, the system automatically allocates the default start time 02:00.
	MaintainBegin pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window ends. Format: HH:mm. The
	// start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time
	// window. The end time is four hours later than the start time. For example, if the start time is 22:00, the end time is
	// 02:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainEnd` is left blank, parameter
	// `maintainBegin` is also blank. In this case, the system automatically allocates the default end time 06:00.
	MaintainEnd pulumi.StringPtrInput
	// Indicates the Kafka Manager connection address of a Kafka instance.
	ManagementConnectAddress pulumi.StringPtrInput
	// Specifies the password for logging in to the Kafka Manager. The
	// password must meet the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of
	// the following character types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_
	// =+\\|[{}]:'",<.>/?). Changing this creates a new instance resource.
	ManagerPassword pulumi.StringPtrInput
	// Specifies the username for logging in to the Kafka Manager. The username
	// consists of 4 to 64 characters and can contain letters, digits, hyphens (-), and underscores (_). Changing this
	// creates a new instance resource.
	ManagerUser pulumi.StringPtrInput
	// Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.
	ManegementConnectAddress pulumi.StringPtrInput
	// Specifies the name of the DMS Kafka instance. An instance name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	Name pulumi.StringPtrInput
	// Specifies the ID of a subnet. Changing this creates a new instance
	// resource.
	NetworkId pulumi.StringPtrInput
	// Indicates the number of partitions in Kafka instance.
	PartitionNum pulumi.IntPtrInput
	// Specifies the password of SASL_SSL user. A password must meet the
	// following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following character
	// types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?).
	// Changing this creates a new instance resource.
	Password pulumi.StringPtrInput
	// Specifies the charging period of the instance. If `periodUnit` is set to *month*
	// , the value ranges from 1 to 9. If `periodUnit` is set to *year*, the value ranges from 1 to 3. This parameter is
	// mandatory if `chargingMode` is set to *prePaid*. Changing this creates a new resource.
	Period pulumi.IntPtrInput
	// Specifies the charging period unit of the instance.
	// Valid values are *month* and *year*. This parameter is mandatory if `chargingMode` is set to *prePaid*.
	// Changing this creates a new resource.
	PeriodUnit pulumi.StringPtrInput
	// The port number.
	Port pulumi.IntPtrInput
	// Specifies a product ID, which includes bandwidth, partition, broker and default
	// storage capacity.
	ProductId pulumi.StringPtrInput
	// Specifies the IDs of the elastic IP address (EIP)
	// bound to the DMS Kafka instance. Changing this creates a new instance resource.
	// + If the instance is created with `flavorId`, the total number of public IPs is equal to `brokerNum`.
	// + If the instance is created with `productId`, the total number of public IPs must provide as follows:
	PublicIpIds pulumi.StringArrayInput
	// The region in which to create the DMS Kafka instances. If omitted, the
	// provider-level region will be used. Changing this creates a new instance resource.
	Region pulumi.StringPtrInput
	// Indicates a resource specifications identifier.
	ResourceSpecCode pulumi.StringPtrInput
	// Specifies the action to be taken when the memory usage reaches the disk
	// capacity threshold. The valid values are as follows:
	// + **time_base**: Automatically delete the earliest messages.
	// + **produce_reject**: Stop producing new messages.
	RetentionPolicy pulumi.StringPtrInput
	// Specifies the ID of a security group.
	SecurityGroupId pulumi.StringPtrInput
	// Indicates whether the Kafka SASL_SSL is enabled.
	SslEnable pulumi.BoolPtrInput
	// Indicates the status of the DMS Kafka instance.
	Status pulumi.StringPtrInput
	// Specifies the message storage capacity, the unit is GB.
	// The storage spaces corresponding to the product IDs are as follows:
	// + **c6.2u4g.cluster** (100MB bandwidth): `300` to `300,000` GB
	// + **c6.4u8g.cluster** (300MB bandwidth): `300` to `600,000` GB
	// + **c6.8u16g.cluster** (600MB bandwidth): `300` to `900,000` GB
	// + **c6.12u12g.cluster**: `300` to `900,000` GB
	// + **c6.16u32g.cluster** (1,200MB bandwidth): `300` to `900,000` GB
	StorageSpace pulumi.IntPtrInput
	// Specifies the storage I/O specification.
	// If the instance is created with `flavorId`, the valid values are as follows:
	// + **dms.physical.storage.high.v2**: Type of the disk that uses high I/O.
	// + **dms.physical.storage.ultra.v2**: Type of the disk that uses ultra-high I/O.
	StorageSpecCode pulumi.StringPtrInput
	// The key/value pairs to associate with the DMS Kafka instance.
	Tags pulumi.StringMapInput
	// Indicates the DMS Kafka instance type.
	Type pulumi.StringPtrInput
	// Indicates the used message storage space. Unit: GB
	UsedStorageSpace pulumi.IntPtrInput
	// Indicates the ID of the user who created the DMS Kafka instance
	UserId pulumi.StringPtrInput
	// Indicates the name of the user who created the DMS Kafka instance
	UserName pulumi.StringPtrInput
	// Specifies the ID of a VPC. Changing this creates a new instance resource.
	VpcId pulumi.StringPtrInput
}

func (KafkaInstanceState) ElementType 

func (KafkaInstanceState) ElementType() reflect.Type

type KafkaPermissions 

type KafkaPermissions struct {
	pulumi.CustomResourceState

	// Specifies the ID of the DMS kafka instance to which the permissions belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Specifies the permissions policies. The object structure is
	// documented below.
	Policies KafkaPermissionsPolicyArrayOutput `pulumi:"policies"`
	// The region in which to create the DMS kafka permissions resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringOutput `pulumi:"region"`
	// Specifies the name of the topic to which the permissions belongs.
	// Changing this creates a new resource.
	TopicName pulumi.StringOutput `pulumi:"topicName"`
}

Use the resource to grant user permissions of a kafka topic within HuaweiCloud.

## Example Usage

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		kafkaInstanceId := cfg.RequireObject("kafkaInstanceId")
		kafkaTopicName := cfg.RequireObject("kafkaTopicName")
		user1 := cfg.RequireObject("user1")
		user2 := cfg.RequireObject("user2")
		_, err := Dms.NewKafkaPermissions(ctx, "test", &Dms.KafkaPermissionsArgs{
			InstanceId: pulumi.Any(kafkaInstanceId),
			TopicName:  pulumi.Any(kafkaTopicName),
			Policies: dms.KafkaPermissionsPolicyArray{
				&dms.KafkaPermissionsPolicyArgs{
					UserName:     pulumi.Any(user1),
					AccessPolicy: pulumi.String("all"),
				},
				&dms.KafkaPermissionsPolicyArgs{
					UserName:     pulumi.Any(user2),
					AccessPolicy: pulumi.String("pub"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

DMS kafka permissions can be imported using the kafka instance ID and topic name separated by a slash, e.g.

```sh 

$ pulumi import huaweicloud:Dms/kafkaPermissions:KafkaPermissions permissions c8057fe5-23a8-46ef-ad83-c0055b4e0c5c/topic_1

```

func GetKafkaPermissions 

func GetKafkaPermissions(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaPermissionsState, opts ...pulumi.ResourceOption) (*KafkaPermissions, error)

GetKafkaPermissions gets an existing KafkaPermissions resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaPermissions 

func NewKafkaPermissions(ctx *pulumi.Context,
	name string, args *KafkaPermissionsArgs, opts ...pulumi.ResourceOption) (*KafkaPermissions, error)

NewKafkaPermissions registers a new resource with the given unique name, arguments, and options.

func (*KafkaPermissions) ElementType 

func (*KafkaPermissions) ElementType() reflect.Type

func (*KafkaPermissions) ToKafkaPermissionsOutput 

func (i *KafkaPermissions) ToKafkaPermissionsOutput() KafkaPermissionsOutput

func (*KafkaPermissions) ToKafkaPermissionsOutputWithContext 

func (i *KafkaPermissions) ToKafkaPermissionsOutputWithContext(ctx context.Context) KafkaPermissionsOutput

type KafkaPermissionsArgs 

type KafkaPermissionsArgs struct {
	// Specifies the ID of the DMS kafka instance to which the permissions belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringInput
	// Specifies the permissions policies. The object structure is
	// documented below.
	Policies KafkaPermissionsPolicyArrayInput
	// The region in which to create the DMS kafka permissions resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringPtrInput
	// Specifies the name of the topic to which the permissions belongs.
	// Changing this creates a new resource.
	TopicName pulumi.StringInput
}

The set of arguments for constructing a KafkaPermissions resource.

func (KafkaPermissionsArgs) ElementType 

func (KafkaPermissionsArgs) ElementType() reflect.Type

type KafkaPermissionsArray 

type KafkaPermissionsArray []KafkaPermissionsInput

func (KafkaPermissionsArray) ElementType 

func (KafkaPermissionsArray) ElementType() reflect.Type

func (KafkaPermissionsArray) ToKafkaPermissionsArrayOutput 

func (i KafkaPermissionsArray) ToKafkaPermissionsArrayOutput() KafkaPermissionsArrayOutput

func (KafkaPermissionsArray) ToKafkaPermissionsArrayOutputWithContext 

func (i KafkaPermissionsArray) ToKafkaPermissionsArrayOutputWithContext(ctx context.Context) KafkaPermissionsArrayOutput

type KafkaPermissionsArrayInput 

type KafkaPermissionsArrayInput interface {
	pulumi.Input

	ToKafkaPermissionsArrayOutput() KafkaPermissionsArrayOutput
	ToKafkaPermissionsArrayOutputWithContext(context.Context) KafkaPermissionsArrayOutput
}

KafkaPermissionsArrayInput is an input type that accepts KafkaPermissionsArray and KafkaPermissionsArrayOutput values. You can construct a concrete instance of `KafkaPermissionsArrayInput` via: 

KafkaPermissionsArray{ KafkaPermissionsArgs{...} }

type KafkaPermissionsArrayOutput 

type KafkaPermissionsArrayOutput struct{ *pulumi.OutputState }

func (KafkaPermissionsArrayOutput) ElementType 

func (KafkaPermissionsArrayOutput) ElementType() reflect.Type

func (KafkaPermissionsArrayOutput) Index 

func (o KafkaPermissionsArrayOutput) Index(i pulumi.IntInput) KafkaPermissionsOutput

func (KafkaPermissionsArrayOutput) ToKafkaPermissionsArrayOutput 

func (o KafkaPermissionsArrayOutput) ToKafkaPermissionsArrayOutput() KafkaPermissionsArrayOutput

func (KafkaPermissionsArrayOutput) ToKafkaPermissionsArrayOutputWithContext 

func (o KafkaPermissionsArrayOutput) ToKafkaPermissionsArrayOutputWithContext(ctx context.Context) KafkaPermissionsArrayOutput

type KafkaPermissionsInput 

type KafkaPermissionsInput interface {
	pulumi.Input

	ToKafkaPermissionsOutput() KafkaPermissionsOutput
	ToKafkaPermissionsOutputWithContext(ctx context.Context) KafkaPermissionsOutput
}

type KafkaPermissionsMap 

type KafkaPermissionsMap map[string]KafkaPermissionsInput

func (KafkaPermissionsMap) ElementType 

func (KafkaPermissionsMap) ElementType() reflect.Type

func (KafkaPermissionsMap) ToKafkaPermissionsMapOutput 

func (i KafkaPermissionsMap) ToKafkaPermissionsMapOutput() KafkaPermissionsMapOutput

func (KafkaPermissionsMap) ToKafkaPermissionsMapOutputWithContext 

func (i KafkaPermissionsMap) ToKafkaPermissionsMapOutputWithContext(ctx context.Context) KafkaPermissionsMapOutput

type KafkaPermissionsMapInput 

type KafkaPermissionsMapInput interface {
	pulumi.Input

	ToKafkaPermissionsMapOutput() KafkaPermissionsMapOutput
	ToKafkaPermissionsMapOutputWithContext(context.Context) KafkaPermissionsMapOutput
}

KafkaPermissionsMapInput is an input type that accepts KafkaPermissionsMap and KafkaPermissionsMapOutput values. You can construct a concrete instance of `KafkaPermissionsMapInput` via: 

KafkaPermissionsMap{ "key": KafkaPermissionsArgs{...} }

type KafkaPermissionsMapOutput 

type KafkaPermissionsMapOutput struct{ *pulumi.OutputState }

func (KafkaPermissionsMapOutput) ElementType 

func (KafkaPermissionsMapOutput) ElementType() reflect.Type

func (KafkaPermissionsMapOutput) MapIndex 

func (o KafkaPermissionsMapOutput) MapIndex(k pulumi.StringInput) KafkaPermissionsOutput

func (KafkaPermissionsMapOutput) ToKafkaPermissionsMapOutput 

func (o KafkaPermissionsMapOutput) ToKafkaPermissionsMapOutput() KafkaPermissionsMapOutput

func (KafkaPermissionsMapOutput) ToKafkaPermissionsMapOutputWithContext 

func (o KafkaPermissionsMapOutput) ToKafkaPermissionsMapOutputWithContext(ctx context.Context) KafkaPermissionsMapOutput

type KafkaPermissionsOutput 

type KafkaPermissionsOutput struct{ *pulumi.OutputState }

func (KafkaPermissionsOutput) ElementType 

func (KafkaPermissionsOutput) ElementType() reflect.Type

func (KafkaPermissionsOutput) InstanceId 

func (o KafkaPermissionsOutput) InstanceId() pulumi.StringOutput

Specifies the ID of the DMS kafka instance to which the permissions belongs. Changing this creates a new resource.

func (KafkaPermissionsOutput) Policies 

func (o KafkaPermissionsOutput) Policies() KafkaPermissionsPolicyArrayOutput

Specifies the permissions policies. The object structure is documented below.

func (KafkaPermissionsOutput) Region 

func (o KafkaPermissionsOutput) Region() pulumi.StringOutput

The region in which to create the DMS kafka permissions resource. If omitted, the provider-level region will be used. Changing this creates a new resource.

func (KafkaPermissionsOutput) ToKafkaPermissionsOutput 

func (o KafkaPermissionsOutput) ToKafkaPermissionsOutput() KafkaPermissionsOutput

func (KafkaPermissionsOutput) ToKafkaPermissionsOutputWithContext 

func (o KafkaPermissionsOutput) ToKafkaPermissionsOutputWithContext(ctx context.Context) KafkaPermissionsOutput

func (KafkaPermissionsOutput) TopicName 

func (o KafkaPermissionsOutput) TopicName() pulumi.StringOutput

Specifies the name of the topic to which the permissions belongs. Changing this creates a new resource.

type KafkaPermissionsPolicy 

type KafkaPermissionsPolicy struct {
	// Specifies the permissions type. The value can be:
	// + **all**: publish and subscribe permissions.
	// + **pub**: publish permissions.
	// + **sub**: subscribe permissions.
	AccessPolicy string `pulumi:"accessPolicy"`
	// Specifies the username.
	UserName string `pulumi:"userName"`
}

type KafkaPermissionsPolicyArgs 

type KafkaPermissionsPolicyArgs struct {
	// Specifies the permissions type. The value can be:
	// + **all**: publish and subscribe permissions.
	// + **pub**: publish permissions.
	// + **sub**: subscribe permissions.
	AccessPolicy pulumi.StringInput `pulumi:"accessPolicy"`
	// Specifies the username.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (KafkaPermissionsPolicyArgs) ElementType 

func (KafkaPermissionsPolicyArgs) ElementType() reflect.Type

func (KafkaPermissionsPolicyArgs) ToKafkaPermissionsPolicyOutput 

func (i KafkaPermissionsPolicyArgs) ToKafkaPermissionsPolicyOutput() KafkaPermissionsPolicyOutput

func (KafkaPermissionsPolicyArgs) ToKafkaPermissionsPolicyOutputWithContext 

func (i KafkaPermissionsPolicyArgs) ToKafkaPermissionsPolicyOutputWithContext(ctx context.Context) KafkaPermissionsPolicyOutput

type KafkaPermissionsPolicyArray 

type KafkaPermissionsPolicyArray []KafkaPermissionsPolicyInput

func (KafkaPermissionsPolicyArray) ElementType 

func (KafkaPermissionsPolicyArray) ElementType() reflect.Type

func (KafkaPermissionsPolicyArray) ToKafkaPermissionsPolicyArrayOutput 

func (i KafkaPermissionsPolicyArray) ToKafkaPermissionsPolicyArrayOutput() KafkaPermissionsPolicyArrayOutput

func (KafkaPermissionsPolicyArray) ToKafkaPermissionsPolicyArrayOutputWithContext 

func (i KafkaPermissionsPolicyArray) ToKafkaPermissionsPolicyArrayOutputWithContext(ctx context.Context) KafkaPermissionsPolicyArrayOutput

type KafkaPermissionsPolicyArrayInput 

type KafkaPermissionsPolicyArrayInput interface {
	pulumi.Input

	ToKafkaPermissionsPolicyArrayOutput() KafkaPermissionsPolicyArrayOutput
	ToKafkaPermissionsPolicyArrayOutputWithContext(context.Context) KafkaPermissionsPolicyArrayOutput
}

KafkaPermissionsPolicyArrayInput is an input type that accepts KafkaPermissionsPolicyArray and KafkaPermissionsPolicyArrayOutput values. You can construct a concrete instance of `KafkaPermissionsPolicyArrayInput` via: 

KafkaPermissionsPolicyArray{ KafkaPermissionsPolicyArgs{...} }

type KafkaPermissionsPolicyArrayOutput 

type KafkaPermissionsPolicyArrayOutput struct{ *pulumi.OutputState }

func (KafkaPermissionsPolicyArrayOutput) ElementType 

func (KafkaPermissionsPolicyArrayOutput) ElementType() reflect.Type

func (KafkaPermissionsPolicyArrayOutput) Index 

func (o KafkaPermissionsPolicyArrayOutput) Index(i pulumi.IntInput) KafkaPermissionsPolicyOutput

func (KafkaPermissionsPolicyArrayOutput) ToKafkaPermissionsPolicyArrayOutput 

func (o KafkaPermissionsPolicyArrayOutput) ToKafkaPermissionsPolicyArrayOutput() KafkaPermissionsPolicyArrayOutput

func (KafkaPermissionsPolicyArrayOutput) ToKafkaPermissionsPolicyArrayOutputWithContext 

func (o KafkaPermissionsPolicyArrayOutput) ToKafkaPermissionsPolicyArrayOutputWithContext(ctx context.Context) KafkaPermissionsPolicyArrayOutput

type KafkaPermissionsPolicyInput 

type KafkaPermissionsPolicyInput interface {
	pulumi.Input

	ToKafkaPermissionsPolicyOutput() KafkaPermissionsPolicyOutput
	ToKafkaPermissionsPolicyOutputWithContext(context.Context) KafkaPermissionsPolicyOutput
}

KafkaPermissionsPolicyInput is an input type that accepts KafkaPermissionsPolicyArgs and KafkaPermissionsPolicyOutput values. You can construct a concrete instance of `KafkaPermissionsPolicyInput` via: 

KafkaPermissionsPolicyArgs{...}

type KafkaPermissionsPolicyOutput 

type KafkaPermissionsPolicyOutput struct{ *pulumi.OutputState }

func (KafkaPermissionsPolicyOutput) AccessPolicy 

func (o KafkaPermissionsPolicyOutput) AccessPolicy() pulumi.StringOutput

Specifies the permissions type. The value can be: + **all**: publish and subscribe permissions. + **pub**: publish permissions. + **sub**: subscribe permissions.

func (KafkaPermissionsPolicyOutput) ElementType 

func (KafkaPermissionsPolicyOutput) ElementType() reflect.Type

func (KafkaPermissionsPolicyOutput) ToKafkaPermissionsPolicyOutput 

func (o KafkaPermissionsPolicyOutput) ToKafkaPermissionsPolicyOutput() KafkaPermissionsPolicyOutput

func (KafkaPermissionsPolicyOutput) ToKafkaPermissionsPolicyOutputWithContext 

func (o KafkaPermissionsPolicyOutput) ToKafkaPermissionsPolicyOutputWithContext(ctx context.Context) KafkaPermissionsPolicyOutput

func (KafkaPermissionsPolicyOutput) UserName 

func (o KafkaPermissionsPolicyOutput) UserName() pulumi.StringOutput

Specifies the username.

type KafkaPermissionsState 

type KafkaPermissionsState struct {
	// Specifies the ID of the DMS kafka instance to which the permissions belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringPtrInput
	// Specifies the permissions policies. The object structure is
	// documented below.
	Policies KafkaPermissionsPolicyArrayInput
	// The region in which to create the DMS kafka permissions resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringPtrInput
	// Specifies the name of the topic to which the permissions belongs.
	// Changing this creates a new resource.
	TopicName pulumi.StringPtrInput
}

func (KafkaPermissionsState) ElementType 

func (KafkaPermissionsState) ElementType() reflect.Type

type KafkaTopic 

type KafkaTopic struct {
	pulumi.CustomResourceState

	// Specifies the aging time in hours. The value ranges from 1 to 168 and defaults to 72.
	AgingTime pulumi.IntOutput `pulumi:"agingTime"`
	// Specifies the ID of the DMS kafka instance to which the topic belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Specifies the name of the topic. The name starts with a letter, consists of 4 to
	// 64 characters, and supports only letters, digits, hyphens (-) and underscores (_). Changing this creates a new
	// resource.
	Name pulumi.StringOutput `pulumi:"name"`
	// Specifies the partition number. The value ranges from 1 to 100.
	Partitions pulumi.IntOutput `pulumi:"partitions"`
	// The region in which to create the DMS kafka topic resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringOutput `pulumi:"region"`
	// Specifies the replica number. The value ranges from 1 to 3 and defaults to 3.
	// Changing this creates a new resource.
	Replicas pulumi.IntOutput `pulumi:"replicas"`
	// Whether or not to enable synchronous flushing.
	SyncFlushing pulumi.BoolOutput `pulumi:"syncFlushing"`
	// Whether or not to enable synchronous replication.
	SyncReplication pulumi.BoolOutput `pulumi:"syncReplication"`
}

Manages a DMS kafka topic resource within HuaweiCloud.

## Example Usage

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		kafkaInstanceId := cfg.RequireObject("kafkaInstanceId")
		_, err := Dms.NewKafkaTopic(ctx, "topic", &Dms.KafkaTopicArgs{
			InstanceId: pulumi.Any(kafkaInstanceId),
			Partitions: pulumi.Int(20),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

DMS kafka topics can be imported using the kafka instance ID and topic name separated by a slash, e.g.

```sh 

$ pulumi import huaweicloud:Dms/kafkaTopic:KafkaTopic topic c8057fe5-23a8-46ef-ad83-c0055b4e0c5c/topic_1

```

func GetKafkaTopic 

func GetKafkaTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaTopicState, opts ...pulumi.ResourceOption) (*KafkaTopic, error)

GetKafkaTopic gets an existing KafkaTopic resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaTopic 

func NewKafkaTopic(ctx *pulumi.Context,
	name string, args *KafkaTopicArgs, opts ...pulumi.ResourceOption) (*KafkaTopic, error)

NewKafkaTopic registers a new resource with the given unique name, arguments, and options.

func (*KafkaTopic) ElementType 

func (*KafkaTopic) ElementType() reflect.Type

func (*KafkaTopic) ToKafkaTopicOutput 

func (i *KafkaTopic) ToKafkaTopicOutput() KafkaTopicOutput

func (*KafkaTopic) ToKafkaTopicOutputWithContext 

func (i *KafkaTopic) ToKafkaTopicOutputWithContext(ctx context.Context) KafkaTopicOutput

type KafkaTopicArgs 

type KafkaTopicArgs struct {
	// Specifies the aging time in hours. The value ranges from 1 to 168 and defaults to 72.
	AgingTime pulumi.IntPtrInput
	// Specifies the ID of the DMS kafka instance to which the topic belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringInput
	// Specifies the name of the topic. The name starts with a letter, consists of 4 to
	// 64 characters, and supports only letters, digits, hyphens (-) and underscores (_). Changing this creates a new
	// resource.
	Name pulumi.StringPtrInput
	// Specifies the partition number. The value ranges from 1 to 100.
	Partitions pulumi.IntInput
	// The region in which to create the DMS kafka topic resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringPtrInput
	// Specifies the replica number. The value ranges from 1 to 3 and defaults to 3.
	// Changing this creates a new resource.
	Replicas pulumi.IntPtrInput
	// Whether or not to enable synchronous flushing.
	SyncFlushing pulumi.BoolPtrInput
	// Whether or not to enable synchronous replication.
	SyncReplication pulumi.BoolPtrInput
}

The set of arguments for constructing a KafkaTopic resource.

func (KafkaTopicArgs) ElementType 

func (KafkaTopicArgs) ElementType() reflect.Type

type KafkaTopicArray 

type KafkaTopicArray []KafkaTopicInput

func (KafkaTopicArray) ElementType 

func (KafkaTopicArray) ElementType() reflect.Type

func (KafkaTopicArray) ToKafkaTopicArrayOutput 

func (i KafkaTopicArray) ToKafkaTopicArrayOutput() KafkaTopicArrayOutput

func (KafkaTopicArray) ToKafkaTopicArrayOutputWithContext 

func (i KafkaTopicArray) ToKafkaTopicArrayOutputWithContext(ctx context.Context) KafkaTopicArrayOutput

type KafkaTopicArrayInput 

type KafkaTopicArrayInput interface {
	pulumi.Input

	ToKafkaTopicArrayOutput() KafkaTopicArrayOutput
	ToKafkaTopicArrayOutputWithContext(context.Context) KafkaTopicArrayOutput
}

KafkaTopicArrayInput is an input type that accepts KafkaTopicArray and KafkaTopicArrayOutput values. You can construct a concrete instance of `KafkaTopicArrayInput` via: 

KafkaTopicArray{ KafkaTopicArgs{...} }

type KafkaTopicArrayOutput 

type KafkaTopicArrayOutput struct{ *pulumi.OutputState }

func (KafkaTopicArrayOutput) ElementType 

func (KafkaTopicArrayOutput) ElementType() reflect.Type

func (KafkaTopicArrayOutput) Index 

func (o KafkaTopicArrayOutput) Index(i pulumi.IntInput) KafkaTopicOutput

func (KafkaTopicArrayOutput) ToKafkaTopicArrayOutput 

func (o KafkaTopicArrayOutput) ToKafkaTopicArrayOutput() KafkaTopicArrayOutput

func (KafkaTopicArrayOutput) ToKafkaTopicArrayOutputWithContext 

func (o KafkaTopicArrayOutput) ToKafkaTopicArrayOutputWithContext(ctx context.Context) KafkaTopicArrayOutput

type KafkaTopicInput 

type KafkaTopicInput interface {
	pulumi.Input

	ToKafkaTopicOutput() KafkaTopicOutput
	ToKafkaTopicOutputWithContext(ctx context.Context) KafkaTopicOutput
}

type KafkaTopicMap 

type KafkaTopicMap map[string]KafkaTopicInput

func (KafkaTopicMap) ElementType 

func (KafkaTopicMap) ElementType() reflect.Type

func (KafkaTopicMap) ToKafkaTopicMapOutput 

func (i KafkaTopicMap) ToKafkaTopicMapOutput() KafkaTopicMapOutput

func (KafkaTopicMap) ToKafkaTopicMapOutputWithContext 

func (i KafkaTopicMap) ToKafkaTopicMapOutputWithContext(ctx context.Context) KafkaTopicMapOutput

type KafkaTopicMapInput 

type KafkaTopicMapInput interface {
	pulumi.Input

	ToKafkaTopicMapOutput() KafkaTopicMapOutput
	ToKafkaTopicMapOutputWithContext(context.Context) KafkaTopicMapOutput
}

KafkaTopicMapInput is an input type that accepts KafkaTopicMap and KafkaTopicMapOutput values. You can construct a concrete instance of `KafkaTopicMapInput` via: 

KafkaTopicMap{ "key": KafkaTopicArgs{...} }

type KafkaTopicMapOutput 

type KafkaTopicMapOutput struct{ *pulumi.OutputState }

func (KafkaTopicMapOutput) ElementType 

func (KafkaTopicMapOutput) ElementType() reflect.Type

func (KafkaTopicMapOutput) MapIndex 

func (o KafkaTopicMapOutput) MapIndex(k pulumi.StringInput) KafkaTopicOutput

func (KafkaTopicMapOutput) ToKafkaTopicMapOutput 

func (o KafkaTopicMapOutput) ToKafkaTopicMapOutput() KafkaTopicMapOutput

func (KafkaTopicMapOutput) ToKafkaTopicMapOutputWithContext 

func (o KafkaTopicMapOutput) ToKafkaTopicMapOutputWithContext(ctx context.Context) KafkaTopicMapOutput

type KafkaTopicOutput 

type KafkaTopicOutput struct{ *pulumi.OutputState }

func (KafkaTopicOutput) AgingTime 

func (o KafkaTopicOutput) AgingTime() pulumi.IntOutput

Specifies the aging time in hours. The value ranges from 1 to 168 and defaults to 72.

func (KafkaTopicOutput) ElementType 

func (KafkaTopicOutput) ElementType() reflect.Type

func (KafkaTopicOutput) InstanceId 

func (o KafkaTopicOutput) InstanceId() pulumi.StringOutput

Specifies the ID of the DMS kafka instance to which the topic belongs. Changing this creates a new resource.

func (KafkaTopicOutput) Name 

func (o KafkaTopicOutput) Name() pulumi.StringOutput

Specifies the name of the topic. The name starts with a letter, consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_). Changing this creates a new resource.

func (KafkaTopicOutput) Partitions 

func (o KafkaTopicOutput) Partitions() pulumi.IntOutput

Specifies the partition number. The value ranges from 1 to 100.

func (KafkaTopicOutput) Region 

func (o KafkaTopicOutput) Region() pulumi.StringOutput

The region in which to create the DMS kafka topic resource. If omitted, the provider-level region will be used. Changing this creates a new resource.

func (KafkaTopicOutput) Replicas 

func (o KafkaTopicOutput) Replicas() pulumi.IntOutput

Specifies the replica number. The value ranges from 1 to 3 and defaults to 3. Changing this creates a new resource.

func (KafkaTopicOutput) SyncFlushing 

func (o KafkaTopicOutput) SyncFlushing() pulumi.BoolOutput

Whether or not to enable synchronous flushing.

func (KafkaTopicOutput) SyncReplication 

func (o KafkaTopicOutput) SyncReplication() pulumi.BoolOutput

Whether or not to enable synchronous replication.

func (KafkaTopicOutput) ToKafkaTopicOutput 

func (o KafkaTopicOutput) ToKafkaTopicOutput() KafkaTopicOutput

func (KafkaTopicOutput) ToKafkaTopicOutputWithContext 

func (o KafkaTopicOutput) ToKafkaTopicOutputWithContext(ctx context.Context) KafkaTopicOutput

type KafkaTopicState 

type KafkaTopicState struct {
	// Specifies the aging time in hours. The value ranges from 1 to 168 and defaults to 72.
	AgingTime pulumi.IntPtrInput
	// Specifies the ID of the DMS kafka instance to which the topic belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringPtrInput
	// Specifies the name of the topic. The name starts with a letter, consists of 4 to
	// 64 characters, and supports only letters, digits, hyphens (-) and underscores (_). Changing this creates a new
	// resource.
	Name pulumi.StringPtrInput
	// Specifies the partition number. The value ranges from 1 to 100.
	Partitions pulumi.IntPtrInput
	// The region in which to create the DMS kafka topic resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringPtrInput
	// Specifies the replica number. The value ranges from 1 to 3 and defaults to 3.
	// Changing this creates a new resource.
	Replicas pulumi.IntPtrInput
	// Whether or not to enable synchronous flushing.
	SyncFlushing pulumi.BoolPtrInput
	// Whether or not to enable synchronous replication.
	SyncReplication pulumi.BoolPtrInput
}

func (KafkaTopicState) ElementType 

func (KafkaTopicState) ElementType() reflect.Type

type KafkaUser 

type KafkaUser struct {
	pulumi.CustomResourceState

	// Specifies the ID of the DMS kafka instance to which the user belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Specifies the name of the user. Changing this creates a new resource.
	Name pulumi.StringOutput `pulumi:"name"`
	// Specifies the password of the user. The parameter must be 8 to 32 characters
	// long and contain only letters(case-sensitive), digits, and special characters(`~!@#$%^&*()-_=+|[{}]:'",<.>/?).
	// The value must be different from name.
	Password pulumi.StringOutput `pulumi:"password"`
	// The region in which to create the DMS kafka user resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringOutput `pulumi:"region"`
}

Manages a DMS kafka user resource within HuaweiCloud.

## Example Usage

```go package main

import ( 

"github.com/huaweicloud/pulumi-huaweicloud/sdk/go/huaweicloud/Dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		kafkaInstanceId := cfg.RequireObject("kafkaInstanceId")
		_, err := Dms.NewKafkaUser(ctx, "user", &Dms.KafkaUserArgs{
			InstanceId: pulumi.Any(kafkaInstanceId),
			Password:   pulumi.String("Test@123"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

DMS kafka users can be imported using the kafka instance ID and user name separated by a slash, e.g.

```sh 

$ pulumi import huaweicloud:Dms/kafkaUser:KafkaUser user c8057fe5-23a8-46ef-ad83-c0055b4e0c5c/user_1

```

func GetKafkaUser 

func GetKafkaUser(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *KafkaUserState, opts ...pulumi.ResourceOption) (*KafkaUser, error)

GetKafkaUser gets an existing KafkaUser resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewKafkaUser 

func NewKafkaUser(ctx *pulumi.Context,
	name string, args *KafkaUserArgs, opts ...pulumi.ResourceOption) (*KafkaUser, error)

NewKafkaUser registers a new resource with the given unique name, arguments, and options.

func (*KafkaUser) ElementType 

func (*KafkaUser) ElementType() reflect.Type

func (*KafkaUser) ToKafkaUserOutput 

func (i *KafkaUser) ToKafkaUserOutput() KafkaUserOutput

func (*KafkaUser) ToKafkaUserOutputWithContext 

func (i *KafkaUser) ToKafkaUserOutputWithContext(ctx context.Context) KafkaUserOutput

type KafkaUserArgs 

type KafkaUserArgs struct {
	// Specifies the ID of the DMS kafka instance to which the user belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringInput
	// Specifies the name of the user. Changing this creates a new resource.
	Name pulumi.StringPtrInput
	// Specifies the password of the user. The parameter must be 8 to 32 characters
	// long and contain only letters(case-sensitive), digits, and special characters(`~!@#$%^&*()-_=+|[{}]:'",<.>/?).
	// The value must be different from name.
	Password pulumi.StringInput
	// The region in which to create the DMS kafka user resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringPtrInput
}

The set of arguments for constructing a KafkaUser resource.

func (KafkaUserArgs) ElementType 

func (KafkaUserArgs) ElementType() reflect.Type

type KafkaUserArray 

type KafkaUserArray []KafkaUserInput

func (KafkaUserArray) ElementType 

func (KafkaUserArray) ElementType() reflect.Type

func (KafkaUserArray) ToKafkaUserArrayOutput 

func (i KafkaUserArray) ToKafkaUserArrayOutput() KafkaUserArrayOutput

func (KafkaUserArray) ToKafkaUserArrayOutputWithContext 

func (i KafkaUserArray) ToKafkaUserArrayOutputWithContext(ctx context.Context) KafkaUserArrayOutput

type KafkaUserArrayInput 

type KafkaUserArrayInput interface {
	pulumi.Input

	ToKafkaUserArrayOutput() KafkaUserArrayOutput
	ToKafkaUserArrayOutputWithContext(context.Context) KafkaUserArrayOutput
}

KafkaUserArrayInput is an input type that accepts KafkaUserArray and KafkaUserArrayOutput values. You can construct a concrete instance of `KafkaUserArrayInput` via: 

KafkaUserArray{ KafkaUserArgs{...} }

type KafkaUserArrayOutput 

type KafkaUserArrayOutput struct{ *pulumi.OutputState }

func (KafkaUserArrayOutput) ElementType 

func (KafkaUserArrayOutput) ElementType() reflect.Type

func (KafkaUserArrayOutput) Index 

func (o KafkaUserArrayOutput) Index(i pulumi.IntInput) KafkaUserOutput

func (KafkaUserArrayOutput) ToKafkaUserArrayOutput 

func (o KafkaUserArrayOutput) ToKafkaUserArrayOutput() KafkaUserArrayOutput

func (KafkaUserArrayOutput) ToKafkaUserArrayOutputWithContext 

func (o KafkaUserArrayOutput) ToKafkaUserArrayOutputWithContext(ctx context.Context) KafkaUserArrayOutput

type KafkaUserInput 

type KafkaUserInput interface {
	pulumi.Input

	ToKafkaUserOutput() KafkaUserOutput
	ToKafkaUserOutputWithContext(ctx context.Context) KafkaUserOutput
}

type KafkaUserMap 

type KafkaUserMap map[string]KafkaUserInput

func (KafkaUserMap) ElementType 

func (KafkaUserMap) ElementType() reflect.Type

func (KafkaUserMap) ToKafkaUserMapOutput 

func (i KafkaUserMap) ToKafkaUserMapOutput() KafkaUserMapOutput

func (KafkaUserMap) ToKafkaUserMapOutputWithContext 

func (i KafkaUserMap) ToKafkaUserMapOutputWithContext(ctx context.Context) KafkaUserMapOutput

type KafkaUserMapInput 

type KafkaUserMapInput interface {
	pulumi.Input

	ToKafkaUserMapOutput() KafkaUserMapOutput
	ToKafkaUserMapOutputWithContext(context.Context) KafkaUserMapOutput
}

KafkaUserMapInput is an input type that accepts KafkaUserMap and KafkaUserMapOutput values. You can construct a concrete instance of `KafkaUserMapInput` via: 

KafkaUserMap{ "key": KafkaUserArgs{...} }

type KafkaUserMapOutput 

type KafkaUserMapOutput struct{ *pulumi.OutputState }

func (KafkaUserMapOutput) ElementType 

func (KafkaUserMapOutput) ElementType() reflect.Type

func (KafkaUserMapOutput) MapIndex 

func (o KafkaUserMapOutput) MapIndex(k pulumi.StringInput) KafkaUserOutput

func (KafkaUserMapOutput) ToKafkaUserMapOutput 

func (o KafkaUserMapOutput) ToKafkaUserMapOutput() KafkaUserMapOutput

func (KafkaUserMapOutput) ToKafkaUserMapOutputWithContext 

func (o KafkaUserMapOutput) ToKafkaUserMapOutputWithContext(ctx context.Context) KafkaUserMapOutput

type KafkaUserOutput 

type KafkaUserOutput struct{ *pulumi.OutputState }

func (KafkaUserOutput) ElementType 

func (KafkaUserOutput) ElementType() reflect.Type

func (KafkaUserOutput) InstanceId 

func (o KafkaUserOutput) InstanceId() pulumi.StringOutput

Specifies the ID of the DMS kafka instance to which the user belongs. Changing this creates a new resource.

func (KafkaUserOutput) Name 

func (o KafkaUserOutput) Name() pulumi.StringOutput

Specifies the name of the user. Changing this creates a new resource.

func (KafkaUserOutput) Password 

func (o KafkaUserOutput) Password() pulumi.StringOutput

Specifies the password of the user. The parameter must be 8 to 32 characters long and contain only letters(case-sensitive), digits, and special characters(`~!@#$%^&*()-_=+|[{}]:'",<.>/?). The value must be different from name.

func (KafkaUserOutput) Region 

func (o KafkaUserOutput) Region() pulumi.StringOutput

The region in which to create the DMS kafka user resource. If omitted, the provider-level region will be used. Changing this creates a new resource.

func (KafkaUserOutput) ToKafkaUserOutput 

func (o KafkaUserOutput) ToKafkaUserOutput() KafkaUserOutput

func (KafkaUserOutput) ToKafkaUserOutputWithContext 

func (o KafkaUserOutput) ToKafkaUserOutputWithContext(ctx context.Context) KafkaUserOutput

type KafkaUserState 

type KafkaUserState struct {
	// Specifies the ID of the DMS kafka instance to which the user belongs.
	// Changing this creates a new resource.
	InstanceId pulumi.StringPtrInput
	// Specifies the name of the user. Changing this creates a new resource.
	Name pulumi.StringPtrInput
	// Specifies the password of the user. The parameter must be 8 to 32 characters
	// long and contain only letters(case-sensitive), digits, and special characters(`~!@#$%^&*()-_=+|[{}]:'",<.>/?).
	// The value must be different from name.
	Password pulumi.StringPtrInput
	// The region in which to create the DMS kafka user resource. If omitted, the
	// provider-level region will be used. Changing this creates a new resource.
	Region pulumi.StringPtrInput
}

func (KafkaUserState) ElementType 

func (KafkaUserState) ElementType() reflect.Type

type RabbitmqInstance 

type RabbitmqInstance struct {
	pulumi.CustomResourceState

	// Specifies a username. A username consists of 4 to 64 characters and
	// supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.
	AccessUser pulumi.StringOutput `pulumi:"accessUser"`
	// Specifies whether auto renew is enabled. Valid values are **true** and **false**.
	AutoRenew pulumi.StringPtrOutput `pulumi:"autoRenew"`
	// Specifies the names of an AZ.
	// The parameter value can not be left blank or an empty array.
	// Changing this creates a new instance resource.
	AvailabilityZones pulumi.StringArrayOutput `pulumi:"availabilityZones"`
	// Deprecated: available_zones has deprecated, please use "availability_zones" instead.
	AvailableZones pulumi.StringArrayOutput `pulumi:"availableZones"`
	// Specifies the broker numbers.
	// It is required when creating a cluster instance with `flavorId`.
	BrokerNum pulumi.IntOutput `pulumi:"brokerNum"`
	// Specifies the charging mode of the instance. Valid values are
	// **prePaid** and **postPaid**, defaults to **postPaid**. Changing this creates a new resource.
	ChargingMode pulumi.StringOutput `pulumi:"chargingMode"`
	// Indicates the IP address of the DMS RabbitMQ instance.
	ConnectAddress pulumi.StringOutput `pulumi:"connectAddress"`
	// Specifies the description of the DMS RabbitMQ instance.
	// It is a character string containing not more than 1,024 characters.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Indicates whether public access to the DMS RabbitMQ instance is enabled.
	EnablePublicIp pulumi.BoolOutput `pulumi:"enablePublicIp"`
	// Indicates the message engine.
	Engine pulumi.StringOutput `pulumi:"engine"`
	// Specifies the version of the RabbitMQ engine. Default to "3.7.17".
	// Changing this creates a new instance resource.
	EngineVersion pulumi.StringPtrOutput `pulumi:"engineVersion"`
	// Specifies the enterprise project ID of the RabbitMQ instance.
	EnterpriseProjectId pulumi.StringOutput `pulumi:"enterpriseProjectId"`
	// Specifies a flavor ID.
	// It is mandatory when the `chargingMode` is **prePaid**.
	FlavorId pulumi.StringPtrOutput `pulumi:"flavorId"`
	// Specifies the time at which a maintenance time window starts. Format: HH:mm.
	// The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance
	// time window.
	// The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also
	// blank. In this case, the system automatically allocates the default start time 02:00.
	MaintainBegin pulumi.StringOutput `pulumi:"maintainBegin"`
	// Specifies the time at which a maintenance time window ends. Format: HH:mm.
	// The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance
	// time window. The end time is four hours later than the start time.
	// For example, if the start time is 22:00, the end time is 02:00.
	// Parameters `maintainBegin` and `maintainEnd` must be set in pairs.
	// If parameter `maintainEnd` is left  blank, parameter `maintainBegin` is also blank.
	// In this case, the system automatically allocates the default end time 06:00.
	MaintainEnd pulumi.StringOutput `pulumi:"maintainEnd"`
	// Indicates the management address of the DMS RabbitMQ instance.
	ManagementConnectAddress pulumi.StringOutput `pulumi:"managementConnectAddress"`
	// Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.
	ManegementConnectAddress pulumi.StringOutput `pulumi:"manegementConnectAddress"`
	// Specifies the name of the DMS RabbitMQ instance. An instance name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	Name pulumi.StringOutput `pulumi:"name"`
	// Specifies the ID of a subnet. Changing this creates a new instance
	// resource.
	NetworkId pulumi.StringOutput `pulumi:"networkId"`
	// Specifies the password of the DMS RabbitMQ instance. A password must meet
	// the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following
	// character types: lowercase letters, uppercase letters, digits,
	// and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?).
	// Changing this creates a new instance resource.
	Password pulumi.StringOutput `pulumi:"password"`
	// Specifies the charging period of the instance. If `periodUnit` is set to
	// **month**, the value ranges from 1 to 9. If `periodUnit` is set to **year**, the value ranges from 1 to 3.
	// This parameter is mandatory if `chargingMode` is set to **prePaid**. Changing this creates a new resource.
	Period pulumi.IntPtrOutput `pulumi:"period"`
	// Specifies the charging period unit of the instance.
	// Valid values are **month** and **year**. This parameter is mandatory if `chargingMode` is set to **prePaid**.
	// Changing this creates a new resource.
	PeriodUnit pulumi.StringPtrOutput `pulumi:"periodUnit"`
	// Indicates the port number of the DMS RabbitMQ instance.
	Port pulumi.IntOutput `pulumi:"port"`
	// Deprecated: product_id has deprecated, please use "flavor_id" instead.
	ProductId pulumi.StringPtrOutput `pulumi:"productId"`
	// Specifies the ID of the elastic IP address (EIP)
	// bound to the DMS RabbitMQ instance.
	PublicIpId pulumi.StringPtrOutput `pulumi:"publicIpId"`
	// The region in which to create the DMS RabbitMQ instance resource. If omitted,
	// the provider-level region will be used. Changing this creates a new instance resource.
	Region pulumi.StringOutput `pulumi:"region"`
	// Indicates a resource specifications identifier.
	ResourceSpecCode pulumi.StringOutput `pulumi:"resourceSpecCode"`
	// Specifies the ID of a security group.
	SecurityGroupId pulumi.StringOutput `pulumi:"securityGroupId"`
	// Indicates the instance specification. For a single-node DMS RabbitMQ instance, VM specifications are
	// returned. For a cluster DMS RabbitMQ instance, VM specifications and the number of nodes are returned.
	Specification pulumi.StringOutput `pulumi:"specification"`
	// Specifies whether to enable public access for the DMS RabbitMQ instance.
	// Changing this creates a new instance resource.
	SslEnable pulumi.BoolPtrOutput `pulumi:"sslEnable"`
	// Indicates the status of the DMS RabbitMQ instance.
	Status pulumi.StringOutput `pulumi:"status"`
	// Specifies the message storage space, unit is GB.
	// It is required when creating a instance with `flavorId`. Value range:
	// + Single-node RabbitMQ instance: 100–90,000 GB
	// + Cluster RabbitMQ instance: 100 GB x number of nodes to 90,000 GB, 200 GB x number of nodes to 90,000 GB,
	//   and 300 GB x number of nodes to 90,000 GB
	StorageSpace pulumi.IntOutput `pulumi:"storageSpace"`
	// Specifies the storage I/O specification.
	// Valid values are **dms.physical.storage.high** and **dms.physical.storage.ultra**.
	// Changing this creates a new instance resource.
	StorageSpecCode pulumi.StringOutput `pulumi:"storageSpecCode"`
	// The key/value pairs to associate with the DMS RabbitMQ instance.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// Indicates the DMS RabbitMQ instance type.
	Type pulumi.StringOutput `pulumi:"type"`
	// Indicates the used message storage space. Unit: GB
	UsedStorageSpace pulumi.IntOutput `pulumi:"usedStorageSpace"`
	// Indicates the ID of the user who created the DMS RabbitMQ instance
	UserId pulumi.StringOutput `pulumi:"userId"`
	// Indicates the name of the user who created the DMS RabbitMQ instance
	UserName pulumi.StringOutput `pulumi:"userName"`
	// Specifies the ID of a VPC. Changing this creates a new instance resource.
	VpcId pulumi.StringOutput `pulumi:"vpcId"`
}

Manage DMS RabbitMQ instance resources within HuaweiCloud.

## Example Usage

## Import

DMS RabbitMQ instance can be imported using the instance id, e.g.

```sh 

$ pulumi import huaweicloud:Dms/rabbitmqInstance:RabbitmqInstance huaweicloud_dms_rabbitmq_instance.instance_1 8d3c7938-dc47-4937-a30f-c80de381c5e3

``` 

Note that the imported state may not be identical to your resource definition, due to some attributes missing from the API response, security or some other reason. The missing attributes include`password`, `auto_renew`, `period` and `period_unit`. It is generally recommended running `terraform plan` after importing a DMS RabbitMQ instance. You can then decide if changes should be applied to the instance, or the resource definition should be updated to align with the instance. Also you can ignore changes as below. resource "huaweicloud_dms_rabbitmq_instance" "instance_1" {

...

lifecycle {

ignore_changes = [

password, auto_renew, period, period_unit,

]

} }

func GetRabbitmqInstance 

func GetRabbitmqInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *RabbitmqInstanceState, opts ...pulumi.ResourceOption) (*RabbitmqInstance, error)

GetRabbitmqInstance gets an existing RabbitmqInstance resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewRabbitmqInstance 

func NewRabbitmqInstance(ctx *pulumi.Context,
	name string, args *RabbitmqInstanceArgs, opts ...pulumi.ResourceOption) (*RabbitmqInstance, error)

NewRabbitmqInstance registers a new resource with the given unique name, arguments, and options.

func (*RabbitmqInstance) ElementType 

func (*RabbitmqInstance) ElementType() reflect.Type

func (*RabbitmqInstance) ToRabbitmqInstanceOutput 

func (i *RabbitmqInstance) ToRabbitmqInstanceOutput() RabbitmqInstanceOutput

func (*RabbitmqInstance) ToRabbitmqInstanceOutputWithContext 

func (i *RabbitmqInstance) ToRabbitmqInstanceOutputWithContext(ctx context.Context) RabbitmqInstanceOutput

type RabbitmqInstanceArgs 

type RabbitmqInstanceArgs struct {
	// Specifies a username. A username consists of 4 to 64 characters and
	// supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.
	AccessUser pulumi.StringInput
	// Specifies whether auto renew is enabled. Valid values are **true** and **false**.
	AutoRenew pulumi.StringPtrInput
	// Specifies the names of an AZ.
	// The parameter value can not be left blank or an empty array.
	// Changing this creates a new instance resource.
	AvailabilityZones pulumi.StringArrayInput
	// Deprecated: available_zones has deprecated, please use "availability_zones" instead.
	AvailableZones pulumi.StringArrayInput
	// Specifies the broker numbers.
	// It is required when creating a cluster instance with `flavorId`.
	BrokerNum pulumi.IntPtrInput
	// Specifies the charging mode of the instance. Valid values are
	// **prePaid** and **postPaid**, defaults to **postPaid**. Changing this creates a new resource.
	ChargingMode pulumi.StringPtrInput
	// Specifies the description of the DMS RabbitMQ instance.
	// It is a character string containing not more than 1,024 characters.
	Description pulumi.StringPtrInput
	// Specifies the version of the RabbitMQ engine. Default to "3.7.17".
	// Changing this creates a new instance resource.
	EngineVersion pulumi.StringPtrInput
	// Specifies the enterprise project ID of the RabbitMQ instance.
	EnterpriseProjectId pulumi.StringPtrInput
	// Specifies a flavor ID.
	// It is mandatory when the `chargingMode` is **prePaid**.
	FlavorId pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window starts. Format: HH:mm.
	// The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance
	// time window.
	// The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also
	// blank. In this case, the system automatically allocates the default start time 02:00.
	MaintainBegin pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window ends. Format: HH:mm.
	// The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance
	// time window. The end time is four hours later than the start time.
	// For example, if the start time is 22:00, the end time is 02:00.
	// Parameters `maintainBegin` and `maintainEnd` must be set in pairs.
	// If parameter `maintainEnd` is left  blank, parameter `maintainBegin` is also blank.
	// In this case, the system automatically allocates the default end time 06:00.
	MaintainEnd pulumi.StringPtrInput
	// Specifies the name of the DMS RabbitMQ instance. An instance name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	Name pulumi.StringPtrInput
	// Specifies the ID of a subnet. Changing this creates a new instance
	// resource.
	NetworkId pulumi.StringInput
	// Specifies the password of the DMS RabbitMQ instance. A password must meet
	// the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following
	// character types: lowercase letters, uppercase letters, digits,
	// and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?).
	// Changing this creates a new instance resource.
	Password pulumi.StringInput
	// Specifies the charging period of the instance. If `periodUnit` is set to
	// **month**, the value ranges from 1 to 9. If `periodUnit` is set to **year**, the value ranges from 1 to 3.
	// This parameter is mandatory if `chargingMode` is set to **prePaid**. Changing this creates a new resource.
	Period pulumi.IntPtrInput
	// Specifies the charging period unit of the instance.
	// Valid values are **month** and **year**. This parameter is mandatory if `chargingMode` is set to **prePaid**.
	// Changing this creates a new resource.
	PeriodUnit pulumi.StringPtrInput
	// Deprecated: product_id has deprecated, please use "flavor_id" instead.
	ProductId pulumi.StringPtrInput
	// Specifies the ID of the elastic IP address (EIP)
	// bound to the DMS RabbitMQ instance.
	PublicIpId pulumi.StringPtrInput
	// The region in which to create the DMS RabbitMQ instance resource. If omitted,
	// the provider-level region will be used. Changing this creates a new instance resource.
	Region pulumi.StringPtrInput
	// Specifies the ID of a security group.
	SecurityGroupId pulumi.StringInput
	// Specifies whether to enable public access for the DMS RabbitMQ instance.
	// Changing this creates a new instance resource.
	SslEnable pulumi.BoolPtrInput
	// Specifies the message storage space, unit is GB.
	// It is required when creating a instance with `flavorId`. Value range:
	// + Single-node RabbitMQ instance: 100–90,000 GB
	// + Cluster RabbitMQ instance: 100 GB x number of nodes to 90,000 GB, 200 GB x number of nodes to 90,000 GB,
	//   and 300 GB x number of nodes to 90,000 GB
	StorageSpace pulumi.IntPtrInput
	// Specifies the storage I/O specification.
	// Valid values are **dms.physical.storage.high** and **dms.physical.storage.ultra**.
	// Changing this creates a new instance resource.
	StorageSpecCode pulumi.StringInput
	// The key/value pairs to associate with the DMS RabbitMQ instance.
	Tags pulumi.StringMapInput
	// Specifies the ID of a VPC. Changing this creates a new instance resource.
	VpcId pulumi.StringInput
}

The set of arguments for constructing a RabbitmqInstance resource.

func (RabbitmqInstanceArgs) ElementType 

func (RabbitmqInstanceArgs) ElementType() reflect.Type

type RabbitmqInstanceArray 

type RabbitmqInstanceArray []RabbitmqInstanceInput

func (RabbitmqInstanceArray) ElementType 

func (RabbitmqInstanceArray) ElementType() reflect.Type

func (RabbitmqInstanceArray) ToRabbitmqInstanceArrayOutput 

func (i RabbitmqInstanceArray) ToRabbitmqInstanceArrayOutput() RabbitmqInstanceArrayOutput

func (RabbitmqInstanceArray) ToRabbitmqInstanceArrayOutputWithContext 

func (i RabbitmqInstanceArray) ToRabbitmqInstanceArrayOutputWithContext(ctx context.Context) RabbitmqInstanceArrayOutput

type RabbitmqInstanceArrayInput 

type RabbitmqInstanceArrayInput interface {
	pulumi.Input

	ToRabbitmqInstanceArrayOutput() RabbitmqInstanceArrayOutput
	ToRabbitmqInstanceArrayOutputWithContext(context.Context) RabbitmqInstanceArrayOutput
}

RabbitmqInstanceArrayInput is an input type that accepts RabbitmqInstanceArray and RabbitmqInstanceArrayOutput values. You can construct a concrete instance of `RabbitmqInstanceArrayInput` via: 

RabbitmqInstanceArray{ RabbitmqInstanceArgs{...} }

type RabbitmqInstanceArrayOutput 

type RabbitmqInstanceArrayOutput struct{ *pulumi.OutputState }

func (RabbitmqInstanceArrayOutput) ElementType 

func (RabbitmqInstanceArrayOutput) ElementType() reflect.Type

func (RabbitmqInstanceArrayOutput) Index 

func (o RabbitmqInstanceArrayOutput) Index(i pulumi.IntInput) RabbitmqInstanceOutput

func (RabbitmqInstanceArrayOutput) ToRabbitmqInstanceArrayOutput 

func (o RabbitmqInstanceArrayOutput) ToRabbitmqInstanceArrayOutput() RabbitmqInstanceArrayOutput

func (RabbitmqInstanceArrayOutput) ToRabbitmqInstanceArrayOutputWithContext 

func (o RabbitmqInstanceArrayOutput) ToRabbitmqInstanceArrayOutputWithContext(ctx context.Context) RabbitmqInstanceArrayOutput

type RabbitmqInstanceInput 

type RabbitmqInstanceInput interface {
	pulumi.Input

	ToRabbitmqInstanceOutput() RabbitmqInstanceOutput
	ToRabbitmqInstanceOutputWithContext(ctx context.Context) RabbitmqInstanceOutput
}

type RabbitmqInstanceMap 

type RabbitmqInstanceMap map[string]RabbitmqInstanceInput

func (RabbitmqInstanceMap) ElementType 

func (RabbitmqInstanceMap) ElementType() reflect.Type

func (RabbitmqInstanceMap) ToRabbitmqInstanceMapOutput 

func (i RabbitmqInstanceMap) ToRabbitmqInstanceMapOutput() RabbitmqInstanceMapOutput

func (RabbitmqInstanceMap) ToRabbitmqInstanceMapOutputWithContext 

func (i RabbitmqInstanceMap) ToRabbitmqInstanceMapOutputWithContext(ctx context.Context) RabbitmqInstanceMapOutput

type RabbitmqInstanceMapInput 

type RabbitmqInstanceMapInput interface {
	pulumi.Input

	ToRabbitmqInstanceMapOutput() RabbitmqInstanceMapOutput
	ToRabbitmqInstanceMapOutputWithContext(context.Context) RabbitmqInstanceMapOutput
}

RabbitmqInstanceMapInput is an input type that accepts RabbitmqInstanceMap and RabbitmqInstanceMapOutput values. You can construct a concrete instance of `RabbitmqInstanceMapInput` via: 

RabbitmqInstanceMap{ "key": RabbitmqInstanceArgs{...} }

type RabbitmqInstanceMapOutput 

type RabbitmqInstanceMapOutput struct{ *pulumi.OutputState }

func (RabbitmqInstanceMapOutput) ElementType 

func (RabbitmqInstanceMapOutput) ElementType() reflect.Type

func (RabbitmqInstanceMapOutput) MapIndex 

func (o RabbitmqInstanceMapOutput) MapIndex(k pulumi.StringInput) RabbitmqInstanceOutput

func (RabbitmqInstanceMapOutput) ToRabbitmqInstanceMapOutput 

func (o RabbitmqInstanceMapOutput) ToRabbitmqInstanceMapOutput() RabbitmqInstanceMapOutput

func (RabbitmqInstanceMapOutput) ToRabbitmqInstanceMapOutputWithContext 

func (o RabbitmqInstanceMapOutput) ToRabbitmqInstanceMapOutputWithContext(ctx context.Context) RabbitmqInstanceMapOutput

type RabbitmqInstanceOutput 

type RabbitmqInstanceOutput struct{ *pulumi.OutputState }

func (RabbitmqInstanceOutput) AccessUser 

func (o RabbitmqInstanceOutput) AccessUser() pulumi.StringOutput

Specifies a username. A username consists of 4 to 64 characters and supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) AutoRenew added in v0.0.8 

func (o RabbitmqInstanceOutput) AutoRenew() pulumi.StringPtrOutput

Specifies whether auto renew is enabled. Valid values are **true** and **false**.

func (RabbitmqInstanceOutput) AvailabilityZones 

func (o RabbitmqInstanceOutput) AvailabilityZones() pulumi.StringArrayOutput

Specifies the names of an AZ. The parameter value can not be left blank or an empty array. Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) AvailableZones deprecated 

func (o RabbitmqInstanceOutput) AvailableZones() pulumi.StringArrayOutput

Deprecated: available_zones has deprecated, please use "availability_zones" instead.

func (RabbitmqInstanceOutput) BrokerNum added in v0.0.8 

func (o RabbitmqInstanceOutput) BrokerNum() pulumi.IntOutput

Specifies the broker numbers. It is required when creating a cluster instance with `flavorId`.

func (RabbitmqInstanceOutput) ChargingMode added in v0.0.8 

func (o RabbitmqInstanceOutput) ChargingMode() pulumi.StringOutput

Specifies the charging mode of the instance. Valid values are **prePaid** and **postPaid**, defaults to **postPaid**. Changing this creates a new resource.

func (RabbitmqInstanceOutput) ConnectAddress 

func (o RabbitmqInstanceOutput) ConnectAddress() pulumi.StringOutput

Indicates the IP address of the DMS RabbitMQ instance.

func (RabbitmqInstanceOutput) Description 

func (o RabbitmqInstanceOutput) Description() pulumi.StringPtrOutput

Specifies the description of the DMS RabbitMQ instance. It is a character string containing not more than 1,024 characters.

func (RabbitmqInstanceOutput) ElementType 

func (RabbitmqInstanceOutput) ElementType() reflect.Type

func (RabbitmqInstanceOutput) EnablePublicIp 

func (o RabbitmqInstanceOutput) EnablePublicIp() pulumi.BoolOutput

Indicates whether public access to the DMS RabbitMQ instance is enabled.

func (RabbitmqInstanceOutput) Engine 

func (o RabbitmqInstanceOutput) Engine() pulumi.StringOutput

Indicates the message engine.

func (RabbitmqInstanceOutput) EngineVersion 

func (o RabbitmqInstanceOutput) EngineVersion() pulumi.StringPtrOutput

Specifies the version of the RabbitMQ engine. Default to "3.7.17". Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) EnterpriseProjectId 

func (o RabbitmqInstanceOutput) EnterpriseProjectId() pulumi.StringOutput

Specifies the enterprise project ID of the RabbitMQ instance.

func (RabbitmqInstanceOutput) FlavorId added in v0.0.8 

func (o RabbitmqInstanceOutput) FlavorId() pulumi.StringPtrOutput

Specifies a flavor ID. It is mandatory when the `chargingMode` is **prePaid**.

func (RabbitmqInstanceOutput) MaintainBegin 

func (o RabbitmqInstanceOutput) MaintainBegin() pulumi.StringOutput

Specifies the time at which a maintenance time window starts. Format: HH:mm. The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time window. The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin` and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also blank. In this case, the system automatically allocates the default start time 02:00.

func (RabbitmqInstanceOutput) MaintainEnd 

func (o RabbitmqInstanceOutput) MaintainEnd() pulumi.StringOutput

Specifies the time at which a maintenance time window ends. Format: HH:mm. The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance time window. The end time is four hours later than the start time. For example, if the start time is 22:00, the end time is 02:00. Parameters `maintainBegin` and `maintainEnd` must be set in pairs. If parameter `maintainEnd` is left blank, parameter `maintainBegin` is also blank. In this case, the system automatically allocates the default end time 06:00.

func (RabbitmqInstanceOutput) ManagementConnectAddress added in v0.0.8 

func (o RabbitmqInstanceOutput) ManagementConnectAddress() pulumi.StringOutput

Indicates the management address of the DMS RabbitMQ instance.

func (RabbitmqInstanceOutput) ManegementConnectAddress deprecated 

func (o RabbitmqInstanceOutput) ManegementConnectAddress() pulumi.StringOutput

Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.

func (RabbitmqInstanceOutput) Name 

func (o RabbitmqInstanceOutput) Name() pulumi.StringOutput

Specifies the name of the DMS RabbitMQ instance. An instance name starts with a letter, consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).

func (RabbitmqInstanceOutput) NetworkId 

func (o RabbitmqInstanceOutput) NetworkId() pulumi.StringOutput

Specifies the ID of a subnet. Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) Password 

func (o RabbitmqInstanceOutput) Password() pulumi.StringOutput

Specifies the password of the DMS RabbitMQ instance. A password must meet the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following character types: lowercase letters, uppercase letters, digits, and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?). Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) Period added in v0.0.8 

func (o RabbitmqInstanceOutput) Period() pulumi.IntPtrOutput

Specifies the charging period of the instance. If `periodUnit` is set to **month**, the value ranges from 1 to 9. If `periodUnit` is set to **year**, the value ranges from 1 to 3. This parameter is mandatory if `chargingMode` is set to **prePaid**. Changing this creates a new resource.

func (RabbitmqInstanceOutput) PeriodUnit added in v0.0.8 

func (o RabbitmqInstanceOutput) PeriodUnit() pulumi.StringPtrOutput

Specifies the charging period unit of the instance. Valid values are **month** and **year**. This parameter is mandatory if `chargingMode` is set to **prePaid**. Changing this creates a new resource.

func (RabbitmqInstanceOutput) Port 

func (o RabbitmqInstanceOutput) Port() pulumi.IntOutput

Indicates the port number of the DMS RabbitMQ instance.

func (RabbitmqInstanceOutput) ProductId deprecated 

func (o RabbitmqInstanceOutput) ProductId() pulumi.StringPtrOutput

Deprecated: product_id has deprecated, please use "flavor_id" instead.

func (RabbitmqInstanceOutput) PublicIpId 

func (o RabbitmqInstanceOutput) PublicIpId() pulumi.StringPtrOutput

Specifies the ID of the elastic IP address (EIP) bound to the DMS RabbitMQ instance.

func (RabbitmqInstanceOutput) Region 

func (o RabbitmqInstanceOutput) Region() pulumi.StringOutput

The region in which to create the DMS RabbitMQ instance resource. If omitted, the provider-level region will be used. Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) ResourceSpecCode 

func (o RabbitmqInstanceOutput) ResourceSpecCode() pulumi.StringOutput

Indicates a resource specifications identifier.

func (RabbitmqInstanceOutput) SecurityGroupId 

func (o RabbitmqInstanceOutput) SecurityGroupId() pulumi.StringOutput

Specifies the ID of a security group.

func (RabbitmqInstanceOutput) Specification 

func (o RabbitmqInstanceOutput) Specification() pulumi.StringOutput

Indicates the instance specification. For a single-node DMS RabbitMQ instance, VM specifications are returned. For a cluster DMS RabbitMQ instance, VM specifications and the number of nodes are returned.

func (RabbitmqInstanceOutput) SslEnable 

func (o RabbitmqInstanceOutput) SslEnable() pulumi.BoolPtrOutput

Specifies whether to enable public access for the DMS RabbitMQ instance. Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) Status 

func (o RabbitmqInstanceOutput) Status() pulumi.StringOutput

Indicates the status of the DMS RabbitMQ instance.

func (RabbitmqInstanceOutput) StorageSpace 

func (o RabbitmqInstanceOutput) StorageSpace() pulumi.IntOutput

Specifies the message storage space, unit is GB. It is required when creating a instance with `flavorId`. Value range:

  • Single-node RabbitMQ instance: 100–90,000 GB
  • Cluster RabbitMQ instance: 100 GB x number of nodes to 90,000 GB, 200 GB x number of nodes to 90,000 GB, and 300 GB x number of nodes to 90,000 GB

func (RabbitmqInstanceOutput) StorageSpecCode 

func (o RabbitmqInstanceOutput) StorageSpecCode() pulumi.StringOutput

Specifies the storage I/O specification. Valid values are **dms.physical.storage.high** and **dms.physical.storage.ultra**. Changing this creates a new instance resource.

func (RabbitmqInstanceOutput) Tags 

func (o RabbitmqInstanceOutput) Tags() pulumi.StringMapOutput

The key/value pairs to associate with the DMS RabbitMQ instance.

func (RabbitmqInstanceOutput) ToRabbitmqInstanceOutput 

func (o RabbitmqInstanceOutput) ToRabbitmqInstanceOutput() RabbitmqInstanceOutput

func (RabbitmqInstanceOutput) ToRabbitmqInstanceOutputWithContext 

func (o RabbitmqInstanceOutput) ToRabbitmqInstanceOutputWithContext(ctx context.Context) RabbitmqInstanceOutput

func (RabbitmqInstanceOutput) Type 

func (o RabbitmqInstanceOutput) Type() pulumi.StringOutput

Indicates the DMS RabbitMQ instance type.

func (RabbitmqInstanceOutput) UsedStorageSpace 

func (o RabbitmqInstanceOutput) UsedStorageSpace() pulumi.IntOutput

Indicates the used message storage space. Unit: GB

func (RabbitmqInstanceOutput) UserId 

func (o RabbitmqInstanceOutput) UserId() pulumi.StringOutput

Indicates the ID of the user who created the DMS RabbitMQ instance

func (RabbitmqInstanceOutput) UserName 

func (o RabbitmqInstanceOutput) UserName() pulumi.StringOutput

Indicates the name of the user who created the DMS RabbitMQ instance

func (RabbitmqInstanceOutput) VpcId 

func (o RabbitmqInstanceOutput) VpcId() pulumi.StringOutput

Specifies the ID of a VPC. Changing this creates a new instance resource.

type RabbitmqInstanceState 

type RabbitmqInstanceState struct {
	// Specifies a username. A username consists of 4 to 64 characters and
	// supports only letters, digits, and hyphens (-). Changing this creates a new instance resource.
	AccessUser pulumi.StringPtrInput
	// Specifies whether auto renew is enabled. Valid values are **true** and **false**.
	AutoRenew pulumi.StringPtrInput
	// Specifies the names of an AZ.
	// The parameter value can not be left blank or an empty array.
	// Changing this creates a new instance resource.
	AvailabilityZones pulumi.StringArrayInput
	// Deprecated: available_zones has deprecated, please use "availability_zones" instead.
	AvailableZones pulumi.StringArrayInput
	// Specifies the broker numbers.
	// It is required when creating a cluster instance with `flavorId`.
	BrokerNum pulumi.IntPtrInput
	// Specifies the charging mode of the instance. Valid values are
	// **prePaid** and **postPaid**, defaults to **postPaid**. Changing this creates a new resource.
	ChargingMode pulumi.StringPtrInput
	// Indicates the IP address of the DMS RabbitMQ instance.
	ConnectAddress pulumi.StringPtrInput
	// Specifies the description of the DMS RabbitMQ instance.
	// It is a character string containing not more than 1,024 characters.
	Description pulumi.StringPtrInput
	// Indicates whether public access to the DMS RabbitMQ instance is enabled.
	EnablePublicIp pulumi.BoolPtrInput
	// Indicates the message engine.
	Engine pulumi.StringPtrInput
	// Specifies the version of the RabbitMQ engine. Default to "3.7.17".
	// Changing this creates a new instance resource.
	EngineVersion pulumi.StringPtrInput
	// Specifies the enterprise project ID of the RabbitMQ instance.
	EnterpriseProjectId pulumi.StringPtrInput
	// Specifies a flavor ID.
	// It is mandatory when the `chargingMode` is **prePaid**.
	FlavorId pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window starts. Format: HH:mm.
	// The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance
	// time window.
	// The start time must be set to 22:00, 02:00, 06:00, 10:00, 14:00, or 18:00. Parameters `maintainBegin`
	// and `maintainEnd` must be set in pairs. If parameter `maintainBegin` is left blank, parameter `maintainEnd` is also
	// blank. In this case, the system automatically allocates the default start time 02:00.
	MaintainBegin pulumi.StringPtrInput
	// Specifies the time at which a maintenance time window ends. Format: HH:mm.
	// The start time and end time of a maintenance time window must indicate the time segment of a supported maintenance
	// time window. The end time is four hours later than the start time.
	// For example, if the start time is 22:00, the end time is 02:00.
	// Parameters `maintainBegin` and `maintainEnd` must be set in pairs.
	// If parameter `maintainEnd` is left  blank, parameter `maintainBegin` is also blank.
	// In this case, the system automatically allocates the default end time 06:00.
	MaintainEnd pulumi.StringPtrInput
	// Indicates the management address of the DMS RabbitMQ instance.
	ManagementConnectAddress pulumi.StringPtrInput
	// Deprecated: typo in manegement_connect_address, please use "management_connect_address" instead.
	ManegementConnectAddress pulumi.StringPtrInput
	// Specifies the name of the DMS RabbitMQ instance. An instance name starts with a letter,
	// consists of 4 to 64 characters, and supports only letters, digits, hyphens (-) and underscores (_).
	Name pulumi.StringPtrInput
	// Specifies the ID of a subnet. Changing this creates a new instance
	// resource.
	NetworkId pulumi.StringPtrInput
	// Specifies the password of the DMS RabbitMQ instance. A password must meet
	// the following complexity requirements: Must be 8 to 32 characters long. Must contain at least 2 of the following
	// character types: lowercase letters, uppercase letters, digits,
	// and special characters (`~!@#$%^&*()-_=+\\|[{}]:'",<.>/?).
	// Changing this creates a new instance resource.
	Password pulumi.StringPtrInput
	// Specifies the charging period of the instance. If `periodUnit` is set to
	// **month**, the value ranges from 1 to 9. If `periodUnit` is set to **year**, the value ranges from 1 to 3.
	// This parameter is mandatory if `chargingMode` is set to **prePaid**. Changing this creates a new resource.
	Period pulumi.IntPtrInput
	// Specifies the charging period unit of the instance.
	// Valid values are **month** and **year**. This parameter is mandatory if `chargingMode` is set to **prePaid**.
	// Changing this creates a new resource.
	PeriodUnit pulumi.StringPtrInput
	// Indicates the port number of the DMS RabbitMQ instance.
	Port pulumi.IntPtrInput
	// Deprecated: product_id has deprecated, please use "flavor_id" instead.
	ProductId pulumi.StringPtrInput
	// Specifies the ID of the elastic IP address (EIP)
	// bound to the DMS RabbitMQ instance.
	PublicIpId pulumi.StringPtrInput
	// The region in which to create the DMS RabbitMQ instance resource. If omitted,
	// the provider-level region will be used. Changing this creates a new instance resource.
	Region pulumi.StringPtrInput
	// Indicates a resource specifications identifier.
	ResourceSpecCode pulumi.StringPtrInput
	// Specifies the ID of a security group.
	SecurityGroupId pulumi.StringPtrInput
	// Indicates the instance specification. For a single-node DMS RabbitMQ instance, VM specifications are
	// returned. For a cluster DMS RabbitMQ instance, VM specifications and the number of nodes are returned.
	Specification pulumi.StringPtrInput
	// Specifies whether to enable public access for the DMS RabbitMQ instance.
	// Changing this creates a new instance resource.
	SslEnable pulumi.BoolPtrInput
	// Indicates the status of the DMS RabbitMQ instance.
	Status pulumi.StringPtrInput
	// Specifies the message storage space, unit is GB.
	// It is required when creating a instance with `flavorId`. Value range:
	// + Single-node RabbitMQ instance: 100–90,000 GB
	// + Cluster RabbitMQ instance: 100 GB x number of nodes to 90,000 GB, 200 GB x number of nodes to 90,000 GB,
	//   and 300 GB x number of nodes to 90,000 GB
	StorageSpace pulumi.IntPtrInput
	// Specifies the storage I/O specification.
	// Valid values are **dms.physical.storage.high** and **dms.physical.storage.ultra**.
	// Changing this creates a new instance resource.
	StorageSpecCode pulumi.StringPtrInput
	// The key/value pairs to associate with the DMS RabbitMQ instance.
	Tags pulumi.StringMapInput
	// Indicates the DMS RabbitMQ instance type.
	Type pulumi.StringPtrInput
	// Indicates the used message storage space. Unit: GB
	UsedStorageSpace pulumi.IntPtrInput
	// Indicates the ID of the user who created the DMS RabbitMQ instance
	UserId pulumi.StringPtrInput
	// Indicates the name of the user who created the DMS RabbitMQ instance
	UserName pulumi.StringPtrInput
	// Specifies the ID of a VPC. Changing this creates a new instance resource.
	VpcId pulumi.StringPtrInput
}

func (RabbitmqInstanceState) ElementType 

func (RabbitmqInstanceState) ElementType() reflect.Type

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.