dms

package
v3.38.1 Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2021 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.
	Tags pulumi.StringMapOutput `pulumi:"tags"`
}

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/v3/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("..."),
			Tags: pulumi.StringMap{
				"Name": pulumi.String("test"),
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

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

```sh 

$ pulumi import aws:dms/certificate:Certificate test arn:aws:dms:us-west-2:123456789:cert:xxxxxxxxxx

```

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 added in v3.13.0 

func (*Certificate) ElementType() reflect.Type

func (*Certificate) ToCertificateOutput added in v3.13.0 

func (i *Certificate) ToCertificateOutput() CertificateOutput

func (*Certificate) ToCertificateOutputWithContext added in v3.13.0 

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

func (*Certificate) ToCertificatePtrOutput added in v3.25.0 

func (i *Certificate) ToCertificatePtrOutput() CertificatePtrOutput

func (*Certificate) ToCertificatePtrOutputWithContext added in v3.25.0 

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

The set of arguments for constructing a Certificate resource.

func (CertificateArgs) ElementType 

func (CertificateArgs) ElementType() reflect.Type

type CertificateArray added in v3.25.0 

type CertificateArray []CertificateInput

func (CertificateArray) ElementType added in v3.25.0 

func (CertificateArray) ElementType() reflect.Type

func (CertificateArray) ToCertificateArrayOutput added in v3.25.0 

func (i CertificateArray) ToCertificateArrayOutput() CertificateArrayOutput

func (CertificateArray) ToCertificateArrayOutputWithContext added in v3.25.0 

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

type CertificateArrayInput added in v3.25.0 

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 added in v3.25.0 

type CertificateArrayOutput struct{ *pulumi.OutputState }

func (CertificateArrayOutput) ElementType added in v3.25.0 

func (CertificateArrayOutput) ElementType() reflect.Type

func (CertificateArrayOutput) Index added in v3.25.0 

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

func (CertificateArrayOutput) ToCertificateArrayOutput added in v3.25.0 

func (o CertificateArrayOutput) ToCertificateArrayOutput() CertificateArrayOutput

func (CertificateArrayOutput) ToCertificateArrayOutputWithContext added in v3.25.0 

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

type CertificateInput added in v3.13.0 

type CertificateInput interface {
	pulumi.Input

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

type CertificateMap added in v3.25.0 

type CertificateMap map[string]CertificateInput

func (CertificateMap) ElementType added in v3.25.0 

func (CertificateMap) ElementType() reflect.Type

func (CertificateMap) ToCertificateMapOutput added in v3.25.0 

func (i CertificateMap) ToCertificateMapOutput() CertificateMapOutput

func (CertificateMap) ToCertificateMapOutputWithContext added in v3.25.0 

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

type CertificateMapInput added in v3.25.0 

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 added in v3.25.0 

type CertificateMapOutput struct{ *pulumi.OutputState }

func (CertificateMapOutput) ElementType added in v3.25.0 

func (CertificateMapOutput) ElementType() reflect.Type

func (CertificateMapOutput) MapIndex added in v3.25.0 

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

func (CertificateMapOutput) ToCertificateMapOutput added in v3.25.0 

func (o CertificateMapOutput) ToCertificateMapOutput() CertificateMapOutput

func (CertificateMapOutput) ToCertificateMapOutputWithContext added in v3.25.0 

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

type CertificateOutput added in v3.13.0 

type CertificateOutput struct {
	*pulumi.OutputState
}

func (CertificateOutput) ElementType added in v3.13.0 

func (CertificateOutput) ElementType() reflect.Type

func (CertificateOutput) ToCertificateOutput added in v3.13.0 

func (o CertificateOutput) ToCertificateOutput() CertificateOutput

func (CertificateOutput) ToCertificateOutputWithContext added in v3.13.0 

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

func (CertificateOutput) ToCertificatePtrOutput added in v3.25.0 

func (o CertificateOutput) ToCertificatePtrOutput() CertificatePtrOutput

func (CertificateOutput) ToCertificatePtrOutputWithContext added in v3.25.0 

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

type CertificatePtrInput added in v3.25.0 

type CertificatePtrInput interface {
	pulumi.Input

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

type CertificatePtrOutput added in v3.25.0 

type CertificatePtrOutput struct {
	*pulumi.OutputState
}

func (CertificatePtrOutput) ElementType added in v3.25.0 

func (CertificatePtrOutput) ElementType() reflect.Type

func (CertificatePtrOutput) ToCertificatePtrOutput added in v3.25.0 

func (o CertificatePtrOutput) ToCertificatePtrOutput() CertificatePtrOutput

func (CertificatePtrOutput) ToCertificatePtrOutputWithContext added in v3.25.0 

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

## Example Usage

```go package main

import ( 

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

```

## 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 added in v3.13.0 

func (*Endpoint) ElementType() reflect.Type

func (*Endpoint) ToEndpointOutput added in v3.13.0 

func (i *Endpoint) ToEndpointOutput() EndpointOutput

func (*Endpoint) ToEndpointOutputWithContext added in v3.13.0 

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

func (*Endpoint) ToEndpointPtrOutput added in v3.25.0 

func (i *Endpoint) ToEndpointPtrOutput() EndpointPtrOutput

func (*Endpoint) ToEndpointPtrOutputWithContext added in v3.25.0 

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](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 EndpointArray added in v3.25.0 

type EndpointArray []EndpointInput

func (EndpointArray) ElementType added in v3.25.0 

func (EndpointArray) ElementType() reflect.Type

func (EndpointArray) ToEndpointArrayOutput added in v3.25.0 

func (i EndpointArray) ToEndpointArrayOutput() EndpointArrayOutput

func (EndpointArray) ToEndpointArrayOutputWithContext added in v3.25.0 

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

type EndpointArrayInput added in v3.25.0 

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 added in v3.25.0 

type EndpointArrayOutput struct{ *pulumi.OutputState }

func (EndpointArrayOutput) ElementType added in v3.25.0 

func (EndpointArrayOutput) ElementType() reflect.Type

func (EndpointArrayOutput) Index added in v3.25.0 

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

func (EndpointArrayOutput) ToEndpointArrayOutput added in v3.25.0 

func (o EndpointArrayOutput) ToEndpointArrayOutput() EndpointArrayOutput

func (EndpointArrayOutput) ToEndpointArrayOutputWithContext added in v3.25.0 

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 added in v3.13.0 

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"`
	// 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"`
	// 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) 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) 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 {
	// 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 

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 

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) 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) 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) 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) 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 added in v3.25.0 

type EndpointMap map[string]EndpointInput

func (EndpointMap) ElementType added in v3.25.0 

func (EndpointMap) ElementType() reflect.Type

func (EndpointMap) ToEndpointMapOutput added in v3.25.0 

func (i EndpointMap) ToEndpointMapOutput() EndpointMapOutput

func (EndpointMap) ToEndpointMapOutputWithContext added in v3.25.0 

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

type EndpointMapInput added in v3.25.0 

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 added in v3.25.0 

type EndpointMapOutput struct{ *pulumi.OutputState }

func (EndpointMapOutput) ElementType added in v3.25.0 

func (EndpointMapOutput) ElementType() reflect.Type

func (EndpointMapOutput) MapIndex added in v3.25.0 

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

func (EndpointMapOutput) ToEndpointMapOutput added in v3.25.0 

func (o EndpointMapOutput) ToEndpointMapOutput() EndpointMapOutput

func (EndpointMapOutput) ToEndpointMapOutputWithContext added in v3.25.0 

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 added in v3.13.0 

type EndpointOutput struct {
	*pulumi.OutputState
}

func (EndpointOutput) ElementType added in v3.13.0 

func (EndpointOutput) ElementType() reflect.Type

func (EndpointOutput) ToEndpointOutput added in v3.13.0 

func (o EndpointOutput) ToEndpointOutput() EndpointOutput

func (EndpointOutput) ToEndpointOutputWithContext added in v3.13.0 

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

func (EndpointOutput) ToEndpointPtrOutput added in v3.25.0 

func (o EndpointOutput) ToEndpointPtrOutput() EndpointPtrOutput

func (EndpointOutput) ToEndpointPtrOutputWithContext added in v3.25.0 

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

type EndpointPtrInput added in v3.25.0 

type EndpointPtrInput interface {
	pulumi.Input

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

type EndpointPtrOutput added in v3.25.0 

type EndpointPtrOutput struct {
	*pulumi.OutputState
}

func (EndpointPtrOutput) ElementType added in v3.25.0 

func (EndpointPtrOutput) ElementType() reflect.Type

func (EndpointPtrOutput) ToEndpointPtrOutput added in v3.25.0 

func (o EndpointPtrOutput) ToEndpointPtrOutput() EndpointPtrOutput

func (EndpointPtrOutput) ToEndpointPtrOutputWithContext added in v3.25.0 

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"`
	// Partition S3 bucket folders based on transaction commit dates. Defaults to `false`.
	DatePartitionEnabled *bool `pulumi:"datePartitionEnabled"`
	// 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"`
	// Partition S3 bucket folders based on transaction commit dates. Defaults to `false`.
	DatePartitionEnabled pulumi.BoolPtrInput `pulumi:"datePartitionEnabled"`
	// 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) DatePartitionEnabled added in v3.24.0 

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) 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) DatePartitionEnabled added in v3.24.0 

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

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

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

## 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 added in v3.13.0 

func (*EventSubscription) ElementType() reflect.Type

func (*EventSubscription) ToEventSubscriptionOutput added in v3.13.0 

func (i *EventSubscription) ToEventSubscriptionOutput() EventSubscriptionOutput

func (*EventSubscription) ToEventSubscriptionOutputWithContext added in v3.13.0 

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

func (*EventSubscription) ToEventSubscriptionPtrOutput added in v3.25.0 

func (i *EventSubscription) ToEventSubscriptionPtrOutput() EventSubscriptionPtrOutput

func (*EventSubscription) ToEventSubscriptionPtrOutputWithContext added in v3.25.0 

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

The set of arguments for constructing a EventSubscription resource.

func (EventSubscriptionArgs) ElementType 

func (EventSubscriptionArgs) ElementType() reflect.Type

type EventSubscriptionArray added in v3.25.0 

type EventSubscriptionArray []EventSubscriptionInput

func (EventSubscriptionArray) ElementType added in v3.25.0 

func (EventSubscriptionArray) ElementType() reflect.Type

func (EventSubscriptionArray) ToEventSubscriptionArrayOutput added in v3.25.0 

func (i EventSubscriptionArray) ToEventSubscriptionArrayOutput() EventSubscriptionArrayOutput

func (EventSubscriptionArray) ToEventSubscriptionArrayOutputWithContext added in v3.25.0 

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

type EventSubscriptionArrayInput added in v3.25.0 

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 added in v3.25.0 

type EventSubscriptionArrayOutput struct{ *pulumi.OutputState }

func (EventSubscriptionArrayOutput) ElementType added in v3.25.0 

func (EventSubscriptionArrayOutput) ElementType() reflect.Type

func (EventSubscriptionArrayOutput) Index added in v3.25.0 

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

func (EventSubscriptionArrayOutput) ToEventSubscriptionArrayOutput added in v3.25.0 

func (o EventSubscriptionArrayOutput) ToEventSubscriptionArrayOutput() EventSubscriptionArrayOutput

func (EventSubscriptionArrayOutput) ToEventSubscriptionArrayOutputWithContext added in v3.25.0 

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

type EventSubscriptionInput added in v3.13.0 

type EventSubscriptionInput interface {
	pulumi.Input

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

type EventSubscriptionMap added in v3.25.0 

type EventSubscriptionMap map[string]EventSubscriptionInput

func (EventSubscriptionMap) ElementType added in v3.25.0 

func (EventSubscriptionMap) ElementType() reflect.Type

func (EventSubscriptionMap) ToEventSubscriptionMapOutput added in v3.25.0 

func (i EventSubscriptionMap) ToEventSubscriptionMapOutput() EventSubscriptionMapOutput

func (EventSubscriptionMap) ToEventSubscriptionMapOutputWithContext added in v3.25.0 

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

type EventSubscriptionMapInput added in v3.25.0 

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 added in v3.25.0 

type EventSubscriptionMapOutput struct{ *pulumi.OutputState }

func (EventSubscriptionMapOutput) ElementType added in v3.25.0 

func (EventSubscriptionMapOutput) ElementType() reflect.Type

func (EventSubscriptionMapOutput) MapIndex added in v3.25.0 

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

func (EventSubscriptionMapOutput) ToEventSubscriptionMapOutput added in v3.25.0 

func (o EventSubscriptionMapOutput) ToEventSubscriptionMapOutput() EventSubscriptionMapOutput

func (EventSubscriptionMapOutput) ToEventSubscriptionMapOutputWithContext added in v3.25.0 

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

type EventSubscriptionOutput added in v3.13.0 

type EventSubscriptionOutput struct {
	*pulumi.OutputState
}

func (EventSubscriptionOutput) ElementType added in v3.13.0 

func (EventSubscriptionOutput) ElementType() reflect.Type

func (EventSubscriptionOutput) ToEventSubscriptionOutput added in v3.13.0 

func (o EventSubscriptionOutput) ToEventSubscriptionOutput() EventSubscriptionOutput

func (EventSubscriptionOutput) ToEventSubscriptionOutputWithContext added in v3.13.0 

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

func (EventSubscriptionOutput) ToEventSubscriptionPtrOutput added in v3.25.0 

func (o EventSubscriptionOutput) ToEventSubscriptionPtrOutput() EventSubscriptionPtrOutput

func (EventSubscriptionOutput) ToEventSubscriptionPtrOutputWithContext added in v3.25.0 

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

type EventSubscriptionPtrInput added in v3.25.0 

type EventSubscriptionPtrInput interface {
	pulumi.Input

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

type EventSubscriptionPtrOutput added in v3.25.0 

type EventSubscriptionPtrOutput struct {
	*pulumi.OutputState
}

func (EventSubscriptionPtrOutput) ElementType added in v3.25.0 

func (EventSubscriptionPtrOutput) ElementType() reflect.Type

func (EventSubscriptionPtrOutput) ToEventSubscriptionPtrOutput added in v3.25.0 

func (o EventSubscriptionPtrOutput) ToEventSubscriptionPtrOutput() EventSubscriptionPtrOutput

func (EventSubscriptionPtrOutput) ToEventSubscriptionPtrOutputWithContext added in v3.25.0 

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
	Tags       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. 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/v3/go/aws/dms"
"github.com/pulumi/pulumi-aws/sdk/v3/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.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"),
			},
		})
		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 added in v3.13.0 

func (*ReplicationInstance) ElementType() reflect.Type

func (*ReplicationInstance) ToReplicationInstanceOutput added in v3.13.0 

func (i *ReplicationInstance) ToReplicationInstanceOutput() ReplicationInstanceOutput

func (*ReplicationInstance) ToReplicationInstanceOutputWithContext added in v3.13.0 

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

func (*ReplicationInstance) ToReplicationInstancePtrOutput added in v3.25.0 

func (i *ReplicationInstance) ToReplicationInstancePtrOutput() ReplicationInstancePtrOutput

func (*ReplicationInstance) ToReplicationInstancePtrOutputWithContext added in v3.25.0 

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. 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 ReplicationInstanceArray added in v3.25.0 

type ReplicationInstanceArray []ReplicationInstanceInput

func (ReplicationInstanceArray) ElementType added in v3.25.0 

func (ReplicationInstanceArray) ElementType() reflect.Type

func (ReplicationInstanceArray) ToReplicationInstanceArrayOutput added in v3.25.0 

func (i ReplicationInstanceArray) ToReplicationInstanceArrayOutput() ReplicationInstanceArrayOutput

func (ReplicationInstanceArray) ToReplicationInstanceArrayOutputWithContext added in v3.25.0 

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

type ReplicationInstanceArrayInput added in v3.25.0 

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 added in v3.25.0 

type ReplicationInstanceArrayOutput struct{ *pulumi.OutputState }

func (ReplicationInstanceArrayOutput) ElementType added in v3.25.0 

func (ReplicationInstanceArrayOutput) ElementType() reflect.Type

func (ReplicationInstanceArrayOutput) Index added in v3.25.0 

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

func (ReplicationInstanceArrayOutput) ToReplicationInstanceArrayOutput added in v3.25.0 

func (o ReplicationInstanceArrayOutput) ToReplicationInstanceArrayOutput() ReplicationInstanceArrayOutput

func (ReplicationInstanceArrayOutput) ToReplicationInstanceArrayOutputWithContext added in v3.25.0 

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

type ReplicationInstanceInput added in v3.13.0 

type ReplicationInstanceInput interface {
	pulumi.Input

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

type ReplicationInstanceMap added in v3.25.0 

type ReplicationInstanceMap map[string]ReplicationInstanceInput

func (ReplicationInstanceMap) ElementType added in v3.25.0 

func (ReplicationInstanceMap) ElementType() reflect.Type

func (ReplicationInstanceMap) ToReplicationInstanceMapOutput added in v3.25.0 

func (i ReplicationInstanceMap) ToReplicationInstanceMapOutput() ReplicationInstanceMapOutput

func (ReplicationInstanceMap) ToReplicationInstanceMapOutputWithContext added in v3.25.0 

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

type ReplicationInstanceMapInput added in v3.25.0 

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 added in v3.25.0 

type ReplicationInstanceMapOutput struct{ *pulumi.OutputState }

func (ReplicationInstanceMapOutput) ElementType added in v3.25.0 

func (ReplicationInstanceMapOutput) ElementType() reflect.Type

func (ReplicationInstanceMapOutput) MapIndex added in v3.25.0 

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

func (ReplicationInstanceMapOutput) ToReplicationInstanceMapOutput added in v3.25.0 

func (o ReplicationInstanceMapOutput) ToReplicationInstanceMapOutput() ReplicationInstanceMapOutput

func (ReplicationInstanceMapOutput) ToReplicationInstanceMapOutputWithContext added in v3.25.0 

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

type ReplicationInstanceOutput added in v3.13.0 

type ReplicationInstanceOutput struct {
	*pulumi.OutputState
}

func (ReplicationInstanceOutput) ElementType added in v3.13.0 

func (ReplicationInstanceOutput) ElementType() reflect.Type

func (ReplicationInstanceOutput) ToReplicationInstanceOutput added in v3.13.0 

func (o ReplicationInstanceOutput) ToReplicationInstanceOutput() ReplicationInstanceOutput

func (ReplicationInstanceOutput) ToReplicationInstanceOutputWithContext added in v3.13.0 

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

func (ReplicationInstanceOutput) ToReplicationInstancePtrOutput added in v3.25.0 

func (o ReplicationInstanceOutput) ToReplicationInstancePtrOutput() ReplicationInstancePtrOutput

func (ReplicationInstanceOutput) ToReplicationInstancePtrOutputWithContext added in v3.25.0 

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

type ReplicationInstancePtrInput added in v3.25.0 

type ReplicationInstancePtrInput interface {
	pulumi.Input

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

type ReplicationInstancePtrOutput added in v3.25.0 

type ReplicationInstancePtrOutput struct {
	*pulumi.OutputState
}

func (ReplicationInstancePtrOutput) ElementType added in v3.25.0 

func (ReplicationInstancePtrOutput) ElementType() reflect.Type

func (ReplicationInstancePtrOutput) ToReplicationInstancePtrOutput added in v3.25.0 

func (o ReplicationInstancePtrOutput) ToReplicationInstancePtrOutput() ReplicationInstancePtrOutput

func (ReplicationInstancePtrOutput) ToReplicationInstancePtrOutputWithContext added in v3.25.0 

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. 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/v3/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
	})
}

```

## 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 added in v3.13.0 

func (*ReplicationSubnetGroup) ElementType() reflect.Type

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupOutput added in v3.13.0 

func (i *ReplicationSubnetGroup) ToReplicationSubnetGroupOutput() ReplicationSubnetGroupOutput

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupOutputWithContext added in v3.13.0 

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

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupPtrOutput added in v3.25.0 

func (i *ReplicationSubnetGroup) ToReplicationSubnetGroupPtrOutput() ReplicationSubnetGroupPtrOutput

func (*ReplicationSubnetGroup) ToReplicationSubnetGroupPtrOutputWithContext added in v3.25.0 

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

The set of arguments for constructing a ReplicationSubnetGroup resource.

func (ReplicationSubnetGroupArgs) ElementType 

func (ReplicationSubnetGroupArgs) ElementType() reflect.Type

type ReplicationSubnetGroupArray added in v3.25.0 

type ReplicationSubnetGroupArray []ReplicationSubnetGroupInput

func (ReplicationSubnetGroupArray) ElementType added in v3.25.0 

func (ReplicationSubnetGroupArray) ElementType() reflect.Type

func (ReplicationSubnetGroupArray) ToReplicationSubnetGroupArrayOutput added in v3.25.0 

func (i ReplicationSubnetGroupArray) ToReplicationSubnetGroupArrayOutput() ReplicationSubnetGroupArrayOutput

func (ReplicationSubnetGroupArray) ToReplicationSubnetGroupArrayOutputWithContext added in v3.25.0 

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

type ReplicationSubnetGroupArrayInput added in v3.25.0 

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 added in v3.25.0 

type ReplicationSubnetGroupArrayOutput struct{ *pulumi.OutputState }

func (ReplicationSubnetGroupArrayOutput) ElementType added in v3.25.0 

func (ReplicationSubnetGroupArrayOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupArrayOutput) Index added in v3.25.0 

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

func (ReplicationSubnetGroupArrayOutput) ToReplicationSubnetGroupArrayOutput added in v3.25.0 

func (o ReplicationSubnetGroupArrayOutput) ToReplicationSubnetGroupArrayOutput() ReplicationSubnetGroupArrayOutput

func (ReplicationSubnetGroupArrayOutput) ToReplicationSubnetGroupArrayOutputWithContext added in v3.25.0 

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

type ReplicationSubnetGroupInput added in v3.13.0 

type ReplicationSubnetGroupInput interface {
	pulumi.Input

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

type ReplicationSubnetGroupMap added in v3.25.0 

type ReplicationSubnetGroupMap map[string]ReplicationSubnetGroupInput

func (ReplicationSubnetGroupMap) ElementType added in v3.25.0 

func (ReplicationSubnetGroupMap) ElementType() reflect.Type

func (ReplicationSubnetGroupMap) ToReplicationSubnetGroupMapOutput added in v3.25.0 

func (i ReplicationSubnetGroupMap) ToReplicationSubnetGroupMapOutput() ReplicationSubnetGroupMapOutput

func (ReplicationSubnetGroupMap) ToReplicationSubnetGroupMapOutputWithContext added in v3.25.0 

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

type ReplicationSubnetGroupMapInput added in v3.25.0 

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 added in v3.25.0 

type ReplicationSubnetGroupMapOutput struct{ *pulumi.OutputState }

func (ReplicationSubnetGroupMapOutput) ElementType added in v3.25.0 

func (ReplicationSubnetGroupMapOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupMapOutput) MapIndex added in v3.25.0 

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

func (ReplicationSubnetGroupMapOutput) ToReplicationSubnetGroupMapOutput added in v3.25.0 

func (o ReplicationSubnetGroupMapOutput) ToReplicationSubnetGroupMapOutput() ReplicationSubnetGroupMapOutput

func (ReplicationSubnetGroupMapOutput) ToReplicationSubnetGroupMapOutputWithContext added in v3.25.0 

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

type ReplicationSubnetGroupOutput added in v3.13.0 

type ReplicationSubnetGroupOutput struct {
	*pulumi.OutputState
}

func (ReplicationSubnetGroupOutput) ElementType added in v3.13.0 

func (ReplicationSubnetGroupOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutput added in v3.13.0 

func (o ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutput() ReplicationSubnetGroupOutput

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupOutputWithContext added in v3.13.0 

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

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupPtrOutput added in v3.25.0 

func (o ReplicationSubnetGroupOutput) ToReplicationSubnetGroupPtrOutput() ReplicationSubnetGroupPtrOutput

func (ReplicationSubnetGroupOutput) ToReplicationSubnetGroupPtrOutputWithContext added in v3.25.0 

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

type ReplicationSubnetGroupPtrInput added in v3.25.0 

type ReplicationSubnetGroupPtrInput interface {
	pulumi.Input

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

type ReplicationSubnetGroupPtrOutput added in v3.25.0 

type ReplicationSubnetGroupPtrOutput struct {
	*pulumi.OutputState
}

func (ReplicationSubnetGroupPtrOutput) ElementType added in v3.25.0 

func (ReplicationSubnetGroupPtrOutput) ElementType() reflect.Type

func (ReplicationSubnetGroupPtrOutput) ToReplicationSubnetGroupPtrOutput added in v3.25.0 

func (o ReplicationSubnetGroupPtrOutput) ToReplicationSubnetGroupPtrOutput() ReplicationSubnetGroupPtrOutput

func (ReplicationSubnetGroupPtrOutput) ToReplicationSubnetGroupPtrOutputWithContext added in v3.25.0 

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.
	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/v3/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.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 added in v3.13.0 

func (*ReplicationTask) ElementType() reflect.Type

func (*ReplicationTask) ToReplicationTaskOutput added in v3.13.0 

func (i *ReplicationTask) ToReplicationTaskOutput() ReplicationTaskOutput

func (*ReplicationTask) ToReplicationTaskOutputWithContext added in v3.13.0 

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

func (*ReplicationTask) ToReplicationTaskPtrOutput added in v3.25.0 

func (i *ReplicationTask) ToReplicationTaskPtrOutput() ReplicationTaskPtrOutput

func (*ReplicationTask) ToReplicationTaskPtrOutputWithContext added in v3.25.0 

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

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 ReplicationTaskArray added in v3.25.0 

type ReplicationTaskArray []ReplicationTaskInput

func (ReplicationTaskArray) ElementType added in v3.25.0 

func (ReplicationTaskArray) ElementType() reflect.Type

func (ReplicationTaskArray) ToReplicationTaskArrayOutput added in v3.25.0 

func (i ReplicationTaskArray) ToReplicationTaskArrayOutput() ReplicationTaskArrayOutput

func (ReplicationTaskArray) ToReplicationTaskArrayOutputWithContext added in v3.25.0 

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

type ReplicationTaskArrayInput added in v3.25.0 

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 added in v3.25.0 

type ReplicationTaskArrayOutput struct{ *pulumi.OutputState }

func (ReplicationTaskArrayOutput) ElementType added in v3.25.0 

func (ReplicationTaskArrayOutput) ElementType() reflect.Type

func (ReplicationTaskArrayOutput) Index added in v3.25.0 

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

func (ReplicationTaskArrayOutput) ToReplicationTaskArrayOutput added in v3.25.0 

func (o ReplicationTaskArrayOutput) ToReplicationTaskArrayOutput() ReplicationTaskArrayOutput

func (ReplicationTaskArrayOutput) ToReplicationTaskArrayOutputWithContext added in v3.25.0 

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

type ReplicationTaskInput added in v3.13.0 

type ReplicationTaskInput interface {
	pulumi.Input

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

type ReplicationTaskMap added in v3.25.0 

type ReplicationTaskMap map[string]ReplicationTaskInput

func (ReplicationTaskMap) ElementType added in v3.25.0 

func (ReplicationTaskMap) ElementType() reflect.Type

func (ReplicationTaskMap) ToReplicationTaskMapOutput added in v3.25.0 

func (i ReplicationTaskMap) ToReplicationTaskMapOutput() ReplicationTaskMapOutput

func (ReplicationTaskMap) ToReplicationTaskMapOutputWithContext added in v3.25.0 

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

type ReplicationTaskMapInput added in v3.25.0 

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 added in v3.25.0 

type ReplicationTaskMapOutput struct{ *pulumi.OutputState }

func (ReplicationTaskMapOutput) ElementType added in v3.25.0 

func (ReplicationTaskMapOutput) ElementType() reflect.Type

func (ReplicationTaskMapOutput) MapIndex added in v3.25.0 

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

func (ReplicationTaskMapOutput) ToReplicationTaskMapOutput added in v3.25.0 

func (o ReplicationTaskMapOutput) ToReplicationTaskMapOutput() ReplicationTaskMapOutput

func (ReplicationTaskMapOutput) ToReplicationTaskMapOutputWithContext added in v3.25.0 

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

type ReplicationTaskOutput added in v3.13.0 

type ReplicationTaskOutput struct {
	*pulumi.OutputState
}

func (ReplicationTaskOutput) ElementType added in v3.13.0 

func (ReplicationTaskOutput) ElementType() reflect.Type

func (ReplicationTaskOutput) ToReplicationTaskOutput added in v3.13.0 

func (o ReplicationTaskOutput) ToReplicationTaskOutput() ReplicationTaskOutput

func (ReplicationTaskOutput) ToReplicationTaskOutputWithContext added in v3.13.0 

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

func (ReplicationTaskOutput) ToReplicationTaskPtrOutput added in v3.25.0 

func (o ReplicationTaskOutput) ToReplicationTaskPtrOutput() ReplicationTaskPtrOutput

func (ReplicationTaskOutput) ToReplicationTaskPtrOutputWithContext added in v3.25.0 

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

type ReplicationTaskPtrInput added in v3.25.0 

type ReplicationTaskPtrInput interface {
	pulumi.Input

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

type ReplicationTaskPtrOutput added in v3.25.0 

type ReplicationTaskPtrOutput struct {
	*pulumi.OutputState
}

func (ReplicationTaskPtrOutput) ElementType added in v3.25.0 

func (ReplicationTaskPtrOutput) ElementType() reflect.Type

func (ReplicationTaskPtrOutput) ToReplicationTaskPtrOutput added in v3.25.0 

func (o ReplicationTaskPtrOutput) ToReplicationTaskPtrOutput() ReplicationTaskPtrOutput

func (ReplicationTaskPtrOutput) ToReplicationTaskPtrOutputWithContext added in v3.25.0 

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

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.