Add instance relevant interface.

ChangeLog.txt

@@ -1,3 +1,6 @@
+2019-10-13 Version: 1.60.195
+- Add instance relevant interface.
+
 2019-10-12 Version: 1.60.194
 - Add new api.
 

services/alikafka/create_post_pay_order.go

@@ -0,0 +1,112 @@
+package alikafka
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// CreatePostPayOrder invokes the alikafka.CreatePostPayOrder API synchronously
+// api document: https://help.aliyun.com/api/alikafka/createpostpayorder.html
+func (client *Client) CreatePostPayOrder(request *CreatePostPayOrderRequest) (response *CreatePostPayOrderResponse, err error) {
+	response = CreateCreatePostPayOrderResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// CreatePostPayOrderWithChan invokes the alikafka.CreatePostPayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createpostpayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreatePostPayOrderWithChan(request *CreatePostPayOrderRequest) (<-chan *CreatePostPayOrderResponse, <-chan error) {
+	responseChan := make(chan *CreatePostPayOrderResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.CreatePostPayOrder(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// CreatePostPayOrderWithCallback invokes the alikafka.CreatePostPayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createpostpayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreatePostPayOrderWithCallback(request *CreatePostPayOrderRequest, callback func(response *CreatePostPayOrderResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *CreatePostPayOrderResponse
+		var err error
+		defer close(result)
+		response, err = client.CreatePostPayOrder(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// CreatePostPayOrderRequest is the request struct for api CreatePostPayOrder
+type CreatePostPayOrderRequest struct {
+	*requests.RpcRequest
+	DiskSize   requests.Integer `position:"Query" name:"DiskSize"`
+	IoMax      requests.Integer `position:"Query" name:"IoMax"`
+	DiskType   string           `position:"Query" name:"DiskType"`
+	TopicQuota requests.Integer `position:"Query" name:"TopicQuota"`
+	EipMax     requests.Integer `position:"Query" name:"EipMax"`
+	DeployType requests.Integer `position:"Query" name:"DeployType"`
+}
+
+// CreatePostPayOrderResponse is the response struct for api CreatePostPayOrder
+type CreatePostPayOrderResponse struct {
+	*responses.BaseResponse
+	RequestId string   `json:"RequestId" xml:"RequestId"`
+	Success   bool     `json:"Success" xml:"Success"`
+	Code      int      `json:"Code" xml:"Code"`
+	Message   string   `json:"Message" xml:"Message"`
+	Instance  Instance `json:"Instance" xml:"Instance"`
+}
+
+// CreateCreatePostPayOrderRequest creates a request to invoke CreatePostPayOrder API
+func CreateCreatePostPayOrderRequest() (request *CreatePostPayOrderRequest) {
+	request = &CreatePostPayOrderRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "CreatePostPayOrder", "alikafka", "openAPI")
+	return
+}
+
+// CreateCreatePostPayOrderResponse creates a response to parse from CreatePostPayOrder response
+func CreateCreatePostPayOrderResponse() (response *CreatePostPayOrderResponse) {
+	response = &CreatePostPayOrderResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/get_instance_list.go

@@ -81,11 +81,12 @@ type GetInstanceListRequest struct {
 // GetInstanceListResponse is the response struct for api GetInstanceList
 type GetInstanceListResponse struct {
 	*responses.BaseResponse
-	Success      bool         `json:"Success" xml:"Success"`
-	RequestId    string       `json:"RequestId" xml:"RequestId"`
-	Code         int          `json:"Code" xml:"Code"`
-	Message      string       `json:"Message" xml:"Message"`
-	InstanceList InstanceList `json:"InstanceList" xml:"InstanceList"`
+	Success       bool         `json:"Success" xml:"Success"`
+	RequestId     string       `json:"RequestId" xml:"RequestId"`
+	Code          int          `json:"Code" xml:"Code"`
+	Message       string       `json:"Message" xml:"Message"`
+	TopicNumLimit int          `json:"TopicNumLimit" xml:"TopicNumLimit"`
+	InstanceList  InstanceList `json:"InstanceList" xml:"InstanceList"`
 }
 
 // CreateGetInstanceListRequest creates a request to invoke GetInstanceList API

services/alikafka/modify_instance_name.go

@@ -0,0 +1,107 @@
+package alikafka
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// ModifyInstanceName invokes the alikafka.ModifyInstanceName API synchronously
+// api document: https://help.aliyun.com/api/alikafka/modifyinstancename.html
+func (client *Client) ModifyInstanceName(request *ModifyInstanceNameRequest) (response *ModifyInstanceNameResponse, err error) {
+	response = CreateModifyInstanceNameResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// ModifyInstanceNameWithChan invokes the alikafka.ModifyInstanceName API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/modifyinstancename.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) ModifyInstanceNameWithChan(request *ModifyInstanceNameRequest) (<-chan *ModifyInstanceNameResponse, <-chan error) {
+	responseChan := make(chan *ModifyInstanceNameResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.ModifyInstanceName(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// ModifyInstanceNameWithCallback invokes the alikafka.ModifyInstanceName API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/modifyinstancename.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) ModifyInstanceNameWithCallback(request *ModifyInstanceNameRequest, callback func(response *ModifyInstanceNameResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *ModifyInstanceNameResponse
+		var err error
+		defer close(result)
+		response, err = client.ModifyInstanceName(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// ModifyInstanceNameRequest is the request struct for api ModifyInstanceName
+type ModifyInstanceNameRequest struct {
+	*requests.RpcRequest
+	InstanceId   string `position:"Query" name:"InstanceId"`
+	InstanceName string `position:"Query" name:"InstanceName"`
+}
+
+// ModifyInstanceNameResponse is the response struct for api ModifyInstanceName
+type ModifyInstanceNameResponse struct {
+	*responses.BaseResponse
+	Success   bool   `json:"Success" xml:"Success"`
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	Code      int    `json:"Code" xml:"Code"`
+	Message   string `json:"Message" xml:"Message"`
+}
+
+// CreateModifyInstanceNameRequest creates a request to invoke ModifyInstanceName API
+func CreateModifyInstanceNameRequest() (request *ModifyInstanceNameRequest) {
+	request = &ModifyInstanceNameRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "ModifyInstanceName", "alikafka", "openAPI")
+	return
+}
+
+// CreateModifyInstanceNameResponse creates a response to parse from ModifyInstanceName response
+func CreateModifyInstanceNameResponse() (response *ModifyInstanceNameResponse) {
+	response = &ModifyInstanceNameResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/release_instance.go

@@ -0,0 +1,106 @@
+package alikafka
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// ReleaseInstance invokes the alikafka.ReleaseInstance API synchronously
+// api document: https://help.aliyun.com/api/alikafka/releaseinstance.html
+func (client *Client) ReleaseInstance(request *ReleaseInstanceRequest) (response *ReleaseInstanceResponse, err error) {
+	response = CreateReleaseInstanceResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// ReleaseInstanceWithChan invokes the alikafka.ReleaseInstance API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/releaseinstance.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) ReleaseInstanceWithChan(request *ReleaseInstanceRequest) (<-chan *ReleaseInstanceResponse, <-chan error) {
+	responseChan := make(chan *ReleaseInstanceResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.ReleaseInstance(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// ReleaseInstanceWithCallback invokes the alikafka.ReleaseInstance API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/releaseinstance.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) ReleaseInstanceWithCallback(request *ReleaseInstanceRequest, callback func(response *ReleaseInstanceResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *ReleaseInstanceResponse
+		var err error
+		defer close(result)
+		response, err = client.ReleaseInstance(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// ReleaseInstanceRequest is the request struct for api ReleaseInstance
+type ReleaseInstanceRequest struct {
+	*requests.RpcRequest
+	InstanceId string `position:"Query" name:"InstanceId"`
+}
+
+// ReleaseInstanceResponse is the response struct for api ReleaseInstance
+type ReleaseInstanceResponse struct {
+	*responses.BaseResponse
+	Success   bool   `json:"Success" xml:"Success"`
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	Code      int    `json:"Code" xml:"Code"`
+	Message   string `json:"Message" xml:"Message"`
+}
+
+// CreateReleaseInstanceRequest creates a request to invoke ReleaseInstance API
+func CreateReleaseInstanceRequest() (request *ReleaseInstanceRequest) {
+	request = &ReleaseInstanceRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "ReleaseInstance", "alikafka", "openAPI")
+	return
+}
+
+// CreateReleaseInstanceResponse creates a response to parse from ReleaseInstance response
+func CreateReleaseInstanceResponse() (response *ReleaseInstanceResponse) {
+	response = &ReleaseInstanceResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/start_instance.go

@@ -0,0 +1,115 @@
+package alikafka
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// StartInstance invokes the alikafka.StartInstance API synchronously
+// api document: https://help.aliyun.com/api/alikafka/startinstance.html
+func (client *Client) StartInstance(request *StartInstanceRequest) (response *StartInstanceResponse, err error) {
+	response = CreateStartInstanceResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// StartInstanceWithChan invokes the alikafka.StartInstance API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/startinstance.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) StartInstanceWithChan(request *StartInstanceRequest) (<-chan *StartInstanceResponse, <-chan error) {
+	responseChan := make(chan *StartInstanceResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.StartInstance(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// StartInstanceWithCallback invokes the alikafka.StartInstance API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/startinstance.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) StartInstanceWithCallback(request *StartInstanceRequest, callback func(response *StartInstanceResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *StartInstanceResponse
+		var err error
+		defer close(result)
+		response, err = client.StartInstance(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// StartInstanceRequest is the request struct for api StartInstance
+type StartInstanceRequest struct {
+	*requests.RpcRequest
+	IsEipInner           requests.Boolean `position:"Query" name:"IsEipInner"`
+	DeployModule         string           `position:"Query" name:"DeployModule"`
+	IsSetUserAndPassword requests.Boolean `position:"Query" name:"IsSetUserAndPassword"`
+	VSwitchId            string           `position:"Query" name:"VSwitchId"`
+	Password             string           `position:"Query" name:"Password"`
+	InstanceId           string           `position:"Query" name:"InstanceId"`
+	VpcId                string           `position:"Query" name:"VpcId"`
+	Name                 string           `position:"Query" name:"Name"`
+	ZoneId               string           `position:"Query" name:"ZoneId"`
+	Username             string           `position:"Query" name:"Username"`
+}
+
+// StartInstanceResponse is the response struct for api StartInstance
+type StartInstanceResponse struct {
+	*responses.BaseResponse
+	Success   bool   `json:"Success" xml:"Success"`
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	Code      int    `json:"Code" xml:"Code"`
+	Message   string `json:"Message" xml:"Message"`
+}
+
+// CreateStartInstanceRequest creates a request to invoke StartInstance API
+func CreateStartInstanceRequest() (request *StartInstanceRequest) {
+	request = &StartInstanceRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "StartInstance", "alikafka", "openAPI")
+	return
+}
+
+// CreateStartInstanceResponse creates a response to parse from StartInstance response
+func CreateStartInstanceResponse() (response *StartInstanceResponse) {
+	response = &StartInstanceResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/struct_instance.go

@@ -0,0 +1,31 @@
+package alikafka
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+// Instance is a nested struct in alikafka response
+type Instance struct {
+	InstanceId    string `json:"InstanceId" xml:"InstanceId"`
+	InstanceName  string `json:"InstanceName" xml:"InstanceName"`
+	CreateTime    int64  `json:"CreateTime" xml:"CreateTime"`
+	Bandwidth     int    `json:"Bandwidth" xml:"Bandwidth"`
+	SslEndPoint   string `json:"SslEndPoint" xml:"SslEndPoint"`
+	EndPoint      string `json:"EndPoint" xml:"EndPoint"`
+	IoMax         int    `json:"IoMax" xml:"IoMax"`
+	DiskType      int    `json:"DiskType" xml:"DiskType"`
+	DiskSize      int    `json:"DiskSize" xml:"DiskSize"`
+	MsgRetain     int    `json:"MsgRetain" xml:"MsgRetain"`
+	TopicNumLimit int    `json:"TopicNumLimit" xml:"TopicNumLimit"`
+}

services/alikafka/struct_instance_vo.go

@@ -28,5 +28,11 @@ type InstanceVO struct {
 	DeployType               int                      `json:"DeployType" xml:"DeployType"`
 	SslEndPoint              string                   `json:"SslEndPoint" xml:"SslEndPoint"`
 	Name                     string                   `json:"Name" xml:"Name"`
+	IoMax                    int                      `json:"IoMax" xml:"IoMax"`
+	EipMax                   int                      `json:"EipMax" xml:"EipMax"`
+	DiskType                 int                      `json:"DiskType" xml:"DiskType"`
+	DiskSize                 int                      `json:"DiskSize" xml:"DiskSize"`
+	MsgRetain                int                      `json:"MsgRetain" xml:"MsgRetain"`
+	TopicNumLimit            int                      `json:"TopicNumLimit" xml:"TopicNumLimit"`
 	UpgradeServiceDetailInfo UpgradeServiceDetailInfo `json:"UpgradeServiceDetailInfo" xml:"UpgradeServiceDetailInfo"`
 }

services/alikafka/struct_offset_list.go

@@ -17,5 +17,5 @@ package alikafka
 
 // OffsetList is a nested struct in alikafka response
 type OffsetList struct {
-	OffsetListItem []OffsetListItem `json:"OffsetListItem" xml:"OffsetListItem"`
+	OffsetListItem []OffsetListItem `json:"OffsetList" xml:"OffsetList"`
 }

services/alikafka/struct_offset_table.go

@@ -17,5 +17,5 @@ package alikafka
 
 // OffsetTable is a nested struct in alikafka response
 type OffsetTable struct {
-	OffsetTableItem []OffsetTableItem `json:"OffsetTableItem" xml:"OffsetTableItem"`
+	OffsetTableItem []OffsetTableItem `json:"OffsetTable" xml:"OffsetTable"`
 }

services/alikafka/struct_topic_list_in_get_consumer_progress.go

@@ -17,5 +17,5 @@ package alikafka
 
 // TopicListInGetConsumerProgress is a nested struct in alikafka response
 type TopicListInGetConsumerProgress struct {
-	TopicListItem []TopicListItem `json:"TopicListItem" xml:"TopicListItem"`
+	TopicListItem []TopicListItem `json:"TopicList" xml:"TopicList"`
 }

services/alikafka/upgrade_post_pay_order.go

@@ -0,0 +1,111 @@
+package alikafka
+
+//Licensed under the Apache License, Version 2.0 (the "License");
+//you may not use this file except in compliance with the License.
+//You may obtain a copy of the License at
+//
+//http://www.apache.org/licenses/LICENSE-2.0
+//
+//Unless required by applicable law or agreed to in writing, software
+//distributed under the License is distributed on an "AS IS" BASIS,
+//WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+//See the License for the specific language governing permissions and
+//limitations under the License.
+//
+// Code generated by Alibaba Cloud SDK Code Generator.
+// Changes may cause incorrect behavior and will be lost if the code is regenerated.
+
+import (
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/requests"
+	"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
+)
+
+// UpgradePostPayOrder invokes the alikafka.UpgradePostPayOrder API synchronously
+// api document: https://help.aliyun.com/api/alikafka/upgradepostpayorder.html
+func (client *Client) UpgradePostPayOrder(request *UpgradePostPayOrderRequest) (response *UpgradePostPayOrderResponse, err error) {
+	response = CreateUpgradePostPayOrderResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// UpgradePostPayOrderWithChan invokes the alikafka.UpgradePostPayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/upgradepostpayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) UpgradePostPayOrderWithChan(request *UpgradePostPayOrderRequest) (<-chan *UpgradePostPayOrderResponse, <-chan error) {
+	responseChan := make(chan *UpgradePostPayOrderResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.UpgradePostPayOrder(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// UpgradePostPayOrderWithCallback invokes the alikafka.UpgradePostPayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/upgradepostpayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) UpgradePostPayOrderWithCallback(request *UpgradePostPayOrderRequest, callback func(response *UpgradePostPayOrderResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *UpgradePostPayOrderResponse
+		var err error
+		defer close(result)
+		response, err = client.UpgradePostPayOrder(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// UpgradePostPayOrderRequest is the request struct for api UpgradePostPayOrder
+type UpgradePostPayOrderRequest struct {
+	*requests.RpcRequest
+	DiskSize   requests.Integer `position:"Query" name:"DiskSize"`
+	IoMax      requests.Integer `position:"Query" name:"IoMax"`
+	TopicQuota requests.Integer `position:"Query" name:"TopicQuota"`
+	EipMax     requests.Integer `position:"Query" name:"EipMax"`
+	InstanceId string           `position:"Query" name:"InstanceId"`
+	MsgRetain  requests.Integer `position:"Query" name:"MsgRetain"`
+}
+
+// UpgradePostPayOrderResponse is the response struct for api UpgradePostPayOrder
+type UpgradePostPayOrderResponse struct {
+	*responses.BaseResponse
+	Success   bool   `json:"Success" xml:"Success"`
+	RequestId string `json:"RequestId" xml:"RequestId"`
+	Code      int    `json:"Code" xml:"Code"`
+	Message   string `json:"Message" xml:"Message"`
+}
+
+// CreateUpgradePostPayOrderRequest creates a request to invoke UpgradePostPayOrder API
+func CreateUpgradePostPayOrderRequest() (request *UpgradePostPayOrderRequest) {
+	request = &UpgradePostPayOrderRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "UpgradePostPayOrder", "alikafka", "openAPI")
+	return
+}
+
+// CreateUpgradePostPayOrderResponse creates a response to parse from UpgradePostPayOrder response
+func CreateUpgradePostPayOrderResponse() (response *UpgradePostPayOrderResponse) {
+	response = &UpgradePostPayOrderResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}