kafkaconnect

package
v0.76.0 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2023 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")
)

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.AnyOutput `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"`
	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

func (*Connector) ToOutput added in v0.76.0 

func (i *Connector) ToOutput(ctx context.Context) pulumix.Output[*Connector]

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

func (ConnectorApacheKafkaClusterArgs) ToOutput added in v0.76.0 

func (i ConnectorApacheKafkaClusterArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorApacheKafkaCluster]

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) ToOutput added in v0.76.0 

func (o ConnectorApacheKafkaClusterOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorApacheKafkaCluster]

func (ConnectorApacheKafkaClusterOutput) Vpc 

func (o ConnectorApacheKafkaClusterOutput) Vpc() ConnectorVpcOutput

type ConnectorArgs 

type ConnectorArgs struct {
	Capacity ConnectorCapacityInput
	// The configuration for the connector.
	ConnectorConfiguration pulumi.Input
	// 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
	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

func (ConnectorAutoScalingArgs) ToOutput added in v0.76.0 

func (i ConnectorAutoScalingArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorAutoScaling]

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

func (ConnectorAutoScalingOutput) ToOutput added in v0.76.0 

func (o ConnectorAutoScalingOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorAutoScaling]

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

func (ConnectorAutoScalingPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorAutoScalingPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorAutoScaling]

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

func (ConnectorCapacityArgs) ToOutput added in v0.76.0 

func (i ConnectorCapacityArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorCapacity]

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

func (ConnectorCapacityOutput) ToOutput added in v0.76.0 

func (o ConnectorCapacityOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorCapacity]

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

func (ConnectorCapacityPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorCapacityPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorCapacity]

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

func (ConnectorCloudWatchLogsLogDeliveryArgs) ToOutput added in v0.76.0 

func (i ConnectorCloudWatchLogsLogDeliveryArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorCloudWatchLogsLogDelivery]

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

func (ConnectorCloudWatchLogsLogDeliveryOutput) ToOutput added in v0.76.0 

func (o ConnectorCloudWatchLogsLogDeliveryOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorCloudWatchLogsLogDelivery]

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

func (ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorCloudWatchLogsLogDeliveryPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorCloudWatchLogsLogDelivery]

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

func (ConnectorCustomPluginArgs) ToOutput added in v0.76.0 

func (i ConnectorCustomPluginArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorCustomPlugin]

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

func (ConnectorCustomPluginOutput) ToOutput added in v0.76.0 

func (o ConnectorCustomPluginOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorCustomPlugin]

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

func (ConnectorFirehoseLogDeliveryArgs) ToOutput added in v0.76.0 

func (i ConnectorFirehoseLogDeliveryArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorFirehoseLogDelivery]

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

func (ConnectorFirehoseLogDeliveryOutput) ToOutput added in v0.76.0 

func (o ConnectorFirehoseLogDeliveryOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorFirehoseLogDelivery]

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

func (ConnectorFirehoseLogDeliveryPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorFirehoseLogDeliveryPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorFirehoseLogDelivery]

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

func (ConnectorKafkaClusterArgs) ToOutput added in v0.76.0 

func (i ConnectorKafkaClusterArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaCluster]

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

func (ConnectorKafkaClusterClientAuthenticationArgs) ToOutput added in v0.76.0 

func (i ConnectorKafkaClusterClientAuthenticationArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaClusterClientAuthentication]

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

func (ConnectorKafkaClusterClientAuthenticationOutput) ToOutput added in v0.76.0 

func (o ConnectorKafkaClusterClientAuthenticationOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaClusterClientAuthentication]

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 ConnectorKafkaClusterClientAuthenticationTypeArgs and ConnectorKafkaClusterClientAuthenticationTypeOutput values. You can construct a concrete instance of `ConnectorKafkaClusterClientAuthenticationTypeInput` via: 

ConnectorKafkaClusterClientAuthenticationTypeArgs{...}

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) ToOutput added in v0.76.0 

func (o ConnectorKafkaClusterClientAuthenticationTypeOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaClusterClientAuthenticationType]

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) ToOutput added in v0.76.0 

func (o ConnectorKafkaClusterClientAuthenticationTypePtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorKafkaClusterClientAuthenticationType]

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

func (ConnectorKafkaClusterEncryptionInTransitArgs) ToOutput added in v0.76.0 

func (i ConnectorKafkaClusterEncryptionInTransitArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaClusterEncryptionInTransit]

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

func (ConnectorKafkaClusterEncryptionInTransitOutput) ToOutput added in v0.76.0 

func (o ConnectorKafkaClusterEncryptionInTransitOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaClusterEncryptionInTransit]

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 ConnectorKafkaClusterEncryptionInTransitTypeArgs and ConnectorKafkaClusterEncryptionInTransitTypeOutput values. You can construct a concrete instance of `ConnectorKafkaClusterEncryptionInTransitTypeInput` via: 

ConnectorKafkaClusterEncryptionInTransitTypeArgs{...}

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) ToOutput added in v0.76.0 

func (o ConnectorKafkaClusterEncryptionInTransitTypeOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaClusterEncryptionInTransitType]

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) ToOutput added in v0.76.0 

func (o ConnectorKafkaClusterEncryptionInTransitTypePtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorKafkaClusterEncryptionInTransitType]

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

func (ConnectorKafkaClusterOutput) ToOutput added in v0.76.0 

func (o ConnectorKafkaClusterOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorKafkaCluster]

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

func (ConnectorLogDeliveryArgs) ToOutput added in v0.76.0 

func (i ConnectorLogDeliveryArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorLogDelivery]

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) ToOutput added in v0.76.0 

func (o ConnectorLogDeliveryOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorLogDelivery]

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) ToOutput added in v0.76.0 

func (o ConnectorLogDeliveryPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorLogDelivery]

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

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

func (o ConnectorOutput) ToConnectorOutput() ConnectorOutput

func (ConnectorOutput) ToConnectorOutputWithContext 

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

func (ConnectorOutput) ToOutput added in v0.76.0 

func (o ConnectorOutput) ToOutput(ctx context.Context) pulumix.Output[*Connector]

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

func (ConnectorPluginArgs) ToOutput added in v0.76.0 

func (i ConnectorPluginArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorPlugin]

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

func (ConnectorPluginArray) ToOutput added in v0.76.0 

func (i ConnectorPluginArray) ToOutput(ctx context.Context) pulumix.Output[[]ConnectorPlugin]

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

func (ConnectorPluginArrayOutput) ToOutput added in v0.76.0 

func (o ConnectorPluginArrayOutput) ToOutput(ctx context.Context) pulumix.Output[[]ConnectorPlugin]

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

func (ConnectorPluginOutput) ToOutput added in v0.76.0 

func (o ConnectorPluginOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorPlugin]

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

func (ConnectorProvisionedCapacityArgs) ToOutput added in v0.76.0 

func (i ConnectorProvisionedCapacityArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorProvisionedCapacity]

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) ToOutput added in v0.76.0 

func (o ConnectorProvisionedCapacityOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorProvisionedCapacity]

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) ToOutput added in v0.76.0 

func (o ConnectorProvisionedCapacityPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorProvisionedCapacity]

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

func (ConnectorS3LogDeliveryArgs) ToOutput added in v0.76.0 

func (i ConnectorS3LogDeliveryArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorS3LogDelivery]

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

func (ConnectorS3LogDeliveryOutput) ToOutput added in v0.76.0 

func (o ConnectorS3LogDeliveryOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorS3LogDelivery]

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

func (ConnectorS3LogDeliveryPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorS3LogDeliveryPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorS3LogDelivery]

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

func (ConnectorScaleInPolicyArgs) ToOutput added in v0.76.0 

func (i ConnectorScaleInPolicyArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorScaleInPolicy]

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

func (ConnectorScaleInPolicyOutput) ToOutput added in v0.76.0 

func (o ConnectorScaleInPolicyOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorScaleInPolicy]

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

func (ConnectorScaleInPolicyPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorScaleInPolicyPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorScaleInPolicy]

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

func (ConnectorScaleOutPolicyArgs) ToOutput added in v0.76.0 

func (i ConnectorScaleOutPolicyArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorScaleOutPolicy]

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

func (ConnectorScaleOutPolicyOutput) ToOutput added in v0.76.0 

func (o ConnectorScaleOutPolicyOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorScaleOutPolicy]

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

func (ConnectorScaleOutPolicyPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorScaleOutPolicyPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorScaleOutPolicy]

type ConnectorState 

type ConnectorState struct {
}

func (ConnectorState) ElementType 

func (ConnectorState) ElementType() reflect.Type

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

func (ConnectorVpcArgs) ToOutput added in v0.76.0 

func (i ConnectorVpcArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorVpc]

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

func (ConnectorVpcOutput) ToOutput added in v0.76.0 

func (o ConnectorVpcOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorVpc]

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

func (ConnectorWorkerConfigurationArgs) ToOutput added in v0.76.0 

func (i ConnectorWorkerConfigurationArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorWorkerConfiguration]

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) ToOutput added in v0.76.0 

func (o ConnectorWorkerConfigurationOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorWorkerConfiguration]

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) ToOutput added in v0.76.0 

func (o ConnectorWorkerConfigurationPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorWorkerConfiguration]

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

func (ConnectorWorkerLogDeliveryArgs) ToOutput added in v0.76.0 

func (i ConnectorWorkerLogDeliveryArgs) ToOutput(ctx context.Context) pulumix.Output[ConnectorWorkerLogDelivery]

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

func (ConnectorWorkerLogDeliveryOutput) ToOutput added in v0.76.0 

func (o ConnectorWorkerLogDeliveryOutput) ToOutput(ctx context.Context) pulumix.Output[ConnectorWorkerLogDelivery]

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

func (ConnectorWorkerLogDeliveryPtrOutput) ToOutput added in v0.76.0 

func (o ConnectorWorkerLogDeliveryPtrOutput) ToOutput(ctx context.Context) pulumix.Output[*ConnectorWorkerLogDelivery]

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

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

func (LookupConnectorResultOutput) ToOutput added in v0.76.0 

func (o LookupConnectorResultOutput) ToOutput(ctx context.Context) pulumix.Output[LookupConnectorResult]

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.