msk

package
v5.1.3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type 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.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"`
	// 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 AWS Managed Streaming for Kafka cluster

## Example Usage

```go package main

import ( 

"fmt"

"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, &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
		}
		firehoseRole, err := iam.NewRole(ctx, "firehoseRole", &iam.RoleArgs{
			AssumeRolePolicy: pulumi.Any(fmt.Sprintf("%v%v%v%v%v%v%v%v%v%v%v%v%v", "{\n", "\"Version\": \"2012-10-17\",\n", "\"Statement\": [\n", "  {\n", "    \"Action\": \"sts:AssumeRole\",\n", "    \"Principal\": {\n", "      \"Service\": \"firehose.amazonaws.com\"\n", "    },\n", "    \"Effect\": \"Allow\",\n", "    \"Sid\": \"\"\n", "  }\n", "  ]\n", "}\n")),
		})
		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("2.4.1"),
			NumberOfBrokerNodes: pulumi.Int(3),
			BrokerNodeGroupInfo: &msk.ClusterBrokerNodeGroupInfoArgs{
				InstanceType:  pulumi.String("kafka.m5.large"),
				EbsVolumeSize: pulumi.Int(1000),
				ClientSubnets: pulumi.StringArray{
					subnetAz1.ID(),
					subnetAz2.ID(),
					subnetAz3.ID(),
				},
				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
	})
}

```

## 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
	// 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"`
	// The size in GiB of the EBS volume for the data drive on each broker node.
	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"`
}

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"`
	// The size in GiB of the EBS volume for the data drive on each broker node.
	EbsVolumeSize pulumi.IntInput `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"`
}

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

func (o ClusterBrokerNodeGroupInfoOutput) EbsVolumeSize() pulumi.IntOutput

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

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

func (o ClusterBrokerNodeGroupInfoPtrOutput) EbsVolumeSize() pulumi.IntPtrOutput

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

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

func (o ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutput() ClusterBrokerNodeGroupInfoPtrOutput

func (ClusterBrokerNodeGroupInfoPtrOutput) ToClusterBrokerNodeGroupInfoPtrOutputWithContext 

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

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

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

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

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

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 {
	// Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.
	Enabled bool `pulumi:"enabled"`
	// Name of the Cloudwatch Log Group to deliver logs to.
	LogGroup *string `pulumi:"logGroup"`
}

type ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs 

type ClusterLoggingInfoBrokerLogsCloudwatchLogsArgs struct {
	// Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.
	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

Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

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

Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

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"`
	// Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.
	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"`
	// Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.
	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

Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

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

Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

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"`
	// Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.
	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"`
	// Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.
	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

Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

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

Indicates whether you want to enable or disable streaming broker logs to Cloudwatch Logs.

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

func (ClusterOutput) ElementType() reflect.Type

func (ClusterOutput) ToClusterOutput 

func (o ClusterOutput) ToClusterOutput() ClusterOutput

func (ClusterOutput) ToClusterOutputWithContext 

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

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.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
	// 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 ( 

"fmt"

"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(fmt.Sprintf("%v%v%v", "auto.create.topics.enable = true\n", "delete.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) ElementType 

func (ConfigurationOutput) ElementType() reflect.Type

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 {
	// The ARN of the cluster the nodes belong to.
	ClusterArn string `pulumi:"clusterArn"`
}

A collection of arguments for invoking getBrokerNodes.

type GetBrokerNodesNodeInfoList 

type GetBrokerNodesNodeInfoList struct {
	// The attached elastic network interface of the broker
	AttachedEniId string `pulumi:"attachedEniId"`
	// The ID of the broker
	BrokerId float64 `pulumi:"brokerId"`
	// The 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"`
	// The Amazon Resource Name (ARN) of the node
	NodeArn string `pulumi:"nodeArn"`
}

type GetBrokerNodesNodeInfoListArgs 

type GetBrokerNodesNodeInfoListArgs struct {
	// The attached elastic network interface of the broker
	AttachedEniId pulumi.StringInput `pulumi:"attachedEniId"`
	// The ID of the broker
	BrokerId pulumi.Float64Input `pulumi:"brokerId"`
	// The 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"`
	// The Amazon Resource Name (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

The attached elastic network interface of the broker

func (GetBrokerNodesNodeInfoListOutput) BrokerId 

func (o GetBrokerNodesNodeInfoListOutput) BrokerId() pulumi.Float64Output

The ID of the broker

func (GetBrokerNodesNodeInfoListOutput) ClientSubnet 

func (o GetBrokerNodesNodeInfoListOutput) ClientSubnet() pulumi.StringOutput

The 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

The Amazon Resource Name (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 {
	// The 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 {
	// Amazon Resource Name (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.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 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.

## 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

Amazon Resource Name (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) 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.

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 {
	// Amazon Resource Name (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

Amazon Resource Name (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"`
}

## Example Usage

```go package main

import ( 

"encoding/json"
"fmt"

"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
		}
		_, err = secretsmanager.NewSecretPolicy(ctx, "exampleSecretPolicy", &secretsmanager.SecretPolicyArgs{
			SecretArn: exampleSecret.Arn,
			Policy: exampleSecret.Arn.ApplyT(func(arn string) (string, error) {
				return fmt.Sprintf("%v%v%v%v%v%v%v%v%v%v%v%v%v%v", "{\n", "  \"Version\" : \"2012-10-17\",\n", "  \"Statement\" : [ {\n", "    \"Sid\": \"AWSKafkaResourcePolicy\",\n", "    \"Effect\" : \"Allow\",\n", "    \"Principal\" : {\n", "      \"Service\" : \"kafka.amazonaws.com\"\n", "    },\n", "    \"Action\" : \"secretsmanager:getSecretValue\",\n", "    \"Resource\" : \"", arn, "\"\n", "  } ]\n", "}\n"), nil
			}).(pulumi.StringOutput),
		})
		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) ElementType 

func (ScramSecretAssociationOutput) ElementType() reflect.Type

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

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.