get_repo_sync_task.go 2.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. package cr
  2. //Licensed under the Apache License, Version 2.0 (the "License");
  3. //you may not use this file except in compliance with the License.
  4. //You may obtain a copy of the License at
  5. //
  6. //http://www.apache.org/licenses/LICENSE-2.0
  7. //
  8. //Unless required by applicable law or agreed to in writing, software
  9. //distributed under the License is distributed on an "AS IS" BASIS,
  10. //WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  11. //See the License for the specific language governing permissions and
  12. //limitations under the License.
  13. //
  14. // Code generated by Alibaba Cloud SDK Code Generator.
  15. // Changes may cause incorrect behavior and will be lost if the code is regenerated.
  16. import (
  17. "github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
  18. "github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
  19. )
  20. func (client *Client) GetRepoSyncTask(request *GetRepoSyncTaskRequest) (response *GetRepoSyncTaskResponse, err error) {
  21. response = CreateGetRepoSyncTaskResponse()
  22. err = client.DoAction(request, response)
  23. return
  24. }
  25. func (client *Client) GetRepoSyncTaskWithChan(request *GetRepoSyncTaskRequest) (<-chan *GetRepoSyncTaskResponse, <-chan error) {
  26. responseChan := make(chan *GetRepoSyncTaskResponse, 1)
  27. errChan := make(chan error, 1)
  28. err := client.AddAsyncTask(func() {
  29. defer close(responseChan)
  30. defer close(errChan)
  31. response, err := client.GetRepoSyncTask(request)
  32. responseChan <- response
  33. errChan <- err
  34. })
  35. if err != nil {
  36. errChan <- err
  37. close(responseChan)
  38. close(errChan)
  39. }
  40. return responseChan, errChan
  41. }
  42. func (client *Client) GetRepoSyncTaskWithCallback(request *GetRepoSyncTaskRequest, callback func(response *GetRepoSyncTaskResponse, err error)) <-chan int {
  43. result := make(chan int, 1)
  44. err := client.AddAsyncTask(func() {
  45. var response *GetRepoSyncTaskResponse
  46. var err error
  47. defer close(result)
  48. response, err = client.GetRepoSyncTask(request)
  49. callback(response, err)
  50. result <- 1
  51. })
  52. if err != nil {
  53. defer close(result)
  54. callback(nil, err)
  55. result <- 0
  56. }
  57. return result
  58. }
  59. type GetRepoSyncTaskRequest struct {
  60. *requests.RoaRequest
  61. RepoNamespace string `position:"Path" name:"RepoNamespace"`
  62. RepoName string `position:"Path" name:"RepoName"`
  63. SyncTaskId string `position:"Path" name:"SyncTaskId"`
  64. }
  65. type GetRepoSyncTaskResponse struct {
  66. *responses.BaseResponse
  67. }
  68. func CreateGetRepoSyncTaskRequest() (request *GetRepoSyncTaskRequest) {
  69. request = &GetRepoSyncTaskRequest{
  70. RoaRequest: &requests.RoaRequest{},
  71. }
  72. request.InitWithApiInfo("cr", "2016-06-07", "GetRepoSyncTask", "/repos/[RepoNamespace]/[RepoName]/syncTasks/[SyncTaskId]", "", "")
  73. return
  74. }
  75. func CreateGetRepoSyncTaskResponse() (response *GetRepoSyncTaskResponse) {
  76. response = &GetRepoSyncTaskResponse{
  77. BaseResponse: &responses.BaseResponse{},
  78. }
  79. return
  80. }