kafkaconnect

package
v0.104.0 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ConnectorKafkaClusterClientAuthenticationTypeNone = ConnectorKafkaClusterClientAuthenticationType("NONE")
	ConnectorKafkaClusterClientAuthenticationTypeIam  = ConnectorKafkaClusterClientAuthenticationType("IAM")
)
View Source 
const (
	ConnectorKafkaClusterEncryptionInTransitTypePlaintext = ConnectorKafkaClusterEncryptionInTransitType("PLAINTEXT")
	ConnectorKafkaClusterEncryptionInTransitTypeTls       = ConnectorKafkaClusterEncryptionInTransitType("TLS")
)
View Source 
const (
	CustomPluginContentTypeJar = CustomPluginContentType("JAR")
	CustomPluginContentTypeZip = CustomPluginContentType("ZIP")
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Connector 

type Connector struct {
	pulumi.CustomResourceState

	Capacity ConnectorCapacityOutput `pulumi:"capacity"`
	// Amazon Resource Name for the created Connector.
	ConnectorArn pulumi.StringOutput `pulumi:"connectorArn"`
	// The configuration for the connector.
	ConnectorConfiguration pulumi.StringMapOutput `pulumi:"connectorConfiguration"`
	// A summary description of the connector.
	ConnectorDescription pulumi.StringPtrOutput `pulumi:"connectorDescription"`
	// The name of the connector.
	ConnectorName                    pulumi.StringOutput                             `pulumi:"connectorName"`
	KafkaCluster                     ConnectorKafkaClusterOutput                     `pulumi:"kafkaCluster"`
	KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationOutput `pulumi:"kafkaClusterClientAuthentication"`
	KafkaClusterEncryptionInTransit  ConnectorKafkaClusterEncryptionInTransitOutput  `pulumi:"kafkaClusterEncryptionInTransit"`
	// The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
	KafkaConnectVersion pulumi.StringOutput           `pulumi:"kafkaConnectVersion"`
	LogDelivery         ConnectorLogDeliveryPtrOutput `pulumi:"logDelivery"`
	// List of plugins to use with the connector.
	Plugins ConnectorPluginArrayOutput `pulumi:"plugins"`
	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
	ServiceExecutionRoleArn pulumi.StringOutput `pulumi:"serviceExecutionRoleArn"`
	// A collection of tags associated with a resource
	Tags                aws.TagArrayOutput                    `pulumi:"tags"`
	WorkerConfiguration ConnectorWorkerConfigurationPtrOutput `pulumi:"workerConfiguration"`
}

Resource Type definition for AWS::KafkaConnect::Connector

func GetConnector 

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

GetConnector gets an existing Connector resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewConnector 

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

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

func (*Connector) ElementType 

func (*Connector) ElementType() reflect.Type

func (*Connector) ToConnectorOutput 

func (i *Connector) ToConnectorOutput() ConnectorOutput

func (*Connector) ToConnectorOutputWithContext 

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

type ConnectorApacheKafkaCluster 

type ConnectorApacheKafkaCluster struct {
	// The bootstrap servers string of the Apache Kafka cluster.
	BootstrapServers string       `pulumi:"bootstrapServers"`
	Vpc              ConnectorVpc `pulumi:"vpc"`
}

Details of how to connect to an Apache Kafka cluster.

type ConnectorApacheKafkaClusterArgs 

type ConnectorApacheKafkaClusterArgs struct {
	// The bootstrap servers string of the Apache Kafka cluster.
	BootstrapServers pulumi.StringInput `pulumi:"bootstrapServers"`
	Vpc              ConnectorVpcInput  `pulumi:"vpc"`
}

Details of how to connect to an Apache Kafka cluster.

func (ConnectorApacheKafkaClusterArgs) ElementType 

func (ConnectorApacheKafkaClusterArgs) ElementType() reflect.Type

func (ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutput 

func (i ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput

func (ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutputWithContext 

func (i ConnectorApacheKafkaClusterArgs) ToConnectorApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorApacheKafkaClusterOutput

type ConnectorApacheKafkaClusterInput 

type ConnectorApacheKafkaClusterInput interface {
	pulumi.Input

	ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput
	ToConnectorApacheKafkaClusterOutputWithContext(context.Context) ConnectorApacheKafkaClusterOutput
}

ConnectorApacheKafkaClusterInput is an input type that accepts ConnectorApacheKafkaClusterArgs and ConnectorApacheKafkaClusterOutput values. You can construct a concrete instance of `ConnectorApacheKafkaClusterInput` via: 

ConnectorApacheKafkaClusterArgs{...}

type ConnectorApacheKafkaClusterOutput 

type ConnectorApacheKafkaClusterOutput struct{ *pulumi.OutputState }

Details of how to connect to an Apache Kafka cluster.

func (ConnectorApacheKafkaClusterOutput) BootstrapServers 

func (o ConnectorApacheKafkaClusterOutput) BootstrapServers() pulumi.StringOutput

The bootstrap servers string of the Apache Kafka cluster.

func (ConnectorApacheKafkaClusterOutput) ElementType 

func (ConnectorApacheKafkaClusterOutput) ElementType() reflect.Type

func (ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutput 

func (o ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutput() ConnectorApacheKafkaClusterOutput

func (ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutputWithContext 

func (o ConnectorApacheKafkaClusterOutput) ToConnectorApacheKafkaClusterOutputWithContext(ctx context.Context) ConnectorApacheKafkaClusterOutput

func (ConnectorApacheKafkaClusterOutput) Vpc 

func (o ConnectorApacheKafkaClusterOutput) Vpc() ConnectorVpcOutput

type ConnectorArgs 

type ConnectorArgs struct {
	Capacity ConnectorCapacityInput
	// The configuration for the connector.
	ConnectorConfiguration pulumi.StringMapInput
	// A summary description of the connector.
	ConnectorDescription pulumi.StringPtrInput
	// The name of the connector.
	ConnectorName                    pulumi.StringPtrInput
	KafkaCluster                     ConnectorKafkaClusterInput
	KafkaClusterClientAuthentication ConnectorKafkaClusterClientAuthenticationInput
	KafkaClusterEncryptionInTransit  ConnectorKafkaClusterEncryptionInTransitInput
	// The version of Kafka Connect. It has to be compatible with both the Kafka cluster's version and the plugins.
	KafkaConnectVersion pulumi.StringInput
	LogDelivery         ConnectorLogDeliveryPtrInput
	// List of plugins to use with the connector.
	Plugins ConnectorPluginArrayInput
	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.
	ServiceExecutionRoleArn pulumi.StringInput
	// A collection of tags associated with a resource
	Tags                aws.TagArrayInput
	WorkerConfiguration ConnectorWorkerConfigurationPtrInput
}

The set of arguments for constructing a Connector resource.

func (ConnectorArgs) ElementType 

func (ConnectorArgs) ElementType() reflect.Type

type ConnectorAutoScaling 

type ConnectorAutoScaling struct {
	// The maximum number of workers for a connector.
	MaxWorkerCount int `pulumi:"maxWorkerCount"`
	// Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
	McuCount int `pulumi:"mcuCount"`
	// The minimum number of workers for a connector.
	MinWorkerCount int                     `pulumi:"minWorkerCount"`
	ScaleInPolicy  ConnectorScaleInPolicy  `pulumi:"scaleInPolicy"`
	ScaleOutPolicy ConnectorScaleOutPolicy `pulumi:"scaleOutPolicy"`
}

Details about auto scaling of a connector.

type ConnectorAutoScalingArgs 

type ConnectorAutoScalingArgs struct {
	// The maximum number of workers for a connector.
	MaxWorkerCount pulumi.IntInput `pulumi:"maxWorkerCount"`
	// Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.
	McuCount pulumi.IntInput `pulumi:"mcuCount"`
	// The minimum number of workers for a connector.
	MinWorkerCount pulumi.IntInput              `pulumi:"minWorkerCount"`
	ScaleInPolicy  ConnectorScaleInPolicyInput  `pulumi:"scaleInPolicy"`
	ScaleOutPolicy ConnectorScaleOutPolicyInput `pulumi:"scaleOutPolicy"`
}

Details about auto scaling of a connector.

func (ConnectorAutoScalingArgs) ElementType 

func (ConnectorAutoScalingArgs) ElementType() reflect.Type

func (ConnectorAutoScalingArgs) ToConnectorAutoScalingOutput 

func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput

func (ConnectorAutoScalingArgs) ToConnectorAutoScalingOutputWithContext 

func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingOutputWithContext(ctx context.Context) ConnectorAutoScalingOutput

func (ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutput 

func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput

func (ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutputWithContext 

func (i ConnectorAutoScalingArgs) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput

type ConnectorAutoScalingInput 

type ConnectorAutoScalingInput interface {
	pulumi.Input

	ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput
	ToConnectorAutoScalingOutputWithContext(context.Context) ConnectorAutoScalingOutput
}

ConnectorAutoScalingInput is an input type that accepts ConnectorAutoScalingArgs and ConnectorAutoScalingOutput values. You can construct a concrete instance of `ConnectorAutoScalingInput` via: 

ConnectorAutoScalingArgs{...}

type ConnectorAutoScalingOutput 

type ConnectorAutoScalingOutput struct{ *pulumi.OutputState }

Details about auto scaling of a connector.

func (ConnectorAutoScalingOutput) ElementType 

func (ConnectorAutoScalingOutput) ElementType() reflect.Type

func (ConnectorAutoScalingOutput) MaxWorkerCount 

func (o ConnectorAutoScalingOutput) MaxWorkerCount() pulumi.IntOutput

The maximum number of workers for a connector.

func (ConnectorAutoScalingOutput) McuCount 

func (o ConnectorAutoScalingOutput) McuCount() pulumi.IntOutput

Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.

func (ConnectorAutoScalingOutput) MinWorkerCount 

func (o ConnectorAutoScalingOutput) MinWorkerCount() pulumi.IntOutput

The minimum number of workers for a connector.

func (ConnectorAutoScalingOutput) ScaleInPolicy 

func (o ConnectorAutoScalingOutput) ScaleInPolicy() ConnectorScaleInPolicyOutput

func (ConnectorAutoScalingOutput) ScaleOutPolicy 

func (o ConnectorAutoScalingOutput) ScaleOutPolicy() ConnectorScaleOutPolicyOutput

func (ConnectorAutoScalingOutput) ToConnectorAutoScalingOutput 

func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingOutput() ConnectorAutoScalingOutput

func (ConnectorAutoScalingOutput) ToConnectorAutoScalingOutputWithContext 

func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingOutputWithContext(ctx context.Context) ConnectorAutoScalingOutput

func (ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutput 

func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput

func (ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutputWithContext 

func (o ConnectorAutoScalingOutput) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput

type ConnectorAutoScalingPtrInput 

type ConnectorAutoScalingPtrInput interface {
	pulumi.Input

	ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput
	ToConnectorAutoScalingPtrOutputWithContext(context.Context) ConnectorAutoScalingPtrOutput
}

ConnectorAutoScalingPtrInput is an input type that accepts ConnectorAutoScalingArgs, ConnectorAutoScalingPtr and ConnectorAutoScalingPtrOutput values. You can construct a concrete instance of `ConnectorAutoScalingPtrInput` via: 

        ConnectorAutoScalingArgs{...}

or:

        nil

func ConnectorAutoScalingPtr 

func ConnectorAutoScalingPtr(v *ConnectorAutoScalingArgs) ConnectorAutoScalingPtrInput

type ConnectorAutoScalingPtrOutput 

type ConnectorAutoScalingPtrOutput struct{ *pulumi.OutputState }

func (ConnectorAutoScalingPtrOutput) Elem 

func (o ConnectorAutoScalingPtrOutput) Elem() ConnectorAutoScalingOutput

func (ConnectorAutoScalingPtrOutput) ElementType 

func (ConnectorAutoScalingPtrOutput) ElementType() reflect.Type

func (ConnectorAutoScalingPtrOutput) MaxWorkerCount 

func (o ConnectorAutoScalingPtrOutput) MaxWorkerCount() pulumi.IntPtrOutput

The maximum number of workers for a connector.

func (ConnectorAutoScalingPtrOutput) McuCount 

func (o ConnectorAutoScalingPtrOutput) McuCount() pulumi.IntPtrOutput

Specifies how many MSK Connect Units (MCU) as the minimum scaling unit.

func (ConnectorAutoScalingPtrOutput) MinWorkerCount 

func (o ConnectorAutoScalingPtrOutput) MinWorkerCount() pulumi.IntPtrOutput

The minimum number of workers for a connector.

func (ConnectorAutoScalingPtrOutput) ScaleInPolicy 

func (o ConnectorAutoScalingPtrOutput) ScaleInPolicy() ConnectorScaleInPolicyPtrOutput

func (ConnectorAutoScalingPtrOutput) ScaleOutPolicy 

func (o ConnectorAutoScalingPtrOutput) ScaleOutPolicy() ConnectorScaleOutPolicyPtrOutput

func (ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutput 

func (o ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutput() ConnectorAutoScalingPtrOutput

func (ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutputWithContext 

func (o ConnectorAutoScalingPtrOutput) ToConnectorAutoScalingPtrOutputWithContext(ctx context.Context) ConnectorAutoScalingPtrOutput

type ConnectorCapacity 

type ConnectorCapacity struct {
	AutoScaling         *ConnectorAutoScaling         `pulumi:"autoScaling"`
	ProvisionedCapacity *ConnectorProvisionedCapacity `pulumi:"provisionedCapacity"`
}

Information about the capacity allocated to the connector.

type ConnectorCapacityArgs 

type ConnectorCapacityArgs struct {
	AutoScaling         ConnectorAutoScalingPtrInput         `pulumi:"autoScaling"`
	ProvisionedCapacity ConnectorProvisionedCapacityPtrInput `pulumi:"provisionedCapacity"`
}

Information about the capacity allocated to the connector.

func (ConnectorCapacityArgs) ElementType 

func (ConnectorCapacityArgs) ElementType() reflect.Type

func (ConnectorCapacityArgs) ToConnectorCapacityOutput 

func (i ConnectorCapacityArgs) ToConnectorCapacityOutput() ConnectorCapacityOutput

func (ConnectorCapacityArgs) ToConnectorCapacityOutputWithContext 

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

type ConnectorCapacityInput 

type ConnectorCapacityInput interface {
	pulumi.Input

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

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

ConnectorCapacityArgs{...}

type ConnectorCapacityOutput 

type ConnectorCapacityOutput struct{ *pulumi.OutputState }

Information about the capacity allocated to the connector.

func (ConnectorCapacityOutput) AutoScaling 

func (o ConnectorCapacityOutput) AutoScaling() ConnectorAutoScalingPtrOutput

func (ConnectorCapacityOutput) ElementType 

func (ConnectorCapacityOutput) ElementType() reflect.Type

func (ConnectorCapacityOutput) ProvisionedCapacity 

func (o ConnectorCapacityOutput) ProvisionedCapacity() ConnectorProvisionedCapacityPtrOutput

func (ConnectorCapacityOutput) ToConnectorCapacityOutput 

func (o ConnectorCapacityOutput) ToConnectorCapacityOutput() ConnectorCapacityOutput

func (ConnectorCapacityOutput) ToConnectorCapacityOutputWithContext 

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

type ConnectorCapacityPtrOutput 

type ConnectorCapacityPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCapacityPtrOutput) AutoScaling 

func (o ConnectorCapacityPtrOutput) AutoScaling() ConnectorAutoScalingPtrOutput

func (ConnectorCapacityPtrOutput) Elem 

func (o ConnectorCapacityPtrOutput) Elem() ConnectorCapacityOutput

func (ConnectorCapacityPtrOutput) ElementType 

func (ConnectorCapacityPtrOutput) ElementType() reflect.Type

func (ConnectorCapacityPtrOutput) ProvisionedCapacity 

func (o ConnectorCapacityPtrOutput) ProvisionedCapacity() ConnectorProvisionedCapacityPtrOutput

func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput 

func (o ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutput() ConnectorCapacityPtrOutput

func (ConnectorCapacityPtrOutput) ToConnectorCapacityPtrOutputWithContext 

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

type ConnectorCloudWatchLogsLogDelivery 

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

Details about delivering logs to Amazon CloudWatch Logs.

type ConnectorCloudWatchLogsLogDeliveryArgs 

type ConnectorCloudWatchLogsLogDeliveryArgs struct {
	// Specifies whether the logs get sent to the specified CloudWatch Logs destination.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
	// The CloudWatch log group that is the destination for log delivery.
	LogGroup pulumi.StringPtrInput `pulumi:"logGroup"`
}

Details about delivering logs to Amazon CloudWatch Logs.

func (ConnectorCloudWatchLogsLogDeliveryArgs) ElementType 

func (ConnectorCloudWatchLogsLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutput 

func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput

func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext 

func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryOutput

func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutput 

func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput

func (ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext 

func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput

type ConnectorCloudWatchLogsLogDeliveryInput 

type ConnectorCloudWatchLogsLogDeliveryInput interface {
	pulumi.Input

	ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput
	ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(context.Context) ConnectorCloudWatchLogsLogDeliveryOutput
}

ConnectorCloudWatchLogsLogDeliveryInput is an input type that accepts ConnectorCloudWatchLogsLogDeliveryArgs and ConnectorCloudWatchLogsLogDeliveryOutput values. You can construct a concrete instance of `ConnectorCloudWatchLogsLogDeliveryInput` via: 

ConnectorCloudWatchLogsLogDeliveryArgs{...}

type ConnectorCloudWatchLogsLogDeliveryOutput 

type ConnectorCloudWatchLogsLogDeliveryOutput struct{ *pulumi.OutputState }

Details about delivering logs to Amazon CloudWatch Logs.

func (ConnectorCloudWatchLogsLogDeliveryOutput) ElementType 

func (ConnectorCloudWatchLogsLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorCloudWatchLogsLogDeliveryOutput) Enabled 

func (o ConnectorCloudWatchLogsLogDeliveryOutput) Enabled() pulumi.BoolOutput

Specifies whether the logs get sent to the specified CloudWatch Logs destination.

func (ConnectorCloudWatchLogsLogDeliveryOutput) LogGroup 

func (o ConnectorCloudWatchLogsLogDeliveryOutput) LogGroup() pulumi.StringPtrOutput

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

func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutput 

func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutput() ConnectorCloudWatchLogsLogDeliveryOutput

func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext 

func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryOutput

func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput 

func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput

func (ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext 

func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput

type ConnectorCloudWatchLogsLogDeliveryPtrInput 

type ConnectorCloudWatchLogsLogDeliveryPtrInput interface {
	pulumi.Input

	ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput
	ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput
}

ConnectorCloudWatchLogsLogDeliveryPtrInput is an input type that accepts ConnectorCloudWatchLogsLogDeliveryArgs, ConnectorCloudWatchLogsLogDeliveryPtr and ConnectorCloudWatchLogsLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorCloudWatchLogsLogDeliveryPtrInput` via: 

        ConnectorCloudWatchLogsLogDeliveryArgs{...}

or:

        nil

func ConnectorCloudWatchLogsLogDeliveryPtr 

func ConnectorCloudWatchLogsLogDeliveryPtr(v *ConnectorCloudWatchLogsLogDeliveryArgs) ConnectorCloudWatchLogsLogDeliveryPtrInput

type ConnectorCloudWatchLogsLogDeliveryPtrOutput 

type ConnectorCloudWatchLogsLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) Elem 

func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) Elem() ConnectorCloudWatchLogsLogDeliveryOutput

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ElementType 

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) Enabled 

func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput

Specifies whether the logs get sent to the specified CloudWatch Logs destination.

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) LogGroup 

func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) LogGroup() pulumi.StringPtrOutput

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

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput 

func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutput() ConnectorCloudWatchLogsLogDeliveryPtrOutput

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext 

func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToConnectorCloudWatchLogsLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorCloudWatchLogsLogDeliveryPtrOutput

type ConnectorCustomPlugin 

type ConnectorCustomPlugin struct {
	// The Amazon Resource Name (ARN) of the custom plugin to use.
	CustomPluginArn string `pulumi:"customPluginArn"`
	// The revision of the custom plugin to use.
	Revision int `pulumi:"revision"`
}

Details about a custom plugin.

type ConnectorCustomPluginArgs 

type ConnectorCustomPluginArgs struct {
	// The Amazon Resource Name (ARN) of the custom plugin to use.
	CustomPluginArn pulumi.StringInput `pulumi:"customPluginArn"`
	// The revision of the custom plugin to use.
	Revision pulumi.IntInput `pulumi:"revision"`
}

Details about a custom plugin.

func (ConnectorCustomPluginArgs) ElementType 

func (ConnectorCustomPluginArgs) ElementType() reflect.Type

func (ConnectorCustomPluginArgs) ToConnectorCustomPluginOutput 

func (i ConnectorCustomPluginArgs) ToConnectorCustomPluginOutput() ConnectorCustomPluginOutput

func (ConnectorCustomPluginArgs) ToConnectorCustomPluginOutputWithContext 

func (i ConnectorCustomPluginArgs) ToConnectorCustomPluginOutputWithContext(ctx context.Context) ConnectorCustomPluginOutput

type ConnectorCustomPluginInput 

type ConnectorCustomPluginInput interface {
	pulumi.Input

	ToConnectorCustomPluginOutput() ConnectorCustomPluginOutput
	ToConnectorCustomPluginOutputWithContext(context.Context) ConnectorCustomPluginOutput
}

ConnectorCustomPluginInput is an input type that accepts ConnectorCustomPluginArgs and ConnectorCustomPluginOutput values. You can construct a concrete instance of `ConnectorCustomPluginInput` via: 

ConnectorCustomPluginArgs{...}

type ConnectorCustomPluginOutput 

type ConnectorCustomPluginOutput struct{ *pulumi.OutputState }

Details about a custom plugin.

func (ConnectorCustomPluginOutput) CustomPluginArn 

func (o ConnectorCustomPluginOutput) CustomPluginArn() pulumi.StringOutput

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

func (ConnectorCustomPluginOutput) ElementType 

func (ConnectorCustomPluginOutput) ElementType() reflect.Type

func (ConnectorCustomPluginOutput) Revision 

func (o ConnectorCustomPluginOutput) Revision() pulumi.IntOutput

The revision of the custom plugin to use.

func (ConnectorCustomPluginOutput) ToConnectorCustomPluginOutput 

func (o ConnectorCustomPluginOutput) ToConnectorCustomPluginOutput() ConnectorCustomPluginOutput

func (ConnectorCustomPluginOutput) ToConnectorCustomPluginOutputWithContext 

func (o ConnectorCustomPluginOutput) ToConnectorCustomPluginOutputWithContext(ctx context.Context) ConnectorCustomPluginOutput

type ConnectorFirehoseLogDelivery 

type ConnectorFirehoseLogDelivery struct {
	// The Kinesis Data Firehose delivery stream that is the destination for log delivery.
	DeliveryStream *string `pulumi:"deliveryStream"`
	// Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
	Enabled bool `pulumi:"enabled"`
}

Details about delivering logs to Amazon Kinesis Data Firehose.

type ConnectorFirehoseLogDeliveryArgs 

type ConnectorFirehoseLogDeliveryArgs struct {
	// The Kinesis Data Firehose delivery stream that is the destination for log delivery.
	DeliveryStream pulumi.StringPtrInput `pulumi:"deliveryStream"`
	// Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.
	Enabled pulumi.BoolInput `pulumi:"enabled"`
}

Details about delivering logs to Amazon Kinesis Data Firehose.

func (ConnectorFirehoseLogDeliveryArgs) ElementType 

func (ConnectorFirehoseLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutput 

func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput

func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutputWithContext 

func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryOutput

func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutput 

func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput

func (ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutputWithContext 

func (i ConnectorFirehoseLogDeliveryArgs) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput

type ConnectorFirehoseLogDeliveryInput 

type ConnectorFirehoseLogDeliveryInput interface {
	pulumi.Input

	ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput
	ToConnectorFirehoseLogDeliveryOutputWithContext(context.Context) ConnectorFirehoseLogDeliveryOutput
}

ConnectorFirehoseLogDeliveryInput is an input type that accepts ConnectorFirehoseLogDeliveryArgs and ConnectorFirehoseLogDeliveryOutput values. You can construct a concrete instance of `ConnectorFirehoseLogDeliveryInput` via: 

ConnectorFirehoseLogDeliveryArgs{...}

type ConnectorFirehoseLogDeliveryOutput 

type ConnectorFirehoseLogDeliveryOutput struct{ *pulumi.OutputState }

Details about delivering logs to Amazon Kinesis Data Firehose.

func (ConnectorFirehoseLogDeliveryOutput) DeliveryStream 

func (o ConnectorFirehoseLogDeliveryOutput) DeliveryStream() pulumi.StringPtrOutput

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

func (ConnectorFirehoseLogDeliveryOutput) ElementType 

func (ConnectorFirehoseLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorFirehoseLogDeliveryOutput) Enabled 

func (o ConnectorFirehoseLogDeliveryOutput) Enabled() pulumi.BoolOutput

Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.

func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutput 

func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutput() ConnectorFirehoseLogDeliveryOutput

func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutputWithContext 

func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryOutput

func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutput 

func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput

func (ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext 

func (o ConnectorFirehoseLogDeliveryOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput

type ConnectorFirehoseLogDeliveryPtrInput 

type ConnectorFirehoseLogDeliveryPtrInput interface {
	pulumi.Input

	ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput
	ToConnectorFirehoseLogDeliveryPtrOutputWithContext(context.Context) ConnectorFirehoseLogDeliveryPtrOutput
}

ConnectorFirehoseLogDeliveryPtrInput is an input type that accepts ConnectorFirehoseLogDeliveryArgs, ConnectorFirehoseLogDeliveryPtr and ConnectorFirehoseLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorFirehoseLogDeliveryPtrInput` via: 

        ConnectorFirehoseLogDeliveryArgs{...}

or:

        nil

func ConnectorFirehoseLogDeliveryPtr 

func ConnectorFirehoseLogDeliveryPtr(v *ConnectorFirehoseLogDeliveryArgs) ConnectorFirehoseLogDeliveryPtrInput

type ConnectorFirehoseLogDeliveryPtrOutput 

type ConnectorFirehoseLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorFirehoseLogDeliveryPtrOutput) DeliveryStream 

func (o ConnectorFirehoseLogDeliveryPtrOutput) DeliveryStream() pulumi.StringPtrOutput

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

func (ConnectorFirehoseLogDeliveryPtrOutput) Elem 

func (o ConnectorFirehoseLogDeliveryPtrOutput) Elem() ConnectorFirehoseLogDeliveryOutput

func (ConnectorFirehoseLogDeliveryPtrOutput) ElementType 

func (ConnectorFirehoseLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorFirehoseLogDeliveryPtrOutput) Enabled 

func (o ConnectorFirehoseLogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput

Specifies whether the logs get sent to the specified Kinesis Data Firehose delivery stream.

func (ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutput 

func (o ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutput() ConnectorFirehoseLogDeliveryPtrOutput

func (ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext 

func (o ConnectorFirehoseLogDeliveryPtrOutput) ToConnectorFirehoseLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorFirehoseLogDeliveryPtrOutput

type ConnectorInput 

type ConnectorInput interface {
	pulumi.Input

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

type ConnectorKafkaCluster 

type ConnectorKafkaCluster struct {
	ApacheKafkaCluster ConnectorApacheKafkaCluster `pulumi:"apacheKafkaCluster"`
}

Details of how to connect to the Kafka cluster.

type ConnectorKafkaClusterArgs 

type ConnectorKafkaClusterArgs struct {
	ApacheKafkaCluster ConnectorApacheKafkaClusterInput `pulumi:"apacheKafkaCluster"`
}

Details of how to connect to the Kafka cluster.

func (ConnectorKafkaClusterArgs) ElementType 

func (ConnectorKafkaClusterArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput 

func (i ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterArgs) ToConnectorKafkaClusterOutputWithContext 

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

type ConnectorKafkaClusterClientAuthentication 

type ConnectorKafkaClusterClientAuthentication struct {
	AuthenticationType ConnectorKafkaClusterClientAuthenticationType `pulumi:"authenticationType"`
}

Details of the client authentication used by the Kafka cluster.

type ConnectorKafkaClusterClientAuthenticationArgs 

type ConnectorKafkaClusterClientAuthenticationArgs struct {
	AuthenticationType ConnectorKafkaClusterClientAuthenticationTypeInput `pulumi:"authenticationType"`
}

Details of the client authentication used by the Kafka cluster.

func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType 

func (ConnectorKafkaClusterClientAuthenticationArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationArgs) ToConnectorKafkaClusterClientAuthenticationOutputWithContext 

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

type ConnectorKafkaClusterClientAuthenticationInput 

type ConnectorKafkaClusterClientAuthenticationInput interface {
	pulumi.Input

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

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

ConnectorKafkaClusterClientAuthenticationArgs{...}

type ConnectorKafkaClusterClientAuthenticationOutput 

type ConnectorKafkaClusterClientAuthenticationOutput struct{ *pulumi.OutputState }

Details of the client authentication used by the Kafka cluster.

func (ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType 

func (o ConnectorKafkaClusterClientAuthenticationOutput) AuthenticationType() ConnectorKafkaClusterClientAuthenticationTypeOutput

func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType 

func (ConnectorKafkaClusterClientAuthenticationOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutput() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorKafkaClusterClientAuthenticationOutput) ToConnectorKafkaClusterClientAuthenticationOutputWithContext 

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

type ConnectorKafkaClusterClientAuthenticationType 

type ConnectorKafkaClusterClientAuthenticationType string

The type of client authentication used to connect to the Kafka cluster. Value NONE means that no client authentication is used.

func (ConnectorKafkaClusterClientAuthenticationType) ElementType 

func (ConnectorKafkaClusterClientAuthenticationType) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutput 

func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput

func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext 

func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput

func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput 

func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput

func (ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext 

func (e ConnectorKafkaClusterClientAuthenticationType) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput

func (ConnectorKafkaClusterClientAuthenticationType) ToStringOutput 

func (e ConnectorKafkaClusterClientAuthenticationType) ToStringOutput() pulumi.StringOutput

func (ConnectorKafkaClusterClientAuthenticationType) ToStringOutputWithContext 

func (e ConnectorKafkaClusterClientAuthenticationType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutput 

func (e ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutput() pulumi.StringPtrOutput

func (ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutputWithContext 

func (e ConnectorKafkaClusterClientAuthenticationType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ConnectorKafkaClusterClientAuthenticationTypeInput 

type ConnectorKafkaClusterClientAuthenticationTypeInput interface {
	pulumi.Input

	ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput
	ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput
}

ConnectorKafkaClusterClientAuthenticationTypeInput is an input type that accepts values of the ConnectorKafkaClusterClientAuthenticationType enum A concrete instance of `ConnectorKafkaClusterClientAuthenticationTypeInput` can be one of the following: 

ConnectorKafkaClusterClientAuthenticationTypeNone
ConnectorKafkaClusterClientAuthenticationTypeIam

type ConnectorKafkaClusterClientAuthenticationTypeOutput 

type ConnectorKafkaClusterClientAuthenticationTypeOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ElementType 

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutput 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutput() ConnectorKafkaClusterClientAuthenticationTypeOutput

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypeOutput

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutput 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutput() pulumi.StringOutput

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutput 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ConnectorKafkaClusterClientAuthenticationTypePtrInput 

type ConnectorKafkaClusterClientAuthenticationTypePtrInput interface {
	pulumi.Input

	ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput
	ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput
}

func ConnectorKafkaClusterClientAuthenticationTypePtr 

func ConnectorKafkaClusterClientAuthenticationTypePtr(v string) ConnectorKafkaClusterClientAuthenticationTypePtrInput

type ConnectorKafkaClusterClientAuthenticationTypePtrOutput 

type ConnectorKafkaClusterClientAuthenticationTypePtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) Elem 

func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) Elem() ConnectorKafkaClusterClientAuthenticationTypeOutput

func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ElementType 

func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput 

func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutput() ConnectorKafkaClusterClientAuthenticationTypePtrOutput

func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToConnectorKafkaClusterClientAuthenticationTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterClientAuthenticationTypePtrOutput

func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutput 

func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutputWithContext 

func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ConnectorKafkaClusterEncryptionInTransit 

type ConnectorKafkaClusterEncryptionInTransit struct {
	EncryptionType ConnectorKafkaClusterEncryptionInTransitType `pulumi:"encryptionType"`
}

Details of encryption in transit to the Kafka cluster.

type ConnectorKafkaClusterEncryptionInTransitArgs 

type ConnectorKafkaClusterEncryptionInTransitArgs struct {
	EncryptionType ConnectorKafkaClusterEncryptionInTransitTypeInput `pulumi:"encryptionType"`
}

Details of encryption in transit to the Kafka cluster.

func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitArgs) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext 

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

type ConnectorKafkaClusterEncryptionInTransitInput 

type ConnectorKafkaClusterEncryptionInTransitInput interface {
	pulumi.Input

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

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

ConnectorKafkaClusterEncryptionInTransitArgs{...}

type ConnectorKafkaClusterEncryptionInTransitOutput 

type ConnectorKafkaClusterEncryptionInTransitOutput struct{ *pulumi.OutputState }

Details of encryption in transit to the Kafka cluster.

func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) EncryptionType() ConnectorKafkaClusterEncryptionInTransitTypeOutput

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutput() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToConnectorKafkaClusterEncryptionInTransitOutputWithContext 

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

type ConnectorKafkaClusterEncryptionInTransitType 

type ConnectorKafkaClusterEncryptionInTransitType string

The type of encryption in transit to the Kafka cluster.

func (ConnectorKafkaClusterEncryptionInTransitType) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitType) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutput 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput

func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput

func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput

func (ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput

func (ConnectorKafkaClusterEncryptionInTransitType) ToStringOutput 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringOutput() pulumi.StringOutput

func (ConnectorKafkaClusterEncryptionInTransitType) ToStringOutputWithContext 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutput 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutput() pulumi.StringPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutputWithContext 

func (e ConnectorKafkaClusterEncryptionInTransitType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ConnectorKafkaClusterEncryptionInTransitTypeInput 

type ConnectorKafkaClusterEncryptionInTransitTypeInput interface {
	pulumi.Input

	ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput
	ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput
}

ConnectorKafkaClusterEncryptionInTransitTypeInput is an input type that accepts values of the ConnectorKafkaClusterEncryptionInTransitType enum A concrete instance of `ConnectorKafkaClusterEncryptionInTransitTypeInput` can be one of the following: 

ConnectorKafkaClusterEncryptionInTransitTypePlaintext
ConnectorKafkaClusterEncryptionInTransitTypeTls

type ConnectorKafkaClusterEncryptionInTransitTypeOutput 

type ConnectorKafkaClusterEncryptionInTransitTypeOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutput 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutput() ConnectorKafkaClusterEncryptionInTransitTypeOutput

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypeOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypeOutput

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutput 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutput() pulumi.StringOutput

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutput 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ConnectorKafkaClusterEncryptionInTransitTypePtrInput 

type ConnectorKafkaClusterEncryptionInTransitTypePtrInput interface {
	pulumi.Input

	ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
	ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput
}

func ConnectorKafkaClusterEncryptionInTransitTypePtr 

func ConnectorKafkaClusterEncryptionInTransitTypePtr(v string) ConnectorKafkaClusterEncryptionInTransitTypePtrInput

type ConnectorKafkaClusterEncryptionInTransitTypePtrOutput 

type ConnectorKafkaClusterEncryptionInTransitTypePtrOutput struct{ *pulumi.OutputState }

func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) Elem 

func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) Elem() ConnectorKafkaClusterEncryptionInTransitTypeOutput

func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ElementType 

func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput 

func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutput() ConnectorKafkaClusterEncryptionInTransitTypePtrOutput

func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToConnectorKafkaClusterEncryptionInTransitTypePtrOutputWithContext(ctx context.Context) ConnectorKafkaClusterEncryptionInTransitTypePtrOutput

func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutput 

func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutputWithContext 

func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type ConnectorKafkaClusterInput 

type ConnectorKafkaClusterInput interface {
	pulumi.Input

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

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

ConnectorKafkaClusterArgs{...}

type ConnectorKafkaClusterOutput 

type ConnectorKafkaClusterOutput struct{ *pulumi.OutputState }

Details of how to connect to the Kafka cluster.

func (ConnectorKafkaClusterOutput) ApacheKafkaCluster 

func (o ConnectorKafkaClusterOutput) ApacheKafkaCluster() ConnectorApacheKafkaClusterOutput

func (ConnectorKafkaClusterOutput) ElementType 

func (ConnectorKafkaClusterOutput) ElementType() reflect.Type

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput 

func (o ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutput() ConnectorKafkaClusterOutput

func (ConnectorKafkaClusterOutput) ToConnectorKafkaClusterOutputWithContext 

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

type ConnectorLogDelivery 

type ConnectorLogDelivery struct {
	WorkerLogDelivery ConnectorWorkerLogDelivery `pulumi:"workerLogDelivery"`
}

Details of what logs are delivered and where they are delivered.

type ConnectorLogDeliveryArgs 

type ConnectorLogDeliveryArgs struct {
	WorkerLogDelivery ConnectorWorkerLogDeliveryInput `pulumi:"workerLogDelivery"`
}

Details of what logs are delivered and where they are delivered.

func (ConnectorLogDeliveryArgs) ElementType 

func (ConnectorLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryOutputWithContext 

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

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput 

func (i ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryArgs) ToConnectorLogDeliveryPtrOutputWithContext 

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

type ConnectorLogDeliveryInput 

type ConnectorLogDeliveryInput interface {
	pulumi.Input

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

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

ConnectorLogDeliveryArgs{...}

type ConnectorLogDeliveryOutput 

type ConnectorLogDeliveryOutput struct{ *pulumi.OutputState }

Details of what logs are delivered and where they are delivered.

func (ConnectorLogDeliveryOutput) ElementType 

func (ConnectorLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutput() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryOutputWithContext 

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

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput 

func (o ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryOutput) ToConnectorLogDeliveryPtrOutputWithContext 

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

func (ConnectorLogDeliveryOutput) WorkerLogDelivery 

func (o ConnectorLogDeliveryOutput) WorkerLogDelivery() ConnectorWorkerLogDeliveryOutput

type ConnectorLogDeliveryPtrInput 

type ConnectorLogDeliveryPtrInput interface {
	pulumi.Input

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

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

        ConnectorLogDeliveryArgs{...}

or:

        nil

func ConnectorLogDeliveryPtr 

func ConnectorLogDeliveryPtr(v *ConnectorLogDeliveryArgs) ConnectorLogDeliveryPtrInput

type ConnectorLogDeliveryPtrOutput 

type ConnectorLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorLogDeliveryPtrOutput) Elem 

func (o ConnectorLogDeliveryPtrOutput) Elem() ConnectorLogDeliveryOutput

func (ConnectorLogDeliveryPtrOutput) ElementType 

func (ConnectorLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput 

func (o ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutput() ConnectorLogDeliveryPtrOutput

func (ConnectorLogDeliveryPtrOutput) ToConnectorLogDeliveryPtrOutputWithContext 

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

func (ConnectorLogDeliveryPtrOutput) WorkerLogDelivery 

func (o ConnectorLogDeliveryPtrOutput) WorkerLogDelivery() ConnectorWorkerLogDeliveryPtrOutput

type ConnectorOutput 

type ConnectorOutput struct{ *pulumi.OutputState }

func (ConnectorOutput) Capacity added in v0.17.0 

func (o ConnectorOutput) Capacity() ConnectorCapacityOutput

func (ConnectorOutput) ConnectorArn added in v0.17.0 

func (o ConnectorOutput) ConnectorArn() pulumi.StringOutput

Amazon Resource Name for the created Connector.

func (ConnectorOutput) ConnectorConfiguration added in v0.17.0 

func (o ConnectorOutput) ConnectorConfiguration() pulumi.StringMapOutput

The configuration for the connector.

func (ConnectorOutput) ConnectorDescription added in v0.17.0 

func (o ConnectorOutput) ConnectorDescription() pulumi.StringPtrOutput

A summary description of the connector.

func (ConnectorOutput) ConnectorName added in v0.17.0 

func (o ConnectorOutput) ConnectorName() pulumi.StringOutput

The name of the connector.

func (ConnectorOutput) ElementType 

func (ConnectorOutput) ElementType() reflect.Type

func (ConnectorOutput) KafkaCluster added in v0.17.0 

func (o ConnectorOutput) KafkaCluster() ConnectorKafkaClusterOutput

func (ConnectorOutput) KafkaClusterClientAuthentication added in v0.17.0 

func (o ConnectorOutput) KafkaClusterClientAuthentication() ConnectorKafkaClusterClientAuthenticationOutput

func (ConnectorOutput) KafkaClusterEncryptionInTransit added in v0.17.0 

func (o ConnectorOutput) KafkaClusterEncryptionInTransit() ConnectorKafkaClusterEncryptionInTransitOutput

func (ConnectorOutput) KafkaConnectVersion added in v0.17.0 

func (o ConnectorOutput) KafkaConnectVersion() pulumi.StringOutput

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

func (ConnectorOutput) LogDelivery added in v0.17.0 

func (o ConnectorOutput) LogDelivery() ConnectorLogDeliveryPtrOutput

func (ConnectorOutput) Plugins added in v0.17.0 

func (o ConnectorOutput) Plugins() ConnectorPluginArrayOutput

List of plugins to use with the connector.

func (ConnectorOutput) ServiceExecutionRoleArn added in v0.17.0 

func (o ConnectorOutput) ServiceExecutionRoleArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the IAM role used by the connector to access Amazon S3 objects and other external resources.

func (ConnectorOutput) Tags added in v0.100.0 

func (o ConnectorOutput) Tags() aws.TagArrayOutput

A collection of tags associated with a resource

func (ConnectorOutput) ToConnectorOutput 

func (o ConnectorOutput) ToConnectorOutput() ConnectorOutput

func (ConnectorOutput) ToConnectorOutputWithContext 

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

func (ConnectorOutput) WorkerConfiguration added in v0.17.0 

func (o ConnectorOutput) WorkerConfiguration() ConnectorWorkerConfigurationPtrOutput

type ConnectorPlugin 

type ConnectorPlugin struct {
	CustomPlugin ConnectorCustomPlugin `pulumi:"customPlugin"`
}

Details about a Kafka Connect plugin which will be used with the connector.

type ConnectorPluginArgs 

type ConnectorPluginArgs struct {
	CustomPlugin ConnectorCustomPluginInput `pulumi:"customPlugin"`
}

Details about a Kafka Connect plugin which will be used with the connector.

func (ConnectorPluginArgs) ElementType 

func (ConnectorPluginArgs) ElementType() reflect.Type

func (ConnectorPluginArgs) ToConnectorPluginOutput 

func (i ConnectorPluginArgs) ToConnectorPluginOutput() ConnectorPluginOutput

func (ConnectorPluginArgs) ToConnectorPluginOutputWithContext 

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

type ConnectorPluginArray 

type ConnectorPluginArray []ConnectorPluginInput

func (ConnectorPluginArray) ElementType 

func (ConnectorPluginArray) ElementType() reflect.Type

func (ConnectorPluginArray) ToConnectorPluginArrayOutput 

func (i ConnectorPluginArray) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput

func (ConnectorPluginArray) ToConnectorPluginArrayOutputWithContext 

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

type ConnectorPluginArrayInput 

type ConnectorPluginArrayInput interface {
	pulumi.Input

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

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

ConnectorPluginArray{ ConnectorPluginArgs{...} }

type ConnectorPluginArrayOutput 

type ConnectorPluginArrayOutput struct{ *pulumi.OutputState }

func (ConnectorPluginArrayOutput) ElementType 

func (ConnectorPluginArrayOutput) ElementType() reflect.Type

func (ConnectorPluginArrayOutput) Index 

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

func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput 

func (o ConnectorPluginArrayOutput) ToConnectorPluginArrayOutput() ConnectorPluginArrayOutput

func (ConnectorPluginArrayOutput) ToConnectorPluginArrayOutputWithContext 

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

type ConnectorPluginInput 

type ConnectorPluginInput interface {
	pulumi.Input

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

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

ConnectorPluginArgs{...}

type ConnectorPluginOutput 

type ConnectorPluginOutput struct{ *pulumi.OutputState }

Details about a Kafka Connect plugin which will be used with the connector.

func (ConnectorPluginOutput) CustomPlugin 

func (o ConnectorPluginOutput) CustomPlugin() ConnectorCustomPluginOutput

func (ConnectorPluginOutput) ElementType 

func (ConnectorPluginOutput) ElementType() reflect.Type

func (ConnectorPluginOutput) ToConnectorPluginOutput 

func (o ConnectorPluginOutput) ToConnectorPluginOutput() ConnectorPluginOutput

func (ConnectorPluginOutput) ToConnectorPluginOutputWithContext 

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

type ConnectorProvisionedCapacity 

type ConnectorProvisionedCapacity struct {
	// Specifies how many MSK Connect Units (MCU) are allocated to the connector.
	McuCount *int `pulumi:"mcuCount"`
	// Number of workers for a connector.
	WorkerCount int `pulumi:"workerCount"`
}

Details about a fixed capacity allocated to a connector.

type ConnectorProvisionedCapacityArgs 

type ConnectorProvisionedCapacityArgs struct {
	// Specifies how many MSK Connect Units (MCU) are allocated to the connector.
	McuCount pulumi.IntPtrInput `pulumi:"mcuCount"`
	// Number of workers for a connector.
	WorkerCount pulumi.IntInput `pulumi:"workerCount"`
}

Details about a fixed capacity allocated to a connector.

func (ConnectorProvisionedCapacityArgs) ElementType 

func (ConnectorProvisionedCapacityArgs) ElementType() reflect.Type

func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutput 

func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput

func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutputWithContext 

func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityOutput

func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutput 

func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput

func (ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutputWithContext 

func (i ConnectorProvisionedCapacityArgs) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput

type ConnectorProvisionedCapacityInput 

type ConnectorProvisionedCapacityInput interface {
	pulumi.Input

	ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput
	ToConnectorProvisionedCapacityOutputWithContext(context.Context) ConnectorProvisionedCapacityOutput
}

ConnectorProvisionedCapacityInput is an input type that accepts ConnectorProvisionedCapacityArgs and ConnectorProvisionedCapacityOutput values. You can construct a concrete instance of `ConnectorProvisionedCapacityInput` via: 

ConnectorProvisionedCapacityArgs{...}

type ConnectorProvisionedCapacityOutput 

type ConnectorProvisionedCapacityOutput struct{ *pulumi.OutputState }

Details about a fixed capacity allocated to a connector.

func (ConnectorProvisionedCapacityOutput) ElementType 

func (ConnectorProvisionedCapacityOutput) ElementType() reflect.Type

func (ConnectorProvisionedCapacityOutput) McuCount 

func (o ConnectorProvisionedCapacityOutput) McuCount() pulumi.IntPtrOutput

Specifies how many MSK Connect Units (MCU) are allocated to the connector.

func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutput 

func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutput() ConnectorProvisionedCapacityOutput

func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutputWithContext 

func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityOutput

func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutput 

func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput

func (ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutputWithContext 

func (o ConnectorProvisionedCapacityOutput) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput

func (ConnectorProvisionedCapacityOutput) WorkerCount 

func (o ConnectorProvisionedCapacityOutput) WorkerCount() pulumi.IntOutput

Number of workers for a connector.

type ConnectorProvisionedCapacityPtrInput 

type ConnectorProvisionedCapacityPtrInput interface {
	pulumi.Input

	ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput
	ToConnectorProvisionedCapacityPtrOutputWithContext(context.Context) ConnectorProvisionedCapacityPtrOutput
}

ConnectorProvisionedCapacityPtrInput is an input type that accepts ConnectorProvisionedCapacityArgs, ConnectorProvisionedCapacityPtr and ConnectorProvisionedCapacityPtrOutput values. You can construct a concrete instance of `ConnectorProvisionedCapacityPtrInput` via: 

        ConnectorProvisionedCapacityArgs{...}

or:

        nil

func ConnectorProvisionedCapacityPtr 

func ConnectorProvisionedCapacityPtr(v *ConnectorProvisionedCapacityArgs) ConnectorProvisionedCapacityPtrInput

type ConnectorProvisionedCapacityPtrOutput 

type ConnectorProvisionedCapacityPtrOutput struct{ *pulumi.OutputState }

func (ConnectorProvisionedCapacityPtrOutput) Elem 

func (o ConnectorProvisionedCapacityPtrOutput) Elem() ConnectorProvisionedCapacityOutput

func (ConnectorProvisionedCapacityPtrOutput) ElementType 

func (ConnectorProvisionedCapacityPtrOutput) ElementType() reflect.Type

func (ConnectorProvisionedCapacityPtrOutput) McuCount 

func (o ConnectorProvisionedCapacityPtrOutput) McuCount() pulumi.IntPtrOutput

Specifies how many MSK Connect Units (MCU) are allocated to the connector.

func (ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutput 

func (o ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutput() ConnectorProvisionedCapacityPtrOutput

func (ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutputWithContext 

func (o ConnectorProvisionedCapacityPtrOutput) ToConnectorProvisionedCapacityPtrOutputWithContext(ctx context.Context) ConnectorProvisionedCapacityPtrOutput

func (ConnectorProvisionedCapacityPtrOutput) WorkerCount 

func (o ConnectorProvisionedCapacityPtrOutput) WorkerCount() pulumi.IntPtrOutput

Number of workers for a connector.

type ConnectorS3LogDelivery 

type ConnectorS3LogDelivery struct {
	// The name of the S3 bucket that is the destination for log delivery.
	Bucket *string `pulumi:"bucket"`
	// Specifies whether the 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"`
}

Details about delivering logs to Amazon S3.

type ConnectorS3LogDeliveryArgs 

type ConnectorS3LogDeliveryArgs struct {
	// The name of the S3 bucket that is the destination for log delivery.
	Bucket pulumi.StringPtrInput `pulumi:"bucket"`
	// Specifies whether the 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"`
}

Details about delivering logs to Amazon S3.

func (ConnectorS3LogDeliveryArgs) ElementType 

func (ConnectorS3LogDeliveryArgs) ElementType() reflect.Type

func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutput 

func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput

func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutputWithContext 

func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryOutput

func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutput 

func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput

func (ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutputWithContext 

func (i ConnectorS3LogDeliveryArgs) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput

type ConnectorS3LogDeliveryInput 

type ConnectorS3LogDeliveryInput interface {
	pulumi.Input

	ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput
	ToConnectorS3LogDeliveryOutputWithContext(context.Context) ConnectorS3LogDeliveryOutput
}

ConnectorS3LogDeliveryInput is an input type that accepts ConnectorS3LogDeliveryArgs and ConnectorS3LogDeliveryOutput values. You can construct a concrete instance of `ConnectorS3LogDeliveryInput` via: 

ConnectorS3LogDeliveryArgs{...}

type ConnectorS3LogDeliveryOutput 

type ConnectorS3LogDeliveryOutput struct{ *pulumi.OutputState }

Details about delivering logs to Amazon S3.

func (ConnectorS3LogDeliveryOutput) Bucket 

func (o ConnectorS3LogDeliveryOutput) Bucket() pulumi.StringPtrOutput

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

func (ConnectorS3LogDeliveryOutput) ElementType 

func (ConnectorS3LogDeliveryOutput) ElementType() reflect.Type

func (ConnectorS3LogDeliveryOutput) Enabled 

func (o ConnectorS3LogDeliveryOutput) Enabled() pulumi.BoolOutput

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

func (ConnectorS3LogDeliveryOutput) Prefix 

func (o ConnectorS3LogDeliveryOutput) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for log delivery.

func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutput 

func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutput() ConnectorS3LogDeliveryOutput

func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutputWithContext 

func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryOutput

func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutput 

func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput

func (ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutputWithContext 

func (o ConnectorS3LogDeliveryOutput) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput

type ConnectorS3LogDeliveryPtrInput 

type ConnectorS3LogDeliveryPtrInput interface {
	pulumi.Input

	ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput
	ToConnectorS3LogDeliveryPtrOutputWithContext(context.Context) ConnectorS3LogDeliveryPtrOutput
}

ConnectorS3LogDeliveryPtrInput is an input type that accepts ConnectorS3LogDeliveryArgs, ConnectorS3LogDeliveryPtr and ConnectorS3LogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorS3LogDeliveryPtrInput` via: 

        ConnectorS3LogDeliveryArgs{...}

or:

        nil

func ConnectorS3LogDeliveryPtr 

func ConnectorS3LogDeliveryPtr(v *ConnectorS3LogDeliveryArgs) ConnectorS3LogDeliveryPtrInput

type ConnectorS3LogDeliveryPtrOutput 

type ConnectorS3LogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorS3LogDeliveryPtrOutput) Bucket 

func (o ConnectorS3LogDeliveryPtrOutput) Bucket() pulumi.StringPtrOutput

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

func (ConnectorS3LogDeliveryPtrOutput) Elem 

func (o ConnectorS3LogDeliveryPtrOutput) Elem() ConnectorS3LogDeliveryOutput

func (ConnectorS3LogDeliveryPtrOutput) ElementType 

func (ConnectorS3LogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorS3LogDeliveryPtrOutput) Enabled 

func (o ConnectorS3LogDeliveryPtrOutput) Enabled() pulumi.BoolPtrOutput

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

func (ConnectorS3LogDeliveryPtrOutput) Prefix 

func (o ConnectorS3LogDeliveryPtrOutput) Prefix() pulumi.StringPtrOutput

The S3 prefix that is the destination for log delivery.

func (ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutput 

func (o ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutput() ConnectorS3LogDeliveryPtrOutput

func (ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutputWithContext 

func (o ConnectorS3LogDeliveryPtrOutput) ToConnectorS3LogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorS3LogDeliveryPtrOutput

type ConnectorScaleInPolicy 

type ConnectorScaleInPolicy struct {
	// Specifies the CPU utilization percentage threshold at which connector scale in should trigger.
	CpuUtilizationPercentage int `pulumi:"cpuUtilizationPercentage"`
}

Information about the scale in policy of the connector.

type ConnectorScaleInPolicyArgs 

type ConnectorScaleInPolicyArgs struct {
	// Specifies the CPU utilization percentage threshold at which connector scale in should trigger.
	CpuUtilizationPercentage pulumi.IntInput `pulumi:"cpuUtilizationPercentage"`
}

Information about the scale in policy of the connector.

func (ConnectorScaleInPolicyArgs) ElementType 

func (ConnectorScaleInPolicyArgs) ElementType() reflect.Type

func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutput 

func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput

func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutputWithContext 

func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyOutputWithContext(ctx context.Context) ConnectorScaleInPolicyOutput

func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutput 

func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput

func (ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutputWithContext 

func (i ConnectorScaleInPolicyArgs) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput

type ConnectorScaleInPolicyInput 

type ConnectorScaleInPolicyInput interface {
	pulumi.Input

	ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput
	ToConnectorScaleInPolicyOutputWithContext(context.Context) ConnectorScaleInPolicyOutput
}

ConnectorScaleInPolicyInput is an input type that accepts ConnectorScaleInPolicyArgs and ConnectorScaleInPolicyOutput values. You can construct a concrete instance of `ConnectorScaleInPolicyInput` via: 

ConnectorScaleInPolicyArgs{...}

type ConnectorScaleInPolicyOutput 

type ConnectorScaleInPolicyOutput struct{ *pulumi.OutputState }

Information about the scale in policy of the connector.

func (ConnectorScaleInPolicyOutput) CpuUtilizationPercentage 

func (o ConnectorScaleInPolicyOutput) CpuUtilizationPercentage() pulumi.IntOutput

Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

func (ConnectorScaleInPolicyOutput) ElementType 

func (ConnectorScaleInPolicyOutput) ElementType() reflect.Type

func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutput 

func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutput() ConnectorScaleInPolicyOutput

func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutputWithContext 

func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyOutputWithContext(ctx context.Context) ConnectorScaleInPolicyOutput

func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutput 

func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput

func (ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutputWithContext 

func (o ConnectorScaleInPolicyOutput) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput

type ConnectorScaleInPolicyPtrInput 

type ConnectorScaleInPolicyPtrInput interface {
	pulumi.Input

	ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput
	ToConnectorScaleInPolicyPtrOutputWithContext(context.Context) ConnectorScaleInPolicyPtrOutput
}

ConnectorScaleInPolicyPtrInput is an input type that accepts ConnectorScaleInPolicyArgs, ConnectorScaleInPolicyPtr and ConnectorScaleInPolicyPtrOutput values. You can construct a concrete instance of `ConnectorScaleInPolicyPtrInput` via: 

        ConnectorScaleInPolicyArgs{...}

or:

        nil

func ConnectorScaleInPolicyPtr 

func ConnectorScaleInPolicyPtr(v *ConnectorScaleInPolicyArgs) ConnectorScaleInPolicyPtrInput

type ConnectorScaleInPolicyPtrOutput 

type ConnectorScaleInPolicyPtrOutput struct{ *pulumi.OutputState }

func (ConnectorScaleInPolicyPtrOutput) CpuUtilizationPercentage 

func (o ConnectorScaleInPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

Specifies the CPU utilization percentage threshold at which connector scale in should trigger.

func (ConnectorScaleInPolicyPtrOutput) Elem 

func (o ConnectorScaleInPolicyPtrOutput) Elem() ConnectorScaleInPolicyOutput

func (ConnectorScaleInPolicyPtrOutput) ElementType 

func (ConnectorScaleInPolicyPtrOutput) ElementType() reflect.Type

func (ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutput 

func (o ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutput() ConnectorScaleInPolicyPtrOutput

func (ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutputWithContext 

func (o ConnectorScaleInPolicyPtrOutput) ToConnectorScaleInPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleInPolicyPtrOutput

type ConnectorScaleOutPolicy 

type ConnectorScaleOutPolicy struct {
	// Specifies the CPU utilization percentage threshold at which connector scale out should trigger.
	CpuUtilizationPercentage int `pulumi:"cpuUtilizationPercentage"`
}

Information about the scale out policy of the connector.

type ConnectorScaleOutPolicyArgs 

type ConnectorScaleOutPolicyArgs struct {
	// Specifies the CPU utilization percentage threshold at which connector scale out should trigger.
	CpuUtilizationPercentage pulumi.IntInput `pulumi:"cpuUtilizationPercentage"`
}

Information about the scale out policy of the connector.

func (ConnectorScaleOutPolicyArgs) ElementType 

func (ConnectorScaleOutPolicyArgs) ElementType() reflect.Type

func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutput 

func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput

func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutputWithContext 

func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyOutput

func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutput 

func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput

func (ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutputWithContext 

func (i ConnectorScaleOutPolicyArgs) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput

type ConnectorScaleOutPolicyInput 

type ConnectorScaleOutPolicyInput interface {
	pulumi.Input

	ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput
	ToConnectorScaleOutPolicyOutputWithContext(context.Context) ConnectorScaleOutPolicyOutput
}

ConnectorScaleOutPolicyInput is an input type that accepts ConnectorScaleOutPolicyArgs and ConnectorScaleOutPolicyOutput values. You can construct a concrete instance of `ConnectorScaleOutPolicyInput` via: 

ConnectorScaleOutPolicyArgs{...}

type ConnectorScaleOutPolicyOutput 

type ConnectorScaleOutPolicyOutput struct{ *pulumi.OutputState }

Information about the scale out policy of the connector.

func (ConnectorScaleOutPolicyOutput) CpuUtilizationPercentage 

func (o ConnectorScaleOutPolicyOutput) CpuUtilizationPercentage() pulumi.IntOutput

Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

func (ConnectorScaleOutPolicyOutput) ElementType 

func (ConnectorScaleOutPolicyOutput) ElementType() reflect.Type

func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutput 

func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutput() ConnectorScaleOutPolicyOutput

func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutputWithContext 

func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyOutput

func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutput 

func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput

func (ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutputWithContext 

func (o ConnectorScaleOutPolicyOutput) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput

type ConnectorScaleOutPolicyPtrInput 

type ConnectorScaleOutPolicyPtrInput interface {
	pulumi.Input

	ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput
	ToConnectorScaleOutPolicyPtrOutputWithContext(context.Context) ConnectorScaleOutPolicyPtrOutput
}

ConnectorScaleOutPolicyPtrInput is an input type that accepts ConnectorScaleOutPolicyArgs, ConnectorScaleOutPolicyPtr and ConnectorScaleOutPolicyPtrOutput values. You can construct a concrete instance of `ConnectorScaleOutPolicyPtrInput` via: 

        ConnectorScaleOutPolicyArgs{...}

or:

        nil

func ConnectorScaleOutPolicyPtr 

func ConnectorScaleOutPolicyPtr(v *ConnectorScaleOutPolicyArgs) ConnectorScaleOutPolicyPtrInput

type ConnectorScaleOutPolicyPtrOutput 

type ConnectorScaleOutPolicyPtrOutput struct{ *pulumi.OutputState }

func (ConnectorScaleOutPolicyPtrOutput) CpuUtilizationPercentage 

func (o ConnectorScaleOutPolicyPtrOutput) CpuUtilizationPercentage() pulumi.IntPtrOutput

Specifies the CPU utilization percentage threshold at which connector scale out should trigger.

func (ConnectorScaleOutPolicyPtrOutput) Elem 

func (o ConnectorScaleOutPolicyPtrOutput) Elem() ConnectorScaleOutPolicyOutput

func (ConnectorScaleOutPolicyPtrOutput) ElementType 

func (ConnectorScaleOutPolicyPtrOutput) ElementType() reflect.Type

func (ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutput 

func (o ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutput() ConnectorScaleOutPolicyPtrOutput

func (ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutputWithContext 

func (o ConnectorScaleOutPolicyPtrOutput) ToConnectorScaleOutPolicyPtrOutputWithContext(ctx context.Context) ConnectorScaleOutPolicyPtrOutput

type ConnectorState 

type ConnectorState struct {
}

func (ConnectorState) ElementType 

func (ConnectorState) ElementType() reflect.Type

type ConnectorTag added in v0.100.0 

type ConnectorTag struct {
	Key   string `pulumi:"key"`
	Value string `pulumi:"value"`
}

type ConnectorVpc 

type ConnectorVpc struct {
	// The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
	SecurityGroups []string `pulumi:"securityGroups"`
	// The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
	Subnets []string `pulumi:"subnets"`
}

Information about a VPC used with the connector.

type ConnectorVpcArgs 

type ConnectorVpcArgs struct {
	// The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.
	SecurityGroups pulumi.StringArrayInput `pulumi:"securityGroups"`
	// The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.
	Subnets pulumi.StringArrayInput `pulumi:"subnets"`
}

Information about a VPC used with the connector.

func (ConnectorVpcArgs) ElementType 

func (ConnectorVpcArgs) ElementType() reflect.Type

func (ConnectorVpcArgs) ToConnectorVpcOutput 

func (i ConnectorVpcArgs) ToConnectorVpcOutput() ConnectorVpcOutput

func (ConnectorVpcArgs) ToConnectorVpcOutputWithContext 

func (i ConnectorVpcArgs) ToConnectorVpcOutputWithContext(ctx context.Context) ConnectorVpcOutput

type ConnectorVpcInput 

type ConnectorVpcInput interface {
	pulumi.Input

	ToConnectorVpcOutput() ConnectorVpcOutput
	ToConnectorVpcOutputWithContext(context.Context) ConnectorVpcOutput
}

ConnectorVpcInput is an input type that accepts ConnectorVpcArgs and ConnectorVpcOutput values. You can construct a concrete instance of `ConnectorVpcInput` via: 

ConnectorVpcArgs{...}

type ConnectorVpcOutput 

type ConnectorVpcOutput struct{ *pulumi.OutputState }

Information about a VPC used with the connector.

func (ConnectorVpcOutput) ElementType 

func (ConnectorVpcOutput) ElementType() reflect.Type

func (ConnectorVpcOutput) SecurityGroups 

func (o ConnectorVpcOutput) SecurityGroups() pulumi.StringArrayOutput

The AWS security groups to associate with the elastic network interfaces in order to specify what the connector has access to.

func (ConnectorVpcOutput) Subnets 

func (o ConnectorVpcOutput) Subnets() pulumi.StringArrayOutput

The list of subnets to connect to in the virtual private cloud (VPC). AWS creates elastic network interfaces inside these subnets.

func (ConnectorVpcOutput) ToConnectorVpcOutput 

func (o ConnectorVpcOutput) ToConnectorVpcOutput() ConnectorVpcOutput

func (ConnectorVpcOutput) ToConnectorVpcOutputWithContext 

func (o ConnectorVpcOutput) ToConnectorVpcOutputWithContext(ctx context.Context) ConnectorVpcOutput

type ConnectorWorkerConfiguration 

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

Specifies the worker configuration to use with the connector.

type ConnectorWorkerConfigurationArgs 

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

Specifies the worker configuration to use with the connector.

func (ConnectorWorkerConfigurationArgs) ElementType 

func (ConnectorWorkerConfigurationArgs) ElementType() reflect.Type

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationOutputWithContext 

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

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput 

func (i ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationArgs) ToConnectorWorkerConfigurationPtrOutputWithContext 

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

type ConnectorWorkerConfigurationInput 

type ConnectorWorkerConfigurationInput interface {
	pulumi.Input

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

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

ConnectorWorkerConfigurationArgs{...}

type ConnectorWorkerConfigurationOutput 

type ConnectorWorkerConfigurationOutput struct{ *pulumi.OutputState }

Specifies the worker configuration to use with the connector.

func (ConnectorWorkerConfigurationOutput) ElementType 

func (ConnectorWorkerConfigurationOutput) ElementType() reflect.Type

func (ConnectorWorkerConfigurationOutput) Revision 

func (o ConnectorWorkerConfigurationOutput) Revision() pulumi.IntOutput

The revision of the worker configuration to use.

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutput() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationOutputWithContext 

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

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput 

func (o ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationOutput) ToConnectorWorkerConfigurationPtrOutputWithContext 

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

func (ConnectorWorkerConfigurationOutput) WorkerConfigurationArn 

func (o ConnectorWorkerConfigurationOutput) WorkerConfigurationArn() pulumi.StringOutput

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

type ConnectorWorkerConfigurationPtrInput 

type ConnectorWorkerConfigurationPtrInput interface {
	pulumi.Input

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

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

        ConnectorWorkerConfigurationArgs{...}

or:

        nil

func ConnectorWorkerConfigurationPtr 

func ConnectorWorkerConfigurationPtr(v *ConnectorWorkerConfigurationArgs) ConnectorWorkerConfigurationPtrInput

type ConnectorWorkerConfigurationPtrOutput 

type ConnectorWorkerConfigurationPtrOutput struct{ *pulumi.OutputState }

func (ConnectorWorkerConfigurationPtrOutput) Elem 

func (o ConnectorWorkerConfigurationPtrOutput) Elem() ConnectorWorkerConfigurationOutput

func (ConnectorWorkerConfigurationPtrOutput) ElementType 

func (ConnectorWorkerConfigurationPtrOutput) ElementType() reflect.Type

func (ConnectorWorkerConfigurationPtrOutput) Revision 

func (o ConnectorWorkerConfigurationPtrOutput) Revision() pulumi.IntPtrOutput

The revision of the worker configuration to use.

func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput 

func (o ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutput() ConnectorWorkerConfigurationPtrOutput

func (ConnectorWorkerConfigurationPtrOutput) ToConnectorWorkerConfigurationPtrOutputWithContext 

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

func (ConnectorWorkerConfigurationPtrOutput) WorkerConfigurationArn 

func (o ConnectorWorkerConfigurationPtrOutput) WorkerConfigurationArn() pulumi.StringPtrOutput

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

type ConnectorWorkerLogDelivery 

type ConnectorWorkerLogDelivery struct {
	CloudWatchLogs *ConnectorCloudWatchLogsLogDelivery `pulumi:"cloudWatchLogs"`
	Firehose       *ConnectorFirehoseLogDelivery       `pulumi:"firehose"`
	S3             *ConnectorS3LogDelivery             `pulumi:"s3"`
}

Specifies where worker logs are delivered.

type ConnectorWorkerLogDeliveryArgs 

type ConnectorWorkerLogDeliveryArgs struct {
	CloudWatchLogs ConnectorCloudWatchLogsLogDeliveryPtrInput `pulumi:"cloudWatchLogs"`
	Firehose       ConnectorFirehoseLogDeliveryPtrInput       `pulumi:"firehose"`
	S3             ConnectorS3LogDeliveryPtrInput             `pulumi:"s3"`
}

Specifies where worker logs are delivered.

func (ConnectorWorkerLogDeliveryArgs) ElementType 

func (ConnectorWorkerLogDeliveryArgs) ElementType() reflect.Type

func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutput 

func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput

func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutputWithContext 

func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryOutput

func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutput 

func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutputWithContext 

func (i ConnectorWorkerLogDeliveryArgs) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput

type ConnectorWorkerLogDeliveryInput 

type ConnectorWorkerLogDeliveryInput interface {
	pulumi.Input

	ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput
	ToConnectorWorkerLogDeliveryOutputWithContext(context.Context) ConnectorWorkerLogDeliveryOutput
}

ConnectorWorkerLogDeliveryInput is an input type that accepts ConnectorWorkerLogDeliveryArgs and ConnectorWorkerLogDeliveryOutput values. You can construct a concrete instance of `ConnectorWorkerLogDeliveryInput` via: 

ConnectorWorkerLogDeliveryArgs{...}

type ConnectorWorkerLogDeliveryOutput 

type ConnectorWorkerLogDeliveryOutput struct{ *pulumi.OutputState }

Specifies where worker logs are delivered.

func (ConnectorWorkerLogDeliveryOutput) CloudWatchLogs 

func (o ConnectorWorkerLogDeliveryOutput) CloudWatchLogs() ConnectorCloudWatchLogsLogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryOutput) ElementType 

func (ConnectorWorkerLogDeliveryOutput) ElementType() reflect.Type

func (ConnectorWorkerLogDeliveryOutput) Firehose 

func (o ConnectorWorkerLogDeliveryOutput) Firehose() ConnectorFirehoseLogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryOutput) S3 

func (o ConnectorWorkerLogDeliveryOutput) S3() ConnectorS3LogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutput 

func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutput() ConnectorWorkerLogDeliveryOutput

func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutputWithContext 

func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryOutput

func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutput 

func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext 

func (o ConnectorWorkerLogDeliveryOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput

type ConnectorWorkerLogDeliveryPtrInput 

type ConnectorWorkerLogDeliveryPtrInput interface {
	pulumi.Input

	ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput
	ToConnectorWorkerLogDeliveryPtrOutputWithContext(context.Context) ConnectorWorkerLogDeliveryPtrOutput
}

ConnectorWorkerLogDeliveryPtrInput is an input type that accepts ConnectorWorkerLogDeliveryArgs, ConnectorWorkerLogDeliveryPtr and ConnectorWorkerLogDeliveryPtrOutput values. You can construct a concrete instance of `ConnectorWorkerLogDeliveryPtrInput` via: 

        ConnectorWorkerLogDeliveryArgs{...}

or:

        nil

func ConnectorWorkerLogDeliveryPtr 

func ConnectorWorkerLogDeliveryPtr(v *ConnectorWorkerLogDeliveryArgs) ConnectorWorkerLogDeliveryPtrInput

type ConnectorWorkerLogDeliveryPtrOutput 

type ConnectorWorkerLogDeliveryPtrOutput struct{ *pulumi.OutputState }

func (ConnectorWorkerLogDeliveryPtrOutput) CloudWatchLogs 

func (o ConnectorWorkerLogDeliveryPtrOutput) CloudWatchLogs() ConnectorCloudWatchLogsLogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryPtrOutput) Elem 

func (o ConnectorWorkerLogDeliveryPtrOutput) Elem() ConnectorWorkerLogDeliveryOutput

func (ConnectorWorkerLogDeliveryPtrOutput) ElementType 

func (ConnectorWorkerLogDeliveryPtrOutput) ElementType() reflect.Type

func (ConnectorWorkerLogDeliveryPtrOutput) Firehose 

func (o ConnectorWorkerLogDeliveryPtrOutput) Firehose() ConnectorFirehoseLogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryPtrOutput) S3 

func (o ConnectorWorkerLogDeliveryPtrOutput) S3() ConnectorS3LogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutput 

func (o ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutput() ConnectorWorkerLogDeliveryPtrOutput

func (ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext 

func (o ConnectorWorkerLogDeliveryPtrOutput) ToConnectorWorkerLogDeliveryPtrOutputWithContext(ctx context.Context) ConnectorWorkerLogDeliveryPtrOutput

type CustomPlugin added in v0.101.0 

type CustomPlugin struct {
	pulumi.CustomResourceState

	// The type of the plugin file.
	ContentType CustomPluginContentTypeOutput `pulumi:"contentType"`
	// The Amazon Resource Name (ARN) of the custom plugin to use.
	CustomPluginArn pulumi.StringOutput `pulumi:"customPluginArn"`
	// A summary description of the custom plugin.
	Description     pulumi.StringPtrOutput            `pulumi:"description"`
	FileDescription CustomPluginFileDescriptionOutput `pulumi:"fileDescription"`
	Location        CustomPluginLocationOutput        `pulumi:"location"`
	// The name of the custom plugin.
	Name pulumi.StringOutput `pulumi:"name"`
	// The revision of the custom plugin.
	Revision pulumi.IntOutput `pulumi:"revision"`
	// An array of key-value pairs to apply to this resource.
	Tags aws.TagArrayOutput `pulumi:"tags"`
}

An example resource schema demonstrating some basic constructs and validation rules.

func GetCustomPlugin added in v0.101.0 

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 added in v0.101.0 

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 added in v0.101.0 

func (*CustomPlugin) ElementType() reflect.Type

func (*CustomPlugin) ToCustomPluginOutput added in v0.101.0 

func (i *CustomPlugin) ToCustomPluginOutput() CustomPluginOutput

func (*CustomPlugin) ToCustomPluginOutputWithContext added in v0.101.0 

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

type CustomPluginArgs added in v0.101.0 

type CustomPluginArgs struct {
	// The type of the plugin file.
	ContentType CustomPluginContentTypeInput
	// A summary description of the custom plugin.
	Description pulumi.StringPtrInput
	Location    CustomPluginLocationInput
	// The name of the custom plugin.
	Name pulumi.StringPtrInput
	// An array of key-value pairs to apply to this resource.
	Tags aws.TagArrayInput
}

The set of arguments for constructing a CustomPlugin resource.

func (CustomPluginArgs) ElementType added in v0.101.0 

func (CustomPluginArgs) ElementType() reflect.Type

type CustomPluginContentType added in v0.101.0 

type CustomPluginContentType string

The type of the plugin file.

func (CustomPluginContentType) ElementType added in v0.101.0 

func (CustomPluginContentType) ElementType() reflect.Type

func (CustomPluginContentType) ToCustomPluginContentTypeOutput added in v0.101.0 

func (e CustomPluginContentType) ToCustomPluginContentTypeOutput() CustomPluginContentTypeOutput

func (CustomPluginContentType) ToCustomPluginContentTypeOutputWithContext added in v0.101.0 

func (e CustomPluginContentType) ToCustomPluginContentTypeOutputWithContext(ctx context.Context) CustomPluginContentTypeOutput

func (CustomPluginContentType) ToCustomPluginContentTypePtrOutput added in v0.101.0 

func (e CustomPluginContentType) ToCustomPluginContentTypePtrOutput() CustomPluginContentTypePtrOutput

func (CustomPluginContentType) ToCustomPluginContentTypePtrOutputWithContext added in v0.101.0 

func (e CustomPluginContentType) ToCustomPluginContentTypePtrOutputWithContext(ctx context.Context) CustomPluginContentTypePtrOutput

func (CustomPluginContentType) ToStringOutput added in v0.101.0 

func (e CustomPluginContentType) ToStringOutput() pulumi.StringOutput

func (CustomPluginContentType) ToStringOutputWithContext added in v0.101.0 

func (e CustomPluginContentType) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (CustomPluginContentType) ToStringPtrOutput added in v0.101.0 

func (e CustomPluginContentType) ToStringPtrOutput() pulumi.StringPtrOutput

func (CustomPluginContentType) ToStringPtrOutputWithContext added in v0.101.0 

func (e CustomPluginContentType) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type CustomPluginContentTypeInput added in v0.101.0 

type CustomPluginContentTypeInput interface {
	pulumi.Input

	ToCustomPluginContentTypeOutput() CustomPluginContentTypeOutput
	ToCustomPluginContentTypeOutputWithContext(context.Context) CustomPluginContentTypeOutput
}

CustomPluginContentTypeInput is an input type that accepts values of the CustomPluginContentType enum A concrete instance of `CustomPluginContentTypeInput` can be one of the following: 

CustomPluginContentTypeJar
CustomPluginContentTypeZip

type CustomPluginContentTypeOutput added in v0.101.0 

type CustomPluginContentTypeOutput struct{ *pulumi.OutputState }

func (CustomPluginContentTypeOutput) ElementType added in v0.101.0 

func (CustomPluginContentTypeOutput) ElementType() reflect.Type

func (CustomPluginContentTypeOutput) ToCustomPluginContentTypeOutput added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToCustomPluginContentTypeOutput() CustomPluginContentTypeOutput

func (CustomPluginContentTypeOutput) ToCustomPluginContentTypeOutputWithContext added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToCustomPluginContentTypeOutputWithContext(ctx context.Context) CustomPluginContentTypeOutput

func (CustomPluginContentTypeOutput) ToCustomPluginContentTypePtrOutput added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToCustomPluginContentTypePtrOutput() CustomPluginContentTypePtrOutput

func (CustomPluginContentTypeOutput) ToCustomPluginContentTypePtrOutputWithContext added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToCustomPluginContentTypePtrOutputWithContext(ctx context.Context) CustomPluginContentTypePtrOutput

func (CustomPluginContentTypeOutput) ToStringOutput added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToStringOutput() pulumi.StringOutput

func (CustomPluginContentTypeOutput) ToStringOutputWithContext added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToStringOutputWithContext(ctx context.Context) pulumi.StringOutput

func (CustomPluginContentTypeOutput) ToStringPtrOutput added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (CustomPluginContentTypeOutput) ToStringPtrOutputWithContext added in v0.101.0 

func (o CustomPluginContentTypeOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type CustomPluginContentTypePtrInput added in v0.101.0 

type CustomPluginContentTypePtrInput interface {
	pulumi.Input

	ToCustomPluginContentTypePtrOutput() CustomPluginContentTypePtrOutput
	ToCustomPluginContentTypePtrOutputWithContext(context.Context) CustomPluginContentTypePtrOutput
}

func CustomPluginContentTypePtr added in v0.101.0 

func CustomPluginContentTypePtr(v string) CustomPluginContentTypePtrInput

type CustomPluginContentTypePtrOutput added in v0.101.0 

type CustomPluginContentTypePtrOutput struct{ *pulumi.OutputState }

func (CustomPluginContentTypePtrOutput) Elem added in v0.101.0 

func (o CustomPluginContentTypePtrOutput) Elem() CustomPluginContentTypeOutput

func (CustomPluginContentTypePtrOutput) ElementType added in v0.101.0 

func (CustomPluginContentTypePtrOutput) ElementType() reflect.Type

func (CustomPluginContentTypePtrOutput) ToCustomPluginContentTypePtrOutput added in v0.101.0 

func (o CustomPluginContentTypePtrOutput) ToCustomPluginContentTypePtrOutput() CustomPluginContentTypePtrOutput

func (CustomPluginContentTypePtrOutput) ToCustomPluginContentTypePtrOutputWithContext added in v0.101.0 

func (o CustomPluginContentTypePtrOutput) ToCustomPluginContentTypePtrOutputWithContext(ctx context.Context) CustomPluginContentTypePtrOutput

func (CustomPluginContentTypePtrOutput) ToStringPtrOutput added in v0.101.0 

func (o CustomPluginContentTypePtrOutput) ToStringPtrOutput() pulumi.StringPtrOutput

func (CustomPluginContentTypePtrOutput) ToStringPtrOutputWithContext added in v0.101.0 

func (o CustomPluginContentTypePtrOutput) ToStringPtrOutputWithContext(ctx context.Context) pulumi.StringPtrOutput

type CustomPluginFileDescription added in v0.101.0 

type CustomPluginFileDescription struct {
	// The hex-encoded MD5 checksum of the custom plugin file. You can use it to validate the file.
	FileMd5 *string `pulumi:"fileMd5"`
	// The size in bytes of the custom plugin file. You can use it to validate the file.
	FileSize *int `pulumi:"fileSize"`
}

Details about the custom plugin file.

type CustomPluginFileDescriptionOutput added in v0.101.0 

type CustomPluginFileDescriptionOutput struct{ *pulumi.OutputState }

Details about the custom plugin file.

func (CustomPluginFileDescriptionOutput) ElementType added in v0.101.0 

func (CustomPluginFileDescriptionOutput) ElementType() reflect.Type

func (CustomPluginFileDescriptionOutput) FileMd5 added in v0.101.0 

func (o CustomPluginFileDescriptionOutput) FileMd5() pulumi.StringPtrOutput

The hex-encoded MD5 checksum of the custom plugin file. You can use it to validate the file.

func (CustomPluginFileDescriptionOutput) FileSize added in v0.101.0 

func (o CustomPluginFileDescriptionOutput) FileSize() pulumi.IntPtrOutput

The size in bytes of the custom plugin file. You can use it to validate the file.

func (CustomPluginFileDescriptionOutput) ToCustomPluginFileDescriptionOutput added in v0.101.0 

func (o CustomPluginFileDescriptionOutput) ToCustomPluginFileDescriptionOutput() CustomPluginFileDescriptionOutput

func (CustomPluginFileDescriptionOutput) ToCustomPluginFileDescriptionOutputWithContext added in v0.101.0 

func (o CustomPluginFileDescriptionOutput) ToCustomPluginFileDescriptionOutputWithContext(ctx context.Context) CustomPluginFileDescriptionOutput

type CustomPluginFileDescriptionPtrOutput added in v0.101.0 

type CustomPluginFileDescriptionPtrOutput struct{ *pulumi.OutputState }

func (CustomPluginFileDescriptionPtrOutput) Elem added in v0.101.0 

func (o CustomPluginFileDescriptionPtrOutput) Elem() CustomPluginFileDescriptionOutput

func (CustomPluginFileDescriptionPtrOutput) ElementType added in v0.101.0 

func (CustomPluginFileDescriptionPtrOutput) ElementType() reflect.Type

func (CustomPluginFileDescriptionPtrOutput) FileMd5 added in v0.101.0 

func (o CustomPluginFileDescriptionPtrOutput) FileMd5() pulumi.StringPtrOutput

The hex-encoded MD5 checksum of the custom plugin file. You can use it to validate the file.

func (CustomPluginFileDescriptionPtrOutput) FileSize added in v0.101.0 

func (o CustomPluginFileDescriptionPtrOutput) FileSize() pulumi.IntPtrOutput

The size in bytes of the custom plugin file. You can use it to validate the file.

func (CustomPluginFileDescriptionPtrOutput) ToCustomPluginFileDescriptionPtrOutput added in v0.101.0 

func (o CustomPluginFileDescriptionPtrOutput) ToCustomPluginFileDescriptionPtrOutput() CustomPluginFileDescriptionPtrOutput

func (CustomPluginFileDescriptionPtrOutput) ToCustomPluginFileDescriptionPtrOutputWithContext added in v0.101.0 

func (o CustomPluginFileDescriptionPtrOutput) ToCustomPluginFileDescriptionPtrOutputWithContext(ctx context.Context) CustomPluginFileDescriptionPtrOutput

type CustomPluginInput added in v0.101.0 

type CustomPluginInput interface {
	pulumi.Input

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

type CustomPluginLocation added in v0.101.0 

type CustomPluginLocation struct {
	S3Location CustomPluginS3Location `pulumi:"s3Location"`
}

Information about the location of a custom plugin.

type CustomPluginLocationArgs added in v0.101.0 

type CustomPluginLocationArgs struct {
	S3Location CustomPluginS3LocationInput `pulumi:"s3Location"`
}

Information about the location of a custom plugin.

func (CustomPluginLocationArgs) ElementType added in v0.101.0 

func (CustomPluginLocationArgs) ElementType() reflect.Type

func (CustomPluginLocationArgs) ToCustomPluginLocationOutput added in v0.101.0 

func (i CustomPluginLocationArgs) ToCustomPluginLocationOutput() CustomPluginLocationOutput

func (CustomPluginLocationArgs) ToCustomPluginLocationOutputWithContext added in v0.101.0 

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

type CustomPluginLocationInput added in v0.101.0 

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 added in v0.101.0 

type CustomPluginLocationOutput struct{ *pulumi.OutputState }

Information about the location of a custom plugin.

func (CustomPluginLocationOutput) ElementType added in v0.101.0 

func (CustomPluginLocationOutput) ElementType() reflect.Type

func (CustomPluginLocationOutput) S3Location added in v0.101.0 

func (o CustomPluginLocationOutput) S3Location() CustomPluginS3LocationOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationOutput added in v0.101.0 

func (o CustomPluginLocationOutput) ToCustomPluginLocationOutput() CustomPluginLocationOutput

func (CustomPluginLocationOutput) ToCustomPluginLocationOutputWithContext added in v0.101.0 

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

type CustomPluginOutput added in v0.101.0 

type CustomPluginOutput struct{ *pulumi.OutputState }

func (CustomPluginOutput) ContentType added in v0.101.0 

func (o CustomPluginOutput) ContentType() CustomPluginContentTypeOutput

The type of the plugin file.

func (CustomPluginOutput) CustomPluginArn added in v0.101.0 

func (o CustomPluginOutput) CustomPluginArn() pulumi.StringOutput

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

func (CustomPluginOutput) Description added in v0.101.0 

func (o CustomPluginOutput) Description() pulumi.StringPtrOutput

A summary description of the custom plugin.

func (CustomPluginOutput) ElementType added in v0.101.0 

func (CustomPluginOutput) ElementType() reflect.Type

func (CustomPluginOutput) FileDescription added in v0.101.0 

func (o CustomPluginOutput) FileDescription() CustomPluginFileDescriptionOutput

func (CustomPluginOutput) Location added in v0.101.0 

func (o CustomPluginOutput) Location() CustomPluginLocationOutput

func (CustomPluginOutput) Name added in v0.101.0 

func (o CustomPluginOutput) Name() pulumi.StringOutput

The name of the custom plugin.

func (CustomPluginOutput) Revision added in v0.101.0 

func (o CustomPluginOutput) Revision() pulumi.IntOutput

The revision of the custom plugin.

func (CustomPluginOutput) Tags added in v0.101.0 

func (o CustomPluginOutput) Tags() aws.TagArrayOutput

An array of key-value pairs to apply to this resource.

func (CustomPluginOutput) ToCustomPluginOutput added in v0.101.0 

func (o CustomPluginOutput) ToCustomPluginOutput() CustomPluginOutput

func (CustomPluginOutput) ToCustomPluginOutputWithContext added in v0.101.0 

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

type CustomPluginS3Location added in v0.101.0 

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

The S3 bucket Amazon Resource Name (ARN), file key, and object version of the plugin file stored in Amazon S3.

type CustomPluginS3LocationArgs added in v0.101.0 

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

The S3 bucket Amazon Resource Name (ARN), file key, and object version of the plugin file stored in Amazon S3.

func (CustomPluginS3LocationArgs) ElementType added in v0.101.0 

func (CustomPluginS3LocationArgs) ElementType() reflect.Type

func (CustomPluginS3LocationArgs) ToCustomPluginS3LocationOutput added in v0.101.0 

func (i CustomPluginS3LocationArgs) ToCustomPluginS3LocationOutput() CustomPluginS3LocationOutput

func (CustomPluginS3LocationArgs) ToCustomPluginS3LocationOutputWithContext added in v0.101.0 

func (i CustomPluginS3LocationArgs) ToCustomPluginS3LocationOutputWithContext(ctx context.Context) CustomPluginS3LocationOutput

type CustomPluginS3LocationInput added in v0.101.0 

type CustomPluginS3LocationInput interface {
	pulumi.Input

	ToCustomPluginS3LocationOutput() CustomPluginS3LocationOutput
	ToCustomPluginS3LocationOutputWithContext(context.Context) CustomPluginS3LocationOutput
}

CustomPluginS3LocationInput is an input type that accepts CustomPluginS3LocationArgs and CustomPluginS3LocationOutput values. You can construct a concrete instance of `CustomPluginS3LocationInput` via: 

CustomPluginS3LocationArgs{...}

type CustomPluginS3LocationOutput added in v0.101.0 

type CustomPluginS3LocationOutput struct{ *pulumi.OutputState }

The S3 bucket Amazon Resource Name (ARN), file key, and object version of the plugin file stored in Amazon S3.

func (CustomPluginS3LocationOutput) BucketArn added in v0.101.0 

func (o CustomPluginS3LocationOutput) BucketArn() pulumi.StringOutput

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

func (CustomPluginS3LocationOutput) ElementType added in v0.101.0 

func (CustomPluginS3LocationOutput) ElementType() reflect.Type

func (CustomPluginS3LocationOutput) FileKey added in v0.101.0 

func (o CustomPluginS3LocationOutput) FileKey() pulumi.StringOutput

The file key for an object in an S3 bucket.

func (CustomPluginS3LocationOutput) ObjectVersion added in v0.101.0 

func (o CustomPluginS3LocationOutput) ObjectVersion() pulumi.StringPtrOutput

The version of an object in an S3 bucket.

func (CustomPluginS3LocationOutput) ToCustomPluginS3LocationOutput added in v0.101.0 

func (o CustomPluginS3LocationOutput) ToCustomPluginS3LocationOutput() CustomPluginS3LocationOutput

func (CustomPluginS3LocationOutput) ToCustomPluginS3LocationOutputWithContext added in v0.101.0 

func (o CustomPluginS3LocationOutput) ToCustomPluginS3LocationOutputWithContext(ctx context.Context) CustomPluginS3LocationOutput

type CustomPluginState added in v0.101.0 

type CustomPluginState struct {
}

func (CustomPluginState) ElementType added in v0.101.0 

func (CustomPluginState) ElementType() reflect.Type

type CustomPluginTag added in v0.101.0 

type CustomPluginTag struct {
	// The key name of the tag. You can specify a value that is 1 to 128 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Key string `pulumi:"key"`
	// The value for the tag. You can specify a value that is 0 to 256 Unicode characters in length and cannot be prefixed with aws:. You can use any of the following characters: the set of Unicode letters, digits, whitespace, _, ., /, =, +, and -.
	Value string `pulumi:"value"`
}

A key-value pair to associate with a resource.

type LookupConnectorArgs added in v0.12.0 

type LookupConnectorArgs struct {
	// Amazon Resource Name for the created Connector.
	ConnectorArn string `pulumi:"connectorArn"`
}

type LookupConnectorOutputArgs added in v0.12.0 

type LookupConnectorOutputArgs struct {
	// Amazon Resource Name for the created Connector.
	ConnectorArn pulumi.StringInput `pulumi:"connectorArn"`
}

func (LookupConnectorOutputArgs) ElementType added in v0.12.0 

func (LookupConnectorOutputArgs) ElementType() reflect.Type

type LookupConnectorResult added in v0.12.0 

type LookupConnectorResult struct {
	Capacity *ConnectorCapacity `pulumi:"capacity"`
	// Amazon Resource Name for the created Connector.
	ConnectorArn *string `pulumi:"connectorArn"`
	// A collection of tags associated with a resource
	Tags []aws.Tag `pulumi:"tags"`
}

func LookupConnector added in v0.12.0 

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

Resource Type definition for AWS::KafkaConnect::Connector

type LookupConnectorResultOutput added in v0.12.0 

type LookupConnectorResultOutput struct{ *pulumi.OutputState }

func LookupConnectorOutput added in v0.12.0 

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

func (LookupConnectorResultOutput) Capacity added in v0.12.0 

func (o LookupConnectorResultOutput) Capacity() ConnectorCapacityPtrOutput

func (LookupConnectorResultOutput) ConnectorArn added in v0.12.0 

func (o LookupConnectorResultOutput) ConnectorArn() pulumi.StringPtrOutput

Amazon Resource Name for the created Connector.

func (LookupConnectorResultOutput) ElementType added in v0.12.0 

func (LookupConnectorResultOutput) ElementType() reflect.Type

func (LookupConnectorResultOutput) Tags added in v0.100.0 

func (o LookupConnectorResultOutput) Tags() aws.TagArrayOutput

A collection of tags associated with a resource

func (LookupConnectorResultOutput) ToLookupConnectorResultOutput added in v0.12.0 

func (o LookupConnectorResultOutput) ToLookupConnectorResultOutput() LookupConnectorResultOutput

func (LookupConnectorResultOutput) ToLookupConnectorResultOutputWithContext added in v0.12.0 

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

type LookupCustomPluginArgs added in v0.101.0 

type LookupCustomPluginArgs struct {
	// The Amazon Resource Name (ARN) of the custom plugin to use.
	CustomPluginArn string `pulumi:"customPluginArn"`
}

type LookupCustomPluginOutputArgs added in v0.101.0 

type LookupCustomPluginOutputArgs struct {
	// The Amazon Resource Name (ARN) of the custom plugin to use.
	CustomPluginArn pulumi.StringInput `pulumi:"customPluginArn"`
}

func (LookupCustomPluginOutputArgs) ElementType added in v0.101.0 

func (LookupCustomPluginOutputArgs) ElementType() reflect.Type

type LookupCustomPluginResult added in v0.101.0 

type LookupCustomPluginResult struct {
	// The Amazon Resource Name (ARN) of the custom plugin to use.
	CustomPluginArn *string                      `pulumi:"customPluginArn"`
	FileDescription *CustomPluginFileDescription `pulumi:"fileDescription"`
	// The revision of the custom plugin.
	Revision *int `pulumi:"revision"`
	// An array of key-value pairs to apply to this resource.
	Tags []aws.Tag `pulumi:"tags"`
}

func LookupCustomPlugin added in v0.101.0 

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

An example resource schema demonstrating some basic constructs and validation rules.

type LookupCustomPluginResultOutput added in v0.101.0 

type LookupCustomPluginResultOutput struct{ *pulumi.OutputState }

func LookupCustomPluginOutput added in v0.101.0 

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

func (LookupCustomPluginResultOutput) CustomPluginArn added in v0.101.0 

func (o LookupCustomPluginResultOutput) CustomPluginArn() pulumi.StringPtrOutput

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

func (LookupCustomPluginResultOutput) ElementType added in v0.101.0 

func (LookupCustomPluginResultOutput) ElementType() reflect.Type

func (LookupCustomPluginResultOutput) FileDescription added in v0.101.0 

func (o LookupCustomPluginResultOutput) FileDescription() CustomPluginFileDescriptionPtrOutput

func (LookupCustomPluginResultOutput) Revision added in v0.101.0 

func (o LookupCustomPluginResultOutput) Revision() pulumi.IntPtrOutput

The revision of the custom plugin.

func (LookupCustomPluginResultOutput) Tags added in v0.101.0 

func (o LookupCustomPluginResultOutput) Tags() aws.TagArrayOutput

An array of key-value pairs to apply to this resource.

func (LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutput added in v0.101.0 

func (o LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutput() LookupCustomPluginResultOutput

func (LookupCustomPluginResultOutput) ToLookupCustomPluginResultOutputWithContext added in v0.101.0 

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

type LookupWorkerConfigurationArgs added in v0.101.0 

type LookupWorkerConfigurationArgs struct {
	// The Amazon Resource Name (ARN) of the custom configuration.
	WorkerConfigurationArn string `pulumi:"workerConfigurationArn"`
}

type LookupWorkerConfigurationOutputArgs added in v0.101.0 

type LookupWorkerConfigurationOutputArgs struct {
	// The Amazon Resource Name (ARN) of the custom configuration.
	WorkerConfigurationArn pulumi.StringInput `pulumi:"workerConfigurationArn"`
}

func (LookupWorkerConfigurationOutputArgs) ElementType added in v0.101.0 

func (LookupWorkerConfigurationOutputArgs) ElementType() reflect.Type

type LookupWorkerConfigurationResult added in v0.101.0 

type LookupWorkerConfigurationResult struct {
	// The description of a revision of the worker configuration.
	Revision *int `pulumi:"revision"`
	// A collection of tags associated with a resource
	Tags []aws.Tag `pulumi:"tags"`
	// The Amazon Resource Name (ARN) of the custom configuration.
	WorkerConfigurationArn *string `pulumi:"workerConfigurationArn"`
}

func LookupWorkerConfiguration added in v0.101.0 

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

The configuration of the workers, which are the processes that run the connector logic.

type LookupWorkerConfigurationResultOutput added in v0.101.0 

type LookupWorkerConfigurationResultOutput struct{ *pulumi.OutputState }

func LookupWorkerConfigurationOutput added in v0.101.0 

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

func (LookupWorkerConfigurationResultOutput) ElementType added in v0.101.0 

func (LookupWorkerConfigurationResultOutput) ElementType() reflect.Type

func (LookupWorkerConfigurationResultOutput) Revision added in v0.101.0 

func (o LookupWorkerConfigurationResultOutput) Revision() pulumi.IntPtrOutput

The description of a revision of the worker configuration.

func (LookupWorkerConfigurationResultOutput) Tags added in v0.101.0 

func (o LookupWorkerConfigurationResultOutput) Tags() aws.TagArrayOutput

A collection of tags associated with a resource

func (LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutput added in v0.101.0 

func (o LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutput() LookupWorkerConfigurationResultOutput

func (LookupWorkerConfigurationResultOutput) ToLookupWorkerConfigurationResultOutputWithContext added in v0.101.0 

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

func (LookupWorkerConfigurationResultOutput) WorkerConfigurationArn added in v0.101.0 

func (o LookupWorkerConfigurationResultOutput) WorkerConfigurationArn() pulumi.StringPtrOutput

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

type WorkerConfiguration added in v0.101.0 

type WorkerConfiguration struct {
	pulumi.CustomResourceState

	// A summary description of the worker configuration.
	Description pulumi.StringPtrOutput `pulumi:"description"`
	// The name of the worker configuration.
	Name pulumi.StringOutput `pulumi:"name"`
	// Base64 encoded contents of connect-distributed.properties file.
	PropertiesFileContent pulumi.StringOutput `pulumi:"propertiesFileContent"`
	// The description of a revision of the worker configuration.
	Revision pulumi.IntOutput `pulumi:"revision"`
	// A collection of tags associated with a resource
	Tags aws.TagArrayOutput `pulumi:"tags"`
	// The Amazon Resource Name (ARN) of the custom configuration.
	WorkerConfigurationArn pulumi.StringOutput `pulumi:"workerConfigurationArn"`
}

The configuration of the workers, which are the processes that run the connector logic.

func GetWorkerConfiguration added in v0.101.0 

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 added in v0.101.0 

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 added in v0.101.0 

func (*WorkerConfiguration) ElementType() reflect.Type

func (*WorkerConfiguration) ToWorkerConfigurationOutput added in v0.101.0 

func (i *WorkerConfiguration) ToWorkerConfigurationOutput() WorkerConfigurationOutput

func (*WorkerConfiguration) ToWorkerConfigurationOutputWithContext added in v0.101.0 

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

type WorkerConfigurationArgs added in v0.101.0 

type WorkerConfigurationArgs struct {
	// A summary description of the worker configuration.
	Description pulumi.StringPtrInput
	// The name of the worker configuration.
	Name pulumi.StringPtrInput
	// Base64 encoded contents of connect-distributed.properties file.
	PropertiesFileContent pulumi.StringInput
	// A collection of tags associated with a resource
	Tags aws.TagArrayInput
}

The set of arguments for constructing a WorkerConfiguration resource.

func (WorkerConfigurationArgs) ElementType added in v0.101.0 

func (WorkerConfigurationArgs) ElementType() reflect.Type

type WorkerConfigurationInput added in v0.101.0 

type WorkerConfigurationInput interface {
	pulumi.Input

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

type WorkerConfigurationOutput added in v0.101.0 

type WorkerConfigurationOutput struct{ *pulumi.OutputState }

func (WorkerConfigurationOutput) Description added in v0.101.0 

func (o WorkerConfigurationOutput) Description() pulumi.StringPtrOutput

A summary description of the worker configuration.

func (WorkerConfigurationOutput) ElementType added in v0.101.0 

func (WorkerConfigurationOutput) ElementType() reflect.Type

func (WorkerConfigurationOutput) Name added in v0.101.0 

func (o WorkerConfigurationOutput) Name() pulumi.StringOutput

The name of the worker configuration.

func (WorkerConfigurationOutput) PropertiesFileContent added in v0.101.0 

func (o WorkerConfigurationOutput) PropertiesFileContent() pulumi.StringOutput

Base64 encoded contents of connect-distributed.properties file.

func (WorkerConfigurationOutput) Revision added in v0.101.0 

func (o WorkerConfigurationOutput) Revision() pulumi.IntOutput

The description of a revision of the worker configuration.

func (WorkerConfigurationOutput) Tags added in v0.101.0 

func (o WorkerConfigurationOutput) Tags() aws.TagArrayOutput

A collection of tags associated with a resource

func (WorkerConfigurationOutput) ToWorkerConfigurationOutput added in v0.101.0 

func (o WorkerConfigurationOutput) ToWorkerConfigurationOutput() WorkerConfigurationOutput

func (WorkerConfigurationOutput) ToWorkerConfigurationOutputWithContext added in v0.101.0 

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

func (WorkerConfigurationOutput) WorkerConfigurationArn added in v0.101.0 

func (o WorkerConfigurationOutput) WorkerConfigurationArn() pulumi.StringOutput

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

type WorkerConfigurationState added in v0.101.0 

type WorkerConfigurationState struct {
}

func (WorkerConfigurationState) ElementType added in v0.101.0 

func (WorkerConfigurationState) ElementType() reflect.Type

type WorkerConfigurationTag added in v0.101.0 

type WorkerConfigurationTag struct {
	Key   string `pulumi:"key"`
	Value string `pulumi:"value"`
}

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.