Generated 2019-09-16 for alikafka.

ChangeLog.txt

@@ -1,3 +1,7 @@
+2019-12-18 Version: v1.60.294
+- Generated 2019-09-16 for `alikafka`.
+- Support sasl and acl.
+
 2019-12-16 Version: v1.60.293
 - DescribeTransferDomains add query param, TargetUserId, FromUserId, DomainName.
 

services/alikafka/create_acl.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"
+)
+
+// CreateAcl invokes the alikafka.CreateAcl API synchronously
+// api document: https://help.aliyun.com/api/alikafka/createacl.html
+func (client *Client) CreateAcl(request *CreateAclRequest) (response *CreateAclResponse, err error) {
+	response = CreateCreateAclResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// CreateAclWithChan invokes the alikafka.CreateAcl API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createacl.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreateAclWithChan(request *CreateAclRequest) (<-chan *CreateAclResponse, <-chan error) {
+	responseChan := make(chan *CreateAclResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.CreateAcl(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// CreateAclWithCallback invokes the alikafka.CreateAcl API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createacl.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreateAclWithCallback(request *CreateAclRequest, callback func(response *CreateAclResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *CreateAclResponse
+		var err error
+		defer close(result)
+		response, err = client.CreateAcl(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// CreateAclRequest is the request struct for api CreateAcl
+type CreateAclRequest struct {
+	*requests.RpcRequest
+	AclResourcePatternType string `position:"Query" name:"AclResourcePatternType"`
+	AclResourceType        string `position:"Query" name:"AclResourceType"`
+	AclOperationType       string `position:"Query" name:"AclOperationType"`
+	AclResourceName        string `position:"Query" name:"AclResourceName"`
+	InstanceId             string `position:"Query" name:"InstanceId"`
+	Username               string `position:"Query" name:"Username"`
+}
+
+// CreateAclResponse is the response struct for api CreateAcl
+type CreateAclResponse 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"`
+}
+
+// CreateCreateAclRequest creates a request to invoke CreateAcl API
+func CreateCreateAclRequest() (request *CreateAclRequest) {
+	request = &CreateAclRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "CreateAcl", "alikafka", "openAPI")
+	return
+}
+
+// CreateCreateAclResponse creates a response to parse from CreateAcl response
+func CreateCreateAclResponse() (response *CreateAclResponse) {
+	response = &CreateAclResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/create_pre_pay_order.go

@@ -0,0 +1,113 @@
+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"
+)
+
+// CreatePrePayOrder invokes the alikafka.CreatePrePayOrder API synchronously
+// api document: https://help.aliyun.com/api/alikafka/createprepayorder.html
+func (client *Client) CreatePrePayOrder(request *CreatePrePayOrderRequest) (response *CreatePrePayOrderResponse, err error) {
+	response = CreateCreatePrePayOrderResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// CreatePrePayOrderWithChan invokes the alikafka.CreatePrePayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createprepayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreatePrePayOrderWithChan(request *CreatePrePayOrderRequest) (<-chan *CreatePrePayOrderResponse, <-chan error) {
+	responseChan := make(chan *CreatePrePayOrderResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.CreatePrePayOrder(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// CreatePrePayOrderWithCallback invokes the alikafka.CreatePrePayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createprepayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreatePrePayOrderWithCallback(request *CreatePrePayOrderRequest, callback func(response *CreatePrePayOrderResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *CreatePrePayOrderResponse
+		var err error
+		defer close(result)
+		response, err = client.CreatePrePayOrder(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// CreatePrePayOrderRequest is the request struct for api CreatePrePayOrder
+type CreatePrePayOrderRequest 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"`
+	SpecType   string           `position:"Query" name:"SpecType"`
+	DeployType requests.Integer `position:"Query" name:"DeployType"`
+}
+
+// CreatePrePayOrderResponse is the response struct for api CreatePrePayOrder
+type CreatePrePayOrderResponse 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"`
+	OrderId   string `json:"OrderId" xml:"OrderId"`
+}
+
+// CreateCreatePrePayOrderRequest creates a request to invoke CreatePrePayOrder API
+func CreateCreatePrePayOrderRequest() (request *CreatePrePayOrderRequest) {
+	request = &CreatePrePayOrderRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "CreatePrePayOrder", "alikafka", "openAPI")
+	return
+}
+
+// CreateCreatePrePayOrderResponse creates a response to parse from CreatePrePayOrder response
+func CreateCreatePrePayOrderResponse() (response *CreatePrePayOrderResponse) {
+	response = &CreatePrePayOrderResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/create_sasl_user.go

@@ -0,0 +1,108 @@
+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"
+)
+
+// CreateSaslUser invokes the alikafka.CreateSaslUser API synchronously
+// api document: https://help.aliyun.com/api/alikafka/createsasluser.html
+func (client *Client) CreateSaslUser(request *CreateSaslUserRequest) (response *CreateSaslUserResponse, err error) {
+	response = CreateCreateSaslUserResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// CreateSaslUserWithChan invokes the alikafka.CreateSaslUser API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createsasluser.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreateSaslUserWithChan(request *CreateSaslUserRequest) (<-chan *CreateSaslUserResponse, <-chan error) {
+	responseChan := make(chan *CreateSaslUserResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.CreateSaslUser(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// CreateSaslUserWithCallback invokes the alikafka.CreateSaslUser API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/createsasluser.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) CreateSaslUserWithCallback(request *CreateSaslUserRequest, callback func(response *CreateSaslUserResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *CreateSaslUserResponse
+		var err error
+		defer close(result)
+		response, err = client.CreateSaslUser(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// CreateSaslUserRequest is the request struct for api CreateSaslUser
+type CreateSaslUserRequest struct {
+	*requests.RpcRequest
+	Password   string `position:"Query" name:"Password"`
+	InstanceId string `position:"Query" name:"InstanceId"`
+	Username   string `position:"Query" name:"Username"`
+}
+
+// CreateSaslUserResponse is the response struct for api CreateSaslUser
+type CreateSaslUserResponse 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"`
+}
+
+// CreateCreateSaslUserRequest creates a request to invoke CreateSaslUser API
+func CreateCreateSaslUserRequest() (request *CreateSaslUserRequest) {
+	request = &CreateSaslUserRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "CreateSaslUser", "alikafka", "openAPI")
+	return
+}
+
+// CreateCreateSaslUserResponse creates a response to parse from CreateSaslUser response
+func CreateCreateSaslUserResponse() (response *CreateSaslUserResponse) {
+	response = &CreateSaslUserResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/delete_acl.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"
+)
+
+// DeleteAcl invokes the alikafka.DeleteAcl API synchronously
+// api document: https://help.aliyun.com/api/alikafka/deleteacl.html
+func (client *Client) DeleteAcl(request *DeleteAclRequest) (response *DeleteAclResponse, err error) {
+	response = CreateDeleteAclResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DeleteAclWithChan invokes the alikafka.DeleteAcl API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/deleteacl.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DeleteAclWithChan(request *DeleteAclRequest) (<-chan *DeleteAclResponse, <-chan error) {
+	responseChan := make(chan *DeleteAclResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DeleteAcl(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DeleteAclWithCallback invokes the alikafka.DeleteAcl API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/deleteacl.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DeleteAclWithCallback(request *DeleteAclRequest, callback func(response *DeleteAclResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DeleteAclResponse
+		var err error
+		defer close(result)
+		response, err = client.DeleteAcl(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DeleteAclRequest is the request struct for api DeleteAcl
+type DeleteAclRequest struct {
+	*requests.RpcRequest
+	AclResourcePatternType string `position:"Query" name:"AclResourcePatternType"`
+	AclResourceType        string `position:"Query" name:"AclResourceType"`
+	AclOperationType       string `position:"Query" name:"AclOperationType"`
+	AclResourceName        string `position:"Query" name:"AclResourceName"`
+	InstanceId             string `position:"Query" name:"InstanceId"`
+	Username               string `position:"Query" name:"Username"`
+}
+
+// DeleteAclResponse is the response struct for api DeleteAcl
+type DeleteAclResponse 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"`
+}
+
+// CreateDeleteAclRequest creates a request to invoke DeleteAcl API
+func CreateDeleteAclRequest() (request *DeleteAclRequest) {
+	request = &DeleteAclRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "DeleteAcl", "alikafka", "openAPI")
+	return
+}
+
+// CreateDeleteAclResponse creates a response to parse from DeleteAcl response
+func CreateDeleteAclResponse() (response *DeleteAclResponse) {
+	response = &DeleteAclResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/delete_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"
+)
+
+// DeleteInstance invokes the alikafka.DeleteInstance API synchronously
+// api document: https://help.aliyun.com/api/alikafka/deleteinstance.html
+func (client *Client) DeleteInstance(request *DeleteInstanceRequest) (response *DeleteInstanceResponse, err error) {
+	response = CreateDeleteInstanceResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DeleteInstanceWithChan invokes the alikafka.DeleteInstance API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/deleteinstance.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DeleteInstanceWithChan(request *DeleteInstanceRequest) (<-chan *DeleteInstanceResponse, <-chan error) {
+	responseChan := make(chan *DeleteInstanceResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DeleteInstance(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DeleteInstanceWithCallback invokes the alikafka.DeleteInstance API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/deleteinstance.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DeleteInstanceWithCallback(request *DeleteInstanceRequest, callback func(response *DeleteInstanceResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DeleteInstanceResponse
+		var err error
+		defer close(result)
+		response, err = client.DeleteInstance(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DeleteInstanceRequest is the request struct for api DeleteInstance
+type DeleteInstanceRequest struct {
+	*requests.RpcRequest
+	InstanceId string `position:"Query" name:"InstanceId"`
+}
+
+// DeleteInstanceResponse is the response struct for api DeleteInstance
+type DeleteInstanceResponse 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"`
+}
+
+// CreateDeleteInstanceRequest creates a request to invoke DeleteInstance API
+func CreateDeleteInstanceRequest() (request *DeleteInstanceRequest) {
+	request = &DeleteInstanceRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "DeleteInstance", "alikafka", "openAPI")
+	return
+}
+
+// CreateDeleteInstanceResponse creates a response to parse from DeleteInstance response
+func CreateDeleteInstanceResponse() (response *DeleteInstanceResponse) {
+	response = &DeleteInstanceResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/delete_sasl_user.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"
+)
+
+// DeleteSaslUser invokes the alikafka.DeleteSaslUser API synchronously
+// api document: https://help.aliyun.com/api/alikafka/deletesasluser.html
+func (client *Client) DeleteSaslUser(request *DeleteSaslUserRequest) (response *DeleteSaslUserResponse, err error) {
+	response = CreateDeleteSaslUserResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DeleteSaslUserWithChan invokes the alikafka.DeleteSaslUser API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/deletesasluser.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DeleteSaslUserWithChan(request *DeleteSaslUserRequest) (<-chan *DeleteSaslUserResponse, <-chan error) {
+	responseChan := make(chan *DeleteSaslUserResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DeleteSaslUser(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DeleteSaslUserWithCallback invokes the alikafka.DeleteSaslUser API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/deletesasluser.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DeleteSaslUserWithCallback(request *DeleteSaslUserRequest, callback func(response *DeleteSaslUserResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DeleteSaslUserResponse
+		var err error
+		defer close(result)
+		response, err = client.DeleteSaslUser(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DeleteSaslUserRequest is the request struct for api DeleteSaslUser
+type DeleteSaslUserRequest struct {
+	*requests.RpcRequest
+	InstanceId string `position:"Query" name:"InstanceId"`
+	Username   string `position:"Query" name:"Username"`
+}
+
+// DeleteSaslUserResponse is the response struct for api DeleteSaslUser
+type DeleteSaslUserResponse 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"`
+}
+
+// CreateDeleteSaslUserRequest creates a request to invoke DeleteSaslUser API
+func CreateDeleteSaslUserRequest() (request *DeleteSaslUserRequest) {
+	request = &DeleteSaslUserRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "DeleteSaslUser", "alikafka", "openAPI")
+	return
+}
+
+// CreateDeleteSaslUserResponse creates a response to parse from DeleteSaslUser response
+func CreateDeleteSaslUserResponse() (response *DeleteSaslUserResponse) {
+	response = &DeleteSaslUserResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/describe_acls.go

@@ -0,0 +1,110 @@
+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"
+)
+
+// DescribeAcls invokes the alikafka.DescribeAcls API synchronously
+// api document: https://help.aliyun.com/api/alikafka/describeacls.html
+func (client *Client) DescribeAcls(request *DescribeAclsRequest) (response *DescribeAclsResponse, err error) {
+	response = CreateDescribeAclsResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeAclsWithChan invokes the alikafka.DescribeAcls API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/describeacls.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeAclsWithChan(request *DescribeAclsRequest) (<-chan *DescribeAclsResponse, <-chan error) {
+	responseChan := make(chan *DescribeAclsResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeAcls(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeAclsWithCallback invokes the alikafka.DescribeAcls API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/describeacls.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeAclsWithCallback(request *DescribeAclsRequest, callback func(response *DescribeAclsResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeAclsResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeAcls(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeAclsRequest is the request struct for api DescribeAcls
+type DescribeAclsRequest struct {
+	*requests.RpcRequest
+	AclResourceType string `position:"Query" name:"AclResourceType"`
+	AclResourceName string `position:"Query" name:"AclResourceName"`
+	InstanceId      string `position:"Query" name:"InstanceId"`
+	Username        string `position:"Query" name:"Username"`
+}
+
+// DescribeAclsResponse is the response struct for api DescribeAcls
+type DescribeAclsResponse 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"`
+	KafkaAclList KafkaAclList `json:"KafkaAclList" xml:"KafkaAclList"`
+}
+
+// CreateDescribeAclsRequest creates a request to invoke DescribeAcls API
+func CreateDescribeAclsRequest() (request *DescribeAclsRequest) {
+	request = &DescribeAclsRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "DescribeAcls", "alikafka", "openAPI")
+	return
+}
+
+// CreateDescribeAclsResponse creates a response to parse from DescribeAcls response
+func CreateDescribeAclsResponse() (response *DescribeAclsResponse) {
+	response = &DescribeAclsResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/describe_sasl_users.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"
+)
+
+// DescribeSaslUsers invokes the alikafka.DescribeSaslUsers API synchronously
+// api document: https://help.aliyun.com/api/alikafka/describesaslusers.html
+func (client *Client) DescribeSaslUsers(request *DescribeSaslUsersRequest) (response *DescribeSaslUsersResponse, err error) {
+	response = CreateDescribeSaslUsersResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// DescribeSaslUsersWithChan invokes the alikafka.DescribeSaslUsers API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/describesaslusers.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeSaslUsersWithChan(request *DescribeSaslUsersRequest) (<-chan *DescribeSaslUsersResponse, <-chan error) {
+	responseChan := make(chan *DescribeSaslUsersResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.DescribeSaslUsers(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// DescribeSaslUsersWithCallback invokes the alikafka.DescribeSaslUsers API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/describesaslusers.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) DescribeSaslUsersWithCallback(request *DescribeSaslUsersRequest, callback func(response *DescribeSaslUsersResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *DescribeSaslUsersResponse
+		var err error
+		defer close(result)
+		response, err = client.DescribeSaslUsers(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// DescribeSaslUsersRequest is the request struct for api DescribeSaslUsers
+type DescribeSaslUsersRequest struct {
+	*requests.RpcRequest
+	InstanceId string `position:"Query" name:"InstanceId"`
+}
+
+// DescribeSaslUsersResponse is the response struct for api DescribeSaslUsers
+type DescribeSaslUsersResponse 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"`
+	SaslUserList SaslUserList `json:"SaslUserList" xml:"SaslUserList"`
+}
+
+// CreateDescribeSaslUsersRequest creates a request to invoke DescribeSaslUsers API
+func CreateDescribeSaslUsersRequest() (request *DescribeSaslUsersRequest) {
+	request = &DescribeSaslUsersRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "DescribeSaslUsers", "alikafka", "openAPI")
+	return
+}
+
+// CreateDescribeSaslUsersResponse creates a response to parse from DescribeSaslUsers response
+func CreateDescribeSaslUsersResponse() (response *DescribeSaslUsersResponse) {
+	response = &DescribeSaslUsersResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/get_meta_product_list.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"
+)
+
+// GetMetaProductList invokes the alikafka.GetMetaProductList API synchronously
+// api document: https://help.aliyun.com/api/alikafka/getmetaproductlist.html
+func (client *Client) GetMetaProductList(request *GetMetaProductListRequest) (response *GetMetaProductListResponse, err error) {
+	response = CreateGetMetaProductListResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// GetMetaProductListWithChan invokes the alikafka.GetMetaProductList API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/getmetaproductlist.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) GetMetaProductListWithChan(request *GetMetaProductListRequest) (<-chan *GetMetaProductListResponse, <-chan error) {
+	responseChan := make(chan *GetMetaProductListResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.GetMetaProductList(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// GetMetaProductListWithCallback invokes the alikafka.GetMetaProductList API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/getmetaproductlist.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) GetMetaProductListWithCallback(request *GetMetaProductListRequest, callback func(response *GetMetaProductListResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *GetMetaProductListResponse
+		var err error
+		defer close(result)
+		response, err = client.GetMetaProductList(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// GetMetaProductListRequest is the request struct for api GetMetaProductList
+type GetMetaProductListRequest struct {
+	*requests.RpcRequest
+	ListNormal string `position:"Query" name:"ListNormal"`
+}
+
+// GetMetaProductListResponse is the response struct for api GetMetaProductList
+type GetMetaProductListResponse 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"`
+	MetaData  string `json:"MetaData" xml:"MetaData"`
+}
+
+// CreateGetMetaProductListRequest creates a request to invoke GetMetaProductList API
+func CreateGetMetaProductListRequest() (request *GetMetaProductListRequest) {
+	request = &GetMetaProductListRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "GetMetaProductList", "alikafka", "openAPI")
+	return
+}
+
+// CreateGetMetaProductListResponse creates a response to parse from GetMetaProductList response
+func CreateGetMetaProductListResponse() (response *GetMetaProductListResponse) {
+	response = &GetMetaProductListResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}

services/alikafka/struct_kafka_acl_list.go

@@ -0,0 +1,21 @@
+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.
+
+// KafkaAclList is a nested struct in alikafka response
+type KafkaAclList struct {
+	KafkaAclVO []KafkaAclVO `json:"KafkaAclVO" xml:"KafkaAclVO"`
+}

services/alikafka/struct_kafka_acl_vo.go

@@ -0,0 +1,26 @@
+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.
+
+// KafkaAclVO is a nested struct in alikafka response
+type KafkaAclVO struct {
+	Username               string `json:"Username" xml:"Username"`
+	AclResourceType        string `json:"AclResourceType" xml:"AclResourceType"`
+	AclResourceName        string `json:"AclResourceName" xml:"AclResourceName"`
+	AclResourcePatternType string `json:"AclResourcePatternType" xml:"AclResourcePatternType"`
+	Host                   string `json:"Host" xml:"Host"`
+	AclOperationType       string `json:"AclOperationType" xml:"AclOperationType"`
+}

services/alikafka/struct_sasl_user_list.go

@@ -0,0 +1,21 @@
+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.
+
+// SaslUserList is a nested struct in alikafka response
+type SaslUserList struct {
+	SaslUserVO []SaslUserVO `json:"SaslUserVO" xml:"SaslUserVO"`
+}

services/alikafka/struct_sasl_user_vo.go

@@ -0,0 +1,22 @@
+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.
+
+// SaslUserVO is a nested struct in alikafka response
+type SaslUserVO struct {
+	Username string `json:"Username" xml:"Username"`
+	Password string `json:"Password" xml:"Password"`
+}

services/alikafka/upgrade_pre_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"
+)
+
+// UpgradePrePayOrder invokes the alikafka.UpgradePrePayOrder API synchronously
+// api document: https://help.aliyun.com/api/alikafka/upgradeprepayorder.html
+func (client *Client) UpgradePrePayOrder(request *UpgradePrePayOrderRequest) (response *UpgradePrePayOrderResponse, err error) {
+	response = CreateUpgradePrePayOrderResponse()
+	err = client.DoAction(request, response)
+	return
+}
+
+// UpgradePrePayOrderWithChan invokes the alikafka.UpgradePrePayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/upgradeprepayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) UpgradePrePayOrderWithChan(request *UpgradePrePayOrderRequest) (<-chan *UpgradePrePayOrderResponse, <-chan error) {
+	responseChan := make(chan *UpgradePrePayOrderResponse, 1)
+	errChan := make(chan error, 1)
+	err := client.AddAsyncTask(func() {
+		defer close(responseChan)
+		defer close(errChan)
+		response, err := client.UpgradePrePayOrder(request)
+		if err != nil {
+			errChan <- err
+		} else {
+			responseChan <- response
+		}
+	})
+	if err != nil {
+		errChan <- err
+		close(responseChan)
+		close(errChan)
+	}
+	return responseChan, errChan
+}
+
+// UpgradePrePayOrderWithCallback invokes the alikafka.UpgradePrePayOrder API asynchronously
+// api document: https://help.aliyun.com/api/alikafka/upgradeprepayorder.html
+// asynchronous document: https://help.aliyun.com/document_detail/66220.html
+func (client *Client) UpgradePrePayOrderWithCallback(request *UpgradePrePayOrderRequest, callback func(response *UpgradePrePayOrderResponse, err error)) <-chan int {
+	result := make(chan int, 1)
+	err := client.AddAsyncTask(func() {
+		var response *UpgradePrePayOrderResponse
+		var err error
+		defer close(result)
+		response, err = client.UpgradePrePayOrder(request)
+		callback(response, err)
+		result <- 1
+	})
+	if err != nil {
+		defer close(result)
+		callback(nil, err)
+		result <- 0
+	}
+	return result
+}
+
+// UpgradePrePayOrderRequest is the request struct for api UpgradePrePayOrder
+type UpgradePrePayOrderRequest 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"`
+	SpecType   string           `position:"Query" name:"SpecType"`
+	InstanceId string           `position:"Query" name:"InstanceId"`
+}
+
+// UpgradePrePayOrderResponse is the response struct for api UpgradePrePayOrder
+type UpgradePrePayOrderResponse 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"`
+}
+
+// CreateUpgradePrePayOrderRequest creates a request to invoke UpgradePrePayOrder API
+func CreateUpgradePrePayOrderRequest() (request *UpgradePrePayOrderRequest) {
+	request = &UpgradePrePayOrderRequest{
+		RpcRequest: &requests.RpcRequest{},
+	}
+	request.InitWithApiInfo("alikafka", "2019-09-16", "UpgradePrePayOrder", "alikafka", "openAPI")
+	return
+}
+
+// CreateUpgradePrePayOrderResponse creates a response to parse from UpgradePrePayOrder response
+func CreateUpgradePrePayOrderResponse() (response *UpgradePrePayOrderResponse) {
+	response = &UpgradePrePayOrderResponse{
+		BaseResponse: &responses.BaseResponse{},
+	}
+	return
+}