query_topology.go 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293
  1. package teslamaxcompute
  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) QueryTopology(request *QueryTopologyRequest) (response *QueryTopologyResponse, err error) {
  21. response = CreateQueryTopologyResponse()
  22. err = client.DoAction(request, response)
  23. return
  24. }
  25. func (client *Client) QueryTopologyWithChan(request *QueryTopologyRequest) (<-chan *QueryTopologyResponse, <-chan error) {
  26. responseChan := make(chan *QueryTopologyResponse, 1)
  27. errChan := make(chan error, 1)
  28. err := client.AddAsyncTask(func() {
  29. defer close(responseChan)
  30. defer close(errChan)
  31. response, err := client.QueryTopology(request)
  32. if err != nil {
  33. errChan <- err
  34. } else {
  35. responseChan <- response
  36. }
  37. })
  38. if err != nil {
  39. errChan <- err
  40. close(responseChan)
  41. close(errChan)
  42. }
  43. return responseChan, errChan
  44. }
  45. func (client *Client) QueryTopologyWithCallback(request *QueryTopologyRequest, callback func(response *QueryTopologyResponse, err error)) <-chan int {
  46. result := make(chan int, 1)
  47. err := client.AddAsyncTask(func() {
  48. var response *QueryTopologyResponse
  49. var err error
  50. defer close(result)
  51. response, err = client.QueryTopology(request)
  52. callback(response, err)
  53. result <- 1
  54. })
  55. if err != nil {
  56. defer close(result)
  57. callback(nil, err)
  58. result <- 0
  59. }
  60. return result
  61. }
  62. type QueryTopologyRequest struct {
  63. *requests.RpcRequest
  64. }
  65. type QueryTopologyResponse struct {
  66. *responses.BaseResponse
  67. Code int `json:"Code" xml:"Code"`
  68. Message string `json:"Message" xml:"Message"`
  69. RequestId string `json:"RequestId" xml:"RequestId"`
  70. Result Result `json:"Result" xml:"Result"`
  71. }
  72. func CreateQueryTopologyRequest() (request *QueryTopologyRequest) {
  73. request = &QueryTopologyRequest{
  74. RpcRequest: &requests.RpcRequest{},
  75. }
  76. request.InitWithApiInfo("TeslaMaxCompute", "2018-01-04", "QueryTopology", "", "")
  77. return
  78. }
  79. func CreateQueryTopologyResponse() (response *QueryTopologyResponse) {
  80. response = &QueryTopologyResponse{
  81. BaseResponse: &responses.BaseResponse{},
  82. }
  83. return
  84. }