msk

package
v0.108.1 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterEncryptionInTransitClientBrokerTls          = ClusterEncryptionInTransitClientBroker("TLS")
	ClusterEncryptionInTransitClientBrokerTlsPlaintext = ClusterEncryptionInTransitClientBroker("TLS_PLAINTEXT")
	ClusterEncryptionInTransitClientBrokerPlaintext    = ClusterEncryptionInTransitClientBroker("PLAINTEXT")
)
View Source 
const (
	ClusterEnhancedMonitoringDefault              = ClusterEnhancedMonitoring("DEFAULT")
	ClusterEnhancedMonitoringPerBroker            = ClusterEnhancedMonitoring("PER_BROKER")
	ClusterEnhancedMonitoringPerTopicPerBroker    = ClusterEnhancedMonitoring("PER_TOPIC_PER_BROKER")
	ClusterEnhancedMonitoringPerTopicPerPartition = ClusterEnhancedMonitoring("PER_TOPIC_PER_PARTITION")
)
View Source 
const (
	ClusterStorageModeLocal  = ClusterStorageMode("LOCAL")
	ClusterStorageModeTiered = ClusterStorageMode("TIERED")
)
View Source 
const (
	ReplicatorReplicationInfoTargetCompressionTypeNone   = ReplicatorReplicationInfoTargetCompressionType("NONE")
	ReplicatorReplicationInfoTargetCompressionTypeGzip   = ReplicatorReplicationInfoTargetCompressionType("GZIP")
	ReplicatorReplicationInfoTargetCompressionTypeSnappy = ReplicatorReplicationInfoTargetCompressionType("SNAPPY")
	ReplicatorReplicationInfoTargetCompressionTypeLz4    = ReplicatorReplicationInfoTargetCompressionType("LZ4")
	ReplicatorReplicationInfoTargetCompressionTypeZstd   = ReplicatorReplicationInfoTargetCompressionType("ZSTD")
)
View Source 
const (
	ReplicatorReplicationStartingPositionTypeLatest   = ReplicatorReplicationStartingPositionType("LATEST")
	ReplicatorReplicationStartingPositionTypeEarliest = ReplicatorReplicationStartingPositionType("EARLIEST")
)
View Source 
const (
	VpcConnectionAuthenticationSaslIam   = VpcConnectionAuthentication("SASL_IAM")
	VpcConnectionAuthenticationSaslScram = VpcConnectionAuthentication("SASL_SCRAM")
	VpcConnectionAuthenticationTls       = VpcConnectionAuthentication("TLS")
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchScramSecret added in v0.14.0 

type BatchScramSecret struct {
	pulumi.CustomResourceState

	ClusterArn    pulumi.StringOutput      `pulumi:"clusterArn"`
	SecretArnList pulumi.StringArrayOutput `pulumi:"secretArnList"`
}

Resource Type definition for AWS::MSK::BatchScramSecret

func GetBatchScramSecret added in v0.14.0 

func GetBatchScramSecret(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *BatchScramSecretState, opts ...pulumi.ResourceOption) (*BatchScramSecret, error)

GetBatchScramSecret gets an existing BatchScramSecret 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 NewBatchScramSecret added in v0.14.0 

func NewBatchScramSecret(ctx *pulumi.Context,
	name string, args *BatchScramSecretArgs, opts ...pulumi.ResourceOption) (*BatchScramSecret, error)

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

func (*BatchScramSecret) ElementType added in v0.14.0 

func (*BatchScramSecret) ElementType() reflect.Type

func (*BatchScramSecret) ToBatchScramSecretOutput added in v0.14.0 

func (i *BatchScramSecret) ToBatchScramSecretOutput() BatchScramSecretOutput

func (*BatchScramSecret) ToBatchScramSecretOutputWithContext added in v0.14.0 

func (i *BatchScramSecret) ToBatchScramSecretOutputWithContext(ctx context.Context) BatchScramSecretOutput

type BatchScramSecretArgs added in v0.14.0 

type BatchScramSecretArgs struct {
	ClusterArn    pulumi.StringInput
	SecretArnList pulumi.StringArrayInput
}

The set of arguments for constructing a BatchScramSecret resource.

func (BatchScramSecretArgs) ElementType added in v0.14.0 

func (BatchScramSecretArgs) ElementType() reflect.Type

type BatchScramSecretInput added in v0.14.0 

type BatchScramSecretInput interface {
	pulumi.Input

	ToBatchScramSecretOutput() BatchScramSecretOutput
	ToBatchScramSecretOutputWithContext(ctx context.Context) BatchScramSecretOutput
}

type BatchScramSecretOutput added in v0.14.0 

type BatchScramSecretOutput struct{ *pulumi.OutputState }

func (BatchScramSecretOutput) ClusterArn added in v0.17.0 

func (o BatchScramSecretOutput) ClusterArn() pulumi.StringOutput

func (BatchScramSecretOutput) ElementType added in v0.14.0 

func (BatchScramSecretOutput) ElementType() reflect.Type

func (BatchScramSecretOutput) SecretArnList added in v0.17.0 

func (o BatchScramSecretOutput) SecretArnList() pulumi.StringArrayOutput

func (BatchScramSecretOutput) ToBatchScramSecretOutput added in v0.14.0 

func (o BatchScramSecretOutput) ToBatchScramSecretOutput() BatchScramSecretOutput

func (BatchScramSecretOutput) ToBatchScramSecretOutputWithContext added in v0.14.0 

func (o BatchScramSecretOutput) ToBatchScramSecretOutputWithContext(ctx context.Context) BatchScramSecretOutput

type BatchScramSecretState added in v0.14.0 

type BatchScramSecretState struct {
}

func (BatchScramSecretState) ElementType added in v0.14.0 

func (BatchScramSecretState) ElementType() reflect.Type

type Cluster 

type Cluster struct {
	pulumi.CustomResourceState

	Arn pulumi.StringOutput `pulumi:"arn"`
	// Information about the broker nodes in the cluster.
	BrokerNodeGroupInfo ClusterBrokerNodeGroupInfoOutput `pulumi:"brokerNodeGroupInfo"`
	// VPC connection control settings for brokers.
	ClientAuthentication ClusterClientAuthenticationPtrOutput `pulumi:"clientAuthentication"`
	// The name of the cluster.
	ClusterName pulumi.StringOutput `pulumi:"clusterName"`
	// Represents the configuration that you want MSK to use for the cluster.
	ConfigurationInfo ClusterConfigurationInfoPtrOutput `pulumi:"configurationInfo"`
	// The current version of the MSK cluster
	CurrentVersion pulumi.StringPtrOutput `pulumi:"currentVersion"`
	// Includes all encryption-related information.
	EncryptionInfo ClusterEncryptionInfoPtrOutput `pulumi:"encryptionInfo"`
	// Specifies the level of monitoring for the MSK cluster. The possible values are `DEFAULT` , `PER_BROKER` , and `PER_TOPIC_PER_BROKER` .
	EnhancedMonitoring ClusterEnhancedMonitoringPtrOutput `pulumi:"enhancedMonitoring"`
	// The version of Apache Kafka. You can use Amazon MSK to create clusters that use Apache Kafka versions 1.1.1 and 2.2.1.
	KafkaVersion pulumi.StringOutput `pulumi:"kafkaVersion"`
	// Logging Info details.
	LoggingInfo ClusterLoggingInfoPtrOutput `pulumi:"loggingInfo"`
	// The number of broker nodes in the cluster.
	NumberOfBrokerNodes pulumi.IntOutput `pulumi:"numberOfBrokerNodes"`
	// The settings for open monitoring.
	OpenMonitoring ClusterOpenMonitoringPtrOutput `pulumi:"openMonitoring"`
	// This controls storage mode for supported storage tiers.
	StorageMode ClusterStorageModePtrOutput `pulumi:"storageMode"`
	// A key-value pair to associate with a resource.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
}

Resource Type definition for AWS::MSK::Cluster

func GetCluster 

func GetCluster(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ClusterState, opts ...pulumi.ResourceOption) (*Cluster, error)

GetCluster gets an existing Cluster 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 NewCluster 

func NewCluster(ctx *pulumi.Context,
	name string, args *ClusterArgs, opts ...pulumi.ResourceOption) (*Cluster, error)

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

func (*Cluster) ElementType 

func (*Cluster) ElementType() reflect.Type

func (*Cluster) ToClusterOutput 

func (i *Cluster) ToClusterOutput() ClusterOutput

func (*Cluster) ToClusterOutputWithContext 

func (i *Cluster) ToClusterOutputWithContext(ctx context.Context) ClusterOutput

type ClusterArgs 

type ClusterArgs struct {
	// Information about the broker nodes in the cluster.
	BrokerNodeGroupInfo ClusterBrokerNodeGroupInfoInput
	// VPC connection control settings for brokers.
	ClientAuthentication ClusterClientAuthenticationPtrInput
	// The name of the cluster.
	ClusterName pulumi.StringPtrInput
	// Represents the configuration that you want MSK to use for the cluster.
	ConfigurationInfo ClusterConfigurationInfoPtrInput
	// The current version of the MSK cluster
	CurrentVersion pulumi.StringPtrInput
	// Includes all encryption-related information.
	EncryptionInfo ClusterEncryptionInfoPtrInput
	// Specifies the level of monitoring for the MSK cluster. The possible values are `DEFAULT` , `PER_BROKER` , and `PER_TOPIC_PER_BROKER` .
	EnhancedMonitoring ClusterEnhancedMonitoringPtrInput
	// The version of Apache Kafka. You can use Amazon MSK to create clusters that use Apache Kafka versions 1.1.1 and 2.2.1.
	KafkaVersion pulumi.StringInput
	// Logging Info details.
	LoggingInfo ClusterLoggingInfoPtrInput
	// The number of broker nodes in the cluster.
	NumberOfBrokerNodes pulumi.IntInput
	// The settings for open monitoring.
	OpenMonitoring ClusterOpenMonitoringPtrInput
	// This controls storage mode for supported storage tiers.
	StorageMode ClusterStorageModePtrInput
	// A key-value pair to associate with a resource.
	Tags pulumi.StringMapInput
}

The set of arguments for constructing a Cluster resource.

func (ClusterArgs) ElementType 

func (ClusterArgs) ElementType() reflect.Type

type ClusterBrokerLogs 

type ClusterBrokerLogs struct {
	// Details of the CloudWatch Logs destination for broker logs.
	CloudWatchLogs *ClusterCloudWatchLogs `pulumi:"cloudWatchLogs"`
	// Details of the Kinesis Data Firehose delivery stream that is the destination for broker logs.
	Firehose *ClusterFirehose `pulumi:"firehose"`
	// Details of the Amazon S3 destination for broker logs.
	S3 *ClusterS3 `pulumi:"s3"`
}

type ClusterBrokerLogsArgs 

type ClusterBrokerLogsArgs struct {
	// Details of the CloudWatch Logs destination for broker logs.
	CloudWatchLogs ClusterCloudWatchLogsPtrInput `pulumi:"cloudWatchLogs"`
	// Details of the Kinesis Data Firehose delivery stream that is the destination for broker logs.
	Firehose ClusterFirehosePtrInput `pulumi:"firehose"`
	// Details of the Amazon S3 destination for broker logs.
	S3 ClusterS3PtrInput `pulumi:"s3"`
}

func (ClusterBrokerLogsArgs) ElementType 

func (ClusterBrokerLogsArgs) ElementType() reflect.Type

func (ClusterBrokerLogsArgs) ToClusterBrokerLogsOutput 

func (i ClusterBrokerLogsArgs) ToClusterBrokerLogsOutput() ClusterBrokerLogsOutput

func (ClusterBrokerLogsArgs) ToClusterBrokerLogsOutputWithContext 

func (i ClusterBrokerLogsArgs) ToClusterBrokerLogsOutputWithContext(ctx context.Context) ClusterBrokerLogsOutput

func (ClusterBrokerLogsArgs) ToClusterBrokerLogsPtrOutput 

func (i ClusterBrokerLogsArgs) ToClusterBrokerLogsPtrOutput() ClusterBrokerLogsPtrOutput

func (ClusterBrokerLogsArgs) ToClusterBrokerLogsPtrOutputWithContext 

func (i ClusterBrokerLogsArgs) ToClusterBrokerLogsPtrOutputWithContext(ctx context.Context) ClusterBrokerLogsPtrOutput

type ClusterBrokerLogsInput 

type ClusterBrokerLogsInput interface {
	pulumi.Input

	ToClusterBrokerLogsOutput() ClusterBrokerLogsOutput
	ToClusterBrokerLogsOutputWithContext(context.Context) ClusterBrokerLogsOutput
}

ClusterBrokerLogsInput is an input type that accepts ClusterBrokerLogsArgs and ClusterBrokerLogsOutput values. You can construct a concrete instance of `ClusterBrokerLogsInput` via: 

ClusterBrokerLogsArgs{...}

type ClusterBrokerLogsOutput 

type ClusterBrokerLogsOutput struct{ *pulumi.OutputState }

func (ClusterBrokerLogsOutput) CloudWatchLogs 

func (o ClusterBrokerLogsOutput) CloudWatchLogs() ClusterCloudWatchLogsPtrOutput

Details of the CloudWatch Logs destination for broker logs.

func (ClusterBrokerLogsOutput) ElementType 

func (ClusterBrokerLogsOutput) ElementType() reflect.Type

func (ClusterBrokerLogsOutput) Firehose 

func (o ClusterBrokerLogsOutput) Firehose() ClusterFirehosePtrOutput

Details of the Kinesis Data Firehose delivery stream that is the destination for broker logs.

func (ClusterBrokerLogsOutput) S3 

func (o ClusterBrokerLogsOutput) S3() ClusterS3PtrOutput

Details of the Amazon S3 destination for broker logs.

func (ClusterBrokerLogsOutput) ToClusterBrokerLogsOutput 

func (o ClusterBrokerLogsOutput) ToClusterBrokerLogsOutput() ClusterBrokerLogsOutput

func (ClusterBrokerLogsOutput) ToClusterBrokerLogsOutputWithContext 

func (o ClusterBrokerLogsOutput) ToClusterBrokerLogsOutputWithContext(ctx context.Context) ClusterBrokerLogsOutput

func (ClusterBrokerLogsOutput) ToClusterBrokerLogsPtrOutput 

func (o ClusterBrokerLogsOutput) ToClusterBrokerLogsPtrOutput() ClusterBrokerLogsPtrOutput

func (ClusterBrokerLogsOutput) ToClusterBrokerLogsPtrOutputWithContext 

func (o ClusterBrokerLogsOutput) ToClusterBrokerLogsPtrOutputWithContext(ctx context.Context) ClusterBrokerLogsPtrOutput

type ClusterBrokerLogsPtrInput 

type ClusterBrokerLogsPtrInput interface {
	pulumi.Input

	ToClusterBrokerLogsPtrOutput() ClusterBrokerLogsPtrOutput
	ToClusterBrokerLogsPtrOutputWithContext(context.Context) ClusterBrokerLogsPtrOutput
}

ClusterBrokerLogsPtrInput is an input type that accepts ClusterBrokerLogsArgs, ClusterBrokerLogsPtr and ClusterBrokerLogsPtrOutput values. You can construct a concrete instance of `ClusterBrokerLogsPtrInput` via: 

        ClusterBrokerLogsArgs{...}

or:

        nil

func ClusterBrokerLogsPtr 

func ClusterBrokerLogsPtr(v *ClusterBrokerLogsArgs) ClusterBrokerLogsPtrInput

type ClusterBrokerLogsPtrOutput 

type ClusterBrokerLogsPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerLogsPtrOutput) CloudWatchLogs 

func (o ClusterBrokerLogsPtrOutput) CloudWatchLogs() ClusterCloudWatchLogsPtrOutput

Details of the CloudWatch Logs destination for broker logs.

func (ClusterBrokerLogsPtrOutput) Elem 

func (o ClusterBrokerLogsPtrOutput) Elem() ClusterBrokerLogsOutput

func (ClusterBrokerLogsPtrOutput) ElementType 

func (ClusterBrokerLogsPtrOutput) ElementType() reflect.Type

func (ClusterBrokerLogsPtrOutput) Firehose 

func (o ClusterBrokerLogsPtrOutput) Firehose() ClusterFirehosePtrOutput

Details of the Kinesis Data Firehose delivery stream that is the destination for broker logs.

func (ClusterBrokerLogsPtrOutput) S3 

func (o ClusterBrokerLogsPtrOutput) S3() ClusterS3PtrOutput

Details of the Amazon S3 destination for broker logs.

func (ClusterBrokerLogsPtrOutput) ToClusterBrokerLogsPtrOutput 

func (o ClusterBrokerLogsPtrOutput) ToClusterBrokerLogsPtrOutput() ClusterBrokerLogsPtrOutput

func (ClusterBrokerLogsPtrOutput) ToClusterBrokerLogsPtrOutputWithContext 

func (o ClusterBrokerLogsPtrOutput) ToClusterBrokerLogsPtrOutputWithContext(ctx context.Context) ClusterBrokerLogsPtrOutput

type ClusterBrokerNodeGroupInfo 

type ClusterBrokerNodeGroupInfo struct {
	// This parameter is currently not in use.
	BrokerAzDistribution *string `pulumi:"brokerAzDistribution"`
	// The list of subnets to connect to in the client virtual private cloud (VPC). Amazon creates elastic network interfaces inside these subnets. Client applications use elastic network interfaces to produce and consume data.
	//
	// If you use the US West (N. California) Region, specify exactly two subnets. For other Regions where Amazon MSK is available, you can specify either two or three subnets. The subnets that you specify must be in distinct Availability Zones. When you create a cluster, Amazon MSK distributes the broker nodes evenly across the subnets that you specify.
	//
	// Client subnets can't occupy the Availability Zone with ID `use1-az3` .
	ClientSubnets []string `pulumi:"clientSubnets"`
	// Information about the cluster's connectivity setting.
	ConnectivityInfo *ClusterConnectivityInfo `pulumi:"connectivityInfo"`
	// The type of Amazon EC2 instances to use for brokers. The following instance types are allowed: kafka.m5.large, kafka.m5.xlarge, kafka.m5.2xlarge, kafka.m5.4xlarge, kafka.m5.8xlarge, kafka.m5.12xlarge, kafka.m5.16xlarge, kafka.m5.24xlarge, and kafka.t3.small.
	InstanceType string `pulumi:"instanceType"`
	// The security groups to associate with the elastic network interfaces in order to specify who can connect to and communicate with the Amazon MSK cluster. If you don't specify a security group, Amazon MSK uses the default security group associated with the VPC. If you specify security groups that were shared with you, you must ensure that you have permissions to them. Specifically, you need the `ec2:DescribeSecurityGroups` permission.
	SecurityGroups []string `pulumi:"securityGroups"`
	// Contains information about storage volumes attached to Amazon MSK broker nodes.
	StorageInfo *ClusterStorageInfo `pulumi:"storageInfo"`
}

type ClusterBrokerNodeGroupInfoArgs 

type ClusterBrokerNodeGroupInfoArgs struct {
	// This parameter is currently not in use.
	BrokerAzDistribution pulumi.StringPtrInput `pulumi:"brokerAzDistribution"`
	// The list of subnets to connect to in the client virtual private cloud (VPC). Amazon creates elastic network interfaces inside these subnets. Client applications use elastic network interfaces to produce and consume data.
	//
	// If you use the US West (N. California) Region, specify exactly two subnets. For other Regions where Amazon MSK is available, you can specify either two or three subnets. The subnets that you specify must be in distinct Availability Zones. When you create a cluster, Amazon MSK distributes the broker nodes evenly across the subnets that you specify.
	//
	// Client subnets can't occupy the Availability Zone with ID `use1-az3` .
	ClientSubnets pulumi.StringArrayInput `pulumi:"clientSubnets"`
	// Information about the cluster's connectivity setting.
	ConnectivityInfo ClusterConnectivityInfoPtrInput `pulumi:"connectivityInfo"`
	// The type of Amazon EC2 instances to use for brokers. The following instance types are allowed: kafka.m5.large, kafka.m5.xlarge, kafka.m5.2xlarge, kafka.m5.4xlarge, kafka.m5.8xlarge, kafka.m5.12xlarge, kafka.m5.16xlarge, kafka.m5.24xlarge, and kafka.t3.small.
	InstanceType pulumi.StringInput `pulumi:"instanceType"`
	// The security groups to associate with the elastic network interfaces in order to specify who can connect to and communicate with the Amazon MSK cluster. If you don't specify a security group, Amazon MSK uses the default security group associated with the VPC. If you specify security groups that were shared with you, you must ensure that you have permissions to them. Specifically, you need the `ec2:DescribeSecurityGroups` permission.
	SecurityGroups pulumi.StringArrayInput `pulumi:"securityGroups"`
	// Contains information about storage volumes attached to Amazon MSK broker nodes.
	StorageInfo ClusterStorageInfoPtrInput `pulumi:"storageInfo"`
}

func (ClusterBrokerNodeGroupInfoArgs) ElementType 

func (ClusterBrokerNodeGroupInfoArgs) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoOutput 

func (i ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoOutput() ClusterBrokerNodeGroupInfoOutput

func (ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoOutputWithContext 

func (i ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoOutput

type ClusterBrokerNodeGroupInfoInput 

type ClusterBrokerNodeGroupInfoInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoOutput() ClusterBrokerNodeGroupInfoOutput
	ToClusterBrokerNodeGroupInfoOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoOutput
}

ClusterBrokerNodeGroupInfoInput is an input type that accepts ClusterBrokerNodeGroupInfoArgs and ClusterBrokerNodeGroupInfoOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoInput` via: 

ClusterBrokerNodeGroupInfoArgs{...}

type ClusterBrokerNodeGroupInfoOutput 

type ClusterBrokerNodeGroupInfoOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoOutput) BrokerAzDistribution added in v0.72.0 

func (o ClusterBrokerNodeGroupInfoOutput) BrokerAzDistribution() pulumi.StringPtrOutput

This parameter is currently not in use.

func (ClusterBrokerNodeGroupInfoOutput) ClientSubnets 

func (o ClusterBrokerNodeGroupInfoOutput) ClientSubnets() pulumi.StringArrayOutput

The list of subnets to connect to in the client virtual private cloud (VPC). Amazon creates elastic network interfaces inside these subnets. Client applications use elastic network interfaces to produce and consume data.

If you use the US West (N. California) Region, specify exactly two subnets. For other Regions where Amazon MSK is available, you can specify either two or three subnets. The subnets that you specify must be in distinct Availability Zones. When you create a cluster, Amazon MSK distributes the broker nodes evenly across the subnets that you specify.

Client subnets can't occupy the Availability Zone with ID `use1-az3` .

func (ClusterBrokerNodeGroupInfoOutput) ConnectivityInfo added in v0.7.0 

func (o ClusterBrokerNodeGroupInfoOutput) ConnectivityInfo() ClusterConnectivityInfoPtrOutput

Information about the cluster's connectivity setting.

func (ClusterBrokerNodeGroupInfoOutput) ElementType 

func (ClusterBrokerNodeGroupInfoOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoOutput) InstanceType 

func (o ClusterBrokerNodeGroupInfoOutput) InstanceType() pulumi.StringOutput

The type of Amazon EC2 instances to use for brokers. The following instance types are allowed: kafka.m5.large, kafka.m5.xlarge, kafka.m5.2xlarge, kafka.m5.4xlarge, kafka.m5.8xlarge, kafka.m5.12xlarge, kafka.m5.16xlarge, kafka.m5.24xlarge, and kafka.t3.small.

func (ClusterBrokerNodeGroupInfoOutput) SecurityGroups 

func (o ClusterBrokerNodeGroupInfoOutput) SecurityGroups() pulumi.StringArrayOutput

The security groups to associate with the elastic network interfaces in order to specify who can connect to and communicate with the Amazon MSK cluster. If you don't specify a security group, Amazon MSK uses the default security group associated with the VPC. If you specify security groups that were shared with you, you must ensure that you have permissions to them. Specifically, you need the `ec2:DescribeSecurityGroups` permission.

func (ClusterBrokerNodeGroupInfoOutput) StorageInfo 

func (o ClusterBrokerNodeGroupInfoOutput) StorageInfo() ClusterStorageInfoPtrOutput

Contains information about storage volumes attached to Amazon MSK broker nodes.

func (ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoOutput 

func (o ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoOutput() ClusterBrokerNodeGroupInfoOutput

func (ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoOutputWithContext 

func (o ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoOutput

type ClusterBrokerNodeGroupInfoPtrOutput 

type ClusterBrokerNodeGroupInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoPtrOutput) BrokerAzDistribution added in v0.72.0 

func (o ClusterBrokerNodeGroupInfoPtrOutput) BrokerAzDistribution() pulumi.StringPtrOutput

This parameter is currently not in use.

func (ClusterBrokerNodeGroupInfoPtrOutput) ClientSubnets 

func (o ClusterBrokerNodeGroupInfoPtrOutput) ClientSubnets() pulumi.StringArrayOutput

The list of subnets to connect to in the client virtual private cloud (VPC). Amazon creates elastic network interfaces inside these subnets. Client applications use elastic network interfaces to produce and consume data.

If you use the US West (N. California) Region, specify exactly two subnets. For other Regions where Amazon MSK is available, you can specify either two or three subnets. The subnets that you specify must be in distinct Availability Zones. When you create a cluster, Amazon MSK distributes the broker nodes evenly across the subnets that you specify.

Client subnets can't occupy the Availability Zone with ID `use1-az3` .

func (ClusterBrokerNodeGroupInfoPtrOutput) ConnectivityInfo added in v0.7.0 

func (o ClusterBrokerNodeGroupInfoPtrOutput) ConnectivityInfo() ClusterConnectivityInfoPtrOutput

Information about the cluster's connectivity setting.

func (ClusterBrokerNodeGroupInfoPtrOutput) Elem 

func (o ClusterBrokerNodeGroupInfoPtrOutput) Elem() ClusterBrokerNodeGroupInfoOutput

func (ClusterBrokerNodeGroupInfoPtrOutput) ElementType 

func (ClusterBrokerNodeGroupInfoPtrOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoPtrOutput) InstanceType 

func (o ClusterBrokerNodeGroupInfoPtrOutput) InstanceType() pulumi.StringPtrOutput

The type of Amazon EC2 instances to use for brokers. The following instance types are allowed: kafka.m5.large, kafka.m5.xlarge, kafka.m5.2xlarge, kafka.m5.4xlarge, kafka.m5.8xlarge, kafka.m5.12xlarge, kafka.m5.16xlarge, kafka.m5.24xlarge, and kafka.t3.small.

func (ClusterBrokerNodeGroupInfoPtrOutput) SecurityGroups 

func (o ClusterBrokerNodeGroupInfoPtrOutput) SecurityGroups() pulumi.StringArrayOutput

The security groups to associate with the elastic network interfaces in order to specify who can connect to and communicate with the Amazon MSK cluster. If you don't specify a security group, Amazon MSK uses the default security group associated with the VPC. If you specify security groups that were shared with you, you must ensure that you have permissions to them. Specifically, you need the `ec2:DescribeSecurityGroups` permission.

func (ClusterBrokerNodeGroupInfoPtrOutput) StorageInfo 

func (o ClusterBrokerNodeGroupInfoPtrOutput) StorageInfo() ClusterStorageInfoPtrOutput

Contains information about storage volumes attached to Amazon MSK broker nodes.

func (ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutput 

func (o ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutput() ClusterBrokerNodeGroupInfoPtrOutput

func (ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutputWithContext 

func (o ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoPtrOutput

type ClusterClientAuthentication 

type ClusterClientAuthentication struct {
	// Details for client authentication using SASL. To turn on SASL, you must also turn on `EncryptionInTransit` by setting `inCluster` to true. You must set `clientBroker` to either `TLS` or `TLS_PLAINTEXT` . If you choose `TLS_PLAINTEXT` , then you must also set `unauthenticated` to true.
	Sasl *ClusterSasl `pulumi:"sasl"`
	// Details for ClientAuthentication using TLS. To turn on TLS access control, you must also turn on `EncryptionInTransit` by setting `inCluster` to true and `clientBroker` to `TLS` .
	Tls *ClusterTls `pulumi:"tls"`
	// Details for ClientAuthentication using no authentication.
	Unauthenticated *ClusterUnauthenticated `pulumi:"unauthenticated"`
}

type ClusterClientAuthenticationArgs 

type ClusterClientAuthenticationArgs struct {
	// Details for client authentication using SASL. To turn on SASL, you must also turn on `EncryptionInTransit` by setting `inCluster` to true. You must set `clientBroker` to either `TLS` or `TLS_PLAINTEXT` . If you choose `TLS_PLAINTEXT` , then you must also set `unauthenticated` to true.
	Sasl ClusterSaslPtrInput `pulumi:"sasl"`
	// Details for ClientAuthentication using TLS. To turn on TLS access control, you must also turn on `EncryptionInTransit` by setting `inCluster` to true and `clientBroker` to `TLS` .
	Tls ClusterTlsPtrInput `pulumi:"tls"`
	// Details for ClientAuthentication using no authentication.
	Unauthenticated ClusterUnauthenticatedPtrInput `pulumi:"unauthenticated"`
}

func (ClusterClientAuthenticationArgs) ElementType 

func (ClusterClientAuthenticationArgs) ElementType() reflect.Type

func (ClusterClientAuthenticationArgs) ToClusterClientAuthenticationOutput 

func (i ClusterClientAuthenticationArgs) ToClusterClientAuthenticationOutput() ClusterClientAuthenticationOutput

func (ClusterClientAuthenticationArgs) ToClusterClientAuthenticationOutputWithContext 

func (i ClusterClientAuthenticationArgs) ToClusterClientAuthenticationOutputWithContext(ctx context.Context) ClusterClientAuthenticationOutput

func (ClusterClientAuthenticationArgs) ToClusterClientAuthenticationPtrOutput 

func (i ClusterClientAuthenticationArgs) ToClusterClientAuthenticationPtrOutput() ClusterClientAuthenticationPtrOutput

func (ClusterClientAuthenticationArgs) ToClusterClientAuthenticationPtrOutputWithContext 

func (i ClusterClientAuthenticationArgs) ToClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationPtrOutput

type ClusterClientAuthenticationInput 

type ClusterClientAuthenticationInput interface {
	pulumi.Input

	ToClusterClientAuthenticationOutput() ClusterClientAuthenticationOutput
	ToClusterClientAuthenticationOutputWithContext(context.Context) ClusterClientAuthenticationOutput
}

ClusterClientAuthenticationInput is an input type that accepts ClusterClientAuthenticationArgs and ClusterClientAuthenticationOutput values. You can construct a concrete instance of `ClusterClientAuthenticationInput` via: 

ClusterClientAuthenticationArgs{...}

type ClusterClientAuthenticationOutput 

type ClusterClientAuthenticationOutput struct{ *pulumi.OutputState }

func (ClusterClientAuthenticationOutput) ElementType 

func (ClusterClientAuthenticationOutput) ElementType() reflect.Type

func (ClusterClientAuthenticationOutput) Sasl 

func (o ClusterClientAuthenticationOutput) Sasl() ClusterSaslPtrOutput

Details for client authentication using SASL. To turn on SASL, you must also turn on `EncryptionInTransit` by setting `inCluster` to true. You must set `clientBroker` to either `TLS` or `TLS_PLAINTEXT` . If you choose `TLS_PLAINTEXT` , then you must also set `unauthenticated` to true.

func (ClusterClientAuthenticationOutput) Tls 

func (o ClusterClientAuthenticationOutput) Tls() ClusterTlsPtrOutput

Details for ClientAuthentication using TLS. To turn on TLS access control, you must also turn on `EncryptionInTransit` by setting `inCluster` to true and `clientBroker` to `TLS` .

func (ClusterClientAuthenticationOutput) ToClusterClientAuthenticationOutput 

func (o ClusterClientAuthenticationOutput) ToClusterClientAuthenticationOutput() ClusterClientAuthenticationOutput

func (ClusterClientAuthenticationOutput) ToClusterClientAuthenticationOutputWithContext 

func (o ClusterClientAuthenticationOutput) ToClusterClientAuthenticationOutputWithContext(ctx context.Context) ClusterClientAuthenticationOutput

func (ClusterClientAuthenticationOutput) ToClusterClientAuthenticationPtrOutput 

func (o ClusterClientAuthenticationOutput) ToClusterClientAuthenticationPtrOutput() ClusterClientAuthenticationPtrOutput

func (ClusterClientAuthenticationOutput) ToClusterClientAuthenticationPtrOutputWithContext 

func (o ClusterClientAuthenticationOutput) ToClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationPtrOutput

func (ClusterClientAuthenticationOutput) Unauthenticated 

func (o ClusterClientAuthenticationOutput) Unauthenticated() ClusterUnauthenticatedPtrOutput

Details for ClientAuthentication using no authentication.

type ClusterClientAuthenticationPtrInput 

type ClusterClientAuthenticationPtrInput interface {
	pulumi.Input

	ToClusterClientAuthenticationPtrOutput() ClusterClientAuthenticationPtrOutput
	ToClusterClientAuthenticationPtrOutputWithContext(context.Context) ClusterClientAuthenticationPtrOutput
}

ClusterClientAuthenticationPtrInput is an input type that accepts ClusterClientAuthenticationArgs, ClusterClientAuthenticationPtr and ClusterClientAuthenticationPtrOutput values. You can construct a concrete instance of `ClusterClientAuthenticationPtrInput` via: 

        ClusterClientAuthenticationArgs{...}

or:

        nil

func ClusterClientAuthenticationPtr 

func ClusterClientAuthenticationPtr(v *ClusterClientAuthenticationArgs) ClusterClientAuthenticationPtrInput

type ClusterClientAuthenticationPtrOutput 

type ClusterClientAuthenticationPtrOutput struct{ *pulumi.OutputState }

func (ClusterClientAuthenticationPtrOutput) Elem 

func (o ClusterClientAuthenticationPtrOutput) Elem() ClusterClientAuthenticationOutput

func (ClusterClientAuthenticationPtrOutput) ElementType 

func (ClusterClientAuthenticationPtrOutput) ElementType() reflect.Type

func (ClusterClientAuthenticationPtrOutput) Sasl 

func (o ClusterClientAuthenticationPtrOutput) Sasl() ClusterSaslPtrOutput

Details for client authentication using SASL. To turn on SASL, you must also turn on `EncryptionInTransit` by setting `inCluster` to true. You must set `clientBroker` to either `TLS` or `TLS_PLAINTEXT` . If you choose `TLS_PLAINTEXT` , then you must also set `unauthenticated` to true.

func (ClusterClientAuthenticationPtrOutput) Tls 

func (o ClusterClientAuthenticationPtrOutput) Tls() ClusterTlsPtrOutput

Details for ClientAuthentication using TLS. To turn on TLS access control, you must also turn on `EncryptionInTransit` by setting `inCluster` to true and `clientBroker` to `TLS` .

func (ClusterClientAuthenticationPtrOutput) ToClusterClientAuthenticationPtrOutput 

func (o ClusterClientAuthenticationPtrOutput) ToClusterClientAuthenticationPtrOutput() ClusterClientAuthenticationPtrOutput

func (ClusterClientAuthenticationPtrOutput) ToClusterClientAuthenticationPtrOutputWithContext 

func (o ClusterClientAuthenticationPtrOutput) ToClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationPtrOutput

func (ClusterClientAuthenticationPtrOutput) Unauthenticated 

func (o ClusterClientAuthenticationPtrOutput) Unauthenticated() ClusterUnauthenticatedPtrOutput

Details for ClientAuthentication using no authentication.

type ClusterCloudWatchLogs 

type ClusterCloudWatchLogs struct {
	// Specifies whether broker logs get sent to the specified CloudWatch Logs destination.
	Enabled bool `pulumi:"enabled"`
	// The CloudWatch log group that is the destination for broker logs.
	LogGroup *string `pulumi:"logGroup"`
}

type ClusterCloudWatchLogsArgs 

type ClusterCloudWatchLogsArgs struct {
	// Specifies whether broker logs get sent to the specified CloudWatch Logs destination.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// The CloudWatch log group that is the destination for broker logs.
	LogGroup pulumi.StringPtrInput `pulumi:"logGroup"`
}

func (ClusterCloudWatchLogsArgs) ElementType 

func (ClusterCloudWatchLogsArgs) ElementType() reflect.Type

func (ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsOutput 

func (i ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsOutput() ClusterCloudWatchLogsOutput

func (ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsOutputWithContext 

func (i ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsOutputWithContext(ctx context.Context) ClusterCloudWatchLogsOutput

func (ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsPtrOutput 

func (i ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsPtrOutput() ClusterCloudWatchLogsPtrOutput

func (ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsPtrOutputWithContext 

func (i ClusterCloudWatchLogsArgs) ToClusterCloudWatchLogsPtrOutputWithContext(ctx context.Context) ClusterCloudWatchLogsPtrOutput

type ClusterCloudWatchLogsInput 

type ClusterCloudWatchLogsInput interface {
	pulumi.Input

	ToClusterCloudWatchLogsOutput() ClusterCloudWatchLogsOutput
	ToClusterCloudWatchLogsOutputWithContext(context.Context) ClusterCloudWatchLogsOutput
}

ClusterCloudWatchLogsInput is an input type that accepts ClusterCloudWatchLogsArgs and ClusterCloudWatchLogsOutput values. You can construct a concrete instance of `ClusterCloudWatchLogsInput` via: 

ClusterCloudWatchLogsArgs{...}

type ClusterCloudWatchLogsOutput 

type ClusterCloudWatchLogsOutput struct{ *pulumi.OutputState }

func (ClusterCloudWatchLogsOutput) ElementType 

func (ClusterCloudWatchLogsOutput) ElementType() reflect.Type

func (ClusterCloudWatchLogsOutput) Enabled 

func (o ClusterCloudWatchLogsOutput) Enabled() pulumi.BoolOutput

Specifies whether broker logs get sent to the specified CloudWatch Logs destination.

func (ClusterCloudWatchLogsOutput) LogGroup 

func (o ClusterCloudWatchLogsOutput) LogGroup() pulumi.StringPtrOutput

The CloudWatch log group that is the destination for broker logs.

func (ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsOutput 

func (o ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsOutput() ClusterCloudWatchLogsOutput

func (ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsOutputWithContext 

func (o ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsOutputWithContext(ctx context.Context) ClusterCloudWatchLogsOutput

func (ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsPtrOutput 

func (o ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsPtrOutput() ClusterCloudWatchLogsPtrOutput

func (ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsPtrOutputWithContext 

func (o ClusterCloudWatchLogsOutput) ToClusterCloudWatchLogsPtrOutputWithContext(ctx context.Context) ClusterCloudWatchLogsPtrOutput

type ClusterCloudWatchLogsPtrInput 

type ClusterCloudWatchLogsPtrInput interface {
	pulumi.Input

	ToClusterCloudWatchLogsPtrOutput() ClusterCloudWatchLogsPtrOutput
	ToClusterCloudWatchLogsPtrOutputWithContext(context.Context) ClusterCloudWatchLogsPtrOutput
}

ClusterCloudWatchLogsPtrInput is an input type that accepts ClusterCloudWatchLogsArgs, ClusterCloudWatchLogsPtr and ClusterCloudWatchLogsPtrOutput values. You can construct a concrete instance of `ClusterCloudWatchLogsPtrInput` via: 

        ClusterCloudWatchLogsArgs{...}

or:

        nil

func ClusterCloudWatchLogsPtr 

func ClusterCloudWatchLogsPtr(v *ClusterCloudWatchLogsArgs) ClusterCloudWatchLogsPtrInput

type ClusterCloudWatchLogsPtrOutput 

type ClusterCloudWatchLogsPtrOutput struct{ *pulumi.OutputState }

func (ClusterCloudWatchLogsPtrOutput) Elem 

func (o ClusterCloudWatchLogsPtrOutput) Elem() ClusterCloudWatchLogsOutput

func (ClusterCloudWatchLogsPtrOutput) ElementType 

func (ClusterCloudWatchLogsPtrOutput) ElementType() reflect.Type

func (ClusterCloudWatchLogsPtrOutput) Enabled 

func (o ClusterCloudWatchLogsPtrOutput) Enabled() pulumi.BoolPtrOutput

Specifies whether broker logs get sent to the specified CloudWatch Logs destination.

func (ClusterCloudWatchLogsPtrOutput) LogGroup 

func (o ClusterCloudWatchLogsPtrOutput) LogGroup() pulumi.StringPtrOutput

The CloudWatch log group that is the destination for broker logs.

func (ClusterCloudWatchLogsPtrOutput) ToClusterCloudWatchLogsPtrOutput 

func (o ClusterCloudWatchLogsPtrOutput) ToClusterCloudWatchLogsPtrOutput() ClusterCloudWatchLogsPtrOutput

func (ClusterCloudWatchLogsPtrOutput) ToClusterCloudWatchLogsPtrOutputWithContext 

func (o ClusterCloudWatchLogsPtrOutput) ToClusterCloudWatchLogsPtrOutputWithContext(ctx context.Context) ClusterCloudWatchLogsPtrOutput

type ClusterConfigurationInfo 

type ClusterConfigurationInfo struct {
	// ARN of the configuration to use.
	Arn string `pulumi:"arn"`
	// The revision of the configuration to use.
	Revision int `pulumi:"revision"`
}

type ClusterConfigurationInfoArgs 

type ClusterConfigurationInfoArgs struct {
	// ARN of the configuration to use.
	Arn pulumi.StringInput `pulumi:"arn"`
	// The revision of the configuration to use.
	Revision pulumi.IntInput `pulumi:"revision"`
}

func (ClusterConfigurationInfoArgs) ElementType 

func (ClusterConfigurationInfoArgs) ElementType() reflect.Type

func (ClusterConfigurationInfoArgs) ToClusterConfigurationInfoOutput 

func (i ClusterConfigurationInfoArgs) ToClusterConfigurationInfoOutput() ClusterConfigurationInfoOutput

func (ClusterConfigurationInfoArgs) ToClusterConfigurationInfoOutputWithContext 

func (i ClusterConfigurationInfoArgs) ToClusterConfigurationInfoOutputWithContext(ctx context.Context) ClusterConfigurationInfoOutput

func (ClusterConfigurationInfoArgs) ToClusterConfigurationInfoPtrOutput 

func (i ClusterConfigurationInfoArgs) ToClusterConfigurationInfoPtrOutput() ClusterConfigurationInfoPtrOutput

func (ClusterConfigurationInfoArgs) ToClusterConfigurationInfoPtrOutputWithContext 

func (i ClusterConfigurationInfoArgs) ToClusterConfigurationInfoPtrOutputWithContext(ctx context.Context) ClusterConfigurationInfoPtrOutput

type ClusterConfigurationInfoInput 

type ClusterConfigurationInfoInput interface {
	pulumi.Input

	ToClusterConfigurationInfoOutput() ClusterConfigurationInfoOutput
	ToClusterConfigurationInfoOutputWithContext(context.Context) ClusterConfigurationInfoOutput
}

ClusterConfigurationInfoInput is an input type that accepts ClusterConfigurationInfoArgs and ClusterConfigurationInfoOutput values. You can construct a concrete instance of `ClusterConfigurationInfoInput` via: 

ClusterConfigurationInfoArgs{...}

type ClusterConfigurationInfoOutput 

type ClusterConfigurationInfoOutput struct{ *pulumi.OutputState }

func (ClusterConfigurationInfoOutput) Arn 

func (o ClusterConfigurationInfoOutput) Arn() pulumi.StringOutput

ARN of the configuration to use.

func (ClusterConfigurationInfoOutput) ElementType 

func (ClusterConfigurationInfoOutput) ElementType() reflect.Type

func (ClusterConfigurationInfoOutput) Revision 

func (o ClusterConfigurationInfoOutput) Revision() pulumi.IntOutput

The revision of the configuration to use.

func (ClusterConfigurationInfoOutput) ToClusterConfigurationInfoOutput 

func (o ClusterConfigurationInfoOutput) ToClusterConfigurationInfoOutput() ClusterConfigurationInfoOutput

func (ClusterConfigurationInfoOutput) ToClusterConfigurationInfoOutputWithContext 

func (o ClusterConfigurationInfoOutput) ToClusterConfigurationInfoOutputWithContext(ctx context.Context) ClusterConfigurationInfoOutput

func (ClusterConfigurationInfoOutput) ToClusterConfigurationInfoPtrOutput 

func (o ClusterConfigurationInfoOutput) ToClusterConfigurationInfoPtrOutput() ClusterConfigurationInfoPtrOutput

func (ClusterConfigurationInfoOutput) ToClusterConfigurationInfoPtrOutputWithContext 

func (o ClusterConfigurationInfoOutput) ToClusterConfigurationInfoPtrOutputWithContext(ctx context.Context) ClusterConfigurationInfoPtrOutput

type ClusterConfigurationInfoPtrInput 

type ClusterConfigurationInfoPtrInput interface {
	pulumi.Input

	ToClusterConfigurationInfoPtrOutput() ClusterConfigurationInfoPtrOutput
	ToClusterConfigurationInfoPtrOutputWithContext(context.Context) ClusterConfigurationInfoPtrOutput
}

ClusterConfigurationInfoPtrInput is an input type that accepts ClusterConfigurationInfoArgs, ClusterConfigurationInfoPtr and ClusterConfigurationInfoPtrOutput values. You can construct a concrete instance of `ClusterConfigurationInfoPtrInput` via: 

        ClusterConfigurationInfoArgs{...}

or:

        nil

func ClusterConfigurationInfoPtr 

func ClusterConfigurationInfoPtr(v *ClusterConfigurationInfoArgs) ClusterConfigurationInfoPtrInput

type ClusterConfigurationInfoPtrOutput 

type ClusterConfigurationInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterConfigurationInfoPtrOutput) Arn 

func (o ClusterConfigurationInfoPtrOutput) Arn() pulumi.StringPtrOutput

ARN of the configuration to use.

func (ClusterConfigurationInfoPtrOutput) Elem 

func (o ClusterConfigurationInfoPtrOutput) Elem() ClusterConfigurationInfoOutput

func (ClusterConfigurationInfoPtrOutput) ElementType 

func (ClusterConfigurationInfoPtrOutput) ElementType() reflect.Type

func (ClusterConfigurationInfoPtrOutput) Revision 

func (o ClusterConfigurationInfoPtrOutput) Revision() pulumi.IntPtrOutput

The revision of the configuration to use.

func (ClusterConfigurationInfoPtrOutput) ToClusterConfigurationInfoPtrOutput 

func (o ClusterConfigurationInfoPtrOutput) ToClusterConfigurationInfoPtrOutput() ClusterConfigurationInfoPtrOutput

func (ClusterConfigurationInfoPtrOutput) ToClusterConfigurationInfoPtrOutputWithContext 

func (o ClusterConfigurationInfoPtrOutput) ToClusterConfigurationInfoPtrOutputWithContext(ctx context.Context) ClusterConfigurationInfoPtrOutput

type ClusterConnectivityInfo added in v0.7.0 

type ClusterConnectivityInfo struct {
	// Access control settings for the cluster's brokers.
	PublicAccess *ClusterPublicAccess `pulumi:"publicAccess"`
	// VPC connection control settings for brokers
	VpcConnectivity *ClusterVpcConnectivity `pulumi:"vpcConnectivity"`
}

type ClusterConnectivityInfoArgs added in v0.7.0 

type ClusterConnectivityInfoArgs struct {
	// Access control settings for the cluster's brokers.
	PublicAccess ClusterPublicAccessPtrInput `pulumi:"publicAccess"`
	// VPC connection control settings for brokers
	VpcConnectivity ClusterVpcConnectivityPtrInput `pulumi:"vpcConnectivity"`
}

func (ClusterConnectivityInfoArgs) ElementType added in v0.7.0 

func (ClusterConnectivityInfoArgs) ElementType() reflect.Type

func (ClusterConnectivityInfoArgs) ToClusterConnectivityInfoOutput added in v0.7.0 

func (i ClusterConnectivityInfoArgs) ToClusterConnectivityInfoOutput() ClusterConnectivityInfoOutput

func (ClusterConnectivityInfoArgs) ToClusterConnectivityInfoOutputWithContext added in v0.7.0 

func (i ClusterConnectivityInfoArgs) ToClusterConnectivityInfoOutputWithContext(ctx context.Context) ClusterConnectivityInfoOutput

func (ClusterConnectivityInfoArgs) ToClusterConnectivityInfoPtrOutput added in v0.7.0 

func (i ClusterConnectivityInfoArgs) ToClusterConnectivityInfoPtrOutput() ClusterConnectivityInfoPtrOutput

func (ClusterConnectivityInfoArgs) ToClusterConnectivityInfoPtrOutputWithContext added in v0.7.0 

func (i ClusterConnectivityInfoArgs) ToClusterConnectivityInfoPtrOutputWithContext(ctx context.Context) ClusterConnectivityInfoPtrOutput

type ClusterConnectivityInfoInput added in v0.7.0 

type ClusterConnectivityInfoInput interface {
	pulumi.Input

	ToClusterConnectivityInfoOutput() ClusterConnectivityInfoOutput
	ToClusterConnectivityInfoOutputWithContext(context.Context) ClusterConnectivityInfoOutput
}

ClusterConnectivityInfoInput is an input type that accepts ClusterConnectivityInfoArgs and ClusterConnectivityInfoOutput values. You can construct a concrete instance of `ClusterConnectivityInfoInput` via: 

ClusterConnectivityInfoArgs{...}

type ClusterConnectivityInfoOutput added in v0.7.0 

type ClusterConnectivityInfoOutput struct{ *pulumi.OutputState }

func (ClusterConnectivityInfoOutput) ElementType added in v0.7.0 

func (ClusterConnectivityInfoOutput) ElementType() reflect.Type

func (ClusterConnectivityInfoOutput) PublicAccess added in v0.7.0 

func (o ClusterConnectivityInfoOutput) PublicAccess() ClusterPublicAccessPtrOutput

Access control settings for the cluster's brokers.

func (ClusterConnectivityInfoOutput) ToClusterConnectivityInfoOutput added in v0.7.0 

func (o ClusterConnectivityInfoOutput) ToClusterConnectivityInfoOutput() ClusterConnectivityInfoOutput

func (ClusterConnectivityInfoOutput) ToClusterConnectivityInfoOutputWithContext added in v0.7.0 

func (o ClusterConnectivityInfoOutput) ToClusterConnectivityInfoOutputWithContext(ctx context.Context) ClusterConnectivityInfoOutput

func (ClusterConnectivityInfoOutput) ToClusterConnectivityInfoPtrOutput added in v0.7.0 

func (o ClusterConnectivityInfoOutput) ToClusterConnectivityInfoPtrOutput() ClusterConnectivityInfoPtrOutput

func (ClusterConnectivityInfoOutput) ToClusterConnectivityInfoPtrOutputWithContext added in v0.7.0 

func (o ClusterConnectivityInfoOutput) ToClusterConnectivityInfoPtrOutputWithContext(ctx context.Context) ClusterConnectivityInfoPtrOutput

func (ClusterConnectivityInfoOutput) VpcConnectivity added in v0.44.0 

func (o ClusterConnectivityInfoOutput) VpcConnectivity() ClusterVpcConnectivityPtrOutput

VPC connection control settings for brokers

type ClusterConnectivityInfoPtrInput added in v0.7.0 

type ClusterConnectivityInfoPtrInput interface {
	pulumi.Input

	ToClusterConnectivityInfoPtrOutput() ClusterConnectivityInfoPtrOutput
	ToClusterConnectivityInfoPtrOutputWithContext(context.Context) ClusterConnectivityInfoPtrOutput
}

ClusterConnectivityInfoPtrInput is an input type that accepts ClusterConnectivityInfoArgs, ClusterConnectivityInfoPtr and ClusterConnectivityInfoPtrOutput values. You can construct a concrete instance of `ClusterConnectivityInfoPtrInput` via: 

        ClusterConnectivityInfoArgs{...}

or:

        nil

func ClusterConnectivityInfoPtr added in v0.7.0 

func ClusterConnectivityInfoPtr(v *ClusterConnectivityInfoArgs) ClusterConnectivityInfoPtrInput

type ClusterConnectivityInfoPtrOutput added in v0.7.0 

type ClusterConnectivityInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterConnectivityInfoPtrOutput) Elem added in v0.7.0 

func (o ClusterConnectivityInfoPtrOutput) Elem() ClusterConnectivityInfoOutput

func (ClusterConnectivityInfoPtrOutput) ElementType added in v0.7.0 

func (ClusterConnectivityInfoPtrOutput) ElementType() reflect.Type

func (ClusterConnectivityInfoPtrOutput) PublicAccess added in v0.7.0 

func (o ClusterConnectivityInfoPtrOutput) PublicAccess() ClusterPublicAccessPtrOutput

Access control settings for the cluster's brokers.

func (ClusterConnectivityInfoPtrOutput) ToClusterConnectivityInfoPtrOutput added in v0.7.0 

func (o ClusterConnectivityInfoPtrOutput) ToClusterConnectivityInfoPtrOutput() ClusterConnectivityInfoPtrOutput

func (ClusterConnectivityInfoPtrOutput) ToClusterConnectivityInfoPtrOutputWithContext added in v0.7.0 

func (o ClusterConnectivityInfoPtrOutput) ToClusterConnectivityInfoPtrOutputWithContext(ctx context.Context) ClusterConnectivityInfoPtrOutput

func (ClusterConnectivityInfoPtrOutput) VpcConnectivity added in v0.44.0 

func (o ClusterConnectivityInfoPtrOutput) VpcConnectivity() ClusterVpcConnectivityPtrOutput

VPC connection control settings for brokers

type ClusterEbsStorageInfo added in v0.72.0 

type ClusterEbsStorageInfo struct {
	// EBS volume provisioned throughput information.
	ProvisionedThroughput *ClusterProvisionedThroughput `pulumi:"provisionedThroughput"`
	// The size in GiB of the EBS volume for the data drive on each broker node.
	VolumeSize *int `pulumi:"volumeSize"`
}

type ClusterEbsStorageInfoArgs added in v0.72.0 

type ClusterEbsStorageInfoArgs struct {
	// EBS volume provisioned throughput information.
	ProvisionedThroughput ClusterProvisionedThroughputPtrInput `pulumi:"provisionedThroughput"`
	// The size in GiB of the EBS volume for the data drive on each broker node.
	VolumeSize pulumi.IntPtrInput `pulumi:"volumeSize"`
}

func (ClusterEbsStorageInfoArgs) ElementType added in v0.72.0 

func (ClusterEbsStorageInfoArgs) ElementType() reflect.Type

func (ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoOutput added in v0.72.0 

func (i ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoOutput() ClusterEbsStorageInfoOutput

func (ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoOutputWithContext added in v0.72.0 

func (i ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoOutputWithContext(ctx context.Context) ClusterEbsStorageInfoOutput

func (ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoPtrOutput added in v0.72.0 

func (i ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoPtrOutput() ClusterEbsStorageInfoPtrOutput

func (ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoPtrOutputWithContext added in v0.72.0 

func (i ClusterEbsStorageInfoArgs) ToClusterEbsStorageInfoPtrOutputWithContext(ctx context.Context) ClusterEbsStorageInfoPtrOutput

type ClusterEbsStorageInfoInput added in v0.72.0 

type ClusterEbsStorageInfoInput interface {
	pulumi.Input

	ToClusterEbsStorageInfoOutput() ClusterEbsStorageInfoOutput
	ToClusterEbsStorageInfoOutputWithContext(context.Context) ClusterEbsStorageInfoOutput
}

ClusterEbsStorageInfoInput is an input type that accepts ClusterEbsStorageInfoArgs and ClusterEbsStorageInfoOutput values. You can construct a concrete instance of `ClusterEbsStorageInfoInput` via: 

ClusterEbsStorageInfoArgs{...}

type ClusterEbsStorageInfoOutput added in v0.72.0 

type ClusterEbsStorageInfoOutput struct{ *pulumi.OutputState }

func (ClusterEbsStorageInfoOutput) ElementType added in v0.72.0 

func (ClusterEbsStorageInfoOutput) ElementType() reflect.Type

func (ClusterEbsStorageInfoOutput) ProvisionedThroughput added in v0.72.0 

func (o ClusterEbsStorageInfoOutput) ProvisionedThroughput() ClusterProvisionedThroughputPtrOutput

EBS volume provisioned throughput information.

func (ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoOutput added in v0.72.0 

func (o ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoOutput() ClusterEbsStorageInfoOutput

func (ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoOutputWithContext added in v0.72.0 

func (o ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoOutputWithContext(ctx context.Context) ClusterEbsStorageInfoOutput

func (ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoPtrOutput added in v0.72.0 

func (o ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoPtrOutput() ClusterEbsStorageInfoPtrOutput

func (ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoPtrOutputWithContext added in v0.72.0 

func (o ClusterEbsStorageInfoOutput) ToClusterEbsStorageInfoPtrOutputWithContext(ctx context.Context) ClusterEbsStorageInfoPtrOutput

func (ClusterEbsStorageInfoOutput) VolumeSize added in v0.72.0 

func (o ClusterEbsStorageInfoOutput) VolumeSize() pulumi.IntPtrOutput

The size in GiB of the EBS volume for the data drive on each broker node.

type ClusterEbsStorageInfoPtrInput added in v0.72.0 

type ClusterEbsStorageInfoPtrInput interface {
	pulumi.Input

	ToClusterEbsStorageInfoPtrOutput() ClusterEbsStorageInfoPtrOutput
	ToClusterEbsStorageInfoPtrOutputWithContext(context.Context) ClusterEbsStorageInfoPtrOutput
}

ClusterEbsStorageInfoPtrInput is an input type that accepts ClusterEbsStorageInfoArgs, ClusterEbsStorageInfoPtr and ClusterEbsStorageInfoPtrOutput values. You can construct a concrete instance of `ClusterEbsStorageInfoPtrInput` via: 

        ClusterEbsStorageInfoArgs{...}

or:

        nil

func ClusterEbsStorageInfoPtr added in v0.72.0 

func ClusterEbsStorageInfoPtr(v *ClusterEbsStorageInfoArgs) ClusterEbsStorageInfoPtrInput

type ClusterEbsStorageInfoPtrOutput added in v0.72.0 

type ClusterEbsStorageInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterEbsStorageInfoPtrOutput) Elem added in v0.72.0 

func (o ClusterEbsStorageInfoPtrOutput) Elem() ClusterEbsStorageInfoOutput

func (ClusterEbsStorageInfoPtrOutput) ElementType added in v0.72.0 

func (ClusterEbsStorageInfoPtrOutput) ElementType() reflect.Type

func (ClusterEbsStorageInfoPtrOutput) ProvisionedThroughput added in v0.72.0 

func (o ClusterEbsStorageInfoPtrOutput) ProvisionedThroughput() ClusterProvisionedThroughputPtrOutput

EBS volume provisioned throughput information.

func (ClusterEbsStorageInfoPtrOutput) ToClusterEbsStorageInfoPtrOutput added in v0.72.0 

func (o ClusterEbsStorageInfoPtrOutput) ToClusterEbsStorageInfoPtrOutput() ClusterEbsStorageInfoPtrOutput

func (ClusterEbsStorageInfoPtrOutput) ToClusterEbsStorageInfoPtrOutputWithContext added in v0.72.0 

func (o ClusterEbsStorageInfoPtrOutput) ToClusterEbsStorageInfoPtrOutputWithContext(ctx context.Context) ClusterEbsStorageInfoPtrOutput

func (ClusterEbsStorageInfoPtrOutput) VolumeSize added in v0.72.0 

func (o ClusterEbsStorageInfoPtrOutput) VolumeSize() pulumi.IntPtrOutput

The size in GiB of the EBS volume for the data drive on each broker node.

type ClusterEncryptionAtRest 

type ClusterEncryptionAtRest struct {
	// The Amazon Resource Name (ARN) of the Amazon KMS key for encrypting data at rest. If you don't specify a KMS key, MSK creates one for you and uses it.
	DataVolumeKmsKeyId string `pulumi:"dataVolumeKmsKeyId"`
}

type ClusterEncryptionAtRestArgs 

type ClusterEncryptionAtRestArgs struct {
	// The Amazon Resource Name (ARN) of the Amazon KMS key for encrypting data at rest. If you don't specify a KMS key, MSK creates one for you and uses it.
	DataVolumeKmsKeyId pulumi.StringInput `pulumi:"dataVolumeKmsKeyId"`
}

func (ClusterEncryptionAtRestArgs) ElementType 

func (ClusterEncryptionAtRestArgs) ElementType() reflect.Type

func (ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestOutput 

func (i ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestOutput() ClusterEncryptionAtRestOutput

func (ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestOutputWithContext 

func (i ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestOutputWithContext(ctx context.Context) ClusterEncryptionAtRestOutput

func (ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestPtrOutput 

func (i ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestPtrOutput() ClusterEncryptionAtRestPtrOutput

func (ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestPtrOutputWithContext 

func (i ClusterEncryptionAtRestArgs) ToClusterEncryptionAtRestPtrOutputWithContext(ctx context.Context) ClusterEncryptionAtRestPtrOutput

type ClusterEncryptionAtRestInput 

type ClusterEncryptionAtRestInput interface {
	pulumi.Input

	ToClusterEncryptionAtRestOutput() ClusterEncryptionAtRestOutput
	ToClusterEncryptionAtRestOutputWithContext(context.Context) ClusterEncryptionAtRestOutput
}

ClusterEncryptionAtRestInput is an input type that accepts ClusterEncryptionAtRestArgs and ClusterEncryptionAtRestOutput values. You can construct a concrete instance of `ClusterEncryptionAtRestInput` via: 

ClusterEncryptionAtRestArgs{...}

type ClusterEncryptionAtRestOutput 

type ClusterEncryptionAtRestOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionAtRestOutput) DataVolumeKmsKeyId added in v0.72.0 

func (o ClusterEncryptionAtRestOutput) DataVolumeKmsKeyId() pulumi.StringOutput

The Amazon Resource Name (ARN) of the Amazon KMS key for encrypting data at rest. If you don't specify a KMS key, MSK creates one for you and uses it.

func (ClusterEncryptionAtRestOutput) ElementType 

func (ClusterEncryptionAtRestOutput) ElementType() reflect.Type

func (ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestOutput 

func (o ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestOutput() ClusterEncryptionAtRestOutput

func (ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestOutputWithContext 

func (o ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestOutputWithContext(ctx context.Context) ClusterEncryptionAtRestOutput

func (ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestPtrOutput 

func (o ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestPtrOutput() ClusterEncryptionAtRestPtrOutput

func (ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestPtrOutputWithContext 

func (o ClusterEncryptionAtRestOutput) ToClusterEncryptionAtRestPtrOutputWithContext(ctx context.Context) ClusterEncryptionAtRestPtrOutput

type ClusterEncryptionAtRestPtrInput 

type ClusterEncryptionAtRestPtrInput interface {
	pulumi.Input

	ToClusterEncryptionAtRestPtrOutput() ClusterEncryptionAtRestPtrOutput
	ToClusterEncryptionAtRestPtrOutputWithContext(context.Context) ClusterEncryptionAtRestPtrOutput
}

ClusterEncryptionAtRestPtrInput is an input type that accepts ClusterEncryptionAtRestArgs, ClusterEncryptionAtRestPtr and ClusterEncryptionAtRestPtrOutput values. You can construct a concrete instance of `ClusterEncryptionAtRestPtrInput` via: 

        ClusterEncryptionAtRestArgs{...}

or:

        nil

func ClusterEncryptionAtRestPtr 

func ClusterEncryptionAtRestPtr(v *ClusterEncryptionAtRestArgs) ClusterEncryptionAtRestPtrInput

type ClusterEncryptionAtRestPtrOutput 

type ClusterEncryptionAtRestPtrOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionAtRestPtrOutput) DataVolumeKmsKeyId added in v0.72.0 

func (o ClusterEncryptionAtRestPtrOutput) DataVolumeKmsKeyId() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) of the Amazon KMS key for encrypting data at rest. If you don't specify a KMS key, MSK creates one for you and uses it.

func (ClusterEncryptionAtRestPtrOutput) Elem 

func (o ClusterEncryptionAtRestPtrOutput) Elem() ClusterEncryptionAtRestOutput

func (ClusterEncryptionAtRestPtrOutput) ElementType 

func (ClusterEncryptionAtRestPtrOutput) ElementType() reflect.Type

func (ClusterEncryptionAtRestPtrOutput) ToClusterEncryptionAtRestPtrOutput 

func (o ClusterEncryptionAtRestPtrOutput) ToClusterEncryptionAtRestPtrOutput() ClusterEncryptionAtRestPtrOutput

func (ClusterEncryptionAtRestPtrOutput) ToClusterEncryptionAtRestPtrOutputWithContext 

func (o ClusterEncryptionAtRestPtrOutput) ToClusterEncryptionAtRestPtrOutputWithContext(ctx context.Context) ClusterEncryptionAtRestPtrOutput

type ClusterEncryptionInTransit 

type ClusterEncryptionInTransit struct {
	// Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.
	//
	// `TLS` means that client-broker communication is enabled with TLS only.
	//
	// `TLS_PLAINTEXT` means that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
	//
	// `PLAINTEXT` means that client-broker communication is enabled in plaintext only.
	//
	// The default value is `TLS` .
	ClientBroker *ClusterEncryptionInTransitClientBroker `pulumi:"clientBroker"`
	// When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.
	//
	// The default value is true.
	InCluster *bool `pulumi:"inCluster"`
}

type ClusterEncryptionInTransitArgs 

type ClusterEncryptionInTransitArgs struct {
	// Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.
	//
	// `TLS` means that client-broker communication is enabled with TLS only.
	//
	// `TLS_PLAINTEXT` means that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.
	//
	// `PLAINTEXT` means that client-broker communication is enabled in plaintext only.
	//
	// The default value is `TLS` .
	ClientBroker ClusterEncryptionInTransitClientBrokerPtrInput `pulumi:"clientBroker"`
	// When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.
	//
	// The default value is true.
	InCluster pulumi.BoolPtrInput `pulumi:"inCluster"`
}

func (ClusterEncryptionInTransitArgs) ElementType 

func (ClusterEncryptionInTransitArgs) ElementType() reflect.Type

func (ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitOutput 

func (i ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitOutput() ClusterEncryptionInTransitOutput

func (ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitOutputWithContext 

func (i ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitOutputWithContext(ctx context.Context) ClusterEncryptionInTransitOutput

func (ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitPtrOutput 

func (i ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitPtrOutput() ClusterEncryptionInTransitPtrOutput

func (ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitPtrOutputWithContext 

func (i ClusterEncryptionInTransitArgs) ToClusterEncryptionInTransitPtrOutputWithContext(ctx context.Context) ClusterEncryptionInTransitPtrOutput

type ClusterEncryptionInTransitClientBroker added in v0.14.0 

type ClusterEncryptionInTransitClientBroker string

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

`TLS` means that client-broker communication is enabled with TLS only.

`TLS_PLAINTEXT` means that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.

`PLAINTEXT` means that client-broker communication is enabled in plaintext only.

The default value is `TLS` .

func (ClusterEncryptionInTransitClientBroker) ElementType added in v0.14.0 

func (ClusterEncryptionInTransitClientBroker) ElementType() reflect.Type

func (ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerOutput added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerOutput() ClusterEncryptionInTransitClientBrokerOutput

func (ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerOutputWithContext added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerOutputWithContext(ctx context.Context) ClusterEncryptionInTransitClientBrokerOutput

func (ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerPtrOutput added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerPtrOutput() ClusterEncryptionInTransitClientBrokerPtrOutput

func (ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerPtrOutputWithContext added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToClusterEncryptionInTransitClientBrokerPtrOutputWithContext(ctx context.Context) ClusterEncryptionInTransitClientBrokerPtrOutput

func (ClusterEncryptionInTransitClientBroker) ToStringOutput added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToStringOutput() pulumi.StringOutput

func (ClusterEncryptionInTransitClientBroker) ToStringOutputWithContext added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ClusterEncryptionInTransitClientBroker) ToStringPtrOutput added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterEncryptionInTransitClientBroker) ToStringPtrOutputWithContext added in v0.14.0 

func (e ClusterEncryptionInTransitClientBroker) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterEncryptionInTransitClientBrokerInput added in v0.14.0 

type ClusterEncryptionInTransitClientBrokerInput interface {
	pulumi.Input

	ToClusterEncryptionInTransitClientBrokerOutput() ClusterEncryptionInTransitClientBrokerOutput
	ToClusterEncryptionInTransitClientBrokerOutputWithContext(context.Context) ClusterEncryptionInTransitClientBrokerOutput
}

ClusterEncryptionInTransitClientBrokerInput is an input type that accepts values of the ClusterEncryptionInTransitClientBroker enum A concrete instance of `ClusterEncryptionInTransitClientBrokerInput` can be one of the following: 

ClusterEncryptionInTransitClientBrokerTls
ClusterEncryptionInTransitClientBrokerTlsPlaintext
ClusterEncryptionInTransitClientBrokerPlaintext

type ClusterEncryptionInTransitClientBrokerOutput added in v0.14.0 

type ClusterEncryptionInTransitClientBrokerOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInTransitClientBrokerOutput) ElementType added in v0.14.0 

func (ClusterEncryptionInTransitClientBrokerOutput) ElementType() reflect.Type

func (ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerOutput added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerOutput() ClusterEncryptionInTransitClientBrokerOutput

func (ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerOutputWithContext added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerOutputWithContext(ctx context.Context) ClusterEncryptionInTransitClientBrokerOutput

func (ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerPtrOutput added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerPtrOutput() ClusterEncryptionInTransitClientBrokerPtrOutput

func (ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerPtrOutputWithContext added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToClusterEncryptionInTransitClientBrokerPtrOutputWithContext(ctx context.Context) ClusterEncryptionInTransitClientBrokerPtrOutput

func (ClusterEncryptionInTransitClientBrokerOutput) ToStringOutput added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToStringOutput() pulumi.StringOutput

func (ClusterEncryptionInTransitClientBrokerOutput) ToStringOutputWithContext added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ClusterEncryptionInTransitClientBrokerOutput) ToStringPtrOutput added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterEncryptionInTransitClientBrokerOutput) ToStringPtrOutputWithContext added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterEncryptionInTransitClientBrokerPtrInput added in v0.14.0 

type ClusterEncryptionInTransitClientBrokerPtrInput interface {
	pulumi.Input

	ToClusterEncryptionInTransitClientBrokerPtrOutput() ClusterEncryptionInTransitClientBrokerPtrOutput
	ToClusterEncryptionInTransitClientBrokerPtrOutputWithContext(context.Context) ClusterEncryptionInTransitClientBrokerPtrOutput
}

func ClusterEncryptionInTransitClientBrokerPtr added in v0.14.0 

func ClusterEncryptionInTransitClientBrokerPtr(v string) ClusterEncryptionInTransitClientBrokerPtrInput

type ClusterEncryptionInTransitClientBrokerPtrOutput added in v0.14.0 

type ClusterEncryptionInTransitClientBrokerPtrOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInTransitClientBrokerPtrOutput) Elem added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerPtrOutput) Elem() ClusterEncryptionInTransitClientBrokerOutput

func (ClusterEncryptionInTransitClientBrokerPtrOutput) ElementType added in v0.14.0 

func (ClusterEncryptionInTransitClientBrokerPtrOutput) ElementType() reflect.Type

func (ClusterEncryptionInTransitClientBrokerPtrOutput) ToClusterEncryptionInTransitClientBrokerPtrOutput added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerPtrOutput) ToClusterEncryptionInTransitClientBrokerPtrOutput() ClusterEncryptionInTransitClientBrokerPtrOutput

func (ClusterEncryptionInTransitClientBrokerPtrOutput) ToClusterEncryptionInTransitClientBrokerPtrOutputWithContext added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerPtrOutput) ToClusterEncryptionInTransitClientBrokerPtrOutputWithContext(ctx context.Context) ClusterEncryptionInTransitClientBrokerPtrOutput

func (ClusterEncryptionInTransitClientBrokerPtrOutput) ToStringPtrOutput added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerPtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterEncryptionInTransitClientBrokerPtrOutput) ToStringPtrOutputWithContext added in v0.14.0 

func (o ClusterEncryptionInTransitClientBrokerPtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterEncryptionInTransitInput 

type ClusterEncryptionInTransitInput interface {
	pulumi.Input

	ToClusterEncryptionInTransitOutput() ClusterEncryptionInTransitOutput
	ToClusterEncryptionInTransitOutputWithContext(context.Context) ClusterEncryptionInTransitOutput
}

ClusterEncryptionInTransitInput is an input type that accepts ClusterEncryptionInTransitArgs and ClusterEncryptionInTransitOutput values. You can construct a concrete instance of `ClusterEncryptionInTransitInput` via: 

ClusterEncryptionInTransitArgs{...}

type ClusterEncryptionInTransitOutput 

type ClusterEncryptionInTransitOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInTransitOutput) ClientBroker 

func (o ClusterEncryptionInTransitOutput) ClientBroker() ClusterEncryptionInTransitClientBrokerPtrOutput

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

`TLS` means that client-broker communication is enabled with TLS only.

`TLS_PLAINTEXT` means that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.

`PLAINTEXT` means that client-broker communication is enabled in plaintext only.

The default value is `TLS` .

func (ClusterEncryptionInTransitOutput) ElementType 

func (ClusterEncryptionInTransitOutput) ElementType() reflect.Type

func (ClusterEncryptionInTransitOutput) InCluster 

func (o ClusterEncryptionInTransitOutput) InCluster() pulumi.BoolPtrOutput

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.

func (ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitOutput 

func (o ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitOutput() ClusterEncryptionInTransitOutput

func (ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitOutputWithContext 

func (o ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitOutputWithContext(ctx context.Context) ClusterEncryptionInTransitOutput

func (ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitPtrOutput 

func (o ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitPtrOutput() ClusterEncryptionInTransitPtrOutput

func (ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitPtrOutputWithContext 

func (o ClusterEncryptionInTransitOutput) ToClusterEncryptionInTransitPtrOutputWithContext(ctx context.Context) ClusterEncryptionInTransitPtrOutput

type ClusterEncryptionInTransitPtrInput 

type ClusterEncryptionInTransitPtrInput interface {
	pulumi.Input

	ToClusterEncryptionInTransitPtrOutput() ClusterEncryptionInTransitPtrOutput
	ToClusterEncryptionInTransitPtrOutputWithContext(context.Context) ClusterEncryptionInTransitPtrOutput
}

ClusterEncryptionInTransitPtrInput is an input type that accepts ClusterEncryptionInTransitArgs, ClusterEncryptionInTransitPtr and ClusterEncryptionInTransitPtrOutput values. You can construct a concrete instance of `ClusterEncryptionInTransitPtrInput` via: 

        ClusterEncryptionInTransitArgs{...}

or:

        nil

func ClusterEncryptionInTransitPtr 

func ClusterEncryptionInTransitPtr(v *ClusterEncryptionInTransitArgs) ClusterEncryptionInTransitPtrInput

type ClusterEncryptionInTransitPtrOutput 

type ClusterEncryptionInTransitPtrOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInTransitPtrOutput) ClientBroker 

func (o ClusterEncryptionInTransitPtrOutput) ClientBroker() ClusterEncryptionInTransitClientBrokerPtrOutput

Indicates the encryption setting for data in transit between clients and brokers. You must set it to one of the following values.

`TLS` means that client-broker communication is enabled with TLS only.

`TLS_PLAINTEXT` means that client-broker communication is enabled for both TLS-encrypted, as well as plaintext data.

`PLAINTEXT` means that client-broker communication is enabled in plaintext only.

The default value is `TLS` .

func (ClusterEncryptionInTransitPtrOutput) Elem 

func (o ClusterEncryptionInTransitPtrOutput) Elem() ClusterEncryptionInTransitOutput

func (ClusterEncryptionInTransitPtrOutput) ElementType 

func (ClusterEncryptionInTransitPtrOutput) ElementType() reflect.Type

func (ClusterEncryptionInTransitPtrOutput) InCluster 

func (o ClusterEncryptionInTransitPtrOutput) InCluster() pulumi.BoolPtrOutput

When set to true, it indicates that data communication among the broker nodes of the cluster is encrypted. When set to false, the communication happens in plaintext.

The default value is true.

func (ClusterEncryptionInTransitPtrOutput) ToClusterEncryptionInTransitPtrOutput 

func (o ClusterEncryptionInTransitPtrOutput) ToClusterEncryptionInTransitPtrOutput() ClusterEncryptionInTransitPtrOutput

func (ClusterEncryptionInTransitPtrOutput) ToClusterEncryptionInTransitPtrOutputWithContext 

func (o ClusterEncryptionInTransitPtrOutput) ToClusterEncryptionInTransitPtrOutputWithContext(ctx context.Context) ClusterEncryptionInTransitPtrOutput

type ClusterEncryptionInfo 

type ClusterEncryptionInfo struct {
	// The data-volume encryption details.
	EncryptionAtRest *ClusterEncryptionAtRest `pulumi:"encryptionAtRest"`
	// The details for encryption in transit.
	EncryptionInTransit *ClusterEncryptionInTransit `pulumi:"encryptionInTransit"`
}

type ClusterEncryptionInfoArgs 

type ClusterEncryptionInfoArgs struct {
	// The data-volume encryption details.
	EncryptionAtRest ClusterEncryptionAtRestPtrInput `pulumi:"encryptionAtRest"`
	// The details for encryption in transit.
	EncryptionInTransit ClusterEncryptionInTransitPtrInput `pulumi:"encryptionInTransit"`
}

func (ClusterEncryptionInfoArgs) ElementType 

func (ClusterEncryptionInfoArgs) ElementType() reflect.Type

func (ClusterEncryptionInfoArgs) ToClusterEncryptionInfoOutput 

func (i ClusterEncryptionInfoArgs) ToClusterEncryptionInfoOutput() ClusterEncryptionInfoOutput

func (ClusterEncryptionInfoArgs) ToClusterEncryptionInfoOutputWithContext 

func (i ClusterEncryptionInfoArgs) ToClusterEncryptionInfoOutputWithContext(ctx context.Context) ClusterEncryptionInfoOutput

func (ClusterEncryptionInfoArgs) ToClusterEncryptionInfoPtrOutput 

func (i ClusterEncryptionInfoArgs) ToClusterEncryptionInfoPtrOutput() ClusterEncryptionInfoPtrOutput

func (ClusterEncryptionInfoArgs) ToClusterEncryptionInfoPtrOutputWithContext 

func (i ClusterEncryptionInfoArgs) ToClusterEncryptionInfoPtrOutputWithContext(ctx context.Context) ClusterEncryptionInfoPtrOutput

type ClusterEncryptionInfoInput 

type ClusterEncryptionInfoInput interface {
	pulumi.Input

	ToClusterEncryptionInfoOutput() ClusterEncryptionInfoOutput
	ToClusterEncryptionInfoOutputWithContext(context.Context) ClusterEncryptionInfoOutput
}

ClusterEncryptionInfoInput is an input type that accepts ClusterEncryptionInfoArgs and ClusterEncryptionInfoOutput values. You can construct a concrete instance of `ClusterEncryptionInfoInput` via: 

ClusterEncryptionInfoArgs{...}

type ClusterEncryptionInfoOutput 

type ClusterEncryptionInfoOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInfoOutput) ElementType 

func (ClusterEncryptionInfoOutput) ElementType() reflect.Type

func (ClusterEncryptionInfoOutput) EncryptionAtRest 

func (o ClusterEncryptionInfoOutput) EncryptionAtRest() ClusterEncryptionAtRestPtrOutput

The data-volume encryption details.

func (ClusterEncryptionInfoOutput) EncryptionInTransit 

func (o ClusterEncryptionInfoOutput) EncryptionInTransit() ClusterEncryptionInTransitPtrOutput

The details for encryption in transit.

func (ClusterEncryptionInfoOutput) ToClusterEncryptionInfoOutput 

func (o ClusterEncryptionInfoOutput) ToClusterEncryptionInfoOutput() ClusterEncryptionInfoOutput

func (ClusterEncryptionInfoOutput) ToClusterEncryptionInfoOutputWithContext 

func (o ClusterEncryptionInfoOutput) ToClusterEncryptionInfoOutputWithContext(ctx context.Context) ClusterEncryptionInfoOutput

func (ClusterEncryptionInfoOutput) ToClusterEncryptionInfoPtrOutput 

func (o ClusterEncryptionInfoOutput) ToClusterEncryptionInfoPtrOutput() ClusterEncryptionInfoPtrOutput

func (ClusterEncryptionInfoOutput) ToClusterEncryptionInfoPtrOutputWithContext 

func (o ClusterEncryptionInfoOutput) ToClusterEncryptionInfoPtrOutputWithContext(ctx context.Context) ClusterEncryptionInfoPtrOutput

type ClusterEncryptionInfoPtrInput 

type ClusterEncryptionInfoPtrInput interface {
	pulumi.Input

	ToClusterEncryptionInfoPtrOutput() ClusterEncryptionInfoPtrOutput
	ToClusterEncryptionInfoPtrOutputWithContext(context.Context) ClusterEncryptionInfoPtrOutput
}

ClusterEncryptionInfoPtrInput is an input type that accepts ClusterEncryptionInfoArgs, ClusterEncryptionInfoPtr and ClusterEncryptionInfoPtrOutput values. You can construct a concrete instance of `ClusterEncryptionInfoPtrInput` via: 

        ClusterEncryptionInfoArgs{...}

or:

        nil

func ClusterEncryptionInfoPtr 

func ClusterEncryptionInfoPtr(v *ClusterEncryptionInfoArgs) ClusterEncryptionInfoPtrInput

type ClusterEncryptionInfoPtrOutput 

type ClusterEncryptionInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInfoPtrOutput) Elem 

func (o ClusterEncryptionInfoPtrOutput) Elem() ClusterEncryptionInfoOutput

func (ClusterEncryptionInfoPtrOutput) ElementType 

func (ClusterEncryptionInfoPtrOutput) ElementType() reflect.Type

func (ClusterEncryptionInfoPtrOutput) EncryptionAtRest 

func (o ClusterEncryptionInfoPtrOutput) EncryptionAtRest() ClusterEncryptionAtRestPtrOutput

The data-volume encryption details.

func (ClusterEncryptionInfoPtrOutput) EncryptionInTransit 

func (o ClusterEncryptionInfoPtrOutput) EncryptionInTransit() ClusterEncryptionInTransitPtrOutput

The details for encryption in transit.

func (ClusterEncryptionInfoPtrOutput) ToClusterEncryptionInfoPtrOutput 

func (o ClusterEncryptionInfoPtrOutput) ToClusterEncryptionInfoPtrOutput() ClusterEncryptionInfoPtrOutput

func (ClusterEncryptionInfoPtrOutput) ToClusterEncryptionInfoPtrOutputWithContext 

func (o ClusterEncryptionInfoPtrOutput) ToClusterEncryptionInfoPtrOutputWithContext(ctx context.Context) ClusterEncryptionInfoPtrOutput

type ClusterEnhancedMonitoring added in v0.14.0 

type ClusterEnhancedMonitoring string

Specifies the level of monitoring for the MSK cluster. The possible values are `DEFAULT` , `PER_BROKER` , and `PER_TOPIC_PER_BROKER` .

func (ClusterEnhancedMonitoring) ElementType added in v0.14.0 

func (ClusterEnhancedMonitoring) ElementType() reflect.Type

func (ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringOutput added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringOutput() ClusterEnhancedMonitoringOutput

func (ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringOutputWithContext added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringOutputWithContext(ctx context.Context) ClusterEnhancedMonitoringOutput

func (ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringPtrOutput added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringPtrOutput() ClusterEnhancedMonitoringPtrOutput

func (ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringPtrOutputWithContext added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToClusterEnhancedMonitoringPtrOutputWithContext(ctx context.Context) ClusterEnhancedMonitoringPtrOutput

func (ClusterEnhancedMonitoring) ToStringOutput added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToStringOutput() pulumi.StringOutput

func (ClusterEnhancedMonitoring) ToStringOutputWithContext added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ClusterEnhancedMonitoring) ToStringPtrOutput added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterEnhancedMonitoring) ToStringPtrOutputWithContext added in v0.14.0 

func (e ClusterEnhancedMonitoring) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterEnhancedMonitoringInput added in v0.14.0 

type ClusterEnhancedMonitoringInput interface {
	pulumi.Input

	ToClusterEnhancedMonitoringOutput() ClusterEnhancedMonitoringOutput
	ToClusterEnhancedMonitoringOutputWithContext(context.Context) ClusterEnhancedMonitoringOutput
}

ClusterEnhancedMonitoringInput is an input type that accepts values of the ClusterEnhancedMonitoring enum A concrete instance of `ClusterEnhancedMonitoringInput` can be one of the following: 

ClusterEnhancedMonitoringDefault
ClusterEnhancedMonitoringPerBroker
ClusterEnhancedMonitoringPerTopicPerBroker
ClusterEnhancedMonitoringPerTopicPerPartition

type ClusterEnhancedMonitoringOutput added in v0.14.0 

type ClusterEnhancedMonitoringOutput struct{ *pulumi.OutputState }

func (ClusterEnhancedMonitoringOutput) ElementType added in v0.14.0 

func (ClusterEnhancedMonitoringOutput) ElementType() reflect.Type

func (ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringOutput added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringOutput() ClusterEnhancedMonitoringOutput

func (ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringOutputWithContext added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringOutputWithContext(ctx context.Context) ClusterEnhancedMonitoringOutput

func (ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringPtrOutput added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringPtrOutput() ClusterEnhancedMonitoringPtrOutput

func (ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringPtrOutputWithContext added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToClusterEnhancedMonitoringPtrOutputWithContext(ctx context.Context) ClusterEnhancedMonitoringPtrOutput

func (ClusterEnhancedMonitoringOutput) ToStringOutput added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToStringOutput() pulumi.StringOutput

func (ClusterEnhancedMonitoringOutput) ToStringOutputWithContext added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ClusterEnhancedMonitoringOutput) ToStringPtrOutput added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterEnhancedMonitoringOutput) ToStringPtrOutputWithContext added in v0.14.0 

func (o ClusterEnhancedMonitoringOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterEnhancedMonitoringPtrInput added in v0.14.0 

type ClusterEnhancedMonitoringPtrInput interface {
	pulumi.Input

	ToClusterEnhancedMonitoringPtrOutput() ClusterEnhancedMonitoringPtrOutput
	ToClusterEnhancedMonitoringPtrOutputWithContext(context.Context) ClusterEnhancedMonitoringPtrOutput
}

func ClusterEnhancedMonitoringPtr added in v0.14.0 

func ClusterEnhancedMonitoringPtr(v string) ClusterEnhancedMonitoringPtrInput

type ClusterEnhancedMonitoringPtrOutput added in v0.14.0 

type ClusterEnhancedMonitoringPtrOutput struct{ *pulumi.OutputState }

func (ClusterEnhancedMonitoringPtrOutput) Elem added in v0.14.0 

func (o ClusterEnhancedMonitoringPtrOutput) Elem() ClusterEnhancedMonitoringOutput

func (ClusterEnhancedMonitoringPtrOutput) ElementType added in v0.14.0 

func (ClusterEnhancedMonitoringPtrOutput) ElementType() reflect.Type

func (ClusterEnhancedMonitoringPtrOutput) ToClusterEnhancedMonitoringPtrOutput added in v0.14.0 

func (o ClusterEnhancedMonitoringPtrOutput) ToClusterEnhancedMonitoringPtrOutput() ClusterEnhancedMonitoringPtrOutput

func (ClusterEnhancedMonitoringPtrOutput) ToClusterEnhancedMonitoringPtrOutputWithContext added in v0.14.0 

func (o ClusterEnhancedMonitoringPtrOutput) ToClusterEnhancedMonitoringPtrOutputWithContext(ctx context.Context) ClusterEnhancedMonitoringPtrOutput

func (ClusterEnhancedMonitoringPtrOutput) ToStringPtrOutput added in v0.14.0 

func (o ClusterEnhancedMonitoringPtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterEnhancedMonitoringPtrOutput) ToStringPtrOutputWithContext added in v0.14.0 

func (o ClusterEnhancedMonitoringPtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterFirehose 

type ClusterFirehose struct {
	// The Kinesis Data Firehose delivery stream that is the destination for broker logs.
	DeliveryStream *string `pulumi:"deliveryStream"`
	// Specifies whether broker logs get sent to the specified Kinesis Data Firehose delivery stream.
	Enabled bool `pulumi:"enabled"`
}

type ClusterFirehoseArgs 

type ClusterFirehoseArgs struct {
	// The Kinesis Data Firehose delivery stream that is the destination for broker logs.
	DeliveryStream pulumi.StringPtrInput `pulumi:"deliveryStream"`
	// Specifies whether broker logs get sent to the specified Kinesis Data Firehose delivery stream.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterFirehoseArgs) ElementType 

func (ClusterFirehoseArgs) ElementType() reflect.Type

func (ClusterFirehoseArgs) ToClusterFirehoseOutput 

func (i ClusterFirehoseArgs) ToClusterFirehoseOutput() ClusterFirehoseOutput

func (ClusterFirehoseArgs) ToClusterFirehoseOutputWithContext 

func (i ClusterFirehoseArgs) ToClusterFirehoseOutputWithContext(ctx context.Context) ClusterFirehoseOutput

func (ClusterFirehoseArgs) ToClusterFirehosePtrOutput 

func (i ClusterFirehoseArgs) ToClusterFirehosePtrOutput() ClusterFirehosePtrOutput

func (ClusterFirehoseArgs) ToClusterFirehosePtrOutputWithContext 

func (i ClusterFirehoseArgs) ToClusterFirehosePtrOutputWithContext(ctx context.Context) ClusterFirehosePtrOutput

type ClusterFirehoseInput 

type ClusterFirehoseInput interface {
	pulumi.Input

	ToClusterFirehoseOutput() ClusterFirehoseOutput
	ToClusterFirehoseOutputWithContext(context.Context) ClusterFirehoseOutput
}

ClusterFirehoseInput is an input type that accepts ClusterFirehoseArgs and ClusterFirehoseOutput values. You can construct a concrete instance of `ClusterFirehoseInput` via: 

ClusterFirehoseArgs{...}

type ClusterFirehoseOutput 

type ClusterFirehoseOutput struct{ *pulumi.OutputState }

func (ClusterFirehoseOutput) DeliveryStream 

func (o ClusterFirehoseOutput) DeliveryStream() pulumi.StringPtrOutput

The Kinesis Data Firehose delivery stream that is the destination for broker logs.

func (ClusterFirehoseOutput) ElementType 

func (ClusterFirehoseOutput) ElementType() reflect.Type

func (ClusterFirehoseOutput) Enabled 

func (o ClusterFirehoseOutput) Enabled() pulumi.BoolOutput

Specifies whether broker logs get sent to the specified Kinesis Data Firehose delivery stream.

func (ClusterFirehoseOutput) ToClusterFirehoseOutput 

func (o ClusterFirehoseOutput) ToClusterFirehoseOutput() ClusterFirehoseOutput

func (ClusterFirehoseOutput) ToClusterFirehoseOutputWithContext 

func (o ClusterFirehoseOutput) ToClusterFirehoseOutputWithContext(ctx context.Context) ClusterFirehoseOutput

func (ClusterFirehoseOutput) ToClusterFirehosePtrOutput 

func (o ClusterFirehoseOutput) ToClusterFirehosePtrOutput() ClusterFirehosePtrOutput

func (ClusterFirehoseOutput) ToClusterFirehosePtrOutputWithContext 

func (o ClusterFirehoseOutput) ToClusterFirehosePtrOutputWithContext(ctx context.Context) ClusterFirehosePtrOutput

type ClusterFirehosePtrInput 

type ClusterFirehosePtrInput interface {
	pulumi.Input

	ToClusterFirehosePtrOutput() ClusterFirehosePtrOutput
	ToClusterFirehosePtrOutputWithContext(context.Context) ClusterFirehosePtrOutput
}

ClusterFirehosePtrInput is an input type that accepts ClusterFirehoseArgs, ClusterFirehosePtr and ClusterFirehosePtrOutput values. You can construct a concrete instance of `ClusterFirehosePtrInput` via: 

        ClusterFirehoseArgs{...}

or:

        nil

func ClusterFirehosePtr 

func ClusterFirehosePtr(v *ClusterFirehoseArgs) ClusterFirehosePtrInput

type ClusterFirehosePtrOutput 

type ClusterFirehosePtrOutput struct{ *pulumi.OutputState }

func (ClusterFirehosePtrOutput) DeliveryStream 

func (o ClusterFirehosePtrOutput) DeliveryStream() pulumi.StringPtrOutput

The Kinesis Data Firehose delivery stream that is the destination for broker logs.

func (ClusterFirehosePtrOutput) Elem 

func (o ClusterFirehosePtrOutput) Elem() ClusterFirehoseOutput

func (ClusterFirehosePtrOutput) ElementType 

func (ClusterFirehosePtrOutput) ElementType() reflect.Type

func (ClusterFirehosePtrOutput) Enabled 

func (o ClusterFirehosePtrOutput) Enabled() pulumi.BoolPtrOutput

Specifies whether broker logs get sent to the specified Kinesis Data Firehose delivery stream.

func (ClusterFirehosePtrOutput) ToClusterFirehosePtrOutput 

func (o ClusterFirehosePtrOutput) ToClusterFirehosePtrOutput() ClusterFirehosePtrOutput

func (ClusterFirehosePtrOutput) ToClusterFirehosePtrOutputWithContext 

func (o ClusterFirehosePtrOutput) ToClusterFirehosePtrOutputWithContext(ctx context.Context) ClusterFirehosePtrOutput

type ClusterIam 

type ClusterIam struct {
	// SASL/IAM authentication is enabled or not.
	Enabled bool `pulumi:"enabled"`
}

type ClusterIamArgs 

type ClusterIamArgs struct {
	// SASL/IAM authentication is enabled or not.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterIamArgs) ElementType 

func (ClusterIamArgs) ElementType() reflect.Type

func (ClusterIamArgs) ToClusterIamOutput 

func (i ClusterIamArgs) ToClusterIamOutput() ClusterIamOutput

func (ClusterIamArgs) ToClusterIamOutputWithContext 

func (i ClusterIamArgs) ToClusterIamOutputWithContext(ctx context.Context) ClusterIamOutput

func (ClusterIamArgs) ToClusterIamPtrOutput 

func (i ClusterIamArgs) ToClusterIamPtrOutput() ClusterIamPtrOutput

func (ClusterIamArgs) ToClusterIamPtrOutputWithContext 

func (i ClusterIamArgs) ToClusterIamPtrOutputWithContext(ctx context.Context) ClusterIamPtrOutput

type ClusterIamInput 

type ClusterIamInput interface {
	pulumi.Input

	ToClusterIamOutput() ClusterIamOutput
	ToClusterIamOutputWithContext(context.Context) ClusterIamOutput
}

ClusterIamInput is an input type that accepts ClusterIamArgs and ClusterIamOutput values. You can construct a concrete instance of `ClusterIamInput` via: 

ClusterIamArgs{...}

type ClusterIamOutput 

type ClusterIamOutput struct{ *pulumi.OutputState }

func (ClusterIamOutput) ElementType 

func (ClusterIamOutput) ElementType() reflect.Type

func (ClusterIamOutput) Enabled 

func (o ClusterIamOutput) Enabled() pulumi.BoolOutput

SASL/IAM authentication is enabled or not.

func (ClusterIamOutput) ToClusterIamOutput 

func (o ClusterIamOutput) ToClusterIamOutput() ClusterIamOutput

func (ClusterIamOutput) ToClusterIamOutputWithContext 

func (o ClusterIamOutput) ToClusterIamOutputWithContext(ctx context.Context) ClusterIamOutput

func (ClusterIamOutput) ToClusterIamPtrOutput 

func (o ClusterIamOutput) ToClusterIamPtrOutput() ClusterIamPtrOutput

func (ClusterIamOutput) ToClusterIamPtrOutputWithContext 

func (o ClusterIamOutput) ToClusterIamPtrOutputWithContext(ctx context.Context) ClusterIamPtrOutput

type ClusterIamPtrInput 

type ClusterIamPtrInput interface {
	pulumi.Input

	ToClusterIamPtrOutput() ClusterIamPtrOutput
	ToClusterIamPtrOutputWithContext(context.Context) ClusterIamPtrOutput
}

ClusterIamPtrInput is an input type that accepts ClusterIamArgs, ClusterIamPtr and ClusterIamPtrOutput values. You can construct a concrete instance of `ClusterIamPtrInput` via: 

        ClusterIamArgs{...}

or:

        nil

func ClusterIamPtr 

func ClusterIamPtr(v *ClusterIamArgs) ClusterIamPtrInput

type ClusterIamPtrOutput 

type ClusterIamPtrOutput struct{ *pulumi.OutputState }

func (ClusterIamPtrOutput) Elem 

func (o ClusterIamPtrOutput) Elem() ClusterIamOutput

func (ClusterIamPtrOutput) ElementType 

func (ClusterIamPtrOutput) ElementType() reflect.Type

func (ClusterIamPtrOutput) Enabled 

func (o ClusterIamPtrOutput) Enabled() pulumi.BoolPtrOutput

SASL/IAM authentication is enabled or not.

func (ClusterIamPtrOutput) ToClusterIamPtrOutput 

func (o ClusterIamPtrOutput) ToClusterIamPtrOutput() ClusterIamPtrOutput

func (ClusterIamPtrOutput) ToClusterIamPtrOutputWithContext 

func (o ClusterIamPtrOutput) ToClusterIamPtrOutputWithContext(ctx context.Context) ClusterIamPtrOutput

type ClusterInput 

type ClusterInput interface {
	pulumi.Input

	ToClusterOutput() ClusterOutput
	ToClusterOutputWithContext(ctx context.Context) ClusterOutput
}

type ClusterJmxExporter 

type ClusterJmxExporter struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	EnabledInBroker bool `pulumi:"enabledInBroker"`
}

type ClusterJmxExporterArgs 

type ClusterJmxExporterArgs struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	EnabledInBroker pulumi.BoolInput `pulumi:"enabledInBroker"`
}

func (ClusterJmxExporterArgs) ElementType 

func (ClusterJmxExporterArgs) ElementType() reflect.Type

func (ClusterJmxExporterArgs) ToClusterJmxExporterOutput 

func (i ClusterJmxExporterArgs) ToClusterJmxExporterOutput() ClusterJmxExporterOutput

func (ClusterJmxExporterArgs) ToClusterJmxExporterOutputWithContext 

func (i ClusterJmxExporterArgs) ToClusterJmxExporterOutputWithContext(ctx context.Context) ClusterJmxExporterOutput

func (ClusterJmxExporterArgs) ToClusterJmxExporterPtrOutput 

func (i ClusterJmxExporterArgs) ToClusterJmxExporterPtrOutput() ClusterJmxExporterPtrOutput

func (ClusterJmxExporterArgs) ToClusterJmxExporterPtrOutputWithContext 

func (i ClusterJmxExporterArgs) ToClusterJmxExporterPtrOutputWithContext(ctx context.Context) ClusterJmxExporterPtrOutput

type ClusterJmxExporterInput 

type ClusterJmxExporterInput interface {
	pulumi.Input

	ToClusterJmxExporterOutput() ClusterJmxExporterOutput
	ToClusterJmxExporterOutputWithContext(context.Context) ClusterJmxExporterOutput
}

ClusterJmxExporterInput is an input type that accepts ClusterJmxExporterArgs and ClusterJmxExporterOutput values. You can construct a concrete instance of `ClusterJmxExporterInput` via: 

ClusterJmxExporterArgs{...}

type ClusterJmxExporterOutput 

type ClusterJmxExporterOutput struct{ *pulumi.OutputState }

func (ClusterJmxExporterOutput) ElementType 

func (ClusterJmxExporterOutput) ElementType() reflect.Type

func (ClusterJmxExporterOutput) EnabledInBroker 

func (o ClusterJmxExporterOutput) EnabledInBroker() pulumi.BoolOutput

Indicates whether you want to enable or disable the JMX Exporter.

func (ClusterJmxExporterOutput) ToClusterJmxExporterOutput 

func (o ClusterJmxExporterOutput) ToClusterJmxExporterOutput() ClusterJmxExporterOutput

func (ClusterJmxExporterOutput) ToClusterJmxExporterOutputWithContext 

func (o ClusterJmxExporterOutput) ToClusterJmxExporterOutputWithContext(ctx context.Context) ClusterJmxExporterOutput

func (ClusterJmxExporterOutput) ToClusterJmxExporterPtrOutput 

func (o ClusterJmxExporterOutput) ToClusterJmxExporterPtrOutput() ClusterJmxExporterPtrOutput

func (ClusterJmxExporterOutput) ToClusterJmxExporterPtrOutputWithContext 

func (o ClusterJmxExporterOutput) ToClusterJmxExporterPtrOutputWithContext(ctx context.Context) ClusterJmxExporterPtrOutput

type ClusterJmxExporterPtrInput 

type ClusterJmxExporterPtrInput interface {
	pulumi.Input

	ToClusterJmxExporterPtrOutput() ClusterJmxExporterPtrOutput
	ToClusterJmxExporterPtrOutputWithContext(context.Context) ClusterJmxExporterPtrOutput
}

ClusterJmxExporterPtrInput is an input type that accepts ClusterJmxExporterArgs, ClusterJmxExporterPtr and ClusterJmxExporterPtrOutput values. You can construct a concrete instance of `ClusterJmxExporterPtrInput` via: 

        ClusterJmxExporterArgs{...}

or:

        nil

func ClusterJmxExporterPtr 

func ClusterJmxExporterPtr(v *ClusterJmxExporterArgs) ClusterJmxExporterPtrInput

type ClusterJmxExporterPtrOutput 

type ClusterJmxExporterPtrOutput struct{ *pulumi.OutputState }

func (ClusterJmxExporterPtrOutput) Elem 

func (o ClusterJmxExporterPtrOutput) Elem() ClusterJmxExporterOutput

func (ClusterJmxExporterPtrOutput) ElementType 

func (ClusterJmxExporterPtrOutput) ElementType() reflect.Type

func (ClusterJmxExporterPtrOutput) EnabledInBroker 

func (o ClusterJmxExporterPtrOutput) EnabledInBroker() pulumi.BoolPtrOutput

Indicates whether you want to enable or disable the JMX Exporter.

func (ClusterJmxExporterPtrOutput) ToClusterJmxExporterPtrOutput 

func (o ClusterJmxExporterPtrOutput) ToClusterJmxExporterPtrOutput() ClusterJmxExporterPtrOutput

func (ClusterJmxExporterPtrOutput) ToClusterJmxExporterPtrOutputWithContext 

func (o ClusterJmxExporterPtrOutput) ToClusterJmxExporterPtrOutputWithContext(ctx context.Context) ClusterJmxExporterPtrOutput

type ClusterLoggingInfo 

type ClusterLoggingInfo struct {
	// You can configure your MSK cluster to send broker logs to different destination types. This configuration specifies the details of these destinations.
	BrokerLogs ClusterBrokerLogs `pulumi:"brokerLogs"`
}

type ClusterLoggingInfoArgs 

type ClusterLoggingInfoArgs struct {
	// You can configure your MSK cluster to send broker logs to different destination types. This configuration specifies the details of these destinations.
	BrokerLogs ClusterBrokerLogsInput `pulumi:"brokerLogs"`
}

func (ClusterLoggingInfoArgs) ElementType 

func (ClusterLoggingInfoArgs) ElementType() reflect.Type

func (ClusterLoggingInfoArgs) ToClusterLoggingInfoOutput 

func (i ClusterLoggingInfoArgs) ToClusterLoggingInfoOutput() ClusterLoggingInfoOutput

func (ClusterLoggingInfoArgs) ToClusterLoggingInfoOutputWithContext 

func (i ClusterLoggingInfoArgs) ToClusterLoggingInfoOutputWithContext(ctx context.Context) ClusterLoggingInfoOutput

func (ClusterLoggingInfoArgs) ToClusterLoggingInfoPtrOutput 

func (i ClusterLoggingInfoArgs) ToClusterLoggingInfoPtrOutput() ClusterLoggingInfoPtrOutput

func (ClusterLoggingInfoArgs) ToClusterLoggingInfoPtrOutputWithContext 

func (i ClusterLoggingInfoArgs) ToClusterLoggingInfoPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoPtrOutput

type ClusterLoggingInfoInput 

type ClusterLoggingInfoInput interface {
	pulumi.Input

	ToClusterLoggingInfoOutput() ClusterLoggingInfoOutput
	ToClusterLoggingInfoOutputWithContext(context.Context) ClusterLoggingInfoOutput
}

ClusterLoggingInfoInput is an input type that accepts ClusterLoggingInfoArgs and ClusterLoggingInfoOutput values. You can construct a concrete instance of `ClusterLoggingInfoInput` via: 

ClusterLoggingInfoArgs{...}

type ClusterLoggingInfoOutput 

type ClusterLoggingInfoOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoOutput) BrokerLogs 

func (o ClusterLoggingInfoOutput) BrokerLogs() ClusterBrokerLogsOutput

You can configure your MSK cluster to send broker logs to different destination types. This configuration specifies the details of these destinations.

func (ClusterLoggingInfoOutput) ElementType 

func (ClusterLoggingInfoOutput) ElementType() reflect.Type

func (ClusterLoggingInfoOutput) ToClusterLoggingInfoOutput 

func (o ClusterLoggingInfoOutput) ToClusterLoggingInfoOutput() ClusterLoggingInfoOutput

func (ClusterLoggingInfoOutput) ToClusterLoggingInfoOutputWithContext 

func (o ClusterLoggingInfoOutput) ToClusterLoggingInfoOutputWithContext(ctx context.Context) ClusterLoggingInfoOutput

func (ClusterLoggingInfoOutput) ToClusterLoggingInfoPtrOutput 

func (o ClusterLoggingInfoOutput) ToClusterLoggingInfoPtrOutput() ClusterLoggingInfoPtrOutput

func (ClusterLoggingInfoOutput) ToClusterLoggingInfoPtrOutputWithContext 

func (o ClusterLoggingInfoOutput) ToClusterLoggingInfoPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoPtrOutput

type ClusterLoggingInfoPtrInput 

type ClusterLoggingInfoPtrInput interface {
	pulumi.Input

	ToClusterLoggingInfoPtrOutput() ClusterLoggingInfoPtrOutput
	ToClusterLoggingInfoPtrOutputWithContext(context.Context) ClusterLoggingInfoPtrOutput
}

ClusterLoggingInfoPtrInput is an input type that accepts ClusterLoggingInfoArgs, ClusterLoggingInfoPtr and ClusterLoggingInfoPtrOutput values. You can construct a concrete instance of `ClusterLoggingInfoPtrInput` via: 

        ClusterLoggingInfoArgs{...}

or:

        nil

func ClusterLoggingInfoPtr 

func ClusterLoggingInfoPtr(v *ClusterLoggingInfoArgs) ClusterLoggingInfoPtrInput

type ClusterLoggingInfoPtrOutput 

type ClusterLoggingInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoPtrOutput) BrokerLogs 

func (o ClusterLoggingInfoPtrOutput) BrokerLogs() ClusterBrokerLogsPtrOutput

You can configure your MSK cluster to send broker logs to different destination types. This configuration specifies the details of these destinations.

func (ClusterLoggingInfoPtrOutput) Elem 

func (o ClusterLoggingInfoPtrOutput) Elem() ClusterLoggingInfoOutput

func (ClusterLoggingInfoPtrOutput) ElementType 

func (ClusterLoggingInfoPtrOutput) ElementType() reflect.Type

func (ClusterLoggingInfoPtrOutput) ToClusterLoggingInfoPtrOutput 

func (o ClusterLoggingInfoPtrOutput) ToClusterLoggingInfoPtrOutput() ClusterLoggingInfoPtrOutput

func (ClusterLoggingInfoPtrOutput) ToClusterLoggingInfoPtrOutputWithContext 

func (o ClusterLoggingInfoPtrOutput) ToClusterLoggingInfoPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoPtrOutput

type ClusterNodeExporter 

type ClusterNodeExporter struct {
	// Indicates whether you want to enable or disable the Node Exporter.
	EnabledInBroker bool `pulumi:"enabledInBroker"`
}

type ClusterNodeExporterArgs 

type ClusterNodeExporterArgs struct {
	// Indicates whether you want to enable or disable the Node Exporter.
	EnabledInBroker pulumi.BoolInput `pulumi:"enabledInBroker"`
}

func (ClusterNodeExporterArgs) ElementType 

func (ClusterNodeExporterArgs) ElementType() reflect.Type

func (ClusterNodeExporterArgs) ToClusterNodeExporterOutput 

func (i ClusterNodeExporterArgs) ToClusterNodeExporterOutput() ClusterNodeExporterOutput

func (ClusterNodeExporterArgs) ToClusterNodeExporterOutputWithContext 

func (i ClusterNodeExporterArgs) ToClusterNodeExporterOutputWithContext(ctx context.Context) ClusterNodeExporterOutput

func (ClusterNodeExporterArgs) ToClusterNodeExporterPtrOutput 

func (i ClusterNodeExporterArgs) ToClusterNodeExporterPtrOutput() ClusterNodeExporterPtrOutput

func (ClusterNodeExporterArgs) ToClusterNodeExporterPtrOutputWithContext 

func (i ClusterNodeExporterArgs) ToClusterNodeExporterPtrOutputWithContext(ctx context.Context) ClusterNodeExporterPtrOutput

type ClusterNodeExporterInput 

type ClusterNodeExporterInput interface {
	pulumi.Input

	ToClusterNodeExporterOutput() ClusterNodeExporterOutput
	ToClusterNodeExporterOutputWithContext(context.Context) ClusterNodeExporterOutput
}

ClusterNodeExporterInput is an input type that accepts ClusterNodeExporterArgs and ClusterNodeExporterOutput values. You can construct a concrete instance of `ClusterNodeExporterInput` via: 

ClusterNodeExporterArgs{...}

type ClusterNodeExporterOutput 

type ClusterNodeExporterOutput struct{ *pulumi.OutputState }

func (ClusterNodeExporterOutput) ElementType 

func (ClusterNodeExporterOutput) ElementType() reflect.Type

func (ClusterNodeExporterOutput) EnabledInBroker 

func (o ClusterNodeExporterOutput) EnabledInBroker() pulumi.BoolOutput

Indicates whether you want to enable or disable the Node Exporter.

func (ClusterNodeExporterOutput) ToClusterNodeExporterOutput 

func (o ClusterNodeExporterOutput) ToClusterNodeExporterOutput() ClusterNodeExporterOutput

func (ClusterNodeExporterOutput) ToClusterNodeExporterOutputWithContext 

func (o ClusterNodeExporterOutput) ToClusterNodeExporterOutputWithContext(ctx context.Context) ClusterNodeExporterOutput

func (ClusterNodeExporterOutput) ToClusterNodeExporterPtrOutput 

func (o ClusterNodeExporterOutput) ToClusterNodeExporterPtrOutput() ClusterNodeExporterPtrOutput

func (ClusterNodeExporterOutput) ToClusterNodeExporterPtrOutputWithContext 

func (o ClusterNodeExporterOutput) ToClusterNodeExporterPtrOutputWithContext(ctx context.Context) ClusterNodeExporterPtrOutput

type ClusterNodeExporterPtrInput 

type ClusterNodeExporterPtrInput interface {
	pulumi.Input

	ToClusterNodeExporterPtrOutput() ClusterNodeExporterPtrOutput
	ToClusterNodeExporterPtrOutputWithContext(context.Context) ClusterNodeExporterPtrOutput
}

ClusterNodeExporterPtrInput is an input type that accepts ClusterNodeExporterArgs, ClusterNodeExporterPtr and ClusterNodeExporterPtrOutput values. You can construct a concrete instance of `ClusterNodeExporterPtrInput` via: 

        ClusterNodeExporterArgs{...}

or:

        nil

func ClusterNodeExporterPtr 

func ClusterNodeExporterPtr(v *ClusterNodeExporterArgs) ClusterNodeExporterPtrInput

type ClusterNodeExporterPtrOutput 

type ClusterNodeExporterPtrOutput struct{ *pulumi.OutputState }

func (ClusterNodeExporterPtrOutput) Elem 

func (o ClusterNodeExporterPtrOutput) Elem() ClusterNodeExporterOutput

func (ClusterNodeExporterPtrOutput) ElementType 

func (ClusterNodeExporterPtrOutput) ElementType() reflect.Type

func (ClusterNodeExporterPtrOutput) EnabledInBroker 

func (o ClusterNodeExporterPtrOutput) EnabledInBroker() pulumi.BoolPtrOutput

Indicates whether you want to enable or disable the Node Exporter.

func (ClusterNodeExporterPtrOutput) ToClusterNodeExporterPtrOutput 

func (o ClusterNodeExporterPtrOutput) ToClusterNodeExporterPtrOutput() ClusterNodeExporterPtrOutput

func (ClusterNodeExporterPtrOutput) ToClusterNodeExporterPtrOutputWithContext 

func (o ClusterNodeExporterPtrOutput) ToClusterNodeExporterPtrOutputWithContext(ctx context.Context) ClusterNodeExporterPtrOutput

type ClusterOpenMonitoring 

type ClusterOpenMonitoring struct {
	// Prometheus exporter settings.
	Prometheus ClusterPrometheus `pulumi:"prometheus"`
}

type ClusterOpenMonitoringArgs 

type ClusterOpenMonitoringArgs struct {
	// Prometheus exporter settings.
	Prometheus ClusterPrometheusInput `pulumi:"prometheus"`
}

func (ClusterOpenMonitoringArgs) ElementType 

func (ClusterOpenMonitoringArgs) ElementType() reflect.Type

func (ClusterOpenMonitoringArgs) ToClusterOpenMonitoringOutput 

func (i ClusterOpenMonitoringArgs) ToClusterOpenMonitoringOutput() ClusterOpenMonitoringOutput

func (ClusterOpenMonitoringArgs) ToClusterOpenMonitoringOutputWithContext 

func (i ClusterOpenMonitoringArgs) ToClusterOpenMonitoringOutputWithContext(ctx context.Context) ClusterOpenMonitoringOutput

func (ClusterOpenMonitoringArgs) ToClusterOpenMonitoringPtrOutput 

func (i ClusterOpenMonitoringArgs) ToClusterOpenMonitoringPtrOutput() ClusterOpenMonitoringPtrOutput

func (ClusterOpenMonitoringArgs) ToClusterOpenMonitoringPtrOutputWithContext 

func (i ClusterOpenMonitoringArgs) ToClusterOpenMonitoringPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPtrOutput

type ClusterOpenMonitoringInput 

type ClusterOpenMonitoringInput interface {
	pulumi.Input

	ToClusterOpenMonitoringOutput() ClusterOpenMonitoringOutput
	ToClusterOpenMonitoringOutputWithContext(context.Context) ClusterOpenMonitoringOutput
}

ClusterOpenMonitoringInput is an input type that accepts ClusterOpenMonitoringArgs and ClusterOpenMonitoringOutput values. You can construct a concrete instance of `ClusterOpenMonitoringInput` via: 

ClusterOpenMonitoringArgs{...}

type ClusterOpenMonitoringOutput 

type ClusterOpenMonitoringOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringOutput) ElementType 

func (ClusterOpenMonitoringOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringOutput) Prometheus 

func (o ClusterOpenMonitoringOutput) Prometheus() ClusterPrometheusOutput

Prometheus exporter settings.

func (ClusterOpenMonitoringOutput) ToClusterOpenMonitoringOutput 

func (o ClusterOpenMonitoringOutput) ToClusterOpenMonitoringOutput() ClusterOpenMonitoringOutput

func (ClusterOpenMonitoringOutput) ToClusterOpenMonitoringOutputWithContext 

func (o ClusterOpenMonitoringOutput) ToClusterOpenMonitoringOutputWithContext(ctx context.Context) ClusterOpenMonitoringOutput

func (ClusterOpenMonitoringOutput) ToClusterOpenMonitoringPtrOutput 

func (o ClusterOpenMonitoringOutput) ToClusterOpenMonitoringPtrOutput() ClusterOpenMonitoringPtrOutput

func (ClusterOpenMonitoringOutput) ToClusterOpenMonitoringPtrOutputWithContext 

func (o ClusterOpenMonitoringOutput) ToClusterOpenMonitoringPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPtrOutput

type ClusterOpenMonitoringPtrInput 

type ClusterOpenMonitoringPtrInput interface {
	pulumi.Input

	ToClusterOpenMonitoringPtrOutput() ClusterOpenMonitoringPtrOutput
	ToClusterOpenMonitoringPtrOutputWithContext(context.Context) ClusterOpenMonitoringPtrOutput
}

ClusterOpenMonitoringPtrInput is an input type that accepts ClusterOpenMonitoringArgs, ClusterOpenMonitoringPtr and ClusterOpenMonitoringPtrOutput values. You can construct a concrete instance of `ClusterOpenMonitoringPtrInput` via: 

        ClusterOpenMonitoringArgs{...}

or:

        nil

func ClusterOpenMonitoringPtr 

func ClusterOpenMonitoringPtr(v *ClusterOpenMonitoringArgs) ClusterOpenMonitoringPtrInput

type ClusterOpenMonitoringPtrOutput 

type ClusterOpenMonitoringPtrOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringPtrOutput) Elem 

func (o ClusterOpenMonitoringPtrOutput) Elem() ClusterOpenMonitoringOutput

func (ClusterOpenMonitoringPtrOutput) ElementType 

func (ClusterOpenMonitoringPtrOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringPtrOutput) Prometheus 

func (o ClusterOpenMonitoringPtrOutput) Prometheus() ClusterPrometheusPtrOutput

Prometheus exporter settings.

func (ClusterOpenMonitoringPtrOutput) ToClusterOpenMonitoringPtrOutput 

func (o ClusterOpenMonitoringPtrOutput) ToClusterOpenMonitoringPtrOutput() ClusterOpenMonitoringPtrOutput

func (ClusterOpenMonitoringPtrOutput) ToClusterOpenMonitoringPtrOutputWithContext 

func (o ClusterOpenMonitoringPtrOutput) ToClusterOpenMonitoringPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPtrOutput

type ClusterOutput 

type ClusterOutput struct{ *pulumi.OutputState }

func (ClusterOutput) Arn added in v0.17.0 

func (o ClusterOutput) Arn() pulumi.StringOutput

func (ClusterOutput) BrokerNodeGroupInfo added in v0.17.0 

func (o ClusterOutput) BrokerNodeGroupInfo() ClusterBrokerNodeGroupInfoOutput

Information about the broker nodes in the cluster.

func (ClusterOutput) ClientAuthentication added in v0.17.0 

func (o ClusterOutput) ClientAuthentication() ClusterClientAuthenticationPtrOutput

VPC connection control settings for brokers.

func (ClusterOutput) ClusterName added in v0.17.0 

func (o ClusterOutput) ClusterName() pulumi.StringOutput

The name of the cluster.

func (ClusterOutput) ConfigurationInfo added in v0.17.0 

func (o ClusterOutput) ConfigurationInfo() ClusterConfigurationInfoPtrOutput

Represents the configuration that you want MSK to use for the cluster.

func (ClusterOutput) CurrentVersion added in v0.17.0 

func (o ClusterOutput) CurrentVersion() pulumi.StringPtrOutput

The current version of the MSK cluster

func (ClusterOutput) ElementType 

func (ClusterOutput) ElementType() reflect.Type

func (ClusterOutput) EncryptionInfo added in v0.17.0 

func (o ClusterOutput) EncryptionInfo() ClusterEncryptionInfoPtrOutput

Includes all encryption-related information.

func (ClusterOutput) EnhancedMonitoring added in v0.17.0 

func (o ClusterOutput) EnhancedMonitoring() ClusterEnhancedMonitoringPtrOutput

Specifies the level of monitoring for the MSK cluster. The possible values are `DEFAULT` , `PER_BROKER` , and `PER_TOPIC_PER_BROKER` .

func (ClusterOutput) KafkaVersion added in v0.17.0 

func (o ClusterOutput) KafkaVersion() pulumi.StringOutput

The version of Apache Kafka. You can use Amazon MSK to create clusters that use Apache Kafka versions 1.1.1 and 2.2.1.

func (ClusterOutput) LoggingInfo added in v0.17.0 

func (o ClusterOutput) LoggingInfo() ClusterLoggingInfoPtrOutput

Logging Info details.

func (ClusterOutput) NumberOfBrokerNodes added in v0.17.0 

func (o ClusterOutput) NumberOfBrokerNodes() pulumi.IntOutput

The number of broker nodes in the cluster.

func (ClusterOutput) OpenMonitoring added in v0.17.0 

func (o ClusterOutput) OpenMonitoring() ClusterOpenMonitoringPtrOutput

The settings for open monitoring.

func (ClusterOutput) StorageMode added in v0.38.0 

func (o ClusterOutput) StorageMode() ClusterStorageModePtrOutput

This controls storage mode for supported storage tiers.

func (ClusterOutput) Tags added in v0.17.0 

func (o ClusterOutput) Tags() pulumi.StringMapOutput

A key-value pair to associate with a resource.

func (ClusterOutput) ToClusterOutput 

func (o ClusterOutput) ToClusterOutput() ClusterOutput

func (ClusterOutput) ToClusterOutputWithContext 

func (o ClusterOutput) ToClusterOutputWithContext(ctx context.Context) ClusterOutput

type ClusterPolicy added in v0.59.0 

type ClusterPolicy struct {
	pulumi.CustomResourceState

	// The arn of the cluster for the resource policy.
	ClusterArn pulumi.StringOutput `pulumi:"clusterArn"`
	// The current version of the policy attached to the specified cluster
	CurrentVersion pulumi.StringOutput `pulumi:"currentVersion"`
	// A policy document containing permissions to add to the specified cluster.
	//
	// Search the [CloudFormation User Guide](https://docs.aws.amazon.com/cloudformation/) for `AWS::MSK::ClusterPolicy` for more information about the expected schema for this property.
	Policy pulumi.AnyOutput `pulumi:"policy"`
}

Resource Type definition for AWS::MSK::ClusterPolicy

func GetClusterPolicy added in v0.59.0 

func GetClusterPolicy(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ClusterPolicyState, opts ...pulumi.ResourceOption) (*ClusterPolicy, error)

GetClusterPolicy gets an existing ClusterPolicy 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 NewClusterPolicy added in v0.59.0 

func NewClusterPolicy(ctx *pulumi.Context,
	name string, args *ClusterPolicyArgs, opts ...pulumi.ResourceOption) (*ClusterPolicy, error)

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

func (*ClusterPolicy) ElementType added in v0.59.0 

func (*ClusterPolicy) ElementType() reflect.Type

func (*ClusterPolicy) ToClusterPolicyOutput added in v0.59.0 

func (i *ClusterPolicy) ToClusterPolicyOutput() ClusterPolicyOutput

func (*ClusterPolicy) ToClusterPolicyOutputWithContext added in v0.59.0 

func (i *ClusterPolicy) ToClusterPolicyOutputWithContext(ctx context.Context) ClusterPolicyOutput

type ClusterPolicyArgs added in v0.59.0 

type ClusterPolicyArgs struct {
	// The arn of the cluster for the resource policy.
	ClusterArn pulumi.StringInput
	// A policy document containing permissions to add to the specified cluster.
	//
	// Search the [CloudFormation User Guide](https://docs.aws.amazon.com/cloudformation/) for `AWS::MSK::ClusterPolicy` for more information about the expected schema for this property.
	Policy pulumi.Input
}

The set of arguments for constructing a ClusterPolicy resource.

func (ClusterPolicyArgs) ElementType added in v0.59.0 

func (ClusterPolicyArgs) ElementType() reflect.Type

type ClusterPolicyInput added in v0.59.0 

type ClusterPolicyInput interface {
	pulumi.Input

	ToClusterPolicyOutput() ClusterPolicyOutput
	ToClusterPolicyOutputWithContext(ctx context.Context) ClusterPolicyOutput
}

type ClusterPolicyOutput added in v0.59.0 

type ClusterPolicyOutput struct{ *pulumi.OutputState }

func (ClusterPolicyOutput) ClusterArn added in v0.59.0 

func (o ClusterPolicyOutput) ClusterArn() pulumi.StringOutput

The arn of the cluster for the resource policy.

func (ClusterPolicyOutput) CurrentVersion added in v0.59.0 

func (o ClusterPolicyOutput) CurrentVersion() pulumi.StringOutput

The current version of the policy attached to the specified cluster

func (ClusterPolicyOutput) ElementType added in v0.59.0 

func (ClusterPolicyOutput) ElementType() reflect.Type

func (ClusterPolicyOutput) Policy added in v0.59.0 

func (o ClusterPolicyOutput) Policy() pulumi.AnyOutput

A policy document containing permissions to add to the specified cluster.

Search the [CloudFormation User Guide](https://docs.aws.amazon.com/cloudformation/) for `AWS::MSK::ClusterPolicy` for more information about the expected schema for this property.

func (ClusterPolicyOutput) ToClusterPolicyOutput added in v0.59.0 

func (o ClusterPolicyOutput) ToClusterPolicyOutput() ClusterPolicyOutput

func (ClusterPolicyOutput) ToClusterPolicyOutputWithContext added in v0.59.0 

func (o ClusterPolicyOutput) ToClusterPolicyOutputWithContext(ctx context.Context) ClusterPolicyOutput

type ClusterPolicyState added in v0.59.0 

type ClusterPolicyState struct {
}

func (ClusterPolicyState) ElementType added in v0.59.0 

func (ClusterPolicyState) ElementType() reflect.Type

type ClusterPrometheus 

type ClusterPrometheus struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter *ClusterJmxExporter `pulumi:"jmxExporter"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter *ClusterNodeExporter `pulumi:"nodeExporter"`
}

type ClusterPrometheusArgs 

type ClusterPrometheusArgs struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter ClusterJmxExporterPtrInput `pulumi:"jmxExporter"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter ClusterNodeExporterPtrInput `pulumi:"nodeExporter"`
}

func (ClusterPrometheusArgs) ElementType 

func (ClusterPrometheusArgs) ElementType() reflect.Type

func (ClusterPrometheusArgs) ToClusterPrometheusOutput 

func (i ClusterPrometheusArgs) ToClusterPrometheusOutput() ClusterPrometheusOutput

func (ClusterPrometheusArgs) ToClusterPrometheusOutputWithContext 

func (i ClusterPrometheusArgs) ToClusterPrometheusOutputWithContext(ctx context.Context) ClusterPrometheusOutput

func (ClusterPrometheusArgs) ToClusterPrometheusPtrOutput 

func (i ClusterPrometheusArgs) ToClusterPrometheusPtrOutput() ClusterPrometheusPtrOutput

func (ClusterPrometheusArgs) ToClusterPrometheusPtrOutputWithContext 

func (i ClusterPrometheusArgs) ToClusterPrometheusPtrOutputWithContext(ctx context.Context) ClusterPrometheusPtrOutput

type ClusterPrometheusInput 

type ClusterPrometheusInput interface {
	pulumi.Input

	ToClusterPrometheusOutput() ClusterPrometheusOutput
	ToClusterPrometheusOutputWithContext(context.Context) ClusterPrometheusOutput
}

ClusterPrometheusInput is an input type that accepts ClusterPrometheusArgs and ClusterPrometheusOutput values. You can construct a concrete instance of `ClusterPrometheusInput` via: 

ClusterPrometheusArgs{...}

type ClusterPrometheusOutput 

type ClusterPrometheusOutput struct{ *pulumi.OutputState }

func (ClusterPrometheusOutput) ElementType 

func (ClusterPrometheusOutput) ElementType() reflect.Type

func (ClusterPrometheusOutput) JmxExporter 

func (o ClusterPrometheusOutput) JmxExporter() ClusterJmxExporterPtrOutput

Indicates whether you want to enable or disable the JMX Exporter.

func (ClusterPrometheusOutput) NodeExporter 

func (o ClusterPrometheusOutput) NodeExporter() ClusterNodeExporterPtrOutput

Indicates whether you want to enable or disable the Node Exporter.

func (ClusterPrometheusOutput) ToClusterPrometheusOutput 

func (o ClusterPrometheusOutput) ToClusterPrometheusOutput() ClusterPrometheusOutput

func (ClusterPrometheusOutput) ToClusterPrometheusOutputWithContext 

func (o ClusterPrometheusOutput) ToClusterPrometheusOutputWithContext(ctx context.Context) ClusterPrometheusOutput

func (ClusterPrometheusOutput) ToClusterPrometheusPtrOutput 

func (o ClusterPrometheusOutput) ToClusterPrometheusPtrOutput() ClusterPrometheusPtrOutput

func (ClusterPrometheusOutput) ToClusterPrometheusPtrOutputWithContext 

func (o ClusterPrometheusOutput) ToClusterPrometheusPtrOutputWithContext(ctx context.Context) ClusterPrometheusPtrOutput

type ClusterPrometheusPtrInput 

type ClusterPrometheusPtrInput interface {
	pulumi.Input

	ToClusterPrometheusPtrOutput() ClusterPrometheusPtrOutput
	ToClusterPrometheusPtrOutputWithContext(context.Context) ClusterPrometheusPtrOutput
}

ClusterPrometheusPtrInput is an input type that accepts ClusterPrometheusArgs, ClusterPrometheusPtr and ClusterPrometheusPtrOutput values. You can construct a concrete instance of `ClusterPrometheusPtrInput` via: 

        ClusterPrometheusArgs{...}

or:

        nil

func ClusterPrometheusPtr 

func ClusterPrometheusPtr(v *ClusterPrometheusArgs) ClusterPrometheusPtrInput

type ClusterPrometheusPtrOutput 

type ClusterPrometheusPtrOutput struct{ *pulumi.OutputState }

func (ClusterPrometheusPtrOutput) Elem 

func (o ClusterPrometheusPtrOutput) Elem() ClusterPrometheusOutput

func (ClusterPrometheusPtrOutput) ElementType 

func (ClusterPrometheusPtrOutput) ElementType() reflect.Type

func (ClusterPrometheusPtrOutput) JmxExporter 

func (o ClusterPrometheusPtrOutput) JmxExporter() ClusterJmxExporterPtrOutput

Indicates whether you want to enable or disable the JMX Exporter.

func (ClusterPrometheusPtrOutput) NodeExporter 

func (o ClusterPrometheusPtrOutput) NodeExporter() ClusterNodeExporterPtrOutput

Indicates whether you want to enable or disable the Node Exporter.

func (ClusterPrometheusPtrOutput) ToClusterPrometheusPtrOutput 

func (o ClusterPrometheusPtrOutput) ToClusterPrometheusPtrOutput() ClusterPrometheusPtrOutput

func (ClusterPrometheusPtrOutput) ToClusterPrometheusPtrOutputWithContext 

func (o ClusterPrometheusPtrOutput) ToClusterPrometheusPtrOutputWithContext(ctx context.Context) ClusterPrometheusPtrOutput

type ClusterProvisionedThroughput added in v0.12.0 

type ClusterProvisionedThroughput struct {
	// Provisioned throughput is enabled or not.
	Enabled *bool `pulumi:"enabled"`
	// Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second.
	VolumeThroughput *int `pulumi:"volumeThroughput"`
}

type ClusterProvisionedThroughputArgs added in v0.12.0 

type ClusterProvisionedThroughputArgs struct {
	// Provisioned throughput is enabled or not.
	Enabled pulumi.BoolPtrInput `pulumi:"enabled"`
	// Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second.
	VolumeThroughput pulumi.IntPtrInput `pulumi:"volumeThroughput"`
}

func (ClusterProvisionedThroughputArgs) ElementType added in v0.12.0 

func (ClusterProvisionedThroughputArgs) ElementType() reflect.Type

func (ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputOutput added in v0.12.0 

func (i ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputOutput() ClusterProvisionedThroughputOutput

func (ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputOutputWithContext added in v0.12.0 

func (i ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputOutputWithContext(ctx context.Context) ClusterProvisionedThroughputOutput

func (ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputPtrOutput added in v0.12.0 

func (i ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputPtrOutput() ClusterProvisionedThroughputPtrOutput

func (ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputPtrOutputWithContext added in v0.12.0 

func (i ClusterProvisionedThroughputArgs) ToClusterProvisionedThroughputPtrOutputWithContext(ctx context.Context) ClusterProvisionedThroughputPtrOutput

type ClusterProvisionedThroughputInput added in v0.12.0 

type ClusterProvisionedThroughputInput interface {
	pulumi.Input

	ToClusterProvisionedThroughputOutput() ClusterProvisionedThroughputOutput
	ToClusterProvisionedThroughputOutputWithContext(context.Context) ClusterProvisionedThroughputOutput
}

ClusterProvisionedThroughputInput is an input type that accepts ClusterProvisionedThroughputArgs and ClusterProvisionedThroughputOutput values. You can construct a concrete instance of `ClusterProvisionedThroughputInput` via: 

ClusterProvisionedThroughputArgs{...}

type ClusterProvisionedThroughputOutput added in v0.12.0 

type ClusterProvisionedThroughputOutput struct{ *pulumi.OutputState }

func (ClusterProvisionedThroughputOutput) ElementType added in v0.12.0 

func (ClusterProvisionedThroughputOutput) ElementType() reflect.Type

func (ClusterProvisionedThroughputOutput) Enabled added in v0.12.0 

func (o ClusterProvisionedThroughputOutput) Enabled() pulumi.BoolPtrOutput

Provisioned throughput is enabled or not.

func (ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputOutput added in v0.12.0 

func (o ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputOutput() ClusterProvisionedThroughputOutput

func (ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputOutputWithContext added in v0.12.0 

func (o ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputOutputWithContext(ctx context.Context) ClusterProvisionedThroughputOutput

func (ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputPtrOutput added in v0.12.0 

func (o ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputPtrOutput() ClusterProvisionedThroughputPtrOutput

func (ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputPtrOutputWithContext added in v0.12.0 

func (o ClusterProvisionedThroughputOutput) ToClusterProvisionedThroughputPtrOutputWithContext(ctx context.Context) ClusterProvisionedThroughputPtrOutput

func (ClusterProvisionedThroughputOutput) VolumeThroughput added in v0.12.0 

func (o ClusterProvisionedThroughputOutput) VolumeThroughput() pulumi.IntPtrOutput

Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second.

type ClusterProvisionedThroughputPtrInput added in v0.12.0 

type ClusterProvisionedThroughputPtrInput interface {
	pulumi.Input

	ToClusterProvisionedThroughputPtrOutput() ClusterProvisionedThroughputPtrOutput
	ToClusterProvisionedThroughputPtrOutputWithContext(context.Context) ClusterProvisionedThroughputPtrOutput
}

ClusterProvisionedThroughputPtrInput is an input type that accepts ClusterProvisionedThroughputArgs, ClusterProvisionedThroughputPtr and ClusterProvisionedThroughputPtrOutput values. You can construct a concrete instance of `ClusterProvisionedThroughputPtrInput` via: 

        ClusterProvisionedThroughputArgs{...}

or:

        nil

func ClusterProvisionedThroughputPtr added in v0.12.0 

func ClusterProvisionedThroughputPtr(v *ClusterProvisionedThroughputArgs) ClusterProvisionedThroughputPtrInput

type ClusterProvisionedThroughputPtrOutput added in v0.12.0 

type ClusterProvisionedThroughputPtrOutput struct{ *pulumi.OutputState }

func (ClusterProvisionedThroughputPtrOutput) Elem added in v0.12.0 

func (o ClusterProvisionedThroughputPtrOutput) Elem() ClusterProvisionedThroughputOutput

func (ClusterProvisionedThroughputPtrOutput) ElementType added in v0.12.0 

func (ClusterProvisionedThroughputPtrOutput) ElementType() reflect.Type

func (ClusterProvisionedThroughputPtrOutput) Enabled added in v0.12.0 

func (o ClusterProvisionedThroughputPtrOutput) Enabled() pulumi.BoolPtrOutput

Provisioned throughput is enabled or not.

func (ClusterProvisionedThroughputPtrOutput) ToClusterProvisionedThroughputPtrOutput added in v0.12.0 

func (o ClusterProvisionedThroughputPtrOutput) ToClusterProvisionedThroughputPtrOutput() ClusterProvisionedThroughputPtrOutput

func (ClusterProvisionedThroughputPtrOutput) ToClusterProvisionedThroughputPtrOutputWithContext added in v0.12.0 

func (o ClusterProvisionedThroughputPtrOutput) ToClusterProvisionedThroughputPtrOutputWithContext(ctx context.Context) ClusterProvisionedThroughputPtrOutput

func (ClusterProvisionedThroughputPtrOutput) VolumeThroughput added in v0.12.0 

func (o ClusterProvisionedThroughputPtrOutput) VolumeThroughput() pulumi.IntPtrOutput

Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second.

type ClusterPublicAccess added in v0.7.0 

type ClusterPublicAccess struct {
	// DISABLED means that public access is turned off. SERVICE_PROVIDED_EIPS means that public access is turned on.
	Type *string `pulumi:"type"`
}

type ClusterPublicAccessArgs added in v0.7.0 

type ClusterPublicAccessArgs struct {
	// DISABLED means that public access is turned off. SERVICE_PROVIDED_EIPS means that public access is turned on.
	Type pulumi.StringPtrInput `pulumi:"type"`
}

func (ClusterPublicAccessArgs) ElementType added in v0.7.0 

func (ClusterPublicAccessArgs) ElementType() reflect.Type

func (ClusterPublicAccessArgs) ToClusterPublicAccessOutput added in v0.7.0 

func (i ClusterPublicAccessArgs) ToClusterPublicAccessOutput() ClusterPublicAccessOutput

func (ClusterPublicAccessArgs) ToClusterPublicAccessOutputWithContext added in v0.7.0 

func (i ClusterPublicAccessArgs) ToClusterPublicAccessOutputWithContext(ctx context.Context) ClusterPublicAccessOutput

func (ClusterPublicAccessArgs) ToClusterPublicAccessPtrOutput added in v0.7.0 

func (i ClusterPublicAccessArgs) ToClusterPublicAccessPtrOutput() ClusterPublicAccessPtrOutput

func (ClusterPublicAccessArgs) ToClusterPublicAccessPtrOutputWithContext added in v0.7.0 

func (i ClusterPublicAccessArgs) ToClusterPublicAccessPtrOutputWithContext(ctx context.Context) ClusterPublicAccessPtrOutput

type ClusterPublicAccessInput added in v0.7.0 

type ClusterPublicAccessInput interface {
	pulumi.Input

	ToClusterPublicAccessOutput() ClusterPublicAccessOutput
	ToClusterPublicAccessOutputWithContext(context.Context) ClusterPublicAccessOutput
}

ClusterPublicAccessInput is an input type that accepts ClusterPublicAccessArgs and ClusterPublicAccessOutput values. You can construct a concrete instance of `ClusterPublicAccessInput` via: 

ClusterPublicAccessArgs{...}

type ClusterPublicAccessOutput added in v0.7.0 

type ClusterPublicAccessOutput struct{ *pulumi.OutputState }

func (ClusterPublicAccessOutput) ElementType added in v0.7.0 

func (ClusterPublicAccessOutput) ElementType() reflect.Type

func (ClusterPublicAccessOutput) ToClusterPublicAccessOutput added in v0.7.0 

func (o ClusterPublicAccessOutput) ToClusterPublicAccessOutput() ClusterPublicAccessOutput

func (ClusterPublicAccessOutput) ToClusterPublicAccessOutputWithContext added in v0.7.0 

func (o ClusterPublicAccessOutput) ToClusterPublicAccessOutputWithContext(ctx context.Context) ClusterPublicAccessOutput

func (ClusterPublicAccessOutput) ToClusterPublicAccessPtrOutput added in v0.7.0 

func (o ClusterPublicAccessOutput) ToClusterPublicAccessPtrOutput() ClusterPublicAccessPtrOutput

func (ClusterPublicAccessOutput) ToClusterPublicAccessPtrOutputWithContext added in v0.7.0 

func (o ClusterPublicAccessOutput) ToClusterPublicAccessPtrOutputWithContext(ctx context.Context) ClusterPublicAccessPtrOutput

func (ClusterPublicAccessOutput) Type added in v0.7.0 

func (o ClusterPublicAccessOutput) Type() pulumi.StringPtrOutput

DISABLED means that public access is turned off. SERVICE_PROVIDED_EIPS means that public access is turned on.

type ClusterPublicAccessPtrInput added in v0.7.0 

type ClusterPublicAccessPtrInput interface {
	pulumi.Input

	ToClusterPublicAccessPtrOutput() ClusterPublicAccessPtrOutput
	ToClusterPublicAccessPtrOutputWithContext(context.Context) ClusterPublicAccessPtrOutput
}

ClusterPublicAccessPtrInput is an input type that accepts ClusterPublicAccessArgs, ClusterPublicAccessPtr and ClusterPublicAccessPtrOutput values. You can construct a concrete instance of `ClusterPublicAccessPtrInput` via: 

        ClusterPublicAccessArgs{...}

or:

        nil

func ClusterPublicAccessPtr added in v0.7.0 

func ClusterPublicAccessPtr(v *ClusterPublicAccessArgs) ClusterPublicAccessPtrInput

type ClusterPublicAccessPtrOutput added in v0.7.0 

type ClusterPublicAccessPtrOutput struct{ *pulumi.OutputState }

func (ClusterPublicAccessPtrOutput) Elem added in v0.7.0 

func (o ClusterPublicAccessPtrOutput) Elem() ClusterPublicAccessOutput

func (ClusterPublicAccessPtrOutput) ElementType added in v0.7.0 

func (ClusterPublicAccessPtrOutput) ElementType() reflect.Type

func (ClusterPublicAccessPtrOutput) ToClusterPublicAccessPtrOutput added in v0.7.0 

func (o ClusterPublicAccessPtrOutput) ToClusterPublicAccessPtrOutput() ClusterPublicAccessPtrOutput

func (ClusterPublicAccessPtrOutput) ToClusterPublicAccessPtrOutputWithContext added in v0.7.0 

func (o ClusterPublicAccessPtrOutput) ToClusterPublicAccessPtrOutputWithContext(ctx context.Context) ClusterPublicAccessPtrOutput

func (ClusterPublicAccessPtrOutput) Type added in v0.7.0 

func (o ClusterPublicAccessPtrOutput) Type() pulumi.StringPtrOutput

DISABLED means that public access is turned off. SERVICE_PROVIDED_EIPS means that public access is turned on.

type ClusterS3 

type ClusterS3 struct {
	// The name of the S3 bucket that is the destination for broker logs.
	Bucket *string `pulumi:"bucket"`
	// Specifies whether broker logs get sent to the specified Amazon S3 destination.
	Enabled bool `pulumi:"enabled"`
	// The S3 prefix that is the destination for broker logs.
	Prefix *string `pulumi:"prefix"`
}

type ClusterS3Args 

type ClusterS3Args struct {
	// The name of the S3 bucket that is the destination for broker logs.
	Bucket pulumi.StringPtrInput `pulumi:"bucket"`
	// Specifies whether broker logs get sent to the specified Amazon S3 destination.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// The S3 prefix that is the destination for broker logs.
	Prefix pulumi.StringPtrInput `pulumi:"prefix"`
}

func (ClusterS3Args) ElementType 

func (ClusterS3Args) ElementType() reflect.Type

func (ClusterS3Args) ToClusterS3Output 

func (i ClusterS3Args) ToClusterS3Output() ClusterS3Output

func (ClusterS3Args) ToClusterS3OutputWithContext 

func (i ClusterS3Args) ToClusterS3OutputWithContext(ctx context.Context) ClusterS3Output

func (ClusterS3Args) ToClusterS3PtrOutput 

func (i ClusterS3Args) ToClusterS3PtrOutput() ClusterS3PtrOutput

func (ClusterS3Args) ToClusterS3PtrOutputWithContext 

func (i ClusterS3Args) ToClusterS3PtrOutputWithContext(ctx context.Context) ClusterS3PtrOutput

type ClusterS3Input 

type ClusterS3Input interface {
	pulumi.Input

	ToClusterS3Output() ClusterS3Output
	ToClusterS3OutputWithContext(context.Context) ClusterS3Output
}

ClusterS3Input is an input type that accepts ClusterS3Args and ClusterS3Output values. You can construct a concrete instance of `ClusterS3Input` via: 

ClusterS3Args{...}

type ClusterS3Output 

type ClusterS3Output struct{ *pulumi.OutputState }

func (ClusterS3Output) Bucket 

func (o ClusterS3Output) Bucket() pulumi.StringPtrOutput

The name of the S3 bucket that is the destination for broker logs.

func (ClusterS3Output) ElementType 

func (ClusterS3Output) ElementType() reflect.Type

func (ClusterS3Output) Enabled 

func (o ClusterS3Output) Enabled() pulumi.BoolOutput

Specifies whether broker logs get sent to the specified Amazon S3 destination.

func (ClusterS3Output) Prefix 

func (o ClusterS3Output) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for broker logs.

func (ClusterS3Output) ToClusterS3Output 

func (o ClusterS3Output) ToClusterS3Output() ClusterS3Output

func (ClusterS3Output) ToClusterS3OutputWithContext 

func (o ClusterS3Output) ToClusterS3OutputWithContext(ctx context.Context) ClusterS3Output

func (ClusterS3Output) ToClusterS3PtrOutput 

func (o ClusterS3Output) ToClusterS3PtrOutput() ClusterS3PtrOutput

func (ClusterS3Output) ToClusterS3PtrOutputWithContext 

func (o ClusterS3Output) ToClusterS3PtrOutputWithContext(ctx context.Context) ClusterS3PtrOutput

type ClusterS3PtrInput 

type ClusterS3PtrInput interface {
	pulumi.Input

	ToClusterS3PtrOutput() ClusterS3PtrOutput
	ToClusterS3PtrOutputWithContext(context.Context) ClusterS3PtrOutput
}

ClusterS3PtrInput is an input type that accepts ClusterS3Args, ClusterS3Ptr and ClusterS3PtrOutput values. You can construct a concrete instance of `ClusterS3PtrInput` via: 

        ClusterS3Args{...}

or:

        nil

func ClusterS3Ptr 

func ClusterS3Ptr(v *ClusterS3Args) ClusterS3PtrInput

type ClusterS3PtrOutput 

type ClusterS3PtrOutput struct{ *pulumi.OutputState }

func (ClusterS3PtrOutput) Bucket 

func (o ClusterS3PtrOutput) Bucket() pulumi.StringPtrOutput

The name of the S3 bucket that is the destination for broker logs.

func (ClusterS3PtrOutput) Elem 

func (o ClusterS3PtrOutput) Elem() ClusterS3Output

func (ClusterS3PtrOutput) ElementType 

func (ClusterS3PtrOutput) ElementType() reflect.Type

func (ClusterS3PtrOutput) Enabled 

func (o ClusterS3PtrOutput) Enabled() pulumi.BoolPtrOutput

Specifies whether broker logs get sent to the specified Amazon S3 destination.

func (ClusterS3PtrOutput) Prefix 

func (o ClusterS3PtrOutput) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for broker logs.

func (ClusterS3PtrOutput) ToClusterS3PtrOutput 

func (o ClusterS3PtrOutput) ToClusterS3PtrOutput() ClusterS3PtrOutput

func (ClusterS3PtrOutput) ToClusterS3PtrOutputWithContext 

func (o ClusterS3PtrOutput) ToClusterS3PtrOutputWithContext(ctx context.Context) ClusterS3PtrOutput

type ClusterSasl 

type ClusterSasl struct {
	// Details for ClientAuthentication using IAM.
	Iam *ClusterIam `pulumi:"iam"`
	// Details for SASL/SCRAM client authentication.
	Scram *ClusterScram `pulumi:"scram"`
}

type ClusterSaslArgs 

type ClusterSaslArgs struct {
	// Details for ClientAuthentication using IAM.
	Iam ClusterIamPtrInput `pulumi:"iam"`
	// Details for SASL/SCRAM client authentication.
	Scram ClusterScramPtrInput `pulumi:"scram"`
}

func (ClusterSaslArgs) ElementType 

func (ClusterSaslArgs) ElementType() reflect.Type

func (ClusterSaslArgs) ToClusterSaslOutput 

func (i ClusterSaslArgs) ToClusterSaslOutput() ClusterSaslOutput

func (ClusterSaslArgs) ToClusterSaslOutputWithContext 

func (i ClusterSaslArgs) ToClusterSaslOutputWithContext(ctx context.Context) ClusterSaslOutput

func (ClusterSaslArgs) ToClusterSaslPtrOutput 

func (i ClusterSaslArgs) ToClusterSaslPtrOutput() ClusterSaslPtrOutput

func (ClusterSaslArgs) ToClusterSaslPtrOutputWithContext 

func (i ClusterSaslArgs) ToClusterSaslPtrOutputWithContext(ctx context.Context) ClusterSaslPtrOutput

type ClusterSaslInput 

type ClusterSaslInput interface {
	pulumi.Input

	ToClusterSaslOutput() ClusterSaslOutput
	ToClusterSaslOutputWithContext(context.Context) ClusterSaslOutput
}

ClusterSaslInput is an input type that accepts ClusterSaslArgs and ClusterSaslOutput values. You can construct a concrete instance of `ClusterSaslInput` via: 

ClusterSaslArgs{...}

type ClusterSaslOutput 

type ClusterSaslOutput struct{ *pulumi.OutputState }

func (ClusterSaslOutput) ElementType 

func (ClusterSaslOutput) ElementType() reflect.Type

func (ClusterSaslOutput) Iam 

func (o ClusterSaslOutput) Iam() ClusterIamPtrOutput

Details for ClientAuthentication using IAM.

func (ClusterSaslOutput) Scram 

func (o ClusterSaslOutput) Scram() ClusterScramPtrOutput

Details for SASL/SCRAM client authentication.

func (ClusterSaslOutput) ToClusterSaslOutput 

func (o ClusterSaslOutput) ToClusterSaslOutput() ClusterSaslOutput

func (ClusterSaslOutput) ToClusterSaslOutputWithContext 

func (o ClusterSaslOutput) ToClusterSaslOutputWithContext(ctx context.Context) ClusterSaslOutput

func (ClusterSaslOutput) ToClusterSaslPtrOutput 

func (o ClusterSaslOutput) ToClusterSaslPtrOutput() ClusterSaslPtrOutput

func (ClusterSaslOutput) ToClusterSaslPtrOutputWithContext 

func (o ClusterSaslOutput) ToClusterSaslPtrOutputWithContext(ctx context.Context) ClusterSaslPtrOutput

type ClusterSaslPtrInput 

type ClusterSaslPtrInput interface {
	pulumi.Input

	ToClusterSaslPtrOutput() ClusterSaslPtrOutput
	ToClusterSaslPtrOutputWithContext(context.Context) ClusterSaslPtrOutput
}

ClusterSaslPtrInput is an input type that accepts ClusterSaslArgs, ClusterSaslPtr and ClusterSaslPtrOutput values. You can construct a concrete instance of `ClusterSaslPtrInput` via: 

        ClusterSaslArgs{...}

or:

        nil

func ClusterSaslPtr 

func ClusterSaslPtr(v *ClusterSaslArgs) ClusterSaslPtrInput

type ClusterSaslPtrOutput 

type ClusterSaslPtrOutput struct{ *pulumi.OutputState }

func (ClusterSaslPtrOutput) Elem 

func (o ClusterSaslPtrOutput) Elem() ClusterSaslOutput

func (ClusterSaslPtrOutput) ElementType 

func (ClusterSaslPtrOutput) ElementType() reflect.Type

func (ClusterSaslPtrOutput) Iam 

func (o ClusterSaslPtrOutput) Iam() ClusterIamPtrOutput

Details for ClientAuthentication using IAM.

func (ClusterSaslPtrOutput) Scram 

func (o ClusterSaslPtrOutput) Scram() ClusterScramPtrOutput

Details for SASL/SCRAM client authentication.

func (ClusterSaslPtrOutput) ToClusterSaslPtrOutput 

func (o ClusterSaslPtrOutput) ToClusterSaslPtrOutput() ClusterSaslPtrOutput

func (ClusterSaslPtrOutput) ToClusterSaslPtrOutputWithContext 

func (o ClusterSaslPtrOutput) ToClusterSaslPtrOutputWithContext(ctx context.Context) ClusterSaslPtrOutput

type ClusterScram 

type ClusterScram struct {
	// SASL/SCRAM authentication is enabled or not.
	Enabled bool `pulumi:"enabled"`
}

type ClusterScramArgs 

type ClusterScramArgs struct {
	// SASL/SCRAM authentication is enabled or not.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterScramArgs) ElementType 

func (ClusterScramArgs) ElementType() reflect.Type

func (ClusterScramArgs) ToClusterScramOutput 

func (i ClusterScramArgs) ToClusterScramOutput() ClusterScramOutput

func (ClusterScramArgs) ToClusterScramOutputWithContext 

func (i ClusterScramArgs) ToClusterScramOutputWithContext(ctx context.Context) ClusterScramOutput

func (ClusterScramArgs) ToClusterScramPtrOutput 

func (i ClusterScramArgs) ToClusterScramPtrOutput() ClusterScramPtrOutput

func (ClusterScramArgs) ToClusterScramPtrOutputWithContext 

func (i ClusterScramArgs) ToClusterScramPtrOutputWithContext(ctx context.Context) ClusterScramPtrOutput

type ClusterScramInput 

type ClusterScramInput interface {
	pulumi.Input

	ToClusterScramOutput() ClusterScramOutput
	ToClusterScramOutputWithContext(context.Context) ClusterScramOutput
}

ClusterScramInput is an input type that accepts ClusterScramArgs and ClusterScramOutput values. You can construct a concrete instance of `ClusterScramInput` via: 

ClusterScramArgs{...}

type ClusterScramOutput 

type ClusterScramOutput struct{ *pulumi.OutputState }

func (ClusterScramOutput) ElementType 

func (ClusterScramOutput) ElementType() reflect.Type

func (ClusterScramOutput) Enabled 

func (o ClusterScramOutput) Enabled() pulumi.BoolOutput

SASL/SCRAM authentication is enabled or not.

func (ClusterScramOutput) ToClusterScramOutput 

func (o ClusterScramOutput) ToClusterScramOutput() ClusterScramOutput

func (ClusterScramOutput) ToClusterScramOutputWithContext 

func (o ClusterScramOutput) ToClusterScramOutputWithContext(ctx context.Context) ClusterScramOutput

func (ClusterScramOutput) ToClusterScramPtrOutput 

func (o ClusterScramOutput) ToClusterScramPtrOutput() ClusterScramPtrOutput

func (ClusterScramOutput) ToClusterScramPtrOutputWithContext 

func (o ClusterScramOutput) ToClusterScramPtrOutputWithContext(ctx context.Context) ClusterScramPtrOutput

type ClusterScramPtrInput 

type ClusterScramPtrInput interface {
	pulumi.Input

	ToClusterScramPtrOutput() ClusterScramPtrOutput
	ToClusterScramPtrOutputWithContext(context.Context) ClusterScramPtrOutput
}

ClusterScramPtrInput is an input type that accepts ClusterScramArgs, ClusterScramPtr and ClusterScramPtrOutput values. You can construct a concrete instance of `ClusterScramPtrInput` via: 

        ClusterScramArgs{...}

or:

        nil

func ClusterScramPtr 

func ClusterScramPtr(v *ClusterScramArgs) ClusterScramPtrInput

type ClusterScramPtrOutput 

type ClusterScramPtrOutput struct{ *pulumi.OutputState }

func (ClusterScramPtrOutput) Elem 

func (o ClusterScramPtrOutput) Elem() ClusterScramOutput

func (ClusterScramPtrOutput) ElementType 

func (ClusterScramPtrOutput) ElementType() reflect.Type

func (ClusterScramPtrOutput) Enabled 

func (o ClusterScramPtrOutput) Enabled() pulumi.BoolPtrOutput

SASL/SCRAM authentication is enabled or not.

func (ClusterScramPtrOutput) ToClusterScramPtrOutput 

func (o ClusterScramPtrOutput) ToClusterScramPtrOutput() ClusterScramPtrOutput

func (ClusterScramPtrOutput) ToClusterScramPtrOutputWithContext 

func (o ClusterScramPtrOutput) ToClusterScramPtrOutputWithContext(ctx context.Context) ClusterScramPtrOutput

type ClusterState 

type ClusterState struct {
}

func (ClusterState) ElementType 

func (ClusterState) ElementType() reflect.Type

type ClusterStorageInfo 

type ClusterStorageInfo struct {
	// EBS volume information.
	EbsStorageInfo *ClusterEbsStorageInfo `pulumi:"ebsStorageInfo"`
}

type ClusterStorageInfoArgs 

type ClusterStorageInfoArgs struct {
	// EBS volume information.
	EbsStorageInfo ClusterEbsStorageInfoPtrInput `pulumi:"ebsStorageInfo"`
}

func (ClusterStorageInfoArgs) ElementType 

func (ClusterStorageInfoArgs) ElementType() reflect.Type

func (ClusterStorageInfoArgs) ToClusterStorageInfoOutput 

func (i ClusterStorageInfoArgs) ToClusterStorageInfoOutput() ClusterStorageInfoOutput

func (ClusterStorageInfoArgs) ToClusterStorageInfoOutputWithContext 

func (i ClusterStorageInfoArgs) ToClusterStorageInfoOutputWithContext(ctx context.Context) ClusterStorageInfoOutput

func (ClusterStorageInfoArgs) ToClusterStorageInfoPtrOutput 

func (i ClusterStorageInfoArgs) ToClusterStorageInfoPtrOutput() ClusterStorageInfoPtrOutput

func (ClusterStorageInfoArgs) ToClusterStorageInfoPtrOutputWithContext 

func (i ClusterStorageInfoArgs) ToClusterStorageInfoPtrOutputWithContext(ctx context.Context) ClusterStorageInfoPtrOutput

type ClusterStorageInfoInput 

type ClusterStorageInfoInput interface {
	pulumi.Input

	ToClusterStorageInfoOutput() ClusterStorageInfoOutput
	ToClusterStorageInfoOutputWithContext(context.Context) ClusterStorageInfoOutput
}

ClusterStorageInfoInput is an input type that accepts ClusterStorageInfoArgs and ClusterStorageInfoOutput values. You can construct a concrete instance of `ClusterStorageInfoInput` via: 

ClusterStorageInfoArgs{...}

type ClusterStorageInfoOutput 

type ClusterStorageInfoOutput struct{ *pulumi.OutputState }

func (ClusterStorageInfoOutput) EbsStorageInfo added in v0.72.0 

func (o ClusterStorageInfoOutput) EbsStorageInfo() ClusterEbsStorageInfoPtrOutput

EBS volume information.

func (ClusterStorageInfoOutput) ElementType 

func (ClusterStorageInfoOutput) ElementType() reflect.Type

func (ClusterStorageInfoOutput) ToClusterStorageInfoOutput 

func (o ClusterStorageInfoOutput) ToClusterStorageInfoOutput() ClusterStorageInfoOutput

func (ClusterStorageInfoOutput) ToClusterStorageInfoOutputWithContext 

func (o ClusterStorageInfoOutput) ToClusterStorageInfoOutputWithContext(ctx context.Context) ClusterStorageInfoOutput

func (ClusterStorageInfoOutput) ToClusterStorageInfoPtrOutput 

func (o ClusterStorageInfoOutput) ToClusterStorageInfoPtrOutput() ClusterStorageInfoPtrOutput

func (ClusterStorageInfoOutput) ToClusterStorageInfoPtrOutputWithContext 

func (o ClusterStorageInfoOutput) ToClusterStorageInfoPtrOutputWithContext(ctx context.Context) ClusterStorageInfoPtrOutput

type ClusterStorageInfoPtrInput 

type ClusterStorageInfoPtrInput interface {
	pulumi.Input

	ToClusterStorageInfoPtrOutput() ClusterStorageInfoPtrOutput
	ToClusterStorageInfoPtrOutputWithContext(context.Context) ClusterStorageInfoPtrOutput
}

ClusterStorageInfoPtrInput is an input type that accepts ClusterStorageInfoArgs, ClusterStorageInfoPtr and ClusterStorageInfoPtrOutput values. You can construct a concrete instance of `ClusterStorageInfoPtrInput` via: 

        ClusterStorageInfoArgs{...}

or:

        nil

func ClusterStorageInfoPtr 

func ClusterStorageInfoPtr(v *ClusterStorageInfoArgs) ClusterStorageInfoPtrInput

type ClusterStorageInfoPtrOutput 

type ClusterStorageInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterStorageInfoPtrOutput) EbsStorageInfo added in v0.72.0 

func (o ClusterStorageInfoPtrOutput) EbsStorageInfo() ClusterEbsStorageInfoPtrOutput

EBS volume information.

func (ClusterStorageInfoPtrOutput) Elem 

func (o ClusterStorageInfoPtrOutput) Elem() ClusterStorageInfoOutput

func (ClusterStorageInfoPtrOutput) ElementType 

func (ClusterStorageInfoPtrOutput) ElementType() reflect.Type

func (ClusterStorageInfoPtrOutput) ToClusterStorageInfoPtrOutput 

func (o ClusterStorageInfoPtrOutput) ToClusterStorageInfoPtrOutput() ClusterStorageInfoPtrOutput

func (ClusterStorageInfoPtrOutput) ToClusterStorageInfoPtrOutputWithContext 

func (o ClusterStorageInfoPtrOutput) ToClusterStorageInfoPtrOutputWithContext(ctx context.Context) ClusterStorageInfoPtrOutput

type ClusterStorageMode added in v0.38.0 

type ClusterStorageMode string

This controls storage mode for supported storage tiers.

func (ClusterStorageMode) ElementType added in v0.38.0 

func (ClusterStorageMode) ElementType() reflect.Type

func (ClusterStorageMode) ToClusterStorageModeOutput added in v0.38.0 

func (e ClusterStorageMode) ToClusterStorageModeOutput() ClusterStorageModeOutput

func (ClusterStorageMode) ToClusterStorageModeOutputWithContext added in v0.38.0 

func (e ClusterStorageMode) ToClusterStorageModeOutputWithContext(ctx context.Context) ClusterStorageModeOutput

func (ClusterStorageMode) ToClusterStorageModePtrOutput added in v0.38.0 

func (e ClusterStorageMode) ToClusterStorageModePtrOutput() ClusterStorageModePtrOutput

func (ClusterStorageMode) ToClusterStorageModePtrOutputWithContext added in v0.38.0 

func (e ClusterStorageMode) ToClusterStorageModePtrOutputWithContext(ctx context.Context) ClusterStorageModePtrOutput

func (ClusterStorageMode) ToStringOutput added in v0.38.0 

func (e ClusterStorageMode) ToStringOutput() pulumi.StringOutput

func (ClusterStorageMode) ToStringOutputWithContext added in v0.38.0 

func (e ClusterStorageMode) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ClusterStorageMode) ToStringPtrOutput added in v0.38.0 

func (e ClusterStorageMode) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterStorageMode) ToStringPtrOutputWithContext added in v0.38.0 

func (e ClusterStorageMode) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterStorageModeInput added in v0.38.0 

type ClusterStorageModeInput interface {
	pulumi.Input

	ToClusterStorageModeOutput() ClusterStorageModeOutput
	ToClusterStorageModeOutputWithContext(context.Context) ClusterStorageModeOutput
}

ClusterStorageModeInput is an input type that accepts values of the ClusterStorageMode enum A concrete instance of `ClusterStorageModeInput` can be one of the following: 

ClusterStorageModeLocal
ClusterStorageModeTiered

type ClusterStorageModeOutput added in v0.38.0 

type ClusterStorageModeOutput struct{ *pulumi.OutputState }

func (ClusterStorageModeOutput) ElementType added in v0.38.0 

func (ClusterStorageModeOutput) ElementType() reflect.Type

func (ClusterStorageModeOutput) ToClusterStorageModeOutput added in v0.38.0 

func (o ClusterStorageModeOutput) ToClusterStorageModeOutput() ClusterStorageModeOutput

func (ClusterStorageModeOutput) ToClusterStorageModeOutputWithContext added in v0.38.0 

func (o ClusterStorageModeOutput) ToClusterStorageModeOutputWithContext(ctx context.Context) ClusterStorageModeOutput

func (ClusterStorageModeOutput) ToClusterStorageModePtrOutput added in v0.38.0 

func (o ClusterStorageModeOutput) ToClusterStorageModePtrOutput() ClusterStorageModePtrOutput

func (ClusterStorageModeOutput) ToClusterStorageModePtrOutputWithContext added in v0.38.0 

func (o ClusterStorageModeOutput) ToClusterStorageModePtrOutputWithContext(ctx context.Context) ClusterStorageModePtrOutput

func (ClusterStorageModeOutput) ToStringOutput added in v0.38.0 

func (o ClusterStorageModeOutput) ToStringOutput() pulumi.StringOutput

func (ClusterStorageModeOutput) ToStringOutputWithContext added in v0.38.0 

func (o ClusterStorageModeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ClusterStorageModeOutput) ToStringPtrOutput added in v0.38.0 

func (o ClusterStorageModeOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterStorageModeOutput) ToStringPtrOutputWithContext added in v0.38.0 

func (o ClusterStorageModeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterStorageModePtrInput added in v0.38.0 

type ClusterStorageModePtrInput interface {
	pulumi.Input

	ToClusterStorageModePtrOutput() ClusterStorageModePtrOutput
	ToClusterStorageModePtrOutputWithContext(context.Context) ClusterStorageModePtrOutput
}

func ClusterStorageModePtr added in v0.38.0 

func ClusterStorageModePtr(v string) ClusterStorageModePtrInput

type ClusterStorageModePtrOutput added in v0.38.0 

type ClusterStorageModePtrOutput struct{ *pulumi.OutputState }

func (ClusterStorageModePtrOutput) Elem added in v0.38.0 

func (o ClusterStorageModePtrOutput) Elem() ClusterStorageModeOutput

func (ClusterStorageModePtrOutput) ElementType added in v0.38.0 

func (ClusterStorageModePtrOutput) ElementType() reflect.Type

func (ClusterStorageModePtrOutput) ToClusterStorageModePtrOutput added in v0.38.0 

func (o ClusterStorageModePtrOutput) ToClusterStorageModePtrOutput() ClusterStorageModePtrOutput

func (ClusterStorageModePtrOutput) ToClusterStorageModePtrOutputWithContext added in v0.38.0 

func (o ClusterStorageModePtrOutput) ToClusterStorageModePtrOutputWithContext(ctx context.Context) ClusterStorageModePtrOutput

func (ClusterStorageModePtrOutput) ToStringPtrOutput added in v0.38.0 

func (o ClusterStorageModePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ClusterStorageModePtrOutput) ToStringPtrOutputWithContext added in v0.38.0 

func (o ClusterStorageModePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ClusterTls 

type ClusterTls struct {
	// List of AWS Private CA Amazon Resource Name (ARN)s.
	CertificateAuthorityArnList []string `pulumi:"certificateAuthorityArnList"`
	// TLS authentication is enabled or not.
	Enabled *bool `pulumi:"enabled"`
}

type ClusterTlsArgs 

type ClusterTlsArgs struct {
	// List of AWS Private CA Amazon Resource Name (ARN)s.
	CertificateAuthorityArnList pulumi.StringArrayInput `pulumi:"certificateAuthorityArnList"`
	// TLS authentication is enabled or not.
	Enabled pulumi.BoolPtrInput `pulumi:"enabled"`
}

func (ClusterTlsArgs) ElementType 

func (ClusterTlsArgs) ElementType() reflect.Type

func (ClusterTlsArgs) ToClusterTlsOutput 

func (i ClusterTlsArgs) ToClusterTlsOutput() ClusterTlsOutput

func (ClusterTlsArgs) ToClusterTlsOutputWithContext 

func (i ClusterTlsArgs) ToClusterTlsOutputWithContext(ctx context.Context) ClusterTlsOutput

func (ClusterTlsArgs) ToClusterTlsPtrOutput 

func (i ClusterTlsArgs) ToClusterTlsPtrOutput() ClusterTlsPtrOutput

func (ClusterTlsArgs) ToClusterTlsPtrOutputWithContext 

func (i ClusterTlsArgs) ToClusterTlsPtrOutputWithContext(ctx context.Context) ClusterTlsPtrOutput

type ClusterTlsInput 

type ClusterTlsInput interface {
	pulumi.Input

	ToClusterTlsOutput() ClusterTlsOutput
	ToClusterTlsOutputWithContext(context.Context) ClusterTlsOutput
}

ClusterTlsInput is an input type that accepts ClusterTlsArgs and ClusterTlsOutput values. You can construct a concrete instance of `ClusterTlsInput` via: 

ClusterTlsArgs{...}

type ClusterTlsOutput 

type ClusterTlsOutput struct{ *pulumi.OutputState }

func (ClusterTlsOutput) CertificateAuthorityArnList 

func (o ClusterTlsOutput) CertificateAuthorityArnList() pulumi.StringArrayOutput

List of AWS Private CA Amazon Resource Name (ARN)s.

func (ClusterTlsOutput) ElementType 

func (ClusterTlsOutput) ElementType() reflect.Type

func (ClusterTlsOutput) Enabled 

func (o ClusterTlsOutput) Enabled() pulumi.BoolPtrOutput

TLS authentication is enabled or not.

func (ClusterTlsOutput) ToClusterTlsOutput 

func (o ClusterTlsOutput) ToClusterTlsOutput() ClusterTlsOutput

func (ClusterTlsOutput) ToClusterTlsOutputWithContext 

func (o ClusterTlsOutput) ToClusterTlsOutputWithContext(ctx context.Context) ClusterTlsOutput

func (ClusterTlsOutput) ToClusterTlsPtrOutput 

func (o ClusterTlsOutput) ToClusterTlsPtrOutput() ClusterTlsPtrOutput

func (ClusterTlsOutput) ToClusterTlsPtrOutputWithContext 

func (o ClusterTlsOutput) ToClusterTlsPtrOutputWithContext(ctx context.Context) ClusterTlsPtrOutput

type ClusterTlsPtrInput 

type ClusterTlsPtrInput interface {
	pulumi.Input

	ToClusterTlsPtrOutput() ClusterTlsPtrOutput
	ToClusterTlsPtrOutputWithContext(context.Context) ClusterTlsPtrOutput
}

ClusterTlsPtrInput is an input type that accepts ClusterTlsArgs, ClusterTlsPtr and ClusterTlsPtrOutput values. You can construct a concrete instance of `ClusterTlsPtrInput` via: 

        ClusterTlsArgs{...}

or:

        nil

func ClusterTlsPtr 

func ClusterTlsPtr(v *ClusterTlsArgs) ClusterTlsPtrInput

type ClusterTlsPtrOutput 

type ClusterTlsPtrOutput struct{ *pulumi.OutputState }

func (ClusterTlsPtrOutput) CertificateAuthorityArnList 

func (o ClusterTlsPtrOutput) CertificateAuthorityArnList() pulumi.StringArrayOutput

List of AWS Private CA Amazon Resource Name (ARN)s.

func (ClusterTlsPtrOutput) Elem 

func (o ClusterTlsPtrOutput) Elem() ClusterTlsOutput

func (ClusterTlsPtrOutput) ElementType 

func (ClusterTlsPtrOutput) ElementType() reflect.Type

func (ClusterTlsPtrOutput) Enabled 

func (o ClusterTlsPtrOutput) Enabled() pulumi.BoolPtrOutput

TLS authentication is enabled or not.

func (ClusterTlsPtrOutput) ToClusterTlsPtrOutput 

func (o ClusterTlsPtrOutput) ToClusterTlsPtrOutput() ClusterTlsPtrOutput

func (ClusterTlsPtrOutput) ToClusterTlsPtrOutputWithContext 

func (o ClusterTlsPtrOutput) ToClusterTlsPtrOutputWithContext(ctx context.Context) ClusterTlsPtrOutput

type ClusterUnauthenticated 

type ClusterUnauthenticated struct {
	// Unauthenticated is enabled or not.
	Enabled bool `pulumi:"enabled"`
}

type ClusterUnauthenticatedArgs 

type ClusterUnauthenticatedArgs struct {
	// Unauthenticated is enabled or not.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterUnauthenticatedArgs) ElementType 

func (ClusterUnauthenticatedArgs) ElementType() reflect.Type

func (ClusterUnauthenticatedArgs) ToClusterUnauthenticatedOutput 

func (i ClusterUnauthenticatedArgs) ToClusterUnauthenticatedOutput() ClusterUnauthenticatedOutput

func (ClusterUnauthenticatedArgs) ToClusterUnauthenticatedOutputWithContext 

func (i ClusterUnauthenticatedArgs) ToClusterUnauthenticatedOutputWithContext(ctx context.Context) ClusterUnauthenticatedOutput

func (ClusterUnauthenticatedArgs) ToClusterUnauthenticatedPtrOutput 

func (i ClusterUnauthenticatedArgs) ToClusterUnauthenticatedPtrOutput() ClusterUnauthenticatedPtrOutput

func (ClusterUnauthenticatedArgs) ToClusterUnauthenticatedPtrOutputWithContext 

func (i ClusterUnauthenticatedArgs) ToClusterUnauthenticatedPtrOutputWithContext(ctx context.Context) ClusterUnauthenticatedPtrOutput

type ClusterUnauthenticatedInput 

type ClusterUnauthenticatedInput interface {
	pulumi.Input

	ToClusterUnauthenticatedOutput() ClusterUnauthenticatedOutput
	ToClusterUnauthenticatedOutputWithContext(context.Context) ClusterUnauthenticatedOutput
}

ClusterUnauthenticatedInput is an input type that accepts ClusterUnauthenticatedArgs and ClusterUnauthenticatedOutput values. You can construct a concrete instance of `ClusterUnauthenticatedInput` via: 

ClusterUnauthenticatedArgs{...}

type ClusterUnauthenticatedOutput 

type ClusterUnauthenticatedOutput struct{ *pulumi.OutputState }

func (ClusterUnauthenticatedOutput) ElementType 

func (ClusterUnauthenticatedOutput) ElementType() reflect.Type

func (ClusterUnauthenticatedOutput) Enabled 

func (o ClusterUnauthenticatedOutput) Enabled() pulumi.BoolOutput

Unauthenticated is enabled or not.

func (ClusterUnauthenticatedOutput) ToClusterUnauthenticatedOutput 

func (o ClusterUnauthenticatedOutput) ToClusterUnauthenticatedOutput() ClusterUnauthenticatedOutput

func (ClusterUnauthenticatedOutput) ToClusterUnauthenticatedOutputWithContext 

func (o ClusterUnauthenticatedOutput) ToClusterUnauthenticatedOutputWithContext(ctx context.Context) ClusterUnauthenticatedOutput

func (ClusterUnauthenticatedOutput) ToClusterUnauthenticatedPtrOutput 

func (o ClusterUnauthenticatedOutput) ToClusterUnauthenticatedPtrOutput() ClusterUnauthenticatedPtrOutput

func (ClusterUnauthenticatedOutput) ToClusterUnauthenticatedPtrOutputWithContext 

func (o ClusterUnauthenticatedOutput) ToClusterUnauthenticatedPtrOutputWithContext(ctx context.Context) ClusterUnauthenticatedPtrOutput

type ClusterUnauthenticatedPtrInput 

type ClusterUnauthenticatedPtrInput interface {
	pulumi.Input

	ToClusterUnauthenticatedPtrOutput() ClusterUnauthenticatedPtrOutput
	ToClusterUnauthenticatedPtrOutputWithContext(context.Context) ClusterUnauthenticatedPtrOutput
}

ClusterUnauthenticatedPtrInput is an input type that accepts ClusterUnauthenticatedArgs, ClusterUnauthenticatedPtr and ClusterUnauthenticatedPtrOutput values. You can construct a concrete instance of `ClusterUnauthenticatedPtrInput` via: 

        ClusterUnauthenticatedArgs{...}

or:

        nil

func ClusterUnauthenticatedPtr 

func ClusterUnauthenticatedPtr(v *ClusterUnauthenticatedArgs) ClusterUnauthenticatedPtrInput

type ClusterUnauthenticatedPtrOutput 

type ClusterUnauthenticatedPtrOutput struct{ *pulumi.OutputState }

func (ClusterUnauthenticatedPtrOutput) Elem 

func (o ClusterUnauthenticatedPtrOutput) Elem() ClusterUnauthenticatedOutput

func (ClusterUnauthenticatedPtrOutput) ElementType 

func (ClusterUnauthenticatedPtrOutput) ElementType() reflect.Type

func (ClusterUnauthenticatedPtrOutput) Enabled 

func (o ClusterUnauthenticatedPtrOutput) Enabled() pulumi.BoolPtrOutput

Unauthenticated is enabled or not.

func (ClusterUnauthenticatedPtrOutput) ToClusterUnauthenticatedPtrOutput 

func (o ClusterUnauthenticatedPtrOutput) ToClusterUnauthenticatedPtrOutput() ClusterUnauthenticatedPtrOutput

func (ClusterUnauthenticatedPtrOutput) ToClusterUnauthenticatedPtrOutputWithContext 

func (o ClusterUnauthenticatedPtrOutput) ToClusterUnauthenticatedPtrOutputWithContext(ctx context.Context) ClusterUnauthenticatedPtrOutput

type ClusterVpcConnectivity added in v0.44.0 

type ClusterVpcConnectivity struct {
	// VPC connection control settings for brokers.
	ClientAuthentication *ClusterVpcConnectivityClientAuthentication `pulumi:"clientAuthentication"`
}

type ClusterVpcConnectivityArgs added in v0.44.0 

type ClusterVpcConnectivityArgs struct {
	// VPC connection control settings for brokers.
	ClientAuthentication ClusterVpcConnectivityClientAuthenticationPtrInput `pulumi:"clientAuthentication"`
}

func (ClusterVpcConnectivityArgs) ElementType added in v0.44.0 

func (ClusterVpcConnectivityArgs) ElementType() reflect.Type

func (ClusterVpcConnectivityArgs) ToClusterVpcConnectivityOutput added in v0.44.0 

func (i ClusterVpcConnectivityArgs) ToClusterVpcConnectivityOutput() ClusterVpcConnectivityOutput

func (ClusterVpcConnectivityArgs) ToClusterVpcConnectivityOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityArgs) ToClusterVpcConnectivityOutputWithContext(ctx context.Context) ClusterVpcConnectivityOutput

func (ClusterVpcConnectivityArgs) ToClusterVpcConnectivityPtrOutput added in v0.44.0 

func (i ClusterVpcConnectivityArgs) ToClusterVpcConnectivityPtrOutput() ClusterVpcConnectivityPtrOutput

func (ClusterVpcConnectivityArgs) ToClusterVpcConnectivityPtrOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityArgs) ToClusterVpcConnectivityPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityPtrOutput

type ClusterVpcConnectivityClientAuthentication added in v0.44.0 

type ClusterVpcConnectivityClientAuthentication struct {
	// Details for VpcConnectivity ClientAuthentication using SASL.
	Sasl *ClusterVpcConnectivitySasl `pulumi:"sasl"`
	// Details for VpcConnectivity ClientAuthentication using TLS.
	Tls *ClusterVpcConnectivityTls `pulumi:"tls"`
}

type ClusterVpcConnectivityClientAuthenticationArgs added in v0.44.0 

type ClusterVpcConnectivityClientAuthenticationArgs struct {
	// Details for VpcConnectivity ClientAuthentication using SASL.
	Sasl ClusterVpcConnectivitySaslPtrInput `pulumi:"sasl"`
	// Details for VpcConnectivity ClientAuthentication using TLS.
	Tls ClusterVpcConnectivityTlsPtrInput `pulumi:"tls"`
}

func (ClusterVpcConnectivityClientAuthenticationArgs) ElementType added in v0.44.0 

func (ClusterVpcConnectivityClientAuthenticationArgs) ElementType() reflect.Type

func (ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationOutput added in v0.44.0 

func (i ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationOutput() ClusterVpcConnectivityClientAuthenticationOutput

func (ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationOutputWithContext(ctx context.Context) ClusterVpcConnectivityClientAuthenticationOutput

func (ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationPtrOutput added in v0.44.0 

func (i ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationPtrOutput() ClusterVpcConnectivityClientAuthenticationPtrOutput

func (ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationPtrOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityClientAuthenticationArgs) ToClusterVpcConnectivityClientAuthenticationPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityClientAuthenticationPtrOutput

type ClusterVpcConnectivityClientAuthenticationInput added in v0.44.0 

type ClusterVpcConnectivityClientAuthenticationInput interface {
	pulumi.Input

	ToClusterVpcConnectivityClientAuthenticationOutput() ClusterVpcConnectivityClientAuthenticationOutput
	ToClusterVpcConnectivityClientAuthenticationOutputWithContext(context.Context) ClusterVpcConnectivityClientAuthenticationOutput
}

ClusterVpcConnectivityClientAuthenticationInput is an input type that accepts ClusterVpcConnectivityClientAuthenticationArgs and ClusterVpcConnectivityClientAuthenticationOutput values. You can construct a concrete instance of `ClusterVpcConnectivityClientAuthenticationInput` via: 

ClusterVpcConnectivityClientAuthenticationArgs{...}

type ClusterVpcConnectivityClientAuthenticationOutput added in v0.44.0 

type ClusterVpcConnectivityClientAuthenticationOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityClientAuthenticationOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityClientAuthenticationOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityClientAuthenticationOutput) Sasl added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationOutput) Sasl() ClusterVpcConnectivitySaslPtrOutput

Details for VpcConnectivity ClientAuthentication using SASL.

func (ClusterVpcConnectivityClientAuthenticationOutput) Tls added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationOutput) Tls() ClusterVpcConnectivityTlsPtrOutput

Details for VpcConnectivity ClientAuthentication using TLS.

func (ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationOutput added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationOutput() ClusterVpcConnectivityClientAuthenticationOutput

func (ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationOutputWithContext(ctx context.Context) ClusterVpcConnectivityClientAuthenticationOutput

func (ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutput() ClusterVpcConnectivityClientAuthenticationPtrOutput

func (ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityClientAuthenticationPtrOutput

type ClusterVpcConnectivityClientAuthenticationPtrInput added in v0.44.0 

type ClusterVpcConnectivityClientAuthenticationPtrInput interface {
	pulumi.Input

	ToClusterVpcConnectivityClientAuthenticationPtrOutput() ClusterVpcConnectivityClientAuthenticationPtrOutput
	ToClusterVpcConnectivityClientAuthenticationPtrOutputWithContext(context.Context) ClusterVpcConnectivityClientAuthenticationPtrOutput
}

ClusterVpcConnectivityClientAuthenticationPtrInput is an input type that accepts ClusterVpcConnectivityClientAuthenticationArgs, ClusterVpcConnectivityClientAuthenticationPtr and ClusterVpcConnectivityClientAuthenticationPtrOutput values. You can construct a concrete instance of `ClusterVpcConnectivityClientAuthenticationPtrInput` via: 

        ClusterVpcConnectivityClientAuthenticationArgs{...}

or:

        nil

func ClusterVpcConnectivityClientAuthenticationPtr added in v0.44.0 

func ClusterVpcConnectivityClientAuthenticationPtr(v *ClusterVpcConnectivityClientAuthenticationArgs) ClusterVpcConnectivityClientAuthenticationPtrInput

type ClusterVpcConnectivityClientAuthenticationPtrOutput added in v0.44.0 

type ClusterVpcConnectivityClientAuthenticationPtrOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityClientAuthenticationPtrOutput) Elem added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationPtrOutput) Elem() ClusterVpcConnectivityClientAuthenticationOutput

func (ClusterVpcConnectivityClientAuthenticationPtrOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityClientAuthenticationPtrOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityClientAuthenticationPtrOutput) Sasl added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationPtrOutput) Sasl() ClusterVpcConnectivitySaslPtrOutput

Details for VpcConnectivity ClientAuthentication using SASL.

func (ClusterVpcConnectivityClientAuthenticationPtrOutput) Tls added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationPtrOutput) Tls() ClusterVpcConnectivityTlsPtrOutput

Details for VpcConnectivity ClientAuthentication using TLS.

func (ClusterVpcConnectivityClientAuthenticationPtrOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationPtrOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutput() ClusterVpcConnectivityClientAuthenticationPtrOutput

func (ClusterVpcConnectivityClientAuthenticationPtrOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityClientAuthenticationPtrOutput) ToClusterVpcConnectivityClientAuthenticationPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityClientAuthenticationPtrOutput

type ClusterVpcConnectivityIam added in v0.44.0 

type ClusterVpcConnectivityIam struct {
	// SASL/IAM authentication is enabled or not.
	Enabled bool `pulumi:"enabled"`
}

type ClusterVpcConnectivityIamArgs added in v0.44.0 

type ClusterVpcConnectivityIamArgs struct {
	// SASL/IAM authentication is enabled or not.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterVpcConnectivityIamArgs) ElementType added in v0.44.0 

func (ClusterVpcConnectivityIamArgs) ElementType() reflect.Type

func (ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamOutput added in v0.44.0 

func (i ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamOutput() ClusterVpcConnectivityIamOutput

func (ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamOutputWithContext(ctx context.Context) ClusterVpcConnectivityIamOutput

func (ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamPtrOutput added in v0.44.0 

func (i ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamPtrOutput() ClusterVpcConnectivityIamPtrOutput

func (ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamPtrOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityIamArgs) ToClusterVpcConnectivityIamPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityIamPtrOutput

type ClusterVpcConnectivityIamInput added in v0.44.0 

type ClusterVpcConnectivityIamInput interface {
	pulumi.Input

	ToClusterVpcConnectivityIamOutput() ClusterVpcConnectivityIamOutput
	ToClusterVpcConnectivityIamOutputWithContext(context.Context) ClusterVpcConnectivityIamOutput
}

ClusterVpcConnectivityIamInput is an input type that accepts ClusterVpcConnectivityIamArgs and ClusterVpcConnectivityIamOutput values. You can construct a concrete instance of `ClusterVpcConnectivityIamInput` via: 

ClusterVpcConnectivityIamArgs{...}

type ClusterVpcConnectivityIamOutput added in v0.44.0 

type ClusterVpcConnectivityIamOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityIamOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityIamOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityIamOutput) Enabled added in v0.44.0 

func (o ClusterVpcConnectivityIamOutput) Enabled() pulumi.BoolOutput

SASL/IAM authentication is enabled or not.

func (ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamOutput added in v0.44.0 

func (o ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamOutput() ClusterVpcConnectivityIamOutput

func (ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamOutputWithContext(ctx context.Context) ClusterVpcConnectivityIamOutput

func (ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamPtrOutput() ClusterVpcConnectivityIamPtrOutput

func (ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityIamOutput) ToClusterVpcConnectivityIamPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityIamPtrOutput

type ClusterVpcConnectivityIamPtrInput added in v0.44.0 

type ClusterVpcConnectivityIamPtrInput interface {
	pulumi.Input

	ToClusterVpcConnectivityIamPtrOutput() ClusterVpcConnectivityIamPtrOutput
	ToClusterVpcConnectivityIamPtrOutputWithContext(context.Context) ClusterVpcConnectivityIamPtrOutput
}

ClusterVpcConnectivityIamPtrInput is an input type that accepts ClusterVpcConnectivityIamArgs, ClusterVpcConnectivityIamPtr and ClusterVpcConnectivityIamPtrOutput values. You can construct a concrete instance of `ClusterVpcConnectivityIamPtrInput` via: 

        ClusterVpcConnectivityIamArgs{...}

or:

        nil

func ClusterVpcConnectivityIamPtr added in v0.44.0 

func ClusterVpcConnectivityIamPtr(v *ClusterVpcConnectivityIamArgs) ClusterVpcConnectivityIamPtrInput

type ClusterVpcConnectivityIamPtrOutput added in v0.44.0 

type ClusterVpcConnectivityIamPtrOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityIamPtrOutput) Elem added in v0.44.0 

func (o ClusterVpcConnectivityIamPtrOutput) Elem() ClusterVpcConnectivityIamOutput

func (ClusterVpcConnectivityIamPtrOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityIamPtrOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityIamPtrOutput) Enabled added in v0.44.0 

func (o ClusterVpcConnectivityIamPtrOutput) Enabled() pulumi.BoolPtrOutput

SASL/IAM authentication is enabled or not.

func (ClusterVpcConnectivityIamPtrOutput) ToClusterVpcConnectivityIamPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityIamPtrOutput) ToClusterVpcConnectivityIamPtrOutput() ClusterVpcConnectivityIamPtrOutput

func (ClusterVpcConnectivityIamPtrOutput) ToClusterVpcConnectivityIamPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityIamPtrOutput) ToClusterVpcConnectivityIamPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityIamPtrOutput

type ClusterVpcConnectivityInput added in v0.44.0 

type ClusterVpcConnectivityInput interface {
	pulumi.Input

	ToClusterVpcConnectivityOutput() ClusterVpcConnectivityOutput
	ToClusterVpcConnectivityOutputWithContext(context.Context) ClusterVpcConnectivityOutput
}

ClusterVpcConnectivityInput is an input type that accepts ClusterVpcConnectivityArgs and ClusterVpcConnectivityOutput values. You can construct a concrete instance of `ClusterVpcConnectivityInput` via: 

ClusterVpcConnectivityArgs{...}

type ClusterVpcConnectivityOutput added in v0.44.0 

type ClusterVpcConnectivityOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityOutput) ClientAuthentication added in v0.44.0 

func (o ClusterVpcConnectivityOutput) ClientAuthentication() ClusterVpcConnectivityClientAuthenticationPtrOutput

VPC connection control settings for brokers.

func (ClusterVpcConnectivityOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityOutput) ToClusterVpcConnectivityOutput added in v0.44.0 

func (o ClusterVpcConnectivityOutput) ToClusterVpcConnectivityOutput() ClusterVpcConnectivityOutput

func (ClusterVpcConnectivityOutput) ToClusterVpcConnectivityOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityOutput) ToClusterVpcConnectivityOutputWithContext(ctx context.Context) ClusterVpcConnectivityOutput

func (ClusterVpcConnectivityOutput) ToClusterVpcConnectivityPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityOutput) ToClusterVpcConnectivityPtrOutput() ClusterVpcConnectivityPtrOutput

func (ClusterVpcConnectivityOutput) ToClusterVpcConnectivityPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityOutput) ToClusterVpcConnectivityPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityPtrOutput

type ClusterVpcConnectivityPtrInput added in v0.44.0 

type ClusterVpcConnectivityPtrInput interface {
	pulumi.Input

	ToClusterVpcConnectivityPtrOutput() ClusterVpcConnectivityPtrOutput
	ToClusterVpcConnectivityPtrOutputWithContext(context.Context) ClusterVpcConnectivityPtrOutput
}

ClusterVpcConnectivityPtrInput is an input type that accepts ClusterVpcConnectivityArgs, ClusterVpcConnectivityPtr and ClusterVpcConnectivityPtrOutput values. You can construct a concrete instance of `ClusterVpcConnectivityPtrInput` via: 

        ClusterVpcConnectivityArgs{...}

or:

        nil

func ClusterVpcConnectivityPtr added in v0.44.0 

func ClusterVpcConnectivityPtr(v *ClusterVpcConnectivityArgs) ClusterVpcConnectivityPtrInput

type ClusterVpcConnectivityPtrOutput added in v0.44.0 

type ClusterVpcConnectivityPtrOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityPtrOutput) ClientAuthentication added in v0.44.0 

func (o ClusterVpcConnectivityPtrOutput) ClientAuthentication() ClusterVpcConnectivityClientAuthenticationPtrOutput

VPC connection control settings for brokers.

func (ClusterVpcConnectivityPtrOutput) Elem added in v0.44.0 

func (o ClusterVpcConnectivityPtrOutput) Elem() ClusterVpcConnectivityOutput

func (ClusterVpcConnectivityPtrOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityPtrOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityPtrOutput) ToClusterVpcConnectivityPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityPtrOutput) ToClusterVpcConnectivityPtrOutput() ClusterVpcConnectivityPtrOutput

func (ClusterVpcConnectivityPtrOutput) ToClusterVpcConnectivityPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityPtrOutput) ToClusterVpcConnectivityPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityPtrOutput

type ClusterVpcConnectivitySasl added in v0.44.0 

type ClusterVpcConnectivitySasl struct {
	// Details for ClientAuthentication using IAM for VpcConnectivity.
	Iam *ClusterVpcConnectivityIam `pulumi:"iam"`
	// Details for SASL/SCRAM client authentication for VpcConnectivity.
	Scram *ClusterVpcConnectivityScram `pulumi:"scram"`
}

type ClusterVpcConnectivitySaslArgs added in v0.44.0 

type ClusterVpcConnectivitySaslArgs struct {
	// Details for ClientAuthentication using IAM for VpcConnectivity.
	Iam ClusterVpcConnectivityIamPtrInput `pulumi:"iam"`
	// Details for SASL/SCRAM client authentication for VpcConnectivity.
	Scram ClusterVpcConnectivityScramPtrInput `pulumi:"scram"`
}

func (ClusterVpcConnectivitySaslArgs) ElementType added in v0.44.0 

func (ClusterVpcConnectivitySaslArgs) ElementType() reflect.Type

func (ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslOutput added in v0.44.0 

func (i ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslOutput() ClusterVpcConnectivitySaslOutput

func (ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslOutputWithContext(ctx context.Context) ClusterVpcConnectivitySaslOutput

func (ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslPtrOutput added in v0.44.0 

func (i ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslPtrOutput() ClusterVpcConnectivitySaslPtrOutput

func (ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslPtrOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivitySaslArgs) ToClusterVpcConnectivitySaslPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivitySaslPtrOutput

type ClusterVpcConnectivitySaslInput added in v0.44.0 

type ClusterVpcConnectivitySaslInput interface {
	pulumi.Input

	ToClusterVpcConnectivitySaslOutput() ClusterVpcConnectivitySaslOutput
	ToClusterVpcConnectivitySaslOutputWithContext(context.Context) ClusterVpcConnectivitySaslOutput
}

ClusterVpcConnectivitySaslInput is an input type that accepts ClusterVpcConnectivitySaslArgs and ClusterVpcConnectivitySaslOutput values. You can construct a concrete instance of `ClusterVpcConnectivitySaslInput` via: 

ClusterVpcConnectivitySaslArgs{...}

type ClusterVpcConnectivitySaslOutput added in v0.44.0 

type ClusterVpcConnectivitySaslOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivitySaslOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivitySaslOutput) ElementType() reflect.Type

func (ClusterVpcConnectivitySaslOutput) Iam added in v0.44.0 

func (o ClusterVpcConnectivitySaslOutput) Iam() ClusterVpcConnectivityIamPtrOutput

Details for ClientAuthentication using IAM for VpcConnectivity.

func (ClusterVpcConnectivitySaslOutput) Scram added in v0.44.0 

func (o ClusterVpcConnectivitySaslOutput) Scram() ClusterVpcConnectivityScramPtrOutput

Details for SASL/SCRAM client authentication for VpcConnectivity.

func (ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslOutput added in v0.44.0 

func (o ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslOutput() ClusterVpcConnectivitySaslOutput

func (ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslOutputWithContext(ctx context.Context) ClusterVpcConnectivitySaslOutput

func (ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslPtrOutput() ClusterVpcConnectivitySaslPtrOutput

func (ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivitySaslOutput) ToClusterVpcConnectivitySaslPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivitySaslPtrOutput

type ClusterVpcConnectivitySaslPtrInput added in v0.44.0 

type ClusterVpcConnectivitySaslPtrInput interface {
	pulumi.Input

	ToClusterVpcConnectivitySaslPtrOutput() ClusterVpcConnectivitySaslPtrOutput
	ToClusterVpcConnectivitySaslPtrOutputWithContext(context.Context) ClusterVpcConnectivitySaslPtrOutput
}

ClusterVpcConnectivitySaslPtrInput is an input type that accepts ClusterVpcConnectivitySaslArgs, ClusterVpcConnectivitySaslPtr and ClusterVpcConnectivitySaslPtrOutput values. You can construct a concrete instance of `ClusterVpcConnectivitySaslPtrInput` via: 

        ClusterVpcConnectivitySaslArgs{...}

or:

        nil

func ClusterVpcConnectivitySaslPtr added in v0.44.0 

func ClusterVpcConnectivitySaslPtr(v *ClusterVpcConnectivitySaslArgs) ClusterVpcConnectivitySaslPtrInput

type ClusterVpcConnectivitySaslPtrOutput added in v0.44.0 

type ClusterVpcConnectivitySaslPtrOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivitySaslPtrOutput) Elem added in v0.44.0 

func (o ClusterVpcConnectivitySaslPtrOutput) Elem() ClusterVpcConnectivitySaslOutput

func (ClusterVpcConnectivitySaslPtrOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivitySaslPtrOutput) ElementType() reflect.Type

func (ClusterVpcConnectivitySaslPtrOutput) Iam added in v0.44.0 

func (o ClusterVpcConnectivitySaslPtrOutput) Iam() ClusterVpcConnectivityIamPtrOutput

Details for ClientAuthentication using IAM for VpcConnectivity.

func (ClusterVpcConnectivitySaslPtrOutput) Scram added in v0.44.0 

func (o ClusterVpcConnectivitySaslPtrOutput) Scram() ClusterVpcConnectivityScramPtrOutput

Details for SASL/SCRAM client authentication for VpcConnectivity.

func (ClusterVpcConnectivitySaslPtrOutput) ToClusterVpcConnectivitySaslPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivitySaslPtrOutput) ToClusterVpcConnectivitySaslPtrOutput() ClusterVpcConnectivitySaslPtrOutput

func (ClusterVpcConnectivitySaslPtrOutput) ToClusterVpcConnectivitySaslPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivitySaslPtrOutput) ToClusterVpcConnectivitySaslPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivitySaslPtrOutput

type ClusterVpcConnectivityScram added in v0.44.0 

type ClusterVpcConnectivityScram struct {
	// SASL/SCRAM authentication is enabled or not.
	Enabled bool `pulumi:"enabled"`
}

type ClusterVpcConnectivityScramArgs added in v0.44.0 

type ClusterVpcConnectivityScramArgs struct {
	// SASL/SCRAM authentication is enabled or not.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterVpcConnectivityScramArgs) ElementType added in v0.44.0 

func (ClusterVpcConnectivityScramArgs) ElementType() reflect.Type

func (ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramOutput added in v0.44.0 

func (i ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramOutput() ClusterVpcConnectivityScramOutput

func (ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramOutputWithContext(ctx context.Context) ClusterVpcConnectivityScramOutput

func (ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramPtrOutput added in v0.44.0 

func (i ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramPtrOutput() ClusterVpcConnectivityScramPtrOutput

func (ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramPtrOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityScramArgs) ToClusterVpcConnectivityScramPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityScramPtrOutput

type ClusterVpcConnectivityScramInput added in v0.44.0 

type ClusterVpcConnectivityScramInput interface {
	pulumi.Input

	ToClusterVpcConnectivityScramOutput() ClusterVpcConnectivityScramOutput
	ToClusterVpcConnectivityScramOutputWithContext(context.Context) ClusterVpcConnectivityScramOutput
}

ClusterVpcConnectivityScramInput is an input type that accepts ClusterVpcConnectivityScramArgs and ClusterVpcConnectivityScramOutput values. You can construct a concrete instance of `ClusterVpcConnectivityScramInput` via: 

ClusterVpcConnectivityScramArgs{...}

type ClusterVpcConnectivityScramOutput added in v0.44.0 

type ClusterVpcConnectivityScramOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityScramOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityScramOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityScramOutput) Enabled added in v0.44.0 

func (o ClusterVpcConnectivityScramOutput) Enabled() pulumi.BoolOutput

SASL/SCRAM authentication is enabled or not.

func (ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramOutput added in v0.44.0 

func (o ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramOutput() ClusterVpcConnectivityScramOutput

func (ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramOutputWithContext(ctx context.Context) ClusterVpcConnectivityScramOutput

func (ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramPtrOutput() ClusterVpcConnectivityScramPtrOutput

func (ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityScramOutput) ToClusterVpcConnectivityScramPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityScramPtrOutput

type ClusterVpcConnectivityScramPtrInput added in v0.44.0 

type ClusterVpcConnectivityScramPtrInput interface {
	pulumi.Input

	ToClusterVpcConnectivityScramPtrOutput() ClusterVpcConnectivityScramPtrOutput
	ToClusterVpcConnectivityScramPtrOutputWithContext(context.Context) ClusterVpcConnectivityScramPtrOutput
}

ClusterVpcConnectivityScramPtrInput is an input type that accepts ClusterVpcConnectivityScramArgs, ClusterVpcConnectivityScramPtr and ClusterVpcConnectivityScramPtrOutput values. You can construct a concrete instance of `ClusterVpcConnectivityScramPtrInput` via: 

        ClusterVpcConnectivityScramArgs{...}

or:

        nil

func ClusterVpcConnectivityScramPtr added in v0.44.0 

func ClusterVpcConnectivityScramPtr(v *ClusterVpcConnectivityScramArgs) ClusterVpcConnectivityScramPtrInput

type ClusterVpcConnectivityScramPtrOutput added in v0.44.0 

type ClusterVpcConnectivityScramPtrOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityScramPtrOutput) Elem added in v0.44.0 

func (o ClusterVpcConnectivityScramPtrOutput) Elem() ClusterVpcConnectivityScramOutput

func (ClusterVpcConnectivityScramPtrOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityScramPtrOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityScramPtrOutput) Enabled added in v0.44.0 

func (o ClusterVpcConnectivityScramPtrOutput) Enabled() pulumi.BoolPtrOutput

SASL/SCRAM authentication is enabled or not.

func (ClusterVpcConnectivityScramPtrOutput) ToClusterVpcConnectivityScramPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityScramPtrOutput) ToClusterVpcConnectivityScramPtrOutput() ClusterVpcConnectivityScramPtrOutput

func (ClusterVpcConnectivityScramPtrOutput) ToClusterVpcConnectivityScramPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityScramPtrOutput) ToClusterVpcConnectivityScramPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityScramPtrOutput

type ClusterVpcConnectivityTls added in v0.44.0 

type ClusterVpcConnectivityTls struct {
	// TLS authentication is enabled or not.
	Enabled bool `pulumi:"enabled"`
}

type ClusterVpcConnectivityTlsArgs added in v0.44.0 

type ClusterVpcConnectivityTlsArgs struct {
	// TLS authentication is enabled or not.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterVpcConnectivityTlsArgs) ElementType added in v0.44.0 

func (ClusterVpcConnectivityTlsArgs) ElementType() reflect.Type

func (ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsOutput added in v0.44.0 

func (i ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsOutput() ClusterVpcConnectivityTlsOutput

func (ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsOutputWithContext(ctx context.Context) ClusterVpcConnectivityTlsOutput

func (ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsPtrOutput added in v0.44.0 

func (i ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsPtrOutput() ClusterVpcConnectivityTlsPtrOutput

func (ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsPtrOutputWithContext added in v0.44.0 

func (i ClusterVpcConnectivityTlsArgs) ToClusterVpcConnectivityTlsPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityTlsPtrOutput

type ClusterVpcConnectivityTlsInput added in v0.44.0 

type ClusterVpcConnectivityTlsInput interface {
	pulumi.Input

	ToClusterVpcConnectivityTlsOutput() ClusterVpcConnectivityTlsOutput
	ToClusterVpcConnectivityTlsOutputWithContext(context.Context) ClusterVpcConnectivityTlsOutput
}

ClusterVpcConnectivityTlsInput is an input type that accepts ClusterVpcConnectivityTlsArgs and ClusterVpcConnectivityTlsOutput values. You can construct a concrete instance of `ClusterVpcConnectivityTlsInput` via: 

ClusterVpcConnectivityTlsArgs{...}

type ClusterVpcConnectivityTlsOutput added in v0.44.0 

type ClusterVpcConnectivityTlsOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityTlsOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityTlsOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityTlsOutput) Enabled added in v0.44.0 

func (o ClusterVpcConnectivityTlsOutput) Enabled() pulumi.BoolOutput

TLS authentication is enabled or not.

func (ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsOutput added in v0.44.0 

func (o ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsOutput() ClusterVpcConnectivityTlsOutput

func (ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsOutputWithContext(ctx context.Context) ClusterVpcConnectivityTlsOutput

func (ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsPtrOutput() ClusterVpcConnectivityTlsPtrOutput

func (ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityTlsOutput) ToClusterVpcConnectivityTlsPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityTlsPtrOutput

type ClusterVpcConnectivityTlsPtrInput added in v0.44.0 

type ClusterVpcConnectivityTlsPtrInput interface {
	pulumi.Input

	ToClusterVpcConnectivityTlsPtrOutput() ClusterVpcConnectivityTlsPtrOutput
	ToClusterVpcConnectivityTlsPtrOutputWithContext(context.Context) ClusterVpcConnectivityTlsPtrOutput
}

ClusterVpcConnectivityTlsPtrInput is an input type that accepts ClusterVpcConnectivityTlsArgs, ClusterVpcConnectivityTlsPtr and ClusterVpcConnectivityTlsPtrOutput values. You can construct a concrete instance of `ClusterVpcConnectivityTlsPtrInput` via: 

        ClusterVpcConnectivityTlsArgs{...}

or:

        nil

func ClusterVpcConnectivityTlsPtr added in v0.44.0 

func ClusterVpcConnectivityTlsPtr(v *ClusterVpcConnectivityTlsArgs) ClusterVpcConnectivityTlsPtrInput

type ClusterVpcConnectivityTlsPtrOutput added in v0.44.0 

type ClusterVpcConnectivityTlsPtrOutput struct{ *pulumi.OutputState }

func (ClusterVpcConnectivityTlsPtrOutput) Elem added in v0.44.0 

func (o ClusterVpcConnectivityTlsPtrOutput) Elem() ClusterVpcConnectivityTlsOutput

func (ClusterVpcConnectivityTlsPtrOutput) ElementType added in v0.44.0 

func (ClusterVpcConnectivityTlsPtrOutput) ElementType() reflect.Type

func (ClusterVpcConnectivityTlsPtrOutput) Enabled added in v0.44.0 

func (o ClusterVpcConnectivityTlsPtrOutput) Enabled() pulumi.BoolPtrOutput

TLS authentication is enabled or not.

func (ClusterVpcConnectivityTlsPtrOutput) ToClusterVpcConnectivityTlsPtrOutput added in v0.44.0 

func (o ClusterVpcConnectivityTlsPtrOutput) ToClusterVpcConnectivityTlsPtrOutput() ClusterVpcConnectivityTlsPtrOutput

func (ClusterVpcConnectivityTlsPtrOutput) ToClusterVpcConnectivityTlsPtrOutputWithContext added in v0.44.0 

func (o ClusterVpcConnectivityTlsPtrOutput) ToClusterVpcConnectivityTlsPtrOutputWithContext(ctx context.Context) ClusterVpcConnectivityTlsPtrOutput

type Configuration added in v0.14.0 

type Configuration struct {
	pulumi.CustomResourceState

	Arn pulumi.StringOutput `pulumi:"arn"`
	// The description of the configuration.
	Description       pulumi.StringPtrOutput   `pulumi:"description"`
	KafkaVersionsList pulumi.StringArrayOutput `pulumi:"kafkaVersionsList"`
	// Latest revision of the configuration.
	LatestRevision ConfigurationLatestRevisionPtrOutput `pulumi:"latestRevision"`
	// The name of the configuration. Configuration names are strings that match the regex "^[0-9A-Za-z][0-9A-Za-z-]{0,}$".
	Name pulumi.StringOutput `pulumi:"name"`
	// Contents of the server.properties file. When using the API, you must ensure that the contents of the file are base64 encoded. When using the console, the SDK, or the CLI, the contents of server.properties can be in plaintext.
	ServerProperties pulumi.StringOutput `pulumi:"serverProperties"`
}

Resource Type definition for AWS::MSK::Configuration

func GetConfiguration added in v0.14.0 

func GetConfiguration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ConfigurationState, opts ...pulumi.ResourceOption) (*Configuration, error)

GetConfiguration gets an existing Configuration 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 NewConfiguration added in v0.14.0 

func NewConfiguration(ctx *pulumi.Context,
	name string, args *ConfigurationArgs, opts ...pulumi.ResourceOption) (*Configuration, error)

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

func (*Configuration) ElementType added in v0.14.0 

func (*Configuration) ElementType() reflect.Type

func (*Configuration) ToConfigurationOutput added in v0.14.0 

func (i *Configuration) ToConfigurationOutput() ConfigurationOutput

func (*Configuration) ToConfigurationOutputWithContext added in v0.14.0 

func (i *Configuration) ToConfigurationOutputWithContext(ctx context.Context) ConfigurationOutput

type ConfigurationArgs added in v0.14.0 

type ConfigurationArgs struct {
	// The description of the configuration.
	Description       pulumi.StringPtrInput
	KafkaVersionsList pulumi.StringArrayInput
	// Latest revision of the configuration.
	LatestRevision ConfigurationLatestRevisionPtrInput
	// The name of the configuration. Configuration names are strings that match the regex "^[0-9A-Za-z][0-9A-Za-z-]{0,}$".
	Name pulumi.StringPtrInput
	// Contents of the server.properties file. When using the API, you must ensure that the contents of the file are base64 encoded. When using the console, the SDK, or the CLI, the contents of server.properties can be in plaintext.
	ServerProperties pulumi.StringInput
}

The set of arguments for constructing a Configuration resource.

func (ConfigurationArgs) ElementType added in v0.14.0 

func (ConfigurationArgs) ElementType() reflect.Type

type ConfigurationInput added in v0.14.0 

type ConfigurationInput interface {
	pulumi.Input

	ToConfigurationOutput() ConfigurationOutput
	ToConfigurationOutputWithContext(ctx context.Context) ConfigurationOutput
}

type ConfigurationLatestRevision added in v0.77.0 

type ConfigurationLatestRevision struct {
	CreationTime *string `pulumi:"creationTime"`
	Description  *string `pulumi:"description"`
	Revision     *int    `pulumi:"revision"`
}

type ConfigurationLatestRevisionArgs added in v0.77.0 

type ConfigurationLatestRevisionArgs struct {
	CreationTime pulumi.StringPtrInput `pulumi:"creationTime"`
	Description  pulumi.StringPtrInput `pulumi:"description"`
	Revision     pulumi.IntPtrInput    `pulumi:"revision"`
}

func (ConfigurationLatestRevisionArgs) ElementType added in v0.77.0 

func (ConfigurationLatestRevisionArgs) ElementType() reflect.Type

func (ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionOutput added in v0.77.0 

func (i ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionOutput() ConfigurationLatestRevisionOutput

func (ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionOutputWithContext added in v0.77.0 

func (i ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionOutputWithContext(ctx context.Context) ConfigurationLatestRevisionOutput

func (ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionPtrOutput added in v0.77.0 

func (i ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionPtrOutput() ConfigurationLatestRevisionPtrOutput

func (ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionPtrOutputWithContext added in v0.77.0 

func (i ConfigurationLatestRevisionArgs) ToConfigurationLatestRevisionPtrOutputWithContext(ctx context.Context) ConfigurationLatestRevisionPtrOutput

type ConfigurationLatestRevisionInput added in v0.77.0 

type ConfigurationLatestRevisionInput interface {
	pulumi.Input

	ToConfigurationLatestRevisionOutput() ConfigurationLatestRevisionOutput
	ToConfigurationLatestRevisionOutputWithContext(context.Context) ConfigurationLatestRevisionOutput
}

ConfigurationLatestRevisionInput is an input type that accepts ConfigurationLatestRevisionArgs and ConfigurationLatestRevisionOutput values. You can construct a concrete instance of `ConfigurationLatestRevisionInput` via: 

ConfigurationLatestRevisionArgs{...}

type ConfigurationLatestRevisionOutput added in v0.77.0 

type ConfigurationLatestRevisionOutput struct{ *pulumi.OutputState }

func (ConfigurationLatestRevisionOutput) CreationTime added in v0.77.0 

func (o ConfigurationLatestRevisionOutput) CreationTime() pulumi.StringPtrOutput

func (ConfigurationLatestRevisionOutput) Description added in v0.77.0 

func (o ConfigurationLatestRevisionOutput) Description() pulumi.StringPtrOutput

func (ConfigurationLatestRevisionOutput) ElementType added in v0.77.0 

func (ConfigurationLatestRevisionOutput) ElementType() reflect.Type

func (ConfigurationLatestRevisionOutput) Revision added in v0.77.0 

func (o ConfigurationLatestRevisionOutput) Revision() pulumi.IntPtrOutput

func (ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionOutput added in v0.77.0 

func (o ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionOutput() ConfigurationLatestRevisionOutput

func (ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionOutputWithContext added in v0.77.0 

func (o ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionOutputWithContext(ctx context.Context) ConfigurationLatestRevisionOutput

func (ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionPtrOutput added in v0.77.0 

func (o ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionPtrOutput() ConfigurationLatestRevisionPtrOutput

func (ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionPtrOutputWithContext added in v0.77.0 

func (o ConfigurationLatestRevisionOutput) ToConfigurationLatestRevisionPtrOutputWithContext(ctx context.Context) ConfigurationLatestRevisionPtrOutput

type ConfigurationLatestRevisionPtrInput added in v0.77.0 

type ConfigurationLatestRevisionPtrInput interface {
	pulumi.Input

	ToConfigurationLatestRevisionPtrOutput() ConfigurationLatestRevisionPtrOutput
	ToConfigurationLatestRevisionPtrOutputWithContext(context.Context) ConfigurationLatestRevisionPtrOutput
}

ConfigurationLatestRevisionPtrInput is an input type that accepts ConfigurationLatestRevisionArgs, ConfigurationLatestRevisionPtr and ConfigurationLatestRevisionPtrOutput values. You can construct a concrete instance of `ConfigurationLatestRevisionPtrInput` via: 

        ConfigurationLatestRevisionArgs{...}

or:

        nil

func ConfigurationLatestRevisionPtr added in v0.77.0 

func ConfigurationLatestRevisionPtr(v *ConfigurationLatestRevisionArgs) ConfigurationLatestRevisionPtrInput

type ConfigurationLatestRevisionPtrOutput added in v0.77.0 

type ConfigurationLatestRevisionPtrOutput struct{ *pulumi.OutputState }

func (ConfigurationLatestRevisionPtrOutput) CreationTime added in v0.77.0 

func (o ConfigurationLatestRevisionPtrOutput) CreationTime() pulumi.StringPtrOutput

func (ConfigurationLatestRevisionPtrOutput) Description added in v0.77.0 

func (o ConfigurationLatestRevisionPtrOutput) Description() pulumi.StringPtrOutput

func (ConfigurationLatestRevisionPtrOutput) Elem added in v0.77.0 

func (o ConfigurationLatestRevisionPtrOutput) Elem() ConfigurationLatestRevisionOutput

func (ConfigurationLatestRevisionPtrOutput) ElementType added in v0.77.0 

func (ConfigurationLatestRevisionPtrOutput) ElementType() reflect.Type

func (ConfigurationLatestRevisionPtrOutput) Revision added in v0.77.0 

func (o ConfigurationLatestRevisionPtrOutput) Revision() pulumi.IntPtrOutput

func (ConfigurationLatestRevisionPtrOutput) ToConfigurationLatestRevisionPtrOutput added in v0.77.0 

func (o ConfigurationLatestRevisionPtrOutput) ToConfigurationLatestRevisionPtrOutput() ConfigurationLatestRevisionPtrOutput

func (ConfigurationLatestRevisionPtrOutput) ToConfigurationLatestRevisionPtrOutputWithContext added in v0.77.0 

func (o ConfigurationLatestRevisionPtrOutput) ToConfigurationLatestRevisionPtrOutputWithContext(ctx context.Context) ConfigurationLatestRevisionPtrOutput

type ConfigurationOutput added in v0.14.0 

type ConfigurationOutput struct{ *pulumi.OutputState }

func (ConfigurationOutput) Arn added in v0.17.0 

func (o ConfigurationOutput) Arn() pulumi.StringOutput

func (ConfigurationOutput) Description added in v0.17.0 

func (o ConfigurationOutput) Description() pulumi.StringPtrOutput

The description of the configuration.

func (ConfigurationOutput) ElementType added in v0.14.0 

func (ConfigurationOutput) ElementType() reflect.Type

func (ConfigurationOutput) KafkaVersionsList added in v0.17.0 

func (o ConfigurationOutput) KafkaVersionsList() pulumi.StringArrayOutput

func (ConfigurationOutput) LatestRevision added in v0.77.0 

func (o ConfigurationOutput) LatestRevision() ConfigurationLatestRevisionPtrOutput

Latest revision of the configuration.

func (ConfigurationOutput) Name added in v0.17.0 

func (o ConfigurationOutput) Name() pulumi.StringOutput

The name of the configuration. Configuration names are strings that match the regex "^[0-9A-Za-z][0-9A-Za-z-]{0,}$".

func (ConfigurationOutput) ServerProperties added in v0.17.0 

func (o ConfigurationOutput) ServerProperties() pulumi.StringOutput

Contents of the server.properties file. When using the API, you must ensure that the contents of the file are base64 encoded. When using the console, the SDK, or the CLI, the contents of server.properties can be in plaintext.

func (ConfigurationOutput) ToConfigurationOutput added in v0.14.0 

func (o ConfigurationOutput) ToConfigurationOutput() ConfigurationOutput

func (ConfigurationOutput) ToConfigurationOutputWithContext added in v0.14.0 

func (o ConfigurationOutput) ToConfigurationOutputWithContext(ctx context.Context) ConfigurationOutput

type ConfigurationState added in v0.14.0 

type ConfigurationState struct {
}

func (ConfigurationState) ElementType added in v0.14.0 

func (ConfigurationState) ElementType() reflect.Type

type LookupBatchScramSecretArgs added in v0.14.0 

type LookupBatchScramSecretArgs struct {
	ClusterArn string `pulumi:"clusterArn"`
}

type LookupBatchScramSecretOutputArgs added in v0.14.0 

type LookupBatchScramSecretOutputArgs struct {
	ClusterArn pulumi.StringInput `pulumi:"clusterArn"`
}

func (LookupBatchScramSecretOutputArgs) ElementType added in v0.14.0 

func (LookupBatchScramSecretOutputArgs) ElementType() reflect.Type

type LookupBatchScramSecretResult added in v0.14.0 

type LookupBatchScramSecretResult struct {
	SecretArnList []string `pulumi:"secretArnList"`
}

func LookupBatchScramSecret added in v0.14.0 

func LookupBatchScramSecret(ctx *pulumi.Context, args *LookupBatchScramSecretArgs, opts ...pulumi.InvokeOption) (*LookupBatchScramSecretResult, error)

Resource Type definition for AWS::MSK::BatchScramSecret

type LookupBatchScramSecretResultOutput added in v0.14.0 

type LookupBatchScramSecretResultOutput struct{ *pulumi.OutputState }

func LookupBatchScramSecretOutput added in v0.14.0 

func LookupBatchScramSecretOutput(ctx *pulumi.Context, args LookupBatchScramSecretOutputArgs, opts ...pulumi.InvokeOption) LookupBatchScramSecretResultOutput

func (LookupBatchScramSecretResultOutput) ElementType added in v0.14.0 

func (LookupBatchScramSecretResultOutput) ElementType() reflect.Type

func (LookupBatchScramSecretResultOutput) SecretArnList added in v0.14.0 

func (o LookupBatchScramSecretResultOutput) SecretArnList() pulumi.StringArrayOutput

func (LookupBatchScramSecretResultOutput) ToLookupBatchScramSecretResultOutput added in v0.14.0 

func (o LookupBatchScramSecretResultOutput) ToLookupBatchScramSecretResultOutput() LookupBatchScramSecretResultOutput

func (LookupBatchScramSecretResultOutput) ToLookupBatchScramSecretResultOutputWithContext added in v0.14.0 

func (o LookupBatchScramSecretResultOutput) ToLookupBatchScramSecretResultOutputWithContext(ctx context.Context) LookupBatchScramSecretResultOutput

type LookupClusterArgs added in v0.12.0 

type LookupClusterArgs struct {
	Arn string `pulumi:"arn"`
}

type LookupClusterOutputArgs added in v0.12.0 

type LookupClusterOutputArgs struct {
	Arn pulumi.StringInput `pulumi:"arn"`
}

func (LookupClusterOutputArgs) ElementType added in v0.12.0 

func (LookupClusterOutputArgs) ElementType() reflect.Type

type LookupClusterPolicyArgs added in v0.59.0 

type LookupClusterPolicyArgs struct {
	// The arn of the cluster for the resource policy.
	ClusterArn string `pulumi:"clusterArn"`
}

type LookupClusterPolicyOutputArgs added in v0.59.0 

type LookupClusterPolicyOutputArgs struct {
	// The arn of the cluster for the resource policy.
	ClusterArn pulumi.StringInput `pulumi:"clusterArn"`
}

func (LookupClusterPolicyOutputArgs) ElementType added in v0.59.0 

func (LookupClusterPolicyOutputArgs) ElementType() reflect.Type

type LookupClusterPolicyResult added in v0.59.0 

type LookupClusterPolicyResult struct {
	// The current version of the policy attached to the specified cluster
	CurrentVersion *string `pulumi:"currentVersion"`
	// A policy document containing permissions to add to the specified cluster.
	//
	// Search the [CloudFormation User Guide](https://docs.aws.amazon.com/cloudformation/) for `AWS::MSK::ClusterPolicy` for more information about the expected schema for this property.
	Policy interface{} `pulumi:"policy"`
}

func LookupClusterPolicy added in v0.59.0 

func LookupClusterPolicy(ctx *pulumi.Context, args *LookupClusterPolicyArgs, opts ...pulumi.InvokeOption) (*LookupClusterPolicyResult, error)

Resource Type definition for AWS::MSK::ClusterPolicy

type LookupClusterPolicyResultOutput added in v0.59.0 

type LookupClusterPolicyResultOutput struct{ *pulumi.OutputState }

func LookupClusterPolicyOutput added in v0.59.0 

func LookupClusterPolicyOutput(ctx *pulumi.Context, args LookupClusterPolicyOutputArgs, opts ...pulumi.InvokeOption) LookupClusterPolicyResultOutput

func (LookupClusterPolicyResultOutput) CurrentVersion added in v0.59.0 

func (o LookupClusterPolicyResultOutput) CurrentVersion() pulumi.StringPtrOutput

The current version of the policy attached to the specified cluster

func (LookupClusterPolicyResultOutput) ElementType added in v0.59.0 

func (LookupClusterPolicyResultOutput) ElementType() reflect.Type

func (LookupClusterPolicyResultOutput) Policy added in v0.59.0 

func (o LookupClusterPolicyResultOutput) Policy() pulumi.AnyOutput

A policy document containing permissions to add to the specified cluster.

Search the [CloudFormation User Guide](https://docs.aws.amazon.com/cloudformation/) for `AWS::MSK::ClusterPolicy` for more information about the expected schema for this property.

func (LookupClusterPolicyResultOutput) ToLookupClusterPolicyResultOutput added in v0.59.0 

func (o LookupClusterPolicyResultOutput) ToLookupClusterPolicyResultOutput() LookupClusterPolicyResultOutput

func (LookupClusterPolicyResultOutput) ToLookupClusterPolicyResultOutputWithContext added in v0.59.0 

func (o LookupClusterPolicyResultOutput) ToLookupClusterPolicyResultOutputWithContext(ctx context.Context) LookupClusterPolicyResultOutput

type LookupClusterResult added in v0.12.0 

type LookupClusterResult struct {
	Arn *string `pulumi:"arn"`
	// Information about the broker nodes in the cluster.
	BrokerNodeGroupInfo *ClusterBrokerNodeGroupInfo `pulumi:"brokerNodeGroupInfo"`
	// VPC connection control settings for brokers.
	ClientAuthentication *ClusterClientAuthentication `pulumi:"clientAuthentication"`
	// Represents the configuration that you want MSK to use for the cluster.
	ConfigurationInfo *ClusterConfigurationInfo `pulumi:"configurationInfo"`
	// The current version of the MSK cluster
	CurrentVersion *string `pulumi:"currentVersion"`
	// Includes all encryption-related information.
	EncryptionInfo *ClusterEncryptionInfo `pulumi:"encryptionInfo"`
	// Specifies the level of monitoring for the MSK cluster. The possible values are `DEFAULT` , `PER_BROKER` , and `PER_TOPIC_PER_BROKER` .
	EnhancedMonitoring *ClusterEnhancedMonitoring `pulumi:"enhancedMonitoring"`
	// The version of Apache Kafka. You can use Amazon MSK to create clusters that use Apache Kafka versions 1.1.1 and 2.2.1.
	KafkaVersion *string `pulumi:"kafkaVersion"`
	// Logging Info details.
	LoggingInfo *ClusterLoggingInfo `pulumi:"loggingInfo"`
	// The number of broker nodes in the cluster.
	NumberOfBrokerNodes *int `pulumi:"numberOfBrokerNodes"`
	// The settings for open monitoring.
	OpenMonitoring *ClusterOpenMonitoring `pulumi:"openMonitoring"`
	// This controls storage mode for supported storage tiers.
	StorageMode *ClusterStorageMode `pulumi:"storageMode"`
	// A key-value pair to associate with a resource.
	Tags map[string]string `pulumi:"tags"`
}

func LookupCluster added in v0.12.0 

func LookupCluster(ctx *pulumi.Context, args *LookupClusterArgs, opts ...pulumi.InvokeOption) (*LookupClusterResult, error)

Resource Type definition for AWS::MSK::Cluster

type LookupClusterResultOutput added in v0.12.0 

type LookupClusterResultOutput struct{ *pulumi.OutputState }

func LookupClusterOutput added in v0.12.0 

func LookupClusterOutput(ctx *pulumi.Context, args LookupClusterOutputArgs, opts ...pulumi.InvokeOption) LookupClusterResultOutput

func (LookupClusterResultOutput) Arn added in v0.14.0 

func (o LookupClusterResultOutput) Arn() pulumi.StringPtrOutput

func (LookupClusterResultOutput) BrokerNodeGroupInfo added in v0.12.0 

func (o LookupClusterResultOutput) BrokerNodeGroupInfo() ClusterBrokerNodeGroupInfoPtrOutput

Information about the broker nodes in the cluster.

func (LookupClusterResultOutput) ClientAuthentication added in v0.12.0 

func (o LookupClusterResultOutput) ClientAuthentication() ClusterClientAuthenticationPtrOutput

VPC connection control settings for brokers.

func (LookupClusterResultOutput) ConfigurationInfo added in v0.12.0 

func (o LookupClusterResultOutput) ConfigurationInfo() ClusterConfigurationInfoPtrOutput

Represents the configuration that you want MSK to use for the cluster.

func (LookupClusterResultOutput) CurrentVersion added in v0.14.0 

func (o LookupClusterResultOutput) CurrentVersion() pulumi.StringPtrOutput

The current version of the MSK cluster

func (LookupClusterResultOutput) ElementType added in v0.12.0 

func (LookupClusterResultOutput) ElementType() reflect.Type

func (LookupClusterResultOutput) EncryptionInfo added in v0.12.0 

func (o LookupClusterResultOutput) EncryptionInfo() ClusterEncryptionInfoPtrOutput

Includes all encryption-related information.

func (LookupClusterResultOutput) EnhancedMonitoring added in v0.12.0 

func (o LookupClusterResultOutput) EnhancedMonitoring() ClusterEnhancedMonitoringPtrOutput

Specifies the level of monitoring for the MSK cluster. The possible values are `DEFAULT` , `PER_BROKER` , and `PER_TOPIC_PER_BROKER` .

func (LookupClusterResultOutput) KafkaVersion added in v0.12.0 

func (o LookupClusterResultOutput) KafkaVersion() pulumi.StringPtrOutput

The version of Apache Kafka. You can use Amazon MSK to create clusters that use Apache Kafka versions 1.1.1 and 2.2.1.

func (LookupClusterResultOutput) LoggingInfo added in v0.12.0 

func (o LookupClusterResultOutput) LoggingInfo() ClusterLoggingInfoPtrOutput

Logging Info details.

func (LookupClusterResultOutput) NumberOfBrokerNodes added in v0.12.0 

func (o LookupClusterResultOutput) NumberOfBrokerNodes() pulumi.IntPtrOutput

The number of broker nodes in the cluster.

func (LookupClusterResultOutput) OpenMonitoring added in v0.12.0 

func (o LookupClusterResultOutput) OpenMonitoring() ClusterOpenMonitoringPtrOutput

The settings for open monitoring.

func (LookupClusterResultOutput) StorageMode added in v0.38.0 

func (o LookupClusterResultOutput) StorageMode() ClusterStorageModePtrOutput

This controls storage mode for supported storage tiers.

func (LookupClusterResultOutput) Tags added in v0.73.1 

func (o LookupClusterResultOutput) Tags() pulumi.StringMapOutput

A key-value pair to associate with a resource.

func (LookupClusterResultOutput) ToLookupClusterResultOutput added in v0.12.0 

func (o LookupClusterResultOutput) ToLookupClusterResultOutput() LookupClusterResultOutput

func (LookupClusterResultOutput) ToLookupClusterResultOutputWithContext added in v0.12.0 

func (o LookupClusterResultOutput) ToLookupClusterResultOutputWithContext(ctx context.Context) LookupClusterResultOutput

type LookupConfigurationArgs added in v0.14.0 

type LookupConfigurationArgs struct {
	Arn string `pulumi:"arn"`
}

type LookupConfigurationOutputArgs added in v0.14.0 

type LookupConfigurationOutputArgs struct {
	Arn pulumi.StringInput `pulumi:"arn"`
}

func (LookupConfigurationOutputArgs) ElementType added in v0.14.0 

func (LookupConfigurationOutputArgs) ElementType() reflect.Type

type LookupConfigurationResult added in v0.14.0 

type LookupConfigurationResult struct {
	Arn *string `pulumi:"arn"`
	// The description of the configuration.
	Description *string `pulumi:"description"`
	// Latest revision of the configuration.
	LatestRevision *ConfigurationLatestRevision `pulumi:"latestRevision"`
}

func LookupConfiguration added in v0.14.0 

func LookupConfiguration(ctx *pulumi.Context, args *LookupConfigurationArgs, opts ...pulumi.InvokeOption) (*LookupConfigurationResult, error)

Resource Type definition for AWS::MSK::Configuration

type LookupConfigurationResultOutput added in v0.14.0 

type LookupConfigurationResultOutput struct{ *pulumi.OutputState }

func LookupConfigurationOutput added in v0.14.0 

func LookupConfigurationOutput(ctx *pulumi.Context, args LookupConfigurationOutputArgs, opts ...pulumi.InvokeOption) LookupConfigurationResultOutput

func (LookupConfigurationResultOutput) Arn added in v0.14.0 

func (o LookupConfigurationResultOutput) Arn() pulumi.StringPtrOutput

func (LookupConfigurationResultOutput) Description added in v0.14.0 

func (o LookupConfigurationResultOutput) Description() pulumi.StringPtrOutput

The description of the configuration.

func (LookupConfigurationResultOutput) ElementType added in v0.14.0 

func (LookupConfigurationResultOutput) ElementType() reflect.Type

func (LookupConfigurationResultOutput) LatestRevision added in v0.77.0 

func (o LookupConfigurationResultOutput) LatestRevision() ConfigurationLatestRevisionPtrOutput

Latest revision of the configuration.

func (LookupConfigurationResultOutput) ToLookupConfigurationResultOutput added in v0.14.0 

func (o LookupConfigurationResultOutput) ToLookupConfigurationResultOutput() LookupConfigurationResultOutput

func (LookupConfigurationResultOutput) ToLookupConfigurationResultOutputWithContext added in v0.14.0 

func (o LookupConfigurationResultOutput) ToLookupConfigurationResultOutputWithContext(ctx context.Context) LookupConfigurationResultOutput

type LookupReplicatorArgs added in v0.82.0 

type LookupReplicatorArgs struct {
	// Amazon Resource Name for the created replicator.
	ReplicatorArn string `pulumi:"replicatorArn"`
}

type LookupReplicatorOutputArgs added in v0.82.0 

type LookupReplicatorOutputArgs struct {
	// Amazon Resource Name for the created replicator.
	ReplicatorArn pulumi.StringInput `pulumi:"replicatorArn"`
}

func (LookupReplicatorOutputArgs) ElementType added in v0.82.0 

func (LookupReplicatorOutputArgs) ElementType() reflect.Type

type LookupReplicatorResult added in v0.82.0 

type LookupReplicatorResult struct {
	// The current version of the MSK replicator.
	CurrentVersion *string `pulumi:"currentVersion"`
	// A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
	ReplicationInfoList []ReplicatorReplicationInfo `pulumi:"replicationInfoList"`
	// Amazon Resource Name for the created replicator.
	ReplicatorArn *string `pulumi:"replicatorArn"`
	// A collection of tags associated with a resource
	Tags []aws.Tag `pulumi:"tags"`
}

func LookupReplicator added in v0.82.0 

func LookupReplicator(ctx *pulumi.Context, args *LookupReplicatorArgs, opts ...pulumi.InvokeOption) (*LookupReplicatorResult, error)

Resource Type definition for AWS::MSK::Replicator

type LookupReplicatorResultOutput added in v0.82.0 

type LookupReplicatorResultOutput struct{ *pulumi.OutputState }

func LookupReplicatorOutput added in v0.82.0 

func LookupReplicatorOutput(ctx *pulumi.Context, args LookupReplicatorOutputArgs, opts ...pulumi.InvokeOption) LookupReplicatorResultOutput

func (LookupReplicatorResultOutput) CurrentVersion added in v0.82.0 

func (o LookupReplicatorResultOutput) CurrentVersion() pulumi.StringPtrOutput

The current version of the MSK replicator.

func (LookupReplicatorResultOutput) ElementType added in v0.82.0 

func (LookupReplicatorResultOutput) ElementType() reflect.Type

func (LookupReplicatorResultOutput) ReplicationInfoList added in v0.82.0 

func (o LookupReplicatorResultOutput) ReplicationInfoList() ReplicatorReplicationInfoArrayOutput

A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.

func (LookupReplicatorResultOutput) ReplicatorArn added in v0.82.0 

func (o LookupReplicatorResultOutput) ReplicatorArn() pulumi.StringPtrOutput

Amazon Resource Name for the created replicator.

func (LookupReplicatorResultOutput) Tags added in v0.82.0 

func (o LookupReplicatorResultOutput) Tags() aws.TagArrayOutput

A collection of tags associated with a resource

func (LookupReplicatorResultOutput) ToLookupReplicatorResultOutput added in v0.82.0 

func (o LookupReplicatorResultOutput) ToLookupReplicatorResultOutput() LookupReplicatorResultOutput

func (LookupReplicatorResultOutput) ToLookupReplicatorResultOutputWithContext added in v0.82.0 

func (o LookupReplicatorResultOutput) ToLookupReplicatorResultOutputWithContext(ctx context.Context) LookupReplicatorResultOutput

type LookupServerlessClusterArgs added in v0.21.0 

type LookupServerlessClusterArgs struct {
	Arn string `pulumi:"arn"`
}

type LookupServerlessClusterOutputArgs added in v0.21.0 

type LookupServerlessClusterOutputArgs struct {
	Arn pulumi.StringInput `pulumi:"arn"`
}

func (LookupServerlessClusterOutputArgs) ElementType added in v0.21.0 

func (LookupServerlessClusterOutputArgs) ElementType() reflect.Type

type LookupServerlessClusterResult added in v0.21.0 

type LookupServerlessClusterResult struct {
	Arn *string `pulumi:"arn"`
}

func LookupServerlessCluster added in v0.21.0 

func LookupServerlessCluster(ctx *pulumi.Context, args *LookupServerlessClusterArgs, opts ...pulumi.InvokeOption) (*LookupServerlessClusterResult, error)

Resource Type definition for AWS::MSK::ServerlessCluster

type LookupServerlessClusterResultOutput added in v0.21.0 

type LookupServerlessClusterResultOutput struct{ *pulumi.OutputState }

func LookupServerlessClusterOutput added in v0.21.0 

func LookupServerlessClusterOutput(ctx *pulumi.Context, args LookupServerlessClusterOutputArgs, opts ...pulumi.InvokeOption) LookupServerlessClusterResultOutput

func (LookupServerlessClusterResultOutput) Arn added in v0.21.0 

func (o LookupServerlessClusterResultOutput) Arn() pulumi.StringPtrOutput

func (LookupServerlessClusterResultOutput) ElementType added in v0.21.0 

func (LookupServerlessClusterResultOutput) ElementType() reflect.Type

func (LookupServerlessClusterResultOutput) ToLookupServerlessClusterResultOutput added in v0.21.0 

func (o LookupServerlessClusterResultOutput) ToLookupServerlessClusterResultOutput() LookupServerlessClusterResultOutput

func (LookupServerlessClusterResultOutput) ToLookupServerlessClusterResultOutputWithContext added in v0.21.0 

func (o LookupServerlessClusterResultOutput) ToLookupServerlessClusterResultOutputWithContext(ctx context.Context) LookupServerlessClusterResultOutput

type LookupVpcConnectionArgs added in v0.60.0 

type LookupVpcConnectionArgs struct {
	// The ARN of the VPC connection.
	Arn string `pulumi:"arn"`
}

type LookupVpcConnectionOutputArgs added in v0.60.0 

type LookupVpcConnectionOutputArgs struct {
	// The ARN of the VPC connection.
	Arn pulumi.StringInput `pulumi:"arn"`
}

func (LookupVpcConnectionOutputArgs) ElementType added in v0.60.0 

func (LookupVpcConnectionOutputArgs) ElementType() reflect.Type

type LookupVpcConnectionResult added in v0.60.0 

type LookupVpcConnectionResult struct {
	// The ARN of the VPC connection.
	Arn *string `pulumi:"arn"`
	// Create tags when creating the VPC connection.
	Tags map[string]string `pulumi:"tags"`
}

func LookupVpcConnection added in v0.60.0 

func LookupVpcConnection(ctx *pulumi.Context, args *LookupVpcConnectionArgs, opts ...pulumi.InvokeOption) (*LookupVpcConnectionResult, error)

Resource Type definition for AWS::MSK::VpcConnection

type LookupVpcConnectionResultOutput added in v0.60.0 

type LookupVpcConnectionResultOutput struct{ *pulumi.OutputState }

func LookupVpcConnectionOutput added in v0.60.0 

func LookupVpcConnectionOutput(ctx *pulumi.Context, args LookupVpcConnectionOutputArgs, opts ...pulumi.InvokeOption) LookupVpcConnectionResultOutput

func (LookupVpcConnectionResultOutput) Arn added in v0.60.0 

func (o LookupVpcConnectionResultOutput) Arn() pulumi.StringPtrOutput

The ARN of the VPC connection.

func (LookupVpcConnectionResultOutput) ElementType added in v0.60.0 

func (LookupVpcConnectionResultOutput) ElementType() reflect.Type

func (LookupVpcConnectionResultOutput) Tags added in v0.60.0 

func (o LookupVpcConnectionResultOutput) Tags() pulumi.StringMapOutput

Create tags when creating the VPC connection.

func (LookupVpcConnectionResultOutput) ToLookupVpcConnectionResultOutput added in v0.60.0 

func (o LookupVpcConnectionResultOutput) ToLookupVpcConnectionResultOutput() LookupVpcConnectionResultOutput

func (LookupVpcConnectionResultOutput) ToLookupVpcConnectionResultOutputWithContext added in v0.60.0 

func (o LookupVpcConnectionResultOutput) ToLookupVpcConnectionResultOutputWithContext(ctx context.Context) LookupVpcConnectionResultOutput

type Replicator added in v0.82.0 

type Replicator struct {
	pulumi.CustomResourceState

	// The current version of the MSK replicator.
	CurrentVersion pulumi.StringPtrOutput `pulumi:"currentVersion"`
	// A summary description of the replicator.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Specifies a list of Kafka clusters which are targets of the replicator.
	KafkaClusters ReplicatorKafkaClusterArrayOutput `pulumi:"kafkaClusters"`
	// A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
	ReplicationInfoList ReplicatorReplicationInfoArrayOutput `pulumi:"replicationInfoList"`
	// Amazon Resource Name for the created replicator.
	ReplicatorArn pulumi.StringOutput `pulumi:"replicatorArn"`
	// The name of the replicator.
	ReplicatorName pulumi.StringOutput `pulumi:"replicatorName"`
	// The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
	ServiceExecutionRoleArn pulumi.StringOutput `pulumi:"serviceExecutionRoleArn"`
	// A collection of tags associated with a resource
	Tags aws.TagArrayOutput `pulumi:"tags"`
}

Resource Type definition for AWS::MSK::Replicator

func GetReplicator added in v0.82.0 

func GetReplicator(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ReplicatorState, opts ...pulumi.ResourceOption) (*Replicator, error)

GetReplicator gets an existing Replicator 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 NewReplicator added in v0.82.0 

func NewReplicator(ctx *pulumi.Context,
	name string, args *ReplicatorArgs, opts ...pulumi.ResourceOption) (*Replicator, error)

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

func (*Replicator) ElementType added in v0.82.0 

func (*Replicator) ElementType() reflect.Type

func (*Replicator) ToReplicatorOutput added in v0.82.0 

func (i *Replicator) ToReplicatorOutput() ReplicatorOutput

func (*Replicator) ToReplicatorOutputWithContext added in v0.82.0 

func (i *Replicator) ToReplicatorOutputWithContext(ctx context.Context) ReplicatorOutput

type ReplicatorAmazonMskCluster added in v0.82.0 

type ReplicatorAmazonMskCluster struct {
	// The ARN of an Amazon MSK cluster.
	MskClusterArn string `pulumi:"mskClusterArn"`
}

Details of an Amazon MSK cluster.

type ReplicatorAmazonMskClusterArgs added in v0.82.0 

type ReplicatorAmazonMskClusterArgs struct {
	// The ARN of an Amazon MSK cluster.
	MskClusterArn pulumi.StringInput `pulumi:"mskClusterArn"`
}

Details of an Amazon MSK cluster.

func (ReplicatorAmazonMskClusterArgs) ElementType added in v0.82.0 

func (ReplicatorAmazonMskClusterArgs) ElementType() reflect.Type

func (ReplicatorAmazonMskClusterArgs) ToReplicatorAmazonMskClusterOutput added in v0.82.0 

func (i ReplicatorAmazonMskClusterArgs) ToReplicatorAmazonMskClusterOutput() ReplicatorAmazonMskClusterOutput

func (ReplicatorAmazonMskClusterArgs) ToReplicatorAmazonMskClusterOutputWithContext added in v0.82.0 

func (i ReplicatorAmazonMskClusterArgs) ToReplicatorAmazonMskClusterOutputWithContext(ctx context.Context) ReplicatorAmazonMskClusterOutput

type ReplicatorAmazonMskClusterInput added in v0.82.0 

type ReplicatorAmazonMskClusterInput interface {
	pulumi.Input

	ToReplicatorAmazonMskClusterOutput() ReplicatorAmazonMskClusterOutput
	ToReplicatorAmazonMskClusterOutputWithContext(context.Context) ReplicatorAmazonMskClusterOutput
}

ReplicatorAmazonMskClusterInput is an input type that accepts ReplicatorAmazonMskClusterArgs and ReplicatorAmazonMskClusterOutput values. You can construct a concrete instance of `ReplicatorAmazonMskClusterInput` via: 

ReplicatorAmazonMskClusterArgs{...}

type ReplicatorAmazonMskClusterOutput added in v0.82.0 

type ReplicatorAmazonMskClusterOutput struct{ *pulumi.OutputState }

Details of an Amazon MSK cluster.

func (ReplicatorAmazonMskClusterOutput) ElementType added in v0.82.0 

func (ReplicatorAmazonMskClusterOutput) ElementType() reflect.Type

func (ReplicatorAmazonMskClusterOutput) MskClusterArn added in v0.82.0 

func (o ReplicatorAmazonMskClusterOutput) MskClusterArn() pulumi.StringOutput

The ARN of an Amazon MSK cluster.

func (ReplicatorAmazonMskClusterOutput) ToReplicatorAmazonMskClusterOutput added in v0.82.0 

func (o ReplicatorAmazonMskClusterOutput) ToReplicatorAmazonMskClusterOutput() ReplicatorAmazonMskClusterOutput

func (ReplicatorAmazonMskClusterOutput) ToReplicatorAmazonMskClusterOutputWithContext added in v0.82.0 

func (o ReplicatorAmazonMskClusterOutput) ToReplicatorAmazonMskClusterOutputWithContext(ctx context.Context) ReplicatorAmazonMskClusterOutput

type ReplicatorArgs added in v0.82.0 

type ReplicatorArgs struct {
	// The current version of the MSK replicator.
	CurrentVersion pulumi.StringPtrInput
	// A summary description of the replicator.
	Description pulumi.StringPtrInput
	// Specifies a list of Kafka clusters which are targets of the replicator.
	KafkaClusters ReplicatorKafkaClusterArrayInput
	// A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.
	ReplicationInfoList ReplicatorReplicationInfoArrayInput
	// The name of the replicator.
	ReplicatorName pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.
	ServiceExecutionRoleArn pulumi.StringInput
	// A collection of tags associated with a resource
	Tags aws.TagArrayInput
}

The set of arguments for constructing a Replicator resource.

func (ReplicatorArgs) ElementType added in v0.82.0 

func (ReplicatorArgs) ElementType() reflect.Type

type ReplicatorConsumerGroupReplication added in v0.82.0 

type ReplicatorConsumerGroupReplication struct {
	// List of regular expression patterns indicating the consumer groups that should not be replicated.
	ConsumerGroupsToExclude []string `pulumi:"consumerGroupsToExclude"`
	// List of regular expression patterns indicating the consumer groups to copy.
	ConsumerGroupsToReplicate []string `pulumi:"consumerGroupsToReplicate"`
	// Whether to periodically check for new consumer groups.
	DetectAndCopyNewConsumerGroups *bool `pulumi:"detectAndCopyNewConsumerGroups"`
	// Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.
	SynchroniseConsumerGroupOffsets *bool `pulumi:"synchroniseConsumerGroupOffsets"`
}

Configuration relating to consumer group replication.

type ReplicatorConsumerGroupReplicationArgs added in v0.82.0 

type ReplicatorConsumerGroupReplicationArgs struct {
	// List of regular expression patterns indicating the consumer groups that should not be replicated.
	ConsumerGroupsToExclude pulumi.StringArrayInput `pulumi:"consumerGroupsToExclude"`
	// List of regular expression patterns indicating the consumer groups to copy.
	ConsumerGroupsToReplicate pulumi.StringArrayInput `pulumi:"consumerGroupsToReplicate"`
	// Whether to periodically check for new consumer groups.
	DetectAndCopyNewConsumerGroups pulumi.BoolPtrInput `pulumi:"detectAndCopyNewConsumerGroups"`
	// Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.
	SynchroniseConsumerGroupOffsets pulumi.BoolPtrInput `pulumi:"synchroniseConsumerGroupOffsets"`
}

Configuration relating to consumer group replication.

func (ReplicatorConsumerGroupReplicationArgs) ElementType added in v0.82.0 

func (ReplicatorConsumerGroupReplicationArgs) ElementType() reflect.Type

func (ReplicatorConsumerGroupReplicationArgs) ToReplicatorConsumerGroupReplicationOutput added in v0.82.0 

func (i ReplicatorConsumerGroupReplicationArgs) ToReplicatorConsumerGroupReplicationOutput() ReplicatorConsumerGroupReplicationOutput

func (ReplicatorConsumerGroupReplicationArgs) ToReplicatorConsumerGroupReplicationOutputWithContext added in v0.82.0 

func (i ReplicatorConsumerGroupReplicationArgs) ToReplicatorConsumerGroupReplicationOutputWithContext(ctx context.Context) ReplicatorConsumerGroupReplicationOutput

type ReplicatorConsumerGroupReplicationInput added in v0.82.0 

type ReplicatorConsumerGroupReplicationInput interface {
	pulumi.Input

	ToReplicatorConsumerGroupReplicationOutput() ReplicatorConsumerGroupReplicationOutput
	ToReplicatorConsumerGroupReplicationOutputWithContext(context.Context) ReplicatorConsumerGroupReplicationOutput
}

ReplicatorConsumerGroupReplicationInput is an input type that accepts ReplicatorConsumerGroupReplicationArgs and ReplicatorConsumerGroupReplicationOutput values. You can construct a concrete instance of `ReplicatorConsumerGroupReplicationInput` via: 

ReplicatorConsumerGroupReplicationArgs{...}

type ReplicatorConsumerGroupReplicationOutput added in v0.82.0 

type ReplicatorConsumerGroupReplicationOutput struct{ *pulumi.OutputState }

Configuration relating to consumer group replication.

func (ReplicatorConsumerGroupReplicationOutput) ConsumerGroupsToExclude added in v0.82.0 

func (o ReplicatorConsumerGroupReplicationOutput) ConsumerGroupsToExclude() pulumi.StringArrayOutput

List of regular expression patterns indicating the consumer groups that should not be replicated.

func (ReplicatorConsumerGroupReplicationOutput) ConsumerGroupsToReplicate added in v0.82.0 

func (o ReplicatorConsumerGroupReplicationOutput) ConsumerGroupsToReplicate() pulumi.StringArrayOutput

List of regular expression patterns indicating the consumer groups to copy.

func (ReplicatorConsumerGroupReplicationOutput) DetectAndCopyNewConsumerGroups added in v0.82.0 

func (o ReplicatorConsumerGroupReplicationOutput) DetectAndCopyNewConsumerGroups() pulumi.BoolPtrOutput

Whether to periodically check for new consumer groups.

func (ReplicatorConsumerGroupReplicationOutput) ElementType added in v0.82.0 

func (ReplicatorConsumerGroupReplicationOutput) ElementType() reflect.Type

func (ReplicatorConsumerGroupReplicationOutput) SynchroniseConsumerGroupOffsets added in v0.82.0 

func (o ReplicatorConsumerGroupReplicationOutput) SynchroniseConsumerGroupOffsets() pulumi.BoolPtrOutput

Whether to periodically write the translated offsets to __consumer_offsets topic in target cluster.

func (ReplicatorConsumerGroupReplicationOutput) ToReplicatorConsumerGroupReplicationOutput added in v0.82.0 

func (o ReplicatorConsumerGroupReplicationOutput) ToReplicatorConsumerGroupReplicationOutput() ReplicatorConsumerGroupReplicationOutput

func (ReplicatorConsumerGroupReplicationOutput) ToReplicatorConsumerGroupReplicationOutputWithContext added in v0.82.0 

func (o ReplicatorConsumerGroupReplicationOutput) ToReplicatorConsumerGroupReplicationOutputWithContext(ctx context.Context) ReplicatorConsumerGroupReplicationOutput

type ReplicatorInput added in v0.82.0 

type ReplicatorInput interface {
	pulumi.Input

	ToReplicatorOutput() ReplicatorOutput
	ToReplicatorOutputWithContext(ctx context.Context) ReplicatorOutput
}

type ReplicatorKafkaCluster added in v0.82.0 

type ReplicatorKafkaCluster struct {
	// Details of an Amazon MSK cluster. Exactly one of AmazonMskCluster is required.
	AmazonMskCluster ReplicatorAmazonMskCluster `pulumi:"amazonMskCluster"`
	// Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
	VpcConfig ReplicatorKafkaClusterClientVpcConfig `pulumi:"vpcConfig"`
}

Details of a Kafka cluster for replication.

type ReplicatorKafkaClusterArgs added in v0.82.0 

type ReplicatorKafkaClusterArgs struct {
	// Details of an Amazon MSK cluster. Exactly one of AmazonMskCluster is required.
	AmazonMskCluster ReplicatorAmazonMskClusterInput `pulumi:"amazonMskCluster"`
	// Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
	VpcConfig ReplicatorKafkaClusterClientVpcConfigInput `pulumi:"vpcConfig"`
}

Details of a Kafka cluster for replication.

func (ReplicatorKafkaClusterArgs) ElementType added in v0.82.0 

func (ReplicatorKafkaClusterArgs) ElementType() reflect.Type

func (ReplicatorKafkaClusterArgs) ToReplicatorKafkaClusterOutput added in v0.82.0 

func (i ReplicatorKafkaClusterArgs) ToReplicatorKafkaClusterOutput() ReplicatorKafkaClusterOutput

func (ReplicatorKafkaClusterArgs) ToReplicatorKafkaClusterOutputWithContext added in v0.82.0 

func (i ReplicatorKafkaClusterArgs) ToReplicatorKafkaClusterOutputWithContext(ctx context.Context) ReplicatorKafkaClusterOutput

type ReplicatorKafkaClusterArray added in v0.82.0 

type ReplicatorKafkaClusterArray []ReplicatorKafkaClusterInput

func (ReplicatorKafkaClusterArray) ElementType added in v0.82.0 

func (ReplicatorKafkaClusterArray) ElementType() reflect.Type

func (ReplicatorKafkaClusterArray) ToReplicatorKafkaClusterArrayOutput added in v0.82.0 

func (i ReplicatorKafkaClusterArray) ToReplicatorKafkaClusterArrayOutput() ReplicatorKafkaClusterArrayOutput

func (ReplicatorKafkaClusterArray) ToReplicatorKafkaClusterArrayOutputWithContext added in v0.82.0 

func (i ReplicatorKafkaClusterArray) ToReplicatorKafkaClusterArrayOutputWithContext(ctx context.Context) ReplicatorKafkaClusterArrayOutput

type ReplicatorKafkaClusterArrayInput added in v0.82.0 

type ReplicatorKafkaClusterArrayInput interface {
	pulumi.Input

	ToReplicatorKafkaClusterArrayOutput() ReplicatorKafkaClusterArrayOutput
	ToReplicatorKafkaClusterArrayOutputWithContext(context.Context) ReplicatorKafkaClusterArrayOutput
}

ReplicatorKafkaClusterArrayInput is an input type that accepts ReplicatorKafkaClusterArray and ReplicatorKafkaClusterArrayOutput values. You can construct a concrete instance of `ReplicatorKafkaClusterArrayInput` via: 

ReplicatorKafkaClusterArray{ ReplicatorKafkaClusterArgs{...} }

type ReplicatorKafkaClusterArrayOutput added in v0.82.0 

type ReplicatorKafkaClusterArrayOutput struct{ *pulumi.OutputState }

func (ReplicatorKafkaClusterArrayOutput) ElementType added in v0.82.0 

func (ReplicatorKafkaClusterArrayOutput) ElementType() reflect.Type

func (ReplicatorKafkaClusterArrayOutput) Index added in v0.82.0 

func (o ReplicatorKafkaClusterArrayOutput) Index(i pulumi.IntInput) ReplicatorKafkaClusterOutput

func (ReplicatorKafkaClusterArrayOutput) ToReplicatorKafkaClusterArrayOutput added in v0.82.0 

func (o ReplicatorKafkaClusterArrayOutput) ToReplicatorKafkaClusterArrayOutput() ReplicatorKafkaClusterArrayOutput

func (ReplicatorKafkaClusterArrayOutput) ToReplicatorKafkaClusterArrayOutputWithContext added in v0.82.0 

func (o ReplicatorKafkaClusterArrayOutput) ToReplicatorKafkaClusterArrayOutputWithContext(ctx context.Context) ReplicatorKafkaClusterArrayOutput

type ReplicatorKafkaClusterClientVpcConfig added in v0.82.0 

type ReplicatorKafkaClusterClientVpcConfig struct {
	// The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.
	SecurityGroupIds []string `pulumi:"securityGroupIds"`
	// The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
	SubnetIds []string `pulumi:"subnetIds"`
}

Details of an Amazon VPC which has network connectivity to the Kafka cluster.

type ReplicatorKafkaClusterClientVpcConfigArgs added in v0.82.0 

type ReplicatorKafkaClusterClientVpcConfigArgs struct {
	// The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.
	SecurityGroupIds pulumi.StringArrayInput `pulumi:"securityGroupIds"`
	// The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
	SubnetIds pulumi.StringArrayInput `pulumi:"subnetIds"`
}

Details of an Amazon VPC which has network connectivity to the Kafka cluster.

func (ReplicatorKafkaClusterClientVpcConfigArgs) ElementType added in v0.82.0 

func (ReplicatorKafkaClusterClientVpcConfigArgs) ElementType() reflect.Type

func (ReplicatorKafkaClusterClientVpcConfigArgs) ToReplicatorKafkaClusterClientVpcConfigOutput added in v0.82.0 

func (i ReplicatorKafkaClusterClientVpcConfigArgs) ToReplicatorKafkaClusterClientVpcConfigOutput() ReplicatorKafkaClusterClientVpcConfigOutput

func (ReplicatorKafkaClusterClientVpcConfigArgs) ToReplicatorKafkaClusterClientVpcConfigOutputWithContext added in v0.82.0 

func (i ReplicatorKafkaClusterClientVpcConfigArgs) ToReplicatorKafkaClusterClientVpcConfigOutputWithContext(ctx context.Context) ReplicatorKafkaClusterClientVpcConfigOutput

type ReplicatorKafkaClusterClientVpcConfigInput added in v0.82.0 

type ReplicatorKafkaClusterClientVpcConfigInput interface {
	pulumi.Input

	ToReplicatorKafkaClusterClientVpcConfigOutput() ReplicatorKafkaClusterClientVpcConfigOutput
	ToReplicatorKafkaClusterClientVpcConfigOutputWithContext(context.Context) ReplicatorKafkaClusterClientVpcConfigOutput
}

ReplicatorKafkaClusterClientVpcConfigInput is an input type that accepts ReplicatorKafkaClusterClientVpcConfigArgs and ReplicatorKafkaClusterClientVpcConfigOutput values. You can construct a concrete instance of `ReplicatorKafkaClusterClientVpcConfigInput` via: 

ReplicatorKafkaClusterClientVpcConfigArgs{...}

type ReplicatorKafkaClusterClientVpcConfigOutput added in v0.82.0 

type ReplicatorKafkaClusterClientVpcConfigOutput struct{ *pulumi.OutputState }

Details of an Amazon VPC which has network connectivity to the Kafka cluster.

func (ReplicatorKafkaClusterClientVpcConfigOutput) ElementType added in v0.82.0 

func (ReplicatorKafkaClusterClientVpcConfigOutput) ElementType() reflect.Type

func (ReplicatorKafkaClusterClientVpcConfigOutput) SecurityGroupIds added in v0.82.0 

func (o ReplicatorKafkaClusterClientVpcConfigOutput) SecurityGroupIds() pulumi.StringArrayOutput

The AWS security groups to associate with the elastic network interfaces in order to specify what the replicator has access to. If a security group is not specified, the default security group associated with the VPC is used.

func (ReplicatorKafkaClusterClientVpcConfigOutput) SubnetIds added in v0.82.0 

func (o ReplicatorKafkaClusterClientVpcConfigOutput) SubnetIds() pulumi.StringArrayOutput

The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

func (ReplicatorKafkaClusterClientVpcConfigOutput) ToReplicatorKafkaClusterClientVpcConfigOutput added in v0.82.0 

func (o ReplicatorKafkaClusterClientVpcConfigOutput) ToReplicatorKafkaClusterClientVpcConfigOutput() ReplicatorKafkaClusterClientVpcConfigOutput

func (ReplicatorKafkaClusterClientVpcConfigOutput) ToReplicatorKafkaClusterClientVpcConfigOutputWithContext added in v0.82.0 

func (o ReplicatorKafkaClusterClientVpcConfigOutput) ToReplicatorKafkaClusterClientVpcConfigOutputWithContext(ctx context.Context) ReplicatorKafkaClusterClientVpcConfigOutput

type ReplicatorKafkaClusterInput added in v0.82.0 

type ReplicatorKafkaClusterInput interface {
	pulumi.Input

	ToReplicatorKafkaClusterOutput() ReplicatorKafkaClusterOutput
	ToReplicatorKafkaClusterOutputWithContext(context.Context) ReplicatorKafkaClusterOutput
}

ReplicatorKafkaClusterInput is an input type that accepts ReplicatorKafkaClusterArgs and ReplicatorKafkaClusterOutput values. You can construct a concrete instance of `ReplicatorKafkaClusterInput` via: 

ReplicatorKafkaClusterArgs{...}

type ReplicatorKafkaClusterOutput added in v0.82.0 

type ReplicatorKafkaClusterOutput struct{ *pulumi.OutputState }

Details of a Kafka cluster for replication.

func (ReplicatorKafkaClusterOutput) AmazonMskCluster added in v0.82.0 

func (o ReplicatorKafkaClusterOutput) AmazonMskCluster() ReplicatorAmazonMskClusterOutput

Details of an Amazon MSK cluster. Exactly one of AmazonMskCluster is required.

func (ReplicatorKafkaClusterOutput) ElementType added in v0.82.0 

func (ReplicatorKafkaClusterOutput) ElementType() reflect.Type

func (ReplicatorKafkaClusterOutput) ToReplicatorKafkaClusterOutput added in v0.82.0 

func (o ReplicatorKafkaClusterOutput) ToReplicatorKafkaClusterOutput() ReplicatorKafkaClusterOutput

func (ReplicatorKafkaClusterOutput) ToReplicatorKafkaClusterOutputWithContext added in v0.82.0 

func (o ReplicatorKafkaClusterOutput) ToReplicatorKafkaClusterOutputWithContext(ctx context.Context) ReplicatorKafkaClusterOutput

func (ReplicatorKafkaClusterOutput) VpcConfig added in v0.82.0 

func (o ReplicatorKafkaClusterOutput) VpcConfig() ReplicatorKafkaClusterClientVpcConfigOutput

Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.

type ReplicatorOutput added in v0.82.0 

type ReplicatorOutput struct{ *pulumi.OutputState }

func (ReplicatorOutput) CurrentVersion added in v0.82.0 

func (o ReplicatorOutput) CurrentVersion() pulumi.StringPtrOutput

The current version of the MSK replicator.

func (ReplicatorOutput) Description added in v0.82.0 

func (o ReplicatorOutput) Description() pulumi.StringPtrOutput

A summary description of the replicator.

func (ReplicatorOutput) ElementType added in v0.82.0 

func (ReplicatorOutput) ElementType() reflect.Type

func (ReplicatorOutput) KafkaClusters added in v0.82.0 

func (o ReplicatorOutput) KafkaClusters() ReplicatorKafkaClusterArrayOutput

Specifies a list of Kafka clusters which are targets of the replicator.

func (ReplicatorOutput) ReplicationInfoList added in v0.82.0 

func (o ReplicatorOutput) ReplicationInfoList() ReplicatorReplicationInfoArrayOutput

A list of replication configurations, where each configuration targets a given source cluster to target cluster replication flow.

func (ReplicatorOutput) ReplicatorArn added in v0.82.0 

func (o ReplicatorOutput) ReplicatorArn() pulumi.StringOutput

Amazon Resource Name for the created replicator.

func (ReplicatorOutput) ReplicatorName added in v0.82.0 

func (o ReplicatorOutput) ReplicatorName() pulumi.StringOutput

The name of the replicator.

func (ReplicatorOutput) ServiceExecutionRoleArn added in v0.82.0 

func (o ReplicatorOutput) ServiceExecutionRoleArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the IAM role used by the replicator to access external resources.

func (ReplicatorOutput) Tags added in v0.82.0 

func (o ReplicatorOutput) Tags() aws.TagArrayOutput

A collection of tags associated with a resource

func (ReplicatorOutput) ToReplicatorOutput added in v0.82.0 

func (o ReplicatorOutput) ToReplicatorOutput() ReplicatorOutput

func (ReplicatorOutput) ToReplicatorOutputWithContext added in v0.82.0 

func (o ReplicatorOutput) ToReplicatorOutputWithContext(ctx context.Context) ReplicatorOutput

type ReplicatorReplicationInfo added in v0.82.0 

type ReplicatorReplicationInfo struct {
	// Configuration relating to consumer group replication.
	ConsumerGroupReplication ReplicatorConsumerGroupReplication `pulumi:"consumerGroupReplication"`
	// Amazon Resource Name of the source Kafka cluster.
	SourceKafkaClusterArn string `pulumi:"sourceKafkaClusterArn"`
	// The type of compression to use writing records to target Kafka cluster.
	TargetCompressionType ReplicatorReplicationInfoTargetCompressionType `pulumi:"targetCompressionType"`
	// Amazon Resource Name of the target Kafka cluster.
	TargetKafkaClusterArn string `pulumi:"targetKafkaClusterArn"`
	// Configuration relating to topic replication.
	TopicReplication ReplicatorTopicReplication `pulumi:"topicReplication"`
}

Specifies configuration for replication between a source and target Kafka cluster.

type ReplicatorReplicationInfoArgs added in v0.82.0 

type ReplicatorReplicationInfoArgs struct {
	// Configuration relating to consumer group replication.
	ConsumerGroupReplication ReplicatorConsumerGroupReplicationInput `pulumi:"consumerGroupReplication"`
	// Amazon Resource Name of the source Kafka cluster.
	SourceKafkaClusterArn pulumi.StringInput `pulumi:"sourceKafkaClusterArn"`
	// The type of compression to use writing records to target Kafka cluster.
	TargetCompressionType ReplicatorReplicationInfoTargetCompressionTypeInput `pulumi:"targetCompressionType"`
	// Amazon Resource Name of the target Kafka cluster.
	TargetKafkaClusterArn pulumi.StringInput `pulumi:"targetKafkaClusterArn"`
	// Configuration relating to topic replication.
	TopicReplication ReplicatorTopicReplicationInput `pulumi:"topicReplication"`
}

Specifies configuration for replication between a source and target Kafka cluster.

func (ReplicatorReplicationInfoArgs) ElementType added in v0.82.0 

func (ReplicatorReplicationInfoArgs) ElementType() reflect.Type

func (ReplicatorReplicationInfoArgs) ToReplicatorReplicationInfoOutput added in v0.82.0 

func (i ReplicatorReplicationInfoArgs) ToReplicatorReplicationInfoOutput() ReplicatorReplicationInfoOutput

func (ReplicatorReplicationInfoArgs) ToReplicatorReplicationInfoOutputWithContext added in v0.82.0 

func (i ReplicatorReplicationInfoArgs) ToReplicatorReplicationInfoOutputWithContext(ctx context.Context) ReplicatorReplicationInfoOutput

type ReplicatorReplicationInfoArray added in v0.82.0 

type ReplicatorReplicationInfoArray []ReplicatorReplicationInfoInput

func (ReplicatorReplicationInfoArray) ElementType added in v0.82.0 

func (ReplicatorReplicationInfoArray) ElementType() reflect.Type

func (ReplicatorReplicationInfoArray) ToReplicatorReplicationInfoArrayOutput added in v0.82.0 

func (i ReplicatorReplicationInfoArray) ToReplicatorReplicationInfoArrayOutput() ReplicatorReplicationInfoArrayOutput

func (ReplicatorReplicationInfoArray) ToReplicatorReplicationInfoArrayOutputWithContext added in v0.82.0 

func (i ReplicatorReplicationInfoArray) ToReplicatorReplicationInfoArrayOutputWithContext(ctx context.Context) ReplicatorReplicationInfoArrayOutput

type ReplicatorReplicationInfoArrayInput added in v0.82.0 

type ReplicatorReplicationInfoArrayInput interface {
	pulumi.Input

	ToReplicatorReplicationInfoArrayOutput() ReplicatorReplicationInfoArrayOutput
	ToReplicatorReplicationInfoArrayOutputWithContext(context.Context) ReplicatorReplicationInfoArrayOutput
}

ReplicatorReplicationInfoArrayInput is an input type that accepts ReplicatorReplicationInfoArray and ReplicatorReplicationInfoArrayOutput values. You can construct a concrete instance of `ReplicatorReplicationInfoArrayInput` via: 

ReplicatorReplicationInfoArray{ ReplicatorReplicationInfoArgs{...} }

type ReplicatorReplicationInfoArrayOutput added in v0.82.0 

type ReplicatorReplicationInfoArrayOutput struct{ *pulumi.OutputState }

func (ReplicatorReplicationInfoArrayOutput) ElementType added in v0.82.0 

func (ReplicatorReplicationInfoArrayOutput) ElementType() reflect.Type

func (ReplicatorReplicationInfoArrayOutput) Index added in v0.82.0 

func (o ReplicatorReplicationInfoArrayOutput) Index(i pulumi.IntInput) ReplicatorReplicationInfoOutput

func (ReplicatorReplicationInfoArrayOutput) ToReplicatorReplicationInfoArrayOutput added in v0.82.0 

func (o ReplicatorReplicationInfoArrayOutput) ToReplicatorReplicationInfoArrayOutput() ReplicatorReplicationInfoArrayOutput

func (ReplicatorReplicationInfoArrayOutput) ToReplicatorReplicationInfoArrayOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoArrayOutput) ToReplicatorReplicationInfoArrayOutputWithContext(ctx context.Context) ReplicatorReplicationInfoArrayOutput

type ReplicatorReplicationInfoInput added in v0.82.0 

type ReplicatorReplicationInfoInput interface {
	pulumi.Input

	ToReplicatorReplicationInfoOutput() ReplicatorReplicationInfoOutput
	ToReplicatorReplicationInfoOutputWithContext(context.Context) ReplicatorReplicationInfoOutput
}

ReplicatorReplicationInfoInput is an input type that accepts ReplicatorReplicationInfoArgs and ReplicatorReplicationInfoOutput values. You can construct a concrete instance of `ReplicatorReplicationInfoInput` via: 

ReplicatorReplicationInfoArgs{...}

type ReplicatorReplicationInfoOutput added in v0.82.0 

type ReplicatorReplicationInfoOutput struct{ *pulumi.OutputState }

Specifies configuration for replication between a source and target Kafka cluster.

func (ReplicatorReplicationInfoOutput) ConsumerGroupReplication added in v0.82.0 

func (o ReplicatorReplicationInfoOutput) ConsumerGroupReplication() ReplicatorConsumerGroupReplicationOutput

Configuration relating to consumer group replication.

func (ReplicatorReplicationInfoOutput) ElementType added in v0.82.0 

func (ReplicatorReplicationInfoOutput) ElementType() reflect.Type

func (ReplicatorReplicationInfoOutput) SourceKafkaClusterArn added in v0.82.0 

func (o ReplicatorReplicationInfoOutput) SourceKafkaClusterArn() pulumi.StringOutput

Amazon Resource Name of the source Kafka cluster.

func (ReplicatorReplicationInfoOutput) TargetCompressionType added in v0.82.0 

func (o ReplicatorReplicationInfoOutput) TargetCompressionType() ReplicatorReplicationInfoTargetCompressionTypeOutput

The type of compression to use writing records to target Kafka cluster.

func (ReplicatorReplicationInfoOutput) TargetKafkaClusterArn added in v0.82.0 

func (o ReplicatorReplicationInfoOutput) TargetKafkaClusterArn() pulumi.StringOutput

Amazon Resource Name of the target Kafka cluster.

func (ReplicatorReplicationInfoOutput) ToReplicatorReplicationInfoOutput added in v0.82.0 

func (o ReplicatorReplicationInfoOutput) ToReplicatorReplicationInfoOutput() ReplicatorReplicationInfoOutput

func (ReplicatorReplicationInfoOutput) ToReplicatorReplicationInfoOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoOutput) ToReplicatorReplicationInfoOutputWithContext(ctx context.Context) ReplicatorReplicationInfoOutput

func (ReplicatorReplicationInfoOutput) TopicReplication added in v0.82.0 

func (o ReplicatorReplicationInfoOutput) TopicReplication() ReplicatorTopicReplicationOutput

Configuration relating to topic replication.

type ReplicatorReplicationInfoTargetCompressionType added in v0.82.0 

type ReplicatorReplicationInfoTargetCompressionType string

The type of compression to use writing records to target Kafka cluster.

func (ReplicatorReplicationInfoTargetCompressionType) ElementType added in v0.82.0 

func (ReplicatorReplicationInfoTargetCompressionType) ElementType() reflect.Type

func (ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypeOutput added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypeOutput() ReplicatorReplicationInfoTargetCompressionTypeOutput

func (ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypeOutputWithContext added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypeOutputWithContext(ctx context.Context) ReplicatorReplicationInfoTargetCompressionTypeOutput

func (ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypePtrOutput added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypePtrOutput() ReplicatorReplicationInfoTargetCompressionTypePtrOutput

func (ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypePtrOutputWithContext added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToReplicatorReplicationInfoTargetCompressionTypePtrOutputWithContext(ctx context.Context) ReplicatorReplicationInfoTargetCompressionTypePtrOutput

func (ReplicatorReplicationInfoTargetCompressionType) ToStringOutput added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToStringOutput() pulumi.StringOutput

func (ReplicatorReplicationInfoTargetCompressionType) ToStringOutputWithContext added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ReplicatorReplicationInfoTargetCompressionType) ToStringPtrOutput added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToStringPtrOutput() pulumi.StringPtrOutput

func (ReplicatorReplicationInfoTargetCompressionType) ToStringPtrOutputWithContext added in v0.82.0 

func (e ReplicatorReplicationInfoTargetCompressionType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ReplicatorReplicationInfoTargetCompressionTypeInput added in v0.82.0 

type ReplicatorReplicationInfoTargetCompressionTypeInput interface {
	pulumi.Input

	ToReplicatorReplicationInfoTargetCompressionTypeOutput() ReplicatorReplicationInfoTargetCompressionTypeOutput
	ToReplicatorReplicationInfoTargetCompressionTypeOutputWithContext(context.Context) ReplicatorReplicationInfoTargetCompressionTypeOutput
}

ReplicatorReplicationInfoTargetCompressionTypeInput is an input type that accepts values of the ReplicatorReplicationInfoTargetCompressionType enum A concrete instance of `ReplicatorReplicationInfoTargetCompressionTypeInput` can be one of the following: 

ReplicatorReplicationInfoTargetCompressionTypeNone
ReplicatorReplicationInfoTargetCompressionTypeGzip
ReplicatorReplicationInfoTargetCompressionTypeSnappy
ReplicatorReplicationInfoTargetCompressionTypeLz4
ReplicatorReplicationInfoTargetCompressionTypeZstd

type ReplicatorReplicationInfoTargetCompressionTypeOutput added in v0.82.0 

type ReplicatorReplicationInfoTargetCompressionTypeOutput struct{ *pulumi.OutputState }

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ElementType added in v0.82.0 

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ElementType() reflect.Type

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypeOutput added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypeOutput() ReplicatorReplicationInfoTargetCompressionTypeOutput

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypeOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypeOutputWithContext(ctx context.Context) ReplicatorReplicationInfoTargetCompressionTypeOutput

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutput added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutput() ReplicatorReplicationInfoTargetCompressionTypePtrOutput

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutputWithContext(ctx context.Context) ReplicatorReplicationInfoTargetCompressionTypePtrOutput

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringOutput added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringOutput() pulumi.StringOutput

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringPtrOutput added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringPtrOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ReplicatorReplicationInfoTargetCompressionTypePtrInput added in v0.82.0 

type ReplicatorReplicationInfoTargetCompressionTypePtrInput interface {
	pulumi.Input

	ToReplicatorReplicationInfoTargetCompressionTypePtrOutput() ReplicatorReplicationInfoTargetCompressionTypePtrOutput
	ToReplicatorReplicationInfoTargetCompressionTypePtrOutputWithContext(context.Context) ReplicatorReplicationInfoTargetCompressionTypePtrOutput
}

func ReplicatorReplicationInfoTargetCompressionTypePtr added in v0.82.0 

func ReplicatorReplicationInfoTargetCompressionTypePtr(v string) ReplicatorReplicationInfoTargetCompressionTypePtrInput

type ReplicatorReplicationInfoTargetCompressionTypePtrOutput added in v0.82.0 

type ReplicatorReplicationInfoTargetCompressionTypePtrOutput struct{ *pulumi.OutputState }

func (ReplicatorReplicationInfoTargetCompressionTypePtrOutput) Elem added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypePtrOutput) Elem() ReplicatorReplicationInfoTargetCompressionTypeOutput

func (ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ElementType added in v0.82.0 

func (ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ElementType() reflect.Type

func (ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutput added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutput() ReplicatorReplicationInfoTargetCompressionTypePtrOutput

func (ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToReplicatorReplicationInfoTargetCompressionTypePtrOutputWithContext(ctx context.Context) ReplicatorReplicationInfoTargetCompressionTypePtrOutput

func (ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToStringPtrOutput added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToStringPtrOutputWithContext added in v0.82.0 

func (o ReplicatorReplicationInfoTargetCompressionTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ReplicatorReplicationStartingPosition added in v0.99.0 

type ReplicatorReplicationStartingPosition struct {
	Type *ReplicatorReplicationStartingPositionType `pulumi:"type"`
}

Configuration for specifying the position in the topics to start replicating from.

type ReplicatorReplicationStartingPositionArgs added in v0.99.0 

type ReplicatorReplicationStartingPositionArgs struct {
	Type ReplicatorReplicationStartingPositionTypePtrInput `pulumi:"type"`
}

Configuration for specifying the position in the topics to start replicating from.

func (ReplicatorReplicationStartingPositionArgs) ElementType added in v0.99.0 

func (ReplicatorReplicationStartingPositionArgs) ElementType() reflect.Type

func (ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionOutput added in v0.99.0 

func (i ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionOutput() ReplicatorReplicationStartingPositionOutput

func (ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionOutputWithContext added in v0.99.0 

func (i ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionOutput

func (ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionPtrOutput added in v0.99.0 

func (i ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionPtrOutput() ReplicatorReplicationStartingPositionPtrOutput

func (ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionPtrOutputWithContext added in v0.99.0 

func (i ReplicatorReplicationStartingPositionArgs) ToReplicatorReplicationStartingPositionPtrOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionPtrOutput

type ReplicatorReplicationStartingPositionInput added in v0.99.0 

type ReplicatorReplicationStartingPositionInput interface {
	pulumi.Input

	ToReplicatorReplicationStartingPositionOutput() ReplicatorReplicationStartingPositionOutput
	ToReplicatorReplicationStartingPositionOutputWithContext(context.Context) ReplicatorReplicationStartingPositionOutput
}

ReplicatorReplicationStartingPositionInput is an input type that accepts ReplicatorReplicationStartingPositionArgs and ReplicatorReplicationStartingPositionOutput values. You can construct a concrete instance of `ReplicatorReplicationStartingPositionInput` via: 

ReplicatorReplicationStartingPositionArgs{...}

type ReplicatorReplicationStartingPositionOutput added in v0.99.0 

type ReplicatorReplicationStartingPositionOutput struct{ *pulumi.OutputState }

Configuration for specifying the position in the topics to start replicating from.

func (ReplicatorReplicationStartingPositionOutput) ElementType added in v0.99.0 

func (ReplicatorReplicationStartingPositionOutput) ElementType() reflect.Type

func (ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionOutput() ReplicatorReplicationStartingPositionOutput

func (ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionOutput

func (ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionPtrOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionPtrOutput() ReplicatorReplicationStartingPositionPtrOutput

func (ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionPtrOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionOutput) ToReplicatorReplicationStartingPositionPtrOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionPtrOutput

func (ReplicatorReplicationStartingPositionOutput) Type added in v0.99.0 

func (o ReplicatorReplicationStartingPositionOutput) Type() ReplicatorReplicationStartingPositionTypePtrOutput

type ReplicatorReplicationStartingPositionPtrInput added in v0.99.0 

type ReplicatorReplicationStartingPositionPtrInput interface {
	pulumi.Input

	ToReplicatorReplicationStartingPositionPtrOutput() ReplicatorReplicationStartingPositionPtrOutput
	ToReplicatorReplicationStartingPositionPtrOutputWithContext(context.Context) ReplicatorReplicationStartingPositionPtrOutput
}

ReplicatorReplicationStartingPositionPtrInput is an input type that accepts ReplicatorReplicationStartingPositionArgs, ReplicatorReplicationStartingPositionPtr and ReplicatorReplicationStartingPositionPtrOutput values. You can construct a concrete instance of `ReplicatorReplicationStartingPositionPtrInput` via: 

        ReplicatorReplicationStartingPositionArgs{...}

or:

        nil

func ReplicatorReplicationStartingPositionPtr added in v0.99.0 

func ReplicatorReplicationStartingPositionPtr(v *ReplicatorReplicationStartingPositionArgs) ReplicatorReplicationStartingPositionPtrInput

type ReplicatorReplicationStartingPositionPtrOutput added in v0.99.0 

type ReplicatorReplicationStartingPositionPtrOutput struct{ *pulumi.OutputState }

func (ReplicatorReplicationStartingPositionPtrOutput) Elem added in v0.99.0 

func (o ReplicatorReplicationStartingPositionPtrOutput) Elem() ReplicatorReplicationStartingPositionOutput

func (ReplicatorReplicationStartingPositionPtrOutput) ElementType added in v0.99.0 

func (ReplicatorReplicationStartingPositionPtrOutput) ElementType() reflect.Type

func (ReplicatorReplicationStartingPositionPtrOutput) ToReplicatorReplicationStartingPositionPtrOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionPtrOutput) ToReplicatorReplicationStartingPositionPtrOutput() ReplicatorReplicationStartingPositionPtrOutput

func (ReplicatorReplicationStartingPositionPtrOutput) ToReplicatorReplicationStartingPositionPtrOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionPtrOutput) ToReplicatorReplicationStartingPositionPtrOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionPtrOutput

func (ReplicatorReplicationStartingPositionPtrOutput) Type added in v0.99.0 

func (o ReplicatorReplicationStartingPositionPtrOutput) Type() ReplicatorReplicationStartingPositionTypePtrOutput

type ReplicatorReplicationStartingPositionType added in v0.99.0 

type ReplicatorReplicationStartingPositionType string

The type of replication starting position.

func (ReplicatorReplicationStartingPositionType) ElementType added in v0.99.0 

func (ReplicatorReplicationStartingPositionType) ElementType() reflect.Type

func (ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypeOutput added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypeOutput() ReplicatorReplicationStartingPositionTypeOutput

func (ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypeOutputWithContext added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypeOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionTypeOutput

func (ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypePtrOutput added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypePtrOutput() ReplicatorReplicationStartingPositionTypePtrOutput

func (ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypePtrOutputWithContext added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToReplicatorReplicationStartingPositionTypePtrOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionTypePtrOutput

func (ReplicatorReplicationStartingPositionType) ToStringOutput added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToStringOutput() pulumi.StringOutput

func (ReplicatorReplicationStartingPositionType) ToStringOutputWithContext added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ReplicatorReplicationStartingPositionType) ToStringPtrOutput added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToStringPtrOutput() pulumi.StringPtrOutput

func (ReplicatorReplicationStartingPositionType) ToStringPtrOutputWithContext added in v0.99.0 

func (e ReplicatorReplicationStartingPositionType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ReplicatorReplicationStartingPositionTypeInput added in v0.99.0 

type ReplicatorReplicationStartingPositionTypeInput interface {
	pulumi.Input

	ToReplicatorReplicationStartingPositionTypeOutput() ReplicatorReplicationStartingPositionTypeOutput
	ToReplicatorReplicationStartingPositionTypeOutputWithContext(context.Context) ReplicatorReplicationStartingPositionTypeOutput
}

ReplicatorReplicationStartingPositionTypeInput is an input type that accepts values of the ReplicatorReplicationStartingPositionType enum A concrete instance of `ReplicatorReplicationStartingPositionTypeInput` can be one of the following: 

ReplicatorReplicationStartingPositionTypeLatest
ReplicatorReplicationStartingPositionTypeEarliest

type ReplicatorReplicationStartingPositionTypeOutput added in v0.99.0 

type ReplicatorReplicationStartingPositionTypeOutput struct{ *pulumi.OutputState }

func (ReplicatorReplicationStartingPositionTypeOutput) ElementType added in v0.99.0 

func (ReplicatorReplicationStartingPositionTypeOutput) ElementType() reflect.Type

func (ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypeOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypeOutput() ReplicatorReplicationStartingPositionTypeOutput

func (ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypeOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypeOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionTypeOutput

func (ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypePtrOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypePtrOutput() ReplicatorReplicationStartingPositionTypePtrOutput

func (ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypePtrOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToReplicatorReplicationStartingPositionTypePtrOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionTypePtrOutput

func (ReplicatorReplicationStartingPositionTypeOutput) ToStringOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToStringOutput() pulumi.StringOutput

func (ReplicatorReplicationStartingPositionTypeOutput) ToStringOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ReplicatorReplicationStartingPositionTypeOutput) ToStringPtrOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ReplicatorReplicationStartingPositionTypeOutput) ToStringPtrOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ReplicatorReplicationStartingPositionTypePtrInput added in v0.99.0 

type ReplicatorReplicationStartingPositionTypePtrInput interface {
	pulumi.Input

	ToReplicatorReplicationStartingPositionTypePtrOutput() ReplicatorReplicationStartingPositionTypePtrOutput
	ToReplicatorReplicationStartingPositionTypePtrOutputWithContext(context.Context) ReplicatorReplicationStartingPositionTypePtrOutput
}

func ReplicatorReplicationStartingPositionTypePtr added in v0.99.0 

func ReplicatorReplicationStartingPositionTypePtr(v string) ReplicatorReplicationStartingPositionTypePtrInput

type ReplicatorReplicationStartingPositionTypePtrOutput added in v0.99.0 

type ReplicatorReplicationStartingPositionTypePtrOutput struct{ *pulumi.OutputState }

func (ReplicatorReplicationStartingPositionTypePtrOutput) Elem added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypePtrOutput) Elem() ReplicatorReplicationStartingPositionTypeOutput

func (ReplicatorReplicationStartingPositionTypePtrOutput) ElementType added in v0.99.0 

func (ReplicatorReplicationStartingPositionTypePtrOutput) ElementType() reflect.Type

func (ReplicatorReplicationStartingPositionTypePtrOutput) ToReplicatorReplicationStartingPositionTypePtrOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypePtrOutput) ToReplicatorReplicationStartingPositionTypePtrOutput() ReplicatorReplicationStartingPositionTypePtrOutput

func (ReplicatorReplicationStartingPositionTypePtrOutput) ToReplicatorReplicationStartingPositionTypePtrOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypePtrOutput) ToReplicatorReplicationStartingPositionTypePtrOutputWithContext(ctx context.Context) ReplicatorReplicationStartingPositionTypePtrOutput

func (ReplicatorReplicationStartingPositionTypePtrOutput) ToStringPtrOutput added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ReplicatorReplicationStartingPositionTypePtrOutput) ToStringPtrOutputWithContext added in v0.99.0 

func (o ReplicatorReplicationStartingPositionTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ReplicatorState added in v0.82.0 

type ReplicatorState struct {
}

func (ReplicatorState) ElementType added in v0.82.0 

func (ReplicatorState) ElementType() reflect.Type

type ReplicatorTag added in v0.82.0 

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

type ReplicatorTopicReplication added in v0.82.0 

type ReplicatorTopicReplication struct {
	// Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
	CopyAccessControlListsForTopics *bool `pulumi:"copyAccessControlListsForTopics"`
	// Whether to periodically configure remote topics to match their corresponding upstream topics.
	CopyTopicConfigurations *bool `pulumi:"copyTopicConfigurations"`
	// Whether to periodically check for new topics and partitions.
	DetectAndCopyNewTopics *bool `pulumi:"detectAndCopyNewTopics"`
	// Configuration for specifying the position in the topics to start replicating from.
	StartingPosition *ReplicatorReplicationStartingPosition `pulumi:"startingPosition"`
	// List of regular expression patterns indicating the topics that should not be replicated.
	TopicsToExclude []string `pulumi:"topicsToExclude"`
	// List of regular expression patterns indicating the topics to copy.
	TopicsToReplicate []string `pulumi:"topicsToReplicate"`
}

type ReplicatorTopicReplicationArgs added in v0.82.0 

type ReplicatorTopicReplicationArgs struct {
	// Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.
	CopyAccessControlListsForTopics pulumi.BoolPtrInput `pulumi:"copyAccessControlListsForTopics"`
	// Whether to periodically configure remote topics to match their corresponding upstream topics.
	CopyTopicConfigurations pulumi.BoolPtrInput `pulumi:"copyTopicConfigurations"`
	// Whether to periodically check for new topics and partitions.
	DetectAndCopyNewTopics pulumi.BoolPtrInput `pulumi:"detectAndCopyNewTopics"`
	// Configuration for specifying the position in the topics to start replicating from.
	StartingPosition ReplicatorReplicationStartingPositionPtrInput `pulumi:"startingPosition"`
	// List of regular expression patterns indicating the topics that should not be replicated.
	TopicsToExclude pulumi.StringArrayInput `pulumi:"topicsToExclude"`
	// List of regular expression patterns indicating the topics to copy.
	TopicsToReplicate pulumi.StringArrayInput `pulumi:"topicsToReplicate"`
}

func (ReplicatorTopicReplicationArgs) ElementType added in v0.82.0 

func (ReplicatorTopicReplicationArgs) ElementType() reflect.Type

func (ReplicatorTopicReplicationArgs) ToReplicatorTopicReplicationOutput added in v0.82.0 

func (i ReplicatorTopicReplicationArgs) ToReplicatorTopicReplicationOutput() ReplicatorTopicReplicationOutput

func (ReplicatorTopicReplicationArgs) ToReplicatorTopicReplicationOutputWithContext added in v0.82.0 

func (i ReplicatorTopicReplicationArgs) ToReplicatorTopicReplicationOutputWithContext(ctx context.Context) ReplicatorTopicReplicationOutput

type ReplicatorTopicReplicationInput added in v0.82.0 

type ReplicatorTopicReplicationInput interface {
	pulumi.Input

	ToReplicatorTopicReplicationOutput() ReplicatorTopicReplicationOutput
	ToReplicatorTopicReplicationOutputWithContext(context.Context) ReplicatorTopicReplicationOutput
}

ReplicatorTopicReplicationInput is an input type that accepts ReplicatorTopicReplicationArgs and ReplicatorTopicReplicationOutput values. You can construct a concrete instance of `ReplicatorTopicReplicationInput` via: 

ReplicatorTopicReplicationArgs{...}

type ReplicatorTopicReplicationOutput added in v0.82.0 

type ReplicatorTopicReplicationOutput struct{ *pulumi.OutputState }

func (ReplicatorTopicReplicationOutput) CopyAccessControlListsForTopics added in v0.82.0 

func (o ReplicatorTopicReplicationOutput) CopyAccessControlListsForTopics() pulumi.BoolPtrOutput

Whether to periodically configure remote topic ACLs to match their corresponding upstream topics.

func (ReplicatorTopicReplicationOutput) CopyTopicConfigurations added in v0.82.0 

func (o ReplicatorTopicReplicationOutput) CopyTopicConfigurations() pulumi.BoolPtrOutput

Whether to periodically configure remote topics to match their corresponding upstream topics.

func (ReplicatorTopicReplicationOutput) DetectAndCopyNewTopics added in v0.82.0 

func (o ReplicatorTopicReplicationOutput) DetectAndCopyNewTopics() pulumi.BoolPtrOutput

Whether to periodically check for new topics and partitions.

func (ReplicatorTopicReplicationOutput) ElementType added in v0.82.0 

func (ReplicatorTopicReplicationOutput) ElementType() reflect.Type

func (ReplicatorTopicReplicationOutput) StartingPosition added in v0.99.0 

func (o ReplicatorTopicReplicationOutput) StartingPosition() ReplicatorReplicationStartingPositionPtrOutput

Configuration for specifying the position in the topics to start replicating from.

func (ReplicatorTopicReplicationOutput) ToReplicatorTopicReplicationOutput added in v0.82.0 

func (o ReplicatorTopicReplicationOutput) ToReplicatorTopicReplicationOutput() ReplicatorTopicReplicationOutput

func (ReplicatorTopicReplicationOutput) ToReplicatorTopicReplicationOutputWithContext added in v0.82.0 

func (o ReplicatorTopicReplicationOutput) ToReplicatorTopicReplicationOutputWithContext(ctx context.Context) ReplicatorTopicReplicationOutput

func (ReplicatorTopicReplicationOutput) TopicsToExclude added in v0.82.0 

func (o ReplicatorTopicReplicationOutput) TopicsToExclude() pulumi.StringArrayOutput

List of regular expression patterns indicating the topics that should not be replicated.

func (ReplicatorTopicReplicationOutput) TopicsToReplicate added in v0.82.0 

func (o ReplicatorTopicReplicationOutput) TopicsToReplicate() pulumi.StringArrayOutput

List of regular expression patterns indicating the topics to copy.

type ServerlessCluster added in v0.21.0 

type ServerlessCluster struct {
	pulumi.CustomResourceState

	Arn pulumi.StringOutput `pulumi:"arn"`
	// Includes all client authentication information.
	ClientAuthentication ServerlessClusterClientAuthenticationOutput `pulumi:"clientAuthentication"`
	ClusterName          pulumi.StringOutput                         `pulumi:"clusterName"`
	// A key-value pair to associate with a resource.
	Tags       pulumi.StringMapOutput                `pulumi:"tags"`
	VpcConfigs ServerlessClusterVpcConfigArrayOutput `pulumi:"vpcConfigs"`
}

Resource Type definition for AWS::MSK::ServerlessCluster

func GetServerlessCluster added in v0.21.0 

func GetServerlessCluster(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ServerlessClusterState, opts ...pulumi.ResourceOption) (*ServerlessCluster, error)

GetServerlessCluster gets an existing ServerlessCluster 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 NewServerlessCluster added in v0.21.0 

func NewServerlessCluster(ctx *pulumi.Context,
	name string, args *ServerlessClusterArgs, opts ...pulumi.ResourceOption) (*ServerlessCluster, error)

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

func (*ServerlessCluster) ElementType added in v0.21.0 

func (*ServerlessCluster) ElementType() reflect.Type

func (*ServerlessCluster) ToServerlessClusterOutput added in v0.21.0 

func (i *ServerlessCluster) ToServerlessClusterOutput() ServerlessClusterOutput

func (*ServerlessCluster) ToServerlessClusterOutputWithContext added in v0.21.0 

func (i *ServerlessCluster) ToServerlessClusterOutputWithContext(ctx context.Context) ServerlessClusterOutput

type ServerlessClusterArgs added in v0.21.0 

type ServerlessClusterArgs struct {
	// Includes all client authentication information.
	ClientAuthentication ServerlessClusterClientAuthenticationInput
	ClusterName          pulumi.StringPtrInput
	// A key-value pair to associate with a resource.
	Tags       pulumi.StringMapInput
	VpcConfigs ServerlessClusterVpcConfigArrayInput
}

The set of arguments for constructing a ServerlessCluster resource.

func (ServerlessClusterArgs) ElementType added in v0.21.0 

func (ServerlessClusterArgs) ElementType() reflect.Type

type ServerlessClusterClientAuthentication added in v0.21.0 

type ServerlessClusterClientAuthentication struct {
	// Details for client authentication using SASL. To turn on SASL, you must also turn on `EncryptionInTransit` by setting `inCluster` to true. You must set `clientBroker` to either `TLS` or `TLS_PLAINTEXT` . If you choose `TLS_PLAINTEXT` , then you must also set `unauthenticated` to true.
	Sasl ServerlessClusterSasl `pulumi:"sasl"`
}

type ServerlessClusterClientAuthenticationArgs added in v0.21.0 

type ServerlessClusterClientAuthenticationArgs struct {
	// Details for client authentication using SASL. To turn on SASL, you must also turn on `EncryptionInTransit` by setting `inCluster` to true. You must set `clientBroker` to either `TLS` or `TLS_PLAINTEXT` . If you choose `TLS_PLAINTEXT` , then you must also set `unauthenticated` to true.
	Sasl ServerlessClusterSaslInput `pulumi:"sasl"`
}

func (ServerlessClusterClientAuthenticationArgs) ElementType added in v0.21.0 

func (ServerlessClusterClientAuthenticationArgs) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationOutput added in v0.21.0 

func (i ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationOutput() ServerlessClusterClientAuthenticationOutput

func (ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationOutputWithContext added in v0.21.0 

func (i ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationOutput

type ServerlessClusterClientAuthenticationInput added in v0.21.0 

type ServerlessClusterClientAuthenticationInput interface {
	pulumi.Input

	ToServerlessClusterClientAuthenticationOutput() ServerlessClusterClientAuthenticationOutput
	ToServerlessClusterClientAuthenticationOutputWithContext(context.Context) ServerlessClusterClientAuthenticationOutput
}

ServerlessClusterClientAuthenticationInput is an input type that accepts ServerlessClusterClientAuthenticationArgs and ServerlessClusterClientAuthenticationOutput values. You can construct a concrete instance of `ServerlessClusterClientAuthenticationInput` via: 

ServerlessClusterClientAuthenticationArgs{...}

type ServerlessClusterClientAuthenticationOutput added in v0.21.0 

type ServerlessClusterClientAuthenticationOutput struct{ *pulumi.OutputState }

func (ServerlessClusterClientAuthenticationOutput) ElementType added in v0.21.0 

func (ServerlessClusterClientAuthenticationOutput) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationOutput) Sasl added in v0.21.0 

func (o ServerlessClusterClientAuthenticationOutput) Sasl() ServerlessClusterSaslOutput

Details for client authentication using SASL. To turn on SASL, you must also turn on `EncryptionInTransit` by setting `inCluster` to true. You must set `clientBroker` to either `TLS` or `TLS_PLAINTEXT` . If you choose `TLS_PLAINTEXT` , then you must also set `unauthenticated` to true.

func (ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationOutput added in v0.21.0 

func (o ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationOutput() ServerlessClusterClientAuthenticationOutput

func (ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationOutputWithContext added in v0.21.0 

func (o ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationOutput

type ServerlessClusterIam added in v0.21.0 

type ServerlessClusterIam struct {
	// SASL/IAM authentication is enabled or not.
	Enabled bool `pulumi:"enabled"`
}

type ServerlessClusterIamArgs added in v0.21.0 

type ServerlessClusterIamArgs struct {
	// SASL/IAM authentication is enabled or not.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ServerlessClusterIamArgs) ElementType added in v0.21.0 

func (ServerlessClusterIamArgs) ElementType() reflect.Type

func (ServerlessClusterIamArgs) ToServerlessClusterIamOutput added in v0.21.0 

func (i ServerlessClusterIamArgs) ToServerlessClusterIamOutput() ServerlessClusterIamOutput

func (ServerlessClusterIamArgs) ToServerlessClusterIamOutputWithContext added in v0.21.0 

func (i ServerlessClusterIamArgs) ToServerlessClusterIamOutputWithContext(ctx context.Context) ServerlessClusterIamOutput

type ServerlessClusterIamInput added in v0.21.0 

type ServerlessClusterIamInput interface {
	pulumi.Input

	ToServerlessClusterIamOutput() ServerlessClusterIamOutput
	ToServerlessClusterIamOutputWithContext(context.Context) ServerlessClusterIamOutput
}

ServerlessClusterIamInput is an input type that accepts ServerlessClusterIamArgs and ServerlessClusterIamOutput values. You can construct a concrete instance of `ServerlessClusterIamInput` via: 

ServerlessClusterIamArgs{...}

type ServerlessClusterIamOutput added in v0.21.0 

type ServerlessClusterIamOutput struct{ *pulumi.OutputState }

func (ServerlessClusterIamOutput) ElementType added in v0.21.0 

func (ServerlessClusterIamOutput) ElementType() reflect.Type

func (ServerlessClusterIamOutput) Enabled added in v0.21.0 

func (o ServerlessClusterIamOutput) Enabled() pulumi.BoolOutput

SASL/IAM authentication is enabled or not.

func (ServerlessClusterIamOutput) ToServerlessClusterIamOutput added in v0.21.0 

func (o ServerlessClusterIamOutput) ToServerlessClusterIamOutput() ServerlessClusterIamOutput

func (ServerlessClusterIamOutput) ToServerlessClusterIamOutputWithContext added in v0.21.0 

func (o ServerlessClusterIamOutput) ToServerlessClusterIamOutputWithContext(ctx context.Context) ServerlessClusterIamOutput

type ServerlessClusterInput added in v0.21.0 

type ServerlessClusterInput interface {
	pulumi.Input

	ToServerlessClusterOutput() ServerlessClusterOutput
	ToServerlessClusterOutputWithContext(ctx context.Context) ServerlessClusterOutput
}

type ServerlessClusterOutput added in v0.21.0 

type ServerlessClusterOutput struct{ *pulumi.OutputState }

func (ServerlessClusterOutput) Arn added in v0.21.0 

func (o ServerlessClusterOutput) Arn() pulumi.StringOutput

func (ServerlessClusterOutput) ClientAuthentication added in v0.21.0 

func (o ServerlessClusterOutput) ClientAuthentication() ServerlessClusterClientAuthenticationOutput

Includes all client authentication information.

func (ServerlessClusterOutput) ClusterName added in v0.21.0 

func (o ServerlessClusterOutput) ClusterName() pulumi.StringOutput

func (ServerlessClusterOutput) ElementType added in v0.21.0 

func (ServerlessClusterOutput) ElementType() reflect.Type

func (ServerlessClusterOutput) Tags added in v0.21.0 

func (o ServerlessClusterOutput) Tags() pulumi.StringMapOutput

A key-value pair to associate with a resource.

func (ServerlessClusterOutput) ToServerlessClusterOutput added in v0.21.0 

func (o ServerlessClusterOutput) ToServerlessClusterOutput() ServerlessClusterOutput

func (ServerlessClusterOutput) ToServerlessClusterOutputWithContext added in v0.21.0 

func (o ServerlessClusterOutput) ToServerlessClusterOutputWithContext(ctx context.Context) ServerlessClusterOutput

func (ServerlessClusterOutput) VpcConfigs added in v0.21.0 

func (o ServerlessClusterOutput) VpcConfigs() ServerlessClusterVpcConfigArrayOutput

type ServerlessClusterSasl added in v0.21.0 

type ServerlessClusterSasl struct {
	// Details for ClientAuthentication using IAM.
	Iam ServerlessClusterIam `pulumi:"iam"`
}

type ServerlessClusterSaslArgs added in v0.21.0 

type ServerlessClusterSaslArgs struct {
	// Details for ClientAuthentication using IAM.
	Iam ServerlessClusterIamInput `pulumi:"iam"`
}

func (ServerlessClusterSaslArgs) ElementType added in v0.21.0 

func (ServerlessClusterSaslArgs) ElementType() reflect.Type

func (ServerlessClusterSaslArgs) ToServerlessClusterSaslOutput added in v0.21.0 

func (i ServerlessClusterSaslArgs) ToServerlessClusterSaslOutput() ServerlessClusterSaslOutput

func (ServerlessClusterSaslArgs) ToServerlessClusterSaslOutputWithContext added in v0.21.0 

func (i ServerlessClusterSaslArgs) ToServerlessClusterSaslOutputWithContext(ctx context.Context) ServerlessClusterSaslOutput

type ServerlessClusterSaslInput added in v0.21.0 

type ServerlessClusterSaslInput interface {
	pulumi.Input

	ToServerlessClusterSaslOutput() ServerlessClusterSaslOutput
	ToServerlessClusterSaslOutputWithContext(context.Context) ServerlessClusterSaslOutput
}

ServerlessClusterSaslInput is an input type that accepts ServerlessClusterSaslArgs and ServerlessClusterSaslOutput values. You can construct a concrete instance of `ServerlessClusterSaslInput` via: 

ServerlessClusterSaslArgs{...}

type ServerlessClusterSaslOutput added in v0.21.0 

type ServerlessClusterSaslOutput struct{ *pulumi.OutputState }

func (ServerlessClusterSaslOutput) ElementType added in v0.21.0 

func (ServerlessClusterSaslOutput) ElementType() reflect.Type

func (ServerlessClusterSaslOutput) Iam added in v0.21.0 

func (o ServerlessClusterSaslOutput) Iam() ServerlessClusterIamOutput

Details for ClientAuthentication using IAM.

func (ServerlessClusterSaslOutput) ToServerlessClusterSaslOutput added in v0.21.0 

func (o ServerlessClusterSaslOutput) ToServerlessClusterSaslOutput() ServerlessClusterSaslOutput

func (ServerlessClusterSaslOutput) ToServerlessClusterSaslOutputWithContext added in v0.21.0 

func (o ServerlessClusterSaslOutput) ToServerlessClusterSaslOutputWithContext(ctx context.Context) ServerlessClusterSaslOutput

type ServerlessClusterState added in v0.21.0 

type ServerlessClusterState struct {
}

func (ServerlessClusterState) ElementType added in v0.21.0 

func (ServerlessClusterState) ElementType() reflect.Type

type ServerlessClusterVpcConfig added in v0.21.0 

type ServerlessClusterVpcConfig struct {
	SecurityGroups []string `pulumi:"securityGroups"`
	SubnetIds      []string `pulumi:"subnetIds"`
}

type ServerlessClusterVpcConfigArgs added in v0.21.0 

type ServerlessClusterVpcConfigArgs struct {
	SecurityGroups pulumi.StringArrayInput `pulumi:"securityGroups"`
	SubnetIds      pulumi.StringArrayInput `pulumi:"subnetIds"`
}

func (ServerlessClusterVpcConfigArgs) ElementType added in v0.21.0 

func (ServerlessClusterVpcConfigArgs) ElementType() reflect.Type

func (ServerlessClusterVpcConfigArgs) ToServerlessClusterVpcConfigOutput added in v0.21.0 

func (i ServerlessClusterVpcConfigArgs) ToServerlessClusterVpcConfigOutput() ServerlessClusterVpcConfigOutput

func (ServerlessClusterVpcConfigArgs) ToServerlessClusterVpcConfigOutputWithContext added in v0.21.0 

func (i ServerlessClusterVpcConfigArgs) ToServerlessClusterVpcConfigOutputWithContext(ctx context.Context) ServerlessClusterVpcConfigOutput

type ServerlessClusterVpcConfigArray added in v0.21.0 

type ServerlessClusterVpcConfigArray []ServerlessClusterVpcConfigInput

func (ServerlessClusterVpcConfigArray) ElementType added in v0.21.0 

func (ServerlessClusterVpcConfigArray) ElementType() reflect.Type

func (ServerlessClusterVpcConfigArray) ToServerlessClusterVpcConfigArrayOutput added in v0.21.0 

func (i ServerlessClusterVpcConfigArray) ToServerlessClusterVpcConfigArrayOutput() ServerlessClusterVpcConfigArrayOutput

func (ServerlessClusterVpcConfigArray) ToServerlessClusterVpcConfigArrayOutputWithContext added in v0.21.0 

func (i ServerlessClusterVpcConfigArray) ToServerlessClusterVpcConfigArrayOutputWithContext(ctx context.Context) ServerlessClusterVpcConfigArrayOutput

type ServerlessClusterVpcConfigArrayInput added in v0.21.0 

type ServerlessClusterVpcConfigArrayInput interface {
	pulumi.Input

	ToServerlessClusterVpcConfigArrayOutput() ServerlessClusterVpcConfigArrayOutput
	ToServerlessClusterVpcConfigArrayOutputWithContext(context.Context) ServerlessClusterVpcConfigArrayOutput
}

ServerlessClusterVpcConfigArrayInput is an input type that accepts ServerlessClusterVpcConfigArray and ServerlessClusterVpcConfigArrayOutput values. You can construct a concrete instance of `ServerlessClusterVpcConfigArrayInput` via: 

ServerlessClusterVpcConfigArray{ ServerlessClusterVpcConfigArgs{...} }

type ServerlessClusterVpcConfigArrayOutput added in v0.21.0 

type ServerlessClusterVpcConfigArrayOutput struct{ *pulumi.OutputState }

func (ServerlessClusterVpcConfigArrayOutput) ElementType added in v0.21.0 

func (ServerlessClusterVpcConfigArrayOutput) ElementType() reflect.Type

func (ServerlessClusterVpcConfigArrayOutput) Index added in v0.21.0 

func (o ServerlessClusterVpcConfigArrayOutput) Index(i pulumi.IntInput) ServerlessClusterVpcConfigOutput

func (ServerlessClusterVpcConfigArrayOutput) ToServerlessClusterVpcConfigArrayOutput added in v0.21.0 

func (o ServerlessClusterVpcConfigArrayOutput) ToServerlessClusterVpcConfigArrayOutput() ServerlessClusterVpcConfigArrayOutput

func (ServerlessClusterVpcConfigArrayOutput) ToServerlessClusterVpcConfigArrayOutputWithContext added in v0.21.0 

func (o ServerlessClusterVpcConfigArrayOutput) ToServerlessClusterVpcConfigArrayOutputWithContext(ctx context.Context) ServerlessClusterVpcConfigArrayOutput

type ServerlessClusterVpcConfigInput added in v0.21.0 

type ServerlessClusterVpcConfigInput interface {
	pulumi.Input

	ToServerlessClusterVpcConfigOutput() ServerlessClusterVpcConfigOutput
	ToServerlessClusterVpcConfigOutputWithContext(context.Context) ServerlessClusterVpcConfigOutput
}

ServerlessClusterVpcConfigInput is an input type that accepts ServerlessClusterVpcConfigArgs and ServerlessClusterVpcConfigOutput values. You can construct a concrete instance of `ServerlessClusterVpcConfigInput` via: 

ServerlessClusterVpcConfigArgs{...}

type ServerlessClusterVpcConfigOutput added in v0.21.0 

type ServerlessClusterVpcConfigOutput struct{ *pulumi.OutputState }

func (ServerlessClusterVpcConfigOutput) ElementType added in v0.21.0 

func (ServerlessClusterVpcConfigOutput) ElementType() reflect.Type

func (ServerlessClusterVpcConfigOutput) SecurityGroups added in v0.21.0 

func (o ServerlessClusterVpcConfigOutput) SecurityGroups() pulumi.StringArrayOutput

func (ServerlessClusterVpcConfigOutput) SubnetIds added in v0.21.0 

func (o ServerlessClusterVpcConfigOutput) SubnetIds() pulumi.StringArrayOutput

func (ServerlessClusterVpcConfigOutput) ToServerlessClusterVpcConfigOutput added in v0.21.0 

func (o ServerlessClusterVpcConfigOutput) ToServerlessClusterVpcConfigOutput() ServerlessClusterVpcConfigOutput

func (ServerlessClusterVpcConfigOutput) ToServerlessClusterVpcConfigOutputWithContext added in v0.21.0 

func (o ServerlessClusterVpcConfigOutput) ToServerlessClusterVpcConfigOutputWithContext(ctx context.Context) ServerlessClusterVpcConfigOutput

type VpcConnection added in v0.60.0 

type VpcConnection struct {
	pulumi.CustomResourceState

	// The ARN of the VPC connection.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// The type of private link authentication.
	Authentication VpcConnectionAuthenticationOutput `pulumi:"authentication"`
	// The list of subnets in the client VPC to connect to.
	ClientSubnets pulumi.StringArrayOutput `pulumi:"clientSubnets"`
	// The security groups to attach to the ENIs for the broker nodes.
	SecurityGroups pulumi.StringArrayOutput `pulumi:"securityGroups"`
	// Create tags when creating the VPC connection.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// The Amazon Resource Name (ARN) of the target cluster
	TargetClusterArn pulumi.StringOutput `pulumi:"targetClusterArn"`
	// The VPC id of the remote client.
	VpcId pulumi.StringOutput `pulumi:"vpcId"`
}

Resource Type definition for AWS::MSK::VpcConnection

func GetVpcConnection added in v0.60.0 

func GetVpcConnection(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *VpcConnectionState, opts ...pulumi.ResourceOption) (*VpcConnection, error)

GetVpcConnection gets an existing VpcConnection 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 NewVpcConnection added in v0.60.0 

func NewVpcConnection(ctx *pulumi.Context,
	name string, args *VpcConnectionArgs, opts ...pulumi.ResourceOption) (*VpcConnection, error)

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

func (*VpcConnection) ElementType added in v0.60.0 

func (*VpcConnection) ElementType() reflect.Type

func (*VpcConnection) ToVpcConnectionOutput added in v0.60.0 

func (i *VpcConnection) ToVpcConnectionOutput() VpcConnectionOutput

func (*VpcConnection) ToVpcConnectionOutputWithContext added in v0.60.0 

func (i *VpcConnection) ToVpcConnectionOutputWithContext(ctx context.Context) VpcConnectionOutput

type VpcConnectionArgs added in v0.60.0 

type VpcConnectionArgs struct {
	// The type of private link authentication.
	Authentication VpcConnectionAuthenticationInput
	// The list of subnets in the client VPC to connect to.
	ClientSubnets pulumi.StringArrayInput
	// The security groups to attach to the ENIs for the broker nodes.
	SecurityGroups pulumi.StringArrayInput
	// Create tags when creating the VPC connection.
	Tags pulumi.StringMapInput
	// The Amazon Resource Name (ARN) of the target cluster
	TargetClusterArn pulumi.StringInput
	// The VPC id of the remote client.
	VpcId pulumi.StringInput
}

The set of arguments for constructing a VpcConnection resource.

func (VpcConnectionArgs) ElementType added in v0.60.0 

func (VpcConnectionArgs) ElementType() reflect.Type

type VpcConnectionAuthentication added in v0.60.0 

type VpcConnectionAuthentication string

The type of private link authentication

func (VpcConnectionAuthentication) ElementType added in v0.60.0 

func (VpcConnectionAuthentication) ElementType() reflect.Type

func (VpcConnectionAuthentication) ToStringOutput added in v0.60.0 

func (e VpcConnectionAuthentication) ToStringOutput() pulumi.StringOutput

func (VpcConnectionAuthentication) ToStringOutputWithContext added in v0.60.0 

func (e VpcConnectionAuthentication) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (VpcConnectionAuthentication) ToStringPtrOutput added in v0.60.0 

func (e VpcConnectionAuthentication) ToStringPtrOutput() pulumi.StringPtrOutput

func (VpcConnectionAuthentication) ToStringPtrOutputWithContext added in v0.60.0 

func (e VpcConnectionAuthentication) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

func (VpcConnectionAuthentication) ToVpcConnectionAuthenticationOutput added in v0.60.0 

func (e VpcConnectionAuthentication) ToVpcConnectionAuthenticationOutput() VpcConnectionAuthenticationOutput

func (VpcConnectionAuthentication) ToVpcConnectionAuthenticationOutputWithContext added in v0.60.0 

func (e VpcConnectionAuthentication) ToVpcConnectionAuthenticationOutputWithContext(ctx context.Context) VpcConnectionAuthenticationOutput

func (VpcConnectionAuthentication) ToVpcConnectionAuthenticationPtrOutput added in v0.60.0 

func (e VpcConnectionAuthentication) ToVpcConnectionAuthenticationPtrOutput() VpcConnectionAuthenticationPtrOutput

func (VpcConnectionAuthentication) ToVpcConnectionAuthenticationPtrOutputWithContext added in v0.60.0 

func (e VpcConnectionAuthentication) ToVpcConnectionAuthenticationPtrOutputWithContext(ctx context.Context) VpcConnectionAuthenticationPtrOutput

type VpcConnectionAuthenticationInput added in v0.60.0 

type VpcConnectionAuthenticationInput interface {
	pulumi.Input

	ToVpcConnectionAuthenticationOutput() VpcConnectionAuthenticationOutput
	ToVpcConnectionAuthenticationOutputWithContext(context.Context) VpcConnectionAuthenticationOutput
}

VpcConnectionAuthenticationInput is an input type that accepts values of the VpcConnectionAuthentication enum A concrete instance of `VpcConnectionAuthenticationInput` can be one of the following: 

VpcConnectionAuthenticationSaslIam
VpcConnectionAuthenticationSaslScram
VpcConnectionAuthenticationTls

type VpcConnectionAuthenticationOutput added in v0.60.0 

type VpcConnectionAuthenticationOutput struct{ *pulumi.OutputState }

func (VpcConnectionAuthenticationOutput) ElementType added in v0.60.0 

func (VpcConnectionAuthenticationOutput) ElementType() reflect.Type

func (VpcConnectionAuthenticationOutput) ToStringOutput added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToStringOutput() pulumi.StringOutput

func (VpcConnectionAuthenticationOutput) ToStringOutputWithContext added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (VpcConnectionAuthenticationOutput) ToStringPtrOutput added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (VpcConnectionAuthenticationOutput) ToStringPtrOutputWithContext added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

func (VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationOutput added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationOutput() VpcConnectionAuthenticationOutput

func (VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationOutputWithContext added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationOutputWithContext(ctx context.Context) VpcConnectionAuthenticationOutput

func (VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationPtrOutput added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationPtrOutput() VpcConnectionAuthenticationPtrOutput

func (VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationPtrOutputWithContext added in v0.60.0 

func (o VpcConnectionAuthenticationOutput) ToVpcConnectionAuthenticationPtrOutputWithContext(ctx context.Context) VpcConnectionAuthenticationPtrOutput

type VpcConnectionAuthenticationPtrInput added in v0.60.0 

type VpcConnectionAuthenticationPtrInput interface {
	pulumi.Input

	ToVpcConnectionAuthenticationPtrOutput() VpcConnectionAuthenticationPtrOutput
	ToVpcConnectionAuthenticationPtrOutputWithContext(context.Context) VpcConnectionAuthenticationPtrOutput
}

func VpcConnectionAuthenticationPtr added in v0.60.0 

func VpcConnectionAuthenticationPtr(v string) VpcConnectionAuthenticationPtrInput

type VpcConnectionAuthenticationPtrOutput added in v0.60.0 

type VpcConnectionAuthenticationPtrOutput struct{ *pulumi.OutputState }

func (VpcConnectionAuthenticationPtrOutput) Elem added in v0.60.0 

func (o VpcConnectionAuthenticationPtrOutput) Elem() VpcConnectionAuthenticationOutput

func (VpcConnectionAuthenticationPtrOutput) ElementType added in v0.60.0 

func (VpcConnectionAuthenticationPtrOutput) ElementType() reflect.Type

func (VpcConnectionAuthenticationPtrOutput) ToStringPtrOutput added in v0.60.0 

func (o VpcConnectionAuthenticationPtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (VpcConnectionAuthenticationPtrOutput) ToStringPtrOutputWithContext added in v0.60.0 

func (o VpcConnectionAuthenticationPtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

func (VpcConnectionAuthenticationPtrOutput) ToVpcConnectionAuthenticationPtrOutput added in v0.60.0 

func (o VpcConnectionAuthenticationPtrOutput) ToVpcConnectionAuthenticationPtrOutput() VpcConnectionAuthenticationPtrOutput

func (VpcConnectionAuthenticationPtrOutput) ToVpcConnectionAuthenticationPtrOutputWithContext added in v0.60.0 

func (o VpcConnectionAuthenticationPtrOutput) ToVpcConnectionAuthenticationPtrOutputWithContext(ctx context.Context) VpcConnectionAuthenticationPtrOutput

type VpcConnectionInput added in v0.60.0 

type VpcConnectionInput interface {
	pulumi.Input

	ToVpcConnectionOutput() VpcConnectionOutput
	ToVpcConnectionOutputWithContext(ctx context.Context) VpcConnectionOutput
}

type VpcConnectionOutput added in v0.60.0 

type VpcConnectionOutput struct{ *pulumi.OutputState }

func (VpcConnectionOutput) Arn added in v0.60.0 

func (o VpcConnectionOutput) Arn() pulumi.StringOutput

The ARN of the VPC connection.

func (VpcConnectionOutput) Authentication added in v0.60.0 

func (o VpcConnectionOutput) Authentication() VpcConnectionAuthenticationOutput

The type of private link authentication.

func (VpcConnectionOutput) ClientSubnets added in v0.60.0 

func (o VpcConnectionOutput) ClientSubnets() pulumi.StringArrayOutput

The list of subnets in the client VPC to connect to.

func (VpcConnectionOutput) ElementType added in v0.60.0 

func (VpcConnectionOutput) ElementType() reflect.Type

func (VpcConnectionOutput) SecurityGroups added in v0.60.0 

func (o VpcConnectionOutput) SecurityGroups() pulumi.StringArrayOutput

The security groups to attach to the ENIs for the broker nodes.

func (VpcConnectionOutput) Tags added in v0.60.0 

func (o VpcConnectionOutput) Tags() pulumi.StringMapOutput

Create tags when creating the VPC connection.

func (VpcConnectionOutput) TargetClusterArn added in v0.60.0 

func (o VpcConnectionOutput) TargetClusterArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the target cluster

func (VpcConnectionOutput) ToVpcConnectionOutput added in v0.60.0 

func (o VpcConnectionOutput) ToVpcConnectionOutput() VpcConnectionOutput

func (VpcConnectionOutput) ToVpcConnectionOutputWithContext added in v0.60.0 

func (o VpcConnectionOutput) ToVpcConnectionOutputWithContext(ctx context.Context) VpcConnectionOutput

func (VpcConnectionOutput) VpcId added in v0.60.0 

func (o VpcConnectionOutput) VpcId() pulumi.StringOutput

The VPC id of the remote client.

type VpcConnectionState added in v0.60.0 

type VpcConnectionState struct {
}

func (VpcConnectionState) ElementType added in v0.60.0 

func (VpcConnectionState) ElementType() reflect.Type

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.