list_resource_pool.go 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152
  1. package emr
  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) ListResourcePool(request *ListResourcePoolRequest) (response *ListResourcePoolResponse, err error) {
  21. response = CreateListResourcePoolResponse()
  22. err = client.DoAction(request, response)
  23. return
  24. }
  25. func (client *Client) ListResourcePoolWithChan(request *ListResourcePoolRequest) (<-chan *ListResourcePoolResponse, <-chan error) {
  26. responseChan := make(chan *ListResourcePoolResponse, 1)
  27. errChan := make(chan error, 1)
  28. err := client.AddAsyncTask(func() {
  29. defer close(responseChan)
  30. defer close(errChan)
  31. response, err := client.ListResourcePool(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) ListResourcePoolWithCallback(request *ListResourcePoolRequest, callback func(response *ListResourcePoolResponse, err error)) <-chan int {
  43. result := make(chan int, 1)
  44. err := client.AddAsyncTask(func() {
  45. var response *ListResourcePoolResponse
  46. var err error
  47. defer close(result)
  48. response, err = client.ListResourcePool(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 ListResourcePoolRequest struct {
  60. *requests.RpcRequest
  61. PoolType string `position:"Query" name:"PoolType"`
  62. ClusterId string `position:"Query" name:"ClusterId"`
  63. ResourceOwnerId string `position:"Query" name:"ResourceOwnerId"`
  64. }
  65. type ListResourcePoolResponse struct {
  66. *responses.BaseResponse
  67. RequestId string `json:"RequestId" xml:"RequestId"`
  68. PageNumber int `json:"PageNumber" xml:"PageNumber"`
  69. PageSize int `json:"PageSize" xml:"PageSize"`
  70. Total int `json:"Total" xml:"Total"`
  71. PoolInfoList []struct {
  72. EcmResourcePool struct {
  73. Id int64 `json:"Id" xml:"Id"`
  74. Name string `json:"Name" xml:"Name"`
  75. ClusterId int64 `json:"ClusterId" xml:"ClusterId"`
  76. PoolType string `json:"PoolType" xml:"PoolType"`
  77. Active bool `json:"Active" xml:"Active"`
  78. Note string `json:"Note" xml:"Note"`
  79. UserId string `json:"UserId" xml:"UserId"`
  80. YarnSiteConfig string `json:"YarnSiteConfig" xml:"YarnSiteConfig"`
  81. } `json:"EcmResourcePool" xml:"EcmResourcePool"`
  82. QueueList []struct {
  83. EcmResourceQueue struct {
  84. Id int64 `json:"Id" xml:"Id"`
  85. Name string `json:"Name" xml:"Name"`
  86. QualifiedName string `json:"QualifiedName" xml:"QualifiedName"`
  87. ClusterId int64 `json:"ClusterId" xml:"ClusterId"`
  88. QueueType string `json:"QueueType" xml:"QueueType"`
  89. ParentQueueId int64 `json:"ParentQueueId" xml:"ParentQueueId"`
  90. Leaf bool `json:"Leaf" xml:"Leaf"`
  91. Status string `json:"Status" xml:"Status"`
  92. UserId string `json:"UserId" xml:"UserId"`
  93. ResourcePoolId int64 `json:"ResourcePoolId" xml:"ResourcePoolId"`
  94. } `json:"EcmResourceQueue" xml:"EcmResourceQueue"`
  95. EcmResourcePoolConfigList []struct {
  96. Id int64 `json:"Id" xml:"Id"`
  97. ConfigKey string `json:"ConfigKey" xml:"ConfigKey"`
  98. ConfigValue string `json:"ConfigValue" xml:"ConfigValue"`
  99. ClusterId int64 `json:"ClusterId" xml:"ClusterId"`
  100. ConfigType string `json:"ConfigType" xml:"ConfigType"`
  101. TargetId int64 `json:"TargetId" xml:"TargetId"`
  102. Category string `json:"Category" xml:"Category"`
  103. Status string `json:"Status" xml:"Status"`
  104. Note string `json:"Note" xml:"Note"`
  105. } `json:"EcmResourcePoolConfigList" xml:"EcmResourcePoolConfigList"`
  106. } `json:"QueueList" xml:"QueueList"`
  107. DefaultSettingList []struct {
  108. Id int64 `json:"Id" xml:"Id"`
  109. ConfigKey string `json:"ConfigKey" xml:"ConfigKey"`
  110. ConfigValue string `json:"ConfigValue" xml:"ConfigValue"`
  111. ClusterId int64 `json:"ClusterId" xml:"ClusterId"`
  112. ConfigType string `json:"ConfigType" xml:"ConfigType"`
  113. TargetId int64 `json:"TargetId" xml:"TargetId"`
  114. Category string `json:"Category" xml:"Category"`
  115. Status string `json:"Status" xml:"Status"`
  116. Note string `json:"Note" xml:"Note"`
  117. } `json:"DefaultSettingList" xml:"DefaultSettingList"`
  118. AccessControlSettingList []struct {
  119. Id int64 `json:"Id" xml:"Id"`
  120. ConfigKey string `json:"ConfigKey" xml:"ConfigKey"`
  121. ConfigValue string `json:"ConfigValue" xml:"ConfigValue"`
  122. ClusterId int64 `json:"ClusterId" xml:"ClusterId"`
  123. ConfigType string `json:"ConfigType" xml:"ConfigType"`
  124. TargetId int64 `json:"TargetId" xml:"TargetId"`
  125. Category string `json:"Category" xml:"Category"`
  126. Status string `json:"Status" xml:"Status"`
  127. Note string `json:"Note" xml:"Note"`
  128. } `json:"AccessControlSettingList" xml:"AccessControlSettingList"`
  129. } `json:"PoolInfoList" xml:"PoolInfoList"`
  130. }
  131. func CreateListResourcePoolRequest() (request *ListResourcePoolRequest) {
  132. request = &ListResourcePoolRequest{
  133. RpcRequest: &requests.RpcRequest{},
  134. }
  135. request.InitWithApiInfo("Emr", "2016-04-08", "ListResourcePool", "", "")
  136. return
  137. }
  138. func CreateListResourcePoolResponse() (response *ListResourcePoolResponse) {
  139. response = &ListResourcePoolResponse{
  140. BaseResponse: &responses.BaseResponse{},
  141. }
  142. return
  143. }