modify_execution_plan_cluster_info.go 6.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  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) ModifyExecutionPlanClusterInfo(request *ModifyExecutionPlanClusterInfoRequest) (response *ModifyExecutionPlanClusterInfoResponse, err error) {
  21. response = CreateModifyExecutionPlanClusterInfoResponse()
  22. err = client.DoAction(request, response)
  23. return
  24. }
  25. func (client *Client) ModifyExecutionPlanClusterInfoWithChan(request *ModifyExecutionPlanClusterInfoRequest) (<-chan *ModifyExecutionPlanClusterInfoResponse, <-chan error) {
  26. responseChan := make(chan *ModifyExecutionPlanClusterInfoResponse, 1)
  27. errChan := make(chan error, 1)
  28. err := client.AddAsyncTask(func() {
  29. defer close(responseChan)
  30. defer close(errChan)
  31. response, err := client.ModifyExecutionPlanClusterInfo(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) ModifyExecutionPlanClusterInfoWithCallback(request *ModifyExecutionPlanClusterInfoRequest, callback func(response *ModifyExecutionPlanClusterInfoResponse, err error)) <-chan int {
  43. result := make(chan int, 1)
  44. err := client.AddAsyncTask(func() {
  45. var response *ModifyExecutionPlanClusterInfoResponse
  46. var err error
  47. defer close(result)
  48. response, err = client.ModifyExecutionPlanClusterInfo(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 ModifyExecutionPlanClusterInfoRequest struct {
  60. *requests.RpcRequest
  61. ZoneId string `position:"Query" name:"ZoneId"`
  62. ClusterId string `position:"Query" name:"ClusterId"`
  63. IsOpenPublicIp string `position:"Query" name:"IsOpenPublicIp"`
  64. InstanceGeneration string `position:"Query" name:"InstanceGeneration"`
  65. OptionSoftWareList *[]string `position:"Query" name:"OptionSoftWareList" type:"Repeated"`
  66. Id string `position:"Query" name:"Id"`
  67. LogEnable string `position:"Query" name:"LogEnable"`
  68. UseLocalMetaDb string `position:"Query" name:"UseLocalMetaDb"`
  69. EcsOrder *[]ModifyExecutionPlanClusterInfoEcsOrder `position:"Query" name:"EcsOrder" type:"Repeated"`
  70. NetType string `position:"Query" name:"NetType"`
  71. ResourceOwnerId string `position:"Query" name:"ResourceOwnerId"`
  72. HighAvailabilityEnable string `position:"Query" name:"HighAvailabilityEnable"`
  73. BootstrapAction *[]ModifyExecutionPlanClusterInfoBootstrapAction `position:"Query" name:"BootstrapAction" type:"Repeated"`
  74. VSwitchId string `position:"Query" name:"VSwitchId"`
  75. SecurityGroupId string `position:"Query" name:"SecurityGroupId"`
  76. ClusterName string `position:"Query" name:"ClusterName"`
  77. LogPath string `position:"Query" name:"LogPath"`
  78. IoOptimized string `position:"Query" name:"IoOptimized"`
  79. ClusterType string `position:"Query" name:"ClusterType"`
  80. EasEnable string `position:"Query" name:"EasEnable"`
  81. EmrVer string `position:"Query" name:"EmrVer"`
  82. Configurations string `position:"Query" name:"Configurations"`
  83. CreateClusterOnDemand string `position:"Query" name:"CreateClusterOnDemand"`
  84. VpcId string `position:"Query" name:"VpcId"`
  85. }
  86. type ModifyExecutionPlanClusterInfoEcsOrder struct {
  87. Index string `name:"Index"`
  88. NodeCount string `name:"NodeCount"`
  89. InstanceType string `name:"InstanceType"`
  90. DiskType string `name:"DiskType"`
  91. DiskCapacity string `name:"DiskCapacity"`
  92. NodeType string `name:"NodeType"`
  93. DiskCount string `name:"DiskCount"`
  94. }
  95. type ModifyExecutionPlanClusterInfoBootstrapAction struct {
  96. Name string `name:"Name"`
  97. Path string `name:"Path"`
  98. Arg string `name:"Arg"`
  99. }
  100. type ModifyExecutionPlanClusterInfoResponse struct {
  101. *responses.BaseResponse
  102. RequestId string `json:"RequestId" xml:"RequestId"`
  103. }
  104. func CreateModifyExecutionPlanClusterInfoRequest() (request *ModifyExecutionPlanClusterInfoRequest) {
  105. request = &ModifyExecutionPlanClusterInfoRequest{
  106. RpcRequest: &requests.RpcRequest{},
  107. }
  108. request.InitWithApiInfo("Emr", "2016-04-08", "ModifyExecutionPlanClusterInfo", "", "")
  109. return
  110. }
  111. func CreateModifyExecutionPlanClusterInfoResponse() (response *ModifyExecutionPlanClusterInfoResponse) {
  112. response = &ModifyExecutionPlanClusterInfoResponse{
  113. BaseResponse: &responses.BaseResponse{},
  114. }
  115. return
  116. }