-
Notifications
You must be signed in to change notification settings - Fork 273
/
describe_dts_job_detail.go
154 lines (145 loc) · 8.49 KB
/
describe_dts_job_detail.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
package dts
//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"
)
// DescribeDtsJobDetail invokes the dts.DescribeDtsJobDetail API synchronously
func (client *Client) DescribeDtsJobDetail(request *DescribeDtsJobDetailRequest) (response *DescribeDtsJobDetailResponse, err error) {
response = CreateDescribeDtsJobDetailResponse()
err = client.DoAction(request, response)
return
}
// DescribeDtsJobDetailWithChan invokes the dts.DescribeDtsJobDetail API asynchronously
func (client *Client) DescribeDtsJobDetailWithChan(request *DescribeDtsJobDetailRequest) (<-chan *DescribeDtsJobDetailResponse, <-chan error) {
responseChan := make(chan *DescribeDtsJobDetailResponse, 1)
errChan := make(chan error, 1)
err := client.AddAsyncTask(func() {
defer close(responseChan)
defer close(errChan)
response, err := client.DescribeDtsJobDetail(request)
if err != nil {
errChan <- err
} else {
responseChan <- response
}
})
if err != nil {
errChan <- err
close(responseChan)
close(errChan)
}
return responseChan, errChan
}
// DescribeDtsJobDetailWithCallback invokes the dts.DescribeDtsJobDetail API asynchronously
func (client *Client) DescribeDtsJobDetailWithCallback(request *DescribeDtsJobDetailRequest, callback func(response *DescribeDtsJobDetailResponse, err error)) <-chan int {
result := make(chan int, 1)
err := client.AddAsyncTask(func() {
var response *DescribeDtsJobDetailResponse
var err error
defer close(result)
response, err = client.DescribeDtsJobDetail(request)
callback(response, err)
result <- 1
})
if err != nil {
defer close(result)
callback(nil, err)
result <- 0
}
return result
}
// DescribeDtsJobDetailRequest is the request struct for api DescribeDtsJobDetail
type DescribeDtsJobDetailRequest struct {
*requests.RpcRequest
SyncSubJobHistory requests.Boolean `position:"Query" name:"SyncSubJobHistory"`
DtsJobId string `position:"Query" name:"DtsJobId"`
DtsInstanceID string `position:"Query" name:"DtsInstanceID"`
SynchronizationDirection string `position:"Query" name:"SynchronizationDirection"`
}
// DescribeDtsJobDetailResponse is the response struct for api DescribeDtsJobDetail
type DescribeDtsJobDetailResponse struct {
*responses.BaseResponse
Status string `json:"Status" xml:"Status"`
DtsJobName string `json:"DtsJobName" xml:"DtsJobName"`
FinishTime string `json:"FinishTime" xml:"FinishTime"`
ErrorMessage string `json:"ErrorMessage" xml:"ErrorMessage"`
DtsJobId string `json:"DtsJobId" xml:"DtsJobId"`
CreateTime string `json:"CreateTime" xml:"CreateTime"`
PayType string `json:"PayType" xml:"PayType"`
Reserved string `json:"Reserved" xml:"Reserved"`
DatabaseCount int `json:"DatabaseCount" xml:"DatabaseCount"`
DtsJobClass string `json:"DtsJobClass" xml:"DtsJobClass"`
EndTimestamp string `json:"EndTimestamp" xml:"EndTimestamp"`
AppName string `json:"AppName" xml:"AppName"`
DestNetType string `json:"DestNetType" xml:"DestNetType"`
SubscribeTopic string `json:"SubscribeTopic" xml:"SubscribeTopic"`
DtsInstanceID string `json:"DtsInstanceID" xml:"DtsInstanceID"`
RequestId string `json:"RequestId" xml:"RequestId"`
Code int `json:"Code" xml:"Code"`
Checkpoint int64 `json:"Checkpoint" xml:"Checkpoint"`
Delay int64 `json:"Delay" xml:"Delay"`
ExpireTime string `json:"ExpireTime" xml:"ExpireTime"`
ErrCode string `json:"ErrCode" xml:"ErrCode"`
Success bool `json:"Success" xml:"Success"`
ErrMessage string `json:"ErrMessage" xml:"ErrMessage"`
ConsumptionClient string `json:"ConsumptionClient" xml:"ConsumptionClient"`
DbObject string `json:"DbObject" xml:"DbObject"`
DynamicMessage string `json:"DynamicMessage" xml:"DynamicMessage"`
ConsumptionCheckpoint string `json:"ConsumptionCheckpoint" xml:"ConsumptionCheckpoint"`
EtlCalculator string `json:"EtlCalculator" xml:"EtlCalculator"`
HttpStatusCode int `json:"HttpStatusCode" xml:"HttpStatusCode"`
BeginTimestamp string `json:"BeginTimestamp" xml:"BeginTimestamp"`
GroupId string `json:"GroupId" xml:"GroupId"`
SynchronizationDirection string `json:"SynchronizationDirection" xml:"SynchronizationDirection"`
DtsJobDirection string `json:"DtsJobDirection" xml:"DtsJobDirection"`
DemoJob bool `json:"DemoJob" xml:"DemoJob"`
JobType string `json:"JobType" xml:"JobType"`
TaskType string `json:"TaskType" xml:"TaskType"`
DedicatedClusterId string `json:"DedicatedClusterId" xml:"DedicatedClusterId"`
BootTime string `json:"BootTime" xml:"BootTime"`
Binlog string `json:"Binlog" xml:"Binlog"`
BinlogSite string `json:"BinlogSite" xml:"BinlogSite"`
BinlogTime string `json:"BinlogTime" xml:"BinlogTime"`
LastUpdateTime string `json:"LastUpdateTime" xml:"LastUpdateTime"`
ResourceGroupId string `json:"ResourceGroupId" xml:"ResourceGroupId"`
ResourceGroupDisplayName string `json:"ResourceGroupDisplayName" xml:"ResourceGroupDisplayName"`
SourceEndpoint SourceEndpoint `json:"SourceEndpoint" xml:"SourceEndpoint"`
DestinationEndpoint DestinationEndpoint `json:"DestinationEndpoint" xml:"DestinationEndpoint"`
MigrationMode MigrationMode `json:"MigrationMode" xml:"MigrationMode"`
SubscriptionHost SubscriptionHost `json:"SubscriptionHost" xml:"SubscriptionHost"`
SubscriptionDataType SubscriptionDataType `json:"SubscriptionDataType" xml:"SubscriptionDataType"`
DataSynchronizationStatus DataSynchronizationStatus `json:"DataSynchronizationStatus" xml:"DataSynchronizationStatus"`
RetryState RetryState `json:"RetryState" xml:"RetryState"`
SubDistributedJob []SubDistributedJobItem `json:"SubDistributedJob" xml:"SubDistributedJob"`
SubSyncJob []SubSyncJobItem `json:"SubSyncJob" xml:"SubSyncJob"`
}
// CreateDescribeDtsJobDetailRequest creates a request to invoke DescribeDtsJobDetail API
func CreateDescribeDtsJobDetailRequest() (request *DescribeDtsJobDetailRequest) {
request = &DescribeDtsJobDetailRequest{
RpcRequest: &requests.RpcRequest{},
}
request.InitWithApiInfo("Dts", "2020-01-01", "DescribeDtsJobDetail", "dts", "openAPI")
request.Method = requests.POST
return
}
// CreateDescribeDtsJobDetailResponse creates a response to parse from DescribeDtsJobDetail response
func CreateDescribeDtsJobDetailResponse() (response *DescribeDtsJobDetailResponse) {
response = &DescribeDtsJobDetailResponse{
BaseResponse: &responses.BaseResponse{},
}
return
}