DDS SDK Auto Released By junjun.zhang,Version：1.34.9

Signed-off-by: yixiong.jxy <yixiong.jxy@alibaba-inc.com>

ChangeLog.txt

@@ -1,3 +1,7 @@
+2018-10-31 Version: 1.34.9
+1, The DescribeDBInstanceAttribute add replicaSets response value.
+2, The DescribeDBInstances support engine query.
+
 2018-10-30 Version: 1.34.8
 1, Add API DescribeLiveDomainBpsData,DescribeLiveDomainTrafficData.
 

services/dds/describe_active_operation_task.go

@@ -0,0 +1,116 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeActiveOperationTask invokes the dds.DescribeActiveOperationTask API synchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtask.html
+func (client *Client) DescribeActiveOperationTask(request *DescribeActiveOperationTaskRequest) (response *DescribeActiveOperationTaskResponse, err error) {
+	response = CreateDescribeActiveOperationTaskResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeActiveOperationTaskWithChan invokes the dds.DescribeActiveOperationTask API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtask.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskWithChan(request *DescribeActiveOperationTaskRequest) (<-chan *DescribeActiveOperationTaskResponse, <-chan error) {
+	responseChan := make(chan *DescribeActiveOperationTaskResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeActiveOperationTask(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeActiveOperationTaskWithCallback invokes the dds.DescribeActiveOperationTask API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtask.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskWithCallback(request *DescribeActiveOperationTaskRequest, callback func(response *DescribeActiveOperationTaskResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeActiveOperationTaskResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeActiveOperationTask(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeActiveOperationTaskRequest is the request struct for api DescribeActiveOperationTask
+type DescribeActiveOperationTaskRequest struct {
+	*requests.RpcRequest
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	TaskType             string           `position:"Query" name:"TaskType"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+	PageNumber           requests.Integer `position:"Query" name:"PageNumber"`
+	IsHistory            requests.Integer `position:"Query" name:"IsHistory"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	PageSize             requests.Integer `position:"Query" name:"PageSize"`
+	Region               string           `position:"Query" name:"Region"`
+}
+
+// DescribeActiveOperationTaskResponse is the response struct for api DescribeActiveOperationTask
+type DescribeActiveOperationTaskResponse struct {
+	*responses.BaseResponse
+	RequestId        string      `json:"RequestId" xml:"RequestId"`
+	TotalRecordCount int         `json:"TotalRecordCount" xml:"TotalRecordCount"`
+	PageSize         int         `json:"PageSize" xml:"PageSize"`
+	PageNumber       int         `json:"PageNumber" xml:"PageNumber"`
+	Items            []ItemsItem `json:"Items" xml:"Items"`
+}
+
+// CreateDescribeActiveOperationTaskRequest creates a request to invoke DescribeActiveOperationTask API
+func CreateDescribeActiveOperationTaskRequest() (request *DescribeActiveOperationTaskRequest) {
+	request = &DescribeActiveOperationTaskRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeActiveOperationTask", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeActiveOperationTaskResponse creates a response to parse from DescribeActiveOperationTask response
+func CreateDescribeActiveOperationTaskResponse() (response *DescribeActiveOperationTaskResponse) {
+	response = &DescribeActiveOperationTaskResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/describe_active_operation_task_count.go

@@ -0,0 +1,109 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeActiveOperationTaskCount invokes the dds.DescribeActiveOperationTaskCount API synchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtaskcount.html
+func (client *Client) DescribeActiveOperationTaskCount(request *DescribeActiveOperationTaskCountRequest) (response *DescribeActiveOperationTaskCountResponse, err error) {
+	response = CreateDescribeActiveOperationTaskCountResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeActiveOperationTaskCountWithChan invokes the dds.DescribeActiveOperationTaskCount API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtaskcount.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskCountWithChan(request *DescribeActiveOperationTaskCountRequest) (<-chan *DescribeActiveOperationTaskCountResponse, <-chan error) {
+	responseChan := make(chan *DescribeActiveOperationTaskCountResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeActiveOperationTaskCount(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeActiveOperationTaskCountWithCallback invokes the dds.DescribeActiveOperationTaskCount API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtaskcount.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskCountWithCallback(request *DescribeActiveOperationTaskCountRequest, callback func(response *DescribeActiveOperationTaskCountResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeActiveOperationTaskCountResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeActiveOperationTaskCount(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeActiveOperationTaskCountRequest is the request struct for api DescribeActiveOperationTaskCount
+type DescribeActiveOperationTaskCountRequest struct {
+	*requests.RpcRequest
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+}
+
+// DescribeActiveOperationTaskCountResponse is the response struct for api DescribeActiveOperationTaskCount
+type DescribeActiveOperationTaskCountResponse struct {
+	*responses.BaseResponse
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	TaskCount int    `json:"TaskCount" xml:"TaskCount"`
+	NeedPop   int    `json:"NeedPop" xml:"NeedPop"`
+}
+
+// CreateDescribeActiveOperationTaskCountRequest creates a request to invoke DescribeActiveOperationTaskCount API
+func CreateDescribeActiveOperationTaskCountRequest() (request *DescribeActiveOperationTaskCountRequest) {
+	request = &DescribeActiveOperationTaskCountRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeActiveOperationTaskCount", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeActiveOperationTaskCountResponse creates a response to parse from DescribeActiveOperationTaskCount response
+func CreateDescribeActiveOperationTaskCountResponse() (response *DescribeActiveOperationTaskCountResponse) {
+	response = &DescribeActiveOperationTaskCountResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/describe_active_operation_task_region.go

@@ -0,0 +1,110 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeActiveOperationTaskRegion invokes the dds.DescribeActiveOperationTaskRegion API synchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtaskregion.html
+func (client *Client) DescribeActiveOperationTaskRegion(request *DescribeActiveOperationTaskRegionRequest) (response *DescribeActiveOperationTaskRegionResponse, err error) {
+	response = CreateDescribeActiveOperationTaskRegionResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeActiveOperationTaskRegionWithChan invokes the dds.DescribeActiveOperationTaskRegion API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtaskregion.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskRegionWithChan(request *DescribeActiveOperationTaskRegionRequest) (<-chan *DescribeActiveOperationTaskRegionResponse, <-chan error) {
+	responseChan := make(chan *DescribeActiveOperationTaskRegionResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeActiveOperationTaskRegion(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeActiveOperationTaskRegionWithCallback invokes the dds.DescribeActiveOperationTaskRegion API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtaskregion.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskRegionWithCallback(request *DescribeActiveOperationTaskRegionRequest, callback func(response *DescribeActiveOperationTaskRegionResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeActiveOperationTaskRegionResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeActiveOperationTaskRegion(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeActiveOperationTaskRegionRequest is the request struct for api DescribeActiveOperationTaskRegion
+type DescribeActiveOperationTaskRegionRequest struct {
+	*requests.RpcRequest
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	IsHistory            requests.Integer `position:"Query" name:"IsHistory"`
+	TaskType             string           `position:"Query" name:"TaskType"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+}
+
+// DescribeActiveOperationTaskRegionResponse is the response struct for api DescribeActiveOperationTaskRegion
+type DescribeActiveOperationTaskRegionResponse struct {
+	*responses.BaseResponse
+	RequestId  string  `json:"RequestId" xml:"RequestId"`
+	RegionList []Items `json:"RegionList" xml:"RegionList"`
+}
+
+// CreateDescribeActiveOperationTaskRegionRequest creates a request to invoke DescribeActiveOperationTaskRegion API
+func CreateDescribeActiveOperationTaskRegionRequest() (request *DescribeActiveOperationTaskRegionRequest) {
+	request = &DescribeActiveOperationTaskRegionRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeActiveOperationTaskRegion", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeActiveOperationTaskRegionResponse creates a response to parse from DescribeActiveOperationTaskRegion response
+func CreateDescribeActiveOperationTaskRegionResponse() (response *DescribeActiveOperationTaskRegionResponse) {
+	response = &DescribeActiveOperationTaskRegionResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/describe_active_operation_task_type.go

@@ -0,0 +1,109 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeActiveOperationTaskType invokes the dds.DescribeActiveOperationTaskType API synchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtasktype.html
+func (client *Client) DescribeActiveOperationTaskType(request *DescribeActiveOperationTaskTypeRequest) (response *DescribeActiveOperationTaskTypeResponse, err error) {
+	response = CreateDescribeActiveOperationTaskTypeResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeActiveOperationTaskTypeWithChan invokes the dds.DescribeActiveOperationTaskType API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtasktype.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskTypeWithChan(request *DescribeActiveOperationTaskTypeRequest) (<-chan *DescribeActiveOperationTaskTypeResponse, <-chan error) {
+	responseChan := make(chan *DescribeActiveOperationTaskTypeResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeActiveOperationTaskType(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeActiveOperationTaskTypeWithCallback invokes the dds.DescribeActiveOperationTaskType API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeactiveoperationtasktype.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeActiveOperationTaskTypeWithCallback(request *DescribeActiveOperationTaskTypeRequest, callback func(response *DescribeActiveOperationTaskTypeResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeActiveOperationTaskTypeResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeActiveOperationTaskType(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeActiveOperationTaskTypeRequest is the request struct for api DescribeActiveOperationTaskType
+type DescribeActiveOperationTaskTypeRequest struct {
+	*requests.RpcRequest
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	IsHistory            requests.Integer `position:"Query" name:"IsHistory"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+}
+
+// DescribeActiveOperationTaskTypeResponse is the response struct for api DescribeActiveOperationTaskType
+type DescribeActiveOperationTaskTypeResponse struct {
+	*responses.BaseResponse
+	RequestId string  `json:"RequestId" xml:"RequestId"`
+	TypeList  []Items `json:"TypeList" xml:"TypeList"`
+}
+
+// CreateDescribeActiveOperationTaskTypeRequest creates a request to invoke DescribeActiveOperationTaskType API
+func CreateDescribeActiveOperationTaskTypeRequest() (request *DescribeActiveOperationTaskTypeRequest) {
+	request = &DescribeActiveOperationTaskTypeRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeActiveOperationTaskType", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeActiveOperationTaskTypeResponse creates a response to parse from DescribeActiveOperationTaskType response
+func CreateDescribeActiveOperationTaskTypeResponse() (response *DescribeActiveOperationTaskTypeResponse) {
+	response = &DescribeActiveOperationTaskTypeResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/describe_backups.go

@@ -79,7 +79,7 @@ type DescribeBackupsRequest struct {
 	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
 	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
 	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
-	BackupId             requests.Integer `position:"Query" name:"BackupId"`
+	BackupId             string           `position:"Query" name:"BackupId"`
 	EndTime              string           `position:"Query" name:"EndTime"`
 	StartTime            string           `position:"Query" name:"StartTime"`
 	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`

services/dds/describe_db_instance_performance.go

@@ -78,6 +78,7 @@ type DescribeDBInstancePerformanceRequest struct {
 	*requests.RpcRequest
 	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
 	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	RoleId               string           `position:"Query" name:"RoleId"`
 	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
 	EndTime              string           `position:"Query" name:"EndTime"`
 	StartTime            string           `position:"Query" name:"StartTime"`

services/dds/describe_db_instances.go

@@ -76,18 +76,22 @@ func (client *Client) DescribeDBInstancesWithCallback(request *DescribeDBInstanc
 // DescribeDBInstancesRequest is the request struct for api DescribeDBInstances
 type DescribeDBInstancesRequest struct {
 	*requests.RpcRequest
-	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
-	DBInstanceIds        string           `position:"Query" name:"DBInstanceIds"`
-	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
-	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
-	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
-	PageNumber           requests.Integer `position:"Query" name:"PageNumber"`
-	ReplicationFactor    string           `position:"Query" name:"ReplicationFactor"`
-	DBInstanceType       string           `position:"Query" name:"DBInstanceType"`
-	Expired              string           `position:"Query" name:"Expired"`
-	SecurityToken        string           `position:"Query" name:"SecurityToken"`
-	Engine               string           `position:"Query" name:"Engine"`
-	PageSize             requests.Integer `position:"Query" name:"PageSize"`
+	ExpireTime            string           `position:"Query" name:"ExpireTime"`
+	ResourceOwnerId       requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	ResourceOwnerAccount  string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount          string           `position:"Query" name:"OwnerAccount"`
+	OwnerId               requests.Integer `position:"Query" name:"OwnerId"`
+	PageNumber            requests.Integer `position:"Query" name:"PageNumber"`
+	ReplicationFactor     string           `position:"Query" name:"ReplicationFactor"`
+	DBInstanceType        string           `position:"Query" name:"DBInstanceType"`
+	DBInstanceClass       string           `position:"Query" name:"DBInstanceClass"`
+	Expired               string           `position:"Query" name:"Expired"`
+	SecurityToken         string           `position:"Query" name:"SecurityToken"`
+	PageSize              requests.Integer `position:"Query" name:"PageSize"`
+	ZoneId                string           `position:"Query" name:"ZoneId"`
+	DBInstanceId          string           `position:"Query" name:"DBInstanceId"`
+	DBInstanceDescription string           `position:"Query" name:"DBInstanceDescription"`
+	DBInstanceStatus      string           `position:"Query" name:"DBInstanceStatus"`
 }
 
 // DescribeDBInstancesResponse is the response struct for api DescribeDBInstances

services/dds/describe_error_log_records.go

@@ -0,0 +1,121 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeErrorLogRecords invokes the dds.DescribeErrorLogRecords API synchronously
+// api document: https://help.aliyun.com/api/dds/describeerrorlogrecords.html
+func (client *Client) DescribeErrorLogRecords(request *DescribeErrorLogRecordsRequest) (response *DescribeErrorLogRecordsResponse, err error) {
+	response = CreateDescribeErrorLogRecordsResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeErrorLogRecordsWithChan invokes the dds.DescribeErrorLogRecords API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeerrorlogrecords.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeErrorLogRecordsWithChan(request *DescribeErrorLogRecordsRequest) (<-chan *DescribeErrorLogRecordsResponse, <-chan error) {
+	responseChan := make(chan *DescribeErrorLogRecordsResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeErrorLogRecords(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeErrorLogRecordsWithCallback invokes the dds.DescribeErrorLogRecords API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeerrorlogrecords.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeErrorLogRecordsWithCallback(request *DescribeErrorLogRecordsRequest, callback func(response *DescribeErrorLogRecordsResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeErrorLogRecordsResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeErrorLogRecords(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeErrorLogRecordsRequest is the request struct for api DescribeErrorLogRecords
+type DescribeErrorLogRecordsRequest struct {
+	*requests.RpcRequest
+	SQLId                requests.Integer `position:"Query" name:"SQLId"`
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	EndTime              string           `position:"Query" name:"EndTime"`
+	StartTime            string           `position:"Query" name:"StartTime"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+	PageNumber           requests.Integer `position:"Query" name:"PageNumber"`
+	DBName               string           `position:"Query" name:"DBName"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	PageSize             requests.Integer `position:"Query" name:"PageSize"`
+	DBInstanceId         string           `position:"Query" name:"DBInstanceId"`
+	RoleType             string           `position:"Query" name:"RoleType"`
+	NodeId               string           `position:"Query" name:"NodeId"`
+}
+
+// DescribeErrorLogRecordsResponse is the response struct for api DescribeErrorLogRecords
+type DescribeErrorLogRecordsResponse struct {
+	*responses.BaseResponse
+	RequestId        string                         `json:"RequestId" xml:"RequestId"`
+	Engine           string                         `json:"Engine" xml:"Engine"`
+	TotalRecordCount int                            `json:"TotalRecordCount" xml:"TotalRecordCount"`
+	PageNumber       int                            `json:"PageNumber" xml:"PageNumber"`
+	PageRecordCount  int                            `json:"PageRecordCount" xml:"PageRecordCount"`
+	Items            ItemsInDescribeErrorLogRecords `json:"Items" xml:"Items"`
+}
+
+// CreateDescribeErrorLogRecordsRequest creates a request to invoke DescribeErrorLogRecords API
+func CreateDescribeErrorLogRecordsRequest() (request *DescribeErrorLogRecordsRequest) {
+	request = &DescribeErrorLogRecordsRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeErrorLogRecords", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeErrorLogRecordsResponse creates a response to parse from DescribeErrorLogRecords response
+func CreateDescribeErrorLogRecordsResponse() (response *DescribeErrorLogRecordsResponse) {
+	response = &DescribeErrorLogRecordsResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/describe_replica_initialize_progress.go

@@ -87,8 +87,8 @@ type DescribeReplicaInitializeProgressRequest struct {
 // DescribeReplicaInitializeProgressResponse is the response struct for api DescribeReplicaInitializeProgress
 type DescribeReplicaInitializeProgressResponse struct {
 	*responses.BaseResponse
-	RequestId string      `json:"RequestId" xml:"RequestId"`
-	Items     []ItemsItem `json:"Items" xml:"Items"`
+	RequestId string                                         `json:"RequestId" xml:"RequestId"`
+	Items     []ItemsItemInDescribeReplicaInitializeProgress `json:"Items" xml:"Items"`
 }
 
 // CreateDescribeReplicaInitializeProgressRequest creates a request to invoke DescribeReplicaInitializeProgress API

services/dds/describe_replica_performance.go

@@ -76,16 +76,17 @@ func (client *Client) DescribeReplicaPerformanceWithCallback(request *DescribeRe
 // DescribeReplicaPerformanceRequest is the request struct for api DescribeReplicaPerformance
 type DescribeReplicaPerformanceRequest struct {
 	*requests.RpcRequest
-	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
-	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
-	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
-	EndTime              string           `position:"Query" name:"EndTime"`
-	StartTime            string           `position:"Query" name:"StartTime"`
-	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
-	SourceDBInstanceId   string           `position:"Query" name:"SourceDBInstanceId"`
-	SecurityToken        string           `position:"Query" name:"SecurityToken"`
-	ReplicaId            string           `position:"Query" name:"ReplicaId"`
-	Key                  string           `position:"Query" name:"Key"`
+	ResourceOwnerId         requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	DestinationDBInstanceId string           `position:"Query" name:"DestinationDBInstanceId"`
+	ResourceOwnerAccount    string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount            string           `position:"Query" name:"OwnerAccount"`
+	EndTime                 string           `position:"Query" name:"EndTime"`
+	StartTime               string           `position:"Query" name:"StartTime"`
+	OwnerId                 requests.Integer `position:"Query" name:"OwnerId"`
+	SourceDBInstanceId      string           `position:"Query" name:"SourceDBInstanceId"`
+	SecurityToken           string           `position:"Query" name:"SecurityToken"`
+	ReplicaId               string           `position:"Query" name:"ReplicaId"`
+	Key                     string           `position:"Query" name:"Key"`
 }
 
 // DescribeReplicaPerformanceResponse is the response struct for api DescribeReplicaPerformance

services/dds/describe_replica_set_role.go

@@ -87,9 +87,9 @@ type DescribeReplicaSetRoleRequest struct {
 // DescribeReplicaSetRoleResponse is the response struct for api DescribeReplicaSetRole
 type DescribeReplicaSetRoleResponse struct {
 	*responses.BaseResponse
-	RequestId    string      `json:"RequestId" xml:"RequestId"`
-	DBInstanceId string      `json:"DBInstanceId" xml:"DBInstanceId"`
-	ReplicaSets  ReplicaSets `json:"ReplicaSets" xml:"ReplicaSets"`
+	RequestId    string                              `json:"RequestId" xml:"RequestId"`
+	DBInstanceId string                              `json:"DBInstanceId" xml:"DBInstanceId"`
+	ReplicaSets  ReplicaSetsInDescribeReplicaSetRole `json:"ReplicaSets" xml:"ReplicaSets"`
 }
 
 // CreateDescribeReplicaSetRoleRequest creates a request to invoke DescribeReplicaSetRole API

services/dds/describe_replica_usage.go

@@ -76,13 +76,14 @@ func (client *Client) DescribeReplicaUsageWithCallback(request *DescribeReplicaU
 // DescribeReplicaUsageRequest is the request struct for api DescribeReplicaUsage
 type DescribeReplicaUsageRequest struct {
 	*requests.RpcRequest
-	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
-	SourceDBInstanceId   string           `position:"Query" name:"SourceDBInstanceId"`
-	SecurityToken        string           `position:"Query" name:"SecurityToken"`
-	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
-	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
-	ReplicaId            string           `position:"Query" name:"ReplicaId"`
-	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+	ResourceOwnerId         requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	SourceDBInstanceId      string           `position:"Query" name:"SourceDBInstanceId"`
+	DestinationDBInstanceId string           `position:"Query" name:"DestinationDBInstanceId"`
+	SecurityToken           string           `position:"Query" name:"SecurityToken"`
+	ResourceOwnerAccount    string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount            string           `position:"Query" name:"OwnerAccount"`
+	ReplicaId               string           `position:"Query" name:"ReplicaId"`
+	OwnerId                 requests.Integer `position:"Query" name:"OwnerId"`
 }
 
 // DescribeReplicaUsageResponse is the response struct for api DescribeReplicaUsage

services/dds/describe_replication_group.go

@@ -0,0 +1,111 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeReplicationGroup invokes the dds.DescribeReplicationGroup API synchronously
+// api document: https://help.aliyun.com/api/dds/describereplicationgroup.html
+func (client *Client) DescribeReplicationGroup(request *DescribeReplicationGroupRequest) (response *DescribeReplicationGroupResponse, err error) {
+	response = CreateDescribeReplicationGroupResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeReplicationGroupWithChan invokes the dds.DescribeReplicationGroup API asynchronously
+// api document: https://help.aliyun.com/api/dds/describereplicationgroup.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeReplicationGroupWithChan(request *DescribeReplicationGroupRequest) (<-chan *DescribeReplicationGroupResponse, <-chan error) {
+	responseChan := make(chan *DescribeReplicationGroupResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeReplicationGroup(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeReplicationGroupWithCallback invokes the dds.DescribeReplicationGroup API asynchronously
+// api document: https://help.aliyun.com/api/dds/describereplicationgroup.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeReplicationGroupWithCallback(request *DescribeReplicationGroupRequest, callback func(response *DescribeReplicationGroupResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeReplicationGroupResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeReplicationGroup(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeReplicationGroupRequest is the request struct for api DescribeReplicationGroup
+type DescribeReplicationGroupRequest struct {
+	*requests.RpcRequest
+	DestinationInstanceIds string           `position:"Query" name:"DestinationInstanceIds"`
+	ResourceOwnerId        requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	SecurityToken          string           `position:"Query" name:"SecurityToken"`
+	ResourceOwnerAccount   string           `position:"Query" name:"ResourceOwnerAccount"`
+	ReplicationGroupId     string           `position:"Query" name:"ReplicationGroupId"`
+	OwnerAccount           string           `position:"Query" name:"OwnerAccount"`
+	SourceInstanceId       string           `position:"Query" name:"SourceInstanceId"`
+	OwnerId                requests.Integer `position:"Query" name:"OwnerId"`
+}
+
+// DescribeReplicationGroupResponse is the response struct for api DescribeReplicationGroup
+type DescribeReplicationGroupResponse struct {
+	*responses.BaseResponse
+	RequestId     string   `json:"RequestId" xml:"RequestId"`
+	TunnelContext []string `json:"tunnelContext" xml:"tunnelContext"`
+}
+
+// CreateDescribeReplicationGroupRequest creates a request to invoke DescribeReplicationGroup API
+func CreateDescribeReplicationGroupRequest() (request *DescribeReplicationGroupRequest) {
+	request = &DescribeReplicationGroupRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeReplicationGroup", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeReplicationGroupResponse creates a response to parse from DescribeReplicationGroup response
+func CreateDescribeReplicationGroupResponse() (response *DescribeReplicationGroupResponse) {
+	response = &DescribeReplicationGroupResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/describe_running_log_records.go

@@ -0,0 +1,121 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeRunningLogRecords invokes the dds.DescribeRunningLogRecords API synchronously
+// api document: https://help.aliyun.com/api/dds/describerunninglogrecords.html
+func (client *Client) DescribeRunningLogRecords(request *DescribeRunningLogRecordsRequest) (response *DescribeRunningLogRecordsResponse, err error) {
+	response = CreateDescribeRunningLogRecordsResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeRunningLogRecordsWithChan invokes the dds.DescribeRunningLogRecords API asynchronously
+// api document: https://help.aliyun.com/api/dds/describerunninglogrecords.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeRunningLogRecordsWithChan(request *DescribeRunningLogRecordsRequest) (<-chan *DescribeRunningLogRecordsResponse, <-chan error) {
+	responseChan := make(chan *DescribeRunningLogRecordsResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeRunningLogRecords(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeRunningLogRecordsWithCallback invokes the dds.DescribeRunningLogRecords API asynchronously
+// api document: https://help.aliyun.com/api/dds/describerunninglogrecords.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeRunningLogRecordsWithCallback(request *DescribeRunningLogRecordsRequest, callback func(response *DescribeRunningLogRecordsResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeRunningLogRecordsResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeRunningLogRecords(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeRunningLogRecordsRequest is the request struct for api DescribeRunningLogRecords
+type DescribeRunningLogRecordsRequest struct {
+	*requests.RpcRequest
+	SQLId                requests.Integer `position:"Query" name:"SQLId"`
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	EndTime              string           `position:"Query" name:"EndTime"`
+	StartTime            string           `position:"Query" name:"StartTime"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+	PageNumber           requests.Integer `position:"Query" name:"PageNumber"`
+	DBName               string           `position:"Query" name:"DBName"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	PageSize             requests.Integer `position:"Query" name:"PageSize"`
+	DBInstanceId         string           `position:"Query" name:"DBInstanceId"`
+	RoleType             string           `position:"Query" name:"RoleType"`
+	NodeId               string           `position:"Query" name:"NodeId"`
+}
+
+// DescribeRunningLogRecordsResponse is the response struct for api DescribeRunningLogRecords
+type DescribeRunningLogRecordsResponse struct {
+	*responses.BaseResponse
+	RequestId        string                           `json:"RequestId" xml:"RequestId"`
+	Engine           string                           `json:"Engine" xml:"Engine"`
+	TotalRecordCount int                              `json:"TotalRecordCount" xml:"TotalRecordCount"`
+	PageNumber       int                              `json:"PageNumber" xml:"PageNumber"`
+	PageRecordCount  int                              `json:"PageRecordCount" xml:"PageRecordCount"`
+	Items            ItemsInDescribeRunningLogRecords `json:"Items" xml:"Items"`
+}
+
+// CreateDescribeRunningLogRecordsRequest creates a request to invoke DescribeRunningLogRecords API
+func CreateDescribeRunningLogRecordsRequest() (request *DescribeRunningLogRecordsRequest) {
+	request = &DescribeRunningLogRecordsRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeRunningLogRecords", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeRunningLogRecordsResponse creates a response to parse from DescribeRunningLogRecords response
+func CreateDescribeRunningLogRecordsResponse() (response *DescribeRunningLogRecordsResponse) {
+	response = &DescribeRunningLogRecordsResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/describe_slow_log_records.go

@@ -0,0 +1,120 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// DescribeSlowLogRecords invokes the dds.DescribeSlowLogRecords API synchronously
+// api document: https://help.aliyun.com/api/dds/describeslowlogrecords.html
+func (client *Client) DescribeSlowLogRecords(request *DescribeSlowLogRecordsRequest) (response *DescribeSlowLogRecordsResponse, err error) {
+	response = CreateDescribeSlowLogRecordsResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeSlowLogRecordsWithChan invokes the dds.DescribeSlowLogRecords API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeslowlogrecords.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeSlowLogRecordsWithChan(request *DescribeSlowLogRecordsRequest) (<-chan *DescribeSlowLogRecordsResponse, <-chan error) {
+	responseChan := make(chan *DescribeSlowLogRecordsResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeSlowLogRecords(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeSlowLogRecordsWithCallback invokes the dds.DescribeSlowLogRecords API asynchronously
+// api document: https://help.aliyun.com/api/dds/describeslowlogrecords.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeSlowLogRecordsWithCallback(request *DescribeSlowLogRecordsRequest, callback func(response *DescribeSlowLogRecordsResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeSlowLogRecordsResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeSlowLogRecords(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeSlowLogRecordsRequest is the request struct for api DescribeSlowLogRecords
+type DescribeSlowLogRecordsRequest struct {
+	*requests.RpcRequest
+	SQLId                requests.Integer `position:"Query" name:"SQLId"`
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	EndTime              string           `position:"Query" name:"EndTime"`
+	StartTime            string           `position:"Query" name:"StartTime"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+	PageNumber           requests.Integer `position:"Query" name:"PageNumber"`
+	DBName               string           `position:"Query" name:"DBName"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	PageSize             requests.Integer `position:"Query" name:"PageSize"`
+	DBInstanceId         string           `position:"Query" name:"DBInstanceId"`
+	NodeId               string           `position:"Query" name:"NodeId"`
+}
+
+// DescribeSlowLogRecordsResponse is the response struct for api DescribeSlowLogRecords
+type DescribeSlowLogRecordsResponse struct {
+	*responses.BaseResponse
+	RequestId        string                        `json:"RequestId" xml:"RequestId"`
+	Engine           string                        `json:"Engine" xml:"Engine"`
+	TotalRecordCount int                           `json:"TotalRecordCount" xml:"TotalRecordCount"`
+	PageNumber       int                           `json:"PageNumber" xml:"PageNumber"`
+	PageRecordCount  int                           `json:"PageRecordCount" xml:"PageRecordCount"`
+	Items            ItemsInDescribeSlowLogRecords `json:"Items" xml:"Items"`
+}
+
+// CreateDescribeSlowLogRecordsRequest creates a request to invoke DescribeSlowLogRecords API
+func CreateDescribeSlowLogRecordsRequest() (request *DescribeSlowLogRecordsRequest) {
+	request = &DescribeSlowLogRecordsRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "DescribeSlowLogRecords", "dds", "openAPI")
+	return
+}
+
+// CreateDescribeSlowLogRecordsResponse creates a response to parse from DescribeSlowLogRecords response
+func CreateDescribeSlowLogRecordsResponse() (response *DescribeSlowLogRecordsResponse) {
+	response = &DescribeSlowLogRecordsResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/modify_active_operation_task.go

@@ -0,0 +1,110 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// ModifyActiveOperationTask invokes the dds.ModifyActiveOperationTask API synchronously
+// api document: https://help.aliyun.com/api/dds/modifyactiveoperationtask.html
+func (client *Client) ModifyActiveOperationTask(request *ModifyActiveOperationTaskRequest) (response *ModifyActiveOperationTaskResponse, err error) {
+	response = CreateModifyActiveOperationTaskResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// ModifyActiveOperationTaskWithChan invokes the dds.ModifyActiveOperationTask API asynchronously
+// api document: https://help.aliyun.com/api/dds/modifyactiveoperationtask.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) ModifyActiveOperationTaskWithChan(request *ModifyActiveOperationTaskRequest) (<-chan *ModifyActiveOperationTaskResponse, <-chan error) {
+	responseChan := make(chan *ModifyActiveOperationTaskResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.ModifyActiveOperationTask(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// ModifyActiveOperationTaskWithCallback invokes the dds.ModifyActiveOperationTask API asynchronously
+// api document: https://help.aliyun.com/api/dds/modifyactiveoperationtask.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) ModifyActiveOperationTaskWithCallback(request *ModifyActiveOperationTaskRequest, callback func(response *ModifyActiveOperationTaskResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *ModifyActiveOperationTaskResponse
+		var err error
+		defer close(result)
+		response, err = client.ModifyActiveOperationTask(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// ModifyActiveOperationTaskRequest is the request struct for api ModifyActiveOperationTask
+type ModifyActiveOperationTaskRequest struct {
+	*requests.RpcRequest
+	ResourceOwnerId      requests.Integer `position:"Query" name:"ResourceOwnerId"`
+	SecurityToken        string           `position:"Query" name:"SecurityToken"`
+	ResourceOwnerAccount string           `position:"Query" name:"ResourceOwnerAccount"`
+	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
+	Ids                  string           `position:"Query" name:"Ids"`
+	SwitchTime           string           `position:"Query" name:"SwitchTime"`
+	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+}
+
+// ModifyActiveOperationTaskResponse is the response struct for api ModifyActiveOperationTask
+type ModifyActiveOperationTaskResponse struct {
+	*responses.BaseResponse
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	Ids       string `json:"Ids" xml:"Ids"`
+}
+
+// CreateModifyActiveOperationTaskRequest creates a request to invoke ModifyActiveOperationTask API
+func CreateModifyActiveOperationTaskRequest() (request *ModifyActiveOperationTaskRequest) {
+	request = &ModifyActiveOperationTaskRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("Dds", "2015-12-01", "ModifyActiveOperationTask", "dds", "openAPI")
+	return
+}
+
+// CreateModifyActiveOperationTaskResponse creates a response to parse from ModifyActiveOperationTask response
+func CreateModifyActiveOperationTaskResponse() (response *ModifyActiveOperationTaskResponse) {
+	response = &ModifyActiveOperationTaskResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/dds/modify_db_instance_spec.go

@@ -84,6 +84,7 @@ type ModifyDBInstanceSpecRequest struct {
 	OwnerAccount         string           `position:"Query" name:"OwnerAccount"`
 	CouponNo             string           `position:"Query" name:"CouponNo"`
 	OwnerId              requests.Integer `position:"Query" name:"OwnerId"`
+	ReplicationFactor    string           `position:"Query" name:"ReplicationFactor"`
 	DBInstanceClass      string           `position:"Query" name:"DBInstanceClass"`
 	SecurityToken        string           `position:"Query" name:"SecurityToken"`
 	EffectiveTime        string           `position:"Query" name:"EffectiveTime"`

services/dds/struct_db_instance.go

@@ -17,34 +17,36 @@ package dds
 
 // DBInstance is a nested struct in dds response
 type DBInstance struct {
-	ReplicaSetName        string                                  `json:"ReplicaSetName" xml:"ReplicaSetName"`
-	DBInstanceDescription string                                  `json:"DBInstanceDescription" xml:"DBInstanceDescription"`
-	Engine                string                                  `json:"Engine" xml:"Engine"`
-	ChargeType            string                                  `json:"ChargeType" xml:"ChargeType"`
-	DBInstanceClass       string                                  `json:"DBInstanceClass" xml:"DBInstanceClass"`
-	DestroyTime           string                                  `json:"DestroyTime" xml:"DestroyTime"`
-	RegionId              string                                  `json:"RegionId" xml:"RegionId"`
-	MaxConnections        int                                     `json:"MaxConnections" xml:"MaxConnections"`
-	DBInstanceType        string                                  `json:"DBInstanceType" xml:"DBInstanceType"`
-	MaintainEndTime       string                                  `json:"MaintainEndTime" xml:"MaintainEndTime"`
-	ExpireTime            string                                  `json:"ExpireTime" xml:"ExpireTime"`
-	DBInstanceId          string                                  `json:"DBInstanceId" xml:"DBInstanceId"`
-	NetworkType           string                                  `json:"NetworkType" xml:"NetworkType"`
-	ReplicationFactor     string                                  `json:"ReplicationFactor" xml:"ReplicationFactor"`
-	MaxIOPS               int                                     `json:"MaxIOPS" xml:"MaxIOPS"`
-	ReplacateId           string                                  `json:"ReplacateId" xml:"ReplacateId"`
-	EngineVersion         string                                  `json:"EngineVersion" xml:"EngineVersion"`
-	VPCId                 string                                  `json:"VPCId" xml:"VPCId"`
-	VSwitchId             string                                  `json:"VSwitchId" xml:"VSwitchId"`
-	MaintainStartTime     string                                  `json:"MaintainStartTime" xml:"MaintainStartTime"`
-	DBInstanceStorage     int                                     `json:"DBInstanceStorage" xml:"DBInstanceStorage"`
-	CreationTime          string                                  `json:"CreationTime" xml:"CreationTime"`
-	StorageEngine         string                                  `json:"StorageEngine" xml:"StorageEngine"`
-	DBInstanceStatus      string                                  `json:"DBInstanceStatus" xml:"DBInstanceStatus"`
-	CurrentKernelVersion  string                                  `json:"CurrentKernelVersion" xml:"CurrentKernelVersion"`
-	ZoneId                string                                  `json:"ZoneId" xml:"ZoneId"`
-	LastDowngradeTime     int                                     `json:"LastDowngradeTime" xml:"LastDowngradeTime"`
-	LockMode              string                                  `json:"LockMode" xml:"LockMode"`
-	ShardList             ShardListInDescribeDBInstances          `json:"ShardList" xml:"ShardList"`
-	MongosList            MongosListInDescribeDBInstanceAttribute `json:"MongosList" xml:"MongosList"`
+	ReplicaSetName        string                                   `json:"ReplicaSetName" xml:"ReplicaSetName"`
+	DBInstanceDescription string                                   `json:"DBInstanceDescription" xml:"DBInstanceDescription"`
+	Engine                string                                   `json:"Engine" xml:"Engine"`
+	ChargeType            string                                   `json:"ChargeType" xml:"ChargeType"`
+	DBInstanceClass       string                                   `json:"DBInstanceClass" xml:"DBInstanceClass"`
+	DestroyTime           string                                   `json:"DestroyTime" xml:"DestroyTime"`
+	RegionId              string                                   `json:"RegionId" xml:"RegionId"`
+	MaxConnections        int                                      `json:"MaxConnections" xml:"MaxConnections"`
+	DBInstanceType        string                                   `json:"DBInstanceType" xml:"DBInstanceType"`
+	MaintainEndTime       string                                   `json:"MaintainEndTime" xml:"MaintainEndTime"`
+	ExpireTime            string                                   `json:"ExpireTime" xml:"ExpireTime"`
+	DBInstanceId          string                                   `json:"DBInstanceId" xml:"DBInstanceId"`
+	NetworkType           string                                   `json:"NetworkType" xml:"NetworkType"`
+	ReplicationFactor     string                                   `json:"ReplicationFactor" xml:"ReplicationFactor"`
+	MaxIOPS               int                                      `json:"MaxIOPS" xml:"MaxIOPS"`
+	ReplacateId           string                                   `json:"ReplacateId" xml:"ReplacateId"`
+	EngineVersion         string                                   `json:"EngineVersion" xml:"EngineVersion"`
+	VPCId                 string                                   `json:"VPCId" xml:"VPCId"`
+	VSwitchId             string                                   `json:"VSwitchId" xml:"VSwitchId"`
+	VPCCloudInstanceIds   string                                   `json:"VPCCloudInstanceIds" xml:"VPCCloudInstanceIds"`
+	MaintainStartTime     string                                   `json:"MaintainStartTime" xml:"MaintainStartTime"`
+	DBInstanceStorage     int                                      `json:"DBInstanceStorage" xml:"DBInstanceStorage"`
+	CreationTime          string                                   `json:"CreationTime" xml:"CreationTime"`
+	StorageEngine         string                                   `json:"StorageEngine" xml:"StorageEngine"`
+	DBInstanceStatus      string                                   `json:"DBInstanceStatus" xml:"DBInstanceStatus"`
+	CurrentKernelVersion  string                                   `json:"CurrentKernelVersion" xml:"CurrentKernelVersion"`
+	ZoneId                string                                   `json:"ZoneId" xml:"ZoneId"`
+	LastDowngradeTime     int                                      `json:"LastDowngradeTime" xml:"LastDowngradeTime"`
+	LockMode              string                                   `json:"LockMode" xml:"LockMode"`
+	ReplicaSets           ReplicaSetsInDescribeDBInstanceAttribute `json:"ReplicaSets" xml:"ReplicaSets"`
+	ShardList             ShardListInDescribeDBInstances           `json:"ShardList" xml:"ShardList"`
+	MongosList            MongosListInDescribeDBInstanceAttribute  `json:"MongosList" xml:"MongosList"`
 }

services/dds/struct_items.go

@@ -17,20 +17,21 @@ package dds
 
 // Items is a nested struct in dds response
 type Items struct {
-	DBInstanceDescription    string  `json:"DBInstanceDescription" xml:"DBInstanceDescription"`
-	Engine                   string  `json:"Engine" xml:"Engine"`
-	ReadWriteType            string  `json:"ReadWriteType" xml:"ReadWriteType"`
-	DomainMode               string  `json:"DomainMode" xml:"DomainMode"`
-	ReplicaStatus            string  `json:"ReplicaStatus" xml:"ReplicaStatus"`
-	ReplicaMode              string  `json:"ReplicaMode" xml:"ReplicaMode"`
-	ReplicationClusterStatus string  `json:"ReplicationClusterStatus" xml:"ReplicationClusterStatus"`
-	DBInstanceStatus         string  `json:"DBInstanceStatus" xml:"DBInstanceStatus"`
-	RegionId                 string  `json:"RegionId" xml:"RegionId"`
-	Role                     string  `json:"Role" xml:"Role"`
-	InstanceNetworkType      string  `json:"InstanceNetworkType" xml:"InstanceNetworkType"`
-	ZoneId                   string  `json:"ZoneId" xml:"ZoneId"`
-	ReplicaDescription       string  `json:"ReplicaDescription" xml:"ReplicaDescription"`
-	DBInstanceId             string  `json:"DBInstanceId" xml:"DBInstanceId"`
-	ReplicaId                string  `json:"ReplicaId" xml:"ReplicaId"`
-	DBInstances              []Items `json:"DBInstances" xml:"DBInstances"`
+	Region                string  `json:"Region" xml:"Region"`
+	Count                 int     `json:"Count" xml:"Count"`
+	DBInstanceDescription string  `json:"DBInstanceDescription" xml:"DBInstanceDescription"`
+	Engine                string  `json:"Engine" xml:"Engine"`
+	ReadWriteType         string  `json:"ReadWriteType" xml:"ReadWriteType"`
+	DomainMode            string  `json:"DomainMode" xml:"DomainMode"`
+	ReplicaStatus         string  `json:"ReplicaStatus" xml:"ReplicaStatus"`
+	ReplicaMode           string  `json:"ReplicaMode" xml:"ReplicaMode"`
+	DBInstanceStatus      string  `json:"DBInstanceStatus" xml:"DBInstanceStatus"`
+	RegionId              string  `json:"RegionId" xml:"RegionId"`
+	Role                  string  `json:"Role" xml:"Role"`
+	InstanceNetworkType   string  `json:"InstanceNetworkType" xml:"InstanceNetworkType"`
+	ReplicaDescription    string  `json:"ReplicaDescription" xml:"ReplicaDescription"`
+	DBInstanceId          string  `json:"DBInstanceId" xml:"DBInstanceId"`
+	TaskType              string  `json:"TaskType" xml:"TaskType"`
+	ReplicaId             string  `json:"ReplicaId" xml:"ReplicaId"`
+	DBInstances           []Items `json:"DBInstances" xml:"DBInstances"`
 }

services/dds/struct_items_in_describe_active_operation_task.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// ItemsInDescribeActiveOperationTask is a nested struct in dds response
+type ItemsInDescribeActiveOperationTask struct {
+	ItemsItem []ItemsItem `json:"ItemsItem" xml:"ItemsItem"`
+}

services/dds/struct_items_in_describe_error_log_records.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// ItemsInDescribeErrorLogRecords is a nested struct in dds response
+type ItemsInDescribeErrorLogRecords struct {
+	LogRecords []LogRecords `json:"LogRecords" xml:"LogRecords"`
+}

services/dds/struct_items_in_describe_replica_initialize_progress.go

@@ -17,5 +17,5 @@ package dds
 
 // ItemsInDescribeReplicaInitializeProgress is a nested struct in dds response
 type ItemsInDescribeReplicaInitializeProgress struct {
-	ItemsItem []ItemsItem `json:"ItemsItem" xml:"ItemsItem"`
+	ItemsItem []ItemsItemInDescribeReplicaInitializeProgress `json:"ItemsItem" xml:"ItemsItem"`
 }

services/dds/struct_items_in_describe_running_log_records.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// ItemsInDescribeRunningLogRecords is a nested struct in dds response
+type ItemsInDescribeRunningLogRecords struct {
+	LogRecords []LogRecords `json:"LogRecords" xml:"LogRecords"`
+}

services/dds/struct_items_in_describe_slow_log_records.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// ItemsInDescribeSlowLogRecords is a nested struct in dds response
+type ItemsInDescribeSlowLogRecords struct {
+	LogRecords []LogRecords `json:"LogRecords" xml:"LogRecords"`
+}

services/dds/struct_items_item.go

@@ -17,36 +17,44 @@ package dds
 
 // ItemsItem is a nested struct in dds response
 type ItemsItem struct {
+	ResultInfo            string         `json:"ResultInfo" xml:"ResultInfo"`
+	InsName               string         `json:"InsName" xml:"InsName"`
 	InternetIP            string         `json:"InternetIP" xml:"InternetIP"`
 	ConfictReason         string         `json:"ConfictReason" xml:"ConfictReason"`
 	SourceDetail          string         `json:"SourceDetail" xml:"SourceDetail"`
+	TaskParams            string         `json:"TaskParams" xml:"TaskParams"`
 	InconsistentFields    string         `json:"InconsistentFields" xml:"InconsistentFields"`
 	InstanceIdA           string         `json:"InstanceIdA" xml:"InstanceIdA"`
+	Deadline              string         `json:"Deadline" xml:"Deadline"`
 	ConflictGtid          string         `json:"ConflictGtid" xml:"ConflictGtid"`
 	DestinationDetail     string         `json:"DestinationDetail" xml:"DestinationDetail"`
+	DbType                string         `json:"DbType" xml:"DbType"`
 	Key                   string         `json:"Key" xml:"Key"`
+	ModifiedTime          string         `json:"ModifiedTime" xml:"ModifiedTime"`
+	CreatedTime           string         `json:"CreatedTime" xml:"CreatedTime"`
 	RegionId              string         `json:"RegionId" xml:"RegionId"`
 	InstanceNetworkType   string         `json:"InstanceNetworkType" xml:"InstanceNetworkType"`
 	RecoveryMode          string         `json:"RecoveryMode" xml:"RecoveryMode"`
 	AbnormalType          string         `json:"AbnormalType" xml:"AbnormalType"`
+	SwitchTime            string         `json:"SwitchTime" xml:"SwitchTime"`
 	DBInstanceId          string         `json:"DBInstanceId" xml:"DBInstanceId"`
 	DatabaseName          string         `json:"DatabaseName" xml:"DatabaseName"`
 	SecurityIPList        string         `json:"SecurityIPList" xml:"SecurityIPList"`
 	DetailInfo            string         `json:"DetailInfo" xml:"DetailInfo"`
+	Id                    int            `json:"Id" xml:"Id"`
+	Status                int            `json:"Status" xml:"Status"`
 	Schema                string         `json:"Schema" xml:"Schema"`
 	ReadWriteType         string         `json:"ReadWriteType" xml:"ReadWriteType"`
 	HasInternetIP         bool           `json:"HasInternetIP" xml:"HasInternetIP"`
 	DestinationInstanceId string         `json:"DestinationInstanceId" xml:"DestinationInstanceId"`
-	FinishTime            string         `json:"FinishTime" xml:"FinishTime"`
+	PrepareInterval       string         `json:"PrepareInterval" xml:"PrepareInterval"`
 	OccurTime             string         `json:"OccurTime" xml:"OccurTime"`
-	Progress              string         `json:"Progress" xml:"Progress"`
 	InstanceIdB           string         `json:"InstanceIdB" xml:"InstanceIdB"`
-	CurrentStep           string         `json:"CurrentStep" xml:"CurrentStep"`
+	StartTime             string         `json:"StartTime" xml:"StartTime"`
 	SourceInstanceId      string         `json:"SourceInstanceId" xml:"SourceInstanceId"`
 	InconsistentType      string         `json:"InconsistentType" xml:"InconsistentType"`
 	ConfictKey            string         `json:"ConfictKey" xml:"ConfictKey"`
 	KeyType               string         `json:"KeyType" xml:"KeyType"`
-	Status                string         `json:"Status" xml:"Status"`
-	ReplicaId             string         `json:"ReplicaId" xml:"ReplicaId"`
+	TaskType              string         `json:"TaskType" xml:"TaskType"`
 	Accounts              []AccountsItem `json:"Accounts" xml:"Accounts"`
 }

services/dds/struct_items_item_in_describe_replica_initialize_progress.go

@@ -0,0 +1,25 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// ItemsItemInDescribeReplicaInitializeProgress is a nested struct in dds response
+type ItemsItemInDescribeReplicaInitializeProgress struct {
+	ReplicaId   string `json:"ReplicaId" xml:"ReplicaId"`
+	Status      string `json:"Status" xml:"Status"`
+	Progress    string `json:"Progress" xml:"Progress"`
+	FinishTime  string `json:"FinishTime" xml:"FinishTime"`
+	CurrentStep string `json:"CurrentStep" xml:"CurrentStep"`
+}

services/dds/struct_log_records.go

@@ -0,0 +1,34 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// LogRecords is a nested struct in dds response
+type LogRecords struct {
+	Category           string `json:"Category" xml:"Category"`
+	Id                 int    `json:"Id" xml:"Id"`
+	HostAddress        string `json:"HostAddress" xml:"HostAddress"`
+	CreateTime         string `json:"CreateTime" xml:"CreateTime"`
+	QueryTimes         string `json:"QueryTimes" xml:"QueryTimes"`
+	SQLText            string `json:"SQLText" xml:"SQLText"`
+	ConnInfo           string `json:"ConnInfo" xml:"ConnInfo"`
+	Content            int    `json:"Content" xml:"Content"`
+	ExecutionStartTime string `json:"ExecutionStartTime" xml:"ExecutionStartTime"`
+	ReturnRowCounts    int    `json:"ReturnRowCounts" xml:"ReturnRowCounts"`
+	AccountName        string `json:"AccountName" xml:"AccountName"`
+	DocsExamined       int    `json:"DocsExamined" xml:"DocsExamined"`
+	DBName             string `json:"DBName" xml:"DBName"`
+	KeysExamined       int    `json:"KeysExamined" xml:"KeysExamined"`
+}

services/dds/struct_mongos_attribute.go

@@ -17,11 +17,14 @@ package dds
 
 // MongosAttribute is a nested struct in dds response
 type MongosAttribute struct {
-	MaxIOPS         int    `json:"MaxIOPS" xml:"MaxIOPS"`
-	NodeId          string `json:"NodeId" xml:"NodeId"`
-	NodeDescription string `json:"NodeDescription" xml:"NodeDescription"`
-	Port            int    `json:"Port" xml:"Port"`
-	MaxConnections  int    `json:"MaxConnections" xml:"MaxConnections"`
-	ConnectSting    string `json:"ConnectSting" xml:"ConnectSting"`
-	NodeClass       string `json:"NodeClass" xml:"NodeClass"`
+	MaxIOPS            int    `json:"MaxIOPS" xml:"MaxIOPS"`
+	NodeId             string `json:"NodeId" xml:"NodeId"`
+	NodeDescription    string `json:"NodeDescription" xml:"NodeDescription"`
+	Port               int    `json:"Port" xml:"Port"`
+	MaxConnections     int    `json:"MaxConnections" xml:"MaxConnections"`
+	VPCId              string `json:"VPCId" xml:"VPCId"`
+	ConnectSting       string `json:"ConnectSting" xml:"ConnectSting"`
+	VSwitchId          string `json:"VSwitchId" xml:"VSwitchId"`
+	NodeClass          string `json:"NodeClass" xml:"NodeClass"`
+	VpcCloudInstanceId string `json:"VpcCloudInstanceId" xml:"VpcCloudInstanceId"`
 }

services/dds/struct_region_list.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// RegionList is a nested struct in dds response
+type RegionList struct {
+	Items []Items `json:"Items" xml:"Items"`
+}

services/dds/struct_replica_set.go

@@ -17,9 +17,13 @@ package dds
 
 // ReplicaSet is a nested struct in dds response
 type ReplicaSet struct {
-	ReplicaSetRole   string `json:"ReplicaSetRole" xml:"ReplicaSetRole"`
-	ConnectionDomain string `json:"ConnectionDomain" xml:"ConnectionDomain"`
-	ConnectionPort   string `json:"ConnectionPort" xml:"ConnectionPort"`
-	ExpiredTime      string `json:"ExpiredTime" xml:"ExpiredTime"`
-	NetworkType      string `json:"NetworkType" xml:"NetworkType"`
+	VPCCloudInstanceId string `json:"VPCCloudInstanceId" xml:"VPCCloudInstanceId"`
+	ConnectionPort     string `json:"ConnectionPort" xml:"ConnectionPort"`
+	RoleId             string `json:"RoleId" xml:"RoleId"`
+	ExpiredTime        string `json:"ExpiredTime" xml:"ExpiredTime"`
+	VPCId              string `json:"VPCId" xml:"VPCId"`
+	VSwitchId          string `json:"VSwitchId" xml:"VSwitchId"`
+	ReplicaSetRole     string `json:"ReplicaSetRole" xml:"ReplicaSetRole"`
+	ConnectionDomain   string `json:"ConnectionDomain" xml:"ConnectionDomain"`
+	NetworkType        string `json:"NetworkType" xml:"NetworkType"`
 }

services/dds/struct_replica_sets_in_describe_db_instance_attribute.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// ReplicaSetsInDescribeDBInstanceAttribute is a nested struct in dds response
+type ReplicaSetsInDescribeDBInstanceAttribute struct {
+	ReplicaSet []ReplicaSet `json:"ReplicaSet" xml:"ReplicaSet"`
+}

services/dds/struct_replica_sets.go → services/dds/struct_replica_sets_in_describe_replica_set_role.go

@@ -15,7 +15,7 @@ package dds
 // Code generated by Alibaba Cloud SDK Code Generator.
 // Changes may cause incorrect behavior and will be lost if the code is regenerated.
 
-// ReplicaSets is a nested struct in dds response
-type ReplicaSets struct {
+// ReplicaSetsInDescribeReplicaSetRole is a nested struct in dds response
+type ReplicaSetsInDescribeReplicaSetRole struct {
 	ReplicaSet []ReplicaSet `json:"ReplicaSet" xml:"ReplicaSet"`
 }

services/dds/struct_tunnel_context.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// TunnelContext is a nested struct in dds response
+type TunnelContext struct {
+	TunnelContext []string `json:"TunnelContext" xml:"TunnelContext"`
+}

services/dds/struct_type_list.go

@@ -0,0 +1,21 @@
+package dds
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// TypeList is a nested struct in dds response
+type TypeList struct {
+	Items []Items `json:"Items" xml:"Items"`
+}