dts

package
v3.14.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConsumerChannel added in v3.11.0 

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

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

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

func (*ConsumerChannel) ElementType() reflect.Type

func (*ConsumerChannel) ToConsumerChannelOutput added in v3.11.0 

func (i *ConsumerChannel) ToConsumerChannelOutput() ConsumerChannelOutput

func (*ConsumerChannel) ToConsumerChannelOutputWithContext added in v3.11.0 

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

func (*ConsumerChannel) ToConsumerChannelPtrOutput added in v3.11.0 

func (i *ConsumerChannel) ToConsumerChannelPtrOutput() ConsumerChannelPtrOutput

func (*ConsumerChannel) ToConsumerChannelPtrOutputWithContext added in v3.11.0 

func (i *ConsumerChannel) ToConsumerChannelPtrOutputWithContext(ctx context.Context) ConsumerChannelPtrOutput

type ConsumerChannelArgs added in v3.11.0 

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

func (ConsumerChannelArgs) ElementType() reflect.Type

type ConsumerChannelArray added in v3.11.0 

type ConsumerChannelArray []ConsumerChannelInput

func (ConsumerChannelArray) ElementType added in v3.11.0 

func (ConsumerChannelArray) ElementType() reflect.Type

func (ConsumerChannelArray) ToConsumerChannelArrayOutput added in v3.11.0 

func (i ConsumerChannelArray) ToConsumerChannelArrayOutput() ConsumerChannelArrayOutput

func (ConsumerChannelArray) ToConsumerChannelArrayOutputWithContext added in v3.11.0 

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

type ConsumerChannelArrayInput added in v3.11.0 

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

type ConsumerChannelArrayOutput struct{ *pulumi.OutputState }

func (ConsumerChannelArrayOutput) ElementType added in v3.11.0 

func (ConsumerChannelArrayOutput) ElementType() reflect.Type

func (ConsumerChannelArrayOutput) Index added in v3.11.0 

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

func (ConsumerChannelArrayOutput) ToConsumerChannelArrayOutput added in v3.11.0 

func (o ConsumerChannelArrayOutput) ToConsumerChannelArrayOutput() ConsumerChannelArrayOutput

func (ConsumerChannelArrayOutput) ToConsumerChannelArrayOutputWithContext added in v3.11.0 

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

type ConsumerChannelInput added in v3.11.0 

type ConsumerChannelInput interface {
	pulumi.Input

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

type ConsumerChannelMap added in v3.11.0 

type ConsumerChannelMap map[string]ConsumerChannelInput

func (ConsumerChannelMap) ElementType added in v3.11.0 

func (ConsumerChannelMap) ElementType() reflect.Type

func (ConsumerChannelMap) ToConsumerChannelMapOutput added in v3.11.0 

func (i ConsumerChannelMap) ToConsumerChannelMapOutput() ConsumerChannelMapOutput

func (ConsumerChannelMap) ToConsumerChannelMapOutputWithContext added in v3.11.0 

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

type ConsumerChannelMapInput added in v3.11.0 

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

type ConsumerChannelMapOutput struct{ *pulumi.OutputState }

func (ConsumerChannelMapOutput) ElementType added in v3.11.0 

func (ConsumerChannelMapOutput) ElementType() reflect.Type

func (ConsumerChannelMapOutput) MapIndex added in v3.11.0 

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

func (ConsumerChannelMapOutput) ToConsumerChannelMapOutput added in v3.11.0 

func (o ConsumerChannelMapOutput) ToConsumerChannelMapOutput() ConsumerChannelMapOutput

func (ConsumerChannelMapOutput) ToConsumerChannelMapOutputWithContext added in v3.11.0 

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

type ConsumerChannelOutput added in v3.11.0 

type ConsumerChannelOutput struct{ *pulumi.OutputState }

func (ConsumerChannelOutput) ElementType added in v3.11.0 

func (ConsumerChannelOutput) ElementType() reflect.Type

func (ConsumerChannelOutput) ToConsumerChannelOutput added in v3.11.0 

func (o ConsumerChannelOutput) ToConsumerChannelOutput() ConsumerChannelOutput

func (ConsumerChannelOutput) ToConsumerChannelOutputWithContext added in v3.11.0 

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

func (ConsumerChannelOutput) ToConsumerChannelPtrOutput added in v3.11.0 

func (o ConsumerChannelOutput) ToConsumerChannelPtrOutput() ConsumerChannelPtrOutput

func (ConsumerChannelOutput) ToConsumerChannelPtrOutputWithContext added in v3.11.0 

func (o ConsumerChannelOutput) ToConsumerChannelPtrOutputWithContext(ctx context.Context) ConsumerChannelPtrOutput

type ConsumerChannelPtrInput added in v3.11.0 

type ConsumerChannelPtrInput interface {
	pulumi.Input

	ToConsumerChannelPtrOutput() ConsumerChannelPtrOutput
	ToConsumerChannelPtrOutputWithContext(ctx context.Context) ConsumerChannelPtrOutput
}

type ConsumerChannelPtrOutput added in v3.11.0 

type ConsumerChannelPtrOutput struct{ *pulumi.OutputState }

func (ConsumerChannelPtrOutput) Elem added in v3.11.0 

func (o ConsumerChannelPtrOutput) Elem() ConsumerChannelOutput

func (ConsumerChannelPtrOutput) ElementType added in v3.11.0 

func (ConsumerChannelPtrOutput) ElementType() reflect.Type

func (ConsumerChannelPtrOutput) ToConsumerChannelPtrOutput added in v3.11.0 

func (o ConsumerChannelPtrOutput) ToConsumerChannelPtrOutput() ConsumerChannelPtrOutput

func (ConsumerChannelPtrOutput) ToConsumerChannelPtrOutputWithContext added in v3.11.0 

func (o ConsumerChannelPtrOutput) ToConsumerChannelPtrOutputWithContext(ctx context.Context) ConsumerChannelPtrOutput

type ConsumerChannelState added in v3.11.0 

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

func (ConsumerChannelState) ElementType() reflect.Type

type GetConsumerChannelsArgs added in v3.11.0 

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

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

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

func (GetConsumerChannelsChannelArgs) ElementType() reflect.Type

func (GetConsumerChannelsChannelArgs) ToGetConsumerChannelsChannelOutput added in v3.11.0 

func (i GetConsumerChannelsChannelArgs) ToGetConsumerChannelsChannelOutput() GetConsumerChannelsChannelOutput

func (GetConsumerChannelsChannelArgs) ToGetConsumerChannelsChannelOutputWithContext added in v3.11.0 

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

type GetConsumerChannelsChannelArray added in v3.11.0 

type GetConsumerChannelsChannelArray []GetConsumerChannelsChannelInput

func (GetConsumerChannelsChannelArray) ElementType added in v3.11.0 

func (GetConsumerChannelsChannelArray) ElementType() reflect.Type

func (GetConsumerChannelsChannelArray) ToGetConsumerChannelsChannelArrayOutput added in v3.11.0 

func (i GetConsumerChannelsChannelArray) ToGetConsumerChannelsChannelArrayOutput() GetConsumerChannelsChannelArrayOutput

func (GetConsumerChannelsChannelArray) ToGetConsumerChannelsChannelArrayOutputWithContext added in v3.11.0 

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

type GetConsumerChannelsChannelArrayInput added in v3.11.0 

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

type GetConsumerChannelsChannelArrayOutput struct{ *pulumi.OutputState }

func (GetConsumerChannelsChannelArrayOutput) ElementType added in v3.11.0 

func (GetConsumerChannelsChannelArrayOutput) ElementType() reflect.Type

func (GetConsumerChannelsChannelArrayOutput) Index added in v3.11.0 

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

func (GetConsumerChannelsChannelArrayOutput) ToGetConsumerChannelsChannelArrayOutput added in v3.11.0 

func (o GetConsumerChannelsChannelArrayOutput) ToGetConsumerChannelsChannelArrayOutput() GetConsumerChannelsChannelArrayOutput

func (GetConsumerChannelsChannelArrayOutput) ToGetConsumerChannelsChannelArrayOutputWithContext added in v3.11.0 

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

type GetConsumerChannelsChannelInput added in v3.11.0 

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

type GetConsumerChannelsChannelOutput struct{ *pulumi.OutputState }

func (GetConsumerChannelsChannelOutput) ConsumerGroupId added in v3.11.0 

func (o GetConsumerChannelsChannelOutput) ConsumerGroupId() pulumi.StringOutput

The ID of the consumer group.

func (GetConsumerChannelsChannelOutput) ConsumerGroupName added in v3.11.0 

func (o GetConsumerChannelsChannelOutput) ConsumerGroupName() pulumi.StringOutput

The name of the consumer group.

func (GetConsumerChannelsChannelOutput) ConsumerGroupUserName added in v3.11.0 

func (o GetConsumerChannelsChannelOutput) ConsumerGroupUserName() pulumi.StringOutput

The username of the consumer group.

func (GetConsumerChannelsChannelOutput) ConsumptionCheckpoint added in v3.11.0 

func (o GetConsumerChannelsChannelOutput) ConsumptionCheckpoint() pulumi.StringOutput

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

func (GetConsumerChannelsChannelOutput) ElementType added in v3.11.0 

func (GetConsumerChannelsChannelOutput) ElementType() reflect.Type

func (GetConsumerChannelsChannelOutput) Id added in v3.11.0 

func (o GetConsumerChannelsChannelOutput) Id() pulumi.StringOutput

The ID of the Consumer Channel.

func (GetConsumerChannelsChannelOutput) MessageDelay added in v3.11.0 

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

func (o GetConsumerChannelsChannelOutput) ToGetConsumerChannelsChannelOutput() GetConsumerChannelsChannelOutput

func (GetConsumerChannelsChannelOutput) ToGetConsumerChannelsChannelOutputWithContext added in v3.11.0 

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

func (GetConsumerChannelsChannelOutput) UnconsumedData added in v3.11.0 

func (o GetConsumerChannelsChannelOutput) UnconsumedData() pulumi.IntOutput

The total number of unconsumed messages.

type GetConsumerChannelsOutputArgs added in v3.11.0 

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

func (GetConsumerChannelsOutputArgs) ElementType() reflect.Type

type GetConsumerChannelsResult added in v3.11.0 

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

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/v3/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

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

type GetConsumerChannelsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getConsumerChannels.

func GetConsumerChannelsOutput added in v3.11.0 

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

func (GetConsumerChannelsResultOutput) Channels added in v3.11.0 

func (o GetConsumerChannelsResultOutput) Channels() GetConsumerChannelsChannelArrayOutput

func (GetConsumerChannelsResultOutput) DtsInstanceId added in v3.11.0 

func (o GetConsumerChannelsResultOutput) DtsInstanceId() pulumi.StringOutput

func (GetConsumerChannelsResultOutput) ElementType added in v3.11.0 

func (GetConsumerChannelsResultOutput) ElementType() reflect.Type

func (GetConsumerChannelsResultOutput) Id added in v3.11.0 

func (o GetConsumerChannelsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetConsumerChannelsResultOutput) Ids added in v3.11.0 

func (o GetConsumerChannelsResultOutput) Ids() pulumi.StringArrayOutput

func (GetConsumerChannelsResultOutput) OutputFile added in v3.11.0 

func (o GetConsumerChannelsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetConsumerChannelsResultOutput) ToGetConsumerChannelsResultOutput added in v3.11.0 

func (o GetConsumerChannelsResultOutput) ToGetConsumerChannelsResultOutput() GetConsumerChannelsResultOutput

func (GetConsumerChannelsResultOutput) ToGetConsumerChannelsResultOutputWithContext added in v3.11.0 

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

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

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

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/v3/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

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

type GetSubscriptionJobsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getSubscriptionJobs.

func GetSubscriptionJobsOutput added in v3.9.0 

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

func (GetSubscriptionJobsResultOutput) ElementType added in v3.9.0 

func (GetSubscriptionJobsResultOutput) ElementType() reflect.Type

func (GetSubscriptionJobsResultOutput) EnableDetails added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) EnableDetails() pulumi.BoolPtrOutput

func (GetSubscriptionJobsResultOutput) Id added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetSubscriptionJobsResultOutput) Ids added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) Ids() pulumi.StringArrayOutput

func (GetSubscriptionJobsResultOutput) Jobs added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) Jobs() GetSubscriptionJobsJobArrayOutput

func (GetSubscriptionJobsResultOutput) NameRegex added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) NameRegex() pulumi.StringPtrOutput

func (GetSubscriptionJobsResultOutput) Names added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) Names() pulumi.StringArrayOutput

func (GetSubscriptionJobsResultOutput) OutputFile added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetSubscriptionJobsResultOutput) Status added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) Status() pulumi.StringPtrOutput

func (GetSubscriptionJobsResultOutput) Tags added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) Tags() pulumi.MapOutput

func (GetSubscriptionJobsResultOutput) ToGetSubscriptionJobsResultOutput added in v3.9.0 

func (o GetSubscriptionJobsResultOutput) ToGetSubscriptionJobsResultOutput() GetSubscriptionJobsResultOutput

func (GetSubscriptionJobsResultOutput) ToGetSubscriptionJobsResultOutputWithContext added in v3.9.0 

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

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

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/v3/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

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

type GetSynchronizationJobsResultOutput struct{ *pulumi.OutputState }

A collection of values returned by getSynchronizationJobs.

func GetSynchronizationJobsOutput added in v3.9.0 

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

func (GetSynchronizationJobsResultOutput) ElementType added in v3.9.0 

func (GetSynchronizationJobsResultOutput) ElementType() reflect.Type

func (GetSynchronizationJobsResultOutput) EnableDetails added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) EnableDetails() pulumi.BoolPtrOutput

func (GetSynchronizationJobsResultOutput) Id added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) Id() pulumi.StringOutput

The provider-assigned unique ID for this managed resource.

func (GetSynchronizationJobsResultOutput) Ids added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) Ids() pulumi.StringArrayOutput

func (GetSynchronizationJobsResultOutput) Jobs added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) Jobs() GetSynchronizationJobsJobArrayOutput

func (GetSynchronizationJobsResultOutput) NameRegex added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) NameRegex() pulumi.StringPtrOutput

func (GetSynchronizationJobsResultOutput) OutputFile added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) OutputFile() pulumi.StringPtrOutput

func (GetSynchronizationJobsResultOutput) Status added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) Status() pulumi.StringPtrOutput

func (GetSynchronizationJobsResultOutput) ToGetSynchronizationJobsResultOutput added in v3.9.0 

func (o GetSynchronizationJobsResultOutput) ToGetSynchronizationJobsResultOutput() GetSynchronizationJobsResultOutput

func (GetSynchronizationJobsResultOutput) ToGetSynchronizationJobsResultOutputWithContext added in v3.9.0 

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.StringOutput `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-alicloud/sdk/v3/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

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

func (*JobMonitorRule) ToJobMonitorRulePtrOutput 

func (i *JobMonitorRule) ToJobMonitorRulePtrOutput() JobMonitorRulePtrOutput

func (*JobMonitorRule) ToJobMonitorRulePtrOutputWithContext 

func (i *JobMonitorRule) ToJobMonitorRulePtrOutputWithContext(ctx context.Context) JobMonitorRulePtrOutput

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

func (JobMonitorRuleOutput) ElementType() reflect.Type

func (JobMonitorRuleOutput) ToJobMonitorRuleOutput 

func (o JobMonitorRuleOutput) ToJobMonitorRuleOutput() JobMonitorRuleOutput

func (JobMonitorRuleOutput) ToJobMonitorRuleOutputWithContext 

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

func (JobMonitorRuleOutput) ToJobMonitorRulePtrOutput 

func (o JobMonitorRuleOutput) ToJobMonitorRulePtrOutput() JobMonitorRulePtrOutput

func (JobMonitorRuleOutput) ToJobMonitorRulePtrOutputWithContext 

func (o JobMonitorRuleOutput) ToJobMonitorRulePtrOutputWithContext(ctx context.Context) JobMonitorRulePtrOutput

type JobMonitorRulePtrInput 

type JobMonitorRulePtrInput interface {
	pulumi.Input

	ToJobMonitorRulePtrOutput() JobMonitorRulePtrOutput
	ToJobMonitorRulePtrOutputWithContext(ctx context.Context) JobMonitorRulePtrOutput
}

type JobMonitorRulePtrOutput 

type JobMonitorRulePtrOutput struct{ *pulumi.OutputState }

func (JobMonitorRulePtrOutput) Elem added in v3.9.0 

func (o JobMonitorRulePtrOutput) Elem() JobMonitorRuleOutput

func (JobMonitorRulePtrOutput) ElementType 

func (JobMonitorRulePtrOutput) ElementType() reflect.Type

func (JobMonitorRulePtrOutput) ToJobMonitorRulePtrOutput 

func (o JobMonitorRulePtrOutput) ToJobMonitorRulePtrOutput() JobMonitorRulePtrOutput

func (JobMonitorRulePtrOutput) ToJobMonitorRulePtrOutputWithContext 

func (o JobMonitorRulePtrOutput) ToJobMonitorRulePtrOutputWithContext(ctx context.Context) JobMonitorRulePtrOutput

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 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"`
	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

func (*SubscriptionJob) ToSubscriptionJobPtrOutput 

func (i *SubscriptionJob) ToSubscriptionJobPtrOutput() SubscriptionJobPtrOutput

func (*SubscriptionJob) ToSubscriptionJobPtrOutputWithContext 

func (i *SubscriptionJob) ToSubscriptionJobPtrOutputWithContext(ctx context.Context) SubscriptionJobPtrOutput

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

func (SubscriptionJobOutput) ElementType() reflect.Type

func (SubscriptionJobOutput) ToSubscriptionJobOutput 

func (o SubscriptionJobOutput) ToSubscriptionJobOutput() SubscriptionJobOutput

func (SubscriptionJobOutput) ToSubscriptionJobOutputWithContext 

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

func (SubscriptionJobOutput) ToSubscriptionJobPtrOutput 

func (o SubscriptionJobOutput) ToSubscriptionJobPtrOutput() SubscriptionJobPtrOutput

func (SubscriptionJobOutput) ToSubscriptionJobPtrOutputWithContext 

func (o SubscriptionJobOutput) ToSubscriptionJobPtrOutputWithContext(ctx context.Context) SubscriptionJobPtrOutput

type SubscriptionJobPtrInput 

type SubscriptionJobPtrInput interface {
	pulumi.Input

	ToSubscriptionJobPtrOutput() SubscriptionJobPtrOutput
	ToSubscriptionJobPtrOutputWithContext(ctx context.Context) SubscriptionJobPtrOutput
}

type SubscriptionJobPtrOutput 

type SubscriptionJobPtrOutput struct{ *pulumi.OutputState }

func (SubscriptionJobPtrOutput) Elem added in v3.9.0 

func (o SubscriptionJobPtrOutput) Elem() SubscriptionJobOutput

func (SubscriptionJobPtrOutput) ElementType 

func (SubscriptionJobPtrOutput) ElementType() reflect.Type

func (SubscriptionJobPtrOutput) ToSubscriptionJobPtrOutput 

func (o SubscriptionJobPtrOutput) ToSubscriptionJobPtrOutput() SubscriptionJobPtrOutput

func (SubscriptionJobPtrOutput) ToSubscriptionJobPtrOutputWithContext 

func (o SubscriptionJobPtrOutput) ToSubscriptionJobPtrOutputWithContext(ctx context.Context) SubscriptionJobPtrOutput

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

func (SubscriptionJobState) ElementType 

func (SubscriptionJobState) ElementType() reflect.Type

type SynchronizationInstance 

type SynchronizationInstance 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 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. 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"`
	// 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-alicloud/sdk/v3/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

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

func (*SynchronizationInstance) ToSynchronizationInstancePtrOutput 

func (i *SynchronizationInstance) ToSynchronizationInstancePtrOutput() SynchronizationInstancePtrOutput

func (*SynchronizationInstance) ToSynchronizationInstancePtrOutputWithContext 

func (i *SynchronizationInstance) ToSynchronizationInstancePtrOutputWithContext(ctx context.Context) SynchronizationInstancePtrOutput

type SynchronizationInstanceArgs 

type SynchronizationInstanceArgs 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`, `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. 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
	// 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) ElementType 

func (SynchronizationInstanceOutput) ElementType() reflect.Type

func (SynchronizationInstanceOutput) ToSynchronizationInstanceOutput 

func (o SynchronizationInstanceOutput) ToSynchronizationInstanceOutput() SynchronizationInstanceOutput

func (SynchronizationInstanceOutput) ToSynchronizationInstanceOutputWithContext 

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

func (SynchronizationInstanceOutput) ToSynchronizationInstancePtrOutput 

func (o SynchronizationInstanceOutput) ToSynchronizationInstancePtrOutput() SynchronizationInstancePtrOutput

func (SynchronizationInstanceOutput) ToSynchronizationInstancePtrOutputWithContext 

func (o SynchronizationInstanceOutput) ToSynchronizationInstancePtrOutputWithContext(ctx context.Context) SynchronizationInstancePtrOutput

type SynchronizationInstancePtrInput 

type SynchronizationInstancePtrInput interface {
	pulumi.Input

	ToSynchronizationInstancePtrOutput() SynchronizationInstancePtrOutput
	ToSynchronizationInstancePtrOutputWithContext(ctx context.Context) SynchronizationInstancePtrOutput
}

type SynchronizationInstancePtrOutput 

type SynchronizationInstancePtrOutput struct{ *pulumi.OutputState }

func (SynchronizationInstancePtrOutput) Elem added in v3.9.0 

func (o SynchronizationInstancePtrOutput) Elem() SynchronizationInstanceOutput

func (SynchronizationInstancePtrOutput) ElementType 

func (SynchronizationInstancePtrOutput) ElementType() reflect.Type

func (SynchronizationInstancePtrOutput) ToSynchronizationInstancePtrOutput 

func (o SynchronizationInstancePtrOutput) ToSynchronizationInstancePtrOutput() SynchronizationInstancePtrOutput

func (SynchronizationInstancePtrOutput) ToSynchronizationInstancePtrOutputWithContext 

func (o SynchronizationInstancePtrOutput) ToSynchronizationInstancePtrOutputWithContext(ctx context.Context) SynchronizationInstancePtrOutput

type SynchronizationInstanceState 

type SynchronizationInstanceState 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 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. 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
	// 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).
	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: `ADB20`, `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.StringPtrOutput `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-alicloud/sdk/v3/go/alicloud/dts"
"github.com/pulumi/pulumi/sdk/v3/go/pulumi"

) 

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

func (*SynchronizationJob) ToSynchronizationJobPtrOutput 

func (i *SynchronizationJob) ToSynchronizationJobPtrOutput() SynchronizationJobPtrOutput

func (*SynchronizationJob) ToSynchronizationJobPtrOutputWithContext 

func (i *SynchronizationJob) ToSynchronizationJobPtrOutputWithContext(ctx context.Context) SynchronizationJobPtrOutput

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).
	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: `ADB20`, `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.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.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) ElementType 

func (SynchronizationJobOutput) ElementType() reflect.Type

func (SynchronizationJobOutput) ToSynchronizationJobOutput 

func (o SynchronizationJobOutput) ToSynchronizationJobOutput() SynchronizationJobOutput

func (SynchronizationJobOutput) ToSynchronizationJobOutputWithContext 

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

func (SynchronizationJobOutput) ToSynchronizationJobPtrOutput 

func (o SynchronizationJobOutput) ToSynchronizationJobPtrOutput() SynchronizationJobPtrOutput

func (SynchronizationJobOutput) ToSynchronizationJobPtrOutputWithContext 

func (o SynchronizationJobOutput) ToSynchronizationJobPtrOutputWithContext(ctx context.Context) SynchronizationJobPtrOutput

type SynchronizationJobPtrInput 

type SynchronizationJobPtrInput interface {
	pulumi.Input

	ToSynchronizationJobPtrOutput() SynchronizationJobPtrOutput
	ToSynchronizationJobPtrOutputWithContext(ctx context.Context) SynchronizationJobPtrOutput
}

type SynchronizationJobPtrOutput 

type SynchronizationJobPtrOutput struct{ *pulumi.OutputState }

func (SynchronizationJobPtrOutput) Elem added in v3.9.0 

func (o SynchronizationJobPtrOutput) Elem() SynchronizationJobOutput

func (SynchronizationJobPtrOutput) ElementType 

func (SynchronizationJobPtrOutput) ElementType() reflect.Type

func (SynchronizationJobPtrOutput) ToSynchronizationJobPtrOutput 

func (o SynchronizationJobPtrOutput) ToSynchronizationJobPtrOutput() SynchronizationJobPtrOutput

func (SynchronizationJobPtrOutput) ToSynchronizationJobPtrOutputWithContext 

func (o SynchronizationJobPtrOutput) ToSynchronizationJobPtrOutputWithContext(ctx context.Context) SynchronizationJobPtrOutput

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).
	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: `ADB20`, `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.