ckafka

package
v0.1.4 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PkgVersion added in v0.0.5 

func PkgVersion() (semver.Version, error)

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

Types

type 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 ConnectResource added in v0.1.3 

type ConnectResource struct {
	pulumi.CustomResourceState

	// ClickHouse configuration, required when Type is CLICKHOUSE.
	ClickhouseConnectParam ConnectResourceClickhouseConnectParamPtrOutput `pulumi:"clickhouseConnectParam"`
	// Connection source description.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Doris configuration, required when Type is DORIS.
	DorisConnectParam ConnectResourceDorisConnectParamPtrOutput `pulumi:"dorisConnectParam"`
	// Dts configuration, required when Type is DTS.
	DtsConnectParam ConnectResourceDtsConnectParamPtrOutput `pulumi:"dtsConnectParam"`
	// Es configuration, required when Type is ES.
	EsConnectParam ConnectResourceEsConnectParamPtrOutput `pulumi:"esConnectParam"`
	// Kafka configuration, required when Type is KAFKA.
	KafkaConnectParam ConnectResourceKafkaConnectParamPtrOutput `pulumi:"kafkaConnectParam"`
	// Maria DB configuration, required when Type is MARIADB.
	MariadbConnectParam ConnectResourceMariadbConnectParamPtrOutput `pulumi:"mariadbConnectParam"`
	// Mongo DB configuration, required when Type is MONGODB.
	MongodbConnectParam ConnectResourceMongodbConnectParamPtrOutput `pulumi:"mongodbConnectParam"`
	// MySQL configuration, required when Type is MYSQL or TDSQL C_MYSQL.
	MysqlConnectParam ConnectResourceMysqlConnectParamPtrOutput `pulumi:"mysqlConnectParam"`
	// Postgresql configuration, required when Type is POSTGRESQL or TDSQL C POSTGRESQL.
	PostgresqlConnectParam ConnectResourcePostgresqlConnectParamPtrOutput `pulumi:"postgresqlConnectParam"`
	// connection source name.
	ResourceName pulumi.StringOutput `pulumi:"resourceName"`
	// SQLServer configuration, required when Type is SQLSERVER.
	SqlserverConnectParam ConnectResourceSqlserverConnectParamPtrOutput `pulumi:"sqlserverConnectParam"`
	// connection source type.
	Type pulumi.StringOutput `pulumi:"type"`
}

Provides a resource to create a ckafka connectResource

## 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.NewConnectResource(ctx, "connectResource", &Ckafka.ConnectResourceArgs{
			Description: pulumi.String("for terraform test"),
			MysqlConnectParam: &ckafka.ConnectResourceMysqlConnectParamArgs{
				Password:   pulumi.String("xxxxxxxxx"),
				Port:       pulumi.Int(3306),
				Resource:   pulumi.String("cdb-fitq5t9h"),
				SelfBuilt:  pulumi.Bool(false),
				ServiceVip: pulumi.String("172.16.80.59"),
				UniqVpcId:  pulumi.String("vpc-4owdpnwr"),
				UserName:   pulumi.String("root"),
			},
			ResourceName: pulumi.String("terraform-test"),
			Type:         pulumi.String("MYSQL"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

ckafka connect_resource can be imported using the id, e.g.

```sh 

$ pulumi import tencentcloud:Ckafka/connectResource:ConnectResource connect_resource connect_resource_id

```

func GetConnectResource added in v0.1.3 

func GetConnectResource(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ConnectResourceState, opts ...pulumi.ResourceOption) (*ConnectResource, error)

GetConnectResource gets an existing ConnectResource 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 NewConnectResource added in v0.1.3 

func NewConnectResource(ctx *pulumi.Context,
	name string, args *ConnectResourceArgs, opts ...pulumi.ResourceOption) (*ConnectResource, error)

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

func (*ConnectResource) ElementType added in v0.1.3 

func (*ConnectResource) ElementType() reflect.Type

func (*ConnectResource) ToConnectResourceOutput added in v0.1.3 

func (i *ConnectResource) ToConnectResourceOutput() ConnectResourceOutput

func (*ConnectResource) ToConnectResourceOutputWithContext added in v0.1.3 

func (i *ConnectResource) ToConnectResourceOutputWithContext(ctx context.Context) ConnectResourceOutput

type ConnectResourceArgs added in v0.1.3 

type ConnectResourceArgs struct {
	// ClickHouse configuration, required when Type is CLICKHOUSE.
	ClickhouseConnectParam ConnectResourceClickhouseConnectParamPtrInput
	// Connection source description.
	Description pulumi.StringPtrInput
	// Doris configuration, required when Type is DORIS.
	DorisConnectParam ConnectResourceDorisConnectParamPtrInput
	// Dts configuration, required when Type is DTS.
	DtsConnectParam ConnectResourceDtsConnectParamPtrInput
	// Es configuration, required when Type is ES.
	EsConnectParam ConnectResourceEsConnectParamPtrInput
	// Kafka configuration, required when Type is KAFKA.
	KafkaConnectParam ConnectResourceKafkaConnectParamPtrInput
	// Maria DB configuration, required when Type is MARIADB.
	MariadbConnectParam ConnectResourceMariadbConnectParamPtrInput
	// Mongo DB configuration, required when Type is MONGODB.
	MongodbConnectParam ConnectResourceMongodbConnectParamPtrInput
	// MySQL configuration, required when Type is MYSQL or TDSQL C_MYSQL.
	MysqlConnectParam ConnectResourceMysqlConnectParamPtrInput
	// Postgresql configuration, required when Type is POSTGRESQL or TDSQL C POSTGRESQL.
	PostgresqlConnectParam ConnectResourcePostgresqlConnectParamPtrInput
	// connection source name.
	ResourceName pulumi.StringInput
	// SQLServer configuration, required when Type is SQLSERVER.
	SqlserverConnectParam ConnectResourceSqlserverConnectParamPtrInput
	// connection source type.
	Type pulumi.StringInput
}

The set of arguments for constructing a ConnectResource resource.

func (ConnectResourceArgs) ElementType added in v0.1.3 

func (ConnectResourceArgs) ElementType() reflect.Type

type ConnectResourceArray added in v0.1.3 

type ConnectResourceArray []ConnectResourceInput

func (ConnectResourceArray) ElementType added in v0.1.3 

func (ConnectResourceArray) ElementType() reflect.Type

func (ConnectResourceArray) ToConnectResourceArrayOutput added in v0.1.3 

func (i ConnectResourceArray) ToConnectResourceArrayOutput() ConnectResourceArrayOutput

func (ConnectResourceArray) ToConnectResourceArrayOutputWithContext added in v0.1.3 

func (i ConnectResourceArray) ToConnectResourceArrayOutputWithContext(ctx context.Context) ConnectResourceArrayOutput

type ConnectResourceArrayInput added in v0.1.3 

type ConnectResourceArrayInput interface {
	pulumi.Input

	ToConnectResourceArrayOutput() ConnectResourceArrayOutput
	ToConnectResourceArrayOutputWithContext(context.Context) ConnectResourceArrayOutput
}

ConnectResourceArrayInput is an input type that accepts ConnectResourceArray and ConnectResourceArrayOutput values. You can construct a concrete instance of `ConnectResourceArrayInput` via: 

ConnectResourceArray{ ConnectResourceArgs{...} }

type ConnectResourceArrayOutput added in v0.1.3 

type ConnectResourceArrayOutput struct{ *pulumi.OutputState }

func (ConnectResourceArrayOutput) ElementType added in v0.1.3 

func (ConnectResourceArrayOutput) ElementType() reflect.Type

func (ConnectResourceArrayOutput) Index added in v0.1.3 

func (o ConnectResourceArrayOutput) Index(i pulumi.IntInput) ConnectResourceOutput

func (ConnectResourceArrayOutput) ToConnectResourceArrayOutput added in v0.1.3 

func (o ConnectResourceArrayOutput) ToConnectResourceArrayOutput() ConnectResourceArrayOutput

func (ConnectResourceArrayOutput) ToConnectResourceArrayOutputWithContext added in v0.1.3 

func (o ConnectResourceArrayOutput) ToConnectResourceArrayOutputWithContext(ctx context.Context) ConnectResourceArrayOutput

type ConnectResourceClickhouseConnectParam added in v0.1.3 

type ConnectResourceClickhouseConnectParam struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// Password for Clickhouse connection source.
	Password string `pulumi:"password"`
	// Clickhouse connection port.
	Port int `pulumi:"port"`
	// Instance resources for Click House connection sources.
	Resource string `pulumi:"resource"`
	// Whether the Clickhouse connection source is a self-built cluster.
	SelfBuilt bool `pulumi:"selfBuilt"`
	// Instance VIP of the ClickHouse connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// The vpc Id of the source of the ClickHouse connection, when it is a Tencent Cloud instance, it is required.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// The username of the clickhouse connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourceClickhouseConnectParamArgs added in v0.1.3 

type ConnectResourceClickhouseConnectParamArgs struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// Password for Clickhouse connection source.
	Password pulumi.StringInput `pulumi:"password"`
	// Clickhouse connection port.
	Port pulumi.IntInput `pulumi:"port"`
	// Instance resources for Click House connection sources.
	Resource pulumi.StringInput `pulumi:"resource"`
	// Whether the Clickhouse connection source is a self-built cluster.
	SelfBuilt pulumi.BoolInput `pulumi:"selfBuilt"`
	// Instance VIP of the ClickHouse connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// The vpc Id of the source of the ClickHouse connection, when it is a Tencent Cloud instance, it is required.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// The username of the clickhouse connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceClickhouseConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceClickhouseConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamOutput added in v0.1.3 

func (i ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamOutput() ConnectResourceClickhouseConnectParamOutput

func (ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamOutputWithContext(ctx context.Context) ConnectResourceClickhouseConnectParamOutput

func (ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamPtrOutput() ConnectResourceClickhouseConnectParamPtrOutput

func (ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceClickhouseConnectParamArgs) ToConnectResourceClickhouseConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceClickhouseConnectParamPtrOutput

type ConnectResourceClickhouseConnectParamInput added in v0.1.3 

type ConnectResourceClickhouseConnectParamInput interface {
	pulumi.Input

	ToConnectResourceClickhouseConnectParamOutput() ConnectResourceClickhouseConnectParamOutput
	ToConnectResourceClickhouseConnectParamOutputWithContext(context.Context) ConnectResourceClickhouseConnectParamOutput
}

ConnectResourceClickhouseConnectParamInput is an input type that accepts ConnectResourceClickhouseConnectParamArgs and ConnectResourceClickhouseConnectParamOutput values. You can construct a concrete instance of `ConnectResourceClickhouseConnectParamInput` via: 

ConnectResourceClickhouseConnectParamArgs{...}

type ConnectResourceClickhouseConnectParamOutput added in v0.1.3 

type ConnectResourceClickhouseConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceClickhouseConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceClickhouseConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceClickhouseConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceClickhouseConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) Password() pulumi.StringOutput

Password for Clickhouse connection source.

func (ConnectResourceClickhouseConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) Port() pulumi.IntOutput

Clickhouse connection port.

func (ConnectResourceClickhouseConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) Resource() pulumi.StringOutput

Instance resources for Click House connection sources.

func (ConnectResourceClickhouseConnectParamOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) SelfBuilt() pulumi.BoolOutput

Whether the Clickhouse connection source is a self-built cluster.

func (ConnectResourceClickhouseConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

Instance VIP of the ClickHouse connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamOutput added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamOutput() ConnectResourceClickhouseConnectParamOutput

func (ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamOutputWithContext(ctx context.Context) ConnectResourceClickhouseConnectParamOutput

func (ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamPtrOutput() ConnectResourceClickhouseConnectParamPtrOutput

func (ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) ToConnectResourceClickhouseConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceClickhouseConnectParamPtrOutput

func (ConnectResourceClickhouseConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the source of the ClickHouse connection, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceClickhouseConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamOutput) UserName() pulumi.StringOutput

The username of the clickhouse connection source.

type ConnectResourceClickhouseConnectParamPtrInput added in v0.1.3 

type ConnectResourceClickhouseConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceClickhouseConnectParamPtrOutput() ConnectResourceClickhouseConnectParamPtrOutput
	ToConnectResourceClickhouseConnectParamPtrOutputWithContext(context.Context) ConnectResourceClickhouseConnectParamPtrOutput
}

ConnectResourceClickhouseConnectParamPtrInput is an input type that accepts ConnectResourceClickhouseConnectParamArgs, ConnectResourceClickhouseConnectParamPtr and ConnectResourceClickhouseConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceClickhouseConnectParamPtrInput` via: 

        ConnectResourceClickhouseConnectParamArgs{...}

or:

        nil

func ConnectResourceClickhouseConnectParamPtr added in v0.1.3 

func ConnectResourceClickhouseConnectParamPtr(v *ConnectResourceClickhouseConnectParamArgs) ConnectResourceClickhouseConnectParamPtrInput

type ConnectResourceClickhouseConnectParamPtrOutput added in v0.1.3 

type ConnectResourceClickhouseConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceClickhouseConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) Elem() ConnectResourceClickhouseConnectParamOutput

func (ConnectResourceClickhouseConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceClickhouseConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceClickhouseConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceClickhouseConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) Password() pulumi.StringPtrOutput

Password for Clickhouse connection source.

func (ConnectResourceClickhouseConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) Port() pulumi.IntPtrOutput

Clickhouse connection port.

func (ConnectResourceClickhouseConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

Instance resources for Click House connection sources.

func (ConnectResourceClickhouseConnectParamPtrOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) SelfBuilt() pulumi.BoolPtrOutput

Whether the Clickhouse connection source is a self-built cluster.

func (ConnectResourceClickhouseConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

Instance VIP of the ClickHouse connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceClickhouseConnectParamPtrOutput) ToConnectResourceClickhouseConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) ToConnectResourceClickhouseConnectParamPtrOutput() ConnectResourceClickhouseConnectParamPtrOutput

func (ConnectResourceClickhouseConnectParamPtrOutput) ToConnectResourceClickhouseConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) ToConnectResourceClickhouseConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceClickhouseConnectParamPtrOutput

func (ConnectResourceClickhouseConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the source of the ClickHouse connection, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceClickhouseConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceClickhouseConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

The username of the clickhouse connection source.

type ConnectResourceDorisConnectParam added in v0.1.3 

type ConnectResourceDorisConnectParam struct {
	// Doris http CLB port, Usually mapped to port 8040 of be.
	BePort *int `pulumi:"bePort"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// Doris  password.
	Password string `pulumi:"password"`
	// Doris jdbc CLB port, Usually mapped to port 9030 of fe.
	Port int `pulumi:"port"`
	// Doris  instanceId.
	Resource string `pulumi:"resource"`
	// Doris Whether the connection source is a self-built cluster, default: false.
	SelfBuilt *bool `pulumi:"selfBuilt"`
	// Doris vip, When it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// Doris vpcId, When it is a Tencent Cloud instance, it is required.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// Doris  The username of the connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourceDorisConnectParamArgs added in v0.1.3 

type ConnectResourceDorisConnectParamArgs struct {
	// Doris http CLB port, Usually mapped to port 8040 of be.
	BePort pulumi.IntPtrInput `pulumi:"bePort"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// Doris  password.
	Password pulumi.StringInput `pulumi:"password"`
	// Doris jdbc CLB port, Usually mapped to port 9030 of fe.
	Port pulumi.IntInput `pulumi:"port"`
	// Doris  instanceId.
	Resource pulumi.StringInput `pulumi:"resource"`
	// Doris Whether the connection source is a self-built cluster, default: false.
	SelfBuilt pulumi.BoolPtrInput `pulumi:"selfBuilt"`
	// Doris vip, When it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// Doris vpcId, When it is a Tencent Cloud instance, it is required.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// Doris  The username of the connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceDorisConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceDorisConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamOutput added in v0.1.3 

func (i ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamOutput() ConnectResourceDorisConnectParamOutput

func (ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamOutputWithContext(ctx context.Context) ConnectResourceDorisConnectParamOutput

func (ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamPtrOutput() ConnectResourceDorisConnectParamPtrOutput

func (ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceDorisConnectParamArgs) ToConnectResourceDorisConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceDorisConnectParamPtrOutput

type ConnectResourceDorisConnectParamInput added in v0.1.3 

type ConnectResourceDorisConnectParamInput interface {
	pulumi.Input

	ToConnectResourceDorisConnectParamOutput() ConnectResourceDorisConnectParamOutput
	ToConnectResourceDorisConnectParamOutputWithContext(context.Context) ConnectResourceDorisConnectParamOutput
}

ConnectResourceDorisConnectParamInput is an input type that accepts ConnectResourceDorisConnectParamArgs and ConnectResourceDorisConnectParamOutput values. You can construct a concrete instance of `ConnectResourceDorisConnectParamInput` via: 

ConnectResourceDorisConnectParamArgs{...}

type ConnectResourceDorisConnectParamOutput added in v0.1.3 

type ConnectResourceDorisConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceDorisConnectParamOutput) BePort added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) BePort() pulumi.IntPtrOutput

Doris http CLB port, Usually mapped to port 8040 of be.

func (ConnectResourceDorisConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceDorisConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceDorisConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceDorisConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) Password() pulumi.StringOutput

Doris password.

func (ConnectResourceDorisConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) Port() pulumi.IntOutput

Doris jdbc CLB port, Usually mapped to port 9030 of fe.

func (ConnectResourceDorisConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) Resource() pulumi.StringOutput

Doris instanceId.

func (ConnectResourceDorisConnectParamOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) SelfBuilt() pulumi.BoolPtrOutput

Doris Whether the connection source is a self-built cluster, default: false.

func (ConnectResourceDorisConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

Doris vip, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamOutput added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamOutput() ConnectResourceDorisConnectParamOutput

func (ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamOutputWithContext(ctx context.Context) ConnectResourceDorisConnectParamOutput

func (ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamPtrOutput() ConnectResourceDorisConnectParamPtrOutput

func (ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) ToConnectResourceDorisConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceDorisConnectParamPtrOutput

func (ConnectResourceDorisConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

Doris vpcId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceDorisConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceDorisConnectParamOutput) UserName() pulumi.StringOutput

Doris The username of the connection source.

type ConnectResourceDorisConnectParamPtrInput added in v0.1.3 

type ConnectResourceDorisConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceDorisConnectParamPtrOutput() ConnectResourceDorisConnectParamPtrOutput
	ToConnectResourceDorisConnectParamPtrOutputWithContext(context.Context) ConnectResourceDorisConnectParamPtrOutput
}

ConnectResourceDorisConnectParamPtrInput is an input type that accepts ConnectResourceDorisConnectParamArgs, ConnectResourceDorisConnectParamPtr and ConnectResourceDorisConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceDorisConnectParamPtrInput` via: 

        ConnectResourceDorisConnectParamArgs{...}

or:

        nil

func ConnectResourceDorisConnectParamPtr added in v0.1.3 

func ConnectResourceDorisConnectParamPtr(v *ConnectResourceDorisConnectParamArgs) ConnectResourceDorisConnectParamPtrInput

type ConnectResourceDorisConnectParamPtrOutput added in v0.1.3 

type ConnectResourceDorisConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceDorisConnectParamPtrOutput) BePort added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) BePort() pulumi.IntPtrOutput

Doris http CLB port, Usually mapped to port 8040 of be.

func (ConnectResourceDorisConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) Elem() ConnectResourceDorisConnectParamOutput

func (ConnectResourceDorisConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceDorisConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceDorisConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceDorisConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) Password() pulumi.StringPtrOutput

Doris password.

func (ConnectResourceDorisConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) Port() pulumi.IntPtrOutput

Doris jdbc CLB port, Usually mapped to port 9030 of fe.

func (ConnectResourceDorisConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

Doris instanceId.

func (ConnectResourceDorisConnectParamPtrOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) SelfBuilt() pulumi.BoolPtrOutput

Doris Whether the connection source is a self-built cluster, default: false.

func (ConnectResourceDorisConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

Doris vip, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceDorisConnectParamPtrOutput) ToConnectResourceDorisConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) ToConnectResourceDorisConnectParamPtrOutput() ConnectResourceDorisConnectParamPtrOutput

func (ConnectResourceDorisConnectParamPtrOutput) ToConnectResourceDorisConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) ToConnectResourceDorisConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceDorisConnectParamPtrOutput

func (ConnectResourceDorisConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

Doris vpcId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceDorisConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceDorisConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

Doris The username of the connection source.

type ConnectResourceDtsConnectParam added in v0.1.3 

type ConnectResourceDtsConnectParam struct {
	// Id of the Dts consumption group.
	GroupId string `pulumi:"groupId"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// The password of the Dts consumption group.
	Password string `pulumi:"password"`
	// Dts port.
	Port int `pulumi:"port"`
	// Dts instance Id.
	Resource string `pulumi:"resource"`
	// Topic subscribed by Dts.
	Topic string `pulumi:"topic"`
	// The account number of the Dts consumption group.
	UserName string `pulumi:"userName"`
}

type ConnectResourceDtsConnectParamArgs added in v0.1.3 

type ConnectResourceDtsConnectParamArgs struct {
	// Id of the Dts consumption group.
	GroupId pulumi.StringInput `pulumi:"groupId"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// The password of the Dts consumption group.
	Password pulumi.StringInput `pulumi:"password"`
	// Dts port.
	Port pulumi.IntInput `pulumi:"port"`
	// Dts instance Id.
	Resource pulumi.StringInput `pulumi:"resource"`
	// Topic subscribed by Dts.
	Topic pulumi.StringInput `pulumi:"topic"`
	// The account number of the Dts consumption group.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceDtsConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceDtsConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamOutput added in v0.1.3 

func (i ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamOutput() ConnectResourceDtsConnectParamOutput

func (ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamOutputWithContext(ctx context.Context) ConnectResourceDtsConnectParamOutput

func (ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamPtrOutput() ConnectResourceDtsConnectParamPtrOutput

func (ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceDtsConnectParamArgs) ToConnectResourceDtsConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceDtsConnectParamPtrOutput

type ConnectResourceDtsConnectParamInput added in v0.1.3 

type ConnectResourceDtsConnectParamInput interface {
	pulumi.Input

	ToConnectResourceDtsConnectParamOutput() ConnectResourceDtsConnectParamOutput
	ToConnectResourceDtsConnectParamOutputWithContext(context.Context) ConnectResourceDtsConnectParamOutput
}

ConnectResourceDtsConnectParamInput is an input type that accepts ConnectResourceDtsConnectParamArgs and ConnectResourceDtsConnectParamOutput values. You can construct a concrete instance of `ConnectResourceDtsConnectParamInput` via: 

ConnectResourceDtsConnectParamArgs{...}

type ConnectResourceDtsConnectParamOutput added in v0.1.3 

type ConnectResourceDtsConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceDtsConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceDtsConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceDtsConnectParamOutput) GroupId added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) GroupId() pulumi.StringOutput

Id of the Dts consumption group.

func (ConnectResourceDtsConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceDtsConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) Password() pulumi.StringOutput

The password of the Dts consumption group.

func (ConnectResourceDtsConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) Port() pulumi.IntOutput

Dts port.

func (ConnectResourceDtsConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) Resource() pulumi.StringOutput

Dts instance Id.

func (ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamOutput added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamOutput() ConnectResourceDtsConnectParamOutput

func (ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamOutputWithContext(ctx context.Context) ConnectResourceDtsConnectParamOutput

func (ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamPtrOutput() ConnectResourceDtsConnectParamPtrOutput

func (ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) ToConnectResourceDtsConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceDtsConnectParamPtrOutput

func (ConnectResourceDtsConnectParamOutput) Topic added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) Topic() pulumi.StringOutput

Topic subscribed by Dts.

func (ConnectResourceDtsConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceDtsConnectParamOutput) UserName() pulumi.StringOutput

The account number of the Dts consumption group.

type ConnectResourceDtsConnectParamPtrInput added in v0.1.3 

type ConnectResourceDtsConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceDtsConnectParamPtrOutput() ConnectResourceDtsConnectParamPtrOutput
	ToConnectResourceDtsConnectParamPtrOutputWithContext(context.Context) ConnectResourceDtsConnectParamPtrOutput
}

ConnectResourceDtsConnectParamPtrInput is an input type that accepts ConnectResourceDtsConnectParamArgs, ConnectResourceDtsConnectParamPtr and ConnectResourceDtsConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceDtsConnectParamPtrInput` via: 

        ConnectResourceDtsConnectParamArgs{...}

or:

        nil

func ConnectResourceDtsConnectParamPtr added in v0.1.3 

func ConnectResourceDtsConnectParamPtr(v *ConnectResourceDtsConnectParamArgs) ConnectResourceDtsConnectParamPtrInput

type ConnectResourceDtsConnectParamPtrOutput added in v0.1.3 

type ConnectResourceDtsConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceDtsConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) Elem() ConnectResourceDtsConnectParamOutput

func (ConnectResourceDtsConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceDtsConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceDtsConnectParamPtrOutput) GroupId added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) GroupId() pulumi.StringPtrOutput

Id of the Dts consumption group.

func (ConnectResourceDtsConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceDtsConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) Password() pulumi.StringPtrOutput

The password of the Dts consumption group.

func (ConnectResourceDtsConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) Port() pulumi.IntPtrOutput

Dts port.

func (ConnectResourceDtsConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

Dts instance Id.

func (ConnectResourceDtsConnectParamPtrOutput) ToConnectResourceDtsConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) ToConnectResourceDtsConnectParamPtrOutput() ConnectResourceDtsConnectParamPtrOutput

func (ConnectResourceDtsConnectParamPtrOutput) ToConnectResourceDtsConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) ToConnectResourceDtsConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceDtsConnectParamPtrOutput

func (ConnectResourceDtsConnectParamPtrOutput) Topic added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) Topic() pulumi.StringPtrOutput

Topic subscribed by Dts.

func (ConnectResourceDtsConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceDtsConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

The account number of the Dts consumption group.

type ConnectResourceEsConnectParam added in v0.1.3 

type ConnectResourceEsConnectParam struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// Es The password of the connection source.
	Password string `pulumi:"password"`
	// Es port.
	Port int `pulumi:"port"`
	// Instance resource of Es connection source.
	Resource string `pulumi:"resource"`
	// Whether the Es connection source is a self-built cluster.
	SelfBuilt bool `pulumi:"selfBuilt"`
	// The instance vip of the Es connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// The vpc Id of the Es connection source, when it is a Tencent Cloud instance, it is required.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// Es The username of the connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourceEsConnectParamArgs added in v0.1.3 

type ConnectResourceEsConnectParamArgs struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// Es The password of the connection source.
	Password pulumi.StringInput `pulumi:"password"`
	// Es port.
	Port pulumi.IntInput `pulumi:"port"`
	// Instance resource of Es connection source.
	Resource pulumi.StringInput `pulumi:"resource"`
	// Whether the Es connection source is a self-built cluster.
	SelfBuilt pulumi.BoolInput `pulumi:"selfBuilt"`
	// The instance vip of the Es connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// The vpc Id of the Es connection source, when it is a Tencent Cloud instance, it is required.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// Es The username of the connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceEsConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceEsConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamOutput added in v0.1.3 

func (i ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamOutput() ConnectResourceEsConnectParamOutput

func (ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamOutputWithContext(ctx context.Context) ConnectResourceEsConnectParamOutput

func (ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamPtrOutput() ConnectResourceEsConnectParamPtrOutput

func (ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceEsConnectParamArgs) ToConnectResourceEsConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceEsConnectParamPtrOutput

type ConnectResourceEsConnectParamInput added in v0.1.3 

type ConnectResourceEsConnectParamInput interface {
	pulumi.Input

	ToConnectResourceEsConnectParamOutput() ConnectResourceEsConnectParamOutput
	ToConnectResourceEsConnectParamOutputWithContext(context.Context) ConnectResourceEsConnectParamOutput
}

ConnectResourceEsConnectParamInput is an input type that accepts ConnectResourceEsConnectParamArgs and ConnectResourceEsConnectParamOutput values. You can construct a concrete instance of `ConnectResourceEsConnectParamInput` via: 

ConnectResourceEsConnectParamArgs{...}

type ConnectResourceEsConnectParamOutput added in v0.1.3 

type ConnectResourceEsConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceEsConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceEsConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceEsConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceEsConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) Password() pulumi.StringOutput

Es The password of the connection source.

func (ConnectResourceEsConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) Port() pulumi.IntOutput

Es port.

func (ConnectResourceEsConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) Resource() pulumi.StringOutput

Instance resource of Es connection source.

func (ConnectResourceEsConnectParamOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) SelfBuilt() pulumi.BoolOutput

Whether the Es connection source is a self-built cluster.

func (ConnectResourceEsConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

The instance vip of the Es connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamOutput added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamOutput() ConnectResourceEsConnectParamOutput

func (ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamOutputWithContext(ctx context.Context) ConnectResourceEsConnectParamOutput

func (ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamPtrOutput() ConnectResourceEsConnectParamPtrOutput

func (ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) ToConnectResourceEsConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceEsConnectParamPtrOutput

func (ConnectResourceEsConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the Es connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceEsConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceEsConnectParamOutput) UserName() pulumi.StringOutput

Es The username of the connection source.

type ConnectResourceEsConnectParamPtrInput added in v0.1.3 

type ConnectResourceEsConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceEsConnectParamPtrOutput() ConnectResourceEsConnectParamPtrOutput
	ToConnectResourceEsConnectParamPtrOutputWithContext(context.Context) ConnectResourceEsConnectParamPtrOutput
}

ConnectResourceEsConnectParamPtrInput is an input type that accepts ConnectResourceEsConnectParamArgs, ConnectResourceEsConnectParamPtr and ConnectResourceEsConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceEsConnectParamPtrInput` via: 

        ConnectResourceEsConnectParamArgs{...}

or:

        nil

func ConnectResourceEsConnectParamPtr added in v0.1.3 

func ConnectResourceEsConnectParamPtr(v *ConnectResourceEsConnectParamArgs) ConnectResourceEsConnectParamPtrInput

type ConnectResourceEsConnectParamPtrOutput added in v0.1.3 

type ConnectResourceEsConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceEsConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) Elem() ConnectResourceEsConnectParamOutput

func (ConnectResourceEsConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceEsConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceEsConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceEsConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) Password() pulumi.StringPtrOutput

Es The password of the connection source.

func (ConnectResourceEsConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) Port() pulumi.IntPtrOutput

Es port.

func (ConnectResourceEsConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

Instance resource of Es connection source.

func (ConnectResourceEsConnectParamPtrOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) SelfBuilt() pulumi.BoolPtrOutput

Whether the Es connection source is a self-built cluster.

func (ConnectResourceEsConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

The instance vip of the Es connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceEsConnectParamPtrOutput) ToConnectResourceEsConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) ToConnectResourceEsConnectParamPtrOutput() ConnectResourceEsConnectParamPtrOutput

func (ConnectResourceEsConnectParamPtrOutput) ToConnectResourceEsConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) ToConnectResourceEsConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceEsConnectParamPtrOutput

func (ConnectResourceEsConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the Es connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceEsConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceEsConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

Es The username of the connection source.

type ConnectResourceInput added in v0.1.3 

type ConnectResourceInput interface {
	pulumi.Input

	ToConnectResourceOutput() ConnectResourceOutput
	ToConnectResourceOutputWithContext(ctx context.Context) ConnectResourceOutput
}

type ConnectResourceKafkaConnectParam added in v0.1.3 

type ConnectResourceKafkaConnectParam struct {
	// Kafka broker ip, Mandatory when self-built.
	BrokerAddress *string `pulumi:"brokerAddress"`
	// Whether to update to the associated Dip task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// CKafka instanceId region, Required when crossing regions.
	Region *string `pulumi:"region"`
	// Kafka instanceId, When it is a Tencent Cloud instance, it is required.
	Resource *string `pulumi:"resource"`
	// Whether it is a self-built cluster, default: false.
	SelfBuilt *bool `pulumi:"selfBuilt"`
}

type ConnectResourceKafkaConnectParamArgs added in v0.1.3 

type ConnectResourceKafkaConnectParamArgs struct {
	// Kafka broker ip, Mandatory when self-built.
	BrokerAddress pulumi.StringPtrInput `pulumi:"brokerAddress"`
	// Whether to update to the associated Dip task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// CKafka instanceId region, Required when crossing regions.
	Region pulumi.StringPtrInput `pulumi:"region"`
	// Kafka instanceId, When it is a Tencent Cloud instance, it is required.
	Resource pulumi.StringPtrInput `pulumi:"resource"`
	// Whether it is a self-built cluster, default: false.
	SelfBuilt pulumi.BoolPtrInput `pulumi:"selfBuilt"`
}

func (ConnectResourceKafkaConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceKafkaConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamOutput added in v0.1.3 

func (i ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamOutput() ConnectResourceKafkaConnectParamOutput

func (ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamOutputWithContext(ctx context.Context) ConnectResourceKafkaConnectParamOutput

func (ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamPtrOutput() ConnectResourceKafkaConnectParamPtrOutput

func (ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceKafkaConnectParamArgs) ToConnectResourceKafkaConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceKafkaConnectParamPtrOutput

type ConnectResourceKafkaConnectParamInput added in v0.1.3 

type ConnectResourceKafkaConnectParamInput interface {
	pulumi.Input

	ToConnectResourceKafkaConnectParamOutput() ConnectResourceKafkaConnectParamOutput
	ToConnectResourceKafkaConnectParamOutputWithContext(context.Context) ConnectResourceKafkaConnectParamOutput
}

ConnectResourceKafkaConnectParamInput is an input type that accepts ConnectResourceKafkaConnectParamArgs and ConnectResourceKafkaConnectParamOutput values. You can construct a concrete instance of `ConnectResourceKafkaConnectParamInput` via: 

ConnectResourceKafkaConnectParamArgs{...}

type ConnectResourceKafkaConnectParamOutput added in v0.1.3 

type ConnectResourceKafkaConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceKafkaConnectParamOutput) BrokerAddress added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) BrokerAddress() pulumi.StringPtrOutput

Kafka broker ip, Mandatory when self-built.

func (ConnectResourceKafkaConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceKafkaConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceKafkaConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Dip task, default: false.

func (ConnectResourceKafkaConnectParamOutput) Region added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) Region() pulumi.StringPtrOutput

CKafka instanceId region, Required when crossing regions.

func (ConnectResourceKafkaConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) Resource() pulumi.StringPtrOutput

Kafka instanceId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceKafkaConnectParamOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) SelfBuilt() pulumi.BoolPtrOutput

Whether it is a self-built cluster, default: false.

func (ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamOutput added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamOutput() ConnectResourceKafkaConnectParamOutput

func (ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamOutputWithContext(ctx context.Context) ConnectResourceKafkaConnectParamOutput

func (ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamPtrOutput() ConnectResourceKafkaConnectParamPtrOutput

func (ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceKafkaConnectParamOutput) ToConnectResourceKafkaConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceKafkaConnectParamPtrOutput

type ConnectResourceKafkaConnectParamPtrInput added in v0.1.3 

type ConnectResourceKafkaConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceKafkaConnectParamPtrOutput() ConnectResourceKafkaConnectParamPtrOutput
	ToConnectResourceKafkaConnectParamPtrOutputWithContext(context.Context) ConnectResourceKafkaConnectParamPtrOutput
}

ConnectResourceKafkaConnectParamPtrInput is an input type that accepts ConnectResourceKafkaConnectParamArgs, ConnectResourceKafkaConnectParamPtr and ConnectResourceKafkaConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceKafkaConnectParamPtrInput` via: 

        ConnectResourceKafkaConnectParamArgs{...}

or:

        nil

func ConnectResourceKafkaConnectParamPtr added in v0.1.3 

func ConnectResourceKafkaConnectParamPtr(v *ConnectResourceKafkaConnectParamArgs) ConnectResourceKafkaConnectParamPtrInput

type ConnectResourceKafkaConnectParamPtrOutput added in v0.1.3 

type ConnectResourceKafkaConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceKafkaConnectParamPtrOutput) BrokerAddress added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) BrokerAddress() pulumi.StringPtrOutput

Kafka broker ip, Mandatory when self-built.

func (ConnectResourceKafkaConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) Elem() ConnectResourceKafkaConnectParamOutput

func (ConnectResourceKafkaConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceKafkaConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceKafkaConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Dip task, default: false.

func (ConnectResourceKafkaConnectParamPtrOutput) Region added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) Region() pulumi.StringPtrOutput

CKafka instanceId region, Required when crossing regions.

func (ConnectResourceKafkaConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

Kafka instanceId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceKafkaConnectParamPtrOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) SelfBuilt() pulumi.BoolPtrOutput

Whether it is a self-built cluster, default: false.

func (ConnectResourceKafkaConnectParamPtrOutput) ToConnectResourceKafkaConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) ToConnectResourceKafkaConnectParamPtrOutput() ConnectResourceKafkaConnectParamPtrOutput

func (ConnectResourceKafkaConnectParamPtrOutput) ToConnectResourceKafkaConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceKafkaConnectParamPtrOutput) ToConnectResourceKafkaConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceKafkaConnectParamPtrOutput

type ConnectResourceMap added in v0.1.3 

type ConnectResourceMap map[string]ConnectResourceInput

func (ConnectResourceMap) ElementType added in v0.1.3 

func (ConnectResourceMap) ElementType() reflect.Type

func (ConnectResourceMap) ToConnectResourceMapOutput added in v0.1.3 

func (i ConnectResourceMap) ToConnectResourceMapOutput() ConnectResourceMapOutput

func (ConnectResourceMap) ToConnectResourceMapOutputWithContext added in v0.1.3 

func (i ConnectResourceMap) ToConnectResourceMapOutputWithContext(ctx context.Context) ConnectResourceMapOutput

type ConnectResourceMapInput added in v0.1.3 

type ConnectResourceMapInput interface {
	pulumi.Input

	ToConnectResourceMapOutput() ConnectResourceMapOutput
	ToConnectResourceMapOutputWithContext(context.Context) ConnectResourceMapOutput
}

ConnectResourceMapInput is an input type that accepts ConnectResourceMap and ConnectResourceMapOutput values. You can construct a concrete instance of `ConnectResourceMapInput` via: 

ConnectResourceMap{ "key": ConnectResourceArgs{...} }

type ConnectResourceMapOutput added in v0.1.3 

type ConnectResourceMapOutput struct{ *pulumi.OutputState }

func (ConnectResourceMapOutput) ElementType added in v0.1.3 

func (ConnectResourceMapOutput) ElementType() reflect.Type

func (ConnectResourceMapOutput) MapIndex added in v0.1.3 

func (o ConnectResourceMapOutput) MapIndex(k pulumi.StringInput) ConnectResourceOutput

func (ConnectResourceMapOutput) ToConnectResourceMapOutput added in v0.1.3 

func (o ConnectResourceMapOutput) ToConnectResourceMapOutput() ConnectResourceMapOutput

func (ConnectResourceMapOutput) ToConnectResourceMapOutputWithContext added in v0.1.3 

func (o ConnectResourceMapOutput) ToConnectResourceMapOutputWithContext(ctx context.Context) ConnectResourceMapOutput

type ConnectResourceMariadbConnectParam added in v0.1.3 

type ConnectResourceMariadbConnectParam struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// MariaDB password.
	Password string `pulumi:"password"`
	// MariaDB port.
	Port int `pulumi:"port"`
	// MariaDB instanceId.
	Resource string `pulumi:"resource"`
	// The instance vip of the Maria DB connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// MariaDB vpcId, When it is a Tencent Cloud instance, it is required.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// MariaDB The username of the connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourceMariadbConnectParamArgs added in v0.1.3 

type ConnectResourceMariadbConnectParamArgs struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// MariaDB password.
	Password pulumi.StringInput `pulumi:"password"`
	// MariaDB port.
	Port pulumi.IntInput `pulumi:"port"`
	// MariaDB instanceId.
	Resource pulumi.StringInput `pulumi:"resource"`
	// The instance vip of the Maria DB connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// MariaDB vpcId, When it is a Tencent Cloud instance, it is required.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// MariaDB The username of the connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceMariadbConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceMariadbConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamOutput added in v0.1.3 

func (i ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamOutput() ConnectResourceMariadbConnectParamOutput

func (ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamOutputWithContext(ctx context.Context) ConnectResourceMariadbConnectParamOutput

func (ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamPtrOutput() ConnectResourceMariadbConnectParamPtrOutput

func (ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceMariadbConnectParamArgs) ToConnectResourceMariadbConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMariadbConnectParamPtrOutput

type ConnectResourceMariadbConnectParamInput added in v0.1.3 

type ConnectResourceMariadbConnectParamInput interface {
	pulumi.Input

	ToConnectResourceMariadbConnectParamOutput() ConnectResourceMariadbConnectParamOutput
	ToConnectResourceMariadbConnectParamOutputWithContext(context.Context) ConnectResourceMariadbConnectParamOutput
}

ConnectResourceMariadbConnectParamInput is an input type that accepts ConnectResourceMariadbConnectParamArgs and ConnectResourceMariadbConnectParamOutput values. You can construct a concrete instance of `ConnectResourceMariadbConnectParamInput` via: 

ConnectResourceMariadbConnectParamArgs{...}

type ConnectResourceMariadbConnectParamOutput added in v0.1.3 

type ConnectResourceMariadbConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceMariadbConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceMariadbConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceMariadbConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceMariadbConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) Password() pulumi.StringOutput

MariaDB password.

func (ConnectResourceMariadbConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) Port() pulumi.IntOutput

MariaDB port.

func (ConnectResourceMariadbConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) Resource() pulumi.StringOutput

MariaDB instanceId.

func (ConnectResourceMariadbConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

The instance vip of the Maria DB connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamOutput added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamOutput() ConnectResourceMariadbConnectParamOutput

func (ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamOutputWithContext(ctx context.Context) ConnectResourceMariadbConnectParamOutput

func (ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamPtrOutput() ConnectResourceMariadbConnectParamPtrOutput

func (ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) ToConnectResourceMariadbConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMariadbConnectParamPtrOutput

func (ConnectResourceMariadbConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

MariaDB vpcId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceMariadbConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceMariadbConnectParamOutput) UserName() pulumi.StringOutput

MariaDB The username of the connection source.

type ConnectResourceMariadbConnectParamPtrInput added in v0.1.3 

type ConnectResourceMariadbConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceMariadbConnectParamPtrOutput() ConnectResourceMariadbConnectParamPtrOutput
	ToConnectResourceMariadbConnectParamPtrOutputWithContext(context.Context) ConnectResourceMariadbConnectParamPtrOutput
}

ConnectResourceMariadbConnectParamPtrInput is an input type that accepts ConnectResourceMariadbConnectParamArgs, ConnectResourceMariadbConnectParamPtr and ConnectResourceMariadbConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceMariadbConnectParamPtrInput` via: 

        ConnectResourceMariadbConnectParamArgs{...}

or:

        nil

func ConnectResourceMariadbConnectParamPtr added in v0.1.3 

func ConnectResourceMariadbConnectParamPtr(v *ConnectResourceMariadbConnectParamArgs) ConnectResourceMariadbConnectParamPtrInput

type ConnectResourceMariadbConnectParamPtrOutput added in v0.1.3 

type ConnectResourceMariadbConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceMariadbConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) Elem() ConnectResourceMariadbConnectParamOutput

func (ConnectResourceMariadbConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceMariadbConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceMariadbConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceMariadbConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) Password() pulumi.StringPtrOutput

MariaDB password.

func (ConnectResourceMariadbConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) Port() pulumi.IntPtrOutput

MariaDB port.

func (ConnectResourceMariadbConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

MariaDB instanceId.

func (ConnectResourceMariadbConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

The instance vip of the Maria DB connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMariadbConnectParamPtrOutput) ToConnectResourceMariadbConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) ToConnectResourceMariadbConnectParamPtrOutput() ConnectResourceMariadbConnectParamPtrOutput

func (ConnectResourceMariadbConnectParamPtrOutput) ToConnectResourceMariadbConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) ToConnectResourceMariadbConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMariadbConnectParamPtrOutput

func (ConnectResourceMariadbConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

MariaDB vpcId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceMariadbConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceMariadbConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

MariaDB The username of the connection source.

type ConnectResourceMongodbConnectParam added in v0.1.3 

type ConnectResourceMongodbConnectParam struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// Password for the source of the Mongo DB connection.
	Password string `pulumi:"password"`
	// MongoDB port.
	Port int `pulumi:"port"`
	// Instance resource of Mongo DB connection source.
	Resource string `pulumi:"resource"`
	// Whether the Mongo DB connection source is a self-built cluster.
	SelfBuilt bool `pulumi:"selfBuilt"`
	// The instance VIP of the Mongo DB connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// The vpc Id of the Mongo DB connection source, which is required when it is a Tencent Cloud instance.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// The username of the Mongo DB connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourceMongodbConnectParamArgs added in v0.1.3 

type ConnectResourceMongodbConnectParamArgs struct {
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// Password for the source of the Mongo DB connection.
	Password pulumi.StringInput `pulumi:"password"`
	// MongoDB port.
	Port pulumi.IntInput `pulumi:"port"`
	// Instance resource of Mongo DB connection source.
	Resource pulumi.StringInput `pulumi:"resource"`
	// Whether the Mongo DB connection source is a self-built cluster.
	SelfBuilt pulumi.BoolInput `pulumi:"selfBuilt"`
	// The instance VIP of the Mongo DB connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// The vpc Id of the Mongo DB connection source, which is required when it is a Tencent Cloud instance.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// The username of the Mongo DB connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceMongodbConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceMongodbConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamOutput added in v0.1.3 

func (i ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamOutput() ConnectResourceMongodbConnectParamOutput

func (ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamOutputWithContext(ctx context.Context) ConnectResourceMongodbConnectParamOutput

func (ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamPtrOutput() ConnectResourceMongodbConnectParamPtrOutput

func (ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceMongodbConnectParamArgs) ToConnectResourceMongodbConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMongodbConnectParamPtrOutput

type ConnectResourceMongodbConnectParamInput added in v0.1.3 

type ConnectResourceMongodbConnectParamInput interface {
	pulumi.Input

	ToConnectResourceMongodbConnectParamOutput() ConnectResourceMongodbConnectParamOutput
	ToConnectResourceMongodbConnectParamOutputWithContext(context.Context) ConnectResourceMongodbConnectParamOutput
}

ConnectResourceMongodbConnectParamInput is an input type that accepts ConnectResourceMongodbConnectParamArgs and ConnectResourceMongodbConnectParamOutput values. You can construct a concrete instance of `ConnectResourceMongodbConnectParamInput` via: 

ConnectResourceMongodbConnectParamArgs{...}

type ConnectResourceMongodbConnectParamOutput added in v0.1.3 

type ConnectResourceMongodbConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceMongodbConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceMongodbConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceMongodbConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceMongodbConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) Password() pulumi.StringOutput

Password for the source of the Mongo DB connection.

func (ConnectResourceMongodbConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) Port() pulumi.IntOutput

MongoDB port.

func (ConnectResourceMongodbConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) Resource() pulumi.StringOutput

Instance resource of Mongo DB connection source.

func (ConnectResourceMongodbConnectParamOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) SelfBuilt() pulumi.BoolOutput

Whether the Mongo DB connection source is a self-built cluster.

func (ConnectResourceMongodbConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

The instance VIP of the Mongo DB connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamOutput added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamOutput() ConnectResourceMongodbConnectParamOutput

func (ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamOutputWithContext(ctx context.Context) ConnectResourceMongodbConnectParamOutput

func (ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamPtrOutput() ConnectResourceMongodbConnectParamPtrOutput

func (ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) ToConnectResourceMongodbConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMongodbConnectParamPtrOutput

func (ConnectResourceMongodbConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the Mongo DB connection source, which is required when it is a Tencent Cloud instance.

func (ConnectResourceMongodbConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceMongodbConnectParamOutput) UserName() pulumi.StringOutput

The username of the Mongo DB connection source.

type ConnectResourceMongodbConnectParamPtrInput added in v0.1.3 

type ConnectResourceMongodbConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceMongodbConnectParamPtrOutput() ConnectResourceMongodbConnectParamPtrOutput
	ToConnectResourceMongodbConnectParamPtrOutputWithContext(context.Context) ConnectResourceMongodbConnectParamPtrOutput
}

ConnectResourceMongodbConnectParamPtrInput is an input type that accepts ConnectResourceMongodbConnectParamArgs, ConnectResourceMongodbConnectParamPtr and ConnectResourceMongodbConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceMongodbConnectParamPtrInput` via: 

        ConnectResourceMongodbConnectParamArgs{...}

or:

        nil

func ConnectResourceMongodbConnectParamPtr added in v0.1.3 

func ConnectResourceMongodbConnectParamPtr(v *ConnectResourceMongodbConnectParamArgs) ConnectResourceMongodbConnectParamPtrInput

type ConnectResourceMongodbConnectParamPtrOutput added in v0.1.3 

type ConnectResourceMongodbConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceMongodbConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) Elem() ConnectResourceMongodbConnectParamOutput

func (ConnectResourceMongodbConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceMongodbConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceMongodbConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceMongodbConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) Password() pulumi.StringPtrOutput

Password for the source of the Mongo DB connection.

func (ConnectResourceMongodbConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) Port() pulumi.IntPtrOutput

MongoDB port.

func (ConnectResourceMongodbConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

Instance resource of Mongo DB connection source.

func (ConnectResourceMongodbConnectParamPtrOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) SelfBuilt() pulumi.BoolPtrOutput

Whether the Mongo DB connection source is a self-built cluster.

func (ConnectResourceMongodbConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

The instance VIP of the Mongo DB connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMongodbConnectParamPtrOutput) ToConnectResourceMongodbConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) ToConnectResourceMongodbConnectParamPtrOutput() ConnectResourceMongodbConnectParamPtrOutput

func (ConnectResourceMongodbConnectParamPtrOutput) ToConnectResourceMongodbConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) ToConnectResourceMongodbConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMongodbConnectParamPtrOutput

func (ConnectResourceMongodbConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the Mongo DB connection source, which is required when it is a Tencent Cloud instance.

func (ConnectResourceMongodbConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceMongodbConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

The username of the Mongo DB connection source.

type ConnectResourceMysqlConnectParam added in v0.1.3 

type ConnectResourceMysqlConnectParam struct {
	// Required when type is TDSQL C_MYSQL.
	ClusterId *string `pulumi:"clusterId"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// Mysql connection source password.
	Password string `pulumi:"password"`
	// MySQL port.
	Port int `pulumi:"port"`
	// Instance resource of My SQL connection source.
	Resource string `pulumi:"resource"`
	// Mysql Whether the connection source is a self-built cluster, default: false.
	SelfBuilt *bool `pulumi:"selfBuilt"`
	// The instance vip of the MySQL connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// The vpc Id of the My SQL connection source, when it is a Tencent Cloud instance, it is required.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// Username of Mysql connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourceMysqlConnectParamArgs added in v0.1.3 

type ConnectResourceMysqlConnectParamArgs struct {
	// Required when type is TDSQL C_MYSQL.
	ClusterId pulumi.StringPtrInput `pulumi:"clusterId"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// Mysql connection source password.
	Password pulumi.StringInput `pulumi:"password"`
	// MySQL port.
	Port pulumi.IntInput `pulumi:"port"`
	// Instance resource of My SQL connection source.
	Resource pulumi.StringInput `pulumi:"resource"`
	// Mysql Whether the connection source is a self-built cluster, default: false.
	SelfBuilt pulumi.BoolPtrInput `pulumi:"selfBuilt"`
	// The instance vip of the MySQL connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// The vpc Id of the My SQL connection source, when it is a Tencent Cloud instance, it is required.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// Username of Mysql connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceMysqlConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceMysqlConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamOutput added in v0.1.3 

func (i ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamOutput() ConnectResourceMysqlConnectParamOutput

func (ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamOutputWithContext(ctx context.Context) ConnectResourceMysqlConnectParamOutput

func (ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamPtrOutput() ConnectResourceMysqlConnectParamPtrOutput

func (ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceMysqlConnectParamArgs) ToConnectResourceMysqlConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMysqlConnectParamPtrOutput

type ConnectResourceMysqlConnectParamInput added in v0.1.3 

type ConnectResourceMysqlConnectParamInput interface {
	pulumi.Input

	ToConnectResourceMysqlConnectParamOutput() ConnectResourceMysqlConnectParamOutput
	ToConnectResourceMysqlConnectParamOutputWithContext(context.Context) ConnectResourceMysqlConnectParamOutput
}

ConnectResourceMysqlConnectParamInput is an input type that accepts ConnectResourceMysqlConnectParamArgs and ConnectResourceMysqlConnectParamOutput values. You can construct a concrete instance of `ConnectResourceMysqlConnectParamInput` via: 

ConnectResourceMysqlConnectParamArgs{...}

type ConnectResourceMysqlConnectParamOutput added in v0.1.3 

type ConnectResourceMysqlConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceMysqlConnectParamOutput) ClusterId added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) ClusterId() pulumi.StringPtrOutput

Required when type is TDSQL C_MYSQL.

func (ConnectResourceMysqlConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceMysqlConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceMysqlConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceMysqlConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) Password() pulumi.StringOutput

Mysql connection source password.

func (ConnectResourceMysqlConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) Port() pulumi.IntOutput

MySQL port.

func (ConnectResourceMysqlConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) Resource() pulumi.StringOutput

Instance resource of My SQL connection source.

func (ConnectResourceMysqlConnectParamOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) SelfBuilt() pulumi.BoolPtrOutput

Mysql Whether the connection source is a self-built cluster, default: false.

func (ConnectResourceMysqlConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

The instance vip of the MySQL connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamOutput added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamOutput() ConnectResourceMysqlConnectParamOutput

func (ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamOutputWithContext(ctx context.Context) ConnectResourceMysqlConnectParamOutput

func (ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamPtrOutput() ConnectResourceMysqlConnectParamPtrOutput

func (ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) ToConnectResourceMysqlConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMysqlConnectParamPtrOutput

func (ConnectResourceMysqlConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the My SQL connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMysqlConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceMysqlConnectParamOutput) UserName() pulumi.StringOutput

Username of Mysql connection source.

type ConnectResourceMysqlConnectParamPtrInput added in v0.1.3 

type ConnectResourceMysqlConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceMysqlConnectParamPtrOutput() ConnectResourceMysqlConnectParamPtrOutput
	ToConnectResourceMysqlConnectParamPtrOutputWithContext(context.Context) ConnectResourceMysqlConnectParamPtrOutput
}

ConnectResourceMysqlConnectParamPtrInput is an input type that accepts ConnectResourceMysqlConnectParamArgs, ConnectResourceMysqlConnectParamPtr and ConnectResourceMysqlConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceMysqlConnectParamPtrInput` via: 

        ConnectResourceMysqlConnectParamArgs{...}

or:

        nil

func ConnectResourceMysqlConnectParamPtr added in v0.1.3 

func ConnectResourceMysqlConnectParamPtr(v *ConnectResourceMysqlConnectParamArgs) ConnectResourceMysqlConnectParamPtrInput

type ConnectResourceMysqlConnectParamPtrOutput added in v0.1.3 

type ConnectResourceMysqlConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceMysqlConnectParamPtrOutput) ClusterId added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) ClusterId() pulumi.StringPtrOutput

Required when type is TDSQL C_MYSQL.

func (ConnectResourceMysqlConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) Elem() ConnectResourceMysqlConnectParamOutput

func (ConnectResourceMysqlConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceMysqlConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceMysqlConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourceMysqlConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) Password() pulumi.StringPtrOutput

Mysql connection source password.

func (ConnectResourceMysqlConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) Port() pulumi.IntPtrOutput

MySQL port.

func (ConnectResourceMysqlConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

Instance resource of My SQL connection source.

func (ConnectResourceMysqlConnectParamPtrOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) SelfBuilt() pulumi.BoolPtrOutput

Mysql Whether the connection source is a self-built cluster, default: false.

func (ConnectResourceMysqlConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

The instance vip of the MySQL connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMysqlConnectParamPtrOutput) ToConnectResourceMysqlConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) ToConnectResourceMysqlConnectParamPtrOutput() ConnectResourceMysqlConnectParamPtrOutput

func (ConnectResourceMysqlConnectParamPtrOutput) ToConnectResourceMysqlConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) ToConnectResourceMysqlConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceMysqlConnectParamPtrOutput

func (ConnectResourceMysqlConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

The vpc Id of the My SQL connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourceMysqlConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceMysqlConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

Username of Mysql connection source.

type ConnectResourceOutput added in v0.1.3 

type ConnectResourceOutput struct{ *pulumi.OutputState }

func (ConnectResourceOutput) ClickhouseConnectParam added in v0.1.3 

func (o ConnectResourceOutput) ClickhouseConnectParam() ConnectResourceClickhouseConnectParamPtrOutput

ClickHouse configuration, required when Type is CLICKHOUSE.

func (ConnectResourceOutput) Description added in v0.1.3 

func (o ConnectResourceOutput) Description() pulumi.StringPtrOutput

Connection source description.

func (ConnectResourceOutput) DorisConnectParam added in v0.1.3 

func (o ConnectResourceOutput) DorisConnectParam() ConnectResourceDorisConnectParamPtrOutput

Doris configuration, required when Type is DORIS.

func (ConnectResourceOutput) DtsConnectParam added in v0.1.3 

func (o ConnectResourceOutput) DtsConnectParam() ConnectResourceDtsConnectParamPtrOutput

Dts configuration, required when Type is DTS.

func (ConnectResourceOutput) ElementType added in v0.1.3 

func (ConnectResourceOutput) ElementType() reflect.Type

func (ConnectResourceOutput) EsConnectParam added in v0.1.3 

func (o ConnectResourceOutput) EsConnectParam() ConnectResourceEsConnectParamPtrOutput

Es configuration, required when Type is ES.

func (ConnectResourceOutput) KafkaConnectParam added in v0.1.3 

func (o ConnectResourceOutput) KafkaConnectParam() ConnectResourceKafkaConnectParamPtrOutput

Kafka configuration, required when Type is KAFKA.

func (ConnectResourceOutput) MariadbConnectParam added in v0.1.3 

func (o ConnectResourceOutput) MariadbConnectParam() ConnectResourceMariadbConnectParamPtrOutput

Maria DB configuration, required when Type is MARIADB.

func (ConnectResourceOutput) MongodbConnectParam added in v0.1.3 

func (o ConnectResourceOutput) MongodbConnectParam() ConnectResourceMongodbConnectParamPtrOutput

Mongo DB configuration, required when Type is MONGODB.

func (ConnectResourceOutput) MysqlConnectParam added in v0.1.3 

func (o ConnectResourceOutput) MysqlConnectParam() ConnectResourceMysqlConnectParamPtrOutput

MySQL configuration, required when Type is MYSQL or TDSQL C_MYSQL.

func (ConnectResourceOutput) PostgresqlConnectParam added in v0.1.3 

func (o ConnectResourceOutput) PostgresqlConnectParam() ConnectResourcePostgresqlConnectParamPtrOutput

Postgresql configuration, required when Type is POSTGRESQL or TDSQL C POSTGRESQL.

func (ConnectResourceOutput) ResourceName added in v0.1.3 

func (o ConnectResourceOutput) ResourceName() pulumi.StringOutput

connection source name.

func (ConnectResourceOutput) SqlserverConnectParam added in v0.1.3 

func (o ConnectResourceOutput) SqlserverConnectParam() ConnectResourceSqlserverConnectParamPtrOutput

SQLServer configuration, required when Type is SQLSERVER.

func (ConnectResourceOutput) ToConnectResourceOutput added in v0.1.3 

func (o ConnectResourceOutput) ToConnectResourceOutput() ConnectResourceOutput

func (ConnectResourceOutput) ToConnectResourceOutputWithContext added in v0.1.3 

func (o ConnectResourceOutput) ToConnectResourceOutputWithContext(ctx context.Context) ConnectResourceOutput

func (ConnectResourceOutput) Type added in v0.1.3 

func (o ConnectResourceOutput) Type() pulumi.StringOutput

connection source type.

type ConnectResourcePostgresqlConnectParam added in v0.1.3 

type ConnectResourcePostgresqlConnectParam struct {
	// Required when type is TDSQL C_POSTGRESQL.
	ClusterId *string `pulumi:"clusterId"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// PostgreSQL password.
	Password string `pulumi:"password"`
	// PostgreSQL port.
	Port int `pulumi:"port"`
	// PostgreSQL instanceId.
	Resource string `pulumi:"resource"`
	// PostgreSQL Whether the connection source is a self-built cluster, default: false.
	SelfBuilt *bool `pulumi:"selfBuilt"`
	// The instance VIP of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// The instance vpcId of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// PostgreSQL The username of the connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourcePostgresqlConnectParamArgs added in v0.1.3 

type ConnectResourcePostgresqlConnectParamArgs struct {
	// Required when type is TDSQL C_POSTGRESQL.
	ClusterId pulumi.StringPtrInput `pulumi:"clusterId"`
	// Whether to update to the associated Datahub task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// PostgreSQL password.
	Password pulumi.StringInput `pulumi:"password"`
	// PostgreSQL port.
	Port pulumi.IntInput `pulumi:"port"`
	// PostgreSQL instanceId.
	Resource pulumi.StringInput `pulumi:"resource"`
	// PostgreSQL Whether the connection source is a self-built cluster, default: false.
	SelfBuilt pulumi.BoolPtrInput `pulumi:"selfBuilt"`
	// The instance VIP of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// The instance vpcId of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// PostgreSQL The username of the connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourcePostgresqlConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourcePostgresqlConnectParamArgs) ElementType() reflect.Type

func (ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamOutput added in v0.1.3 

func (i ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamOutput() ConnectResourcePostgresqlConnectParamOutput

func (ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamOutputWithContext(ctx context.Context) ConnectResourcePostgresqlConnectParamOutput

func (ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamPtrOutput() ConnectResourcePostgresqlConnectParamPtrOutput

func (ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourcePostgresqlConnectParamArgs) ToConnectResourcePostgresqlConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourcePostgresqlConnectParamPtrOutput

type ConnectResourcePostgresqlConnectParamInput added in v0.1.3 

type ConnectResourcePostgresqlConnectParamInput interface {
	pulumi.Input

	ToConnectResourcePostgresqlConnectParamOutput() ConnectResourcePostgresqlConnectParamOutput
	ToConnectResourcePostgresqlConnectParamOutputWithContext(context.Context) ConnectResourcePostgresqlConnectParamOutput
}

ConnectResourcePostgresqlConnectParamInput is an input type that accepts ConnectResourcePostgresqlConnectParamArgs and ConnectResourcePostgresqlConnectParamOutput values. You can construct a concrete instance of `ConnectResourcePostgresqlConnectParamInput` via: 

ConnectResourcePostgresqlConnectParamArgs{...}

type ConnectResourcePostgresqlConnectParamOutput added in v0.1.3 

type ConnectResourcePostgresqlConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourcePostgresqlConnectParamOutput) ClusterId added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) ClusterId() pulumi.StringPtrOutput

Required when type is TDSQL C_POSTGRESQL.

func (ConnectResourcePostgresqlConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourcePostgresqlConnectParamOutput) ElementType() reflect.Type

func (ConnectResourcePostgresqlConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourcePostgresqlConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) Password() pulumi.StringOutput

PostgreSQL password.

func (ConnectResourcePostgresqlConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) Port() pulumi.IntOutput

PostgreSQL port.

func (ConnectResourcePostgresqlConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) Resource() pulumi.StringOutput

PostgreSQL instanceId.

func (ConnectResourcePostgresqlConnectParamOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) SelfBuilt() pulumi.BoolPtrOutput

PostgreSQL Whether the connection source is a self-built cluster, default: false.

func (ConnectResourcePostgresqlConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

The instance VIP of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamOutput added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamOutput() ConnectResourcePostgresqlConnectParamOutput

func (ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamOutputWithContext(ctx context.Context) ConnectResourcePostgresqlConnectParamOutput

func (ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamPtrOutput() ConnectResourcePostgresqlConnectParamPtrOutput

func (ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) ToConnectResourcePostgresqlConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourcePostgresqlConnectParamPtrOutput

func (ConnectResourcePostgresqlConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

The instance vpcId of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourcePostgresqlConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamOutput) UserName() pulumi.StringOutput

PostgreSQL The username of the connection source.

type ConnectResourcePostgresqlConnectParamPtrInput added in v0.1.3 

type ConnectResourcePostgresqlConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourcePostgresqlConnectParamPtrOutput() ConnectResourcePostgresqlConnectParamPtrOutput
	ToConnectResourcePostgresqlConnectParamPtrOutputWithContext(context.Context) ConnectResourcePostgresqlConnectParamPtrOutput
}

ConnectResourcePostgresqlConnectParamPtrInput is an input type that accepts ConnectResourcePostgresqlConnectParamArgs, ConnectResourcePostgresqlConnectParamPtr and ConnectResourcePostgresqlConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourcePostgresqlConnectParamPtrInput` via: 

        ConnectResourcePostgresqlConnectParamArgs{...}

or:

        nil

func ConnectResourcePostgresqlConnectParamPtr added in v0.1.3 

func ConnectResourcePostgresqlConnectParamPtr(v *ConnectResourcePostgresqlConnectParamArgs) ConnectResourcePostgresqlConnectParamPtrInput

type ConnectResourcePostgresqlConnectParamPtrOutput added in v0.1.3 

type ConnectResourcePostgresqlConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourcePostgresqlConnectParamPtrOutput) ClusterId added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) ClusterId() pulumi.StringPtrOutput

Required when type is TDSQL C_POSTGRESQL.

func (ConnectResourcePostgresqlConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) Elem() ConnectResourcePostgresqlConnectParamOutput

func (ConnectResourcePostgresqlConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourcePostgresqlConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourcePostgresqlConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Datahub task, default: false.

func (ConnectResourcePostgresqlConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) Password() pulumi.StringPtrOutput

PostgreSQL password.

func (ConnectResourcePostgresqlConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) Port() pulumi.IntPtrOutput

PostgreSQL port.

func (ConnectResourcePostgresqlConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

PostgreSQL instanceId.

func (ConnectResourcePostgresqlConnectParamPtrOutput) SelfBuilt added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) SelfBuilt() pulumi.BoolPtrOutput

PostgreSQL Whether the connection source is a self-built cluster, default: false.

func (ConnectResourcePostgresqlConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

The instance VIP of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourcePostgresqlConnectParamPtrOutput) ToConnectResourcePostgresqlConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) ToConnectResourcePostgresqlConnectParamPtrOutput() ConnectResourcePostgresqlConnectParamPtrOutput

func (ConnectResourcePostgresqlConnectParamPtrOutput) ToConnectResourcePostgresqlConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) ToConnectResourcePostgresqlConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourcePostgresqlConnectParamPtrOutput

func (ConnectResourcePostgresqlConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

The instance vpcId of the Postgresql connection source, when it is a Tencent Cloud instance, it is required.

func (ConnectResourcePostgresqlConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourcePostgresqlConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

PostgreSQL The username of the connection source.

type ConnectResourceSqlserverConnectParam added in v0.1.3 

type ConnectResourceSqlserverConnectParam struct {
	// Whether to update to the associated Dip task, default: false.
	IsUpdate *bool `pulumi:"isUpdate"`
	// SQLServer password.
	Password string `pulumi:"password"`
	// SQLServer port.
	Port int `pulumi:"port"`
	// SQLServer instanceId.
	Resource string `pulumi:"resource"`
	// SQLServer instance vip, When it is a Tencent Cloud instance, it is required.
	ServiceVip *string `pulumi:"serviceVip"`
	// SQLServer vpcId, When it is a Tencent Cloud instance, it is required.
	UniqVpcId *string `pulumi:"uniqVpcId"`
	// SQLServer The username of the connection source.
	UserName string `pulumi:"userName"`
}

type ConnectResourceSqlserverConnectParamArgs added in v0.1.3 

type ConnectResourceSqlserverConnectParamArgs struct {
	// Whether to update to the associated Dip task, default: false.
	IsUpdate pulumi.BoolPtrInput `pulumi:"isUpdate"`
	// SQLServer password.
	Password pulumi.StringInput `pulumi:"password"`
	// SQLServer port.
	Port pulumi.IntInput `pulumi:"port"`
	// SQLServer instanceId.
	Resource pulumi.StringInput `pulumi:"resource"`
	// SQLServer instance vip, When it is a Tencent Cloud instance, it is required.
	ServiceVip pulumi.StringPtrInput `pulumi:"serviceVip"`
	// SQLServer vpcId, When it is a Tencent Cloud instance, it is required.
	UniqVpcId pulumi.StringPtrInput `pulumi:"uniqVpcId"`
	// SQLServer The username of the connection source.
	UserName pulumi.StringInput `pulumi:"userName"`
}

func (ConnectResourceSqlserverConnectParamArgs) ElementType added in v0.1.3 

func (ConnectResourceSqlserverConnectParamArgs) ElementType() reflect.Type

func (ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamOutput added in v0.1.3 

func (i ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamOutput() ConnectResourceSqlserverConnectParamOutput

func (ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamOutputWithContext added in v0.1.3 

func (i ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamOutputWithContext(ctx context.Context) ConnectResourceSqlserverConnectParamOutput

func (ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamPtrOutput added in v0.1.3 

func (i ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamPtrOutput() ConnectResourceSqlserverConnectParamPtrOutput

func (ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamPtrOutputWithContext added in v0.1.3 

func (i ConnectResourceSqlserverConnectParamArgs) ToConnectResourceSqlserverConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceSqlserverConnectParamPtrOutput

type ConnectResourceSqlserverConnectParamInput added in v0.1.3 

type ConnectResourceSqlserverConnectParamInput interface {
	pulumi.Input

	ToConnectResourceSqlserverConnectParamOutput() ConnectResourceSqlserverConnectParamOutput
	ToConnectResourceSqlserverConnectParamOutputWithContext(context.Context) ConnectResourceSqlserverConnectParamOutput
}

ConnectResourceSqlserverConnectParamInput is an input type that accepts ConnectResourceSqlserverConnectParamArgs and ConnectResourceSqlserverConnectParamOutput values. You can construct a concrete instance of `ConnectResourceSqlserverConnectParamInput` via: 

ConnectResourceSqlserverConnectParamArgs{...}

type ConnectResourceSqlserverConnectParamOutput added in v0.1.3 

type ConnectResourceSqlserverConnectParamOutput struct{ *pulumi.OutputState }

func (ConnectResourceSqlserverConnectParamOutput) ElementType added in v0.1.3 

func (ConnectResourceSqlserverConnectParamOutput) ElementType() reflect.Type

func (ConnectResourceSqlserverConnectParamOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Dip task, default: false.

func (ConnectResourceSqlserverConnectParamOutput) Password added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) Password() pulumi.StringOutput

SQLServer password.

func (ConnectResourceSqlserverConnectParamOutput) Port added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) Port() pulumi.IntOutput

SQLServer port.

func (ConnectResourceSqlserverConnectParamOutput) Resource added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) Resource() pulumi.StringOutput

SQLServer instanceId.

func (ConnectResourceSqlserverConnectParamOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) ServiceVip() pulumi.StringPtrOutput

SQLServer instance vip, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamOutput added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamOutput() ConnectResourceSqlserverConnectParamOutput

func (ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamOutputWithContext added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamOutputWithContext(ctx context.Context) ConnectResourceSqlserverConnectParamOutput

func (ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamPtrOutput() ConnectResourceSqlserverConnectParamPtrOutput

func (ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) ToConnectResourceSqlserverConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceSqlserverConnectParamPtrOutput

func (ConnectResourceSqlserverConnectParamOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) UniqVpcId() pulumi.StringPtrOutput

SQLServer vpcId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceSqlserverConnectParamOutput) UserName added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamOutput) UserName() pulumi.StringOutput

SQLServer The username of the connection source.

type ConnectResourceSqlserverConnectParamPtrInput added in v0.1.3 

type ConnectResourceSqlserverConnectParamPtrInput interface {
	pulumi.Input

	ToConnectResourceSqlserverConnectParamPtrOutput() ConnectResourceSqlserverConnectParamPtrOutput
	ToConnectResourceSqlserverConnectParamPtrOutputWithContext(context.Context) ConnectResourceSqlserverConnectParamPtrOutput
}

ConnectResourceSqlserverConnectParamPtrInput is an input type that accepts ConnectResourceSqlserverConnectParamArgs, ConnectResourceSqlserverConnectParamPtr and ConnectResourceSqlserverConnectParamPtrOutput values. You can construct a concrete instance of `ConnectResourceSqlserverConnectParamPtrInput` via: 

        ConnectResourceSqlserverConnectParamArgs{...}

or:

        nil

func ConnectResourceSqlserverConnectParamPtr added in v0.1.3 

func ConnectResourceSqlserverConnectParamPtr(v *ConnectResourceSqlserverConnectParamArgs) ConnectResourceSqlserverConnectParamPtrInput

type ConnectResourceSqlserverConnectParamPtrOutput added in v0.1.3 

type ConnectResourceSqlserverConnectParamPtrOutput struct{ *pulumi.OutputState }

func (ConnectResourceSqlserverConnectParamPtrOutput) Elem added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) Elem() ConnectResourceSqlserverConnectParamOutput

func (ConnectResourceSqlserverConnectParamPtrOutput) ElementType added in v0.1.3 

func (ConnectResourceSqlserverConnectParamPtrOutput) ElementType() reflect.Type

func (ConnectResourceSqlserverConnectParamPtrOutput) IsUpdate added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) IsUpdate() pulumi.BoolPtrOutput

Whether to update to the associated Dip task, default: false.

func (ConnectResourceSqlserverConnectParamPtrOutput) Password added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) Password() pulumi.StringPtrOutput

SQLServer password.

func (ConnectResourceSqlserverConnectParamPtrOutput) Port added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) Port() pulumi.IntPtrOutput

SQLServer port.

func (ConnectResourceSqlserverConnectParamPtrOutput) Resource added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) Resource() pulumi.StringPtrOutput

SQLServer instanceId.

func (ConnectResourceSqlserverConnectParamPtrOutput) ServiceVip added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) ServiceVip() pulumi.StringPtrOutput

SQLServer instance vip, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceSqlserverConnectParamPtrOutput) ToConnectResourceSqlserverConnectParamPtrOutput added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) ToConnectResourceSqlserverConnectParamPtrOutput() ConnectResourceSqlserverConnectParamPtrOutput

func (ConnectResourceSqlserverConnectParamPtrOutput) ToConnectResourceSqlserverConnectParamPtrOutputWithContext added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) ToConnectResourceSqlserverConnectParamPtrOutputWithContext(ctx context.Context) ConnectResourceSqlserverConnectParamPtrOutput

func (ConnectResourceSqlserverConnectParamPtrOutput) UniqVpcId added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) UniqVpcId() pulumi.StringPtrOutput

SQLServer vpcId, When it is a Tencent Cloud instance, it is required.

func (ConnectResourceSqlserverConnectParamPtrOutput) UserName added in v0.1.3 

func (o ConnectResourceSqlserverConnectParamPtrOutput) UserName() pulumi.StringPtrOutput

SQLServer The username of the connection source.

type ConnectResourceState added in v0.1.3 

type ConnectResourceState struct {
	// ClickHouse configuration, required when Type is CLICKHOUSE.
	ClickhouseConnectParam ConnectResourceClickhouseConnectParamPtrInput
	// Connection source description.
	Description pulumi.StringPtrInput
	// Doris configuration, required when Type is DORIS.
	DorisConnectParam ConnectResourceDorisConnectParamPtrInput
	// Dts configuration, required when Type is DTS.
	DtsConnectParam ConnectResourceDtsConnectParamPtrInput
	// Es configuration, required when Type is ES.
	EsConnectParam ConnectResourceEsConnectParamPtrInput
	// Kafka configuration, required when Type is KAFKA.
	KafkaConnectParam ConnectResourceKafkaConnectParamPtrInput
	// Maria DB configuration, required when Type is MARIADB.
	MariadbConnectParam ConnectResourceMariadbConnectParamPtrInput
	// Mongo DB configuration, required when Type is MONGODB.
	MongodbConnectParam ConnectResourceMongodbConnectParamPtrInput
	// MySQL configuration, required when Type is MYSQL or TDSQL C_MYSQL.
	MysqlConnectParam ConnectResourceMysqlConnectParamPtrInput
	// Postgresql configuration, required when Type is POSTGRESQL or TDSQL C POSTGRESQL.
	PostgresqlConnectParam ConnectResourcePostgresqlConnectParamPtrInput
	// connection source name.
	ResourceName pulumi.StringPtrInput
	// SQLServer configuration, required when Type is SQLSERVER.
	SqlserverConnectParam ConnectResourceSqlserverConnectParamPtrInput
	// connection source type.
	Type pulumi.StringPtrInput
}

func (ConnectResourceState) ElementType added in v0.1.3 

func (ConnectResourceState) ElementType() reflect.Type

type DatahubTopic added in v0.1.3 

type DatahubTopic struct {
	pulumi.CustomResourceState

	// Name, start with appid, which is a string of no more than 128 characters, must start with a letter, and the rest can contain letters, numbers, and dashes (-).
	Name pulumi.StringOutput `pulumi:"name"`
	// Subject note, which is a string of no more than 64 characters, must start with a letter, and the rest can contain letters, numbers and dashes (-).
	Note pulumi.StringPtrOutput `pulumi:"note"`
	// Number of Partitions, greater than 0.
	PartitionNum pulumi.IntOutput `pulumi:"partitionNum"`
	// Message retention time, in ms, the current minimum value is 60000 ms.
	RetentionMs pulumi.IntOutput `pulumi:"retentionMs"`
	// Tags of dataHub topic.
	Tags pulumi.MapOutput `pulumi:"tags"`
}

Provides a resource to create a ckafka datahubTopic

## Import

ckafka datahub_topic can be imported using the id, e.g.

```sh 

$ pulumi import tencentcloud:Ckafka/datahubTopic:DatahubTopic datahub_topic datahub_topic_name

```

func GetDatahubTopic added in v0.1.3 

func GetDatahubTopic(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *DatahubTopicState, opts ...pulumi.ResourceOption) (*DatahubTopic, error)

GetDatahubTopic gets an existing DatahubTopic 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 NewDatahubTopic added in v0.1.3 

func NewDatahubTopic(ctx *pulumi.Context,
	name string, args *DatahubTopicArgs, opts ...pulumi.ResourceOption) (*DatahubTopic, error)

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

func (*DatahubTopic) ElementType added in v0.1.3 

func (*DatahubTopic) ElementType() reflect.Type

func (*DatahubTopic) ToDatahubTopicOutput added in v0.1.3 

func (i *DatahubTopic) ToDatahubTopicOutput() DatahubTopicOutput

func (*DatahubTopic) ToDatahubTopicOutputWithContext added in v0.1.3 

func (i *DatahubTopic) ToDatahubTopicOutputWithContext(ctx context.Context) DatahubTopicOutput

type DatahubTopicArgs added in v0.1.3 

type DatahubTopicArgs struct {
	// Name, start with appid, which is a string of no more than 128 characters, must start with a letter, and the rest can contain letters, numbers, and dashes (-).
	Name pulumi.StringPtrInput
	// Subject note, which is a string of no more than 64 characters, must start with a letter, and the rest can contain letters, numbers and dashes (-).
	Note pulumi.StringPtrInput
	// Number of Partitions, greater than 0.
	PartitionNum pulumi.IntInput
	// Message retention time, in ms, the current minimum value is 60000 ms.
	RetentionMs pulumi.IntInput
	// Tags of dataHub topic.
	Tags pulumi.MapInput
}

The set of arguments for constructing a DatahubTopic resource.

func (DatahubTopicArgs) ElementType added in v0.1.3 

func (DatahubTopicArgs) ElementType() reflect.Type

type DatahubTopicArray added in v0.1.3 

type DatahubTopicArray []DatahubTopicInput

func (DatahubTopicArray) ElementType added in v0.1.3 

func (DatahubTopicArray) ElementType() reflect.Type

func (DatahubTopicArray) ToDatahubTopicArrayOutput added in v0.1.3 

func (i DatahubTopicArray) ToDatahubTopicArrayOutput() DatahubTopicArrayOutput

func (DatahubTopicArray) ToDatahubTopicArrayOutputWithContext added in v0.1.3 

func (i DatahubTopicArray) ToDatahubTopicArrayOutputWithContext(ctx context.Context) DatahubTopicArrayOutput

type DatahubTopicArrayInput added in v0.1.3 

type DatahubTopicArrayInput interface {
	pulumi.Input

	ToDatahubTopicArrayOutput() DatahubTopicArrayOutput
	ToDatahubTopicArrayOutputWithContext(context.Context) DatahubTopicArrayOutput
}

DatahubTopicArrayInput is an input type that accepts DatahubTopicArray and DatahubTopicArrayOutput values. You can construct a concrete instance of `DatahubTopicArrayInput` via: 

DatahubTopicArray{ DatahubTopicArgs{...} }

type DatahubTopicArrayOutput added in v0.1.3 

type DatahubTopicArrayOutput struct{ *pulumi.OutputState }

func (DatahubTopicArrayOutput) ElementType added in v0.1.3 

func (DatahubTopicArrayOutput) ElementType() reflect.Type

func (DatahubTopicArrayOutput) Index added in v0.1.3 

func (o DatahubTopicArrayOutput) Index(i pulumi.IntInput) DatahubTopicOutput

func (DatahubTopicArrayOutput) ToDatahubTopicArrayOutput added in v0.1.3 

func (o DatahubTopicArrayOutput) ToDatahubTopicArrayOutput() DatahubTopicArrayOutput

func (DatahubTopicArrayOutput) ToDatahubTopicArrayOutputWithContext added in v0.1.3 

func (o DatahubTopicArrayOutput) ToDatahubTopicArrayOutputWithContext(ctx context.Context) DatahubTopicArrayOutput

type DatahubTopicInput added in v0.1.3 

type DatahubTopicInput interface {
	pulumi.Input

	ToDatahubTopicOutput() DatahubTopicOutput
	ToDatahubTopicOutputWithContext(ctx context.Context) DatahubTopicOutput
}

type DatahubTopicMap added in v0.1.3 

type DatahubTopicMap map[string]DatahubTopicInput

func (DatahubTopicMap) ElementType added in v0.1.3 

func (DatahubTopicMap) ElementType() reflect.Type

func (DatahubTopicMap) ToDatahubTopicMapOutput added in v0.1.3 

func (i DatahubTopicMap) ToDatahubTopicMapOutput() DatahubTopicMapOutput

func (DatahubTopicMap) ToDatahubTopicMapOutputWithContext added in v0.1.3 

func (i DatahubTopicMap) ToDatahubTopicMapOutputWithContext(ctx context.Context) DatahubTopicMapOutput

type DatahubTopicMapInput added in v0.1.3 

type DatahubTopicMapInput interface {
	pulumi.Input

	ToDatahubTopicMapOutput() DatahubTopicMapOutput
	ToDatahubTopicMapOutputWithContext(context.Context) DatahubTopicMapOutput
}

DatahubTopicMapInput is an input type that accepts DatahubTopicMap and DatahubTopicMapOutput values. You can construct a concrete instance of `DatahubTopicMapInput` via: 

DatahubTopicMap{ "key": DatahubTopicArgs{...} }

type DatahubTopicMapOutput added in v0.1.3 

type DatahubTopicMapOutput struct{ *pulumi.OutputState }

func (DatahubTopicMapOutput) ElementType added in v0.1.3 

func (DatahubTopicMapOutput) ElementType() reflect.Type

func (DatahubTopicMapOutput) MapIndex added in v0.1.3 

func (o DatahubTopicMapOutput) MapIndex(k pulumi.StringInput) DatahubTopicOutput

func (DatahubTopicMapOutput) ToDatahubTopicMapOutput added in v0.1.3 

func (o DatahubTopicMapOutput) ToDatahubTopicMapOutput() DatahubTopicMapOutput

func (DatahubTopicMapOutput) ToDatahubTopicMapOutputWithContext added in v0.1.3 

func (o DatahubTopicMapOutput) ToDatahubTopicMapOutputWithContext(ctx context.Context) DatahubTopicMapOutput

type DatahubTopicOutput added in v0.1.3 

type DatahubTopicOutput struct{ *pulumi.OutputState }

func (DatahubTopicOutput) ElementType added in v0.1.3 

func (DatahubTopicOutput) ElementType() reflect.Type

func (DatahubTopicOutput) Name added in v0.1.3 

func (o DatahubTopicOutput) Name() pulumi.StringOutput

Name, start with appid, which is a string of no more than 128 characters, must start with a letter, and the rest can contain letters, numbers, and dashes (-).

func (DatahubTopicOutput) Note added in v0.1.3 

func (o DatahubTopicOutput) Note() pulumi.StringPtrOutput

Subject note, which is a string of no more than 64 characters, must start with a letter, and the rest can contain letters, numbers and dashes (-).

func (DatahubTopicOutput) PartitionNum added in v0.1.3 

func (o DatahubTopicOutput) PartitionNum() pulumi.IntOutput

Number of Partitions, greater than 0.

func (DatahubTopicOutput) RetentionMs added in v0.1.3 

func (o DatahubTopicOutput) RetentionMs() pulumi.IntOutput

Message retention time, in ms, the current minimum value is 60000 ms.

func (DatahubTopicOutput) Tags added in v0.1.3 

func (o DatahubTopicOutput) Tags() pulumi.MapOutput

Tags of dataHub topic.

func (DatahubTopicOutput) ToDatahubTopicOutput added in v0.1.3 

func (o DatahubTopicOutput) ToDatahubTopicOutput() DatahubTopicOutput

func (DatahubTopicOutput) ToDatahubTopicOutputWithContext added in v0.1.3 

func (o DatahubTopicOutput) ToDatahubTopicOutputWithContext(ctx context.Context) DatahubTopicOutput

type DatahubTopicState added in v0.1.3 

type DatahubTopicState struct {
	// Name, start with appid, which is a string of no more than 128 characters, must start with a letter, and the rest can contain letters, numbers, and dashes (-).
	Name pulumi.StringPtrInput
	// Subject note, which is a string of no more than 64 characters, must start with a letter, and the rest can contain letters, numbers and dashes (-).
	Note pulumi.StringPtrInput
	// Number of Partitions, greater than 0.
	PartitionNum pulumi.IntPtrInput
	// Message retention time, in ms, the current minimum value is 60000 ms.
	RetentionMs pulumi.IntPtrInput
	// Tags of dataHub topic.
	Tags pulumi.MapInput
}

func (DatahubTopicState) ElementType added in v0.1.3 

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

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(1024),
			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"`
	// Description of instance type. `profession`: 1, `standard`:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	InstanceType pulumi.IntOutput `pulumi:"instanceType"`
	// 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"`
	// Bandwidth of the public network.
	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"`
	// Specifications type of instance. Allowed values are `standard`, `profession`. Default is `profession`.
	SpecificationsType pulumi.StringPtrOutput `pulumi:"specificationsType"`
	// Subnet id, it will be basic network if not set.
	SubnetId pulumi.StringPtrOutput `pulumi:"subnetId"`
	// Tag set of instance.
	TagSet pulumi.MapOutput `pulumi:"tagSet"`
	// It has been deprecated from version 1.78.5, because it do not support change. Use `tagSet` instead. Tags of instance. Partition size, the professional version does not need tag.
	//
	// Deprecated: It has been deprecated from version 1.78.5, because it do not support change. Use `tag_set` instead.
	Tags InstanceTagArrayOutput `pulumi:"tags"`
	// Vip of instance.
	Vip pulumi.StringOutput `pulumi:"vip"`
	// Vpc id, it will be basic network if not set.
	VpcId pulumi.StringPtrOutput `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 prepaid 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),
			SpecificationsType: pulumi.String("profession"),
			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
	// Description of instance type. `profession`: 1, `standard`:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	InstanceType pulumi.IntPtrInput
	// 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
	// Bandwidth of the public network.
	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
	// Specifications type of instance. Allowed values are `standard`, `profession`. Default is `profession`.
	SpecificationsType pulumi.StringPtrInput
	// Subnet id, it will be basic network if not set.
	SubnetId pulumi.StringPtrInput
	// Tag set of instance.
	TagSet pulumi.MapInput
	// It has been deprecated from version 1.78.5, because it do not support change. Use `tagSet` instead. Tags of instance. Partition size, the professional version does not need tag.
	//
	// Deprecated: It has been deprecated from version 1.78.5, because it do not support change. Use `tag_set` instead.
	Tags InstanceTagArrayInput
	// Vpc id, it will be basic network if not set.
	VpcId pulumi.StringPtrInput
	// 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) InstanceType added in v0.1.3 

func (o InstanceOutput) InstanceType() pulumi.IntOutput

Description of instance type. `profession`: 1, `standard`: 1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).

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

Bandwidth of the public network.

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) SpecificationsType added in v0.1.3 

func (o InstanceOutput) SpecificationsType() pulumi.StringPtrOutput

Specifications type of instance. Allowed values are `standard`, `profession`. Default is `profession`.

func (InstanceOutput) SubnetId 

func (o InstanceOutput) SubnetId() pulumi.StringPtrOutput

Subnet id, it will be basic network if not set.

func (InstanceOutput) TagSet added in v0.1.3 

func (o InstanceOutput) TagSet() pulumi.MapOutput

Tag set of instance.

func (InstanceOutput) Tags deprecated 

func (o InstanceOutput) Tags() InstanceTagArrayOutput

It has been deprecated from version 1.78.5, because it do not support change. Use `tagSet` instead. Tags of instance. Partition size, the professional version does not need tag.

Deprecated: It has been deprecated from version 1.78.5, because it do not support change. Use `tag_set` instead.

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.StringPtrOutput

Vpc id, it will be basic network if not set.

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
	// Description of instance type. `profession`: 1, `standard`:  1(general), 2(standard), 3(advanced), 4(capacity), 5(specialized-1), 6(specialized-2), 7(specialized-3), 8(specialized-4), 9(exclusive).
	InstanceType pulumi.IntPtrInput
	// 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
	// Bandwidth of the public network.
	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
	// Specifications type of instance. Allowed values are `standard`, `profession`. Default is `profession`.
	SpecificationsType pulumi.StringPtrInput
	// Subnet id, it will be basic network if not set.
	SubnetId pulumi.StringPtrInput
	// Tag set of instance.
	TagSet pulumi.MapInput
	// It has been deprecated from version 1.78.5, because it do not support change. Use `tagSet` instead. Tags of instance. Partition size, the professional version does not need tag.
	//
	// Deprecated: It has been deprecated from version 1.78.5, because it do not support change. Use `tag_set` instead.
	Tags InstanceTagArrayInput
	// Vip of instance.
	Vip pulumi.StringPtrInput
	// Vpc id, it will be basic network if not set.
	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. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	MaxMessageBytes pulumi.IntOutput `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. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	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.IntOutput

Max message bytes. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).

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. min: 1024 Byte(1KB), max: 8388608 Byte(8MB).
	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.