mskconnect

package
v6.0.2-alpha.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Connector 

type Connector struct {
	pulumi.CustomResourceState

	// The Amazon Resource Name (ARN) of the custom plugin.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// Information about the capacity allocated to the connector. See below.
	Capacity ConnectorCapacityOutput `pulumi:"capacity"`
	// A map of keys to values that represent the configuration for the connector.
	ConnectorConfiguration pulumi.StringMapOutput `pulumi:"connectorConfiguration"`
	// A summary description of the connector.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// Specifies which Apache Kafka cluster to connect to. See below.
	KafkaCluster ConnectorKafkaClusterOutput `pulumi:"kafkaCluster"`
	// Details of the client authentication used by the Apache Kafka cluster. See below.
	KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationOutput `pulumi:"kafkaClusterClientAuthentication"`
	// Details of encryption in transit to the Apache Kafka cluster. See below.
	KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitOutput `pulumi:"kafkaClusterEncryptionInTransit"`
	// The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
	KafkaconnectVersion pulumi.StringOutput `pulumi:"kafkaconnectVersion"`
	// Details about log delivery. See below.
	LogDelivery ConnectorLogDeliveryPtrOutput `pulumi:"logDelivery"`
	// The name of the connector.
	Name pulumi.StringOutput `pulumi:"name"`
	// Specifies which plugins to use for the connector. See below.
	Plugins ConnectorPluginArrayOutput `pulumi:"plugins"`
	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
	ServiceExecutionRoleArn pulumi.StringOutput `pulumi:"serviceExecutionRoleArn"`
	// The current version of the connector.
	Version pulumi.StringOutput `pulumi:"version"`
	// Specifies which worker configuration to use with the connector. See below.
	WorkerConfiguration ConnectorWorkerConfigurationPtrOutput `pulumi:"workerConfiguration"`
}

Provides an Amazon MSK Connect Connector resource.

## Example Usage ### Basic configuration

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.NewConnector(ctx, "example", &mskconnect.ConnectorArgs{
			KafkaconnectVersion: pulumi.String("2.7.1"),
			Capacity: &mskconnect.ConnectorCapacityArgs{
				Autoscaling: &mskconnect.ConnectorCapacityAutoscalingArgs{
					McuCount:       pulumi.Int(1),
					MinWorkerCount: pulumi.Int(1),
					MaxWorkerCount: pulumi.Int(2),
					ScaleInPolicy: &mskconnect.ConnectorCapacityAutoscalingScaleInPolicyArgs{
						CpuUtilizationPercentage: pulumi.Int(20),
					},
					ScaleOutPolicy: &mskconnect.ConnectorCapacityAutoscalingScaleOutPolicyArgs{
						CpuUtilizationPercentage: pulumi.Int(80),
					},
				},
			},
			ConnectorConfiguration: pulumi.StringMap{
				"connector.class": pulumi.String("com.github.jcustenborder.kafka.connect.simulator.SimulatorSinkConnector"),
				"tasks.max":       pulumi.String("1"),
				"topics":          pulumi.String("example"),
			},
			KafkaCluster: &mskconnect.ConnectorKafkaClusterArgs{
				ApacheKafkaCluster: &mskconnect.ConnectorKafkaClusterApacheKafkaClusterArgs{
					BootstrapServers: pulumi.Any(aws_msk_cluster.Example.Bootstrap_brokers_tls),
					Vpc: &mskconnect.ConnectorKafkaClusterApacheKafkaClusterVpcArgs{
						SecurityGroups: pulumi.StringArray{
							aws_security_group.Example.Id,
						},
						Subnets: pulumi.StringArray{
							aws_subnet.Example1.Id,
							aws_subnet.Example2.Id,
							aws_subnet.Example3.Id,
						},
					},
				},
			},
			KafkaClusterClientAuthentication: &mskconnect.ConnectorKafkaClusterClientAuthenticationArgs{
				AuthenticationType: pulumi.String("NONE"),
			},
			KafkaClusterEncryptionInTransit: &mskconnect.ConnectorKafkaClusterEncryptionInTransitArgs{
				EncryptionType: pulumi.String("TLS"),
			},
			Plugins: mskconnect.ConnectorPluginArray{
				&mskconnect.ConnectorPluginArgs{
					CustomPlugin: &mskconnect.ConnectorPluginCustomPluginArgs{
						Arn:      pulumi.Any(aws_mskconnect_custom_plugin.Example.Arn),
						Revision: pulumi.Any(aws_mskconnect_custom_plugin.Example.Latest_revision),
					},
				},
			},
			ServiceExecutionRoleArn: pulumi.Any(aws_iam_role.Example.Arn),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

terraform import { 

to = aws_mskconnect_connector.example

id = "arn:aws:kafkaconnect:eu-central-1:123456789012:connector/example/264edee4-17a3-412e-bd76-6681cfc93805-3" } Using `pulumi import`, import MSK Connect Connector using the connector's `arn`. For exampleconsole % pulumi import aws_mskconnect_connector.example 'arn:aws:kafkaconnect:eu-central-1:123456789012:connector/example/264edee4-17a3-412e-bd76-6681cfc93805-3'

func GetConnector 

func GetConnector(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ConnectorState, opts ...pulumi.ResourceOption) (*Connector, error)

GetConnector gets an existing Connector 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 NewConnector 

func NewConnector(ctx *pulumi.Context,
	name string, args *ConnectorArgs, opts ...pulumi.ResourceOption) (*Connector, error)

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

func (*Connector) ElementType 

func (*Connector) ElementType() reflect.Type

func (*Connector) ToConnectorOutput 

func (i *Connector) ToConnectorOutput() ConnectorOutput

func (*Connector) ToConnectorOutputWithContext 

func (i *Connector) ToConnectorOutputWithContext(ctx context.Context) ConnectorOutput

type ConnectorArgs 

type ConnectorArgs struct {
	// Information about the capacity allocated to the connector. See below.
	Capacity ConnectorCapacityInput
	// A map of keys to values that represent the configuration for the connector.
	ConnectorConfiguration pulumi.StringMapInput
	// A summary description of the connector.
	Description pulumi.StringPtrInput
	// Specifies which Apache Kafka cluster to connect to. See below.
	KafkaCluster ConnectorKafkaClusterInput
	// Details of the client authentication used by the Apache Kafka cluster. See below.
	KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationInput
	// Details of encryption in transit to the Apache Kafka cluster. See below.
	KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitInput
	// The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
	KafkaconnectVersion pulumi.StringInput
	// Details about log delivery. See below.
	LogDelivery ConnectorLogDeliveryPtrInput
	// The name of the connector.
	Name pulumi.StringPtrInput
	// Specifies which plugins to use for the connector. See below.
	Plugins ConnectorPluginArrayInput
	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
	ServiceExecutionRoleArn pulumi.StringInput
	// Specifies which worker configuration to use with the connector. See below.
	WorkerConfiguration ConnectorWorkerConfigurationPtrInput
}

The set of arguments for constructing a Connector resource.

func (ConnectorArgs) ElementType 

func (ConnectorArgs) ElementType() reflect.Type

type ConnectorArray 

type ConnectorArray []ConnectorInput

func (ConnectorArray) ElementType 

func (ConnectorArray) ElementType() reflect.Type

func (ConnectorArray) ToConnectorArrayOutput 

func (i ConnectorArray) ToConnectorArrayOutput() ConnectorArrayOutput

func (ConnectorArray) ToConnectorArrayOutputWithContext 

func (i ConnectorArray) ToConnectorArrayOutputWithContext(ctx context.Context) ConnectorArrayOutput

type ConnectorArrayInput 

type ConnectorArrayInput interface {
	pulumi.Input

	ToConnectorArrayOutput() ConnectorArrayOutput
	ToConnectorArrayOutputWithContext(context.Context) ConnectorArrayOutput
}

ConnectorArrayInput is an input type that accepts ConnectorArray and ConnectorArrayOutput values. You can construct a concrete instance of `ConnectorArrayInput` via: 

ConnectorArray{ ConnectorArgs{...} }

type ConnectorArrayOutput 

type ConnectorArrayOutput struct{ *pulumi.OutputState }

func (ConnectorArrayOutput) ElementType 

func (ConnectorArrayOutput) ElementType() reflect.Type

func (ConnectorArrayOutput) Index 

func (o ConnectorArrayOutput) Index(i pulumi.IntInput) ConnectorOutput

func (ConnectorArrayOutput) ToConnectorArrayOutput 

func (o ConnectorArrayOutput) ToConnectorArrayOutput() ConnectorArrayOutput

func (ConnectorArrayOutput) ToConnectorArrayOutputWithContext 

func (o ConnectorArrayOutput) ToConnectorArrayOutputWithContext(ctx context.Context) ConnectorArrayOutput

type ConnectorCapacity 

type ConnectorCapacity struct {
	// Information about the auto scaling parameters for the connector. See below.
	Autoscaling *ConnectorCapacityAutoscaling `pulumi:"autoscaling"`
	// Details about a fixed capacity allocated to a connector. See below.
	ProvisionedCapacity *ConnectorCapacityProvisionedCapacity `pulumi:"provisionedCapacity"`
}

type ConnectorCapacityArgs 

type ConnectorCapacityArgs struct {
	// Information about the auto scaling parameters for the connector. See below.
	Autoscaling ConnectorCapacityAutoscalingPtrInput `pulumi:"autoscaling"`
	// Details about a fixed capacity allocated to a connector. See below.
	ProvisionedCapacity ConnectorCapacityProvisionedCapacityPtrInput `pulumi:"provisionedCapacity"`
}

func (ConnectorCapacityArgs) ElementType 

func (ConnectorCapacityArgs) ElementType() reflect.Type

func (ConnectorCapacityArgs) ToConnectorCapacityOutput 

func (i ConnectorCapacityArgs) ToConnectorCapacityOutput() ConnectorCapacityOutput

func (ConnectorCapacityArgs) ToConnectorCapacityOutputWithContext 

func (i ConnectorCapacityArgs) ToConnectorCapacityOutputWithContext(ctx context.Context) ConnectorCapacityOutput

func (ConnectorCapacityArgs) ToConnectorCapacityPtrOutput 

func (i ConnectorCapacityArgs) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput

func (ConnectorCapacityArgs) ToConnectorCapacityPtrOutputWithContext 

func (i ConnectorCapacityArgs) ToConnectorCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityPtrOutput

type ConnectorCapacityAutoscaling 

type ConnectorCapacityAutoscaling struct {
	// The maximum number of workers allocated to the connector.
	MaxWorkerCount int `pulumi:"maxWorkerCount"`
	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.
	McuCount *int `pulumi:"mcuCount"`
	// The minimum number of workers allocated to the connector.
	MinWorkerCount int `pulumi:"minWorkerCount"`
	// The scale-in policy for the connector. See below.
	ScaleInPolicy *ConnectorCapacityAutoscalingScaleInPolicy `pulumi:"scaleInPolicy"`
	// The scale-out policy for the connector. See below.
	ScaleOutPolicy *ConnectorCapacityAutoscalingScaleOutPolicy `pulumi:"scaleOutPolicy"`
}

type ConnectorCapacityAutoscalingArgs 

type ConnectorCapacityAutoscalingArgs struct {
	// The maximum number of workers allocated to the connector.
	MaxWorkerCount pulumi.IntInput `pulumi:"maxWorkerCount"`
	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.
	McuCount pulumi.IntPtrInput `pulumi:"mcuCount"`
	// The minimum number of workers allocated to the connector.
	MinWorkerCount pulumi.IntInput `pulumi:"minWorkerCount"`
	// The scale-in policy for the connector. See below.
	ScaleInPolicy ConnectorCapacityAutoscalingScaleInPolicyPtrInput `pulumi:"scaleInPolicy"`
	// The scale-out policy for the connector. See below.
	ScaleOutPolicy ConnectorCapacityAutoscalingScaleOutPolicyPtrInput `pulumi:"scaleOutPolicy"`
}

func (ConnectorCapacityAutoscalingArgs) ElementType 

func (ConnectorCapacityAutoscalingArgs) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingOutput 

func (i ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingOutput() ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingOutputWithContext 

func (i ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingPtrOutput 

func (i ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingPtrOutput() ConnectorCapacityAutoscalingPtrOutput

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingPtrOutputWithContext 

func (i ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingPtrOutput

type ConnectorCapacityAutoscalingInput 

type ConnectorCapacityAutoscalingInput interface {
	pulumi.Input

	ToConnectorCapacityAutoscalingOutput() ConnectorCapacityAutoscalingOutput
	ToConnectorCapacityAutoscalingOutputWithContext(context.Context) ConnectorCapacityAutoscalingOutput
}

ConnectorCapacityAutoscalingInput is an input type that accepts ConnectorCapacityAutoscalingArgs and ConnectorCapacityAutoscalingOutput values. You can construct a concrete instance of `ConnectorCapacityAutoscalingInput` via: 

ConnectorCapacityAutoscalingArgs{...}

type ConnectorCapacityAutoscalingOutput 

type ConnectorCapacityAutoscalingOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingOutput) ElementType 

func (ConnectorCapacityAutoscalingOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingOutput) MaxWorkerCount 

func (o ConnectorCapacityAutoscalingOutput) MaxWorkerCount() pulumi.IntOutput

The maximum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingOutput) McuCount 

func (o ConnectorCapacityAutoscalingOutput) McuCount() pulumi.IntPtrOutput

The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.

func (ConnectorCapacityAutoscalingOutput) MinWorkerCount 

func (o ConnectorCapacityAutoscalingOutput) MinWorkerCount() pulumi.IntOutput

The minimum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingOutput) ScaleInPolicy 

func (o ConnectorCapacityAutoscalingOutput) ScaleInPolicy() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

The scale-in policy for the connector. See below.

func (ConnectorCapacityAutoscalingOutput) ScaleOutPolicy 

func (o ConnectorCapacityAutoscalingOutput) ScaleOutPolicy() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

The scale-out policy for the connector. See below.

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingOutput 

func (o ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingOutput() ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingOutputWithContext 

func (o ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingPtrOutput 

func (o ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingPtrOutput() ConnectorCapacityAutoscalingPtrOutput

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingPtrOutputWithContext 

func (o ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingPtrOutput

type ConnectorCapacityAutoscalingPtrInput 

type ConnectorCapacityAutoscalingPtrInput interface {
	pulumi.Input

	ToConnectorCapacityAutoscalingPtrOutput() ConnectorCapacityAutoscalingPtrOutput
	ToConnectorCapacityAutoscalingPtrOutputWithContext(context.Context) ConnectorCapacityAutoscalingPtrOutput
}

ConnectorCapacityAutoscalingPtrInput is an input type that accepts ConnectorCapacityAutoscalingArgs, ConnectorCapacityAutoscalingPtr and ConnectorCapacityAutoscalingPtrOutput values. You can construct a concrete instance of `ConnectorCapacityAutoscalingPtrInput` via: 

        ConnectorCapacityAutoscalingArgs{...}

or:

        nil

func ConnectorCapacityAutoscalingPtr 

func ConnectorCapacityAutoscalingPtr(v *ConnectorCapacityAutoscalingArgs) ConnectorCapacityAutoscalingPtrInput

type ConnectorCapacityAutoscalingPtrOutput 

type ConnectorCapacityAutoscalingPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingPtrOutput) Elem 

func (o ConnectorCapacityAutoscalingPtrOutput) Elem() ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingPtrOutput) ElementType 

func (ConnectorCapacityAutoscalingPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingPtrOutput) MaxWorkerCount 

func (o ConnectorCapacityAutoscalingPtrOutput) MaxWorkerCount() pulumi.IntPtrOutput

The maximum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingPtrOutput) McuCount 

func (o ConnectorCapacityAutoscalingPtrOutput) McuCount() pulumi.IntPtrOutput

The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.

func (ConnectorCapacityAutoscalingPtrOutput) MinWorkerCount 

func (o ConnectorCapacityAutoscalingPtrOutput) MinWorkerCount() pulumi.IntPtrOutput

The minimum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingPtrOutput) ScaleInPolicy 

func (o ConnectorCapacityAutoscalingPtrOutput) ScaleInPolicy() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

The scale-in policy for the connector. See below.

func (ConnectorCapacityAutoscalingPtrOutput) ScaleOutPolicy 

func (o ConnectorCapacityAutoscalingPtrOutput) ScaleOutPolicy() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

The scale-out policy for the connector. See below.

func (ConnectorCapacityAutoscalingPtrOutput) ToConnectorCapacityAutoscalingPtrOutput 

func (o ConnectorCapacityAutoscalingPtrOutput) ToConnectorCapacityAutoscalingPtrOutput() ConnectorCapacityAutoscalingPtrOutput

func (ConnectorCapacityAutoscalingPtrOutput) ToConnectorCapacityAutoscalingPtrOutputWithContext 

func (o ConnectorCapacityAutoscalingPtrOutput) ToConnectorCapacityAutoscalingPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingPtrOutput

type ConnectorCapacityAutoscalingScaleInPolicy 

type ConnectorCapacityAutoscalingScaleInPolicy struct {
	// Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.
	CpuUtilizationPercentage *int `pulumi:"cpuUtilizationPercentage"`
}

type ConnectorCapacityAutoscalingScaleInPolicyArgs 

type ConnectorCapacityAutoscalingScaleInPolicyArgs struct {
	// Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.
	CpuUtilizationPercentage pulumi.IntPtrInput `pulumi:"cpuUtilizationPercentage"`
}

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ElementType 

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyOutput 

func (i ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyOutput() ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyOutputWithContext 

func (i ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput 

func (i ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext 

func (i ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

type ConnectorCapacityAutoscalingScaleInPolicyInput 

type ConnectorCapacityAutoscalingScaleInPolicyInput interface {
	pulumi.Input

	ToConnectorCapacityAutoscalingScaleInPolicyOutput() ConnectorCapacityAutoscalingScaleInPolicyOutput
	ToConnectorCapacityAutoscalingScaleInPolicyOutputWithContext(context.Context) ConnectorCapacityAutoscalingScaleInPolicyOutput
}

ConnectorCapacityAutoscalingScaleInPolicyInput is an input type that accepts ConnectorCapacityAutoscalingScaleInPolicyArgs and ConnectorCapacityAutoscalingScaleInPolicyOutput values. You can construct a concrete instance of `ConnectorCapacityAutoscalingScaleInPolicyInput` via: 

ConnectorCapacityAutoscalingScaleInPolicyArgs{...}

type ConnectorCapacityAutoscalingScaleInPolicyOutput 

type ConnectorCapacityAutoscalingScaleInPolicyOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) CpuUtilizationPercentage 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ElementType 

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyOutput 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyOutput() ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyOutputWithContext 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

type ConnectorCapacityAutoscalingScaleInPolicyPtrInput 

type ConnectorCapacityAutoscalingScaleInPolicyPtrInput interface {
	pulumi.Input

	ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput
	ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext(context.Context) ConnectorCapacityAutoscalingScaleInPolicyPtrOutput
}

ConnectorCapacityAutoscalingScaleInPolicyPtrInput is an input type that accepts ConnectorCapacityAutoscalingScaleInPolicyArgs, ConnectorCapacityAutoscalingScaleInPolicyPtr and ConnectorCapacityAutoscalingScaleInPolicyPtrOutput values. You can construct a concrete instance of `ConnectorCapacityAutoscalingScaleInPolicyPtrInput` via: 

        ConnectorCapacityAutoscalingScaleInPolicyArgs{...}

or:

        nil

func ConnectorCapacityAutoscalingScaleInPolicyPtr 

func ConnectorCapacityAutoscalingScaleInPolicyPtr(v *ConnectorCapacityAutoscalingScaleInPolicyArgs) ConnectorCapacityAutoscalingScaleInPolicyPtrInput

type ConnectorCapacityAutoscalingScaleInPolicyPtrOutput 

type ConnectorCapacityAutoscalingScaleInPolicyPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) CpuUtilizationPercentage 

func (o ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

Specifies the CPU utilization percentage threshold at which you want connector scale in to be triggered.

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) Elem 

func (o ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) Elem() ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ElementType 

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput 

func (o ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext 

func (o ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

type ConnectorCapacityAutoscalingScaleOutPolicy 

type ConnectorCapacityAutoscalingScaleOutPolicy struct {
	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	CpuUtilizationPercentage *int `pulumi:"cpuUtilizationPercentage"`
}

type ConnectorCapacityAutoscalingScaleOutPolicyArgs 

type ConnectorCapacityAutoscalingScaleOutPolicyArgs struct {
	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	CpuUtilizationPercentage pulumi.IntPtrInput `pulumi:"cpuUtilizationPercentage"`
}

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ElementType 

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyOutput 

func (i ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyOutput() ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyOutputWithContext 

func (i ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput 

func (i ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext 

func (i ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

type ConnectorCapacityAutoscalingScaleOutPolicyInput 

type ConnectorCapacityAutoscalingScaleOutPolicyInput interface {
	pulumi.Input

	ToConnectorCapacityAutoscalingScaleOutPolicyOutput() ConnectorCapacityAutoscalingScaleOutPolicyOutput
	ToConnectorCapacityAutoscalingScaleOutPolicyOutputWithContext(context.Context) ConnectorCapacityAutoscalingScaleOutPolicyOutput
}

ConnectorCapacityAutoscalingScaleOutPolicyInput is an input type that accepts ConnectorCapacityAutoscalingScaleOutPolicyArgs and ConnectorCapacityAutoscalingScaleOutPolicyOutput values. You can construct a concrete instance of `ConnectorCapacityAutoscalingScaleOutPolicyInput` via: 

ConnectorCapacityAutoscalingScaleOutPolicyArgs{...}

type ConnectorCapacityAutoscalingScaleOutPolicyOutput 

type ConnectorCapacityAutoscalingScaleOutPolicyOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) CpuUtilizationPercentage 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

The CPU utilization percentage threshold at which you want connector scale out to be triggered.

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ElementType 

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyOutput 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyOutput() ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyOutputWithContext 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

type ConnectorCapacityAutoscalingScaleOutPolicyPtrInput 

type ConnectorCapacityAutoscalingScaleOutPolicyPtrInput interface {
	pulumi.Input

	ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput
	ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext(context.Context) ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput
}

ConnectorCapacityAutoscalingScaleOutPolicyPtrInput is an input type that accepts ConnectorCapacityAutoscalingScaleOutPolicyArgs, ConnectorCapacityAutoscalingScaleOutPolicyPtr and ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput values. You can construct a concrete instance of `ConnectorCapacityAutoscalingScaleOutPolicyPtrInput` via: 

        ConnectorCapacityAutoscalingScaleOutPolicyArgs{...}

or:

        nil

func ConnectorCapacityAutoscalingScaleOutPolicyPtr 

func ConnectorCapacityAutoscalingScaleOutPolicyPtr(v *ConnectorCapacityAutoscalingScaleOutPolicyArgs) ConnectorCapacityAutoscalingScaleOutPolicyPtrInput

type ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput 

type ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) CpuUtilizationPercentage 

func (o ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

The CPU utilization percentage threshold at which you want connector scale out to be triggered.

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) Elem 

func (o ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) Elem() ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ElementType 

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput 

func (o ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext 

func (o ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

type ConnectorCapacityInput 

type ConnectorCapacityInput interface {
	pulumi.Input

	ToConnectorCapacityOutput() ConnectorCapacityOutput
	ToConnectorCapacityOutputWithContext(context.Context) ConnectorCapacityOutput
}

ConnectorCapacityInput is an input type that accepts ConnectorCapacityArgs and ConnectorCapacityOutput values. You can construct a concrete instance of `ConnectorCapacityInput` via: 

ConnectorCapacityArgs{...}

type ConnectorCapacityOutput 

type ConnectorCapacityOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityOutput) Autoscaling 

func (o ConnectorCapacityOutput) Autoscaling() ConnectorCapacityAutoscalingPtrOutput

Information about the auto scaling parameters for the connector. See below.

func (ConnectorCapacityOutput) ElementType 

func (ConnectorCapacityOutput) ElementType() reflect.Type

func (ConnectorCapacityOutput) ProvisionedCapacity 

func (o ConnectorCapacityOutput) ProvisionedCapacity() ConnectorCapacityProvisionedCapacityPtrOutput

Details about a fixed capacity allocated to a connector. See below.

func (ConnectorCapacityOutput) ToConnectorCapacityOutput 

func (o ConnectorCapacityOutput) ToConnectorCapacityOutput() ConnectorCapacityOutput

func (ConnectorCapacityOutput) ToConnectorCapacityOutputWithContext 

func (o ConnectorCapacityOutput) ToConnectorCapacityOutputWithContext(ctx context.Context) ConnectorCapacityOutput

func (ConnectorCapacityOutput) ToConnectorCapacityPtrOutput 

func (o ConnectorCapacityOutput) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput

func (ConnectorCapacityOutput) ToConnectorCapacityPtrOutputWithContext 

func (o ConnectorCapacityOutput) ToConnectorCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityPtrOutput

type ConnectorCapacityProvisionedCapacity 

type ConnectorCapacityProvisionedCapacity struct {
	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.
	McuCount *int `pulumi:"mcuCount"`
	// The number of workers that are allocated to the connector.
	WorkerCount int `pulumi:"workerCount"`
}

type ConnectorCapacityProvisionedCapacityArgs 

type ConnectorCapacityProvisionedCapacityArgs struct {
	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.
	McuCount pulumi.IntPtrInput `pulumi:"mcuCount"`
	// The number of workers that are allocated to the connector.
	WorkerCount pulumi.IntInput `pulumi:"workerCount"`
}

func (ConnectorCapacityProvisionedCapacityArgs) ElementType 

func (ConnectorCapacityProvisionedCapacityArgs) ElementType() reflect.Type

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityOutput 

func (i ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityOutput() ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityOutputWithContext 

func (i ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityPtrOutput 

func (i ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityPtrOutput() ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext 

func (i ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityProvisionedCapacityPtrOutput

type ConnectorCapacityProvisionedCapacityInput 

type ConnectorCapacityProvisionedCapacityInput interface {
	pulumi.Input

	ToConnectorCapacityProvisionedCapacityOutput() ConnectorCapacityProvisionedCapacityOutput
	ToConnectorCapacityProvisionedCapacityOutputWithContext(context.Context) ConnectorCapacityProvisionedCapacityOutput
}

ConnectorCapacityProvisionedCapacityInput is an input type that accepts ConnectorCapacityProvisionedCapacityArgs and ConnectorCapacityProvisionedCapacityOutput values. You can construct a concrete instance of `ConnectorCapacityProvisionedCapacityInput` via: 

ConnectorCapacityProvisionedCapacityArgs{...}

type ConnectorCapacityProvisionedCapacityOutput 

type ConnectorCapacityProvisionedCapacityOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityProvisionedCapacityOutput) ElementType 

func (ConnectorCapacityProvisionedCapacityOutput) ElementType() reflect.Type

func (ConnectorCapacityProvisionedCapacityOutput) McuCount 

func (o ConnectorCapacityProvisionedCapacityOutput) McuCount() pulumi.IntPtrOutput

The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.

func (ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityOutput 

func (o ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityOutput() ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityOutputWithContext 

func (o ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityPtrOutput 

func (o ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityPtrOutput() ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext 

func (o ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityOutput) WorkerCount 

func (o ConnectorCapacityProvisionedCapacityOutput) WorkerCount() pulumi.IntOutput

The number of workers that are allocated to the connector.

type ConnectorCapacityProvisionedCapacityPtrInput 

type ConnectorCapacityProvisionedCapacityPtrInput interface {
	pulumi.Input

	ToConnectorCapacityProvisionedCapacityPtrOutput() ConnectorCapacityProvisionedCapacityPtrOutput
	ToConnectorCapacityProvisionedCapacityPtrOutputWithContext(context.Context) ConnectorCapacityProvisionedCapacityPtrOutput
}

ConnectorCapacityProvisionedCapacityPtrInput is an input type that accepts ConnectorCapacityProvisionedCapacityArgs, ConnectorCapacityProvisionedCapacityPtr and ConnectorCapacityProvisionedCapacityPtrOutput values. You can construct a concrete instance of `ConnectorCapacityProvisionedCapacityPtrInput` via: 

        ConnectorCapacityProvisionedCapacityArgs{...}

or:

        nil

func ConnectorCapacityProvisionedCapacityPtr 

func ConnectorCapacityProvisionedCapacityPtr(v *ConnectorCapacityProvisionedCapacityArgs) ConnectorCapacityProvisionedCapacityPtrInput

type ConnectorCapacityProvisionedCapacityPtrOutput 

type ConnectorCapacityProvisionedCapacityPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityProvisionedCapacityPtrOutput) Elem 

func (o ConnectorCapacityProvisionedCapacityPtrOutput) Elem() ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityPtrOutput) ElementType 

func (ConnectorCapacityProvisionedCapacityPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityProvisionedCapacityPtrOutput) McuCount 

func (o ConnectorCapacityProvisionedCapacityPtrOutput) McuCount() pulumi.IntPtrOutput

The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: `1`, `2`, `4`, `8`. The default value is `1`.

func (ConnectorCapacityProvisionedCapacityPtrOutput) ToConnectorCapacityProvisionedCapacityPtrOutput 

func (o ConnectorCapacityProvisionedCapacityPtrOutput) ToConnectorCapacityProvisionedCapacityPtrOutput() ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityPtrOutput) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext 

func (o ConnectorCapacityProvisionedCapacityPtrOutput) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityPtrOutput) WorkerCount 

func (o ConnectorCapacityProvisionedCapacityPtrOutput) WorkerCount() pulumi.IntPtrOutput

The number of workers that are allocated to the connector.

type ConnectorCapacityPtrInput 

type ConnectorCapacityPtrInput interface {
	pulumi.Input

	ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput
	ToConnectorCapacityPtrOutputWithContext(context.Context) ConnectorCapacityPtrOutput
}

ConnectorCapacityPtrInput is an input type that accepts ConnectorCapacityArgs, ConnectorCapacityPtr and ConnectorCapacityPtrOutput values. You can construct a concrete instance of `ConnectorCapacityPtrInput` via: 

        ConnectorCapacityArgs{...}

or:

        nil

func ConnectorCapacityPtr 

func ConnectorCapacityPtr(v *ConnectorCapacityArgs) ConnectorCapacityPtrInput

type ConnectorCapacityPtrOutput 

type ConnectorCapacityPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityPtrOutput) Autoscaling 

func (o ConnectorCapacityPtrOutput) Autoscaling() ConnectorCapacityAutoscalingPtrOutput

Information about the auto scaling parameters for the connector. See below.

func (ConnectorCapacityPtrOutput) Elem 

func (o ConnectorCapacityPtrOutput) Elem() ConnectorCapacityOutput

func (ConnectorCapacityPtrOutput) ElementType 

func (ConnectorCapacityPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityPtrOutput) ProvisionedCapacity 

func (o ConnectorCapacityPtrOutput) ProvisionedCapacity() ConnectorCapacityProvisionedCapacityPtrOutput

Details about a fixed capacity allocated to a connector. See below.

func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput 

func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput

func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutputWithContext 

func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutputWithContext(ctx context.Context) ConnectorCapacityPtrOutput

type ConnectorInput 

type ConnectorInput interface {
	pulumi.Input

	ToConnectorOutput() ConnectorOutput
	ToConnectorOutputWithContext(ctx context.Context) ConnectorOutput
}

type ConnectorKafkaCluster 

type ConnectorKafkaCluster struct {
	// The Apache Kafka cluster to which the connector is connected.
	ApacheKafkaCluster ConnectorKafkaClusterApacheKafkaCluster `pulumi:"apacheKafkaCluster"`
}

type ConnectorKafkaClusterApacheKafkaCluster 

type ConnectorKafkaClusterApacheKafkaCluster struct {
	// The bootstrap servers of the cluster.
	BootstrapServers string `pulumi:"bootstrapServers"`
	// Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
	Vpc ConnectorKafkaClusterApacheKafkaClusterVpc `pulumi:"vpc"`
}

type ConnectorKafkaClusterApacheKafkaClusterArgs 

type ConnectorKafkaClusterApacheKafkaClusterArgs struct {
	// The bootstrap servers of the cluster.
	BootstrapServers pulumi.StringInput `pulumi:"bootstrapServers"`
	// Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
	Vpc ConnectorKafkaClusterApacheKafkaClusterVpcInput `pulumi:"vpc"`
}

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ElementType 

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterOutput 

func (i ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterOutput() ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterOutputWithContext 

func (i ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput 

func (i ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext 

func (i ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterPtrOutput

type ConnectorKafkaClusterApacheKafkaClusterInput 

type ConnectorKafkaClusterApacheKafkaClusterInput interface {
	pulumi.Input

	ToConnectorKafkaClusterApacheKafkaClusterOutput() ConnectorKafkaClusterApacheKafkaClusterOutput
	ToConnectorKafkaClusterApacheKafkaClusterOutputWithContext(context.Context) ConnectorKafkaClusterApacheKafkaClusterOutput
}

ConnectorKafkaClusterApacheKafkaClusterInput is an input type that accepts ConnectorKafkaClusterApacheKafkaClusterArgs and ConnectorKafkaClusterApacheKafkaClusterOutput values. You can construct a concrete instance of `ConnectorKafkaClusterApacheKafkaClusterInput` via: 

ConnectorKafkaClusterApacheKafkaClusterArgs{...}

type ConnectorKafkaClusterApacheKafkaClusterOutput 

type ConnectorKafkaClusterApacheKafkaClusterOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterOutput) BootstrapServers 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) BootstrapServers() pulumi.StringOutput

The bootstrap servers of the cluster.

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ElementType 

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterOutput 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterOutput() ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterOutputWithContext 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterOutput) Vpc 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) Vpc() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

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

type ConnectorKafkaClusterApacheKafkaClusterPtrInput 

type ConnectorKafkaClusterApacheKafkaClusterPtrInput interface {
	pulumi.Input

	ToConnectorKafkaClusterApacheKafkaClusterPtrOutput() ConnectorKafkaClusterApacheKafkaClusterPtrOutput
	ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext(context.Context) ConnectorKafkaClusterApacheKafkaClusterPtrOutput
}

ConnectorKafkaClusterApacheKafkaClusterPtrInput is an input type that accepts ConnectorKafkaClusterApacheKafkaClusterArgs, ConnectorKafkaClusterApacheKafkaClusterPtr and ConnectorKafkaClusterApacheKafkaClusterPtrOutput values. You can construct a concrete instance of `ConnectorKafkaClusterApacheKafkaClusterPtrInput` via: 

        ConnectorKafkaClusterApacheKafkaClusterArgs{...}

or:

        nil

func ConnectorKafkaClusterApacheKafkaClusterPtr 

func ConnectorKafkaClusterApacheKafkaClusterPtr(v *ConnectorKafkaClusterApacheKafkaClusterArgs) ConnectorKafkaClusterApacheKafkaClusterPtrInput

type ConnectorKafkaClusterApacheKafkaClusterPtrOutput 

type ConnectorKafkaClusterApacheKafkaClusterPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) BootstrapServers 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) BootstrapServers() pulumi.StringPtrOutput

The bootstrap servers of the cluster.

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Elem 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Elem() ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ElementType 

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Vpc 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Vpc() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

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

type ConnectorKafkaClusterApacheKafkaClusterVpc 

type ConnectorKafkaClusterApacheKafkaClusterVpc struct {
	// The security groups for the connector.
	SecurityGroups []string `pulumi:"securityGroups"`
	// The subnets for the connector.
	Subnets []string `pulumi:"subnets"`
}

type ConnectorKafkaClusterApacheKafkaClusterVpcArgs 

type ConnectorKafkaClusterApacheKafkaClusterVpcArgs struct {
	// The security groups for the connector.
	SecurityGroups pulumi.StringArrayInput `pulumi:"securityGroups"`
	// The subnets for the connector.
	Subnets pulumi.StringArrayInput `pulumi:"subnets"`
}

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ElementType 

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput 

func (i ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcOutputWithContext 

func (i ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput 

func (i ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext 

func (i ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

type ConnectorKafkaClusterApacheKafkaClusterVpcInput 

type ConnectorKafkaClusterApacheKafkaClusterVpcInput interface {
	pulumi.Input

	ToConnectorKafkaClusterApacheKafkaClusterVpcOutput() ConnectorKafkaClusterApacheKafkaClusterVpcOutput
	ToConnectorKafkaClusterApacheKafkaClusterVpcOutputWithContext(context.Context) ConnectorKafkaClusterApacheKafkaClusterVpcOutput
}

ConnectorKafkaClusterApacheKafkaClusterVpcInput is an input type that accepts ConnectorKafkaClusterApacheKafkaClusterVpcArgs and ConnectorKafkaClusterApacheKafkaClusterVpcOutput values. You can construct a concrete instance of `ConnectorKafkaClusterApacheKafkaClusterVpcInput` via: 

ConnectorKafkaClusterApacheKafkaClusterVpcArgs{...}

type ConnectorKafkaClusterApacheKafkaClusterVpcOutput 

type ConnectorKafkaClusterApacheKafkaClusterVpcOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ElementType 

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) SecurityGroups 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) SecurityGroups() pulumi.StringArrayOutput

The security groups for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) Subnets 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) Subnets() pulumi.StringArrayOutput

The subnets for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcOutputWithContext 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

type ConnectorKafkaClusterApacheKafkaClusterVpcPtrInput 

type ConnectorKafkaClusterApacheKafkaClusterVpcPtrInput interface {
	pulumi.Input

	ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput
	ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext(context.Context) ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput
}

ConnectorKafkaClusterApacheKafkaClusterVpcPtrInput is an input type that accepts ConnectorKafkaClusterApacheKafkaClusterVpcArgs, ConnectorKafkaClusterApacheKafkaClusterVpcPtr and ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput values. You can construct a concrete instance of `ConnectorKafkaClusterApacheKafkaClusterVpcPtrInput` via: 

        ConnectorKafkaClusterApacheKafkaClusterVpcArgs{...}

or:

        nil

func ConnectorKafkaClusterApacheKafkaClusterVpcPtr 

func ConnectorKafkaClusterApacheKafkaClusterVpcPtr(v *ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ConnectorKafkaClusterApacheKafkaClusterVpcPtrInput

type ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput 

type ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Elem 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Elem() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ElementType 

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) SecurityGroups 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) SecurityGroups() pulumi.StringArrayOutput

The security groups for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Subnets 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Subnets() pulumi.StringArrayOutput

The subnets for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

type ConnectorKafkaClusterArgs 

type ConnectorKafkaClusterArgs struct {
	// The Apache Kafka cluster to which the connector is connected.
	ApacheKafkaCluster ConnectorKafkaClusterApacheKafkaClusterInput `pulumi:"apacheKafkaCluster"`
}

func (ConnectorKafkaClusterArgs) ElementType 

func (ConnectorKafkaClusterArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput 

func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutputWithContext 

func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutputWithContext(ctx context.Context) ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterPtrOutput 

func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterPtrOutput() ConnectorKafkaClusterPtrOutput

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterPtrOutputWithContext 

func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterPtrOutput

type ConnectorKafkaClusterClientAuthentication 

type ConnectorKafkaClusterClientAuthentication struct {
	// The type of client authentication used to connect to the Apache Kafka cluster. Valid values: `IAM`, `NONE`. A value of `NONE` means that no client authentication is used. The default value is `NONE`.
	AuthenticationType *string `pulumi:"authenticationType"`
}

type ConnectorKafkaClusterClientAuthenticationArgs 

type ConnectorKafkaClusterClientAuthenticationArgs struct {
	// The type of client authentication used to connect to the Apache Kafka cluster. Valid values: `IAM`, `NONE`. A value of `NONE` means that no client authentication is used. The default value is `NONE`.
	AuthenticationType pulumi.StringPtrInput `pulumi:"authenticationType"`
}

func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType 

func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutputWithContext 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationPtrOutput 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationPtrOutput() ConnectorKafkaClusterClientAuthenticationPtrOutput

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationPtrOutput

type ConnectorKafkaClusterClientAuthenticationInput 

type ConnectorKafkaClusterClientAuthenticationInput interface {
	pulumi.Input

	ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput
	ToConnectorKafkaClusterClientAuthenticationOutputWithContext(context.Context) ConnectorKafkaClusterClientAuthenticationOutput
}

ConnectorKafkaClusterClientAuthenticationInput is an input type that accepts ConnectorKafkaClusterClientAuthenticationArgs and ConnectorKafkaClusterClientAuthenticationOutput values. You can construct a concrete instance of `ConnectorKafkaClusterClientAuthenticationInput` via: 

ConnectorKafkaClusterClientAuthenticationArgs{...}

type ConnectorKafkaClusterClientAuthenticationOutput 

type ConnectorKafkaClusterClientAuthenticationOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType 

func (o ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType() pulumi.StringPtrOutput

The type of client authentication used to connect to the Apache Kafka cluster. Valid values: `IAM`, `NONE`. A value of `NONE` means that no client authentication is used. The default value is `NONE`.

func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType 

func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput() ConnectorKafkaClusterClientAuthenticationPtrOutput

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationPtrOutput

type ConnectorKafkaClusterClientAuthenticationPtrInput 

type ConnectorKafkaClusterClientAuthenticationPtrInput interface {
	pulumi.Input

	ToConnectorKafkaClusterClientAuthenticationPtrOutput() ConnectorKafkaClusterClientAuthenticationPtrOutput
	ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext(context.Context) ConnectorKafkaClusterClientAuthenticationPtrOutput
}

ConnectorKafkaClusterClientAuthenticationPtrInput is an input type that accepts ConnectorKafkaClusterClientAuthenticationArgs, ConnectorKafkaClusterClientAuthenticationPtr and ConnectorKafkaClusterClientAuthenticationPtrOutput values. You can construct a concrete instance of `ConnectorKafkaClusterClientAuthenticationPtrInput` via: 

        ConnectorKafkaClusterClientAuthenticationArgs{...}

or:

        nil

func ConnectorKafkaClusterClientAuthenticationPtr 

func ConnectorKafkaClusterClientAuthenticationPtr(v *ConnectorKafkaClusterClientAuthenticationArgs) ConnectorKafkaClusterClientAuthenticationPtrInput

type ConnectorKafkaClusterClientAuthenticationPtrOutput 

type ConnectorKafkaClusterClientAuthenticationPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) AuthenticationType 

func (o ConnectorKafkaClusterClientAuthenticationPtrOutput) AuthenticationType() pulumi.StringPtrOutput

The type of client authentication used to connect to the Apache Kafka cluster. Valid values: `IAM`, `NONE`. A value of `NONE` means that no client authentication is used. The default value is `NONE`.

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) Elem 

func (o ConnectorKafkaClusterClientAuthenticationPtrOutput) Elem() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ElementType 

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput 

func (o ConnectorKafkaClusterClientAuthenticationPtrOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput() ConnectorKafkaClusterClientAuthenticationPtrOutput

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationPtrOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationPtrOutput

type ConnectorKafkaClusterEncryptionInTransit 

type ConnectorKafkaClusterEncryptionInTransit struct {
	// The type of encryption in transit to the Apache Kafka cluster. Valid values: `PLAINTEXT`, `TLS`. The default values is `PLAINTEXT`.
	EncryptionType *string `pulumi:"encryptionType"`
}

type ConnectorKafkaClusterEncryptionInTransitArgs 

type ConnectorKafkaClusterEncryptionInTransitArgs struct {
	// The type of encryption in transit to the Apache Kafka cluster. Valid values: `PLAINTEXT`, `TLS`. The default values is `PLAINTEXT`.
	EncryptionType pulumi.StringPtrInput `pulumi:"encryptionType"`
}

func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitPtrOutput 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitPtrOutput() ConnectorKafkaClusterEncryptionInTransitPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitPtrOutput

type ConnectorKafkaClusterEncryptionInTransitInput 

type ConnectorKafkaClusterEncryptionInTransitInput interface {
	pulumi.Input

	ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput
	ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(context.Context) ConnectorKafkaClusterEncryptionInTransitOutput
}

ConnectorKafkaClusterEncryptionInTransitInput is an input type that accepts ConnectorKafkaClusterEncryptionInTransitArgs and ConnectorKafkaClusterEncryptionInTransitOutput values. You can construct a concrete instance of `ConnectorKafkaClusterEncryptionInTransitInput` via: 

ConnectorKafkaClusterEncryptionInTransitArgs{...}

type ConnectorKafkaClusterEncryptionInTransitOutput 

type ConnectorKafkaClusterEncryptionInTransitOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType() pulumi.StringPtrOutput

The type of encryption in transit to the Apache Kafka cluster. Valid values: `PLAINTEXT`, `TLS`. The default values is `PLAINTEXT`.

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutput 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutput() ConnectorKafkaClusterEncryptionInTransitPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitPtrOutput

type ConnectorKafkaClusterEncryptionInTransitPtrInput 

type ConnectorKafkaClusterEncryptionInTransitPtrInput interface {
	pulumi.Input

	ToConnectorKafkaClusterEncryptionInTransitPtrOutput() ConnectorKafkaClusterEncryptionInTransitPtrOutput
	ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext(context.Context) ConnectorKafkaClusterEncryptionInTransitPtrOutput
}

ConnectorKafkaClusterEncryptionInTransitPtrInput is an input type that accepts ConnectorKafkaClusterEncryptionInTransitArgs, ConnectorKafkaClusterEncryptionInTransitPtr and ConnectorKafkaClusterEncryptionInTransitPtrOutput values. You can construct a concrete instance of `ConnectorKafkaClusterEncryptionInTransitPtrInput` via: 

        ConnectorKafkaClusterEncryptionInTransitArgs{...}

or:

        nil

func ConnectorKafkaClusterEncryptionInTransitPtr 

func ConnectorKafkaClusterEncryptionInTransitPtr(v *ConnectorKafkaClusterEncryptionInTransitArgs) ConnectorKafkaClusterEncryptionInTransitPtrInput

type ConnectorKafkaClusterEncryptionInTransitPtrOutput 

type ConnectorKafkaClusterEncryptionInTransitPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) Elem 

func (o ConnectorKafkaClusterEncryptionInTransitPtrOutput) Elem() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) EncryptionType 

func (o ConnectorKafkaClusterEncryptionInTransitPtrOutput) EncryptionType() pulumi.StringPtrOutput

The type of encryption in transit to the Apache Kafka cluster. Valid values: `PLAINTEXT`, `TLS`. The default values is `PLAINTEXT`.

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutput 

func (o ConnectorKafkaClusterEncryptionInTransitPtrOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutput() ConnectorKafkaClusterEncryptionInTransitPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitPtrOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitPtrOutput

type ConnectorKafkaClusterInput 

type ConnectorKafkaClusterInput interface {
	pulumi.Input

	ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput
	ToConnectorKafkaClusterOutputWithContext(context.Context) ConnectorKafkaClusterOutput
}

ConnectorKafkaClusterInput is an input type that accepts ConnectorKafkaClusterArgs and ConnectorKafkaClusterOutput values. You can construct a concrete instance of `ConnectorKafkaClusterInput` via: 

ConnectorKafkaClusterArgs{...}

type ConnectorKafkaClusterOutput 

type ConnectorKafkaClusterOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterOutput) ApacheKafkaCluster 

func (o ConnectorKafkaClusterOutput) ApacheKafkaCluster() ConnectorKafkaClusterApacheKafkaClusterOutput

The Apache Kafka cluster to which the connector is connected.

func (ConnectorKafkaClusterOutput) ElementType 

func (ConnectorKafkaClusterOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput 

func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutputWithContext 

func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutputWithContext(ctx context.Context) ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterPtrOutput 

func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterPtrOutput() ConnectorKafkaClusterPtrOutput

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterPtrOutputWithContext 

func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterPtrOutput

type ConnectorKafkaClusterPtrInput 

type ConnectorKafkaClusterPtrInput interface {
	pulumi.Input

	ToConnectorKafkaClusterPtrOutput() ConnectorKafkaClusterPtrOutput
	ToConnectorKafkaClusterPtrOutputWithContext(context.Context) ConnectorKafkaClusterPtrOutput
}

ConnectorKafkaClusterPtrInput is an input type that accepts ConnectorKafkaClusterArgs, ConnectorKafkaClusterPtr and ConnectorKafkaClusterPtrOutput values. You can construct a concrete instance of `ConnectorKafkaClusterPtrInput` via: 

        ConnectorKafkaClusterArgs{...}

or:

        nil

func ConnectorKafkaClusterPtr 

func ConnectorKafkaClusterPtr(v *ConnectorKafkaClusterArgs) ConnectorKafkaClusterPtrInput

type ConnectorKafkaClusterPtrOutput 

type ConnectorKafkaClusterPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterPtrOutput) ApacheKafkaCluster 

func (o ConnectorKafkaClusterPtrOutput) ApacheKafkaCluster() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

The Apache Kafka cluster to which the connector is connected.

func (ConnectorKafkaClusterPtrOutput) Elem 

func (o ConnectorKafkaClusterPtrOutput) Elem() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterPtrOutput) ElementType 

func (ConnectorKafkaClusterPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterPtrOutput) ToConnectorKafkaClusterPtrOutput 

func (o ConnectorKafkaClusterPtrOutput) ToConnectorKafkaClusterPtrOutput() ConnectorKafkaClusterPtrOutput

func (ConnectorKafkaClusterPtrOutput) ToConnectorKafkaClusterPtrOutputWithContext 

func (o ConnectorKafkaClusterPtrOutput) ToConnectorKafkaClusterPtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterPtrOutput

type ConnectorLogDelivery 

type ConnectorLogDelivery struct {
	// The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
	WorkerLogDelivery ConnectorLogDeliveryWorkerLogDelivery `pulumi:"workerLogDelivery"`
}

type ConnectorLogDeliveryArgs 

type ConnectorLogDeliveryArgs struct {
	// The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
	WorkerLogDelivery ConnectorLogDeliveryWorkerLogDeliveryInput `pulumi:"workerLogDelivery"`
}

func (ConnectorLogDeliveryArgs) ElementType 

func (ConnectorLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutputWithContext 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutputWithContext 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput

type ConnectorLogDeliveryInput 

type ConnectorLogDeliveryInput interface {
	pulumi.Input

	ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput
	ToConnectorLogDeliveryOutputWithContext(context.Context) ConnectorLogDeliveryOutput
}

ConnectorLogDeliveryInput is an input type that accepts ConnectorLogDeliveryArgs and ConnectorLogDeliveryOutput values. You can construct a concrete instance of `ConnectorLogDeliveryInput` via: 

ConnectorLogDeliveryArgs{...}

type ConnectorLogDeliveryOutput 

type ConnectorLogDeliveryOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryOutput) ElementType 

func (ConnectorLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutputWithContext 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutputWithContext 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryOutput) WorkerLogDelivery 

func (o ConnectorLogDeliveryOutput) WorkerLogDelivery() ConnectorLogDeliveryWorkerLogDeliveryOutput

The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.

type ConnectorLogDeliveryPtrInput 

type ConnectorLogDeliveryPtrInput interface {
	pulumi.Input

	ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput
	ToConnectorLogDeliveryPtrOutputWithContext(context.Context) ConnectorLogDeliveryPtrOutput
}

ConnectorLogDeliveryPtrInput is an input type that accepts ConnectorLogDeliveryArgs, ConnectorLogDeliveryPtr and ConnectorLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorLogDeliveryPtrInput` via: 

        ConnectorLogDeliveryArgs{...}

or:

        nil

func ConnectorLogDeliveryPtr 

func ConnectorLogDeliveryPtr(v *ConnectorLogDeliveryArgs) ConnectorLogDeliveryPtrInput

type ConnectorLogDeliveryPtrOutput 

type ConnectorLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryPtrOutput) Elem 

func (o ConnectorLogDeliveryPtrOutput) Elem() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryPtrOutput) ElementType 

func (ConnectorLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput 

func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutputWithContext 

func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryPtrOutput) WorkerLogDelivery 

func (o ConnectorLogDeliveryPtrOutput) WorkerLogDelivery() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.

type ConnectorLogDeliveryWorkerLogDelivery 

type ConnectorLogDeliveryWorkerLogDelivery struct {
	// Details about delivering logs to Amazon CloudWatch Logs. See below.
	CloudwatchLogs *ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs `pulumi:"cloudwatchLogs"`
	// Details about delivering logs to Amazon Kinesis Data Firehose. See below.
	Firehose *ConnectorLogDeliveryWorkerLogDeliveryFirehose `pulumi:"firehose"`
	// Details about delivering logs to Amazon S3. See below.
	S3 *ConnectorLogDeliveryWorkerLogDeliveryS3 `pulumi:"s3"`
}

type ConnectorLogDeliveryWorkerLogDeliveryArgs 

type ConnectorLogDeliveryWorkerLogDeliveryArgs struct {
	// Details about delivering logs to Amazon CloudWatch Logs. See below.
	CloudwatchLogs ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput `pulumi:"cloudwatchLogs"`
	// Details about delivering logs to Amazon Kinesis Data Firehose. See below.
	Firehose ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput `pulumi:"firehose"`
	// Details about delivering logs to Amazon S3. See below.
	S3 ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput `pulumi:"s3"`
}

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryOutput 

func (i ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryOutput() ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryOutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput 

func (i ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs struct {
	// Whether log delivery to Amazon CloudWatch Logs is enabled.
	Enabled bool `pulumi:"enabled"`
	// The name of the CloudWatch log group that is the destination for log delivery.
	LogGroup *string `pulumi:"logGroup"`
}

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs struct {
	// Whether log delivery to Amazon CloudWatch Logs is enabled.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// The name of the CloudWatch log group that is the destination for log delivery.
	LogGroup pulumi.StringPtrInput `pulumi:"logGroup"`
}

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput 

func (i ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput 

func (i ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsInput 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsInput interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput
	ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput
}

ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsInput is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs and ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsInput` via: 

ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs{...}

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) Enabled 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) Enabled() pulumi.BoolOutput

Whether log delivery to Amazon CloudWatch Logs is enabled.

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) LogGroup 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) LogGroup() pulumi.StringPtrOutput

The name of the CloudWatch log group that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput
	ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput
}

ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs, ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtr and ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput` via: 

        ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs{...}

or:

        nil

func ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtr 

func ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtr(v *ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Elem 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Enabled 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Enabled() pulumi.BoolPtrOutput

Whether log delivery to Amazon CloudWatch Logs is enabled.

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) LogGroup 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) LogGroup() pulumi.StringPtrOutput

The name of the CloudWatch log group that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryFirehose 

type ConnectorLogDeliveryWorkerLogDeliveryFirehose struct {
	// The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
	DeliveryStream *string `pulumi:"deliveryStream"`
	// Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
	Enabled bool `pulumi:"enabled"`
}

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs 

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs struct {
	// The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
	DeliveryStream pulumi.StringPtrInput `pulumi:"deliveryStream"`
	// Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput 

func (i ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput 

func (i ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseInput 

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseInput interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput
	ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput
}

ConnectorLogDeliveryWorkerLogDeliveryFirehoseInput is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs and ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryFirehoseInput` via: 

ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs{...}

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput 

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) DeliveryStream 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) DeliveryStream() pulumi.StringPtrOutput

The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) Enabled 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) Enabled() pulumi.BoolOutput

Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput 

type ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput
	ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput
}

ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs, ConnectorLogDeliveryWorkerLogDeliveryFirehosePtr and ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput` via: 

        ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs{...}

or:

        nil

func ConnectorLogDeliveryWorkerLogDeliveryFirehosePtr 

func ConnectorLogDeliveryWorkerLogDeliveryFirehosePtr(v *ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput

type ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput 

type ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) DeliveryStream 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) DeliveryStream() pulumi.StringPtrOutput

The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) Elem 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) Enabled 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) Enabled() pulumi.BoolPtrOutput

Specifies whether connector logs get delivered to Amazon Kinesis Data Firehose.

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryInput 

type ConnectorLogDeliveryWorkerLogDeliveryInput interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryOutput() ConnectorLogDeliveryWorkerLogDeliveryOutput
	ToConnectorLogDeliveryWorkerLogDeliveryOutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryOutput
}

ConnectorLogDeliveryWorkerLogDeliveryInput is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryArgs and ConnectorLogDeliveryWorkerLogDeliveryOutput values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryInput` via: 

ConnectorLogDeliveryWorkerLogDeliveryArgs{...}

type ConnectorLogDeliveryWorkerLogDeliveryOutput 

type ConnectorLogDeliveryWorkerLogDeliveryOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) CloudwatchLogs 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) CloudwatchLogs() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

Details about delivering logs to Amazon CloudWatch Logs. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) Firehose 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) Firehose() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

Details about delivering logs to Amazon Kinesis Data Firehose. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) S3 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) S3() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

Details about delivering logs to Amazon S3. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryOutput() ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryPtrInput 

type ConnectorLogDeliveryWorkerLogDeliveryPtrInput interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput
	ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryPtrOutput
}

ConnectorLogDeliveryWorkerLogDeliveryPtrInput is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryArgs, ConnectorLogDeliveryWorkerLogDeliveryPtr and ConnectorLogDeliveryWorkerLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryPtrInput` via: 

        ConnectorLogDeliveryWorkerLogDeliveryArgs{...}

or:

        nil

func ConnectorLogDeliveryWorkerLogDeliveryPtr 

func ConnectorLogDeliveryWorkerLogDeliveryPtr(v *ConnectorLogDeliveryWorkerLogDeliveryArgs) ConnectorLogDeliveryWorkerLogDeliveryPtrInput

type ConnectorLogDeliveryWorkerLogDeliveryPtrOutput 

type ConnectorLogDeliveryWorkerLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) CloudwatchLogs 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) CloudwatchLogs() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

Details about delivering logs to Amazon CloudWatch Logs. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Elem 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Firehose 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Firehose() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

Details about delivering logs to Amazon Kinesis Data Firehose. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) S3 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) S3() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

Details about delivering logs to Amazon S3. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryS3 

type ConnectorLogDeliveryWorkerLogDeliveryS3 struct {
	// The name of the S3 bucket that is the destination for log delivery.
	Bucket *string `pulumi:"bucket"`
	// Whether log delivery to Amazon CloudWatch Logs is enabled.
	Enabled bool `pulumi:"enabled"`
	// The S3 prefix that is the destination for log delivery.
	Prefix *string `pulumi:"prefix"`
}

type ConnectorLogDeliveryWorkerLogDeliveryS3Args 

type ConnectorLogDeliveryWorkerLogDeliveryS3Args struct {
	// The name of the S3 bucket that is the destination for log delivery.
	Bucket pulumi.StringPtrInput `pulumi:"bucket"`
	// Whether log delivery to Amazon CloudWatch Logs is enabled.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// The S3 prefix that is the destination for log delivery.
	Prefix pulumi.StringPtrInput `pulumi:"prefix"`
}

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3Output 

func (i ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3Output() ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3OutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3OutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput 

func (i ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext 

func (i ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryS3Input 

type ConnectorLogDeliveryWorkerLogDeliveryS3Input interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryS3Output() ConnectorLogDeliveryWorkerLogDeliveryS3Output
	ToConnectorLogDeliveryWorkerLogDeliveryS3OutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryS3Output
}

ConnectorLogDeliveryWorkerLogDeliveryS3Input is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryS3Args and ConnectorLogDeliveryWorkerLogDeliveryS3Output values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryS3Input` via: 

ConnectorLogDeliveryWorkerLogDeliveryS3Args{...}

type ConnectorLogDeliveryWorkerLogDeliveryS3Output 

type ConnectorLogDeliveryWorkerLogDeliveryS3Output struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) Bucket 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) Bucket() pulumi.StringPtrOutput

The name of the S3 bucket that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) Enabled 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) Enabled() pulumi.BoolOutput

Whether log delivery to Amazon CloudWatch Logs is enabled.

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) Prefix 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3Output 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3Output() ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3OutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3OutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

type ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput 

type ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput interface {
	pulumi.Input

	ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput
	ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext(context.Context) ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput
}

ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput is an input type that accepts ConnectorLogDeliveryWorkerLogDeliveryS3Args, ConnectorLogDeliveryWorkerLogDeliveryS3Ptr and ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput values. You can construct a concrete instance of `ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput` via: 

        ConnectorLogDeliveryWorkerLogDeliveryS3Args{...}

or:

        nil

func ConnectorLogDeliveryWorkerLogDeliveryS3Ptr 

func ConnectorLogDeliveryWorkerLogDeliveryS3Ptr(v *ConnectorLogDeliveryWorkerLogDeliveryS3Args) ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput

type ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput 

type ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Bucket 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Bucket() pulumi.StringPtrOutput

The name of the S3 bucket that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Elem 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ElementType 

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Enabled 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Enabled() pulumi.BoolPtrOutput

Whether log delivery to Amazon CloudWatch Logs is enabled.

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Prefix 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext(ctx context.Context) ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

type ConnectorMap 

type ConnectorMap map[string]ConnectorInput

func (ConnectorMap) ElementType 

func (ConnectorMap) ElementType() reflect.Type

func (ConnectorMap) ToConnectorMapOutput 

func (i ConnectorMap) ToConnectorMapOutput() ConnectorMapOutput

func (ConnectorMap) ToConnectorMapOutputWithContext 

func (i ConnectorMap) ToConnectorMapOutputWithContext(ctx context.Context) ConnectorMapOutput

type ConnectorMapInput 

type ConnectorMapInput interface {
	pulumi.Input

	ToConnectorMapOutput() ConnectorMapOutput
	ToConnectorMapOutputWithContext(context.Context) ConnectorMapOutput
}

ConnectorMapInput is an input type that accepts ConnectorMap and ConnectorMapOutput values. You can construct a concrete instance of `ConnectorMapInput` via: 

ConnectorMap{ "key": ConnectorArgs{...} }

type ConnectorMapOutput 

type ConnectorMapOutput struct{ *pulumi.OutputState }

func (ConnectorMapOutput) ElementType 

func (ConnectorMapOutput) ElementType() reflect.Type

func (ConnectorMapOutput) MapIndex 

func (o ConnectorMapOutput) MapIndex(k pulumi.StringInput) ConnectorOutput

func (ConnectorMapOutput) ToConnectorMapOutput 

func (o ConnectorMapOutput) ToConnectorMapOutput() ConnectorMapOutput

func (ConnectorMapOutput) ToConnectorMapOutputWithContext 

func (o ConnectorMapOutput) ToConnectorMapOutputWithContext(ctx context.Context) ConnectorMapOutput

type ConnectorOutput 

type ConnectorOutput struct{ *pulumi.OutputState }

func (ConnectorOutput) Arn 

func (o ConnectorOutput) Arn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the custom plugin.

func (ConnectorOutput) Capacity 

func (o ConnectorOutput) Capacity() ConnectorCapacityOutput

Information about the capacity allocated to the connector. See below.

func (ConnectorOutput) ConnectorConfiguration 

func (o ConnectorOutput) ConnectorConfiguration() pulumi.StringMapOutput

A map of keys to values that represent the configuration for the connector.

func (ConnectorOutput) Description 

func (o ConnectorOutput) Description() pulumi.StringPtrOutput

A summary description of the connector.

func (ConnectorOutput) ElementType 

func (ConnectorOutput) ElementType() reflect.Type

func (ConnectorOutput) KafkaCluster 

func (o ConnectorOutput) KafkaCluster() ConnectorKafkaClusterOutput

Specifies which Apache Kafka cluster to connect to. See below.

func (ConnectorOutput) KafkaClusterClientAuthentication 

func (o ConnectorOutput) KafkaClusterClientAuthentication() ConnectorKafkaClusterClientAuthenticationOutput

Details of the client authentication used by the Apache Kafka cluster. See below.

func (ConnectorOutput) KafkaClusterEncryptionInTransit 

func (o ConnectorOutput) KafkaClusterEncryptionInTransit() ConnectorKafkaClusterEncryptionInTransitOutput

Details of encryption in transit to the Apache Kafka cluster. See below.

func (ConnectorOutput) KafkaconnectVersion 

func (o ConnectorOutput) KafkaconnectVersion() pulumi.StringOutput

The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.

func (ConnectorOutput) LogDelivery 

func (o ConnectorOutput) LogDelivery() ConnectorLogDeliveryPtrOutput

Details about log delivery. See below.

func (ConnectorOutput) Name 

func (o ConnectorOutput) Name() pulumi.StringOutput

The name of the connector.

func (ConnectorOutput) Plugins 

func (o ConnectorOutput) Plugins() ConnectorPluginArrayOutput

Specifies which plugins to use for the connector. See below.

func (ConnectorOutput) ServiceExecutionRoleArn 

func (o ConnectorOutput) ServiceExecutionRoleArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.

func (ConnectorOutput) ToConnectorOutput 

func (o ConnectorOutput) ToConnectorOutput() ConnectorOutput

func (ConnectorOutput) ToConnectorOutputWithContext 

func (o ConnectorOutput) ToConnectorOutputWithContext(ctx context.Context) ConnectorOutput

func (ConnectorOutput) Version 

func (o ConnectorOutput) Version() pulumi.StringOutput

The current version of the connector.

func (ConnectorOutput) WorkerConfiguration 

func (o ConnectorOutput) WorkerConfiguration() ConnectorWorkerConfigurationPtrOutput

Specifies which worker configuration to use with the connector. See below.

type ConnectorPlugin 

type ConnectorPlugin struct {
	// Details about a custom plugin. See below.
	CustomPlugin ConnectorPluginCustomPlugin `pulumi:"customPlugin"`
}

type ConnectorPluginArgs 

type ConnectorPluginArgs struct {
	// Details about a custom plugin. See below.
	CustomPlugin ConnectorPluginCustomPluginInput `pulumi:"customPlugin"`
}

func (ConnectorPluginArgs) ElementType 

func (ConnectorPluginArgs) ElementType() reflect.Type

func (ConnectorPluginArgs) ToConnectorPluginOutput 

func (i ConnectorPluginArgs) ToConnectorPluginOutput() ConnectorPluginOutput

func (ConnectorPluginArgs) ToConnectorPluginOutputWithContext 

func (i ConnectorPluginArgs) ToConnectorPluginOutputWithContext(ctx context.Context) ConnectorPluginOutput

type ConnectorPluginArray 

type ConnectorPluginArray []ConnectorPluginInput

func (ConnectorPluginArray) ElementType 

func (ConnectorPluginArray) ElementType() reflect.Type

func (ConnectorPluginArray) ToConnectorPluginArrayOutput 

func (i ConnectorPluginArray) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput

func (ConnectorPluginArray) ToConnectorPluginArrayOutputWithContext 

func (i ConnectorPluginArray) ToConnectorPluginArrayOutputWithContext(ctx context.Context) ConnectorPluginArrayOutput

type ConnectorPluginArrayInput 

type ConnectorPluginArrayInput interface {
	pulumi.Input

	ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput
	ToConnectorPluginArrayOutputWithContext(context.Context) ConnectorPluginArrayOutput
}

ConnectorPluginArrayInput is an input type that accepts ConnectorPluginArray and ConnectorPluginArrayOutput values. You can construct a concrete instance of `ConnectorPluginArrayInput` via: 

ConnectorPluginArray{ ConnectorPluginArgs{...} }

type ConnectorPluginArrayOutput 

type ConnectorPluginArrayOutput struct{ *pulumi.OutputState }

func (ConnectorPluginArrayOutput) ElementType 

func (ConnectorPluginArrayOutput) ElementType() reflect.Type

func (ConnectorPluginArrayOutput) Index 

func (o ConnectorPluginArrayOutput) Index(i pulumi.IntInput) ConnectorPluginOutput

func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput 

func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput

func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutputWithContext 

func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutputWithContext(ctx context.Context) ConnectorPluginArrayOutput

type ConnectorPluginCustomPlugin 

type ConnectorPluginCustomPlugin struct {
	// The Amazon Resource Name (ARN) of the custom plugin.
	Arn string `pulumi:"arn"`
	// The revision of the custom plugin.
	Revision int `pulumi:"revision"`
}

type ConnectorPluginCustomPluginArgs 

type ConnectorPluginCustomPluginArgs struct {
	// The Amazon Resource Name (ARN) of the custom plugin.
	Arn pulumi.StringInput `pulumi:"arn"`
	// The revision of the custom plugin.
	Revision pulumi.IntInput `pulumi:"revision"`
}

func (ConnectorPluginCustomPluginArgs) ElementType 

func (ConnectorPluginCustomPluginArgs) ElementType() reflect.Type

func (ConnectorPluginCustomPluginArgs) ToConnectorPluginCustomPluginOutput 

func (i ConnectorPluginCustomPluginArgs) ToConnectorPluginCustomPluginOutput() ConnectorPluginCustomPluginOutput

func (ConnectorPluginCustomPluginArgs) ToConnectorPluginCustomPluginOutputWithContext 

func (i ConnectorPluginCustomPluginArgs) ToConnectorPluginCustomPluginOutputWithContext(ctx context.Context) ConnectorPluginCustomPluginOutput

type ConnectorPluginCustomPluginInput 

type ConnectorPluginCustomPluginInput interface {
	pulumi.Input

	ToConnectorPluginCustomPluginOutput() ConnectorPluginCustomPluginOutput
	ToConnectorPluginCustomPluginOutputWithContext(context.Context) ConnectorPluginCustomPluginOutput
}

ConnectorPluginCustomPluginInput is an input type that accepts ConnectorPluginCustomPluginArgs and ConnectorPluginCustomPluginOutput values. You can construct a concrete instance of `ConnectorPluginCustomPluginInput` via: 

ConnectorPluginCustomPluginArgs{...}

type ConnectorPluginCustomPluginOutput 

type ConnectorPluginCustomPluginOutput struct{ *pulumi.OutputState }

func (ConnectorPluginCustomPluginOutput) Arn 

func (o ConnectorPluginCustomPluginOutput) Arn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the custom plugin.

func (ConnectorPluginCustomPluginOutput) ElementType 

func (ConnectorPluginCustomPluginOutput) ElementType() reflect.Type

func (ConnectorPluginCustomPluginOutput) Revision 

func (o ConnectorPluginCustomPluginOutput) Revision() pulumi.IntOutput

The revision of the custom plugin.

func (ConnectorPluginCustomPluginOutput) ToConnectorPluginCustomPluginOutput 

func (o ConnectorPluginCustomPluginOutput) ToConnectorPluginCustomPluginOutput() ConnectorPluginCustomPluginOutput

func (ConnectorPluginCustomPluginOutput) ToConnectorPluginCustomPluginOutputWithContext 

func (o ConnectorPluginCustomPluginOutput) ToConnectorPluginCustomPluginOutputWithContext(ctx context.Context) ConnectorPluginCustomPluginOutput

type ConnectorPluginInput 

type ConnectorPluginInput interface {
	pulumi.Input

	ToConnectorPluginOutput() ConnectorPluginOutput
	ToConnectorPluginOutputWithContext(context.Context) ConnectorPluginOutput
}

ConnectorPluginInput is an input type that accepts ConnectorPluginArgs and ConnectorPluginOutput values. You can construct a concrete instance of `ConnectorPluginInput` via: 

ConnectorPluginArgs{...}

type ConnectorPluginOutput 

type ConnectorPluginOutput struct{ *pulumi.OutputState }

func (ConnectorPluginOutput) CustomPlugin 

func (o ConnectorPluginOutput) CustomPlugin() ConnectorPluginCustomPluginOutput

Details about a custom plugin. See below.

func (ConnectorPluginOutput) ElementType 

func (ConnectorPluginOutput) ElementType() reflect.Type

func (ConnectorPluginOutput) ToConnectorPluginOutput 

func (o ConnectorPluginOutput) ToConnectorPluginOutput() ConnectorPluginOutput

func (ConnectorPluginOutput) ToConnectorPluginOutputWithContext 

func (o ConnectorPluginOutput) ToConnectorPluginOutputWithContext(ctx context.Context) ConnectorPluginOutput

type ConnectorState 

type ConnectorState struct {
	// The Amazon Resource Name (ARN) of the custom plugin.
	Arn pulumi.StringPtrInput
	// Information about the capacity allocated to the connector. See below.
	Capacity ConnectorCapacityPtrInput
	// A map of keys to values that represent the configuration for the connector.
	ConnectorConfiguration pulumi.StringMapInput
	// A summary description of the connector.
	Description pulumi.StringPtrInput
	// Specifies which Apache Kafka cluster to connect to. See below.
	KafkaCluster ConnectorKafkaClusterPtrInput
	// Details of the client authentication used by the Apache Kafka cluster. See below.
	KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationPtrInput
	// Details of encryption in transit to the Apache Kafka cluster. See below.
	KafkaClusterEncryptionInTransit ConnectorKafkaClusterEncryptionInTransitPtrInput
	// The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
	KafkaconnectVersion pulumi.StringPtrInput
	// Details about log delivery. See below.
	LogDelivery ConnectorLogDeliveryPtrInput
	// The name of the connector.
	Name pulumi.StringPtrInput
	// Specifies which plugins to use for the connector. See below.
	Plugins ConnectorPluginArrayInput
	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
	ServiceExecutionRoleArn pulumi.StringPtrInput
	// The current version of the connector.
	Version pulumi.StringPtrInput
	// Specifies which worker configuration to use with the connector. See below.
	WorkerConfiguration ConnectorWorkerConfigurationPtrInput
}

func (ConnectorState) ElementType 

func (ConnectorState) ElementType() reflect.Type

type ConnectorWorkerConfiguration 

type ConnectorWorkerConfiguration struct {
	// The Amazon Resource Name (ARN) of the worker configuration.
	Arn string `pulumi:"arn"`
	// The revision of the worker configuration.
	Revision int `pulumi:"revision"`
}

type ConnectorWorkerConfigurationArgs 

type ConnectorWorkerConfigurationArgs struct {
	// The Amazon Resource Name (ARN) of the worker configuration.
	Arn pulumi.StringInput `pulumi:"arn"`
	// The revision of the worker configuration.
	Revision pulumi.IntInput `pulumi:"revision"`
}

func (ConnectorWorkerConfigurationArgs) ElementType 

func (ConnectorWorkerConfigurationArgs) ElementType() reflect.Type

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutputWithContext 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutputWithContext 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput

type ConnectorWorkerConfigurationInput 

type ConnectorWorkerConfigurationInput interface {
	pulumi.Input

	ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput
	ToConnectorWorkerConfigurationOutputWithContext(context.Context) ConnectorWorkerConfigurationOutput
}

ConnectorWorkerConfigurationInput is an input type that accepts ConnectorWorkerConfigurationArgs and ConnectorWorkerConfigurationOutput values. You can construct a concrete instance of `ConnectorWorkerConfigurationInput` via: 

ConnectorWorkerConfigurationArgs{...}

type ConnectorWorkerConfigurationOutput 

type ConnectorWorkerConfigurationOutput struct{ *pulumi.OutputState }

func (ConnectorWorkerConfigurationOutput) Arn 

func (o ConnectorWorkerConfigurationOutput) Arn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the worker configuration.

func (ConnectorWorkerConfigurationOutput) ElementType 

func (ConnectorWorkerConfigurationOutput) ElementType() reflect.Type

func (ConnectorWorkerConfigurationOutput) Revision 

func (o ConnectorWorkerConfigurationOutput) Revision() pulumi.IntOutput

The revision of the worker configuration.

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutputWithContext 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutputWithContext 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput

type ConnectorWorkerConfigurationPtrInput 

type ConnectorWorkerConfigurationPtrInput interface {
	pulumi.Input

	ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput
	ToConnectorWorkerConfigurationPtrOutputWithContext(context.Context) ConnectorWorkerConfigurationPtrOutput
}

ConnectorWorkerConfigurationPtrInput is an input type that accepts ConnectorWorkerConfigurationArgs, ConnectorWorkerConfigurationPtr and ConnectorWorkerConfigurationPtrOutput values. You can construct a concrete instance of `ConnectorWorkerConfigurationPtrInput` via: 

        ConnectorWorkerConfigurationArgs{...}

or:

        nil

func ConnectorWorkerConfigurationPtr 

func ConnectorWorkerConfigurationPtr(v *ConnectorWorkerConfigurationArgs) ConnectorWorkerConfigurationPtrInput

type ConnectorWorkerConfigurationPtrOutput 

type ConnectorWorkerConfigurationPtrOutput struct{ *pulumi.OutputState }

func (ConnectorWorkerConfigurationPtrOutput) Arn 

func (o ConnectorWorkerConfigurationPtrOutput) Arn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) of the worker configuration.

func (ConnectorWorkerConfigurationPtrOutput) Elem 

func (o ConnectorWorkerConfigurationPtrOutput) Elem() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationPtrOutput) ElementType 

func (ConnectorWorkerConfigurationPtrOutput) ElementType() reflect.Type

func (ConnectorWorkerConfigurationPtrOutput) Revision 

func (o ConnectorWorkerConfigurationPtrOutput) Revision() pulumi.IntPtrOutput

The revision of the worker configuration.

func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput 

func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutputWithContext 

func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutputWithContext(ctx context.Context) ConnectorWorkerConfigurationPtrOutput

type CustomPlugin 

type CustomPlugin struct {
	pulumi.CustomResourceState

	// the Amazon Resource Name (ARN) of the custom plugin.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// The type of the plugin file. Allowed values are `ZIP` and `JAR`.
	ContentType pulumi.StringOutput `pulumi:"contentType"`
	// A summary description of the custom plugin.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// an ID of the latest successfully created revision of the custom plugin.
	LatestRevision pulumi.IntOutput `pulumi:"latestRevision"`
	// Information about the location of a custom plugin. See below.
	//
	// The following arguments are optional:
	Location CustomPluginLocationOutput `pulumi:"location"`
	// The name of the custom plugin..
	Name pulumi.StringOutput `pulumi:"name"`
	// the state of the custom plugin.
	State pulumi.StringOutput `pulumi:"state"`
}

Provides an Amazon MSK Connect Custom Plugin Resource.

## Example Usage ### Basic configuration

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/mskconnect"
"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/s3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		exampleBucketV2, err := s3.NewBucketV2(ctx, "exampleBucketV2", nil)
		if err != nil {
			return err
		}
		exampleBucketObjectv2, err := s3.NewBucketObjectv2(ctx, "exampleBucketObjectv2", &s3.BucketObjectv2Args{
			Bucket: exampleBucketV2.ID(),
			Key:    pulumi.String("debezium.zip"),
			Source: pulumi.NewFileAsset("debezium.zip"),
		})
		if err != nil {
			return err
		}
		_, err = mskconnect.NewCustomPlugin(ctx, "exampleCustomPlugin", &mskconnect.CustomPluginArgs{
			ContentType: pulumi.String("ZIP"),
			Location: &mskconnect.CustomPluginLocationArgs{
				S3: &mskconnect.CustomPluginLocationS3Args{
					BucketArn: exampleBucketV2.Arn,
					FileKey:   exampleBucketObjectv2.Key,
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

terraform import { 

to = aws_mskconnect_custom_plugin.example

id = "arn:aws:kafkaconnect:eu-central-1:123456789012:custom-plugin/debezium-example/abcdefgh-1234-5678-9abc-defghijklmno-4" } Using `pulumi import`, import MSK Connect Custom Plugin using the plugin's `arn`. For exampleconsole % pulumi import aws_mskconnect_custom_plugin.example 'arn:aws:kafkaconnect:eu-central-1:123456789012:custom-plugin/debezium-example/abcdefgh-1234-5678-9abc-defghijklmno-4'

func GetCustomPlugin 

func GetCustomPlugin(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *CustomPluginState, opts ...pulumi.ResourceOption) (*CustomPlugin, error)

GetCustomPlugin gets an existing CustomPlugin 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 NewCustomPlugin 

func NewCustomPlugin(ctx *pulumi.Context,
	name string, args *CustomPluginArgs, opts ...pulumi.ResourceOption) (*CustomPlugin, error)

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

func (*CustomPlugin) ElementType 

func (*CustomPlugin) ElementType() reflect.Type

func (*CustomPlugin) ToCustomPluginOutput 

func (i *CustomPlugin) ToCustomPluginOutput() CustomPluginOutput

func (*CustomPlugin) ToCustomPluginOutputWithContext 

func (i *CustomPlugin) ToCustomPluginOutputWithContext(ctx context.Context) CustomPluginOutput

type CustomPluginArgs 

type CustomPluginArgs struct {
	// The type of the plugin file. Allowed values are `ZIP` and `JAR`.
	ContentType pulumi.StringInput
	// A summary description of the custom plugin.
	Description pulumi.StringPtrInput
	// Information about the location of a custom plugin. See below.
	//
	// The following arguments are optional:
	Location CustomPluginLocationInput
	// The name of the custom plugin..
	Name pulumi.StringPtrInput
}

The set of arguments for constructing a CustomPlugin resource.

func (CustomPluginArgs) ElementType 

func (CustomPluginArgs) ElementType() reflect.Type

type CustomPluginArray 

type CustomPluginArray []CustomPluginInput

func (CustomPluginArray) ElementType 

func (CustomPluginArray) ElementType() reflect.Type

func (CustomPluginArray) ToCustomPluginArrayOutput 

func (i CustomPluginArray) ToCustomPluginArrayOutput() CustomPluginArrayOutput

func (CustomPluginArray) ToCustomPluginArrayOutputWithContext 

func (i CustomPluginArray) ToCustomPluginArrayOutputWithContext(ctx context.Context) CustomPluginArrayOutput

type CustomPluginArrayInput 

type CustomPluginArrayInput interface {
	pulumi.Input

	ToCustomPluginArrayOutput() CustomPluginArrayOutput
	ToCustomPluginArrayOutputWithContext(context.Context) CustomPluginArrayOutput
}

CustomPluginArrayInput is an input type that accepts CustomPluginArray and CustomPluginArrayOutput values. You can construct a concrete instance of `CustomPluginArrayInput` via: 

CustomPluginArray{ CustomPluginArgs{...} }

type CustomPluginArrayOutput 

type CustomPluginArrayOutput struct{ *pulumi.OutputState }

func (CustomPluginArrayOutput) ElementType 

func (CustomPluginArrayOutput) ElementType() reflect.Type

func (CustomPluginArrayOutput) Index 

func (o CustomPluginArrayOutput) Index(i pulumi.IntInput) CustomPluginOutput

func (CustomPluginArrayOutput) ToCustomPluginArrayOutput 

func (o CustomPluginArrayOutput) ToCustomPluginArrayOutput() CustomPluginArrayOutput

func (CustomPluginArrayOutput) ToCustomPluginArrayOutputWithContext 

func (o CustomPluginArrayOutput) ToCustomPluginArrayOutputWithContext(ctx context.Context) CustomPluginArrayOutput

type CustomPluginInput 

type CustomPluginInput interface {
	pulumi.Input

	ToCustomPluginOutput() CustomPluginOutput
	ToCustomPluginOutputWithContext(ctx context.Context) CustomPluginOutput
}

type CustomPluginLocation 

type CustomPluginLocation struct {
	// Information of the plugin file stored in Amazon S3. See below.
	S3 CustomPluginLocationS3 `pulumi:"s3"`
}

type CustomPluginLocationArgs 

type CustomPluginLocationArgs struct {
	// Information of the plugin file stored in Amazon S3. See below.
	S3 CustomPluginLocationS3Input `pulumi:"s3"`
}

func (CustomPluginLocationArgs) ElementType 

func (CustomPluginLocationArgs) ElementType() reflect.Type

func (CustomPluginLocationArgs) ToCustomPluginLocationOutput 

func (i CustomPluginLocationArgs) ToCustomPluginLocationOutput() CustomPluginLocationOutput

func (CustomPluginLocationArgs) ToCustomPluginLocationOutputWithContext 

func (i CustomPluginLocationArgs) ToCustomPluginLocationOutputWithContext(ctx context.Context) CustomPluginLocationOutput

func (CustomPluginLocationArgs) ToCustomPluginLocationPtrOutput 

func (i CustomPluginLocationArgs) ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput

func (CustomPluginLocationArgs) ToCustomPluginLocationPtrOutputWithContext 

func (i CustomPluginLocationArgs) ToCustomPluginLocationPtrOutputWithContext(ctx context.Context) CustomPluginLocationPtrOutput

type CustomPluginLocationInput 

type CustomPluginLocationInput interface {
	pulumi.Input

	ToCustomPluginLocationOutput() CustomPluginLocationOutput
	ToCustomPluginLocationOutputWithContext(context.Context) CustomPluginLocationOutput
}

CustomPluginLocationInput is an input type that accepts CustomPluginLocationArgs and CustomPluginLocationOutput values. You can construct a concrete instance of `CustomPluginLocationInput` via: 

CustomPluginLocationArgs{...}

type CustomPluginLocationOutput 

type CustomPluginLocationOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationOutput) ElementType 

func (CustomPluginLocationOutput) ElementType() reflect.Type

func (CustomPluginLocationOutput) S3 

func (o CustomPluginLocationOutput) S3() CustomPluginLocationS3Output

Information of the plugin file stored in Amazon S3. See below.

func (CustomPluginLocationOutput) ToCustomPluginLocationOutput 

func (o CustomPluginLocationOutput) ToCustomPluginLocationOutput() CustomPluginLocationOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationOutputWithContext 

func (o CustomPluginLocationOutput) ToCustomPluginLocationOutputWithContext(ctx context.Context) CustomPluginLocationOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationPtrOutput 

func (o CustomPluginLocationOutput) ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationPtrOutputWithContext 

func (o CustomPluginLocationOutput) ToCustomPluginLocationPtrOutputWithContext(ctx context.Context) CustomPluginLocationPtrOutput

type CustomPluginLocationPtrInput 

type CustomPluginLocationPtrInput interface {
	pulumi.Input

	ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput
	ToCustomPluginLocationPtrOutputWithContext(context.Context) CustomPluginLocationPtrOutput
}

CustomPluginLocationPtrInput is an input type that accepts CustomPluginLocationArgs, CustomPluginLocationPtr and CustomPluginLocationPtrOutput values. You can construct a concrete instance of `CustomPluginLocationPtrInput` via: 

        CustomPluginLocationArgs{...}

or:

        nil

func CustomPluginLocationPtr 

func CustomPluginLocationPtr(v *CustomPluginLocationArgs) CustomPluginLocationPtrInput

type CustomPluginLocationPtrOutput 

type CustomPluginLocationPtrOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationPtrOutput) Elem 

func (o CustomPluginLocationPtrOutput) Elem() CustomPluginLocationOutput

func (CustomPluginLocationPtrOutput) ElementType 

func (CustomPluginLocationPtrOutput) ElementType() reflect.Type

func (CustomPluginLocationPtrOutput) S3 

func (o CustomPluginLocationPtrOutput) S3() CustomPluginLocationS3PtrOutput

Information of the plugin file stored in Amazon S3. See below.

func (CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutput 

func (o CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutput() CustomPluginLocationPtrOutput

func (CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutputWithContext 

func (o CustomPluginLocationPtrOutput) ToCustomPluginLocationPtrOutputWithContext(ctx context.Context) CustomPluginLocationPtrOutput

type CustomPluginLocationS3 

type CustomPluginLocationS3 struct {
	// The Amazon Resource Name (ARN) of an S3 bucket.
	BucketArn string `pulumi:"bucketArn"`
	// The file key for an object in an S3 bucket.
	FileKey string `pulumi:"fileKey"`
	// The version of an object in an S3 bucket.
	ObjectVersion *string `pulumi:"objectVersion"`
}

type CustomPluginLocationS3Args 

type CustomPluginLocationS3Args struct {
	// The Amazon Resource Name (ARN) of an S3 bucket.
	BucketArn pulumi.StringInput `pulumi:"bucketArn"`
	// The file key for an object in an S3 bucket.
	FileKey pulumi.StringInput `pulumi:"fileKey"`
	// The version of an object in an S3 bucket.
	ObjectVersion pulumi.StringPtrInput `pulumi:"objectVersion"`
}

func (CustomPluginLocationS3Args) ElementType 

func (CustomPluginLocationS3Args) ElementType() reflect.Type

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3Output 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3Output() CustomPluginLocationS3Output

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3OutputWithContext 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3OutputWithContext(ctx context.Context) CustomPluginLocationS3Output

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutput 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput

func (CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutputWithContext 

func (i CustomPluginLocationS3Args) ToCustomPluginLocationS3PtrOutputWithContext(ctx context.Context) CustomPluginLocationS3PtrOutput

type CustomPluginLocationS3Input 

type CustomPluginLocationS3Input interface {
	pulumi.Input

	ToCustomPluginLocationS3Output() CustomPluginLocationS3Output
	ToCustomPluginLocationS3OutputWithContext(context.Context) CustomPluginLocationS3Output
}

CustomPluginLocationS3Input is an input type that accepts CustomPluginLocationS3Args and CustomPluginLocationS3Output values. You can construct a concrete instance of `CustomPluginLocationS3Input` via: 

CustomPluginLocationS3Args{...}

type CustomPluginLocationS3Output 

type CustomPluginLocationS3Output struct{ *pulumi.OutputState }

func (CustomPluginLocationS3Output) BucketArn 

func (o CustomPluginLocationS3Output) BucketArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of an S3 bucket.

func (CustomPluginLocationS3Output) ElementType 

func (CustomPluginLocationS3Output) ElementType() reflect.Type

func (CustomPluginLocationS3Output) FileKey 

func (o CustomPluginLocationS3Output) FileKey() pulumi.StringOutput

The file key for an object in an S3 bucket.

func (CustomPluginLocationS3Output) ObjectVersion 

func (o CustomPluginLocationS3Output) ObjectVersion() pulumi.StringPtrOutput

The version of an object in an S3 bucket.

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3Output 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3Output() CustomPluginLocationS3Output

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3OutputWithContext 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3OutputWithContext(ctx context.Context) CustomPluginLocationS3Output

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutput 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput

func (CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutputWithContext 

func (o CustomPluginLocationS3Output) ToCustomPluginLocationS3PtrOutputWithContext(ctx context.Context) CustomPluginLocationS3PtrOutput

type CustomPluginLocationS3PtrInput 

type CustomPluginLocationS3PtrInput interface {
	pulumi.Input

	ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput
	ToCustomPluginLocationS3PtrOutputWithContext(context.Context) CustomPluginLocationS3PtrOutput
}

CustomPluginLocationS3PtrInput is an input type that accepts CustomPluginLocationS3Args, CustomPluginLocationS3Ptr and CustomPluginLocationS3PtrOutput values. You can construct a concrete instance of `CustomPluginLocationS3PtrInput` via: 

        CustomPluginLocationS3Args{...}

or:

        nil

func CustomPluginLocationS3Ptr 

func CustomPluginLocationS3Ptr(v *CustomPluginLocationS3Args) CustomPluginLocationS3PtrInput

type CustomPluginLocationS3PtrOutput 

type CustomPluginLocationS3PtrOutput struct{ *pulumi.OutputState }

func (CustomPluginLocationS3PtrOutput) BucketArn 

func (o CustomPluginLocationS3PtrOutput) BucketArn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) of an S3 bucket.

func (CustomPluginLocationS3PtrOutput) Elem 

func (o CustomPluginLocationS3PtrOutput) Elem() CustomPluginLocationS3Output

func (CustomPluginLocationS3PtrOutput) ElementType 

func (CustomPluginLocationS3PtrOutput) ElementType() reflect.Type

func (CustomPluginLocationS3PtrOutput) FileKey 

func (o CustomPluginLocationS3PtrOutput) FileKey() pulumi.StringPtrOutput

The file key for an object in an S3 bucket.

func (CustomPluginLocationS3PtrOutput) ObjectVersion 

func (o CustomPluginLocationS3PtrOutput) ObjectVersion() pulumi.StringPtrOutput

The version of an object in an S3 bucket.

func (CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutput 

func (o CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutput() CustomPluginLocationS3PtrOutput

func (CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutputWithContext 

func (o CustomPluginLocationS3PtrOutput) ToCustomPluginLocationS3PtrOutputWithContext(ctx context.Context) CustomPluginLocationS3PtrOutput

type CustomPluginMap 

type CustomPluginMap map[string]CustomPluginInput

func (CustomPluginMap) ElementType 

func (CustomPluginMap) ElementType() reflect.Type

func (CustomPluginMap) ToCustomPluginMapOutput 

func (i CustomPluginMap) ToCustomPluginMapOutput() CustomPluginMapOutput

func (CustomPluginMap) ToCustomPluginMapOutputWithContext 

func (i CustomPluginMap) ToCustomPluginMapOutputWithContext(ctx context.Context) CustomPluginMapOutput

type CustomPluginMapInput 

type CustomPluginMapInput interface {
	pulumi.Input

	ToCustomPluginMapOutput() CustomPluginMapOutput
	ToCustomPluginMapOutputWithContext(context.Context) CustomPluginMapOutput
}

CustomPluginMapInput is an input type that accepts CustomPluginMap and CustomPluginMapOutput values. You can construct a concrete instance of `CustomPluginMapInput` via: 

CustomPluginMap{ "key": CustomPluginArgs{...} }

type CustomPluginMapOutput 

type CustomPluginMapOutput struct{ *pulumi.OutputState }

func (CustomPluginMapOutput) ElementType 

func (CustomPluginMapOutput) ElementType() reflect.Type

func (CustomPluginMapOutput) MapIndex 

func (o CustomPluginMapOutput) MapIndex(k pulumi.StringInput) CustomPluginOutput

func (CustomPluginMapOutput) ToCustomPluginMapOutput 

func (o CustomPluginMapOutput) ToCustomPluginMapOutput() CustomPluginMapOutput

func (CustomPluginMapOutput) ToCustomPluginMapOutputWithContext 

func (o CustomPluginMapOutput) ToCustomPluginMapOutputWithContext(ctx context.Context) CustomPluginMapOutput

type CustomPluginOutput 

type CustomPluginOutput struct{ *pulumi.OutputState }

func (CustomPluginOutput) Arn 

func (o CustomPluginOutput) Arn() pulumi.StringOutput

the Amazon Resource Name (ARN) of the custom plugin.

func (CustomPluginOutput) ContentType 

func (o CustomPluginOutput) ContentType() pulumi.StringOutput

The type of the plugin file. Allowed values are `ZIP` and `JAR`.

func (CustomPluginOutput) Description 

func (o CustomPluginOutput) Description() pulumi.StringPtrOutput

A summary description of the custom plugin.

func (CustomPluginOutput) ElementType 

func (CustomPluginOutput) ElementType() reflect.Type

func (CustomPluginOutput) LatestRevision 

func (o CustomPluginOutput) LatestRevision() pulumi.IntOutput

an ID of the latest successfully created revision of the custom plugin.

func (CustomPluginOutput) Location 

func (o CustomPluginOutput) Location() CustomPluginLocationOutput

Information about the location of a custom plugin. See below.

The following arguments are optional:

func (CustomPluginOutput) Name 

func (o CustomPluginOutput) Name() pulumi.StringOutput

The name of the custom plugin..

func (CustomPluginOutput) State 

func (o CustomPluginOutput) State() pulumi.StringOutput

the state of the custom plugin.

func (CustomPluginOutput) ToCustomPluginOutput 

func (o CustomPluginOutput) ToCustomPluginOutput() CustomPluginOutput

func (CustomPluginOutput) ToCustomPluginOutputWithContext 

func (o CustomPluginOutput) ToCustomPluginOutputWithContext(ctx context.Context) CustomPluginOutput

type CustomPluginState 

type CustomPluginState struct {
	// the Amazon Resource Name (ARN) of the custom plugin.
	Arn pulumi.StringPtrInput
	// The type of the plugin file. Allowed values are `ZIP` and `JAR`.
	ContentType pulumi.StringPtrInput
	// A summary description of the custom plugin.
	Description pulumi.StringPtrInput
	// an ID of the latest successfully created revision of the custom plugin.
	LatestRevision pulumi.IntPtrInput
	// Information about the location of a custom plugin. See below.
	//
	// The following arguments are optional:
	Location CustomPluginLocationPtrInput
	// The name of the custom plugin..
	Name pulumi.StringPtrInput
	// the state of the custom plugin.
	State pulumi.StringPtrInput
}

func (CustomPluginState) ElementType 

func (CustomPluginState) ElementType() reflect.Type

type LookupConnectorArgs 

type LookupConnectorArgs struct {
	// Name of the connector.
	Name string `pulumi:"name"`
}

A collection of arguments for invoking getConnector.

type LookupConnectorOutputArgs 

type LookupConnectorOutputArgs struct {
	// Name of the connector.
	Name pulumi.StringInput `pulumi:"name"`
}

A collection of arguments for invoking getConnector.

func (LookupConnectorOutputArgs) ElementType 

func (LookupConnectorOutputArgs) ElementType() reflect.Type

type LookupConnectorResult 

type LookupConnectorResult struct {
	// ARN of the connector.
	Arn string `pulumi:"arn"`
	// Summary description of the connector.
	Description string `pulumi:"description"`
	// The provider-assigned unique ID for this managed resource.
	Id   string `pulumi:"id"`
	Name string `pulumi:"name"`
	// Current version of the connector.
	Version string `pulumi:"version"`
}

A collection of values returned by getConnector.

func LookupConnector 

func LookupConnector(ctx *pulumi.Context, args *LookupConnectorArgs, opts ...pulumi.InvokeOption) (*LookupConnectorResult, error)

Get information on an Amazon MSK Connect Connector.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.LookupConnector(ctx, &mskconnect.LookupConnectorArgs{
			Name: "example-mskconnector",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupConnectorResultOutput 

type LookupConnectorResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getConnector.

func LookupConnectorOutput 

func LookupConnectorOutput(ctx *pulumi.Context, args LookupConnectorOutputArgs, opts ...pulumi.InvokeOption) LookupConnectorResultOutput

func (LookupConnectorResultOutput) Arn 

func (o LookupConnectorResultOutput) Arn() pulumi.StringOutput

ARN of the connector.

func (LookupConnectorResultOutput) Description 

func (o LookupConnectorResultOutput) Description() pulumi.StringOutput

Summary description of the connector.

func (LookupConnectorResultOutput) ElementType 

func (LookupConnectorResultOutput) ElementType() reflect.Type

func (LookupConnectorResultOutput) Id 

func (o LookupConnectorResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupConnectorResultOutput) Name 

func (o LookupConnectorResultOutput) Name() pulumi.StringOutput

func (LookupConnectorResultOutput) ToLookupConnectorResultOutput 

func (o LookupConnectorResultOutput) ToLookupConnectorResultOutput() LookupConnectorResultOutput

func (LookupConnectorResultOutput) ToLookupConnectorResultOutputWithContext 

func (o LookupConnectorResultOutput) ToLookupConnectorResultOutputWithContext(ctx context.Context) LookupConnectorResultOutput

func (LookupConnectorResultOutput) Version 

func (o LookupConnectorResultOutput) Version() pulumi.StringOutput

Current version of the connector.

type LookupCustomPluginArgs 

type LookupCustomPluginArgs struct {
	// Name of the custom plugin.
	Name string `pulumi:"name"`
}

A collection of arguments for invoking getCustomPlugin.

type LookupCustomPluginOutputArgs 

type LookupCustomPluginOutputArgs struct {
	// Name of the custom plugin.
	Name pulumi.StringInput `pulumi:"name"`
}

A collection of arguments for invoking getCustomPlugin.

func (LookupCustomPluginOutputArgs) ElementType 

func (LookupCustomPluginOutputArgs) ElementType() reflect.Type

type LookupCustomPluginResult 

type LookupCustomPluginResult struct {
	// the ARN of the custom plugin.
	Arn string `pulumi:"arn"`
	// a summary description of the custom plugin.
	Description string `pulumi:"description"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// an ID of the latest successfully created revision of the custom plugin.
	LatestRevision int    `pulumi:"latestRevision"`
	Name           string `pulumi:"name"`
	// the state of the custom plugin.
	State string `pulumi:"state"`
}

A collection of values returned by getCustomPlugin.

func LookupCustomPlugin 

func LookupCustomPlugin(ctx *pulumi.Context, args *LookupCustomPluginArgs, opts ...pulumi.InvokeOption) (*LookupCustomPluginResult, error)

Get information on an Amazon MSK Connect custom plugin.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.LookupCustomPlugin(ctx, &mskconnect.LookupCustomPluginArgs{
			Name: "example-debezium-1",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

```

type LookupCustomPluginResultOutput 

type LookupCustomPluginResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getCustomPlugin.

func LookupCustomPluginOutput 

func LookupCustomPluginOutput(ctx *pulumi.Context, args LookupCustomPluginOutputArgs, opts ...pulumi.InvokeOption) LookupCustomPluginResultOutput

func (LookupCustomPluginResultOutput) Arn 

func (o LookupCustomPluginResultOutput) Arn() pulumi.StringOutput

the ARN of the custom plugin.

func (LookupCustomPluginResultOutput) Description 

func (o LookupCustomPluginResultOutput) Description() pulumi.StringOutput

a summary description of the custom plugin.

func (LookupCustomPluginResultOutput) ElementType 

func (LookupCustomPluginResultOutput) ElementType() reflect.Type

func (LookupCustomPluginResultOutput) Id 

func (o LookupCustomPluginResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupCustomPluginResultOutput) LatestRevision 

func (o LookupCustomPluginResultOutput) LatestRevision() pulumi.IntOutput

an ID of the latest successfully created revision of the custom plugin.

func (LookupCustomPluginResultOutput) Name 

func (o LookupCustomPluginResultOutput) Name() pulumi.StringOutput

func (LookupCustomPluginResultOutput) State 

func (o LookupCustomPluginResultOutput) State() pulumi.StringOutput

the state of the custom plugin.

func (LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutput 

func (o LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutput() LookupCustomPluginResultOutput

func (LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutputWithContext 

func (o LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutputWithContext(ctx context.Context) LookupCustomPluginResultOutput

type LookupWorkerConfigurationArgs 

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

A collection of arguments for invoking getWorkerConfiguration.

type LookupWorkerConfigurationOutputArgs 

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

A collection of arguments for invoking getWorkerConfiguration.

func (LookupWorkerConfigurationOutputArgs) ElementType 

func (LookupWorkerConfigurationOutputArgs) ElementType() reflect.Type

type LookupWorkerConfigurationResult 

type LookupWorkerConfigurationResult struct {
	// the ARN of the worker configuration.
	Arn string `pulumi:"arn"`
	// a summary description of the worker configuration.
	Description string `pulumi:"description"`
	// The provider-assigned unique ID for this managed resource.
	Id string `pulumi:"id"`
	// an ID of the latest successfully created revision of the worker configuration.
	LatestRevision int    `pulumi:"latestRevision"`
	Name           string `pulumi:"name"`
	// contents of connect-distributed.properties file.
	PropertiesFileContent string `pulumi:"propertiesFileContent"`
}

A collection of values returned by getWorkerConfiguration.

func LookupWorkerConfiguration 

func LookupWorkerConfiguration(ctx *pulumi.Context, args *LookupWorkerConfigurationArgs, opts ...pulumi.InvokeOption) (*LookupWorkerConfigurationResult, error)

Get information on an Amazon MSK Connect Worker Configuration.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

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

```

type LookupWorkerConfigurationResultOutput 

type LookupWorkerConfigurationResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getWorkerConfiguration.

func LookupWorkerConfigurationOutput 

func LookupWorkerConfigurationOutput(ctx *pulumi.Context, args LookupWorkerConfigurationOutputArgs, opts ...pulumi.InvokeOption) LookupWorkerConfigurationResultOutput

func (LookupWorkerConfigurationResultOutput) Arn 

func (o LookupWorkerConfigurationResultOutput) Arn() pulumi.StringOutput

the ARN of the worker configuration.

func (LookupWorkerConfigurationResultOutput) Description 

func (o LookupWorkerConfigurationResultOutput) Description() pulumi.StringOutput

a summary description of the worker configuration.

func (LookupWorkerConfigurationResultOutput) ElementType 

func (LookupWorkerConfigurationResultOutput) ElementType() reflect.Type

func (LookupWorkerConfigurationResultOutput) Id 

func (o LookupWorkerConfigurationResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupWorkerConfigurationResultOutput) LatestRevision 

func (o LookupWorkerConfigurationResultOutput) LatestRevision() pulumi.IntOutput

an ID of the latest successfully created revision of the worker configuration.

func (LookupWorkerConfigurationResultOutput) Name 

func (o LookupWorkerConfigurationResultOutput) Name() pulumi.StringOutput

func (LookupWorkerConfigurationResultOutput) PropertiesFileContent 

func (o LookupWorkerConfigurationResultOutput) PropertiesFileContent() pulumi.StringOutput

contents of connect-distributed.properties file.

func (LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutput 

func (o LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutput() LookupWorkerConfigurationResultOutput

func (LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutputWithContext 

func (o LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutputWithContext(ctx context.Context) LookupWorkerConfigurationResultOutput

type WorkerConfiguration 

type WorkerConfiguration struct {
	pulumi.CustomResourceState

	// the Amazon Resource Name (ARN) of the worker configuration.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// A summary description of the worker configuration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// an ID of the latest successfully created revision of the worker configuration.
	LatestRevision pulumi.IntOutput `pulumi:"latestRevision"`
	// The name of the worker configuration.
	Name pulumi.StringOutput `pulumi:"name"`
	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	//
	// The following arguments are optional:
	PropertiesFileContent pulumi.StringOutput `pulumi:"propertiesFileContent"`
}

Provides an Amazon MSK Connect Worker Configuration Resource.

## Example Usage ### Basic configuration

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v6/go/aws/mskconnect"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := mskconnect.NewWorkerConfiguration(ctx, "example", &mskconnect.WorkerConfigurationArgs{
			PropertiesFileContent: pulumi.String("key.converter=org.apache.kafka.connect.storage.StringConverter\nvalue.converter=org.apache.kafka.connect.storage.StringConverter\n\n"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

terraform import { 

to = aws_mskconnect_worker_configuration.example

id = "arn:aws:kafkaconnect:eu-central-1:123456789012:worker-configuration/example/8848493b-7fcc-478c-a646-4a52634e3378-4" } Using `pulumi import`, import MSK Connect Worker Configuration using the plugin's `arn`. For exampleconsole % pulumi import aws_mskconnect_worker_configuration.example 'arn:aws:kafkaconnect:eu-central-1:123456789012:worker-configuration/example/8848493b-7fcc-478c-a646-4a52634e3378-4'

func GetWorkerConfiguration 

func GetWorkerConfiguration(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *WorkerConfigurationState, opts ...pulumi.ResourceOption) (*WorkerConfiguration, error)

GetWorkerConfiguration gets an existing WorkerConfiguration 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 NewWorkerConfiguration 

func NewWorkerConfiguration(ctx *pulumi.Context,
	name string, args *WorkerConfigurationArgs, opts ...pulumi.ResourceOption) (*WorkerConfiguration, error)

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

func (*WorkerConfiguration) ElementType 

func (*WorkerConfiguration) ElementType() reflect.Type

func (*WorkerConfiguration) ToWorkerConfigurationOutput 

func (i *WorkerConfiguration) ToWorkerConfigurationOutput() WorkerConfigurationOutput

func (*WorkerConfiguration) ToWorkerConfigurationOutputWithContext 

func (i *WorkerConfiguration) ToWorkerConfigurationOutputWithContext(ctx context.Context) WorkerConfigurationOutput

type WorkerConfigurationArgs 

type WorkerConfigurationArgs struct {
	// A summary description of the worker configuration.
	Description pulumi.StringPtrInput
	// The name of the worker configuration.
	Name pulumi.StringPtrInput
	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	//
	// The following arguments are optional:
	PropertiesFileContent pulumi.StringInput
}

The set of arguments for constructing a WorkerConfiguration resource.

func (WorkerConfigurationArgs) ElementType 

func (WorkerConfigurationArgs) ElementType() reflect.Type

type WorkerConfigurationArray 

type WorkerConfigurationArray []WorkerConfigurationInput

func (WorkerConfigurationArray) ElementType 

func (WorkerConfigurationArray) ElementType() reflect.Type

func (WorkerConfigurationArray) ToWorkerConfigurationArrayOutput 

func (i WorkerConfigurationArray) ToWorkerConfigurationArrayOutput() WorkerConfigurationArrayOutput

func (WorkerConfigurationArray) ToWorkerConfigurationArrayOutputWithContext 

func (i WorkerConfigurationArray) ToWorkerConfigurationArrayOutputWithContext(ctx context.Context) WorkerConfigurationArrayOutput

type WorkerConfigurationArrayInput 

type WorkerConfigurationArrayInput interface {
	pulumi.Input

	ToWorkerConfigurationArrayOutput() WorkerConfigurationArrayOutput
	ToWorkerConfigurationArrayOutputWithContext(context.Context) WorkerConfigurationArrayOutput
}

WorkerConfigurationArrayInput is an input type that accepts WorkerConfigurationArray and WorkerConfigurationArrayOutput values. You can construct a concrete instance of `WorkerConfigurationArrayInput` via: 

WorkerConfigurationArray{ WorkerConfigurationArgs{...} }

type WorkerConfigurationArrayOutput 

type WorkerConfigurationArrayOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationArrayOutput) ElementType 

func (WorkerConfigurationArrayOutput) ElementType() reflect.Type

func (WorkerConfigurationArrayOutput) Index 

func (o WorkerConfigurationArrayOutput) Index(i pulumi.IntInput) WorkerConfigurationOutput

func (WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutput 

func (o WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutput() WorkerConfigurationArrayOutput

func (WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutputWithContext 

func (o WorkerConfigurationArrayOutput) ToWorkerConfigurationArrayOutputWithContext(ctx context.Context) WorkerConfigurationArrayOutput

type WorkerConfigurationInput 

type WorkerConfigurationInput interface {
	pulumi.Input

	ToWorkerConfigurationOutput() WorkerConfigurationOutput
	ToWorkerConfigurationOutputWithContext(ctx context.Context) WorkerConfigurationOutput
}

type WorkerConfigurationMap 

type WorkerConfigurationMap map[string]WorkerConfigurationInput

func (WorkerConfigurationMap) ElementType 

func (WorkerConfigurationMap) ElementType() reflect.Type

func (WorkerConfigurationMap) ToWorkerConfigurationMapOutput 

func (i WorkerConfigurationMap) ToWorkerConfigurationMapOutput() WorkerConfigurationMapOutput

func (WorkerConfigurationMap) ToWorkerConfigurationMapOutputWithContext 

func (i WorkerConfigurationMap) ToWorkerConfigurationMapOutputWithContext(ctx context.Context) WorkerConfigurationMapOutput

type WorkerConfigurationMapInput 

type WorkerConfigurationMapInput interface {
	pulumi.Input

	ToWorkerConfigurationMapOutput() WorkerConfigurationMapOutput
	ToWorkerConfigurationMapOutputWithContext(context.Context) WorkerConfigurationMapOutput
}

WorkerConfigurationMapInput is an input type that accepts WorkerConfigurationMap and WorkerConfigurationMapOutput values. You can construct a concrete instance of `WorkerConfigurationMapInput` via: 

WorkerConfigurationMap{ "key": WorkerConfigurationArgs{...} }

type WorkerConfigurationMapOutput 

type WorkerConfigurationMapOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationMapOutput) ElementType 

func (WorkerConfigurationMapOutput) ElementType() reflect.Type

func (WorkerConfigurationMapOutput) MapIndex 

func (o WorkerConfigurationMapOutput) MapIndex(k pulumi.StringInput) WorkerConfigurationOutput

func (WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutput 

func (o WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutput() WorkerConfigurationMapOutput

func (WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutputWithContext 

func (o WorkerConfigurationMapOutput) ToWorkerConfigurationMapOutputWithContext(ctx context.Context) WorkerConfigurationMapOutput

type WorkerConfigurationOutput 

type WorkerConfigurationOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationOutput) Arn 

func (o WorkerConfigurationOutput) Arn() pulumi.StringOutput

the Amazon Resource Name (ARN) of the worker configuration.

func (WorkerConfigurationOutput) Description 

func (o WorkerConfigurationOutput) Description() pulumi.StringPtrOutput

A summary description of the worker configuration.

func (WorkerConfigurationOutput) ElementType 

func (WorkerConfigurationOutput) ElementType() reflect.Type

func (WorkerConfigurationOutput) LatestRevision 

func (o WorkerConfigurationOutput) LatestRevision() pulumi.IntOutput

an ID of the latest successfully created revision of the worker configuration.

func (WorkerConfigurationOutput) Name 

func (o WorkerConfigurationOutput) Name() pulumi.StringOutput

The name of the worker configuration.

func (WorkerConfigurationOutput) PropertiesFileContent 

func (o WorkerConfigurationOutput) PropertiesFileContent() pulumi.StringOutput

Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.

The following arguments are optional:

func (WorkerConfigurationOutput) ToWorkerConfigurationOutput 

func (o WorkerConfigurationOutput) ToWorkerConfigurationOutput() WorkerConfigurationOutput

func (WorkerConfigurationOutput) ToWorkerConfigurationOutputWithContext 

func (o WorkerConfigurationOutput) ToWorkerConfigurationOutputWithContext(ctx context.Context) WorkerConfigurationOutput

type WorkerConfigurationState 

type WorkerConfigurationState struct {
	// the Amazon Resource Name (ARN) of the worker configuration.
	Arn pulumi.StringPtrInput
	// A summary description of the worker configuration.
	Description pulumi.StringPtrInput
	// an ID of the latest successfully created revision of the worker configuration.
	LatestRevision pulumi.IntPtrInput
	// The name of the worker configuration.
	Name pulumi.StringPtrInput
	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	//
	// The following arguments are optional:
	PropertiesFileContent pulumi.StringPtrInput
}

func (WorkerConfigurationState) ElementType 

func (WorkerConfigurationState) 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.