Documentation ¶
Index ¶
- 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 AclsAclList
- type AclsAclListArgs
- type AclsAclListArray
- type AclsAclListArrayInput
- type AclsAclListArrayOutput
- func (AclsAclListArrayOutput) ElementType() reflect.Type
- func (o AclsAclListArrayOutput) Index(i pulumi.IntInput) AclsAclListOutput
- func (o AclsAclListArrayOutput) ToAclsAclListArrayOutput() AclsAclListArrayOutput
- func (o AclsAclListArrayOutput) ToAclsAclListArrayOutputWithContext(ctx context.Context) AclsAclListArrayOutput
- type AclsAclListInput
- type AclsAclListOutput
- func (AclsAclListOutput) ElementType() reflect.Type
- func (o AclsAclListOutput) Host() pulumi.StringOutput
- func (o AclsAclListOutput) OperationType() pulumi.StringOutput
- func (o AclsAclListOutput) PermissionType() pulumi.StringOutput
- func (o AclsAclListOutput) Principal() pulumi.StringOutput
- func (o AclsAclListOutput) ResourceName() pulumi.StringOutput
- func (o AclsAclListOutput) ResourceType() pulumi.StringOutput
- func (o AclsAclListOutput) ToAclsAclListOutput() AclsAclListOutput
- func (o AclsAclListOutput) ToAclsAclListOutputWithContext(ctx context.Context) AclsAclListOutput
- type AclsArgs
- type AclsOutputArgs
- type AclsResult
- type AclsResultOutput
- func (o AclsResultOutput) AclLists() AclsAclListArrayOutput
- func (AclsResultOutput) ElementType() reflect.Type
- func (o AclsResultOutput) Host() pulumi.StringPtrOutput
- func (o AclsResultOutput) Id() pulumi.StringOutput
- func (o AclsResultOutput) InstanceId() pulumi.StringOutput
- func (o AclsResultOutput) ResourceName() pulumi.StringOutput
- func (o AclsResultOutput) ResourceType() pulumi.StringOutput
- func (o AclsResultOutput) ResultOutputFile() pulumi.StringPtrOutput
- func (o AclsResultOutput) ToAclsResultOutput() AclsResultOutput
- func (o AclsResultOutput) ToAclsResultOutputWithContext(ctx context.Context) AclsResultOutput
- 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) VpcId() 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 TopicsArgs
- type TopicsInstanceList
- type TopicsInstanceListArgs
- type TopicsInstanceListArray
- type TopicsInstanceListArrayInput
- type TopicsInstanceListArrayOutput
- func (TopicsInstanceListArrayOutput) ElementType() reflect.Type
- func (o TopicsInstanceListArrayOutput) Index(i pulumi.IntInput) TopicsInstanceListOutput
- func (o TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutput() TopicsInstanceListArrayOutput
- func (o TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutputWithContext(ctx context.Context) TopicsInstanceListArrayOutput
- type TopicsInstanceListInput
- type TopicsInstanceListOutput
- func (o TopicsInstanceListOutput) CleanUpPolicy() pulumi.StringOutput
- func (o TopicsInstanceListOutput) CreateTime() pulumi.StringOutput
- func (TopicsInstanceListOutput) ElementType() reflect.Type
- func (o TopicsInstanceListOutput) EnableWhiteList() pulumi.BoolOutput
- func (o TopicsInstanceListOutput) ForwardCosBucket() pulumi.StringOutput
- func (o TopicsInstanceListOutput) ForwardInterval() pulumi.IntOutput
- func (o TopicsInstanceListOutput) ForwardStatus() pulumi.IntOutput
- func (o TopicsInstanceListOutput) IpWhiteListCount() pulumi.IntOutput
- func (o TopicsInstanceListOutput) MaxMessageBytes() pulumi.IntOutput
- func (o TopicsInstanceListOutput) Note() pulumi.StringOutput
- func (o TopicsInstanceListOutput) PartitionNum() pulumi.IntOutput
- func (o TopicsInstanceListOutput) ReplicaNum() pulumi.IntOutput
- func (o TopicsInstanceListOutput) Retention() pulumi.IntOutput
- func (o TopicsInstanceListOutput) Segment() pulumi.IntOutput
- func (o TopicsInstanceListOutput) SegmentBytes() pulumi.IntOutput
- func (o TopicsInstanceListOutput) SyncReplicaMinNum() pulumi.IntOutput
- func (o TopicsInstanceListOutput) ToTopicsInstanceListOutput() TopicsInstanceListOutput
- func (o TopicsInstanceListOutput) ToTopicsInstanceListOutputWithContext(ctx context.Context) TopicsInstanceListOutput
- func (o TopicsInstanceListOutput) TopicId() pulumi.StringOutput
- func (o TopicsInstanceListOutput) TopicName() pulumi.StringOutput
- func (o TopicsInstanceListOutput) UncleanLeaderElectionEnable() pulumi.BoolOutput
- type TopicsOutputArgs
- type TopicsResult
- type TopicsResultOutput
- func (TopicsResultOutput) ElementType() reflect.Type
- func (o TopicsResultOutput) Id() pulumi.StringOutput
- func (o TopicsResultOutput) InstanceId() pulumi.StringOutput
- func (o TopicsResultOutput) InstanceLists() TopicsInstanceListArrayOutput
- func (o TopicsResultOutput) ResultOutputFile() pulumi.StringPtrOutput
- func (o TopicsResultOutput) ToTopicsResultOutput() TopicsResultOutput
- func (o TopicsResultOutput) ToTopicsResultOutputWithContext(ctx context.Context) TopicsResultOutput
- func (o TopicsResultOutput) TopicName() pulumi.StringPtrOutput
- 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
- type UsersArgs
- type UsersOutputArgs
- type UsersResult
- type UsersResultOutput
- func (o UsersResultOutput) AccountName() pulumi.StringPtrOutput
- func (UsersResultOutput) ElementType() reflect.Type
- func (o UsersResultOutput) Id() pulumi.StringOutput
- func (o UsersResultOutput) InstanceId() pulumi.StringOutput
- func (o UsersResultOutput) ResultOutputFile() pulumi.StringPtrOutput
- func (o UsersResultOutput) ToUsersResultOutput() UsersResultOutput
- func (o UsersResultOutput) ToUsersResultOutputWithContext(ctx context.Context) UsersResultOutput
- func (o UsersResultOutput) UserLists() UsersUserListArrayOutput
- type UsersUserList
- type UsersUserListArgs
- type UsersUserListArray
- type UsersUserListArrayInput
- type UsersUserListArrayOutput
- func (UsersUserListArrayOutput) ElementType() reflect.Type
- func (o UsersUserListArrayOutput) Index(i pulumi.IntInput) UsersUserListOutput
- func (o UsersUserListArrayOutput) ToUsersUserListArrayOutput() UsersUserListArrayOutput
- func (o UsersUserListArrayOutput) ToUsersUserListArrayOutputWithContext(ctx context.Context) UsersUserListArrayOutput
- type UsersUserListInput
- type UsersUserListOutput
- func (o UsersUserListOutput) AccountName() pulumi.StringOutput
- func (o UsersUserListOutput) CreateTime() pulumi.StringOutput
- func (UsersUserListOutput) ElementType() reflect.Type
- func (o UsersUserListOutput) ToUsersUserListOutput() UsersUserListOutput
- func (o UsersUserListOutput) ToUsersUserListOutputWithContext(ctx context.Context) UsersUserListOutput
- func (o UsersUserListOutput) UpdateTime() pulumi.StringOutput
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Acl ¶
type Acl struct { pulumi.CustomResourceState // IP address allowed to access. The default value is `*`, which means that any host can access. Host pulumi.StringPtrOutput `pulumi:"host"` // ID of the ckafka instance. InstanceId pulumi.StringOutput `pulumi:"instanceId"` // ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, // `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`. OperationType pulumi.StringOutput `pulumi:"operationType"` // ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports // `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka. PermissionType pulumi.StringPtrOutput `pulumi:"permissionType"` // User list. The default value is `*`, which means that any user can access. The current user can only be one included in // the user list. Principal pulumi.StringPtrOutput `pulumi:"principal"` // ACL resource name, which is related to `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates // the topic name; if `resource_type` is `GROUP`, this field indicates the group name. ResourceName pulumi.StringOutput `pulumi:"resourceName"` // ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by // default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source // Kafka. ResourceType pulumi.StringPtrOutput `pulumi:"resourceType"` }
func GetAcl ¶
func GetAcl(ctx *pulumi.Context, name string, id pulumi.IDInput, state *AclState, opts ...pulumi.ResourceOption) (*Acl, error)
GetAcl gets an existing Acl resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewAcl ¶
func NewAcl(ctx *pulumi.Context, name string, args *AclArgs, opts ...pulumi.ResourceOption) (*Acl, error)
NewAcl registers a new resource with the given unique name, arguments, and options.
func (*Acl) ElementType ¶
func (*Acl) 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 `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates // the topic name; if `resource_type` is `GROUP`, this field indicates the group name. ResourceName pulumi.StringInput // ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by // default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source // Kafka. ResourceType pulumi.StringPtrInput }
The set of arguments for constructing a Acl resource.
func (AclArgs) ElementType ¶
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 `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates the topic name; if `resource_type` is `GROUP`, this field indicates the group name.
func (AclOutput) ResourceType ¶
func (o AclOutput) ResourceType() pulumi.StringPtrOutput
ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source Kafka.
func (AclOutput) ToAclOutput ¶
type AclState ¶
type AclState struct { // IP address allowed to access. The default value is `*`, which means that any host can access. Host pulumi.StringPtrInput // ID of the ckafka instance. InstanceId pulumi.StringPtrInput // ACL operation mode. Valid values: `UNKNOWN`, `ANY`, `ALL`, `READ`, `WRITE`, `CREATE`, `DELETE`, `ALTER`, `DESCRIBE`, // `CLUSTER_ACTION`, `DESCRIBE_CONFIGS` and `ALTER_CONFIGS`. OperationType pulumi.StringPtrInput // ACL permission type. Valid values: `UNKNOWN`, `ANY`, `DENY`, `ALLOW`. and `ALLOW` by default. Currently, CKafka supports // `ALLOW` (equivalent to allow list), and other fields will be used for future ACLs compatible with open-source Kafka. PermissionType pulumi.StringPtrInput // User list. The default value is `*`, which means that any user can access. The current user can only be one included in // the user list. Principal pulumi.StringPtrInput // ACL resource name, which is related to `resource_type`. For example, if `resource_type` is `TOPIC`, this field indicates // the topic name; if `resource_type` is `GROUP`, this field indicates the group name. ResourceName pulumi.StringPtrInput // ACL resource type. Valid values are `UNKNOWN`, `ANY`, `TOPIC`, `GROUP`, `CLUSTER`, `TRANSACTIONAL_ID`. and `TOPIC` by // default. Currently, only `TOPIC` is available, and other fields will be used for future ACLs compatible with open-source // Kafka. ResourceType pulumi.StringPtrInput }
func (AclState) ElementType ¶
type AclsAclList ¶
type AclsAclListArgs ¶
type AclsAclListArgs struct { Host pulumi.StringInput `pulumi:"host"` OperationType pulumi.StringInput `pulumi:"operationType"` PermissionType pulumi.StringInput `pulumi:"permissionType"` Principal pulumi.StringInput `pulumi:"principal"` ResourceName pulumi.StringInput `pulumi:"resourceName"` ResourceType pulumi.StringInput `pulumi:"resourceType"` }
func (AclsAclListArgs) ElementType ¶
func (AclsAclListArgs) ElementType() reflect.Type
func (AclsAclListArgs) ToAclsAclListOutput ¶
func (i AclsAclListArgs) ToAclsAclListOutput() AclsAclListOutput
func (AclsAclListArgs) ToAclsAclListOutputWithContext ¶
func (i AclsAclListArgs) ToAclsAclListOutputWithContext(ctx context.Context) AclsAclListOutput
type AclsAclListArray ¶
type AclsAclListArray []AclsAclListInput
func (AclsAclListArray) ElementType ¶
func (AclsAclListArray) ElementType() reflect.Type
func (AclsAclListArray) ToAclsAclListArrayOutput ¶
func (i AclsAclListArray) ToAclsAclListArrayOutput() AclsAclListArrayOutput
func (AclsAclListArray) ToAclsAclListArrayOutputWithContext ¶
func (i AclsAclListArray) ToAclsAclListArrayOutputWithContext(ctx context.Context) AclsAclListArrayOutput
type AclsAclListArrayInput ¶
type AclsAclListArrayInput interface { pulumi.Input ToAclsAclListArrayOutput() AclsAclListArrayOutput ToAclsAclListArrayOutputWithContext(context.Context) AclsAclListArrayOutput }
AclsAclListArrayInput is an input type that accepts AclsAclListArray and AclsAclListArrayOutput values. You can construct a concrete instance of `AclsAclListArrayInput` via:
AclsAclListArray{ AclsAclListArgs{...} }
type AclsAclListArrayOutput ¶
type AclsAclListArrayOutput struct{ *pulumi.OutputState }
func (AclsAclListArrayOutput) ElementType ¶
func (AclsAclListArrayOutput) ElementType() reflect.Type
func (AclsAclListArrayOutput) Index ¶
func (o AclsAclListArrayOutput) Index(i pulumi.IntInput) AclsAclListOutput
func (AclsAclListArrayOutput) ToAclsAclListArrayOutput ¶
func (o AclsAclListArrayOutput) ToAclsAclListArrayOutput() AclsAclListArrayOutput
func (AclsAclListArrayOutput) ToAclsAclListArrayOutputWithContext ¶
func (o AclsAclListArrayOutput) ToAclsAclListArrayOutputWithContext(ctx context.Context) AclsAclListArrayOutput
type AclsAclListInput ¶
type AclsAclListInput interface { pulumi.Input ToAclsAclListOutput() AclsAclListOutput ToAclsAclListOutputWithContext(context.Context) AclsAclListOutput }
AclsAclListInput is an input type that accepts AclsAclListArgs and AclsAclListOutput values. You can construct a concrete instance of `AclsAclListInput` via:
AclsAclListArgs{...}
type AclsAclListOutput ¶
type AclsAclListOutput struct{ *pulumi.OutputState }
func (AclsAclListOutput) ElementType ¶
func (AclsAclListOutput) ElementType() reflect.Type
func (AclsAclListOutput) Host ¶
func (o AclsAclListOutput) Host() pulumi.StringOutput
func (AclsAclListOutput) OperationType ¶
func (o AclsAclListOutput) OperationType() pulumi.StringOutput
func (AclsAclListOutput) PermissionType ¶
func (o AclsAclListOutput) PermissionType() pulumi.StringOutput
func (AclsAclListOutput) Principal ¶
func (o AclsAclListOutput) Principal() pulumi.StringOutput
func (AclsAclListOutput) ResourceName ¶
func (o AclsAclListOutput) ResourceName() pulumi.StringOutput
func (AclsAclListOutput) ResourceType ¶
func (o AclsAclListOutput) ResourceType() pulumi.StringOutput
func (AclsAclListOutput) ToAclsAclListOutput ¶
func (o AclsAclListOutput) ToAclsAclListOutput() AclsAclListOutput
func (AclsAclListOutput) ToAclsAclListOutputWithContext ¶
func (o AclsAclListOutput) ToAclsAclListOutputWithContext(ctx context.Context) AclsAclListOutput
type AclsArgs ¶
type AclsArgs struct { Host *string `pulumi:"host"` InstanceId string `pulumi:"instanceId"` ResourceName string `pulumi:"resourceName"` ResourceType string `pulumi:"resourceType"` ResultOutputFile *string `pulumi:"resultOutputFile"` }
A collection of arguments for invoking Acls.
type AclsOutputArgs ¶
type AclsOutputArgs struct { Host pulumi.StringPtrInput `pulumi:"host"` InstanceId pulumi.StringInput `pulumi:"instanceId"` ResourceName pulumi.StringInput `pulumi:"resourceName"` ResourceType pulumi.StringInput `pulumi:"resourceType"` ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"` }
A collection of arguments for invoking Acls.
func (AclsOutputArgs) ElementType ¶
func (AclsOutputArgs) ElementType() reflect.Type
type AclsResult ¶
type AclsResult struct { AclLists []AclsAclList `pulumi:"aclLists"` Host *string `pulumi:"host"` // The provider-assigned unique ID for this managed resource. Id string `pulumi:"id"` InstanceId string `pulumi:"instanceId"` ResourceName string `pulumi:"resourceName"` ResourceType string `pulumi:"resourceType"` ResultOutputFile *string `pulumi:"resultOutputFile"` }
A collection of values returned by Acls.
func Acls ¶
func Acls(ctx *pulumi.Context, args *AclsArgs, opts ...pulumi.InvokeOption) (*AclsResult, error)
type AclsResultOutput ¶
type AclsResultOutput struct{ *pulumi.OutputState }
A collection of values returned by Acls.
func AclsOutput ¶
func AclsOutput(ctx *pulumi.Context, args AclsOutputArgs, opts ...pulumi.InvokeOption) AclsResultOutput
func (AclsResultOutput) AclLists ¶
func (o AclsResultOutput) AclLists() AclsAclListArrayOutput
func (AclsResultOutput) ElementType ¶
func (AclsResultOutput) ElementType() reflect.Type
func (AclsResultOutput) Host ¶
func (o AclsResultOutput) Host() pulumi.StringPtrOutput
func (AclsResultOutput) Id ¶
func (o AclsResultOutput) Id() pulumi.StringOutput
The provider-assigned unique ID for this managed resource.
func (AclsResultOutput) InstanceId ¶
func (o AclsResultOutput) InstanceId() pulumi.StringOutput
func (AclsResultOutput) ResourceName ¶
func (o AclsResultOutput) ResourceName() pulumi.StringOutput
func (AclsResultOutput) ResourceType ¶
func (o AclsResultOutput) ResourceType() pulumi.StringOutput
func (AclsResultOutput) ResultOutputFile ¶
func (o AclsResultOutput) ResultOutputFile() pulumi.StringPtrOutput
func (AclsResultOutput) ToAclsResultOutput ¶
func (o AclsResultOutput) ToAclsResultOutput() AclsResultOutput
func (AclsResultOutput) ToAclsResultOutputWithContext ¶
func (o AclsResultOutput) ToAclsResultOutputWithContext(ctx context.Context) AclsResultOutput
type Instance ¶
type Instance struct { pulumi.CustomResourceState // Instance bandwidth in MBps. BandWidth pulumi.IntOutput `pulumi:"bandWidth"` // Instance configuration. Config InstanceConfigPtrOutput `pulumi:"config"` // Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through // the control. If it is not within the interval, the plan will cause a change when first created. DiskSize pulumi.IntOutput `pulumi:"diskSize"` // Type of disk. DiskType pulumi.StringOutput `pulumi:"diskType"` // Dynamic message retention policy configuration. DynamicRetentionConfig InstanceDynamicRetentionConfigOutput `pulumi:"dynamicRetentionConfig"` // Instance name. InstanceName pulumi.StringOutput `pulumi:"instanceName"` // Kafka version (0.10.2/1.1.1/2.4.1). KafkaVersion pulumi.StringOutput `pulumi:"kafkaVersion"` // The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the // default 0 is not filled, which means that the log retention time recovery policy is not enabled. MsgRetentionTime pulumi.IntOutput `pulumi:"msgRetentionTime"` // Indicates whether the instance is multi zones. NOTE: if set to `true`, `zone_ids` must set together. MultiZoneFlag pulumi.BoolPtrOutput `pulumi:"multiZoneFlag"` // Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed // through the control. If it is not within the interval, the plan will cause a change when first created. Partition pulumi.IntOutput `pulumi:"partition"` // Prepaid purchase time, such as 1, is one month. Period pulumi.IntPtrOutput `pulumi:"period"` // Timestamp. PublicNetwork pulumi.IntOutput `pulumi:"publicNetwork"` // Modification of the rebalancing time after upgrade. RebalanceTime pulumi.IntPtrOutput `pulumi:"rebalanceTime"` // Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear // no automatic renewal (user setting). RenewFlag pulumi.IntOutput `pulumi:"renewFlag"` // Subnet id. SubnetId pulumi.StringOutput `pulumi:"subnetId"` // Partition size, the professional version does not need tag. Tags InstanceTagArrayOutput `pulumi:"tags"` // Vpc id. VpcId pulumi.StringOutput `pulumi:"vpcId"` // Available zone id. ZoneId pulumi.IntOutput `pulumi:"zoneId"` // List of available zone id. NOTE: this argument must set together with `multi_zone_flag`. ZoneIds pulumi.IntArrayOutput `pulumi:"zoneIds"` }
func GetInstance ¶
func GetInstance(ctx *pulumi.Context, name string, id pulumi.IDInput, state *InstanceState, opts ...pulumi.ResourceOption) (*Instance, error)
GetInstance gets an existing Instance resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewInstance ¶
func NewInstance(ctx *pulumi.Context, name string, args *InstanceArgs, opts ...pulumi.ResourceOption) (*Instance, error)
NewInstance registers a new resource with the given unique name, arguments, and options.
func (*Instance) ElementType ¶
func (*Instance) ToInstanceOutput ¶
func (i *Instance) ToInstanceOutput() InstanceOutput
func (*Instance) ToInstanceOutputWithContext ¶
func (i *Instance) ToInstanceOutputWithContext(ctx context.Context) InstanceOutput
type InstanceArgs ¶
type InstanceArgs struct { // Instance bandwidth in MBps. BandWidth pulumi.IntPtrInput // Instance configuration. Config InstanceConfigPtrInput // Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through // the control. If it is not within the interval, the plan will cause a change when first created. DiskSize pulumi.IntPtrInput // Type of disk. DiskType pulumi.StringPtrInput // Dynamic message retention policy configuration. DynamicRetentionConfig InstanceDynamicRetentionConfigPtrInput // Instance name. InstanceName pulumi.StringInput // Kafka version (0.10.2/1.1.1/2.4.1). KafkaVersion pulumi.StringPtrInput // The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the // default 0 is not filled, which means that the log retention time recovery policy is not enabled. MsgRetentionTime pulumi.IntPtrInput // Indicates whether the instance is multi zones. NOTE: if set to `true`, `zone_ids` must set together. MultiZoneFlag pulumi.BoolPtrInput // Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed // through the control. If it is not within the interval, the plan will cause a change when first created. Partition pulumi.IntPtrInput // Prepaid purchase time, such as 1, is one month. Period pulumi.IntPtrInput // Timestamp. PublicNetwork pulumi.IntPtrInput // Modification of the rebalancing time after upgrade. RebalanceTime pulumi.IntPtrInput // Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear // no automatic renewal (user setting). RenewFlag pulumi.IntPtrInput // Subnet id. SubnetId pulumi.StringInput // Partition size, the professional version does not need tag. Tags InstanceTagArrayInput // Vpc id. VpcId pulumi.StringInput // Available zone id. ZoneId pulumi.IntInput // List of available zone id. NOTE: this argument must set together with `multi_zone_flag`. ZoneIds pulumi.IntArrayInput }
The set of arguments for constructing a Instance resource.
func (InstanceArgs) ElementType ¶
func (InstanceArgs) ElementType() reflect.Type
type InstanceArray ¶
type InstanceArray []InstanceInput
func (InstanceArray) ElementType ¶
func (InstanceArray) ElementType() reflect.Type
func (InstanceArray) ToInstanceArrayOutput ¶
func (i InstanceArray) ToInstanceArrayOutput() InstanceArrayOutput
func (InstanceArray) ToInstanceArrayOutputWithContext ¶
func (i InstanceArray) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput
type InstanceArrayInput ¶
type InstanceArrayInput interface { pulumi.Input ToInstanceArrayOutput() InstanceArrayOutput ToInstanceArrayOutputWithContext(context.Context) InstanceArrayOutput }
InstanceArrayInput is an input type that accepts InstanceArray and InstanceArrayOutput values. You can construct a concrete instance of `InstanceArrayInput` via:
InstanceArray{ InstanceArgs{...} }
type InstanceArrayOutput ¶
type InstanceArrayOutput struct{ *pulumi.OutputState }
func (InstanceArrayOutput) ElementType ¶
func (InstanceArrayOutput) ElementType() reflect.Type
func (InstanceArrayOutput) Index ¶
func (o InstanceArrayOutput) Index(i pulumi.IntInput) InstanceOutput
func (InstanceArrayOutput) ToInstanceArrayOutput ¶
func (o InstanceArrayOutput) ToInstanceArrayOutput() InstanceArrayOutput
func (InstanceArrayOutput) ToInstanceArrayOutputWithContext ¶
func (o InstanceArrayOutput) ToInstanceArrayOutputWithContext(ctx context.Context) InstanceArrayOutput
type InstanceConfig ¶
type InstanceConfigArgs ¶
type InstanceConfigArgs struct { AutoCreateTopicEnable pulumi.BoolInput `pulumi:"autoCreateTopicEnable"` DefaultNumPartitions pulumi.IntInput `pulumi:"defaultNumPartitions"` DefaultReplicationFactor pulumi.IntInput `pulumi:"defaultReplicationFactor"` }
func (InstanceConfigArgs) ElementType ¶
func (InstanceConfigArgs) ElementType() reflect.Type
func (InstanceConfigArgs) ToInstanceConfigOutput ¶
func (i InstanceConfigArgs) ToInstanceConfigOutput() InstanceConfigOutput
func (InstanceConfigArgs) ToInstanceConfigOutputWithContext ¶
func (i InstanceConfigArgs) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput
func (InstanceConfigArgs) ToInstanceConfigPtrOutput ¶
func (i InstanceConfigArgs) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
func (InstanceConfigArgs) ToInstanceConfigPtrOutputWithContext ¶
func (i InstanceConfigArgs) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
type InstanceConfigInput ¶
type InstanceConfigInput interface { pulumi.Input ToInstanceConfigOutput() InstanceConfigOutput ToInstanceConfigOutputWithContext(context.Context) InstanceConfigOutput }
InstanceConfigInput is an input type that accepts InstanceConfigArgs and InstanceConfigOutput values. You can construct a concrete instance of `InstanceConfigInput` via:
InstanceConfigArgs{...}
type InstanceConfigOutput ¶
type InstanceConfigOutput struct{ *pulumi.OutputState }
func (InstanceConfigOutput) AutoCreateTopicEnable ¶
func (o InstanceConfigOutput) AutoCreateTopicEnable() pulumi.BoolOutput
func (InstanceConfigOutput) DefaultNumPartitions ¶
func (o InstanceConfigOutput) DefaultNumPartitions() pulumi.IntOutput
func (InstanceConfigOutput) DefaultReplicationFactor ¶
func (o InstanceConfigOutput) DefaultReplicationFactor() pulumi.IntOutput
func (InstanceConfigOutput) ElementType ¶
func (InstanceConfigOutput) ElementType() reflect.Type
func (InstanceConfigOutput) ToInstanceConfigOutput ¶
func (o InstanceConfigOutput) ToInstanceConfigOutput() InstanceConfigOutput
func (InstanceConfigOutput) ToInstanceConfigOutputWithContext ¶
func (o InstanceConfigOutput) ToInstanceConfigOutputWithContext(ctx context.Context) InstanceConfigOutput
func (InstanceConfigOutput) ToInstanceConfigPtrOutput ¶
func (o InstanceConfigOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
func (InstanceConfigOutput) ToInstanceConfigPtrOutputWithContext ¶
func (o InstanceConfigOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
type InstanceConfigPtrInput ¶
type InstanceConfigPtrInput interface { pulumi.Input ToInstanceConfigPtrOutput() InstanceConfigPtrOutput ToInstanceConfigPtrOutputWithContext(context.Context) InstanceConfigPtrOutput }
InstanceConfigPtrInput is an input type that accepts InstanceConfigArgs, InstanceConfigPtr and InstanceConfigPtrOutput values. You can construct a concrete instance of `InstanceConfigPtrInput` via:
InstanceConfigArgs{...} or: nil
func InstanceConfigPtr ¶
func InstanceConfigPtr(v *InstanceConfigArgs) InstanceConfigPtrInput
type InstanceConfigPtrOutput ¶
type InstanceConfigPtrOutput struct{ *pulumi.OutputState }
func (InstanceConfigPtrOutput) AutoCreateTopicEnable ¶
func (o InstanceConfigPtrOutput) AutoCreateTopicEnable() pulumi.BoolPtrOutput
func (InstanceConfigPtrOutput) DefaultNumPartitions ¶
func (o InstanceConfigPtrOutput) DefaultNumPartitions() pulumi.IntPtrOutput
func (InstanceConfigPtrOutput) DefaultReplicationFactor ¶
func (o InstanceConfigPtrOutput) DefaultReplicationFactor() pulumi.IntPtrOutput
func (InstanceConfigPtrOutput) Elem ¶
func (o InstanceConfigPtrOutput) Elem() InstanceConfigOutput
func (InstanceConfigPtrOutput) ElementType ¶
func (InstanceConfigPtrOutput) ElementType() reflect.Type
func (InstanceConfigPtrOutput) ToInstanceConfigPtrOutput ¶
func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutput() InstanceConfigPtrOutput
func (InstanceConfigPtrOutput) ToInstanceConfigPtrOutputWithContext ¶
func (o InstanceConfigPtrOutput) ToInstanceConfigPtrOutputWithContext(ctx context.Context) InstanceConfigPtrOutput
type InstanceDynamicRetentionConfigArgs ¶
type InstanceDynamicRetentionConfigArgs struct { BottomRetention pulumi.IntPtrInput `pulumi:"bottomRetention"` DiskQuotaPercentage pulumi.IntPtrInput `pulumi:"diskQuotaPercentage"` Enable pulumi.IntPtrInput `pulumi:"enable"` StepForwardPercentage pulumi.IntPtrInput `pulumi:"stepForwardPercentage"` }
func (InstanceDynamicRetentionConfigArgs) ElementType ¶
func (InstanceDynamicRetentionConfigArgs) ElementType() reflect.Type
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutput ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutputWithContext ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutput ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
func (InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutputWithContext ¶
func (i InstanceDynamicRetentionConfigArgs) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
type InstanceDynamicRetentionConfigInput ¶
type InstanceDynamicRetentionConfigInput interface { pulumi.Input ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput ToInstanceDynamicRetentionConfigOutputWithContext(context.Context) InstanceDynamicRetentionConfigOutput }
InstanceDynamicRetentionConfigInput is an input type that accepts InstanceDynamicRetentionConfigArgs and InstanceDynamicRetentionConfigOutput values. You can construct a concrete instance of `InstanceDynamicRetentionConfigInput` via:
InstanceDynamicRetentionConfigArgs{...}
type InstanceDynamicRetentionConfigOutput ¶
type InstanceDynamicRetentionConfigOutput struct{ *pulumi.OutputState }
func (InstanceDynamicRetentionConfigOutput) BottomRetention ¶
func (o InstanceDynamicRetentionConfigOutput) BottomRetention() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage ¶
func (o InstanceDynamicRetentionConfigOutput) DiskQuotaPercentage() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigOutput) ElementType ¶
func (InstanceDynamicRetentionConfigOutput) ElementType() reflect.Type
func (InstanceDynamicRetentionConfigOutput) Enable ¶
func (o InstanceDynamicRetentionConfigOutput) Enable() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigOutput) StepForwardPercentage ¶
func (o InstanceDynamicRetentionConfigOutput) StepForwardPercentage() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutput ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutput() InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutputWithContext ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigOutput
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutput ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
func (InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext ¶
func (o InstanceDynamicRetentionConfigOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
type InstanceDynamicRetentionConfigPtrInput ¶
type InstanceDynamicRetentionConfigPtrInput interface { pulumi.Input ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput ToInstanceDynamicRetentionConfigPtrOutputWithContext(context.Context) InstanceDynamicRetentionConfigPtrOutput }
InstanceDynamicRetentionConfigPtrInput is an input type that accepts InstanceDynamicRetentionConfigArgs, InstanceDynamicRetentionConfigPtr and InstanceDynamicRetentionConfigPtrOutput values. You can construct a concrete instance of `InstanceDynamicRetentionConfigPtrInput` via:
InstanceDynamicRetentionConfigArgs{...} or: nil
func InstanceDynamicRetentionConfigPtr ¶
func InstanceDynamicRetentionConfigPtr(v *InstanceDynamicRetentionConfigArgs) InstanceDynamicRetentionConfigPtrInput
type InstanceDynamicRetentionConfigPtrOutput ¶
type InstanceDynamicRetentionConfigPtrOutput struct{ *pulumi.OutputState }
func (InstanceDynamicRetentionConfigPtrOutput) BottomRetention ¶
func (o InstanceDynamicRetentionConfigPtrOutput) BottomRetention() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage ¶
func (o InstanceDynamicRetentionConfigPtrOutput) DiskQuotaPercentage() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigPtrOutput) ElementType ¶
func (InstanceDynamicRetentionConfigPtrOutput) ElementType() reflect.Type
func (InstanceDynamicRetentionConfigPtrOutput) Enable ¶
func (o InstanceDynamicRetentionConfigPtrOutput) Enable() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage ¶
func (o InstanceDynamicRetentionConfigPtrOutput) StepForwardPercentage() pulumi.IntPtrOutput
func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput ¶
func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutput() InstanceDynamicRetentionConfigPtrOutput
func (InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext ¶
func (o InstanceDynamicRetentionConfigPtrOutput) ToInstanceDynamicRetentionConfigPtrOutputWithContext(ctx context.Context) InstanceDynamicRetentionConfigPtrOutput
type InstanceInput ¶
type InstanceInput interface { pulumi.Input ToInstanceOutput() InstanceOutput ToInstanceOutputWithContext(ctx context.Context) InstanceOutput }
type InstanceMap ¶
type InstanceMap map[string]InstanceInput
func (InstanceMap) ElementType ¶
func (InstanceMap) ElementType() reflect.Type
func (InstanceMap) ToInstanceMapOutput ¶
func (i InstanceMap) ToInstanceMapOutput() InstanceMapOutput
func (InstanceMap) ToInstanceMapOutputWithContext ¶
func (i InstanceMap) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput
type InstanceMapInput ¶
type InstanceMapInput interface { pulumi.Input ToInstanceMapOutput() InstanceMapOutput ToInstanceMapOutputWithContext(context.Context) InstanceMapOutput }
InstanceMapInput is an input type that accepts InstanceMap and InstanceMapOutput values. You can construct a concrete instance of `InstanceMapInput` via:
InstanceMap{ "key": InstanceArgs{...} }
type InstanceMapOutput ¶
type InstanceMapOutput struct{ *pulumi.OutputState }
func (InstanceMapOutput) ElementType ¶
func (InstanceMapOutput) ElementType() reflect.Type
func (InstanceMapOutput) MapIndex ¶
func (o InstanceMapOutput) MapIndex(k pulumi.StringInput) InstanceOutput
func (InstanceMapOutput) ToInstanceMapOutput ¶
func (o InstanceMapOutput) ToInstanceMapOutput() InstanceMapOutput
func (InstanceMapOutput) ToInstanceMapOutputWithContext ¶
func (o InstanceMapOutput) ToInstanceMapOutputWithContext(ctx context.Context) InstanceMapOutput
type InstanceOutput ¶
type InstanceOutput struct{ *pulumi.OutputState }
func (InstanceOutput) BandWidth ¶
func (o InstanceOutput) BandWidth() pulumi.IntOutput
Instance bandwidth in MBps.
func (InstanceOutput) Config ¶
func (o InstanceOutput) Config() InstanceConfigPtrOutput
Instance configuration.
func (InstanceOutput) DiskSize ¶
func (o InstanceOutput) DiskSize() pulumi.IntOutput
Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
func (InstanceOutput) DiskType ¶
func (o InstanceOutput) DiskType() pulumi.StringOutput
Type of disk.
func (InstanceOutput) DynamicRetentionConfig ¶
func (o InstanceOutput) DynamicRetentionConfig() InstanceDynamicRetentionConfigOutput
Dynamic message retention policy configuration.
func (InstanceOutput) ElementType ¶
func (InstanceOutput) ElementType() reflect.Type
func (InstanceOutput) InstanceName ¶
func (o InstanceOutput) InstanceName() pulumi.StringOutput
Instance name.
func (InstanceOutput) KafkaVersion ¶
func (o InstanceOutput) KafkaVersion() pulumi.StringOutput
Kafka version (0.10.2/1.1.1/2.4.1).
func (InstanceOutput) MsgRetentionTime ¶
func (o InstanceOutput) MsgRetentionTime() pulumi.IntOutput
The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the default 0 is not filled, which means that the log retention time recovery policy is not enabled.
func (InstanceOutput) MultiZoneFlag ¶
func (o InstanceOutput) MultiZoneFlag() pulumi.BoolPtrOutput
Indicates whether the instance is multi zones. NOTE: if set to `true`, `zone_ids` must set together.
func (InstanceOutput) Partition ¶
func (o InstanceOutput) Partition() pulumi.IntOutput
Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through the control. If it is not within the interval, the plan will cause a change when first created.
func (InstanceOutput) Period ¶
func (o InstanceOutput) Period() pulumi.IntPtrOutput
Prepaid purchase time, such as 1, is one month.
func (InstanceOutput) PublicNetwork ¶
func (o InstanceOutput) PublicNetwork() pulumi.IntOutput
Timestamp.
func (InstanceOutput) RebalanceTime ¶
func (o InstanceOutput) RebalanceTime() pulumi.IntPtrOutput
Modification of the rebalancing time after upgrade.
func (InstanceOutput) RenewFlag ¶
func (o InstanceOutput) RenewFlag() pulumi.IntOutput
Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear no automatic renewal (user setting).
func (InstanceOutput) 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 `multi_zone_flag`.
type InstanceState ¶
type InstanceState struct { // Instance bandwidth in MBps. BandWidth pulumi.IntPtrInput // Instance configuration. Config InstanceConfigPtrInput // Disk Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed through // the control. If it is not within the interval, the plan will cause a change when first created. DiskSize pulumi.IntPtrInput // Type of disk. DiskType pulumi.StringPtrInput // Dynamic message retention policy configuration. DynamicRetentionConfig InstanceDynamicRetentionConfigPtrInput // Instance name. InstanceName pulumi.StringPtrInput // Kafka version (0.10.2/1.1.1/2.4.1). KafkaVersion pulumi.StringPtrInput // The maximum retention time of instance logs, in minutes. the default is 10080 (7 days), the maximum is 30 days, and the // default 0 is not filled, which means that the log retention time recovery policy is not enabled. MsgRetentionTime pulumi.IntPtrInput // Indicates whether the instance is multi zones. NOTE: if set to `true`, `zone_ids` must set together. MultiZoneFlag pulumi.BoolPtrInput // Partition Size. Its interval varies with bandwidth, and the input must be within the interval, which can be viewed // through the control. If it is not within the interval, the plan will cause a change when first created. Partition pulumi.IntPtrInput // Prepaid purchase time, such as 1, is one month. Period pulumi.IntPtrInput // Timestamp. PublicNetwork pulumi.IntPtrInput // Modification of the rebalancing time after upgrade. RebalanceTime pulumi.IntPtrInput // Prepaid automatic renewal mark, 0 means the default state, the initial state, 1 means automatic renewal, 2 means clear // no automatic renewal (user setting). RenewFlag pulumi.IntPtrInput // Subnet id. SubnetId pulumi.StringPtrInput // Partition size, the professional version does not need tag. Tags InstanceTagArrayInput // Vpc id. VpcId pulumi.StringPtrInput // Available zone id. ZoneId pulumi.IntPtrInput // List of available zone id. NOTE: this argument must set together with `multi_zone_flag`. ZoneIds pulumi.IntArrayInput }
func (InstanceState) ElementType ¶
func (InstanceState) ElementType() reflect.Type
type InstanceTag ¶
type InstanceTagArgs ¶
type InstanceTagArgs struct { Key pulumi.StringInput `pulumi:"key"` Value pulumi.StringInput `pulumi:"value"` }
func (InstanceTagArgs) ElementType ¶
func (InstanceTagArgs) ElementType() reflect.Type
func (InstanceTagArgs) ToInstanceTagOutput ¶
func (i InstanceTagArgs) ToInstanceTagOutput() InstanceTagOutput
func (InstanceTagArgs) ToInstanceTagOutputWithContext ¶
func (i InstanceTagArgs) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput
type InstanceTagArray ¶
type InstanceTagArray []InstanceTagInput
func (InstanceTagArray) ElementType ¶
func (InstanceTagArray) ElementType() reflect.Type
func (InstanceTagArray) ToInstanceTagArrayOutput ¶
func (i InstanceTagArray) ToInstanceTagArrayOutput() InstanceTagArrayOutput
func (InstanceTagArray) ToInstanceTagArrayOutputWithContext ¶
func (i InstanceTagArray) ToInstanceTagArrayOutputWithContext(ctx context.Context) InstanceTagArrayOutput
type InstanceTagArrayInput ¶
type InstanceTagArrayInput interface { pulumi.Input ToInstanceTagArrayOutput() InstanceTagArrayOutput ToInstanceTagArrayOutputWithContext(context.Context) InstanceTagArrayOutput }
InstanceTagArrayInput is an input type that accepts InstanceTagArray and InstanceTagArrayOutput values. You can construct a concrete instance of `InstanceTagArrayInput` via:
InstanceTagArray{ InstanceTagArgs{...} }
type InstanceTagArrayOutput ¶
type InstanceTagArrayOutput struct{ *pulumi.OutputState }
func (InstanceTagArrayOutput) ElementType ¶
func (InstanceTagArrayOutput) ElementType() reflect.Type
func (InstanceTagArrayOutput) Index ¶
func (o InstanceTagArrayOutput) Index(i pulumi.IntInput) InstanceTagOutput
func (InstanceTagArrayOutput) ToInstanceTagArrayOutput ¶
func (o InstanceTagArrayOutput) ToInstanceTagArrayOutput() InstanceTagArrayOutput
func (InstanceTagArrayOutput) ToInstanceTagArrayOutputWithContext ¶
func (o InstanceTagArrayOutput) ToInstanceTagArrayOutputWithContext(ctx context.Context) InstanceTagArrayOutput
type InstanceTagInput ¶
type InstanceTagInput interface { pulumi.Input ToInstanceTagOutput() InstanceTagOutput ToInstanceTagOutputWithContext(context.Context) InstanceTagOutput }
InstanceTagInput is an input type that accepts InstanceTagArgs and InstanceTagOutput values. You can construct a concrete instance of `InstanceTagInput` via:
InstanceTagArgs{...}
type InstanceTagOutput ¶
type InstanceTagOutput struct{ *pulumi.OutputState }
func (InstanceTagOutput) ElementType ¶
func (InstanceTagOutput) ElementType() reflect.Type
func (InstanceTagOutput) Key ¶
func (o InstanceTagOutput) Key() pulumi.StringOutput
func (InstanceTagOutput) ToInstanceTagOutput ¶
func (o InstanceTagOutput) ToInstanceTagOutput() InstanceTagOutput
func (InstanceTagOutput) ToInstanceTagOutputWithContext ¶
func (o InstanceTagOutput) ToInstanceTagOutputWithContext(ctx context.Context) InstanceTagOutput
func (InstanceTagOutput) Value ¶
func (o InstanceTagOutput) Value() pulumi.StringOutput
type Topic ¶
type Topic struct { pulumi.CustomResourceState // Clear log policy, log clear mode, default is `delete`. `delete`: logs are deleted according to the storage time. // `compact`: logs are compressed according to the key. `compact, delete`: logs are compressed according to the key and // will be deleted according to the storage time. CleanUpPolicy pulumi.StringPtrOutput `pulumi:"cleanUpPolicy"` // Create time of the CKafka topic. CreateTime pulumi.StringOutput `pulumi:"createTime"` // Whether to open the ip whitelist, `true`: open, `false`: close. EnableWhiteList pulumi.BoolPtrOutput `pulumi:"enableWhiteList"` // Data backup cos bucket: the bucket address that is dumped to cos. ForwardCosBucket pulumi.StringOutput `pulumi:"forwardCosBucket"` // Periodic frequency of data backup to cos. ForwardInterval pulumi.IntOutput `pulumi:"forwardInterval"` // Data backup cos status. Valid values: `0`, `1`. `1`: do not open data backup, `0`: open data backup. ForwardStatus pulumi.IntOutput `pulumi:"forwardStatus"` // Ckafka instance ID. InstanceId pulumi.StringOutput `pulumi:"instanceId"` // Ip whitelist, quota limit, required when enableWhileList=true. IpWhiteLists pulumi.StringArrayOutput `pulumi:"ipWhiteLists"` // Max message bytes. MaxMessageBytes pulumi.IntPtrOutput `pulumi:"maxMessageBytes"` // Message storage location. MessageStorageLocation pulumi.StringOutput `pulumi:"messageStorageLocation"` // The subject note. It must start with a letter, and the remaining part can contain letters, numbers and dashes (-). Note pulumi.StringPtrOutput `pulumi:"note"` // The number of partition. PartitionNum pulumi.IntOutput `pulumi:"partitionNum"` // The number of replica. ReplicaNum pulumi.IntOutput `pulumi:"replicaNum"` // Message can be selected. Retention time, unit is ms, the current minimum value is 60000ms. Retention pulumi.IntPtrOutput `pulumi:"retention"` // Segment scrolling time, in ms, the current minimum is 3600000ms. Segment pulumi.IntPtrOutput `pulumi:"segment"` // Number of bytes rolled by shard. SegmentBytes pulumi.IntOutput `pulumi:"segmentBytes"` // Min number of sync replicas, Default is `1`. SyncReplicaMinNum pulumi.IntPtrOutput `pulumi:"syncReplicaMinNum"` // Name of the CKafka topic. It must start with a letter, the rest can contain letters, numbers and dashes(-). TopicName pulumi.StringOutput `pulumi:"topicName"` // Whether to allow unsynchronized replicas to be selected as leader, default is `false`, ` true: `allowed, `false`: not // allowed. UncleanLeaderElectionEnable pulumi.BoolPtrOutput `pulumi:"uncleanLeaderElectionEnable"` }
func GetTopic ¶
func GetTopic(ctx *pulumi.Context, name string, id pulumi.IDInput, state *TopicState, opts ...pulumi.ResourceOption) (*Topic, error)
GetTopic gets an existing Topic resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewTopic ¶
func NewTopic(ctx *pulumi.Context, name string, args *TopicArgs, opts ...pulumi.ResourceOption) (*Topic, error)
NewTopic registers a new resource with the given unique name, arguments, and options.
func (*Topic) ElementType ¶
func (*Topic) 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 TopicsArgs ¶
type TopicsArgs struct { InstanceId string `pulumi:"instanceId"` ResultOutputFile *string `pulumi:"resultOutputFile"` TopicName *string `pulumi:"topicName"` }
A collection of arguments for invoking Topics.
type TopicsInstanceList ¶
type TopicsInstanceList struct { CleanUpPolicy string `pulumi:"cleanUpPolicy"` CreateTime string `pulumi:"createTime"` EnableWhiteList bool `pulumi:"enableWhiteList"` ForwardCosBucket string `pulumi:"forwardCosBucket"` ForwardInterval int `pulumi:"forwardInterval"` ForwardStatus int `pulumi:"forwardStatus"` IpWhiteListCount int `pulumi:"ipWhiteListCount"` MaxMessageBytes int `pulumi:"maxMessageBytes"` Note string `pulumi:"note"` PartitionNum int `pulumi:"partitionNum"` ReplicaNum int `pulumi:"replicaNum"` Retention int `pulumi:"retention"` Segment int `pulumi:"segment"` SegmentBytes int `pulumi:"segmentBytes"` SyncReplicaMinNum int `pulumi:"syncReplicaMinNum"` TopicId string `pulumi:"topicId"` TopicName string `pulumi:"topicName"` UncleanLeaderElectionEnable bool `pulumi:"uncleanLeaderElectionEnable"` }
type TopicsInstanceListArgs ¶
type TopicsInstanceListArgs struct { CleanUpPolicy pulumi.StringInput `pulumi:"cleanUpPolicy"` CreateTime pulumi.StringInput `pulumi:"createTime"` EnableWhiteList pulumi.BoolInput `pulumi:"enableWhiteList"` ForwardCosBucket pulumi.StringInput `pulumi:"forwardCosBucket"` ForwardInterval pulumi.IntInput `pulumi:"forwardInterval"` ForwardStatus pulumi.IntInput `pulumi:"forwardStatus"` IpWhiteListCount pulumi.IntInput `pulumi:"ipWhiteListCount"` MaxMessageBytes pulumi.IntInput `pulumi:"maxMessageBytes"` Note pulumi.StringInput `pulumi:"note"` PartitionNum pulumi.IntInput `pulumi:"partitionNum"` ReplicaNum pulumi.IntInput `pulumi:"replicaNum"` Retention pulumi.IntInput `pulumi:"retention"` Segment pulumi.IntInput `pulumi:"segment"` SegmentBytes pulumi.IntInput `pulumi:"segmentBytes"` SyncReplicaMinNum pulumi.IntInput `pulumi:"syncReplicaMinNum"` TopicId pulumi.StringInput `pulumi:"topicId"` TopicName pulumi.StringInput `pulumi:"topicName"` UncleanLeaderElectionEnable pulumi.BoolInput `pulumi:"uncleanLeaderElectionEnable"` }
func (TopicsInstanceListArgs) ElementType ¶
func (TopicsInstanceListArgs) ElementType() reflect.Type
func (TopicsInstanceListArgs) ToTopicsInstanceListOutput ¶
func (i TopicsInstanceListArgs) ToTopicsInstanceListOutput() TopicsInstanceListOutput
func (TopicsInstanceListArgs) ToTopicsInstanceListOutputWithContext ¶
func (i TopicsInstanceListArgs) ToTopicsInstanceListOutputWithContext(ctx context.Context) TopicsInstanceListOutput
type TopicsInstanceListArray ¶
type TopicsInstanceListArray []TopicsInstanceListInput
func (TopicsInstanceListArray) ElementType ¶
func (TopicsInstanceListArray) ElementType() reflect.Type
func (TopicsInstanceListArray) ToTopicsInstanceListArrayOutput ¶
func (i TopicsInstanceListArray) ToTopicsInstanceListArrayOutput() TopicsInstanceListArrayOutput
func (TopicsInstanceListArray) ToTopicsInstanceListArrayOutputWithContext ¶
func (i TopicsInstanceListArray) ToTopicsInstanceListArrayOutputWithContext(ctx context.Context) TopicsInstanceListArrayOutput
type TopicsInstanceListArrayInput ¶
type TopicsInstanceListArrayInput interface { pulumi.Input ToTopicsInstanceListArrayOutput() TopicsInstanceListArrayOutput ToTopicsInstanceListArrayOutputWithContext(context.Context) TopicsInstanceListArrayOutput }
TopicsInstanceListArrayInput is an input type that accepts TopicsInstanceListArray and TopicsInstanceListArrayOutput values. You can construct a concrete instance of `TopicsInstanceListArrayInput` via:
TopicsInstanceListArray{ TopicsInstanceListArgs{...} }
type TopicsInstanceListArrayOutput ¶
type TopicsInstanceListArrayOutput struct{ *pulumi.OutputState }
func (TopicsInstanceListArrayOutput) ElementType ¶
func (TopicsInstanceListArrayOutput) ElementType() reflect.Type
func (TopicsInstanceListArrayOutput) Index ¶
func (o TopicsInstanceListArrayOutput) Index(i pulumi.IntInput) TopicsInstanceListOutput
func (TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutput ¶
func (o TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutput() TopicsInstanceListArrayOutput
func (TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutputWithContext ¶
func (o TopicsInstanceListArrayOutput) ToTopicsInstanceListArrayOutputWithContext(ctx context.Context) TopicsInstanceListArrayOutput
type TopicsInstanceListInput ¶
type TopicsInstanceListInput interface { pulumi.Input ToTopicsInstanceListOutput() TopicsInstanceListOutput ToTopicsInstanceListOutputWithContext(context.Context) TopicsInstanceListOutput }
TopicsInstanceListInput is an input type that accepts TopicsInstanceListArgs and TopicsInstanceListOutput values. You can construct a concrete instance of `TopicsInstanceListInput` via:
TopicsInstanceListArgs{...}
type TopicsInstanceListOutput ¶
type TopicsInstanceListOutput struct{ *pulumi.OutputState }
func (TopicsInstanceListOutput) CleanUpPolicy ¶
func (o TopicsInstanceListOutput) CleanUpPolicy() pulumi.StringOutput
func (TopicsInstanceListOutput) CreateTime ¶
func (o TopicsInstanceListOutput) CreateTime() pulumi.StringOutput
func (TopicsInstanceListOutput) ElementType ¶
func (TopicsInstanceListOutput) ElementType() reflect.Type
func (TopicsInstanceListOutput) EnableWhiteList ¶
func (o TopicsInstanceListOutput) EnableWhiteList() pulumi.BoolOutput
func (TopicsInstanceListOutput) ForwardCosBucket ¶
func (o TopicsInstanceListOutput) ForwardCosBucket() pulumi.StringOutput
func (TopicsInstanceListOutput) ForwardInterval ¶
func (o TopicsInstanceListOutput) ForwardInterval() pulumi.IntOutput
func (TopicsInstanceListOutput) ForwardStatus ¶
func (o TopicsInstanceListOutput) ForwardStatus() pulumi.IntOutput
func (TopicsInstanceListOutput) IpWhiteListCount ¶
func (o TopicsInstanceListOutput) IpWhiteListCount() pulumi.IntOutput
func (TopicsInstanceListOutput) MaxMessageBytes ¶
func (o TopicsInstanceListOutput) MaxMessageBytes() pulumi.IntOutput
func (TopicsInstanceListOutput) Note ¶
func (o TopicsInstanceListOutput) Note() pulumi.StringOutput
func (TopicsInstanceListOutput) PartitionNum ¶
func (o TopicsInstanceListOutput) PartitionNum() pulumi.IntOutput
func (TopicsInstanceListOutput) ReplicaNum ¶
func (o TopicsInstanceListOutput) ReplicaNum() pulumi.IntOutput
func (TopicsInstanceListOutput) Retention ¶
func (o TopicsInstanceListOutput) Retention() pulumi.IntOutput
func (TopicsInstanceListOutput) Segment ¶
func (o TopicsInstanceListOutput) Segment() pulumi.IntOutput
func (TopicsInstanceListOutput) SegmentBytes ¶
func (o TopicsInstanceListOutput) SegmentBytes() pulumi.IntOutput
func (TopicsInstanceListOutput) SyncReplicaMinNum ¶
func (o TopicsInstanceListOutput) SyncReplicaMinNum() pulumi.IntOutput
func (TopicsInstanceListOutput) ToTopicsInstanceListOutput ¶
func (o TopicsInstanceListOutput) ToTopicsInstanceListOutput() TopicsInstanceListOutput
func (TopicsInstanceListOutput) ToTopicsInstanceListOutputWithContext ¶
func (o TopicsInstanceListOutput) ToTopicsInstanceListOutputWithContext(ctx context.Context) TopicsInstanceListOutput
func (TopicsInstanceListOutput) TopicId ¶
func (o TopicsInstanceListOutput) TopicId() pulumi.StringOutput
func (TopicsInstanceListOutput) TopicName ¶
func (o TopicsInstanceListOutput) TopicName() pulumi.StringOutput
func (TopicsInstanceListOutput) UncleanLeaderElectionEnable ¶
func (o TopicsInstanceListOutput) UncleanLeaderElectionEnable() pulumi.BoolOutput
type TopicsOutputArgs ¶
type TopicsOutputArgs struct { InstanceId pulumi.StringInput `pulumi:"instanceId"` ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"` TopicName pulumi.StringPtrInput `pulumi:"topicName"` }
A collection of arguments for invoking Topics.
func (TopicsOutputArgs) ElementType ¶
func (TopicsOutputArgs) ElementType() reflect.Type
type TopicsResult ¶
type TopicsResult struct { // The provider-assigned unique ID for this managed resource. Id string `pulumi:"id"` InstanceId string `pulumi:"instanceId"` InstanceLists []TopicsInstanceList `pulumi:"instanceLists"` ResultOutputFile *string `pulumi:"resultOutputFile"` TopicName *string `pulumi:"topicName"` }
A collection of values returned by Topics.
func Topics ¶
func Topics(ctx *pulumi.Context, args *TopicsArgs, opts ...pulumi.InvokeOption) (*TopicsResult, error)
type TopicsResultOutput ¶
type TopicsResultOutput struct{ *pulumi.OutputState }
A collection of values returned by Topics.
func TopicsOutput ¶
func TopicsOutput(ctx *pulumi.Context, args TopicsOutputArgs, opts ...pulumi.InvokeOption) TopicsResultOutput
func (TopicsResultOutput) ElementType ¶
func (TopicsResultOutput) ElementType() reflect.Type
func (TopicsResultOutput) Id ¶
func (o TopicsResultOutput) Id() pulumi.StringOutput
The provider-assigned unique ID for this managed resource.
func (TopicsResultOutput) InstanceId ¶
func (o TopicsResultOutput) InstanceId() pulumi.StringOutput
func (TopicsResultOutput) InstanceLists ¶
func (o TopicsResultOutput) InstanceLists() TopicsInstanceListArrayOutput
func (TopicsResultOutput) ResultOutputFile ¶
func (o TopicsResultOutput) ResultOutputFile() pulumi.StringPtrOutput
func (TopicsResultOutput) ToTopicsResultOutput ¶
func (o TopicsResultOutput) ToTopicsResultOutput() TopicsResultOutput
func (TopicsResultOutput) ToTopicsResultOutputWithContext ¶
func (o TopicsResultOutput) ToTopicsResultOutputWithContext(ctx context.Context) TopicsResultOutput
func (TopicsResultOutput) TopicName ¶
func (o TopicsResultOutput) TopicName() pulumi.StringPtrOutput
type User ¶
type User struct { pulumi.CustomResourceState // Account name used to access to ckafka instance. AccountName pulumi.StringOutput `pulumi:"accountName"` // Creation time of the account. CreateTime pulumi.StringOutput `pulumi:"createTime"` // ID of the ckafka instance. InstanceId pulumi.StringOutput `pulumi:"instanceId"` // Password of the account. Password pulumi.StringOutput `pulumi:"password"` // The last update time of the account. UpdateTime pulumi.StringOutput `pulumi:"updateTime"` }
func GetUser ¶
func GetUser(ctx *pulumi.Context, name string, id pulumi.IDInput, state *UserState, opts ...pulumi.ResourceOption) (*User, error)
GetUser gets an existing User resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).
func NewUser ¶
func NewUser(ctx *pulumi.Context, name string, args *UserArgs, opts ...pulumi.ResourceOption) (*User, error)
NewUser registers a new resource with the given unique name, arguments, and options.
func (*User) ElementType ¶
func (*User) 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 }
func (UserState) ElementType ¶
type UsersArgs ¶
type UsersArgs struct { AccountName *string `pulumi:"accountName"` InstanceId string `pulumi:"instanceId"` ResultOutputFile *string `pulumi:"resultOutputFile"` }
A collection of arguments for invoking Users.
type UsersOutputArgs ¶
type UsersOutputArgs struct { AccountName pulumi.StringPtrInput `pulumi:"accountName"` InstanceId pulumi.StringInput `pulumi:"instanceId"` ResultOutputFile pulumi.StringPtrInput `pulumi:"resultOutputFile"` }
A collection of arguments for invoking Users.
func (UsersOutputArgs) ElementType ¶
func (UsersOutputArgs) ElementType() reflect.Type
type UsersResult ¶
type UsersResult struct { AccountName *string `pulumi:"accountName"` // The provider-assigned unique ID for this managed resource. Id string `pulumi:"id"` InstanceId string `pulumi:"instanceId"` ResultOutputFile *string `pulumi:"resultOutputFile"` UserLists []UsersUserList `pulumi:"userLists"` }
A collection of values returned by Users.
func Users ¶
func Users(ctx *pulumi.Context, args *UsersArgs, opts ...pulumi.InvokeOption) (*UsersResult, error)
type UsersResultOutput ¶
type UsersResultOutput struct{ *pulumi.OutputState }
A collection of values returned by Users.
func UsersOutput ¶
func UsersOutput(ctx *pulumi.Context, args UsersOutputArgs, opts ...pulumi.InvokeOption) UsersResultOutput
func (UsersResultOutput) AccountName ¶
func (o UsersResultOutput) AccountName() pulumi.StringPtrOutput
func (UsersResultOutput) ElementType ¶
func (UsersResultOutput) ElementType() reflect.Type
func (UsersResultOutput) Id ¶
func (o UsersResultOutput) Id() pulumi.StringOutput
The provider-assigned unique ID for this managed resource.
func (UsersResultOutput) InstanceId ¶
func (o UsersResultOutput) InstanceId() pulumi.StringOutput
func (UsersResultOutput) ResultOutputFile ¶
func (o UsersResultOutput) ResultOutputFile() pulumi.StringPtrOutput
func (UsersResultOutput) ToUsersResultOutput ¶
func (o UsersResultOutput) ToUsersResultOutput() UsersResultOutput
func (UsersResultOutput) ToUsersResultOutputWithContext ¶
func (o UsersResultOutput) ToUsersResultOutputWithContext(ctx context.Context) UsersResultOutput
func (UsersResultOutput) UserLists ¶
func (o UsersResultOutput) UserLists() UsersUserListArrayOutput
type UsersUserList ¶
type UsersUserListArgs ¶
type UsersUserListArgs struct { AccountName pulumi.StringInput `pulumi:"accountName"` CreateTime pulumi.StringInput `pulumi:"createTime"` UpdateTime pulumi.StringInput `pulumi:"updateTime"` }
func (UsersUserListArgs) ElementType ¶
func (UsersUserListArgs) ElementType() reflect.Type
func (UsersUserListArgs) ToUsersUserListOutput ¶
func (i UsersUserListArgs) ToUsersUserListOutput() UsersUserListOutput
func (UsersUserListArgs) ToUsersUserListOutputWithContext ¶
func (i UsersUserListArgs) ToUsersUserListOutputWithContext(ctx context.Context) UsersUserListOutput
type UsersUserListArray ¶
type UsersUserListArray []UsersUserListInput
func (UsersUserListArray) ElementType ¶
func (UsersUserListArray) ElementType() reflect.Type
func (UsersUserListArray) ToUsersUserListArrayOutput ¶
func (i UsersUserListArray) ToUsersUserListArrayOutput() UsersUserListArrayOutput
func (UsersUserListArray) ToUsersUserListArrayOutputWithContext ¶
func (i UsersUserListArray) ToUsersUserListArrayOutputWithContext(ctx context.Context) UsersUserListArrayOutput
type UsersUserListArrayInput ¶
type UsersUserListArrayInput interface { pulumi.Input ToUsersUserListArrayOutput() UsersUserListArrayOutput ToUsersUserListArrayOutputWithContext(context.Context) UsersUserListArrayOutput }
UsersUserListArrayInput is an input type that accepts UsersUserListArray and UsersUserListArrayOutput values. You can construct a concrete instance of `UsersUserListArrayInput` via:
UsersUserListArray{ UsersUserListArgs{...} }
type UsersUserListArrayOutput ¶
type UsersUserListArrayOutput struct{ *pulumi.OutputState }
func (UsersUserListArrayOutput) ElementType ¶
func (UsersUserListArrayOutput) ElementType() reflect.Type
func (UsersUserListArrayOutput) Index ¶
func (o UsersUserListArrayOutput) Index(i pulumi.IntInput) UsersUserListOutput
func (UsersUserListArrayOutput) ToUsersUserListArrayOutput ¶
func (o UsersUserListArrayOutput) ToUsersUserListArrayOutput() UsersUserListArrayOutput
func (UsersUserListArrayOutput) ToUsersUserListArrayOutputWithContext ¶
func (o UsersUserListArrayOutput) ToUsersUserListArrayOutputWithContext(ctx context.Context) UsersUserListArrayOutput
type UsersUserListInput ¶
type UsersUserListInput interface { pulumi.Input ToUsersUserListOutput() UsersUserListOutput ToUsersUserListOutputWithContext(context.Context) UsersUserListOutput }
UsersUserListInput is an input type that accepts UsersUserListArgs and UsersUserListOutput values. You can construct a concrete instance of `UsersUserListInput` via:
UsersUserListArgs{...}
type UsersUserListOutput ¶
type UsersUserListOutput struct{ *pulumi.OutputState }
func (UsersUserListOutput) AccountName ¶
func (o UsersUserListOutput) AccountName() pulumi.StringOutput
func (UsersUserListOutput) CreateTime ¶
func (o UsersUserListOutput) CreateTime() pulumi.StringOutput
func (UsersUserListOutput) ElementType ¶
func (UsersUserListOutput) ElementType() reflect.Type
func (UsersUserListOutput) ToUsersUserListOutput ¶
func (o UsersUserListOutput) ToUsersUserListOutput() UsersUserListOutput
func (UsersUserListOutput) ToUsersUserListOutputWithContext ¶
func (o UsersUserListOutput) ToUsersUserListOutputWithContext(ctx context.Context) UsersUserListOutput
func (UsersUserListOutput) UpdateTime ¶
func (o UsersUserListOutput) UpdateTime() pulumi.StringOutput