dms

package
v2.13.1 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2020 License: Apache-2.0 Imports: 4 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. Either `certificatePem` or `certificateWallet` must be set.
	CertificateWallet pulumi.StringPtrOutput `pulumi:"certificateWallet"`
}

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

> **Note:** All arguments including the PEM encoded certificate will be stored in the raw state as plain-text.

## Example Usage

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v2/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v2/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("..."),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

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.

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. Either `certificatePem` or `certificateWallet` must be set.
	CertificateWallet pulumi.StringPtrInput
}

The set of arguments for constructing a Certificate resource.

func (CertificateArgs) ElementType 

func (CertificateArgs) ElementType() reflect.Type

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. Either `certificatePem` or `certificateWallet` must be set.
	CertificateWallet pulumi.StringPtrInput
}

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](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Introduction.ConnectionAttributes.html).
	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"`
	// 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.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// 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.

> **Note:** All arguments including the password will be stored in the raw state as plain-text.

## Example Usage

```go package main

import ( 

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

```

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.

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](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Introduction.ConnectionAttributes.html).
	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
	// 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.
	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 EndpointElasticsearchSettings added in v2.1.0 

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 added in v2.1.0 

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 added in v2.1.0 

func (EndpointElasticsearchSettingsArgs) ElementType() reflect.Type

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsOutput added in v2.1.0 

func (i EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsOutput() EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsOutputWithContext added in v2.1.0 

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

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsPtrOutput added in v2.1.0 

func (i EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsPtrOutput() EndpointElasticsearchSettingsPtrOutput

func (EndpointElasticsearchSettingsArgs) ToEndpointElasticsearchSettingsPtrOutputWithContext added in v2.1.0 

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

type EndpointElasticsearchSettingsInput added in v2.1.0 

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 added in v2.1.0 

type EndpointElasticsearchSettingsOutput struct{ *pulumi.OutputState }

func (EndpointElasticsearchSettingsOutput) ElementType added in v2.1.0 

func (EndpointElasticsearchSettingsOutput) ElementType() reflect.Type

func (EndpointElasticsearchSettingsOutput) EndpointUri added in v2.1.0 

func (o EndpointElasticsearchSettingsOutput) EndpointUri() pulumi.StringOutput

Endpoint for the Elasticsearch cluster.

func (EndpointElasticsearchSettingsOutput) ErrorRetryDuration added in v2.1.0 

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 added in v2.1.0 

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 added in v2.1.0 

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 added in v2.1.0 

func (o EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsOutput() EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsOutputWithContext added in v2.1.0 

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

func (EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsPtrOutput added in v2.1.0 

func (o EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsPtrOutput() EndpointElasticsearchSettingsPtrOutput

func (EndpointElasticsearchSettingsOutput) ToEndpointElasticsearchSettingsPtrOutputWithContext added in v2.1.0 

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

type EndpointElasticsearchSettingsPtrInput added in v2.1.0 

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 added in v2.1.0 

func EndpointElasticsearchSettingsPtr(v *EndpointElasticsearchSettingsArgs) EndpointElasticsearchSettingsPtrInput

type EndpointElasticsearchSettingsPtrOutput added in v2.1.0 

type EndpointElasticsearchSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointElasticsearchSettingsPtrOutput) Elem added in v2.1.0 

func (o EndpointElasticsearchSettingsPtrOutput) Elem() EndpointElasticsearchSettingsOutput

func (EndpointElasticsearchSettingsPtrOutput) ElementType added in v2.1.0 

func (EndpointElasticsearchSettingsPtrOutput) ElementType() reflect.Type

func (EndpointElasticsearchSettingsPtrOutput) EndpointUri added in v2.1.0 

func (o EndpointElasticsearchSettingsPtrOutput) EndpointUri() pulumi.StringPtrOutput

Endpoint for the Elasticsearch cluster.

func (EndpointElasticsearchSettingsPtrOutput) ErrorRetryDuration added in v2.1.0 

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 added in v2.1.0 

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 added in v2.1.0 

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 added in v2.1.0 

func (o EndpointElasticsearchSettingsPtrOutput) ToEndpointElasticsearchSettingsPtrOutput() EndpointElasticsearchSettingsPtrOutput

func (EndpointElasticsearchSettingsPtrOutput) ToEndpointElasticsearchSettingsPtrOutputWithContext added in v2.1.0 

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

type EndpointKafkaSettings added in v2.3.0 

type EndpointKafkaSettings struct {
	// Kafka broker location. Specify in the form broker-hostname-or-ip:port.
	Broker string `pulumi:"broker"`
	// Kafka topic for migration. Defaults to `kafka-default-topic`.
	Topic *string `pulumi:"topic"`
}

type EndpointKafkaSettingsArgs added in v2.3.0 

type EndpointKafkaSettingsArgs struct {
	// Kafka broker location. Specify in the form broker-hostname-or-ip:port.
	Broker pulumi.StringInput `pulumi:"broker"`
	// Kafka topic for migration. Defaults to `kafka-default-topic`.
	Topic pulumi.StringPtrInput `pulumi:"topic"`
}

func (EndpointKafkaSettingsArgs) ElementType added in v2.3.0 

func (EndpointKafkaSettingsArgs) ElementType() reflect.Type

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsOutput added in v2.3.0 

func (i EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsOutput() EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsOutputWithContext added in v2.3.0 

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

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsPtrOutput added in v2.3.0 

func (i EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsPtrOutput() EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsArgs) ToEndpointKafkaSettingsPtrOutputWithContext added in v2.3.0 

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

type EndpointKafkaSettingsInput added in v2.3.0 

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 added in v2.3.0 

type EndpointKafkaSettingsOutput struct{ *pulumi.OutputState }

func (EndpointKafkaSettingsOutput) Broker added in v2.3.0 

func (o EndpointKafkaSettingsOutput) Broker() pulumi.StringOutput

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

func (EndpointKafkaSettingsOutput) ElementType added in v2.3.0 

func (EndpointKafkaSettingsOutput) ElementType() reflect.Type

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsOutput added in v2.3.0 

func (o EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsOutput() EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsOutputWithContext added in v2.3.0 

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

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsPtrOutput added in v2.3.0 

func (o EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsPtrOutput() EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsOutput) ToEndpointKafkaSettingsPtrOutputWithContext added in v2.3.0 

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

func (EndpointKafkaSettingsOutput) Topic added in v2.3.0 

func (o EndpointKafkaSettingsOutput) Topic() pulumi.StringPtrOutput

Kafka topic for migration. Defaults to `kafka-default-topic`.

type EndpointKafkaSettingsPtrInput added in v2.3.0 

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 added in v2.3.0 

func EndpointKafkaSettingsPtr(v *EndpointKafkaSettingsArgs) EndpointKafkaSettingsPtrInput

type EndpointKafkaSettingsPtrOutput added in v2.3.0 

type EndpointKafkaSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointKafkaSettingsPtrOutput) Broker added in v2.3.0 

func (o EndpointKafkaSettingsPtrOutput) Broker() pulumi.StringPtrOutput

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

func (EndpointKafkaSettingsPtrOutput) Elem added in v2.3.0 

func (o EndpointKafkaSettingsPtrOutput) Elem() EndpointKafkaSettingsOutput

func (EndpointKafkaSettingsPtrOutput) ElementType added in v2.3.0 

func (EndpointKafkaSettingsPtrOutput) ElementType() reflect.Type

func (EndpointKafkaSettingsPtrOutput) ToEndpointKafkaSettingsPtrOutput added in v2.3.0 

func (o EndpointKafkaSettingsPtrOutput) ToEndpointKafkaSettingsPtrOutput() EndpointKafkaSettingsPtrOutput

func (EndpointKafkaSettingsPtrOutput) ToEndpointKafkaSettingsPtrOutputWithContext added in v2.3.0 

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

func (EndpointKafkaSettingsPtrOutput) Topic added in v2.3.0 

func (o EndpointKafkaSettingsPtrOutput) Topic() pulumi.StringPtrOutput

Kafka topic for migration. Defaults to `kafka-default-topic`.

type EndpointKinesisSettings added in v2.1.0 

type EndpointKinesisSettings struct {
	// 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"`
	// 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 added in v2.1.0 

type EndpointKinesisSettingsArgs struct {
	// 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"`
	// 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 added in v2.1.0 

func (EndpointKinesisSettingsArgs) ElementType() reflect.Type

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsOutput added in v2.1.0 

func (i EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsOutput() EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsOutputWithContext added in v2.1.0 

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

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsPtrOutput added in v2.1.0 

func (i EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsPtrOutput() EndpointKinesisSettingsPtrOutput

func (EndpointKinesisSettingsArgs) ToEndpointKinesisSettingsPtrOutputWithContext added in v2.1.0 

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

type EndpointKinesisSettingsInput added in v2.1.0 

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 added in v2.1.0 

type EndpointKinesisSettingsOutput struct{ *pulumi.OutputState }

func (EndpointKinesisSettingsOutput) ElementType added in v2.1.0 

func (EndpointKinesisSettingsOutput) ElementType() reflect.Type

func (EndpointKinesisSettingsOutput) MessageFormat added in v2.1.0 

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) ServiceAccessRoleArn added in v2.1.0 

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 added in v2.1.0 

func (o EndpointKinesisSettingsOutput) StreamArn() pulumi.StringPtrOutput

Amazon Resource Name (ARN) of the Kinesis data stream.

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsOutput added in v2.1.0 

func (o EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsOutput() EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsOutputWithContext added in v2.1.0 

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

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsPtrOutput added in v2.1.0 

func (o EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsPtrOutput() EndpointKinesisSettingsPtrOutput

func (EndpointKinesisSettingsOutput) ToEndpointKinesisSettingsPtrOutputWithContext added in v2.1.0 

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

type EndpointKinesisSettingsPtrInput added in v2.1.0 

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 added in v2.1.0 

func EndpointKinesisSettingsPtr(v *EndpointKinesisSettingsArgs) EndpointKinesisSettingsPtrInput

type EndpointKinesisSettingsPtrOutput added in v2.1.0 

type EndpointKinesisSettingsPtrOutput struct{ *pulumi.OutputState }

func (EndpointKinesisSettingsPtrOutput) Elem added in v2.1.0 

func (o EndpointKinesisSettingsPtrOutput) Elem() EndpointKinesisSettingsOutput

func (EndpointKinesisSettingsPtrOutput) ElementType added in v2.1.0 

func (EndpointKinesisSettingsPtrOutput) ElementType() reflect.Type

func (EndpointKinesisSettingsPtrOutput) MessageFormat added in v2.1.0 

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) ServiceAccessRoleArn added in v2.1.0 

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 added in v2.1.0 

func (o EndpointKinesisSettingsPtrOutput) StreamArn() pulumi.StringPtrOutput

Amazon Resource Name (ARN) of the Kinesis data stream.

func (EndpointKinesisSettingsPtrOutput) ToEndpointKinesisSettingsPtrOutput added in v2.1.0 

func (o EndpointKinesisSettingsPtrOutput) ToEndpointKinesisSettingsPtrOutput() EndpointKinesisSettingsPtrOutput

func (EndpointKinesisSettingsPtrOutput) ToEndpointKinesisSettingsPtrOutputWithContext added in v2.1.0 

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

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 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"`
	// JSON document that describes how AWS DMS should interpret the data.
	ExternalTableDefinition *string `pulumi:"externalTableDefinition"`
	// 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"`
	// JSON document that describes how AWS DMS should interpret the data.
	ExternalTableDefinition pulumi.StringPtrInput `pulumi:"externalTableDefinition"`
	// 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) ElementType 

func (EndpointS3SettingsOutput) ElementType() reflect.Type

func (EndpointS3SettingsOutput) ExternalTableDefinition 

func (o EndpointS3SettingsOutput) ExternalTableDefinition() pulumi.StringPtrOutput

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

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

func (o EndpointS3SettingsPtrOutput) Elem() EndpointS3SettingsOutput

func (EndpointS3SettingsPtrOutput) ElementType 

func (EndpointS3SettingsPtrOutput) ElementType() reflect.Type

func (EndpointS3SettingsPtrOutput) ExternalTableDefinition 

func (o EndpointS3SettingsPtrOutput) ExternalTableDefinition() pulumi.StringPtrOutput

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

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](http://docs.aws.amazon.com/dms/latest/userguide/CHAP_Introduction.ConnectionAttributes.html).
	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
	// 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.
	Tags 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 added in v2.1.0 

type EventSubscription struct {
	pulumi.CustomResourceState

	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"`
	Tags       pulumi.StringMapOutput `pulumi:"tags"`
}

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

func GetEventSubscription added in v2.1.0 

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 added in v2.1.0 

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.

type EventSubscriptionArgs added in v2.1.0 

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

The set of arguments for constructing a EventSubscription resource.

func (EventSubscriptionArgs) ElementType added in v2.1.0 

func (EventSubscriptionArgs) ElementType() reflect.Type

type EventSubscriptionState added in v2.1.0 

type EventSubscriptionState struct {
	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
	Tags       pulumi.StringMapInput
}

func (EventSubscriptionState) ElementType added in v2.1.0 

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 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. Can be one of `dms.t2.micro | dms.t2.small | dms.t2.medium | dms.t2.large | dms.c4.large | dms.c4.xlarge | dms.c4.2xlarge | dms.c4.4xlarge`
	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.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// 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

```go package main

import ( 

"github.com/pulumi/pulumi-aws/sdk/v2/go/aws/dms"
"github.com/pulumi/pulumi-aws/sdk/v2/go/aws/iam"
"github.com/pulumi/pulumi/sdk/v2/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.String(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"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

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.

type ReplicationInstanceArgs 

type ReplicationInstanceArgs struct {
	// The amount of storage (in gigabytes) to be initially allocated for the replication instance.
	AllocatedStorage pulumi.IntPtrInput
	// 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. Can be one of `dms.t2.micro | dms.t2.small | dms.t2.medium | dms.t2.large | dms.c4.large | dms.c4.xlarge | dms.c4.2xlarge | dms.c4.4xlarge`
	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.
	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 ReplicationInstanceState 

type ReplicationInstanceState struct {
	// The amount of storage (in gigabytes) to be initially allocated for the replication instance.
	AllocatedStorage pulumi.IntPtrInput
	// 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. Can be one of `dms.t2.micro | dms.t2.small | dms.t2.medium | dms.t2.large | dms.c4.large | dms.c4.xlarge | dms.c4.2xlarge | dms.c4.4xlarge`
	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.
	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
}

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.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// 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/v2/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v2/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
	})
}

```

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.

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

The set of arguments for constructing a ReplicationSubnetGroup resource.

func (ReplicationSubnetGroupArgs) ElementType 

func (ReplicationSubnetGroupArgs) ElementType() reflect.Type

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

	// 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.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
	// 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/v2/go/aws/dms"
"github.com/pulumi/pulumi/sdk/v2/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.String(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.String(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.String(aws_dms_endpoint.Test - dms - target - endpoint - tf.Endpoint_arn),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

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.

type ReplicationTaskArgs 

type ReplicationTaskArgs struct {
	// 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.
	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 ReplicationTaskState 

type ReplicationTaskState struct {
	// 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.
	Tags 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.