Documentation ¶
Index ¶
- func PkgVersion() (semver.Version, error)
- type Acl
- type AclArgs
- type AclArray
- type AclArrayInput
- type AclArrayOutput
- type AclInput
- type AclMap
- type AclMapInput
- type AclMapOutput
- type AclOutput
- func (AclOutput) ElementType() reflect.Type
- func (o AclOutput) Host() pulumi.StringPtrOutput
- func (o AclOutput) InstanceId() pulumi.StringOutput
- func (o AclOutput) OperationType() pulumi.StringOutput
- func (o AclOutput) PermissionType() pulumi.StringPtrOutput
- func (o AclOutput) Principal() pulumi.StringPtrOutput
- func (o AclOutput) ResourceName() pulumi.StringOutput
- func (o AclOutput) ResourceType() pulumi.StringPtrOutput
- func (o AclOutput) ToAclOutput() AclOutput
- func (o AclOutput) ToAclOutputWithContext(ctx context.Context) AclOutput
- type AclState
- type GetAclsAclList
- type GetAclsAclListArgs
- type GetAclsAclListArray
- type GetAclsAclListArrayInput
- type GetAclsAclListArrayOutput
- func (GetAclsAclListArrayOutput) ElementType() reflect.Type
- func (o GetAclsAclListArrayOutput) Index(i pulumi.IntInput) GetAclsAclListOutput
- func (o GetAclsAclListArrayOutput) ToGetAclsAclListArrayOutput() GetAclsAclListArrayOutput
- func (o GetAclsAclListArrayOutput) ToGetAclsAclListArrayOutputWithContext(ctx context.Context) GetAclsAclListArrayOutput
- type GetAclsAclListInput
- type GetAclsAclListOutput
- func (GetAclsAclListOutput) ElementType() reflect.Type
- func (o GetAclsAclListOutput) Host() pulumi.StringOutput
- func (o GetAclsAclListOutput) OperationType() pulumi.StringOutput
- func (o GetAclsAclListOutput) PermissionType() pulumi.StringOutput
- func (o GetAclsAclListOutput) Principal() pulumi.StringOutput
- func (o GetAclsAclListOutput) ResourceName() pulumi.StringOutput
- func (o GetAclsAclListOutput) ResourceType() pulumi.StringOutput
- func (o GetAclsAclListOutput) ToGetAclsAclListOutput() GetAclsAclListOutput
- func (o GetAclsAclListOutput) ToGetAclsAclListOutputWithContext(ctx context.Context) GetAclsAclListOutput
- type GetAclsArgs
- type GetAclsOutputArgs
- type GetAclsResult
- type GetAclsResultOutput
- func (o GetAclsResultOutput) AclLists() GetAclsAclListArrayOutput
- func (GetAclsResultOutput) ElementType() reflect.Type
- func (o GetAclsResultOutput) Host() pulumi.StringPtrOutput
- func (o GetAclsResultOutput) Id() pulumi.StringOutput
- func (o GetAclsResultOutput) InstanceId() pulumi.StringOutput
- func (o GetAclsResultOutput) ResourceName() pulumi.StringOutput
- func (o GetAclsResultOutput) ResourceType() pulumi.StringOutput
- func (o GetAclsResultOutput) ResultOutputFile() pulumi.StringPtrOutput
- func (o GetAclsResultOutput) ToGetAclsResultOutput() GetAclsResultOutput
- func (o GetAclsResultOutput) ToGetAclsResultOutputWithContext(ctx context.Context) GetAclsResultOutput
- type GetInstancesArgs
- type GetInstancesFilter
- type GetInstancesFilterArgs
- type GetInstancesFilterArray
- type GetInstancesFilterArrayInput
- type GetInstancesFilterArrayOutput
- func (GetInstancesFilterArrayOutput) ElementType() reflect.Type
- func (o GetInstancesFilterArrayOutput) Index(i pulumi.IntInput) GetInstancesFilterOutput
- func (o GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutput() GetInstancesFilterArrayOutput
- func (o GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutputWithContext(ctx context.Context) GetInstancesFilterArrayOutput
- type GetInstancesFilterInput
- type GetInstancesFilterOutput
- func (GetInstancesFilterOutput) ElementType() reflect.Type
- func (o GetInstancesFilterOutput) Name() pulumi.StringOutput
- func (o GetInstancesFilterOutput) ToGetInstancesFilterOutput() GetInstancesFilterOutput
- func (o GetInstancesFilterOutput) ToGetInstancesFilterOutputWithContext(ctx context.Context) GetInstancesFilterOutput
- func (o GetInstancesFilterOutput) Values() pulumi.StringArrayOutput
- type GetInstancesInstanceList
- type GetInstancesInstanceListArgs
- func (GetInstancesInstanceListArgs) ElementType() reflect.Type
- func (i GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput
- func (i GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutputWithContext(ctx context.Context) GetInstancesInstanceListOutput
- type GetInstancesInstanceListArray
- func (GetInstancesInstanceListArray) ElementType() reflect.Type
- func (i GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput
- func (i GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListArrayOutput
- type GetInstancesInstanceListArrayInput
- type GetInstancesInstanceListArrayOutput
- func (GetInstancesInstanceListArrayOutput) ElementType() reflect.Type
- func (o GetInstancesInstanceListArrayOutput) Index(i pulumi.IntInput) GetInstancesInstanceListOutput
- func (o GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput
- func (o GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListArrayOutput
- type GetInstancesInstanceListInput
- type GetInstancesInstanceListOutput
- func (o GetInstancesInstanceListOutput) Bandwidth() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) CreateTime() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) Cvm() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) DiskSize() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) DiskType() pulumi.StringOutput
- func (GetInstancesInstanceListOutput) ElementType() reflect.Type
- func (o GetInstancesInstanceListOutput) ExpireTime() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) Healthy() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) HealthyMessage() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) InstanceId() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) InstanceName() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) InstanceType() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) IsInternal() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) MaxPartitionNumber() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) MaxTopicNumber() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) PartitionNumber() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) PublicNetwork() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) PublicNetworkChargeType() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) RebalanceTime() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) RenewFlag() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) Status() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) SubnetId() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) Tags() GetInstancesInstanceListTagArrayOutput
- func (o GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput
- func (o GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutputWithContext(ctx context.Context) GetInstancesInstanceListOutput
- func (o GetInstancesInstanceListOutput) TopicNum() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) Version() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) Vip() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) VipList() GetInstancesInstanceListVipListOutput
- func (o GetInstancesInstanceListOutput) VpcId() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) Vport() pulumi.StringOutput
- func (o GetInstancesInstanceListOutput) ZoneId() pulumi.IntOutput
- func (o GetInstancesInstanceListOutput) ZoneIds() pulumi.IntArrayOutput
- type GetInstancesInstanceListTag
- type GetInstancesInstanceListTagArgs
- func (GetInstancesInstanceListTagArgs) ElementType() reflect.Type
- func (i GetInstancesInstanceListTagArgs) ToGetInstancesInstanceListTagOutput() GetInstancesInstanceListTagOutput
- func (i GetInstancesInstanceListTagArgs) ToGetInstancesInstanceListTagOutputWithContext(ctx context.Context) GetInstancesInstanceListTagOutput
- type GetInstancesInstanceListTagArray
- func (GetInstancesInstanceListTagArray) ElementType() reflect.Type
- func (i GetInstancesInstanceListTagArray) ToGetInstancesInstanceListTagArrayOutput() GetInstancesInstanceListTagArrayOutput
- func (i GetInstancesInstanceListTagArray) ToGetInstancesInstanceListTagArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListTagArrayOutput
- type GetInstancesInstanceListTagArrayInput
- type GetInstancesInstanceListTagArrayOutput
- func (GetInstancesInstanceListTagArrayOutput) ElementType() reflect.Type
- func (o GetInstancesInstanceListTagArrayOutput) Index(i pulumi.IntInput) GetInstancesInstanceListTagOutput
- func (o GetInstancesInstanceListTagArrayOutput) ToGetInstancesInstanceListTagArrayOutput() GetInstancesInstanceListTagArrayOutput
- func (o GetInstancesInstanceListTagArrayOutput) ToGetInstancesInstanceListTagArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListTagArrayOutput
- type GetInstancesInstanceListTagInput
- type GetInstancesInstanceListTagOutput
- func (GetInstancesInstanceListTagOutput) ElementType() reflect.Type
- func (o GetInstancesInstanceListTagOutput) TagKey() pulumi.StringOutput
- func (o GetInstancesInstanceListTagOutput) TagValue() pulumi.StringOutput
- func (o GetInstancesInstanceListTagOutput) ToGetInstancesInstanceListTagOutput() GetInstancesInstanceListTagOutput
- func (o GetInstancesInstanceListTagOutput) ToGetInstancesInstanceListTagOutputWithContext(ctx context.Context) GetInstancesInstanceListTagOutput
- type GetInstancesInstanceListVipList
- type GetInstancesInstanceListVipListArgs
- func (GetInstancesInstanceListVipListArgs) ElementType() reflect.Type
- func (i GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput
- func (i GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutputWithContext(ctx context.Context) GetInstancesInstanceListVipListOutput
- type GetInstancesInstanceListVipListInput
- type GetInstancesInstanceListVipListOutput
- func (GetInstancesInstanceListVipListOutput) ElementType() reflect.Type
- func (o GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput
- func (o GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutputWithContext(ctx context.Context) GetInstancesInstanceListVipListOutput
- func (o GetInstancesInstanceListVipListOutput) Vip() pulumi.StringOutput
- func (o GetInstancesInstanceListVipListOutput) Vport() pulumi.StringOutput
- type GetInstancesOutputArgs
- type GetInstancesResult
- type GetInstancesResultOutput
- func (GetInstancesResultOutput) ElementType() reflect.Type
- func (o GetInstancesResultOutput) Filters() GetInstancesFilterArrayOutput
- func (o GetInstancesResultOutput) Id() pulumi.StringOutput
- func (o GetInstancesResultOutput) InstanceIds() pulumi.StringArrayOutput
- func (o GetInstancesResultOutput) InstanceLists() GetInstancesInstanceListArrayOutput
- func (o GetInstancesResultOutput) Limit() pulumi.IntPtrOutput
- func (o GetInstancesResultOutput) Offset() pulumi.IntPtrOutput
- func (o GetInstancesResultOutput) ResultOutputFile() pulumi.StringPtrOutput
- func (o GetInstancesResultOutput) SearchWord() pulumi.StringPtrOutput
- func (o GetInstancesResultOutput) Statuses() pulumi.IntArrayOutput
- func (o GetInstancesResultOutput) TagKey() pulumi.StringPtrOutput
- func (o GetInstancesResultOutput) ToGetInstancesResultOutput() GetInstancesResultOutput
- func (o GetInstancesResultOutput) ToGetInstancesResultOutputWithContext(ctx context.Context) GetInstancesResultOutput
- type GetTopicsArgs
- type GetTopicsInstanceList
- type GetTopicsInstanceListArgs
- type GetTopicsInstanceListArray
- func (GetTopicsInstanceListArray) ElementType() reflect.Type
- func (i GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput
- func (i GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutputWithContext(ctx context.Context) GetTopicsInstanceListArrayOutput
- type GetTopicsInstanceListArrayInput
- type GetTopicsInstanceListArrayOutput
- func (GetTopicsInstanceListArrayOutput) ElementType() reflect.Type
- func (o GetTopicsInstanceListArrayOutput) Index(i pulumi.IntInput) GetTopicsInstanceListOutput
- func (o GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput
- func (o GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutputWithContext(ctx context.Context) GetTopicsInstanceListArrayOutput
- type GetTopicsInstanceListInput
- type GetTopicsInstanceListOutput
- func (o GetTopicsInstanceListOutput) CleanUpPolicy() pulumi.StringOutput
- func (o GetTopicsInstanceListOutput) CreateTime() pulumi.StringOutput
- func (GetTopicsInstanceListOutput) ElementType() reflect.Type
- func (o GetTopicsInstanceListOutput) EnableWhiteList() pulumi.BoolOutput
- func (o GetTopicsInstanceListOutput) ForwardCosBucket() pulumi.StringOutput
- func (o GetTopicsInstanceListOutput) ForwardInterval() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) ForwardStatus() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) IpWhiteListCount() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) MaxMessageBytes() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) Note() pulumi.StringOutput
- func (o GetTopicsInstanceListOutput) PartitionNum() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) ReplicaNum() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) Retention() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) Segment() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) SegmentBytes() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) SyncReplicaMinNum() pulumi.IntOutput
- func (o GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutput() GetTopicsInstanceListOutput
- func (o GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutputWithContext(ctx context.Context) GetTopicsInstanceListOutput
- func (o GetTopicsInstanceListOutput) TopicId() pulumi.StringOutput
- func (o GetTopicsInstanceListOutput) TopicName() pulumi.StringOutput
- func (o GetTopicsInstanceListOutput) UncleanLeaderElectionEnable() pulumi.BoolOutput
- type GetTopicsOutputArgs
- type GetTopicsResult
- type GetTopicsResultOutput
- func (GetTopicsResultOutput) ElementType() reflect.Type
- func (o GetTopicsResultOutput) Id() pulumi.StringOutput
- func (o GetTopicsResultOutput) InstanceId() pulumi.StringOutput
- func (o GetTopicsResultOutput) InstanceLists() GetTopicsInstanceListArrayOutput
- func (o GetTopicsResultOutput) ResultOutputFile() pulumi.StringPtrOutput
- func (o GetTopicsResultOutput) ToGetTopicsResultOutput() GetTopicsResultOutput
- func (o GetTopicsResultOutput) ToGetTopicsResultOutputWithContext(ctx context.Context) GetTopicsResultOutput
- func (o GetTopicsResultOutput) TopicName() pulumi.StringPtrOutput
- type GetUsersArgs
- type GetUsersOutputArgs
- type GetUsersResult
- type GetUsersResultOutput
- func (o GetUsersResultOutput) AccountName() pulumi.StringPtrOutput
- func (GetUsersResultOutput) ElementType() reflect.Type
- func (o GetUsersResultOutput) Id() pulumi.StringOutput
- func (o GetUsersResultOutput) InstanceId() pulumi.StringOutput
- func (o GetUsersResultOutput) ResultOutputFile() pulumi.StringPtrOutput
- func (o GetUsersResultOutput) ToGetUsersResultOutput() GetUsersResultOutput
- func (o GetUsersResultOutput) ToGetUsersResultOutputWithContext(ctx context.Context) GetUsersResultOutput
- func (o GetUsersResultOutput) UserLists() GetUsersUserListArrayOutput
- type GetUsersUserList
- type GetUsersUserListArgs
- type GetUsersUserListArray
- type GetUsersUserListArrayInput
- type GetUsersUserListArrayOutput
- func (GetUsersUserListArrayOutput) ElementType() reflect.Type
- func (o GetUsersUserListArrayOutput) Index(i pulumi.IntInput) GetUsersUserListOutput
- func (o GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutput() GetUsersUserListArrayOutput
- func (o GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutputWithContext(ctx context.Context) GetUsersUserListArrayOutput
- type GetUsersUserListInput
- type GetUsersUserListOutput
- func (o GetUsersUserListOutput) AccountName() pulumi.StringOutput
- func (o GetUsersUserListOutput) CreateTime() pulumi.StringOutput
- func (GetUsersUserListOutput) ElementType() reflect.Type
- func (o GetUsersUserListOutput) ToGetUsersUserListOutput() GetUsersUserListOutput
- func (o GetUsersUserListOutput) ToGetUsersUserListOutputWithContext(ctx context.Context) GetUsersUserListOutput
- func (o GetUsersUserListOutput) UpdateTime() pulumi.StringOutput
- type Instance
- type InstanceArgs
- type InstanceArray
- type InstanceArrayInput
- type InstanceArrayOutput
- type InstanceConfig
- type InstanceConfigArgs
- func (InstanceConfigArgs) ElementType() reflect.Type
- func (i InstanceConfigArgs) ToInstanceConfigOutput() InstanceConfigOutput
- func (i InstanceConfigArgs) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput
- func (i InstanceConfigArgs) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
- func (i InstanceConfigArgs) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
- type InstanceConfigInput
- type InstanceConfigOutput
- func (o InstanceConfigOutput) AutoCreateTopicEnable() pulumi.BoolOutput
- func (o InstanceConfigOutput) DefaultNumPartitions() pulumi.IntOutput
- func (o InstanceConfigOutput) DefaultReplicationFactor() pulumi.IntOutput
- func (InstanceConfigOutput) ElementType() reflect.Type
- func (o InstanceConfigOutput) ToInstanceConfigOutput() InstanceConfigOutput
- func (o InstanceConfigOutput) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput
- func (o InstanceConfigOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
- func (o InstanceConfigOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
- type InstanceConfigPtrInput
- type InstanceConfigPtrOutput
- func (o InstanceConfigPtrOutput) AutoCreateTopicEnable() pulumi.BoolPtrOutput
- func (o InstanceConfigPtrOutput) DefaultNumPartitions() pulumi.IntPtrOutput
- func (o InstanceConfigPtrOutput) DefaultReplicationFactor() pulumi.IntPtrOutput
- func (o InstanceConfigPtrOutput) Elem() InstanceConfigOutput
- func (InstanceConfigPtrOutput) ElementType() reflect.Type
- func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
- func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
- type InstanceDynamicRetentionConfig
- type InstanceDynamicRetentionConfigArgs
- func (InstanceDynamicRetentionConfigArgs) ElementType() reflect.Type
- func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput
- func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput
- func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
- func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
- type InstanceDynamicRetentionConfigInput
- type InstanceDynamicRetentionConfigOutput
- func (o InstanceDynamicRetentionConfigOutput) BottomRetention() pulumi.IntPtrOutput
- func (o InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage() pulumi.IntPtrOutput
- func (InstanceDynamicRetentionConfigOutput) ElementType() reflect.Type
- func (o InstanceDynamicRetentionConfigOutput) Enable() pulumi.IntPtrOutput
- func (o InstanceDynamicRetentionConfigOutput) StepForwardPercentage() pulumi.IntPtrOutput
- func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput
- func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput
- func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
- func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
- type InstanceDynamicRetentionConfigPtrInput
- type InstanceDynamicRetentionConfigPtrOutput
- func (o InstanceDynamicRetentionConfigPtrOutput) BottomRetention() pulumi.IntPtrOutput
- func (o InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage() pulumi.IntPtrOutput
- func (o InstanceDynamicRetentionConfigPtrOutput) Elem() InstanceDynamicRetentionConfigOutput
- func (InstanceDynamicRetentionConfigPtrOutput) ElementType() reflect.Type
- func (o InstanceDynamicRetentionConfigPtrOutput) Enable() pulumi.IntPtrOutput
- func (o InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage() pulumi.IntPtrOutput
- func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
- func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
- type InstanceInput
- type InstanceMap
- type InstanceMapInput
- type InstanceMapOutput
- type InstanceOutput
- func (o InstanceOutput) BandWidth() pulumi.IntOutput
- func (o InstanceOutput) Config() InstanceConfigPtrOutput
- func (o InstanceOutput) DiskSize() pulumi.IntOutput
- func (o InstanceOutput) DiskType() pulumi.StringOutput
- func (o InstanceOutput) DynamicRetentionConfig() InstanceDynamicRetentionConfigOutput
- func (InstanceOutput) ElementType() reflect.Type
- func (o InstanceOutput) InstanceName() pulumi.StringOutput
- func (o InstanceOutput) KafkaVersion() pulumi.StringOutput
- func (o InstanceOutput) MsgRetentionTime() pulumi.IntOutput
- func (o InstanceOutput) MultiZoneFlag() pulumi.BoolPtrOutput
- func (o InstanceOutput) Partition() pulumi.IntOutput
- func (o InstanceOutput) Period() pulumi.IntPtrOutput
- func (o InstanceOutput) PublicNetwork() pulumi.IntOutput
- func (o InstanceOutput) RebalanceTime() pulumi.IntPtrOutput
- func (o InstanceOutput) RenewFlag() pulumi.IntOutput
- func (o InstanceOutput) SubnetId() pulumi.StringOutput
- func (o InstanceOutput) Tags() InstanceTagArrayOutput
- func (o InstanceOutput) ToInstanceOutput() InstanceOutput
- func (o InstanceOutput) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput
- func (o InstanceOutput) Vip() pulumi.StringOutput
- func (o InstanceOutput) VpcId() pulumi.StringOutput
- func (o InstanceOutput) Vport() pulumi.StringOutput
- func (o InstanceOutput) ZoneId() pulumi.IntOutput
- func (o InstanceOutput) ZoneIds() pulumi.IntArrayOutput
- type InstanceState
- type InstanceTag
- type InstanceTagArgs
- type InstanceTagArray
- type InstanceTagArrayInput
- type InstanceTagArrayOutput
- func (InstanceTagArrayOutput) ElementType() reflect.Type
- func (o InstanceTagArrayOutput) Index(i pulumi.IntInput) InstanceTagOutput
- func (o InstanceTagArrayOutput) ToInstanceTagArrayOutput() InstanceTagArrayOutput
- func (o InstanceTagArrayOutput) ToInstanceTagArrayOutputWithContext(ctx context.Context) InstanceTagArrayOutput
- type InstanceTagInput
- type InstanceTagOutput
- func (InstanceTagOutput) ElementType() reflect.Type
- func (o InstanceTagOutput) Key() pulumi.StringOutput
- func (o InstanceTagOutput) ToInstanceTagOutput() InstanceTagOutput
- func (o InstanceTagOutput) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput
- func (o InstanceTagOutput) Value() pulumi.StringOutput
- type Topic
- type TopicArgs
- type TopicArray
- type TopicArrayInput
- type TopicArrayOutput
- type TopicInput
- type TopicMap
- type TopicMapInput
- type TopicMapOutput
- type TopicOutput
- func (o TopicOutput) CleanUpPolicy() pulumi.StringPtrOutput
- func (o TopicOutput) CreateTime() pulumi.StringOutput
- func (TopicOutput) ElementType() reflect.Type
- func (o TopicOutput) EnableWhiteList() pulumi.BoolPtrOutput
- func (o TopicOutput) ForwardCosBucket() pulumi.StringOutput
- func (o TopicOutput) ForwardInterval() pulumi.IntOutput
- func (o TopicOutput) ForwardStatus() pulumi.IntOutput
- func (o TopicOutput) InstanceId() pulumi.StringOutput
- func (o TopicOutput) IpWhiteLists() pulumi.StringArrayOutput
- func (o TopicOutput) MaxMessageBytes() pulumi.IntPtrOutput
- func (o TopicOutput) MessageStorageLocation() pulumi.StringOutput
- func (o TopicOutput) Note() pulumi.StringPtrOutput
- func (o TopicOutput) PartitionNum() pulumi.IntOutput
- func (o TopicOutput) ReplicaNum() pulumi.IntOutput
- func (o TopicOutput) Retention() pulumi.IntPtrOutput
- func (o TopicOutput) Segment() pulumi.IntPtrOutput
- func (o TopicOutput) SegmentBytes() pulumi.IntOutput
- func (o TopicOutput) SyncReplicaMinNum() pulumi.IntPtrOutput
- func (o TopicOutput) ToTopicOutput() TopicOutput
- func (o TopicOutput) ToTopicOutputWithContext(ctx context.Context) TopicOutput
- func (o TopicOutput) TopicName() pulumi.StringOutput
- func (o TopicOutput) UncleanLeaderElectionEnable() pulumi.BoolPtrOutput
- type TopicState
- type User
- type UserArgs
- type UserArray
- type UserArrayInput
- type UserArrayOutput
- type UserInput
- type UserMap
- type UserMapInput
- type UserMapOutput
- type UserOutput
- func (o UserOutput) AccountName() pulumi.StringOutput
- func (o UserOutput) CreateTime() pulumi.StringOutput
- func (UserOutput) ElementType() reflect.Type
- func (o UserOutput) InstanceId() pulumi.StringOutput
- func (o UserOutput) Password() pulumi.StringOutput
- func (o UserOutput) ToUserOutput() UserOutput
- func (o UserOutput) ToUserOutputWithContext(ctx context.Context) UserOutput
- func (o UserOutput) UpdateTime() pulumi.StringOutput
- type UserState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func PkgVersion ¶ added in v0.0.5
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) ToAclOutput ¶
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 ¶
type AclArray ¶
type AclArray []AclInput
func (AclArray) ElementType ¶
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) ToAclArrayOutput ¶
func (o AclArrayOutput) ToAclArrayOutput() AclArrayOutput
func (AclArrayOutput) ToAclArrayOutputWithContext ¶
func (o AclArrayOutput) ToAclArrayOutputWithContext(ctx context.Context) AclArrayOutput
type AclMap ¶
func (AclMap) ElementType ¶
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) 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 ¶
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 ¶
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 GetInstancesFilterArgs ¶
type GetInstancesFilterArgs struct { // The field that needs to be filtered. Name pulumi.StringInput `pulumi:"name"` // The filtered value of the field. Values pulumi.StringArrayInput `pulumi:"values"` }
func (GetInstancesFilterArgs) ElementType ¶
func (GetInstancesFilterArgs) ElementType() reflect.Type
func (GetInstancesFilterArgs) ToGetInstancesFilterOutput ¶
func (i GetInstancesFilterArgs) ToGetInstancesFilterOutput() GetInstancesFilterOutput
func (GetInstancesFilterArgs) ToGetInstancesFilterOutputWithContext ¶
func (i GetInstancesFilterArgs) ToGetInstancesFilterOutputWithContext(ctx context.Context) GetInstancesFilterOutput
type GetInstancesFilterArray ¶
type GetInstancesFilterArray []GetInstancesFilterInput
func (GetInstancesFilterArray) ElementType ¶
func (GetInstancesFilterArray) ElementType() reflect.Type
func (GetInstancesFilterArray) ToGetInstancesFilterArrayOutput ¶
func (i GetInstancesFilterArray) ToGetInstancesFilterArrayOutput() GetInstancesFilterArrayOutput
func (GetInstancesFilterArray) ToGetInstancesFilterArrayOutputWithContext ¶
func (i GetInstancesFilterArray) ToGetInstancesFilterArrayOutputWithContext(ctx context.Context) GetInstancesFilterArrayOutput
type GetInstancesFilterArrayInput ¶
type GetInstancesFilterArrayInput interface { pulumi.Input ToGetInstancesFilterArrayOutput() GetInstancesFilterArrayOutput ToGetInstancesFilterArrayOutputWithContext(context.Context) GetInstancesFilterArrayOutput }
GetInstancesFilterArrayInput is an input type that accepts GetInstancesFilterArray and GetInstancesFilterArrayOutput values. You can construct a concrete instance of `GetInstancesFilterArrayInput` via:
GetInstancesFilterArray{ GetInstancesFilterArgs{...} }
type GetInstancesFilterArrayOutput ¶
type GetInstancesFilterArrayOutput struct{ *pulumi.OutputState }
func (GetInstancesFilterArrayOutput) ElementType ¶
func (GetInstancesFilterArrayOutput) ElementType() reflect.Type
func (GetInstancesFilterArrayOutput) Index ¶
func (o GetInstancesFilterArrayOutput) Index(i pulumi.IntInput) GetInstancesFilterOutput
func (GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutput ¶
func (o GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutput() GetInstancesFilterArrayOutput
func (GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutputWithContext ¶
func (o GetInstancesFilterArrayOutput) ToGetInstancesFilterArrayOutputWithContext(ctx context.Context) GetInstancesFilterArrayOutput
type GetInstancesFilterInput ¶
type GetInstancesFilterInput interface { pulumi.Input ToGetInstancesFilterOutput() GetInstancesFilterOutput ToGetInstancesFilterOutputWithContext(context.Context) GetInstancesFilterOutput }
GetInstancesFilterInput is an input type that accepts GetInstancesFilterArgs and GetInstancesFilterOutput values. You can construct a concrete instance of `GetInstancesFilterInput` via:
GetInstancesFilterArgs{...}
type GetInstancesFilterOutput ¶
type GetInstancesFilterOutput struct{ *pulumi.OutputState }
func (GetInstancesFilterOutput) ElementType ¶
func (GetInstancesFilterOutput) ElementType() reflect.Type
func (GetInstancesFilterOutput) Name ¶
func (o GetInstancesFilterOutput) Name() pulumi.StringOutput
The field that needs to be filtered.
func (GetInstancesFilterOutput) ToGetInstancesFilterOutput ¶
func (o GetInstancesFilterOutput) ToGetInstancesFilterOutput() GetInstancesFilterOutput
func (GetInstancesFilterOutput) ToGetInstancesFilterOutputWithContext ¶
func (o GetInstancesFilterOutput) ToGetInstancesFilterOutputWithContext(ctx context.Context) GetInstancesFilterOutput
func (GetInstancesFilterOutput) Values ¶
func (o GetInstancesFilterOutput) Values() pulumi.StringArrayOutput
The filtered value of the field.
type GetInstancesInstanceList ¶
type GetInstancesInstanceList struct { // Instance bandwidth, in Mbps. Bandwidth int `pulumi:"bandwidth"` // The time when the instance was created. CreateTime int `pulumi:"createTime"` // ckafka sale type. Note: This field may return null, indicating that a valid value could not be retrieved. Cvm int `pulumi:"cvm"` // The storage size of the instance, in GB. DiskSize int `pulumi:"diskSize"` // Disk Type. Note: This field may return null, indicating that a valid value could not be retrieved. DiskType string `pulumi:"diskType"` // The instance expiration time. ExpireTime int `pulumi:"expireTime"` // Instance status int: 1 indicates health, 2 indicates alarm, and 3 indicates abnormal instance status. Healthy int `pulumi:"healthy"` // Instance status information. HealthyMessage string `pulumi:"healthyMessage"` // The instance ID. InstanceId string `pulumi:"instanceId"` // The instance name. InstanceName string `pulumi:"instanceName"` // ckafka instance type. Note: This field may return null, indicating that a valid value could not be retrieved. InstanceType string `pulumi:"instanceType"` // Whether it is an internal customer. A value of 1 indicates an internal customer. IsInternal int `pulumi:"isInternal"` // The maximum number of Partitions for the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved. MaxPartitionNumber int `pulumi:"maxPartitionNumber"` // The maximum number of topics in the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved.. MaxTopicNumber int `pulumi:"maxTopicNumber"` // The current number of instances. Note: This field may return null, indicating that a valid value could not be retrieved.. PartitionNumber int `pulumi:"partitionNumber"` // The Internet bandwidth value. Note: This field may return null, indicating that a valid value could not be retrieved.. PublicNetwork int `pulumi:"publicNetwork"` // The type of Internet bandwidth. Note: This field may return null, indicating that a valid value could not be retrieved.. PublicNetworkChargeType string `pulumi:"publicNetworkChargeType"` // Schedule the upgrade configuration time. Note: This field may return null, indicating that a valid value could not be retrieved.. RebalanceTime string `pulumi:"rebalanceTime"` // Whether the instance is renewed, the int enumeration value: 1 indicates auto-renewal, and 2 indicates that it is not automatically renewed. RenewFlag int `pulumi:"renewFlag"` // (Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all. Status int `pulumi:"status"` // Subnet id. SubnetId string `pulumi:"subnetId"` // Tag infomation. Tags []GetInstancesInstanceListTag `pulumi:"tags"` // The number of topics. TopicNum int `pulumi:"topicNum"` // Kafka version information. Note: This field may return null, indicating that a valid value could not be retrieved. Version string `pulumi:"version"` // Virtual IP. Vip string `pulumi:"vip"` // Virtual IP entities. VipList GetInstancesInstanceListVipList `pulumi:"vipList"` // VpcId, if empty, indicates that it is the underlying network. VpcId string `pulumi:"vpcId"` // Virtual PORT. Vport string `pulumi:"vport"` // Availability Zone ID. ZoneId int `pulumi:"zoneId"` // Across Availability Zones. Note: This field may return null, indicating that a valid value could not be retrieved. ZoneIds []int `pulumi:"zoneIds"` }
type GetInstancesInstanceListArgs ¶
type GetInstancesInstanceListArgs struct { // Instance bandwidth, in Mbps. Bandwidth pulumi.IntInput `pulumi:"bandwidth"` // The time when the instance was created. CreateTime pulumi.IntInput `pulumi:"createTime"` // ckafka sale type. Note: This field may return null, indicating that a valid value could not be retrieved. Cvm pulumi.IntInput `pulumi:"cvm"` // The storage size of the instance, in GB. DiskSize pulumi.IntInput `pulumi:"diskSize"` // Disk Type. Note: This field may return null, indicating that a valid value could not be retrieved. DiskType pulumi.StringInput `pulumi:"diskType"` // The instance expiration time. ExpireTime pulumi.IntInput `pulumi:"expireTime"` // Instance status int: 1 indicates health, 2 indicates alarm, and 3 indicates abnormal instance status. Healthy pulumi.IntInput `pulumi:"healthy"` // Instance status information. HealthyMessage pulumi.StringInput `pulumi:"healthyMessage"` // The instance ID. InstanceId pulumi.StringInput `pulumi:"instanceId"` // The instance name. InstanceName pulumi.StringInput `pulumi:"instanceName"` // ckafka instance type. Note: This field may return null, indicating that a valid value could not be retrieved. InstanceType pulumi.StringInput `pulumi:"instanceType"` // Whether it is an internal customer. A value of 1 indicates an internal customer. IsInternal pulumi.IntInput `pulumi:"isInternal"` // The maximum number of Partitions for the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved. MaxPartitionNumber pulumi.IntInput `pulumi:"maxPartitionNumber"` // The maximum number of topics in the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved.. MaxTopicNumber pulumi.IntInput `pulumi:"maxTopicNumber"` // The current number of instances. Note: This field may return null, indicating that a valid value could not be retrieved.. PartitionNumber pulumi.IntInput `pulumi:"partitionNumber"` // The Internet bandwidth value. Note: This field may return null, indicating that a valid value could not be retrieved.. PublicNetwork pulumi.IntInput `pulumi:"publicNetwork"` // The type of Internet bandwidth. Note: This field may return null, indicating that a valid value could not be retrieved.. PublicNetworkChargeType pulumi.StringInput `pulumi:"publicNetworkChargeType"` // Schedule the upgrade configuration time. Note: This field may return null, indicating that a valid value could not be retrieved.. RebalanceTime pulumi.StringInput `pulumi:"rebalanceTime"` // Whether the instance is renewed, the int enumeration value: 1 indicates auto-renewal, and 2 indicates that it is not automatically renewed. RenewFlag pulumi.IntInput `pulumi:"renewFlag"` // (Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all. Status pulumi.IntInput `pulumi:"status"` // Subnet id. SubnetId pulumi.StringInput `pulumi:"subnetId"` // Tag infomation. Tags GetInstancesInstanceListTagArrayInput `pulumi:"tags"` // The number of topics. TopicNum pulumi.IntInput `pulumi:"topicNum"` // Kafka version information. Note: This field may return null, indicating that a valid value could not be retrieved. Version pulumi.StringInput `pulumi:"version"` // Virtual IP. Vip pulumi.StringInput `pulumi:"vip"` // Virtual IP entities. VipList GetInstancesInstanceListVipListInput `pulumi:"vipList"` // VpcId, if empty, indicates that it is the underlying network. VpcId pulumi.StringInput `pulumi:"vpcId"` // Virtual PORT. Vport pulumi.StringInput `pulumi:"vport"` // Availability Zone ID. ZoneId pulumi.IntInput `pulumi:"zoneId"` // Across Availability Zones. Note: This field may return null, indicating that a valid value could not be retrieved. ZoneIds pulumi.IntArrayInput `pulumi:"zoneIds"` }
func (GetInstancesInstanceListArgs) ElementType ¶
func (GetInstancesInstanceListArgs) ElementType() reflect.Type
func (GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutput ¶
func (i GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput
func (GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutputWithContext ¶
func (i GetInstancesInstanceListArgs) ToGetInstancesInstanceListOutputWithContext(ctx context.Context) GetInstancesInstanceListOutput
type GetInstancesInstanceListArray ¶
type GetInstancesInstanceListArray []GetInstancesInstanceListInput
func (GetInstancesInstanceListArray) ElementType ¶
func (GetInstancesInstanceListArray) ElementType() reflect.Type
func (GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutput ¶
func (i GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput
func (GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutputWithContext ¶
func (i GetInstancesInstanceListArray) ToGetInstancesInstanceListArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListArrayOutput
type GetInstancesInstanceListArrayInput ¶
type GetInstancesInstanceListArrayInput interface { pulumi.Input ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput ToGetInstancesInstanceListArrayOutputWithContext(context.Context) GetInstancesInstanceListArrayOutput }
GetInstancesInstanceListArrayInput is an input type that accepts GetInstancesInstanceListArray and GetInstancesInstanceListArrayOutput values. You can construct a concrete instance of `GetInstancesInstanceListArrayInput` via:
GetInstancesInstanceListArray{ GetInstancesInstanceListArgs{...} }
type GetInstancesInstanceListArrayOutput ¶
type GetInstancesInstanceListArrayOutput struct{ *pulumi.OutputState }
func (GetInstancesInstanceListArrayOutput) ElementType ¶
func (GetInstancesInstanceListArrayOutput) ElementType() reflect.Type
func (GetInstancesInstanceListArrayOutput) Index ¶
func (o GetInstancesInstanceListArrayOutput) Index(i pulumi.IntInput) GetInstancesInstanceListOutput
func (GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutput ¶
func (o GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutput() GetInstancesInstanceListArrayOutput
func (GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutputWithContext ¶
func (o GetInstancesInstanceListArrayOutput) ToGetInstancesInstanceListArrayOutputWithContext(ctx context.Context) GetInstancesInstanceListArrayOutput
type GetInstancesInstanceListInput ¶
type GetInstancesInstanceListInput interface { pulumi.Input ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput ToGetInstancesInstanceListOutputWithContext(context.Context) GetInstancesInstanceListOutput }
GetInstancesInstanceListInput is an input type that accepts GetInstancesInstanceListArgs and GetInstancesInstanceListOutput values. You can construct a concrete instance of `GetInstancesInstanceListInput` via:
GetInstancesInstanceListArgs{...}
type GetInstancesInstanceListOutput ¶
type GetInstancesInstanceListOutput struct{ *pulumi.OutputState }
func (GetInstancesInstanceListOutput) Bandwidth ¶
func (o GetInstancesInstanceListOutput) Bandwidth() pulumi.IntOutput
Instance bandwidth, in Mbps.
func (GetInstancesInstanceListOutput) CreateTime ¶
func (o GetInstancesInstanceListOutput) CreateTime() pulumi.IntOutput
The time when the instance was created.
func (GetInstancesInstanceListOutput) Cvm ¶
func (o GetInstancesInstanceListOutput) Cvm() pulumi.IntOutput
ckafka sale type. Note: This field may return null, indicating that a valid value could not be retrieved.
func (GetInstancesInstanceListOutput) DiskSize ¶
func (o GetInstancesInstanceListOutput) DiskSize() pulumi.IntOutput
The storage size of the instance, in GB.
func (GetInstancesInstanceListOutput) DiskType ¶
func (o GetInstancesInstanceListOutput) DiskType() pulumi.StringOutput
Disk Type. Note: This field may return null, indicating that a valid value could not be retrieved.
func (GetInstancesInstanceListOutput) ElementType ¶
func (GetInstancesInstanceListOutput) ElementType() reflect.Type
func (GetInstancesInstanceListOutput) ExpireTime ¶
func (o GetInstancesInstanceListOutput) ExpireTime() pulumi.IntOutput
The instance expiration time.
func (GetInstancesInstanceListOutput) Healthy ¶
func (o GetInstancesInstanceListOutput) Healthy() pulumi.IntOutput
Instance status int: 1 indicates health, 2 indicates alarm, and 3 indicates abnormal instance status.
func (GetInstancesInstanceListOutput) HealthyMessage ¶
func (o GetInstancesInstanceListOutput) HealthyMessage() pulumi.StringOutput
Instance status information.
func (GetInstancesInstanceListOutput) InstanceId ¶
func (o GetInstancesInstanceListOutput) InstanceId() pulumi.StringOutput
The instance ID.
func (GetInstancesInstanceListOutput) InstanceName ¶
func (o GetInstancesInstanceListOutput) InstanceName() pulumi.StringOutput
The instance name.
func (GetInstancesInstanceListOutput) InstanceType ¶
func (o GetInstancesInstanceListOutput) InstanceType() pulumi.StringOutput
ckafka instance type. Note: This field may return null, indicating that a valid value could not be retrieved.
func (GetInstancesInstanceListOutput) IsInternal ¶
func (o GetInstancesInstanceListOutput) IsInternal() pulumi.IntOutput
Whether it is an internal customer. A value of 1 indicates an internal customer.
func (GetInstancesInstanceListOutput) MaxPartitionNumber ¶
func (o GetInstancesInstanceListOutput) MaxPartitionNumber() pulumi.IntOutput
The maximum number of Partitions for the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved.
func (GetInstancesInstanceListOutput) MaxTopicNumber ¶
func (o GetInstancesInstanceListOutput) MaxTopicNumber() pulumi.IntOutput
The maximum number of topics in the current specifications. Note: This field may return null, indicating that a valid value could not be retrieved..
func (GetInstancesInstanceListOutput) PartitionNumber ¶
func (o GetInstancesInstanceListOutput) PartitionNumber() pulumi.IntOutput
The current number of instances. Note: This field may return null, indicating that a valid value could not be retrieved..
func (GetInstancesInstanceListOutput) PublicNetwork ¶
func (o GetInstancesInstanceListOutput) PublicNetwork() pulumi.IntOutput
The Internet bandwidth value. Note: This field may return null, indicating that a valid value could not be retrieved..
func (GetInstancesInstanceListOutput) PublicNetworkChargeType ¶
func (o GetInstancesInstanceListOutput) PublicNetworkChargeType() pulumi.StringOutput
The type of Internet bandwidth. Note: This field may return null, indicating that a valid value could not be retrieved..
func (GetInstancesInstanceListOutput) RebalanceTime ¶
func (o GetInstancesInstanceListOutput) RebalanceTime() pulumi.StringOutput
Schedule the upgrade configuration time. Note: This field may return null, indicating that a valid value could not be retrieved..
func (GetInstancesInstanceListOutput) RenewFlag ¶
func (o GetInstancesInstanceListOutput) RenewFlag() pulumi.IntOutput
Whether the instance is renewed, the int enumeration value: 1 indicates auto-renewal, and 2 indicates that it is not automatically renewed.
func (GetInstancesInstanceListOutput) Status ¶
func (o GetInstancesInstanceListOutput) Status() pulumi.IntOutput
(Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all.
func (GetInstancesInstanceListOutput) SubnetId ¶
func (o GetInstancesInstanceListOutput) SubnetId() pulumi.StringOutput
Subnet id.
func (GetInstancesInstanceListOutput) Tags ¶
func (o GetInstancesInstanceListOutput) Tags() GetInstancesInstanceListTagArrayOutput
Tag infomation.
func (GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutput ¶
func (o GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutput() GetInstancesInstanceListOutput
func (GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutputWithContext ¶
func (o GetInstancesInstanceListOutput) ToGetInstancesInstanceListOutputWithContext(ctx context.Context) GetInstancesInstanceListOutput
func (GetInstancesInstanceListOutput) TopicNum ¶
func (o GetInstancesInstanceListOutput) TopicNum() pulumi.IntOutput
The number of topics.
func (GetInstancesInstanceListOutput) Version ¶
func (o GetInstancesInstanceListOutput) Version() pulumi.StringOutput
Kafka version information. Note: This field may return null, indicating that a valid value could not be retrieved.
func (GetInstancesInstanceListOutput) Vip ¶
func (o GetInstancesInstanceListOutput) Vip() pulumi.StringOutput
Virtual IP.
func (GetInstancesInstanceListOutput) VipList ¶
func (o GetInstancesInstanceListOutput) VipList() GetInstancesInstanceListVipListOutput
Virtual IP entities.
func (GetInstancesInstanceListOutput) VpcId ¶
func (o GetInstancesInstanceListOutput) VpcId() pulumi.StringOutput
VpcId, if empty, indicates that it is the underlying network.
func (GetInstancesInstanceListOutput) Vport ¶
func (o GetInstancesInstanceListOutput) Vport() pulumi.StringOutput
Virtual PORT.
func (GetInstancesInstanceListOutput) ZoneId ¶
func (o GetInstancesInstanceListOutput) ZoneId() pulumi.IntOutput
Availability Zone ID.
func (GetInstancesInstanceListOutput) ZoneIds ¶
func (o GetInstancesInstanceListOutput) ZoneIds() pulumi.IntArrayOutput
Across Availability Zones. Note: This field may return null, indicating that a valid value could not be retrieved.
type 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) 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 GetInstancesInstanceListVipListArgs ¶
type GetInstancesInstanceListVipListArgs struct { // Virtual IP. Vip pulumi.StringInput `pulumi:"vip"` // Virtual PORT. Vport pulumi.StringInput `pulumi:"vport"` }
func (GetInstancesInstanceListVipListArgs) ElementType ¶
func (GetInstancesInstanceListVipListArgs) ElementType() reflect.Type
func (GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutput ¶
func (i GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput
func (GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutputWithContext ¶
func (i GetInstancesInstanceListVipListArgs) ToGetInstancesInstanceListVipListOutputWithContext(ctx context.Context) GetInstancesInstanceListVipListOutput
type GetInstancesInstanceListVipListInput ¶
type GetInstancesInstanceListVipListInput interface { pulumi.Input ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput ToGetInstancesInstanceListVipListOutputWithContext(context.Context) GetInstancesInstanceListVipListOutput }
GetInstancesInstanceListVipListInput is an input type that accepts GetInstancesInstanceListVipListArgs and GetInstancesInstanceListVipListOutput values. You can construct a concrete instance of `GetInstancesInstanceListVipListInput` via:
GetInstancesInstanceListVipListArgs{...}
type GetInstancesInstanceListVipListOutput ¶
type GetInstancesInstanceListVipListOutput struct{ *pulumi.OutputState }
func (GetInstancesInstanceListVipListOutput) ElementType ¶
func (GetInstancesInstanceListVipListOutput) ElementType() reflect.Type
func (GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutput ¶
func (o GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutput() GetInstancesInstanceListVipListOutput
func (GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutputWithContext ¶
func (o GetInstancesInstanceListVipListOutput) ToGetInstancesInstanceListVipListOutputWithContext(ctx context.Context) GetInstancesInstanceListVipListOutput
func (GetInstancesInstanceListVipListOutput) Vip ¶
func (o GetInstancesInstanceListVipListOutput) Vip() pulumi.StringOutput
Virtual IP.
func (GetInstancesInstanceListVipListOutput) Vport ¶
func (o GetInstancesInstanceListVipListOutput) Vport() pulumi.StringOutput
Virtual PORT.
type GetInstancesOutputArgs ¶
type GetInstancesOutputArgs struct { // Filter. filter.name supports ('Ip', 'VpcId', 'SubNetId', 'InstanceType','InstanceId'), filter.values can pass up to 10 values. Filters GetInstancesFilterArrayInput `pulumi:"filters"` // Filter by instance ID. InstanceIds pulumi.StringArrayInput `pulumi:"instanceIds"` // The number of pages, default is `10`. Limit pulumi.IntPtrInput `pulumi:"limit"` // The page start offset, default is `0`. Offset pulumi.IntPtrInput `pulumi:"offset"` // Used to save results. ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"` // Filter by instance name, support fuzzy query. SearchWord pulumi.StringPtrInput `pulumi:"searchWord"` // (Filter Criteria) The status of the instance. 0: Create, 1: Run, 2: Delete, do not fill the default return all. Statuses pulumi.IntArrayInput `pulumi:"statuses"` // Matches the tag key value. TagKey pulumi.StringPtrInput `pulumi:"tagKey"` }
A collection of arguments for invoking getInstances.
func (GetInstancesOutputArgs) ElementType ¶
func (GetInstancesOutputArgs) ElementType() reflect.Type
type GetInstancesResult ¶
type GetInstancesResult struct { Filters []GetInstancesFilter `pulumi:"filters"` // The provider-assigned unique ID for this managed resource. Id string `pulumi:"id"` InstanceIds []string `pulumi:"instanceIds"` // A list of ckafka users. Each element contains the following attributes: InstanceLists []GetInstancesInstanceList `pulumi:"instanceLists"` Limit *int `pulumi:"limit"` Offset *int `pulumi:"offset"` ResultOutputFile *string `pulumi:"resultOutputFile"` SearchWord *string `pulumi:"searchWord"` // The status of the instance. 0: Created, 1: Running, 2: Delete: 5 Quarantined, -1 Creation failed. Statuses []int `pulumi:"statuses"` // Tag Key. TagKey *string `pulumi:"tagKey"` }
A collection of values returned by getInstances.
func GetInstances ¶
func GetInstances(ctx *pulumi.Context, args *GetInstancesArgs, opts ...pulumi.InvokeOption) (*GetInstancesResult, error)
Use this data source to query detailed instance information of Ckafka
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka" "github.com/pulumi/pulumi/sdk/v3/go/pulumi" "github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := Ckafka.GetInstances(ctx, &ckafka.GetInstancesArgs{ InstanceIds: []string{ "ckafka-vv7wpvae", }, }, nil) if err != nil { return err } return nil }) }
```
type GetInstancesResultOutput ¶
type GetInstancesResultOutput struct{ *pulumi.OutputState }
A collection of values returned by getInstances.
func GetInstancesOutput ¶
func GetInstancesOutput(ctx *pulumi.Context, args GetInstancesOutputArgs, opts ...pulumi.InvokeOption) GetInstancesResultOutput
func (GetInstancesResultOutput) ElementType ¶
func (GetInstancesResultOutput) ElementType() reflect.Type
func (GetInstancesResultOutput) Filters ¶
func (o GetInstancesResultOutput) Filters() GetInstancesFilterArrayOutput
func (GetInstancesResultOutput) Id ¶
func (o GetInstancesResultOutput) Id() pulumi.StringOutput
The provider-assigned unique ID for this managed resource.
func (GetInstancesResultOutput) InstanceIds ¶
func (o GetInstancesResultOutput) InstanceIds() pulumi.StringArrayOutput
func (GetInstancesResultOutput) InstanceLists ¶
func (o GetInstancesResultOutput) InstanceLists() GetInstancesInstanceListArrayOutput
A list of ckafka users. Each element contains the following attributes:
func (GetInstancesResultOutput) Limit ¶
func (o GetInstancesResultOutput) Limit() pulumi.IntPtrOutput
func (GetInstancesResultOutput) Offset ¶
func (o GetInstancesResultOutput) Offset() pulumi.IntPtrOutput
func (GetInstancesResultOutput) ResultOutputFile ¶
func (o GetInstancesResultOutput) ResultOutputFile() pulumi.StringPtrOutput
func (GetInstancesResultOutput) SearchWord ¶
func (o GetInstancesResultOutput) SearchWord() pulumi.StringPtrOutput
func (GetInstancesResultOutput) Statuses ¶
func (o GetInstancesResultOutput) Statuses() pulumi.IntArrayOutput
The status of the instance. 0: Created, 1: Running, 2: Delete: 5 Quarantined, -1 Creation failed.
func (GetInstancesResultOutput) TagKey ¶
func (o GetInstancesResultOutput) TagKey() pulumi.StringPtrOutput
Tag Key.
func (GetInstancesResultOutput) ToGetInstancesResultOutput ¶
func (o GetInstancesResultOutput) ToGetInstancesResultOutput() GetInstancesResultOutput
func (GetInstancesResultOutput) ToGetInstancesResultOutputWithContext ¶
func (o GetInstancesResultOutput) ToGetInstancesResultOutputWithContext(ctx context.Context) GetInstancesResultOutput
type GetTopicsArgs ¶
type GetTopicsArgs struct { // Ckafka instance ID. InstanceId string `pulumi:"instanceId"` // Used to store results. ResultOutputFile *string `pulumi:"resultOutputFile"` // Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64. TopicName *string `pulumi:"topicName"` }
A collection of arguments for invoking getTopics.
type GetTopicsInstanceList ¶
type GetTopicsInstanceList struct { // Clear log policy, log clear mode. `delete`: logs are deleted according to the storage time, `compact`: logs are compressed according to the key, `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time. CleanUpPolicy string `pulumi:"cleanUpPolicy"` // Create time of the CKafka topic. CreateTime string `pulumi:"createTime"` // Whether to open the IP Whitelist. `true`: open, `false`: close. EnableWhiteList bool `pulumi:"enableWhiteList"` // Data backup cos bucket: the bucket address that is dumped to cos. ForwardCosBucket string `pulumi:"forwardCosBucket"` // Periodic frequency of data backup to cos. ForwardInterval int `pulumi:"forwardInterval"` // Data backup cos status. `1`: do not open data backup, `0`: open data backup. ForwardStatus int `pulumi:"forwardStatus"` // IP Whitelist count. IpWhiteListCount int `pulumi:"ipWhiteListCount"` // Max message bytes. MaxMessageBytes int `pulumi:"maxMessageBytes"` // CKafka topic note description. Note string `pulumi:"note"` // The number of partition. PartitionNum int `pulumi:"partitionNum"` // The number of replica. ReplicaNum int `pulumi:"replicaNum"` // Message can be selected. Retention time(unit ms). Retention int `pulumi:"retention"` // Segment scrolling time, in ms. Segment int `pulumi:"segment"` // Number of bytes rolled by shard. SegmentBytes int `pulumi:"segmentBytes"` // Min number of sync replicas. SyncReplicaMinNum int `pulumi:"syncReplicaMinNum"` // ID of the CKafka topic. TopicId string `pulumi:"topicId"` // Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64. TopicName string `pulumi:"topicName"` // Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed. UncleanLeaderElectionEnable bool `pulumi:"uncleanLeaderElectionEnable"` }
type GetTopicsInstanceListArgs ¶
type GetTopicsInstanceListArgs struct { // Clear log policy, log clear mode. `delete`: logs are deleted according to the storage time, `compact`: logs are compressed according to the key, `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time. CleanUpPolicy pulumi.StringInput `pulumi:"cleanUpPolicy"` // Create time of the CKafka topic. CreateTime pulumi.StringInput `pulumi:"createTime"` // Whether to open the IP Whitelist. `true`: open, `false`: close. EnableWhiteList pulumi.BoolInput `pulumi:"enableWhiteList"` // Data backup cos bucket: the bucket address that is dumped to cos. ForwardCosBucket pulumi.StringInput `pulumi:"forwardCosBucket"` // Periodic frequency of data backup to cos. ForwardInterval pulumi.IntInput `pulumi:"forwardInterval"` // Data backup cos status. `1`: do not open data backup, `0`: open data backup. ForwardStatus pulumi.IntInput `pulumi:"forwardStatus"` // IP Whitelist count. IpWhiteListCount pulumi.IntInput `pulumi:"ipWhiteListCount"` // Max message bytes. MaxMessageBytes pulumi.IntInput `pulumi:"maxMessageBytes"` // CKafka topic note description. Note pulumi.StringInput `pulumi:"note"` // The number of partition. PartitionNum pulumi.IntInput `pulumi:"partitionNum"` // The number of replica. ReplicaNum pulumi.IntInput `pulumi:"replicaNum"` // Message can be selected. Retention time(unit ms). Retention pulumi.IntInput `pulumi:"retention"` // Segment scrolling time, in ms. Segment pulumi.IntInput `pulumi:"segment"` // Number of bytes rolled by shard. SegmentBytes pulumi.IntInput `pulumi:"segmentBytes"` // Min number of sync replicas. SyncReplicaMinNum pulumi.IntInput `pulumi:"syncReplicaMinNum"` // ID of the CKafka topic. TopicId pulumi.StringInput `pulumi:"topicId"` // Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64. TopicName pulumi.StringInput `pulumi:"topicName"` // Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed. UncleanLeaderElectionEnable pulumi.BoolInput `pulumi:"uncleanLeaderElectionEnable"` }
func (GetTopicsInstanceListArgs) ElementType ¶
func (GetTopicsInstanceListArgs) ElementType() reflect.Type
func (GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutput ¶
func (i GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutput() GetTopicsInstanceListOutput
func (GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutputWithContext ¶
func (i GetTopicsInstanceListArgs) ToGetTopicsInstanceListOutputWithContext(ctx context.Context) GetTopicsInstanceListOutput
type GetTopicsInstanceListArray ¶
type GetTopicsInstanceListArray []GetTopicsInstanceListInput
func (GetTopicsInstanceListArray) ElementType ¶
func (GetTopicsInstanceListArray) ElementType() reflect.Type
func (GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutput ¶
func (i GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput
func (GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutputWithContext ¶
func (i GetTopicsInstanceListArray) ToGetTopicsInstanceListArrayOutputWithContext(ctx context.Context) GetTopicsInstanceListArrayOutput
type GetTopicsInstanceListArrayInput ¶
type GetTopicsInstanceListArrayInput interface { pulumi.Input ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput ToGetTopicsInstanceListArrayOutputWithContext(context.Context) GetTopicsInstanceListArrayOutput }
GetTopicsInstanceListArrayInput is an input type that accepts GetTopicsInstanceListArray and GetTopicsInstanceListArrayOutput values. You can construct a concrete instance of `GetTopicsInstanceListArrayInput` via:
GetTopicsInstanceListArray{ GetTopicsInstanceListArgs{...} }
type GetTopicsInstanceListArrayOutput ¶
type GetTopicsInstanceListArrayOutput struct{ *pulumi.OutputState }
func (GetTopicsInstanceListArrayOutput) ElementType ¶
func (GetTopicsInstanceListArrayOutput) ElementType() reflect.Type
func (GetTopicsInstanceListArrayOutput) Index ¶
func (o GetTopicsInstanceListArrayOutput) Index(i pulumi.IntInput) GetTopicsInstanceListOutput
func (GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutput ¶
func (o GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutput() GetTopicsInstanceListArrayOutput
func (GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutputWithContext ¶
func (o GetTopicsInstanceListArrayOutput) ToGetTopicsInstanceListArrayOutputWithContext(ctx context.Context) GetTopicsInstanceListArrayOutput
type GetTopicsInstanceListInput ¶
type GetTopicsInstanceListInput interface { pulumi.Input ToGetTopicsInstanceListOutput() GetTopicsInstanceListOutput ToGetTopicsInstanceListOutputWithContext(context.Context) GetTopicsInstanceListOutput }
GetTopicsInstanceListInput is an input type that accepts GetTopicsInstanceListArgs and GetTopicsInstanceListOutput values. You can construct a concrete instance of `GetTopicsInstanceListInput` via:
GetTopicsInstanceListArgs{...}
type GetTopicsInstanceListOutput ¶
type GetTopicsInstanceListOutput struct{ *pulumi.OutputState }
func (GetTopicsInstanceListOutput) CleanUpPolicy ¶
func (o GetTopicsInstanceListOutput) CleanUpPolicy() pulumi.StringOutput
Clear log policy, log clear mode. `delete`: logs are deleted according to the storage time, `compact`: logs are compressed according to the key, `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
func (GetTopicsInstanceListOutput) CreateTime ¶
func (o GetTopicsInstanceListOutput) CreateTime() pulumi.StringOutput
Create time of the CKafka topic.
func (GetTopicsInstanceListOutput) ElementType ¶
func (GetTopicsInstanceListOutput) ElementType() reflect.Type
func (GetTopicsInstanceListOutput) EnableWhiteList ¶
func (o GetTopicsInstanceListOutput) EnableWhiteList() pulumi.BoolOutput
Whether to open the IP Whitelist. `true`: open, `false`: close.
func (GetTopicsInstanceListOutput) ForwardCosBucket ¶
func (o GetTopicsInstanceListOutput) ForwardCosBucket() pulumi.StringOutput
Data backup cos bucket: the bucket address that is dumped to cos.
func (GetTopicsInstanceListOutput) ForwardInterval ¶
func (o GetTopicsInstanceListOutput) ForwardInterval() pulumi.IntOutput
Periodic frequency of data backup to cos.
func (GetTopicsInstanceListOutput) ForwardStatus ¶
func (o GetTopicsInstanceListOutput) ForwardStatus() pulumi.IntOutput
Data backup cos status. `1`: do not open data backup, `0`: open data backup.
func (GetTopicsInstanceListOutput) IpWhiteListCount ¶
func (o GetTopicsInstanceListOutput) IpWhiteListCount() pulumi.IntOutput
IP Whitelist count.
func (GetTopicsInstanceListOutput) MaxMessageBytes ¶
func (o GetTopicsInstanceListOutput) MaxMessageBytes() pulumi.IntOutput
Max message bytes.
func (GetTopicsInstanceListOutput) Note ¶
func (o GetTopicsInstanceListOutput) Note() pulumi.StringOutput
CKafka topic note description.
func (GetTopicsInstanceListOutput) PartitionNum ¶
func (o GetTopicsInstanceListOutput) PartitionNum() pulumi.IntOutput
The number of partition.
func (GetTopicsInstanceListOutput) ReplicaNum ¶
func (o GetTopicsInstanceListOutput) ReplicaNum() pulumi.IntOutput
The number of replica.
func (GetTopicsInstanceListOutput) Retention ¶
func (o GetTopicsInstanceListOutput) Retention() pulumi.IntOutput
Message can be selected. Retention time(unit ms).
func (GetTopicsInstanceListOutput) Segment ¶
func (o GetTopicsInstanceListOutput) Segment() pulumi.IntOutput
Segment scrolling time, in ms.
func (GetTopicsInstanceListOutput) SegmentBytes ¶
func (o GetTopicsInstanceListOutput) SegmentBytes() pulumi.IntOutput
Number of bytes rolled by shard.
func (GetTopicsInstanceListOutput) SyncReplicaMinNum ¶
func (o GetTopicsInstanceListOutput) SyncReplicaMinNum() pulumi.IntOutput
Min number of sync replicas.
func (GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutput ¶
func (o GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutput() GetTopicsInstanceListOutput
func (GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutputWithContext ¶
func (o GetTopicsInstanceListOutput) ToGetTopicsInstanceListOutputWithContext(ctx context.Context) GetTopicsInstanceListOutput
func (GetTopicsInstanceListOutput) TopicId ¶
func (o GetTopicsInstanceListOutput) TopicId() pulumi.StringOutput
ID of the CKafka topic.
func (GetTopicsInstanceListOutput) TopicName ¶
func (o GetTopicsInstanceListOutput) TopicName() pulumi.StringOutput
Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64.
func (GetTopicsInstanceListOutput) UncleanLeaderElectionEnable ¶
func (o GetTopicsInstanceListOutput) UncleanLeaderElectionEnable() pulumi.BoolOutput
Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed.
type GetTopicsOutputArgs ¶
type GetTopicsOutputArgs struct { // Ckafka instance ID. InstanceId pulumi.StringInput `pulumi:"instanceId"` // Used to store results. ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"` // Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). The length range is from 1 to 64. TopicName pulumi.StringPtrInput `pulumi:"topicName"` }
A collection of arguments for invoking getTopics.
func (GetTopicsOutputArgs) ElementType ¶
func (GetTopicsOutputArgs) ElementType() reflect.Type
type GetTopicsResult ¶
type GetTopicsResult struct { // The provider-assigned unique ID for this managed resource. Id string `pulumi:"id"` InstanceId string `pulumi:"instanceId"` // A list of instances. Each element contains the following attributes. InstanceLists []GetTopicsInstanceList `pulumi:"instanceLists"` ResultOutputFile *string `pulumi:"resultOutputFile"` // Name of the CKafka topic. TopicName *string `pulumi:"topicName"` }
A collection of values returned by getTopics.
func GetTopics ¶
func GetTopics(ctx *pulumi.Context, args *GetTopicsArgs, opts ...pulumi.InvokeOption) (*GetTopicsResult, error)
Use this data source to query detailed information of ckafka topic.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi/sdk/v3/go/pulumi" "github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := Ckafka.NewTopic(ctx, "foo", &Ckafka.TopicArgs{ CleanUpPolicy: pulumi.String("delete"), EnableWhiteList: pulumi.Bool(true), InstanceId: pulumi.String("ckafka-f9ife4zz"), IpWhiteLists: pulumi.StringArray{ pulumi.String("ip1"), pulumi.String("ip2"), }, MaxMessageBytes: pulumi.Int(0), Note: pulumi.String("topic note"), PartitionNum: pulumi.Int(1), ReplicaNum: pulumi.Int(2), Retention: pulumi.Int(60000), Segment: pulumi.Int(3600000), SyncReplicaMinNum: pulumi.Int(1), TopicName: pulumi.String("example"), UncleanLeaderElectionEnable: pulumi.Bool(false), }) if err != nil { return err } return nil }) }
```
type GetTopicsResultOutput ¶
type GetTopicsResultOutput struct{ *pulumi.OutputState }
A collection of values returned by getTopics.
func GetTopicsOutput ¶
func GetTopicsOutput(ctx *pulumi.Context, args GetTopicsOutputArgs, opts ...pulumi.InvokeOption) GetTopicsResultOutput
func (GetTopicsResultOutput) ElementType ¶
func (GetTopicsResultOutput) ElementType() reflect.Type
func (GetTopicsResultOutput) Id ¶
func (o GetTopicsResultOutput) Id() pulumi.StringOutput
The provider-assigned unique ID for this managed resource.
func (GetTopicsResultOutput) InstanceId ¶
func (o GetTopicsResultOutput) InstanceId() pulumi.StringOutput
func (GetTopicsResultOutput) InstanceLists ¶
func (o GetTopicsResultOutput) InstanceLists() GetTopicsInstanceListArrayOutput
A list of instances. Each element contains the following attributes.
func (GetTopicsResultOutput) ResultOutputFile ¶
func (o GetTopicsResultOutput) ResultOutputFile() pulumi.StringPtrOutput
func (GetTopicsResultOutput) ToGetTopicsResultOutput ¶
func (o GetTopicsResultOutput) ToGetTopicsResultOutput() GetTopicsResultOutput
func (GetTopicsResultOutput) ToGetTopicsResultOutputWithContext ¶
func (o GetTopicsResultOutput) ToGetTopicsResultOutputWithContext(ctx context.Context) GetTopicsResultOutput
func (GetTopicsResultOutput) TopicName ¶
func (o GetTopicsResultOutput) TopicName() pulumi.StringPtrOutput
Name of the CKafka topic.
type GetUsersArgs ¶
type GetUsersArgs struct { // Account name used when query ckafka users' infos. Could be a substr of user name. AccountName *string `pulumi:"accountName"` // Id of the ckafka instance. InstanceId string `pulumi:"instanceId"` // Used to save results. ResultOutputFile *string `pulumi:"resultOutputFile"` }
A collection of arguments for invoking getUsers.
type GetUsersOutputArgs ¶
type GetUsersOutputArgs struct { // Account name used when query ckafka users' infos. Could be a substr of user name. AccountName pulumi.StringPtrInput `pulumi:"accountName"` // Id of the ckafka instance. InstanceId pulumi.StringInput `pulumi:"instanceId"` // Used to save results. ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"` }
A collection of arguments for invoking getUsers.
func (GetUsersOutputArgs) ElementType ¶
func (GetUsersOutputArgs) ElementType() reflect.Type
type GetUsersResult ¶
type GetUsersResult struct { // Account name of user. AccountName *string `pulumi:"accountName"` // The provider-assigned unique ID for this managed resource. Id string `pulumi:"id"` InstanceId string `pulumi:"instanceId"` ResultOutputFile *string `pulumi:"resultOutputFile"` // A list of ckafka users. Each element contains the following attributes: UserLists []GetUsersUserList `pulumi:"userLists"` }
A collection of values returned by getUsers.
func GetUsers ¶
func GetUsers(ctx *pulumi.Context, args *GetUsersArgs, opts ...pulumi.InvokeOption) (*GetUsersResult, error)
Use this data source to query detailed user information of Ckafka
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka" "github.com/pulumi/pulumi/sdk/v3/go/pulumi" "github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := Ckafka.GetUsers(ctx, &ckafka.GetUsersArgs{ AccountName: pulumi.StringRef("test"), InstanceId: "ckafka-f9ife4zz", }, nil) if err != nil { return err } return nil }) }
```
type GetUsersResultOutput ¶
type GetUsersResultOutput struct{ *pulumi.OutputState }
A collection of values returned by getUsers.
func GetUsersOutput ¶
func GetUsersOutput(ctx *pulumi.Context, args GetUsersOutputArgs, opts ...pulumi.InvokeOption) GetUsersResultOutput
func (GetUsersResultOutput) AccountName ¶
func (o GetUsersResultOutput) AccountName() pulumi.StringPtrOutput
Account name of user.
func (GetUsersResultOutput) ElementType ¶
func (GetUsersResultOutput) ElementType() reflect.Type
func (GetUsersResultOutput) Id ¶
func (o GetUsersResultOutput) Id() pulumi.StringOutput
The provider-assigned unique ID for this managed resource.
func (GetUsersResultOutput) InstanceId ¶
func (o GetUsersResultOutput) InstanceId() pulumi.StringOutput
func (GetUsersResultOutput) ResultOutputFile ¶
func (o GetUsersResultOutput) ResultOutputFile() pulumi.StringPtrOutput
func (GetUsersResultOutput) ToGetUsersResultOutput ¶
func (o GetUsersResultOutput) ToGetUsersResultOutput() GetUsersResultOutput
func (GetUsersResultOutput) ToGetUsersResultOutputWithContext ¶
func (o GetUsersResultOutput) ToGetUsersResultOutputWithContext(ctx context.Context) GetUsersResultOutput
func (GetUsersResultOutput) UserLists ¶
func (o GetUsersResultOutput) UserLists() GetUsersUserListArrayOutput
A list of ckafka users. Each element contains the following attributes:
type GetUsersUserList ¶
type GetUsersUserList struct { // Account name used when query ckafka users' infos. Could be a substr of user name. AccountName string `pulumi:"accountName"` // Creation time of the account. CreateTime string `pulumi:"createTime"` // The last update time of the account. UpdateTime string `pulumi:"updateTime"` }
type GetUsersUserListArgs ¶
type GetUsersUserListArgs struct { // Account name used when query ckafka users' infos. Could be a substr of user name. AccountName pulumi.StringInput `pulumi:"accountName"` // Creation time of the account. CreateTime pulumi.StringInput `pulumi:"createTime"` // The last update time of the account. UpdateTime pulumi.StringInput `pulumi:"updateTime"` }
func (GetUsersUserListArgs) ElementType ¶
func (GetUsersUserListArgs) ElementType() reflect.Type
func (GetUsersUserListArgs) ToGetUsersUserListOutput ¶
func (i GetUsersUserListArgs) ToGetUsersUserListOutput() GetUsersUserListOutput
func (GetUsersUserListArgs) ToGetUsersUserListOutputWithContext ¶
func (i GetUsersUserListArgs) ToGetUsersUserListOutputWithContext(ctx context.Context) GetUsersUserListOutput
type GetUsersUserListArray ¶
type GetUsersUserListArray []GetUsersUserListInput
func (GetUsersUserListArray) ElementType ¶
func (GetUsersUserListArray) ElementType() reflect.Type
func (GetUsersUserListArray) ToGetUsersUserListArrayOutput ¶
func (i GetUsersUserListArray) ToGetUsersUserListArrayOutput() GetUsersUserListArrayOutput
func (GetUsersUserListArray) ToGetUsersUserListArrayOutputWithContext ¶
func (i GetUsersUserListArray) ToGetUsersUserListArrayOutputWithContext(ctx context.Context) GetUsersUserListArrayOutput
type GetUsersUserListArrayInput ¶
type GetUsersUserListArrayInput interface { pulumi.Input ToGetUsersUserListArrayOutput() GetUsersUserListArrayOutput ToGetUsersUserListArrayOutputWithContext(context.Context) GetUsersUserListArrayOutput }
GetUsersUserListArrayInput is an input type that accepts GetUsersUserListArray and GetUsersUserListArrayOutput values. You can construct a concrete instance of `GetUsersUserListArrayInput` via:
GetUsersUserListArray{ GetUsersUserListArgs{...} }
type GetUsersUserListArrayOutput ¶
type GetUsersUserListArrayOutput struct{ *pulumi.OutputState }
func (GetUsersUserListArrayOutput) ElementType ¶
func (GetUsersUserListArrayOutput) ElementType() reflect.Type
func (GetUsersUserListArrayOutput) Index ¶
func (o GetUsersUserListArrayOutput) Index(i pulumi.IntInput) GetUsersUserListOutput
func (GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutput ¶
func (o GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutput() GetUsersUserListArrayOutput
func (GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutputWithContext ¶
func (o GetUsersUserListArrayOutput) ToGetUsersUserListArrayOutputWithContext(ctx context.Context) GetUsersUserListArrayOutput
type GetUsersUserListInput ¶
type GetUsersUserListInput interface { pulumi.Input ToGetUsersUserListOutput() GetUsersUserListOutput ToGetUsersUserListOutputWithContext(context.Context) GetUsersUserListOutput }
GetUsersUserListInput is an input type that accepts GetUsersUserListArgs and GetUsersUserListOutput values. You can construct a concrete instance of `GetUsersUserListInput` via:
GetUsersUserListArgs{...}
type GetUsersUserListOutput ¶
type GetUsersUserListOutput struct{ *pulumi.OutputState }
func (GetUsersUserListOutput) AccountName ¶
func (o GetUsersUserListOutput) AccountName() pulumi.StringOutput
Account name used when query ckafka users' infos. Could be a substr of user name.
func (GetUsersUserListOutput) CreateTime ¶
func (o GetUsersUserListOutput) CreateTime() pulumi.StringOutput
Creation time of the account.
func (GetUsersUserListOutput) ElementType ¶
func (GetUsersUserListOutput) ElementType() reflect.Type
func (GetUsersUserListOutput) ToGetUsersUserListOutput ¶
func (o GetUsersUserListOutput) ToGetUsersUserListOutput() GetUsersUserListOutput
func (GetUsersUserListOutput) ToGetUsersUserListOutputWithContext ¶
func (o GetUsersUserListOutput) ToGetUsersUserListOutputWithContext(ctx context.Context) GetUsersUserListOutput
func (GetUsersUserListOutput) UpdateTime ¶
func (o GetUsersUserListOutput) UpdateTime() pulumi.StringOutput
The last update time of the account.
type Instance ¶
type Instance struct { pulumi.CustomResourceState // Instance bandwidth in MBps. BandWidth pulumi.IntOutput `pulumi:"bandWidth"` // Instance configuration. Config InstanceConfigPtrOutput `pulumi:"config"` // Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created. DiskSize pulumi.IntOutput `pulumi:"diskSize"` // Type of disk. DiskType pulumi.StringOutput `pulumi:"diskType"` // Dynamic message retention policy configuration. DynamicRetentionConfig InstanceDynamicRetentionConfigOutput `pulumi:"dynamicRetentionConfig"` // Instance name. InstanceName pulumi.StringOutput `pulumi:"instanceName"` // Kafka version (0.10.2/1.1.1/2.4.1). KafkaVersion pulumi.StringOutput `pulumi:"kafkaVersion"` // The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled. MsgRetentionTime pulumi.IntOutput `pulumi:"msgRetentionTime"` // Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together. MultiZoneFlag pulumi.BoolPtrOutput `pulumi:"multiZoneFlag"` // Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created. Partition pulumi.IntOutput `pulumi:"partition"` // Prepaid purchase time, such as 1, is one month. Period pulumi.IntPtrOutput `pulumi:"period"` // Timestamp. PublicNetwork pulumi.IntOutput `pulumi:"publicNetwork"` // Modification of the rebalancing time after upgrade. RebalanceTime pulumi.IntPtrOutput `pulumi:"rebalanceTime"` // Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting). RenewFlag pulumi.IntOutput `pulumi:"renewFlag"` // Subnet id. SubnetId pulumi.StringOutput `pulumi:"subnetId"` // Partition size, the professional version does not need tag. Tags InstanceTagArrayOutput `pulumi:"tags"` // Vip of instance. Vip pulumi.StringOutput `pulumi:"vip"` // Vpc id. VpcId pulumi.StringOutput `pulumi:"vpcId"` // Type of instance. Vport pulumi.StringOutput `pulumi:"vport"` // Available zone id. ZoneId pulumi.IntOutput `pulumi:"zoneId"` // List of available zone id. NOTE: this argument must set together with `multiZoneFlag`. ZoneIds pulumi.IntArrayOutput `pulumi:"zoneIds"` }
Use this resource to create ckafka instance.
> **NOTE:** It only support create profession ckafka instance.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka" "github.com/pulumi/pulumi/sdk/v3/go/pulumi" "github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := Ckafka.NewInstance(ctx, "foo", &Ckafka.InstanceArgs{ BandWidth: pulumi.Int(40), Config: &ckafka.InstanceConfigArgs{ AutoCreateTopicEnable: pulumi.Bool(true), DefaultNumPartitions: pulumi.Int(3), DefaultReplicationFactor: pulumi.Int(3), }, DiskSize: pulumi.Int(500), DiskType: pulumi.String("CLOUD_BASIC"), DynamicRetentionConfig: &ckafka.InstanceDynamicRetentionConfigArgs{ BottomRetention: pulumi.Int(0), DiskQuotaPercentage: pulumi.Int(0), Enable: pulumi.Int(1), StepForwardPercentage: pulumi.Int(0), }, InstanceName: pulumi.String("ckafka-instance-tf-test"), KafkaVersion: pulumi.String("1.1.1"), MsgRetentionTime: pulumi.Int(1300), MultiZoneFlag: pulumi.Bool(true), Partition: pulumi.Int(800), Period: pulumi.Int(1), PublicNetwork: pulumi.Int(3), RenewFlag: pulumi.Int(0), SubnetId: pulumi.String("subnet-4vwihrzk"), VpcId: pulumi.String("vpc-82p1t1nv"), ZoneId: pulumi.Int(100006), ZoneIds: pulumi.IntArray{ pulumi.Int(100006), pulumi.Int(100007), }, }) if err != nil { return err } return nil }) }
```
## Import
ckafka instance can be imported using the instance_id, e.g.
```sh
$ pulumi import tencentcloud:Ckafka/instance:Instance foo ckafka-f9ife4zz
```
func GetInstance ¶
func GetInstance(ctx *pulumi.Context, name string, id pulumi.IDInput, state *InstanceState, opts ...pulumi.ResourceOption) (*Instance, error)
GetInstance gets an existing Instance resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewInstance ¶
func NewInstance(ctx *pulumi.Context, name string, args *InstanceArgs, opts ...pulumi.ResourceOption) (*Instance, error)
NewInstance registers a new resource with the given unique name, arguments, and options.
func (*Instance) ElementType ¶
func (*Instance) ToInstanceOutput ¶
func (i *Instance) ToInstanceOutput() InstanceOutput
func (*Instance) ToInstanceOutputWithContext ¶
func (i *Instance) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput
type InstanceArgs ¶
type InstanceArgs struct { // Instance bandwidth in MBps. BandWidth pulumi.IntPtrInput // Instance configuration. Config InstanceConfigPtrInput // Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created. DiskSize pulumi.IntPtrInput // Type of disk. DiskType pulumi.StringPtrInput // Dynamic message retention policy configuration. DynamicRetentionConfig InstanceDynamicRetentionConfigPtrInput // Instance name. InstanceName pulumi.StringInput // Kafka version (0.10.2/1.1.1/2.4.1). KafkaVersion pulumi.StringPtrInput // The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled. MsgRetentionTime pulumi.IntPtrInput // Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together. MultiZoneFlag pulumi.BoolPtrInput // Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created. Partition pulumi.IntPtrInput // Prepaid purchase time, such as 1, is one month. Period pulumi.IntPtrInput // Timestamp. PublicNetwork pulumi.IntPtrInput // Modification of the rebalancing time after upgrade. RebalanceTime pulumi.IntPtrInput // Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting). RenewFlag pulumi.IntPtrInput // Subnet id. SubnetId pulumi.StringInput // Partition size, the professional version does not need tag. Tags InstanceTagArrayInput // Vpc id. VpcId pulumi.StringInput // Available zone id. ZoneId pulumi.IntInput // List of available zone id. NOTE: this argument must set together with `multiZoneFlag`. ZoneIds pulumi.IntArrayInput }
The set of arguments for constructing a Instance resource.
func (InstanceArgs) ElementType ¶
func (InstanceArgs) ElementType() reflect.Type
type InstanceArray ¶
type InstanceArray []InstanceInput
func (InstanceArray) ElementType ¶
func (InstanceArray) ElementType() reflect.Type
func (InstanceArray) ToInstanceArrayOutput ¶
func (i InstanceArray) ToInstanceArrayOutput() InstanceArrayOutput
func (InstanceArray) ToInstanceArrayOutputWithContext ¶
func (i InstanceArray) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput
type InstanceArrayInput ¶
type InstanceArrayInput interface { pulumi.Input ToInstanceArrayOutput() InstanceArrayOutput ToInstanceArrayOutputWithContext(context.Context) InstanceArrayOutput }
InstanceArrayInput is an input type that accepts InstanceArray and InstanceArrayOutput values. You can construct a concrete instance of `InstanceArrayInput` via:
InstanceArray{ InstanceArgs{...} }
type InstanceArrayOutput ¶
type InstanceArrayOutput struct{ *pulumi.OutputState }
func (InstanceArrayOutput) ElementType ¶
func (InstanceArrayOutput) ElementType() reflect.Type
func (InstanceArrayOutput) Index ¶
func (o InstanceArrayOutput) Index(i pulumi.IntInput) InstanceOutput
func (InstanceArrayOutput) ToInstanceArrayOutput ¶
func (o InstanceArrayOutput) ToInstanceArrayOutput() InstanceArrayOutput
func (InstanceArrayOutput) ToInstanceArrayOutputWithContext ¶
func (o InstanceArrayOutput) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput
type InstanceConfig ¶
type InstanceConfig struct { // Automatic creation. true: enabled, false: not enabled. AutoCreateTopicEnable bool `pulumi:"autoCreateTopicEnable"` // If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default. DefaultNumPartitions int `pulumi:"defaultNumPartitions"` // If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default. DefaultReplicationFactor int `pulumi:"defaultReplicationFactor"` }
type InstanceConfigArgs ¶
type InstanceConfigArgs struct { // Automatic creation. true: enabled, false: not enabled. AutoCreateTopicEnable pulumi.BoolInput `pulumi:"autoCreateTopicEnable"` // If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default. DefaultNumPartitions pulumi.IntInput `pulumi:"defaultNumPartitions"` // If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default. DefaultReplicationFactor pulumi.IntInput `pulumi:"defaultReplicationFactor"` }
func (InstanceConfigArgs) ElementType ¶
func (InstanceConfigArgs) ElementType() reflect.Type
func (InstanceConfigArgs) ToInstanceConfigOutput ¶
func (i InstanceConfigArgs) ToInstanceConfigOutput() InstanceConfigOutput
func (InstanceConfigArgs) ToInstanceConfigOutputWithContext ¶
func (i InstanceConfigArgs) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput
func (InstanceConfigArgs) ToInstanceConfigPtrOutput ¶
func (i InstanceConfigArgs) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
func (InstanceConfigArgs) ToInstanceConfigPtrOutputWithContext ¶
func (i InstanceConfigArgs) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
type InstanceConfigInput ¶
type InstanceConfigInput interface { pulumi.Input ToInstanceConfigOutput() InstanceConfigOutput ToInstanceConfigOutputWithContext(context.Context) InstanceConfigOutput }
InstanceConfigInput is an input type that accepts InstanceConfigArgs and InstanceConfigOutput values. You can construct a concrete instance of `InstanceConfigInput` via:
InstanceConfigArgs{...}
type InstanceConfigOutput ¶
type InstanceConfigOutput struct{ *pulumi.OutputState }
func (InstanceConfigOutput) AutoCreateTopicEnable ¶
func (o InstanceConfigOutput) AutoCreateTopicEnable() pulumi.BoolOutput
Automatic creation. true: enabled, false: not enabled.
func (InstanceConfigOutput) DefaultNumPartitions ¶
func (o InstanceConfigOutput) DefaultNumPartitions() pulumi.IntOutput
If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
func (InstanceConfigOutput) DefaultReplicationFactor ¶
func (o InstanceConfigOutput) DefaultReplicationFactor() pulumi.IntOutput
If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
func (InstanceConfigOutput) ElementType ¶
func (InstanceConfigOutput) ElementType() reflect.Type
func (InstanceConfigOutput) ToInstanceConfigOutput ¶
func (o InstanceConfigOutput) ToInstanceConfigOutput() InstanceConfigOutput
func (InstanceConfigOutput) ToInstanceConfigOutputWithContext ¶
func (o InstanceConfigOutput) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput
func (InstanceConfigOutput) ToInstanceConfigPtrOutput ¶
func (o InstanceConfigOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
func (InstanceConfigOutput) ToInstanceConfigPtrOutputWithContext ¶
func (o InstanceConfigOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
type InstanceConfigPtrInput ¶
type InstanceConfigPtrInput interface { pulumi.Input ToInstanceConfigPtrOutput() InstanceConfigPtrOutput ToInstanceConfigPtrOutputWithContext(context.Context) InstanceConfigPtrOutput }
InstanceConfigPtrInput is an input type that accepts InstanceConfigArgs, InstanceConfigPtr and InstanceConfigPtrOutput values. You can construct a concrete instance of `InstanceConfigPtrInput` via:
InstanceConfigArgs{...} or: nil
func InstanceConfigPtr ¶
func InstanceConfigPtr(v *InstanceConfigArgs) InstanceConfigPtrInput
type InstanceConfigPtrOutput ¶
type InstanceConfigPtrOutput struct{ *pulumi.OutputState }
func (InstanceConfigPtrOutput) AutoCreateTopicEnable ¶
func (o InstanceConfigPtrOutput) AutoCreateTopicEnable() pulumi.BoolPtrOutput
Automatic creation. true: enabled, false: not enabled.
func (InstanceConfigPtrOutput) DefaultNumPartitions ¶
func (o InstanceConfigPtrOutput) DefaultNumPartitions() pulumi.IntPtrOutput
If auto.create.topic.enable is set to true and this value is not set, 3 will be used by default.
func (InstanceConfigPtrOutput) DefaultReplicationFactor ¶
func (o InstanceConfigPtrOutput) DefaultReplicationFactor() pulumi.IntPtrOutput
If auto.create.topic.enable is set to true but this value is not set, 2 will be used by default.
func (InstanceConfigPtrOutput) Elem ¶
func (o InstanceConfigPtrOutput) Elem() InstanceConfigOutput
func (InstanceConfigPtrOutput) ElementType ¶
func (InstanceConfigPtrOutput) ElementType() reflect.Type
func (InstanceConfigPtrOutput) ToInstanceConfigPtrOutput ¶
func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
func (InstanceConfigPtrOutput) ToInstanceConfigPtrOutputWithContext ¶
func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
type InstanceDynamicRetentionConfig ¶
type InstanceDynamicRetentionConfig struct { // Minimum retention time, in minutes. BottomRetention *int `pulumi:"bottomRetention"` // Disk quota threshold (in percentage) for triggering the message retention time change event. DiskQuotaPercentage *int `pulumi:"diskQuotaPercentage"` // Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled. Enable *int `pulumi:"enable"` // Percentage by which the message retention time is shortened each time. StepForwardPercentage *int `pulumi:"stepForwardPercentage"` }
type InstanceDynamicRetentionConfigArgs ¶
type InstanceDynamicRetentionConfigArgs struct { // Minimum retention time, in minutes. BottomRetention pulumi.IntPtrInput `pulumi:"bottomRetention"` // Disk quota threshold (in percentage) for triggering the message retention time change event. DiskQuotaPercentage pulumi.IntPtrInput `pulumi:"diskQuotaPercentage"` // Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled. Enable pulumi.IntPtrInput `pulumi:"enable"` // Percentage by which the message retention time is shortened each time. StepForwardPercentage pulumi.IntPtrInput `pulumi:"stepForwardPercentage"` }
func (InstanceDynamicRetentionConfigArgs) ElementType ¶
func (InstanceDynamicRetentionConfigArgs) ElementType() reflect.Type
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutput ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutputWithContext ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutput ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutputWithContext ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
type InstanceDynamicRetentionConfigInput ¶
type InstanceDynamicRetentionConfigInput interface { pulumi.Input ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput ToInstanceDynamicRetentionConfigOutputWithContext(context.Context) InstanceDynamicRetentionConfigOutput }
InstanceDynamicRetentionConfigInput is an input type that accepts InstanceDynamicRetentionConfigArgs and InstanceDynamicRetentionConfigOutput values. You can construct a concrete instance of `InstanceDynamicRetentionConfigInput` via:
InstanceDynamicRetentionConfigArgs{...}
type InstanceDynamicRetentionConfigOutput ¶
type InstanceDynamicRetentionConfigOutput struct{ *pulumi.OutputState }
func (InstanceDynamicRetentionConfigOutput) BottomRetention ¶
func (o InstanceDynamicRetentionConfigOutput) BottomRetention() pulumi.IntPtrOutput
Minimum retention time, in minutes.
func (InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage ¶
func (o InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage() pulumi.IntPtrOutput
Disk quota threshold (in percentage) for triggering the message retention time change event.
func (InstanceDynamicRetentionConfigOutput) ElementType ¶
func (InstanceDynamicRetentionConfigOutput) ElementType() reflect.Type
func (InstanceDynamicRetentionConfigOutput) Enable ¶
func (o InstanceDynamicRetentionConfigOutput) Enable() pulumi.IntPtrOutput
Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
func (InstanceDynamicRetentionConfigOutput) StepForwardPercentage ¶
func (o InstanceDynamicRetentionConfigOutput) StepForwardPercentage() pulumi.IntPtrOutput
Percentage by which the message retention time is shortened each time.
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutput ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutputWithContext ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutput ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
type InstanceDynamicRetentionConfigPtrInput ¶
type InstanceDynamicRetentionConfigPtrInput interface { pulumi.Input ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput ToInstanceDynamicRetentionConfigPtrOutputWithContext(context.Context) InstanceDynamicRetentionConfigPtrOutput }
InstanceDynamicRetentionConfigPtrInput is an input type that accepts InstanceDynamicRetentionConfigArgs, InstanceDynamicRetentionConfigPtr and InstanceDynamicRetentionConfigPtrOutput values. You can construct a concrete instance of `InstanceDynamicRetentionConfigPtrInput` via:
InstanceDynamicRetentionConfigArgs{...} or: nil
func InstanceDynamicRetentionConfigPtr ¶
func InstanceDynamicRetentionConfigPtr(v *InstanceDynamicRetentionConfigArgs) InstanceDynamicRetentionConfigPtrInput
type InstanceDynamicRetentionConfigPtrOutput ¶
type InstanceDynamicRetentionConfigPtrOutput struct{ *pulumi.OutputState }
func (InstanceDynamicRetentionConfigPtrOutput) BottomRetention ¶
func (o InstanceDynamicRetentionConfigPtrOutput) BottomRetention() pulumi.IntPtrOutput
Minimum retention time, in minutes.
func (InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage ¶
func (o InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage() pulumi.IntPtrOutput
Disk quota threshold (in percentage) for triggering the message retention time change event.
func (InstanceDynamicRetentionConfigPtrOutput) ElementType ¶
func (InstanceDynamicRetentionConfigPtrOutput) ElementType() reflect.Type
func (InstanceDynamicRetentionConfigPtrOutput) Enable ¶
func (o InstanceDynamicRetentionConfigPtrOutput) Enable() pulumi.IntPtrOutput
Whether the dynamic message retention time configuration is enabled. 0: disabled; 1: enabled.
func (InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage ¶
func (o InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage() pulumi.IntPtrOutput
Percentage by which the message retention time is shortened each time.
func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput ¶
func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext ¶
func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
type InstanceInput ¶
type InstanceInput interface { pulumi.Input ToInstanceOutput() InstanceOutput ToInstanceOutputWithContext(ctx context.Context) InstanceOutput }
type InstanceMap ¶
type InstanceMap map[string]InstanceInput
func (InstanceMap) ElementType ¶
func (InstanceMap) ElementType() reflect.Type
func (InstanceMap) ToInstanceMapOutput ¶
func (i InstanceMap) ToInstanceMapOutput() InstanceMapOutput
func (InstanceMap) ToInstanceMapOutputWithContext ¶
func (i InstanceMap) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput
type InstanceMapInput ¶
type InstanceMapInput interface { pulumi.Input ToInstanceMapOutput() InstanceMapOutput ToInstanceMapOutputWithContext(context.Context) InstanceMapOutput }
InstanceMapInput is an input type that accepts InstanceMap and InstanceMapOutput values. You can construct a concrete instance of `InstanceMapInput` via:
InstanceMap{ "key": InstanceArgs{...} }
type InstanceMapOutput ¶
type InstanceMapOutput struct{ *pulumi.OutputState }
func (InstanceMapOutput) ElementType ¶
func (InstanceMapOutput) ElementType() reflect.Type
func (InstanceMapOutput) MapIndex ¶
func (o InstanceMapOutput) MapIndex(k pulumi.StringInput) InstanceOutput
func (InstanceMapOutput) ToInstanceMapOutput ¶
func (o InstanceMapOutput) ToInstanceMapOutput() InstanceMapOutput
func (InstanceMapOutput) ToInstanceMapOutputWithContext ¶
func (o InstanceMapOutput) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput
type InstanceOutput ¶
type InstanceOutput struct{ *pulumi.OutputState }
func (InstanceOutput) BandWidth ¶
func (o InstanceOutput) BandWidth() pulumi.IntOutput
Instance bandwidth in MBps.
func (InstanceOutput) Config ¶
func (o InstanceOutput) Config() InstanceConfigPtrOutput
Instance configuration.
func (InstanceOutput) DiskSize ¶
func (o InstanceOutput) DiskSize() pulumi.IntOutput
Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
func (InstanceOutput) DiskType ¶
func (o InstanceOutput) DiskType() pulumi.StringOutput
Type of disk.
func (InstanceOutput) DynamicRetentionConfig ¶
func (o InstanceOutput) DynamicRetentionConfig() InstanceDynamicRetentionConfigOutput
Dynamic message retention policy configuration.
func (InstanceOutput) ElementType ¶
func (InstanceOutput) ElementType() reflect.Type
func (InstanceOutput) InstanceName ¶
func (o InstanceOutput) InstanceName() pulumi.StringOutput
Instance name.
func (InstanceOutput) KafkaVersion ¶
func (o InstanceOutput) KafkaVersion() pulumi.StringOutput
Kafka version (0.10.2/1.1.1/2.4.1).
func (InstanceOutput) MsgRetentionTime ¶
func (o InstanceOutput) MsgRetentionTime() pulumi.IntOutput
The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
func (InstanceOutput) MultiZoneFlag ¶
func (o InstanceOutput) MultiZoneFlag() pulumi.BoolPtrOutput
Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together.
func (InstanceOutput) Partition ¶
func (o InstanceOutput) Partition() pulumi.IntOutput
Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
func (InstanceOutput) Period ¶
func (o InstanceOutput) Period() pulumi.IntPtrOutput
Prepaid purchase time, such as 1, is one month.
func (InstanceOutput) PublicNetwork ¶
func (o InstanceOutput) PublicNetwork() pulumi.IntOutput
Timestamp.
func (InstanceOutput) RebalanceTime ¶
func (o InstanceOutput) RebalanceTime() pulumi.IntPtrOutput
Modification of the rebalancing time after upgrade.
func (InstanceOutput) RenewFlag ¶
func (o InstanceOutput) RenewFlag() pulumi.IntOutput
Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
func (InstanceOutput) 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) ZoneIds ¶
func (o InstanceOutput) ZoneIds() pulumi.IntArrayOutput
List of available zone id. NOTE: this argument must set together with `multiZoneFlag`.
type InstanceState ¶
type InstanceState struct { // Instance bandwidth in MBps. BandWidth pulumi.IntPtrInput // Instance configuration. Config InstanceConfigPtrInput // Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created. DiskSize pulumi.IntPtrInput // Type of disk. DiskType pulumi.StringPtrInput // Dynamic message retention policy configuration. DynamicRetentionConfig InstanceDynamicRetentionConfigPtrInput // Instance name. InstanceName pulumi.StringPtrInput // Kafka version (0.10.2/1.1.1/2.4.1). KafkaVersion pulumi.StringPtrInput // The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled. MsgRetentionTime pulumi.IntPtrInput // Indicates whether the instance is multi zones. NOTE: if set to `true`, `zoneIds` must set together. MultiZoneFlag pulumi.BoolPtrInput // Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created. Partition pulumi.IntPtrInput // Prepaid purchase time, such as 1, is one month. Period pulumi.IntPtrInput // Timestamp. PublicNetwork pulumi.IntPtrInput // Modification of the rebalancing time after upgrade. RebalanceTime pulumi.IntPtrInput // Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting). RenewFlag pulumi.IntPtrInput // Subnet id. SubnetId pulumi.StringPtrInput // Partition size, the professional version does not need tag. Tags InstanceTagArrayInput // Vip of instance. Vip pulumi.StringPtrInput // Vpc id. VpcId pulumi.StringPtrInput // Type of instance. Vport pulumi.StringPtrInput // Available zone id. ZoneId pulumi.IntPtrInput // List of available zone id. NOTE: this argument must set together with `multiZoneFlag`. ZoneIds pulumi.IntArrayInput }
func (InstanceState) ElementType ¶
func (InstanceState) ElementType() reflect.Type
type InstanceTag ¶
type 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) ToInstanceTagOutput ¶
func (o InstanceTagOutput) ToInstanceTagOutput() InstanceTagOutput
func (InstanceTagOutput) ToInstanceTagOutputWithContext ¶
func (o InstanceTagOutput) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput
type Topic ¶
type Topic struct { pulumi.CustomResourceState // Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time. CleanUpPolicy pulumi.StringPtrOutput `pulumi:"cleanUpPolicy"` // Create time of the CKafka topic. CreateTime pulumi.StringOutput `pulumi:"createTime"` // Whether to open the ip whitelist, `true`: open, `false`: close. EnableWhiteList pulumi.BoolPtrOutput `pulumi:"enableWhiteList"` // Data backup cos bucket: the bucket address that is dumped to cos. ForwardCosBucket pulumi.StringOutput `pulumi:"forwardCosBucket"` // Periodic frequency of data backup to cos. ForwardInterval pulumi.IntOutput `pulumi:"forwardInterval"` // Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup. ForwardStatus pulumi.IntOutput `pulumi:"forwardStatus"` // Ckafka instance ID. InstanceId pulumi.StringOutput `pulumi:"instanceId"` // Ip whitelist, quota limit, required when enableWhileList=true. IpWhiteLists pulumi.StringArrayOutput `pulumi:"ipWhiteLists"` // Max message bytes. MaxMessageBytes pulumi.IntPtrOutput `pulumi:"maxMessageBytes"` // Message storage location. MessageStorageLocation pulumi.StringOutput `pulumi:"messageStorageLocation"` // The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-). Note pulumi.StringPtrOutput `pulumi:"note"` // The number of partition. PartitionNum pulumi.IntOutput `pulumi:"partitionNum"` // The number of replica. ReplicaNum pulumi.IntOutput `pulumi:"replicaNum"` // Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms. Retention pulumi.IntPtrOutput `pulumi:"retention"` // Segment scrolling time, in ms, the current minimum is 3600000ms. Segment pulumi.IntPtrOutput `pulumi:"segment"` // Number of bytes rolled by shard. SegmentBytes pulumi.IntOutput `pulumi:"segmentBytes"` // Min number of sync replicas, Default is `1`. SyncReplicaMinNum pulumi.IntPtrOutput `pulumi:"syncReplicaMinNum"` // Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). TopicName pulumi.StringOutput `pulumi:"topicName"` // Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed. UncleanLeaderElectionEnable pulumi.BoolPtrOutput `pulumi:"uncleanLeaderElectionEnable"` }
Use this resource to create ckafka topic.
## Example Usage
```go package main
import (
"github.com/pulumi/pulumi/sdk/v3/go/pulumi" "github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := Ckafka.NewTopic(ctx, "foo", &Ckafka.TopicArgs{ CleanUpPolicy: pulumi.String("delete"), EnableWhiteList: pulumi.Bool(true), InstanceId: pulumi.String("ckafka-f9ife4zz"), IpWhiteLists: pulumi.StringArray{ pulumi.String("ip1"), pulumi.String("ip2"), }, MaxMessageBytes: pulumi.Int(0), Note: pulumi.String("topic note"), PartitionNum: pulumi.Int(1), ReplicaNum: pulumi.Int(2), Retention: pulumi.Int(60000), Segment: pulumi.Int(3600000), SyncReplicaMinNum: pulumi.Int(1), TopicName: pulumi.String("example"), UncleanLeaderElectionEnable: pulumi.Bool(false), }) if err != nil { return err } return nil }) }
```
## Import
ckafka topic can be imported using the instance_id#topic_name, e.g.
```sh
$ pulumi import tencentcloud:Ckafka/topic:Topic foo ckafka-f9ife4zz#example
```
func GetTopic ¶
func GetTopic(ctx *pulumi.Context, name string, id pulumi.IDInput, state *TopicState, opts ...pulumi.ResourceOption) (*Topic, error)
GetTopic gets an existing Topic resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewTopic ¶
func NewTopic(ctx *pulumi.Context, name string, args *TopicArgs, opts ...pulumi.ResourceOption) (*Topic, error)
NewTopic registers a new resource with the given unique name, arguments, and options.
func (*Topic) ElementType ¶
func (*Topic) 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 ¶
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) ToTopicMapOutput ¶
func (i TopicMap) ToTopicMapOutput() TopicMapOutput
func (TopicMap) ToTopicMapOutputWithContext ¶
func (i TopicMap) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput
type TopicMapInput ¶
type TopicMapInput interface { pulumi.Input ToTopicMapOutput() TopicMapOutput ToTopicMapOutputWithContext(context.Context) TopicMapOutput }
TopicMapInput is an input type that accepts TopicMap and TopicMapOutput values. You can construct a concrete instance of `TopicMapInput` via:
TopicMap{ "key": TopicArgs{...} }
type TopicMapOutput ¶
type TopicMapOutput struct{ *pulumi.OutputState }
func (TopicMapOutput) ElementType ¶
func (TopicMapOutput) ElementType() reflect.Type
func (TopicMapOutput) MapIndex ¶
func (o TopicMapOutput) MapIndex(k pulumi.StringInput) TopicOutput
func (TopicMapOutput) ToTopicMapOutput ¶
func (o TopicMapOutput) ToTopicMapOutput() TopicMapOutput
func (TopicMapOutput) ToTopicMapOutputWithContext ¶
func (o TopicMapOutput) ToTopicMapOutputWithContext(ctx context.Context) TopicMapOutput
type TopicOutput ¶
type TopicOutput struct{ *pulumi.OutputState }
func (TopicOutput) CleanUpPolicy ¶
func (o TopicOutput) CleanUpPolicy() pulumi.StringPtrOutput
Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time.
func (TopicOutput) CreateTime ¶
func (o TopicOutput) CreateTime() pulumi.StringOutput
Create time of the CKafka topic.
func (TopicOutput) ElementType ¶
func (TopicOutput) ElementType() reflect.Type
func (TopicOutput) EnableWhiteList ¶
func (o TopicOutput) EnableWhiteList() pulumi.BoolPtrOutput
Whether to open the ip whitelist, `true`: open, `false`: close.
func (TopicOutput) ForwardCosBucket ¶
func (o TopicOutput) ForwardCosBucket() pulumi.StringOutput
Data backup cos bucket: the bucket address that is dumped to cos.
func (TopicOutput) ForwardInterval ¶
func (o TopicOutput) ForwardInterval() pulumi.IntOutput
Periodic frequency of data backup to cos.
func (TopicOutput) ForwardStatus ¶
func (o TopicOutput) ForwardStatus() pulumi.IntOutput
Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup.
func (TopicOutput) InstanceId ¶
func (o TopicOutput) InstanceId() pulumi.StringOutput
Ckafka instance ID.
func (TopicOutput) IpWhiteLists ¶
func (o TopicOutput) IpWhiteLists() pulumi.StringArrayOutput
Ip whitelist, quota limit, required when enableWhileList=true.
func (TopicOutput) MaxMessageBytes ¶
func (o TopicOutput) MaxMessageBytes() pulumi.IntPtrOutput
Max message bytes.
func (TopicOutput) MessageStorageLocation ¶
func (o TopicOutput) MessageStorageLocation() pulumi.StringOutput
Message storage location.
func (TopicOutput) Note ¶
func (o TopicOutput) Note() pulumi.StringPtrOutput
The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-).
func (TopicOutput) PartitionNum ¶
func (o TopicOutput) PartitionNum() pulumi.IntOutput
The number of partition.
func (TopicOutput) ReplicaNum ¶
func (o TopicOutput) ReplicaNum() pulumi.IntOutput
The number of replica.
func (TopicOutput) Retention ¶
func (o TopicOutput) Retention() pulumi.IntPtrOutput
Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms.
func (TopicOutput) Segment ¶
func (o TopicOutput) Segment() pulumi.IntPtrOutput
Segment scrolling time, in ms, the current minimum is 3600000ms.
func (TopicOutput) SegmentBytes ¶
func (o TopicOutput) SegmentBytes() pulumi.IntOutput
Number of bytes rolled by shard.
func (TopicOutput) SyncReplicaMinNum ¶
func (o TopicOutput) SyncReplicaMinNum() pulumi.IntPtrOutput
Min number of sync replicas, Default is `1`.
func (TopicOutput) ToTopicOutput ¶
func (o TopicOutput) ToTopicOutput() TopicOutput
func (TopicOutput) ToTopicOutputWithContext ¶
func (o TopicOutput) ToTopicOutputWithContext(ctx context.Context) TopicOutput
func (TopicOutput) TopicName ¶
func (o TopicOutput) TopicName() pulumi.StringOutput
Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-).
func (TopicOutput) UncleanLeaderElectionEnable ¶
func (o TopicOutput) UncleanLeaderElectionEnable() pulumi.BoolPtrOutput
Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed.
type TopicState ¶
type TopicState struct { // Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and will be deleted according to the storage time. CleanUpPolicy pulumi.StringPtrInput // Create time of the CKafka topic. CreateTime pulumi.StringPtrInput // Whether to open the ip whitelist, `true`: open, `false`: close. EnableWhiteList pulumi.BoolPtrInput // Data backup cos bucket: the bucket address that is dumped to cos. ForwardCosBucket pulumi.StringPtrInput // Periodic frequency of data backup to cos. ForwardInterval pulumi.IntPtrInput // Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup. ForwardStatus pulumi.IntPtrInput // Ckafka instance ID. InstanceId pulumi.StringPtrInput // Ip whitelist, quota limit, required when enableWhileList=true. IpWhiteLists pulumi.StringArrayInput // Max message bytes. MaxMessageBytes pulumi.IntPtrInput // Message storage location. MessageStorageLocation pulumi.StringPtrInput // The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-). Note pulumi.StringPtrInput // The number of partition. PartitionNum pulumi.IntPtrInput // The number of replica. ReplicaNum pulumi.IntPtrInput // Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms. Retention pulumi.IntPtrInput // Segment scrolling time, in ms, the current minimum is 3600000ms. Segment pulumi.IntPtrInput // Number of bytes rolled by shard. SegmentBytes pulumi.IntPtrInput // Min number of sync replicas, Default is `1`. SyncReplicaMinNum pulumi.IntPtrInput // Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). TopicName pulumi.StringPtrInput // Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not allowed. UncleanLeaderElectionEnable pulumi.BoolPtrInput }
func (TopicState) ElementType ¶
func (TopicState) ElementType() reflect.Type
type User ¶
type User struct { pulumi.CustomResourceState // Account name used to access to ckafka instance. AccountName pulumi.StringOutput `pulumi:"accountName"` // Creation time of the account. CreateTime pulumi.StringOutput `pulumi:"createTime"` // ID of the ckafka instance. InstanceId pulumi.StringOutput `pulumi:"instanceId"` // Password of the account. Password pulumi.StringOutput `pulumi:"password"` // The last update time of the account. UpdateTime pulumi.StringOutput `pulumi:"updateTime"` }
Provides a resource to create a Ckafka user.
## Example Usage
Ckafka User ¶
```go package main
import (
"github.com/pulumi/pulumi/sdk/v3/go/pulumi" "github.com/tencentcloudstack/pulumi-tencentcloud/sdk/go/tencentcloud/Ckafka"
)
func main() { pulumi.Run(func(ctx *pulumi.Context) error { _, err := Ckafka.NewUser(ctx, "foo", &Ckafka.UserArgs{ AccountName: pulumi.String("tf-test"), InstanceId: pulumi.String("ckafka-f9ife4zz"), Password: pulumi.String("test1234"), }) if err != nil { return err } return nil }) }
```
## Import
Ckafka user can be imported using the instance_id#account_name, e.g.
```sh
$ pulumi import tencentcloud:Ckafka/user:User foo ckafka-f9ife4zz#tf-test
```
func GetUser ¶
func GetUser(ctx *pulumi.Context, name string, id pulumi.IDInput, state *UserState, opts ...pulumi.ResourceOption) (*User, error)
GetUser gets an existing User resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewUser ¶
func NewUser(ctx *pulumi.Context, name string, args *UserArgs, opts ...pulumi.ResourceOption) (*User, error)
NewUser registers a new resource with the given unique name, arguments, and options.
func (*User) ElementType ¶
func (*User) 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 ¶
type UserArray ¶
type UserArray []UserInput
func (UserArray) ElementType ¶
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 ¶
func (UserMap) ElementType ¶
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 }