create_cluster_template.go 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176
  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. // CreateClusterTemplate invokes the emr.CreateClusterTemplate API synchronously
  21. // api document: https://help.aliyun.com/api/emr/createclustertemplate.html
  22. func (client *Client) CreateClusterTemplate(request *CreateClusterTemplateRequest) (response *CreateClusterTemplateResponse, err error) {
  23. response = CreateCreateClusterTemplateResponse()
  24. err = client.DoAction(request, response)
  25. return
  26. }
  27. // CreateClusterTemplateWithChan invokes the emr.CreateClusterTemplate API asynchronously
  28. // api document: https://help.aliyun.com/api/emr/createclustertemplate.html
  29. // asynchronous document: https://help.aliyun.com/document_detail/66220.html
  30. func (client *Client) CreateClusterTemplateWithChan(request *CreateClusterTemplateRequest) (<-chan *CreateClusterTemplateResponse, <-chan error) {
  31. responseChan := make(chan *CreateClusterTemplateResponse, 1)
  32. errChan := make(chan error, 1)
  33. err := client.AddAsyncTask(func() {
  34. defer close(responseChan)
  35. defer close(errChan)
  36. response, err := client.CreateClusterTemplate(request)
  37. if err != nil {
  38. errChan <- err
  39. } else {
  40. responseChan <- response
  41. }
  42. })
  43. if err != nil {
  44. errChan <- err
  45. close(responseChan)
  46. close(errChan)
  47. }
  48. return responseChan, errChan
  49. }
  50. // CreateClusterTemplateWithCallback invokes the emr.CreateClusterTemplate API asynchronously
  51. // api document: https://help.aliyun.com/api/emr/createclustertemplate.html
  52. // asynchronous document: https://help.aliyun.com/document_detail/66220.html
  53. func (client *Client) CreateClusterTemplateWithCallback(request *CreateClusterTemplateRequest, callback func(response *CreateClusterTemplateResponse, err error)) <-chan int {
  54. result := make(chan int, 1)
  55. err := client.AddAsyncTask(func() {
  56. var response *CreateClusterTemplateResponse
  57. var err error
  58. defer close(result)
  59. response, err = client.CreateClusterTemplate(request)
  60. callback(response, err)
  61. result <- 1
  62. })
  63. if err != nil {
  64. defer close(result)
  65. callback(nil, err)
  66. result <- 0
  67. }
  68. return result
  69. }
  70. // CreateClusterTemplateRequest is the request struct for api CreateClusterTemplate
  71. type CreateClusterTemplateRequest struct {
  72. *requests.RpcRequest
  73. ResourceOwnerId requests.Integer `position:"Query" name:"ResourceOwnerId"`
  74. LogPath string `position:"Query" name:"LogPath"`
  75. MasterPwd string `position:"Query" name:"MasterPwd"`
  76. Configurations string `position:"Query" name:"Configurations"`
  77. IoOptimized requests.Boolean `position:"Query" name:"IoOptimized"`
  78. SecurityGroupId string `position:"Query" name:"SecurityGroupId"`
  79. SshEnable requests.Boolean `position:"Query" name:"SshEnable"`
  80. EasEnable requests.Boolean `position:"Query" name:"EasEnable"`
  81. KeyPairName string `position:"Query" name:"KeyPairName"`
  82. MetaStoreType string `position:"Query" name:"MetaStoreType"`
  83. SecurityGroupName string `position:"Query" name:"SecurityGroupName"`
  84. DepositType string `position:"Query" name:"DepositType"`
  85. MachineType string `position:"Query" name:"MachineType"`
  86. BootstrapAction *[]CreateClusterTemplateBootstrapAction `position:"Query" name:"BootstrapAction" type:"Repeated"`
  87. UseLocalMetaDb requests.Boolean `position:"Query" name:"UseLocalMetaDb"`
  88. MetaStoreConf string `position:"Query" name:"MetaStoreConf"`
  89. EmrVer string `position:"Query" name:"EmrVer"`
  90. TemplateName string `position:"Query" name:"TemplateName"`
  91. UserDefinedEmrEcsRole string `position:"Query" name:"UserDefinedEmrEcsRole"`
  92. IsOpenPublicIp requests.Boolean `position:"Query" name:"IsOpenPublicIp"`
  93. Period requests.Integer `position:"Query" name:"Period"`
  94. InstanceGeneration string `position:"Query" name:"InstanceGeneration"`
  95. VSwitchId string `position:"Query" name:"VSwitchId"`
  96. ClusterType string `position:"Query" name:"ClusterType"`
  97. AutoRenew requests.Boolean `position:"Query" name:"AutoRenew"`
  98. OptionSoftWareList *[]string `position:"Query" name:"OptionSoftWareList" type:"Repeated"`
  99. VpcId string `position:"Query" name:"VpcId"`
  100. NetType string `position:"Query" name:"NetType"`
  101. HostGroup *[]CreateClusterTemplateHostGroup `position:"Query" name:"HostGroup" type:"Repeated"`
  102. ZoneId string `position:"Query" name:"ZoneId"`
  103. UseCustomHiveMetaDb requests.Boolean `position:"Query" name:"UseCustomHiveMetaDb"`
  104. Config *[]CreateClusterTemplateConfig `position:"Query" name:"Config" type:"Repeated"`
  105. HighAvailabilityEnable requests.Boolean `position:"Query" name:"HighAvailabilityEnable"`
  106. InitCustomHiveMetaDb requests.Boolean `position:"Query" name:"InitCustomHiveMetaDb"`
  107. }
  108. // CreateClusterTemplateBootstrapAction is a repeated param struct in CreateClusterTemplateRequest
  109. type CreateClusterTemplateBootstrapAction struct {
  110. Path string `name:"Path"`
  111. Arg string `name:"Arg"`
  112. Name string `name:"Name"`
  113. }
  114. // CreateClusterTemplateHostGroup is a repeated param struct in CreateClusterTemplateRequest
  115. type CreateClusterTemplateHostGroup struct {
  116. Period string `name:"Period"`
  117. SysDiskCapacity string `name:"SysDiskCapacity"`
  118. DiskCapacity string `name:"DiskCapacity"`
  119. SysDiskType string `name:"SysDiskType"`
  120. ClusterId string `name:"ClusterId"`
  121. DiskType string `name:"DiskType"`
  122. HostGroupName string `name:"HostGroupName"`
  123. VSwitchId string `name:"VSwitchId"`
  124. DiskCount string `name:"DiskCount"`
  125. AutoRenew string `name:"AutoRenew"`
  126. HostGroupId string `name:"HostGroupId"`
  127. NodeCount string `name:"NodeCount"`
  128. InstanceType string `name:"InstanceType"`
  129. Comment string `name:"Comment"`
  130. ChargeType string `name:"ChargeType"`
  131. MultiInstanceTypes string `name:"MultiInstanceTypes"`
  132. CreateType string `name:"CreateType"`
  133. HostGroupType string `name:"HostGroupType"`
  134. }
  135. // CreateClusterTemplateConfig is a repeated param struct in CreateClusterTemplateRequest
  136. type CreateClusterTemplateConfig struct {
  137. ConfigKey string `name:"ConfigKey"`
  138. FileName string `name:"FileName"`
  139. Encrypt string `name:"Encrypt"`
  140. Replace string `name:"Replace"`
  141. ConfigValue string `name:"ConfigValue"`
  142. ServiceName string `name:"ServiceName"`
  143. }
  144. // CreateClusterTemplateResponse is the response struct for api CreateClusterTemplate
  145. type CreateClusterTemplateResponse struct {
  146. *responses.BaseResponse
  147. RequestId string `json:"RequestId" xml:"RequestId"`
  148. ClusterTemplateId string `json:"ClusterTemplateId" xml:"ClusterTemplateId"`
  149. }
  150. // CreateCreateClusterTemplateRequest creates a request to invoke CreateClusterTemplate API
  151. func CreateCreateClusterTemplateRequest() (request *CreateClusterTemplateRequest) {
  152. request = &CreateClusterTemplateRequest{
  153. RpcRequest: &requests.RpcRequest{},
  154. }
  155. request.InitWithApiInfo("Emr", "2016-04-08", "CreateClusterTemplate", "emr", "openAPI")
  156. return
  157. }
  158. // CreateCreateClusterTemplateResponse creates a response to parse from CreateClusterTemplate response
  159. func CreateCreateClusterTemplateResponse() (response *CreateClusterTemplateResponse) {
  160. response = &CreateClusterTemplateResponse{
  161. BaseResponse: &responses.BaseResponse{},
  162. }
  163. return
  164. }