|
@@ -20,24 +20,24 @@ import (
|
|
|
"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
|
|
"github.com/aliyun/alibaba-cloud-sdk-go/sdk/responses"
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
-// DestroyInstance invokes the r_kvstore.DestroyInstance API synchronously
|
|
|
|
|
-// api document: https://help.aliyun.com/api/r-kvstore/destroyinstance.html
|
|
|
|
|
-func (client *Client) DestroyInstance(request *DestroyInstanceRequest) (response *DestroyInstanceResponse, err error) {
|
|
|
|
|
- response = CreateDestroyInstanceResponse()
|
|
|
|
|
|
|
+// FlushExpireKeys invokes the r_kvstore.FlushExpireKeys API synchronously
|
|
|
|
|
+// api document: https://help.aliyun.com/api/r-kvstore/flushexpirekeys.html
|
|
|
|
|
+func (client *Client) FlushExpireKeys(request *FlushExpireKeysRequest) (response *FlushExpireKeysResponse, err error) {
|
|
|
|
|
+ response = CreateFlushExpireKeysResponse()
|
|
|
err = client.DoAction(request, response)
|
|
err = client.DoAction(request, response)
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// DestroyInstanceWithChan invokes the r_kvstore.DestroyInstance API asynchronously
|
|
|
|
|
-// api document: https://help.aliyun.com/api/r-kvstore/destroyinstance.html
|
|
|
|
|
|
|
+// FlushExpireKeysWithChan invokes the r_kvstore.FlushExpireKeys API asynchronously
|
|
|
|
|
+// api document: https://help.aliyun.com/api/r-kvstore/flushexpirekeys.html
|
|
|
// asynchronous document: https://help.aliyun.com/document_detail/66220.html
|
|
// asynchronous document: https://help.aliyun.com/document_detail/66220.html
|
|
|
-func (client *Client) DestroyInstanceWithChan(request *DestroyInstanceRequest) (<-chan *DestroyInstanceResponse, <-chan error) {
|
|
|
|
|
- responseChan := make(chan *DestroyInstanceResponse, 1)
|
|
|
|
|
|
|
+func (client *Client) FlushExpireKeysWithChan(request *FlushExpireKeysRequest) (<-chan *FlushExpireKeysResponse, <-chan error) {
|
|
|
|
|
+ responseChan := make(chan *FlushExpireKeysResponse, 1)
|
|
|
errChan := make(chan error, 1)
|
|
errChan := make(chan error, 1)
|
|
|
err := client.AddAsyncTask(func() {
|
|
err := client.AddAsyncTask(func() {
|
|
|
defer close(responseChan)
|
|
defer close(responseChan)
|
|
|
defer close(errChan)
|
|
defer close(errChan)
|
|
|
- response, err := client.DestroyInstance(request)
|
|
|
|
|
|
|
+ response, err := client.FlushExpireKeys(request)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
errChan <- err
|
|
errChan <- err
|
|
|
} else {
|
|
} else {
|
|
@@ -52,16 +52,16 @@ func (client *Client) DestroyInstanceWithChan(request *DestroyInstanceRequest) (
|
|
|
return responseChan, errChan
|
|
return responseChan, errChan
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// DestroyInstanceWithCallback invokes the r_kvstore.DestroyInstance API asynchronously
|
|
|
|
|
-// api document: https://help.aliyun.com/api/r-kvstore/destroyinstance.html
|
|
|
|
|
|
|
+// FlushExpireKeysWithCallback invokes the r_kvstore.FlushExpireKeys API asynchronously
|
|
|
|
|
+// api document: https://help.aliyun.com/api/r-kvstore/flushexpirekeys.html
|
|
|
// asynchronous document: https://help.aliyun.com/document_detail/66220.html
|
|
// asynchronous document: https://help.aliyun.com/document_detail/66220.html
|
|
|
-func (client *Client) DestroyInstanceWithCallback(request *DestroyInstanceRequest, callback func(response *DestroyInstanceResponse, err error)) <-chan int {
|
|
|
|
|
|
|
+func (client *Client) FlushExpireKeysWithCallback(request *FlushExpireKeysRequest, callback func(response *FlushExpireKeysResponse, err error)) <-chan int {
|
|
|
result := make(chan int, 1)
|
|
result := make(chan int, 1)
|
|
|
err := client.AddAsyncTask(func() {
|
|
err := client.AddAsyncTask(func() {
|
|
|
- var response *DestroyInstanceResponse
|
|
|
|
|
|
|
+ var response *FlushExpireKeysResponse
|
|
|
var err error
|
|
var err error
|
|
|
defer close(result)
|
|
defer close(result)
|
|
|
- response, err = client.DestroyInstance(request)
|
|
|
|
|
|
|
+ response, err = client.FlushExpireKeys(request)
|
|
|
callback(response, err)
|
|
callback(response, err)
|
|
|
result <- 1
|
|
result <- 1
|
|
|
})
|
|
})
|
|
@@ -73,35 +73,38 @@ func (client *Client) DestroyInstanceWithCallback(request *DestroyInstanceReques
|
|
|
return result
|
|
return result
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// DestroyInstanceRequest is the request struct for api DestroyInstance
|
|
|
|
|
-type DestroyInstanceRequest struct {
|
|
|
|
|
|
|
+// FlushExpireKeysRequest is the request struct for api FlushExpireKeys
|
|
|
|
|
+type FlushExpireKeysRequest struct {
|
|
|
*requests.RpcRequest
|
|
*requests.RpcRequest
|
|
|
ResourceOwnerId requests.Integer `position:"Query" name:"ResourceOwnerId"`
|
|
ResourceOwnerId requests.Integer `position:"Query" name:"ResourceOwnerId"`
|
|
|
SecurityToken string `position:"Query" name:"SecurityToken"`
|
|
SecurityToken string `position:"Query" name:"SecurityToken"`
|
|
|
|
|
+ EffectiveTime string `position:"Query" name:"EffectiveTime"`
|
|
|
ResourceOwnerAccount string `position:"Query" name:"ResourceOwnerAccount"`
|
|
ResourceOwnerAccount string `position:"Query" name:"ResourceOwnerAccount"`
|
|
|
OwnerAccount string `position:"Query" name:"OwnerAccount"`
|
|
OwnerAccount string `position:"Query" name:"OwnerAccount"`
|
|
|
OwnerId requests.Integer `position:"Query" name:"OwnerId"`
|
|
OwnerId requests.Integer `position:"Query" name:"OwnerId"`
|
|
|
InstanceId string `position:"Query" name:"InstanceId"`
|
|
InstanceId string `position:"Query" name:"InstanceId"`
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// DestroyInstanceResponse is the response struct for api DestroyInstance
|
|
|
|
|
-type DestroyInstanceResponse struct {
|
|
|
|
|
|
|
+// FlushExpireKeysResponse is the response struct for api FlushExpireKeys
|
|
|
|
|
+type FlushExpireKeysResponse struct {
|
|
|
*responses.BaseResponse
|
|
*responses.BaseResponse
|
|
|
- RequestId string `json:"RequestId" xml:"RequestId"`
|
|
|
|
|
|
|
+ RequestId string `json:"RequestId" xml:"RequestId"`
|
|
|
|
|
+ InstanceId string `json:"InstanceId" xml:"InstanceId"`
|
|
|
|
|
+ TaskId string `json:"TaskId" xml:"TaskId"`
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// CreateDestroyInstanceRequest creates a request to invoke DestroyInstance API
|
|
|
|
|
-func CreateDestroyInstanceRequest() (request *DestroyInstanceRequest) {
|
|
|
|
|
- request = &DestroyInstanceRequest{
|
|
|
|
|
|
|
+// CreateFlushExpireKeysRequest creates a request to invoke FlushExpireKeys API
|
|
|
|
|
+func CreateFlushExpireKeysRequest() (request *FlushExpireKeysRequest) {
|
|
|
|
|
+ request = &FlushExpireKeysRequest{
|
|
|
RpcRequest: &requests.RpcRequest{},
|
|
RpcRequest: &requests.RpcRequest{},
|
|
|
}
|
|
}
|
|
|
- request.InitWithApiInfo("R-kvstore", "2015-01-01", "DestroyInstance", "", "")
|
|
|
|
|
|
|
+ request.InitWithApiInfo("R-kvstore", "2015-01-01", "FlushExpireKeys", "", "")
|
|
|
return
|
|
return
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
-// CreateDestroyInstanceResponse creates a response to parse from DestroyInstance response
|
|
|
|
|
-func CreateDestroyInstanceResponse() (response *DestroyInstanceResponse) {
|
|
|
|
|
- response = &DestroyInstanceResponse{
|
|
|
|
|
|
|
+// CreateFlushExpireKeysResponse creates a response to parse from FlushExpireKeys response
|
|
|
|
|
+func CreateFlushExpireKeysResponse() (response *FlushExpireKeysResponse) {
|
|
|
|
|
+ response = &FlushExpireKeysResponse{
|
|
|
BaseResponse: &responses.BaseResponse{},
|
|
BaseResponse: &responses.BaseResponse{},
|
|
|
}
|
|
}
|
|
|
return
|
|
return
|