ckafka

package
v0.0.0 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Acl 

type Acl struct {
	pulumi.CustomResourceState

	// IP address allowed to access. The default value is `*`, which means that any host can access.
	Host pulumi.StringPtrOutput `pulumi:"host"`
	// ID of the ckafka instance.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`.
	OperationType pulumi.StringOutput `pulumi:"operationType"`
	// ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	PermissionType pulumi.StringPtrOutput `pulumi:"permissionType"`
	// User list. The default value is `*`, which means that any user can access. The current user can only be one included in the user list.
	Principal pulumi.StringPtrOutput `pulumi:"principal"`
	// ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.
	ResourceName pulumi.StringOutput `pulumi:"resourceName"`
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType pulumi.StringPtrOutput `pulumi:"resourceType"`
}

Provides a resource to create a Ckafka Acl.

## Example Usage

Ckafka Acl

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.NewAcl(ctx, "foo", &Ckafka.AclArgs{
			InstanceId:     pulumi.String("ckafka-f9ife4zz"),
			ResourceType:   pulumi.String("TOPIC"),
			ResourceName:   pulumi.String("topic-tf-test"),
			OperationType:  pulumi.String("WRITE"),
			PermissionType: pulumi.String("ALLOW"),
			Host:           pulumi.String("*"),
			Principal:      pulumi.Any(tencentcloud_ckafka_user.Foo.Account_name),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Ckafka acl can be imported using the instance_id#permission_type#principal#host#operation_type#resource_type#resource_name, e.g.

```sh 

$ pulumi import tencentcloud:Ckafka/acl:Acl foo ckafka-f9ife4zz#ALLOW#test#*#WRITE#TOPIC#topic-tf-test

```

func GetAcl 

func GetAcl(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *AclState, opts ...pulumi.ResourceOption) (*Acl, error)

GetAcl gets an existing Acl 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 NewAcl 

func NewAcl(ctx *pulumi.Context,
	name string, args *AclArgs, opts ...pulumi.ResourceOption) (*Acl, error)

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

func (*Acl) ElementType 

func (*Acl) ElementType() reflect.Type

func (*Acl) ToAclOutput 

func (i *Acl) ToAclOutput() AclOutput

func (*Acl) ToAclOutputWithContext 

func (i *Acl) ToAclOutputWithContext(ctx context.Context) AclOutput

type AclArgs 

type AclArgs struct {
	// IP address allowed to access. The default value is `*`, which means that any host can access.
	Host pulumi.StringPtrInput
	// ID of the ckafka instance.
	InstanceId pulumi.StringInput
	// ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`.
	OperationType pulumi.StringInput
	// ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	PermissionType pulumi.StringPtrInput
	// User list. The default value is `*`, which means that any user can access. The current user can only be one included in the user list.
	Principal pulumi.StringPtrInput
	// ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.
	ResourceName pulumi.StringInput
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType pulumi.StringPtrInput
}

The set of arguments for constructing a Acl resource.

func (AclArgs) ElementType 

func (AclArgs) ElementType() reflect.Type

type AclArray 

type AclArray []AclInput

func (AclArray) ElementType 

func (AclArray) ElementType() reflect.Type

func (AclArray) ToAclArrayOutput 

func (i AclArray) ToAclArrayOutput() AclArrayOutput

func (AclArray) ToAclArrayOutputWithContext 

func (i AclArray) ToAclArrayOutputWithContext(ctx context.Context) AclArrayOutput

type AclArrayInput 

type AclArrayInput interface {
	pulumi.Input

	ToAclArrayOutput() AclArrayOutput
	ToAclArrayOutputWithContext(context.Context) AclArrayOutput
}

AclArrayInput is an input type that accepts AclArray and AclArrayOutput values. You can construct a concrete instance of `AclArrayInput` via: 

AclArray{ AclArgs{...} }

type AclArrayOutput 

type AclArrayOutput struct{ *pulumi.OutputState }

func (AclArrayOutput) ElementType 

func (AclArrayOutput) ElementType() reflect.Type

func (AclArrayOutput) Index 

func (o AclArrayOutput) Index(i pulumi.IntInput) AclOutput

func (AclArrayOutput) ToAclArrayOutput 

func (o AclArrayOutput) ToAclArrayOutput() AclArrayOutput

func (AclArrayOutput) ToAclArrayOutputWithContext 

func (o AclArrayOutput) ToAclArrayOutputWithContext(ctx context.Context) AclArrayOutput

type AclInput 

type AclInput interface {
	pulumi.Input

	ToAclOutput() AclOutput
	ToAclOutputWithContext(ctx context.Context) AclOutput
}

type AclMap 

type AclMap map[string]AclInput

func (AclMap) ElementType 

func (AclMap) ElementType() reflect.Type

func (AclMap) ToAclMapOutput 

func (i AclMap) ToAclMapOutput() AclMapOutput

func (AclMap) ToAclMapOutputWithContext 

func (i AclMap) ToAclMapOutputWithContext(ctx context.Context) AclMapOutput

type AclMapInput 

type AclMapInput interface {
	pulumi.Input

	ToAclMapOutput() AclMapOutput
	ToAclMapOutputWithContext(context.Context) AclMapOutput
}

AclMapInput is an input type that accepts AclMap and AclMapOutput values. You can construct a concrete instance of `AclMapInput` via: 

AclMap{ "key": AclArgs{...} }

type AclMapOutput 

type AclMapOutput struct{ *pulumi.OutputState }

func (AclMapOutput) ElementType 

func (AclMapOutput) ElementType() reflect.Type

func (AclMapOutput) MapIndex 

func (o AclMapOutput) MapIndex(k pulumi.StringInput) AclOutput

func (AclMapOutput) ToAclMapOutput 

func (o AclMapOutput) ToAclMapOutput() AclMapOutput

func (AclMapOutput) ToAclMapOutputWithContext 

func (o AclMapOutput) ToAclMapOutputWithContext(ctx context.Context) AclMapOutput

type AclOutput 

type AclOutput struct{ *pulumi.OutputState }

func (AclOutput) ElementType 

func (AclOutput) ElementType() reflect.Type

func (AclOutput) Host 

func (o AclOutput) Host() pulumi.StringPtrOutput

IP address allowed to access. The default value is `*`, which means that any host can access.

func (AclOutput) InstanceId 

func (o AclOutput) InstanceId() pulumi.StringOutput

ID of the ckafka instance.

func (AclOutput) OperationType 

func (o AclOutput) OperationType() pulumi.StringOutput

ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`.

func (AclOutput) PermissionType 

func (o AclOutput) PermissionType() pulumi.StringPtrOutput

ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.

func (AclOutput) Principal 

func (o AclOutput) Principal() pulumi.StringPtrOutput

User list. The default value is `*`, which means that any user can access. The current user can only be one included in the user list.

func (AclOutput) ResourceName 

func (o AclOutput) ResourceName() pulumi.StringOutput

ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.

func (AclOutput) ResourceType 

func (o AclOutput) ResourceType() pulumi.StringPtrOutput

ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.

func (AclOutput) ToAclOutput 

func (o AclOutput) ToAclOutput() AclOutput

func (AclOutput) ToAclOutputWithContext 

func (o AclOutput) ToAclOutputWithContext(ctx context.Context) AclOutput

type AclState 

type AclState struct {
	// IP address allowed to access. The default value is `*`, which means that any host can access.
	Host pulumi.StringPtrInput
	// ID of the ckafka instance.
	InstanceId pulumi.StringPtrInput
	// ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`.
	OperationType pulumi.StringPtrInput
	// ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	PermissionType pulumi.StringPtrInput
	// User list. The default value is `*`, which means that any user can access. The current user can only be one included in the user list.
	Principal pulumi.StringPtrInput
	// ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.
	ResourceName pulumi.StringPtrInput
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType pulumi.StringPtrInput
}

func (AclState) ElementType 

func (AclState) ElementType() reflect.Type

type GetAclsAclList 

type GetAclsAclList struct {
	// Host substr used for querying.
	Host string `pulumi:"host"`
	// ACL operation mode.
	OperationType string `pulumi:"operationType"`
	// ACL permission type, valid values are `UNKNOWN`, `ANY`, `DENY`, `ALLOW`, and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	PermissionType string `pulumi:"permissionType"`
	// User which can access. `*` means that any user can access.
	Principal string `pulumi:"principal"`
	// ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.
	ResourceName string `pulumi:"resourceName"`
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType string `pulumi:"resourceType"`
}

type GetAclsAclListArgs 

type GetAclsAclListArgs struct {
	// Host substr used for querying.
	Host pulumi.StringInput `pulumi:"host"`
	// ACL operation mode.
	OperationType pulumi.StringInput `pulumi:"operationType"`
	// ACL permission type, valid values are `UNKNOWN`, `ANY`, `DENY`, `ALLOW`, and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.
	PermissionType pulumi.StringInput `pulumi:"permissionType"`
	// User which can access. `*` means that any user can access.
	Principal pulumi.StringInput `pulumi:"principal"`
	// ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.
	ResourceName pulumi.StringInput `pulumi:"resourceName"`
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType pulumi.StringInput `pulumi:"resourceType"`
}

func (GetAclsAclListArgs) ElementType 

func (GetAclsAclListArgs) ElementType() reflect.Type

func (GetAclsAclListArgs) ToGetAclsAclListOutput 

func (i GetAclsAclListArgs) ToGetAclsAclListOutput() GetAclsAclListOutput

func (GetAclsAclListArgs) ToGetAclsAclListOutputWithContext 

func (i GetAclsAclListArgs) ToGetAclsAclListOutputWithContext(ctx context.Context) GetAclsAclListOutput

type GetAclsAclListArray 

type GetAclsAclListArray []GetAclsAclListInput

func (GetAclsAclListArray) ElementType 

func (GetAclsAclListArray) ElementType() reflect.Type

func (GetAclsAclListArray) ToGetAclsAclListArrayOutput 

func (i GetAclsAclListArray) ToGetAclsAclListArrayOutput() GetAclsAclListArrayOutput

func (GetAclsAclListArray) ToGetAclsAclListArrayOutputWithContext 

func (i GetAclsAclListArray) ToGetAclsAclListArrayOutputWithContext(ctx context.Context) GetAclsAclListArrayOutput

type GetAclsAclListArrayInput 

type GetAclsAclListArrayInput interface {
	pulumi.Input

	ToGetAclsAclListArrayOutput() GetAclsAclListArrayOutput
	ToGetAclsAclListArrayOutputWithContext(context.Context) GetAclsAclListArrayOutput
}

GetAclsAclListArrayInput is an input type that accepts GetAclsAclListArray and GetAclsAclListArrayOutput values. You can construct a concrete instance of `GetAclsAclListArrayInput` via: 

GetAclsAclListArray{ GetAclsAclListArgs{...} }

type GetAclsAclListArrayOutput 

type GetAclsAclListArrayOutput struct{ *pulumi.OutputState }

func (GetAclsAclListArrayOutput) ElementType 

func (GetAclsAclListArrayOutput) ElementType() reflect.Type

func (GetAclsAclListArrayOutput) Index 

func (o GetAclsAclListArrayOutput) Index(i pulumi.IntInput) GetAclsAclListOutput

func (GetAclsAclListArrayOutput) ToGetAclsAclListArrayOutput 

func (o GetAclsAclListArrayOutput) ToGetAclsAclListArrayOutput() GetAclsAclListArrayOutput

func (GetAclsAclListArrayOutput) ToGetAclsAclListArrayOutputWithContext 

func (o GetAclsAclListArrayOutput) ToGetAclsAclListArrayOutputWithContext(ctx context.Context) GetAclsAclListArrayOutput

type GetAclsAclListInput 

type GetAclsAclListInput interface {
	pulumi.Input

	ToGetAclsAclListOutput() GetAclsAclListOutput
	ToGetAclsAclListOutputWithContext(context.Context) GetAclsAclListOutput
}

GetAclsAclListInput is an input type that accepts GetAclsAclListArgs and GetAclsAclListOutput values. You can construct a concrete instance of `GetAclsAclListInput` via: 

GetAclsAclListArgs{...}

type GetAclsAclListOutput 

type GetAclsAclListOutput struct{ *pulumi.OutputState }

func (GetAclsAclListOutput) ElementType 

func (GetAclsAclListOutput) ElementType() reflect.Type

func (GetAclsAclListOutput) Host 

func (o GetAclsAclListOutput) Host() pulumi.StringOutput

Host substr used for querying.

func (GetAclsAclListOutput) OperationType 

func (o GetAclsAclListOutput) OperationType() pulumi.StringOutput

ACL operation mode.

func (GetAclsAclListOutput) PermissionType 

func (o GetAclsAclListOutput) PermissionType() pulumi.StringOutput

ACL permission type, valid values are `UNKNOWN`, `ANY`, `DENY`, `ALLOW`, and `ALLOW` by default. Currently, CKafka supports `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka.

func (GetAclsAclListOutput) Principal 

func (o GetAclsAclListOutput) Principal() pulumi.StringOutput

User which can access. `*` means that any user can access.

func (GetAclsAclListOutput) ResourceName 

func (o GetAclsAclListOutput) ResourceName() pulumi.StringOutput

ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.

func (GetAclsAclListOutput) ResourceType 

func (o GetAclsAclListOutput) ResourceType() pulumi.StringOutput

ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.

func (GetAclsAclListOutput) ToGetAclsAclListOutput 

func (o GetAclsAclListOutput) ToGetAclsAclListOutput() GetAclsAclListOutput

func (GetAclsAclListOutput) ToGetAclsAclListOutputWithContext 

func (o GetAclsAclListOutput) ToGetAclsAclListOutputWithContext(ctx context.Context) GetAclsAclListOutput

type GetAclsArgs 

type GetAclsArgs struct {
	// Host substr used for querying.
	Host *string `pulumi:"host"`
	// Id of the ckafka instance.
	InstanceId string `pulumi:"instanceId"`
	// ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.
	ResourceName string `pulumi:"resourceName"`
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType string `pulumi:"resourceType"`
	// Used to save results.
	ResultOutputFile *string `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking getAcls.

type GetAclsOutputArgs 

type GetAclsOutputArgs struct {
	// Host substr used for querying.
	Host pulumi.StringPtrInput `pulumi:"host"`
	// Id of the ckafka instance.
	InstanceId pulumi.StringInput `pulumi:"instanceId"`
	// ACL resource name, which is related to `resourceType`. For example, if `resourceType` is `TOPIC`, this field indicates the topic name; if `resourceType` is `GROUP`, this field indicates the group name.
	ResourceName pulumi.StringInput `pulumi:"resourceName"`
	// ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
	ResourceType pulumi.StringInput `pulumi:"resourceType"`
	// Used to save results.
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking getAcls.

func (GetAclsOutputArgs) ElementType 

func (GetAclsOutputArgs) ElementType() reflect.Type

type GetAclsResult 

type GetAclsResult struct {
	// A list of ckafka acls. Each element contains the following attributes:
	AclLists []GetAclsAclList `pulumi:"aclLists"`
	// IP address allowed to access.
	Host *string `pulumi:"host"`
	// The provider-assigned unique ID for this managed resource.
	Id         string `pulumi:"id"`
	InstanceId string `pulumi:"instanceId"`
	// ACL resource name, which is related to `resourceType`.
	ResourceName string `pulumi:"resourceName"`
	// ACL resource type.
	ResourceType     string  `pulumi:"resourceType"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
}

A collection of values returned by getAcls.

func GetAcls 

func GetAcls(ctx *pulumi.Context, args *GetAclsArgs, opts ...pulumi.InvokeOption) (*GetAclsResult, error)

Use this data source to query detailed acl information of Ckafka

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.GetAcls(ctx, &ckafka.GetAclsArgs{
			Host:         pulumi.StringRef("2"),
			InstanceId:   "ckafka-f9ife4zz",
			ResourceName: "topic-tf-test",
			ResourceType: "TOPIC",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetAclsResultOutput 

type GetAclsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getAcls.

func GetAclsOutput 

func GetAclsOutput(ctx *pulumi.Context, args GetAclsOutputArgs, opts ...pulumi.InvokeOption) GetAclsResultOutput

func (GetAclsResultOutput) AclLists 

func (o GetAclsResultOutput) AclLists() GetAclsAclListArrayOutput

A list of ckafka acls. Each element contains the following attributes:

func (GetAclsResultOutput) ElementType 

func (GetAclsResultOutput) ElementType() reflect.Type

func (GetAclsResultOutput) Host 

func (o GetAclsResultOutput) Host() pulumi.StringPtrOutput

IP address allowed to access.

func (GetAclsResultOutput) Id 

func (o GetAclsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetAclsResultOutput) InstanceId 

func (o GetAclsResultOutput) InstanceId() pulumi.StringOutput

func (GetAclsResultOutput) ResourceName 

func (o GetAclsResultOutput) ResourceName() pulumi.StringOutput

ACL resource name, which is related to `resourceType`.

func (GetAclsResultOutput) ResourceType 

func (o GetAclsResultOutput) ResourceType() pulumi.StringOutput

ACL resource type.

func (GetAclsResultOutput) ResultOutputFile 

func (o GetAclsResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (GetAclsResultOutput) ToGetAclsResultOutput 

func (o GetAclsResultOutput) ToGetAclsResultOutput() GetAclsResultOutput

func (GetAclsResultOutput) ToGetAclsResultOutputWithContext 

func (o GetAclsResultOutput) ToGetAclsResultOutputWithContext(ctx context.Context) GetAclsResultOutput

type GetInstancesArgs 

type GetInstancesArgs struct {
	// Filter. filter.name supports ('Ip', 'VpcId', 'SubNetId', 'InstanceType','InstanceId'), filter.values can pass up to 10 values.
	Filters []GetInstancesFilter `pulumi:"filters"`
	// Filter by instance ID.
	InstanceIds []string `pulumi:"instanceIds"`
	// The number of pages, default is `10`.
	Limit *int `pulumi:"limit"`
	// The page start offset, default is `0`.
	Offset *int `pulumi:"offset"`
	// Used to save results.
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	// Filter by instance name, support fuzzy query.
	SearchWord *string `pulumi:"searchWord"`
	// (Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all.
	Statuses []int `pulumi:"statuses"`
	// Matches the tag key value.
	TagKey *string `pulumi:"tagKey"`
}

A collection of arguments for invoking getInstances.

type GetInstancesFilter 

type GetInstancesFilter struct {
	// The field that needs to be filtered.
	Name string `pulumi:"name"`
	// The filtered value of the field.
	Values []string `pulumi:"values"`
}

type GetInstancesFilterArgs 

type GetInstancesFilterArgs struct {
	// The field that needs to be filtered.
	Name pulumi.StringInput `pulumi:"name"`
	// The filtered value of the field.
	Values pulumi.StringArrayInput `pulumi:"values"`
}

func (GetInstancesFilterArgs) ElementType 

func (GetInstancesFilterArgs) ElementType() reflect.Type

func (GetInstancesFilterArgs) ToGetInstancesFilterOutput 

func (i GetInstancesFilterArgs) ToGetInstancesFilterOutput() GetInstancesFilterOutput

func (GetInstancesFilterArgs) ToGetInstancesFilterOutputWithContext 

func (i GetInstancesFilterArgs) ToGetInstancesFilterOutputWithContext(ctx context.Context) GetInstancesFilterOutput

type GetInstancesFilterArray 

type GetInstancesFilterArray []GetInstancesFilterInput

func (GetInstancesFilterArray) ElementType 

func (GetInstancesFilterArray) ElementType() reflect.Type

func (GetInstancesFilterArray) ToGetInstancesFilterArrayOutput 

func (i GetInstancesFilterArray) ToGetInstancesFilterArrayOutput() GetInstancesFilterArrayOutput

func (GetInstancesFilterArray) ToGetInstancesFilterArrayOutputWithContext 

func (i GetInstancesFilterArray) ToGetInstancesFilterArrayOutputWithContext(ctx context.Context) GetInstancesFilterArrayOutput

type GetInstancesFilterArrayInput 

type GetInstancesFilterArrayInput interface {
	pulumi.Input

	ToGetInstancesFilterArrayOutput() GetInstancesFilterArrayOutput
	ToGetInstancesFilterArrayOutputWithContext(context.Context) GetInstancesFilterArrayOutput
}

GetInstancesFilterArrayInput is an input type that accepts GetInstancesFilterArray and GetInstancesFilterArrayOutput values. You can construct a concrete instance of `GetInstancesFilterArrayInput` via: 

GetInstancesFilterArray{ GetInstancesFilterArgs{...} }

type GetInstancesFilterArrayOutput 

type GetInstancesFilterArrayOutput struct{ *pulumi.OutputState }

func (GetInstancesFilterArrayOutput) ElementType 

func (GetInstancesFilterArrayOutput) ElementType() reflect.Type

func (GetInstancesFilterArrayOutput) Index 

func (o GetInstancesFilterArrayOutput) Index(i pulumi.IntInput) GetInstancesFilterOutput

func (GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutput 

func (o GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutput() GetInstancesFilterArrayOutput

func (GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutputWithContext 

func (o GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutputWithContext(ctx context.Context) GetInstancesFilterArrayOutput

type GetInstancesFilterInput 

type GetInstancesFilterInput interface {
	pulumi.Input

	ToGetInstancesFilterOutput() GetInstancesFilterOutput
	ToGetInstancesFilterOutputWithContext(context.Context) GetInstancesFilterOutput
}

GetInstancesFilterInput is an input type that accepts GetInstancesFilterArgs and GetInstancesFilterOutput values. You can construct a concrete instance of `GetInstancesFilterInput` via: 

GetInstancesFilterArgs{...}

type GetInstancesFilterOutput 

type GetInstancesFilterOutput struct{ *pulumi.OutputState }

func (GetInstancesFilterOutput) ElementType 

func (GetInstancesFilterOutput) ElementType() reflect.Type

func (GetInstancesFilterOutput) Name 

func (o GetInstancesFilterOutput) Name() pulumi.StringOutput

The field that needs to be filtered.

func (GetInstancesFilterOutput) ToGetInstancesFilterOutput 

func (o GetInstancesFilterOutput) ToGetInstancesFilterOutput() GetInstancesFilterOutput

func (GetInstancesFilterOutput) ToGetInstancesFilterOutputWithContext 

func (o GetInstancesFilterOutput) ToGetInstancesFilterOutputWithContext(ctx context.Context) GetInstancesFilterOutput

func (GetInstancesFilterOutput) Values 

func (o GetInstancesFilterOutput) Values() pulumi.StringArrayOutput

The filtered value of the field.

type GetInstancesInstanceList 

type GetInstancesInstanceList struct {
	// Instance bandwidth, in Mbps.
	Bandwidth int `pulumi:"bandwidth"`
	// The time when the instance was created.
	CreateTime int `pulumi:"createTime"`
	// ckafka sale type. Note: This field may return null, indicating that a valid value could not be retrieved.
	Cvm int `pulumi:"cvm"`
	// The storage size of the instance, in GB.
	DiskSize int `pulumi:"diskSize"`
	// Disk Type. Note: This field may return null, indicating that a valid value could not be retrieved.
	DiskType string `pulumi:"diskType"`
	// The instance expiration time.
	ExpireTime int `pulumi:"expireTime"`
	// Instance status int: 1 indicates health, 2 indicates alarm, and 3 indicates abnormal instance status.
	Healthy int `pulumi:"healthy"`
	// Instance status information.
	HealthyMessage string `pulumi:"healthyMessage"`
	// The instance ID.
	InstanceId string `pulumi:"instanceId"`
	// The instance name.
	InstanceName string `pulumi:"instanceName"`
	// ckafka instance type. Note: This field may return null, indicating that a valid value could not be retrieved.
	InstanceType string `pulumi:"instanceType"`
	// Whether it is an internal customer. A value of 1 indicates an internal customer.
	IsInternal int `pulumi:"isInternal"`
	// The maximum number of Partitions for the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved.
	MaxPartitionNumber int `pulumi:"maxPartitionNumber"`
	// The maximum number of topics in the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved..
	MaxTopicNumber int `pulumi:"maxTopicNumber"`
	// The current number of instances. Note: This field may return null, indicating that a valid value could not be retrieved..
	PartitionNumber int `pulumi:"partitionNumber"`
	// The Internet bandwidth value. Note: This field may return null, indicating that a valid value could not be retrieved..
	PublicNetwork int `pulumi:"publicNetwork"`
	// The type of Internet bandwidth. Note: This field may return null, indicating that a valid value could not be retrieved..
	PublicNetworkChargeType string `pulumi:"publicNetworkChargeType"`
	// Schedule the upgrade configuration time. Note: This field may return null, indicating that a valid value could not be retrieved..
	RebalanceTime string `pulumi:"rebalanceTime"`
	// Whether the instance is renewed, the int enumeration value: 1 indicates auto-renewal, and 2 indicates that it is not automatically renewed.
	RenewFlag int `pulumi:"renewFlag"`
	// (Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all.
	Status int `pulumi:"status"`
	// Subnet id.
	SubnetId string `pulumi:"subnetId"`
	// Tag infomation.
	Tags []GetInstancesInstanceListTag `pulumi:"tags"`
	// The number of topics.
	TopicNum int `pulumi:"topicNum"`
	// Kafka version information. Note: This field may return null, indicating that a valid value could not be retrieved.
	Version string `pulumi:"version"`
	// Virtual IP.
	Vip string `pulumi:"vip"`
	// Virtual IP entities.
	VipList GetInstancesInstanceListVipList `pulumi:"vipList"`
	// VpcId, if empty, indicates that it is the underlying network.
	VpcId string `pulumi:"vpcId"`
	// Virtual PORT.
	Vport string `pulumi:"vport"`
	// Availability Zone ID.
	ZoneId int `pulumi:"zoneId"`
	// Across Availability Zones. Note: This field may return null, indicating that a valid value could not be retrieved.
	ZoneIds []int `pulumi:"zoneIds"`
}

type GetInstancesInstanceListArgs 

type GetInstancesInstanceListArgs struct {
	// Instance bandwidth, in Mbps.
	Bandwidth pulumi.IntInput `pulumi:"bandwidth"`
	// The time when the instance was created.
	CreateTime pulumi.IntInput `pulumi:"createTime"`
	// ckafka sale type. Note: This field may return null, indicating that a valid value could not be retrieved.
	Cvm pulumi.IntInput `pulumi:"cvm"`
	// The storage size of the instance, in GB.
	DiskSize pulumi.IntInput `pulumi:"diskSize"`
	// Disk Type. Note: This field may return null, indicating that a valid value could not be retrieved.
	DiskType pulumi.StringInput `pulumi:"diskType"`
	// The instance expiration time.
	ExpireTime pulumi.IntInput `pulumi:"expireTime"`
	// Instance status int: 1 indicates health, 2 indicates alarm, and 3 indicates abnormal instance status.
	Healthy pulumi.IntInput `pulumi:"healthy"`
	// Instance status information.
	HealthyMessage pulumi.StringInput `pulumi:"healthyMessage"`
	// The instance ID.
	InstanceId pulumi.StringInput `pulumi:"instanceId"`
	// The instance name.
	InstanceName pulumi.StringInput `pulumi:"instanceName"`
	// ckafka instance type. Note: This field may return null, indicating that a valid value could not be retrieved.
	InstanceType pulumi.StringInput `pulumi:"instanceType"`
	// Whether it is an internal customer. A value of 1 indicates an internal customer.
	IsInternal pulumi.IntInput `pulumi:"isInternal"`
	// The maximum number of Partitions for the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved.
	MaxPartitionNumber pulumi.IntInput `pulumi:"maxPartitionNumber"`
	// The maximum number of topics in the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved..
	MaxTopicNumber pulumi.IntInput `pulumi:"maxTopicNumber"`
	// The current number of instances. Note: This field may return null, indicating that a valid value could not be retrieved..
	PartitionNumber pulumi.IntInput `pulumi:"partitionNumber"`
	// The Internet bandwidth value. Note: This field may return null, indicating that a valid value could not be retrieved..
	PublicNetwork pulumi.IntInput `pulumi:"publicNetwork"`
	// The type of Internet bandwidth. Note: This field may return null, indicating that a valid value could not be retrieved..
	PublicNetworkChargeType pulumi.StringInput `pulumi:"publicNetworkChargeType"`
	// Schedule the upgrade configuration time. Note: This field may return null, indicating that a valid value could not be retrieved..
	RebalanceTime pulumi.StringInput `pulumi:"rebalanceTime"`
	// Whether the instance is renewed, the int enumeration value: 1 indicates auto-renewal, and 2 indicates that it is not automatically renewed.
	RenewFlag pulumi.IntInput `pulumi:"renewFlag"`
	// (Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all.
	Status pulumi.IntInput `pulumi:"status"`
	// Subnet id.
	SubnetId pulumi.StringInput `pulumi:"subnetId"`
	// Tag infomation.
	Tags GetInstancesInstanceListTagArrayInput `pulumi:"tags"`
	// The number of topics.
	TopicNum pulumi.IntInput `pulumi:"topicNum"`
	// Kafka version information. Note: This field may return null, indicating that a valid value could not be retrieved.
	Version pulumi.StringInput `pulumi:"version"`
	// Virtual IP.
	Vip pulumi.StringInput `pulumi:"vip"`
	// Virtual IP entities.
	VipList GetInstancesInstanceListVipListInput `pulumi:"vipList"`
	// VpcId, if empty, indicates that it is the underlying network.
	VpcId pulumi.StringInput `pulumi:"vpcId"`
	// Virtual PORT.
	Vport pulumi.StringInput `pulumi:"vport"`
	// Availability Zone ID.
	ZoneId pulumi.IntInput `pulumi:"zoneId"`
	// Across Availability Zones. Note: This field may return null, indicating that a valid value could not be retrieved.
	ZoneIds pulumi.IntArrayInput `pulumi:"zoneIds"`
}

func (GetInstancesInstanceListArgs) ElementType 

func (GetInstancesInstanceListArgs) ElementType() reflect.Type

func (GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutput 

func (i GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput

func (GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutputWithContext 

func (i GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutputWithContext(ctx context.Context) GetInstancesInstanceListOutput

type GetInstancesInstanceListArray 

type GetInstancesInstanceListArray []GetInstancesInstanceListInput

func (GetInstancesInstanceListArray) ElementType 

func (GetInstancesInstanceListArray) ElementType() reflect.Type

func (GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutput 

func (i GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput

func (GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutputWithContext 

func (i GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListArrayOutput

type GetInstancesInstanceListArrayInput 

type GetInstancesInstanceListArrayInput interface {
	pulumi.Input

	ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput
	ToGetInstancesInstanceListArrayOutputWithContext(context.Context) GetInstancesInstanceListArrayOutput
}

GetInstancesInstanceListArrayInput is an input type that accepts GetInstancesInstanceListArray and GetInstancesInstanceListArrayOutput values. You can construct a concrete instance of `GetInstancesInstanceListArrayInput` via: 

GetInstancesInstanceListArray{ GetInstancesInstanceListArgs{...} }

type GetInstancesInstanceListArrayOutput 

type GetInstancesInstanceListArrayOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceListArrayOutput) ElementType 

func (GetInstancesInstanceListArrayOutput) ElementType() reflect.Type

func (GetInstancesInstanceListArrayOutput) Index 

func (o GetInstancesInstanceListArrayOutput) Index(i pulumi.IntInput) GetInstancesInstanceListOutput

func (GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutput 

func (o GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput

func (GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutputWithContext 

func (o GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListArrayOutput

type GetInstancesInstanceListInput 

type GetInstancesInstanceListInput interface {
	pulumi.Input

	ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput
	ToGetInstancesInstanceListOutputWithContext(context.Context) GetInstancesInstanceListOutput
}

GetInstancesInstanceListInput is an input type that accepts GetInstancesInstanceListArgs and GetInstancesInstanceListOutput values. You can construct a concrete instance of `GetInstancesInstanceListInput` via: 

GetInstancesInstanceListArgs{...}

type GetInstancesInstanceListOutput 

type GetInstancesInstanceListOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceListOutput) Bandwidth 

func (o GetInstancesInstanceListOutput) Bandwidth() pulumi.IntOutput

Instance bandwidth, in Mbps.

func (GetInstancesInstanceListOutput) CreateTime 

func (o GetInstancesInstanceListOutput) CreateTime() pulumi.IntOutput

The time when the instance was created.

func (GetInstancesInstanceListOutput) Cvm 

func (o GetInstancesInstanceListOutput) Cvm() pulumi.IntOutput

ckafka sale type. Note: This field may return null, indicating that a valid value could not be retrieved.

func (GetInstancesInstanceListOutput) DiskSize 

func (o GetInstancesInstanceListOutput) DiskSize() pulumi.IntOutput

The storage size of the instance, in GB.

func (GetInstancesInstanceListOutput) DiskType 

func (o GetInstancesInstanceListOutput) DiskType() pulumi.StringOutput

Disk Type. Note: This field may return null, indicating that a valid value could not be retrieved.

func (GetInstancesInstanceListOutput) ElementType 

func (GetInstancesInstanceListOutput) ElementType() reflect.Type

func (GetInstancesInstanceListOutput) ExpireTime 

func (o GetInstancesInstanceListOutput) ExpireTime() pulumi.IntOutput

The instance expiration time.

func (GetInstancesInstanceListOutput) Healthy 

func (o GetInstancesInstanceListOutput) Healthy() pulumi.IntOutput

Instance status int: 1 indicates health, 2 indicates alarm, and 3 indicates abnormal instance status.

func (GetInstancesInstanceListOutput) HealthyMessage 

func (o GetInstancesInstanceListOutput) HealthyMessage() pulumi.StringOutput

Instance status information.

func (GetInstancesInstanceListOutput) InstanceId 

func (o GetInstancesInstanceListOutput) InstanceId() pulumi.StringOutput

The instance ID.

func (GetInstancesInstanceListOutput) InstanceName 

func (o GetInstancesInstanceListOutput) InstanceName() pulumi.StringOutput

The instance name.

func (GetInstancesInstanceListOutput) InstanceType 

func (o GetInstancesInstanceListOutput) InstanceType() pulumi.StringOutput

ckafka instance type. Note: This field may return null, indicating that a valid value could not be retrieved.

func (GetInstancesInstanceListOutput) IsInternal 

func (o GetInstancesInstanceListOutput) IsInternal() pulumi.IntOutput

Whether it is an internal customer. A value of 1 indicates an internal customer.

func (GetInstancesInstanceListOutput) MaxPartitionNumber 

func (o GetInstancesInstanceListOutput) MaxPartitionNumber() pulumi.IntOutput

The maximum number of Partitions for the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved.

func (GetInstancesInstanceListOutput) MaxTopicNumber 

func (o GetInstancesInstanceListOutput) MaxTopicNumber() pulumi.IntOutput

The maximum number of topics in the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved..

func (GetInstancesInstanceListOutput) PartitionNumber 

func (o GetInstancesInstanceListOutput) PartitionNumber() pulumi.IntOutput

The current number of instances. Note: This field may return null, indicating that a valid value could not be retrieved..

func (GetInstancesInstanceListOutput) PublicNetwork 

func (o GetInstancesInstanceListOutput) PublicNetwork() pulumi.IntOutput

The Internet bandwidth value. Note: This field may return null, indicating that a valid value could not be retrieved..

func (GetInstancesInstanceListOutput) PublicNetworkChargeType 

func (o GetInstancesInstanceListOutput) PublicNetworkChargeType() pulumi.StringOutput

The type of Internet bandwidth. Note: This field may return null, indicating that a valid value could not be retrieved..

func (GetInstancesInstanceListOutput) RebalanceTime 

func (o GetInstancesInstanceListOutput) RebalanceTime() pulumi.StringOutput

Schedule the upgrade configuration time. Note: This field may return null, indicating that a valid value could not be retrieved..

func (GetInstancesInstanceListOutput) RenewFlag 

func (o GetInstancesInstanceListOutput) RenewFlag() pulumi.IntOutput

Whether the instance is renewed, the int enumeration value: 1 indicates auto-renewal, and 2 indicates that it is not automatically renewed.

func (GetInstancesInstanceListOutput) Status 

func (o GetInstancesInstanceListOutput) Status() pulumi.IntOutput

(Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all.

func (GetInstancesInstanceListOutput) SubnetId 

func (o GetInstancesInstanceListOutput) SubnetId() pulumi.StringOutput

Subnet id.

func (GetInstancesInstanceListOutput) Tags 

func (o GetInstancesInstanceListOutput) Tags() GetInstancesInstanceListTagArrayOutput

Tag infomation.

func (GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutput 

func (o GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput

func (GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutputWithContext 

func (o GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutputWithContext(ctx context.Context) GetInstancesInstanceListOutput

func (GetInstancesInstanceListOutput) TopicNum 

func (o GetInstancesInstanceListOutput) TopicNum() pulumi.IntOutput

The number of topics.

func (GetInstancesInstanceListOutput) Version 

func (o GetInstancesInstanceListOutput) Version() pulumi.StringOutput

Kafka version information. Note: This field may return null, indicating that a valid value could not be retrieved.

func (GetInstancesInstanceListOutput) Vip 

func (o GetInstancesInstanceListOutput) Vip() pulumi.StringOutput

Virtual IP.

func (GetInstancesInstanceListOutput) VipList 

func (o GetInstancesInstanceListOutput) VipList() GetInstancesInstanceListVipListOutput

Virtual IP entities.

func (GetInstancesInstanceListOutput) VpcId 

func (o GetInstancesInstanceListOutput) VpcId() pulumi.StringOutput

VpcId, if empty, indicates that it is the underlying network.

func (GetInstancesInstanceListOutput) Vport 

func (o GetInstancesInstanceListOutput) Vport() pulumi.StringOutput

Virtual PORT.

func (GetInstancesInstanceListOutput) ZoneId 

func (o GetInstancesInstanceListOutput) ZoneId() pulumi.IntOutput

Availability Zone ID.

func (GetInstancesInstanceListOutput) ZoneIds 

func (o GetInstancesInstanceListOutput) ZoneIds() pulumi.IntArrayOutput

Across Availability Zones. Note: This field may return null, indicating that a valid value could not be retrieved.

type GetInstancesInstanceListTag 

type GetInstancesInstanceListTag struct {
	// Matches the tag key value.
	TagKey string `pulumi:"tagKey"`
	// Tag Value.
	TagValue string `pulumi:"tagValue"`
}

type GetInstancesInstanceListTagArgs 

type GetInstancesInstanceListTagArgs struct {
	// Matches the tag key value.
	TagKey pulumi.StringInput `pulumi:"tagKey"`
	// Tag Value.
	TagValue pulumi.StringInput `pulumi:"tagValue"`
}

func (GetInstancesInstanceListTagArgs) ElementType 

func (GetInstancesInstanceListTagArgs) ElementType() reflect.Type

func (GetInstancesInstanceListTagArgs) ToGetInstancesInstanceListTagOutput 

func (i GetInstancesInstanceListTagArgs) ToGetInstancesInstanceListTagOutput() GetInstancesInstanceListTagOutput

func (GetInstancesInstanceListTagArgs) ToGetInstancesInstanceListTagOutputWithContext 

func (i GetInstancesInstanceListTagArgs) ToGetInstancesInstanceListTagOutputWithContext(ctx context.Context) GetInstancesInstanceListTagOutput

type GetInstancesInstanceListTagArray 

type GetInstancesInstanceListTagArray []GetInstancesInstanceListTagInput

func (GetInstancesInstanceListTagArray) ElementType 

func (GetInstancesInstanceListTagArray) ElementType() reflect.Type

func (GetInstancesInstanceListTagArray) ToGetInstancesInstanceListTagArrayOutput 

func (i GetInstancesInstanceListTagArray) ToGetInstancesInstanceListTagArrayOutput() GetInstancesInstanceListTagArrayOutput

func (GetInstancesInstanceListTagArray) ToGetInstancesInstanceListTagArrayOutputWithContext 

func (i GetInstancesInstanceListTagArray) ToGetInstancesInstanceListTagArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListTagArrayOutput

type GetInstancesInstanceListTagArrayInput 

type GetInstancesInstanceListTagArrayInput interface {
	pulumi.Input

	ToGetInstancesInstanceListTagArrayOutput() GetInstancesInstanceListTagArrayOutput
	ToGetInstancesInstanceListTagArrayOutputWithContext(context.Context) GetInstancesInstanceListTagArrayOutput
}

GetInstancesInstanceListTagArrayInput is an input type that accepts GetInstancesInstanceListTagArray and GetInstancesInstanceListTagArrayOutput values. You can construct a concrete instance of `GetInstancesInstanceListTagArrayInput` via: 

GetInstancesInstanceListTagArray{ GetInstancesInstanceListTagArgs{...} }

type GetInstancesInstanceListTagArrayOutput 

type GetInstancesInstanceListTagArrayOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceListTagArrayOutput) ElementType 

func (GetInstancesInstanceListTagArrayOutput) ElementType() reflect.Type

func (GetInstancesInstanceListTagArrayOutput) Index 

func (o GetInstancesInstanceListTagArrayOutput) Index(i pulumi.IntInput) GetInstancesInstanceListTagOutput

func (GetInstancesInstanceListTagArrayOutput) ToGetInstancesInstanceListTagArrayOutput 

func (o GetInstancesInstanceListTagArrayOutput) ToGetInstancesInstanceListTagArrayOutput() GetInstancesInstanceListTagArrayOutput

func (GetInstancesInstanceListTagArrayOutput) ToGetInstancesInstanceListTagArrayOutputWithContext 

func (o GetInstancesInstanceListTagArrayOutput) ToGetInstancesInstanceListTagArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListTagArrayOutput

type GetInstancesInstanceListTagInput 

type GetInstancesInstanceListTagInput interface {
	pulumi.Input

	ToGetInstancesInstanceListTagOutput() GetInstancesInstanceListTagOutput
	ToGetInstancesInstanceListTagOutputWithContext(context.Context) GetInstancesInstanceListTagOutput
}

GetInstancesInstanceListTagInput is an input type that accepts GetInstancesInstanceListTagArgs and GetInstancesInstanceListTagOutput values. You can construct a concrete instance of `GetInstancesInstanceListTagInput` via: 

GetInstancesInstanceListTagArgs{...}

type GetInstancesInstanceListTagOutput 

type GetInstancesInstanceListTagOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceListTagOutput) ElementType 

func (GetInstancesInstanceListTagOutput) ElementType() reflect.Type

func (GetInstancesInstanceListTagOutput) TagKey 

func (o GetInstancesInstanceListTagOutput) TagKey() pulumi.StringOutput

Matches the tag key value.

func (GetInstancesInstanceListTagOutput) TagValue 

func (o GetInstancesInstanceListTagOutput) TagValue() pulumi.StringOutput

Tag Value.

func (GetInstancesInstanceListTagOutput) ToGetInstancesInstanceListTagOutput 

func (o GetInstancesInstanceListTagOutput) ToGetInstancesInstanceListTagOutput() GetInstancesInstanceListTagOutput

func (GetInstancesInstanceListTagOutput) ToGetInstancesInstanceListTagOutputWithContext 

func (o GetInstancesInstanceListTagOutput) ToGetInstancesInstanceListTagOutputWithContext(ctx context.Context) GetInstancesInstanceListTagOutput

type GetInstancesInstanceListVipList 

type GetInstancesInstanceListVipList struct {
	// Virtual IP.
	Vip string `pulumi:"vip"`
	// Virtual PORT.
	Vport string `pulumi:"vport"`
}

type GetInstancesInstanceListVipListArgs 

type GetInstancesInstanceListVipListArgs struct {
	// Virtual IP.
	Vip pulumi.StringInput `pulumi:"vip"`
	// Virtual PORT.
	Vport pulumi.StringInput `pulumi:"vport"`
}

func (GetInstancesInstanceListVipListArgs) ElementType 

func (GetInstancesInstanceListVipListArgs) ElementType() reflect.Type

func (GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutput 

func (i GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput

func (GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutputWithContext 

func (i GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutputWithContext(ctx context.Context) GetInstancesInstanceListVipListOutput

type GetInstancesInstanceListVipListInput 

type GetInstancesInstanceListVipListInput interface {
	pulumi.Input

	ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput
	ToGetInstancesInstanceListVipListOutputWithContext(context.Context) GetInstancesInstanceListVipListOutput
}

GetInstancesInstanceListVipListInput is an input type that accepts GetInstancesInstanceListVipListArgs and GetInstancesInstanceListVipListOutput values. You can construct a concrete instance of `GetInstancesInstanceListVipListInput` via: 

GetInstancesInstanceListVipListArgs{...}

type GetInstancesInstanceListVipListOutput 

type GetInstancesInstanceListVipListOutput struct{ *pulumi.OutputState }

func (GetInstancesInstanceListVipListOutput) ElementType 

func (GetInstancesInstanceListVipListOutput) ElementType() reflect.Type

func (GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutput 

func (o GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput

func (GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutputWithContext 

func (o GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutputWithContext(ctx context.Context) GetInstancesInstanceListVipListOutput

func (GetInstancesInstanceListVipListOutput) Vip 

func (o GetInstancesInstanceListVipListOutput) Vip() pulumi.StringOutput

Virtual IP.

func (GetInstancesInstanceListVipListOutput) Vport 

func (o GetInstancesInstanceListVipListOutput) Vport() pulumi.StringOutput

Virtual PORT.

type GetInstancesOutputArgs 

type GetInstancesOutputArgs struct {
	// Filter. filter.name supports ('Ip', 'VpcId', 'SubNetId', 'InstanceType','InstanceId'), filter.values can pass up to 10 values.
	Filters GetInstancesFilterArrayInput `pulumi:"filters"`
	// Filter by instance ID.
	InstanceIds pulumi.StringArrayInput `pulumi:"instanceIds"`
	// The number of pages, default is `10`.
	Limit pulumi.IntPtrInput `pulumi:"limit"`
	// The page start offset, default is `0`.
	Offset pulumi.IntPtrInput `pulumi:"offset"`
	// Used to save results.
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
	// Filter by instance name, support fuzzy query.
	SearchWord pulumi.StringPtrInput `pulumi:"searchWord"`
	// (Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all.
	Statuses pulumi.IntArrayInput `pulumi:"statuses"`
	// Matches the tag key value.
	TagKey pulumi.StringPtrInput `pulumi:"tagKey"`
}

A collection of arguments for invoking getInstances.

func (GetInstancesOutputArgs) ElementType 

func (GetInstancesOutputArgs) ElementType() reflect.Type

type GetInstancesResult 

type GetInstancesResult struct {
	Filters []GetInstancesFilter `pulumi:"filters"`
	// The provider-assigned unique ID for this managed resource.
	Id          string   `pulumi:"id"`
	InstanceIds []string `pulumi:"instanceIds"`
	// A list of ckafka users. Each element contains the following attributes:
	InstanceLists    []GetInstancesInstanceList `pulumi:"instanceLists"`
	Limit            *int                       `pulumi:"limit"`
	Offset           *int                       `pulumi:"offset"`
	ResultOutputFile *string                    `pulumi:"resultOutputFile"`
	SearchWord       *string                    `pulumi:"searchWord"`
	// The status of the instance. 0: Created, 1: Running, 2: Delete: 5 Quarantined, -1 Creation failed.
	Statuses []int `pulumi:"statuses"`
	// Tag Key.
	TagKey *string `pulumi:"tagKey"`
}

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 detailed instance information of Ckafka

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.GetInstances(ctx, &ckafka.GetInstancesArgs{
			InstanceIds: []string{
				"ckafka-vv7wpvae",
			},
		}, 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) Filters 

func (o GetInstancesResultOutput) Filters() GetInstancesFilterArrayOutput

func (GetInstancesResultOutput) Id 

func (o GetInstancesResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetInstancesResultOutput) InstanceIds 

func (o GetInstancesResultOutput) InstanceIds() pulumi.StringArrayOutput

func (GetInstancesResultOutput) InstanceLists 

func (o GetInstancesResultOutput) InstanceLists() GetInstancesInstanceListArrayOutput

A list of ckafka users. Each element contains the following attributes:

func (GetInstancesResultOutput) Limit 

func (o GetInstancesResultOutput) Limit() pulumi.IntPtrOutput

func (GetInstancesResultOutput) Offset 

func (o GetInstancesResultOutput) Offset() pulumi.IntPtrOutput

func (GetInstancesResultOutput) ResultOutputFile 

func (o GetInstancesResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (GetInstancesResultOutput) SearchWord 

func (o GetInstancesResultOutput) SearchWord() pulumi.StringPtrOutput

func (GetInstancesResultOutput) Statuses 

func (o GetInstancesResultOutput) Statuses() pulumi.IntArrayOutput

The status of the instance. 0: Created, 1: Running, 2: Delete: 5 Quarantined, -1 Creation failed.

func (GetInstancesResultOutput) TagKey 

func (o GetInstancesResultOutput) TagKey() pulumi.StringPtrOutput

Tag Key.

func (GetInstancesResultOutput) ToGetInstancesResultOutput 

func (o GetInstancesResultOutput) ToGetInstancesResultOutput() GetInstancesResultOutput

func (GetInstancesResultOutput) ToGetInstancesResultOutputWithContext 

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

type GetTopicsArgs 

type GetTopicsArgs struct {
	// Ckafka instance ID.
	InstanceId string `pulumi:"instanceId"`
	// Used to store results.
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64.
	TopicName *string `pulumi:"topicName"`
}

A collection of arguments for invoking getTopics.

type GetTopicsInstanceList 

type GetTopicsInstanceList struct {
	// Clear log policy, log clear mode. `delete`: logs are deleted according to the storage time, `compact`: logs are compressed according to the key, `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	CleanUpPolicy string `pulumi:"cleanUpPolicy"`
	// Create time of the CKafka topic.
	CreateTime string `pulumi:"createTime"`
	// Whether to open the IP Whitelist. `true`: open, `false`: close.
	EnableWhiteList bool `pulumi:"enableWhiteList"`
	// Data backup cos bucket: the bucket address that is dumped to cos.
	ForwardCosBucket string `pulumi:"forwardCosBucket"`
	// Periodic frequency of data backup to cos.
	ForwardInterval int `pulumi:"forwardInterval"`
	// Data backup cos status. `1`: do not open data backup, `0`: open data backup.
	ForwardStatus int `pulumi:"forwardStatus"`
	// IP Whitelist count.
	IpWhiteListCount int `pulumi:"ipWhiteListCount"`
	// Max message bytes.
	MaxMessageBytes int `pulumi:"maxMessageBytes"`
	// CKafka topic note description.
	Note string `pulumi:"note"`
	// The number of partition.
	PartitionNum int `pulumi:"partitionNum"`
	// The number of replica.
	ReplicaNum int `pulumi:"replicaNum"`
	// Message can be selected. Retention time(unit ms).
	Retention int `pulumi:"retention"`
	// Segment scrolling time, in ms.
	Segment int `pulumi:"segment"`
	// Number of bytes rolled by shard.
	SegmentBytes int `pulumi:"segmentBytes"`
	// Min number of sync replicas.
	SyncReplicaMinNum int `pulumi:"syncReplicaMinNum"`
	// ID of the CKafka topic.
	TopicId string `pulumi:"topicId"`
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64.
	TopicName string `pulumi:"topicName"`
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true:  `allowed, `false`: not allowed.
	UncleanLeaderElectionEnable bool `pulumi:"uncleanLeaderElectionEnable"`
}

type GetTopicsInstanceListArgs 

type GetTopicsInstanceListArgs struct {
	// Clear log policy, log clear mode. `delete`: logs are deleted according to the storage time, `compact`: logs are compressed according to the key, `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	CleanUpPolicy pulumi.StringInput `pulumi:"cleanUpPolicy"`
	// Create time of the CKafka topic.
	CreateTime pulumi.StringInput `pulumi:"createTime"`
	// Whether to open the IP Whitelist. `true`: open, `false`: close.
	EnableWhiteList pulumi.BoolInput `pulumi:"enableWhiteList"`
	// Data backup cos bucket: the bucket address that is dumped to cos.
	ForwardCosBucket pulumi.StringInput `pulumi:"forwardCosBucket"`
	// Periodic frequency of data backup to cos.
	ForwardInterval pulumi.IntInput `pulumi:"forwardInterval"`
	// Data backup cos status. `1`: do not open data backup, `0`: open data backup.
	ForwardStatus pulumi.IntInput `pulumi:"forwardStatus"`
	// IP Whitelist count.
	IpWhiteListCount pulumi.IntInput `pulumi:"ipWhiteListCount"`
	// Max message bytes.
	MaxMessageBytes pulumi.IntInput `pulumi:"maxMessageBytes"`
	// CKafka topic note description.
	Note pulumi.StringInput `pulumi:"note"`
	// The number of partition.
	PartitionNum pulumi.IntInput `pulumi:"partitionNum"`
	// The number of replica.
	ReplicaNum pulumi.IntInput `pulumi:"replicaNum"`
	// Message can be selected. Retention time(unit ms).
	Retention pulumi.IntInput `pulumi:"retention"`
	// Segment scrolling time, in ms.
	Segment pulumi.IntInput `pulumi:"segment"`
	// Number of bytes rolled by shard.
	SegmentBytes pulumi.IntInput `pulumi:"segmentBytes"`
	// Min number of sync replicas.
	SyncReplicaMinNum pulumi.IntInput `pulumi:"syncReplicaMinNum"`
	// ID of the CKafka topic.
	TopicId pulumi.StringInput `pulumi:"topicId"`
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64.
	TopicName pulumi.StringInput `pulumi:"topicName"`
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true:  `allowed, `false`: not allowed.
	UncleanLeaderElectionEnable pulumi.BoolInput `pulumi:"uncleanLeaderElectionEnable"`
}

func (GetTopicsInstanceListArgs) ElementType 

func (GetTopicsInstanceListArgs) ElementType() reflect.Type

func (GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutput 

func (i GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutput() GetTopicsInstanceListOutput

func (GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutputWithContext 

func (i GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutputWithContext(ctx context.Context) GetTopicsInstanceListOutput

type GetTopicsInstanceListArray 

type GetTopicsInstanceListArray []GetTopicsInstanceListInput

func (GetTopicsInstanceListArray) ElementType 

func (GetTopicsInstanceListArray) ElementType() reflect.Type

func (GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutput 

func (i GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput

func (GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutputWithContext 

func (i GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutputWithContext(ctx context.Context) GetTopicsInstanceListArrayOutput

type GetTopicsInstanceListArrayInput 

type GetTopicsInstanceListArrayInput interface {
	pulumi.Input

	ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput
	ToGetTopicsInstanceListArrayOutputWithContext(context.Context) GetTopicsInstanceListArrayOutput
}

GetTopicsInstanceListArrayInput is an input type that accepts GetTopicsInstanceListArray and GetTopicsInstanceListArrayOutput values. You can construct a concrete instance of `GetTopicsInstanceListArrayInput` via: 

GetTopicsInstanceListArray{ GetTopicsInstanceListArgs{...} }

type GetTopicsInstanceListArrayOutput 

type GetTopicsInstanceListArrayOutput struct{ *pulumi.OutputState }

func (GetTopicsInstanceListArrayOutput) ElementType 

func (GetTopicsInstanceListArrayOutput) ElementType() reflect.Type

func (GetTopicsInstanceListArrayOutput) Index 

func (o GetTopicsInstanceListArrayOutput) Index(i pulumi.IntInput) GetTopicsInstanceListOutput

func (GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutput 

func (o GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput

func (GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutputWithContext 

func (o GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutputWithContext(ctx context.Context) GetTopicsInstanceListArrayOutput

type GetTopicsInstanceListInput 

type GetTopicsInstanceListInput interface {
	pulumi.Input

	ToGetTopicsInstanceListOutput() GetTopicsInstanceListOutput
	ToGetTopicsInstanceListOutputWithContext(context.Context) GetTopicsInstanceListOutput
}

GetTopicsInstanceListInput is an input type that accepts GetTopicsInstanceListArgs and GetTopicsInstanceListOutput values. You can construct a concrete instance of `GetTopicsInstanceListInput` via: 

GetTopicsInstanceListArgs{...}

type GetTopicsInstanceListOutput 

type GetTopicsInstanceListOutput struct{ *pulumi.OutputState }

func (GetTopicsInstanceListOutput) CleanUpPolicy 

func (o GetTopicsInstanceListOutput) CleanUpPolicy() pulumi.StringOutput

Clear log policy, log clear mode. `delete`: logs are deleted according to the storage time, `compact`: logs are compressed according to the key, `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.

func (GetTopicsInstanceListOutput) CreateTime 

func (o GetTopicsInstanceListOutput) CreateTime() pulumi.StringOutput

Create time of the CKafka topic.

func (GetTopicsInstanceListOutput) ElementType 

func (GetTopicsInstanceListOutput) ElementType() reflect.Type

func (GetTopicsInstanceListOutput) EnableWhiteList 

func (o GetTopicsInstanceListOutput) EnableWhiteList() pulumi.BoolOutput

Whether to open the IP Whitelist. `true`: open, `false`: close.

func (GetTopicsInstanceListOutput) ForwardCosBucket 

func (o GetTopicsInstanceListOutput) ForwardCosBucket() pulumi.StringOutput

Data backup cos bucket: the bucket address that is dumped to cos.

func (GetTopicsInstanceListOutput) ForwardInterval 

func (o GetTopicsInstanceListOutput) ForwardInterval() pulumi.IntOutput

Periodic frequency of data backup to cos.

func (GetTopicsInstanceListOutput) ForwardStatus 

func (o GetTopicsInstanceListOutput) ForwardStatus() pulumi.IntOutput

Data backup cos status. `1`: do not open data backup, `0`: open data backup.

func (GetTopicsInstanceListOutput) IpWhiteListCount 

func (o GetTopicsInstanceListOutput) IpWhiteListCount() pulumi.IntOutput

IP Whitelist count.

func (GetTopicsInstanceListOutput) MaxMessageBytes 

func (o GetTopicsInstanceListOutput) MaxMessageBytes() pulumi.IntOutput

Max message bytes.

func (GetTopicsInstanceListOutput) Note 

func (o GetTopicsInstanceListOutput) Note() pulumi.StringOutput

CKafka topic note description.

func (GetTopicsInstanceListOutput) PartitionNum 

func (o GetTopicsInstanceListOutput) PartitionNum() pulumi.IntOutput

The number of partition.

func (GetTopicsInstanceListOutput) ReplicaNum 

func (o GetTopicsInstanceListOutput) ReplicaNum() pulumi.IntOutput

The number of replica.

func (GetTopicsInstanceListOutput) Retention 

func (o GetTopicsInstanceListOutput) Retention() pulumi.IntOutput

Message can be selected. Retention time(unit ms).

func (GetTopicsInstanceListOutput) Segment 

func (o GetTopicsInstanceListOutput) Segment() pulumi.IntOutput

Segment scrolling time, in ms.

func (GetTopicsInstanceListOutput) SegmentBytes 

func (o GetTopicsInstanceListOutput) SegmentBytes() pulumi.IntOutput

Number of bytes rolled by shard.

func (GetTopicsInstanceListOutput) SyncReplicaMinNum 

func (o GetTopicsInstanceListOutput) SyncReplicaMinNum() pulumi.IntOutput

Min number of sync replicas.

func (GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutput 

func (o GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutput() GetTopicsInstanceListOutput

func (GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutputWithContext 

func (o GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutputWithContext(ctx context.Context) GetTopicsInstanceListOutput

func (GetTopicsInstanceListOutput) TopicId 

func (o GetTopicsInstanceListOutput) TopicId() pulumi.StringOutput

ID of the CKafka topic.

func (GetTopicsInstanceListOutput) TopicName 

func (o GetTopicsInstanceListOutput) TopicName() pulumi.StringOutput

Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64.

func (GetTopicsInstanceListOutput) UncleanLeaderElectionEnable 

func (o GetTopicsInstanceListOutput) UncleanLeaderElectionEnable() pulumi.BoolOutput

Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed.

type GetTopicsOutputArgs 

type GetTopicsOutputArgs struct {
	// Ckafka instance ID.
	InstanceId pulumi.StringInput `pulumi:"instanceId"`
	// Used to store results.
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64.
	TopicName pulumi.StringPtrInput `pulumi:"topicName"`
}

A collection of arguments for invoking getTopics.

func (GetTopicsOutputArgs) ElementType 

func (GetTopicsOutputArgs) ElementType() reflect.Type

type GetTopicsResult 

type GetTopicsResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id         string `pulumi:"id"`
	InstanceId string `pulumi:"instanceId"`
	// A list of instances. Each element contains the following attributes.
	InstanceLists    []GetTopicsInstanceList `pulumi:"instanceLists"`
	ResultOutputFile *string                 `pulumi:"resultOutputFile"`
	// Name of the CKafka topic.
	TopicName *string `pulumi:"topicName"`
}

A collection of values returned by getTopics.

func GetTopics 

func GetTopics(ctx *pulumi.Context, args *GetTopicsArgs, opts ...pulumi.InvokeOption) (*GetTopicsResult, error)

Use this data source to query detailed information of ckafka topic.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.NewTopic(ctx, "foo", &Ckafka.TopicArgs{
			CleanUpPolicy:   pulumi.String("delete"),
			EnableWhiteList: pulumi.Bool(true),
			InstanceId:      pulumi.String("ckafka-f9ife4zz"),
			IpWhiteLists: pulumi.StringArray{
				pulumi.String("ip1"),
				pulumi.String("ip2"),
			},
			MaxMessageBytes:             pulumi.Int(0),
			Note:                        pulumi.String("topic note"),
			PartitionNum:                pulumi.Int(1),
			ReplicaNum:                  pulumi.Int(2),
			Retention:                   pulumi.Int(60000),
			Segment:                     pulumi.Int(3600000),
			SyncReplicaMinNum:           pulumi.Int(1),
			TopicName:                   pulumi.String("example"),
			UncleanLeaderElectionEnable: pulumi.Bool(false),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetTopicsResultOutput 

type GetTopicsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getTopics.

func GetTopicsOutput 

func GetTopicsOutput(ctx *pulumi.Context, args GetTopicsOutputArgs, opts ...pulumi.InvokeOption) GetTopicsResultOutput

func (GetTopicsResultOutput) ElementType 

func (GetTopicsResultOutput) ElementType() reflect.Type

func (GetTopicsResultOutput) Id 

func (o GetTopicsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetTopicsResultOutput) InstanceId 

func (o GetTopicsResultOutput) InstanceId() pulumi.StringOutput

func (GetTopicsResultOutput) InstanceLists 

func (o GetTopicsResultOutput) InstanceLists() GetTopicsInstanceListArrayOutput

A list of instances. Each element contains the following attributes.

func (GetTopicsResultOutput) ResultOutputFile 

func (o GetTopicsResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (GetTopicsResultOutput) ToGetTopicsResultOutput 

func (o GetTopicsResultOutput) ToGetTopicsResultOutput() GetTopicsResultOutput

func (GetTopicsResultOutput) ToGetTopicsResultOutputWithContext 

func (o GetTopicsResultOutput) ToGetTopicsResultOutputWithContext(ctx context.Context) GetTopicsResultOutput

func (GetTopicsResultOutput) TopicName 

func (o GetTopicsResultOutput) TopicName() pulumi.StringPtrOutput

Name of the CKafka topic.

type GetUsersArgs 

type GetUsersArgs struct {
	// Account name used when query ckafka users' infos. Could be a substr of user name.
	AccountName *string `pulumi:"accountName"`
	// Id of the ckafka instance.
	InstanceId string `pulumi:"instanceId"`
	// Used to save results.
	ResultOutputFile *string `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking getUsers.

type GetUsersOutputArgs 

type GetUsersOutputArgs struct {
	// Account name used when query ckafka users' infos. Could be a substr of user name.
	AccountName pulumi.StringPtrInput `pulumi:"accountName"`
	// Id of the ckafka instance.
	InstanceId pulumi.StringInput `pulumi:"instanceId"`
	// Used to save results.
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking getUsers.

func (GetUsersOutputArgs) ElementType 

func (GetUsersOutputArgs) ElementType() reflect.Type

type GetUsersResult 

type GetUsersResult struct {
	// Account name of user.
	AccountName *string `pulumi:"accountName"`
	// The provider-assigned unique ID for this managed resource.
	Id               string  `pulumi:"id"`
	InstanceId       string  `pulumi:"instanceId"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	// A list of ckafka users. Each element contains the following attributes:
	UserLists []GetUsersUserList `pulumi:"userLists"`
}

A collection of values returned by getUsers.

func GetUsers 

func GetUsers(ctx *pulumi.Context, args *GetUsersArgs, opts ...pulumi.InvokeOption) (*GetUsersResult, error)

Use this data source to query detailed user information of Ckafka

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.GetUsers(ctx, &ckafka.GetUsersArgs{
			AccountName: pulumi.StringRef("test"),
			InstanceId:  "ckafka-f9ife4zz",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetUsersResultOutput 

type GetUsersResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getUsers.

func GetUsersOutput 

func GetUsersOutput(ctx *pulumi.Context, args GetUsersOutputArgs, opts ...pulumi.InvokeOption) GetUsersResultOutput

func (GetUsersResultOutput) AccountName 

func (o GetUsersResultOutput) AccountName() pulumi.StringPtrOutput

Account name of user.

func (GetUsersResultOutput) ElementType 

func (GetUsersResultOutput) ElementType() reflect.Type

func (GetUsersResultOutput) Id 

func (o GetUsersResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetUsersResultOutput) InstanceId 

func (o GetUsersResultOutput) InstanceId() pulumi.StringOutput

func (GetUsersResultOutput) ResultOutputFile 

func (o GetUsersResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (GetUsersResultOutput) ToGetUsersResultOutput 

func (o GetUsersResultOutput) ToGetUsersResultOutput() GetUsersResultOutput

func (GetUsersResultOutput) ToGetUsersResultOutputWithContext 

func (o GetUsersResultOutput) ToGetUsersResultOutputWithContext(ctx context.Context) GetUsersResultOutput

func (GetUsersResultOutput) UserLists 

func (o GetUsersResultOutput) UserLists() GetUsersUserListArrayOutput

A list of ckafka users. Each element contains the following attributes:

type GetUsersUserList 

type GetUsersUserList struct {
	// Account name used when query ckafka users' infos. Could be a substr of user name.
	AccountName string `pulumi:"accountName"`
	// Creation time of the account.
	CreateTime string `pulumi:"createTime"`
	// The last update time of the account.
	UpdateTime string `pulumi:"updateTime"`
}

type GetUsersUserListArgs 

type GetUsersUserListArgs struct {
	// Account name used when query ckafka users' infos. Could be a substr of user name.
	AccountName pulumi.StringInput `pulumi:"accountName"`
	// Creation time of the account.
	CreateTime pulumi.StringInput `pulumi:"createTime"`
	// The last update time of the account.
	UpdateTime pulumi.StringInput `pulumi:"updateTime"`
}

func (GetUsersUserListArgs) ElementType 

func (GetUsersUserListArgs) ElementType() reflect.Type

func (GetUsersUserListArgs) ToGetUsersUserListOutput 

func (i GetUsersUserListArgs) ToGetUsersUserListOutput() GetUsersUserListOutput

func (GetUsersUserListArgs) ToGetUsersUserListOutputWithContext 

func (i GetUsersUserListArgs) ToGetUsersUserListOutputWithContext(ctx context.Context) GetUsersUserListOutput

type GetUsersUserListArray 

type GetUsersUserListArray []GetUsersUserListInput

func (GetUsersUserListArray) ElementType 

func (GetUsersUserListArray) ElementType() reflect.Type

func (GetUsersUserListArray) ToGetUsersUserListArrayOutput 

func (i GetUsersUserListArray) ToGetUsersUserListArrayOutput() GetUsersUserListArrayOutput

func (GetUsersUserListArray) ToGetUsersUserListArrayOutputWithContext 

func (i GetUsersUserListArray) ToGetUsersUserListArrayOutputWithContext(ctx context.Context) GetUsersUserListArrayOutput

type GetUsersUserListArrayInput 

type GetUsersUserListArrayInput interface {
	pulumi.Input

	ToGetUsersUserListArrayOutput() GetUsersUserListArrayOutput
	ToGetUsersUserListArrayOutputWithContext(context.Context) GetUsersUserListArrayOutput
}

GetUsersUserListArrayInput is an input type that accepts GetUsersUserListArray and GetUsersUserListArrayOutput values. You can construct a concrete instance of `GetUsersUserListArrayInput` via: 

GetUsersUserListArray{ GetUsersUserListArgs{...} }

type GetUsersUserListArrayOutput 

type GetUsersUserListArrayOutput struct{ *pulumi.OutputState }

func (GetUsersUserListArrayOutput) ElementType 

func (GetUsersUserListArrayOutput) ElementType() reflect.Type

func (GetUsersUserListArrayOutput) Index 

func (o GetUsersUserListArrayOutput) Index(i pulumi.IntInput) GetUsersUserListOutput

func (GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutput 

func (o GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutput() GetUsersUserListArrayOutput

func (GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutputWithContext 

func (o GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutputWithContext(ctx context.Context) GetUsersUserListArrayOutput

type GetUsersUserListInput 

type GetUsersUserListInput interface {
	pulumi.Input

	ToGetUsersUserListOutput() GetUsersUserListOutput
	ToGetUsersUserListOutputWithContext(context.Context) GetUsersUserListOutput
}

GetUsersUserListInput is an input type that accepts GetUsersUserListArgs and GetUsersUserListOutput values. You can construct a concrete instance of `GetUsersUserListInput` via: 

GetUsersUserListArgs{...}

type GetUsersUserListOutput 

type GetUsersUserListOutput struct{ *pulumi.OutputState }

func (GetUsersUserListOutput) AccountName 

func (o GetUsersUserListOutput) AccountName() pulumi.StringOutput

Account name used when query ckafka users' infos. Could be a substr of user name.

func (GetUsersUserListOutput) CreateTime 

func (o GetUsersUserListOutput) CreateTime() pulumi.StringOutput

Creation time of the account.

func (GetUsersUserListOutput) ElementType 

func (GetUsersUserListOutput) ElementType() reflect.Type

func (GetUsersUserListOutput) ToGetUsersUserListOutput 

func (o GetUsersUserListOutput) ToGetUsersUserListOutput() GetUsersUserListOutput

func (GetUsersUserListOutput) ToGetUsersUserListOutputWithContext 

func (o GetUsersUserListOutput) ToGetUsersUserListOutputWithContext(ctx context.Context) GetUsersUserListOutput

func (GetUsersUserListOutput) UpdateTime 

func (o GetUsersUserListOutput) UpdateTime() pulumi.StringOutput

The last update time of the account.

type Instance 

type Instance struct {
	pulumi.CustomResourceState

	// Instance bandwidth in MBps.
	BandWidth pulumi.IntOutput `pulumi:"bandWidth"`
	// Instance configuration.
	Config InstanceConfigPtrOutput `pulumi:"config"`
	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	DiskSize pulumi.IntOutput `pulumi:"diskSize"`
	// Type of disk.
	DiskType pulumi.StringOutput `pulumi:"diskType"`
	// Dynamic message retention policy configuration.
	DynamicRetentionConfig InstanceDynamicRetentionConfigOutput `pulumi:"dynamicRetentionConfig"`
	// Instance name.
	InstanceName pulumi.StringOutput `pulumi:"instanceName"`
	// Kafka version (0.10.2/1.1.1/2.4.1).
	KafkaVersion pulumi.StringOutput `pulumi:"kafkaVersion"`
	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	MsgRetentionTime pulumi.IntOutput `pulumi:"msgRetentionTime"`
	// Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together.
	MultiZoneFlag pulumi.BoolPtrOutput `pulumi:"multiZoneFlag"`
	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	Partition pulumi.IntOutput `pulumi:"partition"`
	// Prepaid purchase time, such as 1, is one month.
	Period pulumi.IntPtrOutput `pulumi:"period"`
	// Timestamp.
	PublicNetwork pulumi.IntOutput `pulumi:"publicNetwork"`
	// Modification of the rebalancing time after upgrade.
	RebalanceTime pulumi.IntPtrOutput `pulumi:"rebalanceTime"`
	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	RenewFlag pulumi.IntOutput `pulumi:"renewFlag"`
	// Subnet id.
	SubnetId pulumi.StringOutput `pulumi:"subnetId"`
	// Partition size, the professional version does not need tag.
	Tags InstanceTagArrayOutput `pulumi:"tags"`
	// Vip of instance.
	Vip pulumi.StringOutput `pulumi:"vip"`
	// Vpc id.
	VpcId pulumi.StringOutput `pulumi:"vpcId"`
	// Type of instance.
	Vport pulumi.StringOutput `pulumi:"vport"`
	// Available zone id.
	ZoneId pulumi.IntOutput `pulumi:"zoneId"`
	// List of available zone id. NOTE: this argument must set together with `multiZoneFlag`.
	ZoneIds pulumi.IntArrayOutput `pulumi:"zoneIds"`
}

Use this resource to create ckafka instance.

> **NOTE:** It only support create profession ckafka instance.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.NewInstance(ctx, "foo", &Ckafka.InstanceArgs{
			BandWidth: pulumi.Int(40),
			Config: &ckafka.InstanceConfigArgs{
				AutoCreateTopicEnable:    pulumi.Bool(true),
				DefaultNumPartitions:     pulumi.Int(3),
				DefaultReplicationFactor: pulumi.Int(3),
			},
			DiskSize: pulumi.Int(500),
			DiskType: pulumi.String("CLOUD_BASIC"),
			DynamicRetentionConfig: &ckafka.InstanceDynamicRetentionConfigArgs{
				BottomRetention:       pulumi.Int(0),
				DiskQuotaPercentage:   pulumi.Int(0),
				Enable:                pulumi.Int(1),
				StepForwardPercentage: pulumi.Int(0),
			},
			InstanceName:     pulumi.String("ckafka-instance-tf-test"),
			KafkaVersion:     pulumi.String("1.1.1"),
			MsgRetentionTime: pulumi.Int(1300),
			MultiZoneFlag:    pulumi.Bool(true),
			Partition:        pulumi.Int(800),
			Period:           pulumi.Int(1),
			PublicNetwork:    pulumi.Int(3),
			RenewFlag:        pulumi.Int(0),
			SubnetId:         pulumi.String("subnet-4vwihrzk"),
			VpcId:            pulumi.String("vpc-82p1t1nv"),
			ZoneId:           pulumi.Int(100006),
			ZoneIds: pulumi.IntArray{
				pulumi.Int(100006),
				pulumi.Int(100007),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

ckafka instance can be imported using the instance_id, e.g.

```sh 

$ pulumi import tencentcloud:Ckafka/instance:Instance foo ckafka-f9ife4zz

```

func GetInstance 

func GetInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *InstanceState, opts ...pulumi.ResourceOption) (*Instance, error)

GetInstance gets an existing Instance 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 NewInstance 

func NewInstance(ctx *pulumi.Context,
	name string, args *InstanceArgs, opts ...pulumi.ResourceOption) (*Instance, error)

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

func (*Instance) ElementType 

func (*Instance) ElementType() reflect.Type

func (*Instance) ToInstanceOutput 

func (i *Instance) ToInstanceOutput() InstanceOutput

func (*Instance) ToInstanceOutputWithContext 

func (i *Instance) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput

type InstanceArgs 

type InstanceArgs struct {
	// Instance bandwidth in MBps.
	BandWidth pulumi.IntPtrInput
	// Instance configuration.
	Config InstanceConfigPtrInput
	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	DiskSize pulumi.IntPtrInput
	// Type of disk.
	DiskType pulumi.StringPtrInput
	// Dynamic message retention policy configuration.
	DynamicRetentionConfig InstanceDynamicRetentionConfigPtrInput
	// Instance name.
	InstanceName pulumi.StringInput
	// Kafka version (0.10.2/1.1.1/2.4.1).
	KafkaVersion pulumi.StringPtrInput
	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	MsgRetentionTime pulumi.IntPtrInput
	// Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together.
	MultiZoneFlag pulumi.BoolPtrInput
	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	Partition pulumi.IntPtrInput
	// Prepaid purchase time, such as 1, is one month.
	Period pulumi.IntPtrInput
	// Timestamp.
	PublicNetwork pulumi.IntPtrInput
	// Modification of the rebalancing time after upgrade.
	RebalanceTime pulumi.IntPtrInput
	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	RenewFlag pulumi.IntPtrInput
	// Subnet id.
	SubnetId pulumi.StringInput
	// Partition size, the professional version does not need tag.
	Tags InstanceTagArrayInput
	// Vpc id.
	VpcId pulumi.StringInput
	// Available zone id.
	ZoneId pulumi.IntInput
	// List of available zone id. NOTE: this argument must set together with `multiZoneFlag`.
	ZoneIds pulumi.IntArrayInput
}

The set of arguments for constructing a Instance resource.

func (InstanceArgs) ElementType 

func (InstanceArgs) ElementType() reflect.Type

type InstanceArray 

type InstanceArray []InstanceInput

func (InstanceArray) ElementType 

func (InstanceArray) ElementType() reflect.Type

func (InstanceArray) ToInstanceArrayOutput 

func (i InstanceArray) ToInstanceArrayOutput() InstanceArrayOutput

func (InstanceArray) ToInstanceArrayOutputWithContext 

func (i InstanceArray) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput

type InstanceArrayInput 

type InstanceArrayInput interface {
	pulumi.Input

	ToInstanceArrayOutput() InstanceArrayOutput
	ToInstanceArrayOutputWithContext(context.Context) InstanceArrayOutput
}

InstanceArrayInput is an input type that accepts InstanceArray and InstanceArrayOutput values. You can construct a concrete instance of `InstanceArrayInput` via: 

InstanceArray{ InstanceArgs{...} }

type InstanceArrayOutput 

type InstanceArrayOutput struct{ *pulumi.OutputState }

func (InstanceArrayOutput) ElementType 

func (InstanceArrayOutput) ElementType() reflect.Type

func (InstanceArrayOutput) Index 

func (o InstanceArrayOutput) Index(i pulumi.IntInput) InstanceOutput

func (InstanceArrayOutput) ToInstanceArrayOutput 

func (o InstanceArrayOutput) ToInstanceArrayOutput() InstanceArrayOutput

func (InstanceArrayOutput) ToInstanceArrayOutputWithContext 

func (o InstanceArrayOutput) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput

type InstanceConfig 

type InstanceConfig struct {
	// Automatic creation. true: enabled, false: not enabled.
	AutoCreateTopicEnable bool `pulumi:"autoCreateTopicEnable"`
	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	DefaultNumPartitions int `pulumi:"defaultNumPartitions"`
	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	DefaultReplicationFactor int `pulumi:"defaultReplicationFactor"`
}

type InstanceConfigArgs 

type InstanceConfigArgs struct {
	// Automatic creation. true: enabled, false: not enabled.
	AutoCreateTopicEnable pulumi.BoolInput `pulumi:"autoCreateTopicEnable"`
	// If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
	DefaultNumPartitions pulumi.IntInput `pulumi:"defaultNumPartitions"`
	// If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
	DefaultReplicationFactor pulumi.IntInput `pulumi:"defaultReplicationFactor"`
}

func (InstanceConfigArgs) ElementType 

func (InstanceConfigArgs) ElementType() reflect.Type

func (InstanceConfigArgs) ToInstanceConfigOutput 

func (i InstanceConfigArgs) ToInstanceConfigOutput() InstanceConfigOutput

func (InstanceConfigArgs) ToInstanceConfigOutputWithContext 

func (i InstanceConfigArgs) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput

func (InstanceConfigArgs) ToInstanceConfigPtrOutput 

func (i InstanceConfigArgs) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput

func (InstanceConfigArgs) ToInstanceConfigPtrOutputWithContext 

func (i InstanceConfigArgs) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput

type InstanceConfigInput 

type InstanceConfigInput interface {
	pulumi.Input

	ToInstanceConfigOutput() InstanceConfigOutput
	ToInstanceConfigOutputWithContext(context.Context) InstanceConfigOutput
}

InstanceConfigInput is an input type that accepts InstanceConfigArgs and InstanceConfigOutput values. You can construct a concrete instance of `InstanceConfigInput` via: 

InstanceConfigArgs{...}

type InstanceConfigOutput 

type InstanceConfigOutput struct{ *pulumi.OutputState }

func (InstanceConfigOutput) AutoCreateTopicEnable 

func (o InstanceConfigOutput) AutoCreateTopicEnable() pulumi.BoolOutput

Automatic creation. true: enabled, false: not enabled.

func (InstanceConfigOutput) DefaultNumPartitions 

func (o InstanceConfigOutput) DefaultNumPartitions() pulumi.IntOutput

If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.

func (InstanceConfigOutput) DefaultReplicationFactor 

func (o InstanceConfigOutput) DefaultReplicationFactor() pulumi.IntOutput

If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.

func (InstanceConfigOutput) ElementType 

func (InstanceConfigOutput) ElementType() reflect.Type

func (InstanceConfigOutput) ToInstanceConfigOutput 

func (o InstanceConfigOutput) ToInstanceConfigOutput() InstanceConfigOutput

func (InstanceConfigOutput) ToInstanceConfigOutputWithContext 

func (o InstanceConfigOutput) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput

func (InstanceConfigOutput) ToInstanceConfigPtrOutput 

func (o InstanceConfigOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput

func (InstanceConfigOutput) ToInstanceConfigPtrOutputWithContext 

func (o InstanceConfigOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput

type InstanceConfigPtrInput 

type InstanceConfigPtrInput interface {
	pulumi.Input

	ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
	ToInstanceConfigPtrOutputWithContext(context.Context) InstanceConfigPtrOutput
}

InstanceConfigPtrInput is an input type that accepts InstanceConfigArgs, InstanceConfigPtr and InstanceConfigPtrOutput values. You can construct a concrete instance of `InstanceConfigPtrInput` via: 

        InstanceConfigArgs{...}

or:

        nil

func InstanceConfigPtr 

func InstanceConfigPtr(v *InstanceConfigArgs) InstanceConfigPtrInput

type InstanceConfigPtrOutput 

type InstanceConfigPtrOutput struct{ *pulumi.OutputState }

func (InstanceConfigPtrOutput) AutoCreateTopicEnable 

func (o InstanceConfigPtrOutput) AutoCreateTopicEnable() pulumi.BoolPtrOutput

Automatic creation. true: enabled, false: not enabled.

func (InstanceConfigPtrOutput) DefaultNumPartitions 

func (o InstanceConfigPtrOutput) DefaultNumPartitions() pulumi.IntPtrOutput

If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.

func (InstanceConfigPtrOutput) DefaultReplicationFactor 

func (o InstanceConfigPtrOutput) DefaultReplicationFactor() pulumi.IntPtrOutput

If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.

func (InstanceConfigPtrOutput) Elem 

func (o InstanceConfigPtrOutput) Elem() InstanceConfigOutput

func (InstanceConfigPtrOutput) ElementType 

func (InstanceConfigPtrOutput) ElementType() reflect.Type

func (InstanceConfigPtrOutput) ToInstanceConfigPtrOutput 

func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput

func (InstanceConfigPtrOutput) ToInstanceConfigPtrOutputWithContext 

func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput

type InstanceDynamicRetentionConfig 

type InstanceDynamicRetentionConfig struct {
	// Minimum retention time, in minutes.
	BottomRetention *int `pulumi:"bottomRetention"`
	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	DiskQuotaPercentage *int `pulumi:"diskQuotaPercentage"`
	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	Enable *int `pulumi:"enable"`
	// Percentage by which the message retention time is shortened each time.
	StepForwardPercentage *int `pulumi:"stepForwardPercentage"`
}

type InstanceDynamicRetentionConfigArgs 

type InstanceDynamicRetentionConfigArgs struct {
	// Minimum retention time, in minutes.
	BottomRetention pulumi.IntPtrInput `pulumi:"bottomRetention"`
	// Disk quota threshold (in percentage) for triggering the message retention time change event.
	DiskQuotaPercentage pulumi.IntPtrInput `pulumi:"diskQuotaPercentage"`
	// Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
	Enable pulumi.IntPtrInput `pulumi:"enable"`
	// Percentage by which the message retention time is shortened each time.
	StepForwardPercentage pulumi.IntPtrInput `pulumi:"stepForwardPercentage"`
}

func (InstanceDynamicRetentionConfigArgs) ElementType 

func (InstanceDynamicRetentionConfigArgs) ElementType() reflect.Type

func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutput 

func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput

func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutputWithContext 

func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput

func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutput 

func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput

func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutputWithContext 

func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput

type InstanceDynamicRetentionConfigInput 

type InstanceDynamicRetentionConfigInput interface {
	pulumi.Input

	ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput
	ToInstanceDynamicRetentionConfigOutputWithContext(context.Context) InstanceDynamicRetentionConfigOutput
}

InstanceDynamicRetentionConfigInput is an input type that accepts InstanceDynamicRetentionConfigArgs and InstanceDynamicRetentionConfigOutput values. You can construct a concrete instance of `InstanceDynamicRetentionConfigInput` via: 

InstanceDynamicRetentionConfigArgs{...}

type InstanceDynamicRetentionConfigOutput 

type InstanceDynamicRetentionConfigOutput struct{ *pulumi.OutputState }

func (InstanceDynamicRetentionConfigOutput) BottomRetention 

func (o InstanceDynamicRetentionConfigOutput) BottomRetention() pulumi.IntPtrOutput

Minimum retention time, in minutes.

func (InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage 

func (o InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage() pulumi.IntPtrOutput

Disk quota threshold (in percentage) for triggering the message retention time change event.

func (InstanceDynamicRetentionConfigOutput) ElementType 

func (InstanceDynamicRetentionConfigOutput) ElementType() reflect.Type

func (InstanceDynamicRetentionConfigOutput) Enable 

func (o InstanceDynamicRetentionConfigOutput) Enable() pulumi.IntPtrOutput

Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.

func (InstanceDynamicRetentionConfigOutput) StepForwardPercentage 

func (o InstanceDynamicRetentionConfigOutput) StepForwardPercentage() pulumi.IntPtrOutput

Percentage by which the message retention time is shortened each time.

func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutput 

func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput

func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutputWithContext 

func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput

func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutput 

func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput

func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext 

func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput

type InstanceDynamicRetentionConfigPtrInput 

type InstanceDynamicRetentionConfigPtrInput interface {
	pulumi.Input

	ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
	ToInstanceDynamicRetentionConfigPtrOutputWithContext(context.Context) InstanceDynamicRetentionConfigPtrOutput
}

InstanceDynamicRetentionConfigPtrInput is an input type that accepts InstanceDynamicRetentionConfigArgs, InstanceDynamicRetentionConfigPtr and InstanceDynamicRetentionConfigPtrOutput values. You can construct a concrete instance of `InstanceDynamicRetentionConfigPtrInput` via: 

        InstanceDynamicRetentionConfigArgs{...}

or:

        nil

func InstanceDynamicRetentionConfigPtr 

func InstanceDynamicRetentionConfigPtr(v *InstanceDynamicRetentionConfigArgs) InstanceDynamicRetentionConfigPtrInput

type InstanceDynamicRetentionConfigPtrOutput 

type InstanceDynamicRetentionConfigPtrOutput struct{ *pulumi.OutputState }

func (InstanceDynamicRetentionConfigPtrOutput) BottomRetention 

func (o InstanceDynamicRetentionConfigPtrOutput) BottomRetention() pulumi.IntPtrOutput

Minimum retention time, in minutes.

func (InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage 

func (o InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage() pulumi.IntPtrOutput

Disk quota threshold (in percentage) for triggering the message retention time change event.

func (InstanceDynamicRetentionConfigPtrOutput) Elem 

func (o InstanceDynamicRetentionConfigPtrOutput) Elem() InstanceDynamicRetentionConfigOutput

func (InstanceDynamicRetentionConfigPtrOutput) ElementType 

func (InstanceDynamicRetentionConfigPtrOutput) ElementType() reflect.Type

func (InstanceDynamicRetentionConfigPtrOutput) Enable 

func (o InstanceDynamicRetentionConfigPtrOutput) Enable() pulumi.IntPtrOutput

Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.

func (InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage 

func (o InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage() pulumi.IntPtrOutput

Percentage by which the message retention time is shortened each time.

func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput 

func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput

func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext 

func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput

type InstanceInput 

type InstanceInput interface {
	pulumi.Input

	ToInstanceOutput() InstanceOutput
	ToInstanceOutputWithContext(ctx context.Context) InstanceOutput
}

type InstanceMap 

type InstanceMap map[string]InstanceInput

func (InstanceMap) ElementType 

func (InstanceMap) ElementType() reflect.Type

func (InstanceMap) ToInstanceMapOutput 

func (i InstanceMap) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMap) ToInstanceMapOutputWithContext 

func (i InstanceMap) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput

type InstanceMapInput 

type InstanceMapInput interface {
	pulumi.Input

	ToInstanceMapOutput() InstanceMapOutput
	ToInstanceMapOutputWithContext(context.Context) InstanceMapOutput
}

InstanceMapInput is an input type that accepts InstanceMap and InstanceMapOutput values. You can construct a concrete instance of `InstanceMapInput` via: 

InstanceMap{ "key": InstanceArgs{...} }

type InstanceMapOutput 

type InstanceMapOutput struct{ *pulumi.OutputState }

func (InstanceMapOutput) ElementType 

func (InstanceMapOutput) ElementType() reflect.Type

func (InstanceMapOutput) MapIndex 

func (o InstanceMapOutput) MapIndex(k pulumi.StringInput) InstanceOutput

func (InstanceMapOutput) ToInstanceMapOutput 

func (o InstanceMapOutput) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMapOutput) ToInstanceMapOutputWithContext 

func (o InstanceMapOutput) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput

type InstanceOutput 

type InstanceOutput struct{ *pulumi.OutputState }

func (InstanceOutput) BandWidth 

func (o InstanceOutput) BandWidth() pulumi.IntOutput

Instance bandwidth in MBps.

func (InstanceOutput) Config 

func (o InstanceOutput) Config() InstanceConfigPtrOutput

Instance configuration.

func (InstanceOutput) DiskSize 

func (o InstanceOutput) DiskSize() pulumi.IntOutput

Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.

func (InstanceOutput) DiskType 

func (o InstanceOutput) DiskType() pulumi.StringOutput

Type of disk.

func (InstanceOutput) DynamicRetentionConfig 

func (o InstanceOutput) DynamicRetentionConfig() InstanceDynamicRetentionConfigOutput

Dynamic message retention policy configuration.

func (InstanceOutput) ElementType 

func (InstanceOutput) ElementType() reflect.Type

func (InstanceOutput) InstanceName 

func (o InstanceOutput) InstanceName() pulumi.StringOutput

Instance name.

func (InstanceOutput) KafkaVersion 

func (o InstanceOutput) KafkaVersion() pulumi.StringOutput

Kafka version (0.10.2/1.1.1/2.4.1).

func (InstanceOutput) MsgRetentionTime 

func (o InstanceOutput) MsgRetentionTime() pulumi.IntOutput

The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.

func (InstanceOutput) MultiZoneFlag 

func (o InstanceOutput) MultiZoneFlag() pulumi.BoolPtrOutput

Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together.

func (InstanceOutput) Partition 

func (o InstanceOutput) Partition() pulumi.IntOutput

Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.

func (InstanceOutput) Period 

func (o InstanceOutput) Period() pulumi.IntPtrOutput

Prepaid purchase time, such as 1, is one month.

func (InstanceOutput) PublicNetwork 

func (o InstanceOutput) PublicNetwork() pulumi.IntOutput

Timestamp.

func (InstanceOutput) RebalanceTime 

func (o InstanceOutput) RebalanceTime() pulumi.IntPtrOutput

Modification of the rebalancing time after upgrade.

func (InstanceOutput) RenewFlag 

func (o InstanceOutput) RenewFlag() pulumi.IntOutput

Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).

func (InstanceOutput) SubnetId 

func (o InstanceOutput) SubnetId() pulumi.StringOutput

Subnet id.

func (InstanceOutput) Tags 

func (o InstanceOutput) Tags() InstanceTagArrayOutput

Partition size, the professional version does not need tag.

func (InstanceOutput) ToInstanceOutput 

func (o InstanceOutput) ToInstanceOutput() InstanceOutput

func (InstanceOutput) ToInstanceOutputWithContext 

func (o InstanceOutput) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput

func (InstanceOutput) Vip 

func (o InstanceOutput) Vip() pulumi.StringOutput

Vip of instance.

func (InstanceOutput) VpcId 

func (o InstanceOutput) VpcId() pulumi.StringOutput

Vpc id.

func (InstanceOutput) Vport 

func (o InstanceOutput) Vport() pulumi.StringOutput

Type of instance.

func (InstanceOutput) ZoneId 

func (o InstanceOutput) ZoneId() pulumi.IntOutput

Available zone id.

func (InstanceOutput) ZoneIds 

func (o InstanceOutput) ZoneIds() pulumi.IntArrayOutput

List of available zone id. NOTE: this argument must set together with `multiZoneFlag`.

type InstanceState 

type InstanceState struct {
	// Instance bandwidth in MBps.
	BandWidth pulumi.IntPtrInput
	// Instance configuration.
	Config InstanceConfigPtrInput
	// Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	DiskSize pulumi.IntPtrInput
	// Type of disk.
	DiskType pulumi.StringPtrInput
	// Dynamic message retention policy configuration.
	DynamicRetentionConfig InstanceDynamicRetentionConfigPtrInput
	// Instance name.
	InstanceName pulumi.StringPtrInput
	// Kafka version (0.10.2/1.1.1/2.4.1).
	KafkaVersion pulumi.StringPtrInput
	// The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
	MsgRetentionTime pulumi.IntPtrInput
	// Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together.
	MultiZoneFlag pulumi.BoolPtrInput
	// Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
	Partition pulumi.IntPtrInput
	// Prepaid purchase time, such as 1, is one month.
	Period pulumi.IntPtrInput
	// Timestamp.
	PublicNetwork pulumi.IntPtrInput
	// Modification of the rebalancing time after upgrade.
	RebalanceTime pulumi.IntPtrInput
	// Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
	RenewFlag pulumi.IntPtrInput
	// Subnet id.
	SubnetId pulumi.StringPtrInput
	// Partition size, the professional version does not need tag.
	Tags InstanceTagArrayInput
	// Vip of instance.
	Vip pulumi.StringPtrInput
	// Vpc id.
	VpcId pulumi.StringPtrInput
	// Type of instance.
	Vport pulumi.StringPtrInput
	// Available zone id.
	ZoneId pulumi.IntPtrInput
	// List of available zone id. NOTE: this argument must set together with `multiZoneFlag`.
	ZoneIds pulumi.IntArrayInput
}

func (InstanceState) ElementType 

func (InstanceState) ElementType() reflect.Type

type InstanceTag 

type InstanceTag struct {
	// Tag key.
	Key string `pulumi:"key"`
	// Tag value.
	Value string `pulumi:"value"`
}

type InstanceTagArgs 

type InstanceTagArgs struct {
	// Tag key.
	Key pulumi.StringInput `pulumi:"key"`
	// Tag value.
	Value pulumi.StringInput `pulumi:"value"`
}

func (InstanceTagArgs) ElementType 

func (InstanceTagArgs) ElementType() reflect.Type

func (InstanceTagArgs) ToInstanceTagOutput 

func (i InstanceTagArgs) ToInstanceTagOutput() InstanceTagOutput

func (InstanceTagArgs) ToInstanceTagOutputWithContext 

func (i InstanceTagArgs) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput

type InstanceTagArray 

type InstanceTagArray []InstanceTagInput

func (InstanceTagArray) ElementType 

func (InstanceTagArray) ElementType() reflect.Type

func (InstanceTagArray) ToInstanceTagArrayOutput 

func (i InstanceTagArray) ToInstanceTagArrayOutput() InstanceTagArrayOutput

func (InstanceTagArray) ToInstanceTagArrayOutputWithContext 

func (i InstanceTagArray) ToInstanceTagArrayOutputWithContext(ctx context.Context) InstanceTagArrayOutput

type InstanceTagArrayInput 

type InstanceTagArrayInput interface {
	pulumi.Input

	ToInstanceTagArrayOutput() InstanceTagArrayOutput
	ToInstanceTagArrayOutputWithContext(context.Context) InstanceTagArrayOutput
}

InstanceTagArrayInput is an input type that accepts InstanceTagArray and InstanceTagArrayOutput values. You can construct a concrete instance of `InstanceTagArrayInput` via: 

InstanceTagArray{ InstanceTagArgs{...} }

type InstanceTagArrayOutput 

type InstanceTagArrayOutput struct{ *pulumi.OutputState }

func (InstanceTagArrayOutput) ElementType 

func (InstanceTagArrayOutput) ElementType() reflect.Type

func (InstanceTagArrayOutput) Index 

func (o InstanceTagArrayOutput) Index(i pulumi.IntInput) InstanceTagOutput

func (InstanceTagArrayOutput) ToInstanceTagArrayOutput 

func (o InstanceTagArrayOutput) ToInstanceTagArrayOutput() InstanceTagArrayOutput

func (InstanceTagArrayOutput) ToInstanceTagArrayOutputWithContext 

func (o InstanceTagArrayOutput) ToInstanceTagArrayOutputWithContext(ctx context.Context) InstanceTagArrayOutput

type InstanceTagInput 

type InstanceTagInput interface {
	pulumi.Input

	ToInstanceTagOutput() InstanceTagOutput
	ToInstanceTagOutputWithContext(context.Context) InstanceTagOutput
}

InstanceTagInput is an input type that accepts InstanceTagArgs and InstanceTagOutput values. You can construct a concrete instance of `InstanceTagInput` via: 

InstanceTagArgs{...}

type InstanceTagOutput 

type InstanceTagOutput struct{ *pulumi.OutputState }

func (InstanceTagOutput) ElementType 

func (InstanceTagOutput) ElementType() reflect.Type

func (InstanceTagOutput) Key 

func (o InstanceTagOutput) Key() pulumi.StringOutput

Tag key.

func (InstanceTagOutput) ToInstanceTagOutput 

func (o InstanceTagOutput) ToInstanceTagOutput() InstanceTagOutput

func (InstanceTagOutput) ToInstanceTagOutputWithContext 

func (o InstanceTagOutput) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput

func (InstanceTagOutput) Value 

func (o InstanceTagOutput) Value() pulumi.StringOutput

Tag value.

type Topic 

type Topic struct {
	pulumi.CustomResourceState

	// Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	CleanUpPolicy pulumi.StringPtrOutput `pulumi:"cleanUpPolicy"`
	// Create time of the CKafka topic.
	CreateTime pulumi.StringOutput `pulumi:"createTime"`
	// Whether to open the ip whitelist, `true`: open, `false`: close.
	EnableWhiteList pulumi.BoolPtrOutput `pulumi:"enableWhiteList"`
	// Data backup cos bucket: the bucket address that is dumped to cos.
	ForwardCosBucket pulumi.StringOutput `pulumi:"forwardCosBucket"`
	// Periodic frequency of data backup to cos.
	ForwardInterval pulumi.IntOutput `pulumi:"forwardInterval"`
	// Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup.
	ForwardStatus pulumi.IntOutput `pulumi:"forwardStatus"`
	// Ckafka instance ID.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Ip whitelist, quota limit, required when enableWhileList=true.
	IpWhiteLists pulumi.StringArrayOutput `pulumi:"ipWhiteLists"`
	// Max message bytes.
	MaxMessageBytes pulumi.IntPtrOutput `pulumi:"maxMessageBytes"`
	// Message storage location.
	MessageStorageLocation pulumi.StringOutput `pulumi:"messageStorageLocation"`
	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	Note pulumi.StringPtrOutput `pulumi:"note"`
	// The number of partition.
	PartitionNum pulumi.IntOutput `pulumi:"partitionNum"`
	// The number of replica.
	ReplicaNum pulumi.IntOutput `pulumi:"replicaNum"`
	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	Retention pulumi.IntPtrOutput `pulumi:"retention"`
	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	Segment pulumi.IntPtrOutput `pulumi:"segment"`
	// Number of bytes rolled by shard.
	SegmentBytes pulumi.IntOutput `pulumi:"segmentBytes"`
	// Min number of sync replicas, Default is `1`.
	SyncReplicaMinNum pulumi.IntPtrOutput `pulumi:"syncReplicaMinNum"`
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	TopicName pulumi.StringOutput `pulumi:"topicName"`
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true:  `allowed, `false`: not allowed.
	UncleanLeaderElectionEnable pulumi.BoolPtrOutput `pulumi:"uncleanLeaderElectionEnable"`
}

Use this resource to create ckafka topic.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.NewTopic(ctx, "foo", &Ckafka.TopicArgs{
			CleanUpPolicy:   pulumi.String("delete"),
			EnableWhiteList: pulumi.Bool(true),
			InstanceId:      pulumi.String("ckafka-f9ife4zz"),
			IpWhiteLists: pulumi.StringArray{
				pulumi.String("ip1"),
				pulumi.String("ip2"),
			},
			MaxMessageBytes:             pulumi.Int(0),
			Note:                        pulumi.String("topic note"),
			PartitionNum:                pulumi.Int(1),
			ReplicaNum:                  pulumi.Int(2),
			Retention:                   pulumi.Int(60000),
			Segment:                     pulumi.Int(3600000),
			SyncReplicaMinNum:           pulumi.Int(1),
			TopicName:                   pulumi.String("example"),
			UncleanLeaderElectionEnable: pulumi.Bool(false),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

ckafka topic can be imported using the instance_id#topic_name, e.g.

```sh 

$ pulumi import tencentcloud:Ckafka/topic:Topic foo ckafka-f9ife4zz#example

```

func GetTopic 

func GetTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *TopicState, opts ...pulumi.ResourceOption) (*Topic, error)

GetTopic gets an existing Topic 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 NewTopic 

func NewTopic(ctx *pulumi.Context,
	name string, args *TopicArgs, opts ...pulumi.ResourceOption) (*Topic, error)

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

func (*Topic) ElementType 

func (*Topic) ElementType() reflect.Type

func (*Topic) ToTopicOutput 

func (i *Topic) ToTopicOutput() TopicOutput

func (*Topic) ToTopicOutputWithContext 

func (i *Topic) ToTopicOutputWithContext(ctx context.Context) TopicOutput

type TopicArgs 

type TopicArgs struct {
	// Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	CleanUpPolicy pulumi.StringPtrInput
	// Whether to open the ip whitelist, `true`: open, `false`: close.
	EnableWhiteList pulumi.BoolPtrInput
	// Ckafka instance ID.
	InstanceId pulumi.StringInput
	// Ip whitelist, quota limit, required when enableWhileList=true.
	IpWhiteLists pulumi.StringArrayInput
	// Max message bytes.
	MaxMessageBytes pulumi.IntPtrInput
	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	Note pulumi.StringPtrInput
	// The number of partition.
	PartitionNum pulumi.IntInput
	// The number of replica.
	ReplicaNum pulumi.IntInput
	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	Retention pulumi.IntPtrInput
	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	Segment pulumi.IntPtrInput
	// Min number of sync replicas, Default is `1`.
	SyncReplicaMinNum pulumi.IntPtrInput
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	TopicName pulumi.StringInput
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true:  `allowed, `false`: not allowed.
	UncleanLeaderElectionEnable pulumi.BoolPtrInput
}

The set of arguments for constructing a Topic resource.

func (TopicArgs) ElementType 

func (TopicArgs) ElementType() reflect.Type

type TopicArray 

type TopicArray []TopicInput

func (TopicArray) ElementType 

func (TopicArray) ElementType() reflect.Type

func (TopicArray) ToTopicArrayOutput 

func (i TopicArray) ToTopicArrayOutput() TopicArrayOutput

func (TopicArray) ToTopicArrayOutputWithContext 

func (i TopicArray) ToTopicArrayOutputWithContext(ctx context.Context) TopicArrayOutput

type TopicArrayInput 

type TopicArrayInput interface {
	pulumi.Input

	ToTopicArrayOutput() TopicArrayOutput
	ToTopicArrayOutputWithContext(context.Context) TopicArrayOutput
}

TopicArrayInput is an input type that accepts TopicArray and TopicArrayOutput values. You can construct a concrete instance of `TopicArrayInput` via: 

TopicArray{ TopicArgs{...} }

type TopicArrayOutput 

type TopicArrayOutput struct{ *pulumi.OutputState }

func (TopicArrayOutput) ElementType 

func (TopicArrayOutput) ElementType() reflect.Type

func (TopicArrayOutput) Index 

func (o TopicArrayOutput) Index(i pulumi.IntInput) TopicOutput

func (TopicArrayOutput) ToTopicArrayOutput 

func (o TopicArrayOutput) ToTopicArrayOutput() TopicArrayOutput

func (TopicArrayOutput) ToTopicArrayOutputWithContext 

func (o TopicArrayOutput) ToTopicArrayOutputWithContext(ctx context.Context) TopicArrayOutput

type TopicInput 

type TopicInput interface {
	pulumi.Input

	ToTopicOutput() TopicOutput
	ToTopicOutputWithContext(ctx context.Context) TopicOutput
}

type TopicMap 

type TopicMap map[string]TopicInput

func (TopicMap) ElementType 

func (TopicMap) ElementType() reflect.Type

func (TopicMap) ToTopicMapOutput 

func (i TopicMap) ToTopicMapOutput() TopicMapOutput

func (TopicMap) ToTopicMapOutputWithContext 

func (i TopicMap) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput

type TopicMapInput 

type TopicMapInput interface {
	pulumi.Input

	ToTopicMapOutput() TopicMapOutput
	ToTopicMapOutputWithContext(context.Context) TopicMapOutput
}

TopicMapInput is an input type that accepts TopicMap and TopicMapOutput values. You can construct a concrete instance of `TopicMapInput` via: 

TopicMap{ "key": TopicArgs{...} }

type TopicMapOutput 

type TopicMapOutput struct{ *pulumi.OutputState }

func (TopicMapOutput) ElementType 

func (TopicMapOutput) ElementType() reflect.Type

func (TopicMapOutput) MapIndex 

func (o TopicMapOutput) MapIndex(k pulumi.StringInput) TopicOutput

func (TopicMapOutput) ToTopicMapOutput 

func (o TopicMapOutput) ToTopicMapOutput() TopicMapOutput

func (TopicMapOutput) ToTopicMapOutputWithContext 

func (o TopicMapOutput) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput

type TopicOutput 

type TopicOutput struct{ *pulumi.OutputState }

func (TopicOutput) CleanUpPolicy 

func (o TopicOutput) CleanUpPolicy() pulumi.StringPtrOutput

Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.

func (TopicOutput) CreateTime 

func (o TopicOutput) CreateTime() pulumi.StringOutput

Create time of the CKafka topic.

func (TopicOutput) ElementType 

func (TopicOutput) ElementType() reflect.Type

func (TopicOutput) EnableWhiteList 

func (o TopicOutput) EnableWhiteList() pulumi.BoolPtrOutput

Whether to open the ip whitelist, `true`: open, `false`: close.

func (TopicOutput) ForwardCosBucket 

func (o TopicOutput) ForwardCosBucket() pulumi.StringOutput

Data backup cos bucket: the bucket address that is dumped to cos.

func (TopicOutput) ForwardInterval 

func (o TopicOutput) ForwardInterval() pulumi.IntOutput

Periodic frequency of data backup to cos.

func (TopicOutput) ForwardStatus 

func (o TopicOutput) ForwardStatus() pulumi.IntOutput

Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup.

func (TopicOutput) InstanceId 

func (o TopicOutput) InstanceId() pulumi.StringOutput

Ckafka instance ID.

func (TopicOutput) IpWhiteLists 

func (o TopicOutput) IpWhiteLists() pulumi.StringArrayOutput

Ip whitelist, quota limit, required when enableWhileList=true.

func (TopicOutput) MaxMessageBytes 

func (o TopicOutput) MaxMessageBytes() pulumi.IntPtrOutput

Max message bytes.

func (TopicOutput) MessageStorageLocation 

func (o TopicOutput) MessageStorageLocation() pulumi.StringOutput

Message storage location.

func (TopicOutput) Note 

func (o TopicOutput) Note() pulumi.StringPtrOutput

The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).

func (TopicOutput) PartitionNum 

func (o TopicOutput) PartitionNum() pulumi.IntOutput

The number of partition.

func (TopicOutput) ReplicaNum 

func (o TopicOutput) ReplicaNum() pulumi.IntOutput

The number of replica.

func (TopicOutput) Retention 

func (o TopicOutput) Retention() pulumi.IntPtrOutput

Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.

func (TopicOutput) Segment 

func (o TopicOutput) Segment() pulumi.IntPtrOutput

Segment scrolling time, in ms, the current minimum is 3600000ms.

func (TopicOutput) SegmentBytes 

func (o TopicOutput) SegmentBytes() pulumi.IntOutput

Number of bytes rolled by shard.

func (TopicOutput) SyncReplicaMinNum 

func (o TopicOutput) SyncReplicaMinNum() pulumi.IntPtrOutput

Min number of sync replicas, Default is `1`.

func (TopicOutput) ToTopicOutput 

func (o TopicOutput) ToTopicOutput() TopicOutput

func (TopicOutput) ToTopicOutputWithContext 

func (o TopicOutput) ToTopicOutputWithContext(ctx context.Context) TopicOutput

func (TopicOutput) TopicName 

func (o TopicOutput) TopicName() pulumi.StringOutput

Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).

func (TopicOutput) UncleanLeaderElectionEnable 

func (o TopicOutput) UncleanLeaderElectionEnable() pulumi.BoolPtrOutput

Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed.

type TopicState 

type TopicState struct {
	// Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
	CleanUpPolicy pulumi.StringPtrInput
	// Create time of the CKafka topic.
	CreateTime pulumi.StringPtrInput
	// Whether to open the ip whitelist, `true`: open, `false`: close.
	EnableWhiteList pulumi.BoolPtrInput
	// Data backup cos bucket: the bucket address that is dumped to cos.
	ForwardCosBucket pulumi.StringPtrInput
	// Periodic frequency of data backup to cos.
	ForwardInterval pulumi.IntPtrInput
	// Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup.
	ForwardStatus pulumi.IntPtrInput
	// Ckafka instance ID.
	InstanceId pulumi.StringPtrInput
	// Ip whitelist, quota limit, required when enableWhileList=true.
	IpWhiteLists pulumi.StringArrayInput
	// Max message bytes.
	MaxMessageBytes pulumi.IntPtrInput
	// Message storage location.
	MessageStorageLocation pulumi.StringPtrInput
	// The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
	Note pulumi.StringPtrInput
	// The number of partition.
	PartitionNum pulumi.IntPtrInput
	// The number of replica.
	ReplicaNum pulumi.IntPtrInput
	// Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
	Retention pulumi.IntPtrInput
	// Segment scrolling time, in ms, the current minimum is 3600000ms.
	Segment pulumi.IntPtrInput
	// Number of bytes rolled by shard.
	SegmentBytes pulumi.IntPtrInput
	// Min number of sync replicas, Default is `1`.
	SyncReplicaMinNum pulumi.IntPtrInput
	// Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
	TopicName pulumi.StringPtrInput
	// Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true:  `allowed, `false`: not allowed.
	UncleanLeaderElectionEnable pulumi.BoolPtrInput
}

func (TopicState) ElementType 

func (TopicState) ElementType() reflect.Type

type User 

type User struct {
	pulumi.CustomResourceState

	// Account name used to access to ckafka instance.
	AccountName pulumi.StringOutput `pulumi:"accountName"`
	// Creation time of the account.
	CreateTime pulumi.StringOutput `pulumi:"createTime"`
	// ID of the ckafka instance.
	InstanceId pulumi.StringOutput `pulumi:"instanceId"`
	// Password of the account.
	Password pulumi.StringOutput `pulumi:"password"`
	// The last update time of the account.
	UpdateTime pulumi.StringOutput `pulumi:"updateTime"`
}

Provides a resource to create a Ckafka user.

## Example Usage

Ckafka User

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := Ckafka.NewUser(ctx, "foo", &Ckafka.UserArgs{
			AccountName: pulumi.String("tf-test"),
			InstanceId:  pulumi.String("ckafka-f9ife4zz"),
			Password:    pulumi.String("test1234"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Ckafka user can be imported using the instance_id#account_name, e.g.

```sh 

$ pulumi import tencentcloud:Ckafka/user:User foo ckafka-f9ife4zz#tf-test

```

func GetUser 

func GetUser(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *UserState, opts ...pulumi.ResourceOption) (*User, error)

GetUser gets an existing User 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 NewUser 

func NewUser(ctx *pulumi.Context,
	name string, args *UserArgs, opts ...pulumi.ResourceOption) (*User, error)

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

func (*User) ElementType 

func (*User) ElementType() reflect.Type

func (*User) ToUserOutput 

func (i *User) ToUserOutput() UserOutput

func (*User) ToUserOutputWithContext 

func (i *User) ToUserOutputWithContext(ctx context.Context) UserOutput

type UserArgs 

type UserArgs struct {
	// Account name used to access to ckafka instance.
	AccountName pulumi.StringInput
	// ID of the ckafka instance.
	InstanceId pulumi.StringInput
	// Password of the account.
	Password pulumi.StringInput
}

The set of arguments for constructing a User resource.

func (UserArgs) ElementType 

func (UserArgs) ElementType() reflect.Type

type UserArray 

type UserArray []UserInput

func (UserArray) ElementType 

func (UserArray) ElementType() reflect.Type

func (UserArray) ToUserArrayOutput 

func (i UserArray) ToUserArrayOutput() UserArrayOutput

func (UserArray) ToUserArrayOutputWithContext 

func (i UserArray) ToUserArrayOutputWithContext(ctx context.Context) UserArrayOutput

type UserArrayInput 

type UserArrayInput interface {
	pulumi.Input

	ToUserArrayOutput() UserArrayOutput
	ToUserArrayOutputWithContext(context.Context) UserArrayOutput
}

UserArrayInput is an input type that accepts UserArray and UserArrayOutput values. You can construct a concrete instance of `UserArrayInput` via: 

UserArray{ UserArgs{...} }

type UserArrayOutput 

type UserArrayOutput struct{ *pulumi.OutputState }

func (UserArrayOutput) ElementType 

func (UserArrayOutput) ElementType() reflect.Type

func (UserArrayOutput) Index 

func (o UserArrayOutput) Index(i pulumi.IntInput) UserOutput

func (UserArrayOutput) ToUserArrayOutput 

func (o UserArrayOutput) ToUserArrayOutput() UserArrayOutput

func (UserArrayOutput) ToUserArrayOutputWithContext 

func (o UserArrayOutput) ToUserArrayOutputWithContext(ctx context.Context) UserArrayOutput

type UserInput 

type UserInput interface {
	pulumi.Input

	ToUserOutput() UserOutput
	ToUserOutputWithContext(ctx context.Context) UserOutput
}

type UserMap 

type UserMap map[string]UserInput

func (UserMap) ElementType 

func (UserMap) ElementType() reflect.Type

func (UserMap) ToUserMapOutput 

func (i UserMap) ToUserMapOutput() UserMapOutput

func (UserMap) ToUserMapOutputWithContext 

func (i UserMap) ToUserMapOutputWithContext(ctx context.Context) UserMapOutput

type UserMapInput 

type UserMapInput interface {
	pulumi.Input

	ToUserMapOutput() UserMapOutput
	ToUserMapOutputWithContext(context.Context) UserMapOutput
}

UserMapInput is an input type that accepts UserMap and UserMapOutput values. You can construct a concrete instance of `UserMapInput` via: 

UserMap{ "key": UserArgs{...} }

type UserMapOutput 

type UserMapOutput struct{ *pulumi.OutputState }

func (UserMapOutput) ElementType 

func (UserMapOutput) ElementType() reflect.Type

func (UserMapOutput) MapIndex 

func (o UserMapOutput) MapIndex(k pulumi.StringInput) UserOutput

func (UserMapOutput) ToUserMapOutput 

func (o UserMapOutput) ToUserMapOutput() UserMapOutput

func (UserMapOutput) ToUserMapOutputWithContext 

func (o UserMapOutput) ToUserMapOutputWithContext(ctx context.Context) UserMapOutput

type UserOutput 

type UserOutput struct{ *pulumi.OutputState }

func (UserOutput) AccountName 

func (o UserOutput) AccountName() pulumi.StringOutput

Account name used to access to ckafka instance.

func (UserOutput) CreateTime 

func (o UserOutput) CreateTime() pulumi.StringOutput

Creation time of the account.

func (UserOutput) ElementType 

func (UserOutput) ElementType() reflect.Type

func (UserOutput) InstanceId 

func (o UserOutput) InstanceId() pulumi.StringOutput

ID of the ckafka instance.

func (UserOutput) Password 

func (o UserOutput) Password() pulumi.StringOutput

Password of the account.

func (UserOutput) ToUserOutput 

func (o UserOutput) ToUserOutput() UserOutput

func (UserOutput) ToUserOutputWithContext 

func (o UserOutput) ToUserOutputWithContext(ctx context.Context) UserOutput

func (UserOutput) UpdateTime 

func (o UserOutput) UpdateTime() pulumi.StringOutput

The last update time of the account.

type UserState 

type UserState struct {
	// Account name used to access to ckafka instance.
	AccountName pulumi.StringPtrInput
	// Creation time of the account.
	CreateTime pulumi.StringPtrInput
	// ID of the ckafka instance.
	InstanceId pulumi.StringPtrInput
	// Password of the account.
	Password pulumi.StringPtrInput
	// The last update time of the account.
	UpdateTime pulumi.StringPtrInput
}

func (UserState) ElementType 

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