ckafka

package
v0.0.0-...-9ab2e28 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Acl 

type Acl struct {
	pulumi.CustomResourceState

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

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 `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates
	// the topic name; if `resource_type` 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 `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates the topic name; if `resource_type` 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 `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates
	// the topic name; if `resource_type` 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 AclsAclList 

type AclsAclList struct {
	Host           string `pulumi:"host"`
	OperationType  string `pulumi:"operationType"`
	PermissionType string `pulumi:"permissionType"`
	Principal      string `pulumi:"principal"`
	ResourceName   string `pulumi:"resourceName"`
	ResourceType   string `pulumi:"resourceType"`
}

type AclsAclListArgs 

type AclsAclListArgs struct {
	Host           pulumi.StringInput `pulumi:"host"`
	OperationType  pulumi.StringInput `pulumi:"operationType"`
	PermissionType pulumi.StringInput `pulumi:"permissionType"`
	Principal      pulumi.StringInput `pulumi:"principal"`
	ResourceName   pulumi.StringInput `pulumi:"resourceName"`
	ResourceType   pulumi.StringInput `pulumi:"resourceType"`
}

func (AclsAclListArgs) ElementType 

func (AclsAclListArgs) ElementType() reflect.Type

func (AclsAclListArgs) ToAclsAclListOutput 

func (i AclsAclListArgs) ToAclsAclListOutput() AclsAclListOutput

func (AclsAclListArgs) ToAclsAclListOutputWithContext 

func (i AclsAclListArgs) ToAclsAclListOutputWithContext(ctx context.Context) AclsAclListOutput

type AclsAclListArray 

type AclsAclListArray []AclsAclListInput

func (AclsAclListArray) ElementType 

func (AclsAclListArray) ElementType() reflect.Type

func (AclsAclListArray) ToAclsAclListArrayOutput 

func (i AclsAclListArray) ToAclsAclListArrayOutput() AclsAclListArrayOutput

func (AclsAclListArray) ToAclsAclListArrayOutputWithContext 

func (i AclsAclListArray) ToAclsAclListArrayOutputWithContext(ctx context.Context) AclsAclListArrayOutput

type AclsAclListArrayInput 

type AclsAclListArrayInput interface {
	pulumi.Input

	ToAclsAclListArrayOutput() AclsAclListArrayOutput
	ToAclsAclListArrayOutputWithContext(context.Context) AclsAclListArrayOutput
}

AclsAclListArrayInput is an input type that accepts AclsAclListArray and AclsAclListArrayOutput values. You can construct a concrete instance of `AclsAclListArrayInput` via: 

AclsAclListArray{ AclsAclListArgs{...} }

type AclsAclListArrayOutput 

type AclsAclListArrayOutput struct{ *pulumi.OutputState }

func (AclsAclListArrayOutput) ElementType 

func (AclsAclListArrayOutput) ElementType() reflect.Type

func (AclsAclListArrayOutput) Index 

func (o AclsAclListArrayOutput) Index(i pulumi.IntInput) AclsAclListOutput

func (AclsAclListArrayOutput) ToAclsAclListArrayOutput 

func (o AclsAclListArrayOutput) ToAclsAclListArrayOutput() AclsAclListArrayOutput

func (AclsAclListArrayOutput) ToAclsAclListArrayOutputWithContext 

func (o AclsAclListArrayOutput) ToAclsAclListArrayOutputWithContext(ctx context.Context) AclsAclListArrayOutput

type AclsAclListInput 

type AclsAclListInput interface {
	pulumi.Input

	ToAclsAclListOutput() AclsAclListOutput
	ToAclsAclListOutputWithContext(context.Context) AclsAclListOutput
}

AclsAclListInput is an input type that accepts AclsAclListArgs and AclsAclListOutput values. You can construct a concrete instance of `AclsAclListInput` via: 

AclsAclListArgs{...}

type AclsAclListOutput 

type AclsAclListOutput struct{ *pulumi.OutputState }

func (AclsAclListOutput) ElementType 

func (AclsAclListOutput) ElementType() reflect.Type

func (AclsAclListOutput) Host 

func (o AclsAclListOutput) Host() pulumi.StringOutput

func (AclsAclListOutput) OperationType 

func (o AclsAclListOutput) OperationType() pulumi.StringOutput

func (AclsAclListOutput) PermissionType 

func (o AclsAclListOutput) PermissionType() pulumi.StringOutput

func (AclsAclListOutput) Principal 

func (o AclsAclListOutput) Principal() pulumi.StringOutput

func (AclsAclListOutput) ResourceName 

func (o AclsAclListOutput) ResourceName() pulumi.StringOutput

func (AclsAclListOutput) ResourceType 

func (o AclsAclListOutput) ResourceType() pulumi.StringOutput

func (AclsAclListOutput) ToAclsAclListOutput 

func (o AclsAclListOutput) ToAclsAclListOutput() AclsAclListOutput

func (AclsAclListOutput) ToAclsAclListOutputWithContext 

func (o AclsAclListOutput) ToAclsAclListOutputWithContext(ctx context.Context) AclsAclListOutput

type AclsArgs 

type AclsArgs struct {
	Host             *string `pulumi:"host"`
	InstanceId       string  `pulumi:"instanceId"`
	ResourceName     string  `pulumi:"resourceName"`
	ResourceType     string  `pulumi:"resourceType"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking Acls.

type AclsOutputArgs 

type AclsOutputArgs struct {
	Host             pulumi.StringPtrInput `pulumi:"host"`
	InstanceId       pulumi.StringInput    `pulumi:"instanceId"`
	ResourceName     pulumi.StringInput    `pulumi:"resourceName"`
	ResourceType     pulumi.StringInput    `pulumi:"resourceType"`
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking Acls.

func (AclsOutputArgs) ElementType 

func (AclsOutputArgs) ElementType() reflect.Type

type AclsResult 

type AclsResult struct {
	AclLists []AclsAclList `pulumi:"aclLists"`
	Host     *string       `pulumi:"host"`
	// The provider-assigned unique ID for this managed resource.
	Id               string  `pulumi:"id"`
	InstanceId       string  `pulumi:"instanceId"`
	ResourceName     string  `pulumi:"resourceName"`
	ResourceType     string  `pulumi:"resourceType"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
}

A collection of values returned by Acls.

func Acls 

func Acls(ctx *pulumi.Context, args *AclsArgs, opts ...pulumi.InvokeOption) (*AclsResult, error)

type AclsResultOutput 

type AclsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by Acls.

func AclsOutput 

func AclsOutput(ctx *pulumi.Context, args AclsOutputArgs, opts ...pulumi.InvokeOption) AclsResultOutput

func (AclsResultOutput) AclLists 

func (o AclsResultOutput) AclLists() AclsAclListArrayOutput

func (AclsResultOutput) ElementType 

func (AclsResultOutput) ElementType() reflect.Type

func (AclsResultOutput) Host 

func (o AclsResultOutput) Host() pulumi.StringPtrOutput

func (AclsResultOutput) Id 

func (o AclsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (AclsResultOutput) InstanceId 

func (o AclsResultOutput) InstanceId() pulumi.StringOutput

func (AclsResultOutput) ResourceName 

func (o AclsResultOutput) ResourceName() pulumi.StringOutput

func (AclsResultOutput) ResourceType 

func (o AclsResultOutput) ResourceType() pulumi.StringOutput

func (AclsResultOutput) ResultOutputFile 

func (o AclsResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (AclsResultOutput) ToAclsResultOutput 

func (o AclsResultOutput) ToAclsResultOutput() AclsResultOutput

func (AclsResultOutput) ToAclsResultOutputWithContext 

func (o AclsResultOutput) ToAclsResultOutputWithContext(ctx context.Context) AclsResultOutput

type Instance 

type Instance struct {
	pulumi.CustomResourceState

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

func GetInstance 

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

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

func NewInstance 

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

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

func (*Instance) ElementType 

func (*Instance) ElementType() reflect.Type

func (*Instance) ToInstanceOutput 

func (i *Instance) ToInstanceOutput() InstanceOutput

func (*Instance) ToInstanceOutputWithContext 

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

type InstanceArgs 

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

type InstanceConfigArgs 

type InstanceConfigArgs struct {
	AutoCreateTopicEnable    pulumi.BoolInput `pulumi:"autoCreateTopicEnable"`
	DefaultNumPartitions     pulumi.IntInput  `pulumi:"defaultNumPartitions"`
	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

func (InstanceConfigOutput) DefaultNumPartitions 

func (o InstanceConfigOutput) DefaultNumPartitions() pulumi.IntOutput

func (InstanceConfigOutput) DefaultReplicationFactor 

func (o InstanceConfigOutput) DefaultReplicationFactor() pulumi.IntOutput

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

func (InstanceConfigPtrOutput) DefaultNumPartitions 

func (o InstanceConfigPtrOutput) DefaultNumPartitions() pulumi.IntPtrOutput

func (InstanceConfigPtrOutput) DefaultReplicationFactor 

func (o InstanceConfigPtrOutput) DefaultReplicationFactor() pulumi.IntPtrOutput

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 {
	BottomRetention       *int `pulumi:"bottomRetention"`
	DiskQuotaPercentage   *int `pulumi:"diskQuotaPercentage"`
	Enable                *int `pulumi:"enable"`
	StepForwardPercentage *int `pulumi:"stepForwardPercentage"`
}

type InstanceDynamicRetentionConfigArgs 

type InstanceDynamicRetentionConfigArgs struct {
	BottomRetention       pulumi.IntPtrInput `pulumi:"bottomRetention"`
	DiskQuotaPercentage   pulumi.IntPtrInput `pulumi:"diskQuotaPercentage"`
	Enable                pulumi.IntPtrInput `pulumi:"enable"`
	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

func (InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage 

func (o InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage() pulumi.IntPtrOutput

func (InstanceDynamicRetentionConfigOutput) ElementType 

func (InstanceDynamicRetentionConfigOutput) ElementType() reflect.Type

func (InstanceDynamicRetentionConfigOutput) Enable 

func (o InstanceDynamicRetentionConfigOutput) Enable() pulumi.IntPtrOutput

func (InstanceDynamicRetentionConfigOutput) StepForwardPercentage 

func (o InstanceDynamicRetentionConfigOutput) StepForwardPercentage() pulumi.IntPtrOutput

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

func (InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage 

func (o InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage() pulumi.IntPtrOutput

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

func (InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage 

func (o InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage() pulumi.IntPtrOutput

func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput 

func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput

func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext 

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

type InstanceInput 

type InstanceInput interface {
	pulumi.Input

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

type InstanceMap 

type InstanceMap map[string]InstanceInput

func (InstanceMap) ElementType 

func (InstanceMap) ElementType() reflect.Type

func (InstanceMap) ToInstanceMapOutput 

func (i InstanceMap) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMap) ToInstanceMapOutputWithContext 

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

type InstanceMapInput 

type InstanceMapInput interface {
	pulumi.Input

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

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

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

type InstanceMapOutput 

type InstanceMapOutput struct{ *pulumi.OutputState }

func (InstanceMapOutput) ElementType 

func (InstanceMapOutput) ElementType() reflect.Type

func (InstanceMapOutput) MapIndex 

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

func (InstanceMapOutput) ToInstanceMapOutput 

func (o InstanceMapOutput) ToInstanceMapOutput() InstanceMapOutput

func (InstanceMapOutput) ToInstanceMapOutputWithContext 

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

type InstanceOutput 

type InstanceOutput struct{ *pulumi.OutputState }

func (InstanceOutput) BandWidth 

func (o InstanceOutput) BandWidth() pulumi.IntOutput

Instance bandwidth in MBps.

func (InstanceOutput) Config 

func (o InstanceOutput) Config() InstanceConfigPtrOutput

Instance configuration.

func (InstanceOutput) DiskSize 

func (o InstanceOutput) DiskSize() pulumi.IntOutput

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

func (InstanceOutput) DiskType 

func (o InstanceOutput) DiskType() pulumi.StringOutput

Type of disk.

func (InstanceOutput) DynamicRetentionConfig 

func (o InstanceOutput) DynamicRetentionConfig() InstanceDynamicRetentionConfigOutput

Dynamic message retention policy configuration.

func (InstanceOutput) ElementType 

func (InstanceOutput) ElementType() reflect.Type

func (InstanceOutput) InstanceName 

func (o InstanceOutput) InstanceName() pulumi.StringOutput

Instance name.

func (InstanceOutput) KafkaVersion 

func (o InstanceOutput) KafkaVersion() pulumi.StringOutput

Kafka version (0.10.2/1.1.1/2.4.1).

func (InstanceOutput) MsgRetentionTime 

func (o InstanceOutput) MsgRetentionTime() pulumi.IntOutput

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

func (InstanceOutput) MultiZoneFlag 

func (o InstanceOutput) MultiZoneFlag() pulumi.BoolPtrOutput

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

func (InstanceOutput) Partition 

func (o InstanceOutput) Partition() pulumi.IntOutput

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

func (InstanceOutput) Period 

func (o InstanceOutput) Period() pulumi.IntPtrOutput

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

func (InstanceOutput) PublicNetwork 

func (o InstanceOutput) PublicNetwork() pulumi.IntOutput

Timestamp.

func (InstanceOutput) RebalanceTime 

func (o InstanceOutput) RebalanceTime() pulumi.IntPtrOutput

Modification of the rebalancing time after upgrade.

func (InstanceOutput) RenewFlag 

func (o InstanceOutput) RenewFlag() pulumi.IntOutput

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

func (InstanceOutput) SubnetId 

func (o InstanceOutput) SubnetId() pulumi.StringOutput

Subnet id.

func (InstanceOutput) Tags 

func (o InstanceOutput) Tags() InstanceTagArrayOutput

Partition size, the professional version does not need tag.

func (InstanceOutput) ToInstanceOutput 

func (o InstanceOutput) ToInstanceOutput() InstanceOutput

func (InstanceOutput) ToInstanceOutputWithContext 

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

func (InstanceOutput) VpcId 

func (o InstanceOutput) VpcId() pulumi.StringOutput

Vpc id.

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 `multi_zone_flag`.

type InstanceState 

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

func (InstanceState) ElementType 

func (InstanceState) ElementType() reflect.Type

type InstanceTag 

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

type InstanceTagArgs 

type InstanceTagArgs struct {
	Key   pulumi.StringInput `pulumi:"key"`
	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

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

type Topic 

type Topic struct {
	pulumi.CustomResourceState

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

func GetTopic 

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

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

func NewTopic 

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

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

func (*Topic) ElementType 

func (*Topic) ElementType() reflect.Type

func (*Topic) ToTopicOutput 

func (i *Topic) ToTopicOutput() TopicOutput

func (*Topic) ToTopicOutputWithContext 

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

type TopicArgs 

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

The set of arguments for constructing a Topic resource.

func (TopicArgs) ElementType 

func (TopicArgs) ElementType() reflect.Type

type TopicArray 

type TopicArray []TopicInput

func (TopicArray) ElementType 

func (TopicArray) ElementType() reflect.Type

func (TopicArray) ToTopicArrayOutput 

func (i TopicArray) ToTopicArrayOutput() TopicArrayOutput

func (TopicArray) ToTopicArrayOutputWithContext 

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

type TopicArrayInput 

type TopicArrayInput interface {
	pulumi.Input

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

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

TopicArray{ TopicArgs{...} }

type TopicArrayOutput 

type TopicArrayOutput struct{ *pulumi.OutputState }

func (TopicArrayOutput) ElementType 

func (TopicArrayOutput) ElementType() reflect.Type

func (TopicArrayOutput) Index 

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

func (TopicArrayOutput) ToTopicArrayOutput 

func (o TopicArrayOutput) ToTopicArrayOutput() TopicArrayOutput

func (TopicArrayOutput) ToTopicArrayOutputWithContext 

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

type TopicInput 

type TopicInput interface {
	pulumi.Input

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

type TopicMap 

type TopicMap map[string]TopicInput

func (TopicMap) ElementType 

func (TopicMap) ElementType() reflect.Type

func (TopicMap) ToTopicMapOutput 

func (i TopicMap) ToTopicMapOutput() TopicMapOutput

func (TopicMap) ToTopicMapOutputWithContext 

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

type TopicMapInput 

type TopicMapInput interface {
	pulumi.Input

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

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

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

type TopicMapOutput 

type TopicMapOutput struct{ *pulumi.OutputState }

func (TopicMapOutput) ElementType 

func (TopicMapOutput) ElementType() reflect.Type

func (TopicMapOutput) MapIndex 

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

func (TopicMapOutput) ToTopicMapOutput 

func (o TopicMapOutput) ToTopicMapOutput() TopicMapOutput

func (TopicMapOutput) ToTopicMapOutputWithContext 

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

type TopicOutput 

type TopicOutput struct{ *pulumi.OutputState }

func (TopicOutput) CleanUpPolicy 

func (o TopicOutput) CleanUpPolicy() pulumi.StringPtrOutput

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

func (TopicOutput) CreateTime 

func (o TopicOutput) CreateTime() pulumi.StringOutput

Create time of the CKafka topic.

func (TopicOutput) ElementType 

func (TopicOutput) ElementType() reflect.Type

func (TopicOutput) EnableWhiteList 

func (o TopicOutput) EnableWhiteList() pulumi.BoolPtrOutput

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

func (TopicOutput) ForwardCosBucket 

func (o TopicOutput) ForwardCosBucket() pulumi.StringOutput

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

func (TopicOutput) ForwardInterval 

func (o TopicOutput) ForwardInterval() pulumi.IntOutput

Periodic frequency of data backup to cos.

func (TopicOutput) ForwardStatus 

func (o TopicOutput) ForwardStatus() pulumi.IntOutput

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

func (TopicOutput) InstanceId 

func (o TopicOutput) InstanceId() pulumi.StringOutput

Ckafka instance ID.

func (TopicOutput) IpWhiteLists 

func (o TopicOutput) IpWhiteLists() pulumi.StringArrayOutput

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

func (TopicOutput) MaxMessageBytes 

func (o TopicOutput) MaxMessageBytes() pulumi.IntPtrOutput

Max message bytes.

func (TopicOutput) MessageStorageLocation 

func (o TopicOutput) MessageStorageLocation() pulumi.StringOutput

Message storage location.

func (TopicOutput) Note 

func (o TopicOutput) Note() pulumi.StringPtrOutput

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

func (TopicOutput) PartitionNum 

func (o TopicOutput) PartitionNum() pulumi.IntOutput

The number of partition.

func (TopicOutput) ReplicaNum 

func (o TopicOutput) ReplicaNum() pulumi.IntOutput

The number of replica.

func (TopicOutput) Retention 

func (o TopicOutput) Retention() pulumi.IntPtrOutput

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

func (TopicOutput) Segment 

func (o TopicOutput) Segment() pulumi.IntPtrOutput

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

func (TopicOutput) SegmentBytes 

func (o TopicOutput) SegmentBytes() pulumi.IntOutput

Number of bytes rolled by shard.

func (TopicOutput) SyncReplicaMinNum 

func (o TopicOutput) SyncReplicaMinNum() pulumi.IntPtrOutput

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

func (TopicOutput) ToTopicOutput 

func (o TopicOutput) ToTopicOutput() TopicOutput

func (TopicOutput) ToTopicOutputWithContext 

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

func (TopicOutput) TopicName 

func (o TopicOutput) TopicName() pulumi.StringOutput

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

func (TopicOutput) UncleanLeaderElectionEnable 

func (o TopicOutput) UncleanLeaderElectionEnable() pulumi.BoolPtrOutput

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

type TopicState 

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

func (TopicState) ElementType 

func (TopicState) ElementType() reflect.Type

type TopicsArgs 

type TopicsArgs struct {
	InstanceId       string  `pulumi:"instanceId"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
	TopicName        *string `pulumi:"topicName"`
}

A collection of arguments for invoking Topics.

type TopicsInstanceList 

type TopicsInstanceList struct {
	CleanUpPolicy               string `pulumi:"cleanUpPolicy"`
	CreateTime                  string `pulumi:"createTime"`
	EnableWhiteList             bool   `pulumi:"enableWhiteList"`
	ForwardCosBucket            string `pulumi:"forwardCosBucket"`
	ForwardInterval             int    `pulumi:"forwardInterval"`
	ForwardStatus               int    `pulumi:"forwardStatus"`
	IpWhiteListCount            int    `pulumi:"ipWhiteListCount"`
	MaxMessageBytes             int    `pulumi:"maxMessageBytes"`
	Note                        string `pulumi:"note"`
	PartitionNum                int    `pulumi:"partitionNum"`
	ReplicaNum                  int    `pulumi:"replicaNum"`
	Retention                   int    `pulumi:"retention"`
	Segment                     int    `pulumi:"segment"`
	SegmentBytes                int    `pulumi:"segmentBytes"`
	SyncReplicaMinNum           int    `pulumi:"syncReplicaMinNum"`
	TopicId                     string `pulumi:"topicId"`
	TopicName                   string `pulumi:"topicName"`
	UncleanLeaderElectionEnable bool   `pulumi:"uncleanLeaderElectionEnable"`
}

type TopicsInstanceListArgs 

type TopicsInstanceListArgs struct {
	CleanUpPolicy               pulumi.StringInput `pulumi:"cleanUpPolicy"`
	CreateTime                  pulumi.StringInput `pulumi:"createTime"`
	EnableWhiteList             pulumi.BoolInput   `pulumi:"enableWhiteList"`
	ForwardCosBucket            pulumi.StringInput `pulumi:"forwardCosBucket"`
	ForwardInterval             pulumi.IntInput    `pulumi:"forwardInterval"`
	ForwardStatus               pulumi.IntInput    `pulumi:"forwardStatus"`
	IpWhiteListCount            pulumi.IntInput    `pulumi:"ipWhiteListCount"`
	MaxMessageBytes             pulumi.IntInput    `pulumi:"maxMessageBytes"`
	Note                        pulumi.StringInput `pulumi:"note"`
	PartitionNum                pulumi.IntInput    `pulumi:"partitionNum"`
	ReplicaNum                  pulumi.IntInput    `pulumi:"replicaNum"`
	Retention                   pulumi.IntInput    `pulumi:"retention"`
	Segment                     pulumi.IntInput    `pulumi:"segment"`
	SegmentBytes                pulumi.IntInput    `pulumi:"segmentBytes"`
	SyncReplicaMinNum           pulumi.IntInput    `pulumi:"syncReplicaMinNum"`
	TopicId                     pulumi.StringInput `pulumi:"topicId"`
	TopicName                   pulumi.StringInput `pulumi:"topicName"`
	UncleanLeaderElectionEnable pulumi.BoolInput   `pulumi:"uncleanLeaderElectionEnable"`
}

func (TopicsInstanceListArgs) ElementType 

func (TopicsInstanceListArgs) ElementType() reflect.Type

func (TopicsInstanceListArgs) ToTopicsInstanceListOutput 

func (i TopicsInstanceListArgs) ToTopicsInstanceListOutput() TopicsInstanceListOutput

func (TopicsInstanceListArgs) ToTopicsInstanceListOutputWithContext 

func (i TopicsInstanceListArgs) ToTopicsInstanceListOutputWithContext(ctx context.Context) TopicsInstanceListOutput

type TopicsInstanceListArray 

type TopicsInstanceListArray []TopicsInstanceListInput

func (TopicsInstanceListArray) ElementType 

func (TopicsInstanceListArray) ElementType() reflect.Type

func (TopicsInstanceListArray) ToTopicsInstanceListArrayOutput 

func (i TopicsInstanceListArray) ToTopicsInstanceListArrayOutput() TopicsInstanceListArrayOutput

func (TopicsInstanceListArray) ToTopicsInstanceListArrayOutputWithContext 

func (i TopicsInstanceListArray) ToTopicsInstanceListArrayOutputWithContext(ctx context.Context) TopicsInstanceListArrayOutput

type TopicsInstanceListArrayInput 

type TopicsInstanceListArrayInput interface {
	pulumi.Input

	ToTopicsInstanceListArrayOutput() TopicsInstanceListArrayOutput
	ToTopicsInstanceListArrayOutputWithContext(context.Context) TopicsInstanceListArrayOutput
}

TopicsInstanceListArrayInput is an input type that accepts TopicsInstanceListArray and TopicsInstanceListArrayOutput values. You can construct a concrete instance of `TopicsInstanceListArrayInput` via: 

TopicsInstanceListArray{ TopicsInstanceListArgs{...} }

type TopicsInstanceListArrayOutput 

type TopicsInstanceListArrayOutput struct{ *pulumi.OutputState }

func (TopicsInstanceListArrayOutput) ElementType 

func (TopicsInstanceListArrayOutput) ElementType() reflect.Type

func (TopicsInstanceListArrayOutput) Index 

func (o TopicsInstanceListArrayOutput) Index(i pulumi.IntInput) TopicsInstanceListOutput

func (TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutput 

func (o TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutput() TopicsInstanceListArrayOutput

func (TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutputWithContext 

func (o TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutputWithContext(ctx context.Context) TopicsInstanceListArrayOutput

type TopicsInstanceListInput 

type TopicsInstanceListInput interface {
	pulumi.Input

	ToTopicsInstanceListOutput() TopicsInstanceListOutput
	ToTopicsInstanceListOutputWithContext(context.Context) TopicsInstanceListOutput
}

TopicsInstanceListInput is an input type that accepts TopicsInstanceListArgs and TopicsInstanceListOutput values. You can construct a concrete instance of `TopicsInstanceListInput` via: 

TopicsInstanceListArgs{...}

type TopicsInstanceListOutput 

type TopicsInstanceListOutput struct{ *pulumi.OutputState }

func (TopicsInstanceListOutput) CleanUpPolicy 

func (o TopicsInstanceListOutput) CleanUpPolicy() pulumi.StringOutput

func (TopicsInstanceListOutput) CreateTime 

func (o TopicsInstanceListOutput) CreateTime() pulumi.StringOutput

func (TopicsInstanceListOutput) ElementType 

func (TopicsInstanceListOutput) ElementType() reflect.Type

func (TopicsInstanceListOutput) EnableWhiteList 

func (o TopicsInstanceListOutput) EnableWhiteList() pulumi.BoolOutput

func (TopicsInstanceListOutput) ForwardCosBucket 

func (o TopicsInstanceListOutput) ForwardCosBucket() pulumi.StringOutput

func (TopicsInstanceListOutput) ForwardInterval 

func (o TopicsInstanceListOutput) ForwardInterval() pulumi.IntOutput

func (TopicsInstanceListOutput) ForwardStatus 

func (o TopicsInstanceListOutput) ForwardStatus() pulumi.IntOutput

func (TopicsInstanceListOutput) IpWhiteListCount 

func (o TopicsInstanceListOutput) IpWhiteListCount() pulumi.IntOutput

func (TopicsInstanceListOutput) MaxMessageBytes 

func (o TopicsInstanceListOutput) MaxMessageBytes() pulumi.IntOutput

func (TopicsInstanceListOutput) Note 

func (o TopicsInstanceListOutput) Note() pulumi.StringOutput

func (TopicsInstanceListOutput) PartitionNum 

func (o TopicsInstanceListOutput) PartitionNum() pulumi.IntOutput

func (TopicsInstanceListOutput) ReplicaNum 

func (o TopicsInstanceListOutput) ReplicaNum() pulumi.IntOutput

func (TopicsInstanceListOutput) Retention 

func (o TopicsInstanceListOutput) Retention() pulumi.IntOutput

func (TopicsInstanceListOutput) Segment 

func (o TopicsInstanceListOutput) Segment() pulumi.IntOutput

func (TopicsInstanceListOutput) SegmentBytes 

func (o TopicsInstanceListOutput) SegmentBytes() pulumi.IntOutput

func (TopicsInstanceListOutput) SyncReplicaMinNum 

func (o TopicsInstanceListOutput) SyncReplicaMinNum() pulumi.IntOutput

func (TopicsInstanceListOutput) ToTopicsInstanceListOutput 

func (o TopicsInstanceListOutput) ToTopicsInstanceListOutput() TopicsInstanceListOutput

func (TopicsInstanceListOutput) ToTopicsInstanceListOutputWithContext 

func (o TopicsInstanceListOutput) ToTopicsInstanceListOutputWithContext(ctx context.Context) TopicsInstanceListOutput

func (TopicsInstanceListOutput) TopicId 

func (o TopicsInstanceListOutput) TopicId() pulumi.StringOutput

func (TopicsInstanceListOutput) TopicName 

func (o TopicsInstanceListOutput) TopicName() pulumi.StringOutput

func (TopicsInstanceListOutput) UncleanLeaderElectionEnable 

func (o TopicsInstanceListOutput) UncleanLeaderElectionEnable() pulumi.BoolOutput

type TopicsOutputArgs 

type TopicsOutputArgs struct {
	InstanceId       pulumi.StringInput    `pulumi:"instanceId"`
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
	TopicName        pulumi.StringPtrInput `pulumi:"topicName"`
}

A collection of arguments for invoking Topics.

func (TopicsOutputArgs) ElementType 

func (TopicsOutputArgs) ElementType() reflect.Type

type TopicsResult 

type TopicsResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id               string               `pulumi:"id"`
	InstanceId       string               `pulumi:"instanceId"`
	InstanceLists    []TopicsInstanceList `pulumi:"instanceLists"`
	ResultOutputFile *string              `pulumi:"resultOutputFile"`
	TopicName        *string              `pulumi:"topicName"`
}

A collection of values returned by Topics.

func Topics 

func Topics(ctx *pulumi.Context, args *TopicsArgs, opts ...pulumi.InvokeOption) (*TopicsResult, error)

type TopicsResultOutput 

type TopicsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by Topics.

func TopicsOutput 

func TopicsOutput(ctx *pulumi.Context, args TopicsOutputArgs, opts ...pulumi.InvokeOption) TopicsResultOutput

func (TopicsResultOutput) ElementType 

func (TopicsResultOutput) ElementType() reflect.Type

func (TopicsResultOutput) Id 

func (o TopicsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (TopicsResultOutput) InstanceId 

func (o TopicsResultOutput) InstanceId() pulumi.StringOutput

func (TopicsResultOutput) InstanceLists 

func (o TopicsResultOutput) InstanceLists() TopicsInstanceListArrayOutput

func (TopicsResultOutput) ResultOutputFile 

func (o TopicsResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (TopicsResultOutput) ToTopicsResultOutput 

func (o TopicsResultOutput) ToTopicsResultOutput() TopicsResultOutput

func (TopicsResultOutput) ToTopicsResultOutputWithContext 

func (o TopicsResultOutput) ToTopicsResultOutputWithContext(ctx context.Context) TopicsResultOutput

func (TopicsResultOutput) TopicName 

func (o TopicsResultOutput) TopicName() pulumi.StringPtrOutput

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

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

type UsersArgs 

type UsersArgs struct {
	AccountName      *string `pulumi:"accountName"`
	InstanceId       string  `pulumi:"instanceId"`
	ResultOutputFile *string `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking Users.

type UsersOutputArgs 

type UsersOutputArgs struct {
	AccountName      pulumi.StringPtrInput `pulumi:"accountName"`
	InstanceId       pulumi.StringInput    `pulumi:"instanceId"`
	ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"`
}

A collection of arguments for invoking Users.

func (UsersOutputArgs) ElementType 

func (UsersOutputArgs) ElementType() reflect.Type

type UsersResult 

type UsersResult struct {
	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"`
	UserLists        []UsersUserList `pulumi:"userLists"`
}

A collection of values returned by Users.

func Users 

func Users(ctx *pulumi.Context, args *UsersArgs, opts ...pulumi.InvokeOption) (*UsersResult, error)

type UsersResultOutput 

type UsersResultOutput struct{ *pulumi.OutputState }

A collection of values returned by Users.

func UsersOutput 

func UsersOutput(ctx *pulumi.Context, args UsersOutputArgs, opts ...pulumi.InvokeOption) UsersResultOutput

func (UsersResultOutput) AccountName 

func (o UsersResultOutput) AccountName() pulumi.StringPtrOutput

func (UsersResultOutput) ElementType 

func (UsersResultOutput) ElementType() reflect.Type

func (UsersResultOutput) Id 

func (o UsersResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (UsersResultOutput) InstanceId 

func (o UsersResultOutput) InstanceId() pulumi.StringOutput

func (UsersResultOutput) ResultOutputFile 

func (o UsersResultOutput) ResultOutputFile() pulumi.StringPtrOutput

func (UsersResultOutput) ToUsersResultOutput 

func (o UsersResultOutput) ToUsersResultOutput() UsersResultOutput

func (UsersResultOutput) ToUsersResultOutputWithContext 

func (o UsersResultOutput) ToUsersResultOutputWithContext(ctx context.Context) UsersResultOutput

func (UsersResultOutput) UserLists 

func (o UsersResultOutput) UserLists() UsersUserListArrayOutput

type UsersUserList 

type UsersUserList struct {
	AccountName string `pulumi:"accountName"`
	CreateTime  string `pulumi:"createTime"`
	UpdateTime  string `pulumi:"updateTime"`
}

type UsersUserListArgs 

type UsersUserListArgs struct {
	AccountName pulumi.StringInput `pulumi:"accountName"`
	CreateTime  pulumi.StringInput `pulumi:"createTime"`
	UpdateTime  pulumi.StringInput `pulumi:"updateTime"`
}

func (UsersUserListArgs) ElementType 

func (UsersUserListArgs) ElementType() reflect.Type

func (UsersUserListArgs) ToUsersUserListOutput 

func (i UsersUserListArgs) ToUsersUserListOutput() UsersUserListOutput

func (UsersUserListArgs) ToUsersUserListOutputWithContext 

func (i UsersUserListArgs) ToUsersUserListOutputWithContext(ctx context.Context) UsersUserListOutput

type UsersUserListArray 

type UsersUserListArray []UsersUserListInput

func (UsersUserListArray) ElementType 

func (UsersUserListArray) ElementType() reflect.Type

func (UsersUserListArray) ToUsersUserListArrayOutput 

func (i UsersUserListArray) ToUsersUserListArrayOutput() UsersUserListArrayOutput

func (UsersUserListArray) ToUsersUserListArrayOutputWithContext 

func (i UsersUserListArray) ToUsersUserListArrayOutputWithContext(ctx context.Context) UsersUserListArrayOutput

type UsersUserListArrayInput 

type UsersUserListArrayInput interface {
	pulumi.Input

	ToUsersUserListArrayOutput() UsersUserListArrayOutput
	ToUsersUserListArrayOutputWithContext(context.Context) UsersUserListArrayOutput
}

UsersUserListArrayInput is an input type that accepts UsersUserListArray and UsersUserListArrayOutput values. You can construct a concrete instance of `UsersUserListArrayInput` via: 

UsersUserListArray{ UsersUserListArgs{...} }

type UsersUserListArrayOutput 

type UsersUserListArrayOutput struct{ *pulumi.OutputState }

func (UsersUserListArrayOutput) ElementType 

func (UsersUserListArrayOutput) ElementType() reflect.Type

func (UsersUserListArrayOutput) Index 

func (o UsersUserListArrayOutput) Index(i pulumi.IntInput) UsersUserListOutput

func (UsersUserListArrayOutput) ToUsersUserListArrayOutput 

func (o UsersUserListArrayOutput) ToUsersUserListArrayOutput() UsersUserListArrayOutput

func (UsersUserListArrayOutput) ToUsersUserListArrayOutputWithContext 

func (o UsersUserListArrayOutput) ToUsersUserListArrayOutputWithContext(ctx context.Context) UsersUserListArrayOutput

type UsersUserListInput 

type UsersUserListInput interface {
	pulumi.Input

	ToUsersUserListOutput() UsersUserListOutput
	ToUsersUserListOutputWithContext(context.Context) UsersUserListOutput
}

UsersUserListInput is an input type that accepts UsersUserListArgs and UsersUserListOutput values. You can construct a concrete instance of `UsersUserListInput` via: 

UsersUserListArgs{...}

type UsersUserListOutput 

type UsersUserListOutput struct{ *pulumi.OutputState }

func (UsersUserListOutput) AccountName 

func (o UsersUserListOutput) AccountName() pulumi.StringOutput

func (UsersUserListOutput) CreateTime 

func (o UsersUserListOutput) CreateTime() pulumi.StringOutput

func (UsersUserListOutput) ElementType 

func (UsersUserListOutput) ElementType() reflect.Type

func (UsersUserListOutput) ToUsersUserListOutput 

func (o UsersUserListOutput) ToUsersUserListOutput() UsersUserListOutput

func (UsersUserListOutput) ToUsersUserListOutputWithContext 

func (o UsersUserListOutput) ToUsersUserListOutputWithContext(ctx context.Context) UsersUserListOutput

func (UsersUserListOutput) UpdateTime 

func (o UsersUserListOutput) UpdateTime() pulumi.StringOutput

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.