rpc_http_api3.go 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. package ft
  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) RpcHttpApi3(request *RpcHttpApi3Request) (response *RpcHttpApi3Response, err error) {
  21. response = CreateRpcHttpApi3Response()
  22. err = client.DoAction(request, response)
  23. return
  24. }
  25. func (client *Client) RpcHttpApi3WithChan(request *RpcHttpApi3Request) (<-chan *RpcHttpApi3Response, <-chan error) {
  26. responseChan := make(chan *RpcHttpApi3Response, 1)
  27. errChan := make(chan error, 1)
  28. err := client.AddAsyncTask(func() {
  29. defer close(responseChan)
  30. defer close(errChan)
  31. response, err := client.RpcHttpApi3(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) RpcHttpApi3WithCallback(request *RpcHttpApi3Request, callback func(response *RpcHttpApi3Response, err error)) (<-chan int) {
  43. result := make(chan int, 1)
  44. err := client.AddAsyncTask(func() {
  45. var response *RpcHttpApi3Response
  46. var err error
  47. defer close(result)
  48. response, err = client.RpcHttpApi3(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 RpcHttpApi3Request struct {
  60. *requests.RpcRequest
  61. P1 string `position:"Query" name:"P1"`
  62. Sleep string `position:"Query" name:"Sleep"`
  63. }
  64. type RpcHttpApi3Response struct {
  65. *responses.BaseResponse
  66. Params struct {
  67. RequestId string `json:"RequestId"`
  68. CallerUid string `json:"CallerUid"`
  69. Sleep string `json:"Sleep"`
  70. P1 string `json:"P1"`
  71. } `json:"Params"`
  72. }
  73. func CreateRpcHttpApi3Request() (request *RpcHttpApi3Request) {
  74. request = &RpcHttpApi3Request{
  75. RpcRequest: &requests.RpcRequest{},
  76. }
  77. request.InitWithApiInfo("Ft", "2015-01-01", "RpcHttpApi3", "", "")
  78. return
  79. }
  80. func CreateRpcHttpApi3Response() (response *RpcHttpApi3Response) {
  81. response = &RpcHttpApi3Response{
  82. BaseResponse: &responses.BaseResponse{},
  83. }
  84. return
  85. }