mskconnect

package
v5.7.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Connector added in v5.2.0 

type Connector struct {
	pulumi.CustomResourceState

	// The Amazon Resource Name (ARN) of the worker configuration.
	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/v5/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{
							pulumi.Any(aws_security_group.Example.Id),
						},
						Subnets: pulumi.StringArray{
							pulumi.Any(aws_subnet.Example1.Id),
							pulumi.Any(aws_subnet.Example2.Id),
							pulumi.Any(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

MSK Connect Connector can be imported using the connector's `arn`, e.g.,

```sh 

$ pulumi import aws:mskconnect/connector:Connector example 'arn:aws:kafkaconnect:eu-central-1:123456789012:connector/example/264edee4-17a3-412e-bd76-6681cfc93805-3'

```

func GetConnector added in v5.2.0 

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

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

func (*Connector) ElementType() reflect.Type

func (*Connector) ToConnectorOutput added in v5.2.0 

func (i *Connector) ToConnectorOutput() ConnectorOutput

func (*Connector) ToConnectorOutputWithContext added in v5.2.0 

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

type ConnectorArgs added in v5.2.0 

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

func (ConnectorArgs) ElementType() reflect.Type

type ConnectorArray added in v5.2.0 

type ConnectorArray []ConnectorInput

func (ConnectorArray) ElementType added in v5.2.0 

func (ConnectorArray) ElementType() reflect.Type

func (ConnectorArray) ToConnectorArrayOutput added in v5.2.0 

func (i ConnectorArray) ToConnectorArrayOutput() ConnectorArrayOutput

func (ConnectorArray) ToConnectorArrayOutputWithContext added in v5.2.0 

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

type ConnectorArrayInput added in v5.2.0 

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

type ConnectorArrayOutput struct{ *pulumi.OutputState }

func (ConnectorArrayOutput) ElementType added in v5.2.0 

func (ConnectorArrayOutput) ElementType() reflect.Type

func (ConnectorArrayOutput) Index added in v5.2.0 

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

func (ConnectorArrayOutput) ToConnectorArrayOutput added in v5.2.0 

func (o ConnectorArrayOutput) ToConnectorArrayOutput() ConnectorArrayOutput

func (ConnectorArrayOutput) ToConnectorArrayOutputWithContext added in v5.2.0 

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

type ConnectorCapacity added in v5.2.0 

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

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

func (ConnectorCapacityArgs) ElementType() reflect.Type

func (ConnectorCapacityArgs) ToConnectorCapacityOutput added in v5.2.0 

func (i ConnectorCapacityArgs) ToConnectorCapacityOutput() ConnectorCapacityOutput

func (ConnectorCapacityArgs) ToConnectorCapacityOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityArgs) ToConnectorCapacityPtrOutput added in v5.2.0 

func (i ConnectorCapacityArgs) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput

func (ConnectorCapacityArgs) ToConnectorCapacityPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscaling added in v5.2.0 

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

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

func (ConnectorCapacityAutoscalingArgs) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingOutput added in v5.2.0 

func (i ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingOutput() ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingPtrOutput added in v5.2.0 

func (i ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingPtrOutput() ConnectorCapacityAutoscalingPtrOutput

func (ConnectorCapacityAutoscalingArgs) ToConnectorCapacityAutoscalingPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingInput added in v5.2.0 

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

type ConnectorCapacityAutoscalingOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingOutput) ElementType added in v5.2.0 

func (ConnectorCapacityAutoscalingOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingOutput) MaxWorkerCount added in v5.2.0 

func (o ConnectorCapacityAutoscalingOutput) MaxWorkerCount() pulumi.IntOutput

The maximum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingOutput) McuCount added in v5.2.0 

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

func (o ConnectorCapacityAutoscalingOutput) MinWorkerCount() pulumi.IntOutput

The minimum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingOutput) ScaleInPolicy added in v5.2.0 

func (o ConnectorCapacityAutoscalingOutput) ScaleInPolicy() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

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

func (ConnectorCapacityAutoscalingOutput) ScaleOutPolicy added in v5.2.0 

func (o ConnectorCapacityAutoscalingOutput) ScaleOutPolicy() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

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

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingOutput() ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingPtrOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingPtrOutput() ConnectorCapacityAutoscalingPtrOutput

func (ConnectorCapacityAutoscalingOutput) ToConnectorCapacityAutoscalingPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingPtrInput added in v5.2.0 

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

func ConnectorCapacityAutoscalingPtr(v *ConnectorCapacityAutoscalingArgs) ConnectorCapacityAutoscalingPtrInput

type ConnectorCapacityAutoscalingPtrOutput added in v5.2.0 

type ConnectorCapacityAutoscalingPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingPtrOutput) Elem added in v5.2.0 

func (o ConnectorCapacityAutoscalingPtrOutput) Elem() ConnectorCapacityAutoscalingOutput

func (ConnectorCapacityAutoscalingPtrOutput) ElementType added in v5.2.0 

func (ConnectorCapacityAutoscalingPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingPtrOutput) MaxWorkerCount added in v5.2.0 

func (o ConnectorCapacityAutoscalingPtrOutput) MaxWorkerCount() pulumi.IntPtrOutput

The maximum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingPtrOutput) McuCount added in v5.2.0 

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

func (o ConnectorCapacityAutoscalingPtrOutput) MinWorkerCount() pulumi.IntPtrOutput

The minimum number of workers allocated to the connector.

func (ConnectorCapacityAutoscalingPtrOutput) ScaleInPolicy added in v5.2.0 

func (o ConnectorCapacityAutoscalingPtrOutput) ScaleInPolicy() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

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

func (ConnectorCapacityAutoscalingPtrOutput) ScaleOutPolicy added in v5.2.0 

func (o ConnectorCapacityAutoscalingPtrOutput) ScaleOutPolicy() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

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

func (ConnectorCapacityAutoscalingPtrOutput) ToConnectorCapacityAutoscalingPtrOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingPtrOutput) ToConnectorCapacityAutoscalingPtrOutput() ConnectorCapacityAutoscalingPtrOutput

func (ConnectorCapacityAutoscalingPtrOutput) ToConnectorCapacityAutoscalingPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleInPolicy added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleInPolicyArgs added in v5.2.0 

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

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ElementType added in v5.2.0 

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyOutput added in v5.2.0 

func (i ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyOutput() ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput added in v5.2.0 

func (i ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleInPolicyArgs) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleInPolicyInput added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleInPolicyOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) CpuUtilizationPercentage added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

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

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ElementType added in v5.2.0 

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyOutput() ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleInPolicyOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleInPolicyPtrInput added in v5.2.0 

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

func ConnectorCapacityAutoscalingScaleInPolicyPtr(v *ConnectorCapacityAutoscalingScaleInPolicyArgs) ConnectorCapacityAutoscalingScaleInPolicyPtrInput

type ConnectorCapacityAutoscalingScaleInPolicyPtrOutput added in v5.2.0 

type ConnectorCapacityAutoscalingScaleInPolicyPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) CpuUtilizationPercentage added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

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

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) Elem added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) Elem() ConnectorCapacityAutoscalingScaleInPolicyOutput

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ElementType added in v5.2.0 

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutput() ConnectorCapacityAutoscalingScaleInPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleInPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleInPolicyPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleOutPolicy added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleOutPolicyArgs added in v5.2.0 

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

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyOutput added in v5.2.0 

func (i ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyOutput() ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput added in v5.2.0 

func (i ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyArgs) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleOutPolicyInput added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleOutPolicyOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) CpuUtilizationPercentage added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

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

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ElementType added in v5.2.0 

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyOutput() ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityAutoscalingScaleOutPolicyPtrInput added in v5.2.0 

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

func ConnectorCapacityAutoscalingScaleOutPolicyPtr(v *ConnectorCapacityAutoscalingScaleOutPolicyArgs) ConnectorCapacityAutoscalingScaleOutPolicyPtrInput

type ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput added in v5.2.0 

type ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) CpuUtilizationPercentage added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

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

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) Elem added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) Elem() ConnectorCapacityAutoscalingScaleOutPolicyOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ElementType added in v5.2.0 

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput added in v5.2.0 

func (o ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutput() ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput

func (ConnectorCapacityAutoscalingScaleOutPolicyPtrOutput) ToConnectorCapacityAutoscalingScaleOutPolicyPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityInput added in v5.2.0 

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

type ConnectorCapacityOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityOutput) Autoscaling added in v5.2.0 

func (o ConnectorCapacityOutput) Autoscaling() ConnectorCapacityAutoscalingPtrOutput

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

func (ConnectorCapacityOutput) ElementType added in v5.2.0 

func (ConnectorCapacityOutput) ElementType() reflect.Type

func (ConnectorCapacityOutput) ProvisionedCapacity added in v5.2.0 

func (o ConnectorCapacityOutput) ProvisionedCapacity() ConnectorCapacityProvisionedCapacityPtrOutput

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

func (ConnectorCapacityOutput) ToConnectorCapacityOutput added in v5.2.0 

func (o ConnectorCapacityOutput) ToConnectorCapacityOutput() ConnectorCapacityOutput

func (ConnectorCapacityOutput) ToConnectorCapacityOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityOutput) ToConnectorCapacityPtrOutput added in v5.2.0 

func (o ConnectorCapacityOutput) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput

func (ConnectorCapacityOutput) ToConnectorCapacityPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityProvisionedCapacity added in v5.2.0 

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

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

func (ConnectorCapacityProvisionedCapacityArgs) ElementType() reflect.Type

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityOutput added in v5.2.0 

func (i ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityOutput() ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityPtrOutput added in v5.2.0 

func (i ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityPtrOutput() ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityArgs) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext added in v5.2.0 

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

type ConnectorCapacityProvisionedCapacityInput added in v5.2.0 

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

type ConnectorCapacityProvisionedCapacityOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityProvisionedCapacityOutput) ElementType added in v5.2.0 

func (ConnectorCapacityProvisionedCapacityOutput) ElementType() reflect.Type

func (ConnectorCapacityProvisionedCapacityOutput) McuCount added in v5.2.0 

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

func (o ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityOutput() ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityPtrOutput added in v5.2.0 

func (o ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityPtrOutput() ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityOutput) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityProvisionedCapacityOutput) WorkerCount added in v5.2.0 

func (o ConnectorCapacityProvisionedCapacityOutput) WorkerCount() pulumi.IntOutput

The number of workers that are allocated to the connector.

type ConnectorCapacityProvisionedCapacityPtrInput added in v5.2.0 

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

func ConnectorCapacityProvisionedCapacityPtr(v *ConnectorCapacityProvisionedCapacityArgs) ConnectorCapacityProvisionedCapacityPtrInput

type ConnectorCapacityProvisionedCapacityPtrOutput added in v5.2.0 

type ConnectorCapacityProvisionedCapacityPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityProvisionedCapacityPtrOutput) Elem added in v5.2.0 

func (o ConnectorCapacityProvisionedCapacityPtrOutput) Elem() ConnectorCapacityProvisionedCapacityOutput

func (ConnectorCapacityProvisionedCapacityPtrOutput) ElementType added in v5.2.0 

func (ConnectorCapacityProvisionedCapacityPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityProvisionedCapacityPtrOutput) McuCount added in v5.2.0 

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

func (o ConnectorCapacityProvisionedCapacityPtrOutput) ToConnectorCapacityProvisionedCapacityPtrOutput() ConnectorCapacityProvisionedCapacityPtrOutput

func (ConnectorCapacityProvisionedCapacityPtrOutput) ToConnectorCapacityProvisionedCapacityPtrOutputWithContext added in v5.2.0 

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

func (ConnectorCapacityProvisionedCapacityPtrOutput) WorkerCount added in v5.2.0 

func (o ConnectorCapacityProvisionedCapacityPtrOutput) WorkerCount() pulumi.IntPtrOutput

The number of workers that are allocated to the connector.

type ConnectorCapacityPtrInput added in v5.2.0 

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

func ConnectorCapacityPtr(v *ConnectorCapacityArgs) ConnectorCapacityPtrInput

type ConnectorCapacityPtrOutput added in v5.2.0 

type ConnectorCapacityPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityPtrOutput) Autoscaling added in v5.2.0 

func (o ConnectorCapacityPtrOutput) Autoscaling() ConnectorCapacityAutoscalingPtrOutput

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

func (ConnectorCapacityPtrOutput) Elem added in v5.2.0 

func (o ConnectorCapacityPtrOutput) Elem() ConnectorCapacityOutput

func (ConnectorCapacityPtrOutput) ElementType added in v5.2.0 

func (ConnectorCapacityPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityPtrOutput) ProvisionedCapacity added in v5.2.0 

func (o ConnectorCapacityPtrOutput) ProvisionedCapacity() ConnectorCapacityProvisionedCapacityPtrOutput

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

func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput added in v5.2.0 

func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput

func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutputWithContext added in v5.2.0 

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

type ConnectorInput added in v5.2.0 

type ConnectorInput interface {
	pulumi.Input

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

type ConnectorKafkaCluster added in v5.2.0 

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

type ConnectorKafkaClusterApacheKafkaCluster added in v5.2.0 

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

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

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterOutput added in v5.2.0 

func (i ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterOutput() ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput added in v5.2.0 

func (i ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterArgs) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterApacheKafkaClusterInput added in v5.2.0 

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

type ConnectorKafkaClusterApacheKafkaClusterOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterOutput) BootstrapServers added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) BootstrapServers() pulumi.StringOutput

The bootstrap servers of the cluster.

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterOutput added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterOutput() ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterApacheKafkaClusterOutput) Vpc added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterOutput) Vpc() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

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

type ConnectorKafkaClusterApacheKafkaClusterPtrInput added in v5.2.0 

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

func ConnectorKafkaClusterApacheKafkaClusterPtr(v *ConnectorKafkaClusterApacheKafkaClusterArgs) ConnectorKafkaClusterApacheKafkaClusterPtrInput

type ConnectorKafkaClusterApacheKafkaClusterPtrOutput added in v5.2.0 

type ConnectorKafkaClusterApacheKafkaClusterPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) BootstrapServers added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) BootstrapServers() pulumi.StringPtrOutput

The bootstrap servers of the cluster.

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Elem added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Elem() ConnectorKafkaClusterApacheKafkaClusterOutput

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutput() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterPtrOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Vpc added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterPtrOutput) Vpc() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

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

type ConnectorKafkaClusterApacheKafkaClusterVpc added in v5.2.0 

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

type ConnectorKafkaClusterApacheKafkaClusterVpcArgs added in v5.2.0 

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

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput added in v5.2.0 

func (i ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput added in v5.2.0 

func (i ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterApacheKafkaClusterVpcInput added in v5.2.0 

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

type ConnectorKafkaClusterApacheKafkaClusterVpcOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) SecurityGroups added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) SecurityGroups() pulumi.StringArrayOutput

The security groups for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) Subnets added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) Subnets() pulumi.StringArrayOutput

The subnets for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcOutput() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterApacheKafkaClusterVpcPtrInput added in v5.2.0 

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

func ConnectorKafkaClusterApacheKafkaClusterVpcPtr(v *ConnectorKafkaClusterApacheKafkaClusterVpcArgs) ConnectorKafkaClusterApacheKafkaClusterVpcPtrInput

type ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput added in v5.2.0 

type ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Elem added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Elem() ConnectorKafkaClusterApacheKafkaClusterVpcOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) SecurityGroups added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) SecurityGroups() pulumi.StringArrayOutput

The security groups for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Subnets added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) Subnets() pulumi.StringArrayOutput

The subnets for the connector.

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput() ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput

func (ConnectorKafkaClusterApacheKafkaClusterVpcPtrOutput) ToConnectorKafkaClusterApacheKafkaClusterVpcPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterArgs added in v5.2.0 

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

func (ConnectorKafkaClusterArgs) ElementType added in v5.2.0 

func (ConnectorKafkaClusterArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput added in v5.2.0 

func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterPtrOutput added in v5.2.0 

func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterPtrOutput() ConnectorKafkaClusterPtrOutput

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterClientAuthentication added in v5.2.0 

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

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

func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput added in v5.2.0 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationPtrOutput added in v5.2.0 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationPtrOutput() ConnectorKafkaClusterClientAuthenticationPtrOutput

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterClientAuthenticationInput added in v5.2.0 

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

type ConnectorKafkaClusterClientAuthenticationOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType added in v5.2.0 

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

func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput added in v5.2.0 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput() ConnectorKafkaClusterClientAuthenticationPtrOutput

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterClientAuthenticationPtrInput added in v5.2.0 

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

func ConnectorKafkaClusterClientAuthenticationPtr(v *ConnectorKafkaClusterClientAuthenticationArgs) ConnectorKafkaClusterClientAuthenticationPtrInput

type ConnectorKafkaClusterClientAuthenticationPtrOutput added in v5.2.0 

type ConnectorKafkaClusterClientAuthenticationPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) AuthenticationType added in v5.2.0 

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

func (o ConnectorKafkaClusterClientAuthenticationPtrOutput) Elem() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterClientAuthenticationPtrOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutput() ConnectorKafkaClusterClientAuthenticationPtrOutput

func (ConnectorKafkaClusterClientAuthenticationPtrOutput) ToConnectorKafkaClusterClientAuthenticationPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterEncryptionInTransit added in v5.2.0 

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

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

func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput added in v5.2.0 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitPtrOutput added in v5.2.0 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitPtrOutput() ConnectorKafkaClusterEncryptionInTransitPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterEncryptionInTransitInput added in v5.2.0 

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

type ConnectorKafkaClusterEncryptionInTransitOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType added in v5.2.0 

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

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutput() ConnectorKafkaClusterEncryptionInTransitPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterEncryptionInTransitPtrInput added in v5.2.0 

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

func ConnectorKafkaClusterEncryptionInTransitPtr(v *ConnectorKafkaClusterEncryptionInTransitArgs) ConnectorKafkaClusterEncryptionInTransitPtrInput

type ConnectorKafkaClusterEncryptionInTransitPtrOutput added in v5.2.0 

type ConnectorKafkaClusterEncryptionInTransitPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) Elem added in v5.2.0 

func (o ConnectorKafkaClusterEncryptionInTransitPtrOutput) Elem() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) EncryptionType added in v5.2.0 

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

func (o ConnectorKafkaClusterEncryptionInTransitPtrOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutput() ConnectorKafkaClusterEncryptionInTransitPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitPtrOutput) ToConnectorKafkaClusterEncryptionInTransitPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterInput added in v5.2.0 

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

type ConnectorKafkaClusterOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterOutput) ApacheKafkaCluster added in v5.2.0 

func (o ConnectorKafkaClusterOutput) ApacheKafkaCluster() ConnectorKafkaClusterApacheKafkaClusterOutput

The Apache Kafka cluster to which the connector is connected.

func (ConnectorKafkaClusterOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput added in v5.2.0 

func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutputWithContext added in v5.2.0 

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

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterPtrOutput() ConnectorKafkaClusterPtrOutput

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterPtrOutputWithContext added in v5.2.0 

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

type ConnectorKafkaClusterPtrInput added in v5.2.0 

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

func ConnectorKafkaClusterPtr(v *ConnectorKafkaClusterArgs) ConnectorKafkaClusterPtrInput

type ConnectorKafkaClusterPtrOutput added in v5.2.0 

type ConnectorKafkaClusterPtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterPtrOutput) ApacheKafkaCluster added in v5.2.0 

func (o ConnectorKafkaClusterPtrOutput) ApacheKafkaCluster() ConnectorKafkaClusterApacheKafkaClusterPtrOutput

The Apache Kafka cluster to which the connector is connected.

func (ConnectorKafkaClusterPtrOutput) Elem added in v5.2.0 

func (o ConnectorKafkaClusterPtrOutput) Elem() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterPtrOutput) ElementType added in v5.2.0 

func (ConnectorKafkaClusterPtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterPtrOutput) ToConnectorKafkaClusterPtrOutput added in v5.2.0 

func (o ConnectorKafkaClusterPtrOutput) ToConnectorKafkaClusterPtrOutput() ConnectorKafkaClusterPtrOutput

func (ConnectorKafkaClusterPtrOutput) ToConnectorKafkaClusterPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDelivery added in v5.2.0 

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

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

func (ConnectorLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput added in v5.2.0 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput added in v5.2.0 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryInput added in v5.2.0 

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

type ConnectorLogDeliveryOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput added in v5.2.0 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryOutput) WorkerLogDelivery added in v5.2.0 

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

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

func ConnectorLogDeliveryPtr(v *ConnectorLogDeliveryArgs) ConnectorLogDeliveryPtrInput

type ConnectorLogDeliveryPtrOutput added in v5.2.0 

type ConnectorLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryPtrOutput) Elem added in v5.2.0 

func (o ConnectorLogDeliveryPtrOutput) Elem() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryPtrOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryPtrOutput) WorkerLogDelivery added in v5.2.0 

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

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

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

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryOutput added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryOutput() ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryArgs) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs added in v5.2.0 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogs struct {
	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	Enabled bool `pulumi:"enabled"`
	// The name of the CloudWatch log group that is the destination for log delivery.
	LogGroup *string `pulumi:"logGroup"`
}

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs added in v5.2.0 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs struct {
	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	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 added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsInput added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) Enabled added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) Enabled() pulumi.BoolOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) LogGroup added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) LogGroup() pulumi.StringPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput added in v5.2.0 

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

func ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtr(v *ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsArgs) ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrInput

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput added in v5.2.0 

type ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Elem added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Enabled added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) Enabled() pulumi.BoolPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) LogGroup added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) LogGroup() pulumi.StringPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryFirehose added in v5.2.0 

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 sent to the specified Amazon S3 destination.
	Enabled bool `pulumi:"enabled"`
}

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs added in v5.2.0 

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 sent to the specified Amazon S3 destination.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseInput added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) DeliveryStream added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) Enabled added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) Enabled() pulumi.BoolOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehoseOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput added in v5.2.0 

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

func ConnectorLogDeliveryWorkerLogDeliveryFirehosePtr(v *ConnectorLogDeliveryWorkerLogDeliveryFirehoseArgs) ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrInput

type ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput added in v5.2.0 

type ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) DeliveryStream added in v5.2.0 

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

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryFirehoseOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) Enabled added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) Enabled() pulumi.BoolPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryInput added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) CloudwatchLogs added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) CloudwatchLogs() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) Firehose added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) Firehose() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) S3 added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) S3() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

Details about delivering logs to Amazon S3. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryOutput() ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryOutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryPtrInput added in v5.2.0 

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

func ConnectorLogDeliveryWorkerLogDeliveryPtr(v *ConnectorLogDeliveryWorkerLogDeliveryArgs) ConnectorLogDeliveryWorkerLogDeliveryPtrInput

type ConnectorLogDeliveryWorkerLogDeliveryPtrOutput added in v5.2.0 

type ConnectorLogDeliveryWorkerLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) CloudwatchLogs added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) CloudwatchLogs() ConnectorLogDeliveryWorkerLogDeliveryCloudwatchLogsPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Elem added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryOutput

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Firehose added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) Firehose() ConnectorLogDeliveryWorkerLogDeliveryFirehosePtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) S3 added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) S3() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

Details about delivering logs to Amazon S3. See below.

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutput() ConnectorLogDeliveryWorkerLogDeliveryPtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryPtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryPtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryS3 added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryS3Args added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3Output added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3Output() ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3OutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput added in v5.2.0 

func (i ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryS3Args) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryS3Input added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryS3Output struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) Bucket added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) Bucket() pulumi.StringPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) Enabled added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) Enabled() pulumi.BoolOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) Prefix added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3Output added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3Output() ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3OutputWithContext added in v5.2.0 

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

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryS3Output) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext added in v5.2.0 

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

type ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput added in v5.2.0 

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

func ConnectorLogDeliveryWorkerLogDeliveryS3Ptr(v *ConnectorLogDeliveryWorkerLogDeliveryS3Args) ConnectorLogDeliveryWorkerLogDeliveryS3PtrInput

type ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput added in v5.2.0 

type ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Bucket added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Bucket() pulumi.StringPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Elem added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Elem() ConnectorLogDeliveryWorkerLogDeliveryS3Output

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ElementType added in v5.2.0 

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Enabled added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Enabled() pulumi.BoolPtrOutput

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

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Prefix added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for log delivery.

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput added in v5.2.0 

func (o ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput() ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput

func (ConnectorLogDeliveryWorkerLogDeliveryS3PtrOutput) ToConnectorLogDeliveryWorkerLogDeliveryS3PtrOutputWithContext added in v5.2.0 

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

type ConnectorMap added in v5.2.0 

type ConnectorMap map[string]ConnectorInput

func (ConnectorMap) ElementType added in v5.2.0 

func (ConnectorMap) ElementType() reflect.Type

func (ConnectorMap) ToConnectorMapOutput added in v5.2.0 

func (i ConnectorMap) ToConnectorMapOutput() ConnectorMapOutput

func (ConnectorMap) ToConnectorMapOutputWithContext added in v5.2.0 

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

type ConnectorMapInput added in v5.2.0 

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

type ConnectorMapOutput struct{ *pulumi.OutputState }

func (ConnectorMapOutput) ElementType added in v5.2.0 

func (ConnectorMapOutput) ElementType() reflect.Type

func (ConnectorMapOutput) MapIndex added in v5.2.0 

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

func (ConnectorMapOutput) ToConnectorMapOutput added in v5.2.0 

func (o ConnectorMapOutput) ToConnectorMapOutput() ConnectorMapOutput

func (ConnectorMapOutput) ToConnectorMapOutputWithContext added in v5.2.0 

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

type ConnectorOutput added in v5.2.0 

type ConnectorOutput struct{ *pulumi.OutputState }

func (ConnectorOutput) Arn added in v5.4.0 

func (o ConnectorOutput) Arn() pulumi.StringOutput

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

func (ConnectorOutput) Capacity added in v5.4.0 

func (o ConnectorOutput) Capacity() ConnectorCapacityOutput

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

func (ConnectorOutput) ConnectorConfiguration added in v5.4.0 

func (o ConnectorOutput) ConnectorConfiguration() pulumi.StringMapOutput

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

func (ConnectorOutput) Description added in v5.4.0 

func (o ConnectorOutput) Description() pulumi.StringPtrOutput

A summary description of the connector.

func (ConnectorOutput) ElementType added in v5.2.0 

func (ConnectorOutput) ElementType() reflect.Type

func (ConnectorOutput) KafkaCluster added in v5.4.0 

func (o ConnectorOutput) KafkaCluster() ConnectorKafkaClusterOutput

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

func (ConnectorOutput) KafkaClusterClientAuthentication added in v5.4.0 

func (o ConnectorOutput) KafkaClusterClientAuthentication() ConnectorKafkaClusterClientAuthenticationOutput

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

func (ConnectorOutput) KafkaClusterEncryptionInTransit added in v5.4.0 

func (o ConnectorOutput) KafkaClusterEncryptionInTransit() ConnectorKafkaClusterEncryptionInTransitOutput

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

func (ConnectorOutput) KafkaconnectVersion added in v5.4.0 

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

func (o ConnectorOutput) LogDelivery() ConnectorLogDeliveryPtrOutput

Details about log delivery. See below.

func (ConnectorOutput) Name added in v5.4.0 

func (o ConnectorOutput) Name() pulumi.StringOutput

The name of the connector.

func (ConnectorOutput) Plugins added in v5.4.0 

func (o ConnectorOutput) Plugins() ConnectorPluginArrayOutput

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

func (ConnectorOutput) ServiceExecutionRoleArn added in v5.4.0 

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

func (o ConnectorOutput) ToConnectorOutput() ConnectorOutput

func (ConnectorOutput) ToConnectorOutputWithContext added in v5.2.0 

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

func (ConnectorOutput) Version added in v5.4.0 

func (o ConnectorOutput) Version() pulumi.StringOutput

The current version of the connector.

func (ConnectorOutput) WorkerConfiguration added in v5.4.0 

func (o ConnectorOutput) WorkerConfiguration() ConnectorWorkerConfigurationPtrOutput

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

type ConnectorPlugin added in v5.2.0 

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

type ConnectorPluginArgs added in v5.2.0 

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

func (ConnectorPluginArgs) ElementType added in v5.2.0 

func (ConnectorPluginArgs) ElementType() reflect.Type

func (ConnectorPluginArgs) ToConnectorPluginOutput added in v5.2.0 

func (i ConnectorPluginArgs) ToConnectorPluginOutput() ConnectorPluginOutput

func (ConnectorPluginArgs) ToConnectorPluginOutputWithContext added in v5.2.0 

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

type ConnectorPluginArray added in v5.2.0 

type ConnectorPluginArray []ConnectorPluginInput

func (ConnectorPluginArray) ElementType added in v5.2.0 

func (ConnectorPluginArray) ElementType() reflect.Type

func (ConnectorPluginArray) ToConnectorPluginArrayOutput added in v5.2.0 

func (i ConnectorPluginArray) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput

func (ConnectorPluginArray) ToConnectorPluginArrayOutputWithContext added in v5.2.0 

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

type ConnectorPluginArrayInput added in v5.2.0 

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

type ConnectorPluginArrayOutput struct{ *pulumi.OutputState }

func (ConnectorPluginArrayOutput) ElementType added in v5.2.0 

func (ConnectorPluginArrayOutput) ElementType() reflect.Type

func (ConnectorPluginArrayOutput) Index added in v5.2.0 

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

func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput added in v5.2.0 

func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput

func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutputWithContext added in v5.2.0 

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

type ConnectorPluginCustomPlugin added in v5.2.0 

type ConnectorPluginCustomPlugin 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 ConnectorPluginCustomPluginArgs added in v5.2.0 

type ConnectorPluginCustomPluginArgs 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 (ConnectorPluginCustomPluginArgs) ElementType added in v5.2.0 

func (ConnectorPluginCustomPluginArgs) ElementType() reflect.Type

func (ConnectorPluginCustomPluginArgs) ToConnectorPluginCustomPluginOutput added in v5.2.0 

func (i ConnectorPluginCustomPluginArgs) ToConnectorPluginCustomPluginOutput() ConnectorPluginCustomPluginOutput

func (ConnectorPluginCustomPluginArgs) ToConnectorPluginCustomPluginOutputWithContext added in v5.2.0 

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

type ConnectorPluginCustomPluginInput added in v5.2.0 

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

type ConnectorPluginCustomPluginOutput struct{ *pulumi.OutputState }

func (ConnectorPluginCustomPluginOutput) Arn added in v5.2.0 

func (o ConnectorPluginCustomPluginOutput) Arn() pulumi.StringOutput

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

func (ConnectorPluginCustomPluginOutput) ElementType added in v5.2.0 

func (ConnectorPluginCustomPluginOutput) ElementType() reflect.Type

func (ConnectorPluginCustomPluginOutput) Revision added in v5.2.0 

func (o ConnectorPluginCustomPluginOutput) Revision() pulumi.IntOutput

The revision of the worker configuration.

func (ConnectorPluginCustomPluginOutput) ToConnectorPluginCustomPluginOutput added in v5.2.0 

func (o ConnectorPluginCustomPluginOutput) ToConnectorPluginCustomPluginOutput() ConnectorPluginCustomPluginOutput

func (ConnectorPluginCustomPluginOutput) ToConnectorPluginCustomPluginOutputWithContext added in v5.2.0 

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

type ConnectorPluginInput added in v5.2.0 

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

type ConnectorPluginOutput struct{ *pulumi.OutputState }

func (ConnectorPluginOutput) CustomPlugin added in v5.2.0 

func (o ConnectorPluginOutput) CustomPlugin() ConnectorPluginCustomPluginOutput

Details about a custom plugin. See below.

func (ConnectorPluginOutput) ElementType added in v5.2.0 

func (ConnectorPluginOutput) ElementType() reflect.Type

func (ConnectorPluginOutput) ToConnectorPluginOutput added in v5.2.0 

func (o ConnectorPluginOutput) ToConnectorPluginOutput() ConnectorPluginOutput

func (ConnectorPluginOutput) ToConnectorPluginOutputWithContext added in v5.2.0 

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

type ConnectorState added in v5.2.0 

type ConnectorState struct {
	// The Amazon Resource Name (ARN) of the worker configuration.
	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 added in v5.2.0 

func (ConnectorState) ElementType() reflect.Type

type ConnectorWorkerConfiguration added in v5.2.0 

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

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

func (ConnectorWorkerConfigurationArgs) ElementType() reflect.Type

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput added in v5.2.0 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutputWithContext added in v5.2.0 

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

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput added in v5.2.0 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutputWithContext added in v5.2.0 

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

type ConnectorWorkerConfigurationInput added in v5.2.0 

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

type ConnectorWorkerConfigurationOutput struct{ *pulumi.OutputState }

func (ConnectorWorkerConfigurationOutput) Arn added in v5.2.0 

func (o ConnectorWorkerConfigurationOutput) Arn() pulumi.StringOutput

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

func (ConnectorWorkerConfigurationOutput) ElementType added in v5.2.0 

func (ConnectorWorkerConfigurationOutput) ElementType() reflect.Type

func (ConnectorWorkerConfigurationOutput) Revision added in v5.2.0 

func (o ConnectorWorkerConfigurationOutput) Revision() pulumi.IntOutput

The revision of the worker configuration.

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput added in v5.2.0 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutputWithContext added in v5.2.0 

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

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput added in v5.2.0 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutputWithContext added in v5.2.0 

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

type ConnectorWorkerConfigurationPtrInput added in v5.2.0 

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

func ConnectorWorkerConfigurationPtr(v *ConnectorWorkerConfigurationArgs) ConnectorWorkerConfigurationPtrInput

type ConnectorWorkerConfigurationPtrOutput added in v5.2.0 

type ConnectorWorkerConfigurationPtrOutput struct{ *pulumi.OutputState }

func (ConnectorWorkerConfigurationPtrOutput) Arn added in v5.2.0 

func (o ConnectorWorkerConfigurationPtrOutput) Arn() pulumi.StringPtrOutput

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

func (ConnectorWorkerConfigurationPtrOutput) Elem added in v5.2.0 

func (o ConnectorWorkerConfigurationPtrOutput) Elem() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationPtrOutput) ElementType added in v5.2.0 

func (ConnectorWorkerConfigurationPtrOutput) ElementType() reflect.Type

func (ConnectorWorkerConfigurationPtrOutput) Revision added in v5.2.0 

func (o ConnectorWorkerConfigurationPtrOutput) Revision() pulumi.IntPtrOutput

The revision of the worker configuration.

func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput added in v5.2.0 

func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutputWithContext added in v5.2.0 

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.
	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/v5/go/aws/mskconnect"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/s3"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		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

MSK Connect Custom Plugin can be imported using the plugin's `arn`, e.g.,

```sh 

$ pulumi import aws:mskconnect/customPlugin:CustomPlugin 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.
	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 added in v5.4.0 

func (o CustomPluginOutput) Arn() pulumi.StringOutput

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

func (CustomPluginOutput) ContentType added in v5.4.0 

func (o CustomPluginOutput) ContentType() pulumi.StringOutput

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

func (CustomPluginOutput) Description added in v5.4.0 

func (o CustomPluginOutput) Description() pulumi.StringPtrOutput

A summary description of the custom plugin.

func (CustomPluginOutput) ElementType 

func (CustomPluginOutput) ElementType() reflect.Type

func (CustomPluginOutput) LatestRevision added in v5.4.0 

func (o CustomPluginOutput) LatestRevision() pulumi.IntOutput

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

func (CustomPluginOutput) Location added in v5.4.0 

func (o CustomPluginOutput) Location() CustomPluginLocationOutput

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

func (CustomPluginOutput) Name added in v5.4.0 

func (o CustomPluginOutput) Name() pulumi.StringOutput

The name of the custom plugin..

func (CustomPluginOutput) State added in v5.4.0 

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

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

A collection of arguments for invoking getConnector.

type LookupConnectorOutputArgs added in v5.2.0 

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

A collection of arguments for invoking getConnector.

func (LookupConnectorOutputArgs) ElementType added in v5.2.0 

func (LookupConnectorOutputArgs) ElementType() reflect.Type

type LookupConnectorResult added in v5.2.0 

type LookupConnectorResult struct {
	// The Amazon Resource Name (ARN) of the connector.
	Arn string `pulumi:"arn"`
	// A 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"`
	// The current version of the connector.
	Version string `pulumi:"version"`
}

A collection of values returned by getConnector.

func LookupConnector added in v5.2.0 

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

type LookupConnectorResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getConnector.

func LookupConnectorOutput added in v5.2.0 

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

func (LookupConnectorResultOutput) Arn added in v5.2.0 

func (o LookupConnectorResultOutput) Arn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the connector.

func (LookupConnectorResultOutput) Description added in v5.2.0 

func (o LookupConnectorResultOutput) Description() pulumi.StringOutput

A summary description of the connector.

func (LookupConnectorResultOutput) ElementType added in v5.2.0 

func (LookupConnectorResultOutput) ElementType() reflect.Type

func (LookupConnectorResultOutput) Id added in v5.2.0 

func (o LookupConnectorResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (LookupConnectorResultOutput) Name added in v5.2.0 

func (o LookupConnectorResultOutput) Name() pulumi.StringOutput

func (LookupConnectorResultOutput) ToLookupConnectorResultOutput added in v5.2.0 

func (o LookupConnectorResultOutput) ToLookupConnectorResultOutput() LookupConnectorResultOutput

func (LookupConnectorResultOutput) ToLookupConnectorResultOutputWithContext added in v5.2.0 

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

func (LookupConnectorResultOutput) Version added in v5.2.0 

func (o LookupConnectorResultOutput) Version() pulumi.StringOutput

The 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 Amazon Resource Name (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/v5/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 Amazon Resource Name (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 Amazon Resource Name (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/v5/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 Amazon Resource Name (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.
	PropertiesFileContent pulumi.StringOutput `pulumi:"propertiesFileContent"`
}

Provides an Amazon MSK Connect Worker Configuration Resource.

## Example Usage ### Basic configuration

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-aws/sdk/v5/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(fmt.Sprintf("%v%v%v", "key.converter=org.apache.kafka.connect.storage.StringConverter\n", "value.converter=org.apache.kafka.connect.storage.StringConverter\n", "\n")),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

MSK Connect Worker Configuration can be imported using the plugin's `arn`, e.g.,

```sh 

$ pulumi import aws:mskconnect/workerConfiguration:WorkerConfiguration 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.
	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 added in v5.4.0 

func (o WorkerConfigurationOutput) Arn() pulumi.StringOutput

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

func (WorkerConfigurationOutput) Description added in v5.4.0 

func (o WorkerConfigurationOutput) Description() pulumi.StringPtrOutput

A summary description of the worker configuration.

func (WorkerConfigurationOutput) ElementType 

func (WorkerConfigurationOutput) ElementType() reflect.Type

func (WorkerConfigurationOutput) LatestRevision added in v5.4.0 

func (o WorkerConfigurationOutput) LatestRevision() pulumi.IntOutput

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

func (WorkerConfigurationOutput) Name added in v5.4.0 

func (o WorkerConfigurationOutput) Name() pulumi.StringOutput

The name of the worker configuration.

func (WorkerConfigurationOutput) PropertiesFileContent added in v5.4.0 

func (o WorkerConfigurationOutput) PropertiesFileContent() pulumi.StringOutput

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

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