dms

package
v4.34.0 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 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 .
	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/v4/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

func (*Certificate) ToCertificatePtrOutput 

func (i *Certificate) ToCertificatePtrOutput() CertificatePtrOutput

func (*Certificate) ToCertificatePtrOutputWithContext 

func (i *Certificate) ToCertificatePtrOutputWithContext(ctx context.Context) CertificatePtrOutput

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

func (CertificateOutput) ElementType() reflect.Type

func (CertificateOutput) ToCertificateOutput 

func (o CertificateOutput) ToCertificateOutput() CertificateOutput

func (CertificateOutput) ToCertificateOutputWithContext 

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

func (CertificateOutput) ToCertificatePtrOutput 

func (o CertificateOutput) ToCertificatePtrOutput() CertificatePtrOutput

func (CertificateOutput) ToCertificatePtrOutputWithContext 

func (o CertificateOutput) ToCertificatePtrOutputWithContext(ctx context.Context) CertificatePtrOutput

type CertificatePtrInput 

type CertificatePtrInput interface {
	pulumi.Input

	ToCertificatePtrOutput() CertificatePtrOutput
	ToCertificatePtrOutputWithContext(ctx context.Context) CertificatePtrOutput
}

type CertificatePtrOutput 

type CertificatePtrOutput struct{ *pulumi.OutputState }

func (CertificatePtrOutput) Elem added in v4.15.0 

func (o CertificatePtrOutput) Elem() CertificateOutput

func (CertificatePtrOutput) ElementType 

func (CertificatePtrOutput) ElementType() reflect.Type

func (CertificatePtrOutput) ToCertificatePtrOutput 

func (o CertificatePtrOutput) ToCertificatePtrOutput() CertificatePtrOutput

func (CertificatePtrOutput) ToCertificatePtrOutputWithContext 

func (o CertificatePtrOutput) ToCertificatePtrOutputWithContext(ctx context.Context) CertificatePtrOutput

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 .
	TagsAll pulumi.StringMapInput
}

func (CertificateState) ElementType 

func (CertificateState) ElementType() reflect.Type

type Endpoint 

type Endpoint struct {
	pulumi.CustomResourceState

	// The Amazon Resource Name (ARN) for the certificate.
	CertificateArn pulumi.StringOutput `pulumi:"certificateArn"`
	// The name of the endpoint database.
	DatabaseName pulumi.StringPtrOutput `pulumi:"databaseName"`
	// Configuration block with Elasticsearch settings. Detailed below.
	ElasticsearchSettings EndpointElasticsearchSettingsPtrOutput `pulumi:"elasticsearchSettings"`
	// The Amazon Resource Name (ARN) for the endpoint.
	EndpointArn pulumi.StringOutput `pulumi:"endpointArn"`
	// The database endpoint identifier.
	EndpointId pulumi.StringOutput `pulumi:"endpointId"`
	// The type of endpoint. Can be one of `source | target`.
	EndpointType pulumi.StringOutput `pulumi:"endpointType"`
	// The type of engine for the endpoint. Can be one of `aurora | aurora-postgresql| azuredb | db2 | docdb | dynamodb | elasticsearch | kafka | kinesis | mariadb | mongodb | mysql | oracle | postgres | redshift | s3 | sqlserver | sybase`.
	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 with Kafka settings. Detailed below.
	KafkaSettings EndpointKafkaSettingsPtrOutput `pulumi:"kafkaSettings"`
	// Configuration block with Kinesis settings. Detailed below.
	KinesisSettings EndpointKinesisSettingsPtrOutput `pulumi:"kinesisSettings"`
	// 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"`
	// Configuration block with MongoDB settings. Detailed below.
	MongodbSettings EndpointMongodbSettingsPtrOutput `pulumi:"mongodbSettings"`
	// The password to be used to login to the endpoint database.
	Password pulumi.StringPtrOutput `pulumi:"password"`
	// The port used by the endpoint database.
	Port pulumi.IntPtrOutput `pulumi:"port"`
	// Configuration block with S3 settings. Detailed below.
	S3Settings EndpointS3SettingsPtrOutput `pulumi:"s3Settings"`
	// Amazon Resource Name (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"`
	// The full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for `engineName` as `oracle` and `postgres`.
	SecretsManagerArn pulumi.StringPtrOutput `pulumi:"secretsManagerArn"`
	// The host name of the server.
	ServerName pulumi.StringPtrOutput `pulumi:"serverName"`
	// The Amazon Resource Name (ARN) used by the service access IAM role for dynamodb endpoints.
	ServiceAccessRole pulumi.StringPtrOutput `pulumi:"serviceAccessRole"`
	// The SSL mode to use for the connection. Can be one of `none | require | verify-ca | verify-full`
	SslMode pulumi.StringOutput `pulumi:"sslMode"`
	// 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 .
	TagsAll pulumi.StringMapOutput `pulumi:"tagsAll"`
	// The 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/v4/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

func (*Endpoint) ToEndpointPtrOutput 

func (i *Endpoint) ToEndpointPtrOutput() EndpointPtrOutput

func (*Endpoint) ToEndpointPtrOutputWithContext 

func (i *Endpoint) ToEndpointPtrOutputWithContext(ctx context.Context) EndpointPtrOutput

type EndpointArgs 

type EndpointArgs struct {
	// The Amazon Resource Name (ARN) for the certificate.
	CertificateArn pulumi.StringPtrInput
	// The name of the endpoint database.
	DatabaseName pulumi.StringPtrInput
	// Configuration block with Elasticsearch settings. Detailed below.
	ElasticsearchSettings EndpointElasticsearchSettingsPtrInput
	// The database endpoint identifier.
	EndpointId pulumi.StringInput
	// The type of endpoint. Can be one of `source | target`.
	EndpointType pulumi.StringInput
	// The type of engine for the endpoint. Can be one of `aurora | aurora-postgresql| azuredb | db2 | docdb | dynamodb | elasticsearch | kafka | kinesis | mariadb | mongodb | mysql | oracle | postgres | redshift | s3 | sqlserver | sybase`.
	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 with Kafka settings. Detailed below.
	KafkaSettings EndpointKafkaSettingsPtrInput
	// Configuration block with Kinesis settings. Detailed below.
	KinesisSettings EndpointKinesisSettingsPtrInput
	// 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
	// Configuration block with MongoDB settings. Detailed below.
	MongodbSettings EndpointMongodbSettingsPtrInput
	// The password to be used to login to the endpoint database.
	Password pulumi.StringPtrInput
	// The port used by the endpoint database.
	Port pulumi.IntPtrInput
	// Configuration block with S3 settings. Detailed below.
	S3Settings EndpointS3SettingsPtrInput
	// Amazon Resource Name (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
	// The full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for `engineName` as `oracle` and `postgres`.
	SecretsManagerArn pulumi.StringPtrInput
	// The host name of the server.
	ServerName pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) used by the service access IAM role for dynamodb endpoints.
	ServiceAccessRole pulumi.StringPtrInput
	// The SSL mode to use for the connection. Can be one of `none | require | verify-ca | verify-full`
	SslMode 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 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 Elasticsearch cluster.
	EndpointUri string `pulumi:"endpointUri"`
	// Maximum number of seconds for which DMS retries failed API requests to the Elasticsearch cluster. Defaults to `300`.
	ErrorRetryDuration *int `pulumi:"errorRetryDuration"`
	// Maximum percentage of records that can fail to be written before a full load operation stops. Defaults to `10`.
	FullLoadErrorPercentage *int `pulumi:"fullLoadErrorPercentage"`
	// Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Elasticsearch cluster.
	ServiceAccessRoleArn string `pulumi:"serviceAccessRoleArn"`
}

type EndpointElasticsearchSettingsArgs 

type EndpointElasticsearchSettingsArgs struct {
	// Endpoint for the Elasticsearch cluster.
	EndpointUri pulumi.StringInput `pulumi:"endpointUri"`
	// Maximum number of seconds for which DMS retries failed API requests to the Elasticsearch cluster. Defaults to `300`.
	ErrorRetryDuration pulumi.IntPtrInput `pulumi:"errorRetryDuration"`
	// Maximum percentage of records that can fail to be written before a full load operation stops. Defaults to `10`.
	FullLoadErrorPercentage pulumi.IntPtrInput `pulumi:"fullLoadErrorPercentage"`
	// Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Elasticsearch cluster.
	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 Elasticsearch cluster.

func (EndpointElasticsearchSettingsOutput) ErrorRetryDuration 

func (o EndpointElasticsearchSettingsOutput) ErrorRetryDuration() pulumi.IntPtrOutput

Maximum number of seconds for which DMS retries failed API requests to the Elasticsearch cluster. Defaults to `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. Defaults to `10`.

func (EndpointElasticsearchSettingsOutput) ServiceAccessRoleArn 

func (o EndpointElasticsearchSettingsOutput) ServiceAccessRoleArn() pulumi.StringOutput

Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Elasticsearch cluster.

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

func (EndpointElasticsearchSettingsPtrOutput) ErrorRetryDuration 

func (o EndpointElasticsearchSettingsPtrOutput) ErrorRetryDuration() pulumi.IntPtrOutput

Maximum number of seconds for which DMS retries failed API requests to the Elasticsearch cluster. Defaults to `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. Defaults to `10`.

func (EndpointElasticsearchSettingsPtrOutput) ServiceAccessRoleArn 

func (o EndpointElasticsearchSettingsPtrOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Elasticsearch cluster.

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 Kafka message output. The default is `false`.
	IncludeControlDetails *bool `pulumi:"includeControlDetails"`
	// Include NULL and empty columns for records migrated to the endpoint. The default is `false`.
	IncludeNullAndEmpty *bool `pulumi:"includeNullAndEmpty"`
	// Shows the partition value within the Kafka message output unless the partition type is `schema-table-type`. The default is `false`.
	IncludePartitionValue *bool `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data, such as `rename-table`, `drop-table`, `add-column`, `drop-column`, and `rename-column`. The default is `false`.
	IncludeTableAlterOperations *bool `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for `transactionId`, previous `transactionId`, and `transactionRecordId` (the record offset within a transaction). The default is `false`.
	IncludeTransactionDetails *bool `pulumi:"includeTransactionDetails"`
	// The output format for the records created on the endpoint. The message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).
	MessageFormat *string `pulumi:"messageFormat"`
	// The maximum size in bytes for records created on the endpoint The 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`. Doing this increases data distribution among Kafka partitions. For example, suppose that a SysBench schema has thousands of tables and each table has only limited range for a primary key. In this case, the same primary key is sent from thousands of tables to the same partition, which causes throttling. The default is `false`.
	PartitionIncludeSchemaTable *bool `pulumi:"partitionIncludeSchemaTable"`
	// The 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"`
	// The 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"`
	// The Amazon Resource Name (ARN) for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint.
	SslCaCertificateArn *string `pulumi:"sslCaCertificateArn"`
	// The Amazon Resource Name (ARN) of the client certificate used to securely connect to a Kafka target endpoint.
	SslClientCertificateArn *string `pulumi:"sslClientCertificateArn"`
	// The Amazon Resource Name (ARN) for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyArn *string `pulumi:"sslClientKeyArn"`
	// The password for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyPassword *string `pulumi:"sslClientKeyPassword"`
	// Kafka topic for migration. Defaults to `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 Kafka message output. The default is `false`.
	IncludeControlDetails pulumi.BoolPtrInput `pulumi:"includeControlDetails"`
	// Include NULL and empty columns for records migrated to the endpoint. The default is `false`.
	IncludeNullAndEmpty pulumi.BoolPtrInput `pulumi:"includeNullAndEmpty"`
	// Shows the partition value within the Kafka message output unless the partition type is `schema-table-type`. The default is `false`.
	IncludePartitionValue pulumi.BoolPtrInput `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data, such as `rename-table`, `drop-table`, `add-column`, `drop-column`, and `rename-column`. The default is `false`.
	IncludeTableAlterOperations pulumi.BoolPtrInput `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for `transactionId`, previous `transactionId`, and `transactionRecordId` (the record offset within a transaction). The default is `false`.
	IncludeTransactionDetails pulumi.BoolPtrInput `pulumi:"includeTransactionDetails"`
	// The output format for the records created on the endpoint. The message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).
	MessageFormat pulumi.StringPtrInput `pulumi:"messageFormat"`
	// The maximum size in bytes for records created on the endpoint The 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`. Doing this increases data distribution among Kafka partitions. For example, suppose that a SysBench schema has thousands of tables and each table has only limited range for a primary key. In this case, the same primary key is sent from thousands of tables to the same partition, which causes throttling. The default is `false`.
	PartitionIncludeSchemaTable pulumi.BoolPtrInput `pulumi:"partitionIncludeSchemaTable"`
	// The 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"`
	// The 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"`
	// The Amazon Resource Name (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"`
	// The Amazon Resource Name (ARN) of the client certificate used to securely connect to a Kafka target endpoint.
	SslClientCertificateArn pulumi.StringPtrInput `pulumi:"sslClientCertificateArn"`
	// The Amazon Resource Name (ARN) for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyArn pulumi.StringPtrInput `pulumi:"sslClientKeyArn"`
	// The password for the client private key used to securely connect to a Kafka target endpoint.
	SslClientKeyPassword pulumi.StringPtrInput `pulumi:"sslClientKeyPassword"`
	// Kafka topic for migration. Defaults to `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 added in v4.24.0 

func (o EndpointKafkaSettingsOutput) IncludeControlDetails() pulumi.BoolPtrOutput

Shows detailed control information for table definition, column definition, and table and column changes in the Kafka message output. The default is `false`.

func (EndpointKafkaSettingsOutput) IncludeNullAndEmpty added in v4.24.0 

func (o EndpointKafkaSettingsOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

Include NULL and empty columns for records migrated to the endpoint. The default is `false`.

func (EndpointKafkaSettingsOutput) IncludePartitionValue added in v4.24.0 

func (o EndpointKafkaSettingsOutput) IncludePartitionValue() pulumi.BoolPtrOutput

Shows the partition value within the Kafka message output unless the partition type is `schema-table-type`. The default is `false`.

func (EndpointKafkaSettingsOutput) IncludeTableAlterOperations added in v4.24.0 

func (o EndpointKafkaSettingsOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

Includes any data definition language (DDL) operations that change the table in the control data, such as `rename-table`, `drop-table`, `add-column`, `drop-column`, and `rename-column`. The default is `false`.

func (EndpointKafkaSettingsOutput) IncludeTransactionDetails added in v4.24.0 

func (o EndpointKafkaSettingsOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for `transactionId`, previous `transactionId`, and `transactionRecordId` (the record offset within a transaction). The default is `false`.

func (EndpointKafkaSettingsOutput) MessageFormat added in v4.24.0 

func (o EndpointKafkaSettingsOutput) MessageFormat() pulumi.StringPtrOutput

The output format for the records created on the endpoint. The message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).

func (EndpointKafkaSettingsOutput) MessageMaxBytes added in v4.24.0 

func (o EndpointKafkaSettingsOutput) MessageMaxBytes() pulumi.IntPtrOutput

The maximum size in bytes for records created on the endpoint The default is `1,000,000`.

func (EndpointKafkaSettingsOutput) NoHexPrefix added in v4.24.0 

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 added in v4.24.0 

func (o EndpointKafkaSettingsOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

Prefixes schema and table names to partition values, when the partition type is `primary-key-type`. Doing this increases data distribution among Kafka partitions. For example, suppose that a SysBench schema has thousands of tables and each table has only limited range for a primary key. In this case, the same primary key is sent from thousands of tables to the same partition, which causes throttling. The default is `false`.

func (EndpointKafkaSettingsOutput) SaslPassword added in v4.24.0 

func (o EndpointKafkaSettingsOutput) SaslPassword() pulumi.StringPtrOutput

The 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 added in v4.24.0 

func (o EndpointKafkaSettingsOutput) SaslUsername() pulumi.StringPtrOutput

The 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 added in v4.24.0 

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 added in v4.24.0 

func (o EndpointKafkaSettingsOutput) SslCaCertificateArn() pulumi.StringPtrOutput

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

func (EndpointKafkaSettingsOutput) SslClientCertificateArn added in v4.24.0 

func (o EndpointKafkaSettingsOutput) SslClientCertificateArn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) of the client certificate used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsOutput) SslClientKeyArn added in v4.24.0 

func (o EndpointKafkaSettingsOutput) SslClientKeyArn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) for the client private key used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsOutput) SslClientKeyPassword added in v4.24.0 

func (o EndpointKafkaSettingsOutput) SslClientKeyPassword() pulumi.StringPtrOutput

The 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. Defaults to `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 added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) IncludeControlDetails() pulumi.BoolPtrOutput

Shows detailed control information for table definition, column definition, and table and column changes in the Kafka message output. The default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludeNullAndEmpty added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

Include NULL and empty columns for records migrated to the endpoint. The default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludePartitionValue added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) IncludePartitionValue() pulumi.BoolPtrOutput

Shows the partition value within the Kafka message output unless the partition type is `schema-table-type`. The default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludeTableAlterOperations added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

Includes any data definition language (DDL) operations that change the table in the control data, such as `rename-table`, `drop-table`, `add-column`, `drop-column`, and `rename-column`. The default is `false`.

func (EndpointKafkaSettingsPtrOutput) IncludeTransactionDetails added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for `transactionId`, previous `transactionId`, and `transactionRecordId` (the record offset within a transaction). The default is `false`.

func (EndpointKafkaSettingsPtrOutput) MessageFormat added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) MessageFormat() pulumi.StringPtrOutput

The output format for the records created on the endpoint. The message format is `JSON` (default) or `JSON_UNFORMATTED` (a single line with no tab).

func (EndpointKafkaSettingsPtrOutput) MessageMaxBytes added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) MessageMaxBytes() pulumi.IntPtrOutput

The maximum size in bytes for records created on the endpoint The default is `1,000,000`.

func (EndpointKafkaSettingsPtrOutput) NoHexPrefix added in v4.24.0 

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 added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

Prefixes schema and table names to partition values, when the partition type is `primary-key-type`. Doing this increases data distribution among Kafka partitions. For example, suppose that a SysBench schema has thousands of tables and each table has only limited range for a primary key. In this case, the same primary key is sent from thousands of tables to the same partition, which causes throttling. The default is `false`.

func (EndpointKafkaSettingsPtrOutput) SaslPassword added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) SaslPassword() pulumi.StringPtrOutput

The 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 added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) SaslUsername() pulumi.StringPtrOutput

The 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 added in v4.24.0 

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 added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) SslCaCertificateArn() pulumi.StringPtrOutput

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

func (EndpointKafkaSettingsPtrOutput) SslClientCertificateArn added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) SslClientCertificateArn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) of the client certificate used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsPtrOutput) SslClientKeyArn added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) SslClientKeyArn() pulumi.StringPtrOutput

The Amazon Resource Name (ARN) for the client private key used to securely connect to a Kafka target endpoint.

func (EndpointKafkaSettingsPtrOutput) SslClientKeyPassword added in v4.24.0 

func (o EndpointKafkaSettingsPtrOutput) SslClientKeyPassword() pulumi.StringPtrOutput

The 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. Defaults to `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. The default is `false`.
	IncludeControlDetails *bool `pulumi:"includeControlDetails"`
	// Include NULL and empty columns in the target. The default is `false`.
	IncludeNullAndEmpty *bool `pulumi:"includeNullAndEmpty"`
	// Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. The default is `false`.
	IncludePartitionValue *bool `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data. The default is `false`.
	IncludeTableAlterOperations *bool `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. The default is `false`.
	IncludeTransactionDetails *bool `pulumi:"includeTransactionDetails"`
	// Output format for the records created. Defaults to `json`. Valid values are `json` and `jsonUnformatted` (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. The default is `false`.
	PartitionIncludeSchemaTable *bool `pulumi:"partitionIncludeSchemaTable"`
	// Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Kinesis data stream.
	ServiceAccessRoleArn *string `pulumi:"serviceAccessRoleArn"`
	// Amazon Resource Name (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. The default is `false`.
	IncludeControlDetails pulumi.BoolPtrInput `pulumi:"includeControlDetails"`
	// Include NULL and empty columns in the target. The 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. The default is `false`.
	IncludePartitionValue pulumi.BoolPtrInput `pulumi:"includePartitionValue"`
	// Includes any data definition language (DDL) operations that change the table in the control data. The default is `false`.
	IncludeTableAlterOperations pulumi.BoolPtrInput `pulumi:"includeTableAlterOperations"`
	// Provides detailed transaction information from the source database. The default is `false`.
	IncludeTransactionDetails pulumi.BoolPtrInput `pulumi:"includeTransactionDetails"`
	// Output format for the records created. Defaults to `json`. Valid values are `json` and `jsonUnformatted` (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. The default is `false`.
	PartitionIncludeSchemaTable pulumi.BoolPtrInput `pulumi:"partitionIncludeSchemaTable"`
	// Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Kinesis data stream.
	ServiceAccessRoleArn pulumi.StringPtrInput `pulumi:"serviceAccessRoleArn"`
	// Amazon Resource Name (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 added in v4.27.0 

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. The default is `false`.

func (EndpointKinesisSettingsOutput) IncludeNullAndEmpty added in v4.27.0 

func (o EndpointKinesisSettingsOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsOutput) IncludePartitionValue added in v4.27.0 

func (o EndpointKinesisSettingsOutput) IncludePartitionValue() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsOutput) IncludeTableAlterOperations added in v4.27.0 

func (o EndpointKinesisSettingsOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsOutput) IncludeTransactionDetails added in v4.27.0 

func (o EndpointKinesisSettingsOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsOutput) MessageFormat 

func (o EndpointKinesisSettingsOutput) MessageFormat() pulumi.StringPtrOutput

Output format for the records created. Defaults to `json`. Valid values are `json` and `jsonUnformatted` (a single line with no tab).

func (EndpointKinesisSettingsOutput) PartitionIncludeSchemaTable added in v4.27.0 

func (o EndpointKinesisSettingsOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsOutput) ServiceAccessRoleArn 

func (o EndpointKinesisSettingsOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Kinesis data stream.

func (EndpointKinesisSettingsOutput) StreamArn 

func (o EndpointKinesisSettingsOutput) StreamArn() pulumi.StringPtrOutput

Amazon Resource Name (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 added in v4.27.0 

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. The default is `false`.

func (EndpointKinesisSettingsPtrOutput) IncludeNullAndEmpty added in v4.27.0 

func (o EndpointKinesisSettingsPtrOutput) IncludeNullAndEmpty() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsPtrOutput) IncludePartitionValue added in v4.27.0 

func (o EndpointKinesisSettingsPtrOutput) IncludePartitionValue() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsPtrOutput) IncludeTableAlterOperations added in v4.27.0 

func (o EndpointKinesisSettingsPtrOutput) IncludeTableAlterOperations() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsPtrOutput) IncludeTransactionDetails added in v4.27.0 

func (o EndpointKinesisSettingsPtrOutput) IncludeTransactionDetails() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsPtrOutput) MessageFormat 

func (o EndpointKinesisSettingsPtrOutput) MessageFormat() pulumi.StringPtrOutput

Output format for the records created. Defaults to `json`. Valid values are `json` and `jsonUnformatted` (a single line with no tab).

func (EndpointKinesisSettingsPtrOutput) PartitionIncludeSchemaTable added in v4.27.0 

func (o EndpointKinesisSettingsPtrOutput) PartitionIncludeSchemaTable() pulumi.BoolPtrOutput

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

func (EndpointKinesisSettingsPtrOutput) ServiceAccessRoleArn 

func (o EndpointKinesisSettingsPtrOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

Amazon Resource Name (ARN) of the IAM Role with permissions to write to the Kinesis data stream.

func (EndpointKinesisSettingsPtrOutput) StreamArn 

func (o EndpointKinesisSettingsPtrOutput) StreamArn() pulumi.StringPtrOutput

Amazon Resource Name (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. Defaults to `default`.
	AuthMechanism *string `pulumi:"authMechanism"`
	// Authentication database name. Not used when `authType` is `no`. Defaults to `admin`.
	AuthSource *string `pulumi:"authSource"`
	// Authentication type to access the MongoDB source endpoint. Defaults to `password`.
	AuthType *string `pulumi:"authType"`
	// Number of documents to preview to determine the document organization. Use this setting when `nestingLevel` is set to `one`. Defaults to `1000`.
	DocsToInvestigate *string `pulumi:"docsToInvestigate"`
	// Document ID. Use this setting when `nestingLevel` is set to `none`. Defaults to `false`.
	ExtractDocId *string `pulumi:"extractDocId"`
	// Specifies either document or table mode. Defaults to `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. Defaults to `default`.
	AuthMechanism pulumi.StringPtrInput `pulumi:"authMechanism"`
	// Authentication database name. Not used when `authType` is `no`. Defaults to `admin`.
	AuthSource pulumi.StringPtrInput `pulumi:"authSource"`
	// Authentication type to access the MongoDB source endpoint. Defaults to `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`. Defaults to `1000`.
	DocsToInvestigate pulumi.StringPtrInput `pulumi:"docsToInvestigate"`
	// Document ID. Use this setting when `nestingLevel` is set to `none`. Defaults to `false`.
	ExtractDocId pulumi.StringPtrInput `pulumi:"extractDocId"`
	// Specifies either document or table mode. Defaults to `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. Defaults to `default`.

func (EndpointMongodbSettingsOutput) AuthSource 

func (o EndpointMongodbSettingsOutput) AuthSource() pulumi.StringPtrOutput

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

func (EndpointMongodbSettingsOutput) AuthType 

func (o EndpointMongodbSettingsOutput) AuthType() pulumi.StringPtrOutput

Authentication type to access the MongoDB source endpoint. Defaults to `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`. Defaults to `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`. Defaults to `false`.

func (EndpointMongodbSettingsOutput) NestingLevel 

func (o EndpointMongodbSettingsOutput) NestingLevel() pulumi.StringPtrOutput

Specifies either document or table mode. Defaults to `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. Defaults to `default`.

func (EndpointMongodbSettingsPtrOutput) AuthSource 

func (o EndpointMongodbSettingsPtrOutput) AuthSource() pulumi.StringPtrOutput

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

func (EndpointMongodbSettingsPtrOutput) AuthType 

func (o EndpointMongodbSettingsPtrOutput) AuthType() pulumi.StringPtrOutput

Authentication type to access the MongoDB source endpoint. Defaults to `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`. Defaults to `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`. Defaults to `false`.

func (EndpointMongodbSettingsPtrOutput) NestingLevel 

func (o EndpointMongodbSettingsPtrOutput) NestingLevel() pulumi.StringPtrOutput

Specifies either document or table mode. Defaults to `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) ElementType 

func (EndpointOutput) ElementType() reflect.Type

func (EndpointOutput) ToEndpointOutput 

func (o EndpointOutput) ToEndpointOutput() EndpointOutput

func (EndpointOutput) ToEndpointOutputWithContext 

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

func (EndpointOutput) ToEndpointPtrOutput 

func (o EndpointOutput) ToEndpointPtrOutput() EndpointPtrOutput

func (EndpointOutput) ToEndpointPtrOutputWithContext 

func (o EndpointOutput) ToEndpointPtrOutputWithContext(ctx context.Context) EndpointPtrOutput

type EndpointPtrInput 

type EndpointPtrInput interface {
	pulumi.Input

	ToEndpointPtrOutput() EndpointPtrOutput
	ToEndpointPtrOutputWithContext(ctx context.Context) EndpointPtrOutput
}

type EndpointPtrOutput 

type EndpointPtrOutput struct{ *pulumi.OutputState }

func (EndpointPtrOutput) Elem added in v4.15.0 

func (o EndpointPtrOutput) Elem() EndpointOutput

func (EndpointPtrOutput) ElementType 

func (EndpointPtrOutput) ElementType() reflect.Type

func (EndpointPtrOutput) ToEndpointPtrOutput 

func (o EndpointPtrOutput) ToEndpointPtrOutput() EndpointPtrOutput

func (EndpointPtrOutput) ToEndpointPtrOutputWithContext 

func (o EndpointPtrOutput) ToEndpointPtrOutputWithContext(ctx context.Context) EndpointPtrOutput

type EndpointS3Settings 

type EndpointS3Settings struct {
	// S3 Bucket Object prefix.
	BucketFolder *string `pulumi:"bucketFolder"`
	// S3 Bucket name.
	BucketName *string `pulumi:"bucketName"`
	// Set to compress target files. Defaults to `NONE`. Valid values are `GZIP` and `NONE`.
	CompressionType *string `pulumi:"compressionType"`
	// Delimiter used to separate columns in the source files. Defaults to `,`.
	CsvDelimiter *string `pulumi:"csvDelimiter"`
	// Delimiter used to separate rows in the source files. Defaults to `\n`.
	CsvRowDelimiter *string `pulumi:"csvRowDelimiter"`
	// The output format for the files that AWS DMS uses to create S3 objects. Defaults to `csv`. Valid values are `csv` and `parquet`.
	DataFormat *string `pulumi:"dataFormat"`
	// Partition S3 bucket folders based on transaction commit dates. Defaults to `false`.
	DatePartitionEnabled *bool `pulumi:"datePartitionEnabled"`
	// The server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Defaults to `SSE_S3`. Valid values are `SSE_S3` and `SSE_KMS`.
	EncryptionMode *string `pulumi:"encryptionMode"`
	// JSON document that describes how AWS DMS should interpret the data.
	ExternalTableDefinition *string `pulumi:"externalTableDefinition"`
	// - Specifies the precision of any TIMESTAMP column values written to an S3 object file in .parquet format. Defaults to `false`.
	ParquetTimestampInMillisecond *bool `pulumi:"parquetTimestampInMillisecond"`
	// The version of the .parquet file format. Defaults to `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.
	ParquetVersion *string `pulumi:"parquetVersion"`
	// If you set encryptionMode to `SSE_KMS`, set this parameter to the Amazon Resource Name (ARN) for the AWS KMS key.
	ServerSideEncryptionKmsKeyId *string `pulumi:"serverSideEncryptionKmsKeyId"`
	// Amazon Resource Name (ARN) of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn *string `pulumi:"serviceAccessRoleArn"`
}

type EndpointS3SettingsArgs 

type EndpointS3SettingsArgs struct {
	// S3 Bucket Object prefix.
	BucketFolder pulumi.StringPtrInput `pulumi:"bucketFolder"`
	// S3 Bucket name.
	BucketName pulumi.StringPtrInput `pulumi:"bucketName"`
	// Set to compress target files. Defaults to `NONE`. Valid values are `GZIP` and `NONE`.
	CompressionType pulumi.StringPtrInput `pulumi:"compressionType"`
	// Delimiter used to separate columns in the source files. Defaults to `,`.
	CsvDelimiter pulumi.StringPtrInput `pulumi:"csvDelimiter"`
	// Delimiter used to separate rows in the source files. Defaults to `\n`.
	CsvRowDelimiter pulumi.StringPtrInput `pulumi:"csvRowDelimiter"`
	// The output format for the files that AWS DMS uses to create S3 objects. Defaults to `csv`. Valid values are `csv` and `parquet`.
	DataFormat pulumi.StringPtrInput `pulumi:"dataFormat"`
	// Partition S3 bucket folders based on transaction commit dates. Defaults to `false`.
	DatePartitionEnabled pulumi.BoolPtrInput `pulumi:"datePartitionEnabled"`
	// The server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Defaults to `SSE_S3`. Valid values are `SSE_S3` and `SSE_KMS`.
	EncryptionMode pulumi.StringPtrInput `pulumi:"encryptionMode"`
	// JSON document that describes how AWS DMS should interpret the data.
	ExternalTableDefinition pulumi.StringPtrInput `pulumi:"externalTableDefinition"`
	// - Specifies the precision of any TIMESTAMP column values written to an S3 object file in .parquet format. Defaults to `false`.
	ParquetTimestampInMillisecond pulumi.BoolPtrInput `pulumi:"parquetTimestampInMillisecond"`
	// The version of the .parquet file format. Defaults to `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.
	ParquetVersion pulumi.StringPtrInput `pulumi:"parquetVersion"`
	// If you set encryptionMode to `SSE_KMS`, set this parameter to the Amazon Resource Name (ARN) for the AWS KMS key.
	ServerSideEncryptionKmsKeyId pulumi.StringPtrInput `pulumi:"serverSideEncryptionKmsKeyId"`
	// Amazon Resource Name (ARN) of the IAM Role with permissions to read from or write to the S3 Bucket.
	ServiceAccessRoleArn pulumi.StringPtrInput `pulumi:"serviceAccessRoleArn"`
}

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

func (o EndpointS3SettingsOutput) BucketFolder() pulumi.StringPtrOutput

S3 Bucket Object prefix.

func (EndpointS3SettingsOutput) BucketName 

func (o EndpointS3SettingsOutput) BucketName() pulumi.StringPtrOutput

S3 Bucket name.

func (EndpointS3SettingsOutput) CompressionType 

func (o EndpointS3SettingsOutput) CompressionType() pulumi.StringPtrOutput

Set to compress target files. Defaults to `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. Defaults to `,`.

func (EndpointS3SettingsOutput) CsvRowDelimiter 

func (o EndpointS3SettingsOutput) CsvRowDelimiter() pulumi.StringPtrOutput

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

func (EndpointS3SettingsOutput) DataFormat added in v4.17.0 

func (o EndpointS3SettingsOutput) DataFormat() pulumi.StringPtrOutput

The output format for the files that AWS DMS uses to create S3 objects. Defaults to `csv`. Valid values are `csv` and `parquet`.

func (EndpointS3SettingsOutput) DatePartitionEnabled 

func (o EndpointS3SettingsOutput) DatePartitionEnabled() pulumi.BoolPtrOutput

Partition S3 bucket folders based on transaction commit dates. Defaults to `false`.

func (EndpointS3SettingsOutput) ElementType 

func (EndpointS3SettingsOutput) ElementType() reflect.Type

func (EndpointS3SettingsOutput) EncryptionMode added in v4.17.0 

func (o EndpointS3SettingsOutput) EncryptionMode() pulumi.StringPtrOutput

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

func (EndpointS3SettingsOutput) ExternalTableDefinition 

func (o EndpointS3SettingsOutput) ExternalTableDefinition() pulumi.StringPtrOutput

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

func (EndpointS3SettingsOutput) ParquetTimestampInMillisecond added in v4.17.0 

func (o EndpointS3SettingsOutput) ParquetTimestampInMillisecond() pulumi.BoolPtrOutput

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

func (EndpointS3SettingsOutput) ParquetVersion added in v4.17.0 

func (o EndpointS3SettingsOutput) ParquetVersion() pulumi.StringPtrOutput

The version of the .parquet file format. Defaults to `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.

func (EndpointS3SettingsOutput) ServerSideEncryptionKmsKeyId added in v4.17.0 

func (o EndpointS3SettingsOutput) ServerSideEncryptionKmsKeyId() pulumi.StringPtrOutput

If you set encryptionMode to `SSE_KMS`, set this parameter to the Amazon Resource Name (ARN) for the AWS KMS key.

func (EndpointS3SettingsOutput) ServiceAccessRoleArn 

func (o EndpointS3SettingsOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

Amazon Resource Name (ARN) of the IAM Role with permissions to read from or write to the S3 Bucket.

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

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

func (o EndpointS3SettingsPtrOutput) BucketFolder() pulumi.StringPtrOutput

S3 Bucket Object prefix.

func (EndpointS3SettingsPtrOutput) BucketName 

func (o EndpointS3SettingsPtrOutput) BucketName() pulumi.StringPtrOutput

S3 Bucket name.

func (EndpointS3SettingsPtrOutput) CompressionType 

func (o EndpointS3SettingsPtrOutput) CompressionType() pulumi.StringPtrOutput

Set to compress target files. Defaults to `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. Defaults to `,`.

func (EndpointS3SettingsPtrOutput) CsvRowDelimiter 

func (o EndpointS3SettingsPtrOutput) CsvRowDelimiter() pulumi.StringPtrOutput

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

func (EndpointS3SettingsPtrOutput) DataFormat added in v4.17.0 

func (o EndpointS3SettingsPtrOutput) DataFormat() pulumi.StringPtrOutput

The output format for the files that AWS DMS uses to create S3 objects. Defaults to `csv`. Valid values are `csv` and `parquet`.

func (EndpointS3SettingsPtrOutput) DatePartitionEnabled 

func (o EndpointS3SettingsPtrOutput) DatePartitionEnabled() pulumi.BoolPtrOutput

Partition S3 bucket folders based on transaction commit dates. Defaults to `false`.

func (EndpointS3SettingsPtrOutput) Elem 

func (o EndpointS3SettingsPtrOutput) Elem() EndpointS3SettingsOutput

func (EndpointS3SettingsPtrOutput) ElementType 

func (EndpointS3SettingsPtrOutput) ElementType() reflect.Type

func (EndpointS3SettingsPtrOutput) EncryptionMode added in v4.17.0 

func (o EndpointS3SettingsPtrOutput) EncryptionMode() pulumi.StringPtrOutput

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

func (EndpointS3SettingsPtrOutput) ExternalTableDefinition 

func (o EndpointS3SettingsPtrOutput) ExternalTableDefinition() pulumi.StringPtrOutput

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

func (EndpointS3SettingsPtrOutput) ParquetTimestampInMillisecond added in v4.17.0 

func (o EndpointS3SettingsPtrOutput) ParquetTimestampInMillisecond() pulumi.BoolPtrOutput

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

func (EndpointS3SettingsPtrOutput) ParquetVersion added in v4.17.0 

func (o EndpointS3SettingsPtrOutput) ParquetVersion() pulumi.StringPtrOutput

The version of the .parquet file format. Defaults to `parquet-1-0`. Valid values are `parquet-1-0` and `parquet-2-0`.

func (EndpointS3SettingsPtrOutput) ServerSideEncryptionKmsKeyId added in v4.17.0 

func (o EndpointS3SettingsPtrOutput) ServerSideEncryptionKmsKeyId() pulumi.StringPtrOutput

If you set encryptionMode to `SSE_KMS`, set this parameter to the Amazon Resource Name (ARN) for the AWS KMS key.

func (EndpointS3SettingsPtrOutput) ServiceAccessRoleArn 

func (o EndpointS3SettingsPtrOutput) ServiceAccessRoleArn() pulumi.StringPtrOutput

Amazon Resource Name (ARN) of the IAM Role with permissions to read from or write to the S3 Bucket.

func (EndpointS3SettingsPtrOutput) ToEndpointS3SettingsPtrOutput 

func (o EndpointS3SettingsPtrOutput) ToEndpointS3SettingsPtrOutput() EndpointS3SettingsPtrOutput

func (EndpointS3SettingsPtrOutput) ToEndpointS3SettingsPtrOutputWithContext 

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

type EndpointState 

type EndpointState struct {
	// The Amazon Resource Name (ARN) for the certificate.
	CertificateArn pulumi.StringPtrInput
	// The name of the endpoint database.
	DatabaseName pulumi.StringPtrInput
	// Configuration block with Elasticsearch settings. Detailed below.
	ElasticsearchSettings EndpointElasticsearchSettingsPtrInput
	// The Amazon Resource Name (ARN) for the endpoint.
	EndpointArn pulumi.StringPtrInput
	// The database endpoint identifier.
	EndpointId pulumi.StringPtrInput
	// The type of endpoint. Can be one of `source | target`.
	EndpointType pulumi.StringPtrInput
	// The type of engine for the endpoint. Can be one of `aurora | aurora-postgresql| azuredb | db2 | docdb | dynamodb | elasticsearch | kafka | kinesis | mariadb | mongodb | mysql | oracle | postgres | redshift | s3 | sqlserver | sybase`.
	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 with Kafka settings. Detailed below.
	KafkaSettings EndpointKafkaSettingsPtrInput
	// Configuration block with Kinesis settings. Detailed below.
	KinesisSettings EndpointKinesisSettingsPtrInput
	// 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
	// Configuration block with MongoDB settings. Detailed below.
	MongodbSettings EndpointMongodbSettingsPtrInput
	// The password to be used to login to the endpoint database.
	Password pulumi.StringPtrInput
	// The port used by the endpoint database.
	Port pulumi.IntPtrInput
	// Configuration block with S3 settings. Detailed below.
	S3Settings EndpointS3SettingsPtrInput
	// Amazon Resource Name (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
	// The full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for `engineName` as `oracle` and `postgres`.
	SecretsManagerArn pulumi.StringPtrInput
	// The host name of the server.
	ServerName pulumi.StringPtrInput
	// The Amazon Resource Name (ARN) used by the service access IAM role for dynamodb endpoints.
	ServiceAccessRole pulumi.StringPtrInput
	// The SSL mode to use for the connection. Can be one of `none | require | verify-ca | verify-full`
	SslMode 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 .
	TagsAll pulumi.StringMapInput
	// The 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 .
	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/v4/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

func (*EventSubscription) ToEventSubscriptionPtrOutput 

func (i *EventSubscription) ToEventSubscriptionPtrOutput() EventSubscriptionPtrOutput

func (*EventSubscription) ToEventSubscriptionPtrOutputWithContext 

func (i *EventSubscription) ToEventSubscriptionPtrOutputWithContext(ctx context.Context) EventSubscriptionPtrOutput

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

func (EventSubscriptionOutput) ElementType() reflect.Type

func (EventSubscriptionOutput) ToEventSubscriptionOutput 

func (o EventSubscriptionOutput) ToEventSubscriptionOutput() EventSubscriptionOutput

func (EventSubscriptionOutput) ToEventSubscriptionOutputWithContext 

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

func (EventSubscriptionOutput) ToEventSubscriptionPtrOutput 

func (o EventSubscriptionOutput) ToEventSubscriptionPtrOutput() EventSubscriptionPtrOutput

func (EventSubscriptionOutput) ToEventSubscriptionPtrOutputWithContext 

func (o EventSubscriptionOutput) ToEventSubscriptionPtrOutputWithContext(ctx context.Context) EventSubscriptionPtrOutput

type EventSubscriptionPtrInput 

type EventSubscriptionPtrInput interface {
	pulumi.Input

	ToEventSubscriptionPtrOutput() EventSubscriptionPtrOutput
	ToEventSubscriptionPtrOutputWithContext(ctx context.Context) EventSubscriptionPtrOutput
}

type EventSubscriptionPtrOutput 

type EventSubscriptionPtrOutput struct{ *pulumi.OutputState }

func (EventSubscriptionPtrOutput) Elem added in v4.15.0 

func (o EventSubscriptionPtrOutput) Elem() EventSubscriptionOutput

func (EventSubscriptionPtrOutput) ElementType 

func (EventSubscriptionPtrOutput) ElementType() reflect.Type

func (EventSubscriptionPtrOutput) ToEventSubscriptionPtrOutput 

func (o EventSubscriptionPtrOutput) ToEventSubscriptionPtrOutput() EventSubscriptionPtrOutput

func (EventSubscriptionPtrOutput) ToEventSubscriptionPtrOutputWithContext 

func (o EventSubscriptionPtrOutput) ToEventSubscriptionPtrOutputWithContext(ctx context.Context) EventSubscriptionPtrOutput

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 .
	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 .
	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/v4/go/aws"
"github.com/pulumi/pulumi-aws/sdk/v4/go/aws/dms"
"github.com/pulumi/pulumi-aws/sdk/v4/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

func (*ReplicationInstance) ToReplicationInstancePtrOutput 

func (i *ReplicationInstance) ToReplicationInstancePtrOutput() ReplicationInstancePtrOutput

func (*ReplicationInstance) ToReplicationInstancePtrOutputWithContext 

func (i *ReplicationInstance) ToReplicationInstancePtrOutputWithContext(ctx context.Context) ReplicationInstancePtrOutput

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

func (ReplicationInstanceOutput) ElementType() reflect.Type

func (ReplicationInstanceOutput) ToReplicationInstanceOutput 

func (o ReplicationInstanceOutput) ToReplicationInstanceOutput() ReplicationInstanceOutput

func (ReplicationInstanceOutput) ToReplicationInstanceOutputWithContext 

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

func (ReplicationInstanceOutput) ToReplicationInstancePtrOutput 

func (o ReplicationInstanceOutput) ToReplicationInstancePtrOutput() ReplicationInstancePtrOutput

func (ReplicationInstanceOutput) ToReplicationInstancePtrOutputWithContext 

func (o ReplicationInstanceOutput) ToReplicationInstancePtrOutputWithContext(ctx context.Context) ReplicationInstancePtrOutput

type ReplicationInstancePtrInput 

type ReplicationInstancePtrInput interface {
	pulumi.Input

	ToReplicationInstancePtrOutput() ReplicationInstancePtrOutput
	ToReplicationInstancePtrOutputWithContext(ctx context.Context) ReplicationInstancePtrOutput
}

type ReplicationInstancePtrOutput 

type ReplicationInstancePtrOutput struct{ *pulumi.OutputState }

func (ReplicationInstancePtrOutput) Elem added in v4.15.0 

func (o ReplicationInstancePtrOutput) Elem() ReplicationInstanceOutput

func (ReplicationInstancePtrOutput) ElementType 

func (ReplicationInstancePtrOutput) ElementType() reflect.Type

func (ReplicationInstancePtrOutput) ToReplicationInstancePtrOutput 

func (o ReplicationInstancePtrOutput) ToReplicationInstancePtrOutput() ReplicationInstancePtrOutput

func (ReplicationInstancePtrOutput) ToReplicationInstancePtrOutputWithContext 

func (o ReplicationInstancePtrOutput) ToReplicationInstancePtrOutputWithContext(ctx context.Context) ReplicationInstancePtrOutput

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

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupPtrOutput 

func (i *ReplicationSubnetGroup) ToReplicationSubnetGroupPtrOutput() ReplicationSubnetGroupPtrOutput

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupPtrOutputWithContext 

func (i *ReplicationSubnetGroup) ToReplicationSubnetGroupPtrOutputWithContext(ctx context.Context) ReplicationSubnetGroupPtrOutput

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

func (o ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutput() ReplicationSubnetGroupOutput

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutputWithContext 

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

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupPtrOutput 

func (o ReplicationSubnetGroupOutput) ToReplicationSubnetGroupPtrOutput() ReplicationSubnetGroupPtrOutput

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupPtrOutputWithContext 

func (o ReplicationSubnetGroupOutput) ToReplicationSubnetGroupPtrOutputWithContext(ctx context.Context) ReplicationSubnetGroupPtrOutput

type ReplicationSubnetGroupPtrInput 

type ReplicationSubnetGroupPtrInput interface {
	pulumi.Input

	ToReplicationSubnetGroupPtrOutput() ReplicationSubnetGroupPtrOutput
	ToReplicationSubnetGroupPtrOutputWithContext(ctx context.Context) ReplicationSubnetGroupPtrOutput
}

type ReplicationSubnetGroupPtrOutput 

type ReplicationSubnetGroupPtrOutput struct{ *pulumi.OutputState }

func (ReplicationSubnetGroupPtrOutput) Elem added in v4.15.0 

func (o ReplicationSubnetGroupPtrOutput) Elem() ReplicationSubnetGroupOutput

func (ReplicationSubnetGroupPtrOutput) ElementType 

func (ReplicationSubnetGroupPtrOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupPtrOutput) ToReplicationSubnetGroupPtrOutput 

func (o ReplicationSubnetGroupPtrOutput) ToReplicationSubnetGroupPtrOutput() ReplicationSubnetGroupPtrOutput

func (ReplicationSubnetGroupPtrOutput) ToReplicationSubnetGroupPtrOutputWithContext 

func (o ReplicationSubnetGroupPtrOutput) ToReplicationSubnetGroupPtrOutputWithContext(ctx context.Context) ReplicationSubnetGroupPtrOutput

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 .
	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.StringPtrOutput `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"`
	// 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 .
	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.

## Example Usage

```go package main

import ( 

"fmt"

"github.com/pulumi/pulumi-aws/sdk/v4/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("%v%v%v%v%v", "{\"rules\":[{\"rule-type\":\"selection\",\"rule-id\":\"1\",\"rule-name\":\"1\",\"object-locator\":{\"schema-name\":\"", "%", "\",\"table-name\":\"", "%", "\"},\"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

func (*ReplicationTask) ToReplicationTaskPtrOutput 

func (i *ReplicationTask) ToReplicationTaskPtrOutput() ReplicationTaskPtrOutput

func (*ReplicationTask) ToReplicationTaskPtrOutputWithContext 

func (i *ReplicationTask) ToReplicationTaskPtrOutputWithContext(ctx context.Context) ReplicationTaskPtrOutput

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

func (ReplicationTaskOutput) ElementType() reflect.Type

func (ReplicationTaskOutput) ToReplicationTaskOutput 

func (o ReplicationTaskOutput) ToReplicationTaskOutput() ReplicationTaskOutput

func (ReplicationTaskOutput) ToReplicationTaskOutputWithContext 

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

func (ReplicationTaskOutput) ToReplicationTaskPtrOutput 

func (o ReplicationTaskOutput) ToReplicationTaskPtrOutput() ReplicationTaskPtrOutput

func (ReplicationTaskOutput) ToReplicationTaskPtrOutputWithContext 

func (o ReplicationTaskOutput) ToReplicationTaskPtrOutputWithContext(ctx context.Context) ReplicationTaskPtrOutput

type ReplicationTaskPtrInput 

type ReplicationTaskPtrInput interface {
	pulumi.Input

	ToReplicationTaskPtrOutput() ReplicationTaskPtrOutput
	ToReplicationTaskPtrOutputWithContext(ctx context.Context) ReplicationTaskPtrOutput
}

type ReplicationTaskPtrOutput 

type ReplicationTaskPtrOutput struct{ *pulumi.OutputState }

func (ReplicationTaskPtrOutput) Elem added in v4.15.0 

func (o ReplicationTaskPtrOutput) Elem() ReplicationTaskOutput

func (ReplicationTaskPtrOutput) ElementType 

func (ReplicationTaskPtrOutput) ElementType() reflect.Type

func (ReplicationTaskPtrOutput) ToReplicationTaskPtrOutput 

func (o ReplicationTaskPtrOutput) ToReplicationTaskPtrOutput() ReplicationTaskPtrOutput

func (ReplicationTaskPtrOutput) ToReplicationTaskPtrOutputWithContext 

func (o ReplicationTaskPtrOutput) ToReplicationTaskPtrOutputWithContext(ctx context.Context) ReplicationTaskPtrOutput

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