dts

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PkgVersion added in v0.0.1 

func PkgVersion() (semver.Version, error)

PkgVersion uses reflection to determine the version of the current package. If a version cannot be determined, v1 will be assumed. The second return value is always nil.

Types

type ConsumerChannel 

type ConsumerChannel struct {
	pulumi.CustomResourceState

	// The ID of the consumer group.
	ConsumerGroupId pulumi.StringOutput `pulumi:"consumerGroupId"`
	// The name of the consumer group.
	ConsumerGroupName pulumi.StringOutput `pulumi:"consumerGroupName"`
	// The password of the consumer group account. The length of the `consumerGroupPassword` is limited to `8` to `32` characters. It can contain two or more of the following characters: uppercase letters, lowercase letters, digits, and special characters.
	ConsumerGroupPassword pulumi.StringOutput `pulumi:"consumerGroupPassword"`
	// The username of the consumer group. The length of the `consumerGroupUserName` is limited to `1` to `16` characters. It can contain one or more of the following characters: uppercase letters, lowercase letters, digits, and underscores (_).
	ConsumerGroupUserName pulumi.StringOutput `pulumi:"consumerGroupUserName"`
	// The ID of the subscription instance.
	DtsInstanceId pulumi.StringOutput `pulumi:"dtsInstanceId"`
}

Provides a DTS Consumer Channel resource.

For information about DTS Consumer Channel and how to use it, see [What is Consumer Channel](https://www.alibabacloud.com/help/en/doc-detail/264593.htm).

> **NOTE:** Available in v1.146.0+.

## Import

DTS Consumer Channel can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:dts/consumerChannel:ConsumerChannel example <dts_instance_id>:<consumer_group_id>

```

func GetConsumerChannel 

func GetConsumerChannel(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *ConsumerChannelState, opts ...pulumi.ResourceOption) (*ConsumerChannel, error)

GetConsumerChannel gets an existing ConsumerChannel 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 NewConsumerChannel 

func NewConsumerChannel(ctx *pulumi.Context,
	name string, args *ConsumerChannelArgs, opts ...pulumi.ResourceOption) (*ConsumerChannel, error)

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

func (*ConsumerChannel) ElementType 

func (*ConsumerChannel) ElementType() reflect.Type

func (*ConsumerChannel) ToConsumerChannelOutput 

func (i *ConsumerChannel) ToConsumerChannelOutput() ConsumerChannelOutput

func (*ConsumerChannel) ToConsumerChannelOutputWithContext 

func (i *ConsumerChannel) ToConsumerChannelOutputWithContext(ctx context.Context) ConsumerChannelOutput

type ConsumerChannelArgs 

type ConsumerChannelArgs struct {
	// The name of the consumer group.
	ConsumerGroupName pulumi.StringInput
	// The password of the consumer group account. The length of the `consumerGroupPassword` is limited to `8` to `32` characters. It can contain two or more of the following characters: uppercase letters, lowercase letters, digits, and special characters.
	ConsumerGroupPassword pulumi.StringInput
	// The username of the consumer group. The length of the `consumerGroupUserName` is limited to `1` to `16` characters. It can contain one or more of the following characters: uppercase letters, lowercase letters, digits, and underscores (_).
	ConsumerGroupUserName pulumi.StringInput
	// The ID of the subscription instance.
	DtsInstanceId pulumi.StringInput
}

The set of arguments for constructing a ConsumerChannel resource.

func (ConsumerChannelArgs) ElementType 

func (ConsumerChannelArgs) ElementType() reflect.Type

type ConsumerChannelArray 

type ConsumerChannelArray []ConsumerChannelInput

func (ConsumerChannelArray) ElementType 

func (ConsumerChannelArray) ElementType() reflect.Type

func (ConsumerChannelArray) ToConsumerChannelArrayOutput 

func (i ConsumerChannelArray) ToConsumerChannelArrayOutput() ConsumerChannelArrayOutput

func (ConsumerChannelArray) ToConsumerChannelArrayOutputWithContext 

func (i ConsumerChannelArray) ToConsumerChannelArrayOutputWithContext(ctx context.Context) ConsumerChannelArrayOutput

type ConsumerChannelArrayInput 

type ConsumerChannelArrayInput interface {
	pulumi.Input

	ToConsumerChannelArrayOutput() ConsumerChannelArrayOutput
	ToConsumerChannelArrayOutputWithContext(context.Context) ConsumerChannelArrayOutput
}

ConsumerChannelArrayInput is an input type that accepts ConsumerChannelArray and ConsumerChannelArrayOutput values. You can construct a concrete instance of `ConsumerChannelArrayInput` via: 

ConsumerChannelArray{ ConsumerChannelArgs{...} }

type ConsumerChannelArrayOutput 

type ConsumerChannelArrayOutput struct{ *pulumi.OutputState }

func (ConsumerChannelArrayOutput) ElementType 

func (ConsumerChannelArrayOutput) ElementType() reflect.Type

func (ConsumerChannelArrayOutput) Index 

func (o ConsumerChannelArrayOutput) Index(i pulumi.IntInput) ConsumerChannelOutput

func (ConsumerChannelArrayOutput) ToConsumerChannelArrayOutput 

func (o ConsumerChannelArrayOutput) ToConsumerChannelArrayOutput() ConsumerChannelArrayOutput

func (ConsumerChannelArrayOutput) ToConsumerChannelArrayOutputWithContext 

func (o ConsumerChannelArrayOutput) ToConsumerChannelArrayOutputWithContext(ctx context.Context) ConsumerChannelArrayOutput

type ConsumerChannelInput 

type ConsumerChannelInput interface {
	pulumi.Input

	ToConsumerChannelOutput() ConsumerChannelOutput
	ToConsumerChannelOutputWithContext(ctx context.Context) ConsumerChannelOutput
}

type ConsumerChannelMap 

type ConsumerChannelMap map[string]ConsumerChannelInput

func (ConsumerChannelMap) ElementType 

func (ConsumerChannelMap) ElementType() reflect.Type

func (ConsumerChannelMap) ToConsumerChannelMapOutput 

func (i ConsumerChannelMap) ToConsumerChannelMapOutput() ConsumerChannelMapOutput

func (ConsumerChannelMap) ToConsumerChannelMapOutputWithContext 

func (i ConsumerChannelMap) ToConsumerChannelMapOutputWithContext(ctx context.Context) ConsumerChannelMapOutput

type ConsumerChannelMapInput 

type ConsumerChannelMapInput interface {
	pulumi.Input

	ToConsumerChannelMapOutput() ConsumerChannelMapOutput
	ToConsumerChannelMapOutputWithContext(context.Context) ConsumerChannelMapOutput
}

ConsumerChannelMapInput is an input type that accepts ConsumerChannelMap and ConsumerChannelMapOutput values. You can construct a concrete instance of `ConsumerChannelMapInput` via: 

ConsumerChannelMap{ "key": ConsumerChannelArgs{...} }

type ConsumerChannelMapOutput 

type ConsumerChannelMapOutput struct{ *pulumi.OutputState }

func (ConsumerChannelMapOutput) ElementType 

func (ConsumerChannelMapOutput) ElementType() reflect.Type

func (ConsumerChannelMapOutput) MapIndex 

func (o ConsumerChannelMapOutput) MapIndex(k pulumi.StringInput) ConsumerChannelOutput

func (ConsumerChannelMapOutput) ToConsumerChannelMapOutput 

func (o ConsumerChannelMapOutput) ToConsumerChannelMapOutput() ConsumerChannelMapOutput

func (ConsumerChannelMapOutput) ToConsumerChannelMapOutputWithContext 

func (o ConsumerChannelMapOutput) ToConsumerChannelMapOutputWithContext(ctx context.Context) ConsumerChannelMapOutput

type ConsumerChannelOutput 

type ConsumerChannelOutput struct{ *pulumi.OutputState }

func (ConsumerChannelOutput) ConsumerGroupId 

func (o ConsumerChannelOutput) ConsumerGroupId() pulumi.StringOutput

The ID of the consumer group.

func (ConsumerChannelOutput) ConsumerGroupName 

func (o ConsumerChannelOutput) ConsumerGroupName() pulumi.StringOutput

The name of the consumer group.

func (ConsumerChannelOutput) ConsumerGroupPassword 

func (o ConsumerChannelOutput) ConsumerGroupPassword() pulumi.StringOutput

The password of the consumer group account. The length of the `consumerGroupPassword` is limited to `8` to `32` characters. It can contain two or more of the following characters: uppercase letters, lowercase letters, digits, and special characters.

func (ConsumerChannelOutput) ConsumerGroupUserName 

func (o ConsumerChannelOutput) ConsumerGroupUserName() pulumi.StringOutput

The username of the consumer group. The length of the `consumerGroupUserName` is limited to `1` to `16` characters. It can contain one or more of the following characters: uppercase letters, lowercase letters, digits, and underscores (_).

func (ConsumerChannelOutput) DtsInstanceId 

func (o ConsumerChannelOutput) DtsInstanceId() pulumi.StringOutput

The ID of the subscription instance.

func (ConsumerChannelOutput) ElementType 

func (ConsumerChannelOutput) ElementType() reflect.Type

func (ConsumerChannelOutput) ToConsumerChannelOutput 

func (o ConsumerChannelOutput) ToConsumerChannelOutput() ConsumerChannelOutput

func (ConsumerChannelOutput) ToConsumerChannelOutputWithContext 

func (o ConsumerChannelOutput) ToConsumerChannelOutputWithContext(ctx context.Context) ConsumerChannelOutput

type ConsumerChannelState 

type ConsumerChannelState struct {
	// The ID of the consumer group.
	ConsumerGroupId pulumi.StringPtrInput
	// The name of the consumer group.
	ConsumerGroupName pulumi.StringPtrInput
	// The password of the consumer group account. The length of the `consumerGroupPassword` is limited to `8` to `32` characters. It can contain two or more of the following characters: uppercase letters, lowercase letters, digits, and special characters.
	ConsumerGroupPassword pulumi.StringPtrInput
	// The username of the consumer group. The length of the `consumerGroupUserName` is limited to `1` to `16` characters. It can contain one or more of the following characters: uppercase letters, lowercase letters, digits, and underscores (_).
	ConsumerGroupUserName pulumi.StringPtrInput
	// The ID of the subscription instance.
	DtsInstanceId pulumi.StringPtrInput
}

func (ConsumerChannelState) ElementType 

func (ConsumerChannelState) ElementType() reflect.Type

type GetConsumerChannelsArgs 

type GetConsumerChannelsArgs struct {
	// Subscription instance ID.
	DtsInstanceId string `pulumi:"dtsInstanceId"`
	// A list of Consumer Channel IDs.
	Ids        []string `pulumi:"ids"`
	OutputFile *string  `pulumi:"outputFile"`
}

A collection of arguments for invoking getConsumerChannels.

type GetConsumerChannelsChannel 

type GetConsumerChannelsChannel struct {
	// The ID of the consumer group.
	ConsumerGroupId string `pulumi:"consumerGroupId"`
	// The name of the consumer group.
	ConsumerGroupName string `pulumi:"consumerGroupName"`
	// The username of the consumer group.
	ConsumerGroupUserName string `pulumi:"consumerGroupUserName"`
	// The time point when the client consumed the last message in the subscription channel.
	ConsumptionCheckpoint string `pulumi:"consumptionCheckpoint"`
	// The ID of the Consumer Channel.
	Id string `pulumi:"id"`
	// The message delay time, for the current time data subscription channel in the earliest time of unconsumed messages of the difference, in Unix timestamp format, which is measured in seconds.
	MessageDelay int `pulumi:"messageDelay"`
	// The total number of unconsumed messages.
	UnconsumedData int `pulumi:"unconsumedData"`
}

type GetConsumerChannelsChannelArgs 

type GetConsumerChannelsChannelArgs struct {
	// The ID of the consumer group.
	ConsumerGroupId pulumi.StringInput `pulumi:"consumerGroupId"`
	// The name of the consumer group.
	ConsumerGroupName pulumi.StringInput `pulumi:"consumerGroupName"`
	// The username of the consumer group.
	ConsumerGroupUserName pulumi.StringInput `pulumi:"consumerGroupUserName"`
	// The time point when the client consumed the last message in the subscription channel.
	ConsumptionCheckpoint pulumi.StringInput `pulumi:"consumptionCheckpoint"`
	// The ID of the Consumer Channel.
	Id pulumi.StringInput `pulumi:"id"`
	// The message delay time, for the current time data subscription channel in the earliest time of unconsumed messages of the difference, in Unix timestamp format, which is measured in seconds.
	MessageDelay pulumi.IntInput `pulumi:"messageDelay"`
	// The total number of unconsumed messages.
	UnconsumedData pulumi.IntInput `pulumi:"unconsumedData"`
}

func (GetConsumerChannelsChannelArgs) ElementType 

func (GetConsumerChannelsChannelArgs) ElementType() reflect.Type

func (GetConsumerChannelsChannelArgs) ToGetConsumerChannelsChannelOutput 

func (i GetConsumerChannelsChannelArgs) ToGetConsumerChannelsChannelOutput() GetConsumerChannelsChannelOutput

func (GetConsumerChannelsChannelArgs) ToGetConsumerChannelsChannelOutputWithContext 

func (i GetConsumerChannelsChannelArgs) ToGetConsumerChannelsChannelOutputWithContext(ctx context.Context) GetConsumerChannelsChannelOutput

type GetConsumerChannelsChannelArray 

type GetConsumerChannelsChannelArray []GetConsumerChannelsChannelInput

func (GetConsumerChannelsChannelArray) ElementType 

func (GetConsumerChannelsChannelArray) ElementType() reflect.Type

func (GetConsumerChannelsChannelArray) ToGetConsumerChannelsChannelArrayOutput 

func (i GetConsumerChannelsChannelArray) ToGetConsumerChannelsChannelArrayOutput() GetConsumerChannelsChannelArrayOutput

func (GetConsumerChannelsChannelArray) ToGetConsumerChannelsChannelArrayOutputWithContext 

func (i GetConsumerChannelsChannelArray) ToGetConsumerChannelsChannelArrayOutputWithContext(ctx context.Context) GetConsumerChannelsChannelArrayOutput

type GetConsumerChannelsChannelArrayInput 

type GetConsumerChannelsChannelArrayInput interface {
	pulumi.Input

	ToGetConsumerChannelsChannelArrayOutput() GetConsumerChannelsChannelArrayOutput
	ToGetConsumerChannelsChannelArrayOutputWithContext(context.Context) GetConsumerChannelsChannelArrayOutput
}

GetConsumerChannelsChannelArrayInput is an input type that accepts GetConsumerChannelsChannelArray and GetConsumerChannelsChannelArrayOutput values. You can construct a concrete instance of `GetConsumerChannelsChannelArrayInput` via: 

GetConsumerChannelsChannelArray{ GetConsumerChannelsChannelArgs{...} }

type GetConsumerChannelsChannelArrayOutput 

type GetConsumerChannelsChannelArrayOutput struct{ *pulumi.OutputState }

func (GetConsumerChannelsChannelArrayOutput) ElementType 

func (GetConsumerChannelsChannelArrayOutput) ElementType() reflect.Type

func (GetConsumerChannelsChannelArrayOutput) Index 

func (o GetConsumerChannelsChannelArrayOutput) Index(i pulumi.IntInput) GetConsumerChannelsChannelOutput

func (GetConsumerChannelsChannelArrayOutput) ToGetConsumerChannelsChannelArrayOutput 

func (o GetConsumerChannelsChannelArrayOutput) ToGetConsumerChannelsChannelArrayOutput() GetConsumerChannelsChannelArrayOutput

func (GetConsumerChannelsChannelArrayOutput) ToGetConsumerChannelsChannelArrayOutputWithContext 

func (o GetConsumerChannelsChannelArrayOutput) ToGetConsumerChannelsChannelArrayOutputWithContext(ctx context.Context) GetConsumerChannelsChannelArrayOutput

type GetConsumerChannelsChannelInput 

type GetConsumerChannelsChannelInput interface {
	pulumi.Input

	ToGetConsumerChannelsChannelOutput() GetConsumerChannelsChannelOutput
	ToGetConsumerChannelsChannelOutputWithContext(context.Context) GetConsumerChannelsChannelOutput
}

GetConsumerChannelsChannelInput is an input type that accepts GetConsumerChannelsChannelArgs and GetConsumerChannelsChannelOutput values. You can construct a concrete instance of `GetConsumerChannelsChannelInput` via: 

GetConsumerChannelsChannelArgs{...}

type GetConsumerChannelsChannelOutput 

type GetConsumerChannelsChannelOutput struct{ *pulumi.OutputState }

func (GetConsumerChannelsChannelOutput) ConsumerGroupId 

func (o GetConsumerChannelsChannelOutput) ConsumerGroupId() pulumi.StringOutput

The ID of the consumer group.

func (GetConsumerChannelsChannelOutput) ConsumerGroupName 

func (o GetConsumerChannelsChannelOutput) ConsumerGroupName() pulumi.StringOutput

The name of the consumer group.

func (GetConsumerChannelsChannelOutput) ConsumerGroupUserName 

func (o GetConsumerChannelsChannelOutput) ConsumerGroupUserName() pulumi.StringOutput

The username of the consumer group.

func (GetConsumerChannelsChannelOutput) ConsumptionCheckpoint 

func (o GetConsumerChannelsChannelOutput) ConsumptionCheckpoint() pulumi.StringOutput

The time point when the client consumed the last message in the subscription channel.

func (GetConsumerChannelsChannelOutput) ElementType 

func (GetConsumerChannelsChannelOutput) ElementType() reflect.Type

func (GetConsumerChannelsChannelOutput) Id 

func (o GetConsumerChannelsChannelOutput) Id() pulumi.StringOutput

The ID of the Consumer Channel.

func (GetConsumerChannelsChannelOutput) MessageDelay 

func (o GetConsumerChannelsChannelOutput) MessageDelay() pulumi.IntOutput

The message delay time, for the current time data subscription channel in the earliest time of unconsumed messages of the difference, in Unix timestamp format, which is measured in seconds.

func (GetConsumerChannelsChannelOutput) ToGetConsumerChannelsChannelOutput 

func (o GetConsumerChannelsChannelOutput) ToGetConsumerChannelsChannelOutput() GetConsumerChannelsChannelOutput

func (GetConsumerChannelsChannelOutput) ToGetConsumerChannelsChannelOutputWithContext 

func (o GetConsumerChannelsChannelOutput) ToGetConsumerChannelsChannelOutputWithContext(ctx context.Context) GetConsumerChannelsChannelOutput

func (GetConsumerChannelsChannelOutput) UnconsumedData 

func (o GetConsumerChannelsChannelOutput) UnconsumedData() pulumi.IntOutput

The total number of unconsumed messages.

type GetConsumerChannelsOutputArgs 

type GetConsumerChannelsOutputArgs struct {
	// Subscription instance ID.
	DtsInstanceId pulumi.StringInput `pulumi:"dtsInstanceId"`
	// A list of Consumer Channel IDs.
	Ids        pulumi.StringArrayInput `pulumi:"ids"`
	OutputFile pulumi.StringPtrInput   `pulumi:"outputFile"`
}

A collection of arguments for invoking getConsumerChannels.

func (GetConsumerChannelsOutputArgs) ElementType 

func (GetConsumerChannelsOutputArgs) ElementType() reflect.Type

type GetConsumerChannelsResult 

type GetConsumerChannelsResult struct {
	Channels      []GetConsumerChannelsChannel `pulumi:"channels"`
	DtsInstanceId string                       `pulumi:"dtsInstanceId"`
	// The provider-assigned unique ID for this managed resource.
	Id         string   `pulumi:"id"`
	Ids        []string `pulumi:"ids"`
	OutputFile *string  `pulumi:"outputFile"`
}

A collection of values returned by getConsumerChannels.

func GetConsumerChannels 

func GetConsumerChannels(ctx *pulumi.Context, args *GetConsumerChannelsArgs, opts ...pulumi.InvokeOption) (*GetConsumerChannelsResult, error)

This data source provides the Dts Consumer Channels of the current Alibaba Cloud user.

> **NOTE:** Available in v1.146.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ids, err := dts.GetConsumerChannels(ctx, nil, nil)
		if err != nil {
			return err
		}
		ctx.Export("dtsConsumerChannelId1", ids.Channels[0].Id)
		return nil
	})
}

```

type GetConsumerChannelsResultOutput 

type GetConsumerChannelsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getConsumerChannels.

func GetConsumerChannelsOutput 

func GetConsumerChannelsOutput(ctx *pulumi.Context, args GetConsumerChannelsOutputArgs, opts ...pulumi.InvokeOption) GetConsumerChannelsResultOutput

func (GetConsumerChannelsResultOutput) Channels 

func (o GetConsumerChannelsResultOutput) Channels() GetConsumerChannelsChannelArrayOutput

func (GetConsumerChannelsResultOutput) DtsInstanceId 

func (o GetConsumerChannelsResultOutput) DtsInstanceId() pulumi.StringOutput

func (GetConsumerChannelsResultOutput) ElementType 

func (GetConsumerChannelsResultOutput) ElementType() reflect.Type

func (GetConsumerChannelsResultOutput) Id 

func (o GetConsumerChannelsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetConsumerChannelsResultOutput) Ids 

func (o GetConsumerChannelsResultOutput) Ids() pulumi.StringArrayOutput

func (GetConsumerChannelsResultOutput) OutputFile 

func (o GetConsumerChannelsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetConsumerChannelsResultOutput) ToGetConsumerChannelsResultOutput 

func (o GetConsumerChannelsResultOutput) ToGetConsumerChannelsResultOutput() GetConsumerChannelsResultOutput

func (GetConsumerChannelsResultOutput) ToGetConsumerChannelsResultOutputWithContext 

func (o GetConsumerChannelsResultOutput) ToGetConsumerChannelsResultOutputWithContext(ctx context.Context) GetConsumerChannelsResultOutput

type GetMigrationJobsArgs 

type GetMigrationJobsArgs struct {
	// Default to `false`. Set it to `true` can output more details about resource attributes.
	EnableDetails *bool `pulumi:"enableDetails"`
	// A list of Synchronization Job IDs.
	Ids []string `pulumi:"ids"`
	// A regex string to filter results by Migration Job name.
	NameRegex  *string `pulumi:"nameRegex"`
	OutputFile *string `pulumi:"outputFile"`
}

A collection of arguments for invoking getMigrationJobs.

type GetMigrationJobsJob 

type GetMigrationJobsJob struct {
	// Whether or not to execute DTS supports schema migration, full data migration, or full-data initialization.
	DataInitialization bool `pulumi:"dataInitialization"`
	// Whether to perform incremental data migration for migration types or synchronization values include:
	DataSynchronization bool `pulumi:"dataSynchronization"`
	// The Migration object, in the format of JSON strings.
	DbList string `pulumi:"dbList"`
	// The name of migrate the database.
	DestinationEndpointDataBaseName string `pulumi:"destinationEndpointDataBaseName"`
	// The type of destination database.
	DestinationEndpointEngineName string `pulumi:"destinationEndpointEngineName"`
	// The ID of destination instance.
	DestinationEndpointInstanceId string `pulumi:"destinationEndpointInstanceId"`
	// The type of destination instance.
	DestinationEndpointInstanceType string `pulumi:"destinationEndpointInstanceType"`
	// The ip of source endpoint.
	DestinationEndpointIp string `pulumi:"destinationEndpointIp"`
	// The SID of Oracle database.
	DestinationEndpointOracleSid string `pulumi:"destinationEndpointOracleSid"`
	// The port of source endpoint.
	DestinationEndpointPort string `pulumi:"destinationEndpointPort"`
	// The region of destination instance.
	DestinationEndpointRegion string `pulumi:"destinationEndpointRegion"`
	// The username of database account.
	DestinationEndpointUserName string `pulumi:"destinationEndpointUserName"`
	// The Migration instance ID. The ID of `dts.MigrationInstance`.
	DtsInstanceId string `pulumi:"dtsInstanceId"`
	// The ID of the Migration Job.
	DtsJobId string `pulumi:"dtsJobId"`
	// The name of synchronization job.
	DtsJobName string `pulumi:"dtsJobName"`
	// The ID of the Migration Job. Its value is same as `dtsJobId`.
	Id string `pulumi:"id"`
	// The payment type of the Migration Instance.
	PaymentType string `pulumi:"paymentType"`
	// The name of migrate the database.
	SourceEndpointDatabaseName string `pulumi:"sourceEndpointDatabaseName"`
	// The type of source database.
	SourceEndpointEngineName string `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance.
	SourceEndpointInstanceId string `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance.
	SourceEndpointInstanceType string `pulumi:"sourceEndpointInstanceType"`
	// The ip of source endpoint.
	SourceEndpointIp string `pulumi:"sourceEndpointIp"`
	// The SID of Oracle database.
	SourceEndpointOracleSid string `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs.
	SourceEndpointOwnerId string `pulumi:"sourceEndpointOwnerId"`
	// The port of source endpoint.
	SourceEndpointPort string `pulumi:"sourceEndpointPort"`
	// The region of source instance.
	SourceEndpointRegion string `pulumi:"sourceEndpointRegion"`
	// The name of the role configured for the cloud account to which the source instance belongs.
	SourceEndpointRole string `pulumi:"sourceEndpointRole"`
	// The username of database account.
	SourceEndpointUserName string `pulumi:"sourceEndpointUserName"`
	// The status of the resource.
	Status string `pulumi:"status"`
	// Whether to perform a database table structure to migrate or initialization.
	StructureInitialization bool `pulumi:"structureInitialization"`
}

type GetMigrationJobsJobArgs 

type GetMigrationJobsJobArgs struct {
	// Whether or not to execute DTS supports schema migration, full data migration, or full-data initialization.
	DataInitialization pulumi.BoolInput `pulumi:"dataInitialization"`
	// Whether to perform incremental data migration for migration types or synchronization values include:
	DataSynchronization pulumi.BoolInput `pulumi:"dataSynchronization"`
	// The Migration object, in the format of JSON strings.
	DbList pulumi.StringInput `pulumi:"dbList"`
	// The name of migrate the database.
	DestinationEndpointDataBaseName pulumi.StringInput `pulumi:"destinationEndpointDataBaseName"`
	// The type of destination database.
	DestinationEndpointEngineName pulumi.StringInput `pulumi:"destinationEndpointEngineName"`
	// The ID of destination instance.
	DestinationEndpointInstanceId pulumi.StringInput `pulumi:"destinationEndpointInstanceId"`
	// The type of destination instance.
	DestinationEndpointInstanceType pulumi.StringInput `pulumi:"destinationEndpointInstanceType"`
	// The ip of source endpoint.
	DestinationEndpointIp pulumi.StringInput `pulumi:"destinationEndpointIp"`
	// The SID of Oracle database.
	DestinationEndpointOracleSid pulumi.StringInput `pulumi:"destinationEndpointOracleSid"`
	// The port of source endpoint.
	DestinationEndpointPort pulumi.StringInput `pulumi:"destinationEndpointPort"`
	// The region of destination instance.
	DestinationEndpointRegion pulumi.StringInput `pulumi:"destinationEndpointRegion"`
	// The username of database account.
	DestinationEndpointUserName pulumi.StringInput `pulumi:"destinationEndpointUserName"`
	// The Migration instance ID. The ID of `dts.MigrationInstance`.
	DtsInstanceId pulumi.StringInput `pulumi:"dtsInstanceId"`
	// The ID of the Migration Job.
	DtsJobId pulumi.StringInput `pulumi:"dtsJobId"`
	// The name of synchronization job.
	DtsJobName pulumi.StringInput `pulumi:"dtsJobName"`
	// The ID of the Migration Job. Its value is same as `dtsJobId`.
	Id pulumi.StringInput `pulumi:"id"`
	// The payment type of the Migration Instance.
	PaymentType pulumi.StringInput `pulumi:"paymentType"`
	// The name of migrate the database.
	SourceEndpointDatabaseName pulumi.StringInput `pulumi:"sourceEndpointDatabaseName"`
	// The type of source database.
	SourceEndpointEngineName pulumi.StringInput `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance.
	SourceEndpointInstanceId pulumi.StringInput `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance.
	SourceEndpointInstanceType pulumi.StringInput `pulumi:"sourceEndpointInstanceType"`
	// The ip of source endpoint.
	SourceEndpointIp pulumi.StringInput `pulumi:"sourceEndpointIp"`
	// The SID of Oracle database.
	SourceEndpointOracleSid pulumi.StringInput `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs.
	SourceEndpointOwnerId pulumi.StringInput `pulumi:"sourceEndpointOwnerId"`
	// The port of source endpoint.
	SourceEndpointPort pulumi.StringInput `pulumi:"sourceEndpointPort"`
	// The region of source instance.
	SourceEndpointRegion pulumi.StringInput `pulumi:"sourceEndpointRegion"`
	// The name of the role configured for the cloud account to which the source instance belongs.
	SourceEndpointRole pulumi.StringInput `pulumi:"sourceEndpointRole"`
	// The username of database account.
	SourceEndpointUserName pulumi.StringInput `pulumi:"sourceEndpointUserName"`
	// The status of the resource.
	Status pulumi.StringInput `pulumi:"status"`
	// Whether to perform a database table structure to migrate or initialization.
	StructureInitialization pulumi.BoolInput `pulumi:"structureInitialization"`
}

func (GetMigrationJobsJobArgs) ElementType 

func (GetMigrationJobsJobArgs) ElementType() reflect.Type

func (GetMigrationJobsJobArgs) ToGetMigrationJobsJobOutput 

func (i GetMigrationJobsJobArgs) ToGetMigrationJobsJobOutput() GetMigrationJobsJobOutput

func (GetMigrationJobsJobArgs) ToGetMigrationJobsJobOutputWithContext 

func (i GetMigrationJobsJobArgs) ToGetMigrationJobsJobOutputWithContext(ctx context.Context) GetMigrationJobsJobOutput

type GetMigrationJobsJobArray 

type GetMigrationJobsJobArray []GetMigrationJobsJobInput

func (GetMigrationJobsJobArray) ElementType 

func (GetMigrationJobsJobArray) ElementType() reflect.Type

func (GetMigrationJobsJobArray) ToGetMigrationJobsJobArrayOutput 

func (i GetMigrationJobsJobArray) ToGetMigrationJobsJobArrayOutput() GetMigrationJobsJobArrayOutput

func (GetMigrationJobsJobArray) ToGetMigrationJobsJobArrayOutputWithContext 

func (i GetMigrationJobsJobArray) ToGetMigrationJobsJobArrayOutputWithContext(ctx context.Context) GetMigrationJobsJobArrayOutput

type GetMigrationJobsJobArrayInput 

type GetMigrationJobsJobArrayInput interface {
	pulumi.Input

	ToGetMigrationJobsJobArrayOutput() GetMigrationJobsJobArrayOutput
	ToGetMigrationJobsJobArrayOutputWithContext(context.Context) GetMigrationJobsJobArrayOutput
}

GetMigrationJobsJobArrayInput is an input type that accepts GetMigrationJobsJobArray and GetMigrationJobsJobArrayOutput values. You can construct a concrete instance of `GetMigrationJobsJobArrayInput` via: 

GetMigrationJobsJobArray{ GetMigrationJobsJobArgs{...} }

type GetMigrationJobsJobArrayOutput 

type GetMigrationJobsJobArrayOutput struct{ *pulumi.OutputState }

func (GetMigrationJobsJobArrayOutput) ElementType 

func (GetMigrationJobsJobArrayOutput) ElementType() reflect.Type

func (GetMigrationJobsJobArrayOutput) Index 

func (o GetMigrationJobsJobArrayOutput) Index(i pulumi.IntInput) GetMigrationJobsJobOutput

func (GetMigrationJobsJobArrayOutput) ToGetMigrationJobsJobArrayOutput 

func (o GetMigrationJobsJobArrayOutput) ToGetMigrationJobsJobArrayOutput() GetMigrationJobsJobArrayOutput

func (GetMigrationJobsJobArrayOutput) ToGetMigrationJobsJobArrayOutputWithContext 

func (o GetMigrationJobsJobArrayOutput) ToGetMigrationJobsJobArrayOutputWithContext(ctx context.Context) GetMigrationJobsJobArrayOutput

type GetMigrationJobsJobInput 

type GetMigrationJobsJobInput interface {
	pulumi.Input

	ToGetMigrationJobsJobOutput() GetMigrationJobsJobOutput
	ToGetMigrationJobsJobOutputWithContext(context.Context) GetMigrationJobsJobOutput
}

GetMigrationJobsJobInput is an input type that accepts GetMigrationJobsJobArgs and GetMigrationJobsJobOutput values. You can construct a concrete instance of `GetMigrationJobsJobInput` via: 

GetMigrationJobsJobArgs{...}

type GetMigrationJobsJobOutput 

type GetMigrationJobsJobOutput struct{ *pulumi.OutputState }

func (GetMigrationJobsJobOutput) DataInitialization 

func (o GetMigrationJobsJobOutput) DataInitialization() pulumi.BoolOutput

Whether or not to execute DTS supports schema migration, full data migration, or full-data initialization.

func (GetMigrationJobsJobOutput) DataSynchronization 

func (o GetMigrationJobsJobOutput) DataSynchronization() pulumi.BoolOutput

Whether to perform incremental data migration for migration types or synchronization values include:

func (GetMigrationJobsJobOutput) DbList 

func (o GetMigrationJobsJobOutput) DbList() pulumi.StringOutput

The Migration object, in the format of JSON strings.

func (GetMigrationJobsJobOutput) DestinationEndpointDataBaseName 

func (o GetMigrationJobsJobOutput) DestinationEndpointDataBaseName() pulumi.StringOutput

The name of migrate the database.

func (GetMigrationJobsJobOutput) DestinationEndpointEngineName 

func (o GetMigrationJobsJobOutput) DestinationEndpointEngineName() pulumi.StringOutput

The type of destination database.

func (GetMigrationJobsJobOutput) DestinationEndpointInstanceId 

func (o GetMigrationJobsJobOutput) DestinationEndpointInstanceId() pulumi.StringOutput

The ID of destination instance.

func (GetMigrationJobsJobOutput) DestinationEndpointInstanceType 

func (o GetMigrationJobsJobOutput) DestinationEndpointInstanceType() pulumi.StringOutput

The type of destination instance.

func (GetMigrationJobsJobOutput) DestinationEndpointIp 

func (o GetMigrationJobsJobOutput) DestinationEndpointIp() pulumi.StringOutput

The ip of source endpoint.

func (GetMigrationJobsJobOutput) DestinationEndpointOracleSid 

func (o GetMigrationJobsJobOutput) DestinationEndpointOracleSid() pulumi.StringOutput

The SID of Oracle database.

func (GetMigrationJobsJobOutput) DestinationEndpointPort 

func (o GetMigrationJobsJobOutput) DestinationEndpointPort() pulumi.StringOutput

The port of source endpoint.

func (GetMigrationJobsJobOutput) DestinationEndpointRegion 

func (o GetMigrationJobsJobOutput) DestinationEndpointRegion() pulumi.StringOutput

The region of destination instance.

func (GetMigrationJobsJobOutput) DestinationEndpointUserName 

func (o GetMigrationJobsJobOutput) DestinationEndpointUserName() pulumi.StringOutput

The username of database account.

func (GetMigrationJobsJobOutput) DtsInstanceId 

func (o GetMigrationJobsJobOutput) DtsInstanceId() pulumi.StringOutput

The Migration instance ID. The ID of `dts.MigrationInstance`.

func (GetMigrationJobsJobOutput) DtsJobId 

func (o GetMigrationJobsJobOutput) DtsJobId() pulumi.StringOutput

The ID of the Migration Job.

func (GetMigrationJobsJobOutput) DtsJobName 

func (o GetMigrationJobsJobOutput) DtsJobName() pulumi.StringOutput

The name of synchronization job.

func (GetMigrationJobsJobOutput) ElementType 

func (GetMigrationJobsJobOutput) ElementType() reflect.Type

func (GetMigrationJobsJobOutput) Id 

func (o GetMigrationJobsJobOutput) Id() pulumi.StringOutput

The ID of the Migration Job. Its value is same as `dtsJobId`.

func (GetMigrationJobsJobOutput) PaymentType 

func (o GetMigrationJobsJobOutput) PaymentType() pulumi.StringOutput

The payment type of the Migration Instance.

func (GetMigrationJobsJobOutput) SourceEndpointDatabaseName 

func (o GetMigrationJobsJobOutput) SourceEndpointDatabaseName() pulumi.StringOutput

The name of migrate the database.

func (GetMigrationJobsJobOutput) SourceEndpointEngineName 

func (o GetMigrationJobsJobOutput) SourceEndpointEngineName() pulumi.StringOutput

The type of source database.

func (GetMigrationJobsJobOutput) SourceEndpointInstanceId 

func (o GetMigrationJobsJobOutput) SourceEndpointInstanceId() pulumi.StringOutput

The ID of source instance.

func (GetMigrationJobsJobOutput) SourceEndpointInstanceType 

func (o GetMigrationJobsJobOutput) SourceEndpointInstanceType() pulumi.StringOutput

The type of source instance.

func (GetMigrationJobsJobOutput) SourceEndpointIp 

func (o GetMigrationJobsJobOutput) SourceEndpointIp() pulumi.StringOutput

The ip of source endpoint.

func (GetMigrationJobsJobOutput) SourceEndpointOracleSid 

func (o GetMigrationJobsJobOutput) SourceEndpointOracleSid() pulumi.StringOutput

The SID of Oracle database.

func (GetMigrationJobsJobOutput) SourceEndpointOwnerId 

func (o GetMigrationJobsJobOutput) SourceEndpointOwnerId() pulumi.StringOutput

The Alibaba Cloud account ID to which the source instance belongs.

func (GetMigrationJobsJobOutput) SourceEndpointPort 

func (o GetMigrationJobsJobOutput) SourceEndpointPort() pulumi.StringOutput

The port of source endpoint.

func (GetMigrationJobsJobOutput) SourceEndpointRegion 

func (o GetMigrationJobsJobOutput) SourceEndpointRegion() pulumi.StringOutput

The region of source instance.

func (GetMigrationJobsJobOutput) SourceEndpointRole 

func (o GetMigrationJobsJobOutput) SourceEndpointRole() pulumi.StringOutput

The name of the role configured for the cloud account to which the source instance belongs.

func (GetMigrationJobsJobOutput) SourceEndpointUserName 

func (o GetMigrationJobsJobOutput) SourceEndpointUserName() pulumi.StringOutput

The username of database account.

func (GetMigrationJobsJobOutput) Status 

func (o GetMigrationJobsJobOutput) Status() pulumi.StringOutput

The status of the resource.

func (GetMigrationJobsJobOutput) StructureInitialization 

func (o GetMigrationJobsJobOutput) StructureInitialization() pulumi.BoolOutput

Whether to perform a database table structure to migrate or initialization.

func (GetMigrationJobsJobOutput) ToGetMigrationJobsJobOutput 

func (o GetMigrationJobsJobOutput) ToGetMigrationJobsJobOutput() GetMigrationJobsJobOutput

func (GetMigrationJobsJobOutput) ToGetMigrationJobsJobOutputWithContext 

func (o GetMigrationJobsJobOutput) ToGetMigrationJobsJobOutputWithContext(ctx context.Context) GetMigrationJobsJobOutput

type GetMigrationJobsOutputArgs 

type GetMigrationJobsOutputArgs struct {
	// Default to `false`. Set it to `true` can output more details about resource attributes.
	EnableDetails pulumi.BoolPtrInput `pulumi:"enableDetails"`
	// A list of Synchronization Job IDs.
	Ids pulumi.StringArrayInput `pulumi:"ids"`
	// A regex string to filter results by Migration Job name.
	NameRegex  pulumi.StringPtrInput `pulumi:"nameRegex"`
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
}

A collection of arguments for invoking getMigrationJobs.

func (GetMigrationJobsOutputArgs) ElementType 

func (GetMigrationJobsOutputArgs) ElementType() reflect.Type

type GetMigrationJobsResult 

type GetMigrationJobsResult struct {
	EnableDetails *bool `pulumi:"enableDetails"`
	// The provider-assigned unique ID for this managed resource.
	Id         string                `pulumi:"id"`
	Ids        []string              `pulumi:"ids"`
	Jobs       []GetMigrationJobsJob `pulumi:"jobs"`
	NameRegex  *string               `pulumi:"nameRegex"`
	Names      []string              `pulumi:"names"`
	OutputFile *string               `pulumi:"outputFile"`
}

A collection of values returned by getMigrationJobs.

func GetMigrationJobs 

func GetMigrationJobs(ctx *pulumi.Context, args *GetMigrationJobsArgs, opts ...pulumi.InvokeOption) (*GetMigrationJobsResult, error)

This data source provides the Dts Migration Jobs of the current Alibaba Cloud user.

> **NOTE:** Available in v1.157.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ids, err := dts.GetMigrationJobs(ctx, &dts.GetMigrationJobsArgs{
			Ids: []string{
				"dts_job_id",
			},
		}, nil)
		if err != nil {
			return err
		}
		ctx.Export("dtsMigrationJobId1", ids.Jobs[0].Id)
		return nil
	})
}

```

type GetMigrationJobsResultOutput 

type GetMigrationJobsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getMigrationJobs.

func GetMigrationJobsOutput 

func GetMigrationJobsOutput(ctx *pulumi.Context, args GetMigrationJobsOutputArgs, opts ...pulumi.InvokeOption) GetMigrationJobsResultOutput

func (GetMigrationJobsResultOutput) ElementType 

func (GetMigrationJobsResultOutput) ElementType() reflect.Type

func (GetMigrationJobsResultOutput) EnableDetails 

func (o GetMigrationJobsResultOutput) EnableDetails() pulumi.BoolPtrOutput

func (GetMigrationJobsResultOutput) Id 

func (o GetMigrationJobsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetMigrationJobsResultOutput) Ids 

func (o GetMigrationJobsResultOutput) Ids() pulumi.StringArrayOutput

func (GetMigrationJobsResultOutput) Jobs 

func (o GetMigrationJobsResultOutput) Jobs() GetMigrationJobsJobArrayOutput

func (GetMigrationJobsResultOutput) NameRegex 

func (o GetMigrationJobsResultOutput) NameRegex() pulumi.StringPtrOutput

func (GetMigrationJobsResultOutput) Names 

func (o GetMigrationJobsResultOutput) Names() pulumi.StringArrayOutput

func (GetMigrationJobsResultOutput) OutputFile 

func (o GetMigrationJobsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetMigrationJobsResultOutput) ToGetMigrationJobsResultOutput 

func (o GetMigrationJobsResultOutput) ToGetMigrationJobsResultOutput() GetMigrationJobsResultOutput

func (GetMigrationJobsResultOutput) ToGetMigrationJobsResultOutputWithContext 

func (o GetMigrationJobsResultOutput) ToGetMigrationJobsResultOutputWithContext(ctx context.Context) GetMigrationJobsResultOutput

type GetSubscriptionJobsArgs 

type GetSubscriptionJobsArgs struct {
	EnableDetails *bool `pulumi:"enableDetails"`
	// A list of Subscription Job IDs.
	Ids []string `pulumi:"ids"`
	// A regex string to filter results by subscription job name.
	NameRegex  *string `pulumi:"nameRegex"`
	OutputFile *string `pulumi:"outputFile"`
	// The status of the task. Valid values: `NotStarted`, `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state of `Normal` to start the job, and specify this state of `Abnormal` to stop the job.
	Status *string `pulumi:"status"`
	// The tag of the resource.
	Tags map[string]interface{} `pulumi:"tags"`
}

A collection of arguments for invoking getSubscriptionJobs.

type GetSubscriptionJobsJob 

type GetSubscriptionJobsJob struct {
	// Subscription start time in Unix timestamp format.
	Checkpoint string `pulumi:"checkpoint"`
	// The creation time of subscription job instance.
	CreateTime string `pulumi:"createTime"`
	// Subscription object, in the format of JSON strings.
	DbList string `pulumi:"dbList"`
	// The ID of subscription job instance.
	DtsInstanceId string `pulumi:"dtsInstanceId"`
	// The ID of subscription job instance.
	DtsJobId string `pulumi:"dtsJobId"`
	// The name of subscription job instance.
	DtsJobName string `pulumi:"dtsJobName"`
	// The Expiration Time. Formatting with yyyy-MM-ddTHH:mm:ssZ(UTC time).
	ExpireTime string `pulumi:"expireTime"`
	// The ID of the Subscription Job.
	Id string `pulumi:"id"`
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType string `pulumi:"paymentType"`
	// To subscribe to the name of the database.
	SourceEndpointDatabaseName string `pulumi:"sourceEndpointDatabaseName"`
	// The source database type value is MySQL or Oracle.
	SourceEndpointEngineName string `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance. Only when the type of source database instance was RDS MySQL, PolarDB-X 1.0, PolarDB MySQL, this parameter can be available and must be set.
	SourceEndpointInstanceId string `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance. Valid values: `RDS`, `PolarDB`, `DRDS`, `LocalInstance`, `ECS`, `Express`, `CEN`, `dg`.
	SourceEndpointInstanceType string `pulumi:"sourceEndpointInstanceType"`
	// The IP of source endpoint.
	SourceEndpointIp string `pulumi:"sourceEndpointIp"`
	// The SID of Oracle Database. When the source database is self-built Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid string `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs. This parameter is only available when configuring data subscriptions across Alibaba Cloud accounts and must be passed in.
	SourceEndpointOwnerId string `pulumi:"sourceEndpointOwnerId"`
	// The  port of source database.
	SourceEndpointPort string `pulumi:"sourceEndpointPort"`
	// The region of source database.
	SourceEndpointRegion string `pulumi:"sourceEndpointRegion"`
	// Both the authorization roles. When the source instance and configure subscriptions task of the Alibaba Cloud account is not the same as the need to pass the parameter, to specify the source of the authorization roles, to allow configuration subscription task of the Alibaba Cloud account to access the source of the source instance information.
	SourceEndpointRole string `pulumi:"sourceEndpointRole"`
	// The username of source database instance account.
	SourceEndpointUserName string `pulumi:"sourceEndpointUserName"`
	// The status of the task. Valid values: `NotStarted`, `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state of `Normal` to start the job, and specify this state of `Abnormal` to stop the job.
	Status string `pulumi:"status"`
	// Whether to subscribe the DDL type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDdl bool `pulumi:"subscriptionDataTypeDdl"`
	// Whether to subscribe the DML type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDml bool `pulumi:"subscriptionDataTypeDml"`
	// Network information.
	SubscriptionHosts []GetSubscriptionJobsJobSubscriptionHost `pulumi:"subscriptionHosts"`
	// The type of subscription instance network. Valid value: `classic`, `vpc`.
	SubscriptionInstanceNetworkType string `pulumi:"subscriptionInstanceNetworkType"`
	// The ID of subscription instance vpc.
	SubscriptionInstanceVpcId string `pulumi:"subscriptionInstanceVpcId"`
	// The ID of subscription instance vswitch.
	SubscriptionInstanceVswitchId string `pulumi:"subscriptionInstanceVswitchId"`
	// The tag of the resource.
	Tags map[string]interface{} `pulumi:"tags"`
}

type GetSubscriptionJobsJobArgs 

type GetSubscriptionJobsJobArgs struct {
	// Subscription start time in Unix timestamp format.
	Checkpoint pulumi.StringInput `pulumi:"checkpoint"`
	// The creation time of subscription job instance.
	CreateTime pulumi.StringInput `pulumi:"createTime"`
	// Subscription object, in the format of JSON strings.
	DbList pulumi.StringInput `pulumi:"dbList"`
	// The ID of subscription job instance.
	DtsInstanceId pulumi.StringInput `pulumi:"dtsInstanceId"`
	// The ID of subscription job instance.
	DtsJobId pulumi.StringInput `pulumi:"dtsJobId"`
	// The name of subscription job instance.
	DtsJobName pulumi.StringInput `pulumi:"dtsJobName"`
	// The Expiration Time. Formatting with yyyy-MM-ddTHH:mm:ssZ(UTC time).
	ExpireTime pulumi.StringInput `pulumi:"expireTime"`
	// The ID of the Subscription Job.
	Id pulumi.StringInput `pulumi:"id"`
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType pulumi.StringInput `pulumi:"paymentType"`
	// To subscribe to the name of the database.
	SourceEndpointDatabaseName pulumi.StringInput `pulumi:"sourceEndpointDatabaseName"`
	// The source database type value is MySQL or Oracle.
	SourceEndpointEngineName pulumi.StringInput `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance. Only when the type of source database instance was RDS MySQL, PolarDB-X 1.0, PolarDB MySQL, this parameter can be available and must be set.
	SourceEndpointInstanceId pulumi.StringInput `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance. Valid values: `RDS`, `PolarDB`, `DRDS`, `LocalInstance`, `ECS`, `Express`, `CEN`, `dg`.
	SourceEndpointInstanceType pulumi.StringInput `pulumi:"sourceEndpointInstanceType"`
	// The IP of source endpoint.
	SourceEndpointIp pulumi.StringInput `pulumi:"sourceEndpointIp"`
	// The SID of Oracle Database. When the source database is self-built Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid pulumi.StringInput `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs. This parameter is only available when configuring data subscriptions across Alibaba Cloud accounts and must be passed in.
	SourceEndpointOwnerId pulumi.StringInput `pulumi:"sourceEndpointOwnerId"`
	// The  port of source database.
	SourceEndpointPort pulumi.StringInput `pulumi:"sourceEndpointPort"`
	// The region of source database.
	SourceEndpointRegion pulumi.StringInput `pulumi:"sourceEndpointRegion"`
	// Both the authorization roles. When the source instance and configure subscriptions task of the Alibaba Cloud account is not the same as the need to pass the parameter, to specify the source of the authorization roles, to allow configuration subscription task of the Alibaba Cloud account to access the source of the source instance information.
	SourceEndpointRole pulumi.StringInput `pulumi:"sourceEndpointRole"`
	// The username of source database instance account.
	SourceEndpointUserName pulumi.StringInput `pulumi:"sourceEndpointUserName"`
	// The status of the task. Valid values: `NotStarted`, `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state of `Normal` to start the job, and specify this state of `Abnormal` to stop the job.
	Status pulumi.StringInput `pulumi:"status"`
	// Whether to subscribe the DDL type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDdl pulumi.BoolInput `pulumi:"subscriptionDataTypeDdl"`
	// Whether to subscribe the DML type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDml pulumi.BoolInput `pulumi:"subscriptionDataTypeDml"`
	// Network information.
	SubscriptionHosts GetSubscriptionJobsJobSubscriptionHostArrayInput `pulumi:"subscriptionHosts"`
	// The type of subscription instance network. Valid value: `classic`, `vpc`.
	SubscriptionInstanceNetworkType pulumi.StringInput `pulumi:"subscriptionInstanceNetworkType"`
	// The ID of subscription instance vpc.
	SubscriptionInstanceVpcId pulumi.StringInput `pulumi:"subscriptionInstanceVpcId"`
	// The ID of subscription instance vswitch.
	SubscriptionInstanceVswitchId pulumi.StringInput `pulumi:"subscriptionInstanceVswitchId"`
	// The tag of the resource.
	Tags pulumi.MapInput `pulumi:"tags"`
}

func (GetSubscriptionJobsJobArgs) ElementType 

func (GetSubscriptionJobsJobArgs) ElementType() reflect.Type

func (GetSubscriptionJobsJobArgs) ToGetSubscriptionJobsJobOutput 

func (i GetSubscriptionJobsJobArgs) ToGetSubscriptionJobsJobOutput() GetSubscriptionJobsJobOutput

func (GetSubscriptionJobsJobArgs) ToGetSubscriptionJobsJobOutputWithContext 

func (i GetSubscriptionJobsJobArgs) ToGetSubscriptionJobsJobOutputWithContext(ctx context.Context) GetSubscriptionJobsJobOutput

type GetSubscriptionJobsJobArray 

type GetSubscriptionJobsJobArray []GetSubscriptionJobsJobInput

func (GetSubscriptionJobsJobArray) ElementType 

func (GetSubscriptionJobsJobArray) ElementType() reflect.Type

func (GetSubscriptionJobsJobArray) ToGetSubscriptionJobsJobArrayOutput 

func (i GetSubscriptionJobsJobArray) ToGetSubscriptionJobsJobArrayOutput() GetSubscriptionJobsJobArrayOutput

func (GetSubscriptionJobsJobArray) ToGetSubscriptionJobsJobArrayOutputWithContext 

func (i GetSubscriptionJobsJobArray) ToGetSubscriptionJobsJobArrayOutputWithContext(ctx context.Context) GetSubscriptionJobsJobArrayOutput

type GetSubscriptionJobsJobArrayInput 

type GetSubscriptionJobsJobArrayInput interface {
	pulumi.Input

	ToGetSubscriptionJobsJobArrayOutput() GetSubscriptionJobsJobArrayOutput
	ToGetSubscriptionJobsJobArrayOutputWithContext(context.Context) GetSubscriptionJobsJobArrayOutput
}

GetSubscriptionJobsJobArrayInput is an input type that accepts GetSubscriptionJobsJobArray and GetSubscriptionJobsJobArrayOutput values. You can construct a concrete instance of `GetSubscriptionJobsJobArrayInput` via: 

GetSubscriptionJobsJobArray{ GetSubscriptionJobsJobArgs{...} }

type GetSubscriptionJobsJobArrayOutput 

type GetSubscriptionJobsJobArrayOutput struct{ *pulumi.OutputState }

func (GetSubscriptionJobsJobArrayOutput) ElementType 

func (GetSubscriptionJobsJobArrayOutput) ElementType() reflect.Type

func (GetSubscriptionJobsJobArrayOutput) Index 

func (o GetSubscriptionJobsJobArrayOutput) Index(i pulumi.IntInput) GetSubscriptionJobsJobOutput

func (GetSubscriptionJobsJobArrayOutput) ToGetSubscriptionJobsJobArrayOutput 

func (o GetSubscriptionJobsJobArrayOutput) ToGetSubscriptionJobsJobArrayOutput() GetSubscriptionJobsJobArrayOutput

func (GetSubscriptionJobsJobArrayOutput) ToGetSubscriptionJobsJobArrayOutputWithContext 

func (o GetSubscriptionJobsJobArrayOutput) ToGetSubscriptionJobsJobArrayOutputWithContext(ctx context.Context) GetSubscriptionJobsJobArrayOutput

type GetSubscriptionJobsJobInput 

type GetSubscriptionJobsJobInput interface {
	pulumi.Input

	ToGetSubscriptionJobsJobOutput() GetSubscriptionJobsJobOutput
	ToGetSubscriptionJobsJobOutputWithContext(context.Context) GetSubscriptionJobsJobOutput
}

GetSubscriptionJobsJobInput is an input type that accepts GetSubscriptionJobsJobArgs and GetSubscriptionJobsJobOutput values. You can construct a concrete instance of `GetSubscriptionJobsJobInput` via: 

GetSubscriptionJobsJobArgs{...}

type GetSubscriptionJobsJobOutput 

type GetSubscriptionJobsJobOutput struct{ *pulumi.OutputState }

func (GetSubscriptionJobsJobOutput) Checkpoint 

func (o GetSubscriptionJobsJobOutput) Checkpoint() pulumi.StringOutput

Subscription start time in Unix timestamp format.

func (GetSubscriptionJobsJobOutput) CreateTime 

func (o GetSubscriptionJobsJobOutput) CreateTime() pulumi.StringOutput

The creation time of subscription job instance.

func (GetSubscriptionJobsJobOutput) DbList 

func (o GetSubscriptionJobsJobOutput) DbList() pulumi.StringOutput

Subscription object, in the format of JSON strings.

func (GetSubscriptionJobsJobOutput) DtsInstanceId 

func (o GetSubscriptionJobsJobOutput) DtsInstanceId() pulumi.StringOutput

The ID of subscription job instance.

func (GetSubscriptionJobsJobOutput) DtsJobId 

func (o GetSubscriptionJobsJobOutput) DtsJobId() pulumi.StringOutput

The ID of subscription job instance.

func (GetSubscriptionJobsJobOutput) DtsJobName 

func (o GetSubscriptionJobsJobOutput) DtsJobName() pulumi.StringOutput

The name of subscription job instance.

func (GetSubscriptionJobsJobOutput) ElementType 

func (GetSubscriptionJobsJobOutput) ElementType() reflect.Type

func (GetSubscriptionJobsJobOutput) ExpireTime 

func (o GetSubscriptionJobsJobOutput) ExpireTime() pulumi.StringOutput

The Expiration Time. Formatting with yyyy-MM-ddTHH:mm:ssZ(UTC time).

func (GetSubscriptionJobsJobOutput) Id 

func (o GetSubscriptionJobsJobOutput) Id() pulumi.StringOutput

The ID of the Subscription Job.

func (GetSubscriptionJobsJobOutput) PaymentType 

func (o GetSubscriptionJobsJobOutput) PaymentType() pulumi.StringOutput

The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.

func (GetSubscriptionJobsJobOutput) SourceEndpointDatabaseName 

func (o GetSubscriptionJobsJobOutput) SourceEndpointDatabaseName() pulumi.StringOutput

To subscribe to the name of the database.

func (GetSubscriptionJobsJobOutput) SourceEndpointEngineName 

func (o GetSubscriptionJobsJobOutput) SourceEndpointEngineName() pulumi.StringOutput

The source database type value is MySQL or Oracle.

func (GetSubscriptionJobsJobOutput) SourceEndpointInstanceId 

func (o GetSubscriptionJobsJobOutput) SourceEndpointInstanceId() pulumi.StringOutput

The ID of source instance. Only when the type of source database instance was RDS MySQL, PolarDB-X 1.0, PolarDB MySQL, this parameter can be available and must be set.

func (GetSubscriptionJobsJobOutput) SourceEndpointInstanceType 

func (o GetSubscriptionJobsJobOutput) SourceEndpointInstanceType() pulumi.StringOutput

The type of source instance. Valid values: `RDS`, `PolarDB`, `DRDS`, `LocalInstance`, `ECS`, `Express`, `CEN`, `dg`.

func (GetSubscriptionJobsJobOutput) SourceEndpointIp 

func (o GetSubscriptionJobsJobOutput) SourceEndpointIp() pulumi.StringOutput

The IP of source endpoint.

func (GetSubscriptionJobsJobOutput) SourceEndpointOracleSid 

func (o GetSubscriptionJobsJobOutput) SourceEndpointOracleSid() pulumi.StringOutput

The SID of Oracle Database. When the source database is self-built Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.

func (GetSubscriptionJobsJobOutput) SourceEndpointOwnerId 

func (o GetSubscriptionJobsJobOutput) SourceEndpointOwnerId() pulumi.StringOutput

The Alibaba Cloud account ID to which the source instance belongs. This parameter is only available when configuring data subscriptions across Alibaba Cloud accounts and must be passed in.

func (GetSubscriptionJobsJobOutput) SourceEndpointPort 

func (o GetSubscriptionJobsJobOutput) SourceEndpointPort() pulumi.StringOutput

The port of source database.

func (GetSubscriptionJobsJobOutput) SourceEndpointRegion 

func (o GetSubscriptionJobsJobOutput) SourceEndpointRegion() pulumi.StringOutput

The region of source database.

func (GetSubscriptionJobsJobOutput) SourceEndpointRole 

func (o GetSubscriptionJobsJobOutput) SourceEndpointRole() pulumi.StringOutput

Both the authorization roles. When the source instance and configure subscriptions task of the Alibaba Cloud account is not the same as the need to pass the parameter, to specify the source of the authorization roles, to allow configuration subscription task of the Alibaba Cloud account to access the source of the source instance information.

func (GetSubscriptionJobsJobOutput) SourceEndpointUserName 

func (o GetSubscriptionJobsJobOutput) SourceEndpointUserName() pulumi.StringOutput

The username of source database instance account.

func (GetSubscriptionJobsJobOutput) Status 

func (o GetSubscriptionJobsJobOutput) Status() pulumi.StringOutput

The status of the task. Valid values: `NotStarted`, `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state of `Normal` to start the job, and specify this state of `Abnormal` to stop the job.

func (GetSubscriptionJobsJobOutput) SubscriptionDataTypeDdl 

func (o GetSubscriptionJobsJobOutput) SubscriptionDataTypeDdl() pulumi.BoolOutput

Whether to subscribe the DDL type of data. Valid values: `true`, `false`.

func (GetSubscriptionJobsJobOutput) SubscriptionDataTypeDml 

func (o GetSubscriptionJobsJobOutput) SubscriptionDataTypeDml() pulumi.BoolOutput

Whether to subscribe the DML type of data. Valid values: `true`, `false`.

func (GetSubscriptionJobsJobOutput) SubscriptionHosts 

func (o GetSubscriptionJobsJobOutput) SubscriptionHosts() GetSubscriptionJobsJobSubscriptionHostArrayOutput

Network information.

func (GetSubscriptionJobsJobOutput) SubscriptionInstanceNetworkType 

func (o GetSubscriptionJobsJobOutput) SubscriptionInstanceNetworkType() pulumi.StringOutput

The type of subscription instance network. Valid value: `classic`, `vpc`.

func (GetSubscriptionJobsJobOutput) SubscriptionInstanceVpcId 

func (o GetSubscriptionJobsJobOutput) SubscriptionInstanceVpcId() pulumi.StringOutput

The ID of subscription instance vpc.

func (GetSubscriptionJobsJobOutput) SubscriptionInstanceVswitchId 

func (o GetSubscriptionJobsJobOutput) SubscriptionInstanceVswitchId() pulumi.StringOutput

The ID of subscription instance vswitch.

func (GetSubscriptionJobsJobOutput) Tags 

func (o GetSubscriptionJobsJobOutput) Tags() pulumi.MapOutput

The tag of the resource.

func (GetSubscriptionJobsJobOutput) ToGetSubscriptionJobsJobOutput 

func (o GetSubscriptionJobsJobOutput) ToGetSubscriptionJobsJobOutput() GetSubscriptionJobsJobOutput

func (GetSubscriptionJobsJobOutput) ToGetSubscriptionJobsJobOutputWithContext 

func (o GetSubscriptionJobsJobOutput) ToGetSubscriptionJobsJobOutputWithContext(ctx context.Context) GetSubscriptionJobsJobOutput

type GetSubscriptionJobsJobSubscriptionHost 

type GetSubscriptionJobsJobSubscriptionHost struct {
	// Classic network address.
	PrivateHost string `pulumi:"privateHost"`
	// Public network address.
	PublicHost string `pulumi:"publicHost"`
	// VPC network address.
	VpcHost string `pulumi:"vpcHost"`
}

type GetSubscriptionJobsJobSubscriptionHostArgs 

type GetSubscriptionJobsJobSubscriptionHostArgs struct {
	// Classic network address.
	PrivateHost pulumi.StringInput `pulumi:"privateHost"`
	// Public network address.
	PublicHost pulumi.StringInput `pulumi:"publicHost"`
	// VPC network address.
	VpcHost pulumi.StringInput `pulumi:"vpcHost"`
}

func (GetSubscriptionJobsJobSubscriptionHostArgs) ElementType 

func (GetSubscriptionJobsJobSubscriptionHostArgs) ElementType() reflect.Type

func (GetSubscriptionJobsJobSubscriptionHostArgs) ToGetSubscriptionJobsJobSubscriptionHostOutput 

func (i GetSubscriptionJobsJobSubscriptionHostArgs) ToGetSubscriptionJobsJobSubscriptionHostOutput() GetSubscriptionJobsJobSubscriptionHostOutput

func (GetSubscriptionJobsJobSubscriptionHostArgs) ToGetSubscriptionJobsJobSubscriptionHostOutputWithContext 

func (i GetSubscriptionJobsJobSubscriptionHostArgs) ToGetSubscriptionJobsJobSubscriptionHostOutputWithContext(ctx context.Context) GetSubscriptionJobsJobSubscriptionHostOutput

type GetSubscriptionJobsJobSubscriptionHostArray 

type GetSubscriptionJobsJobSubscriptionHostArray []GetSubscriptionJobsJobSubscriptionHostInput

func (GetSubscriptionJobsJobSubscriptionHostArray) ElementType 

func (GetSubscriptionJobsJobSubscriptionHostArray) ElementType() reflect.Type

func (GetSubscriptionJobsJobSubscriptionHostArray) ToGetSubscriptionJobsJobSubscriptionHostArrayOutput 

func (i GetSubscriptionJobsJobSubscriptionHostArray) ToGetSubscriptionJobsJobSubscriptionHostArrayOutput() GetSubscriptionJobsJobSubscriptionHostArrayOutput

func (GetSubscriptionJobsJobSubscriptionHostArray) ToGetSubscriptionJobsJobSubscriptionHostArrayOutputWithContext 

func (i GetSubscriptionJobsJobSubscriptionHostArray) ToGetSubscriptionJobsJobSubscriptionHostArrayOutputWithContext(ctx context.Context) GetSubscriptionJobsJobSubscriptionHostArrayOutput

type GetSubscriptionJobsJobSubscriptionHostArrayInput 

type GetSubscriptionJobsJobSubscriptionHostArrayInput interface {
	pulumi.Input

	ToGetSubscriptionJobsJobSubscriptionHostArrayOutput() GetSubscriptionJobsJobSubscriptionHostArrayOutput
	ToGetSubscriptionJobsJobSubscriptionHostArrayOutputWithContext(context.Context) GetSubscriptionJobsJobSubscriptionHostArrayOutput
}

GetSubscriptionJobsJobSubscriptionHostArrayInput is an input type that accepts GetSubscriptionJobsJobSubscriptionHostArray and GetSubscriptionJobsJobSubscriptionHostArrayOutput values. You can construct a concrete instance of `GetSubscriptionJobsJobSubscriptionHostArrayInput` via: 

GetSubscriptionJobsJobSubscriptionHostArray{ GetSubscriptionJobsJobSubscriptionHostArgs{...} }

type GetSubscriptionJobsJobSubscriptionHostArrayOutput 

type GetSubscriptionJobsJobSubscriptionHostArrayOutput struct{ *pulumi.OutputState }

func (GetSubscriptionJobsJobSubscriptionHostArrayOutput) ElementType 

func (GetSubscriptionJobsJobSubscriptionHostArrayOutput) ElementType() reflect.Type

func (GetSubscriptionJobsJobSubscriptionHostArrayOutput) Index 

func (o GetSubscriptionJobsJobSubscriptionHostArrayOutput) Index(i pulumi.IntInput) GetSubscriptionJobsJobSubscriptionHostOutput

func (GetSubscriptionJobsJobSubscriptionHostArrayOutput) ToGetSubscriptionJobsJobSubscriptionHostArrayOutput 

func (o GetSubscriptionJobsJobSubscriptionHostArrayOutput) ToGetSubscriptionJobsJobSubscriptionHostArrayOutput() GetSubscriptionJobsJobSubscriptionHostArrayOutput

func (GetSubscriptionJobsJobSubscriptionHostArrayOutput) ToGetSubscriptionJobsJobSubscriptionHostArrayOutputWithContext 

func (o GetSubscriptionJobsJobSubscriptionHostArrayOutput) ToGetSubscriptionJobsJobSubscriptionHostArrayOutputWithContext(ctx context.Context) GetSubscriptionJobsJobSubscriptionHostArrayOutput

type GetSubscriptionJobsJobSubscriptionHostInput 

type GetSubscriptionJobsJobSubscriptionHostInput interface {
	pulumi.Input

	ToGetSubscriptionJobsJobSubscriptionHostOutput() GetSubscriptionJobsJobSubscriptionHostOutput
	ToGetSubscriptionJobsJobSubscriptionHostOutputWithContext(context.Context) GetSubscriptionJobsJobSubscriptionHostOutput
}

GetSubscriptionJobsJobSubscriptionHostInput is an input type that accepts GetSubscriptionJobsJobSubscriptionHostArgs and GetSubscriptionJobsJobSubscriptionHostOutput values. You can construct a concrete instance of `GetSubscriptionJobsJobSubscriptionHostInput` via: 

GetSubscriptionJobsJobSubscriptionHostArgs{...}

type GetSubscriptionJobsJobSubscriptionHostOutput 

type GetSubscriptionJobsJobSubscriptionHostOutput struct{ *pulumi.OutputState }

func (GetSubscriptionJobsJobSubscriptionHostOutput) ElementType 

func (GetSubscriptionJobsJobSubscriptionHostOutput) ElementType() reflect.Type

func (GetSubscriptionJobsJobSubscriptionHostOutput) PrivateHost 

func (o GetSubscriptionJobsJobSubscriptionHostOutput) PrivateHost() pulumi.StringOutput

Classic network address.

func (GetSubscriptionJobsJobSubscriptionHostOutput) PublicHost 

func (o GetSubscriptionJobsJobSubscriptionHostOutput) PublicHost() pulumi.StringOutput

Public network address.

func (GetSubscriptionJobsJobSubscriptionHostOutput) ToGetSubscriptionJobsJobSubscriptionHostOutput 

func (o GetSubscriptionJobsJobSubscriptionHostOutput) ToGetSubscriptionJobsJobSubscriptionHostOutput() GetSubscriptionJobsJobSubscriptionHostOutput

func (GetSubscriptionJobsJobSubscriptionHostOutput) ToGetSubscriptionJobsJobSubscriptionHostOutputWithContext 

func (o GetSubscriptionJobsJobSubscriptionHostOutput) ToGetSubscriptionJobsJobSubscriptionHostOutputWithContext(ctx context.Context) GetSubscriptionJobsJobSubscriptionHostOutput

func (GetSubscriptionJobsJobSubscriptionHostOutput) VpcHost 

func (o GetSubscriptionJobsJobSubscriptionHostOutput) VpcHost() pulumi.StringOutput

VPC network address.

type GetSubscriptionJobsOutputArgs 

type GetSubscriptionJobsOutputArgs struct {
	EnableDetails pulumi.BoolPtrInput `pulumi:"enableDetails"`
	// A list of Subscription Job IDs.
	Ids pulumi.StringArrayInput `pulumi:"ids"`
	// A regex string to filter results by subscription job name.
	NameRegex  pulumi.StringPtrInput `pulumi:"nameRegex"`
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
	// The status of the task. Valid values: `NotStarted`, `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state of `Normal` to start the job, and specify this state of `Abnormal` to stop the job.
	Status pulumi.StringPtrInput `pulumi:"status"`
	// The tag of the resource.
	Tags pulumi.MapInput `pulumi:"tags"`
}

A collection of arguments for invoking getSubscriptionJobs.

func (GetSubscriptionJobsOutputArgs) ElementType 

func (GetSubscriptionJobsOutputArgs) ElementType() reflect.Type

type GetSubscriptionJobsResult 

type GetSubscriptionJobsResult struct {
	EnableDetails *bool `pulumi:"enableDetails"`
	// The provider-assigned unique ID for this managed resource.
	Id         string                   `pulumi:"id"`
	Ids        []string                 `pulumi:"ids"`
	Jobs       []GetSubscriptionJobsJob `pulumi:"jobs"`
	NameRegex  *string                  `pulumi:"nameRegex"`
	Names      []string                 `pulumi:"names"`
	OutputFile *string                  `pulumi:"outputFile"`
	Status     *string                  `pulumi:"status"`
	Tags       map[string]interface{}   `pulumi:"tags"`
}

A collection of values returned by getSubscriptionJobs.

func GetSubscriptionJobs 

func GetSubscriptionJobs(ctx *pulumi.Context, args *GetSubscriptionJobsArgs, opts ...pulumi.InvokeOption) (*GetSubscriptionJobsResult, error)

This data source provides the Dts Subscription Jobs of the current Alibaba Cloud user.

> **NOTE:** Available in v1.138.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ids, err := dts.GetSubscriptionJobs(ctx, nil, nil)
		if err != nil {
			return err
		}
		ctx.Export("dtsSubscriptionJobId1", ids.Jobs[0].Id)
		return nil
	})
}

```

type GetSubscriptionJobsResultOutput 

type GetSubscriptionJobsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getSubscriptionJobs.

func GetSubscriptionJobsOutput 

func GetSubscriptionJobsOutput(ctx *pulumi.Context, args GetSubscriptionJobsOutputArgs, opts ...pulumi.InvokeOption) GetSubscriptionJobsResultOutput

func (GetSubscriptionJobsResultOutput) ElementType 

func (GetSubscriptionJobsResultOutput) ElementType() reflect.Type

func (GetSubscriptionJobsResultOutput) EnableDetails 

func (o GetSubscriptionJobsResultOutput) EnableDetails() pulumi.BoolPtrOutput

func (GetSubscriptionJobsResultOutput) Id 

func (o GetSubscriptionJobsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetSubscriptionJobsResultOutput) Ids 

func (o GetSubscriptionJobsResultOutput) Ids() pulumi.StringArrayOutput

func (GetSubscriptionJobsResultOutput) Jobs 

func (o GetSubscriptionJobsResultOutput) Jobs() GetSubscriptionJobsJobArrayOutput

func (GetSubscriptionJobsResultOutput) NameRegex 

func (o GetSubscriptionJobsResultOutput) NameRegex() pulumi.StringPtrOutput

func (GetSubscriptionJobsResultOutput) Names 

func (o GetSubscriptionJobsResultOutput) Names() pulumi.StringArrayOutput

func (GetSubscriptionJobsResultOutput) OutputFile 

func (o GetSubscriptionJobsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetSubscriptionJobsResultOutput) Status 

func (o GetSubscriptionJobsResultOutput) Status() pulumi.StringPtrOutput

func (GetSubscriptionJobsResultOutput) Tags 

func (o GetSubscriptionJobsResultOutput) Tags() pulumi.MapOutput

func (GetSubscriptionJobsResultOutput) ToGetSubscriptionJobsResultOutput 

func (o GetSubscriptionJobsResultOutput) ToGetSubscriptionJobsResultOutput() GetSubscriptionJobsResultOutput

func (GetSubscriptionJobsResultOutput) ToGetSubscriptionJobsResultOutputWithContext 

func (o GetSubscriptionJobsResultOutput) ToGetSubscriptionJobsResultOutputWithContext(ctx context.Context) GetSubscriptionJobsResultOutput

type GetSynchronizationJobsArgs 

type GetSynchronizationJobsArgs struct {
	EnableDetails *bool `pulumi:"enableDetails"`
	// A list of Synchronization Job IDs.
	Ids []string `pulumi:"ids"`
	// A regex string to filter results by synchronization job name.
	NameRegex  *string `pulumi:"nameRegex"`
	OutputFile *string `pulumi:"outputFile"`
	// The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.
	Status *string `pulumi:"status"`
}

A collection of arguments for invoking getSynchronizationJobs.

type GetSynchronizationJobsJob 

type GetSynchronizationJobsJob struct {
	// Start time in Unix timestamp format.
	Checkpoint string `pulumi:"checkpoint"`
	CreateTime string `pulumi:"createTime"`
	// Whether to execute DTS supports schema migration, full data migration, or full-data initialization.
	DataInitialization bool `pulumi:"dataInitialization"`
	// Whether to perform incremental data migration for migration types or synchronization.
	DataSynchronization bool `pulumi:"dataSynchronization"`
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, synchronization or subscription objects](https://help.aliyun.com/document_detail/209545.html).
	DbList string `pulumi:"dbList"`
	// The name of migrate the database.
	DestinationEndpointDataBaseName string `pulumi:"destinationEndpointDataBaseName"`
	// The type of destination database. Valid values: `ADB20`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName string `pulumi:"destinationEndpointEngineName"`
	// The ID of destination instance.
	DestinationEndpointInstanceId string `pulumi:"destinationEndpointInstanceId"`
	// The type of destination instance. Valid values: `ads`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType string `pulumi:"destinationEndpointInstanceType"`
	// The ip of source endpoint.
	DestinationEndpointIp string `pulumi:"destinationEndpointIp"`
	// The SID of Oracle database.
	DestinationEndpointOracleSid string `pulumi:"destinationEndpointOracleSid"`
	// The port of source endpoint.
	DestinationEndpointPort string `pulumi:"destinationEndpointPort"`
	// The region of destination instance.
	DestinationEndpointRegion string `pulumi:"destinationEndpointRegion"`
	// The username of database account.
	DestinationEndpointUserName string `pulumi:"destinationEndpointUserName"`
	DtsInstanceId               string `pulumi:"dtsInstanceId"`
	DtsJobId                    string `pulumi:"dtsJobId"`
	// The name of synchronization job.
	DtsJobName string `pulumi:"dtsJobName"`
	ExpireTime string `pulumi:"expireTime"`
	// The ID of synchronizing instance. It's the ID of resource `dts.SynchronizationInstance`.
	Id string `pulumi:"id"`
	// The name of migrate the database.
	SourceEndpointDatabaseName string `pulumi:"sourceEndpointDatabaseName"`
	// The type of source database. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName string `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance.
	SourceEndpointInstanceId string `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance. Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType string `pulumi:"sourceEndpointInstanceType"`
	// The ip of source endpoint.
	SourceEndpointIp string `pulumi:"sourceEndpointIp"`
	// The SID of Oracle database.
	SourceEndpointOracleSid string `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs.
	SourceEndpointOwnerId string `pulumi:"sourceEndpointOwnerId"`
	// The port of source endpoint.
	SourceEndpointPort string `pulumi:"sourceEndpointPort"`
	// The region of source instance.
	SourceEndpointRegion string `pulumi:"sourceEndpointRegion"`
	// The name of the role configured for the cloud account to which the source instance belongs.
	SourceEndpointRole string `pulumi:"sourceEndpointRole"`
	// The username of database account.
	SourceEndpointUserName string `pulumi:"sourceEndpointUserName"`
	// The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.
	Status string `pulumi:"status"`
	// Whether to perform a database table structure to migrate or initialization values include:
	StructureInitialization bool `pulumi:"structureInitialization"`
	// Synchronization direction. Valid values: `Forward`, `Reverse`. Only when the property `syncArchitecture` of the `dts.SynchronizationInstance` was `bidirectional` this parameter should be passed, otherwise this parameter should not be specified.
	SynchronizationDirection string `pulumi:"synchronizationDirection"`
}

type GetSynchronizationJobsJobArgs 

type GetSynchronizationJobsJobArgs struct {
	// Start time in Unix timestamp format.
	Checkpoint pulumi.StringInput `pulumi:"checkpoint"`
	CreateTime pulumi.StringInput `pulumi:"createTime"`
	// Whether to execute DTS supports schema migration, full data migration, or full-data initialization.
	DataInitialization pulumi.BoolInput `pulumi:"dataInitialization"`
	// Whether to perform incremental data migration for migration types or synchronization.
	DataSynchronization pulumi.BoolInput `pulumi:"dataSynchronization"`
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, synchronization or subscription objects](https://help.aliyun.com/document_detail/209545.html).
	DbList pulumi.StringInput `pulumi:"dbList"`
	// The name of migrate the database.
	DestinationEndpointDataBaseName pulumi.StringInput `pulumi:"destinationEndpointDataBaseName"`
	// The type of destination database. Valid values: `ADB20`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName pulumi.StringInput `pulumi:"destinationEndpointEngineName"`
	// The ID of destination instance.
	DestinationEndpointInstanceId pulumi.StringInput `pulumi:"destinationEndpointInstanceId"`
	// The type of destination instance. Valid values: `ads`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType pulumi.StringInput `pulumi:"destinationEndpointInstanceType"`
	// The ip of source endpoint.
	DestinationEndpointIp pulumi.StringInput `pulumi:"destinationEndpointIp"`
	// The SID of Oracle database.
	DestinationEndpointOracleSid pulumi.StringInput `pulumi:"destinationEndpointOracleSid"`
	// The port of source endpoint.
	DestinationEndpointPort pulumi.StringInput `pulumi:"destinationEndpointPort"`
	// The region of destination instance.
	DestinationEndpointRegion pulumi.StringInput `pulumi:"destinationEndpointRegion"`
	// The username of database account.
	DestinationEndpointUserName pulumi.StringInput `pulumi:"destinationEndpointUserName"`
	DtsInstanceId               pulumi.StringInput `pulumi:"dtsInstanceId"`
	DtsJobId                    pulumi.StringInput `pulumi:"dtsJobId"`
	// The name of synchronization job.
	DtsJobName pulumi.StringInput `pulumi:"dtsJobName"`
	ExpireTime pulumi.StringInput `pulumi:"expireTime"`
	// The ID of synchronizing instance. It's the ID of resource `dts.SynchronizationInstance`.
	Id pulumi.StringInput `pulumi:"id"`
	// The name of migrate the database.
	SourceEndpointDatabaseName pulumi.StringInput `pulumi:"sourceEndpointDatabaseName"`
	// The type of source database. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName pulumi.StringInput `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance.
	SourceEndpointInstanceId pulumi.StringInput `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance. Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType pulumi.StringInput `pulumi:"sourceEndpointInstanceType"`
	// The ip of source endpoint.
	SourceEndpointIp pulumi.StringInput `pulumi:"sourceEndpointIp"`
	// The SID of Oracle database.
	SourceEndpointOracleSid pulumi.StringInput `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs.
	SourceEndpointOwnerId pulumi.StringInput `pulumi:"sourceEndpointOwnerId"`
	// The port of source endpoint.
	SourceEndpointPort pulumi.StringInput `pulumi:"sourceEndpointPort"`
	// The region of source instance.
	SourceEndpointRegion pulumi.StringInput `pulumi:"sourceEndpointRegion"`
	// The name of the role configured for the cloud account to which the source instance belongs.
	SourceEndpointRole pulumi.StringInput `pulumi:"sourceEndpointRole"`
	// The username of database account.
	SourceEndpointUserName pulumi.StringInput `pulumi:"sourceEndpointUserName"`
	// The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.
	Status pulumi.StringInput `pulumi:"status"`
	// Whether to perform a database table structure to migrate or initialization values include:
	StructureInitialization pulumi.BoolInput `pulumi:"structureInitialization"`
	// Synchronization direction. Valid values: `Forward`, `Reverse`. Only when the property `syncArchitecture` of the `dts.SynchronizationInstance` was `bidirectional` this parameter should be passed, otherwise this parameter should not be specified.
	SynchronizationDirection pulumi.StringInput `pulumi:"synchronizationDirection"`
}

func (GetSynchronizationJobsJobArgs) ElementType 

func (GetSynchronizationJobsJobArgs) ElementType() reflect.Type

func (GetSynchronizationJobsJobArgs) ToGetSynchronizationJobsJobOutput 

func (i GetSynchronizationJobsJobArgs) ToGetSynchronizationJobsJobOutput() GetSynchronizationJobsJobOutput

func (GetSynchronizationJobsJobArgs) ToGetSynchronizationJobsJobOutputWithContext 

func (i GetSynchronizationJobsJobArgs) ToGetSynchronizationJobsJobOutputWithContext(ctx context.Context) GetSynchronizationJobsJobOutput

type GetSynchronizationJobsJobArray 

type GetSynchronizationJobsJobArray []GetSynchronizationJobsJobInput

func (GetSynchronizationJobsJobArray) ElementType 

func (GetSynchronizationJobsJobArray) ElementType() reflect.Type

func (GetSynchronizationJobsJobArray) ToGetSynchronizationJobsJobArrayOutput 

func (i GetSynchronizationJobsJobArray) ToGetSynchronizationJobsJobArrayOutput() GetSynchronizationJobsJobArrayOutput

func (GetSynchronizationJobsJobArray) ToGetSynchronizationJobsJobArrayOutputWithContext 

func (i GetSynchronizationJobsJobArray) ToGetSynchronizationJobsJobArrayOutputWithContext(ctx context.Context) GetSynchronizationJobsJobArrayOutput

type GetSynchronizationJobsJobArrayInput 

type GetSynchronizationJobsJobArrayInput interface {
	pulumi.Input

	ToGetSynchronizationJobsJobArrayOutput() GetSynchronizationJobsJobArrayOutput
	ToGetSynchronizationJobsJobArrayOutputWithContext(context.Context) GetSynchronizationJobsJobArrayOutput
}

GetSynchronizationJobsJobArrayInput is an input type that accepts GetSynchronizationJobsJobArray and GetSynchronizationJobsJobArrayOutput values. You can construct a concrete instance of `GetSynchronizationJobsJobArrayInput` via: 

GetSynchronizationJobsJobArray{ GetSynchronizationJobsJobArgs{...} }

type GetSynchronizationJobsJobArrayOutput 

type GetSynchronizationJobsJobArrayOutput struct{ *pulumi.OutputState }

func (GetSynchronizationJobsJobArrayOutput) ElementType 

func (GetSynchronizationJobsJobArrayOutput) ElementType() reflect.Type

func (GetSynchronizationJobsJobArrayOutput) Index 

func (o GetSynchronizationJobsJobArrayOutput) Index(i pulumi.IntInput) GetSynchronizationJobsJobOutput

func (GetSynchronizationJobsJobArrayOutput) ToGetSynchronizationJobsJobArrayOutput 

func (o GetSynchronizationJobsJobArrayOutput) ToGetSynchronizationJobsJobArrayOutput() GetSynchronizationJobsJobArrayOutput

func (GetSynchronizationJobsJobArrayOutput) ToGetSynchronizationJobsJobArrayOutputWithContext 

func (o GetSynchronizationJobsJobArrayOutput) ToGetSynchronizationJobsJobArrayOutputWithContext(ctx context.Context) GetSynchronizationJobsJobArrayOutput

type GetSynchronizationJobsJobInput 

type GetSynchronizationJobsJobInput interface {
	pulumi.Input

	ToGetSynchronizationJobsJobOutput() GetSynchronizationJobsJobOutput
	ToGetSynchronizationJobsJobOutputWithContext(context.Context) GetSynchronizationJobsJobOutput
}

GetSynchronizationJobsJobInput is an input type that accepts GetSynchronizationJobsJobArgs and GetSynchronizationJobsJobOutput values. You can construct a concrete instance of `GetSynchronizationJobsJobInput` via: 

GetSynchronizationJobsJobArgs{...}

type GetSynchronizationJobsJobOutput 

type GetSynchronizationJobsJobOutput struct{ *pulumi.OutputState }

func (GetSynchronizationJobsJobOutput) Checkpoint 

func (o GetSynchronizationJobsJobOutput) Checkpoint() pulumi.StringOutput

Start time in Unix timestamp format.

func (GetSynchronizationJobsJobOutput) CreateTime 

func (o GetSynchronizationJobsJobOutput) CreateTime() pulumi.StringOutput

func (GetSynchronizationJobsJobOutput) DataInitialization 

func (o GetSynchronizationJobsJobOutput) DataInitialization() pulumi.BoolOutput

Whether to execute DTS supports schema migration, full data migration, or full-data initialization.

func (GetSynchronizationJobsJobOutput) DataSynchronization 

func (o GetSynchronizationJobsJobOutput) DataSynchronization() pulumi.BoolOutput

Whether to perform incremental data migration for migration types or synchronization.

func (GetSynchronizationJobsJobOutput) DbList 

func (o GetSynchronizationJobsJobOutput) DbList() pulumi.StringOutput

Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, synchronization or subscription objects](https://help.aliyun.com/document_detail/209545.html).

func (GetSynchronizationJobsJobOutput) DestinationEndpointDataBaseName 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointDataBaseName() pulumi.StringOutput

The name of migrate the database.

func (GetSynchronizationJobsJobOutput) DestinationEndpointEngineName 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointEngineName() pulumi.StringOutput

The type of destination database. Valid values: `ADB20`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.

func (GetSynchronizationJobsJobOutput) DestinationEndpointInstanceId 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointInstanceId() pulumi.StringOutput

The ID of destination instance.

func (GetSynchronizationJobsJobOutput) DestinationEndpointInstanceType 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointInstanceType() pulumi.StringOutput

The type of destination instance. Valid values: `ads`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.

func (GetSynchronizationJobsJobOutput) DestinationEndpointIp 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointIp() pulumi.StringOutput

The ip of source endpoint.

func (GetSynchronizationJobsJobOutput) DestinationEndpointOracleSid 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointOracleSid() pulumi.StringOutput

The SID of Oracle database.

func (GetSynchronizationJobsJobOutput) DestinationEndpointPort 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointPort() pulumi.StringOutput

The port of source endpoint.

func (GetSynchronizationJobsJobOutput) DestinationEndpointRegion 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointRegion() pulumi.StringOutput

The region of destination instance.

func (GetSynchronizationJobsJobOutput) DestinationEndpointUserName 

func (o GetSynchronizationJobsJobOutput) DestinationEndpointUserName() pulumi.StringOutput

The username of database account.

func (GetSynchronizationJobsJobOutput) DtsInstanceId 

func (o GetSynchronizationJobsJobOutput) DtsInstanceId() pulumi.StringOutput

func (GetSynchronizationJobsJobOutput) DtsJobId 

func (o GetSynchronizationJobsJobOutput) DtsJobId() pulumi.StringOutput

func (GetSynchronizationJobsJobOutput) DtsJobName 

func (o GetSynchronizationJobsJobOutput) DtsJobName() pulumi.StringOutput

The name of synchronization job.

func (GetSynchronizationJobsJobOutput) ElementType 

func (GetSynchronizationJobsJobOutput) ElementType() reflect.Type

func (GetSynchronizationJobsJobOutput) ExpireTime 

func (o GetSynchronizationJobsJobOutput) ExpireTime() pulumi.StringOutput

func (GetSynchronizationJobsJobOutput) Id 

func (o GetSynchronizationJobsJobOutput) Id() pulumi.StringOutput

The ID of synchronizing instance. It's the ID of resource `dts.SynchronizationInstance`.

func (GetSynchronizationJobsJobOutput) SourceEndpointDatabaseName 

func (o GetSynchronizationJobsJobOutput) SourceEndpointDatabaseName() pulumi.StringOutput

The name of migrate the database.

func (GetSynchronizationJobsJobOutput) SourceEndpointEngineName 

func (o GetSynchronizationJobsJobOutput) SourceEndpointEngineName() pulumi.StringOutput

The type of source database. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.

func (GetSynchronizationJobsJobOutput) SourceEndpointInstanceId 

func (o GetSynchronizationJobsJobOutput) SourceEndpointInstanceId() pulumi.StringOutput

The ID of source instance.

func (GetSynchronizationJobsJobOutput) SourceEndpointInstanceType 

func (o GetSynchronizationJobsJobOutput) SourceEndpointInstanceType() pulumi.StringOutput

The type of source instance. Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.

func (GetSynchronizationJobsJobOutput) SourceEndpointIp 

func (o GetSynchronizationJobsJobOutput) SourceEndpointIp() pulumi.StringOutput

The ip of source endpoint.

func (GetSynchronizationJobsJobOutput) SourceEndpointOracleSid 

func (o GetSynchronizationJobsJobOutput) SourceEndpointOracleSid() pulumi.StringOutput

The SID of Oracle database.

func (GetSynchronizationJobsJobOutput) SourceEndpointOwnerId 

func (o GetSynchronizationJobsJobOutput) SourceEndpointOwnerId() pulumi.StringOutput

The Alibaba Cloud account ID to which the source instance belongs.

func (GetSynchronizationJobsJobOutput) SourceEndpointPort 

func (o GetSynchronizationJobsJobOutput) SourceEndpointPort() pulumi.StringOutput

The port of source endpoint.

func (GetSynchronizationJobsJobOutput) SourceEndpointRegion 

func (o GetSynchronizationJobsJobOutput) SourceEndpointRegion() pulumi.StringOutput

The region of source instance.

func (GetSynchronizationJobsJobOutput) SourceEndpointRole 

func (o GetSynchronizationJobsJobOutput) SourceEndpointRole() pulumi.StringOutput

The name of the role configured for the cloud account to which the source instance belongs.

func (GetSynchronizationJobsJobOutput) SourceEndpointUserName 

func (o GetSynchronizationJobsJobOutput) SourceEndpointUserName() pulumi.StringOutput

The username of database account.

func (GetSynchronizationJobsJobOutput) Status 

func (o GetSynchronizationJobsJobOutput) Status() pulumi.StringOutput

The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.

func (GetSynchronizationJobsJobOutput) StructureInitialization 

func (o GetSynchronizationJobsJobOutput) StructureInitialization() pulumi.BoolOutput

Whether to perform a database table structure to migrate or initialization values include:

func (GetSynchronizationJobsJobOutput) SynchronizationDirection 

func (o GetSynchronizationJobsJobOutput) SynchronizationDirection() pulumi.StringOutput

Synchronization direction. Valid values: `Forward`, `Reverse`. Only when the property `syncArchitecture` of the `dts.SynchronizationInstance` was `bidirectional` this parameter should be passed, otherwise this parameter should not be specified.

func (GetSynchronizationJobsJobOutput) ToGetSynchronizationJobsJobOutput 

func (o GetSynchronizationJobsJobOutput) ToGetSynchronizationJobsJobOutput() GetSynchronizationJobsJobOutput

func (GetSynchronizationJobsJobOutput) ToGetSynchronizationJobsJobOutputWithContext 

func (o GetSynchronizationJobsJobOutput) ToGetSynchronizationJobsJobOutputWithContext(ctx context.Context) GetSynchronizationJobsJobOutput

type GetSynchronizationJobsOutputArgs 

type GetSynchronizationJobsOutputArgs struct {
	EnableDetails pulumi.BoolPtrInput `pulumi:"enableDetails"`
	// A list of Synchronization Job IDs.
	Ids pulumi.StringArrayInput `pulumi:"ids"`
	// A regex string to filter results by synchronization job name.
	NameRegex  pulumi.StringPtrInput `pulumi:"nameRegex"`
	OutputFile pulumi.StringPtrInput `pulumi:"outputFile"`
	// The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.
	Status pulumi.StringPtrInput `pulumi:"status"`
}

A collection of arguments for invoking getSynchronizationJobs.

func (GetSynchronizationJobsOutputArgs) ElementType 

func (GetSynchronizationJobsOutputArgs) ElementType() reflect.Type

type GetSynchronizationJobsResult 

type GetSynchronizationJobsResult struct {
	EnableDetails *bool `pulumi:"enableDetails"`
	// The provider-assigned unique ID for this managed resource.
	Id         string                      `pulumi:"id"`
	Ids        []string                    `pulumi:"ids"`
	Jobs       []GetSynchronizationJobsJob `pulumi:"jobs"`
	NameRegex  *string                     `pulumi:"nameRegex"`
	OutputFile *string                     `pulumi:"outputFile"`
	Status     *string                     `pulumi:"status"`
}

A collection of values returned by getSynchronizationJobs.

func GetSynchronizationJobs 

func GetSynchronizationJobs(ctx *pulumi.Context, args *GetSynchronizationJobsArgs, opts ...pulumi.InvokeOption) (*GetSynchronizationJobsResult, error)

This data source provides the Dts Synchronization Jobs of the current Alibaba Cloud user.

> **NOTE:** Available in v1.138.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi-alicloud/sdk/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		ids, err := dts.GetSynchronizationJobs(ctx, nil, nil)
		if err != nil {
			return err
		}
		ctx.Export("dtsSynchronizationJobId1", ids.Jobs[0].Id)
		return nil
	})
}

```

type GetSynchronizationJobsResultOutput 

type GetSynchronizationJobsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getSynchronizationJobs.

func GetSynchronizationJobsOutput 

func GetSynchronizationJobsOutput(ctx *pulumi.Context, args GetSynchronizationJobsOutputArgs, opts ...pulumi.InvokeOption) GetSynchronizationJobsResultOutput

func (GetSynchronizationJobsResultOutput) ElementType 

func (GetSynchronizationJobsResultOutput) ElementType() reflect.Type

func (GetSynchronizationJobsResultOutput) EnableDetails 

func (o GetSynchronizationJobsResultOutput) EnableDetails() pulumi.BoolPtrOutput

func (GetSynchronizationJobsResultOutput) Id 

func (o GetSynchronizationJobsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetSynchronizationJobsResultOutput) Ids 

func (o GetSynchronizationJobsResultOutput) Ids() pulumi.StringArrayOutput

func (GetSynchronizationJobsResultOutput) Jobs 

func (o GetSynchronizationJobsResultOutput) Jobs() GetSynchronizationJobsJobArrayOutput

func (GetSynchronizationJobsResultOutput) NameRegex 

func (o GetSynchronizationJobsResultOutput) NameRegex() pulumi.StringPtrOutput

func (GetSynchronizationJobsResultOutput) OutputFile 

func (o GetSynchronizationJobsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetSynchronizationJobsResultOutput) Status 

func (o GetSynchronizationJobsResultOutput) Status() pulumi.StringPtrOutput

func (GetSynchronizationJobsResultOutput) ToGetSynchronizationJobsResultOutput 

func (o GetSynchronizationJobsResultOutput) ToGetSynchronizationJobsResultOutput() GetSynchronizationJobsResultOutput

func (GetSynchronizationJobsResultOutput) ToGetSynchronizationJobsResultOutputWithContext 

func (o GetSynchronizationJobsResultOutput) ToGetSynchronizationJobsResultOutputWithContext(ctx context.Context) GetSynchronizationJobsResultOutput

type JobMonitorRule 

type JobMonitorRule struct {
	pulumi.CustomResourceState

	// Trigger delay alarm threshold, which is measured in seconds.
	DelayRuleTime pulumi.StringOutput `pulumi:"delayRuleTime"`
	// Migration, synchronization or subscription task ID can be by calling the [DescribeDtsJobs] get.
	DtsJobId pulumi.StringOutput `pulumi:"dtsJobId"`
	// The alarm is triggered after notification of the contact phone number, A plurality of phone numbers between them with a comma (,) to separate.
	Phone pulumi.StringPtrOutput `pulumi:"phone"`
	// Whether to enable monitoring rules, valid values: `Y`, `N`.
	State pulumi.StringOutput `pulumi:"state"`
	// Monitoring rules of type, valid values: `delay`, `error`. **delay**: delay alarm. **error**: abnormal alarm.
	Type pulumi.StringOutput `pulumi:"type"`
}

Provides a DTS Job Monitor Rule resource.

For information about DTS Job Monitor Rule and how to use it, see [What is Job Monitor Rule](https://www.aliyun.com/product/dts).

> **NOTE:** Available in v1.134.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dts.NewJobMonitorRule(ctx, "example", &dts.JobMonitorRuleArgs{
			DtsJobId: pulumi.String("example_value"),
			Type:     pulumi.String("delay"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

DTS Job Monitor Rule can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:dts/jobMonitorRule:JobMonitorRule example <dts_job_id>

```

func GetJobMonitorRule 

func GetJobMonitorRule(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *JobMonitorRuleState, opts ...pulumi.ResourceOption) (*JobMonitorRule, error)

GetJobMonitorRule gets an existing JobMonitorRule 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 NewJobMonitorRule 

func NewJobMonitorRule(ctx *pulumi.Context,
	name string, args *JobMonitorRuleArgs, opts ...pulumi.ResourceOption) (*JobMonitorRule, error)

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

func (*JobMonitorRule) ElementType 

func (*JobMonitorRule) ElementType() reflect.Type

func (*JobMonitorRule) ToJobMonitorRuleOutput 

func (i *JobMonitorRule) ToJobMonitorRuleOutput() JobMonitorRuleOutput

func (*JobMonitorRule) ToJobMonitorRuleOutputWithContext 

func (i *JobMonitorRule) ToJobMonitorRuleOutputWithContext(ctx context.Context) JobMonitorRuleOutput

type JobMonitorRuleArgs 

type JobMonitorRuleArgs struct {
	// Trigger delay alarm threshold, which is measured in seconds.
	DelayRuleTime pulumi.StringPtrInput
	// Migration, synchronization or subscription task ID can be by calling the [DescribeDtsJobs] get.
	DtsJobId pulumi.StringInput
	// The alarm is triggered after notification of the contact phone number, A plurality of phone numbers between them with a comma (,) to separate.
	Phone pulumi.StringPtrInput
	// Whether to enable monitoring rules, valid values: `Y`, `N`.
	State pulumi.StringPtrInput
	// Monitoring rules of type, valid values: `delay`, `error`. **delay**: delay alarm. **error**: abnormal alarm.
	Type pulumi.StringInput
}

The set of arguments for constructing a JobMonitorRule resource.

func (JobMonitorRuleArgs) ElementType 

func (JobMonitorRuleArgs) ElementType() reflect.Type

type JobMonitorRuleArray 

type JobMonitorRuleArray []JobMonitorRuleInput

func (JobMonitorRuleArray) ElementType 

func (JobMonitorRuleArray) ElementType() reflect.Type

func (JobMonitorRuleArray) ToJobMonitorRuleArrayOutput 

func (i JobMonitorRuleArray) ToJobMonitorRuleArrayOutput() JobMonitorRuleArrayOutput

func (JobMonitorRuleArray) ToJobMonitorRuleArrayOutputWithContext 

func (i JobMonitorRuleArray) ToJobMonitorRuleArrayOutputWithContext(ctx context.Context) JobMonitorRuleArrayOutput

type JobMonitorRuleArrayInput 

type JobMonitorRuleArrayInput interface {
	pulumi.Input

	ToJobMonitorRuleArrayOutput() JobMonitorRuleArrayOutput
	ToJobMonitorRuleArrayOutputWithContext(context.Context) JobMonitorRuleArrayOutput
}

JobMonitorRuleArrayInput is an input type that accepts JobMonitorRuleArray and JobMonitorRuleArrayOutput values. You can construct a concrete instance of `JobMonitorRuleArrayInput` via: 

JobMonitorRuleArray{ JobMonitorRuleArgs{...} }

type JobMonitorRuleArrayOutput 

type JobMonitorRuleArrayOutput struct{ *pulumi.OutputState }

func (JobMonitorRuleArrayOutput) ElementType 

func (JobMonitorRuleArrayOutput) ElementType() reflect.Type

func (JobMonitorRuleArrayOutput) Index 

func (o JobMonitorRuleArrayOutput) Index(i pulumi.IntInput) JobMonitorRuleOutput

func (JobMonitorRuleArrayOutput) ToJobMonitorRuleArrayOutput 

func (o JobMonitorRuleArrayOutput) ToJobMonitorRuleArrayOutput() JobMonitorRuleArrayOutput

func (JobMonitorRuleArrayOutput) ToJobMonitorRuleArrayOutputWithContext 

func (o JobMonitorRuleArrayOutput) ToJobMonitorRuleArrayOutputWithContext(ctx context.Context) JobMonitorRuleArrayOutput

type JobMonitorRuleInput 

type JobMonitorRuleInput interface {
	pulumi.Input

	ToJobMonitorRuleOutput() JobMonitorRuleOutput
	ToJobMonitorRuleOutputWithContext(ctx context.Context) JobMonitorRuleOutput
}

type JobMonitorRuleMap 

type JobMonitorRuleMap map[string]JobMonitorRuleInput

func (JobMonitorRuleMap) ElementType 

func (JobMonitorRuleMap) ElementType() reflect.Type

func (JobMonitorRuleMap) ToJobMonitorRuleMapOutput 

func (i JobMonitorRuleMap) ToJobMonitorRuleMapOutput() JobMonitorRuleMapOutput

func (JobMonitorRuleMap) ToJobMonitorRuleMapOutputWithContext 

func (i JobMonitorRuleMap) ToJobMonitorRuleMapOutputWithContext(ctx context.Context) JobMonitorRuleMapOutput

type JobMonitorRuleMapInput 

type JobMonitorRuleMapInput interface {
	pulumi.Input

	ToJobMonitorRuleMapOutput() JobMonitorRuleMapOutput
	ToJobMonitorRuleMapOutputWithContext(context.Context) JobMonitorRuleMapOutput
}

JobMonitorRuleMapInput is an input type that accepts JobMonitorRuleMap and JobMonitorRuleMapOutput values. You can construct a concrete instance of `JobMonitorRuleMapInput` via: 

JobMonitorRuleMap{ "key": JobMonitorRuleArgs{...} }

type JobMonitorRuleMapOutput 

type JobMonitorRuleMapOutput struct{ *pulumi.OutputState }

func (JobMonitorRuleMapOutput) ElementType 

func (JobMonitorRuleMapOutput) ElementType() reflect.Type

func (JobMonitorRuleMapOutput) MapIndex 

func (o JobMonitorRuleMapOutput) MapIndex(k pulumi.StringInput) JobMonitorRuleOutput

func (JobMonitorRuleMapOutput) ToJobMonitorRuleMapOutput 

func (o JobMonitorRuleMapOutput) ToJobMonitorRuleMapOutput() JobMonitorRuleMapOutput

func (JobMonitorRuleMapOutput) ToJobMonitorRuleMapOutputWithContext 

func (o JobMonitorRuleMapOutput) ToJobMonitorRuleMapOutputWithContext(ctx context.Context) JobMonitorRuleMapOutput

type JobMonitorRuleOutput 

type JobMonitorRuleOutput struct{ *pulumi.OutputState }

func (JobMonitorRuleOutput) DelayRuleTime 

func (o JobMonitorRuleOutput) DelayRuleTime() pulumi.StringOutput

Trigger delay alarm threshold, which is measured in seconds.

func (JobMonitorRuleOutput) DtsJobId 

func (o JobMonitorRuleOutput) DtsJobId() pulumi.StringOutput

Migration, synchronization or subscription task ID can be by calling the [DescribeDtsJobs] get.

func (JobMonitorRuleOutput) ElementType 

func (JobMonitorRuleOutput) ElementType() reflect.Type

func (JobMonitorRuleOutput) Phone 

func (o JobMonitorRuleOutput) Phone() pulumi.StringPtrOutput

The alarm is triggered after notification of the contact phone number, A plurality of phone numbers between them with a comma (,) to separate.

func (JobMonitorRuleOutput) State 

func (o JobMonitorRuleOutput) State() pulumi.StringOutput

Whether to enable monitoring rules, valid values: `Y`, `N`.

func (JobMonitorRuleOutput) ToJobMonitorRuleOutput 

func (o JobMonitorRuleOutput) ToJobMonitorRuleOutput() JobMonitorRuleOutput

func (JobMonitorRuleOutput) ToJobMonitorRuleOutputWithContext 

func (o JobMonitorRuleOutput) ToJobMonitorRuleOutputWithContext(ctx context.Context) JobMonitorRuleOutput

func (JobMonitorRuleOutput) Type 

func (o JobMonitorRuleOutput) Type() pulumi.StringOutput

Monitoring rules of type, valid values: `delay`, `error`. **delay**: delay alarm. **error**: abnormal alarm.

type JobMonitorRuleState 

type JobMonitorRuleState struct {
	// Trigger delay alarm threshold, which is measured in seconds.
	DelayRuleTime pulumi.StringPtrInput
	// Migration, synchronization or subscription task ID can be by calling the [DescribeDtsJobs] get.
	DtsJobId pulumi.StringPtrInput
	// The alarm is triggered after notification of the contact phone number, A plurality of phone numbers between them with a comma (,) to separate.
	Phone pulumi.StringPtrInput
	// Whether to enable monitoring rules, valid values: `Y`, `N`.
	State pulumi.StringPtrInput
	// Monitoring rules of type, valid values: `delay`, `error`. **delay**: delay alarm. **error**: abnormal alarm.
	Type pulumi.StringPtrInput
}

func (JobMonitorRuleState) ElementType 

func (JobMonitorRuleState) ElementType() reflect.Type

type MigrationInstance 

type MigrationInstance struct {
	pulumi.CustomResourceState

	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrOutput `pulumi:"computeUnit"`
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrOutput `pulumi:"databaseCount"`
	// The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	DestinationEndpointEngineName pulumi.StringOutput `pulumi:"destinationEndpointEngineName"`
	// The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationEndpointRegion pulumi.StringOutput `pulumi:"destinationEndpointRegion"`
	// The ID of the Migration Instance.
	DtsInstanceId pulumi.StringOutput `pulumi:"dtsInstanceId"`
	// The instance class. Valid values: `large`, `medium`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringOutput `pulumi:"instanceClass"`
	// The payment type of the resource. Valid values: `PayAsYouGo`.
	PaymentType pulumi.StringOutput `pulumi:"paymentType"`
	// The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	SourceEndpointEngineName pulumi.StringOutput `pulumi:"sourceEndpointEngineName"`
	// The region of source instance.
	SourceEndpointRegion pulumi.StringOutput `pulumi:"sourceEndpointRegion"`
	// The status.
	Status pulumi.StringOutput `pulumi:"status"`
	// The sync architecture. Valid values: `oneway`.
	SyncArchitecture pulumi.StringPtrOutput `pulumi:"syncArchitecture"`
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapOutput `pulumi:"tags"`
}

Provides a DTS Migration Instance resource.

For information about DTS Migration Instance and how to use it, see [What is Synchronization Instance](https://www.alibabacloud.com/help/en/doc-detail/208270.html).

> **NOTE:** Available in v1.157.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dts.NewMigrationInstance(ctx, "default", &dts.MigrationInstanceArgs{
			DestinationEndpointEngineName: pulumi.String("MySQL"),
			DestinationEndpointRegion:     pulumi.String("cn-hangzhou"),
			InstanceClass:                 pulumi.String("small"),
			PaymentType:                   pulumi.String("PayAsYouGo"),
			SourceEndpointEngineName:      pulumi.String("MySQL"),
			SourceEndpointRegion:          pulumi.String("cn-hangzhou"),
			SyncArchitecture:              pulumi.String("oneway"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

DTS Migration Instance can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:dts/migrationInstance:MigrationInstance example <id>

```

func GetMigrationInstance 

func GetMigrationInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *MigrationInstanceState, opts ...pulumi.ResourceOption) (*MigrationInstance, error)

GetMigrationInstance gets an existing MigrationInstance 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 NewMigrationInstance 

func NewMigrationInstance(ctx *pulumi.Context,
	name string, args *MigrationInstanceArgs, opts ...pulumi.ResourceOption) (*MigrationInstance, error)

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

func (*MigrationInstance) ElementType 

func (*MigrationInstance) ElementType() reflect.Type

func (*MigrationInstance) ToMigrationInstanceOutput 

func (i *MigrationInstance) ToMigrationInstanceOutput() MigrationInstanceOutput

func (*MigrationInstance) ToMigrationInstanceOutputWithContext 

func (i *MigrationInstance) ToMigrationInstanceOutputWithContext(ctx context.Context) MigrationInstanceOutput

type MigrationInstanceArgs 

type MigrationInstanceArgs struct {
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrInput
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrInput
	// The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	DestinationEndpointEngineName pulumi.StringInput
	// The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationEndpointRegion pulumi.StringInput
	// The instance class. Valid values: `large`, `medium`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringPtrInput
	// The payment type of the resource. Valid values: `PayAsYouGo`.
	PaymentType pulumi.StringInput
	// The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	SourceEndpointEngineName pulumi.StringInput
	// The region of source instance.
	SourceEndpointRegion pulumi.StringInput
	// The sync architecture. Valid values: `oneway`.
	SyncArchitecture pulumi.StringPtrInput
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapInput
}

The set of arguments for constructing a MigrationInstance resource.

func (MigrationInstanceArgs) ElementType 

func (MigrationInstanceArgs) ElementType() reflect.Type

type MigrationInstanceArray 

type MigrationInstanceArray []MigrationInstanceInput

func (MigrationInstanceArray) ElementType 

func (MigrationInstanceArray) ElementType() reflect.Type

func (MigrationInstanceArray) ToMigrationInstanceArrayOutput 

func (i MigrationInstanceArray) ToMigrationInstanceArrayOutput() MigrationInstanceArrayOutput

func (MigrationInstanceArray) ToMigrationInstanceArrayOutputWithContext 

func (i MigrationInstanceArray) ToMigrationInstanceArrayOutputWithContext(ctx context.Context) MigrationInstanceArrayOutput

type MigrationInstanceArrayInput 

type MigrationInstanceArrayInput interface {
	pulumi.Input

	ToMigrationInstanceArrayOutput() MigrationInstanceArrayOutput
	ToMigrationInstanceArrayOutputWithContext(context.Context) MigrationInstanceArrayOutput
}

MigrationInstanceArrayInput is an input type that accepts MigrationInstanceArray and MigrationInstanceArrayOutput values. You can construct a concrete instance of `MigrationInstanceArrayInput` via: 

MigrationInstanceArray{ MigrationInstanceArgs{...} }

type MigrationInstanceArrayOutput 

type MigrationInstanceArrayOutput struct{ *pulumi.OutputState }

func (MigrationInstanceArrayOutput) ElementType 

func (MigrationInstanceArrayOutput) ElementType() reflect.Type

func (MigrationInstanceArrayOutput) Index 

func (o MigrationInstanceArrayOutput) Index(i pulumi.IntInput) MigrationInstanceOutput

func (MigrationInstanceArrayOutput) ToMigrationInstanceArrayOutput 

func (o MigrationInstanceArrayOutput) ToMigrationInstanceArrayOutput() MigrationInstanceArrayOutput

func (MigrationInstanceArrayOutput) ToMigrationInstanceArrayOutputWithContext 

func (o MigrationInstanceArrayOutput) ToMigrationInstanceArrayOutputWithContext(ctx context.Context) MigrationInstanceArrayOutput

type MigrationInstanceInput 

type MigrationInstanceInput interface {
	pulumi.Input

	ToMigrationInstanceOutput() MigrationInstanceOutput
	ToMigrationInstanceOutputWithContext(ctx context.Context) MigrationInstanceOutput
}

type MigrationInstanceMap 

type MigrationInstanceMap map[string]MigrationInstanceInput

func (MigrationInstanceMap) ElementType 

func (MigrationInstanceMap) ElementType() reflect.Type

func (MigrationInstanceMap) ToMigrationInstanceMapOutput 

func (i MigrationInstanceMap) ToMigrationInstanceMapOutput() MigrationInstanceMapOutput

func (MigrationInstanceMap) ToMigrationInstanceMapOutputWithContext 

func (i MigrationInstanceMap) ToMigrationInstanceMapOutputWithContext(ctx context.Context) MigrationInstanceMapOutput

type MigrationInstanceMapInput 

type MigrationInstanceMapInput interface {
	pulumi.Input

	ToMigrationInstanceMapOutput() MigrationInstanceMapOutput
	ToMigrationInstanceMapOutputWithContext(context.Context) MigrationInstanceMapOutput
}

MigrationInstanceMapInput is an input type that accepts MigrationInstanceMap and MigrationInstanceMapOutput values. You can construct a concrete instance of `MigrationInstanceMapInput` via: 

MigrationInstanceMap{ "key": MigrationInstanceArgs{...} }

type MigrationInstanceMapOutput 

type MigrationInstanceMapOutput struct{ *pulumi.OutputState }

func (MigrationInstanceMapOutput) ElementType 

func (MigrationInstanceMapOutput) ElementType() reflect.Type

func (MigrationInstanceMapOutput) MapIndex 

func (o MigrationInstanceMapOutput) MapIndex(k pulumi.StringInput) MigrationInstanceOutput

func (MigrationInstanceMapOutput) ToMigrationInstanceMapOutput 

func (o MigrationInstanceMapOutput) ToMigrationInstanceMapOutput() MigrationInstanceMapOutput

func (MigrationInstanceMapOutput) ToMigrationInstanceMapOutputWithContext 

func (o MigrationInstanceMapOutput) ToMigrationInstanceMapOutputWithContext(ctx context.Context) MigrationInstanceMapOutput

type MigrationInstanceOutput 

type MigrationInstanceOutput struct{ *pulumi.OutputState }

func (MigrationInstanceOutput) ComputeUnit 

func (o MigrationInstanceOutput) ComputeUnit() pulumi.IntPtrOutput

[ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.

func (MigrationInstanceOutput) DatabaseCount 

func (o MigrationInstanceOutput) DatabaseCount() pulumi.IntPtrOutput

The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.

func (MigrationInstanceOutput) DestinationEndpointEngineName 

func (o MigrationInstanceOutput) DestinationEndpointEngineName() pulumi.StringOutput

The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).

func (MigrationInstanceOutput) DestinationEndpointRegion 

func (o MigrationInstanceOutput) DestinationEndpointRegion() pulumi.StringOutput

The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).

func (MigrationInstanceOutput) DtsInstanceId 

func (o MigrationInstanceOutput) DtsInstanceId() pulumi.StringOutput

The ID of the Migration Instance.

func (MigrationInstanceOutput) ElementType 

func (MigrationInstanceOutput) ElementType() reflect.Type

func (MigrationInstanceOutput) InstanceClass 

func (o MigrationInstanceOutput) InstanceClass() pulumi.StringOutput

The instance class. Valid values: `large`, `medium`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).

func (MigrationInstanceOutput) PaymentType 

func (o MigrationInstanceOutput) PaymentType() pulumi.StringOutput

The payment type of the resource. Valid values: `PayAsYouGo`.

func (MigrationInstanceOutput) SourceEndpointEngineName 

func (o MigrationInstanceOutput) SourceEndpointEngineName() pulumi.StringOutput

The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).

func (MigrationInstanceOutput) SourceEndpointRegion 

func (o MigrationInstanceOutput) SourceEndpointRegion() pulumi.StringOutput

The region of source instance.

func (MigrationInstanceOutput) Status 

func (o MigrationInstanceOutput) Status() pulumi.StringOutput

The status.

func (MigrationInstanceOutput) SyncArchitecture 

func (o MigrationInstanceOutput) SyncArchitecture() pulumi.StringPtrOutput

The sync architecture. Valid values: `oneway`.

func (MigrationInstanceOutput) Tags 

func (o MigrationInstanceOutput) Tags() pulumi.MapOutput

A mapping of tags to assign to the resource.

func (MigrationInstanceOutput) ToMigrationInstanceOutput 

func (o MigrationInstanceOutput) ToMigrationInstanceOutput() MigrationInstanceOutput

func (MigrationInstanceOutput) ToMigrationInstanceOutputWithContext 

func (o MigrationInstanceOutput) ToMigrationInstanceOutputWithContext(ctx context.Context) MigrationInstanceOutput

type MigrationInstanceState 

type MigrationInstanceState struct {
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrInput
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrInput
	// The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	DestinationEndpointEngineName pulumi.StringPtrInput
	// The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationEndpointRegion pulumi.StringPtrInput
	// The ID of the Migration Instance.
	DtsInstanceId pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringPtrInput
	// The payment type of the resource. Valid values: `PayAsYouGo`.
	PaymentType pulumi.StringPtrInput
	// The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	SourceEndpointEngineName pulumi.StringPtrInput
	// The region of source instance.
	SourceEndpointRegion pulumi.StringPtrInput
	// The status.
	Status pulumi.StringPtrInput
	// The sync architecture. Valid values: `oneway`.
	SyncArchitecture pulumi.StringPtrInput
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapInput
}

func (MigrationInstanceState) ElementType 

func (MigrationInstanceState) ElementType() reflect.Type

type MigrationJob 

type MigrationJob struct {
	pulumi.CustomResourceState

	// Start time in Unix timestamp format.
	Checkpoint pulumi.StringOutput `pulumi:"checkpoint"`
	// Whether to execute DTS supports schema migration.
	DataInitialization pulumi.BoolOutput `pulumi:"dataInitialization"`
	// Whether to perform incremental data migration.
	DataSynchronization pulumi.BoolOutput `pulumi:"dataSynchronization"`
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, migration or subscription objects](https://help.aliyun.com/document_detail/209545.html).
	DbList pulumi.StringOutput `pulumi:"dbList"`
	// The name of migrate the database.
	DestinationEndpointDatabaseName pulumi.StringPtrOutput `pulumi:"destinationEndpointDatabaseName"`
	// The type of destination database. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName pulumi.StringOutput `pulumi:"destinationEndpointEngineName"`
	// The ID of destination instance.
	DestinationEndpointInstanceId pulumi.StringPtrOutput `pulumi:"destinationEndpointInstanceId"`
	// The type of destination instance. Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType pulumi.StringOutput `pulumi:"destinationEndpointInstanceType"`
	// The ip of source endpoint.
	DestinationEndpointIp pulumi.StringPtrOutput `pulumi:"destinationEndpointIp"`
	// The SID of Oracle database.
	DestinationEndpointOracleSid pulumi.StringPtrOutput `pulumi:"destinationEndpointOracleSid"`
	// The password of database account.
	DestinationEndpointPassword pulumi.StringPtrOutput `pulumi:"destinationEndpointPassword"`
	// The port of source endpoint.
	DestinationEndpointPort pulumi.StringPtrOutput `pulumi:"destinationEndpointPort"`
	// The region of destination instance.
	DestinationEndpointRegion pulumi.StringPtrOutput `pulumi:"destinationEndpointRegion"`
	// The username of database account.
	DestinationEndpointUserName pulumi.StringPtrOutput `pulumi:"destinationEndpointUserName"`
	// The Migration instance ID. The ID of `dts.MigrationInstance`.
	DtsInstanceId pulumi.StringOutput `pulumi:"dtsInstanceId"`
	// The name of migration job.
	DtsJobName pulumi.StringOutput `pulumi:"dtsJobName"`
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.
	InstanceClass pulumi.StringOutput `pulumi:"instanceClass"`
	// The name of migrate the database.
	SourceEndpointDatabaseName pulumi.StringPtrOutput `pulumi:"sourceEndpointDatabaseName"`
	// The type of source database. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName pulumi.StringOutput `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance.
	SourceEndpointInstanceId pulumi.StringPtrOutput `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance. Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType pulumi.StringOutput `pulumi:"sourceEndpointInstanceType"`
	// The ip of source endpoint.
	SourceEndpointIp pulumi.StringPtrOutput `pulumi:"sourceEndpointIp"`
	// The SID of Oracle database.
	SourceEndpointOracleSid pulumi.StringPtrOutput `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs.
	SourceEndpointOwnerId pulumi.StringPtrOutput `pulumi:"sourceEndpointOwnerId"`
	// The password of database account.
	SourceEndpointPassword pulumi.StringPtrOutput `pulumi:"sourceEndpointPassword"`
	// The port of source endpoint.
	SourceEndpointPort pulumi.StringPtrOutput `pulumi:"sourceEndpointPort"`
	// The region of source instance.
	SourceEndpointRegion pulumi.StringPtrOutput `pulumi:"sourceEndpointRegion"`
	// The name of the role configured for the cloud account to which the source instance belongs.
	SourceEndpointRole pulumi.StringPtrOutput `pulumi:"sourceEndpointRole"`
	// The username of database account.
	SourceEndpointUserName pulumi.StringPtrOutput `pulumi:"sourceEndpointUserName"`
	// The status of the resource. Valid values: `Migrating`, `Suspending`. You can suspend the task by specifying `Suspending` and start the task by specifying `Migrating`.
	Status pulumi.StringOutput `pulumi:"status"`
	// Whether to perform a database table structure to migrate.
	StructureInitialization pulumi.BoolOutput `pulumi:"structureInitialization"`
}

Provides a DTS Migration Job resource.

For information about DTS Migration Job and how to use it, see [What is Migration Job](https://www.alibabacloud.com/help/en/doc-detail/208399.html).

> **NOTE:** Available in v1.157.0+.

## Notice

1. The expiration time cannot be changed after the work of the annual and monthly subscription suspended; 2. After the pay-as-you-go type job suspended, your job configuration fee will still be charged; 3. If the task suspended for more than 6 hours, the task will not start successfully. 4. Suspending the task will only stop writing to the target library, but will still continue to obtain the incremental log of the source, so that the task can be quickly resumed after the suspension is canceled. Therefore, some resources of the source library, such as bandwidth resources, will continue to be occupied during the period. 5. Charges will continue during the task suspension period. If you need to stop charging, please release the instance 6. When a DTS instance suspended for more than 7 days, the instance cannot be resumed, and the status will change from suspended to failed.

## Import

DTS Migration Job can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:dts/migrationJob:MigrationJob example <id>

```

func GetMigrationJob 

func GetMigrationJob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *MigrationJobState, opts ...pulumi.ResourceOption) (*MigrationJob, error)

GetMigrationJob gets an existing MigrationJob 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 NewMigrationJob 

func NewMigrationJob(ctx *pulumi.Context,
	name string, args *MigrationJobArgs, opts ...pulumi.ResourceOption) (*MigrationJob, error)

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

func (*MigrationJob) ElementType 

func (*MigrationJob) ElementType() reflect.Type

func (*MigrationJob) ToMigrationJobOutput 

func (i *MigrationJob) ToMigrationJobOutput() MigrationJobOutput

func (*MigrationJob) ToMigrationJobOutputWithContext 

func (i *MigrationJob) ToMigrationJobOutputWithContext(ctx context.Context) MigrationJobOutput

type MigrationJobArgs 

type MigrationJobArgs struct {
	// Start time in Unix timestamp format.
	Checkpoint pulumi.StringPtrInput
	// Whether to execute DTS supports schema migration.
	DataInitialization pulumi.BoolInput
	// Whether to perform incremental data migration.
	DataSynchronization pulumi.BoolInput
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, migration or subscription objects](https://help.aliyun.com/document_detail/209545.html).
	DbList pulumi.StringInput
	// The name of migrate the database.
	DestinationEndpointDatabaseName pulumi.StringPtrInput
	// The type of destination database. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName pulumi.StringInput
	// The ID of destination instance.
	DestinationEndpointInstanceId pulumi.StringPtrInput
	// The type of destination instance. Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType pulumi.StringInput
	// The ip of source endpoint.
	DestinationEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database.
	DestinationEndpointOracleSid pulumi.StringPtrInput
	// The password of database account.
	DestinationEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint.
	DestinationEndpointPort pulumi.StringPtrInput
	// The region of destination instance.
	DestinationEndpointRegion pulumi.StringPtrInput
	// The username of database account.
	DestinationEndpointUserName pulumi.StringPtrInput
	// The Migration instance ID. The ID of `dts.MigrationInstance`.
	DtsInstanceId pulumi.StringInput
	// The name of migration job.
	DtsJobName pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.
	InstanceClass pulumi.StringPtrInput
	// The name of migrate the database.
	SourceEndpointDatabaseName pulumi.StringPtrInput
	// The type of source database. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName pulumi.StringInput
	// The ID of source instance.
	SourceEndpointInstanceId pulumi.StringPtrInput
	// The type of source instance. Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType pulumi.StringInput
	// The ip of source endpoint.
	SourceEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database.
	SourceEndpointOracleSid pulumi.StringPtrInput
	// The Alibaba Cloud account ID to which the source instance belongs.
	SourceEndpointOwnerId pulumi.StringPtrInput
	// The password of database account.
	SourceEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint.
	SourceEndpointPort pulumi.StringPtrInput
	// The region of source instance.
	SourceEndpointRegion pulumi.StringPtrInput
	// The name of the role configured for the cloud account to which the source instance belongs.
	SourceEndpointRole pulumi.StringPtrInput
	// The username of database account.
	SourceEndpointUserName pulumi.StringPtrInput
	// The status of the resource. Valid values: `Migrating`, `Suspending`. You can suspend the task by specifying `Suspending` and start the task by specifying `Migrating`.
	Status pulumi.StringPtrInput
	// Whether to perform a database table structure to migrate.
	StructureInitialization pulumi.BoolInput
}

The set of arguments for constructing a MigrationJob resource.

func (MigrationJobArgs) ElementType 

func (MigrationJobArgs) ElementType() reflect.Type

type MigrationJobArray 

type MigrationJobArray []MigrationJobInput

func (MigrationJobArray) ElementType 

func (MigrationJobArray) ElementType() reflect.Type

func (MigrationJobArray) ToMigrationJobArrayOutput 

func (i MigrationJobArray) ToMigrationJobArrayOutput() MigrationJobArrayOutput

func (MigrationJobArray) ToMigrationJobArrayOutputWithContext 

func (i MigrationJobArray) ToMigrationJobArrayOutputWithContext(ctx context.Context) MigrationJobArrayOutput

type MigrationJobArrayInput 

type MigrationJobArrayInput interface {
	pulumi.Input

	ToMigrationJobArrayOutput() MigrationJobArrayOutput
	ToMigrationJobArrayOutputWithContext(context.Context) MigrationJobArrayOutput
}

MigrationJobArrayInput is an input type that accepts MigrationJobArray and MigrationJobArrayOutput values. You can construct a concrete instance of `MigrationJobArrayInput` via: 

MigrationJobArray{ MigrationJobArgs{...} }

type MigrationJobArrayOutput 

type MigrationJobArrayOutput struct{ *pulumi.OutputState }

func (MigrationJobArrayOutput) ElementType 

func (MigrationJobArrayOutput) ElementType() reflect.Type

func (MigrationJobArrayOutput) Index 

func (o MigrationJobArrayOutput) Index(i pulumi.IntInput) MigrationJobOutput

func (MigrationJobArrayOutput) ToMigrationJobArrayOutput 

func (o MigrationJobArrayOutput) ToMigrationJobArrayOutput() MigrationJobArrayOutput

func (MigrationJobArrayOutput) ToMigrationJobArrayOutputWithContext 

func (o MigrationJobArrayOutput) ToMigrationJobArrayOutputWithContext(ctx context.Context) MigrationJobArrayOutput

type MigrationJobInput 

type MigrationJobInput interface {
	pulumi.Input

	ToMigrationJobOutput() MigrationJobOutput
	ToMigrationJobOutputWithContext(ctx context.Context) MigrationJobOutput
}

type MigrationJobMap 

type MigrationJobMap map[string]MigrationJobInput

func (MigrationJobMap) ElementType 

func (MigrationJobMap) ElementType() reflect.Type

func (MigrationJobMap) ToMigrationJobMapOutput 

func (i MigrationJobMap) ToMigrationJobMapOutput() MigrationJobMapOutput

func (MigrationJobMap) ToMigrationJobMapOutputWithContext 

func (i MigrationJobMap) ToMigrationJobMapOutputWithContext(ctx context.Context) MigrationJobMapOutput

type MigrationJobMapInput 

type MigrationJobMapInput interface {
	pulumi.Input

	ToMigrationJobMapOutput() MigrationJobMapOutput
	ToMigrationJobMapOutputWithContext(context.Context) MigrationJobMapOutput
}

MigrationJobMapInput is an input type that accepts MigrationJobMap and MigrationJobMapOutput values. You can construct a concrete instance of `MigrationJobMapInput` via: 

MigrationJobMap{ "key": MigrationJobArgs{...} }

type MigrationJobMapOutput 

type MigrationJobMapOutput struct{ *pulumi.OutputState }

func (MigrationJobMapOutput) ElementType 

func (MigrationJobMapOutput) ElementType() reflect.Type

func (MigrationJobMapOutput) MapIndex 

func (o MigrationJobMapOutput) MapIndex(k pulumi.StringInput) MigrationJobOutput

func (MigrationJobMapOutput) ToMigrationJobMapOutput 

func (o MigrationJobMapOutput) ToMigrationJobMapOutput() MigrationJobMapOutput

func (MigrationJobMapOutput) ToMigrationJobMapOutputWithContext 

func (o MigrationJobMapOutput) ToMigrationJobMapOutputWithContext(ctx context.Context) MigrationJobMapOutput

type MigrationJobOutput 

type MigrationJobOutput struct{ *pulumi.OutputState }

func (MigrationJobOutput) Checkpoint 

func (o MigrationJobOutput) Checkpoint() pulumi.StringOutput

Start time in Unix timestamp format.

func (MigrationJobOutput) DataInitialization 

func (o MigrationJobOutput) DataInitialization() pulumi.BoolOutput

Whether to execute DTS supports schema migration.

func (MigrationJobOutput) DataSynchronization 

func (o MigrationJobOutput) DataSynchronization() pulumi.BoolOutput

Whether to perform incremental data migration.

func (MigrationJobOutput) DbList 

func (o MigrationJobOutput) DbList() pulumi.StringOutput

Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, migration or subscription objects](https://help.aliyun.com/document_detail/209545.html).

func (MigrationJobOutput) DestinationEndpointDatabaseName 

func (o MigrationJobOutput) DestinationEndpointDatabaseName() pulumi.StringPtrOutput

The name of migrate the database.

func (MigrationJobOutput) DestinationEndpointEngineName 

func (o MigrationJobOutput) DestinationEndpointEngineName() pulumi.StringOutput

The type of destination database. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.

func (MigrationJobOutput) DestinationEndpointInstanceId 

func (o MigrationJobOutput) DestinationEndpointInstanceId() pulumi.StringPtrOutput

The ID of destination instance.

func (MigrationJobOutput) DestinationEndpointInstanceType 

func (o MigrationJobOutput) DestinationEndpointInstanceType() pulumi.StringOutput

The type of destination instance. Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.

func (MigrationJobOutput) DestinationEndpointIp 

func (o MigrationJobOutput) DestinationEndpointIp() pulumi.StringPtrOutput

The ip of source endpoint.

func (MigrationJobOutput) DestinationEndpointOracleSid 

func (o MigrationJobOutput) DestinationEndpointOracleSid() pulumi.StringPtrOutput

The SID of Oracle database.

func (MigrationJobOutput) DestinationEndpointPassword 

func (o MigrationJobOutput) DestinationEndpointPassword() pulumi.StringPtrOutput

The password of database account.

func (MigrationJobOutput) DestinationEndpointPort 

func (o MigrationJobOutput) DestinationEndpointPort() pulumi.StringPtrOutput

The port of source endpoint.

func (MigrationJobOutput) DestinationEndpointRegion 

func (o MigrationJobOutput) DestinationEndpointRegion() pulumi.StringPtrOutput

The region of destination instance.

func (MigrationJobOutput) DestinationEndpointUserName 

func (o MigrationJobOutput) DestinationEndpointUserName() pulumi.StringPtrOutput

The username of database account.

func (MigrationJobOutput) DtsInstanceId 

func (o MigrationJobOutput) DtsInstanceId() pulumi.StringOutput

The Migration instance ID. The ID of `dts.MigrationInstance`.

func (MigrationJobOutput) DtsJobName 

func (o MigrationJobOutput) DtsJobName() pulumi.StringOutput

The name of migration job.

func (MigrationJobOutput) ElementType 

func (MigrationJobOutput) ElementType() reflect.Type

func (MigrationJobOutput) InstanceClass 

func (o MigrationJobOutput) InstanceClass() pulumi.StringOutput

The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.

func (MigrationJobOutput) SourceEndpointDatabaseName 

func (o MigrationJobOutput) SourceEndpointDatabaseName() pulumi.StringPtrOutput

The name of migrate the database.

func (MigrationJobOutput) SourceEndpointEngineName 

func (o MigrationJobOutput) SourceEndpointEngineName() pulumi.StringOutput

The type of source database. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.

func (MigrationJobOutput) SourceEndpointInstanceId 

func (o MigrationJobOutput) SourceEndpointInstanceId() pulumi.StringPtrOutput

The ID of source instance.

func (MigrationJobOutput) SourceEndpointInstanceType 

func (o MigrationJobOutput) SourceEndpointInstanceType() pulumi.StringOutput

The type of source instance. Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.

func (MigrationJobOutput) SourceEndpointIp 

func (o MigrationJobOutput) SourceEndpointIp() pulumi.StringPtrOutput

The ip of source endpoint.

func (MigrationJobOutput) SourceEndpointOracleSid 

func (o MigrationJobOutput) SourceEndpointOracleSid() pulumi.StringPtrOutput

The SID of Oracle database.

func (MigrationJobOutput) SourceEndpointOwnerId 

func (o MigrationJobOutput) SourceEndpointOwnerId() pulumi.StringPtrOutput

The Alibaba Cloud account ID to which the source instance belongs.

func (MigrationJobOutput) SourceEndpointPassword 

func (o MigrationJobOutput) SourceEndpointPassword() pulumi.StringPtrOutput

The password of database account.

func (MigrationJobOutput) SourceEndpointPort 

func (o MigrationJobOutput) SourceEndpointPort() pulumi.StringPtrOutput

The port of source endpoint.

func (MigrationJobOutput) SourceEndpointRegion 

func (o MigrationJobOutput) SourceEndpointRegion() pulumi.StringPtrOutput

The region of source instance.

func (MigrationJobOutput) SourceEndpointRole 

func (o MigrationJobOutput) SourceEndpointRole() pulumi.StringPtrOutput

The name of the role configured for the cloud account to which the source instance belongs.

func (MigrationJobOutput) SourceEndpointUserName 

func (o MigrationJobOutput) SourceEndpointUserName() pulumi.StringPtrOutput

The username of database account.

func (MigrationJobOutput) Status 

func (o MigrationJobOutput) Status() pulumi.StringOutput

The status of the resource. Valid values: `Migrating`, `Suspending`. You can suspend the task by specifying `Suspending` and start the task by specifying `Migrating`.

func (MigrationJobOutput) StructureInitialization 

func (o MigrationJobOutput) StructureInitialization() pulumi.BoolOutput

Whether to perform a database table structure to migrate.

func (MigrationJobOutput) ToMigrationJobOutput 

func (o MigrationJobOutput) ToMigrationJobOutput() MigrationJobOutput

func (MigrationJobOutput) ToMigrationJobOutputWithContext 

func (o MigrationJobOutput) ToMigrationJobOutputWithContext(ctx context.Context) MigrationJobOutput

type MigrationJobState 

type MigrationJobState struct {
	// Start time in Unix timestamp format.
	Checkpoint pulumi.StringPtrInput
	// Whether to execute DTS supports schema migration.
	DataInitialization pulumi.BoolPtrInput
	// Whether to perform incremental data migration.
	DataSynchronization pulumi.BoolPtrInput
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, migration or subscription objects](https://help.aliyun.com/document_detail/209545.html).
	DbList pulumi.StringPtrInput
	// The name of migrate the database.
	DestinationEndpointDatabaseName pulumi.StringPtrInput
	// The type of destination database. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName pulumi.StringPtrInput
	// The ID of destination instance.
	DestinationEndpointInstanceId pulumi.StringPtrInput
	// The type of destination instance. Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType pulumi.StringPtrInput
	// The ip of source endpoint.
	DestinationEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database.
	DestinationEndpointOracleSid pulumi.StringPtrInput
	// The password of database account.
	DestinationEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint.
	DestinationEndpointPort pulumi.StringPtrInput
	// The region of destination instance.
	DestinationEndpointRegion pulumi.StringPtrInput
	// The username of database account.
	DestinationEndpointUserName pulumi.StringPtrInput
	// The Migration instance ID. The ID of `dts.MigrationInstance`.
	DtsInstanceId pulumi.StringPtrInput
	// The name of migration job.
	DtsJobName pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.
	InstanceClass pulumi.StringPtrInput
	// The name of migrate the database.
	SourceEndpointDatabaseName pulumi.StringPtrInput
	// The type of source database. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName pulumi.StringPtrInput
	// The ID of source instance.
	SourceEndpointInstanceId pulumi.StringPtrInput
	// The type of source instance. Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType pulumi.StringPtrInput
	// The ip of source endpoint.
	SourceEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database.
	SourceEndpointOracleSid pulumi.StringPtrInput
	// The Alibaba Cloud account ID to which the source instance belongs.
	SourceEndpointOwnerId pulumi.StringPtrInput
	// The password of database account.
	SourceEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint.
	SourceEndpointPort pulumi.StringPtrInput
	// The region of source instance.
	SourceEndpointRegion pulumi.StringPtrInput
	// The name of the role configured for the cloud account to which the source instance belongs.
	SourceEndpointRole pulumi.StringPtrInput
	// The username of database account.
	SourceEndpointUserName pulumi.StringPtrInput
	// The status of the resource. Valid values: `Migrating`, `Suspending`. You can suspend the task by specifying `Suspending` and start the task by specifying `Migrating`.
	Status pulumi.StringPtrInput
	// Whether to perform a database table structure to migrate.
	StructureInitialization pulumi.BoolPtrInput
}

func (MigrationJobState) ElementType 

func (MigrationJobState) ElementType() reflect.Type

type SubscriptionJob 

type SubscriptionJob struct {
	pulumi.CustomResourceState

	// Subscription start time in Unix timestamp format.
	Checkpoint pulumi.StringOutput `pulumi:"checkpoint"`
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrOutput `pulumi:"computeUnit"`
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrOutput `pulumi:"databaseCount"`
	// Subscription object, in the format of JSON strings. For detailed definitions, please refer to the description of migration, synchronization or subscription objects [document](https://help.aliyun.com/document_detail/209545.html).
	DbList pulumi.StringPtrOutput `pulumi:"dbList"`
	// This parameter decides whether to monitor the delay status. Valid values: `true`, `false`.
	DelayNotice pulumi.BoolPtrOutput `pulumi:"delayNotice"`
	// The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	DelayPhone pulumi.StringPtrOutput `pulumi:"delayPhone"`
	// When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.
	DelayRuleTime pulumi.StringPtrOutput `pulumi:"delayRuleTime"`
	// The destination endpoint engine name. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`.
	DestinationEndpointEngineName pulumi.StringPtrOutput `pulumi:"destinationEndpointEngineName"`
	// The destination region. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationRegion pulumi.StringPtrOutput `pulumi:"destinationRegion"`
	// The ID of subscription instance.
	DtsInstanceId pulumi.StringOutput `pulumi:"dtsInstanceId"`
	// The name of subscription task.
	DtsJobName pulumi.StringPtrOutput `pulumi:"dtsJobName"`
	// This parameter decides whether to monitor abnormal status. Valid values: `true`, `false`.
	ErrorNotice pulumi.BoolPtrOutput `pulumi:"errorNotice"`
	// The mobile phone number of the contact for abnormal alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	ErrorPhone pulumi.StringPtrOutput `pulumi:"errorPhone"`
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.
	InstanceClass pulumi.StringPtrOutput `pulumi:"instanceClass"`
	// The duration of prepaid instance purchase. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDuration pulumi.IntPtrOutput `pulumi:"paymentDuration"`
	// The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDurationUnit pulumi.StringPtrOutput `pulumi:"paymentDurationUnit"`
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType pulumi.StringOutput `pulumi:"paymentType"`
	// DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter description of the [Reserve parameter](https://help.aliyun.com/document_detail/176470.html).
	Reserve pulumi.StringPtrOutput `pulumi:"reserve"`
	// To subscribe to the name of the database.
	SourceEndpointDatabaseName pulumi.StringPtrOutput `pulumi:"sourceEndpointDatabaseName"`
	// The source database type value is MySQL or Oracle. Valid values: `MySQL`, `Oracle`.
	SourceEndpointEngineName pulumi.StringPtrOutput `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance. Only when the type of source database instance was RDS MySQL, PolarDB-X 1.0, PolarDB MySQL, this parameter can be available and must be set.
	SourceEndpointInstanceId pulumi.StringPtrOutput `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance. Valid values: `RDS`, `PolarDB`, `DRDS`, `LocalInstance`, `ECS`, `Express`, `CEN`, `dg`.
	SourceEndpointInstanceType pulumi.StringPtrOutput `pulumi:"sourceEndpointInstanceType"`
	// The IP of source endpoint.
	SourceEndpointIp pulumi.StringPtrOutput `pulumi:"sourceEndpointIp"`
	// The SID of Oracle Database. When the source database is self-built Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid pulumi.StringPtrOutput `pulumi:"sourceEndpointOracleSid"`
	// The Alibaba Cloud account ID to which the source instance belongs. This parameter is only available when configuring data subscriptions across Alibaba Cloud accounts and must be passed in.
	SourceEndpointOwnerId pulumi.StringPtrOutput `pulumi:"sourceEndpointOwnerId"`
	// The password of source database instance account.
	SourceEndpointPassword pulumi.StringPtrOutput `pulumi:"sourceEndpointPassword"`
	// The port of source database.
	SourceEndpointPort pulumi.StringPtrOutput `pulumi:"sourceEndpointPort"`
	// The region of source database.
	SourceEndpointRegion pulumi.StringPtrOutput `pulumi:"sourceEndpointRegion"`
	// Both the authorization roles. When the source instance and configure subscriptions task of the Alibaba Cloud account is not the same as the need to pass the parameter, to specify the source of the authorization roles, to allow configuration subscription task of the Alibaba Cloud account to access the source of the source instance information.
	SourceEndpointRole pulumi.StringPtrOutput `pulumi:"sourceEndpointRole"`
	// The username of source database instance account.
	SourceEndpointUserName pulumi.StringPtrOutput `pulumi:"sourceEndpointUserName"`
	// The status of the task. Valid values: `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state to `Normal` to start the job, and specify this state of `Abnormal` to stop the job. **Note: We treat the state `Starting` as the state of `Normal`, and consider the two states to be consistent on the user side.**
	Status pulumi.StringOutput `pulumi:"status"`
	// Whether to subscribe the DDL type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDdl pulumi.BoolOutput `pulumi:"subscriptionDataTypeDdl"`
	// Whether to subscribe the DML type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDml pulumi.BoolOutput `pulumi:"subscriptionDataTypeDml"`
	// Subscription task type of network value: classic: classic Network. Virtual Private Cloud (vpc): a vpc. Valid values: `classic`, `vpc`.
	SubscriptionInstanceNetworkType pulumi.StringPtrOutput `pulumi:"subscriptionInstanceNetworkType"`
	// The ID of subscription vpc instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.
	SubscriptionInstanceVpcId pulumi.StringPtrOutput `pulumi:"subscriptionInstanceVpcId"`
	// The ID of subscription VSwitch instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.
	SubscriptionInstanceVswitchId pulumi.StringPtrOutput `pulumi:"subscriptionInstanceVswitchId"`
	// The sync architecture. Valid values: `bidirectional`, `oneway`.
	SyncArchitecture pulumi.StringPtrOutput `pulumi:"syncArchitecture"`
	// The synchronization direction. Valid values: `Forward`, `Reverse`. When the topology type of the data synchronization instance is bidirectional, it can be passed in to reverse to start the reverse synchronization link.
	SynchronizationDirection pulumi.StringPtrOutput `pulumi:"synchronizationDirection"`
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapOutput `pulumi:"tags"`
}

Provides a DTS Subscription Job resource.

For information about DTS Subscription Job and how to use it, see [What is Subscription Job](https://help.aliyun.com/document_detail/254791.html).

> **NOTE:** Available in v1.138.0+.

## Import

DTS Subscription Job can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:dts/subscriptionJob:SubscriptionJob example <id>

```

func GetSubscriptionJob 

func GetSubscriptionJob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *SubscriptionJobState, opts ...pulumi.ResourceOption) (*SubscriptionJob, error)

GetSubscriptionJob gets an existing SubscriptionJob 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 NewSubscriptionJob 

func NewSubscriptionJob(ctx *pulumi.Context,
	name string, args *SubscriptionJobArgs, opts ...pulumi.ResourceOption) (*SubscriptionJob, error)

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

func (*SubscriptionJob) ElementType 

func (*SubscriptionJob) ElementType() reflect.Type

func (*SubscriptionJob) ToSubscriptionJobOutput 

func (i *SubscriptionJob) ToSubscriptionJobOutput() SubscriptionJobOutput

func (*SubscriptionJob) ToSubscriptionJobOutputWithContext 

func (i *SubscriptionJob) ToSubscriptionJobOutputWithContext(ctx context.Context) SubscriptionJobOutput

type SubscriptionJobArgs 

type SubscriptionJobArgs struct {
	// Subscription start time in Unix timestamp format.
	Checkpoint pulumi.StringPtrInput
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrInput
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrInput
	// Subscription object, in the format of JSON strings. For detailed definitions, please refer to the description of migration, synchronization or subscription objects [document](https://help.aliyun.com/document_detail/209545.html).
	DbList pulumi.StringPtrInput
	// This parameter decides whether to monitor the delay status. Valid values: `true`, `false`.
	DelayNotice pulumi.BoolPtrInput
	// The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	DelayPhone pulumi.StringPtrInput
	// When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.
	DelayRuleTime pulumi.StringPtrInput
	// The destination endpoint engine name. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`.
	DestinationEndpointEngineName pulumi.StringPtrInput
	// The destination region. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationRegion pulumi.StringPtrInput
	// The ID of subscription instance.
	DtsInstanceId pulumi.StringPtrInput
	// The name of subscription task.
	DtsJobName pulumi.StringPtrInput
	// This parameter decides whether to monitor abnormal status. Valid values: `true`, `false`.
	ErrorNotice pulumi.BoolPtrInput
	// The mobile phone number of the contact for abnormal alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	ErrorPhone pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.
	InstanceClass pulumi.StringPtrInput
	// The duration of prepaid instance purchase. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDuration pulumi.IntPtrInput
	// The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDurationUnit pulumi.StringPtrInput
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType pulumi.StringInput
	// DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter description of the [Reserve parameter](https://help.aliyun.com/document_detail/176470.html).
	Reserve pulumi.StringPtrInput
	// To subscribe to the name of the database.
	SourceEndpointDatabaseName pulumi.StringPtrInput
	// The source database type value is MySQL or Oracle. Valid values: `MySQL`, `Oracle`.
	SourceEndpointEngineName pulumi.StringPtrInput
	// The ID of source instance. Only when the type of source database instance was RDS MySQL, PolarDB-X 1.0, PolarDB MySQL, this parameter can be available and must be set.
	SourceEndpointInstanceId pulumi.StringPtrInput
	// The type of source instance. Valid values: `RDS`, `PolarDB`, `DRDS`, `LocalInstance`, `ECS`, `Express`, `CEN`, `dg`.
	SourceEndpointInstanceType pulumi.StringPtrInput
	// The IP of source endpoint.
	SourceEndpointIp pulumi.StringPtrInput
	// The SID of Oracle Database. When the source database is self-built Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid pulumi.StringPtrInput
	// The Alibaba Cloud account ID to which the source instance belongs. This parameter is only available when configuring data subscriptions across Alibaba Cloud accounts and must be passed in.
	SourceEndpointOwnerId pulumi.StringPtrInput
	// The password of source database instance account.
	SourceEndpointPassword pulumi.StringPtrInput
	// The port of source database.
	SourceEndpointPort pulumi.StringPtrInput
	// The region of source database.
	SourceEndpointRegion pulumi.StringPtrInput
	// Both the authorization roles. When the source instance and configure subscriptions task of the Alibaba Cloud account is not the same as the need to pass the parameter, to specify the source of the authorization roles, to allow configuration subscription task of the Alibaba Cloud account to access the source of the source instance information.
	SourceEndpointRole pulumi.StringPtrInput
	// The username of source database instance account.
	SourceEndpointUserName pulumi.StringPtrInput
	// The status of the task. Valid values: `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state to `Normal` to start the job, and specify this state of `Abnormal` to stop the job. **Note: We treat the state `Starting` as the state of `Normal`, and consider the two states to be consistent on the user side.**
	Status pulumi.StringPtrInput
	// Whether to subscribe the DDL type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDdl pulumi.BoolPtrInput
	// Whether to subscribe the DML type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDml pulumi.BoolPtrInput
	// Subscription task type of network value: classic: classic Network. Virtual Private Cloud (vpc): a vpc. Valid values: `classic`, `vpc`.
	SubscriptionInstanceNetworkType pulumi.StringPtrInput
	// The ID of subscription vpc instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.
	SubscriptionInstanceVpcId pulumi.StringPtrInput
	// The ID of subscription VSwitch instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.
	SubscriptionInstanceVswitchId pulumi.StringPtrInput
	// The sync architecture. Valid values: `bidirectional`, `oneway`.
	SyncArchitecture pulumi.StringPtrInput
	// The synchronization direction. Valid values: `Forward`, `Reverse`. When the topology type of the data synchronization instance is bidirectional, it can be passed in to reverse to start the reverse synchronization link.
	SynchronizationDirection pulumi.StringPtrInput
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapInput
}

The set of arguments for constructing a SubscriptionJob resource.

func (SubscriptionJobArgs) ElementType 

func (SubscriptionJobArgs) ElementType() reflect.Type

type SubscriptionJobArray 

type SubscriptionJobArray []SubscriptionJobInput

func (SubscriptionJobArray) ElementType 

func (SubscriptionJobArray) ElementType() reflect.Type

func (SubscriptionJobArray) ToSubscriptionJobArrayOutput 

func (i SubscriptionJobArray) ToSubscriptionJobArrayOutput() SubscriptionJobArrayOutput

func (SubscriptionJobArray) ToSubscriptionJobArrayOutputWithContext 

func (i SubscriptionJobArray) ToSubscriptionJobArrayOutputWithContext(ctx context.Context) SubscriptionJobArrayOutput

type SubscriptionJobArrayInput 

type SubscriptionJobArrayInput interface {
	pulumi.Input

	ToSubscriptionJobArrayOutput() SubscriptionJobArrayOutput
	ToSubscriptionJobArrayOutputWithContext(context.Context) SubscriptionJobArrayOutput
}

SubscriptionJobArrayInput is an input type that accepts SubscriptionJobArray and SubscriptionJobArrayOutput values. You can construct a concrete instance of `SubscriptionJobArrayInput` via: 

SubscriptionJobArray{ SubscriptionJobArgs{...} }

type SubscriptionJobArrayOutput 

type SubscriptionJobArrayOutput struct{ *pulumi.OutputState }

func (SubscriptionJobArrayOutput) ElementType 

func (SubscriptionJobArrayOutput) ElementType() reflect.Type

func (SubscriptionJobArrayOutput) Index 

func (o SubscriptionJobArrayOutput) Index(i pulumi.IntInput) SubscriptionJobOutput

func (SubscriptionJobArrayOutput) ToSubscriptionJobArrayOutput 

func (o SubscriptionJobArrayOutput) ToSubscriptionJobArrayOutput() SubscriptionJobArrayOutput

func (SubscriptionJobArrayOutput) ToSubscriptionJobArrayOutputWithContext 

func (o SubscriptionJobArrayOutput) ToSubscriptionJobArrayOutputWithContext(ctx context.Context) SubscriptionJobArrayOutput

type SubscriptionJobInput 

type SubscriptionJobInput interface {
	pulumi.Input

	ToSubscriptionJobOutput() SubscriptionJobOutput
	ToSubscriptionJobOutputWithContext(ctx context.Context) SubscriptionJobOutput
}

type SubscriptionJobMap 

type SubscriptionJobMap map[string]SubscriptionJobInput

func (SubscriptionJobMap) ElementType 

func (SubscriptionJobMap) ElementType() reflect.Type

func (SubscriptionJobMap) ToSubscriptionJobMapOutput 

func (i SubscriptionJobMap) ToSubscriptionJobMapOutput() SubscriptionJobMapOutput

func (SubscriptionJobMap) ToSubscriptionJobMapOutputWithContext 

func (i SubscriptionJobMap) ToSubscriptionJobMapOutputWithContext(ctx context.Context) SubscriptionJobMapOutput

type SubscriptionJobMapInput 

type SubscriptionJobMapInput interface {
	pulumi.Input

	ToSubscriptionJobMapOutput() SubscriptionJobMapOutput
	ToSubscriptionJobMapOutputWithContext(context.Context) SubscriptionJobMapOutput
}

SubscriptionJobMapInput is an input type that accepts SubscriptionJobMap and SubscriptionJobMapOutput values. You can construct a concrete instance of `SubscriptionJobMapInput` via: 

SubscriptionJobMap{ "key": SubscriptionJobArgs{...} }

type SubscriptionJobMapOutput 

type SubscriptionJobMapOutput struct{ *pulumi.OutputState }

func (SubscriptionJobMapOutput) ElementType 

func (SubscriptionJobMapOutput) ElementType() reflect.Type

func (SubscriptionJobMapOutput) MapIndex 

func (o SubscriptionJobMapOutput) MapIndex(k pulumi.StringInput) SubscriptionJobOutput

func (SubscriptionJobMapOutput) ToSubscriptionJobMapOutput 

func (o SubscriptionJobMapOutput) ToSubscriptionJobMapOutput() SubscriptionJobMapOutput

func (SubscriptionJobMapOutput) ToSubscriptionJobMapOutputWithContext 

func (o SubscriptionJobMapOutput) ToSubscriptionJobMapOutputWithContext(ctx context.Context) SubscriptionJobMapOutput

type SubscriptionJobOutput 

type SubscriptionJobOutput struct{ *pulumi.OutputState }

func (SubscriptionJobOutput) Checkpoint 

func (o SubscriptionJobOutput) Checkpoint() pulumi.StringOutput

Subscription start time in Unix timestamp format.

func (SubscriptionJobOutput) ComputeUnit 

func (o SubscriptionJobOutput) ComputeUnit() pulumi.IntPtrOutput

[ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.

func (SubscriptionJobOutput) DatabaseCount 

func (o SubscriptionJobOutput) DatabaseCount() pulumi.IntPtrOutput

The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.

func (SubscriptionJobOutput) DbList 

func (o SubscriptionJobOutput) DbList() pulumi.StringPtrOutput

Subscription object, in the format of JSON strings. For detailed definitions, please refer to the description of migration, synchronization or subscription objects [document](https://help.aliyun.com/document_detail/209545.html).

func (SubscriptionJobOutput) DelayNotice 

func (o SubscriptionJobOutput) DelayNotice() pulumi.BoolPtrOutput

This parameter decides whether to monitor the delay status. Valid values: `true`, `false`.

func (SubscriptionJobOutput) DelayPhone 

func (o SubscriptionJobOutput) DelayPhone() pulumi.StringPtrOutput

The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.

func (SubscriptionJobOutput) DelayRuleTime 

func (o SubscriptionJobOutput) DelayRuleTime() pulumi.StringPtrOutput

When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.

func (SubscriptionJobOutput) DestinationEndpointEngineName 

func (o SubscriptionJobOutput) DestinationEndpointEngineName() pulumi.StringPtrOutput

The destination endpoint engine name. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`.

func (SubscriptionJobOutput) DestinationRegion 

func (o SubscriptionJobOutput) DestinationRegion() pulumi.StringPtrOutput

The destination region. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).

func (SubscriptionJobOutput) DtsInstanceId 

func (o SubscriptionJobOutput) DtsInstanceId() pulumi.StringOutput

The ID of subscription instance.

func (SubscriptionJobOutput) DtsJobName 

func (o SubscriptionJobOutput) DtsJobName() pulumi.StringPtrOutput

The name of subscription task.

func (SubscriptionJobOutput) ElementType 

func (SubscriptionJobOutput) ElementType() reflect.Type

func (SubscriptionJobOutput) ErrorNotice 

func (o SubscriptionJobOutput) ErrorNotice() pulumi.BoolPtrOutput

This parameter decides whether to monitor abnormal status. Valid values: `true`, `false`.

func (SubscriptionJobOutput) ErrorPhone 

func (o SubscriptionJobOutput) ErrorPhone() pulumi.StringPtrOutput

The mobile phone number of the contact for abnormal alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.

func (SubscriptionJobOutput) InstanceClass 

func (o SubscriptionJobOutput) InstanceClass() pulumi.StringPtrOutput

The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.

func (SubscriptionJobOutput) PaymentDuration 

func (o SubscriptionJobOutput) PaymentDuration() pulumi.IntPtrOutput

The duration of prepaid instance purchase. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.

func (SubscriptionJobOutput) PaymentDurationUnit 

func (o SubscriptionJobOutput) PaymentDurationUnit() pulumi.StringPtrOutput

The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.

func (SubscriptionJobOutput) PaymentType 

func (o SubscriptionJobOutput) PaymentType() pulumi.StringOutput

The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.

func (SubscriptionJobOutput) Reserve 

func (o SubscriptionJobOutput) Reserve() pulumi.StringPtrOutput

DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter description of the [Reserve parameter](https://help.aliyun.com/document_detail/176470.html).

func (SubscriptionJobOutput) SourceEndpointDatabaseName 

func (o SubscriptionJobOutput) SourceEndpointDatabaseName() pulumi.StringPtrOutput

To subscribe to the name of the database.

func (SubscriptionJobOutput) SourceEndpointEngineName 

func (o SubscriptionJobOutput) SourceEndpointEngineName() pulumi.StringPtrOutput

The source database type value is MySQL or Oracle. Valid values: `MySQL`, `Oracle`.

func (SubscriptionJobOutput) SourceEndpointInstanceId 

func (o SubscriptionJobOutput) SourceEndpointInstanceId() pulumi.StringPtrOutput

The ID of source instance. Only when the type of source database instance was RDS MySQL, PolarDB-X 1.0, PolarDB MySQL, this parameter can be available and must be set.

func (SubscriptionJobOutput) SourceEndpointInstanceType 

func (o SubscriptionJobOutput) SourceEndpointInstanceType() pulumi.StringPtrOutput

The type of source instance. Valid values: `RDS`, `PolarDB`, `DRDS`, `LocalInstance`, `ECS`, `Express`, `CEN`, `dg`.

func (SubscriptionJobOutput) SourceEndpointIp 

func (o SubscriptionJobOutput) SourceEndpointIp() pulumi.StringPtrOutput

The IP of source endpoint.

func (SubscriptionJobOutput) SourceEndpointOracleSid 

func (o SubscriptionJobOutput) SourceEndpointOracleSid() pulumi.StringPtrOutput

The SID of Oracle Database. When the source database is self-built Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.

func (SubscriptionJobOutput) SourceEndpointOwnerId 

func (o SubscriptionJobOutput) SourceEndpointOwnerId() pulumi.StringPtrOutput

The Alibaba Cloud account ID to which the source instance belongs. This parameter is only available when configuring data subscriptions across Alibaba Cloud accounts and must be passed in.

func (SubscriptionJobOutput) SourceEndpointPassword 

func (o SubscriptionJobOutput) SourceEndpointPassword() pulumi.StringPtrOutput

The password of source database instance account.

func (SubscriptionJobOutput) SourceEndpointPort 

func (o SubscriptionJobOutput) SourceEndpointPort() pulumi.StringPtrOutput

The port of source database.

func (SubscriptionJobOutput) SourceEndpointRegion 

func (o SubscriptionJobOutput) SourceEndpointRegion() pulumi.StringPtrOutput

The region of source database.

func (SubscriptionJobOutput) SourceEndpointRole 

func (o SubscriptionJobOutput) SourceEndpointRole() pulumi.StringPtrOutput

Both the authorization roles. When the source instance and configure subscriptions task of the Alibaba Cloud account is not the same as the need to pass the parameter, to specify the source of the authorization roles, to allow configuration subscription task of the Alibaba Cloud account to access the source of the source instance information.

func (SubscriptionJobOutput) SourceEndpointUserName 

func (o SubscriptionJobOutput) SourceEndpointUserName() pulumi.StringPtrOutput

The username of source database instance account.

func (SubscriptionJobOutput) Status 

func (o SubscriptionJobOutput) Status() pulumi.StringOutput

The status of the task. Valid values: `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state to `Normal` to start the job, and specify this state of `Abnormal` to stop the job. **Note: We treat the state `Starting` as the state of `Normal`, and consider the two states to be consistent on the user side.**

func (SubscriptionJobOutput) SubscriptionDataTypeDdl 

func (o SubscriptionJobOutput) SubscriptionDataTypeDdl() pulumi.BoolOutput

Whether to subscribe the DDL type of data. Valid values: `true`, `false`.

func (SubscriptionJobOutput) SubscriptionDataTypeDml 

func (o SubscriptionJobOutput) SubscriptionDataTypeDml() pulumi.BoolOutput

Whether to subscribe the DML type of data. Valid values: `true`, `false`.

func (SubscriptionJobOutput) SubscriptionInstanceNetworkType 

func (o SubscriptionJobOutput) SubscriptionInstanceNetworkType() pulumi.StringPtrOutput

Subscription task type of network value: classic: classic Network. Virtual Private Cloud (vpc): a vpc. Valid values: `classic`, `vpc`.

func (SubscriptionJobOutput) SubscriptionInstanceVpcId 

func (o SubscriptionJobOutput) SubscriptionInstanceVpcId() pulumi.StringPtrOutput

The ID of subscription vpc instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.

func (SubscriptionJobOutput) SubscriptionInstanceVswitchId 

func (o SubscriptionJobOutput) SubscriptionInstanceVswitchId() pulumi.StringPtrOutput

The ID of subscription VSwitch instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.

func (SubscriptionJobOutput) SyncArchitecture 

func (o SubscriptionJobOutput) SyncArchitecture() pulumi.StringPtrOutput

The sync architecture. Valid values: `bidirectional`, `oneway`.

func (SubscriptionJobOutput) SynchronizationDirection 

func (o SubscriptionJobOutput) SynchronizationDirection() pulumi.StringPtrOutput

The synchronization direction. Valid values: `Forward`, `Reverse`. When the topology type of the data synchronization instance is bidirectional, it can be passed in to reverse to start the reverse synchronization link.

func (SubscriptionJobOutput) Tags 

func (o SubscriptionJobOutput) Tags() pulumi.MapOutput

A mapping of tags to assign to the resource.

func (SubscriptionJobOutput) ToSubscriptionJobOutput 

func (o SubscriptionJobOutput) ToSubscriptionJobOutput() SubscriptionJobOutput

func (SubscriptionJobOutput) ToSubscriptionJobOutputWithContext 

func (o SubscriptionJobOutput) ToSubscriptionJobOutputWithContext(ctx context.Context) SubscriptionJobOutput

type SubscriptionJobState 

type SubscriptionJobState struct {
	// Subscription start time in Unix timestamp format.
	Checkpoint pulumi.StringPtrInput
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrInput
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrInput
	// Subscription object, in the format of JSON strings. For detailed definitions, please refer to the description of migration, synchronization or subscription objects [document](https://help.aliyun.com/document_detail/209545.html).
	DbList pulumi.StringPtrInput
	// This parameter decides whether to monitor the delay status. Valid values: `true`, `false`.
	DelayNotice pulumi.BoolPtrInput
	// The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	DelayPhone pulumi.StringPtrInput
	// When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.
	DelayRuleTime pulumi.StringPtrInput
	// The destination endpoint engine name. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`.
	DestinationEndpointEngineName pulumi.StringPtrInput
	// The destination region. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationRegion pulumi.StringPtrInput
	// The ID of subscription instance.
	DtsInstanceId pulumi.StringPtrInput
	// The name of subscription task.
	DtsJobName pulumi.StringPtrInput
	// This parameter decides whether to monitor abnormal status. Valid values: `true`, `false`.
	ErrorNotice pulumi.BoolPtrInput
	// The mobile phone number of the contact for abnormal alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	ErrorPhone pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`.
	InstanceClass pulumi.StringPtrInput
	// The duration of prepaid instance purchase. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDuration pulumi.IntPtrInput
	// The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDurationUnit pulumi.StringPtrInput
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType pulumi.StringPtrInput
	// DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter description of the [Reserve parameter](https://help.aliyun.com/document_detail/176470.html).
	Reserve pulumi.StringPtrInput
	// To subscribe to the name of the database.
	SourceEndpointDatabaseName pulumi.StringPtrInput
	// The source database type value is MySQL or Oracle. Valid values: `MySQL`, `Oracle`.
	SourceEndpointEngineName pulumi.StringPtrInput
	// The ID of source instance. Only when the type of source database instance was RDS MySQL, PolarDB-X 1.0, PolarDB MySQL, this parameter can be available and must be set.
	SourceEndpointInstanceId pulumi.StringPtrInput
	// The type of source instance. Valid values: `RDS`, `PolarDB`, `DRDS`, `LocalInstance`, `ECS`, `Express`, `CEN`, `dg`.
	SourceEndpointInstanceType pulumi.StringPtrInput
	// The IP of source endpoint.
	SourceEndpointIp pulumi.StringPtrInput
	// The SID of Oracle Database. When the source database is self-built Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid pulumi.StringPtrInput
	// The Alibaba Cloud account ID to which the source instance belongs. This parameter is only available when configuring data subscriptions across Alibaba Cloud accounts and must be passed in.
	SourceEndpointOwnerId pulumi.StringPtrInput
	// The password of source database instance account.
	SourceEndpointPassword pulumi.StringPtrInput
	// The port of source database.
	SourceEndpointPort pulumi.StringPtrInput
	// The region of source database.
	SourceEndpointRegion pulumi.StringPtrInput
	// Both the authorization roles. When the source instance and configure subscriptions task of the Alibaba Cloud account is not the same as the need to pass the parameter, to specify the source of the authorization roles, to allow configuration subscription task of the Alibaba Cloud account to access the source of the source instance information.
	SourceEndpointRole pulumi.StringPtrInput
	// The username of source database instance account.
	SourceEndpointUserName pulumi.StringPtrInput
	// The status of the task. Valid values: `Normal`, `Abnormal`. When a task created, it is in this state of `NotStarted`. You can specify this state to `Normal` to start the job, and specify this state of `Abnormal` to stop the job. **Note: We treat the state `Starting` as the state of `Normal`, and consider the two states to be consistent on the user side.**
	Status pulumi.StringPtrInput
	// Whether to subscribe the DDL type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDdl pulumi.BoolPtrInput
	// Whether to subscribe the DML type of data. Valid values: `true`, `false`.
	SubscriptionDataTypeDml pulumi.BoolPtrInput
	// Subscription task type of network value: classic: classic Network. Virtual Private Cloud (vpc): a vpc. Valid values: `classic`, `vpc`.
	SubscriptionInstanceNetworkType pulumi.StringPtrInput
	// The ID of subscription vpc instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.
	SubscriptionInstanceVpcId pulumi.StringPtrInput
	// The ID of subscription VSwitch instance. When the value of `subscriptionInstanceNetworkType` is vpc, this parameter is available and must be passed in.
	SubscriptionInstanceVswitchId pulumi.StringPtrInput
	// The sync architecture. Valid values: `bidirectional`, `oneway`.
	SyncArchitecture pulumi.StringPtrInput
	// The synchronization direction. Valid values: `Forward`, `Reverse`. When the topology type of the data synchronization instance is bidirectional, it can be passed in to reverse to start the reverse synchronization link.
	SynchronizationDirection pulumi.StringPtrInput
	// A mapping of tags to assign to the resource.
	Tags pulumi.MapInput
}

func (SubscriptionJobState) ElementType 

func (SubscriptionJobState) ElementType() reflect.Type

type SynchronizationInstance 

type SynchronizationInstance struct {
	pulumi.CustomResourceState

	// Whether to automatically renew when it expires. Valid values: `true`, `false`.
	AutoPay pulumi.StringPtrOutput `pulumi:"autoPay"`
	// Whether to automatically start the task after the purchase completed. Valid values: `true`, `false`.
	AutoStart pulumi.StringPtrOutput `pulumi:"autoStart"`
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrOutput `pulumi:"computeUnit"`
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrOutput `pulumi:"databaseCount"`
	// The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	DestinationEndpointEngineName pulumi.StringOutput `pulumi:"destinationEndpointEngineName"`
	// The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationEndpointRegion pulumi.StringOutput `pulumi:"destinationEndpointRegion"`
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringOutput `pulumi:"instanceClass"`
	// The duration of prepaid instance purchase. this parameter is required When `paymentType` equals `Subscription`.
	PaymentDuration pulumi.IntPtrOutput `pulumi:"paymentDuration"`
	// The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDurationUnit pulumi.StringPtrOutput `pulumi:"paymentDurationUnit"`
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType pulumi.StringOutput `pulumi:"paymentType"`
	// The number of instances purchased.
	Quantity pulumi.IntPtrOutput `pulumi:"quantity"`
	// The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	SourceEndpointEngineName pulumi.StringOutput `pulumi:"sourceEndpointEngineName"`
	// The region of source instance.
	SourceEndpointRegion pulumi.StringOutput `pulumi:"sourceEndpointRegion"`
	// The status.
	Status pulumi.StringOutput `pulumi:"status"`
	// The sync architecture. Valid values: `oneway`, `bidirectional`.
	SyncArchitecture pulumi.StringPtrOutput `pulumi:"syncArchitecture"`
}

Provides a DTS Synchronization Instance resource.

For information about DTS Synchronization Instance and how to use it, see [What is Synchronization Instance](https://www.alibabacloud.com/help/en/doc-detail/130744.html).

> **NOTE:** Available in v1.138.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := dts.NewSynchronizationInstance(ctx, "default", &dts.SynchronizationInstanceArgs{
			DestinationEndpointEngineName: pulumi.String("ADB30"),
			DestinationEndpointRegion:     pulumi.String("cn-hangzhou"),
			InstanceClass:                 pulumi.String("small"),
			PaymentType:                   pulumi.String("PayAsYouGo"),
			SourceEndpointEngineName:      pulumi.String("PolarDB"),
			SourceEndpointRegion:          pulumi.String("cn-hangzhou"),
			SyncArchitecture:              pulumi.String("oneway"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

```

## Import

DTS Synchronization Instance can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:dts/synchronizationInstance:SynchronizationInstance example <id>

```

func GetSynchronizationInstance 

func GetSynchronizationInstance(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *SynchronizationInstanceState, opts ...pulumi.ResourceOption) (*SynchronizationInstance, error)

GetSynchronizationInstance gets an existing SynchronizationInstance 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 NewSynchronizationInstance 

func NewSynchronizationInstance(ctx *pulumi.Context,
	name string, args *SynchronizationInstanceArgs, opts ...pulumi.ResourceOption) (*SynchronizationInstance, error)

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

func (*SynchronizationInstance) ElementType 

func (*SynchronizationInstance) ElementType() reflect.Type

func (*SynchronizationInstance) ToSynchronizationInstanceOutput 

func (i *SynchronizationInstance) ToSynchronizationInstanceOutput() SynchronizationInstanceOutput

func (*SynchronizationInstance) ToSynchronizationInstanceOutputWithContext 

func (i *SynchronizationInstance) ToSynchronizationInstanceOutputWithContext(ctx context.Context) SynchronizationInstanceOutput

type SynchronizationInstanceArgs 

type SynchronizationInstanceArgs struct {
	// Whether to automatically renew when it expires. Valid values: `true`, `false`.
	AutoPay pulumi.StringPtrInput
	// Whether to automatically start the task after the purchase completed. Valid values: `true`, `false`.
	AutoStart pulumi.StringPtrInput
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrInput
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrInput
	// The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	DestinationEndpointEngineName pulumi.StringInput
	// The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationEndpointRegion pulumi.StringInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringPtrInput
	// The duration of prepaid instance purchase. this parameter is required When `paymentType` equals `Subscription`.
	PaymentDuration pulumi.IntPtrInput
	// The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDurationUnit pulumi.StringPtrInput
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType pulumi.StringInput
	// The number of instances purchased.
	Quantity pulumi.IntPtrInput
	// The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	SourceEndpointEngineName pulumi.StringInput
	// The region of source instance.
	SourceEndpointRegion pulumi.StringInput
	// The sync architecture. Valid values: `oneway`, `bidirectional`.
	SyncArchitecture pulumi.StringPtrInput
}

The set of arguments for constructing a SynchronizationInstance resource.

func (SynchronizationInstanceArgs) ElementType 

func (SynchronizationInstanceArgs) ElementType() reflect.Type

type SynchronizationInstanceArray 

type SynchronizationInstanceArray []SynchronizationInstanceInput

func (SynchronizationInstanceArray) ElementType 

func (SynchronizationInstanceArray) ElementType() reflect.Type

func (SynchronizationInstanceArray) ToSynchronizationInstanceArrayOutput 

func (i SynchronizationInstanceArray) ToSynchronizationInstanceArrayOutput() SynchronizationInstanceArrayOutput

func (SynchronizationInstanceArray) ToSynchronizationInstanceArrayOutputWithContext 

func (i SynchronizationInstanceArray) ToSynchronizationInstanceArrayOutputWithContext(ctx context.Context) SynchronizationInstanceArrayOutput

type SynchronizationInstanceArrayInput 

type SynchronizationInstanceArrayInput interface {
	pulumi.Input

	ToSynchronizationInstanceArrayOutput() SynchronizationInstanceArrayOutput
	ToSynchronizationInstanceArrayOutputWithContext(context.Context) SynchronizationInstanceArrayOutput
}

SynchronizationInstanceArrayInput is an input type that accepts SynchronizationInstanceArray and SynchronizationInstanceArrayOutput values. You can construct a concrete instance of `SynchronizationInstanceArrayInput` via: 

SynchronizationInstanceArray{ SynchronizationInstanceArgs{...} }

type SynchronizationInstanceArrayOutput 

type SynchronizationInstanceArrayOutput struct{ *pulumi.OutputState }

func (SynchronizationInstanceArrayOutput) ElementType 

func (SynchronizationInstanceArrayOutput) ElementType() reflect.Type

func (SynchronizationInstanceArrayOutput) Index 

func (o SynchronizationInstanceArrayOutput) Index(i pulumi.IntInput) SynchronizationInstanceOutput

func (SynchronizationInstanceArrayOutput) ToSynchronizationInstanceArrayOutput 

func (o SynchronizationInstanceArrayOutput) ToSynchronizationInstanceArrayOutput() SynchronizationInstanceArrayOutput

func (SynchronizationInstanceArrayOutput) ToSynchronizationInstanceArrayOutputWithContext 

func (o SynchronizationInstanceArrayOutput) ToSynchronizationInstanceArrayOutputWithContext(ctx context.Context) SynchronizationInstanceArrayOutput

type SynchronizationInstanceInput 

type SynchronizationInstanceInput interface {
	pulumi.Input

	ToSynchronizationInstanceOutput() SynchronizationInstanceOutput
	ToSynchronizationInstanceOutputWithContext(ctx context.Context) SynchronizationInstanceOutput
}

type SynchronizationInstanceMap 

type SynchronizationInstanceMap map[string]SynchronizationInstanceInput

func (SynchronizationInstanceMap) ElementType 

func (SynchronizationInstanceMap) ElementType() reflect.Type

func (SynchronizationInstanceMap) ToSynchronizationInstanceMapOutput 

func (i SynchronizationInstanceMap) ToSynchronizationInstanceMapOutput() SynchronizationInstanceMapOutput

func (SynchronizationInstanceMap) ToSynchronizationInstanceMapOutputWithContext 

func (i SynchronizationInstanceMap) ToSynchronizationInstanceMapOutputWithContext(ctx context.Context) SynchronizationInstanceMapOutput

type SynchronizationInstanceMapInput 

type SynchronizationInstanceMapInput interface {
	pulumi.Input

	ToSynchronizationInstanceMapOutput() SynchronizationInstanceMapOutput
	ToSynchronizationInstanceMapOutputWithContext(context.Context) SynchronizationInstanceMapOutput
}

SynchronizationInstanceMapInput is an input type that accepts SynchronizationInstanceMap and SynchronizationInstanceMapOutput values. You can construct a concrete instance of `SynchronizationInstanceMapInput` via: 

SynchronizationInstanceMap{ "key": SynchronizationInstanceArgs{...} }

type SynchronizationInstanceMapOutput 

type SynchronizationInstanceMapOutput struct{ *pulumi.OutputState }

func (SynchronizationInstanceMapOutput) ElementType 

func (SynchronizationInstanceMapOutput) ElementType() reflect.Type

func (SynchronizationInstanceMapOutput) MapIndex 

func (o SynchronizationInstanceMapOutput) MapIndex(k pulumi.StringInput) SynchronizationInstanceOutput

func (SynchronizationInstanceMapOutput) ToSynchronizationInstanceMapOutput 

func (o SynchronizationInstanceMapOutput) ToSynchronizationInstanceMapOutput() SynchronizationInstanceMapOutput

func (SynchronizationInstanceMapOutput) ToSynchronizationInstanceMapOutputWithContext 

func (o SynchronizationInstanceMapOutput) ToSynchronizationInstanceMapOutputWithContext(ctx context.Context) SynchronizationInstanceMapOutput

type SynchronizationInstanceOutput 

type SynchronizationInstanceOutput struct{ *pulumi.OutputState }

func (SynchronizationInstanceOutput) AutoPay 

func (o SynchronizationInstanceOutput) AutoPay() pulumi.StringPtrOutput

Whether to automatically renew when it expires. Valid values: `true`, `false`.

func (SynchronizationInstanceOutput) AutoStart 

func (o SynchronizationInstanceOutput) AutoStart() pulumi.StringPtrOutput

Whether to automatically start the task after the purchase completed. Valid values: `true`, `false`.

func (SynchronizationInstanceOutput) ComputeUnit 

func (o SynchronizationInstanceOutput) ComputeUnit() pulumi.IntPtrOutput

[ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.

func (SynchronizationInstanceOutput) DatabaseCount 

func (o SynchronizationInstanceOutput) DatabaseCount() pulumi.IntPtrOutput

The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.

func (SynchronizationInstanceOutput) DestinationEndpointEngineName 

func (o SynchronizationInstanceOutput) DestinationEndpointEngineName() pulumi.StringOutput

The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).

func (SynchronizationInstanceOutput) DestinationEndpointRegion 

func (o SynchronizationInstanceOutput) DestinationEndpointRegion() pulumi.StringOutput

The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).

func (SynchronizationInstanceOutput) ElementType 

func (SynchronizationInstanceOutput) ElementType() reflect.Type

func (SynchronizationInstanceOutput) InstanceClass 

func (o SynchronizationInstanceOutput) InstanceClass() pulumi.StringOutput

The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).

func (SynchronizationInstanceOutput) PaymentDuration 

func (o SynchronizationInstanceOutput) PaymentDuration() pulumi.IntPtrOutput

The duration of prepaid instance purchase. this parameter is required When `paymentType` equals `Subscription`.

func (SynchronizationInstanceOutput) PaymentDurationUnit 

func (o SynchronizationInstanceOutput) PaymentDurationUnit() pulumi.StringPtrOutput

The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.

func (SynchronizationInstanceOutput) PaymentType 

func (o SynchronizationInstanceOutput) PaymentType() pulumi.StringOutput

The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.

func (SynchronizationInstanceOutput) Quantity 

func (o SynchronizationInstanceOutput) Quantity() pulumi.IntPtrOutput

The number of instances purchased.

func (SynchronizationInstanceOutput) SourceEndpointEngineName 

func (o SynchronizationInstanceOutput) SourceEndpointEngineName() pulumi.StringOutput

The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).

func (SynchronizationInstanceOutput) SourceEndpointRegion 

func (o SynchronizationInstanceOutput) SourceEndpointRegion() pulumi.StringOutput

The region of source instance.

func (SynchronizationInstanceOutput) Status 

func (o SynchronizationInstanceOutput) Status() pulumi.StringOutput

The status.

func (SynchronizationInstanceOutput) SyncArchitecture 

func (o SynchronizationInstanceOutput) SyncArchitecture() pulumi.StringPtrOutput

The sync architecture. Valid values: `oneway`, `bidirectional`.

func (SynchronizationInstanceOutput) ToSynchronizationInstanceOutput 

func (o SynchronizationInstanceOutput) ToSynchronizationInstanceOutput() SynchronizationInstanceOutput

func (SynchronizationInstanceOutput) ToSynchronizationInstanceOutputWithContext 

func (o SynchronizationInstanceOutput) ToSynchronizationInstanceOutputWithContext(ctx context.Context) SynchronizationInstanceOutput

type SynchronizationInstanceState 

type SynchronizationInstanceState struct {
	// Whether to automatically renew when it expires. Valid values: `true`, `false`.
	AutoPay pulumi.StringPtrInput
	// Whether to automatically start the task after the purchase completed. Valid values: `true`, `false`.
	AutoStart pulumi.StringPtrInput
	// [ETL specifications](https://help.aliyun.com/document_detail/212324.html). The unit is the computing unit ComputeUnit (CU), 1CU=1vCPU+4 GB memory. The value range is an integer greater than or equal to 2.
	ComputeUnit pulumi.IntPtrInput
	// The number of private customized RDS instances under PolarDB-X. The default value is 1. This parameter needs to be passed only when `sourceEndpointEngineName` equals `drds`.
	DatabaseCount pulumi.IntPtrInput
	// The type of destination engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	DestinationEndpointEngineName pulumi.StringPtrInput
	// The region of destination instance. List of [supported regions](https://help.aliyun.com/document_detail/141033.html).
	DestinationEndpointRegion pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringPtrInput
	// The duration of prepaid instance purchase. this parameter is required When `paymentType` equals `Subscription`.
	PaymentDuration pulumi.IntPtrInput
	// The payment duration unit. Valid values: `Month`, `Year`. When `paymentType` is `Subscription`, this parameter is valid and must be passed in.
	PaymentDurationUnit pulumi.StringPtrInput
	// The payment type of the resource. Valid values: `Subscription`, `PayAsYouGo`.
	PaymentType pulumi.StringPtrInput
	// The number of instances purchased.
	Quantity pulumi.IntPtrInput
	// The type of source endpoint engine. Valid values: `ADS`, `DB2`, `DRDS`, `DataHub`, `Greenplum`, `MSSQL`, `MySQL`, `PolarDB`, `PostgreSQL`, `Redis`, `Tablestore`, `as400`, `clickhouse`, `kafka`, `mongodb`, `odps`, `oracle`, `polardbO`, `polardbPg`, `tidb`. For the correspondence between the supported source and target libraries, see [Supported Databases, Synchronization Initialization Types and Synchronization Topologies](https://help.aliyun.com/document_detail/130744.html), [Supported Databases and Migration Types](https://help.aliyun.com/document_detail/26618.html).
	SourceEndpointEngineName pulumi.StringPtrInput
	// The region of source instance.
	SourceEndpointRegion pulumi.StringPtrInput
	// The status.
	Status pulumi.StringPtrInput
	// The sync architecture. Valid values: `oneway`, `bidirectional`.
	SyncArchitecture pulumi.StringPtrInput
}

func (SynchronizationInstanceState) ElementType 

func (SynchronizationInstanceState) ElementType() reflect.Type

type SynchronizationJob 

type SynchronizationJob struct {
	pulumi.CustomResourceState

	// The start point or synchronization point of incremental data migration, the format is Unix timestamp, and the unit is seconds.
	Checkpoint pulumi.StringOutput `pulumi:"checkpoint"`
	// Whether to perform full data migration or full data initialization. Valid values: `true`, `false`.
	DataInitialization pulumi.BoolOutput `pulumi:"dataInitialization"`
	// Whether to perform incremental data migration or synchronization. Valid values: `true`, `false`.
	DataSynchronization pulumi.BoolOutput `pulumi:"dataSynchronization"`
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, synchronization or subscription objects](https://help.aliyun.com/document_detail/209545.html). **NOTE:** From version 1.173.0, `dbList` can be modified.
	DbList pulumi.StringOutput `pulumi:"dbList"`
	// The delay notice. Valid values: `true`, `false`.
	DelayNotice pulumi.BoolPtrOutput `pulumi:"delayNotice"`
	// The delay phone. The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	DelayPhone pulumi.StringPtrOutput `pulumi:"delayPhone"`
	// The delay rule time. When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.
	DelayRuleTime pulumi.StringPtrOutput `pulumi:"delayRuleTime"`
	// The name of the database to which the migration object belongs in the target instance. Note: when the target instance or target database type is PolarDB O engine, AnalyticDB PostgreSQL, PostgreSQL, MongoDB database, this parameter is available and must be passed in.
	DestinationEndpointDatabaseName pulumi.StringPtrOutput `pulumi:"destinationEndpointDatabaseName"`
	// The type of destination database. The default value is MYSQL. For the correspondence between supported target libraries and source libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the target instance is KAFKA or MONGODB, you also need to pass in some information in the reserved parameter `reserve`. For the configuration method, see the description of `reserve` parameters. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName pulumi.StringOutput `pulumi:"destinationEndpointEngineName"`
	// The ID of destination instance. If the target instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the target instance is a self-built database, the value of this parameter changes according to the value of `destinationEndpointInstanceType`. For example, the value of `destinationEndpointInstanceType` is:
	// ** `ECS`, then this parameter needs to be passed into the instance ID of ECS.
	// ** `DG`, then this parameter needs to be passed into the ID of database gateway.
	// ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.
	DestinationEndpointInstanceId pulumi.StringPtrOutput `pulumi:"destinationEndpointInstanceId"`
	// The type of destination instance. If the target instance is a PolarDB O engine cluster, the target instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. If the target instance is the Kafka version of Message Queuing, the target instance type needs to be `ECS` or `EXPRESS` as a self-built database, and access via ECS or dedicated line. For the correspondence between supported targets and source instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the target instance is a self-built database, you also need to perform corresponding preparations, please refer to the [overview of preparations](https://help.aliyun.com/document_detail/146958.htm). Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType pulumi.StringOutput `pulumi:"destinationEndpointInstanceType"`
	// The IP of source endpoint. When `destinationEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.
	DestinationEndpointIp pulumi.StringPtrOutput `pulumi:"destinationEndpointIp"`
	// The SID of Oracle database. Note: when the value of DestinationEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	DestinationEndpointOracleSid pulumi.StringPtrOutput `pulumi:"destinationEndpointOracleSid"`
	// The password of database account.
	DestinationEndpointPassword pulumi.StringPtrOutput `pulumi:"destinationEndpointPassword"`
	// The port of source endpoint. When the target instance is a self-built database, this parameter is available and must be passed in.
	DestinationEndpointPort pulumi.StringPtrOutput `pulumi:"destinationEndpointPort"`
	// The region of destination instance. For the target instance region, please refer to the [list of supported regions](https://help.aliyun.com/document_detail/141033.htm). Note: if the target is an Alibaba Cloud database, this parameter must be passed in.
	DestinationEndpointRegion pulumi.StringPtrOutput `pulumi:"destinationEndpointRegion"`
	// The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).
	DestinationEndpointUserName pulumi.StringPtrOutput `pulumi:"destinationEndpointUserName"`
	// The ID of synchronization instance, it must be an ID of `dts.SynchronizationInstance`.
	DtsInstanceId pulumi.StringOutput `pulumi:"dtsInstanceId"`
	// The name of synchronization job.
	DtsJobName pulumi.StringOutput `pulumi:"dtsJobName"`
	// The error notice. Valid values: `true`, `false`.
	ErrorNotice pulumi.BoolPtrOutput `pulumi:"errorNotice"`
	// The error phone. The mobile phone number of the contact who error the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	ErrorPhone pulumi.StringPtrOutput `pulumi:"errorPhone"`
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringOutput `pulumi:"instanceClass"`
	// DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter [description of the Reserve parameter](https://help.aliyun.com/document_detail/273111.html).
	Reserve pulumi.StringOutput `pulumi:"reserve"`
	// The name of the database to which the migration object belongs in the source instance. Note: this parameter is only available and must be passed in when the source instance, or the database type of the source instance is PolarDB O engine, PostgreSQL, or MongoDB database.
	SourceEndpointDatabaseName pulumi.StringPtrOutput `pulumi:"sourceEndpointDatabaseName"`
	// The type of source database. The default value is `MySQL`. For the correspondence between supported source libraries and target libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the source instance is `MONGODB`, you also need to pass in some information in the reserved parameter `Reserve`, for the configuration method, see the description of Reserve parameters. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName pulumi.StringOutput `pulumi:"sourceEndpointEngineName"`
	// The ID of source instance. If the source instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the source instance is a self-built database, the value of this parameter changes according to the value of `sourceEndpointInstanceType`. For example, the value of `sourceEndpointInstanceType` is:
	// ** `ECS`, then this parameter needs to be passed into the instance ID of ECS.
	// ** `DG`, then this parameter needs to be passed into the ID of database gateway.
	// ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.
	SourceEndpointInstanceId pulumi.StringPtrOutput `pulumi:"sourceEndpointInstanceId"`
	// The type of source instance. If the source instance is a `PolarDB O` engine cluster, the source instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. For the correspondence between supported source and target instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the source instance is a self-built database, you also need to perform corresponding preparations, for details, see [Preparations Overview](https://help.aliyun.com/document_detail/146958.htm). Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType pulumi.StringOutput `pulumi:"sourceEndpointInstanceType"`
	// The IP of source endpoint. When `sourceEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.
	SourceEndpointIp pulumi.StringPtrOutput `pulumi:"sourceEndpointIp"`
	// The SID of Oracle database. When the value of SourceEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid pulumi.StringPtrOutput `pulumi:"sourceEndpointOracleSid"`
	// The ID of Alibaba Cloud account to which the source instance belongs. Note: passing in this parameter means performing data migration or synchronization across Alibaba Cloud accounts, and you also need to pass in the `sourceEndpointRole` parameter.
	SourceEndpointOwnerId pulumi.StringPtrOutput `pulumi:"sourceEndpointOwnerId"`
	// The password of database account.
	SourceEndpointPassword pulumi.StringPtrOutput `pulumi:"sourceEndpointPassword"`
	// The port of source endpoint. When the source instance is a self-built database, this parameter is available and must be passed in.
	SourceEndpointPort pulumi.StringPtrOutput `pulumi:"sourceEndpointPort"`
	// Source instance area, please refer to the [list of supported areas](https://help.aliyun.com/document_detail/141033.htm) for details. Note if the source is an Alibaba Cloud database, this parameter must be passed in.
	SourceEndpointRegion pulumi.StringPtrOutput `pulumi:"sourceEndpointRegion"`
	// The name of the role configured for the cloud account to which the source instance belongs. Note: this parameter must be passed in when performing cross Alibaba Cloud account data migration or synchronization. For the permissions and authorization methods required by this role, please refer to [How to configure RAM authorization when cross-Alibaba Cloud account data migration or synchronization](https://help.aliyun.com/document_detail/48468.htm).
	SourceEndpointRole pulumi.StringPtrOutput `pulumi:"sourceEndpointRole"`
	// The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).
	SourceEndpointUserName pulumi.StringPtrOutput `pulumi:"sourceEndpointUserName"`
	// The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.
	Status pulumi.StringOutput `pulumi:"status"`
	// Whether to perform library table structure migration or initialization. Valid values: `true`, `false`.
	StructureInitialization pulumi.BoolOutput `pulumi:"structureInitialization"`
	// Synchronization direction. Valid values: `Forward`, `Reverse`. Only when the property `syncArchitecture` of the `dts.SynchronizationInstance` was `bidirectional` this parameter should be passed, otherwise this parameter should not be specified.
	SynchronizationDirection pulumi.StringOutput `pulumi:"synchronizationDirection"`
}

Provides a DTS Synchronization Job resource.

For information about DTS Synchronization Job and how to use it, see [What is Synchronization Job](https://www.alibabacloud.com/product/data-transmission-service).

> **NOTE:** Available in v1.138.0+.

## Example Usage

Basic Usage

```go package main

import ( 

"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
"github.com/rhysmdnz/pulumi-alicloud/sdk/go/alicloud/dts"

) 

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		defaultSynchronizationInstance, err := dts.NewSynchronizationInstance(ctx, "defaultSynchronizationInstance", &dts.SynchronizationInstanceArgs{
			PaymentType:                   pulumi.String("PayAsYouGo"),
			SourceEndpointEngineName:      pulumi.String("PolarDB"),
			SourceEndpointRegion:          pulumi.String("cn-hangzhou"),
			DestinationEndpointEngineName: pulumi.String("ADB30"),
			DestinationEndpointRegion:     pulumi.String("cn-hangzhou"),
			InstanceClass:                 pulumi.String("small"),
			SyncArchitecture:              pulumi.String("oneway"),
		})
		if err != nil {
			return err
		}
		_, err = dts.NewSynchronizationJob(ctx, "defaultSynchronizationJob", &dts.SynchronizationJobArgs{
			DtsInstanceId:                   defaultSynchronizationInstance.ID(),
			DtsJobName:                      pulumi.String("tf-testAccCase1"),
			SourceEndpointInstanceType:      pulumi.String("PolarDB"),
			SourceEndpointInstanceId:        pulumi.String("pc-xxxxxxxx"),
			SourceEndpointEngineName:        pulumi.String("PolarDB"),
			SourceEndpointRegion:            pulumi.String("cn-hangzhou"),
			SourceEndpointDatabaseName:      pulumi.String("tf-testacc"),
			SourceEndpointUserName:          pulumi.String("root"),
			SourceEndpointPassword:          pulumi.String("password"),
			DestinationEndpointInstanceType: pulumi.String("ads"),
			DestinationEndpointInstanceId:   pulumi.String("am-xxxxxxxx"),
			DestinationEndpointEngineName:   pulumi.String("ADB30"),
			DestinationEndpointRegion:       pulumi.String("cn-hangzhou"),
			DestinationEndpointDatabaseName: pulumi.String("tf-testacc"),
			DestinationEndpointUserName:     pulumi.String("root"),
			DestinationEndpointPassword:     pulumi.String("password"),
			DbList:                          pulumi.String("{\"tf-testacc\":{\"name\":\"tf-test\",\"all\":true,\"state\":\"normal\"}}"),
			StructureInitialization:         pulumi.Bool(true),
			DataInitialization:              pulumi.Bool(true),
			DataSynchronization:             pulumi.Bool(true),
			Status:                          pulumi.String("Synchronizing"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

``` ## Notice

1. The expiration time cannot be changed after the work of the annual and monthly subscription suspended; 2. After the pay-as-you-go type job suspended, your job configuration fee will still be charged; 3. If the task suspended for more than 6 hours, the task will not start successfully. 4. Suspending the task will only stop writing to the target library, but will still continue to obtain the incremental log of the source, so that the task can be quickly resumed after the suspension is canceled. Therefore, some resources of the source library, such as bandwidth resources, will continue to be occupied during the period. 5. Charges will continue during the task suspension period. If you need to stop charging, please release the instance 6. When a DTS instance suspended for more than 7 days, the instance cannot be resumed, and the status will change from suspended to failed.

## Import

DTS Synchronization Job can be imported using the id, e.g.

```sh 

$ pulumi import alicloud:dts/synchronizationJob:SynchronizationJob example <id>

```

func GetSynchronizationJob 

func GetSynchronizationJob(ctx *pulumi.Context,
	name string, id pulumi.IDInput, state *SynchronizationJobState, opts ...pulumi.ResourceOption) (*SynchronizationJob, error)

GetSynchronizationJob gets an existing SynchronizationJob 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 NewSynchronizationJob 

func NewSynchronizationJob(ctx *pulumi.Context,
	name string, args *SynchronizationJobArgs, opts ...pulumi.ResourceOption) (*SynchronizationJob, error)

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

func (*SynchronizationJob) ElementType 

func (*SynchronizationJob) ElementType() reflect.Type

func (*SynchronizationJob) ToSynchronizationJobOutput 

func (i *SynchronizationJob) ToSynchronizationJobOutput() SynchronizationJobOutput

func (*SynchronizationJob) ToSynchronizationJobOutputWithContext 

func (i *SynchronizationJob) ToSynchronizationJobOutputWithContext(ctx context.Context) SynchronizationJobOutput

type SynchronizationJobArgs 

type SynchronizationJobArgs struct {
	// The start point or synchronization point of incremental data migration, the format is Unix timestamp, and the unit is seconds.
	Checkpoint pulumi.StringPtrInput
	// Whether to perform full data migration or full data initialization. Valid values: `true`, `false`.
	DataInitialization pulumi.BoolInput
	// Whether to perform incremental data migration or synchronization. Valid values: `true`, `false`.
	DataSynchronization pulumi.BoolInput
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, synchronization or subscription objects](https://help.aliyun.com/document_detail/209545.html). **NOTE:** From version 1.173.0, `dbList` can be modified.
	DbList pulumi.StringInput
	// The delay notice. Valid values: `true`, `false`.
	DelayNotice pulumi.BoolPtrInput
	// The delay phone. The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	DelayPhone pulumi.StringPtrInput
	// The delay rule time. When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.
	DelayRuleTime pulumi.StringPtrInput
	// The name of the database to which the migration object belongs in the target instance. Note: when the target instance or target database type is PolarDB O engine, AnalyticDB PostgreSQL, PostgreSQL, MongoDB database, this parameter is available and must be passed in.
	DestinationEndpointDatabaseName pulumi.StringPtrInput
	// The type of destination database. The default value is MYSQL. For the correspondence between supported target libraries and source libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the target instance is KAFKA or MONGODB, you also need to pass in some information in the reserved parameter `reserve`. For the configuration method, see the description of `reserve` parameters. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName pulumi.StringInput
	// The ID of destination instance. If the target instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the target instance is a self-built database, the value of this parameter changes according to the value of `destinationEndpointInstanceType`. For example, the value of `destinationEndpointInstanceType` is:
	// ** `ECS`, then this parameter needs to be passed into the instance ID of ECS.
	// ** `DG`, then this parameter needs to be passed into the ID of database gateway.
	// ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.
	DestinationEndpointInstanceId pulumi.StringPtrInput
	// The type of destination instance. If the target instance is a PolarDB O engine cluster, the target instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. If the target instance is the Kafka version of Message Queuing, the target instance type needs to be `ECS` or `EXPRESS` as a self-built database, and access via ECS or dedicated line. For the correspondence between supported targets and source instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the target instance is a self-built database, you also need to perform corresponding preparations, please refer to the [overview of preparations](https://help.aliyun.com/document_detail/146958.htm). Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType pulumi.StringInput
	// The IP of source endpoint. When `destinationEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.
	DestinationEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database. Note: when the value of DestinationEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	DestinationEndpointOracleSid pulumi.StringPtrInput
	// The password of database account.
	DestinationEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint. When the target instance is a self-built database, this parameter is available and must be passed in.
	DestinationEndpointPort pulumi.StringPtrInput
	// The region of destination instance. For the target instance region, please refer to the [list of supported regions](https://help.aliyun.com/document_detail/141033.htm). Note: if the target is an Alibaba Cloud database, this parameter must be passed in.
	DestinationEndpointRegion pulumi.StringPtrInput
	// The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).
	DestinationEndpointUserName pulumi.StringPtrInput
	// The ID of synchronization instance, it must be an ID of `dts.SynchronizationInstance`.
	DtsInstanceId pulumi.StringInput
	// The name of synchronization job.
	DtsJobName pulumi.StringInput
	// The error notice. Valid values: `true`, `false`.
	ErrorNotice pulumi.BoolPtrInput
	// The error phone. The mobile phone number of the contact who error the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	ErrorPhone pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringPtrInput
	// DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter [description of the Reserve parameter](https://help.aliyun.com/document_detail/273111.html).
	Reserve pulumi.StringPtrInput
	// The name of the database to which the migration object belongs in the source instance. Note: this parameter is only available and must be passed in when the source instance, or the database type of the source instance is PolarDB O engine, PostgreSQL, or MongoDB database.
	SourceEndpointDatabaseName pulumi.StringPtrInput
	// The type of source database. The default value is `MySQL`. For the correspondence between supported source libraries and target libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the source instance is `MONGODB`, you also need to pass in some information in the reserved parameter `Reserve`, for the configuration method, see the description of Reserve parameters. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName pulumi.StringInput
	// The ID of source instance. If the source instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the source instance is a self-built database, the value of this parameter changes according to the value of `sourceEndpointInstanceType`. For example, the value of `sourceEndpointInstanceType` is:
	// ** `ECS`, then this parameter needs to be passed into the instance ID of ECS.
	// ** `DG`, then this parameter needs to be passed into the ID of database gateway.
	// ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.
	SourceEndpointInstanceId pulumi.StringPtrInput
	// The type of source instance. If the source instance is a `PolarDB O` engine cluster, the source instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. For the correspondence between supported source and target instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the source instance is a self-built database, you also need to perform corresponding preparations, for details, see [Preparations Overview](https://help.aliyun.com/document_detail/146958.htm). Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType pulumi.StringInput
	// The IP of source endpoint. When `sourceEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.
	SourceEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database. When the value of SourceEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid pulumi.StringPtrInput
	// The ID of Alibaba Cloud account to which the source instance belongs. Note: passing in this parameter means performing data migration or synchronization across Alibaba Cloud accounts, and you also need to pass in the `sourceEndpointRole` parameter.
	SourceEndpointOwnerId pulumi.StringPtrInput
	// The password of database account.
	SourceEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint. When the source instance is a self-built database, this parameter is available and must be passed in.
	SourceEndpointPort pulumi.StringPtrInput
	// Source instance area, please refer to the [list of supported areas](https://help.aliyun.com/document_detail/141033.htm) for details. Note if the source is an Alibaba Cloud database, this parameter must be passed in.
	SourceEndpointRegion pulumi.StringPtrInput
	// The name of the role configured for the cloud account to which the source instance belongs. Note: this parameter must be passed in when performing cross Alibaba Cloud account data migration or synchronization. For the permissions and authorization methods required by this role, please refer to [How to configure RAM authorization when cross-Alibaba Cloud account data migration or synchronization](https://help.aliyun.com/document_detail/48468.htm).
	SourceEndpointRole pulumi.StringPtrInput
	// The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).
	SourceEndpointUserName pulumi.StringPtrInput
	// The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.
	Status pulumi.StringPtrInput
	// Whether to perform library table structure migration or initialization. Valid values: `true`, `false`.
	StructureInitialization pulumi.BoolInput
	// Synchronization direction. Valid values: `Forward`, `Reverse`. Only when the property `syncArchitecture` of the `dts.SynchronizationInstance` was `bidirectional` this parameter should be passed, otherwise this parameter should not be specified.
	SynchronizationDirection pulumi.StringPtrInput
}

The set of arguments for constructing a SynchronizationJob resource.

func (SynchronizationJobArgs) ElementType 

func (SynchronizationJobArgs) ElementType() reflect.Type

type SynchronizationJobArray 

type SynchronizationJobArray []SynchronizationJobInput

func (SynchronizationJobArray) ElementType 

func (SynchronizationJobArray) ElementType() reflect.Type

func (SynchronizationJobArray) ToSynchronizationJobArrayOutput 

func (i SynchronizationJobArray) ToSynchronizationJobArrayOutput() SynchronizationJobArrayOutput

func (SynchronizationJobArray) ToSynchronizationJobArrayOutputWithContext 

func (i SynchronizationJobArray) ToSynchronizationJobArrayOutputWithContext(ctx context.Context) SynchronizationJobArrayOutput

type SynchronizationJobArrayInput 

type SynchronizationJobArrayInput interface {
	pulumi.Input

	ToSynchronizationJobArrayOutput() SynchronizationJobArrayOutput
	ToSynchronizationJobArrayOutputWithContext(context.Context) SynchronizationJobArrayOutput
}

SynchronizationJobArrayInput is an input type that accepts SynchronizationJobArray and SynchronizationJobArrayOutput values. You can construct a concrete instance of `SynchronizationJobArrayInput` via: 

SynchronizationJobArray{ SynchronizationJobArgs{...} }

type SynchronizationJobArrayOutput 

type SynchronizationJobArrayOutput struct{ *pulumi.OutputState }

func (SynchronizationJobArrayOutput) ElementType 

func (SynchronizationJobArrayOutput) ElementType() reflect.Type

func (SynchronizationJobArrayOutput) Index 

func (o SynchronizationJobArrayOutput) Index(i pulumi.IntInput) SynchronizationJobOutput

func (SynchronizationJobArrayOutput) ToSynchronizationJobArrayOutput 

func (o SynchronizationJobArrayOutput) ToSynchronizationJobArrayOutput() SynchronizationJobArrayOutput

func (SynchronizationJobArrayOutput) ToSynchronizationJobArrayOutputWithContext 

func (o SynchronizationJobArrayOutput) ToSynchronizationJobArrayOutputWithContext(ctx context.Context) SynchronizationJobArrayOutput

type SynchronizationJobInput 

type SynchronizationJobInput interface {
	pulumi.Input

	ToSynchronizationJobOutput() SynchronizationJobOutput
	ToSynchronizationJobOutputWithContext(ctx context.Context) SynchronizationJobOutput
}

type SynchronizationJobMap 

type SynchronizationJobMap map[string]SynchronizationJobInput

func (SynchronizationJobMap) ElementType 

func (SynchronizationJobMap) ElementType() reflect.Type

func (SynchronizationJobMap) ToSynchronizationJobMapOutput 

func (i SynchronizationJobMap) ToSynchronizationJobMapOutput() SynchronizationJobMapOutput

func (SynchronizationJobMap) ToSynchronizationJobMapOutputWithContext 

func (i SynchronizationJobMap) ToSynchronizationJobMapOutputWithContext(ctx context.Context) SynchronizationJobMapOutput

type SynchronizationJobMapInput 

type SynchronizationJobMapInput interface {
	pulumi.Input

	ToSynchronizationJobMapOutput() SynchronizationJobMapOutput
	ToSynchronizationJobMapOutputWithContext(context.Context) SynchronizationJobMapOutput
}

SynchronizationJobMapInput is an input type that accepts SynchronizationJobMap and SynchronizationJobMapOutput values. You can construct a concrete instance of `SynchronizationJobMapInput` via: 

SynchronizationJobMap{ "key": SynchronizationJobArgs{...} }

type SynchronizationJobMapOutput 

type SynchronizationJobMapOutput struct{ *pulumi.OutputState }

func (SynchronizationJobMapOutput) ElementType 

func (SynchronizationJobMapOutput) ElementType() reflect.Type

func (SynchronizationJobMapOutput) MapIndex 

func (o SynchronizationJobMapOutput) MapIndex(k pulumi.StringInput) SynchronizationJobOutput

func (SynchronizationJobMapOutput) ToSynchronizationJobMapOutput 

func (o SynchronizationJobMapOutput) ToSynchronizationJobMapOutput() SynchronizationJobMapOutput

func (SynchronizationJobMapOutput) ToSynchronizationJobMapOutputWithContext 

func (o SynchronizationJobMapOutput) ToSynchronizationJobMapOutputWithContext(ctx context.Context) SynchronizationJobMapOutput

type SynchronizationJobOutput 

type SynchronizationJobOutput struct{ *pulumi.OutputState }

func (SynchronizationJobOutput) Checkpoint 

func (o SynchronizationJobOutput) Checkpoint() pulumi.StringOutput

The start point or synchronization point of incremental data migration, the format is Unix timestamp, and the unit is seconds.

func (SynchronizationJobOutput) DataInitialization 

func (o SynchronizationJobOutput) DataInitialization() pulumi.BoolOutput

Whether to perform full data migration or full data initialization. Valid values: `true`, `false`.

func (SynchronizationJobOutput) DataSynchronization 

func (o SynchronizationJobOutput) DataSynchronization() pulumi.BoolOutput

Whether to perform incremental data migration or synchronization. Valid values: `true`, `false`.

func (SynchronizationJobOutput) DbList 

func (o SynchronizationJobOutput) DbList() pulumi.StringOutput

Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, synchronization or subscription objects](https://help.aliyun.com/document_detail/209545.html). **NOTE:** From version 1.173.0, `dbList` can be modified.

func (SynchronizationJobOutput) DelayNotice 

func (o SynchronizationJobOutput) DelayNotice() pulumi.BoolPtrOutput

The delay notice. Valid values: `true`, `false`.

func (SynchronizationJobOutput) DelayPhone 

func (o SynchronizationJobOutput) DelayPhone() pulumi.StringPtrOutput

The delay phone. The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.

func (SynchronizationJobOutput) DelayRuleTime 

func (o SynchronizationJobOutput) DelayRuleTime() pulumi.StringPtrOutput

The delay rule time. When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.

func (SynchronizationJobOutput) DestinationEndpointDatabaseName 

func (o SynchronizationJobOutput) DestinationEndpointDatabaseName() pulumi.StringPtrOutput

The name of the database to which the migration object belongs in the target instance. Note: when the target instance or target database type is PolarDB O engine, AnalyticDB PostgreSQL, PostgreSQL, MongoDB database, this parameter is available and must be passed in.

func (SynchronizationJobOutput) DestinationEndpointEngineName 

func (o SynchronizationJobOutput) DestinationEndpointEngineName() pulumi.StringOutput

The type of destination database. The default value is MYSQL. For the correspondence between supported target libraries and source libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the target instance is KAFKA or MONGODB, you also need to pass in some information in the reserved parameter `reserve`. For the configuration method, see the description of `reserve` parameters. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.

func (SynchronizationJobOutput) DestinationEndpointInstanceId 

func (o SynchronizationJobOutput) DestinationEndpointInstanceId() pulumi.StringPtrOutput

The ID of destination instance. If the target instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the target instance is a self-built database, the value of this parameter changes according to the value of `destinationEndpointInstanceType`. For example, the value of `destinationEndpointInstanceType` is: ** `ECS`, then this parameter needs to be passed into the instance ID of ECS. ** `DG`, then this parameter needs to be passed into the ID of database gateway. ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.

func (SynchronizationJobOutput) DestinationEndpointInstanceType 

func (o SynchronizationJobOutput) DestinationEndpointInstanceType() pulumi.StringOutput

The type of destination instance. If the target instance is a PolarDB O engine cluster, the target instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. If the target instance is the Kafka version of Message Queuing, the target instance type needs to be `ECS` or `EXPRESS` as a self-built database, and access via ECS or dedicated line. For the correspondence between supported targets and source instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the target instance is a self-built database, you also need to perform corresponding preparations, please refer to the [overview of preparations](https://help.aliyun.com/document_detail/146958.htm). Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.

func (SynchronizationJobOutput) DestinationEndpointIp 

func (o SynchronizationJobOutput) DestinationEndpointIp() pulumi.StringPtrOutput

The IP of source endpoint. When `destinationEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.

func (SynchronizationJobOutput) DestinationEndpointOracleSid 

func (o SynchronizationJobOutput) DestinationEndpointOracleSid() pulumi.StringPtrOutput

The SID of Oracle database. Note: when the value of DestinationEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.

func (SynchronizationJobOutput) DestinationEndpointPassword 

func (o SynchronizationJobOutput) DestinationEndpointPassword() pulumi.StringPtrOutput

The password of database account.

func (SynchronizationJobOutput) DestinationEndpointPort 

func (o SynchronizationJobOutput) DestinationEndpointPort() pulumi.StringPtrOutput

The port of source endpoint. When the target instance is a self-built database, this parameter is available and must be passed in.

func (SynchronizationJobOutput) DestinationEndpointRegion 

func (o SynchronizationJobOutput) DestinationEndpointRegion() pulumi.StringPtrOutput

The region of destination instance. For the target instance region, please refer to the [list of supported regions](https://help.aliyun.com/document_detail/141033.htm). Note: if the target is an Alibaba Cloud database, this parameter must be passed in.

func (SynchronizationJobOutput) DestinationEndpointUserName 

func (o SynchronizationJobOutput) DestinationEndpointUserName() pulumi.StringPtrOutput

The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).

func (SynchronizationJobOutput) DtsInstanceId 

func (o SynchronizationJobOutput) DtsInstanceId() pulumi.StringOutput

The ID of synchronization instance, it must be an ID of `dts.SynchronizationInstance`.

func (SynchronizationJobOutput) DtsJobName 

func (o SynchronizationJobOutput) DtsJobName() pulumi.StringOutput

The name of synchronization job.

func (SynchronizationJobOutput) ElementType 

func (SynchronizationJobOutput) ElementType() reflect.Type

func (SynchronizationJobOutput) ErrorNotice 

func (o SynchronizationJobOutput) ErrorNotice() pulumi.BoolPtrOutput

The error notice. Valid values: `true`, `false`.

func (SynchronizationJobOutput) ErrorPhone 

func (o SynchronizationJobOutput) ErrorPhone() pulumi.StringPtrOutput

The error phone. The mobile phone number of the contact who error the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.

func (SynchronizationJobOutput) InstanceClass 

func (o SynchronizationJobOutput) InstanceClass() pulumi.StringOutput

The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).

func (SynchronizationJobOutput) Reserve 

func (o SynchronizationJobOutput) Reserve() pulumi.StringOutput

DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter [description of the Reserve parameter](https://help.aliyun.com/document_detail/273111.html).

func (SynchronizationJobOutput) SourceEndpointDatabaseName 

func (o SynchronizationJobOutput) SourceEndpointDatabaseName() pulumi.StringPtrOutput

The name of the database to which the migration object belongs in the source instance. Note: this parameter is only available and must be passed in when the source instance, or the database type of the source instance is PolarDB O engine, PostgreSQL, or MongoDB database.

func (SynchronizationJobOutput) SourceEndpointEngineName 

func (o SynchronizationJobOutput) SourceEndpointEngineName() pulumi.StringOutput

The type of source database. The default value is `MySQL`. For the correspondence between supported source libraries and target libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the source instance is `MONGODB`, you also need to pass in some information in the reserved parameter `Reserve`, for the configuration method, see the description of Reserve parameters. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.

func (SynchronizationJobOutput) SourceEndpointInstanceId 

func (o SynchronizationJobOutput) SourceEndpointInstanceId() pulumi.StringPtrOutput

The ID of source instance. If the source instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the source instance is a self-built database, the value of this parameter changes according to the value of `sourceEndpointInstanceType`. For example, the value of `sourceEndpointInstanceType` is: ** `ECS`, then this parameter needs to be passed into the instance ID of ECS. ** `DG`, then this parameter needs to be passed into the ID of database gateway. ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.

func (SynchronizationJobOutput) SourceEndpointInstanceType 

func (o SynchronizationJobOutput) SourceEndpointInstanceType() pulumi.StringOutput

The type of source instance. If the source instance is a `PolarDB O` engine cluster, the source instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. For the correspondence between supported source and target instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the source instance is a self-built database, you also need to perform corresponding preparations, for details, see [Preparations Overview](https://help.aliyun.com/document_detail/146958.htm). Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.

func (SynchronizationJobOutput) SourceEndpointIp 

func (o SynchronizationJobOutput) SourceEndpointIp() pulumi.StringPtrOutput

The IP of source endpoint. When `sourceEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.

func (SynchronizationJobOutput) SourceEndpointOracleSid 

func (o SynchronizationJobOutput) SourceEndpointOracleSid() pulumi.StringPtrOutput

The SID of Oracle database. When the value of SourceEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.

func (SynchronizationJobOutput) SourceEndpointOwnerId 

func (o SynchronizationJobOutput) SourceEndpointOwnerId() pulumi.StringPtrOutput

The ID of Alibaba Cloud account to which the source instance belongs. Note: passing in this parameter means performing data migration or synchronization across Alibaba Cloud accounts, and you also need to pass in the `sourceEndpointRole` parameter.

func (SynchronizationJobOutput) SourceEndpointPassword 

func (o SynchronizationJobOutput) SourceEndpointPassword() pulumi.StringPtrOutput

The password of database account.

func (SynchronizationJobOutput) SourceEndpointPort 

func (o SynchronizationJobOutput) SourceEndpointPort() pulumi.StringPtrOutput

The port of source endpoint. When the source instance is a self-built database, this parameter is available and must be passed in.

func (SynchronizationJobOutput) SourceEndpointRegion 

func (o SynchronizationJobOutput) SourceEndpointRegion() pulumi.StringPtrOutput

Source instance area, please refer to the [list of supported areas](https://help.aliyun.com/document_detail/141033.htm) for details. Note if the source is an Alibaba Cloud database, this parameter must be passed in.

func (SynchronizationJobOutput) SourceEndpointRole 

func (o SynchronizationJobOutput) SourceEndpointRole() pulumi.StringPtrOutput

The name of the role configured for the cloud account to which the source instance belongs. Note: this parameter must be passed in when performing cross Alibaba Cloud account data migration or synchronization. For the permissions and authorization methods required by this role, please refer to [How to configure RAM authorization when cross-Alibaba Cloud account data migration or synchronization](https://help.aliyun.com/document_detail/48468.htm).

func (SynchronizationJobOutput) SourceEndpointUserName 

func (o SynchronizationJobOutput) SourceEndpointUserName() pulumi.StringPtrOutput

The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).

func (SynchronizationJobOutput) Status 

func (o SynchronizationJobOutput) Status() pulumi.StringOutput

The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.

func (SynchronizationJobOutput) StructureInitialization 

func (o SynchronizationJobOutput) StructureInitialization() pulumi.BoolOutput

Whether to perform library table structure migration or initialization. Valid values: `true`, `false`.

func (SynchronizationJobOutput) SynchronizationDirection 

func (o SynchronizationJobOutput) SynchronizationDirection() pulumi.StringOutput

Synchronization direction. Valid values: `Forward`, `Reverse`. Only when the property `syncArchitecture` of the `dts.SynchronizationInstance` was `bidirectional` this parameter should be passed, otherwise this parameter should not be specified.

func (SynchronizationJobOutput) ToSynchronizationJobOutput 

func (o SynchronizationJobOutput) ToSynchronizationJobOutput() SynchronizationJobOutput

func (SynchronizationJobOutput) ToSynchronizationJobOutputWithContext 

func (o SynchronizationJobOutput) ToSynchronizationJobOutputWithContext(ctx context.Context) SynchronizationJobOutput

type SynchronizationJobState 

type SynchronizationJobState struct {
	// The start point or synchronization point of incremental data migration, the format is Unix timestamp, and the unit is seconds.
	Checkpoint pulumi.StringPtrInput
	// Whether to perform full data migration or full data initialization. Valid values: `true`, `false`.
	DataInitialization pulumi.BoolPtrInput
	// Whether to perform incremental data migration or synchronization. Valid values: `true`, `false`.
	DataSynchronization pulumi.BoolPtrInput
	// Migration object, in the format of JSON strings. For detailed definition instructions, please refer to [the description of migration, synchronization or subscription objects](https://help.aliyun.com/document_detail/209545.html). **NOTE:** From version 1.173.0, `dbList` can be modified.
	DbList pulumi.StringPtrInput
	// The delay notice. Valid values: `true`, `false`.
	DelayNotice pulumi.BoolPtrInput
	// The delay phone. The mobile phone number of the contact who delayed the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	DelayPhone pulumi.StringPtrInput
	// The delay rule time. When `delayNotice` is set to `true`, this parameter must be passed in. The threshold for triggering the delay alarm. The unit is second and needs to be an integer. The threshold can be set according to business needs. It is recommended to set it above 10 seconds to avoid delay fluctuations caused by network and database load.
	DelayRuleTime pulumi.StringPtrInput
	// The name of the database to which the migration object belongs in the target instance. Note: when the target instance or target database type is PolarDB O engine, AnalyticDB PostgreSQL, PostgreSQL, MongoDB database, this parameter is available and must be passed in.
	DestinationEndpointDatabaseName pulumi.StringPtrInput
	// The type of destination database. The default value is MYSQL. For the correspondence between supported target libraries and source libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the target instance is KAFKA or MONGODB, you also need to pass in some information in the reserved parameter `reserve`. For the configuration method, see the description of `reserve` parameters. Valid values: `ADS`, `ADB30`, `AS400`, `DATAHUB`, `DB2`, `GREENPLUM`, `KAFKA`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `PostgreSQL`.
	DestinationEndpointEngineName pulumi.StringPtrInput
	// The ID of destination instance. If the target instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the target instance is a self-built database, the value of this parameter changes according to the value of `destinationEndpointInstanceType`. For example, the value of `destinationEndpointInstanceType` is:
	// ** `ECS`, then this parameter needs to be passed into the instance ID of ECS.
	// ** `DG`, then this parameter needs to be passed into the ID of database gateway.
	// ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.
	DestinationEndpointInstanceId pulumi.StringPtrInput
	// The type of destination instance. If the target instance is a PolarDB O engine cluster, the target instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. If the target instance is the Kafka version of Message Queuing, the target instance type needs to be `ECS` or `EXPRESS` as a self-built database, and access via ECS or dedicated line. For the correspondence between supported targets and source instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the target instance is a self-built database, you also need to perform corresponding preparations, please refer to the [overview of preparations](https://help.aliyun.com/document_detail/146958.htm). Valid values: `ADS`, `CEN`, `DATAHUB`, `DG`, `ECS`, `EXPRESS`, `GREENPLUM`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	DestinationEndpointInstanceType pulumi.StringPtrInput
	// The IP of source endpoint. When `destinationEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.
	DestinationEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database. Note: when the value of DestinationEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	DestinationEndpointOracleSid pulumi.StringPtrInput
	// The password of database account.
	DestinationEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint. When the target instance is a self-built database, this parameter is available and must be passed in.
	DestinationEndpointPort pulumi.StringPtrInput
	// The region of destination instance. For the target instance region, please refer to the [list of supported regions](https://help.aliyun.com/document_detail/141033.htm). Note: if the target is an Alibaba Cloud database, this parameter must be passed in.
	DestinationEndpointRegion pulumi.StringPtrInput
	// The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).
	DestinationEndpointUserName pulumi.StringPtrInput
	// The ID of synchronization instance, it must be an ID of `dts.SynchronizationInstance`.
	DtsInstanceId pulumi.StringPtrInput
	// The name of synchronization job.
	DtsJobName pulumi.StringPtrInput
	// The error notice. Valid values: `true`, `false`.
	ErrorNotice pulumi.BoolPtrInput
	// The error phone. The mobile phone number of the contact who error the alarm. Multiple mobile phone numbers separated by English commas `,`. This parameter currently only supports China stations, and only supports mainland mobile phone numbers, and up to 10 mobile phone numbers can be passed in.
	ErrorPhone pulumi.StringPtrInput
	// The instance class. Valid values: `large`, `medium`, `micro`, `small`, `xlarge`, `xxlarge`. You can only upgrade the configuration, not downgrade the configuration. If you downgrade the instance, you need to [submit a ticket](https://selfservice.console.aliyun.com/ticket/category/dts/today).
	InstanceClass pulumi.StringPtrInput
	// DTS reserves parameters, the format is a JSON string, you can pass in this parameter to complete the source and target database information (such as the data storage format of the target Kafka database, the instance ID of the cloud enterprise network CEN). For more information, please refer to the parameter [description of the Reserve parameter](https://help.aliyun.com/document_detail/273111.html).
	Reserve pulumi.StringPtrInput
	// The name of the database to which the migration object belongs in the source instance. Note: this parameter is only available and must be passed in when the source instance, or the database type of the source instance is PolarDB O engine, PostgreSQL, or MongoDB database.
	SourceEndpointDatabaseName pulumi.StringPtrInput
	// The type of source database. The default value is `MySQL`. For the correspondence between supported source libraries and target libraries, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the database type of the source instance is `MONGODB`, you also need to pass in some information in the reserved parameter `Reserve`, for the configuration method, see the description of Reserve parameters. Valid values: `AS400`, `DB2`, `DMSPOLARDB`, `HBASE`, `MONGODB`, `MSSQL`, `MySQL`, `ORACLE`, `PolarDB`, `POLARDBX20`, `POLARDB_O`, `POSTGRESQL`, `TERADATA`.
	SourceEndpointEngineName pulumi.StringPtrInput
	// The ID of source instance. If the source instance is a cloud database (such as RDS MySQL), you need to pass in the instance ID of the cloud database (such as the instance ID of RDS MySQL). If the source instance is a self-built database, the value of this parameter changes according to the value of `sourceEndpointInstanceType`. For example, the value of `sourceEndpointInstanceType` is:
	// ** `ECS`, then this parameter needs to be passed into the instance ID of ECS.
	// ** `DG`, then this parameter needs to be passed into the ID of database gateway.
	// ** `EXPRESS`, `CEN`, then this parameter needs to be passed in the ID of VPC that has been interconnected with the source database. **Note**: when the value is `CEN`, you also need to pass in the ID of CEN instance in the cloud enterprise network with the reserved parameter `reserve`.
	SourceEndpointInstanceId pulumi.StringPtrInput
	// The type of source instance. If the source instance is a `PolarDB O` engine cluster, the source instance type needs to be `OTHER` or `EXPRESS` as a self-built database, and access via public IP or dedicated line. For the correspondence between supported source and target instances, see [Supported Databases](https://help.aliyun.com/document_detail/131497.htm). When the source instance is a self-built database, you also need to perform corresponding preparations, for details, see [Preparations Overview](https://help.aliyun.com/document_detail/146958.htm). Valid values: `CEN`, `DG`, `DISTRIBUTED_DMSLOGICDB`, `ECS`, `EXPRESS`, `MONGODB`, `OTHER`, `PolarDB`, `POLARDBX20`, `RDS`.
	SourceEndpointInstanceType pulumi.StringPtrInput
	// The IP of source endpoint. When `sourceEndpointInstanceType` is `OTHER`, `EXPRESS`, `DG`, `CEN`, this parameter is available and must be passed in.
	SourceEndpointIp pulumi.StringPtrInput
	// The SID of Oracle database. When the value of SourceEndpointEngineName is Oracle and the Oracle database is a non-RAC instance, this parameter is available and must be passed in.
	SourceEndpointOracleSid pulumi.StringPtrInput
	// The ID of Alibaba Cloud account to which the source instance belongs. Note: passing in this parameter means performing data migration or synchronization across Alibaba Cloud accounts, and you also need to pass in the `sourceEndpointRole` parameter.
	SourceEndpointOwnerId pulumi.StringPtrInput
	// The password of database account.
	SourceEndpointPassword pulumi.StringPtrInput
	// The port of source endpoint. When the source instance is a self-built database, this parameter is available and must be passed in.
	SourceEndpointPort pulumi.StringPtrInput
	// Source instance area, please refer to the [list of supported areas](https://help.aliyun.com/document_detail/141033.htm) for details. Note if the source is an Alibaba Cloud database, this parameter must be passed in.
	SourceEndpointRegion pulumi.StringPtrInput
	// The name of the role configured for the cloud account to which the source instance belongs. Note: this parameter must be passed in when performing cross Alibaba Cloud account data migration or synchronization. For the permissions and authorization methods required by this role, please refer to [How to configure RAM authorization when cross-Alibaba Cloud account data migration or synchronization](https://help.aliyun.com/document_detail/48468.htm).
	SourceEndpointRole pulumi.StringPtrInput
	// The username of database account. Note: in most cases, you need to pass in the database account of the source library. The permissions required for migrating or synchronizing different databases are different. For specific permission requirements, see [Preparing database accounts for data migration](https://help.aliyun.com/document_detail/175878.htm) and [Preparing database accounts for data synchronization](https://help.aliyun.com/document_detail/213152.htm).
	SourceEndpointUserName pulumi.StringPtrInput
	// The status of the resource. Valid values: `Synchronizing`, `Suspending`. You can stop the task by specifying `Suspending` and start the task by specifying `Synchronizing`.
	Status pulumi.StringPtrInput
	// Whether to perform library table structure migration or initialization. Valid values: `true`, `false`.
	StructureInitialization pulumi.BoolPtrInput
	// Synchronization direction. Valid values: `Forward`, `Reverse`. Only when the property `syncArchitecture` of the `dts.SynchronizationInstance` was `bidirectional` this parameter should be passed, otherwise this parameter should not be specified.
	SynchronizationDirection pulumi.StringPtrInput
}

func (SynchronizationJobState) ElementType 

func (SynchronizationJobState) 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.