msk

package
v5.43.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cluster 

type Cluster struct {
	pulumi.CustomResourceState

	// Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// Comma separated list of one or more hostname:port pairs of kafka brokers suitable to bootstrap connectivity to the kafka cluster. Contains a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `PLAINTEXT` or `TLS_PLAINTEXT`. The resource sorts values alphabetically. AWS may not always return all endpoints so this value is not guaranteed to be stable across applies.
	BootstrapBrokers pulumi.StringOutput `pulumi:"bootstrapBrokers"`
	// One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicSaslIam pulumi.StringOutput `pulumi:"bootstrapBrokersPublicSaslIam"`
	// One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicSaslScram pulumi.StringOutput `pulumi:"bootstrapBrokersPublicSaslScram"`
	// One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicTls pulumi.StringOutput `pulumi:"bootstrapBrokersPublicTls"`
	// One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersSaslIam pulumi.StringOutput `pulumi:"bootstrapBrokersSaslIam"`
	// One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersSaslScram pulumi.StringOutput `pulumi:"bootstrapBrokersSaslScram"`
	// One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersTls pulumi.StringOutput `pulumi:"bootstrapBrokersTls"`
	// Configuration block for the broker nodes of the Kafka cluster.
	BrokerNodeGroupInfo ClusterBrokerNodeGroupInfoOutput `pulumi:"brokerNodeGroupInfo"`
	// Configuration block for specifying a client authentication. See below.
	ClientAuthentication ClusterClientAuthenticationPtrOutput `pulumi:"clientAuthentication"`
	// Name of the MSK cluster.
	ClusterName pulumi.StringOutput `pulumi:"clusterName"`
	// Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.
	ConfigurationInfo ClusterConfigurationInfoPtrOutput `pulumi:"configurationInfo"`
	// Current version of the MSK Cluster used for updates, e.g., `K13V1IB3VIYZZH`
	// * `encryption_info.0.encryption_at_rest_kms_key_arn` - The ARN of the KMS key used for encryption at rest of the broker data volumes.
	CurrentVersion pulumi.StringOutput `pulumi:"currentVersion"`
	// Configuration block for specifying encryption. See below.
	EncryptionInfo ClusterEncryptionInfoPtrOutput `pulumi:"encryptionInfo"`
	// Specify the desired enhanced MSK CloudWatch monitoring level. See [Monitoring Amazon MSK with Amazon CloudWatch](https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html)
	EnhancedMonitoring pulumi.StringPtrOutput `pulumi:"enhancedMonitoring"`
	// Specify the desired Kafka software version.
	KafkaVersion pulumi.StringOutput `pulumi:"kafkaVersion"`
	// Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.
	LoggingInfo ClusterLoggingInfoPtrOutput `pulumi:"loggingInfo"`
	// The desired total number of broker nodes in the kafka cluster.  It must be a multiple of the number of specified client subnets.
	NumberOfBrokerNodes pulumi.IntOutput `pulumi:"numberOfBrokerNodes"`
	// Configuration block for JMX and Node monitoring for the MSK cluster. See below.
	OpenMonitoring ClusterOpenMonitoringPtrOutput `pulumi:"openMonitoring"`
	// Controls storage mode for supported storage tiers. Valid values are: `LOCAL` or `TIERED`.
	StorageMode pulumi.StringOutput `pulumi:"storageMode"`
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
	ZookeeperConnectString pulumi.StringOutput `pulumi:"zookeeperConnectString"`
	// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster via TLS. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
	ZookeeperConnectStringTls pulumi.StringOutput `pulumi:"zookeeperConnectStringTls"`
}

Manages an Amazon MSK cluster.

> **Note:** This resource manages _provisioned_ clusters. To manage a _serverless_ Amazon MSK cluster, use the `msk.ServerlessCluster` resource.

## Example Usage ### Basic

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/cloudwatch"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/ec2"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/iam"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/kinesis"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/kms"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/s3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		vpc, err := ec2.NewVpc(ctx, "vpc", &ec2.VpcArgs{
			CidrBlock: pulumi.String("192.168.0.0/22"),
		})
		if err != nil {
			return err
		}
		azs, err := aws.GetAvailabilityZones(ctx, &aws.GetAvailabilityZonesArgs{
			State: pulumi.StringRef("available"),
		}, nil)
		if err != nil {
			return err
		}
		subnetAz1, err := ec2.NewSubnet(ctx, "subnetAz1", &ec2.SubnetArgs{
			AvailabilityZone: *pulumi.String(azs.Names[0]),
			CidrBlock:        pulumi.String("192.168.0.0/24"),
			VpcId:            vpc.ID(),
		})
		if err != nil {
			return err
		}
		subnetAz2, err := ec2.NewSubnet(ctx, "subnetAz2", &ec2.SubnetArgs{
			AvailabilityZone: *pulumi.String(azs.Names[1]),
			CidrBlock:        pulumi.String("192.168.1.0/24"),
			VpcId:            vpc.ID(),
		})
		if err != nil {
			return err
		}
		subnetAz3, err := ec2.NewSubnet(ctx, "subnetAz3", &ec2.SubnetArgs{
			AvailabilityZone: *pulumi.String(azs.Names[2]),
			CidrBlock:        pulumi.String("192.168.2.0/24"),
			VpcId:            vpc.ID(),
		})
		if err != nil {
			return err
		}
		sg, err := ec2.NewSecurityGroup(ctx, "sg", &ec2.SecurityGroupArgs{
			VpcId: vpc.ID(),
		})
		if err != nil {
			return err
		}
		kms, err := kms.NewKey(ctx, "kms", &kms.KeyArgs{
			Description: pulumi.String("example"),
		})
		if err != nil {
			return err
		}
		test, err := cloudwatch.NewLogGroup(ctx, "test", nil)
		if err != nil {
			return err
		}
		bucket, err := s3.NewBucketV2(ctx, "bucket", nil)
		if err != nil {
			return err
		}
		_, err = s3.NewBucketAclV2(ctx, "bucketAcl", &s3.BucketAclV2Args{
			Bucket: bucket.ID(),
			Acl:    pulumi.String("private"),
		})
		if err != nil {
			return err
		}
		assumeRole, err := iam.GetPolicyDocument(ctx, &iam.GetPolicyDocumentArgs{
			Statements: []iam.GetPolicyDocumentStatement{
				{
					Effect: pulumi.StringRef("Allow"),
					Principals: []iam.GetPolicyDocumentStatementPrincipal{
						{
							Type: "Service",
							Identifiers: []string{
								"firehose.amazonaws.com",
							},
						},
					},
					Actions: []string{
						"sts:AssumeRole",
					},
				},
			},
		}, nil)
		if err != nil {
			return err
		}
		firehoseRole, err := iam.NewRole(ctx, "firehoseRole", &iam.RoleArgs{
			AssumeRolePolicy: *pulumi.String(assumeRole.Json),
		})
		if err != nil {
			return err
		}
		testStream, err := kinesis.NewFirehoseDeliveryStream(ctx, "testStream", &kinesis.FirehoseDeliveryStreamArgs{
			Destination: pulumi.String("s3"),
			S3Configuration: &kinesis.FirehoseDeliveryStreamS3ConfigurationArgs{
				RoleArn:   firehoseRole.Arn,
				BucketArn: bucket.Arn,
			},
			Tags: pulumi.StringMap{
				"LogDeliveryEnabled": pulumi.String("placeholder"),
			},
		})
		if err != nil {
			return err
		}
		example, err := msk.NewCluster(ctx, "example", &msk.ClusterArgs{
			KafkaVersion:        pulumi.String("3.2.0"),
			NumberOfBrokerNodes: pulumi.Int(3),
			BrokerNodeGroupInfo: &msk.ClusterBrokerNodeGroupInfoArgs{
				InstanceType: pulumi.String("kafka.m5.large"),
				ClientSubnets: pulumi.StringArray{
					subnetAz1.ID(),
					subnetAz2.ID(),
					subnetAz3.ID(),
				},
				StorageInfo: &msk.ClusterBrokerNodeGroupInfoStorageInfoArgs{
					EbsStorageInfo: &msk.ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs{
						VolumeSize: pulumi.Int(1000),
					},
				},
				SecurityGroups: pulumi.StringArray{
					sg.ID(),
				},
			},
			EncryptionInfo: &msk.ClusterEncryptionInfoArgs{
				EncryptionAtRestKmsKeyArn: kms.Arn,
			},
			OpenMonitoring: &msk.ClusterOpenMonitoringArgs{
				Prometheus: &msk.ClusterOpenMonitoringPrometheusArgs{
					JmxExporter: &msk.ClusterOpenMonitoringPrometheusJmxExporterArgs{
						EnabledInBroker: pulumi.Bool(true),
					},
					NodeExporter: &msk.ClusterOpenMonitoringPrometheusNodeExporterArgs{
						EnabledInBroker: pulumi.Bool(true),
					},
				},
			},
			LoggingInfo: &msk.ClusterLoggingInfoArgs{
				BrokerLogs: &msk.ClusterLoggingInfoBrokerLogsArgs{
					CloudwatchLogs: &msk.ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs{
						Enabled:  pulumi.Bool(true),
						LogGroup: test.Name,
					},
					Firehose: &msk.ClusterLoggingInfoBrokerLogsFirehoseArgs{
						Enabled:        pulumi.Bool(true),
						DeliveryStream: testStream.Name,
					},
					S3: &msk.ClusterLoggingInfoBrokerLogsS3Args{
						Enabled: pulumi.Bool(true),
						Bucket:  bucket.ID(),
						Prefix:  pulumi.String("logs/msk-"),
					},
				},
			},
			Tags: pulumi.StringMap{
				"foo": pulumi.String("bar"),
			},
		})
		if err != nil {
			return err
		}
		ctx.Export("zookeeperConnectString", example.ZookeeperConnectString)
		ctx.Export("bootstrapBrokersTls", example.BootstrapBrokersTls)
		return nil
	})
}

``` ### With volumeThroughput argument

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := msk.NewCluster(ctx, "example", &msk.ClusterArgs{
			KafkaVersion:        pulumi.String("2.7.1"),
			NumberOfBrokerNodes: pulumi.Int(3),
			BrokerNodeGroupInfo: &msk.ClusterBrokerNodeGroupInfoArgs{
				InstanceType: pulumi.String("kafka.m5.4xlarge"),
				ClientSubnets: pulumi.StringArray{
					aws_subnet.Subnet_az1.Id,
					aws_subnet.Subnet_az2.Id,
					aws_subnet.Subnet_az3.Id,
				},
				StorageInfo: &msk.ClusterBrokerNodeGroupInfoStorageInfoArgs{
					EbsStorageInfo: &msk.ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs{
						ProvisionedThroughput: &msk.ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs{
							Enabled:          pulumi.Bool(true),
							VolumeThroughput: pulumi.Int(250),
						},
						VolumeSize: pulumi.Int(1000),
					},
				},
				SecurityGroups: pulumi.StringArray{
					aws_security_group.Sg.Id,
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MSK clusters can be imported using the cluster `arn`, e.g.,

```sh 

$ pulumi import aws:msk/cluster:Cluster example arn:aws:kafka:us-west-2:123456789012:cluster/example/279c0212-d057-4dba-9aa9-1c4e5a25bfc7-3

```

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 {
	// Configuration block for the broker nodes of the Kafka cluster.
	BrokerNodeGroupInfo ClusterBrokerNodeGroupInfoInput
	// Configuration block for specifying a client authentication. See below.
	ClientAuthentication ClusterClientAuthenticationPtrInput
	// Name of the MSK cluster.
	ClusterName pulumi.StringPtrInput
	// Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.
	ConfigurationInfo ClusterConfigurationInfoPtrInput
	// Configuration block for specifying encryption. See below.
	EncryptionInfo ClusterEncryptionInfoPtrInput
	// Specify the desired enhanced MSK CloudWatch monitoring level. See [Monitoring Amazon MSK with Amazon CloudWatch](https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html)
	EnhancedMonitoring pulumi.StringPtrInput
	// Specify the desired Kafka software version.
	KafkaVersion pulumi.StringInput
	// Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.
	LoggingInfo ClusterLoggingInfoPtrInput
	// The desired total number of broker nodes in the kafka cluster.  It must be a multiple of the number of specified client subnets.
	NumberOfBrokerNodes pulumi.IntInput
	// Configuration block for JMX and Node monitoring for the MSK cluster. See below.
	OpenMonitoring ClusterOpenMonitoringPtrInput
	// Controls storage mode for supported storage tiers. Valid values are: `LOCAL` or `TIERED`.
	StorageMode pulumi.StringPtrInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
}

The set of arguments for constructing a Cluster resource.

func (ClusterArgs) ElementType 

func (ClusterArgs) ElementType() reflect.Type

type ClusterArray 

type ClusterArray []ClusterInput

func (ClusterArray) ElementType 

func (ClusterArray) ElementType() reflect.Type

func (ClusterArray) ToClusterArrayOutput 

func (i ClusterArray) ToClusterArrayOutput() ClusterArrayOutput

func (ClusterArray) ToClusterArrayOutputWithContext 

func (i ClusterArray) ToClusterArrayOutputWithContext(ctx context.Context) ClusterArrayOutput

type ClusterArrayInput 

type ClusterArrayInput interface {
	pulumi.Input

	ToClusterArrayOutput() ClusterArrayOutput
	ToClusterArrayOutputWithContext(context.Context) ClusterArrayOutput
}

ClusterArrayInput is an input type that accepts ClusterArray and ClusterArrayOutput values. You can construct a concrete instance of `ClusterArrayInput` via: 

ClusterArray{ ClusterArgs{...} }

type ClusterArrayOutput 

type ClusterArrayOutput struct{ *pulumi.OutputState }

func (ClusterArrayOutput) ElementType 

func (ClusterArrayOutput) ElementType() reflect.Type

func (ClusterArrayOutput) Index 

func (o ClusterArrayOutput) Index(i pulumi.IntInput) ClusterOutput

func (ClusterArrayOutput) ToClusterArrayOutput 

func (o ClusterArrayOutput) ToClusterArrayOutput() ClusterArrayOutput

func (ClusterArrayOutput) ToClusterArrayOutputWithContext 

func (o ClusterArrayOutput) ToClusterArrayOutputWithContext(ctx context.Context) ClusterArrayOutput

type ClusterBrokerNodeGroupInfo 

type ClusterBrokerNodeGroupInfo struct {
	// The distribution of broker nodes across availability zones ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-model-brokerazdistribution)). Currently the only valid value is `DEFAULT`.
	AzDistribution *string `pulumi:"azDistribution"`
	// A list of subnets to connect to in client VPC ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-prop-brokernodegroupinfo-clientsubnets)).
	ClientSubnets []string `pulumi:"clientSubnets"`
	// Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible ([documentation](https://docs.aws.amazon.com/msk/latest/developerguide/public-access.html)).
	ConnectivityInfo *ClusterBrokerNodeGroupInfoConnectivityInfo `pulumi:"connectivityInfo"`
	// The size in GiB of the EBS volume for the data drive on each broker node.
	//
	// Deprecated: use 'storage_info' argument instead
	EbsVolumeSize *int `pulumi:"ebsVolumeSize"`
	// Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. ([Pricing info](https://aws.amazon.com/msk/pricing/))
	InstanceType string `pulumi:"instanceType"`
	// A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.
	SecurityGroups []string `pulumi:"securityGroups"`
	// A block that contains information about storage volumes attached to MSK broker nodes. See below.
	StorageInfo *ClusterBrokerNodeGroupInfoStorageInfo `pulumi:"storageInfo"`
}

type ClusterBrokerNodeGroupInfoArgs 

type ClusterBrokerNodeGroupInfoArgs struct {
	// The distribution of broker nodes across availability zones ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-model-brokerazdistribution)). Currently the only valid value is `DEFAULT`.
	AzDistribution pulumi.StringPtrInput `pulumi:"azDistribution"`
	// A list of subnets to connect to in client VPC ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-prop-brokernodegroupinfo-clientsubnets)).
	ClientSubnets pulumi.StringArrayInput `pulumi:"clientSubnets"`
	// Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible ([documentation](https://docs.aws.amazon.com/msk/latest/developerguide/public-access.html)).
	ConnectivityInfo ClusterBrokerNodeGroupInfoConnectivityInfoPtrInput `pulumi:"connectivityInfo"`
	// The size in GiB of the EBS volume for the data drive on each broker node.
	//
	// Deprecated: use 'storage_info' argument instead
	EbsVolumeSize pulumi.IntPtrInput `pulumi:"ebsVolumeSize"`
	// Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. ([Pricing info](https://aws.amazon.com/msk/pricing/))
	InstanceType pulumi.StringInput `pulumi:"instanceType"`
	// A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.
	SecurityGroups pulumi.StringArrayInput `pulumi:"securityGroups"`
	// A block that contains information about storage volumes attached to MSK broker nodes. See below.
	StorageInfo ClusterBrokerNodeGroupInfoStorageInfoPtrInput `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

func (ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoPtrOutput 

func (i ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoPtrOutput() ClusterBrokerNodeGroupInfoPtrOutput

func (ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoPtrOutputWithContext 

func (i ClusterBrokerNodeGroupInfoArgs) ToClusterBrokerNodeGroupInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoPtrOutput

type ClusterBrokerNodeGroupInfoConnectivityInfo added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfo struct {
	// Access control settings for brokers. See below.
	PublicAccess *ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccess `pulumi:"publicAccess"`
}

type ClusterBrokerNodeGroupInfoConnectivityInfoArgs added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoArgs struct {
	// Access control settings for brokers. See below.
	PublicAccess ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrInput `pulumi:"publicAccess"`
}

func (ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ElementType added in v5.5.0 

func (ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoOutput added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoOutput() ClusterBrokerNodeGroupInfoConnectivityInfoOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoOutputWithContext added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutputWithContext added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

type ClusterBrokerNodeGroupInfoConnectivityInfoInput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoConnectivityInfoOutput() ClusterBrokerNodeGroupInfoConnectivityInfoOutput
	ToClusterBrokerNodeGroupInfoConnectivityInfoOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoOutput
}

ClusterBrokerNodeGroupInfoConnectivityInfoInput is an input type that accepts ClusterBrokerNodeGroupInfoConnectivityInfoArgs and ClusterBrokerNodeGroupInfoConnectivityInfoOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoConnectivityInfoInput` via: 

ClusterBrokerNodeGroupInfoConnectivityInfoArgs{...}

type ClusterBrokerNodeGroupInfoConnectivityInfoOutput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ElementType added in v5.5.0 

func (ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoConnectivityInfoOutput) PublicAccess added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoOutput) PublicAccess() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

Access control settings for brokers. See below.

func (ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoOutput added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoOutput() ClusterBrokerNodeGroupInfoConnectivityInfoOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoOutputWithContext added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutputWithContext added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

type ClusterBrokerNodeGroupInfoConnectivityInfoPtrInput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPtrInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput
	ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput
}

ClusterBrokerNodeGroupInfoConnectivityInfoPtrInput is an input type that accepts ClusterBrokerNodeGroupInfoConnectivityInfoArgs, ClusterBrokerNodeGroupInfoConnectivityInfoPtr and ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoConnectivityInfoPtrInput` via: 

        ClusterBrokerNodeGroupInfoConnectivityInfoArgs{...}

or:

        nil

func ClusterBrokerNodeGroupInfoConnectivityInfoPtr added in v5.5.0 

func ClusterBrokerNodeGroupInfoConnectivityInfoPtr(v *ClusterBrokerNodeGroupInfoConnectivityInfoArgs) ClusterBrokerNodeGroupInfoConnectivityInfoPtrInput

type ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) Elem added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) Elem() ClusterBrokerNodeGroupInfoConnectivityInfoOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) ElementType added in v5.5.0 

func (ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) PublicAccess added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) PublicAccess() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

Access control settings for brokers. See below.

func (ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutputWithContext added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccess added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccess struct {
	// Public access type. Valida values: `DISABLED`, `SERVICE_PROVIDED_EIPS`.
	Type *string `pulumi:"type"`
}

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs struct {
	// Public access type. Valida values: `DISABLED`, `SERVICE_PROVIDED_EIPS`.
	Type pulumi.StringPtrInput `pulumi:"type"`
}

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ElementType added in v5.5.0 

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutputWithContext added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutputWithContext added in v5.5.0 

func (i ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessInput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput
	ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput
}

ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessInput is an input type that accepts ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs and ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessInput` via: 

ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs{...}

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ElementType added in v5.5.0 

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutputWithContext added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutputWithContext added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) Type added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput) Type() pulumi.StringPtrOutput

Public access type. Valida values: `DISABLED`, `SERVICE_PROVIDED_EIPS`.

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrInput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput
	ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput
}

ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrInput is an input type that accepts ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs, ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtr and ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrInput` via: 

        ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs{...}

or:

        nil

func ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtr added in v5.5.0 

func ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtr(v *ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessArgs) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrInput

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput added in v5.5.0 

type ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) Elem added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) Elem() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) ElementType added in v5.5.0 

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput() ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutputWithContext added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) ToClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput

func (ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) Type added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoConnectivityInfoPublicAccessPtrOutput) Type() pulumi.StringPtrOutput

Public access type. Valida values: `DISABLED`, `SERVICE_PROVIDED_EIPS`.

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) AzDistribution 

func (o ClusterBrokerNodeGroupInfoOutput) AzDistribution() pulumi.StringPtrOutput

The distribution of broker nodes across availability zones ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-model-brokerazdistribution)). Currently the only valid value is `DEFAULT`.

func (ClusterBrokerNodeGroupInfoOutput) ClientSubnets 

func (o ClusterBrokerNodeGroupInfoOutput) ClientSubnets() pulumi.StringArrayOutput

A list of subnets to connect to in client VPC ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-prop-brokernodegroupinfo-clientsubnets)).

func (ClusterBrokerNodeGroupInfoOutput) ConnectivityInfo added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoOutput) ConnectivityInfo() ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible ([documentation](https://docs.aws.amazon.com/msk/latest/developerguide/public-access.html)).

func (ClusterBrokerNodeGroupInfoOutput) EbsVolumeSize deprecated 

func (o ClusterBrokerNodeGroupInfoOutput) EbsVolumeSize() pulumi.IntPtrOutput

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

Deprecated: use 'storage_info' argument instead

func (ClusterBrokerNodeGroupInfoOutput) ElementType 

func (ClusterBrokerNodeGroupInfoOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoOutput) InstanceType 

func (o ClusterBrokerNodeGroupInfoOutput) InstanceType() pulumi.StringOutput

Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. ([Pricing info](https://aws.amazon.com/msk/pricing/))

func (ClusterBrokerNodeGroupInfoOutput) SecurityGroups 

func (o ClusterBrokerNodeGroupInfoOutput) SecurityGroups() pulumi.StringArrayOutput

A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.

func (ClusterBrokerNodeGroupInfoOutput) StorageInfo added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoOutput) StorageInfo() ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

A block that contains information about storage volumes attached to MSK broker nodes. See below.

func (ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoOutput 

func (o ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoOutput() ClusterBrokerNodeGroupInfoOutput

func (ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoOutputWithContext 

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

func (ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoPtrOutput 

func (o ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoPtrOutput() ClusterBrokerNodeGroupInfoPtrOutput

func (ClusterBrokerNodeGroupInfoOutput) ToClusterBrokerNodeGroupInfoPtrOutputWithContext 

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

type ClusterBrokerNodeGroupInfoPtrInput 

type ClusterBrokerNodeGroupInfoPtrInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoPtrOutput() ClusterBrokerNodeGroupInfoPtrOutput
	ToClusterBrokerNodeGroupInfoPtrOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoPtrOutput
}

ClusterBrokerNodeGroupInfoPtrInput is an input type that accepts ClusterBrokerNodeGroupInfoArgs, ClusterBrokerNodeGroupInfoPtr and ClusterBrokerNodeGroupInfoPtrOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoPtrInput` via: 

        ClusterBrokerNodeGroupInfoArgs{...}

or:

        nil

func ClusterBrokerNodeGroupInfoPtr 

func ClusterBrokerNodeGroupInfoPtr(v *ClusterBrokerNodeGroupInfoArgs) ClusterBrokerNodeGroupInfoPtrInput

type ClusterBrokerNodeGroupInfoPtrOutput 

type ClusterBrokerNodeGroupInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoPtrOutput) AzDistribution 

func (o ClusterBrokerNodeGroupInfoPtrOutput) AzDistribution() pulumi.StringPtrOutput

The distribution of broker nodes across availability zones ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-model-brokerazdistribution)). Currently the only valid value is `DEFAULT`.

func (ClusterBrokerNodeGroupInfoPtrOutput) ClientSubnets 

func (o ClusterBrokerNodeGroupInfoPtrOutput) ClientSubnets() pulumi.StringArrayOutput

A list of subnets to connect to in client VPC ([documentation](https://docs.aws.amazon.com/msk/1.0/apireference/clusters.html#clusters-prop-brokernodegroupinfo-clientsubnets)).

func (ClusterBrokerNodeGroupInfoPtrOutput) ConnectivityInfo added in v5.5.0 

func (o ClusterBrokerNodeGroupInfoPtrOutput) ConnectivityInfo() ClusterBrokerNodeGroupInfoConnectivityInfoPtrOutput

Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible ([documentation](https://docs.aws.amazon.com/msk/latest/developerguide/public-access.html)).

func (ClusterBrokerNodeGroupInfoPtrOutput) EbsVolumeSize deprecated 

func (o ClusterBrokerNodeGroupInfoPtrOutput) EbsVolumeSize() pulumi.IntPtrOutput

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

Deprecated: use 'storage_info' argument instead

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

Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. ([Pricing info](https://aws.amazon.com/msk/pricing/))

func (ClusterBrokerNodeGroupInfoPtrOutput) SecurityGroups 

func (o ClusterBrokerNodeGroupInfoPtrOutput) SecurityGroups() pulumi.StringArrayOutput

A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.

func (ClusterBrokerNodeGroupInfoPtrOutput) StorageInfo added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoPtrOutput) StorageInfo() ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

A block that contains information about storage volumes attached to MSK broker nodes. See below.

func (ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutput 

func (o ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutput() ClusterBrokerNodeGroupInfoPtrOutput

func (ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutputWithContext 

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

type ClusterBrokerNodeGroupInfoStorageInfo added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfo struct {
	// A block that contains EBS volume information. See below.
	EbsStorageInfo *ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfo `pulumi:"ebsStorageInfo"`
}

type ClusterBrokerNodeGroupInfoStorageInfoArgs added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoArgs struct {
	// A block that contains EBS volume information. See below.
	EbsStorageInfo ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrInput `pulumi:"ebsStorageInfo"`
}

func (ClusterBrokerNodeGroupInfoStorageInfoArgs) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoArgs) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoOutput added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoOutput() ClusterBrokerNodeGroupInfoStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoOutputWithContext added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutput added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutputWithContext added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfo added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfo struct {
	// A block that contains EBS volume provisioned throughput information. To provision storage throughput, you must choose broker type kafka.m5.4xlarge or larger. See below.
	ProvisionedThroughput *ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughput `pulumi:"provisionedThroughput"`
	// The size in GiB of the EBS volume for the data drive on each broker node. Minimum value of `1` and maximum value of `16384`.
	VolumeSize *int `pulumi:"volumeSize"`
}

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs struct {
	// A block that contains EBS volume provisioned throughput information. To provision storage throughput, you must choose broker type kafka.m5.4xlarge or larger. See below.
	ProvisionedThroughput ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrInput `pulumi:"provisionedThroughput"`
	// The size in GiB of the EBS volume for the data drive on each broker node. Minimum value of `1` and maximum value of `16384`.
	VolumeSize pulumi.IntPtrInput `pulumi:"volumeSize"`
}

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutputWithContext added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutputWithContext added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoInput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput
	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput
}

ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoInput is an input type that accepts ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs and ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoInput` via: 

ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs{...}

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ProvisionedThroughput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ProvisionedThroughput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

A block that contains EBS volume provisioned throughput information. To provision storage throughput, you must choose broker type kafka.m5.4xlarge or larger. See below.

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) VolumeSize added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput) VolumeSize() pulumi.IntPtrOutput

The size in GiB of the EBS volume for the data drive on each broker node. Minimum value of `1` and maximum value of `16384`.

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughput struct {
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled *bool `pulumi:"enabled"`
	// Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second. The minimum value is `250`. The maximum value varies between broker type. You can refer to the valid values for the maximum volume throughput at the following [documentation on throughput bottlenecks](https://docs.aws.amazon.com/msk/latest/developerguide/msk-provision-throughput.html#throughput-bottlenecks)
	VolumeThroughput *int `pulumi:"volumeThroughput"`
}

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs struct {
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled pulumi.BoolPtrInput `pulumi:"enabled"`
	// Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second. The minimum value is `250`. The maximum value varies between broker type. You can refer to the valid values for the maximum volume throughput at the following [documentation on throughput bottlenecks](https://docs.aws.amazon.com/msk/latest/developerguide/msk-provision-throughput.html#throughput-bottlenecks)
	VolumeThroughput pulumi.IntPtrInput `pulumi:"volumeThroughput"`
}

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutputWithContext added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutputWithContext added in v5.6.0 

func (i ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputInput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput
	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput
}

ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputInput is an input type that accepts ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs and ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputInput` via: 

ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs{...}

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) Enabled added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) Enabled() pulumi.BoolPtrOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) VolumeThroughput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput) VolumeThroughput() pulumi.IntPtrOutput

Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second. The minimum value is `250`. The maximum value varies between broker type. You can refer to the valid values for the maximum volume throughput at the following [documentation on throughput bottlenecks](https://docs.aws.amazon.com/msk/latest/developerguide/msk-provision-throughput.html#throughput-bottlenecks)

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrInput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput
	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput
}

ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrInput is an input type that accepts ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs, ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtr and ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrInput` via: 

        ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs{...}

or:

        nil

func ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtr added in v5.6.0 

func ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtr(v *ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputArgs) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrInput

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) Elem added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) Elem() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) Enabled added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) Enabled() pulumi.BoolPtrOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) VolumeThroughput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput) VolumeThroughput() pulumi.IntPtrOutput

Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second. The minimum value is `250`. The maximum value varies between broker type. You can refer to the valid values for the maximum volume throughput at the following [documentation on throughput bottlenecks](https://docs.aws.amazon.com/msk/latest/developerguide/msk-provision-throughput.html#throughput-bottlenecks)

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrInput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput
	ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput
}

ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrInput is an input type that accepts ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs, ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtr and ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrInput` via: 

        ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs{...}

or:

        nil

func ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtr added in v5.6.0 

func ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtr(v *ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoArgs) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrInput

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) Elem added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) Elem() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ProvisionedThroughput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ProvisionedThroughput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoProvisionedThroughputPtrOutput

A block that contains EBS volume provisioned throughput information. To provision storage throughput, you must choose broker type kafka.m5.4xlarge or larger. See below.

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) VolumeSize added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput) VolumeSize() pulumi.IntPtrOutput

The size in GiB of the EBS volume for the data drive on each broker node. Minimum value of `1` and maximum value of `16384`.

type ClusterBrokerNodeGroupInfoStorageInfoInput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoStorageInfoOutput() ClusterBrokerNodeGroupInfoStorageInfoOutput
	ToClusterBrokerNodeGroupInfoStorageInfoOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoStorageInfoOutput
}

ClusterBrokerNodeGroupInfoStorageInfoInput is an input type that accepts ClusterBrokerNodeGroupInfoStorageInfoArgs and ClusterBrokerNodeGroupInfoStorageInfoOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoStorageInfoInput` via: 

ClusterBrokerNodeGroupInfoStorageInfoArgs{...}

type ClusterBrokerNodeGroupInfoStorageInfoOutput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoStorageInfoOutput) EbsStorageInfo added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoOutput) EbsStorageInfo() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

A block that contains EBS volume information. See below.

func (ClusterBrokerNodeGroupInfoStorageInfoOutput) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoOutput() ClusterBrokerNodeGroupInfoStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

type ClusterBrokerNodeGroupInfoStorageInfoPtrInput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoPtrInput interface {
	pulumi.Input

	ToClusterBrokerNodeGroupInfoStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoPtrOutput
	ToClusterBrokerNodeGroupInfoStorageInfoPtrOutputWithContext(context.Context) ClusterBrokerNodeGroupInfoStorageInfoPtrOutput
}

ClusterBrokerNodeGroupInfoStorageInfoPtrInput is an input type that accepts ClusterBrokerNodeGroupInfoStorageInfoArgs, ClusterBrokerNodeGroupInfoStorageInfoPtr and ClusterBrokerNodeGroupInfoStorageInfoPtrOutput values. You can construct a concrete instance of `ClusterBrokerNodeGroupInfoStorageInfoPtrInput` via: 

        ClusterBrokerNodeGroupInfoStorageInfoArgs{...}

or:

        nil

func ClusterBrokerNodeGroupInfoStorageInfoPtr added in v5.6.0 

func ClusterBrokerNodeGroupInfoStorageInfoPtr(v *ClusterBrokerNodeGroupInfoStorageInfoArgs) ClusterBrokerNodeGroupInfoStorageInfoPtrInput

type ClusterBrokerNodeGroupInfoStorageInfoPtrOutput added in v5.6.0 

type ClusterBrokerNodeGroupInfoStorageInfoPtrOutput struct{ *pulumi.OutputState }

func (ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) EbsStorageInfo added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) EbsStorageInfo() ClusterBrokerNodeGroupInfoStorageInfoEbsStorageInfoPtrOutput

A block that contains EBS volume information. See below.

func (ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) Elem added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) Elem() ClusterBrokerNodeGroupInfoStorageInfoOutput

func (ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) ElementType added in v5.6.0 

func (ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) ElementType() reflect.Type

func (ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutput added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutput() ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

func (ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutputWithContext added in v5.6.0 

func (o ClusterBrokerNodeGroupInfoStorageInfoPtrOutput) ToClusterBrokerNodeGroupInfoStorageInfoPtrOutputWithContext(ctx context.Context) ClusterBrokerNodeGroupInfoStorageInfoPtrOutput

type ClusterClientAuthentication 

type ClusterClientAuthentication struct {
	// Configuration block for specifying SASL client authentication. See below.
	Sasl *ClusterClientAuthenticationSasl `pulumi:"sasl"`
	// Configuration block for specifying TLS client authentication. See below.
	Tls *ClusterClientAuthenticationTls `pulumi:"tls"`
	// Enables unauthenticated access.
	Unauthenticated *bool `pulumi:"unauthenticated"`
}

type ClusterClientAuthenticationArgs 

type ClusterClientAuthenticationArgs struct {
	// Configuration block for specifying SASL client authentication. See below.
	Sasl ClusterClientAuthenticationSaslPtrInput `pulumi:"sasl"`
	// Configuration block for specifying TLS client authentication. See below.
	Tls ClusterClientAuthenticationTlsPtrInput `pulumi:"tls"`
	// Enables unauthenticated access.
	Unauthenticated pulumi.BoolPtrInput `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() ClusterClientAuthenticationSaslPtrOutput

Configuration block for specifying SASL client authentication. See below.

func (ClusterClientAuthenticationOutput) Tls 

func (o ClusterClientAuthenticationOutput) Tls() ClusterClientAuthenticationTlsPtrOutput

Configuration block for specifying TLS client authentication. See below.

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 added in v5.5.0 

func (o ClusterClientAuthenticationOutput) Unauthenticated() pulumi.BoolPtrOutput

Enables unauthenticated access.

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() ClusterClientAuthenticationSaslPtrOutput

Configuration block for specifying SASL client authentication. See below.

func (ClusterClientAuthenticationPtrOutput) Tls 

func (o ClusterClientAuthenticationPtrOutput) Tls() ClusterClientAuthenticationTlsPtrOutput

Configuration block for specifying TLS client authentication. See below.

func (ClusterClientAuthenticationPtrOutput) ToClusterClientAuthenticationPtrOutput 

func (o ClusterClientAuthenticationPtrOutput) ToClusterClientAuthenticationPtrOutput() ClusterClientAuthenticationPtrOutput

func (ClusterClientAuthenticationPtrOutput) ToClusterClientAuthenticationPtrOutputWithContext 

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

func (ClusterClientAuthenticationPtrOutput) Unauthenticated added in v5.5.0 

func (o ClusterClientAuthenticationPtrOutput) Unauthenticated() pulumi.BoolPtrOutput

Enables unauthenticated access.

type ClusterClientAuthenticationSasl 

type ClusterClientAuthenticationSasl struct {
	// Enables IAM client authentication. Defaults to `false`.
	Iam *bool `pulumi:"iam"`
	// Enables SCRAM client authentication via AWS Secrets Manager. Defaults to `false`.
	Scram *bool `pulumi:"scram"`
}

type ClusterClientAuthenticationSaslArgs 

type ClusterClientAuthenticationSaslArgs struct {
	// Enables IAM client authentication. Defaults to `false`.
	Iam pulumi.BoolPtrInput `pulumi:"iam"`
	// Enables SCRAM client authentication via AWS Secrets Manager. Defaults to `false`.
	Scram pulumi.BoolPtrInput `pulumi:"scram"`
}

func (ClusterClientAuthenticationSaslArgs) ElementType 

func (ClusterClientAuthenticationSaslArgs) ElementType() reflect.Type

func (ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslOutput 

func (i ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslOutput() ClusterClientAuthenticationSaslOutput

func (ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslOutputWithContext 

func (i ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslOutputWithContext(ctx context.Context) ClusterClientAuthenticationSaslOutput

func (ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslPtrOutput 

func (i ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslPtrOutput() ClusterClientAuthenticationSaslPtrOutput

func (ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslPtrOutputWithContext 

func (i ClusterClientAuthenticationSaslArgs) ToClusterClientAuthenticationSaslPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationSaslPtrOutput

type ClusterClientAuthenticationSaslInput 

type ClusterClientAuthenticationSaslInput interface {
	pulumi.Input

	ToClusterClientAuthenticationSaslOutput() ClusterClientAuthenticationSaslOutput
	ToClusterClientAuthenticationSaslOutputWithContext(context.Context) ClusterClientAuthenticationSaslOutput
}

ClusterClientAuthenticationSaslInput is an input type that accepts ClusterClientAuthenticationSaslArgs and ClusterClientAuthenticationSaslOutput values. You can construct a concrete instance of `ClusterClientAuthenticationSaslInput` via: 

ClusterClientAuthenticationSaslArgs{...}

type ClusterClientAuthenticationSaslOutput 

type ClusterClientAuthenticationSaslOutput struct{ *pulumi.OutputState }

func (ClusterClientAuthenticationSaslOutput) ElementType 

func (ClusterClientAuthenticationSaslOutput) ElementType() reflect.Type

func (ClusterClientAuthenticationSaslOutput) Iam 

func (o ClusterClientAuthenticationSaslOutput) Iam() pulumi.BoolPtrOutput

Enables IAM client authentication. Defaults to `false`.

func (ClusterClientAuthenticationSaslOutput) Scram 

func (o ClusterClientAuthenticationSaslOutput) Scram() pulumi.BoolPtrOutput

Enables SCRAM client authentication via AWS Secrets Manager. Defaults to `false`.

func (ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslOutput 

func (o ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslOutput() ClusterClientAuthenticationSaslOutput

func (ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslOutputWithContext 

func (o ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslOutputWithContext(ctx context.Context) ClusterClientAuthenticationSaslOutput

func (ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslPtrOutput 

func (o ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslPtrOutput() ClusterClientAuthenticationSaslPtrOutput

func (ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslPtrOutputWithContext 

func (o ClusterClientAuthenticationSaslOutput) ToClusterClientAuthenticationSaslPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationSaslPtrOutput

type ClusterClientAuthenticationSaslPtrInput 

type ClusterClientAuthenticationSaslPtrInput interface {
	pulumi.Input

	ToClusterClientAuthenticationSaslPtrOutput() ClusterClientAuthenticationSaslPtrOutput
	ToClusterClientAuthenticationSaslPtrOutputWithContext(context.Context) ClusterClientAuthenticationSaslPtrOutput
}

ClusterClientAuthenticationSaslPtrInput is an input type that accepts ClusterClientAuthenticationSaslArgs, ClusterClientAuthenticationSaslPtr and ClusterClientAuthenticationSaslPtrOutput values. You can construct a concrete instance of `ClusterClientAuthenticationSaslPtrInput` via: 

        ClusterClientAuthenticationSaslArgs{...}

or:

        nil

func ClusterClientAuthenticationSaslPtr 

func ClusterClientAuthenticationSaslPtr(v *ClusterClientAuthenticationSaslArgs) ClusterClientAuthenticationSaslPtrInput

type ClusterClientAuthenticationSaslPtrOutput 

type ClusterClientAuthenticationSaslPtrOutput struct{ *pulumi.OutputState }

func (ClusterClientAuthenticationSaslPtrOutput) Elem 

func (o ClusterClientAuthenticationSaslPtrOutput) Elem() ClusterClientAuthenticationSaslOutput

func (ClusterClientAuthenticationSaslPtrOutput) ElementType 

func (ClusterClientAuthenticationSaslPtrOutput) ElementType() reflect.Type

func (ClusterClientAuthenticationSaslPtrOutput) Iam 

func (o ClusterClientAuthenticationSaslPtrOutput) Iam() pulumi.BoolPtrOutput

Enables IAM client authentication. Defaults to `false`.

func (ClusterClientAuthenticationSaslPtrOutput) Scram 

func (o ClusterClientAuthenticationSaslPtrOutput) Scram() pulumi.BoolPtrOutput

Enables SCRAM client authentication via AWS Secrets Manager. Defaults to `false`.

func (ClusterClientAuthenticationSaslPtrOutput) ToClusterClientAuthenticationSaslPtrOutput 

func (o ClusterClientAuthenticationSaslPtrOutput) ToClusterClientAuthenticationSaslPtrOutput() ClusterClientAuthenticationSaslPtrOutput

func (ClusterClientAuthenticationSaslPtrOutput) ToClusterClientAuthenticationSaslPtrOutputWithContext 

func (o ClusterClientAuthenticationSaslPtrOutput) ToClusterClientAuthenticationSaslPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationSaslPtrOutput

type ClusterClientAuthenticationTls 

type ClusterClientAuthenticationTls struct {
	// List of ACM Certificate Authority Amazon Resource Names (ARNs).
	CertificateAuthorityArns []string `pulumi:"certificateAuthorityArns"`
}

type ClusterClientAuthenticationTlsArgs 

type ClusterClientAuthenticationTlsArgs struct {
	// List of ACM Certificate Authority Amazon Resource Names (ARNs).
	CertificateAuthorityArns pulumi.StringArrayInput `pulumi:"certificateAuthorityArns"`
}

func (ClusterClientAuthenticationTlsArgs) ElementType 

func (ClusterClientAuthenticationTlsArgs) ElementType() reflect.Type

func (ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsOutput 

func (i ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsOutput() ClusterClientAuthenticationTlsOutput

func (ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsOutputWithContext 

func (i ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsOutputWithContext(ctx context.Context) ClusterClientAuthenticationTlsOutput

func (ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsPtrOutput 

func (i ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsPtrOutput() ClusterClientAuthenticationTlsPtrOutput

func (ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsPtrOutputWithContext 

func (i ClusterClientAuthenticationTlsArgs) ToClusterClientAuthenticationTlsPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationTlsPtrOutput

type ClusterClientAuthenticationTlsInput 

type ClusterClientAuthenticationTlsInput interface {
	pulumi.Input

	ToClusterClientAuthenticationTlsOutput() ClusterClientAuthenticationTlsOutput
	ToClusterClientAuthenticationTlsOutputWithContext(context.Context) ClusterClientAuthenticationTlsOutput
}

ClusterClientAuthenticationTlsInput is an input type that accepts ClusterClientAuthenticationTlsArgs and ClusterClientAuthenticationTlsOutput values. You can construct a concrete instance of `ClusterClientAuthenticationTlsInput` via: 

ClusterClientAuthenticationTlsArgs{...}

type ClusterClientAuthenticationTlsOutput 

type ClusterClientAuthenticationTlsOutput struct{ *pulumi.OutputState }

func (ClusterClientAuthenticationTlsOutput) CertificateAuthorityArns 

func (o ClusterClientAuthenticationTlsOutput) CertificateAuthorityArns() pulumi.StringArrayOutput

List of ACM Certificate Authority Amazon Resource Names (ARNs).

func (ClusterClientAuthenticationTlsOutput) ElementType 

func (ClusterClientAuthenticationTlsOutput) ElementType() reflect.Type

func (ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsOutput 

func (o ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsOutput() ClusterClientAuthenticationTlsOutput

func (ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsOutputWithContext 

func (o ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsOutputWithContext(ctx context.Context) ClusterClientAuthenticationTlsOutput

func (ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsPtrOutput 

func (o ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsPtrOutput() ClusterClientAuthenticationTlsPtrOutput

func (ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsPtrOutputWithContext 

func (o ClusterClientAuthenticationTlsOutput) ToClusterClientAuthenticationTlsPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationTlsPtrOutput

type ClusterClientAuthenticationTlsPtrInput 

type ClusterClientAuthenticationTlsPtrInput interface {
	pulumi.Input

	ToClusterClientAuthenticationTlsPtrOutput() ClusterClientAuthenticationTlsPtrOutput
	ToClusterClientAuthenticationTlsPtrOutputWithContext(context.Context) ClusterClientAuthenticationTlsPtrOutput
}

ClusterClientAuthenticationTlsPtrInput is an input type that accepts ClusterClientAuthenticationTlsArgs, ClusterClientAuthenticationTlsPtr and ClusterClientAuthenticationTlsPtrOutput values. You can construct a concrete instance of `ClusterClientAuthenticationTlsPtrInput` via: 

        ClusterClientAuthenticationTlsArgs{...}

or:

        nil

func ClusterClientAuthenticationTlsPtr 

func ClusterClientAuthenticationTlsPtr(v *ClusterClientAuthenticationTlsArgs) ClusterClientAuthenticationTlsPtrInput

type ClusterClientAuthenticationTlsPtrOutput 

type ClusterClientAuthenticationTlsPtrOutput struct{ *pulumi.OutputState }

func (ClusterClientAuthenticationTlsPtrOutput) CertificateAuthorityArns 

func (o ClusterClientAuthenticationTlsPtrOutput) CertificateAuthorityArns() pulumi.StringArrayOutput

List of ACM Certificate Authority Amazon Resource Names (ARNs).

func (ClusterClientAuthenticationTlsPtrOutput) Elem 

func (o ClusterClientAuthenticationTlsPtrOutput) Elem() ClusterClientAuthenticationTlsOutput

func (ClusterClientAuthenticationTlsPtrOutput) ElementType 

func (ClusterClientAuthenticationTlsPtrOutput) ElementType() reflect.Type

func (ClusterClientAuthenticationTlsPtrOutput) ToClusterClientAuthenticationTlsPtrOutput 

func (o ClusterClientAuthenticationTlsPtrOutput) ToClusterClientAuthenticationTlsPtrOutput() ClusterClientAuthenticationTlsPtrOutput

func (ClusterClientAuthenticationTlsPtrOutput) ToClusterClientAuthenticationTlsPtrOutputWithContext 

func (o ClusterClientAuthenticationTlsPtrOutput) ToClusterClientAuthenticationTlsPtrOutputWithContext(ctx context.Context) ClusterClientAuthenticationTlsPtrOutput

type ClusterConfigurationInfo 

type ClusterConfigurationInfo struct {
	// Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.
	Arn string `pulumi:"arn"`
	// Revision of the MSK Configuration to use in the cluster.
	Revision int `pulumi:"revision"`
}

type ClusterConfigurationInfoArgs 

type ClusterConfigurationInfoArgs struct {
	// Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.
	Arn pulumi.StringInput `pulumi:"arn"`
	// Revision of the MSK Configuration to use in the cluster.
	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

Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

func (ClusterConfigurationInfoOutput) ElementType 

func (ClusterConfigurationInfoOutput) ElementType() reflect.Type

func (ClusterConfigurationInfoOutput) Revision 

func (o ClusterConfigurationInfoOutput) Revision() pulumi.IntOutput

Revision of the MSK Configuration to use in the cluster.

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

Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

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

Revision of the MSK Configuration to use in the cluster.

func (ClusterConfigurationInfoPtrOutput) ToClusterConfigurationInfoPtrOutput 

func (o ClusterConfigurationInfoPtrOutput) ToClusterConfigurationInfoPtrOutput() ClusterConfigurationInfoPtrOutput

func (ClusterConfigurationInfoPtrOutput) ToClusterConfigurationInfoPtrOutputWithContext 

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

type ClusterEncryptionInfo 

type ClusterEncryptionInfo struct {
	// You may specify a KMS key short ID or ARN (it will always output an ARN) to use for encrypting your data at rest.  If no key is specified, an AWS managed KMS ('aws/msk' managed service) key will be used for encrypting the data at rest.
	EncryptionAtRestKmsKeyArn *string `pulumi:"encryptionAtRestKmsKeyArn"`
	// Configuration block to specify encryption in transit. See below.
	EncryptionInTransit *ClusterEncryptionInfoEncryptionInTransit `pulumi:"encryptionInTransit"`
}

type ClusterEncryptionInfoArgs 

type ClusterEncryptionInfoArgs struct {
	// You may specify a KMS key short ID or ARN (it will always output an ARN) to use for encrypting your data at rest.  If no key is specified, an AWS managed KMS ('aws/msk' managed service) key will be used for encrypting the data at rest.
	EncryptionAtRestKmsKeyArn pulumi.StringPtrInput `pulumi:"encryptionAtRestKmsKeyArn"`
	// Configuration block to specify encryption in transit. See below.
	EncryptionInTransit ClusterEncryptionInfoEncryptionInTransitPtrInput `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 ClusterEncryptionInfoEncryptionInTransit 

type ClusterEncryptionInfoEncryptionInTransit struct {
	// Encryption setting for data in transit between clients and brokers. Valid values: `TLS`, `TLS_PLAINTEXT`, and `PLAINTEXT`. Default value is `TLS`.
	ClientBroker *string `pulumi:"clientBroker"`
	// Whether data communication among broker nodes is encrypted. Default value: `true`.
	InCluster *bool `pulumi:"inCluster"`
}

type ClusterEncryptionInfoEncryptionInTransitArgs 

type ClusterEncryptionInfoEncryptionInTransitArgs struct {
	// Encryption setting for data in transit between clients and brokers. Valid values: `TLS`, `TLS_PLAINTEXT`, and `PLAINTEXT`. Default value is `TLS`.
	ClientBroker pulumi.StringPtrInput `pulumi:"clientBroker"`
	// Whether data communication among broker nodes is encrypted. Default value: `true`.
	InCluster pulumi.BoolPtrInput `pulumi:"inCluster"`
}

func (ClusterEncryptionInfoEncryptionInTransitArgs) ElementType 

func (ClusterEncryptionInfoEncryptionInTransitArgs) ElementType() reflect.Type

func (ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitOutput 

func (i ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitOutput() ClusterEncryptionInfoEncryptionInTransitOutput

func (ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitOutputWithContext 

func (i ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitOutputWithContext(ctx context.Context) ClusterEncryptionInfoEncryptionInTransitOutput

func (ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitPtrOutput 

func (i ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitPtrOutput() ClusterEncryptionInfoEncryptionInTransitPtrOutput

func (ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitPtrOutputWithContext 

func (i ClusterEncryptionInfoEncryptionInTransitArgs) ToClusterEncryptionInfoEncryptionInTransitPtrOutputWithContext(ctx context.Context) ClusterEncryptionInfoEncryptionInTransitPtrOutput

type ClusterEncryptionInfoEncryptionInTransitInput 

type ClusterEncryptionInfoEncryptionInTransitInput interface {
	pulumi.Input

	ToClusterEncryptionInfoEncryptionInTransitOutput() ClusterEncryptionInfoEncryptionInTransitOutput
	ToClusterEncryptionInfoEncryptionInTransitOutputWithContext(context.Context) ClusterEncryptionInfoEncryptionInTransitOutput
}

ClusterEncryptionInfoEncryptionInTransitInput is an input type that accepts ClusterEncryptionInfoEncryptionInTransitArgs and ClusterEncryptionInfoEncryptionInTransitOutput values. You can construct a concrete instance of `ClusterEncryptionInfoEncryptionInTransitInput` via: 

ClusterEncryptionInfoEncryptionInTransitArgs{...}

type ClusterEncryptionInfoEncryptionInTransitOutput 

type ClusterEncryptionInfoEncryptionInTransitOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInfoEncryptionInTransitOutput) ClientBroker 

func (o ClusterEncryptionInfoEncryptionInTransitOutput) ClientBroker() pulumi.StringPtrOutput

Encryption setting for data in transit between clients and brokers. Valid values: `TLS`, `TLS_PLAINTEXT`, and `PLAINTEXT`. Default value is `TLS`.

func (ClusterEncryptionInfoEncryptionInTransitOutput) ElementType 

func (ClusterEncryptionInfoEncryptionInTransitOutput) ElementType() reflect.Type

func (ClusterEncryptionInfoEncryptionInTransitOutput) InCluster 

func (o ClusterEncryptionInfoEncryptionInTransitOutput) InCluster() pulumi.BoolPtrOutput

Whether data communication among broker nodes is encrypted. Default value: `true`.

func (ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitOutput 

func (o ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitOutput() ClusterEncryptionInfoEncryptionInTransitOutput

func (ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitOutputWithContext 

func (o ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitOutputWithContext(ctx context.Context) ClusterEncryptionInfoEncryptionInTransitOutput

func (ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutput 

func (o ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutput() ClusterEncryptionInfoEncryptionInTransitPtrOutput

func (ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutputWithContext 

func (o ClusterEncryptionInfoEncryptionInTransitOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutputWithContext(ctx context.Context) ClusterEncryptionInfoEncryptionInTransitPtrOutput

type ClusterEncryptionInfoEncryptionInTransitPtrInput 

type ClusterEncryptionInfoEncryptionInTransitPtrInput interface {
	pulumi.Input

	ToClusterEncryptionInfoEncryptionInTransitPtrOutput() ClusterEncryptionInfoEncryptionInTransitPtrOutput
	ToClusterEncryptionInfoEncryptionInTransitPtrOutputWithContext(context.Context) ClusterEncryptionInfoEncryptionInTransitPtrOutput
}

ClusterEncryptionInfoEncryptionInTransitPtrInput is an input type that accepts ClusterEncryptionInfoEncryptionInTransitArgs, ClusterEncryptionInfoEncryptionInTransitPtr and ClusterEncryptionInfoEncryptionInTransitPtrOutput values. You can construct a concrete instance of `ClusterEncryptionInfoEncryptionInTransitPtrInput` via: 

        ClusterEncryptionInfoEncryptionInTransitArgs{...}

or:

        nil

func ClusterEncryptionInfoEncryptionInTransitPtr 

func ClusterEncryptionInfoEncryptionInTransitPtr(v *ClusterEncryptionInfoEncryptionInTransitArgs) ClusterEncryptionInfoEncryptionInTransitPtrInput

type ClusterEncryptionInfoEncryptionInTransitPtrOutput 

type ClusterEncryptionInfoEncryptionInTransitPtrOutput struct{ *pulumi.OutputState }

func (ClusterEncryptionInfoEncryptionInTransitPtrOutput) ClientBroker 

func (o ClusterEncryptionInfoEncryptionInTransitPtrOutput) ClientBroker() pulumi.StringPtrOutput

Encryption setting for data in transit between clients and brokers. Valid values: `TLS`, `TLS_PLAINTEXT`, and `PLAINTEXT`. Default value is `TLS`.

func (ClusterEncryptionInfoEncryptionInTransitPtrOutput) Elem 

func (o ClusterEncryptionInfoEncryptionInTransitPtrOutput) Elem() ClusterEncryptionInfoEncryptionInTransitOutput

func (ClusterEncryptionInfoEncryptionInTransitPtrOutput) ElementType 

func (ClusterEncryptionInfoEncryptionInTransitPtrOutput) ElementType() reflect.Type

func (ClusterEncryptionInfoEncryptionInTransitPtrOutput) InCluster 

func (o ClusterEncryptionInfoEncryptionInTransitPtrOutput) InCluster() pulumi.BoolPtrOutput

Whether data communication among broker nodes is encrypted. Default value: `true`.

func (ClusterEncryptionInfoEncryptionInTransitPtrOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutput 

func (o ClusterEncryptionInfoEncryptionInTransitPtrOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutput() ClusterEncryptionInfoEncryptionInTransitPtrOutput

func (ClusterEncryptionInfoEncryptionInTransitPtrOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutputWithContext 

func (o ClusterEncryptionInfoEncryptionInTransitPtrOutput) ToClusterEncryptionInfoEncryptionInTransitPtrOutputWithContext(ctx context.Context) ClusterEncryptionInfoEncryptionInTransitPtrOutput

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) EncryptionAtRestKmsKeyArn 

func (o ClusterEncryptionInfoOutput) EncryptionAtRestKmsKeyArn() pulumi.StringPtrOutput

You may specify a KMS key short ID or ARN (it will always output an ARN) to use for encrypting your data at rest. If no key is specified, an AWS managed KMS ('aws/msk' managed service) key will be used for encrypting the data at rest.

func (ClusterEncryptionInfoOutput) EncryptionInTransit 

func (o ClusterEncryptionInfoOutput) EncryptionInTransit() ClusterEncryptionInfoEncryptionInTransitPtrOutput

Configuration block to specify encryption in transit. See below.

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) EncryptionAtRestKmsKeyArn 

func (o ClusterEncryptionInfoPtrOutput) EncryptionAtRestKmsKeyArn() pulumi.StringPtrOutput

You may specify a KMS key short ID or ARN (it will always output an ARN) to use for encrypting your data at rest. If no key is specified, an AWS managed KMS ('aws/msk' managed service) key will be used for encrypting the data at rest.

func (ClusterEncryptionInfoPtrOutput) EncryptionInTransit 

func (o ClusterEncryptionInfoPtrOutput) EncryptionInTransit() ClusterEncryptionInfoEncryptionInTransitPtrOutput

Configuration block to specify encryption in transit. See below.

func (ClusterEncryptionInfoPtrOutput) ToClusterEncryptionInfoPtrOutput 

func (o ClusterEncryptionInfoPtrOutput) ToClusterEncryptionInfoPtrOutput() ClusterEncryptionInfoPtrOutput

func (ClusterEncryptionInfoPtrOutput) ToClusterEncryptionInfoPtrOutputWithContext 

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

type ClusterInput 

type ClusterInput interface {
	pulumi.Input

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

type ClusterLoggingInfo 

type ClusterLoggingInfo struct {
	// Configuration block for Broker Logs settings for logging info. See below.
	BrokerLogs ClusterLoggingInfoBrokerLogs `pulumi:"brokerLogs"`
}

type ClusterLoggingInfoArgs 

type ClusterLoggingInfoArgs struct {
	// Configuration block for Broker Logs settings for logging info. See below.
	BrokerLogs ClusterLoggingInfoBrokerLogsInput `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 ClusterLoggingInfoBrokerLogs 

type ClusterLoggingInfoBrokerLogs struct {
	CloudwatchLogs *ClusterLoggingInfoBrokerLogsCloudwatchLogs `pulumi:"cloudwatchLogs"`
	Firehose       *ClusterLoggingInfoBrokerLogsFirehose       `pulumi:"firehose"`
	S3             *ClusterLoggingInfoBrokerLogsS3             `pulumi:"s3"`
}

type ClusterLoggingInfoBrokerLogsArgs 

type ClusterLoggingInfoBrokerLogsArgs struct {
	CloudwatchLogs ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrInput `pulumi:"cloudwatchLogs"`
	Firehose       ClusterLoggingInfoBrokerLogsFirehosePtrInput       `pulumi:"firehose"`
	S3             ClusterLoggingInfoBrokerLogsS3PtrInput             `pulumi:"s3"`
}

func (ClusterLoggingInfoBrokerLogsArgs) ElementType 

func (ClusterLoggingInfoBrokerLogsArgs) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsOutput 

func (i ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsOutput() ClusterLoggingInfoBrokerLogsOutput

func (ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsOutputWithContext 

func (i ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsOutput

func (ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsPtrOutput 

func (i ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsPtrOutput() ClusterLoggingInfoBrokerLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsPtrOutputWithContext 

func (i ClusterLoggingInfoBrokerLogsArgs) ToClusterLoggingInfoBrokerLogsPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsPtrOutput

type ClusterLoggingInfoBrokerLogsCloudwatchLogs 

type ClusterLoggingInfoBrokerLogsCloudwatchLogs struct {
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled bool `pulumi:"enabled"`
	// Name of the Cloudwatch Log Group to deliver logs to.
	LogGroup *string `pulumi:"logGroup"`
}

type ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs 

type ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs struct {
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// Name of the Cloudwatch Log Group to deliver logs to.
	LogGroup pulumi.StringPtrInput `pulumi:"logGroup"`
}

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ElementType 

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutput 

func (i ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutput() ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutputWithContext 

func (i ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput 

func (i ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput() ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutputWithContext 

func (i ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

type ClusterLoggingInfoBrokerLogsCloudwatchLogsInput 

type ClusterLoggingInfoBrokerLogsCloudwatchLogsInput interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutput() ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput
	ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput
}

ClusterLoggingInfoBrokerLogsCloudwatchLogsInput is an input type that accepts ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs and ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsCloudwatchLogsInput` via: 

ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs{...}

type ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput 

type ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ElementType 

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) Enabled 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) Enabled() pulumi.BoolOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) LogGroup 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) LogGroup() pulumi.StringPtrOutput

Name of the Cloudwatch Log Group to deliver logs to.

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutput 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutput() ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput() ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

type ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrInput 

type ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrInput interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput() ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput
	ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput
}

ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrInput is an input type that accepts ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs, ClusterLoggingInfoBrokerLogsCloudwatchLogsPtr and ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrInput` via: 

        ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs{...}

or:

        nil

func ClusterLoggingInfoBrokerLogsCloudwatchLogsPtr 

func ClusterLoggingInfoBrokerLogsCloudwatchLogsPtr(v *ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs) ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrInput

type ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput 

type ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) Elem 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) Elem() ClusterLoggingInfoBrokerLogsCloudwatchLogsOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) ElementType 

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) Enabled 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) Enabled() pulumi.BoolPtrOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) LogGroup 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) LogGroup() pulumi.StringPtrOutput

Name of the Cloudwatch Log Group to deliver logs to.

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput() ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput) ToClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

type ClusterLoggingInfoBrokerLogsFirehose 

type ClusterLoggingInfoBrokerLogsFirehose struct {
	// Name of the Kinesis Data Firehose delivery stream to deliver logs to.
	DeliveryStream *string `pulumi:"deliveryStream"`
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled bool `pulumi:"enabled"`
}

type ClusterLoggingInfoBrokerLogsFirehoseArgs 

type ClusterLoggingInfoBrokerLogsFirehoseArgs struct {
	// Name of the Kinesis Data Firehose delivery stream to deliver logs to.
	DeliveryStream pulumi.StringPtrInput `pulumi:"deliveryStream"`
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ClusterLoggingInfoBrokerLogsFirehoseArgs) ElementType 

func (ClusterLoggingInfoBrokerLogsFirehoseArgs) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehoseOutput 

func (i ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehoseOutput() ClusterLoggingInfoBrokerLogsFirehoseOutput

func (ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehoseOutputWithContext 

func (i ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehoseOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsFirehoseOutput

func (ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehosePtrOutput 

func (i ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehosePtrOutput() ClusterLoggingInfoBrokerLogsFirehosePtrOutput

func (ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehosePtrOutputWithContext 

func (i ClusterLoggingInfoBrokerLogsFirehoseArgs) ToClusterLoggingInfoBrokerLogsFirehosePtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsFirehosePtrOutput

type ClusterLoggingInfoBrokerLogsFirehoseInput 

type ClusterLoggingInfoBrokerLogsFirehoseInput interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsFirehoseOutput() ClusterLoggingInfoBrokerLogsFirehoseOutput
	ToClusterLoggingInfoBrokerLogsFirehoseOutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsFirehoseOutput
}

ClusterLoggingInfoBrokerLogsFirehoseInput is an input type that accepts ClusterLoggingInfoBrokerLogsFirehoseArgs and ClusterLoggingInfoBrokerLogsFirehoseOutput values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsFirehoseInput` via: 

ClusterLoggingInfoBrokerLogsFirehoseArgs{...}

type ClusterLoggingInfoBrokerLogsFirehoseOutput 

type ClusterLoggingInfoBrokerLogsFirehoseOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) DeliveryStream 

func (o ClusterLoggingInfoBrokerLogsFirehoseOutput) DeliveryStream() pulumi.StringPtrOutput

Name of the Kinesis Data Firehose delivery stream to deliver logs to.

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) ElementType 

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) Enabled 

func (o ClusterLoggingInfoBrokerLogsFirehoseOutput) Enabled() pulumi.BoolOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehoseOutput 

func (o ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehoseOutput() ClusterLoggingInfoBrokerLogsFirehoseOutput

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehoseOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehoseOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsFirehoseOutput

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutput 

func (o ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutput() ClusterLoggingInfoBrokerLogsFirehosePtrOutput

func (ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsFirehoseOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsFirehosePtrOutput

type ClusterLoggingInfoBrokerLogsFirehosePtrInput 

type ClusterLoggingInfoBrokerLogsFirehosePtrInput interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsFirehosePtrOutput() ClusterLoggingInfoBrokerLogsFirehosePtrOutput
	ToClusterLoggingInfoBrokerLogsFirehosePtrOutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsFirehosePtrOutput
}

ClusterLoggingInfoBrokerLogsFirehosePtrInput is an input type that accepts ClusterLoggingInfoBrokerLogsFirehoseArgs, ClusterLoggingInfoBrokerLogsFirehosePtr and ClusterLoggingInfoBrokerLogsFirehosePtrOutput values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsFirehosePtrInput` via: 

        ClusterLoggingInfoBrokerLogsFirehoseArgs{...}

or:

        nil

func ClusterLoggingInfoBrokerLogsFirehosePtr 

func ClusterLoggingInfoBrokerLogsFirehosePtr(v *ClusterLoggingInfoBrokerLogsFirehoseArgs) ClusterLoggingInfoBrokerLogsFirehosePtrInput

type ClusterLoggingInfoBrokerLogsFirehosePtrOutput 

type ClusterLoggingInfoBrokerLogsFirehosePtrOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsFirehosePtrOutput) DeliveryStream 

func (o ClusterLoggingInfoBrokerLogsFirehosePtrOutput) DeliveryStream() pulumi.StringPtrOutput

Name of the Kinesis Data Firehose delivery stream to deliver logs to.

func (ClusterLoggingInfoBrokerLogsFirehosePtrOutput) Elem 

func (o ClusterLoggingInfoBrokerLogsFirehosePtrOutput) Elem() ClusterLoggingInfoBrokerLogsFirehoseOutput

func (ClusterLoggingInfoBrokerLogsFirehosePtrOutput) ElementType 

func (ClusterLoggingInfoBrokerLogsFirehosePtrOutput) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsFirehosePtrOutput) Enabled 

func (o ClusterLoggingInfoBrokerLogsFirehosePtrOutput) Enabled() pulumi.BoolPtrOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterLoggingInfoBrokerLogsFirehosePtrOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutput 

func (o ClusterLoggingInfoBrokerLogsFirehosePtrOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutput() ClusterLoggingInfoBrokerLogsFirehosePtrOutput

func (ClusterLoggingInfoBrokerLogsFirehosePtrOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsFirehosePtrOutput) ToClusterLoggingInfoBrokerLogsFirehosePtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsFirehosePtrOutput

type ClusterLoggingInfoBrokerLogsInput 

type ClusterLoggingInfoBrokerLogsInput interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsOutput() ClusterLoggingInfoBrokerLogsOutput
	ToClusterLoggingInfoBrokerLogsOutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsOutput
}

ClusterLoggingInfoBrokerLogsInput is an input type that accepts ClusterLoggingInfoBrokerLogsArgs and ClusterLoggingInfoBrokerLogsOutput values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsInput` via: 

ClusterLoggingInfoBrokerLogsArgs{...}

type ClusterLoggingInfoBrokerLogsOutput 

type ClusterLoggingInfoBrokerLogsOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsOutput) CloudwatchLogs 

func (o ClusterLoggingInfoBrokerLogsOutput) CloudwatchLogs() ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsOutput) ElementType 

func (ClusterLoggingInfoBrokerLogsOutput) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsOutput) Firehose 

func (o ClusterLoggingInfoBrokerLogsOutput) Firehose() ClusterLoggingInfoBrokerLogsFirehosePtrOutput

func (ClusterLoggingInfoBrokerLogsOutput) S3 

func (o ClusterLoggingInfoBrokerLogsOutput) S3() ClusterLoggingInfoBrokerLogsS3PtrOutput

func (ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsOutput 

func (o ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsOutput() ClusterLoggingInfoBrokerLogsOutput

func (ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsOutput

func (ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsPtrOutput 

func (o ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsPtrOutput() ClusterLoggingInfoBrokerLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsPtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsOutput) ToClusterLoggingInfoBrokerLogsPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsPtrOutput

type ClusterLoggingInfoBrokerLogsPtrInput 

type ClusterLoggingInfoBrokerLogsPtrInput interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsPtrOutput() ClusterLoggingInfoBrokerLogsPtrOutput
	ToClusterLoggingInfoBrokerLogsPtrOutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsPtrOutput
}

ClusterLoggingInfoBrokerLogsPtrInput is an input type that accepts ClusterLoggingInfoBrokerLogsArgs, ClusterLoggingInfoBrokerLogsPtr and ClusterLoggingInfoBrokerLogsPtrOutput values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsPtrInput` via: 

        ClusterLoggingInfoBrokerLogsArgs{...}

or:

        nil

func ClusterLoggingInfoBrokerLogsPtr 

func ClusterLoggingInfoBrokerLogsPtr(v *ClusterLoggingInfoBrokerLogsArgs) ClusterLoggingInfoBrokerLogsPtrInput

type ClusterLoggingInfoBrokerLogsPtrOutput 

type ClusterLoggingInfoBrokerLogsPtrOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsPtrOutput) CloudwatchLogs 

func (o ClusterLoggingInfoBrokerLogsPtrOutput) CloudwatchLogs() ClusterLoggingInfoBrokerLogsCloudwatchLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsPtrOutput) Elem 

func (o ClusterLoggingInfoBrokerLogsPtrOutput) Elem() ClusterLoggingInfoBrokerLogsOutput

func (ClusterLoggingInfoBrokerLogsPtrOutput) ElementType 

func (ClusterLoggingInfoBrokerLogsPtrOutput) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsPtrOutput) Firehose 

func (o ClusterLoggingInfoBrokerLogsPtrOutput) Firehose() ClusterLoggingInfoBrokerLogsFirehosePtrOutput

func (ClusterLoggingInfoBrokerLogsPtrOutput) S3 

func (o ClusterLoggingInfoBrokerLogsPtrOutput) S3() ClusterLoggingInfoBrokerLogsS3PtrOutput

func (ClusterLoggingInfoBrokerLogsPtrOutput) ToClusterLoggingInfoBrokerLogsPtrOutput 

func (o ClusterLoggingInfoBrokerLogsPtrOutput) ToClusterLoggingInfoBrokerLogsPtrOutput() ClusterLoggingInfoBrokerLogsPtrOutput

func (ClusterLoggingInfoBrokerLogsPtrOutput) ToClusterLoggingInfoBrokerLogsPtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsPtrOutput) ToClusterLoggingInfoBrokerLogsPtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsPtrOutput

type ClusterLoggingInfoBrokerLogsS3 

type ClusterLoggingInfoBrokerLogsS3 struct {
	// Name of the S3 bucket to deliver logs to.
	Bucket *string `pulumi:"bucket"`
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled bool `pulumi:"enabled"`
	// Prefix to append to the folder name.
	Prefix *string `pulumi:"prefix"`
}

type ClusterLoggingInfoBrokerLogsS3Args 

type ClusterLoggingInfoBrokerLogsS3Args struct {
	// Name of the S3 bucket to deliver logs to.
	Bucket pulumi.StringPtrInput `pulumi:"bucket"`
	// Controls whether provisioned throughput is enabled or not. Default value: `false`.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// Prefix to append to the folder name.
	Prefix pulumi.StringPtrInput `pulumi:"prefix"`
}

func (ClusterLoggingInfoBrokerLogsS3Args) ElementType 

func (ClusterLoggingInfoBrokerLogsS3Args) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3Output 

func (i ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3Output() ClusterLoggingInfoBrokerLogsS3Output

func (ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3OutputWithContext 

func (i ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3OutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsS3Output

func (ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3PtrOutput 

func (i ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3PtrOutput() ClusterLoggingInfoBrokerLogsS3PtrOutput

func (ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3PtrOutputWithContext 

func (i ClusterLoggingInfoBrokerLogsS3Args) ToClusterLoggingInfoBrokerLogsS3PtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsS3PtrOutput

type ClusterLoggingInfoBrokerLogsS3Input 

type ClusterLoggingInfoBrokerLogsS3Input interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsS3Output() ClusterLoggingInfoBrokerLogsS3Output
	ToClusterLoggingInfoBrokerLogsS3OutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsS3Output
}

ClusterLoggingInfoBrokerLogsS3Input is an input type that accepts ClusterLoggingInfoBrokerLogsS3Args and ClusterLoggingInfoBrokerLogsS3Output values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsS3Input` via: 

ClusterLoggingInfoBrokerLogsS3Args{...}

type ClusterLoggingInfoBrokerLogsS3Output 

type ClusterLoggingInfoBrokerLogsS3Output struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsS3Output) Bucket 

func (o ClusterLoggingInfoBrokerLogsS3Output) Bucket() pulumi.StringPtrOutput

Name of the S3 bucket to deliver logs to.

func (ClusterLoggingInfoBrokerLogsS3Output) ElementType 

func (ClusterLoggingInfoBrokerLogsS3Output) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsS3Output) Enabled 

func (o ClusterLoggingInfoBrokerLogsS3Output) Enabled() pulumi.BoolOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterLoggingInfoBrokerLogsS3Output) Prefix 

func (o ClusterLoggingInfoBrokerLogsS3Output) Prefix() pulumi.StringPtrOutput

Prefix to append to the folder name.

func (ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3Output 

func (o ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3Output() ClusterLoggingInfoBrokerLogsS3Output

func (ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3OutputWithContext 

func (o ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3OutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsS3Output

func (ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3PtrOutput 

func (o ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3PtrOutput() ClusterLoggingInfoBrokerLogsS3PtrOutput

func (ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3PtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsS3Output) ToClusterLoggingInfoBrokerLogsS3PtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsS3PtrOutput

type ClusterLoggingInfoBrokerLogsS3PtrInput 

type ClusterLoggingInfoBrokerLogsS3PtrInput interface {
	pulumi.Input

	ToClusterLoggingInfoBrokerLogsS3PtrOutput() ClusterLoggingInfoBrokerLogsS3PtrOutput
	ToClusterLoggingInfoBrokerLogsS3PtrOutputWithContext(context.Context) ClusterLoggingInfoBrokerLogsS3PtrOutput
}

ClusterLoggingInfoBrokerLogsS3PtrInput is an input type that accepts ClusterLoggingInfoBrokerLogsS3Args, ClusterLoggingInfoBrokerLogsS3Ptr and ClusterLoggingInfoBrokerLogsS3PtrOutput values. You can construct a concrete instance of `ClusterLoggingInfoBrokerLogsS3PtrInput` via: 

        ClusterLoggingInfoBrokerLogsS3Args{...}

or:

        nil

func ClusterLoggingInfoBrokerLogsS3Ptr 

func ClusterLoggingInfoBrokerLogsS3Ptr(v *ClusterLoggingInfoBrokerLogsS3Args) ClusterLoggingInfoBrokerLogsS3PtrInput

type ClusterLoggingInfoBrokerLogsS3PtrOutput 

type ClusterLoggingInfoBrokerLogsS3PtrOutput struct{ *pulumi.OutputState }

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) Bucket 

func (o ClusterLoggingInfoBrokerLogsS3PtrOutput) Bucket() pulumi.StringPtrOutput

Name of the S3 bucket to deliver logs to.

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) Elem 

func (o ClusterLoggingInfoBrokerLogsS3PtrOutput) Elem() ClusterLoggingInfoBrokerLogsS3Output

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) ElementType 

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) ElementType() reflect.Type

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) Enabled 

func (o ClusterLoggingInfoBrokerLogsS3PtrOutput) Enabled() pulumi.BoolPtrOutput

Controls whether provisioned throughput is enabled or not. Default value: `false`.

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) Prefix 

func (o ClusterLoggingInfoBrokerLogsS3PtrOutput) Prefix() pulumi.StringPtrOutput

Prefix to append to the folder name.

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) ToClusterLoggingInfoBrokerLogsS3PtrOutput 

func (o ClusterLoggingInfoBrokerLogsS3PtrOutput) ToClusterLoggingInfoBrokerLogsS3PtrOutput() ClusterLoggingInfoBrokerLogsS3PtrOutput

func (ClusterLoggingInfoBrokerLogsS3PtrOutput) ToClusterLoggingInfoBrokerLogsS3PtrOutputWithContext 

func (o ClusterLoggingInfoBrokerLogsS3PtrOutput) ToClusterLoggingInfoBrokerLogsS3PtrOutputWithContext(ctx context.Context) ClusterLoggingInfoBrokerLogsS3PtrOutput

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() ClusterLoggingInfoBrokerLogsOutput

Configuration block for Broker Logs settings for logging info. See below.

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() ClusterLoggingInfoBrokerLogsPtrOutput

Configuration block for Broker Logs settings for logging info. See below.

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 ClusterMap 

type ClusterMap map[string]ClusterInput

func (ClusterMap) ElementType 

func (ClusterMap) ElementType() reflect.Type

func (ClusterMap) ToClusterMapOutput 

func (i ClusterMap) ToClusterMapOutput() ClusterMapOutput

func (ClusterMap) ToClusterMapOutputWithContext 

func (i ClusterMap) ToClusterMapOutputWithContext(ctx context.Context) ClusterMapOutput

type ClusterMapInput 

type ClusterMapInput interface {
	pulumi.Input

	ToClusterMapOutput() ClusterMapOutput
	ToClusterMapOutputWithContext(context.Context) ClusterMapOutput
}

ClusterMapInput is an input type that accepts ClusterMap and ClusterMapOutput values. You can construct a concrete instance of `ClusterMapInput` via: 

ClusterMap{ "key": ClusterArgs{...} }

type ClusterMapOutput 

type ClusterMapOutput struct{ *pulumi.OutputState }

func (ClusterMapOutput) ElementType 

func (ClusterMapOutput) ElementType() reflect.Type

func (ClusterMapOutput) MapIndex 

func (o ClusterMapOutput) MapIndex(k pulumi.StringInput) ClusterOutput

func (ClusterMapOutput) ToClusterMapOutput 

func (o ClusterMapOutput) ToClusterMapOutput() ClusterMapOutput

func (ClusterMapOutput) ToClusterMapOutputWithContext 

func (o ClusterMapOutput) ToClusterMapOutputWithContext(ctx context.Context) ClusterMapOutput

type ClusterOpenMonitoring 

type ClusterOpenMonitoring struct {
	// Configuration block for Prometheus settings for open monitoring. See below.
	Prometheus ClusterOpenMonitoringPrometheus `pulumi:"prometheus"`
}

type ClusterOpenMonitoringArgs 

type ClusterOpenMonitoringArgs struct {
	// Configuration block for Prometheus settings for open monitoring. See below.
	Prometheus ClusterOpenMonitoringPrometheusInput `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() ClusterOpenMonitoringPrometheusOutput

Configuration block for Prometheus settings for open monitoring. See below.

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 ClusterOpenMonitoringPrometheus 

type ClusterOpenMonitoringPrometheus struct {
	// Configuration block for JMX Exporter. See below.
	JmxExporter *ClusterOpenMonitoringPrometheusJmxExporter `pulumi:"jmxExporter"`
	// Configuration block for Node Exporter. See below.
	NodeExporter *ClusterOpenMonitoringPrometheusNodeExporter `pulumi:"nodeExporter"`
}

type ClusterOpenMonitoringPrometheusArgs 

type ClusterOpenMonitoringPrometheusArgs struct {
	// Configuration block for JMX Exporter. See below.
	JmxExporter ClusterOpenMonitoringPrometheusJmxExporterPtrInput `pulumi:"jmxExporter"`
	// Configuration block for Node Exporter. See below.
	NodeExporter ClusterOpenMonitoringPrometheusNodeExporterPtrInput `pulumi:"nodeExporter"`
}

func (ClusterOpenMonitoringPrometheusArgs) ElementType 

func (ClusterOpenMonitoringPrometheusArgs) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusOutput 

func (i ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusOutput() ClusterOpenMonitoringPrometheusOutput

func (ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusOutputWithContext 

func (i ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusOutput

func (ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusPtrOutput 

func (i ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusPtrOutput() ClusterOpenMonitoringPrometheusPtrOutput

func (ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusPtrOutputWithContext 

func (i ClusterOpenMonitoringPrometheusArgs) ToClusterOpenMonitoringPrometheusPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusPtrOutput

type ClusterOpenMonitoringPrometheusInput 

type ClusterOpenMonitoringPrometheusInput interface {
	pulumi.Input

	ToClusterOpenMonitoringPrometheusOutput() ClusterOpenMonitoringPrometheusOutput
	ToClusterOpenMonitoringPrometheusOutputWithContext(context.Context) ClusterOpenMonitoringPrometheusOutput
}

ClusterOpenMonitoringPrometheusInput is an input type that accepts ClusterOpenMonitoringPrometheusArgs and ClusterOpenMonitoringPrometheusOutput values. You can construct a concrete instance of `ClusterOpenMonitoringPrometheusInput` via: 

ClusterOpenMonitoringPrometheusArgs{...}

type ClusterOpenMonitoringPrometheusJmxExporter 

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

type ClusterOpenMonitoringPrometheusJmxExporterArgs 

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

func (ClusterOpenMonitoringPrometheusJmxExporterArgs) ElementType 

func (ClusterOpenMonitoringPrometheusJmxExporterArgs) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterOutput 

func (i ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterOutput() ClusterOpenMonitoringPrometheusJmxExporterOutput

func (ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterOutputWithContext 

func (i ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusJmxExporterOutput

func (ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutput 

func (i ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutput() ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

func (ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutputWithContext 

func (i ClusterOpenMonitoringPrometheusJmxExporterArgs) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

type ClusterOpenMonitoringPrometheusJmxExporterInput 

type ClusterOpenMonitoringPrometheusJmxExporterInput interface {
	pulumi.Input

	ToClusterOpenMonitoringPrometheusJmxExporterOutput() ClusterOpenMonitoringPrometheusJmxExporterOutput
	ToClusterOpenMonitoringPrometheusJmxExporterOutputWithContext(context.Context) ClusterOpenMonitoringPrometheusJmxExporterOutput
}

ClusterOpenMonitoringPrometheusJmxExporterInput is an input type that accepts ClusterOpenMonitoringPrometheusJmxExporterArgs and ClusterOpenMonitoringPrometheusJmxExporterOutput values. You can construct a concrete instance of `ClusterOpenMonitoringPrometheusJmxExporterInput` via: 

ClusterOpenMonitoringPrometheusJmxExporterArgs{...}

type ClusterOpenMonitoringPrometheusJmxExporterOutput 

type ClusterOpenMonitoringPrometheusJmxExporterOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringPrometheusJmxExporterOutput) ElementType 

func (ClusterOpenMonitoringPrometheusJmxExporterOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusJmxExporterOutput) EnabledInBroker 

func (o ClusterOpenMonitoringPrometheusJmxExporterOutput) EnabledInBroker() pulumi.BoolOutput

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

func (ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterOutput 

func (o ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterOutput() ClusterOpenMonitoringPrometheusJmxExporterOutput

func (ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterOutputWithContext 

func (o ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusJmxExporterOutput

func (ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutput 

func (o ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutput() ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

func (ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutputWithContext 

func (o ClusterOpenMonitoringPrometheusJmxExporterOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

type ClusterOpenMonitoringPrometheusJmxExporterPtrInput 

type ClusterOpenMonitoringPrometheusJmxExporterPtrInput interface {
	pulumi.Input

	ToClusterOpenMonitoringPrometheusJmxExporterPtrOutput() ClusterOpenMonitoringPrometheusJmxExporterPtrOutput
	ToClusterOpenMonitoringPrometheusJmxExporterPtrOutputWithContext(context.Context) ClusterOpenMonitoringPrometheusJmxExporterPtrOutput
}

ClusterOpenMonitoringPrometheusJmxExporterPtrInput is an input type that accepts ClusterOpenMonitoringPrometheusJmxExporterArgs, ClusterOpenMonitoringPrometheusJmxExporterPtr and ClusterOpenMonitoringPrometheusJmxExporterPtrOutput values. You can construct a concrete instance of `ClusterOpenMonitoringPrometheusJmxExporterPtrInput` via: 

        ClusterOpenMonitoringPrometheusJmxExporterArgs{...}

or:

        nil

func ClusterOpenMonitoringPrometheusJmxExporterPtr 

func ClusterOpenMonitoringPrometheusJmxExporterPtr(v *ClusterOpenMonitoringPrometheusJmxExporterArgs) ClusterOpenMonitoringPrometheusJmxExporterPtrInput

type ClusterOpenMonitoringPrometheusJmxExporterPtrOutput 

type ClusterOpenMonitoringPrometheusJmxExporterPtrOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) Elem 

func (o ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) Elem() ClusterOpenMonitoringPrometheusJmxExporterOutput

func (ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) ElementType 

func (ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) EnabledInBroker 

func (o ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) EnabledInBroker() pulumi.BoolPtrOutput

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

func (ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutput 

func (o ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutput() ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

func (ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutputWithContext 

func (o ClusterOpenMonitoringPrometheusJmxExporterPtrOutput) ToClusterOpenMonitoringPrometheusJmxExporterPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

type ClusterOpenMonitoringPrometheusNodeExporter 

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

type ClusterOpenMonitoringPrometheusNodeExporterArgs 

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

func (ClusterOpenMonitoringPrometheusNodeExporterArgs) ElementType 

func (ClusterOpenMonitoringPrometheusNodeExporterArgs) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterOutput 

func (i ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterOutput() ClusterOpenMonitoringPrometheusNodeExporterOutput

func (ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterOutputWithContext 

func (i ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusNodeExporterOutput

func (ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutput 

func (i ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutput() ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

func (ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutputWithContext 

func (i ClusterOpenMonitoringPrometheusNodeExporterArgs) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

type ClusterOpenMonitoringPrometheusNodeExporterInput 

type ClusterOpenMonitoringPrometheusNodeExporterInput interface {
	pulumi.Input

	ToClusterOpenMonitoringPrometheusNodeExporterOutput() ClusterOpenMonitoringPrometheusNodeExporterOutput
	ToClusterOpenMonitoringPrometheusNodeExporterOutputWithContext(context.Context) ClusterOpenMonitoringPrometheusNodeExporterOutput
}

ClusterOpenMonitoringPrometheusNodeExporterInput is an input type that accepts ClusterOpenMonitoringPrometheusNodeExporterArgs and ClusterOpenMonitoringPrometheusNodeExporterOutput values. You can construct a concrete instance of `ClusterOpenMonitoringPrometheusNodeExporterInput` via: 

ClusterOpenMonitoringPrometheusNodeExporterArgs{...}

type ClusterOpenMonitoringPrometheusNodeExporterOutput 

type ClusterOpenMonitoringPrometheusNodeExporterOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringPrometheusNodeExporterOutput) ElementType 

func (ClusterOpenMonitoringPrometheusNodeExporterOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusNodeExporterOutput) EnabledInBroker 

func (o ClusterOpenMonitoringPrometheusNodeExporterOutput) EnabledInBroker() pulumi.BoolOutput

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

func (ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterOutput 

func (o ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterOutput() ClusterOpenMonitoringPrometheusNodeExporterOutput

func (ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterOutputWithContext 

func (o ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusNodeExporterOutput

func (ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutput 

func (o ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutput() ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

func (ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutputWithContext 

func (o ClusterOpenMonitoringPrometheusNodeExporterOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

type ClusterOpenMonitoringPrometheusNodeExporterPtrInput 

type ClusterOpenMonitoringPrometheusNodeExporterPtrInput interface {
	pulumi.Input

	ToClusterOpenMonitoringPrometheusNodeExporterPtrOutput() ClusterOpenMonitoringPrometheusNodeExporterPtrOutput
	ToClusterOpenMonitoringPrometheusNodeExporterPtrOutputWithContext(context.Context) ClusterOpenMonitoringPrometheusNodeExporterPtrOutput
}

ClusterOpenMonitoringPrometheusNodeExporterPtrInput is an input type that accepts ClusterOpenMonitoringPrometheusNodeExporterArgs, ClusterOpenMonitoringPrometheusNodeExporterPtr and ClusterOpenMonitoringPrometheusNodeExporterPtrOutput values. You can construct a concrete instance of `ClusterOpenMonitoringPrometheusNodeExporterPtrInput` via: 

        ClusterOpenMonitoringPrometheusNodeExporterArgs{...}

or:

        nil

func ClusterOpenMonitoringPrometheusNodeExporterPtr 

func ClusterOpenMonitoringPrometheusNodeExporterPtr(v *ClusterOpenMonitoringPrometheusNodeExporterArgs) ClusterOpenMonitoringPrometheusNodeExporterPtrInput

type ClusterOpenMonitoringPrometheusNodeExporterPtrOutput 

type ClusterOpenMonitoringPrometheusNodeExporterPtrOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) Elem 

func (o ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) Elem() ClusterOpenMonitoringPrometheusNodeExporterOutput

func (ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) ElementType 

func (ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) EnabledInBroker 

func (o ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) EnabledInBroker() pulumi.BoolPtrOutput

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

func (ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutput 

func (o ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutput() ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

func (ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutputWithContext 

func (o ClusterOpenMonitoringPrometheusNodeExporterPtrOutput) ToClusterOpenMonitoringPrometheusNodeExporterPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

type ClusterOpenMonitoringPrometheusOutput 

type ClusterOpenMonitoringPrometheusOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringPrometheusOutput) ElementType 

func (ClusterOpenMonitoringPrometheusOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusOutput) JmxExporter 

func (o ClusterOpenMonitoringPrometheusOutput) JmxExporter() ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

Configuration block for JMX Exporter. See below.

func (ClusterOpenMonitoringPrometheusOutput) NodeExporter 

func (o ClusterOpenMonitoringPrometheusOutput) NodeExporter() ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

Configuration block for Node Exporter. See below.

func (ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusOutput 

func (o ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusOutput() ClusterOpenMonitoringPrometheusOutput

func (ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusOutputWithContext 

func (o ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusOutput

func (ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusPtrOutput 

func (o ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusPtrOutput() ClusterOpenMonitoringPrometheusPtrOutput

func (ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusPtrOutputWithContext 

func (o ClusterOpenMonitoringPrometheusOutput) ToClusterOpenMonitoringPrometheusPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusPtrOutput

type ClusterOpenMonitoringPrometheusPtrInput 

type ClusterOpenMonitoringPrometheusPtrInput interface {
	pulumi.Input

	ToClusterOpenMonitoringPrometheusPtrOutput() ClusterOpenMonitoringPrometheusPtrOutput
	ToClusterOpenMonitoringPrometheusPtrOutputWithContext(context.Context) ClusterOpenMonitoringPrometheusPtrOutput
}

ClusterOpenMonitoringPrometheusPtrInput is an input type that accepts ClusterOpenMonitoringPrometheusArgs, ClusterOpenMonitoringPrometheusPtr and ClusterOpenMonitoringPrometheusPtrOutput values. You can construct a concrete instance of `ClusterOpenMonitoringPrometheusPtrInput` via: 

        ClusterOpenMonitoringPrometheusArgs{...}

or:

        nil

func ClusterOpenMonitoringPrometheusPtr 

func ClusterOpenMonitoringPrometheusPtr(v *ClusterOpenMonitoringPrometheusArgs) ClusterOpenMonitoringPrometheusPtrInput

type ClusterOpenMonitoringPrometheusPtrOutput 

type ClusterOpenMonitoringPrometheusPtrOutput struct{ *pulumi.OutputState }

func (ClusterOpenMonitoringPrometheusPtrOutput) Elem 

func (o ClusterOpenMonitoringPrometheusPtrOutput) Elem() ClusterOpenMonitoringPrometheusOutput

func (ClusterOpenMonitoringPrometheusPtrOutput) ElementType 

func (ClusterOpenMonitoringPrometheusPtrOutput) ElementType() reflect.Type

func (ClusterOpenMonitoringPrometheusPtrOutput) JmxExporter 

func (o ClusterOpenMonitoringPrometheusPtrOutput) JmxExporter() ClusterOpenMonitoringPrometheusJmxExporterPtrOutput

Configuration block for JMX Exporter. See below.

func (ClusterOpenMonitoringPrometheusPtrOutput) NodeExporter 

func (o ClusterOpenMonitoringPrometheusPtrOutput) NodeExporter() ClusterOpenMonitoringPrometheusNodeExporterPtrOutput

Configuration block for Node Exporter. See below.

func (ClusterOpenMonitoringPrometheusPtrOutput) ToClusterOpenMonitoringPrometheusPtrOutput 

func (o ClusterOpenMonitoringPrometheusPtrOutput) ToClusterOpenMonitoringPrometheusPtrOutput() ClusterOpenMonitoringPrometheusPtrOutput

func (ClusterOpenMonitoringPrometheusPtrOutput) ToClusterOpenMonitoringPrometheusPtrOutputWithContext 

func (o ClusterOpenMonitoringPrometheusPtrOutput) ToClusterOpenMonitoringPrometheusPtrOutputWithContext(ctx context.Context) ClusterOpenMonitoringPrometheusPtrOutput

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() ClusterOpenMonitoringPrometheusPtrOutput

Configuration block for Prometheus settings for open monitoring. See below.

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 v5.4.0 

func (o ClusterOutput) Arn() pulumi.StringOutput

Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.

func (ClusterOutput) BootstrapBrokers added in v5.4.0 

func (o ClusterOutput) BootstrapBrokers() pulumi.StringOutput

Comma separated list of one or more hostname:port pairs of kafka brokers suitable to bootstrap connectivity to the kafka cluster. Contains a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `PLAINTEXT` or `TLS_PLAINTEXT`. The resource sorts values alphabetically. AWS may not always return all endpoints so this value is not guaranteed to be stable across applies.

func (ClusterOutput) BootstrapBrokersPublicSaslIam added in v5.5.0 

func (o ClusterOutput) BootstrapBrokersPublicSaslIam() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (ClusterOutput) BootstrapBrokersPublicSaslScram added in v5.5.0 

func (o ClusterOutput) BootstrapBrokersPublicSaslScram() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (ClusterOutput) BootstrapBrokersPublicTls added in v5.5.0 

func (o ClusterOutput) BootstrapBrokersPublicTls() pulumi.StringOutput

One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (ClusterOutput) BootstrapBrokersSaslIam added in v5.4.0 

func (o ClusterOutput) BootstrapBrokersSaslIam() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (ClusterOutput) BootstrapBrokersSaslScram added in v5.4.0 

func (o ClusterOutput) BootstrapBrokersSaslScram() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (ClusterOutput) BootstrapBrokersTls added in v5.4.0 

func (o ClusterOutput) BootstrapBrokersTls() pulumi.StringOutput

One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (ClusterOutput) BrokerNodeGroupInfo added in v5.4.0 

func (o ClusterOutput) BrokerNodeGroupInfo() ClusterBrokerNodeGroupInfoOutput

Configuration block for the broker nodes of the Kafka cluster.

func (ClusterOutput) ClientAuthentication added in v5.4.0 

func (o ClusterOutput) ClientAuthentication() ClusterClientAuthenticationPtrOutput

Configuration block for specifying a client authentication. See below.

func (ClusterOutput) ClusterName added in v5.4.0 

func (o ClusterOutput) ClusterName() pulumi.StringOutput

Name of the MSK cluster.

func (ClusterOutput) ConfigurationInfo added in v5.4.0 

func (o ClusterOutput) ConfigurationInfo() ClusterConfigurationInfoPtrOutput

Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.

func (ClusterOutput) CurrentVersion added in v5.4.0 

func (o ClusterOutput) CurrentVersion() pulumi.StringOutput

Current version of the MSK Cluster used for updates, e.g., `K13V1IB3VIYZZH` * `encryption_info.0.encryption_at_rest_kms_key_arn` - The ARN of the KMS key used for encryption at rest of the broker data volumes.

func (ClusterOutput) ElementType 

func (ClusterOutput) ElementType() reflect.Type

func (ClusterOutput) EncryptionInfo added in v5.4.0 

func (o ClusterOutput) EncryptionInfo() ClusterEncryptionInfoPtrOutput

Configuration block for specifying encryption. See below.

func (ClusterOutput) EnhancedMonitoring added in v5.4.0 

func (o ClusterOutput) EnhancedMonitoring() pulumi.StringPtrOutput

Specify the desired enhanced MSK CloudWatch monitoring level. See [Monitoring Amazon MSK with Amazon CloudWatch](https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html)

func (ClusterOutput) KafkaVersion added in v5.4.0 

func (o ClusterOutput) KafkaVersion() pulumi.StringOutput

Specify the desired Kafka software version.

func (ClusterOutput) LoggingInfo added in v5.4.0 

func (o ClusterOutput) LoggingInfo() ClusterLoggingInfoPtrOutput

Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.

func (ClusterOutput) NumberOfBrokerNodes added in v5.4.0 

func (o ClusterOutput) NumberOfBrokerNodes() pulumi.IntOutput

The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets.

func (ClusterOutput) OpenMonitoring added in v5.4.0 

func (o ClusterOutput) OpenMonitoring() ClusterOpenMonitoringPtrOutput

Configuration block for JMX and Node monitoring for the MSK cluster. See below.

func (ClusterOutput) StorageMode added in v5.22.0 

func (o ClusterOutput) StorageMode() pulumi.StringOutput

Controls storage mode for supported storage tiers. Valid values are: `LOCAL` or `TIERED`.

func (ClusterOutput) Tags added in v5.4.0 

func (o ClusterOutput) Tags() pulumi.StringMapOutput

A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (ClusterOutput) TagsAll added in v5.4.0 

func (o ClusterOutput) TagsAll() pulumi.StringMapOutput

A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (ClusterOutput) ToClusterOutput 

func (o ClusterOutput) ToClusterOutput() ClusterOutput

func (ClusterOutput) ToClusterOutputWithContext 

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

func (ClusterOutput) ZookeeperConnectString added in v5.4.0 

func (o ClusterOutput) ZookeeperConnectString() pulumi.StringOutput

A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.

func (ClusterOutput) ZookeeperConnectStringTls added in v5.4.0 

func (o ClusterOutput) ZookeeperConnectStringTls() pulumi.StringOutput

A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster via TLS. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.

type ClusterState 

type ClusterState struct {
	// Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.
	Arn pulumi.StringPtrInput
	// Comma separated list of one or more hostname:port pairs of kafka brokers suitable to bootstrap connectivity to the kafka cluster. Contains a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `PLAINTEXT` or `TLS_PLAINTEXT`. The resource sorts values alphabetically. AWS may not always return all endpoints so this value is not guaranteed to be stable across applies.
	BootstrapBrokers pulumi.StringPtrInput
	// One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicSaslIam pulumi.StringPtrInput
	// One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicSaslScram pulumi.StringPtrInput
	// One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicTls pulumi.StringPtrInput
	// One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersSaslIam pulumi.StringPtrInput
	// One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersSaslScram pulumi.StringPtrInput
	// One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersTls pulumi.StringPtrInput
	// Configuration block for the broker nodes of the Kafka cluster.
	BrokerNodeGroupInfo ClusterBrokerNodeGroupInfoPtrInput
	// Configuration block for specifying a client authentication. See below.
	ClientAuthentication ClusterClientAuthenticationPtrInput
	// Name of the MSK cluster.
	ClusterName pulumi.StringPtrInput
	// Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.
	ConfigurationInfo ClusterConfigurationInfoPtrInput
	// Current version of the MSK Cluster used for updates, e.g., `K13V1IB3VIYZZH`
	// * `encryption_info.0.encryption_at_rest_kms_key_arn` - The ARN of the KMS key used for encryption at rest of the broker data volumes.
	CurrentVersion pulumi.StringPtrInput
	// Configuration block for specifying encryption. See below.
	EncryptionInfo ClusterEncryptionInfoPtrInput
	// Specify the desired enhanced MSK CloudWatch monitoring level. See [Monitoring Amazon MSK with Amazon CloudWatch](https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html)
	EnhancedMonitoring pulumi.StringPtrInput
	// Specify the desired Kafka software version.
	KafkaVersion pulumi.StringPtrInput
	// Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.
	LoggingInfo ClusterLoggingInfoPtrInput
	// The desired total number of broker nodes in the kafka cluster.  It must be a multiple of the number of specified client subnets.
	NumberOfBrokerNodes pulumi.IntPtrInput
	// Configuration block for JMX and Node monitoring for the MSK cluster. See below.
	OpenMonitoring ClusterOpenMonitoringPtrInput
	// Controls storage mode for supported storage tiers. Valid values are: `LOCAL` or `TIERED`.
	StorageMode pulumi.StringPtrInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
	// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
	ZookeeperConnectString pulumi.StringPtrInput
	// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster via TLS. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
	ZookeeperConnectStringTls pulumi.StringPtrInput
}

func (ClusterState) ElementType 

func (ClusterState) ElementType() reflect.Type

type Configuration 

type Configuration struct {
	pulumi.CustomResourceState

	// Amazon Resource Name (ARN) of the configuration.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// Description of the configuration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// List of Apache Kafka versions which can use this configuration.
	KafkaVersions pulumi.StringArrayOutput `pulumi:"kafkaVersions"`
	// Latest revision of the configuration.
	LatestRevision pulumi.IntOutput `pulumi:"latestRevision"`
	// Name of the configuration.
	Name pulumi.StringOutput `pulumi:"name"`
	// Contents of the server.properties file. Supported properties are documented in the [MSK Developer Guide](https://docs.aws.amazon.com/msk/latest/developerguide/msk-configuration-properties.html).
	ServerProperties pulumi.StringOutput `pulumi:"serverProperties"`
}

Manages an Amazon Managed Streaming for Kafka configuration. More information can be found on the [MSK Developer Guide](https://docs.aws.amazon.com/msk/latest/developerguide/msk-configuration.html).

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := msk.NewConfiguration(ctx, "example", &msk.ConfigurationArgs{
			KafkaVersions: pulumi.StringArray{
				pulumi.String("2.1.0"),
			},
			ServerProperties: pulumi.String("auto.create.topics.enable = true\ndelete.topic.enable = true\n\n"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MSK configurations can be imported using the configuration ARN, e.g.,

```sh 

$ pulumi import aws:msk/configuration:Configuration example arn:aws:kafka:us-west-2:123456789012:configuration/example/279c0212-d057-4dba-9aa9-1c4e5a25bfc7-3

```

func GetConfiguration 

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 

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 

func (*Configuration) ElementType() reflect.Type

func (*Configuration) ToConfigurationOutput 

func (i *Configuration) ToConfigurationOutput() ConfigurationOutput

func (*Configuration) ToConfigurationOutputWithContext 

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

type ConfigurationArgs 

type ConfigurationArgs struct {
	// Description of the configuration.
	Description pulumi.StringPtrInput
	// List of Apache Kafka versions which can use this configuration.
	KafkaVersions pulumi.StringArrayInput
	// Name of the configuration.
	Name pulumi.StringPtrInput
	// Contents of the server.properties file. Supported properties are documented in the [MSK Developer Guide](https://docs.aws.amazon.com/msk/latest/developerguide/msk-configuration-properties.html).
	ServerProperties pulumi.StringInput
}

The set of arguments for constructing a Configuration resource.

func (ConfigurationArgs) ElementType 

func (ConfigurationArgs) ElementType() reflect.Type

type ConfigurationArray 

type ConfigurationArray []ConfigurationInput

func (ConfigurationArray) ElementType 

func (ConfigurationArray) ElementType() reflect.Type

func (ConfigurationArray) ToConfigurationArrayOutput 

func (i ConfigurationArray) ToConfigurationArrayOutput() ConfigurationArrayOutput

func (ConfigurationArray) ToConfigurationArrayOutputWithContext 

func (i ConfigurationArray) ToConfigurationArrayOutputWithContext(ctx context.Context) ConfigurationArrayOutput

type ConfigurationArrayInput 

type ConfigurationArrayInput interface {
	pulumi.Input

	ToConfigurationArrayOutput() ConfigurationArrayOutput
	ToConfigurationArrayOutputWithContext(context.Context) ConfigurationArrayOutput
}

ConfigurationArrayInput is an input type that accepts ConfigurationArray and ConfigurationArrayOutput values. You can construct a concrete instance of `ConfigurationArrayInput` via: 

ConfigurationArray{ ConfigurationArgs{...} }

type ConfigurationArrayOutput 

type ConfigurationArrayOutput struct{ *pulumi.OutputState }

func (ConfigurationArrayOutput) ElementType 

func (ConfigurationArrayOutput) ElementType() reflect.Type

func (ConfigurationArrayOutput) Index 

func (o ConfigurationArrayOutput) Index(i pulumi.IntInput) ConfigurationOutput

func (ConfigurationArrayOutput) ToConfigurationArrayOutput 

func (o ConfigurationArrayOutput) ToConfigurationArrayOutput() ConfigurationArrayOutput

func (ConfigurationArrayOutput) ToConfigurationArrayOutputWithContext 

func (o ConfigurationArrayOutput) ToConfigurationArrayOutputWithContext(ctx context.Context) ConfigurationArrayOutput

type ConfigurationInput 

type ConfigurationInput interface {
	pulumi.Input

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

type ConfigurationMap 

type ConfigurationMap map[string]ConfigurationInput

func (ConfigurationMap) ElementType 

func (ConfigurationMap) ElementType() reflect.Type

func (ConfigurationMap) ToConfigurationMapOutput 

func (i ConfigurationMap) ToConfigurationMapOutput() ConfigurationMapOutput

func (ConfigurationMap) ToConfigurationMapOutputWithContext 

func (i ConfigurationMap) ToConfigurationMapOutputWithContext(ctx context.Context) ConfigurationMapOutput

type ConfigurationMapInput 

type ConfigurationMapInput interface {
	pulumi.Input

	ToConfigurationMapOutput() ConfigurationMapOutput
	ToConfigurationMapOutputWithContext(context.Context) ConfigurationMapOutput
}

ConfigurationMapInput is an input type that accepts ConfigurationMap and ConfigurationMapOutput values. You can construct a concrete instance of `ConfigurationMapInput` via: 

ConfigurationMap{ "key": ConfigurationArgs{...} }

type ConfigurationMapOutput 

type ConfigurationMapOutput struct{ *pulumi.OutputState }

func (ConfigurationMapOutput) ElementType 

func (ConfigurationMapOutput) ElementType() reflect.Type

func (ConfigurationMapOutput) MapIndex 

func (o ConfigurationMapOutput) MapIndex(k pulumi.StringInput) ConfigurationOutput

func (ConfigurationMapOutput) ToConfigurationMapOutput 

func (o ConfigurationMapOutput) ToConfigurationMapOutput() ConfigurationMapOutput

func (ConfigurationMapOutput) ToConfigurationMapOutputWithContext 

func (o ConfigurationMapOutput) ToConfigurationMapOutputWithContext(ctx context.Context) ConfigurationMapOutput

type ConfigurationOutput 

type ConfigurationOutput struct{ *pulumi.OutputState }

func (ConfigurationOutput) Arn added in v5.4.0 

func (o ConfigurationOutput) Arn() pulumi.StringOutput

Amazon Resource Name (ARN) of the configuration.

func (ConfigurationOutput) Description added in v5.4.0 

func (o ConfigurationOutput) Description() pulumi.StringPtrOutput

Description of the configuration.

func (ConfigurationOutput) ElementType 

func (ConfigurationOutput) ElementType() reflect.Type

func (ConfigurationOutput) KafkaVersions added in v5.4.0 

func (o ConfigurationOutput) KafkaVersions() pulumi.StringArrayOutput

List of Apache Kafka versions which can use this configuration.

func (ConfigurationOutput) LatestRevision added in v5.4.0 

func (o ConfigurationOutput) LatestRevision() pulumi.IntOutput

Latest revision of the configuration.

func (ConfigurationOutput) Name added in v5.4.0 

func (o ConfigurationOutput) Name() pulumi.StringOutput

Name of the configuration.

func (ConfigurationOutput) ServerProperties added in v5.4.0 

func (o ConfigurationOutput) ServerProperties() pulumi.StringOutput

Contents of the server.properties file. Supported properties are documented in the [MSK Developer Guide](https://docs.aws.amazon.com/msk/latest/developerguide/msk-configuration-properties.html).

func (ConfigurationOutput) ToConfigurationOutput 

func (o ConfigurationOutput) ToConfigurationOutput() ConfigurationOutput

func (ConfigurationOutput) ToConfigurationOutputWithContext 

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

type ConfigurationState 

type ConfigurationState struct {
	// Amazon Resource Name (ARN) of the configuration.
	Arn pulumi.StringPtrInput
	// Description of the configuration.
	Description pulumi.StringPtrInput
	// List of Apache Kafka versions which can use this configuration.
	KafkaVersions pulumi.StringArrayInput
	// Latest revision of the configuration.
	LatestRevision pulumi.IntPtrInput
	// Name of the configuration.
	Name pulumi.StringPtrInput
	// Contents of the server.properties file. Supported properties are documented in the [MSK Developer Guide](https://docs.aws.amazon.com/msk/latest/developerguide/msk-configuration-properties.html).
	ServerProperties pulumi.StringPtrInput
}

func (ConfigurationState) ElementType 

func (ConfigurationState) ElementType() reflect.Type

type GetBrokerNodesArgs 

type GetBrokerNodesArgs struct {
	// ARN of the cluster the nodes belong to.
	ClusterArn string `pulumi:"clusterArn"`
}

A collection of arguments for invoking getBrokerNodes.

type GetBrokerNodesNodeInfoList 

type GetBrokerNodesNodeInfoList struct {
	// Attached elastic network interface of the broker
	AttachedEniId string `pulumi:"attachedEniId"`
	// ID of the broker
	BrokerId float64 `pulumi:"brokerId"`
	// Client subnet to which this broker node belongs
	ClientSubnet string `pulumi:"clientSubnet"`
	// The client virtual private cloud (VPC) IP address
	ClientVpcIpAddress string `pulumi:"clientVpcIpAddress"`
	// Set of endpoints for accessing the broker. This does not include ports
	Endpoints []string `pulumi:"endpoints"`
	// ARN of the node
	NodeArn string `pulumi:"nodeArn"`
}

type GetBrokerNodesNodeInfoListArgs 

type GetBrokerNodesNodeInfoListArgs struct {
	// Attached elastic network interface of the broker
	AttachedEniId pulumi.StringInput `pulumi:"attachedEniId"`
	// ID of the broker
	BrokerId pulumi.Float64Input `pulumi:"brokerId"`
	// Client subnet to which this broker node belongs
	ClientSubnet pulumi.StringInput `pulumi:"clientSubnet"`
	// The client virtual private cloud (VPC) IP address
	ClientVpcIpAddress pulumi.StringInput `pulumi:"clientVpcIpAddress"`
	// Set of endpoints for accessing the broker. This does not include ports
	Endpoints pulumi.StringArrayInput `pulumi:"endpoints"`
	// ARN of the node
	NodeArn pulumi.StringInput `pulumi:"nodeArn"`
}

func (GetBrokerNodesNodeInfoListArgs) ElementType 

func (GetBrokerNodesNodeInfoListArgs) ElementType() reflect.Type

func (GetBrokerNodesNodeInfoListArgs) ToGetBrokerNodesNodeInfoListOutput 

func (i GetBrokerNodesNodeInfoListArgs) ToGetBrokerNodesNodeInfoListOutput() GetBrokerNodesNodeInfoListOutput

func (GetBrokerNodesNodeInfoListArgs) ToGetBrokerNodesNodeInfoListOutputWithContext 

func (i GetBrokerNodesNodeInfoListArgs) ToGetBrokerNodesNodeInfoListOutputWithContext(ctx context.Context) GetBrokerNodesNodeInfoListOutput

type GetBrokerNodesNodeInfoListArray 

type GetBrokerNodesNodeInfoListArray []GetBrokerNodesNodeInfoListInput

func (GetBrokerNodesNodeInfoListArray) ElementType 

func (GetBrokerNodesNodeInfoListArray) ElementType() reflect.Type

func (GetBrokerNodesNodeInfoListArray) ToGetBrokerNodesNodeInfoListArrayOutput 

func (i GetBrokerNodesNodeInfoListArray) ToGetBrokerNodesNodeInfoListArrayOutput() GetBrokerNodesNodeInfoListArrayOutput

func (GetBrokerNodesNodeInfoListArray) ToGetBrokerNodesNodeInfoListArrayOutputWithContext 

func (i GetBrokerNodesNodeInfoListArray) ToGetBrokerNodesNodeInfoListArrayOutputWithContext(ctx context.Context) GetBrokerNodesNodeInfoListArrayOutput

type GetBrokerNodesNodeInfoListArrayInput 

type GetBrokerNodesNodeInfoListArrayInput interface {
	pulumi.Input

	ToGetBrokerNodesNodeInfoListArrayOutput() GetBrokerNodesNodeInfoListArrayOutput
	ToGetBrokerNodesNodeInfoListArrayOutputWithContext(context.Context) GetBrokerNodesNodeInfoListArrayOutput
}

GetBrokerNodesNodeInfoListArrayInput is an input type that accepts GetBrokerNodesNodeInfoListArray and GetBrokerNodesNodeInfoListArrayOutput values. You can construct a concrete instance of `GetBrokerNodesNodeInfoListArrayInput` via: 

GetBrokerNodesNodeInfoListArray{ GetBrokerNodesNodeInfoListArgs{...} }

type GetBrokerNodesNodeInfoListArrayOutput 

type GetBrokerNodesNodeInfoListArrayOutput struct{ *pulumi.OutputState }

func (GetBrokerNodesNodeInfoListArrayOutput) ElementType 

func (GetBrokerNodesNodeInfoListArrayOutput) ElementType() reflect.Type

func (GetBrokerNodesNodeInfoListArrayOutput) Index 

func (o GetBrokerNodesNodeInfoListArrayOutput) Index(i pulumi.IntInput) GetBrokerNodesNodeInfoListOutput

func (GetBrokerNodesNodeInfoListArrayOutput) ToGetBrokerNodesNodeInfoListArrayOutput 

func (o GetBrokerNodesNodeInfoListArrayOutput) ToGetBrokerNodesNodeInfoListArrayOutput() GetBrokerNodesNodeInfoListArrayOutput

func (GetBrokerNodesNodeInfoListArrayOutput) ToGetBrokerNodesNodeInfoListArrayOutputWithContext 

func (o GetBrokerNodesNodeInfoListArrayOutput) ToGetBrokerNodesNodeInfoListArrayOutputWithContext(ctx context.Context) GetBrokerNodesNodeInfoListArrayOutput

type GetBrokerNodesNodeInfoListInput 

type GetBrokerNodesNodeInfoListInput interface {
	pulumi.Input

	ToGetBrokerNodesNodeInfoListOutput() GetBrokerNodesNodeInfoListOutput
	ToGetBrokerNodesNodeInfoListOutputWithContext(context.Context) GetBrokerNodesNodeInfoListOutput
}

GetBrokerNodesNodeInfoListInput is an input type that accepts GetBrokerNodesNodeInfoListArgs and GetBrokerNodesNodeInfoListOutput values. You can construct a concrete instance of `GetBrokerNodesNodeInfoListInput` via: 

GetBrokerNodesNodeInfoListArgs{...}

type GetBrokerNodesNodeInfoListOutput 

type GetBrokerNodesNodeInfoListOutput struct{ *pulumi.OutputState }

func (GetBrokerNodesNodeInfoListOutput) AttachedEniId 

func (o GetBrokerNodesNodeInfoListOutput) AttachedEniId() pulumi.StringOutput

Attached elastic network interface of the broker

func (GetBrokerNodesNodeInfoListOutput) BrokerId 

func (o GetBrokerNodesNodeInfoListOutput) BrokerId() pulumi.Float64Output

ID of the broker

func (GetBrokerNodesNodeInfoListOutput) ClientSubnet 

func (o GetBrokerNodesNodeInfoListOutput) ClientSubnet() pulumi.StringOutput

Client subnet to which this broker node belongs

func (GetBrokerNodesNodeInfoListOutput) ClientVpcIpAddress 

func (o GetBrokerNodesNodeInfoListOutput) ClientVpcIpAddress() pulumi.StringOutput

The client virtual private cloud (VPC) IP address

func (GetBrokerNodesNodeInfoListOutput) ElementType 

func (GetBrokerNodesNodeInfoListOutput) ElementType() reflect.Type

func (GetBrokerNodesNodeInfoListOutput) Endpoints 

func (o GetBrokerNodesNodeInfoListOutput) Endpoints() pulumi.StringArrayOutput

Set of endpoints for accessing the broker. This does not include ports

func (GetBrokerNodesNodeInfoListOutput) NodeArn 

func (o GetBrokerNodesNodeInfoListOutput) NodeArn() pulumi.StringOutput

ARN of the node

func (GetBrokerNodesNodeInfoListOutput) ToGetBrokerNodesNodeInfoListOutput 

func (o GetBrokerNodesNodeInfoListOutput) ToGetBrokerNodesNodeInfoListOutput() GetBrokerNodesNodeInfoListOutput

func (GetBrokerNodesNodeInfoListOutput) ToGetBrokerNodesNodeInfoListOutputWithContext 

func (o GetBrokerNodesNodeInfoListOutput) ToGetBrokerNodesNodeInfoListOutputWithContext(ctx context.Context) GetBrokerNodesNodeInfoListOutput

type GetBrokerNodesOutputArgs 

type GetBrokerNodesOutputArgs struct {
	// ARN of the cluster the nodes belong to.
	ClusterArn pulumi.StringInput `pulumi:"clusterArn"`
}

A collection of arguments for invoking getBrokerNodes.

func (GetBrokerNodesOutputArgs) ElementType 

func (GetBrokerNodesOutputArgs) ElementType() reflect.Type

type GetBrokerNodesResult 

type GetBrokerNodesResult struct {
	ClusterArn string `pulumi:"clusterArn"`
	// The provider-assigned unique ID for this managed resource.
	Id            string                       `pulumi:"id"`
	NodeInfoLists []GetBrokerNodesNodeInfoList `pulumi:"nodeInfoLists"`
}

A collection of values returned by getBrokerNodes.

func GetBrokerNodes 

func GetBrokerNodes(ctx *pulumi.Context, args *GetBrokerNodesArgs, opts ...pulumi.InvokeOption) (*GetBrokerNodesResult, error)

Get information on an Amazon MSK Broker Nodes.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := msk.GetBrokerNodes(ctx, &msk.GetBrokerNodesArgs{
			ClusterArn: aws_msk_cluster.Example.Arn,
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetBrokerNodesResultOutput 

type GetBrokerNodesResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getBrokerNodes.

func GetBrokerNodesOutput 

func GetBrokerNodesOutput(ctx *pulumi.Context, args GetBrokerNodesOutputArgs, opts ...pulumi.InvokeOption) GetBrokerNodesResultOutput

func (GetBrokerNodesResultOutput) ClusterArn 

func (o GetBrokerNodesResultOutput) ClusterArn() pulumi.StringOutput

func (GetBrokerNodesResultOutput) ElementType 

func (GetBrokerNodesResultOutput) ElementType() reflect.Type

func (GetBrokerNodesResultOutput) Id 

func (o GetBrokerNodesResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetBrokerNodesResultOutput) NodeInfoLists 

func (o GetBrokerNodesResultOutput) NodeInfoLists() GetBrokerNodesNodeInfoListArrayOutput

func (GetBrokerNodesResultOutput) ToGetBrokerNodesResultOutput 

func (o GetBrokerNodesResultOutput) ToGetBrokerNodesResultOutput() GetBrokerNodesResultOutput

func (GetBrokerNodesResultOutput) ToGetBrokerNodesResultOutputWithContext 

func (o GetBrokerNodesResultOutput) ToGetBrokerNodesResultOutputWithContext(ctx context.Context) GetBrokerNodesResultOutput

type GetKafkaVersionArgs 

type GetKafkaVersionArgs struct {
	// Ordered list of preferred Kafka versions. The first match in this list will be returned. Either `preferredVersions` or `version` must be set.
	PreferredVersions []string `pulumi:"preferredVersions"`
	// Version of MSK Kafka. For example 2.4.1.1 or "2.2.1" etc. Either `preferredVersions` or `version` must be set.
	Version *string `pulumi:"version"`
}

A collection of arguments for invoking getKafkaVersion.

type GetKafkaVersionOutputArgs 

type GetKafkaVersionOutputArgs struct {
	// Ordered list of preferred Kafka versions. The first match in this list will be returned. Either `preferredVersions` or `version` must be set.
	PreferredVersions pulumi.StringArrayInput `pulumi:"preferredVersions"`
	// Version of MSK Kafka. For example 2.4.1.1 or "2.2.1" etc. Either `preferredVersions` or `version` must be set.
	Version pulumi.StringPtrInput `pulumi:"version"`
}

A collection of arguments for invoking getKafkaVersion.

func (GetKafkaVersionOutputArgs) ElementType 

func (GetKafkaVersionOutputArgs) ElementType() reflect.Type

type GetKafkaVersionResult 

type GetKafkaVersionResult struct {
	// The provider-assigned unique ID for this managed resource.
	Id                string   `pulumi:"id"`
	PreferredVersions []string `pulumi:"preferredVersions"`
	// Status of the MSK Kafka version eg. `ACTIVE` or `DEPRECATED`.
	Status  string `pulumi:"status"`
	Version string `pulumi:"version"`
}

A collection of values returned by getKafkaVersion.

func GetKafkaVersion 

func GetKafkaVersion(ctx *pulumi.Context, args *GetKafkaVersionArgs, opts ...pulumi.InvokeOption) (*GetKafkaVersionResult, error)

Get information on a Amazon MSK Kafka Version

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := msk.GetKafkaVersion(ctx, &msk.GetKafkaVersionArgs{
			PreferredVersions: []string{
				"2.4.1.1",
				"2.4.1",
				"2.2.1",
			},
		}, nil)
		if err != nil {
			return err
		}
		_, err = msk.GetKafkaVersion(ctx, &msk.GetKafkaVersionArgs{
			Version: pulumi.StringRef("2.8.0"),
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type GetKafkaVersionResultOutput 

type GetKafkaVersionResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getKafkaVersion.

func GetKafkaVersionOutput 

func GetKafkaVersionOutput(ctx *pulumi.Context, args GetKafkaVersionOutputArgs, opts ...pulumi.InvokeOption) GetKafkaVersionResultOutput

func (GetKafkaVersionResultOutput) ElementType 

func (GetKafkaVersionResultOutput) ElementType() reflect.Type

func (GetKafkaVersionResultOutput) Id 

func (o GetKafkaVersionResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetKafkaVersionResultOutput) PreferredVersions 

func (o GetKafkaVersionResultOutput) PreferredVersions() pulumi.StringArrayOutput

func (GetKafkaVersionResultOutput) Status 

func (o GetKafkaVersionResultOutput) Status() pulumi.StringOutput

Status of the MSK Kafka version eg. `ACTIVE` or `DEPRECATED`.

func (GetKafkaVersionResultOutput) ToGetKafkaVersionResultOutput 

func (o GetKafkaVersionResultOutput) ToGetKafkaVersionResultOutput() GetKafkaVersionResultOutput

func (GetKafkaVersionResultOutput) ToGetKafkaVersionResultOutputWithContext 

func (o GetKafkaVersionResultOutput) ToGetKafkaVersionResultOutputWithContext(ctx context.Context) GetKafkaVersionResultOutput

func (GetKafkaVersionResultOutput) Version 

func (o GetKafkaVersionResultOutput) Version() pulumi.StringOutput

type LookupClusterArgs 

type LookupClusterArgs struct {
	// Name of the cluster.
	ClusterName string `pulumi:"clusterName"`
	// Map of key-value pairs assigned to the cluster.
	Tags map[string]string `pulumi:"tags"`
}

A collection of arguments for invoking getCluster.

type LookupClusterOutputArgs 

type LookupClusterOutputArgs struct {
	// Name of the cluster.
	ClusterName pulumi.StringInput `pulumi:"clusterName"`
	// Map of key-value pairs assigned to the cluster.
	Tags pulumi.StringMapInput `pulumi:"tags"`
}

A collection of arguments for invoking getCluster.

func (LookupClusterOutputArgs) ElementType 

func (LookupClusterOutputArgs) ElementType() reflect.Type

type LookupClusterResult 

type LookupClusterResult struct {
	// ARN of the MSK cluster.
	Arn string `pulumi:"arn"`
	// Comma separated list of one or more hostname:port pairs of kafka brokers suitable to bootstrap connectivity to the kafka cluster. Contains a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `PLAINTEXT` or `TLS_PLAINTEXT`. The resource sorts values alphabetically. AWS may not always return all endpoints so this value is not guaranteed to be stable across applies.
	BootstrapBrokers string `pulumi:"bootstrapBrokers"`
	// One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicSaslIam string `pulumi:"bootstrapBrokersPublicSaslIam"`
	// One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicSaslScram string `pulumi:"bootstrapBrokersPublicSaslScram"`
	// One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersPublicTls string `pulumi:"bootstrapBrokersPublicTls"`
	// One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersSaslIam string `pulumi:"bootstrapBrokersSaslIam"`
	// One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersSaslScram string `pulumi:"bootstrapBrokersSaslScram"`
	// One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.
	BootstrapBrokersTls string `pulumi:"bootstrapBrokersTls"`
	ClusterName         string `pulumi:"clusterName"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// Apache Kafka version.
	KafkaVersion string `pulumi:"kafkaVersion"`
	// Number of broker nodes in the cluster.
	NumberOfBrokerNodes int `pulumi:"numberOfBrokerNodes"`
	// Map of key-value pairs assigned to the cluster.
	Tags map[string]string `pulumi:"tags"`
	// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster. The returned values are sorted alphbetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
	ZookeeperConnectString string `pulumi:"zookeeperConnectString"`
	// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster via TLS. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
	ZookeeperConnectStringTls string `pulumi:"zookeeperConnectStringTls"`
}

A collection of values returned by getCluster.

func LookupCluster 

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

Get information on an Amazon MSK Cluster.

> **Note:** This data sources returns information on _provisioned_ clusters.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := msk.LookupCluster(ctx, &msk.LookupClusterArgs{
			ClusterName: "example",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupClusterResultOutput 

type LookupClusterResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getCluster.

func LookupClusterOutput 

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

func (LookupClusterResultOutput) Arn 

func (o LookupClusterResultOutput) Arn() pulumi.StringOutput

ARN of the MSK cluster.

func (LookupClusterResultOutput) BootstrapBrokers 

func (o LookupClusterResultOutput) BootstrapBrokers() pulumi.StringOutput

Comma separated list of one or more hostname:port pairs of kafka brokers suitable to bootstrap connectivity to the kafka cluster. Contains a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `PLAINTEXT` or `TLS_PLAINTEXT`. The resource sorts values alphabetically. AWS may not always return all endpoints so this value is not guaranteed to be stable across applies.

func (LookupClusterResultOutput) BootstrapBrokersPublicSaslIam added in v5.5.0 

func (o LookupClusterResultOutput) BootstrapBrokersPublicSaslIam() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (LookupClusterResultOutput) BootstrapBrokersPublicSaslScram added in v5.5.0 

func (o LookupClusterResultOutput) BootstrapBrokersPublicSaslScram() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (LookupClusterResultOutput) BootstrapBrokersPublicTls added in v5.5.0 

func (o LookupClusterResultOutput) BootstrapBrokersPublicTls() pulumi.StringOutput

One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `broker_node_group_info.0.connectivity_info.0.public_access.0.type` is set to `SERVICE_PROVIDED_EIPS` and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (LookupClusterResultOutput) BootstrapBrokersSaslIam 

func (o LookupClusterResultOutput) BootstrapBrokersSaslIam() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.iam` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (LookupClusterResultOutput) BootstrapBrokersSaslScram 

func (o LookupClusterResultOutput) BootstrapBrokersSaslScram() pulumi.StringOutput

One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS` and `client_authentication.0.sasl.0.scram` is set to `true`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (LookupClusterResultOutput) BootstrapBrokersTls 

func (o LookupClusterResultOutput) BootstrapBrokersTls() pulumi.StringOutput

One or more DNS names (or IP addresses) and TLS port pairs. For example, `b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094`. This attribute will have a value if `encryption_info.0.encryption_in_transit.0.client_broker` is set to `TLS_PLAINTEXT` or `TLS`. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies.

func (LookupClusterResultOutput) ClusterName 

func (o LookupClusterResultOutput) ClusterName() pulumi.StringOutput

func (LookupClusterResultOutput) ElementType 

func (LookupClusterResultOutput) ElementType() reflect.Type

func (LookupClusterResultOutput) Id 

func (o LookupClusterResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupClusterResultOutput) KafkaVersion 

func (o LookupClusterResultOutput) KafkaVersion() pulumi.StringOutput

Apache Kafka version.

func (LookupClusterResultOutput) NumberOfBrokerNodes 

func (o LookupClusterResultOutput) NumberOfBrokerNodes() pulumi.IntOutput

Number of broker nodes in the cluster.

func (LookupClusterResultOutput) Tags 

func (o LookupClusterResultOutput) Tags() pulumi.StringMapOutput

Map of key-value pairs assigned to the cluster.

func (LookupClusterResultOutput) ToLookupClusterResultOutput 

func (o LookupClusterResultOutput) ToLookupClusterResultOutput() LookupClusterResultOutput

func (LookupClusterResultOutput) ToLookupClusterResultOutputWithContext 

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

func (LookupClusterResultOutput) ZookeeperConnectString 

func (o LookupClusterResultOutput) ZookeeperConnectString() pulumi.StringOutput

A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster. The returned values are sorted alphbetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.

func (LookupClusterResultOutput) ZookeeperConnectStringTls added in v5.2.0 

func (o LookupClusterResultOutput) ZookeeperConnectStringTls() pulumi.StringOutput

A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster via TLS. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.

type LookupConfigurationArgs 

type LookupConfigurationArgs struct {
	// Name of the configuration.
	Name string `pulumi:"name"`
}

A collection of arguments for invoking getConfiguration.

type LookupConfigurationOutputArgs 

type LookupConfigurationOutputArgs struct {
	// Name of the configuration.
	Name pulumi.StringInput `pulumi:"name"`
}

A collection of arguments for invoking getConfiguration.

func (LookupConfigurationOutputArgs) ElementType 

func (LookupConfigurationOutputArgs) ElementType() reflect.Type

type LookupConfigurationResult 

type LookupConfigurationResult struct {
	// ARN of the configuration.
	Arn string `pulumi:"arn"`
	// Description of the configuration.
	Description string `pulumi:"description"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// List of Apache Kafka versions which can use this configuration.
	KafkaVersions []string `pulumi:"kafkaVersions"`
	// Latest revision of the configuration.
	LatestRevision int    `pulumi:"latestRevision"`
	Name           string `pulumi:"name"`
	// Contents of the server.properties file.
	ServerProperties string `pulumi:"serverProperties"`
}

A collection of values returned by getConfiguration.

func LookupConfiguration 

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

Get information on an Amazon MSK Configuration.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := msk.LookupConfiguration(ctx, &msk.LookupConfigurationArgs{
			Name: "example",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupConfigurationResultOutput 

type LookupConfigurationResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getConfiguration.

func LookupConfigurationOutput 

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

func (LookupConfigurationResultOutput) Arn 

func (o LookupConfigurationResultOutput) Arn() pulumi.StringOutput

ARN of the configuration.

func (LookupConfigurationResultOutput) Description 

func (o LookupConfigurationResultOutput) Description() pulumi.StringOutput

Description of the configuration.

func (LookupConfigurationResultOutput) ElementType 

func (LookupConfigurationResultOutput) ElementType() reflect.Type

func (LookupConfigurationResultOutput) Id 

func (o LookupConfigurationResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupConfigurationResultOutput) KafkaVersions 

func (o LookupConfigurationResultOutput) KafkaVersions() pulumi.StringArrayOutput

List of Apache Kafka versions which can use this configuration.

func (LookupConfigurationResultOutput) LatestRevision 

func (o LookupConfigurationResultOutput) LatestRevision() pulumi.IntOutput

Latest revision of the configuration.

func (LookupConfigurationResultOutput) Name 

func (o LookupConfigurationResultOutput) Name() pulumi.StringOutput

func (LookupConfigurationResultOutput) ServerProperties 

func (o LookupConfigurationResultOutput) ServerProperties() pulumi.StringOutput

Contents of the server.properties file.

func (LookupConfigurationResultOutput) ToLookupConfigurationResultOutput 

func (o LookupConfigurationResultOutput) ToLookupConfigurationResultOutput() LookupConfigurationResultOutput

func (LookupConfigurationResultOutput) ToLookupConfigurationResultOutputWithContext 

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

type ScramSecretAssociation 

type ScramSecretAssociation struct {
	pulumi.CustomResourceState

	// Amazon Resource Name (ARN) of the MSK cluster.
	ClusterArn pulumi.StringOutput `pulumi:"clusterArn"`
	// List of AWS Secrets Manager secret ARNs.
	SecretArnLists pulumi.StringArrayOutput `pulumi:"secretArnLists"`
}

Associates SCRAM secrets stored in the Secrets Manager service with a Managed Streaming for Kafka (MSK) cluster.

> **Note:** The following assumes the MSK cluster has SASL/SCRAM authentication enabled. See below for example usage or refer to the [Username/Password Authentication](https://docs.aws.amazon.com/msk/latest/developerguide/msk-password.html) section of the MSK Developer Guide for more details.

To set up username and password authentication for a cluster, create an `secretsmanager.Secret` resource and associate a username and password with the secret with an `secretsmanager.SecretVersion` resource. When creating a secret for the cluster, the `name` must have the prefix `AmazonMSK_` and you must either use an existing custom AWS KMS key or create a new custom AWS KMS key for your secret with the `kms.Key` resource. It is important to note that a policy is required for the `secretsmanager.Secret` resource in order for Kafka to be able to read it. This policy is attached automatically when the `msk.ScramSecretAssociation` is used, however, this policy will not be in the state and as such, will present a diff on plan/apply. For that reason, you must use the `secretsmanager.SecretPolicy` resource](/docs/providers/aws/r/secretsmanager_secret_policy.html) as shown below in order to ensure that the state is in a clean state after the creation of secret and the association to the cluster.

## Example Usage

```go package main

import ( 

"encoding/json"

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/iam"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/kms"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/msk"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/secretsmanager"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleCluster, err := msk.NewCluster(ctx, "exampleCluster", &msk.ClusterArgs{
			ClientAuthentication: &msk.ClusterClientAuthenticationArgs{
				Sasl: &msk.ClusterClientAuthenticationSaslArgs{
					Scram: pulumi.Bool(true),
				},
			},
		})
		if err != nil {
			return err
		}
		exampleKey, err := kms.NewKey(ctx, "exampleKey", &kms.KeyArgs{
			Description: pulumi.String("Example Key for MSK Cluster Scram Secret Association"),
		})
		if err != nil {
			return err
		}
		exampleSecret, err := secretsmanager.NewSecret(ctx, "exampleSecret", &secretsmanager.SecretArgs{
			KmsKeyId: exampleKey.KeyId,
		})
		if err != nil {
			return err
		}
		tmpJSON0, err := json.Marshal(map[string]interface{}{
			"username": "user",
			"password": "pass",
		})
		if err != nil {
			return err
		}
		json0 := string(tmpJSON0)
		exampleSecretVersion, err := secretsmanager.NewSecretVersion(ctx, "exampleSecretVersion", &secretsmanager.SecretVersionArgs{
			SecretId:     exampleSecret.ID(),
			SecretString: pulumi.String(json0),
		})
		if err != nil {
			return err
		}
		_, err = msk.NewScramSecretAssociation(ctx, "exampleScramSecretAssociation", &msk.ScramSecretAssociationArgs{
			ClusterArn: exampleCluster.Arn,
			SecretArnLists: pulumi.StringArray{
				exampleSecret.Arn,
			},
		}, pulumi.DependsOn([]pulumi.Resource{
			exampleSecretVersion,
		}))
		if err != nil {
			return err
		}
		examplePolicyDocument := iam.GetPolicyDocumentOutput(ctx, iam.GetPolicyDocumentOutputArgs{
			Statements: iam.GetPolicyDocumentStatementArray{
				&iam.GetPolicyDocumentStatementArgs{
					Sid:    pulumi.String("AWSKafkaResourcePolicy"),
					Effect: pulumi.String("Allow"),
					Principals: iam.GetPolicyDocumentStatementPrincipalArray{
						&iam.GetPolicyDocumentStatementPrincipalArgs{
							Type: pulumi.String("Service"),
							Identifiers: pulumi.StringArray{
								pulumi.String("kafka.amazonaws.com"),
							},
						},
					},
					Actions: pulumi.StringArray{
						pulumi.String("secretsmanager:getSecretValue"),
					},
					Resources: pulumi.StringArray{
						exampleSecret.Arn,
					},
				},
			},
		}, nil)
		_, err = secretsmanager.NewSecretPolicy(ctx, "exampleSecretPolicy", &secretsmanager.SecretPolicyArgs{
			SecretArn: exampleSecret.Arn,
			Policy: examplePolicyDocument.ApplyT(func(examplePolicyDocument iam.GetPolicyDocumentResult) (*string, error) {
				return &examplePolicyDocument.Json, nil
			}).(pulumi.StringPtrOutput),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MSK SCRAM Secret Associations can be imported using the `id` e.g.,

```sh 

$ pulumi import aws:msk/scramSecretAssociation:ScramSecretAssociation example arn:aws:kafka:us-west-2:123456789012:cluster/example/279c0212-d057-4dba-9aa9-1c4e5a25bfc7-3

```

func GetScramSecretAssociation 

func GetScramSecretAssociation(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ScramSecretAssociationState, opts ...pulumi.ResourceOption) (*ScramSecretAssociation, error)

GetScramSecretAssociation gets an existing ScramSecretAssociation 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 NewScramSecretAssociation 

func NewScramSecretAssociation(ctx *pulumi.Context,
	name string, args *ScramSecretAssociationArgs, opts ...pulumi.ResourceOption) (*ScramSecretAssociation, error)

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

func (*ScramSecretAssociation) ElementType 

func (*ScramSecretAssociation) ElementType() reflect.Type

func (*ScramSecretAssociation) ToScramSecretAssociationOutput 

func (i *ScramSecretAssociation) ToScramSecretAssociationOutput() ScramSecretAssociationOutput

func (*ScramSecretAssociation) ToScramSecretAssociationOutputWithContext 

func (i *ScramSecretAssociation) ToScramSecretAssociationOutputWithContext(ctx context.Context) ScramSecretAssociationOutput

type ScramSecretAssociationArgs 

type ScramSecretAssociationArgs struct {
	// Amazon Resource Name (ARN) of the MSK cluster.
	ClusterArn pulumi.StringInput
	// List of AWS Secrets Manager secret ARNs.
	SecretArnLists pulumi.StringArrayInput
}

The set of arguments for constructing a ScramSecretAssociation resource.

func (ScramSecretAssociationArgs) ElementType 

func (ScramSecretAssociationArgs) ElementType() reflect.Type

type ScramSecretAssociationArray 

type ScramSecretAssociationArray []ScramSecretAssociationInput

func (ScramSecretAssociationArray) ElementType 

func (ScramSecretAssociationArray) ElementType() reflect.Type

func (ScramSecretAssociationArray) ToScramSecretAssociationArrayOutput 

func (i ScramSecretAssociationArray) ToScramSecretAssociationArrayOutput() ScramSecretAssociationArrayOutput

func (ScramSecretAssociationArray) ToScramSecretAssociationArrayOutputWithContext 

func (i ScramSecretAssociationArray) ToScramSecretAssociationArrayOutputWithContext(ctx context.Context) ScramSecretAssociationArrayOutput

type ScramSecretAssociationArrayInput 

type ScramSecretAssociationArrayInput interface {
	pulumi.Input

	ToScramSecretAssociationArrayOutput() ScramSecretAssociationArrayOutput
	ToScramSecretAssociationArrayOutputWithContext(context.Context) ScramSecretAssociationArrayOutput
}

ScramSecretAssociationArrayInput is an input type that accepts ScramSecretAssociationArray and ScramSecretAssociationArrayOutput values. You can construct a concrete instance of `ScramSecretAssociationArrayInput` via: 

ScramSecretAssociationArray{ ScramSecretAssociationArgs{...} }

type ScramSecretAssociationArrayOutput 

type ScramSecretAssociationArrayOutput struct{ *pulumi.OutputState }

func (ScramSecretAssociationArrayOutput) ElementType 

func (ScramSecretAssociationArrayOutput) ElementType() reflect.Type

func (ScramSecretAssociationArrayOutput) Index 

func (o ScramSecretAssociationArrayOutput) Index(i pulumi.IntInput) ScramSecretAssociationOutput

func (ScramSecretAssociationArrayOutput) ToScramSecretAssociationArrayOutput 

func (o ScramSecretAssociationArrayOutput) ToScramSecretAssociationArrayOutput() ScramSecretAssociationArrayOutput

func (ScramSecretAssociationArrayOutput) ToScramSecretAssociationArrayOutputWithContext 

func (o ScramSecretAssociationArrayOutput) ToScramSecretAssociationArrayOutputWithContext(ctx context.Context) ScramSecretAssociationArrayOutput

type ScramSecretAssociationInput 

type ScramSecretAssociationInput interface {
	pulumi.Input

	ToScramSecretAssociationOutput() ScramSecretAssociationOutput
	ToScramSecretAssociationOutputWithContext(ctx context.Context) ScramSecretAssociationOutput
}

type ScramSecretAssociationMap 

type ScramSecretAssociationMap map[string]ScramSecretAssociationInput

func (ScramSecretAssociationMap) ElementType 

func (ScramSecretAssociationMap) ElementType() reflect.Type

func (ScramSecretAssociationMap) ToScramSecretAssociationMapOutput 

func (i ScramSecretAssociationMap) ToScramSecretAssociationMapOutput() ScramSecretAssociationMapOutput

func (ScramSecretAssociationMap) ToScramSecretAssociationMapOutputWithContext 

func (i ScramSecretAssociationMap) ToScramSecretAssociationMapOutputWithContext(ctx context.Context) ScramSecretAssociationMapOutput

type ScramSecretAssociationMapInput 

type ScramSecretAssociationMapInput interface {
	pulumi.Input

	ToScramSecretAssociationMapOutput() ScramSecretAssociationMapOutput
	ToScramSecretAssociationMapOutputWithContext(context.Context) ScramSecretAssociationMapOutput
}

ScramSecretAssociationMapInput is an input type that accepts ScramSecretAssociationMap and ScramSecretAssociationMapOutput values. You can construct a concrete instance of `ScramSecretAssociationMapInput` via: 

ScramSecretAssociationMap{ "key": ScramSecretAssociationArgs{...} }

type ScramSecretAssociationMapOutput 

type ScramSecretAssociationMapOutput struct{ *pulumi.OutputState }

func (ScramSecretAssociationMapOutput) ElementType 

func (ScramSecretAssociationMapOutput) ElementType() reflect.Type

func (ScramSecretAssociationMapOutput) MapIndex 

func (o ScramSecretAssociationMapOutput) MapIndex(k pulumi.StringInput) ScramSecretAssociationOutput

func (ScramSecretAssociationMapOutput) ToScramSecretAssociationMapOutput 

func (o ScramSecretAssociationMapOutput) ToScramSecretAssociationMapOutput() ScramSecretAssociationMapOutput

func (ScramSecretAssociationMapOutput) ToScramSecretAssociationMapOutputWithContext 

func (o ScramSecretAssociationMapOutput) ToScramSecretAssociationMapOutputWithContext(ctx context.Context) ScramSecretAssociationMapOutput

type ScramSecretAssociationOutput 

type ScramSecretAssociationOutput struct{ *pulumi.OutputState }

func (ScramSecretAssociationOutput) ClusterArn added in v5.4.0 

func (o ScramSecretAssociationOutput) ClusterArn() pulumi.StringOutput

Amazon Resource Name (ARN) of the MSK cluster.

func (ScramSecretAssociationOutput) ElementType 

func (ScramSecretAssociationOutput) ElementType() reflect.Type

func (ScramSecretAssociationOutput) SecretArnLists added in v5.4.0 

func (o ScramSecretAssociationOutput) SecretArnLists() pulumi.StringArrayOutput

List of AWS Secrets Manager secret ARNs.

func (ScramSecretAssociationOutput) ToScramSecretAssociationOutput 

func (o ScramSecretAssociationOutput) ToScramSecretAssociationOutput() ScramSecretAssociationOutput

func (ScramSecretAssociationOutput) ToScramSecretAssociationOutputWithContext 

func (o ScramSecretAssociationOutput) ToScramSecretAssociationOutputWithContext(ctx context.Context) ScramSecretAssociationOutput

type ScramSecretAssociationState 

type ScramSecretAssociationState struct {
	// Amazon Resource Name (ARN) of the MSK cluster.
	ClusterArn pulumi.StringPtrInput
	// List of AWS Secrets Manager secret ARNs.
	SecretArnLists pulumi.StringArrayInput
}

func (ScramSecretAssociationState) ElementType 

func (ScramSecretAssociationState) ElementType() reflect.Type

type ServerlessCluster added in v5.12.1 

type ServerlessCluster struct {
	pulumi.CustomResourceState

	// The ARN of the serverless cluster.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// Specifies client authentication information for the serverless cluster. See below.
	ClientAuthentication ServerlessClusterClientAuthenticationOutput `pulumi:"clientAuthentication"`
	// The name of the serverless cluster.
	ClusterName pulumi.StringOutput `pulumi:"clusterName"`
	// A map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// VPC configuration information. See below.
	VpcConfigs ServerlessClusterVpcConfigArrayOutput `pulumi:"vpcConfigs"`
}

Manages an Amazon MSK Serverless cluster.

> **Note:** To manage a _provisioned_ Amazon MSK cluster, use the `msk.Cluster` resource.

## Import

MSK serverless clusters can be imported using the cluster `arn`, e.g.,

```sh 

$ pulumi import aws:msk/serverlessCluster:ServerlessCluster example arn:aws:kafka:us-west-2:123456789012:cluster/example/279c0212-d057-4dba-9aa9-1c4e5a25bfc7-3

```

func GetServerlessCluster added in v5.12.1 

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 v5.12.1 

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 v5.12.1 

func (*ServerlessCluster) ElementType() reflect.Type

func (*ServerlessCluster) ToServerlessClusterOutput added in v5.12.1 

func (i *ServerlessCluster) ToServerlessClusterOutput() ServerlessClusterOutput

func (*ServerlessCluster) ToServerlessClusterOutputWithContext added in v5.12.1 

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

type ServerlessClusterArgs added in v5.12.1 

type ServerlessClusterArgs struct {
	// Specifies client authentication information for the serverless cluster. See below.
	ClientAuthentication ServerlessClusterClientAuthenticationInput
	// The name of the serverless cluster.
	ClusterName pulumi.StringPtrInput
	// A map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// VPC configuration information. See below.
	VpcConfigs ServerlessClusterVpcConfigArrayInput
}

The set of arguments for constructing a ServerlessCluster resource.

func (ServerlessClusterArgs) ElementType added in v5.12.1 

func (ServerlessClusterArgs) ElementType() reflect.Type

type ServerlessClusterArray added in v5.12.1 

type ServerlessClusterArray []ServerlessClusterInput

func (ServerlessClusterArray) ElementType added in v5.12.1 

func (ServerlessClusterArray) ElementType() reflect.Type

func (ServerlessClusterArray) ToServerlessClusterArrayOutput added in v5.12.1 

func (i ServerlessClusterArray) ToServerlessClusterArrayOutput() ServerlessClusterArrayOutput

func (ServerlessClusterArray) ToServerlessClusterArrayOutputWithContext added in v5.12.1 

func (i ServerlessClusterArray) ToServerlessClusterArrayOutputWithContext(ctx context.Context) ServerlessClusterArrayOutput

type ServerlessClusterArrayInput added in v5.12.1 

type ServerlessClusterArrayInput interface {
	pulumi.Input

	ToServerlessClusterArrayOutput() ServerlessClusterArrayOutput
	ToServerlessClusterArrayOutputWithContext(context.Context) ServerlessClusterArrayOutput
}

ServerlessClusterArrayInput is an input type that accepts ServerlessClusterArray and ServerlessClusterArrayOutput values. You can construct a concrete instance of `ServerlessClusterArrayInput` via: 

ServerlessClusterArray{ ServerlessClusterArgs{...} }

type ServerlessClusterArrayOutput added in v5.12.1 

type ServerlessClusterArrayOutput struct{ *pulumi.OutputState }

func (ServerlessClusterArrayOutput) ElementType added in v5.12.1 

func (ServerlessClusterArrayOutput) ElementType() reflect.Type

func (ServerlessClusterArrayOutput) Index added in v5.12.1 

func (o ServerlessClusterArrayOutput) Index(i pulumi.IntInput) ServerlessClusterOutput

func (ServerlessClusterArrayOutput) ToServerlessClusterArrayOutput added in v5.12.1 

func (o ServerlessClusterArrayOutput) ToServerlessClusterArrayOutput() ServerlessClusterArrayOutput

func (ServerlessClusterArrayOutput) ToServerlessClusterArrayOutputWithContext added in v5.12.1 

func (o ServerlessClusterArrayOutput) ToServerlessClusterArrayOutputWithContext(ctx context.Context) ServerlessClusterArrayOutput

type ServerlessClusterClientAuthentication added in v5.12.1 

type ServerlessClusterClientAuthentication struct {
	// Details for client authentication using SASL. See below.
	Sasl ServerlessClusterClientAuthenticationSasl `pulumi:"sasl"`
}

type ServerlessClusterClientAuthenticationArgs added in v5.12.1 

type ServerlessClusterClientAuthenticationArgs struct {
	// Details for client authentication using SASL. See below.
	Sasl ServerlessClusterClientAuthenticationSaslInput `pulumi:"sasl"`
}

func (ServerlessClusterClientAuthenticationArgs) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationArgs) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationOutput added in v5.12.1 

func (i ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationOutput() ServerlessClusterClientAuthenticationOutput

func (ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationOutputWithContext added in v5.12.1 

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

func (ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationPtrOutput added in v5.12.1 

func (i ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationPtrOutput() ServerlessClusterClientAuthenticationPtrOutput

func (ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationPtrOutputWithContext added in v5.12.1 

func (i ServerlessClusterClientAuthenticationArgs) ToServerlessClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationPtrOutput

type ServerlessClusterClientAuthenticationInput added in v5.12.1 

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 v5.12.1 

type ServerlessClusterClientAuthenticationOutput struct{ *pulumi.OutputState }

func (ServerlessClusterClientAuthenticationOutput) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationOutput) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationOutput) Sasl added in v5.12.1 

func (o ServerlessClusterClientAuthenticationOutput) Sasl() ServerlessClusterClientAuthenticationSaslOutput

Details for client authentication using SASL. See below.

func (ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationOutput() ServerlessClusterClientAuthenticationOutput

func (ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationOutputWithContext added in v5.12.1 

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

func (ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationPtrOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationPtrOutput() ServerlessClusterClientAuthenticationPtrOutput

func (ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationPtrOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationOutput) ToServerlessClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationPtrOutput

type ServerlessClusterClientAuthenticationPtrInput added in v5.12.1 

type ServerlessClusterClientAuthenticationPtrInput interface {
	pulumi.Input

	ToServerlessClusterClientAuthenticationPtrOutput() ServerlessClusterClientAuthenticationPtrOutput
	ToServerlessClusterClientAuthenticationPtrOutputWithContext(context.Context) ServerlessClusterClientAuthenticationPtrOutput
}

ServerlessClusterClientAuthenticationPtrInput is an input type that accepts ServerlessClusterClientAuthenticationArgs, ServerlessClusterClientAuthenticationPtr and ServerlessClusterClientAuthenticationPtrOutput values. You can construct a concrete instance of `ServerlessClusterClientAuthenticationPtrInput` via: 

        ServerlessClusterClientAuthenticationArgs{...}

or:

        nil

func ServerlessClusterClientAuthenticationPtr added in v5.12.1 

func ServerlessClusterClientAuthenticationPtr(v *ServerlessClusterClientAuthenticationArgs) ServerlessClusterClientAuthenticationPtrInput

type ServerlessClusterClientAuthenticationPtrOutput added in v5.12.1 

type ServerlessClusterClientAuthenticationPtrOutput struct{ *pulumi.OutputState }

func (ServerlessClusterClientAuthenticationPtrOutput) Elem added in v5.12.1 

func (o ServerlessClusterClientAuthenticationPtrOutput) Elem() ServerlessClusterClientAuthenticationOutput

func (ServerlessClusterClientAuthenticationPtrOutput) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationPtrOutput) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationPtrOutput) Sasl added in v5.12.1 

func (o ServerlessClusterClientAuthenticationPtrOutput) Sasl() ServerlessClusterClientAuthenticationSaslPtrOutput

Details for client authentication using SASL. See below.

func (ServerlessClusterClientAuthenticationPtrOutput) ToServerlessClusterClientAuthenticationPtrOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationPtrOutput) ToServerlessClusterClientAuthenticationPtrOutput() ServerlessClusterClientAuthenticationPtrOutput

func (ServerlessClusterClientAuthenticationPtrOutput) ToServerlessClusterClientAuthenticationPtrOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationPtrOutput) ToServerlessClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationPtrOutput

type ServerlessClusterClientAuthenticationSasl added in v5.12.1 

type ServerlessClusterClientAuthenticationSasl struct {
	// Details for client authentication using IAM. See below.
	Iam ServerlessClusterClientAuthenticationSaslIam `pulumi:"iam"`
}

type ServerlessClusterClientAuthenticationSaslArgs added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslArgs struct {
	// Details for client authentication using IAM. See below.
	Iam ServerlessClusterClientAuthenticationSaslIamInput `pulumi:"iam"`
}

func (ServerlessClusterClientAuthenticationSaslArgs) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationSaslArgs) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslOutput added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslOutput() ServerlessClusterClientAuthenticationSaslOutput

func (ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslOutputWithContext added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslOutput

func (ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslPtrOutput added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslPtrOutput() ServerlessClusterClientAuthenticationSaslPtrOutput

func (ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslPtrOutputWithContext added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslArgs) ToServerlessClusterClientAuthenticationSaslPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslPtrOutput

type ServerlessClusterClientAuthenticationSaslIam added in v5.12.1 

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

type ServerlessClusterClientAuthenticationSaslIamArgs added in v5.12.1 

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

func (ServerlessClusterClientAuthenticationSaslIamArgs) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationSaslIamArgs) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamOutput added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamOutput() ServerlessClusterClientAuthenticationSaslIamOutput

func (ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamOutputWithContext added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslIamOutput

func (ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamPtrOutput added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamPtrOutput() ServerlessClusterClientAuthenticationSaslIamPtrOutput

func (ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamPtrOutputWithContext added in v5.12.1 

func (i ServerlessClusterClientAuthenticationSaslIamArgs) ToServerlessClusterClientAuthenticationSaslIamPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslIamPtrOutput

type ServerlessClusterClientAuthenticationSaslIamInput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslIamInput interface {
	pulumi.Input

	ToServerlessClusterClientAuthenticationSaslIamOutput() ServerlessClusterClientAuthenticationSaslIamOutput
	ToServerlessClusterClientAuthenticationSaslIamOutputWithContext(context.Context) ServerlessClusterClientAuthenticationSaslIamOutput
}

ServerlessClusterClientAuthenticationSaslIamInput is an input type that accepts ServerlessClusterClientAuthenticationSaslIamArgs and ServerlessClusterClientAuthenticationSaslIamOutput values. You can construct a concrete instance of `ServerlessClusterClientAuthenticationSaslIamInput` via: 

ServerlessClusterClientAuthenticationSaslIamArgs{...}

type ServerlessClusterClientAuthenticationSaslIamOutput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslIamOutput struct{ *pulumi.OutputState }

func (ServerlessClusterClientAuthenticationSaslIamOutput) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationSaslIamOutput) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationSaslIamOutput) Enabled added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamOutput) Enabled() pulumi.BoolOutput

Whether SASL/IAM authentication is enabled or not.

func (ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamOutput() ServerlessClusterClientAuthenticationSaslIamOutput

func (ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslIamOutput

func (ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutput() ServerlessClusterClientAuthenticationSaslIamPtrOutput

func (ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslIamPtrOutput

type ServerlessClusterClientAuthenticationSaslIamPtrInput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslIamPtrInput interface {
	pulumi.Input

	ToServerlessClusterClientAuthenticationSaslIamPtrOutput() ServerlessClusterClientAuthenticationSaslIamPtrOutput
	ToServerlessClusterClientAuthenticationSaslIamPtrOutputWithContext(context.Context) ServerlessClusterClientAuthenticationSaslIamPtrOutput
}

ServerlessClusterClientAuthenticationSaslIamPtrInput is an input type that accepts ServerlessClusterClientAuthenticationSaslIamArgs, ServerlessClusterClientAuthenticationSaslIamPtr and ServerlessClusterClientAuthenticationSaslIamPtrOutput values. You can construct a concrete instance of `ServerlessClusterClientAuthenticationSaslIamPtrInput` via: 

        ServerlessClusterClientAuthenticationSaslIamArgs{...}

or:

        nil

func ServerlessClusterClientAuthenticationSaslIamPtr added in v5.12.1 

func ServerlessClusterClientAuthenticationSaslIamPtr(v *ServerlessClusterClientAuthenticationSaslIamArgs) ServerlessClusterClientAuthenticationSaslIamPtrInput

type ServerlessClusterClientAuthenticationSaslIamPtrOutput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslIamPtrOutput struct{ *pulumi.OutputState }

func (ServerlessClusterClientAuthenticationSaslIamPtrOutput) Elem added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamPtrOutput) Elem() ServerlessClusterClientAuthenticationSaslIamOutput

func (ServerlessClusterClientAuthenticationSaslIamPtrOutput) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationSaslIamPtrOutput) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationSaslIamPtrOutput) Enabled added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamPtrOutput) Enabled() pulumi.BoolPtrOutput

Whether SASL/IAM authentication is enabled or not.

func (ServerlessClusterClientAuthenticationSaslIamPtrOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamPtrOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutput() ServerlessClusterClientAuthenticationSaslIamPtrOutput

func (ServerlessClusterClientAuthenticationSaslIamPtrOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslIamPtrOutput) ToServerlessClusterClientAuthenticationSaslIamPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslIamPtrOutput

type ServerlessClusterClientAuthenticationSaslInput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslInput interface {
	pulumi.Input

	ToServerlessClusterClientAuthenticationSaslOutput() ServerlessClusterClientAuthenticationSaslOutput
	ToServerlessClusterClientAuthenticationSaslOutputWithContext(context.Context) ServerlessClusterClientAuthenticationSaslOutput
}

ServerlessClusterClientAuthenticationSaslInput is an input type that accepts ServerlessClusterClientAuthenticationSaslArgs and ServerlessClusterClientAuthenticationSaslOutput values. You can construct a concrete instance of `ServerlessClusterClientAuthenticationSaslInput` via: 

ServerlessClusterClientAuthenticationSaslArgs{...}

type ServerlessClusterClientAuthenticationSaslOutput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslOutput struct{ *pulumi.OutputState }

func (ServerlessClusterClientAuthenticationSaslOutput) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationSaslOutput) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationSaslOutput) Iam added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslOutput) Iam() ServerlessClusterClientAuthenticationSaslIamOutput

Details for client authentication using IAM. See below.

func (ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslOutput() ServerlessClusterClientAuthenticationSaslOutput

func (ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslOutput

func (ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslPtrOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslPtrOutput() ServerlessClusterClientAuthenticationSaslPtrOutput

func (ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslPtrOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslOutput) ToServerlessClusterClientAuthenticationSaslPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslPtrOutput

type ServerlessClusterClientAuthenticationSaslPtrInput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslPtrInput interface {
	pulumi.Input

	ToServerlessClusterClientAuthenticationSaslPtrOutput() ServerlessClusterClientAuthenticationSaslPtrOutput
	ToServerlessClusterClientAuthenticationSaslPtrOutputWithContext(context.Context) ServerlessClusterClientAuthenticationSaslPtrOutput
}

ServerlessClusterClientAuthenticationSaslPtrInput is an input type that accepts ServerlessClusterClientAuthenticationSaslArgs, ServerlessClusterClientAuthenticationSaslPtr and ServerlessClusterClientAuthenticationSaslPtrOutput values. You can construct a concrete instance of `ServerlessClusterClientAuthenticationSaslPtrInput` via: 

        ServerlessClusterClientAuthenticationSaslArgs{...}

or:

        nil

func ServerlessClusterClientAuthenticationSaslPtr added in v5.12.1 

func ServerlessClusterClientAuthenticationSaslPtr(v *ServerlessClusterClientAuthenticationSaslArgs) ServerlessClusterClientAuthenticationSaslPtrInput

type ServerlessClusterClientAuthenticationSaslPtrOutput added in v5.12.1 

type ServerlessClusterClientAuthenticationSaslPtrOutput struct{ *pulumi.OutputState }

func (ServerlessClusterClientAuthenticationSaslPtrOutput) Elem added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslPtrOutput) Elem() ServerlessClusterClientAuthenticationSaslOutput

func (ServerlessClusterClientAuthenticationSaslPtrOutput) ElementType added in v5.12.1 

func (ServerlessClusterClientAuthenticationSaslPtrOutput) ElementType() reflect.Type

func (ServerlessClusterClientAuthenticationSaslPtrOutput) Iam added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslPtrOutput) Iam() ServerlessClusterClientAuthenticationSaslIamPtrOutput

Details for client authentication using IAM. See below.

func (ServerlessClusterClientAuthenticationSaslPtrOutput) ToServerlessClusterClientAuthenticationSaslPtrOutput added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslPtrOutput) ToServerlessClusterClientAuthenticationSaslPtrOutput() ServerlessClusterClientAuthenticationSaslPtrOutput

func (ServerlessClusterClientAuthenticationSaslPtrOutput) ToServerlessClusterClientAuthenticationSaslPtrOutputWithContext added in v5.12.1 

func (o ServerlessClusterClientAuthenticationSaslPtrOutput) ToServerlessClusterClientAuthenticationSaslPtrOutputWithContext(ctx context.Context) ServerlessClusterClientAuthenticationSaslPtrOutput

type ServerlessClusterInput added in v5.12.1 

type ServerlessClusterInput interface {
	pulumi.Input

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

type ServerlessClusterMap added in v5.12.1 

type ServerlessClusterMap map[string]ServerlessClusterInput

func (ServerlessClusterMap) ElementType added in v5.12.1 

func (ServerlessClusterMap) ElementType() reflect.Type

func (ServerlessClusterMap) ToServerlessClusterMapOutput added in v5.12.1 

func (i ServerlessClusterMap) ToServerlessClusterMapOutput() ServerlessClusterMapOutput

func (ServerlessClusterMap) ToServerlessClusterMapOutputWithContext added in v5.12.1 

func (i ServerlessClusterMap) ToServerlessClusterMapOutputWithContext(ctx context.Context) ServerlessClusterMapOutput

type ServerlessClusterMapInput added in v5.12.1 

type ServerlessClusterMapInput interface {
	pulumi.Input

	ToServerlessClusterMapOutput() ServerlessClusterMapOutput
	ToServerlessClusterMapOutputWithContext(context.Context) ServerlessClusterMapOutput
}

ServerlessClusterMapInput is an input type that accepts ServerlessClusterMap and ServerlessClusterMapOutput values. You can construct a concrete instance of `ServerlessClusterMapInput` via: 

ServerlessClusterMap{ "key": ServerlessClusterArgs{...} }

type ServerlessClusterMapOutput added in v5.12.1 

type ServerlessClusterMapOutput struct{ *pulumi.OutputState }

func (ServerlessClusterMapOutput) ElementType added in v5.12.1 

func (ServerlessClusterMapOutput) ElementType() reflect.Type

func (ServerlessClusterMapOutput) MapIndex added in v5.12.1 

func (o ServerlessClusterMapOutput) MapIndex(k pulumi.StringInput) ServerlessClusterOutput

func (ServerlessClusterMapOutput) ToServerlessClusterMapOutput added in v5.12.1 

func (o ServerlessClusterMapOutput) ToServerlessClusterMapOutput() ServerlessClusterMapOutput

func (ServerlessClusterMapOutput) ToServerlessClusterMapOutputWithContext added in v5.12.1 

func (o ServerlessClusterMapOutput) ToServerlessClusterMapOutputWithContext(ctx context.Context) ServerlessClusterMapOutput

type ServerlessClusterOutput added in v5.12.1 

type ServerlessClusterOutput struct{ *pulumi.OutputState }

func (ServerlessClusterOutput) Arn added in v5.12.1 

func (o ServerlessClusterOutput) Arn() pulumi.StringOutput

The ARN of the serverless cluster.

func (ServerlessClusterOutput) ClientAuthentication added in v5.12.1 

func (o ServerlessClusterOutput) ClientAuthentication() ServerlessClusterClientAuthenticationOutput

Specifies client authentication information for the serverless cluster. See below.

func (ServerlessClusterOutput) ClusterName added in v5.12.1 

func (o ServerlessClusterOutput) ClusterName() pulumi.StringOutput

The name of the serverless cluster.

func (ServerlessClusterOutput) ElementType added in v5.12.1 

func (ServerlessClusterOutput) ElementType() reflect.Type

func (ServerlessClusterOutput) Tags added in v5.12.1 

func (o ServerlessClusterOutput) Tags() pulumi.StringMapOutput

A map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (ServerlessClusterOutput) TagsAll added in v5.12.1 

func (o ServerlessClusterOutput) TagsAll() pulumi.StringMapOutput

A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (ServerlessClusterOutput) ToServerlessClusterOutput added in v5.12.1 

func (o ServerlessClusterOutput) ToServerlessClusterOutput() ServerlessClusterOutput

func (ServerlessClusterOutput) ToServerlessClusterOutputWithContext added in v5.12.1 

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

func (ServerlessClusterOutput) VpcConfigs added in v5.12.1 

func (o ServerlessClusterOutput) VpcConfigs() ServerlessClusterVpcConfigArrayOutput

VPC configuration information. See below.

type ServerlessClusterState added in v5.12.1 

type ServerlessClusterState struct {
	// The ARN of the serverless cluster.
	Arn pulumi.StringPtrInput
	// Specifies client authentication information for the serverless cluster. See below.
	ClientAuthentication ServerlessClusterClientAuthenticationPtrInput
	// The name of the serverless cluster.
	ClusterName pulumi.StringPtrInput
	// A map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
	// VPC configuration information. See below.
	VpcConfigs ServerlessClusterVpcConfigArrayInput
}

func (ServerlessClusterState) ElementType added in v5.12.1 

func (ServerlessClusterState) ElementType() reflect.Type

type ServerlessClusterVpcConfig added in v5.12.1 

type ServerlessClusterVpcConfig struct {
	// Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster.
	SecurityGroupIds []string `pulumi:"securityGroupIds"`
	// A list of subnets in at least two different Availability Zones that host your client applications.
	SubnetIds []string `pulumi:"subnetIds"`
}

type ServerlessClusterVpcConfigArgs added in v5.12.1 

type ServerlessClusterVpcConfigArgs struct {
	// Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster.
	SecurityGroupIds pulumi.StringArrayInput `pulumi:"securityGroupIds"`
	// A list of subnets in at least two different Availability Zones that host your client applications.
	SubnetIds pulumi.StringArrayInput `pulumi:"subnetIds"`
}

func (ServerlessClusterVpcConfigArgs) ElementType added in v5.12.1 

func (ServerlessClusterVpcConfigArgs) ElementType() reflect.Type

func (ServerlessClusterVpcConfigArgs) ToServerlessClusterVpcConfigOutput added in v5.12.1 

func (i ServerlessClusterVpcConfigArgs) ToServerlessClusterVpcConfigOutput() ServerlessClusterVpcConfigOutput

func (ServerlessClusterVpcConfigArgs) ToServerlessClusterVpcConfigOutputWithContext added in v5.12.1 

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

type ServerlessClusterVpcConfigArray added in v5.12.1 

type ServerlessClusterVpcConfigArray []ServerlessClusterVpcConfigInput

func (ServerlessClusterVpcConfigArray) ElementType added in v5.12.1 

func (ServerlessClusterVpcConfigArray) ElementType() reflect.Type

func (ServerlessClusterVpcConfigArray) ToServerlessClusterVpcConfigArrayOutput added in v5.12.1 

func (i ServerlessClusterVpcConfigArray) ToServerlessClusterVpcConfigArrayOutput() ServerlessClusterVpcConfigArrayOutput

func (ServerlessClusterVpcConfigArray) ToServerlessClusterVpcConfigArrayOutputWithContext added in v5.12.1 

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

type ServerlessClusterVpcConfigArrayInput added in v5.12.1 

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 v5.12.1 

type ServerlessClusterVpcConfigArrayOutput struct{ *pulumi.OutputState }

func (ServerlessClusterVpcConfigArrayOutput) ElementType added in v5.12.1 

func (ServerlessClusterVpcConfigArrayOutput) ElementType() reflect.Type

func (ServerlessClusterVpcConfigArrayOutput) Index added in v5.12.1 

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

func (ServerlessClusterVpcConfigArrayOutput) ToServerlessClusterVpcConfigArrayOutput added in v5.12.1 

func (o ServerlessClusterVpcConfigArrayOutput) ToServerlessClusterVpcConfigArrayOutput() ServerlessClusterVpcConfigArrayOutput

func (ServerlessClusterVpcConfigArrayOutput) ToServerlessClusterVpcConfigArrayOutputWithContext added in v5.12.1 

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

type ServerlessClusterVpcConfigInput added in v5.12.1 

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 v5.12.1 

type ServerlessClusterVpcConfigOutput struct{ *pulumi.OutputState }

func (ServerlessClusterVpcConfigOutput) ElementType added in v5.12.1 

func (ServerlessClusterVpcConfigOutput) ElementType() reflect.Type

func (ServerlessClusterVpcConfigOutput) SecurityGroupIds added in v5.12.1 

func (o ServerlessClusterVpcConfigOutput) SecurityGroupIds() pulumi.StringArrayOutput

Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster.

func (ServerlessClusterVpcConfigOutput) SubnetIds added in v5.12.1 

func (o ServerlessClusterVpcConfigOutput) SubnetIds() pulumi.StringArrayOutput

A list of subnets in at least two different Availability Zones that host your client applications.

func (ServerlessClusterVpcConfigOutput) ToServerlessClusterVpcConfigOutput added in v5.12.1 

func (o ServerlessClusterVpcConfigOutput) ToServerlessClusterVpcConfigOutput() ServerlessClusterVpcConfigOutput

func (ServerlessClusterVpcConfigOutput) ToServerlessClusterVpcConfigOutputWithContext added in v5.12.1 

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

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.