msk

package
v0.18.6 Latest Latest
Warning

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

 Go to latest Published: May 24, 2019 License: Apache-2.0 Imports: 2 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 {
	// contains filtered or unexported fields
}

Manages AWS Managed Streaming for Kafka cluster

> **NOTE:** This AWS service is in Preview and may change before General Availability release. Backwards compatibility is not guaranteed between Terraform AWS Provider releases.

func GetCluster 

func GetCluster(ctx *pulumi.Context,
	name string, id pulumi.ID, state *ClusterState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*Cluster, error)

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

func (*Cluster) Arn 

func (r *Cluster) Arn() *pulumi.StringOutput

Amazon Resource Name (ARN) of the MSK cluster.

func (*Cluster) BootstrapBrokers 

func (r *Cluster) BootstrapBrokers() *pulumi.StringOutput

A comma separated list of one or more hostname:port pairs of kafka brokers suitable to boostrap connectivity to the kafka cluster. * `encryption_info.0.encryption_at_rest_kms_key_arn` - The ARN of the KMS key used for encryption at rest of the broker data volumes.

func (*Cluster) BrokerNodeGroupInfo 

func (r *Cluster) BrokerNodeGroupInfo() *pulumi.Output

Nested data for configuring the broker nodes of the Kafka cluster.

func (*Cluster) ClusterName 

func (r *Cluster) ClusterName() *pulumi.StringOutput

Name of the MSK cluster.

func (*Cluster) EncryptionInfo 

func (r *Cluster) EncryptionInfo() *pulumi.Output

Nested data for specifying encryption at rest info. See below.

func (*Cluster) EnhancedMonitoring 

func (r *Cluster) EnhancedMonitoring() *pulumi.StringOutput

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

func (*Cluster) ID 

func (r *Cluster) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Cluster) KafkaVersion 

func (r *Cluster) KafkaVersion() *pulumi.StringOutput

Specify the desired Kafka software version.

func (*Cluster) NumberOfBrokerNodes 

func (r *Cluster) NumberOfBrokerNodes() *pulumi.IntOutput

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

func (*Cluster) Tags 

func (r *Cluster) Tags() *pulumi.MapOutput

A mapping of tags to assign to the resource

func (*Cluster) URN 

func (r *Cluster) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

func (*Cluster) ZookeeperConnectString 

func (r *Cluster) ZookeeperConnectString() *pulumi.StringOutput

A comma separated list of one or more IP:port pairs to use to connect to the Apache Zookeeper cluster.

type ClusterArgs 

type ClusterArgs struct {
	// Nested data for configuring the broker nodes of the Kafka cluster.
	BrokerNodeGroupInfo interface{}
	// Name of the MSK cluster.
	ClusterName interface{}
	// Nested data for specifying encryption at rest info.  See below.
	EncryptionInfo interface{}
	// 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 interface{}
	// Specify the desired Kafka software version.
	KafkaVersion interface{}
	// The desired total number of broker nodes in the kafka cluster.  It must be a multiple of the number of specified client subnets.
	NumberOfBrokerNodes interface{}
	// A mapping of tags to assign to the resource
	Tags interface{}
}

The set of arguments for constructing a Cluster resource.

type ClusterState 

type ClusterState struct {
	// Amazon Resource Name (ARN) of the MSK cluster.
	Arn interface{}
	// A comma separated list of one or more hostname:port pairs of kafka brokers suitable to boostrap connectivity to the kafka cluster.
	// * `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.
	BootstrapBrokers interface{}
	// Nested data for configuring the broker nodes of the Kafka cluster.
	BrokerNodeGroupInfo interface{}
	// Name of the MSK cluster.
	ClusterName interface{}
	// Nested data for specifying encryption at rest info.  See below.
	EncryptionInfo interface{}
	// 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 interface{}
	// Specify the desired Kafka software version.
	KafkaVersion interface{}
	// The desired total number of broker nodes in the kafka cluster.  It must be a multiple of the number of specified client subnets.
	NumberOfBrokerNodes interface{}
	// A mapping of tags to assign to the resource
	Tags interface{}
	// A comma separated list of one or more IP:port pairs to use to connect to the Apache Zookeeper cluster.
	ZookeeperConnectString interface{}
}

Input properties used for looking up and filtering Cluster resources.

type Configuration 

type Configuration struct {
	// contains filtered or unexported fields
}

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

> **NOTE:** The API does not support deleting MSK configurations. Removing this Terraform resource will only remove the Terraform state for it.

> **NOTE:** This AWS service is in Preview and may change before General Availability release. Backwards compatibility is not guaranteed between Terraform AWS Provider releases.

func GetConfiguration 

func GetConfiguration(ctx *pulumi.Context,
	name string, id pulumi.ID, state *ConfigurationState, opts ...pulumi.ResourceOpt) (*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.ResourceOpt) (*Configuration, error)

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

func (*Configuration) Arn 

func (r *Configuration) Arn() *pulumi.StringOutput

Amazon Resource Name (ARN) of the configuration.

func (*Configuration) Description 

func (r *Configuration) Description() *pulumi.StringOutput

Description of the configuration.

func (*Configuration) ID 

func (r *Configuration) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Configuration) KafkaVersions 

func (r *Configuration) KafkaVersions() *pulumi.ArrayOutput

List of Apache Kafka versions which can use this configuration.

func (*Configuration) LatestRevision 

func (r *Configuration) LatestRevision() *pulumi.IntOutput

Latest revision of the configuration.

func (*Configuration) Name 

func (r *Configuration) Name() *pulumi.StringOutput

Name of the configuration.

func (*Configuration) ServerProperties 

func (r *Configuration) ServerProperties() *pulumi.StringOutput

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

func (*Configuration) URN 

func (r *Configuration) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type ConfigurationArgs 

type ConfigurationArgs struct {
	// Description of the configuration.
	Description interface{}
	// List of Apache Kafka versions which can use this configuration.
	KafkaVersions interface{}
	// Name of the configuration.
	Name interface{}
	// 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 interface{}
}

The set of arguments for constructing a Configuration resource.

type ConfigurationState 

type ConfigurationState struct {
	// Amazon Resource Name (ARN) of the configuration.
	Arn interface{}
	// Description of the configuration.
	Description interface{}
	// List of Apache Kafka versions which can use this configuration.
	KafkaVersions interface{}
	// Latest revision of the configuration.
	LatestRevision interface{}
	// Name of the configuration.
	Name interface{}
	// 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 interface{}
}

Input properties used for looking up and filtering Configuration resources.

type GetClusterArgs 

type GetClusterArgs struct {
	// Name of the cluster.
	ClusterName interface{}
	Tags        interface{}
}

A collection of arguments for invoking getCluster.

type GetClusterResult 

type GetClusterResult struct {
	// Amazon Resource Name (ARN) of the MSK cluster.
	Arn interface{}
	// A comma separated list of one or more hostname:port pairs of Kafka brokers suitable to boostrap connectivity to the Kafka cluster.
	BootstrapBrokers interface{}
	ClusterName      interface{}
	// Apache Kafka version.
	KafkaVersion interface{}
	// Number of broker nodes in the cluster.
	NumberOfBrokerNodes interface{}
	// Map of key-value pairs assigned to the cluster.
	Tags interface{}
	// A comma separated list of one or more IP:port pairs to use to connect to the Apache Zookeeper cluster.
	ZookeeperConnectString interface{}
	// id is the provider-assigned unique ID for this managed resource.
	Id interface{}
}

A collection of values returned by getCluster.

func LookupCluster 

func LookupCluster(ctx *pulumi.Context, args *GetClusterArgs) (*GetClusterResult, error)

Get information on an Amazon MSK Cluster.

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.