dms

package
v5.13.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Certificate 

type Certificate struct {
	pulumi.CustomResourceState

	// The Amazon Resource Name (ARN) for the certificate.
	CertificateArn pulumi.StringOutput `pulumi:"certificateArn"`
	// The certificate identifier.
	CertificateId pulumi.StringOutput `pulumi:"certificateId"`
	// The contents of the .pem X.509 certificate file for the certificate. Either `certificatePem` or `certificateWallet` must be set.
	CertificatePem pulumi.StringPtrOutput `pulumi:"certificatePem"`
	// The contents of the Oracle Wallet certificate for use with SSL, provided as a base64-encoded String. Either `certificatePem` or `certificateWallet` must be set.
	CertificateWallet pulumi.StringPtrOutput `pulumi:"certificateWallet"`
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
}

Provides a DMS (Data Migration Service) certificate resource. DMS certificates can be created, deleted, and imported.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dms.NewCertificate(ctx, "test", &dms.CertificateArgs{
			CertificateId:  pulumi.String("test-dms-certificate-tf"),
			CertificatePem: pulumi.String("..."),
			Tags: pulumi.StringMap{
				"Name": pulumi.String("test"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Certificates can be imported using the `certificate_id`, e.g.,

```sh 

$ pulumi import aws:dms/certificate:Certificate test test-dms-certificate-tf

```

func GetCertificate 

func GetCertificate(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *CertificateState, opts ...pulumi.ResourceOption) (*Certificate, error)

GetCertificate gets an existing Certificate 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 NewCertificate 

func NewCertificate(ctx *pulumi.Context,
	name string, args *CertificateArgs, opts ...pulumi.ResourceOption) (*Certificate, error)

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

func (*Certificate) ElementType 

func (*Certificate) ElementType() reflect.Type

func (*Certificate) ToCertificateOutput 

func (i *Certificate) ToCertificateOutput() CertificateOutput

func (*Certificate) ToCertificateOutputWithContext 

func (i *Certificate) ToCertificateOutputWithContext(ctx context.Context) CertificateOutput

type CertificateArgs 

type CertificateArgs struct {
	// The certificate identifier.
	CertificateId pulumi.StringInput
	// The contents of the .pem X.509 certificate file for the certificate. Either `certificatePem` or `certificateWallet` must be set.
	CertificatePem pulumi.StringPtrInput
	// The contents of the Oracle Wallet certificate for use with SSL, provided as a base64-encoded String. Either `certificatePem` or `certificateWallet` must be set.
	CertificateWallet pulumi.StringPtrInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
}

The set of arguments for constructing a Certificate resource.

func (CertificateArgs) ElementType 

func (CertificateArgs) ElementType() reflect.Type

type CertificateArray 

type CertificateArray []CertificateInput

func (CertificateArray) ElementType 

func (CertificateArray) ElementType() reflect.Type

func (CertificateArray) ToCertificateArrayOutput 

func (i CertificateArray) ToCertificateArrayOutput() CertificateArrayOutput

func (CertificateArray) ToCertificateArrayOutputWithContext 

func (i CertificateArray) ToCertificateArrayOutputWithContext(ctx context.Context) CertificateArrayOutput

type CertificateArrayInput 

type CertificateArrayInput interface {
	pulumi.Input

	ToCertificateArrayOutput() CertificateArrayOutput
	ToCertificateArrayOutputWithContext(context.Context) CertificateArrayOutput
}

CertificateArrayInput is an input type that accepts CertificateArray and CertificateArrayOutput values. You can construct a concrete instance of `CertificateArrayInput` via: 

CertificateArray{ CertificateArgs{...} }

type CertificateArrayOutput 

type CertificateArrayOutput struct{ *pulumi.OutputState }

func (CertificateArrayOutput) ElementType 

func (CertificateArrayOutput) ElementType() reflect.Type

func (CertificateArrayOutput) Index 

func (o CertificateArrayOutput) Index(i pulumi.IntInput) CertificateOutput

func (CertificateArrayOutput) ToCertificateArrayOutput 

func (o CertificateArrayOutput) ToCertificateArrayOutput() CertificateArrayOutput

func (CertificateArrayOutput) ToCertificateArrayOutputWithContext 

func (o CertificateArrayOutput) ToCertificateArrayOutputWithContext(ctx context.Context) CertificateArrayOutput

type CertificateInput 

type CertificateInput interface {
	pulumi.Input

	ToCertificateOutput() CertificateOutput
	ToCertificateOutputWithContext(ctx context.Context) CertificateOutput
}

type CertificateMap 

type CertificateMap map[string]CertificateInput

func (CertificateMap) ElementType 

func (CertificateMap) ElementType() reflect.Type

func (CertificateMap) ToCertificateMapOutput 

func (i CertificateMap) ToCertificateMapOutput() CertificateMapOutput

func (CertificateMap) ToCertificateMapOutputWithContext 

func (i CertificateMap) ToCertificateMapOutputWithContext(ctx context.Context) CertificateMapOutput

type CertificateMapInput 

type CertificateMapInput interface {
	pulumi.Input

	ToCertificateMapOutput() CertificateMapOutput
	ToCertificateMapOutputWithContext(context.Context) CertificateMapOutput
}

CertificateMapInput is an input type that accepts CertificateMap and CertificateMapOutput values. You can construct a concrete instance of `CertificateMapInput` via: 

CertificateMap{ "key": CertificateArgs{...} }

type CertificateMapOutput 

type CertificateMapOutput struct{ *pulumi.OutputState }

func (CertificateMapOutput) ElementType 

func (CertificateMapOutput) ElementType() reflect.Type

func (CertificateMapOutput) MapIndex 

func (o CertificateMapOutput) MapIndex(k pulumi.StringInput) CertificateOutput

func (CertificateMapOutput) ToCertificateMapOutput 

func (o CertificateMapOutput) ToCertificateMapOutput() CertificateMapOutput

func (CertificateMapOutput) ToCertificateMapOutputWithContext 

func (o CertificateMapOutput) ToCertificateMapOutputWithContext(ctx context.Context) CertificateMapOutput

type CertificateOutput 

type CertificateOutput struct{ *pulumi.OutputState }

func (CertificateOutput) CertificateArn added in v5.4.0 

func (o CertificateOutput) CertificateArn() pulumi.StringOutput

The Amazon Resource Name (ARN) for the certificate.

func (CertificateOutput) CertificateId added in v5.4.0 

func (o CertificateOutput) CertificateId() pulumi.StringOutput

The certificate identifier.

func (CertificateOutput) CertificatePem added in v5.4.0 

func (o CertificateOutput) CertificatePem() pulumi.StringPtrOutput

The contents of the .pem X.509 certificate file for the certificate. Either `certificatePem` or `certificateWallet` must be set.

func (CertificateOutput) CertificateWallet added in v5.4.0 

func (o CertificateOutput) CertificateWallet() pulumi.StringPtrOutput

The contents of the Oracle Wallet certificate for use with SSL, provided as a base64-encoded String. Either `certificatePem` or `certificateWallet` must be set.

func (CertificateOutput) ElementType 

func (CertificateOutput) ElementType() reflect.Type

func (CertificateOutput) Tags added in v5.4.0 

func (o CertificateOutput) Tags() pulumi.StringMapOutput

A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (CertificateOutput) TagsAll added in v5.4.0 

func (o CertificateOutput) TagsAll() pulumi.StringMapOutput

A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (CertificateOutput) ToCertificateOutput 

func (o CertificateOutput) ToCertificateOutput() CertificateOutput

func (CertificateOutput) ToCertificateOutputWithContext 

func (o CertificateOutput) ToCertificateOutputWithContext(ctx context.Context) CertificateOutput

type CertificateState 

type CertificateState struct {
	// The Amazon Resource Name (ARN) for the certificate.
	CertificateArn pulumi.StringPtrInput
	// The certificate identifier.
	CertificateId pulumi.StringPtrInput
	// The contents of the .pem X.509 certificate file for the certificate. Either `certificatePem` or `certificateWallet` must be set.
	CertificatePem pulumi.StringPtrInput
	// The contents of the Oracle Wallet certificate for use with SSL, provided as a base64-encoded String. Either `certificatePem` or `certificateWallet` must be set.
	CertificateWallet pulumi.StringPtrInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
}

func (CertificateState) ElementType 

func (CertificateState) ElementType() reflect.Type

type Endpoint 

type Endpoint struct {
	pulumi.CustomResourceState

	// ARN for the certificate.
	CertificateArn pulumi.StringOutput `pulumi:"certificateArn"`
	// Name of the endpoint database.
	DatabaseName pulumi.StringPtrOutput `pulumi:"databaseName"`
	// Configuration block for OpenSearch settings. See below.
	ElasticsearchSettings EndpointElasticsearchSettingsPtrOutput `pulumi:"elasticsearchSettings"`
	// ARN for the endpoint.
	EndpointArn pulumi.StringOutput `pulumi:"endpointArn"`
	// Database endpoint identifier. Identifiers must contain from 1 to 255 alphanumeric characters or hyphens, begin with a letter, contain only ASCII letters, digits, and hyphens, not end with a hyphen, and not contain two consecutive hyphens.
	EndpointId pulumi.StringOutput `pulumi:"endpointId"`
	// Type of endpoint. Valid values are `source`, `target`.
	EndpointType pulumi.StringOutput `pulumi:"endpointType"`
	// Type of engine for the endpoint. Valid values are `aurora`, `aurora-postgresql`, `azuredb`, `db2`, `docdb`, `dynamodb`, `elasticsearch`, `kafka`, `kinesis`, `mariadb`, `mongodb`, `mysql`, `opensearch`, `oracle`, `postgres`, `redshift`, `s3`, `sqlserver`, `sybase`. Please note that some of engine names are available only for `target` endpoint type (e.g. `redshift`).
	EngineName pulumi.StringOutput `pulumi:"engineName"`
	// Additional attributes associated with the connection. For available attributes see [Using Extra Connection Attributes with AWS Database Migration Service](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib).
	ExtraConnectionAttributes pulumi.StringOutput `pulumi:"extraConnectionAttributes"`
	// Configuration block for Kafka settings. See below.
	KafkaSettings EndpointKafkaSettingsPtrOutput `pulumi:"kafkaSettings"`
	// Configuration block for Kinesis settings. See below.
	KinesisSettings EndpointKinesisSettingsPtrOutput `pulumi:"kinesisSettings"`
	// ARN for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.
	KmsKeyArn pulumi.StringOutput `pulumi:"kmsKeyArn"`
	// Configuration block for MongoDB settings. See below.
	MongodbSettings EndpointMongodbSettingsPtrOutput `pulumi:"mongodbSettings"`
	// Password to be used to login to the endpoint database.
	Password pulumi.StringPtrOutput `pulumi:"password"`
	// Port used by the endpoint database.
	Port pulumi.IntPtrOutput `pulumi:"port"`
	// Configuration block for Redshift settings. See below.
	RedshiftSettings EndpointRedshiftSettingsOutput `pulumi:"redshiftSettings"`
	// Configuration block for S3 settings. See below.
	S3Settings EndpointS3SettingsPtrOutput `pulumi:"s3Settings"`
	// ARN of the IAM role that specifies AWS DMS as the trusted entity and has the required permissions to access the value in SecretsManagerSecret.
	SecretsManagerAccessRoleArn pulumi.StringPtrOutput `pulumi:"secretsManagerAccessRoleArn"`
	// Full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for `engineName` as `aurora`, `aurora-postgresql`, `mariadb`, `mongodb`, `mysql`, `oracle`, `postgres`, `redshift` or `sqlserver`.
	SecretsManagerArn pulumi.StringPtrOutput `pulumi:"secretsManagerArn"`
	// Host name of the server.
	ServerName pulumi.StringPtrOutput `pulumi:"serverName"`
	// ARN used by the service access IAM role for dynamodb endpoints.
	ServiceAccessRole pulumi.StringPtrOutput `pulumi:"serviceAccessRole"`
	// SSL mode to use for the connection. Valid values are `none`, `require`, `verify-ca`, `verify-full`
	SslMode pulumi.StringOutput `pulumi:"sslMode"`
	// Map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// User name to be used to login to the endpoint database.
	Username pulumi.StringPtrOutput `pulumi:"username"`
}

Provides a DMS (Data Migration Service) endpoint resource. DMS endpoints can be created, updated, deleted, and imported.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dms.NewEndpoint(ctx, "test", &dms.EndpointArgs{
			CertificateArn:            pulumi.String("arn:aws:acm:us-east-1:123456789012:certificate/12345678-1234-1234-1234-123456789012"),
			DatabaseName:              pulumi.String("test"),
			EndpointId:                pulumi.String("test-dms-endpoint-tf"),
			EndpointType:              pulumi.String("source"),
			EngineName:                pulumi.String("aurora"),
			ExtraConnectionAttributes: pulumi.String(""),
			KmsKeyArn:                 pulumi.String("arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012"),
			Password:                  pulumi.String("test"),
			Port:                      pulumi.Int(3306),
			ServerName:                pulumi.String("test"),
			SslMode:                   pulumi.String("none"),
			Tags: pulumi.StringMap{
				"Name": pulumi.String("test"),
			},
			Username: pulumi.String("test"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Endpoints can be imported using the `endpoint_id`, e.g.,

```sh 

$ pulumi import aws:dms/endpoint:Endpoint test test-dms-endpoint-tf

```

func GetEndpoint 

func GetEndpoint(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *EndpointState, opts ...pulumi.ResourceOption) (*Endpoint, error)

GetEndpoint gets an existing Endpoint 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 NewEndpoint 

func NewEndpoint(ctx *pulumi.Context,
	name string, args *EndpointArgs, opts ...pulumi.ResourceOption) (*Endpoint, error)

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

func (*Endpoint) ElementType 

func (*Endpoint) ElementType() reflect.Type

func (*Endpoint) ToEndpointOutput 

func (i *Endpoint) ToEndpointOutput() EndpointOutput

func (*Endpoint) ToEndpointOutputWithContext 

func (i *Endpoint) ToEndpointOutputWithContext(ctx context.Context) EndpointOutput

type EndpointArgs 

type EndpointArgs struct {
	// ARN for the certificate.
	CertificateArn pulumi.StringPtrInput
	// Name of the endpoint database.
	DatabaseName pulumi.StringPtrInput
	// Configuration block for OpenSearch settings. See below.
	ElasticsearchSettings EndpointElasticsearchSettingsPtrInput
	// Database endpoint identifier. Identifiers must contain from 1 to 255 alphanumeric characters or hyphens, begin with a letter, contain only ASCII letters, digits, and hyphens, not end with a hyphen, and not contain two consecutive hyphens.
	EndpointId pulumi.StringInput
	// Type of endpoint. Valid values are `source`, `target`.
	EndpointType pulumi.StringInput
	// Type of engine for the endpoint. Valid values are `aurora`, `aurora-postgresql`, `azuredb`, `db2`, `docdb`, `dynamodb`, `elasticsearch`, `kafka`, `kinesis`, `mariadb`, `mongodb`, `mysql`, `opensearch`, `oracle`, `postgres`, `redshift`, `s3`, `sqlserver`, `sybase`. Please note that some of engine names are available only for `target` endpoint type (e.g. `redshift`).
	EngineName pulumi.StringInput
	// Additional attributes associated with the connection. For available attributes see [Using Extra Connection Attributes with AWS Database Migration Service](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib).
	ExtraConnectionAttributes pulumi.StringPtrInput
	// Configuration block for Kafka settings. See below.
	KafkaSettings EndpointKafkaSettingsPtrInput
	// Configuration block for Kinesis settings. See below.
	KinesisSettings EndpointKinesisSettingsPtrInput
	// ARN for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.
	KmsKeyArn pulumi.StringPtrInput
	// Configuration block for MongoDB settings. See below.
	MongodbSettings EndpointMongodbSettingsPtrInput
	// Password to be used to login to the endpoint database.
	Password pulumi.StringPtrInput
	// Port used by the endpoint database.
	Port pulumi.IntPtrInput
	// Configuration block for Redshift settings. See below.
	RedshiftSettings EndpointRedshiftSettingsPtrInput
	// Configuration block for S3 settings. See below.
	S3Settings EndpointS3SettingsPtrInput
	// ARN of the IAM role that specifies AWS DMS as the trusted entity and has the required permissions to access the value in SecretsManagerSecret.
	SecretsManagerAccessRoleArn pulumi.StringPtrInput
	// Full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for `engineName` as `aurora`, `aurora-postgresql`, `mariadb`, `mongodb`, `mysql`, `oracle`, `postgres`, `redshift` or `sqlserver`.
	SecretsManagerArn pulumi.StringPtrInput
	// Host name of the server.
	ServerName pulumi.StringPtrInput
	// ARN used by the service access IAM role for dynamodb endpoints.
	ServiceAccessRole pulumi.StringPtrInput
	// SSL mode to use for the connection. Valid values are `none`, `require`, `verify-ca`, `verify-full`
	SslMode pulumi.StringPtrInput
	// Map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// User name to be used to login to the endpoint database.
	Username pulumi.StringPtrInput
}

The set of arguments for constructing a Endpoint resource.

func (EndpointArgs) ElementType 

func (EndpointArgs) ElementType() reflect.Type

type EndpointArray 

type EndpointArray []EndpointInput

func (EndpointArray) ElementType 

func (EndpointArray) ElementType() reflect.Type

func (EndpointArray) ToEndpointArrayOutput 

func (i EndpointArray) ToEndpointArrayOutput() EndpointArrayOutput

func (EndpointArray) ToEndpointArrayOutputWithContext 

func (i EndpointArray) ToEndpointArrayOutputWithContext(ctx context.Context) EndpointArrayOutput

type EndpointArrayInput 

type EndpointArrayInput interface {
	pulumi.Input

	ToEndpointArrayOutput() EndpointArrayOutput
	ToEndpointArrayOutputWithContext(context.Context) EndpointArrayOutput
}

EndpointArrayInput is an input type that accepts EndpointArray and EndpointArrayOutput values. You can construct a concrete instance of `EndpointArrayInput` via: 

EndpointArray{ EndpointArgs{...} }

type EndpointArrayOutput 

type EndpointArrayOutput struct{ *pulumi.OutputState }

func (EndpointArrayOutput) ElementType 

func (EndpointArrayOutput) ElementType() reflect.Type

func (EndpointArrayOutput) Index 

func (o EndpointArrayOutput) Index(i pulumi.IntInput) EndpointOutput

func (EndpointArrayOutput) ToEndpointArrayOutput 

func (o EndpointArrayOutput) ToEndpointArrayOutput() EndpointArrayOutput

func (EndpointArrayOutput) ToEndpointArrayOutputWithContext 

func (o EndpointArrayOutput) ToEndpointArrayOutputWithContext(ctx context.Context) EndpointArrayOutput

type EndpointElasticsearchSettings 

type EndpointElasticsearchSettings struct {
	// Endpoint for the OpenSearch cluster.
	EndpointUri string `pulumi:"endpointUri"`
	// Maximum number of seconds for which DMS retries failed API requests to the OpenSearch cluster. Default is `300`.
	ErrorRetryDuration *int `pulumi:"errorRetryDuration"`
	// Maximum percentage of records that can fail to be written before a full load operation stops. Default is `10`.
	FullLoadErrorPercentage *int `pulumi:"fullLoadErrorPercentage"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn string `pulumi:"serviceAccessRoleArn"`
}

type EndpointElasticsearchSettingsArgs 

type EndpointElasticsearchSettingsArgs struct {
	// Endpoint for the OpenSearch cluster.
	EndpointUri pulumi.StringInput `pulumi:"endpointUri"`
	// Maximum number of seconds for which DMS retries failed API requests to the OpenSearch cluster. Default is `300`.
	ErrorRetryDuration pulumi.IntPtrInput `pulumi:"errorRetryDuration"`
	// Maximum percentage of records that can fail to be written before a full load operation stops. Default is `10`.
	FullLoadErrorPercentage pulumi.IntPtrInput `pulumi:"fullLoadErrorPercentage"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn pulumi.StringInput `pulumi:"serviceAccessRoleArn"`
}

func (EndpointElasticsearchSettingsArgs) ElementType 

func (EndpointElasticsearchSettingsArgs) ElementType() reflect.Type

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsOutput 

func (i EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsOutput() EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsOutputWithContext 

func (i EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsOutputWithContext(ctx context.Context) EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsPtrOutput 

func (i EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsPtrOutput() EndpointElasticsearchSettingsPtrOutput

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsPtrOutputWithContext 

func (i EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsPtrOutputWithContext(ctx context.Context) EndpointElasticsearchSettingsPtrOutput

type EndpointElasticsearchSettingsInput 

type EndpointElasticsearchSettingsInput interface {
	pulumi.Input

	ToEndpointElasticsearchSettingsOutput() EndpointElasticsearchSettingsOutput
	ToEndpointElasticsearchSettingsOutputWithContext(context.Context) EndpointElasticsearchSettingsOutput
}

EndpointElasticsearchSettingsInput is an input type that accepts EndpointElasticsearchSettingsArgs and EndpointElasticsearchSettingsOutput values. You can construct a concrete instance of `EndpointElasticsearchSettingsInput` via: 

EndpointElasticsearchSettingsArgs{...}

type EndpointElasticsearchSettingsOutput 

type EndpointElasticsearchSettingsOutput struct{ *pulumi.OutputState }

func (EndpointElasticsearchSettingsOutput) ElementType 

func (EndpointElasticsearchSettingsOutput) ElementType() reflect.Type

func (EndpointElasticsearchSettingsOutput) EndpointUri 

func (o EndpointElasticsearchSettingsOutput) EndpointUri() pulumi.StringOutput

Endpoint for the OpenSearch cluster.

func (EndpointElasticsearchSettingsOutput) ErrorRetryDuration 

func (o EndpointElasticsearchSettingsOutput) ErrorRetryDuration() pulumi.IntPtrOutput

Maximum number of seconds for which DMS retries failed API requests to the OpenSearch cluster. Default is `300`.

func (EndpointElasticsearchSettingsOutput) FullLoadErrorPercentage 

func (o EndpointElasticsearchSettingsOutput) FullLoadErrorPercentage() pulumi.IntPtrOutput

Maximum percentage of records that can fail to be written before a full load operation stops. Default is `10`.

func (EndpointElasticsearchSettingsOutput) ServiceAccessRoleArn 

func (o EndpointElasticsearchSettingsOutput) ServiceAccessRoleArn() pulumi.StringOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsOutput 

func (o EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsOutput() EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsOutputWithContext 

func (o EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsOutputWithContext(ctx context.Context) EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsPtrOutput 

func (o EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsPtrOutput() EndpointElasticsearchSettingsPtrOutput

func (EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsPtrOutputWithContext 

func (o EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsPtrOutputWithContext(ctx context.Context) EndpointElasticsearchSettingsPtrOutput

type EndpointElasticsearchSettingsPtrInput 

type EndpointElasticsearchSettingsPtrInput interface {
	pulumi.Input

	ToEndpointElasticsearchSettingsPtrOutput() EndpointElasticsearchSettingsPtrOutput
	ToEndpointElasticsearchSettingsPtrOutputWithContext(context.Context) EndpointElasticsearchSettingsPtrOutput
}

EndpointElasticsearchSettingsPtrInput is an input type that accepts EndpointElasticsearchSettingsArgs, EndpointElasticsearchSettingsPtr and EndpointElasticsearchSettingsPtrOutput values. You can construct a concrete instance of `EndpointElasticsearchSettingsPtrInput` via: 

        EndpointElasticsearchSettingsArgs{...}

or:

        nil

func EndpointElasticsearchSettingsPtr 

func EndpointElasticsearchSettingsPtr(v *EndpointElasticsearchSettingsArgs) EndpointElasticsearchSettingsPtrInput

type EndpointElasticsearchSettingsPtrOutput 

type EndpointElasticsearchSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointElasticsearchSettingsPtrOutput) Elem 

func (o EndpointElasticsearchSettingsPtrOutput) Elem() EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsPtrOutput) ElementType 

func (EndpointElasticsearchSettingsPtrOutput) ElementType() reflect.Type

func (EndpointElasticsearchSettingsPtrOutput) EndpointUri 

func (o EndpointElasticsearchSettingsPtrOutput) EndpointUri() pulumi.StringPtrOutput

Endpoint for the OpenSearch cluster.

func (EndpointElasticsearchSettingsPtrOutput) ErrorRetryDuration 

func (o EndpointElasticsearchSettingsPtrOutput) ErrorRetryDuration() pulumi.IntPtrOutput

Maximum number of seconds for which DMS retries failed API requests to the OpenSearch cluster. Default is `300`.

func (EndpointElasticsearchSettingsPtrOutput) FullLoadErrorPercentage 

func (o EndpointElasticsearchSettingsPtrOutput) FullLoadErrorPercentage() pulumi.IntPtrOutput

Maximum percentage of records that can fail to be written before a full load operation stops. Default is `10`.

func (EndpointElasticsearchSettingsPtrOutput) ServiceAccessRoleArn 

func (o EndpointElasticsearchSettingsPtrOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointElasticsearchSettingsPtrOutput) ToEndpointElasticsearchSettingsPtrOutput 

func (o EndpointElasticsearchSettingsPtrOutput) ToEndpointElasticsearchSettingsPtrOutput() EndpointElasticsearchSettingsPtrOutput

func (EndpointElasticsearchSettingsPtrOutput) ToEndpointElasticsearchSettingsPtrOutputWithContext 

func (o EndpointElasticsearchSettingsPtrOutput) ToEndpointElasticsearchSettingsPtrOutputWithContext(ctx context.Context) EndpointElasticsearchSettingsPtrOutput

type EndpointInput 

type EndpointInput interface {
	pulumi.Input

	ToEndpointOutput() EndpointOutput
	ToEndpointOutputWithContext(ctx context.Context) EndpointOutput
}

type EndpointKafkaSettings 

type EndpointKafkaSettings struct {
	// Kafka broker location. Specify in the form broker-hostname-or-ip:port.
	Broker string `pulumi:"broker"`
	// Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.
	IncludeControlDetails *bool `pulumi:"includeControlDetails"`
	// Include NULL and empty columns in the target. Default is `false`.
	IncludeNullAndEmpty *bool `pulumi:"includeNullAndEmpty"`
	// Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.
	IncludePartitionValue *bool `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.
	IncludeTableAlterOperations *bool `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. Default is `false`.
	IncludeTransactionDetails *bool `pulumi:"includeTransactionDetails"`
	// Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).
	MessageFormat *string `pulumi:"messageFormat"`
	// Maximum size in bytes for records created on the endpoint Default is `1,000,000`.
	MessageMaxBytes *int `pulumi:"messageMaxBytes"`
	// Set this optional parameter to true to avoid adding a '0x' prefix to raw data in hexadecimal format. For example, by default, AWS DMS adds a '0x' prefix to the LOB column type in hexadecimal format moving from an Oracle source to a Kafka target. Use the `noHexPrefix` endpoint setting to enable migration of RAW data type columns without adding the `'0x'` prefix.
	NoHexPrefix *bool `pulumi:"noHexPrefix"`
	// Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.
	PartitionIncludeSchemaTable *bool `pulumi:"partitionIncludeSchemaTable"`
	// Secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
	SaslPassword *string `pulumi:"saslPassword"`
	// Secure user name you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
	SaslUsername *string `pulumi:"saslUsername"`
	// Set secure connection to a Kafka target endpoint using Transport Layer Security (TLS). Options include `ssl-encryption`, `ssl-authentication`, and `sasl-ssl`. `sasl-ssl` requires `saslUsername` and `saslPassword`.
	SecurityProtocol *string `pulumi:"securityProtocol"`
	// ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.
	SslCaCertificateArn *string `pulumi:"sslCaCertificateArn"`
	// ARN of the client certificate used to securely connect to a Kafka target endpoint.
	SslClientCertificateArn *string `pulumi:"sslClientCertificateArn"`
	// ARN for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyArn *string `pulumi:"sslClientKeyArn"`
	// Password for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyPassword *string `pulumi:"sslClientKeyPassword"`
	// Kafka topic for migration. Default is `kafka-default-topic`.
	Topic *string `pulumi:"topic"`
}

type EndpointKafkaSettingsArgs 

type EndpointKafkaSettingsArgs struct {
	// Kafka broker location. Specify in the form broker-hostname-or-ip:port.
	Broker pulumi.StringInput `pulumi:"broker"`
	// Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.
	IncludeControlDetails pulumi.BoolPtrInput `pulumi:"includeControlDetails"`
	// Include NULL and empty columns in the target. Default is `false`.
	IncludeNullAndEmpty pulumi.BoolPtrInput `pulumi:"includeNullAndEmpty"`
	// Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.
	IncludePartitionValue pulumi.BoolPtrInput `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.
	IncludeTableAlterOperations pulumi.BoolPtrInput `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. Default is `false`.
	IncludeTransactionDetails pulumi.BoolPtrInput `pulumi:"includeTransactionDetails"`
	// Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).
	MessageFormat pulumi.StringPtrInput `pulumi:"messageFormat"`
	// Maximum size in bytes for records created on the endpoint Default is `1,000,000`.
	MessageMaxBytes pulumi.IntPtrInput `pulumi:"messageMaxBytes"`
	// Set this optional parameter to true to avoid adding a '0x' prefix to raw data in hexadecimal format. For example, by default, AWS DMS adds a '0x' prefix to the LOB column type in hexadecimal format moving from an Oracle source to a Kafka target. Use the `noHexPrefix` endpoint setting to enable migration of RAW data type columns without adding the `'0x'` prefix.
	NoHexPrefix pulumi.BoolPtrInput `pulumi:"noHexPrefix"`
	// Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.
	PartitionIncludeSchemaTable pulumi.BoolPtrInput `pulumi:"partitionIncludeSchemaTable"`
	// Secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
	SaslPassword pulumi.StringPtrInput `pulumi:"saslPassword"`
	// Secure user name you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.
	SaslUsername pulumi.StringPtrInput `pulumi:"saslUsername"`
	// Set secure connection to a Kafka target endpoint using Transport Layer Security (TLS). Options include `ssl-encryption`, `ssl-authentication`, and `sasl-ssl`. `sasl-ssl` requires `saslUsername` and `saslPassword`.
	SecurityProtocol pulumi.StringPtrInput `pulumi:"securityProtocol"`
	// ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.
	SslCaCertificateArn pulumi.StringPtrInput `pulumi:"sslCaCertificateArn"`
	// ARN of the client certificate used to securely connect to a Kafka target endpoint.
	SslClientCertificateArn pulumi.StringPtrInput `pulumi:"sslClientCertificateArn"`
	// ARN for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyArn pulumi.StringPtrInput `pulumi:"sslClientKeyArn"`
	// Password for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyPassword pulumi.StringPtrInput `pulumi:"sslClientKeyPassword"`
	// Kafka topic for migration. Default is `kafka-default-topic`.
	Topic pulumi.StringPtrInput `pulumi:"topic"`
}

func (EndpointKafkaSettingsArgs) ElementType 

func (EndpointKafkaSettingsArgs) ElementType() reflect.Type

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsOutput 

func (i EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsOutput() EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsOutputWithContext 

func (i EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsOutputWithContext(ctx context.Context) EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsPtrOutput 

func (i EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsPtrOutput() EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsPtrOutputWithContext 

func (i EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsPtrOutputWithContext(ctx context.Context) EndpointKafkaSettingsPtrOutput

type EndpointKafkaSettingsInput 

type EndpointKafkaSettingsInput interface {
	pulumi.Input

	ToEndpointKafkaSettingsOutput() EndpointKafkaSettingsOutput
	ToEndpointKafkaSettingsOutputWithContext(context.Context) EndpointKafkaSettingsOutput
}

EndpointKafkaSettingsInput is an input type that accepts EndpointKafkaSettingsArgs and EndpointKafkaSettingsOutput values. You can construct a concrete instance of `EndpointKafkaSettingsInput` via: 

EndpointKafkaSettingsArgs{...}

type EndpointKafkaSettingsOutput 

type EndpointKafkaSettingsOutput struct{ *pulumi.OutputState }

func (EndpointKafkaSettingsOutput) Broker 

func (o EndpointKafkaSettingsOutput) Broker() pulumi.StringOutput

Kafka broker location. Specify in the form broker-hostname-or-ip:port.

func (EndpointKafkaSettingsOutput) ElementType 

func (EndpointKafkaSettingsOutput) ElementType() reflect.Type

func (EndpointKafkaSettingsOutput) IncludeControlDetails 

func (o EndpointKafkaSettingsOutput) IncludeControlDetails() pulumi.BoolPtrOutput

Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.

func (EndpointKafkaSettingsOutput) IncludeNullAndEmpty 

func (o EndpointKafkaSettingsOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

Include NULL and empty columns in the target. Default is `false`.

func (EndpointKafkaSettingsOutput) IncludePartitionValue 

func (o EndpointKafkaSettingsOutput) IncludePartitionValue() pulumi.BoolPtrOutput

Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.

func (EndpointKafkaSettingsOutput) IncludeTableAlterOperations 

func (o EndpointKafkaSettingsOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.

func (EndpointKafkaSettingsOutput) IncludeTransactionDetails 

func (o EndpointKafkaSettingsOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

Provides detailed transaction information from the source database. Default is `false`.

func (EndpointKafkaSettingsOutput) MessageFormat 

func (o EndpointKafkaSettingsOutput) MessageFormat() pulumi.StringPtrOutput

Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).

func (EndpointKafkaSettingsOutput) MessageMaxBytes 

func (o EndpointKafkaSettingsOutput) MessageMaxBytes() pulumi.IntPtrOutput

Maximum size in bytes for records created on the endpoint Default is `1,000,000`.

func (EndpointKafkaSettingsOutput) NoHexPrefix 

func (o EndpointKafkaSettingsOutput) NoHexPrefix() pulumi.BoolPtrOutput

Set this optional parameter to true to avoid adding a '0x' prefix to raw data in hexadecimal format. For example, by default, AWS DMS adds a '0x' prefix to the LOB column type in hexadecimal format moving from an Oracle source to a Kafka target. Use the `noHexPrefix` endpoint setting to enable migration of RAW data type columns without adding the `'0x'` prefix.

func (EndpointKafkaSettingsOutput) PartitionIncludeSchemaTable 

func (o EndpointKafkaSettingsOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.

func (EndpointKafkaSettingsOutput) SaslPassword 

func (o EndpointKafkaSettingsOutput) SaslPassword() pulumi.StringPtrOutput

Secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.

func (EndpointKafkaSettingsOutput) SaslUsername 

func (o EndpointKafkaSettingsOutput) SaslUsername() pulumi.StringPtrOutput

Secure user name you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.

func (EndpointKafkaSettingsOutput) SecurityProtocol 

func (o EndpointKafkaSettingsOutput) SecurityProtocol() pulumi.StringPtrOutput

Set secure connection to a Kafka target endpoint using Transport Layer Security (TLS). Options include `ssl-encryption`, `ssl-authentication`, and `sasl-ssl`. `sasl-ssl` requires `saslUsername` and `saslPassword`.

func (EndpointKafkaSettingsOutput) SslCaCertificateArn 

func (o EndpointKafkaSettingsOutput) SslCaCertificateArn() pulumi.StringPtrOutput

ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.

func (EndpointKafkaSettingsOutput) SslClientCertificateArn 

func (o EndpointKafkaSettingsOutput) SslClientCertificateArn() pulumi.StringPtrOutput

ARN of the client certificate used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsOutput) SslClientKeyArn 

func (o EndpointKafkaSettingsOutput) SslClientKeyArn() pulumi.StringPtrOutput

ARN for the client private key used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsOutput) SslClientKeyPassword 

func (o EndpointKafkaSettingsOutput) SslClientKeyPassword() pulumi.StringPtrOutput

Password for the client private key used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsOutput 

func (o EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsOutput() EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsOutputWithContext 

func (o EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsOutputWithContext(ctx context.Context) EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsPtrOutput 

func (o EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsPtrOutput() EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsPtrOutputWithContext 

func (o EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsPtrOutputWithContext(ctx context.Context) EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsOutput) Topic 

func (o EndpointKafkaSettingsOutput) Topic() pulumi.StringPtrOutput

Kafka topic for migration. Default is `kafka-default-topic`.

type EndpointKafkaSettingsPtrInput 

type EndpointKafkaSettingsPtrInput interface {
	pulumi.Input

	ToEndpointKafkaSettingsPtrOutput() EndpointKafkaSettingsPtrOutput
	ToEndpointKafkaSettingsPtrOutputWithContext(context.Context) EndpointKafkaSettingsPtrOutput
}

EndpointKafkaSettingsPtrInput is an input type that accepts EndpointKafkaSettingsArgs, EndpointKafkaSettingsPtr and EndpointKafkaSettingsPtrOutput values. You can construct a concrete instance of `EndpointKafkaSettingsPtrInput` via: 

        EndpointKafkaSettingsArgs{...}

or:

        nil

func EndpointKafkaSettingsPtr 

func EndpointKafkaSettingsPtr(v *EndpointKafkaSettingsArgs) EndpointKafkaSettingsPtrInput

type EndpointKafkaSettingsPtrOutput 

type EndpointKafkaSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointKafkaSettingsPtrOutput) Broker 

func (o EndpointKafkaSettingsPtrOutput) Broker() pulumi.StringPtrOutput

Kafka broker location. Specify in the form broker-hostname-or-ip:port.

func (EndpointKafkaSettingsPtrOutput) Elem 

func (o EndpointKafkaSettingsPtrOutput) Elem() EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsPtrOutput) ElementType 

func (EndpointKafkaSettingsPtrOutput) ElementType() reflect.Type

func (EndpointKafkaSettingsPtrOutput) IncludeControlDetails 

func (o EndpointKafkaSettingsPtrOutput) IncludeControlDetails() pulumi.BoolPtrOutput

Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludeNullAndEmpty 

func (o EndpointKafkaSettingsPtrOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

Include NULL and empty columns in the target. Default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludePartitionValue 

func (o EndpointKafkaSettingsPtrOutput) IncludePartitionValue() pulumi.BoolPtrOutput

Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludeTableAlterOperations 

func (o EndpointKafkaSettingsPtrOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludeTransactionDetails 

func (o EndpointKafkaSettingsPtrOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

Provides detailed transaction information from the source database. Default is `false`.

func (EndpointKafkaSettingsPtrOutput) MessageFormat 

func (o EndpointKafkaSettingsPtrOutput) MessageFormat() pulumi.StringPtrOutput

Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).

func (EndpointKafkaSettingsPtrOutput) MessageMaxBytes 

func (o EndpointKafkaSettingsPtrOutput) MessageMaxBytes() pulumi.IntPtrOutput

Maximum size in bytes for records created on the endpoint Default is `1,000,000`.

func (EndpointKafkaSettingsPtrOutput) NoHexPrefix 

func (o EndpointKafkaSettingsPtrOutput) NoHexPrefix() pulumi.BoolPtrOutput

Set this optional parameter to true to avoid adding a '0x' prefix to raw data in hexadecimal format. For example, by default, AWS DMS adds a '0x' prefix to the LOB column type in hexadecimal format moving from an Oracle source to a Kafka target. Use the `noHexPrefix` endpoint setting to enable migration of RAW data type columns without adding the `'0x'` prefix.

func (EndpointKafkaSettingsPtrOutput) PartitionIncludeSchemaTable 

func (o EndpointKafkaSettingsPtrOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.

func (EndpointKafkaSettingsPtrOutput) SaslPassword 

func (o EndpointKafkaSettingsPtrOutput) SaslPassword() pulumi.StringPtrOutput

Secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.

func (EndpointKafkaSettingsPtrOutput) SaslUsername 

func (o EndpointKafkaSettingsPtrOutput) SaslUsername() pulumi.StringPtrOutput

Secure user name you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication.

func (EndpointKafkaSettingsPtrOutput) SecurityProtocol 

func (o EndpointKafkaSettingsPtrOutput) SecurityProtocol() pulumi.StringPtrOutput

Set secure connection to a Kafka target endpoint using Transport Layer Security (TLS). Options include `ssl-encryption`, `ssl-authentication`, and `sasl-ssl`. `sasl-ssl` requires `saslUsername` and `saslPassword`.

func (EndpointKafkaSettingsPtrOutput) SslCaCertificateArn 

func (o EndpointKafkaSettingsPtrOutput) SslCaCertificateArn() pulumi.StringPtrOutput

ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.

func (EndpointKafkaSettingsPtrOutput) SslClientCertificateArn 

func (o EndpointKafkaSettingsPtrOutput) SslClientCertificateArn() pulumi.StringPtrOutput

ARN of the client certificate used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsPtrOutput) SslClientKeyArn 

func (o EndpointKafkaSettingsPtrOutput) SslClientKeyArn() pulumi.StringPtrOutput

ARN for the client private key used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsPtrOutput) SslClientKeyPassword 

func (o EndpointKafkaSettingsPtrOutput) SslClientKeyPassword() pulumi.StringPtrOutput

Password for the client private key used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsPtrOutput) ToEndpointKafkaSettingsPtrOutput 

func (o EndpointKafkaSettingsPtrOutput) ToEndpointKafkaSettingsPtrOutput() EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsPtrOutput) ToEndpointKafkaSettingsPtrOutputWithContext 

func (o EndpointKafkaSettingsPtrOutput) ToEndpointKafkaSettingsPtrOutputWithContext(ctx context.Context) EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsPtrOutput) Topic 

func (o EndpointKafkaSettingsPtrOutput) Topic() pulumi.StringPtrOutput

Kafka topic for migration. Default is `kafka-default-topic`.

type EndpointKinesisSettings 

type EndpointKinesisSettings struct {
	// Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.
	IncludeControlDetails *bool `pulumi:"includeControlDetails"`
	// Include NULL and empty columns in the target. Default is `false`.
	IncludeNullAndEmpty *bool `pulumi:"includeNullAndEmpty"`
	// Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.
	IncludePartitionValue *bool `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.
	IncludeTableAlterOperations *bool `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. Default is `false`.
	IncludeTransactionDetails *bool `pulumi:"includeTransactionDetails"`
	// Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).
	MessageFormat *string `pulumi:"messageFormat"`
	// Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.
	PartitionIncludeSchemaTable *bool `pulumi:"partitionIncludeSchemaTable"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn *string `pulumi:"serviceAccessRoleArn"`
	// ARN of the Kinesis data stream.
	StreamArn *string `pulumi:"streamArn"`
}

type EndpointKinesisSettingsArgs 

type EndpointKinesisSettingsArgs struct {
	// Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.
	IncludeControlDetails pulumi.BoolPtrInput `pulumi:"includeControlDetails"`
	// Include NULL and empty columns in the target. Default is `false`.
	IncludeNullAndEmpty pulumi.BoolPtrInput `pulumi:"includeNullAndEmpty"`
	// Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.
	IncludePartitionValue pulumi.BoolPtrInput `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.
	IncludeTableAlterOperations pulumi.BoolPtrInput `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. Default is `false`.
	IncludeTransactionDetails pulumi.BoolPtrInput `pulumi:"includeTransactionDetails"`
	// Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).
	MessageFormat pulumi.StringPtrInput `pulumi:"messageFormat"`
	// Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.
	PartitionIncludeSchemaTable pulumi.BoolPtrInput `pulumi:"partitionIncludeSchemaTable"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn pulumi.StringPtrInput `pulumi:"serviceAccessRoleArn"`
	// ARN of the Kinesis data stream.
	StreamArn pulumi.StringPtrInput `pulumi:"streamArn"`
}

func (EndpointKinesisSettingsArgs) ElementType 

func (EndpointKinesisSettingsArgs) ElementType() reflect.Type

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsOutput 

func (i EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsOutput() EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsOutputWithContext 

func (i EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsOutputWithContext(ctx context.Context) EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsPtrOutput 

func (i EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsPtrOutput() EndpointKinesisSettingsPtrOutput

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsPtrOutputWithContext 

func (i EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsPtrOutputWithContext(ctx context.Context) EndpointKinesisSettingsPtrOutput

type EndpointKinesisSettingsInput 

type EndpointKinesisSettingsInput interface {
	pulumi.Input

	ToEndpointKinesisSettingsOutput() EndpointKinesisSettingsOutput
	ToEndpointKinesisSettingsOutputWithContext(context.Context) EndpointKinesisSettingsOutput
}

EndpointKinesisSettingsInput is an input type that accepts EndpointKinesisSettingsArgs and EndpointKinesisSettingsOutput values. You can construct a concrete instance of `EndpointKinesisSettingsInput` via: 

EndpointKinesisSettingsArgs{...}

type EndpointKinesisSettingsOutput 

type EndpointKinesisSettingsOutput struct{ *pulumi.OutputState }

func (EndpointKinesisSettingsOutput) ElementType 

func (EndpointKinesisSettingsOutput) ElementType() reflect.Type

func (EndpointKinesisSettingsOutput) IncludeControlDetails 

func (o EndpointKinesisSettingsOutput) IncludeControlDetails() pulumi.BoolPtrOutput

Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.

func (EndpointKinesisSettingsOutput) IncludeNullAndEmpty 

func (o EndpointKinesisSettingsOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

Include NULL and empty columns in the target. Default is `false`.

func (EndpointKinesisSettingsOutput) IncludePartitionValue 

func (o EndpointKinesisSettingsOutput) IncludePartitionValue() pulumi.BoolPtrOutput

Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.

func (EndpointKinesisSettingsOutput) IncludeTableAlterOperations 

func (o EndpointKinesisSettingsOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.

func (EndpointKinesisSettingsOutput) IncludeTransactionDetails 

func (o EndpointKinesisSettingsOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

Provides detailed transaction information from the source database. Default is `false`.

func (EndpointKinesisSettingsOutput) MessageFormat 

func (o EndpointKinesisSettingsOutput) MessageFormat() pulumi.StringPtrOutput

Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).

func (EndpointKinesisSettingsOutput) PartitionIncludeSchemaTable 

func (o EndpointKinesisSettingsOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.

func (EndpointKinesisSettingsOutput) ServiceAccessRoleArn 

func (o EndpointKinesisSettingsOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointKinesisSettingsOutput) StreamArn 

func (o EndpointKinesisSettingsOutput) StreamArn() pulumi.StringPtrOutput

ARN of the Kinesis data stream.

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsOutput 

func (o EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsOutput() EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsOutputWithContext 

func (o EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsOutputWithContext(ctx context.Context) EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsPtrOutput 

func (o EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsPtrOutput() EndpointKinesisSettingsPtrOutput

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsPtrOutputWithContext 

func (o EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsPtrOutputWithContext(ctx context.Context) EndpointKinesisSettingsPtrOutput

type EndpointKinesisSettingsPtrInput 

type EndpointKinesisSettingsPtrInput interface {
	pulumi.Input

	ToEndpointKinesisSettingsPtrOutput() EndpointKinesisSettingsPtrOutput
	ToEndpointKinesisSettingsPtrOutputWithContext(context.Context) EndpointKinesisSettingsPtrOutput
}

EndpointKinesisSettingsPtrInput is an input type that accepts EndpointKinesisSettingsArgs, EndpointKinesisSettingsPtr and EndpointKinesisSettingsPtrOutput values. You can construct a concrete instance of `EndpointKinesisSettingsPtrInput` via: 

        EndpointKinesisSettingsArgs{...}

or:

        nil

func EndpointKinesisSettingsPtr 

func EndpointKinesisSettingsPtr(v *EndpointKinesisSettingsArgs) EndpointKinesisSettingsPtrInput

type EndpointKinesisSettingsPtrOutput 

type EndpointKinesisSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointKinesisSettingsPtrOutput) Elem 

func (o EndpointKinesisSettingsPtrOutput) Elem() EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsPtrOutput) ElementType 

func (EndpointKinesisSettingsPtrOutput) ElementType() reflect.Type

func (EndpointKinesisSettingsPtrOutput) IncludeControlDetails 

func (o EndpointKinesisSettingsPtrOutput) IncludeControlDetails() pulumi.BoolPtrOutput

Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is `false`.

func (EndpointKinesisSettingsPtrOutput) IncludeNullAndEmpty 

func (o EndpointKinesisSettingsPtrOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

Include NULL and empty columns in the target. Default is `false`.

func (EndpointKinesisSettingsPtrOutput) IncludePartitionValue 

func (o EndpointKinesisSettingsPtrOutput) IncludePartitionValue() pulumi.BoolPtrOutput

Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is `false`.

func (EndpointKinesisSettingsPtrOutput) IncludeTableAlterOperations 

func (o EndpointKinesisSettingsPtrOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

Includes any data definition language (DDL) operations that change the table in the control data. Default is `false`.

func (EndpointKinesisSettingsPtrOutput) IncludeTransactionDetails 

func (o EndpointKinesisSettingsPtrOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

Provides detailed transaction information from the source database. Default is `false`.

func (EndpointKinesisSettingsPtrOutput) MessageFormat 

func (o EndpointKinesisSettingsPtrOutput) MessageFormat() pulumi.StringPtrOutput

Output format for the records created. Default is `json`. Valid values are `json` and `json-unformatted` (a single line with no tab).

func (EndpointKinesisSettingsPtrOutput) PartitionIncludeSchemaTable 

func (o EndpointKinesisSettingsPtrOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is `false`.

func (EndpointKinesisSettingsPtrOutput) ServiceAccessRoleArn 

func (o EndpointKinesisSettingsPtrOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointKinesisSettingsPtrOutput) StreamArn 

func (o EndpointKinesisSettingsPtrOutput) StreamArn() pulumi.StringPtrOutput

ARN of the Kinesis data stream.

func (EndpointKinesisSettingsPtrOutput) ToEndpointKinesisSettingsPtrOutput 

func (o EndpointKinesisSettingsPtrOutput) ToEndpointKinesisSettingsPtrOutput() EndpointKinesisSettingsPtrOutput

func (EndpointKinesisSettingsPtrOutput) ToEndpointKinesisSettingsPtrOutputWithContext 

func (o EndpointKinesisSettingsPtrOutput) ToEndpointKinesisSettingsPtrOutputWithContext(ctx context.Context) EndpointKinesisSettingsPtrOutput

type EndpointMap 

type EndpointMap map[string]EndpointInput

func (EndpointMap) ElementType 

func (EndpointMap) ElementType() reflect.Type

func (EndpointMap) ToEndpointMapOutput 

func (i EndpointMap) ToEndpointMapOutput() EndpointMapOutput

func (EndpointMap) ToEndpointMapOutputWithContext 

func (i EndpointMap) ToEndpointMapOutputWithContext(ctx context.Context) EndpointMapOutput

type EndpointMapInput 

type EndpointMapInput interface {
	pulumi.Input

	ToEndpointMapOutput() EndpointMapOutput
	ToEndpointMapOutputWithContext(context.Context) EndpointMapOutput
}

EndpointMapInput is an input type that accepts EndpointMap and EndpointMapOutput values. You can construct a concrete instance of `EndpointMapInput` via: 

EndpointMap{ "key": EndpointArgs{...} }

type EndpointMapOutput 

type EndpointMapOutput struct{ *pulumi.OutputState }

func (EndpointMapOutput) ElementType 

func (EndpointMapOutput) ElementType() reflect.Type

func (EndpointMapOutput) MapIndex 

func (o EndpointMapOutput) MapIndex(k pulumi.StringInput) EndpointOutput

func (EndpointMapOutput) ToEndpointMapOutput 

func (o EndpointMapOutput) ToEndpointMapOutput() EndpointMapOutput

func (EndpointMapOutput) ToEndpointMapOutputWithContext 

func (o EndpointMapOutput) ToEndpointMapOutputWithContext(ctx context.Context) EndpointMapOutput

type EndpointMongodbSettings 

type EndpointMongodbSettings struct {
	// Authentication mechanism to access the MongoDB source endpoint. Default is `default`.
	AuthMechanism *string `pulumi:"authMechanism"`
	// Authentication database name. Not used when `authType` is `no`. Default is `admin`.
	AuthSource *string `pulumi:"authSource"`
	// Authentication type to access the MongoDB source endpoint. Default is `password`.
	AuthType *string `pulumi:"authType"`
	// Number of documents to preview to determine the document organization. Use this setting when `nestingLevel` is set to `one`. Default is `1000`.
	DocsToInvestigate *string `pulumi:"docsToInvestigate"`
	// Document ID. Use this setting when `nestingLevel` is set to `none`. Default is `false`.
	ExtractDocId *string `pulumi:"extractDocId"`
	// Specifies either document or table mode. Default is `none`. Valid values are `one` (table mode) and `none` (document mode).
	NestingLevel *string `pulumi:"nestingLevel"`
}

type EndpointMongodbSettingsArgs 

type EndpointMongodbSettingsArgs struct {
	// Authentication mechanism to access the MongoDB source endpoint. Default is `default`.
	AuthMechanism pulumi.StringPtrInput `pulumi:"authMechanism"`
	// Authentication database name. Not used when `authType` is `no`. Default is `admin`.
	AuthSource pulumi.StringPtrInput `pulumi:"authSource"`
	// Authentication type to access the MongoDB source endpoint. Default is `password`.
	AuthType pulumi.StringPtrInput `pulumi:"authType"`
	// Number of documents to preview to determine the document organization. Use this setting when `nestingLevel` is set to `one`. Default is `1000`.
	DocsToInvestigate pulumi.StringPtrInput `pulumi:"docsToInvestigate"`
	// Document ID. Use this setting when `nestingLevel` is set to `none`. Default is `false`.
	ExtractDocId pulumi.StringPtrInput `pulumi:"extractDocId"`
	// Specifies either document or table mode. Default is `none`. Valid values are `one` (table mode) and `none` (document mode).
	NestingLevel pulumi.StringPtrInput `pulumi:"nestingLevel"`
}

func (EndpointMongodbSettingsArgs) ElementType 

func (EndpointMongodbSettingsArgs) ElementType() reflect.Type

func (EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsOutput 

func (i EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsOutput() EndpointMongodbSettingsOutput

func (EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsOutputWithContext 

func (i EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsOutputWithContext(ctx context.Context) EndpointMongodbSettingsOutput

func (EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsPtrOutput 

func (i EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsPtrOutput() EndpointMongodbSettingsPtrOutput

func (EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsPtrOutputWithContext 

func (i EndpointMongodbSettingsArgs) ToEndpointMongodbSettingsPtrOutputWithContext(ctx context.Context) EndpointMongodbSettingsPtrOutput

type EndpointMongodbSettingsInput 

type EndpointMongodbSettingsInput interface {
	pulumi.Input

	ToEndpointMongodbSettingsOutput() EndpointMongodbSettingsOutput
	ToEndpointMongodbSettingsOutputWithContext(context.Context) EndpointMongodbSettingsOutput
}

EndpointMongodbSettingsInput is an input type that accepts EndpointMongodbSettingsArgs and EndpointMongodbSettingsOutput values. You can construct a concrete instance of `EndpointMongodbSettingsInput` via: 

EndpointMongodbSettingsArgs{...}

type EndpointMongodbSettingsOutput 

type EndpointMongodbSettingsOutput struct{ *pulumi.OutputState }

func (EndpointMongodbSettingsOutput) AuthMechanism 

func (o EndpointMongodbSettingsOutput) AuthMechanism() pulumi.StringPtrOutput

Authentication mechanism to access the MongoDB source endpoint. Default is `default`.

func (EndpointMongodbSettingsOutput) AuthSource 

func (o EndpointMongodbSettingsOutput) AuthSource() pulumi.StringPtrOutput

Authentication database name. Not used when `authType` is `no`. Default is `admin`.

func (EndpointMongodbSettingsOutput) AuthType 

func (o EndpointMongodbSettingsOutput) AuthType() pulumi.StringPtrOutput

Authentication type to access the MongoDB source endpoint. Default is `password`.

func (EndpointMongodbSettingsOutput) DocsToInvestigate 

func (o EndpointMongodbSettingsOutput) DocsToInvestigate() pulumi.StringPtrOutput

Number of documents to preview to determine the document organization. Use this setting when `nestingLevel` is set to `one`. Default is `1000`.

func (EndpointMongodbSettingsOutput) ElementType 

func (EndpointMongodbSettingsOutput) ElementType() reflect.Type

func (EndpointMongodbSettingsOutput) ExtractDocId 

func (o EndpointMongodbSettingsOutput) ExtractDocId() pulumi.StringPtrOutput

Document ID. Use this setting when `nestingLevel` is set to `none`. Default is `false`.

func (EndpointMongodbSettingsOutput) NestingLevel 

func (o EndpointMongodbSettingsOutput) NestingLevel() pulumi.StringPtrOutput

Specifies either document or table mode. Default is `none`. Valid values are `one` (table mode) and `none` (document mode).

func (EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsOutput 

func (o EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsOutput() EndpointMongodbSettingsOutput

func (EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsOutputWithContext 

func (o EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsOutputWithContext(ctx context.Context) EndpointMongodbSettingsOutput

func (EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsPtrOutput 

func (o EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsPtrOutput() EndpointMongodbSettingsPtrOutput

func (EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsPtrOutputWithContext 

func (o EndpointMongodbSettingsOutput) ToEndpointMongodbSettingsPtrOutputWithContext(ctx context.Context) EndpointMongodbSettingsPtrOutput

type EndpointMongodbSettingsPtrInput 

type EndpointMongodbSettingsPtrInput interface {
	pulumi.Input

	ToEndpointMongodbSettingsPtrOutput() EndpointMongodbSettingsPtrOutput
	ToEndpointMongodbSettingsPtrOutputWithContext(context.Context) EndpointMongodbSettingsPtrOutput
}

EndpointMongodbSettingsPtrInput is an input type that accepts EndpointMongodbSettingsArgs, EndpointMongodbSettingsPtr and EndpointMongodbSettingsPtrOutput values. You can construct a concrete instance of `EndpointMongodbSettingsPtrInput` via: 

        EndpointMongodbSettingsArgs{...}

or:

        nil

func EndpointMongodbSettingsPtr 

func EndpointMongodbSettingsPtr(v *EndpointMongodbSettingsArgs) EndpointMongodbSettingsPtrInput

type EndpointMongodbSettingsPtrOutput 

type EndpointMongodbSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointMongodbSettingsPtrOutput) AuthMechanism 

func (o EndpointMongodbSettingsPtrOutput) AuthMechanism() pulumi.StringPtrOutput

Authentication mechanism to access the MongoDB source endpoint. Default is `default`.

func (EndpointMongodbSettingsPtrOutput) AuthSource 

func (o EndpointMongodbSettingsPtrOutput) AuthSource() pulumi.StringPtrOutput

Authentication database name. Not used when `authType` is `no`. Default is `admin`.

func (EndpointMongodbSettingsPtrOutput) AuthType 

func (o EndpointMongodbSettingsPtrOutput) AuthType() pulumi.StringPtrOutput

Authentication type to access the MongoDB source endpoint. Default is `password`.

func (EndpointMongodbSettingsPtrOutput) DocsToInvestigate 

func (o EndpointMongodbSettingsPtrOutput) DocsToInvestigate() pulumi.StringPtrOutput

Number of documents to preview to determine the document organization. Use this setting when `nestingLevel` is set to `one`. Default is `1000`.

func (EndpointMongodbSettingsPtrOutput) Elem 

func (o EndpointMongodbSettingsPtrOutput) Elem() EndpointMongodbSettingsOutput

func (EndpointMongodbSettingsPtrOutput) ElementType 

func (EndpointMongodbSettingsPtrOutput) ElementType() reflect.Type

func (EndpointMongodbSettingsPtrOutput) ExtractDocId 

func (o EndpointMongodbSettingsPtrOutput) ExtractDocId() pulumi.StringPtrOutput

Document ID. Use this setting when `nestingLevel` is set to `none`. Default is `false`.

func (EndpointMongodbSettingsPtrOutput) NestingLevel 

func (o EndpointMongodbSettingsPtrOutput) NestingLevel() pulumi.StringPtrOutput

Specifies either document or table mode. Default is `none`. Valid values are `one` (table mode) and `none` (document mode).

func (EndpointMongodbSettingsPtrOutput) ToEndpointMongodbSettingsPtrOutput 

func (o EndpointMongodbSettingsPtrOutput) ToEndpointMongodbSettingsPtrOutput() EndpointMongodbSettingsPtrOutput

func (EndpointMongodbSettingsPtrOutput) ToEndpointMongodbSettingsPtrOutputWithContext 

func (o EndpointMongodbSettingsPtrOutput) ToEndpointMongodbSettingsPtrOutputWithContext(ctx context.Context) EndpointMongodbSettingsPtrOutput

type EndpointOutput 

type EndpointOutput struct{ *pulumi.OutputState }

func (EndpointOutput) CertificateArn added in v5.4.0 

func (o EndpointOutput) CertificateArn() pulumi.StringOutput

ARN for the certificate.

func (EndpointOutput) DatabaseName added in v5.4.0 

func (o EndpointOutput) DatabaseName() pulumi.StringPtrOutput

Name of the endpoint database.

func (EndpointOutput) ElasticsearchSettings added in v5.4.0 

func (o EndpointOutput) ElasticsearchSettings() EndpointElasticsearchSettingsPtrOutput

Configuration block for OpenSearch settings. See below.

func (EndpointOutput) ElementType 

func (EndpointOutput) ElementType() reflect.Type

func (EndpointOutput) EndpointArn added in v5.4.0 

func (o EndpointOutput) EndpointArn() pulumi.StringOutput

ARN for the endpoint.

func (EndpointOutput) EndpointId added in v5.4.0 

func (o EndpointOutput) EndpointId() pulumi.StringOutput

Database endpoint identifier. Identifiers must contain from 1 to 255 alphanumeric characters or hyphens, begin with a letter, contain only ASCII letters, digits, and hyphens, not end with a hyphen, and not contain two consecutive hyphens.

func (EndpointOutput) EndpointType added in v5.4.0 

func (o EndpointOutput) EndpointType() pulumi.StringOutput

Type of endpoint. Valid values are `source`, `target`.

func (EndpointOutput) EngineName added in v5.4.0 

func (o EndpointOutput) EngineName() pulumi.StringOutput

Type of engine for the endpoint. Valid values are `aurora`, `aurora-postgresql`, `azuredb`, `db2`, `docdb`, `dynamodb`, `elasticsearch`, `kafka`, `kinesis`, `mariadb`, `mongodb`, `mysql`, `opensearch`, `oracle`, `postgres`, `redshift`, `s3`, `sqlserver`, `sybase`. Please note that some of engine names are available only for `target` endpoint type (e.g. `redshift`).

func (EndpointOutput) ExtraConnectionAttributes added in v5.4.0 

func (o EndpointOutput) ExtraConnectionAttributes() pulumi.StringOutput

Additional attributes associated with the connection. For available attributes see [Using Extra Connection Attributes with AWS Database Migration Service](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib).

func (EndpointOutput) KafkaSettings added in v5.4.0 

func (o EndpointOutput) KafkaSettings() EndpointKafkaSettingsPtrOutput

Configuration block for Kafka settings. See below.

func (EndpointOutput) KinesisSettings added in v5.4.0 

func (o EndpointOutput) KinesisSettings() EndpointKinesisSettingsPtrOutput

Configuration block for Kinesis settings. See below.

func (EndpointOutput) KmsKeyArn added in v5.4.0 

func (o EndpointOutput) KmsKeyArn() pulumi.StringOutput

ARN for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.

func (EndpointOutput) MongodbSettings added in v5.4.0 

func (o EndpointOutput) MongodbSettings() EndpointMongodbSettingsPtrOutput

Configuration block for MongoDB settings. See below.

func (EndpointOutput) Password added in v5.4.0 

func (o EndpointOutput) Password() pulumi.StringPtrOutput

Password to be used to login to the endpoint database.

func (EndpointOutput) Port added in v5.4.0 

func (o EndpointOutput) Port() pulumi.IntPtrOutput

Port used by the endpoint database.

func (EndpointOutput) RedshiftSettings added in v5.7.0 

func (o EndpointOutput) RedshiftSettings() EndpointRedshiftSettingsOutput

Configuration block for Redshift settings. See below.

func (EndpointOutput) S3Settings added in v5.4.0 

func (o EndpointOutput) S3Settings() EndpointS3SettingsPtrOutput

Configuration block for S3 settings. See below.

func (EndpointOutput) SecretsManagerAccessRoleArn added in v5.4.0 

func (o EndpointOutput) SecretsManagerAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM role that specifies AWS DMS as the trusted entity and has the required permissions to access the value in SecretsManagerSecret.

func (EndpointOutput) SecretsManagerArn added in v5.4.0 

func (o EndpointOutput) SecretsManagerArn() pulumi.StringPtrOutput

Full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for `engineName` as `aurora`, `aurora-postgresql`, `mariadb`, `mongodb`, `mysql`, `oracle`, `postgres`, `redshift` or `sqlserver`.

func (EndpointOutput) ServerName added in v5.4.0 

func (o EndpointOutput) ServerName() pulumi.StringPtrOutput

Host name of the server.

func (EndpointOutput) ServiceAccessRole added in v5.4.0 

func (o EndpointOutput) ServiceAccessRole() pulumi.StringPtrOutput

ARN used by the service access IAM role for dynamodb endpoints.

func (EndpointOutput) SslMode added in v5.4.0 

func (o EndpointOutput) SslMode() pulumi.StringOutput

SSL mode to use for the connection. Valid values are `none`, `require`, `verify-ca`, `verify-full`

func (EndpointOutput) Tags added in v5.4.0 

func (o EndpointOutput) Tags() pulumi.StringMapOutput

Map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (EndpointOutput) TagsAll added in v5.4.0 

func (o EndpointOutput) TagsAll() pulumi.StringMapOutput

Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (EndpointOutput) ToEndpointOutput 

func (o EndpointOutput) ToEndpointOutput() EndpointOutput

func (EndpointOutput) ToEndpointOutputWithContext 

func (o EndpointOutput) ToEndpointOutputWithContext(ctx context.Context) EndpointOutput

func (EndpointOutput) Username added in v5.4.0 

func (o EndpointOutput) Username() pulumi.StringPtrOutput

User name to be used to login to the endpoint database.

type EndpointRedshiftSettings added in v5.7.0 

type EndpointRedshiftSettings struct {
	// S3 object prefix.
	BucketFolder *string `pulumi:"bucketFolder"`
	// S3 bucket name.
	BucketName *string `pulumi:"bucketName"`
	// Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.
	EncryptionMode *string `pulumi:"encryptionMode"`
	// If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.
	ServerSideEncryptionKmsKeyId *string `pulumi:"serverSideEncryptionKmsKeyId"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn *string `pulumi:"serviceAccessRoleArn"`
}

type EndpointRedshiftSettingsArgs added in v5.7.0 

type EndpointRedshiftSettingsArgs struct {
	// S3 object prefix.
	BucketFolder pulumi.StringPtrInput `pulumi:"bucketFolder"`
	// S3 bucket name.
	BucketName pulumi.StringPtrInput `pulumi:"bucketName"`
	// Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.
	EncryptionMode pulumi.StringPtrInput `pulumi:"encryptionMode"`
	// If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.
	ServerSideEncryptionKmsKeyId pulumi.StringPtrInput `pulumi:"serverSideEncryptionKmsKeyId"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn pulumi.StringPtrInput `pulumi:"serviceAccessRoleArn"`
}

func (EndpointRedshiftSettingsArgs) ElementType added in v5.7.0 

func (EndpointRedshiftSettingsArgs) ElementType() reflect.Type

func (EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsOutput added in v5.7.0 

func (i EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsOutput() EndpointRedshiftSettingsOutput

func (EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsOutputWithContext added in v5.7.0 

func (i EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsOutputWithContext(ctx context.Context) EndpointRedshiftSettingsOutput

func (EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsPtrOutput added in v5.7.0 

func (i EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsPtrOutput() EndpointRedshiftSettingsPtrOutput

func (EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsPtrOutputWithContext added in v5.7.0 

func (i EndpointRedshiftSettingsArgs) ToEndpointRedshiftSettingsPtrOutputWithContext(ctx context.Context) EndpointRedshiftSettingsPtrOutput

type EndpointRedshiftSettingsInput added in v5.7.0 

type EndpointRedshiftSettingsInput interface {
	pulumi.Input

	ToEndpointRedshiftSettingsOutput() EndpointRedshiftSettingsOutput
	ToEndpointRedshiftSettingsOutputWithContext(context.Context) EndpointRedshiftSettingsOutput
}

EndpointRedshiftSettingsInput is an input type that accepts EndpointRedshiftSettingsArgs and EndpointRedshiftSettingsOutput values. You can construct a concrete instance of `EndpointRedshiftSettingsInput` via: 

EndpointRedshiftSettingsArgs{...}

type EndpointRedshiftSettingsOutput added in v5.7.0 

type EndpointRedshiftSettingsOutput struct{ *pulumi.OutputState }

func (EndpointRedshiftSettingsOutput) BucketFolder added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) BucketFolder() pulumi.StringPtrOutput

S3 object prefix.

func (EndpointRedshiftSettingsOutput) BucketName added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) BucketName() pulumi.StringPtrOutput

S3 bucket name.

func (EndpointRedshiftSettingsOutput) ElementType added in v5.7.0 

func (EndpointRedshiftSettingsOutput) ElementType() reflect.Type

func (EndpointRedshiftSettingsOutput) EncryptionMode added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) EncryptionMode() pulumi.StringPtrOutput

Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.

func (EndpointRedshiftSettingsOutput) ServerSideEncryptionKmsKeyId added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) ServerSideEncryptionKmsKeyId() pulumi.StringPtrOutput

If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.

func (EndpointRedshiftSettingsOutput) ServiceAccessRoleArn added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsOutput added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsOutput() EndpointRedshiftSettingsOutput

func (EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsOutputWithContext added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsOutputWithContext(ctx context.Context) EndpointRedshiftSettingsOutput

func (EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsPtrOutput added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsPtrOutput() EndpointRedshiftSettingsPtrOutput

func (EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsPtrOutputWithContext added in v5.7.0 

func (o EndpointRedshiftSettingsOutput) ToEndpointRedshiftSettingsPtrOutputWithContext(ctx context.Context) EndpointRedshiftSettingsPtrOutput

type EndpointRedshiftSettingsPtrInput added in v5.7.0 

type EndpointRedshiftSettingsPtrInput interface {
	pulumi.Input

	ToEndpointRedshiftSettingsPtrOutput() EndpointRedshiftSettingsPtrOutput
	ToEndpointRedshiftSettingsPtrOutputWithContext(context.Context) EndpointRedshiftSettingsPtrOutput
}

EndpointRedshiftSettingsPtrInput is an input type that accepts EndpointRedshiftSettingsArgs, EndpointRedshiftSettingsPtr and EndpointRedshiftSettingsPtrOutput values. You can construct a concrete instance of `EndpointRedshiftSettingsPtrInput` via: 

        EndpointRedshiftSettingsArgs{...}

or:

        nil

func EndpointRedshiftSettingsPtr added in v5.7.0 

func EndpointRedshiftSettingsPtr(v *EndpointRedshiftSettingsArgs) EndpointRedshiftSettingsPtrInput

type EndpointRedshiftSettingsPtrOutput added in v5.7.0 

type EndpointRedshiftSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointRedshiftSettingsPtrOutput) BucketFolder added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) BucketFolder() pulumi.StringPtrOutput

S3 object prefix.

func (EndpointRedshiftSettingsPtrOutput) BucketName added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) BucketName() pulumi.StringPtrOutput

S3 bucket name.

func (EndpointRedshiftSettingsPtrOutput) Elem added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) Elem() EndpointRedshiftSettingsOutput

func (EndpointRedshiftSettingsPtrOutput) ElementType added in v5.7.0 

func (EndpointRedshiftSettingsPtrOutput) ElementType() reflect.Type

func (EndpointRedshiftSettingsPtrOutput) EncryptionMode added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) EncryptionMode() pulumi.StringPtrOutput

Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.

func (EndpointRedshiftSettingsPtrOutput) ServerSideEncryptionKmsKeyId added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) ServerSideEncryptionKmsKeyId() pulumi.StringPtrOutput

If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.

func (EndpointRedshiftSettingsPtrOutput) ServiceAccessRoleArn added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointRedshiftSettingsPtrOutput) ToEndpointRedshiftSettingsPtrOutput added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) ToEndpointRedshiftSettingsPtrOutput() EndpointRedshiftSettingsPtrOutput

func (EndpointRedshiftSettingsPtrOutput) ToEndpointRedshiftSettingsPtrOutputWithContext added in v5.7.0 

func (o EndpointRedshiftSettingsPtrOutput) ToEndpointRedshiftSettingsPtrOutputWithContext(ctx context.Context) EndpointRedshiftSettingsPtrOutput

type EndpointS3Settings 

type EndpointS3Settings struct {
	// Whether to add column name information to the .csv output file. Default is `false`.
	AddColumnName *bool `pulumi:"addColumnName"`
	// S3 object prefix.
	BucketFolder *string `pulumi:"bucketFolder"`
	// S3 bucket name.
	BucketName *string `pulumi:"bucketName"`
	// Predefined (canned) access control list for objects created in an S3 bucket. Valid values include `NONE`, `PRIVATE`, `PUBLIC_READ`, `PUBLIC_READ_WRITE`, `AUTHENTICATED_READ`, `AWS_EXEC_READ`, `BUCKET_OWNER_READ`, and `BUCKET_OWNER_FULL_CONTROL`. Default is `NONE`.
	CannedAclForObjects *string `pulumi:"cannedAclForObjects"`
	// Whether to write insert and update operations to .csv or .parquet output files. Default is `false`.
	CdcInsertsAndUpdates *bool `pulumi:"cdcInsertsAndUpdates"`
	// Whether to write insert operations to .csv or .parquet output files. Default is `false`.
	CdcInsertsOnly *bool `pulumi:"cdcInsertsOnly"`
	// Maximum length of the interval, defined in seconds, after which to output a file to Amazon S3. Default is `60`.
	CdcMaxBatchInterval *int `pulumi:"cdcMaxBatchInterval"`
	// Minimum file size, defined in megabytes, to reach for a file output. Default is `32`.
	CdcMinFileSize *int `pulumi:"cdcMinFileSize"`
	// Folder path of CDC files. For an S3 source, this setting is required if a task captures change data; otherwise, it's optional. If `cdcPath` is set, AWS DMS reads CDC files from this path and replicates the data changes to the target endpoint. Supported in AWS DMS versions 3.4.2 and later.
	CdcPath *string `pulumi:"cdcPath"`
	// Set to compress target files. Default is `NONE`. Valid values are `GZIP` and `NONE`.
	CompressionType *string `pulumi:"compressionType"`
	// Delimiter used to separate columns in the source files. Default is `,`.
	CsvDelimiter *string `pulumi:"csvDelimiter"`
	// String to use for all columns not included in the supplemental log.
	CsvNoSupValue *string `pulumi:"csvNoSupValue"`
	// String to as null when writing to the target.
	CsvNullValue *string `pulumi:"csvNullValue"`
	// Delimiter used to separate rows in the source files. Default is `\n`.
	CsvRowDelimiter *string `pulumi:"csvRowDelimiter"`
	// Output format for the files that AWS DMS uses to create S3 objects. Valid values are `csv` and `parquet`. Default is `csv`.
	DataFormat *string `pulumi:"dataFormat"`
	// Size of one data page in bytes. Default is `1048576` (1 MiB).
	DataPageSize *int `pulumi:"dataPageSize"`
	// Date separating delimiter to use during folder partitioning. Valid values are `SLASH`, `UNDERSCORE`, `DASH`, and `NONE`. Default is `SLASH`.
	DatePartitionDelimiter *string `pulumi:"datePartitionDelimiter"`
	// Partition S3 bucket folders based on transaction commit dates. Default is `false`.
	DatePartitionEnabled *bool `pulumi:"datePartitionEnabled"`
	// Date format to use during folder partitioning. Use this parameter when `datePartitionEnabled` is set to true. Valid values are `YYYYMMDD`, `YYYYMMDDHH`, `YYYYMM`, `MMYYYYDD`, and `DDMMYYYY`. Default is `YYYYMMDD`.
	DatePartitionSequence *string `pulumi:"datePartitionSequence"`
	// Maximum size in bytes of an encoded dictionary page of a column. Default is `1048576` (1 MiB).
	DictPageSizeLimit *int `pulumi:"dictPageSizeLimit"`
	// Whether to enable statistics for Parquet pages and row groups. Default is `true`.
	EnableStatistics *bool `pulumi:"enableStatistics"`
	// Type of encoding to use. Value values are `rleDictionary`, `plain`, and `plainDictionary`. Default is `rleDictionary`.
	EncodingType *string `pulumi:"encodingType"`
	// Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.
	EncryptionMode *string `pulumi:"encryptionMode"`
	// JSON document that describes how AWS DMS should interpret the data.
	ExternalTableDefinition *string `pulumi:"externalTableDefinition"`
	// When this value is set to `1`, DMS ignores the first row header in a .csv file. Default is `0`.
	IgnoreHeadersRow *int `pulumi:"ignoreHeadersRow"`
	// Whether to enable a full load to write INSERT operations to the .csv output files only to indicate how the rows were added to the source database. Default is `false`.
	IncludeOpForFullLoad *bool `pulumi:"includeOpForFullLoad"`
	// Maximum size (in KB) of any .csv file to be created while migrating to an S3 target during full load. Valid values are from `1` to `1048576`. Default is `1048576` (1 GB).
	MaxFileSize *int `pulumi:"maxFileSize"`
	// - Specifies the precision of any TIMESTAMP column values written to an S3 object file in .parquet format. Default is `false`.
	ParquetTimestampInMillisecond *bool `pulumi:"parquetTimestampInMillisecond"`
	// Version of the .parquet file format. Default is `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.
	ParquetVersion *string `pulumi:"parquetVersion"`
	// Whether DMS saves the transaction order for a CDC load on the S3 target specified by `cdcPath`. Default is `false`.
	PreserveTransactions *bool `pulumi:"preserveTransactions"`
	// For an S3 source, whether each leading double quotation mark has to be followed by an ending double quotation mark. Default is `true`.
	Rfc4180 *bool `pulumi:"rfc4180"`
	// Number of rows in a row group. Default is `10000`.
	RowGroupLength *int `pulumi:"rowGroupLength"`
	// If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.
	ServerSideEncryptionKmsKeyId *string `pulumi:"serverSideEncryptionKmsKeyId"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn *string `pulumi:"serviceAccessRoleArn"`
	// Column to add with timestamp information to the endpoint data for an Amazon S3 target.
	TimestampColumnName *string `pulumi:"timestampColumnName"`
	// Whether to use `csvNoSupValue` for columns not included in the supplemental log.
	UseCsvNoSupValue *bool `pulumi:"useCsvNoSupValue"`
}

type EndpointS3SettingsArgs 

type EndpointS3SettingsArgs struct {
	// Whether to add column name information to the .csv output file. Default is `false`.
	AddColumnName pulumi.BoolPtrInput `pulumi:"addColumnName"`
	// S3 object prefix.
	BucketFolder pulumi.StringPtrInput `pulumi:"bucketFolder"`
	// S3 bucket name.
	BucketName pulumi.StringPtrInput `pulumi:"bucketName"`
	// Predefined (canned) access control list for objects created in an S3 bucket. Valid values include `NONE`, `PRIVATE`, `PUBLIC_READ`, `PUBLIC_READ_WRITE`, `AUTHENTICATED_READ`, `AWS_EXEC_READ`, `BUCKET_OWNER_READ`, and `BUCKET_OWNER_FULL_CONTROL`. Default is `NONE`.
	CannedAclForObjects pulumi.StringPtrInput `pulumi:"cannedAclForObjects"`
	// Whether to write insert and update operations to .csv or .parquet output files. Default is `false`.
	CdcInsertsAndUpdates pulumi.BoolPtrInput `pulumi:"cdcInsertsAndUpdates"`
	// Whether to write insert operations to .csv or .parquet output files. Default is `false`.
	CdcInsertsOnly pulumi.BoolPtrInput `pulumi:"cdcInsertsOnly"`
	// Maximum length of the interval, defined in seconds, after which to output a file to Amazon S3. Default is `60`.
	CdcMaxBatchInterval pulumi.IntPtrInput `pulumi:"cdcMaxBatchInterval"`
	// Minimum file size, defined in megabytes, to reach for a file output. Default is `32`.
	CdcMinFileSize pulumi.IntPtrInput `pulumi:"cdcMinFileSize"`
	// Folder path of CDC files. For an S3 source, this setting is required if a task captures change data; otherwise, it's optional. If `cdcPath` is set, AWS DMS reads CDC files from this path and replicates the data changes to the target endpoint. Supported in AWS DMS versions 3.4.2 and later.
	CdcPath pulumi.StringPtrInput `pulumi:"cdcPath"`
	// Set to compress target files. Default is `NONE`. Valid values are `GZIP` and `NONE`.
	CompressionType pulumi.StringPtrInput `pulumi:"compressionType"`
	// Delimiter used to separate columns in the source files. Default is `,`.
	CsvDelimiter pulumi.StringPtrInput `pulumi:"csvDelimiter"`
	// String to use for all columns not included in the supplemental log.
	CsvNoSupValue pulumi.StringPtrInput `pulumi:"csvNoSupValue"`
	// String to as null when writing to the target.
	CsvNullValue pulumi.StringPtrInput `pulumi:"csvNullValue"`
	// Delimiter used to separate rows in the source files. Default is `\n`.
	CsvRowDelimiter pulumi.StringPtrInput `pulumi:"csvRowDelimiter"`
	// Output format for the files that AWS DMS uses to create S3 objects. Valid values are `csv` and `parquet`. Default is `csv`.
	DataFormat pulumi.StringPtrInput `pulumi:"dataFormat"`
	// Size of one data page in bytes. Default is `1048576` (1 MiB).
	DataPageSize pulumi.IntPtrInput `pulumi:"dataPageSize"`
	// Date separating delimiter to use during folder partitioning. Valid values are `SLASH`, `UNDERSCORE`, `DASH`, and `NONE`. Default is `SLASH`.
	DatePartitionDelimiter pulumi.StringPtrInput `pulumi:"datePartitionDelimiter"`
	// Partition S3 bucket folders based on transaction commit dates. Default is `false`.
	DatePartitionEnabled pulumi.BoolPtrInput `pulumi:"datePartitionEnabled"`
	// Date format to use during folder partitioning. Use this parameter when `datePartitionEnabled` is set to true. Valid values are `YYYYMMDD`, `YYYYMMDDHH`, `YYYYMM`, `MMYYYYDD`, and `DDMMYYYY`. Default is `YYYYMMDD`.
	DatePartitionSequence pulumi.StringPtrInput `pulumi:"datePartitionSequence"`
	// Maximum size in bytes of an encoded dictionary page of a column. Default is `1048576` (1 MiB).
	DictPageSizeLimit pulumi.IntPtrInput `pulumi:"dictPageSizeLimit"`
	// Whether to enable statistics for Parquet pages and row groups. Default is `true`.
	EnableStatistics pulumi.BoolPtrInput `pulumi:"enableStatistics"`
	// Type of encoding to use. Value values are `rleDictionary`, `plain`, and `plainDictionary`. Default is `rleDictionary`.
	EncodingType pulumi.StringPtrInput `pulumi:"encodingType"`
	// Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.
	EncryptionMode pulumi.StringPtrInput `pulumi:"encryptionMode"`
	// JSON document that describes how AWS DMS should interpret the data.
	ExternalTableDefinition pulumi.StringPtrInput `pulumi:"externalTableDefinition"`
	// When this value is set to `1`, DMS ignores the first row header in a .csv file. Default is `0`.
	IgnoreHeadersRow pulumi.IntPtrInput `pulumi:"ignoreHeadersRow"`
	// Whether to enable a full load to write INSERT operations to the .csv output files only to indicate how the rows were added to the source database. Default is `false`.
	IncludeOpForFullLoad pulumi.BoolPtrInput `pulumi:"includeOpForFullLoad"`
	// Maximum size (in KB) of any .csv file to be created while migrating to an S3 target during full load. Valid values are from `1` to `1048576`. Default is `1048576` (1 GB).
	MaxFileSize pulumi.IntPtrInput `pulumi:"maxFileSize"`
	// - Specifies the precision of any TIMESTAMP column values written to an S3 object file in .parquet format. Default is `false`.
	ParquetTimestampInMillisecond pulumi.BoolPtrInput `pulumi:"parquetTimestampInMillisecond"`
	// Version of the .parquet file format. Default is `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.
	ParquetVersion pulumi.StringPtrInput `pulumi:"parquetVersion"`
	// Whether DMS saves the transaction order for a CDC load on the S3 target specified by `cdcPath`. Default is `false`.
	PreserveTransactions pulumi.BoolPtrInput `pulumi:"preserveTransactions"`
	// For an S3 source, whether each leading double quotation mark has to be followed by an ending double quotation mark. Default is `true`.
	Rfc4180 pulumi.BoolPtrInput `pulumi:"rfc4180"`
	// Number of rows in a row group. Default is `10000`.
	RowGroupLength pulumi.IntPtrInput `pulumi:"rowGroupLength"`
	// If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.
	ServerSideEncryptionKmsKeyId pulumi.StringPtrInput `pulumi:"serverSideEncryptionKmsKeyId"`
	// ARN of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn pulumi.StringPtrInput `pulumi:"serviceAccessRoleArn"`
	// Column to add with timestamp information to the endpoint data for an Amazon S3 target.
	TimestampColumnName pulumi.StringPtrInput `pulumi:"timestampColumnName"`
	// Whether to use `csvNoSupValue` for columns not included in the supplemental log.
	UseCsvNoSupValue pulumi.BoolPtrInput `pulumi:"useCsvNoSupValue"`
}

func (EndpointS3SettingsArgs) ElementType 

func (EndpointS3SettingsArgs) ElementType() reflect.Type

func (EndpointS3SettingsArgs) ToEndpointS3SettingsOutput 

func (i EndpointS3SettingsArgs) ToEndpointS3SettingsOutput() EndpointS3SettingsOutput

func (EndpointS3SettingsArgs) ToEndpointS3SettingsOutputWithContext 

func (i EndpointS3SettingsArgs) ToEndpointS3SettingsOutputWithContext(ctx context.Context) EndpointS3SettingsOutput

func (EndpointS3SettingsArgs) ToEndpointS3SettingsPtrOutput 

func (i EndpointS3SettingsArgs) ToEndpointS3SettingsPtrOutput() EndpointS3SettingsPtrOutput

func (EndpointS3SettingsArgs) ToEndpointS3SettingsPtrOutputWithContext 

func (i EndpointS3SettingsArgs) ToEndpointS3SettingsPtrOutputWithContext(ctx context.Context) EndpointS3SettingsPtrOutput

type EndpointS3SettingsInput 

type EndpointS3SettingsInput interface {
	pulumi.Input

	ToEndpointS3SettingsOutput() EndpointS3SettingsOutput
	ToEndpointS3SettingsOutputWithContext(context.Context) EndpointS3SettingsOutput
}

EndpointS3SettingsInput is an input type that accepts EndpointS3SettingsArgs and EndpointS3SettingsOutput values. You can construct a concrete instance of `EndpointS3SettingsInput` via: 

EndpointS3SettingsArgs{...}

type EndpointS3SettingsOutput 

type EndpointS3SettingsOutput struct{ *pulumi.OutputState }

func (EndpointS3SettingsOutput) AddColumnName added in v5.1.0 

func (o EndpointS3SettingsOutput) AddColumnName() pulumi.BoolPtrOutput

Whether to add column name information to the .csv output file. Default is `false`.

func (EndpointS3SettingsOutput) BucketFolder 

func (o EndpointS3SettingsOutput) BucketFolder() pulumi.StringPtrOutput

S3 object prefix.

func (EndpointS3SettingsOutput) BucketName 

func (o EndpointS3SettingsOutput) BucketName() pulumi.StringPtrOutput

S3 bucket name.

func (EndpointS3SettingsOutput) CannedAclForObjects added in v5.1.0 

func (o EndpointS3SettingsOutput) CannedAclForObjects() pulumi.StringPtrOutput

Predefined (canned) access control list for objects created in an S3 bucket. Valid values include `NONE`, `PRIVATE`, `PUBLIC_READ`, `PUBLIC_READ_WRITE`, `AUTHENTICATED_READ`, `AWS_EXEC_READ`, `BUCKET_OWNER_READ`, and `BUCKET_OWNER_FULL_CONTROL`. Default is `NONE`.

func (EndpointS3SettingsOutput) CdcInsertsAndUpdates added in v5.1.0 

func (o EndpointS3SettingsOutput) CdcInsertsAndUpdates() pulumi.BoolPtrOutput

Whether to write insert and update operations to .csv or .parquet output files. Default is `false`.

func (EndpointS3SettingsOutput) CdcInsertsOnly added in v5.1.0 

func (o EndpointS3SettingsOutput) CdcInsertsOnly() pulumi.BoolPtrOutput

Whether to write insert operations to .csv or .parquet output files. Default is `false`.

func (EndpointS3SettingsOutput) CdcMaxBatchInterval added in v5.1.0 

func (o EndpointS3SettingsOutput) CdcMaxBatchInterval() pulumi.IntPtrOutput

Maximum length of the interval, defined in seconds, after which to output a file to Amazon S3. Default is `60`.

func (EndpointS3SettingsOutput) CdcMinFileSize added in v5.1.0 

func (o EndpointS3SettingsOutput) CdcMinFileSize() pulumi.IntPtrOutput

Minimum file size, defined in megabytes, to reach for a file output. Default is `32`.

func (EndpointS3SettingsOutput) CdcPath added in v5.1.0 

func (o EndpointS3SettingsOutput) CdcPath() pulumi.StringPtrOutput

Folder path of CDC files. For an S3 source, this setting is required if a task captures change data; otherwise, it's optional. If `cdcPath` is set, AWS DMS reads CDC files from this path and replicates the data changes to the target endpoint. Supported in AWS DMS versions 3.4.2 and later.

func (EndpointS3SettingsOutput) CompressionType 

func (o EndpointS3SettingsOutput) CompressionType() pulumi.StringPtrOutput

Set to compress target files. Default is `NONE`. Valid values are `GZIP` and `NONE`.

func (EndpointS3SettingsOutput) CsvDelimiter 

func (o EndpointS3SettingsOutput) CsvDelimiter() pulumi.StringPtrOutput

Delimiter used to separate columns in the source files. Default is `,`.

func (EndpointS3SettingsOutput) CsvNoSupValue added in v5.1.0 

func (o EndpointS3SettingsOutput) CsvNoSupValue() pulumi.StringPtrOutput

String to use for all columns not included in the supplemental log.

func (EndpointS3SettingsOutput) CsvNullValue added in v5.1.0 

func (o EndpointS3SettingsOutput) CsvNullValue() pulumi.StringPtrOutput

String to as null when writing to the target.

func (EndpointS3SettingsOutput) CsvRowDelimiter 

func (o EndpointS3SettingsOutput) CsvRowDelimiter() pulumi.StringPtrOutput

Delimiter used to separate rows in the source files. Default is `\n`.

func (EndpointS3SettingsOutput) DataFormat 

func (o EndpointS3SettingsOutput) DataFormat() pulumi.StringPtrOutput

Output format for the files that AWS DMS uses to create S3 objects. Valid values are `csv` and `parquet`. Default is `csv`.

func (EndpointS3SettingsOutput) DataPageSize added in v5.1.0 

func (o EndpointS3SettingsOutput) DataPageSize() pulumi.IntPtrOutput

Size of one data page in bytes. Default is `1048576` (1 MiB).

func (EndpointS3SettingsOutput) DatePartitionDelimiter added in v5.1.0 

func (o EndpointS3SettingsOutput) DatePartitionDelimiter() pulumi.StringPtrOutput

Date separating delimiter to use during folder partitioning. Valid values are `SLASH`, `UNDERSCORE`, `DASH`, and `NONE`. Default is `SLASH`.

func (EndpointS3SettingsOutput) DatePartitionEnabled 

func (o EndpointS3SettingsOutput) DatePartitionEnabled() pulumi.BoolPtrOutput

Partition S3 bucket folders based on transaction commit dates. Default is `false`.

func (EndpointS3SettingsOutput) DatePartitionSequence added in v5.1.0 

func (o EndpointS3SettingsOutput) DatePartitionSequence() pulumi.StringPtrOutput

Date format to use during folder partitioning. Use this parameter when `datePartitionEnabled` is set to true. Valid values are `YYYYMMDD`, `YYYYMMDDHH`, `YYYYMM`, `MMYYYYDD`, and `DDMMYYYY`. Default is `YYYYMMDD`.

func (EndpointS3SettingsOutput) DictPageSizeLimit added in v5.1.0 

func (o EndpointS3SettingsOutput) DictPageSizeLimit() pulumi.IntPtrOutput

Maximum size in bytes of an encoded dictionary page of a column. Default is `1048576` (1 MiB).

func (EndpointS3SettingsOutput) ElementType 

func (EndpointS3SettingsOutput) ElementType() reflect.Type

func (EndpointS3SettingsOutput) EnableStatistics added in v5.1.0 

func (o EndpointS3SettingsOutput) EnableStatistics() pulumi.BoolPtrOutput

Whether to enable statistics for Parquet pages and row groups. Default is `true`.

func (EndpointS3SettingsOutput) EncodingType added in v5.1.0 

func (o EndpointS3SettingsOutput) EncodingType() pulumi.StringPtrOutput

Type of encoding to use. Value values are `rleDictionary`, `plain`, and `plainDictionary`. Default is `rleDictionary`.

func (EndpointS3SettingsOutput) EncryptionMode 

func (o EndpointS3SettingsOutput) EncryptionMode() pulumi.StringPtrOutput

Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.

func (EndpointS3SettingsOutput) ExternalTableDefinition 

func (o EndpointS3SettingsOutput) ExternalTableDefinition() pulumi.StringPtrOutput

JSON document that describes how AWS DMS should interpret the data.

func (EndpointS3SettingsOutput) IgnoreHeadersRow added in v5.1.0 

func (o EndpointS3SettingsOutput) IgnoreHeadersRow() pulumi.IntPtrOutput

When this value is set to `1`, DMS ignores the first row header in a .csv file. Default is `0`.

func (EndpointS3SettingsOutput) IncludeOpForFullLoad added in v5.1.0 

func (o EndpointS3SettingsOutput) IncludeOpForFullLoad() pulumi.BoolPtrOutput

Whether to enable a full load to write INSERT operations to the .csv output files only to indicate how the rows were added to the source database. Default is `false`.

func (EndpointS3SettingsOutput) MaxFileSize added in v5.1.0 

func (o EndpointS3SettingsOutput) MaxFileSize() pulumi.IntPtrOutput

Maximum size (in KB) of any .csv file to be created while migrating to an S3 target during full load. Valid values are from `1` to `1048576`. Default is `1048576` (1 GB).

func (EndpointS3SettingsOutput) ParquetTimestampInMillisecond 

func (o EndpointS3SettingsOutput) ParquetTimestampInMillisecond() pulumi.BoolPtrOutput

- Specifies the precision of any TIMESTAMP column values written to an S3 object file in .parquet format. Default is `false`.

func (EndpointS3SettingsOutput) ParquetVersion 

func (o EndpointS3SettingsOutput) ParquetVersion() pulumi.StringPtrOutput

Version of the .parquet file format. Default is `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.

func (EndpointS3SettingsOutput) PreserveTransactions added in v5.1.0 

func (o EndpointS3SettingsOutput) PreserveTransactions() pulumi.BoolPtrOutput

Whether DMS saves the transaction order for a CDC load on the S3 target specified by `cdcPath`. Default is `false`.

func (EndpointS3SettingsOutput) Rfc4180 added in v5.1.0 

func (o EndpointS3SettingsOutput) Rfc4180() pulumi.BoolPtrOutput

For an S3 source, whether each leading double quotation mark has to be followed by an ending double quotation mark. Default is `true`.

func (EndpointS3SettingsOutput) RowGroupLength added in v5.1.0 

func (o EndpointS3SettingsOutput) RowGroupLength() pulumi.IntPtrOutput

Number of rows in a row group. Default is `10000`.

func (EndpointS3SettingsOutput) ServerSideEncryptionKmsKeyId 

func (o EndpointS3SettingsOutput) ServerSideEncryptionKmsKeyId() pulumi.StringPtrOutput

If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.

func (EndpointS3SettingsOutput) ServiceAccessRoleArn 

func (o EndpointS3SettingsOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointS3SettingsOutput) TimestampColumnName added in v5.1.0 

func (o EndpointS3SettingsOutput) TimestampColumnName() pulumi.StringPtrOutput

Column to add with timestamp information to the endpoint data for an Amazon S3 target.

func (EndpointS3SettingsOutput) ToEndpointS3SettingsOutput 

func (o EndpointS3SettingsOutput) ToEndpointS3SettingsOutput() EndpointS3SettingsOutput

func (EndpointS3SettingsOutput) ToEndpointS3SettingsOutputWithContext 

func (o EndpointS3SettingsOutput) ToEndpointS3SettingsOutputWithContext(ctx context.Context) EndpointS3SettingsOutput

func (EndpointS3SettingsOutput) ToEndpointS3SettingsPtrOutput 

func (o EndpointS3SettingsOutput) ToEndpointS3SettingsPtrOutput() EndpointS3SettingsPtrOutput

func (EndpointS3SettingsOutput) ToEndpointS3SettingsPtrOutputWithContext 

func (o EndpointS3SettingsOutput) ToEndpointS3SettingsPtrOutputWithContext(ctx context.Context) EndpointS3SettingsPtrOutput

func (EndpointS3SettingsOutput) UseCsvNoSupValue added in v5.1.0 

func (o EndpointS3SettingsOutput) UseCsvNoSupValue() pulumi.BoolPtrOutput

Whether to use `csvNoSupValue` for columns not included in the supplemental log.

type EndpointS3SettingsPtrInput 

type EndpointS3SettingsPtrInput interface {
	pulumi.Input

	ToEndpointS3SettingsPtrOutput() EndpointS3SettingsPtrOutput
	ToEndpointS3SettingsPtrOutputWithContext(context.Context) EndpointS3SettingsPtrOutput
}

EndpointS3SettingsPtrInput is an input type that accepts EndpointS3SettingsArgs, EndpointS3SettingsPtr and EndpointS3SettingsPtrOutput values. You can construct a concrete instance of `EndpointS3SettingsPtrInput` via: 

        EndpointS3SettingsArgs{...}

or:

        nil

func EndpointS3SettingsPtr 

func EndpointS3SettingsPtr(v *EndpointS3SettingsArgs) EndpointS3SettingsPtrInput

type EndpointS3SettingsPtrOutput 

type EndpointS3SettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointS3SettingsPtrOutput) AddColumnName added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) AddColumnName() pulumi.BoolPtrOutput

Whether to add column name information to the .csv output file. Default is `false`.

func (EndpointS3SettingsPtrOutput) BucketFolder 

func (o EndpointS3SettingsPtrOutput) BucketFolder() pulumi.StringPtrOutput

S3 object prefix.

func (EndpointS3SettingsPtrOutput) BucketName 

func (o EndpointS3SettingsPtrOutput) BucketName() pulumi.StringPtrOutput

S3 bucket name.

func (EndpointS3SettingsPtrOutput) CannedAclForObjects added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CannedAclForObjects() pulumi.StringPtrOutput

Predefined (canned) access control list for objects created in an S3 bucket. Valid values include `NONE`, `PRIVATE`, `PUBLIC_READ`, `PUBLIC_READ_WRITE`, `AUTHENTICATED_READ`, `AWS_EXEC_READ`, `BUCKET_OWNER_READ`, and `BUCKET_OWNER_FULL_CONTROL`. Default is `NONE`.

func (EndpointS3SettingsPtrOutput) CdcInsertsAndUpdates added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CdcInsertsAndUpdates() pulumi.BoolPtrOutput

Whether to write insert and update operations to .csv or .parquet output files. Default is `false`.

func (EndpointS3SettingsPtrOutput) CdcInsertsOnly added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CdcInsertsOnly() pulumi.BoolPtrOutput

Whether to write insert operations to .csv or .parquet output files. Default is `false`.

func (EndpointS3SettingsPtrOutput) CdcMaxBatchInterval added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CdcMaxBatchInterval() pulumi.IntPtrOutput

Maximum length of the interval, defined in seconds, after which to output a file to Amazon S3. Default is `60`.

func (EndpointS3SettingsPtrOutput) CdcMinFileSize added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CdcMinFileSize() pulumi.IntPtrOutput

Minimum file size, defined in megabytes, to reach for a file output. Default is `32`.

func (EndpointS3SettingsPtrOutput) CdcPath added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CdcPath() pulumi.StringPtrOutput

Folder path of CDC files. For an S3 source, this setting is required if a task captures change data; otherwise, it's optional. If `cdcPath` is set, AWS DMS reads CDC files from this path and replicates the data changes to the target endpoint. Supported in AWS DMS versions 3.4.2 and later.

func (EndpointS3SettingsPtrOutput) CompressionType 

func (o EndpointS3SettingsPtrOutput) CompressionType() pulumi.StringPtrOutput

Set to compress target files. Default is `NONE`. Valid values are `GZIP` and `NONE`.

func (EndpointS3SettingsPtrOutput) CsvDelimiter 

func (o EndpointS3SettingsPtrOutput) CsvDelimiter() pulumi.StringPtrOutput

Delimiter used to separate columns in the source files. Default is `,`.

func (EndpointS3SettingsPtrOutput) CsvNoSupValue added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CsvNoSupValue() pulumi.StringPtrOutput

String to use for all columns not included in the supplemental log.

func (EndpointS3SettingsPtrOutput) CsvNullValue added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) CsvNullValue() pulumi.StringPtrOutput

String to as null when writing to the target.

func (EndpointS3SettingsPtrOutput) CsvRowDelimiter 

func (o EndpointS3SettingsPtrOutput) CsvRowDelimiter() pulumi.StringPtrOutput

Delimiter used to separate rows in the source files. Default is `\n`.

func (EndpointS3SettingsPtrOutput) DataFormat 

func (o EndpointS3SettingsPtrOutput) DataFormat() pulumi.StringPtrOutput

Output format for the files that AWS DMS uses to create S3 objects. Valid values are `csv` and `parquet`. Default is `csv`.

func (EndpointS3SettingsPtrOutput) DataPageSize added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) DataPageSize() pulumi.IntPtrOutput

Size of one data page in bytes. Default is `1048576` (1 MiB).

func (EndpointS3SettingsPtrOutput) DatePartitionDelimiter added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) DatePartitionDelimiter() pulumi.StringPtrOutput

Date separating delimiter to use during folder partitioning. Valid values are `SLASH`, `UNDERSCORE`, `DASH`, and `NONE`. Default is `SLASH`.

func (EndpointS3SettingsPtrOutput) DatePartitionEnabled 

func (o EndpointS3SettingsPtrOutput) DatePartitionEnabled() pulumi.BoolPtrOutput

Partition S3 bucket folders based on transaction commit dates. Default is `false`.

func (EndpointS3SettingsPtrOutput) DatePartitionSequence added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) DatePartitionSequence() pulumi.StringPtrOutput

Date format to use during folder partitioning. Use this parameter when `datePartitionEnabled` is set to true. Valid values are `YYYYMMDD`, `YYYYMMDDHH`, `YYYYMM`, `MMYYYYDD`, and `DDMMYYYY`. Default is `YYYYMMDD`.

func (EndpointS3SettingsPtrOutput) DictPageSizeLimit added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) DictPageSizeLimit() pulumi.IntPtrOutput

Maximum size in bytes of an encoded dictionary page of a column. Default is `1048576` (1 MiB).

func (EndpointS3SettingsPtrOutput) Elem 

func (o EndpointS3SettingsPtrOutput) Elem() EndpointS3SettingsOutput

func (EndpointS3SettingsPtrOutput) ElementType 

func (EndpointS3SettingsPtrOutput) ElementType() reflect.Type

func (EndpointS3SettingsPtrOutput) EnableStatistics added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) EnableStatistics() pulumi.BoolPtrOutput

Whether to enable statistics for Parquet pages and row groups. Default is `true`.

func (EndpointS3SettingsPtrOutput) EncodingType added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) EncodingType() pulumi.StringPtrOutput

Type of encoding to use. Value values are `rleDictionary`, `plain`, and `plainDictionary`. Default is `rleDictionary`.

func (EndpointS3SettingsPtrOutput) EncryptionMode 

func (o EndpointS3SettingsPtrOutput) EncryptionMode() pulumi.StringPtrOutput

Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are `SSE_S3` and `SSE_KMS`. Default is `SSE_S3`.

func (EndpointS3SettingsPtrOutput) ExternalTableDefinition 

func (o EndpointS3SettingsPtrOutput) ExternalTableDefinition() pulumi.StringPtrOutput

JSON document that describes how AWS DMS should interpret the data.

func (EndpointS3SettingsPtrOutput) IgnoreHeadersRow added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) IgnoreHeadersRow() pulumi.IntPtrOutput

When this value is set to `1`, DMS ignores the first row header in a .csv file. Default is `0`.

func (EndpointS3SettingsPtrOutput) IncludeOpForFullLoad added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) IncludeOpForFullLoad() pulumi.BoolPtrOutput

Whether to enable a full load to write INSERT operations to the .csv output files only to indicate how the rows were added to the source database. Default is `false`.

func (EndpointS3SettingsPtrOutput) MaxFileSize added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) MaxFileSize() pulumi.IntPtrOutput

Maximum size (in KB) of any .csv file to be created while migrating to an S3 target during full load. Valid values are from `1` to `1048576`. Default is `1048576` (1 GB).

func (EndpointS3SettingsPtrOutput) ParquetTimestampInMillisecond 

func (o EndpointS3SettingsPtrOutput) ParquetTimestampInMillisecond() pulumi.BoolPtrOutput

- Specifies the precision of any TIMESTAMP column values written to an S3 object file in .parquet format. Default is `false`.

func (EndpointS3SettingsPtrOutput) ParquetVersion 

func (o EndpointS3SettingsPtrOutput) ParquetVersion() pulumi.StringPtrOutput

Version of the .parquet file format. Default is `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.

func (EndpointS3SettingsPtrOutput) PreserveTransactions added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) PreserveTransactions() pulumi.BoolPtrOutput

Whether DMS saves the transaction order for a CDC load on the S3 target specified by `cdcPath`. Default is `false`.

func (EndpointS3SettingsPtrOutput) Rfc4180 added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) Rfc4180() pulumi.BoolPtrOutput

For an S3 source, whether each leading double quotation mark has to be followed by an ending double quotation mark. Default is `true`.

func (EndpointS3SettingsPtrOutput) RowGroupLength added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) RowGroupLength() pulumi.IntPtrOutput

Number of rows in a row group. Default is `10000`.

func (EndpointS3SettingsPtrOutput) ServerSideEncryptionKmsKeyId 

func (o EndpointS3SettingsPtrOutput) ServerSideEncryptionKmsKeyId() pulumi.StringPtrOutput

If you set encryptionMode to `SSE_KMS`, set this parameter to the ARN for the AWS KMS key.

func (EndpointS3SettingsPtrOutput) ServiceAccessRoleArn 

func (o EndpointS3SettingsPtrOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

ARN of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointS3SettingsPtrOutput) TimestampColumnName added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) TimestampColumnName() pulumi.StringPtrOutput

Column to add with timestamp information to the endpoint data for an Amazon S3 target.

func (EndpointS3SettingsPtrOutput) ToEndpointS3SettingsPtrOutput 

func (o EndpointS3SettingsPtrOutput) ToEndpointS3SettingsPtrOutput() EndpointS3SettingsPtrOutput

func (EndpointS3SettingsPtrOutput) ToEndpointS3SettingsPtrOutputWithContext 

func (o EndpointS3SettingsPtrOutput) ToEndpointS3SettingsPtrOutputWithContext(ctx context.Context) EndpointS3SettingsPtrOutput

func (EndpointS3SettingsPtrOutput) UseCsvNoSupValue added in v5.1.0 

func (o EndpointS3SettingsPtrOutput) UseCsvNoSupValue() pulumi.BoolPtrOutput

Whether to use `csvNoSupValue` for columns not included in the supplemental log.

type EndpointState 

type EndpointState struct {
	// ARN for the certificate.
	CertificateArn pulumi.StringPtrInput
	// Name of the endpoint database.
	DatabaseName pulumi.StringPtrInput
	// Configuration block for OpenSearch settings. See below.
	ElasticsearchSettings EndpointElasticsearchSettingsPtrInput
	// ARN for the endpoint.
	EndpointArn pulumi.StringPtrInput
	// Database endpoint identifier. Identifiers must contain from 1 to 255 alphanumeric characters or hyphens, begin with a letter, contain only ASCII letters, digits, and hyphens, not end with a hyphen, and not contain two consecutive hyphens.
	EndpointId pulumi.StringPtrInput
	// Type of endpoint. Valid values are `source`, `target`.
	EndpointType pulumi.StringPtrInput
	// Type of engine for the endpoint. Valid values are `aurora`, `aurora-postgresql`, `azuredb`, `db2`, `docdb`, `dynamodb`, `elasticsearch`, `kafka`, `kinesis`, `mariadb`, `mongodb`, `mysql`, `opensearch`, `oracle`, `postgres`, `redshift`, `s3`, `sqlserver`, `sybase`. Please note that some of engine names are available only for `target` endpoint type (e.g. `redshift`).
	EngineName pulumi.StringPtrInput
	// Additional attributes associated with the connection. For available attributes see [Using Extra Connection Attributes with AWS Database Migration Service](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Source.PostgreSQL.html#CHAP_Source.PostgreSQL.ConnectionAttrib).
	ExtraConnectionAttributes pulumi.StringPtrInput
	// Configuration block for Kafka settings. See below.
	KafkaSettings EndpointKafkaSettingsPtrInput
	// Configuration block for Kinesis settings. See below.
	KinesisSettings EndpointKinesisSettingsPtrInput
	// ARN for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.
	KmsKeyArn pulumi.StringPtrInput
	// Configuration block for MongoDB settings. See below.
	MongodbSettings EndpointMongodbSettingsPtrInput
	// Password to be used to login to the endpoint database.
	Password pulumi.StringPtrInput
	// Port used by the endpoint database.
	Port pulumi.IntPtrInput
	// Configuration block for Redshift settings. See below.
	RedshiftSettings EndpointRedshiftSettingsPtrInput
	// Configuration block for S3 settings. See below.
	S3Settings EndpointS3SettingsPtrInput
	// ARN of the IAM role that specifies AWS DMS as the trusted entity and has the required permissions to access the value in SecretsManagerSecret.
	SecretsManagerAccessRoleArn pulumi.StringPtrInput
	// Full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for `engineName` as `aurora`, `aurora-postgresql`, `mariadb`, `mongodb`, `mysql`, `oracle`, `postgres`, `redshift` or `sqlserver`.
	SecretsManagerArn pulumi.StringPtrInput
	// Host name of the server.
	ServerName pulumi.StringPtrInput
	// ARN used by the service access IAM role for dynamodb endpoints.
	ServiceAccessRole pulumi.StringPtrInput
	// SSL mode to use for the connection. Valid values are `none`, `require`, `verify-ca`, `verify-full`
	SslMode pulumi.StringPtrInput
	// Map of tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// Map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
	// User name to be used to login to the endpoint database.
	Username pulumi.StringPtrInput
}

func (EndpointState) ElementType 

func (EndpointState) ElementType() reflect.Type

type EventSubscription 

type EventSubscription struct {
	pulumi.CustomResourceState

	// Amazon Resource Name (ARN) of the DMS Event Subscription.
	Arn pulumi.StringOutput `pulumi:"arn"`
	// Whether the event subscription should be enabled.
	Enabled pulumi.BoolPtrOutput `pulumi:"enabled"`
	// List of event categories to listen for, see `DescribeEventCategories` for a canonical list.
	EventCategories pulumi.StringArrayOutput `pulumi:"eventCategories"`
	// Name of event subscription.
	Name pulumi.StringOutput `pulumi:"name"`
	// SNS topic arn to send events on.
	SnsTopicArn pulumi.StringOutput `pulumi:"snsTopicArn"`
	// Ids of sources to listen to.
	SourceIds pulumi.StringArrayOutput `pulumi:"sourceIds"`
	// Type of source for events. Valid values: `replication-instance` or `replication-task`
	SourceType pulumi.StringPtrOutput `pulumi:"sourceType"`
	// Map of resource tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
}

Provides a DMS (Data Migration Service) event subscription resource.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dms.NewEventSubscription(ctx, "example", &dms.EventSubscriptionArgs{
			Enabled: pulumi.Bool(true),
			EventCategories: pulumi.StringArray{
				pulumi.String("creation"),
				pulumi.String("failure"),
			},
			SnsTopicArn: pulumi.Any(aws_sns_topic.Example.Arn),
			SourceIds: pulumi.StringArray{
				pulumi.Any(aws_dms_replication_task.Example.Replication_task_id),
			},
			SourceType: pulumi.String("replication-task"),
			Tags: pulumi.StringMap{
				"Name": pulumi.String("example"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Event subscriptions can be imported using the `name`, e.g.,

```sh 

$ pulumi import aws:dms/eventSubscription:EventSubscription test my-awesome-event-subscription

```

func GetEventSubscription 

func GetEventSubscription(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *EventSubscriptionState, opts ...pulumi.ResourceOption) (*EventSubscription, error)

GetEventSubscription gets an existing EventSubscription 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 NewEventSubscription 

func NewEventSubscription(ctx *pulumi.Context,
	name string, args *EventSubscriptionArgs, opts ...pulumi.ResourceOption) (*EventSubscription, error)

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

func (*EventSubscription) ElementType 

func (*EventSubscription) ElementType() reflect.Type

func (*EventSubscription) ToEventSubscriptionOutput 

func (i *EventSubscription) ToEventSubscriptionOutput() EventSubscriptionOutput

func (*EventSubscription) ToEventSubscriptionOutputWithContext 

func (i *EventSubscription) ToEventSubscriptionOutputWithContext(ctx context.Context) EventSubscriptionOutput

type EventSubscriptionArgs 

type EventSubscriptionArgs struct {
	// Whether the event subscription should be enabled.
	Enabled pulumi.BoolPtrInput
	// List of event categories to listen for, see `DescribeEventCategories` for a canonical list.
	EventCategories pulumi.StringArrayInput
	// Name of event subscription.
	Name pulumi.StringPtrInput
	// SNS topic arn to send events on.
	SnsTopicArn pulumi.StringInput
	// Ids of sources to listen to.
	SourceIds pulumi.StringArrayInput
	// Type of source for events. Valid values: `replication-instance` or `replication-task`
	SourceType pulumi.StringPtrInput
	// Map of resource tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
}

The set of arguments for constructing a EventSubscription resource.

func (EventSubscriptionArgs) ElementType 

func (EventSubscriptionArgs) ElementType() reflect.Type

type EventSubscriptionArray 

type EventSubscriptionArray []EventSubscriptionInput

func (EventSubscriptionArray) ElementType 

func (EventSubscriptionArray) ElementType() reflect.Type

func (EventSubscriptionArray) ToEventSubscriptionArrayOutput 

func (i EventSubscriptionArray) ToEventSubscriptionArrayOutput() EventSubscriptionArrayOutput

func (EventSubscriptionArray) ToEventSubscriptionArrayOutputWithContext 

func (i EventSubscriptionArray) ToEventSubscriptionArrayOutputWithContext(ctx context.Context) EventSubscriptionArrayOutput

type EventSubscriptionArrayInput 

type EventSubscriptionArrayInput interface {
	pulumi.Input

	ToEventSubscriptionArrayOutput() EventSubscriptionArrayOutput
	ToEventSubscriptionArrayOutputWithContext(context.Context) EventSubscriptionArrayOutput
}

EventSubscriptionArrayInput is an input type that accepts EventSubscriptionArray and EventSubscriptionArrayOutput values. You can construct a concrete instance of `EventSubscriptionArrayInput` via: 

EventSubscriptionArray{ EventSubscriptionArgs{...} }

type EventSubscriptionArrayOutput 

type EventSubscriptionArrayOutput struct{ *pulumi.OutputState }

func (EventSubscriptionArrayOutput) ElementType 

func (EventSubscriptionArrayOutput) ElementType() reflect.Type

func (EventSubscriptionArrayOutput) Index 

func (o EventSubscriptionArrayOutput) Index(i pulumi.IntInput) EventSubscriptionOutput

func (EventSubscriptionArrayOutput) ToEventSubscriptionArrayOutput 

func (o EventSubscriptionArrayOutput) ToEventSubscriptionArrayOutput() EventSubscriptionArrayOutput

func (EventSubscriptionArrayOutput) ToEventSubscriptionArrayOutputWithContext 

func (o EventSubscriptionArrayOutput) ToEventSubscriptionArrayOutputWithContext(ctx context.Context) EventSubscriptionArrayOutput

type EventSubscriptionInput 

type EventSubscriptionInput interface {
	pulumi.Input

	ToEventSubscriptionOutput() EventSubscriptionOutput
	ToEventSubscriptionOutputWithContext(ctx context.Context) EventSubscriptionOutput
}

type EventSubscriptionMap 

type EventSubscriptionMap map[string]EventSubscriptionInput

func (EventSubscriptionMap) ElementType 

func (EventSubscriptionMap) ElementType() reflect.Type

func (EventSubscriptionMap) ToEventSubscriptionMapOutput 

func (i EventSubscriptionMap) ToEventSubscriptionMapOutput() EventSubscriptionMapOutput

func (EventSubscriptionMap) ToEventSubscriptionMapOutputWithContext 

func (i EventSubscriptionMap) ToEventSubscriptionMapOutputWithContext(ctx context.Context) EventSubscriptionMapOutput

type EventSubscriptionMapInput 

type EventSubscriptionMapInput interface {
	pulumi.Input

	ToEventSubscriptionMapOutput() EventSubscriptionMapOutput
	ToEventSubscriptionMapOutputWithContext(context.Context) EventSubscriptionMapOutput
}

EventSubscriptionMapInput is an input type that accepts EventSubscriptionMap and EventSubscriptionMapOutput values. You can construct a concrete instance of `EventSubscriptionMapInput` via: 

EventSubscriptionMap{ "key": EventSubscriptionArgs{...} }

type EventSubscriptionMapOutput 

type EventSubscriptionMapOutput struct{ *pulumi.OutputState }

func (EventSubscriptionMapOutput) ElementType 

func (EventSubscriptionMapOutput) ElementType() reflect.Type

func (EventSubscriptionMapOutput) MapIndex 

func (o EventSubscriptionMapOutput) MapIndex(k pulumi.StringInput) EventSubscriptionOutput

func (EventSubscriptionMapOutput) ToEventSubscriptionMapOutput 

func (o EventSubscriptionMapOutput) ToEventSubscriptionMapOutput() EventSubscriptionMapOutput

func (EventSubscriptionMapOutput) ToEventSubscriptionMapOutputWithContext 

func (o EventSubscriptionMapOutput) ToEventSubscriptionMapOutputWithContext(ctx context.Context) EventSubscriptionMapOutput

type EventSubscriptionOutput 

type EventSubscriptionOutput struct{ *pulumi.OutputState }

func (EventSubscriptionOutput) Arn added in v5.4.0 

func (o EventSubscriptionOutput) Arn() pulumi.StringOutput

Amazon Resource Name (ARN) of the DMS Event Subscription.

func (EventSubscriptionOutput) ElementType 

func (EventSubscriptionOutput) ElementType() reflect.Type

func (EventSubscriptionOutput) Enabled added in v5.4.0 

func (o EventSubscriptionOutput) Enabled() pulumi.BoolPtrOutput

Whether the event subscription should be enabled.

func (EventSubscriptionOutput) EventCategories added in v5.4.0 

func (o EventSubscriptionOutput) EventCategories() pulumi.StringArrayOutput

List of event categories to listen for, see `DescribeEventCategories` for a canonical list.

func (EventSubscriptionOutput) Name added in v5.4.0 

func (o EventSubscriptionOutput) Name() pulumi.StringOutput

Name of event subscription.

func (EventSubscriptionOutput) SnsTopicArn added in v5.4.0 

func (o EventSubscriptionOutput) SnsTopicArn() pulumi.StringOutput

SNS topic arn to send events on.

func (EventSubscriptionOutput) SourceIds added in v5.4.0 

func (o EventSubscriptionOutput) SourceIds() pulumi.StringArrayOutput

Ids of sources to listen to.

func (EventSubscriptionOutput) SourceType added in v5.4.0 

func (o EventSubscriptionOutput) SourceType() pulumi.StringPtrOutput

Type of source for events. Valid values: `replication-instance` or `replication-task`

func (EventSubscriptionOutput) Tags added in v5.4.0 

func (o EventSubscriptionOutput) Tags() pulumi.StringMapOutput

Map of resource tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (EventSubscriptionOutput) TagsAll added in v5.4.0 

func (o EventSubscriptionOutput) TagsAll() pulumi.StringMapOutput

A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (EventSubscriptionOutput) ToEventSubscriptionOutput 

func (o EventSubscriptionOutput) ToEventSubscriptionOutput() EventSubscriptionOutput

func (EventSubscriptionOutput) ToEventSubscriptionOutputWithContext 

func (o EventSubscriptionOutput) ToEventSubscriptionOutputWithContext(ctx context.Context) EventSubscriptionOutput

type EventSubscriptionState 

type EventSubscriptionState struct {
	// Amazon Resource Name (ARN) of the DMS Event Subscription.
	Arn pulumi.StringPtrInput
	// Whether the event subscription should be enabled.
	Enabled pulumi.BoolPtrInput
	// List of event categories to listen for, see `DescribeEventCategories` for a canonical list.
	EventCategories pulumi.StringArrayInput
	// Name of event subscription.
	Name pulumi.StringPtrInput
	// SNS topic arn to send events on.
	SnsTopicArn pulumi.StringPtrInput
	// Ids of sources to listen to.
	SourceIds pulumi.StringArrayInput
	// Type of source for events. Valid values: `replication-instance` or `replication-task`
	SourceType pulumi.StringPtrInput
	// Map of resource tags to assign to the resource. If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
}

func (EventSubscriptionState) ElementType 

func (EventSubscriptionState) ElementType() reflect.Type

type ReplicationInstance 

type ReplicationInstance struct {
	pulumi.CustomResourceState

	// The amount of storage (in gigabytes) to be initially allocated for the replication instance.
	AllocatedStorage pulumi.IntOutput `pulumi:"allocatedStorage"`
	// Indicates that major version upgrades are allowed.
	AllowMajorVersionUpgrade pulumi.BoolPtrOutput `pulumi:"allowMajorVersionUpgrade"`
	// Indicates whether the changes should be applied immediately or during the next maintenance window. Only used when updating an existing resource.
	ApplyImmediately pulumi.BoolPtrOutput `pulumi:"applyImmediately"`
	// Indicates that minor engine upgrades will be applied automatically to the replication instance during the maintenance window.
	AutoMinorVersionUpgrade pulumi.BoolOutput `pulumi:"autoMinorVersionUpgrade"`
	// The EC2 Availability Zone that the replication instance will be created in.
	AvailabilityZone pulumi.StringOutput `pulumi:"availabilityZone"`
	// The engine version number of the replication instance.
	EngineVersion pulumi.StringOutput `pulumi:"engineVersion"`
	// The Amazon Resource Name (ARN) for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.
	KmsKeyArn pulumi.StringOutput `pulumi:"kmsKeyArn"`
	// Specifies if the replication instance is a multi-az deployment. You cannot set the `availabilityZone` parameter if the `multiAz` parameter is set to `true`.
	MultiAz pulumi.BoolOutput `pulumi:"multiAz"`
	// The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).
	PreferredMaintenanceWindow pulumi.StringOutput `pulumi:"preferredMaintenanceWindow"`
	// Specifies the accessibility options for the replication instance. A value of true represents an instance with a public IP address. A value of false represents an instance with a private IP address.
	PubliclyAccessible pulumi.BoolOutput `pulumi:"publiclyAccessible"`
	// The Amazon Resource Name (ARN) of the replication instance.
	ReplicationInstanceArn pulumi.StringOutput `pulumi:"replicationInstanceArn"`
	// The compute and memory capacity of the replication instance as specified by the replication instance class. See [AWS DMS User Guide](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_ReplicationInstance.Types.html) for available instance sizes and advice on which one to choose.
	ReplicationInstanceClass pulumi.StringOutput `pulumi:"replicationInstanceClass"`
	// The replication instance identifier. This parameter is stored as a lowercase string.
	ReplicationInstanceId pulumi.StringOutput `pulumi:"replicationInstanceId"`
	// A list of the private IP addresses of the replication instance.
	ReplicationInstancePrivateIps pulumi.StringArrayOutput `pulumi:"replicationInstancePrivateIps"`
	// A list of the public IP addresses of the replication instance.
	ReplicationInstancePublicIps pulumi.StringArrayOutput `pulumi:"replicationInstancePublicIps"`
	// A subnet group to associate with the replication instance.
	ReplicationSubnetGroupId pulumi.StringOutput `pulumi:"replicationSubnetGroupId"`
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// A list of VPC security group IDs to be used with the replication instance. The VPC security groups must work with the VPC containing the replication instance.
	VpcSecurityGroupIds pulumi.StringArrayOutput `pulumi:"vpcSecurityGroupIds"`
}

Provides a DMS (Data Migration Service) replication instance resource. DMS replication instances can be created, updated, deleted, and imported.

## Example Usage

Create required roles and then create a DMS instance, setting the dependsOn to the required role policy attachments.

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/dms"
"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/iam"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		dmsAssumeRole, err := iam.GetPolicyDocument(ctx, &iam.GetPolicyDocumentArgs{
			Statements: []iam.GetPolicyDocumentStatement{
				iam.GetPolicyDocumentStatement{
					Actions: []string{
						"sts:AssumeRole",
					},
					Principals: []iam.GetPolicyDocumentStatementPrincipal{
						iam.GetPolicyDocumentStatementPrincipal{
							Identifiers: []string{
								"dms.amazonaws.com",
							},
							Type: "Service",
						},
					},
				},
			},
		}, nil)
		if err != nil {
			return err
		}
		_, err = iam.NewRole(ctx, "dms-access-for-endpoint", &iam.RoleArgs{
			AssumeRolePolicy: pulumi.String(dmsAssumeRole.Json),
		})
		if err != nil {
			return err
		}
		_, err = iam.NewRolePolicyAttachment(ctx, "dms-access-for-endpoint-AmazonDMSRedshiftS3Role", &iam.RolePolicyAttachmentArgs{
			PolicyArn: pulumi.String("arn:aws:iam::aws:policy/service-role/AmazonDMSRedshiftS3Role"),
			Role:      dms_access_for_endpoint.Name,
		})
		if err != nil {
			return err
		}
		_, err = iam.NewRole(ctx, "dms-cloudwatch-logs-role", &iam.RoleArgs{
			AssumeRolePolicy: pulumi.String(dmsAssumeRole.Json),
		})
		if err != nil {
			return err
		}
		_, err = iam.NewRolePolicyAttachment(ctx, "dms-cloudwatch-logs-role-AmazonDMSCloudWatchLogsRole", &iam.RolePolicyAttachmentArgs{
			PolicyArn: pulumi.String("arn:aws:iam::aws:policy/service-role/AmazonDMSCloudWatchLogsRole"),
			Role:      dms_cloudwatch_logs_role.Name,
		})
		if err != nil {
			return err
		}
		_, err = iam.NewRole(ctx, "dms-vpc-role", &iam.RoleArgs{
			AssumeRolePolicy: pulumi.String(dmsAssumeRole.Json),
		})
		if err != nil {
			return err
		}
		_, err = iam.NewRolePolicyAttachment(ctx, "dms-vpc-role-AmazonDMSVPCManagementRole", &iam.RolePolicyAttachmentArgs{
			PolicyArn: pulumi.String("arn:aws:iam::aws:policy/service-role/AmazonDMSVPCManagementRole"),
			Role:      dms_vpc_role.Name,
		})
		if err != nil {
			return err
		}
		_, err = dms.NewReplicationInstance(ctx, "test", &dms.ReplicationInstanceArgs{
			AllocatedStorage:           pulumi.Int(20),
			ApplyImmediately:           pulumi.Bool(true),
			AutoMinorVersionUpgrade:    pulumi.Bool(true),
			AvailabilityZone:           pulumi.String("us-west-2c"),
			EngineVersion:              pulumi.String("3.1.4"),
			KmsKeyArn:                  pulumi.String("arn:aws:kms:us-east-1:123456789012:key/12345678-1234-1234-1234-123456789012"),
			MultiAz:                    pulumi.Bool(false),
			PreferredMaintenanceWindow: pulumi.String("sun:10:30-sun:14:30"),
			PubliclyAccessible:         pulumi.Bool(true),
			ReplicationInstanceClass:   pulumi.String("dms.t2.micro"),
			ReplicationInstanceId:      pulumi.String("test-dms-replication-instance-tf"),
			ReplicationSubnetGroupId:   pulumi.Any(aws_dms_replication_subnet_group.Test - dms - replication - subnet - group - tf.Id),
			Tags: pulumi.StringMap{
				"Name": pulumi.String("test"),
			},
			VpcSecurityGroupIds: pulumi.StringArray{
				pulumi.String("sg-12345678"),
			},
		}, pulumi.DependsOn([]pulumi.Resource{
			dms_access_for_endpoint_AmazonDMSRedshiftS3Role,
			dms_cloudwatch_logs_role_AmazonDMSCloudWatchLogsRole,
			dms_vpc_role_AmazonDMSVPCManagementRole,
		}))
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Replication instances can be imported using the `replication_instance_id`, e.g.,

```sh 

$ pulumi import aws:dms/replicationInstance:ReplicationInstance test test-dms-replication-instance-tf

```

func GetReplicationInstance 

func GetReplicationInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ReplicationInstanceState, opts ...pulumi.ResourceOption) (*ReplicationInstance, error)

GetReplicationInstance gets an existing ReplicationInstance 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 NewReplicationInstance 

func NewReplicationInstance(ctx *pulumi.Context,
	name string, args *ReplicationInstanceArgs, opts ...pulumi.ResourceOption) (*ReplicationInstance, error)

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

func (*ReplicationInstance) ElementType 

func (*ReplicationInstance) ElementType() reflect.Type

func (*ReplicationInstance) ToReplicationInstanceOutput 

func (i *ReplicationInstance) ToReplicationInstanceOutput() ReplicationInstanceOutput

func (*ReplicationInstance) ToReplicationInstanceOutputWithContext 

func (i *ReplicationInstance) ToReplicationInstanceOutputWithContext(ctx context.Context) ReplicationInstanceOutput

type ReplicationInstanceArgs 

type ReplicationInstanceArgs struct {
	// The amount of storage (in gigabytes) to be initially allocated for the replication instance.
	AllocatedStorage pulumi.IntPtrInput
	// Indicates that major version upgrades are allowed.
	AllowMajorVersionUpgrade pulumi.BoolPtrInput
	// Indicates whether the changes should be applied immediately or during the next maintenance window. Only used when updating an existing resource.
	ApplyImmediately pulumi.BoolPtrInput
	// Indicates that minor engine upgrades will be applied automatically to the replication instance during the maintenance window.
	AutoMinorVersionUpgrade pulumi.BoolPtrInput
	// The EC2 Availability Zone that the replication instance will be created in.
	AvailabilityZone pulumi.StringPtrInput
	// The engine version number of the replication instance.
	EngineVersion pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.
	KmsKeyArn pulumi.StringPtrInput
	// Specifies if the replication instance is a multi-az deployment. You cannot set the `availabilityZone` parameter if the `multiAz` parameter is set to `true`.
	MultiAz pulumi.BoolPtrInput
	// The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).
	PreferredMaintenanceWindow pulumi.StringPtrInput
	// Specifies the accessibility options for the replication instance. A value of true represents an instance with a public IP address. A value of false represents an instance with a private IP address.
	PubliclyAccessible pulumi.BoolPtrInput
	// The compute and memory capacity of the replication instance as specified by the replication instance class. See [AWS DMS User Guide](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_ReplicationInstance.Types.html) for available instance sizes and advice on which one to choose.
	ReplicationInstanceClass pulumi.StringInput
	// The replication instance identifier. This parameter is stored as a lowercase string.
	ReplicationInstanceId pulumi.StringInput
	// A subnet group to associate with the replication instance.
	ReplicationSubnetGroupId pulumi.StringPtrInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A list of VPC security group IDs to be used with the replication instance. The VPC security groups must work with the VPC containing the replication instance.
	VpcSecurityGroupIds pulumi.StringArrayInput
}

The set of arguments for constructing a ReplicationInstance resource.

func (ReplicationInstanceArgs) ElementType 

func (ReplicationInstanceArgs) ElementType() reflect.Type

type ReplicationInstanceArray 

type ReplicationInstanceArray []ReplicationInstanceInput

func (ReplicationInstanceArray) ElementType 

func (ReplicationInstanceArray) ElementType() reflect.Type

func (ReplicationInstanceArray) ToReplicationInstanceArrayOutput 

func (i ReplicationInstanceArray) ToReplicationInstanceArrayOutput() ReplicationInstanceArrayOutput

func (ReplicationInstanceArray) ToReplicationInstanceArrayOutputWithContext 

func (i ReplicationInstanceArray) ToReplicationInstanceArrayOutputWithContext(ctx context.Context) ReplicationInstanceArrayOutput

type ReplicationInstanceArrayInput 

type ReplicationInstanceArrayInput interface {
	pulumi.Input

	ToReplicationInstanceArrayOutput() ReplicationInstanceArrayOutput
	ToReplicationInstanceArrayOutputWithContext(context.Context) ReplicationInstanceArrayOutput
}

ReplicationInstanceArrayInput is an input type that accepts ReplicationInstanceArray and ReplicationInstanceArrayOutput values. You can construct a concrete instance of `ReplicationInstanceArrayInput` via: 

ReplicationInstanceArray{ ReplicationInstanceArgs{...} }

type ReplicationInstanceArrayOutput 

type ReplicationInstanceArrayOutput struct{ *pulumi.OutputState }

func (ReplicationInstanceArrayOutput) ElementType 

func (ReplicationInstanceArrayOutput) ElementType() reflect.Type

func (ReplicationInstanceArrayOutput) Index 

func (o ReplicationInstanceArrayOutput) Index(i pulumi.IntInput) ReplicationInstanceOutput

func (ReplicationInstanceArrayOutput) ToReplicationInstanceArrayOutput 

func (o ReplicationInstanceArrayOutput) ToReplicationInstanceArrayOutput() ReplicationInstanceArrayOutput

func (ReplicationInstanceArrayOutput) ToReplicationInstanceArrayOutputWithContext 

func (o ReplicationInstanceArrayOutput) ToReplicationInstanceArrayOutputWithContext(ctx context.Context) ReplicationInstanceArrayOutput

type ReplicationInstanceInput 

type ReplicationInstanceInput interface {
	pulumi.Input

	ToReplicationInstanceOutput() ReplicationInstanceOutput
	ToReplicationInstanceOutputWithContext(ctx context.Context) ReplicationInstanceOutput
}

type ReplicationInstanceMap 

type ReplicationInstanceMap map[string]ReplicationInstanceInput

func (ReplicationInstanceMap) ElementType 

func (ReplicationInstanceMap) ElementType() reflect.Type

func (ReplicationInstanceMap) ToReplicationInstanceMapOutput 

func (i ReplicationInstanceMap) ToReplicationInstanceMapOutput() ReplicationInstanceMapOutput

func (ReplicationInstanceMap) ToReplicationInstanceMapOutputWithContext 

func (i ReplicationInstanceMap) ToReplicationInstanceMapOutputWithContext(ctx context.Context) ReplicationInstanceMapOutput

type ReplicationInstanceMapInput 

type ReplicationInstanceMapInput interface {
	pulumi.Input

	ToReplicationInstanceMapOutput() ReplicationInstanceMapOutput
	ToReplicationInstanceMapOutputWithContext(context.Context) ReplicationInstanceMapOutput
}

ReplicationInstanceMapInput is an input type that accepts ReplicationInstanceMap and ReplicationInstanceMapOutput values. You can construct a concrete instance of `ReplicationInstanceMapInput` via: 

ReplicationInstanceMap{ "key": ReplicationInstanceArgs{...} }

type ReplicationInstanceMapOutput 

type ReplicationInstanceMapOutput struct{ *pulumi.OutputState }

func (ReplicationInstanceMapOutput) ElementType 

func (ReplicationInstanceMapOutput) ElementType() reflect.Type

func (ReplicationInstanceMapOutput) MapIndex 

func (o ReplicationInstanceMapOutput) MapIndex(k pulumi.StringInput) ReplicationInstanceOutput

func (ReplicationInstanceMapOutput) ToReplicationInstanceMapOutput 

func (o ReplicationInstanceMapOutput) ToReplicationInstanceMapOutput() ReplicationInstanceMapOutput

func (ReplicationInstanceMapOutput) ToReplicationInstanceMapOutputWithContext 

func (o ReplicationInstanceMapOutput) ToReplicationInstanceMapOutputWithContext(ctx context.Context) ReplicationInstanceMapOutput

type ReplicationInstanceOutput 

type ReplicationInstanceOutput struct{ *pulumi.OutputState }

func (ReplicationInstanceOutput) AllocatedStorage added in v5.4.0 

func (o ReplicationInstanceOutput) AllocatedStorage() pulumi.IntOutput

The amount of storage (in gigabytes) to be initially allocated for the replication instance.

func (ReplicationInstanceOutput) AllowMajorVersionUpgrade added in v5.4.0 

func (o ReplicationInstanceOutput) AllowMajorVersionUpgrade() pulumi.BoolPtrOutput

Indicates that major version upgrades are allowed.

func (ReplicationInstanceOutput) ApplyImmediately added in v5.4.0 

func (o ReplicationInstanceOutput) ApplyImmediately() pulumi.BoolPtrOutput

Indicates whether the changes should be applied immediately or during the next maintenance window. Only used when updating an existing resource.

func (ReplicationInstanceOutput) AutoMinorVersionUpgrade added in v5.4.0 

func (o ReplicationInstanceOutput) AutoMinorVersionUpgrade() pulumi.BoolOutput

Indicates that minor engine upgrades will be applied automatically to the replication instance during the maintenance window.

func (ReplicationInstanceOutput) AvailabilityZone added in v5.4.0 

func (o ReplicationInstanceOutput) AvailabilityZone() pulumi.StringOutput

The EC2 Availability Zone that the replication instance will be created in.

func (ReplicationInstanceOutput) ElementType 

func (ReplicationInstanceOutput) ElementType() reflect.Type

func (ReplicationInstanceOutput) EngineVersion added in v5.4.0 

func (o ReplicationInstanceOutput) EngineVersion() pulumi.StringOutput

The engine version number of the replication instance.

func (ReplicationInstanceOutput) KmsKeyArn added in v5.4.0 

func (o ReplicationInstanceOutput) KmsKeyArn() pulumi.StringOutput

The Amazon Resource Name (ARN) for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.

func (ReplicationInstanceOutput) MultiAz added in v5.4.0 

func (o ReplicationInstanceOutput) MultiAz() pulumi.BoolOutput

Specifies if the replication instance is a multi-az deployment. You cannot set the `availabilityZone` parameter if the `multiAz` parameter is set to `true`.

func (ReplicationInstanceOutput) PreferredMaintenanceWindow added in v5.4.0 

func (o ReplicationInstanceOutput) PreferredMaintenanceWindow() pulumi.StringOutput

The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).

func (ReplicationInstanceOutput) PubliclyAccessible added in v5.4.0 

func (o ReplicationInstanceOutput) PubliclyAccessible() pulumi.BoolOutput

Specifies the accessibility options for the replication instance. A value of true represents an instance with a public IP address. A value of false represents an instance with a private IP address.

func (ReplicationInstanceOutput) ReplicationInstanceArn added in v5.4.0 

func (o ReplicationInstanceOutput) ReplicationInstanceArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the replication instance.

func (ReplicationInstanceOutput) ReplicationInstanceClass added in v5.4.0 

func (o ReplicationInstanceOutput) ReplicationInstanceClass() pulumi.StringOutput

The compute and memory capacity of the replication instance as specified by the replication instance class. See [AWS DMS User Guide](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_ReplicationInstance.Types.html) for available instance sizes and advice on which one to choose.

func (ReplicationInstanceOutput) ReplicationInstanceId added in v5.4.0 

func (o ReplicationInstanceOutput) ReplicationInstanceId() pulumi.StringOutput

The replication instance identifier. This parameter is stored as a lowercase string.

func (ReplicationInstanceOutput) ReplicationInstancePrivateIps added in v5.4.0 

func (o ReplicationInstanceOutput) ReplicationInstancePrivateIps() pulumi.StringArrayOutput

A list of the private IP addresses of the replication instance.

func (ReplicationInstanceOutput) ReplicationInstancePublicIps added in v5.4.0 

func (o ReplicationInstanceOutput) ReplicationInstancePublicIps() pulumi.StringArrayOutput

A list of the public IP addresses of the replication instance.

func (ReplicationInstanceOutput) ReplicationSubnetGroupId added in v5.4.0 

func (o ReplicationInstanceOutput) ReplicationSubnetGroupId() pulumi.StringOutput

A subnet group to associate with the replication instance.

func (ReplicationInstanceOutput) Tags added in v5.4.0 

func (o ReplicationInstanceOutput) Tags() pulumi.StringMapOutput

A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (ReplicationInstanceOutput) TagsAll added in v5.4.0 

func (o ReplicationInstanceOutput) TagsAll() pulumi.StringMapOutput

A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (ReplicationInstanceOutput) ToReplicationInstanceOutput 

func (o ReplicationInstanceOutput) ToReplicationInstanceOutput() ReplicationInstanceOutput

func (ReplicationInstanceOutput) ToReplicationInstanceOutputWithContext 

func (o ReplicationInstanceOutput) ToReplicationInstanceOutputWithContext(ctx context.Context) ReplicationInstanceOutput

func (ReplicationInstanceOutput) VpcSecurityGroupIds added in v5.4.0 

func (o ReplicationInstanceOutput) VpcSecurityGroupIds() pulumi.StringArrayOutput

A list of VPC security group IDs to be used with the replication instance. The VPC security groups must work with the VPC containing the replication instance.

type ReplicationInstanceState 

type ReplicationInstanceState struct {
	// The amount of storage (in gigabytes) to be initially allocated for the replication instance.
	AllocatedStorage pulumi.IntPtrInput
	// Indicates that major version upgrades are allowed.
	AllowMajorVersionUpgrade pulumi.BoolPtrInput
	// Indicates whether the changes should be applied immediately or during the next maintenance window. Only used when updating an existing resource.
	ApplyImmediately pulumi.BoolPtrInput
	// Indicates that minor engine upgrades will be applied automatically to the replication instance during the maintenance window.
	AutoMinorVersionUpgrade pulumi.BoolPtrInput
	// The EC2 Availability Zone that the replication instance will be created in.
	AvailabilityZone pulumi.StringPtrInput
	// The engine version number of the replication instance.
	EngineVersion pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for `kmsKeyArn`, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region.
	KmsKeyArn pulumi.StringPtrInput
	// Specifies if the replication instance is a multi-az deployment. You cannot set the `availabilityZone` parameter if the `multiAz` parameter is set to `true`.
	MultiAz pulumi.BoolPtrInput
	// The weekly time range during which system maintenance can occur, in Universal Coordinated Time (UTC).
	PreferredMaintenanceWindow pulumi.StringPtrInput
	// Specifies the accessibility options for the replication instance. A value of true represents an instance with a public IP address. A value of false represents an instance with a private IP address.
	PubliclyAccessible pulumi.BoolPtrInput
	// The Amazon Resource Name (ARN) of the replication instance.
	ReplicationInstanceArn pulumi.StringPtrInput
	// The compute and memory capacity of the replication instance as specified by the replication instance class. See [AWS DMS User Guide](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_ReplicationInstance.Types.html) for available instance sizes and advice on which one to choose.
	ReplicationInstanceClass pulumi.StringPtrInput
	// The replication instance identifier. This parameter is stored as a lowercase string.
	ReplicationInstanceId pulumi.StringPtrInput
	// A list of the private IP addresses of the replication instance.
	ReplicationInstancePrivateIps pulumi.StringArrayInput
	// A list of the public IP addresses of the replication instance.
	ReplicationInstancePublicIps pulumi.StringArrayInput
	// A subnet group to associate with the replication instance.
	ReplicationSubnetGroupId pulumi.StringPtrInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
	// A list of VPC security group IDs to be used with the replication instance. The VPC security groups must work with the VPC containing the replication instance.
	VpcSecurityGroupIds pulumi.StringArrayInput
}

func (ReplicationInstanceState) ElementType 

func (ReplicationInstanceState) ElementType() reflect.Type

type ReplicationSubnetGroup 

type ReplicationSubnetGroup struct {
	pulumi.CustomResourceState

	ReplicationSubnetGroupArn pulumi.StringOutput `pulumi:"replicationSubnetGroupArn"`
	// The description for the subnet group.
	ReplicationSubnetGroupDescription pulumi.StringOutput `pulumi:"replicationSubnetGroupDescription"`
	// The name for the replication subnet group. This value is stored as a lowercase string.
	ReplicationSubnetGroupId pulumi.StringOutput `pulumi:"replicationSubnetGroupId"`
	// A list of the EC2 subnet IDs for the subnet group.
	SubnetIds pulumi.StringArrayOutput `pulumi:"subnetIds"`
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// The ID of the VPC the subnet group is in.
	VpcId pulumi.StringOutput `pulumi:"vpcId"`
}

Provides a DMS (Data Migration Service) replication subnet group resource. DMS replication subnet groups can be created, updated, deleted, and imported.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dms.NewReplicationSubnetGroup(ctx, "test", &dms.ReplicationSubnetGroupArgs{
			ReplicationSubnetGroupDescription: pulumi.String("Test replication subnet group"),
			ReplicationSubnetGroupId:          pulumi.String("test-dms-replication-subnet-group-tf"),
			SubnetIds: pulumi.StringArray{
				pulumi.String("subnet-12345678"),
			},
			Tags: pulumi.StringMap{
				"Name": pulumi.String("test"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Replication subnet groups can be imported using the `replication_subnet_group_id`, e.g.,

```sh 

$ pulumi import aws:dms/replicationSubnetGroup:ReplicationSubnetGroup test test-dms-replication-subnet-group-tf

```

func GetReplicationSubnetGroup 

func GetReplicationSubnetGroup(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ReplicationSubnetGroupState, opts ...pulumi.ResourceOption) (*ReplicationSubnetGroup, error)

GetReplicationSubnetGroup gets an existing ReplicationSubnetGroup 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 NewReplicationSubnetGroup 

func NewReplicationSubnetGroup(ctx *pulumi.Context,
	name string, args *ReplicationSubnetGroupArgs, opts ...pulumi.ResourceOption) (*ReplicationSubnetGroup, error)

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

func (*ReplicationSubnetGroup) ElementType 

func (*ReplicationSubnetGroup) ElementType() reflect.Type

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupOutput 

func (i *ReplicationSubnetGroup) ToReplicationSubnetGroupOutput() ReplicationSubnetGroupOutput

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupOutputWithContext 

func (i *ReplicationSubnetGroup) ToReplicationSubnetGroupOutputWithContext(ctx context.Context) ReplicationSubnetGroupOutput

type ReplicationSubnetGroupArgs 

type ReplicationSubnetGroupArgs struct {
	// The description for the subnet group.
	ReplicationSubnetGroupDescription pulumi.StringInput
	// The name for the replication subnet group. This value is stored as a lowercase string.
	ReplicationSubnetGroupId pulumi.StringInput
	// A list of the EC2 subnet IDs for the subnet group.
	SubnetIds pulumi.StringArrayInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
}

The set of arguments for constructing a ReplicationSubnetGroup resource.

func (ReplicationSubnetGroupArgs) ElementType 

func (ReplicationSubnetGroupArgs) ElementType() reflect.Type

type ReplicationSubnetGroupArray 

type ReplicationSubnetGroupArray []ReplicationSubnetGroupInput

func (ReplicationSubnetGroupArray) ElementType 

func (ReplicationSubnetGroupArray) ElementType() reflect.Type

func (ReplicationSubnetGroupArray) ToReplicationSubnetGroupArrayOutput 

func (i ReplicationSubnetGroupArray) ToReplicationSubnetGroupArrayOutput() ReplicationSubnetGroupArrayOutput

func (ReplicationSubnetGroupArray) ToReplicationSubnetGroupArrayOutputWithContext 

func (i ReplicationSubnetGroupArray) ToReplicationSubnetGroupArrayOutputWithContext(ctx context.Context) ReplicationSubnetGroupArrayOutput

type ReplicationSubnetGroupArrayInput 

type ReplicationSubnetGroupArrayInput interface {
	pulumi.Input

	ToReplicationSubnetGroupArrayOutput() ReplicationSubnetGroupArrayOutput
	ToReplicationSubnetGroupArrayOutputWithContext(context.Context) ReplicationSubnetGroupArrayOutput
}

ReplicationSubnetGroupArrayInput is an input type that accepts ReplicationSubnetGroupArray and ReplicationSubnetGroupArrayOutput values. You can construct a concrete instance of `ReplicationSubnetGroupArrayInput` via: 

ReplicationSubnetGroupArray{ ReplicationSubnetGroupArgs{...} }

type ReplicationSubnetGroupArrayOutput 

type ReplicationSubnetGroupArrayOutput struct{ *pulumi.OutputState }

func (ReplicationSubnetGroupArrayOutput) ElementType 

func (ReplicationSubnetGroupArrayOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupArrayOutput) Index 

func (o ReplicationSubnetGroupArrayOutput) Index(i pulumi.IntInput) ReplicationSubnetGroupOutput

func (ReplicationSubnetGroupArrayOutput) ToReplicationSubnetGroupArrayOutput 

func (o ReplicationSubnetGroupArrayOutput) ToReplicationSubnetGroupArrayOutput() ReplicationSubnetGroupArrayOutput

func (ReplicationSubnetGroupArrayOutput) ToReplicationSubnetGroupArrayOutputWithContext 

func (o ReplicationSubnetGroupArrayOutput) ToReplicationSubnetGroupArrayOutputWithContext(ctx context.Context) ReplicationSubnetGroupArrayOutput

type ReplicationSubnetGroupInput 

type ReplicationSubnetGroupInput interface {
	pulumi.Input

	ToReplicationSubnetGroupOutput() ReplicationSubnetGroupOutput
	ToReplicationSubnetGroupOutputWithContext(ctx context.Context) ReplicationSubnetGroupOutput
}

type ReplicationSubnetGroupMap 

type ReplicationSubnetGroupMap map[string]ReplicationSubnetGroupInput

func (ReplicationSubnetGroupMap) ElementType 

func (ReplicationSubnetGroupMap) ElementType() reflect.Type

func (ReplicationSubnetGroupMap) ToReplicationSubnetGroupMapOutput 

func (i ReplicationSubnetGroupMap) ToReplicationSubnetGroupMapOutput() ReplicationSubnetGroupMapOutput

func (ReplicationSubnetGroupMap) ToReplicationSubnetGroupMapOutputWithContext 

func (i ReplicationSubnetGroupMap) ToReplicationSubnetGroupMapOutputWithContext(ctx context.Context) ReplicationSubnetGroupMapOutput

type ReplicationSubnetGroupMapInput 

type ReplicationSubnetGroupMapInput interface {
	pulumi.Input

	ToReplicationSubnetGroupMapOutput() ReplicationSubnetGroupMapOutput
	ToReplicationSubnetGroupMapOutputWithContext(context.Context) ReplicationSubnetGroupMapOutput
}

ReplicationSubnetGroupMapInput is an input type that accepts ReplicationSubnetGroupMap and ReplicationSubnetGroupMapOutput values. You can construct a concrete instance of `ReplicationSubnetGroupMapInput` via: 

ReplicationSubnetGroupMap{ "key": ReplicationSubnetGroupArgs{...} }

type ReplicationSubnetGroupMapOutput 

type ReplicationSubnetGroupMapOutput struct{ *pulumi.OutputState }

func (ReplicationSubnetGroupMapOutput) ElementType 

func (ReplicationSubnetGroupMapOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupMapOutput) MapIndex 

func (o ReplicationSubnetGroupMapOutput) MapIndex(k pulumi.StringInput) ReplicationSubnetGroupOutput

func (ReplicationSubnetGroupMapOutput) ToReplicationSubnetGroupMapOutput 

func (o ReplicationSubnetGroupMapOutput) ToReplicationSubnetGroupMapOutput() ReplicationSubnetGroupMapOutput

func (ReplicationSubnetGroupMapOutput) ToReplicationSubnetGroupMapOutputWithContext 

func (o ReplicationSubnetGroupMapOutput) ToReplicationSubnetGroupMapOutputWithContext(ctx context.Context) ReplicationSubnetGroupMapOutput

type ReplicationSubnetGroupOutput 

type ReplicationSubnetGroupOutput struct{ *pulumi.OutputState }

func (ReplicationSubnetGroupOutput) ElementType 

func (ReplicationSubnetGroupOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupOutput) ReplicationSubnetGroupArn added in v5.4.0 

func (o ReplicationSubnetGroupOutput) ReplicationSubnetGroupArn() pulumi.StringOutput

func (ReplicationSubnetGroupOutput) ReplicationSubnetGroupDescription added in v5.4.0 

func (o ReplicationSubnetGroupOutput) ReplicationSubnetGroupDescription() pulumi.StringOutput

The description for the subnet group.

func (ReplicationSubnetGroupOutput) ReplicationSubnetGroupId added in v5.4.0 

func (o ReplicationSubnetGroupOutput) ReplicationSubnetGroupId() pulumi.StringOutput

The name for the replication subnet group. This value is stored as a lowercase string.

func (ReplicationSubnetGroupOutput) SubnetIds added in v5.4.0 

func (o ReplicationSubnetGroupOutput) SubnetIds() pulumi.StringArrayOutput

A list of the EC2 subnet IDs for the subnet group.

func (ReplicationSubnetGroupOutput) Tags added in v5.4.0 

func (o ReplicationSubnetGroupOutput) Tags() pulumi.StringMapOutput

A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (ReplicationSubnetGroupOutput) TagsAll added in v5.4.0 

func (o ReplicationSubnetGroupOutput) TagsAll() pulumi.StringMapOutput

A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutput 

func (o ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutput() ReplicationSubnetGroupOutput

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutputWithContext 

func (o ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutputWithContext(ctx context.Context) ReplicationSubnetGroupOutput

func (ReplicationSubnetGroupOutput) VpcId added in v5.4.0 

func (o ReplicationSubnetGroupOutput) VpcId() pulumi.StringOutput

The ID of the VPC the subnet group is in.

type ReplicationSubnetGroupState 

type ReplicationSubnetGroupState struct {
	ReplicationSubnetGroupArn pulumi.StringPtrInput
	// The description for the subnet group.
	ReplicationSubnetGroupDescription pulumi.StringPtrInput
	// The name for the replication subnet group. This value is stored as a lowercase string.
	ReplicationSubnetGroupId pulumi.StringPtrInput
	// A list of the EC2 subnet IDs for the subnet group.
	SubnetIds pulumi.StringArrayInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
	// The ID of the VPC the subnet group is in.
	VpcId pulumi.StringPtrInput
}

func (ReplicationSubnetGroupState) ElementType 

func (ReplicationSubnetGroupState) ElementType() reflect.Type

type ReplicationTask 

type ReplicationTask struct {
	pulumi.CustomResourceState

	// Indicates when you want a change data capture (CDC) operation to start. The value can be in date, checkpoint, or LSN/SCN format depending on the source engine. For more information, see [Determining a CDC native start point](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Task.CDC.html#CHAP_Task.CDC.StartPoint.Native).
	CdcStartPosition pulumi.StringOutput `pulumi:"cdcStartPosition"`
	// The Unix timestamp integer for the start of the Change Data Capture (CDC) operation.
	CdcStartTime pulumi.StringPtrOutput `pulumi:"cdcStartTime"`
	// The migration type. Can be one of `full-load | cdc | full-load-and-cdc`.
	MigrationType pulumi.StringOutput `pulumi:"migrationType"`
	// The Amazon Resource Name (ARN) of the replication instance.
	ReplicationInstanceArn pulumi.StringOutput `pulumi:"replicationInstanceArn"`
	// The Amazon Resource Name (ARN) for the replication task.
	ReplicationTaskArn pulumi.StringOutput `pulumi:"replicationTaskArn"`
	// The replication task identifier.
	ReplicationTaskId pulumi.StringOutput `pulumi:"replicationTaskId"`
	// An escaped JSON string that contains the task settings. For a complete list of task settings, see [Task Settings for AWS Database Migration Service Tasks](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TaskSettings.html).
	ReplicationTaskSettings pulumi.StringPtrOutput `pulumi:"replicationTaskSettings"`
	// The Amazon Resource Name (ARN) string that uniquely identifies the source endpoint.
	SourceEndpointArn pulumi.StringOutput `pulumi:"sourceEndpointArn"`
	// Whether to run or stop the replication task.
	StartReplicationTask pulumi.BoolPtrOutput `pulumi:"startReplicationTask"`
	// Replication Task status.
	Status pulumi.StringOutput `pulumi:"status"`
	// An escaped JSON string that contains the table mappings. For information on table mapping see [Using Table Mapping with an AWS Database Migration Service Task to Select and Filter Data](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TableMapping.html)
	TableMappings pulumi.StringOutput `pulumi:"tableMappings"`
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// The Amazon Resource Name (ARN) string that uniquely identifies the target endpoint.
	TargetEndpointArn pulumi.StringOutput `pulumi:"targetEndpointArn"`
}

Provides a DMS (Data Migration Service) replication task resource. DMS replication tasks can be created, updated, deleted, and imported.

> **NOTE:** Changing most arguments will stop the task if it is running. You can set `startReplicationTask` to resume the task afterwards.

## Example Usage

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-aws/sdk/v5/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dms.NewReplicationTask(ctx, "test", &dms.ReplicationTaskArgs{
			CdcStartTime:            pulumi.String("1484346880"),
			MigrationType:           pulumi.String("full-load"),
			ReplicationInstanceArn:  pulumi.Any(aws_dms_replication_instance.Test - dms - replication - instance - tf.Replication_instance_arn),
			ReplicationTaskId:       pulumi.String("test-dms-replication-task-tf"),
			ReplicationTaskSettings: pulumi.String("..."),
			SourceEndpointArn:       pulumi.Any(aws_dms_endpoint.Test - dms - source - endpoint - tf.Endpoint_arn),
			TableMappings:           pulumi.String(fmt.Sprintf("{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"%v\",\"table-name\":\"%v\"},\"rule-action\":\"include\"}]}", "%", "%")),
			Tags: pulumi.StringMap{
				"Name": pulumi.String("test"),
			},
			TargetEndpointArn: pulumi.Any(aws_dms_endpoint.Test - dms - target - endpoint - tf.Endpoint_arn),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

Replication tasks can be imported using the `replication_task_id`, e.g.,

```sh 

$ pulumi import aws:dms/replicationTask:ReplicationTask test test-dms-replication-task-tf

```

func GetReplicationTask 

func GetReplicationTask(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ReplicationTaskState, opts ...pulumi.ResourceOption) (*ReplicationTask, error)

GetReplicationTask gets an existing ReplicationTask 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 NewReplicationTask 

func NewReplicationTask(ctx *pulumi.Context,
	name string, args *ReplicationTaskArgs, opts ...pulumi.ResourceOption) (*ReplicationTask, error)

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

func (*ReplicationTask) ElementType 

func (*ReplicationTask) ElementType() reflect.Type

func (*ReplicationTask) ToReplicationTaskOutput 

func (i *ReplicationTask) ToReplicationTaskOutput() ReplicationTaskOutput

func (*ReplicationTask) ToReplicationTaskOutputWithContext 

func (i *ReplicationTask) ToReplicationTaskOutputWithContext(ctx context.Context) ReplicationTaskOutput

type ReplicationTaskArgs 

type ReplicationTaskArgs struct {
	// Indicates when you want a change data capture (CDC) operation to start. The value can be in date, checkpoint, or LSN/SCN format depending on the source engine. For more information, see [Determining a CDC native start point](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Task.CDC.html#CHAP_Task.CDC.StartPoint.Native).
	CdcStartPosition pulumi.StringPtrInput
	// The Unix timestamp integer for the start of the Change Data Capture (CDC) operation.
	CdcStartTime pulumi.StringPtrInput
	// The migration type. Can be one of `full-load | cdc | full-load-and-cdc`.
	MigrationType pulumi.StringInput
	// The Amazon Resource Name (ARN) of the replication instance.
	ReplicationInstanceArn pulumi.StringInput
	// The replication task identifier.
	ReplicationTaskId pulumi.StringInput
	// An escaped JSON string that contains the task settings. For a complete list of task settings, see [Task Settings for AWS Database Migration Service Tasks](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TaskSettings.html).
	ReplicationTaskSettings pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) string that uniquely identifies the source endpoint.
	SourceEndpointArn pulumi.StringInput
	// Whether to run or stop the replication task.
	StartReplicationTask pulumi.BoolPtrInput
	// An escaped JSON string that contains the table mappings. For information on table mapping see [Using Table Mapping with an AWS Database Migration Service Task to Select and Filter Data](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TableMapping.html)
	TableMappings pulumi.StringInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// The Amazon Resource Name (ARN) string that uniquely identifies the target endpoint.
	TargetEndpointArn pulumi.StringInput
}

The set of arguments for constructing a ReplicationTask resource.

func (ReplicationTaskArgs) ElementType 

func (ReplicationTaskArgs) ElementType() reflect.Type

type ReplicationTaskArray 

type ReplicationTaskArray []ReplicationTaskInput

func (ReplicationTaskArray) ElementType 

func (ReplicationTaskArray) ElementType() reflect.Type

func (ReplicationTaskArray) ToReplicationTaskArrayOutput 

func (i ReplicationTaskArray) ToReplicationTaskArrayOutput() ReplicationTaskArrayOutput

func (ReplicationTaskArray) ToReplicationTaskArrayOutputWithContext 

func (i ReplicationTaskArray) ToReplicationTaskArrayOutputWithContext(ctx context.Context) ReplicationTaskArrayOutput

type ReplicationTaskArrayInput 

type ReplicationTaskArrayInput interface {
	pulumi.Input

	ToReplicationTaskArrayOutput() ReplicationTaskArrayOutput
	ToReplicationTaskArrayOutputWithContext(context.Context) ReplicationTaskArrayOutput
}

ReplicationTaskArrayInput is an input type that accepts ReplicationTaskArray and ReplicationTaskArrayOutput values. You can construct a concrete instance of `ReplicationTaskArrayInput` via: 

ReplicationTaskArray{ ReplicationTaskArgs{...} }

type ReplicationTaskArrayOutput 

type ReplicationTaskArrayOutput struct{ *pulumi.OutputState }

func (ReplicationTaskArrayOutput) ElementType 

func (ReplicationTaskArrayOutput) ElementType() reflect.Type

func (ReplicationTaskArrayOutput) Index 

func (o ReplicationTaskArrayOutput) Index(i pulumi.IntInput) ReplicationTaskOutput

func (ReplicationTaskArrayOutput) ToReplicationTaskArrayOutput 

func (o ReplicationTaskArrayOutput) ToReplicationTaskArrayOutput() ReplicationTaskArrayOutput

func (ReplicationTaskArrayOutput) ToReplicationTaskArrayOutputWithContext 

func (o ReplicationTaskArrayOutput) ToReplicationTaskArrayOutputWithContext(ctx context.Context) ReplicationTaskArrayOutput

type ReplicationTaskInput 

type ReplicationTaskInput interface {
	pulumi.Input

	ToReplicationTaskOutput() ReplicationTaskOutput
	ToReplicationTaskOutputWithContext(ctx context.Context) ReplicationTaskOutput
}

type ReplicationTaskMap 

type ReplicationTaskMap map[string]ReplicationTaskInput

func (ReplicationTaskMap) ElementType 

func (ReplicationTaskMap) ElementType() reflect.Type

func (ReplicationTaskMap) ToReplicationTaskMapOutput 

func (i ReplicationTaskMap) ToReplicationTaskMapOutput() ReplicationTaskMapOutput

func (ReplicationTaskMap) ToReplicationTaskMapOutputWithContext 

func (i ReplicationTaskMap) ToReplicationTaskMapOutputWithContext(ctx context.Context) ReplicationTaskMapOutput

type ReplicationTaskMapInput 

type ReplicationTaskMapInput interface {
	pulumi.Input

	ToReplicationTaskMapOutput() ReplicationTaskMapOutput
	ToReplicationTaskMapOutputWithContext(context.Context) ReplicationTaskMapOutput
}

ReplicationTaskMapInput is an input type that accepts ReplicationTaskMap and ReplicationTaskMapOutput values. You can construct a concrete instance of `ReplicationTaskMapInput` via: 

ReplicationTaskMap{ "key": ReplicationTaskArgs{...} }

type ReplicationTaskMapOutput 

type ReplicationTaskMapOutput struct{ *pulumi.OutputState }

func (ReplicationTaskMapOutput) ElementType 

func (ReplicationTaskMapOutput) ElementType() reflect.Type

func (ReplicationTaskMapOutput) MapIndex 

func (o ReplicationTaskMapOutput) MapIndex(k pulumi.StringInput) ReplicationTaskOutput

func (ReplicationTaskMapOutput) ToReplicationTaskMapOutput 

func (o ReplicationTaskMapOutput) ToReplicationTaskMapOutput() ReplicationTaskMapOutput

func (ReplicationTaskMapOutput) ToReplicationTaskMapOutputWithContext 

func (o ReplicationTaskMapOutput) ToReplicationTaskMapOutputWithContext(ctx context.Context) ReplicationTaskMapOutput

type ReplicationTaskOutput 

type ReplicationTaskOutput struct{ *pulumi.OutputState }

func (ReplicationTaskOutput) CdcStartPosition added in v5.4.0 

func (o ReplicationTaskOutput) CdcStartPosition() pulumi.StringOutput

Indicates when you want a change data capture (CDC) operation to start. The value can be in date, checkpoint, or LSN/SCN format depending on the source engine. For more information, see [Determining a CDC native start point](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Task.CDC.html#CHAP_Task.CDC.StartPoint.Native).

func (ReplicationTaskOutput) CdcStartTime added in v5.4.0 

func (o ReplicationTaskOutput) CdcStartTime() pulumi.StringPtrOutput

The Unix timestamp integer for the start of the Change Data Capture (CDC) operation.

func (ReplicationTaskOutput) ElementType 

func (ReplicationTaskOutput) ElementType() reflect.Type

func (ReplicationTaskOutput) MigrationType added in v5.4.0 

func (o ReplicationTaskOutput) MigrationType() pulumi.StringOutput

The migration type. Can be one of `full-load | cdc | full-load-and-cdc`.

func (ReplicationTaskOutput) ReplicationInstanceArn added in v5.4.0 

func (o ReplicationTaskOutput) ReplicationInstanceArn() pulumi.StringOutput

The Amazon Resource Name (ARN) of the replication instance.

func (ReplicationTaskOutput) ReplicationTaskArn added in v5.4.0 

func (o ReplicationTaskOutput) ReplicationTaskArn() pulumi.StringOutput

The Amazon Resource Name (ARN) for the replication task.

func (ReplicationTaskOutput) ReplicationTaskId added in v5.4.0 

func (o ReplicationTaskOutput) ReplicationTaskId() pulumi.StringOutput

The replication task identifier.

func (ReplicationTaskOutput) ReplicationTaskSettings added in v5.4.0 

func (o ReplicationTaskOutput) ReplicationTaskSettings() pulumi.StringPtrOutput

An escaped JSON string that contains the task settings. For a complete list of task settings, see [Task Settings for AWS Database Migration Service Tasks](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TaskSettings.html).

func (ReplicationTaskOutput) SourceEndpointArn added in v5.4.0 

func (o ReplicationTaskOutput) SourceEndpointArn() pulumi.StringOutput

The Amazon Resource Name (ARN) string that uniquely identifies the source endpoint.

func (ReplicationTaskOutput) StartReplicationTask added in v5.4.0 

func (o ReplicationTaskOutput) StartReplicationTask() pulumi.BoolPtrOutput

Whether to run or stop the replication task.

func (ReplicationTaskOutput) Status added in v5.4.0 

func (o ReplicationTaskOutput) Status() pulumi.StringOutput

Replication Task status.

func (ReplicationTaskOutput) TableMappings added in v5.4.0 

func (o ReplicationTaskOutput) TableMappings() pulumi.StringOutput

An escaped JSON string that contains the table mappings. For information on table mapping see [Using Table Mapping with an AWS Database Migration Service Task to Select and Filter Data](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TableMapping.html)

func (ReplicationTaskOutput) Tags added in v5.4.0 

func (o ReplicationTaskOutput) Tags() pulumi.StringMapOutput

A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.

func (ReplicationTaskOutput) TagsAll added in v5.4.0 

func (o ReplicationTaskOutput) TagsAll() pulumi.StringMapOutput

A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.

func (ReplicationTaskOutput) TargetEndpointArn added in v5.4.0 

func (o ReplicationTaskOutput) TargetEndpointArn() pulumi.StringOutput

The Amazon Resource Name (ARN) string that uniquely identifies the target endpoint.

func (ReplicationTaskOutput) ToReplicationTaskOutput 

func (o ReplicationTaskOutput) ToReplicationTaskOutput() ReplicationTaskOutput

func (ReplicationTaskOutput) ToReplicationTaskOutputWithContext 

func (o ReplicationTaskOutput) ToReplicationTaskOutputWithContext(ctx context.Context) ReplicationTaskOutput

type ReplicationTaskState 

type ReplicationTaskState struct {
	// Indicates when you want a change data capture (CDC) operation to start. The value can be in date, checkpoint, or LSN/SCN format depending on the source engine. For more information, see [Determining a CDC native start point](https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Task.CDC.html#CHAP_Task.CDC.StartPoint.Native).
	CdcStartPosition pulumi.StringPtrInput
	// The Unix timestamp integer for the start of the Change Data Capture (CDC) operation.
	CdcStartTime pulumi.StringPtrInput
	// The migration type. Can be one of `full-load | cdc | full-load-and-cdc`.
	MigrationType pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) of the replication instance.
	ReplicationInstanceArn pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) for the replication task.
	ReplicationTaskArn pulumi.StringPtrInput
	// The replication task identifier.
	ReplicationTaskId pulumi.StringPtrInput
	// An escaped JSON string that contains the task settings. For a complete list of task settings, see [Task Settings for AWS Database Migration Service Tasks](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TaskSettings.html).
	ReplicationTaskSettings pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) string that uniquely identifies the source endpoint.
	SourceEndpointArn pulumi.StringPtrInput
	// Whether to run or stop the replication task.
	StartReplicationTask pulumi.BoolPtrInput
	// Replication Task status.
	Status pulumi.StringPtrInput
	// An escaped JSON string that contains the table mappings. For information on table mapping see [Using Table Mapping with an AWS Database Migration Service Task to Select and Filter Data](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Tasks.CustomizingTasks.TableMapping.html)
	TableMappings pulumi.StringPtrInput
	// A map of tags to assign to the resource. .If configured with a provider `defaultTags` configuration block present, tags with matching keys will overwrite those defined at the provider-level.
	Tags pulumi.StringMapInput
	// A map of tags assigned to the resource, including those inherited from the provider `defaultTags` configuration block.
	TagsAll pulumi.StringMapInput
	// The Amazon Resource Name (ARN) string that uniquely identifies the target endpoint.
	TargetEndpointArn pulumi.StringPtrInput
}

func (ReplicationTaskState) ElementType 

func (ReplicationTaskState) ElementType() reflect.Type

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.