commonrpc.grpc.pb.h 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311
  1. // Generated by the gRPC C++ plugin.
  2. // If you make any local change, they will be lost.
  3. // source: commonrpc.proto
  4. // Original file comments:
  5. // Copyright 2015 gRPC authors.
  6. //
  7. // Licensed under the Apache License, Version 2.0 (the "License");
  8. // you may not use this file except in compliance with the License.
  9. // You may obtain a copy of the License at
  10. //
  11. // http://www.apache.org/licenses/LICENSE-2.0
  12. //
  13. // Unless required by applicable law or agreed to in writing, software
  14. // distributed under the License is distributed on an "AS IS" BASIS,
  15. // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16. // See the License for the specific language governing permissions and
  17. // limitations under the License.
  18. //
  19. #ifndef GRPC_commonrpc_2eproto__INCLUDED
  20. #define GRPC_commonrpc_2eproto__INCLUDED
  21. #include "commonrpc.pb.h"
  22. #include <functional>
  23. #include <grpc/impl/codegen/port_platform.h>
  24. #include <grpcpp/impl/codegen/async_generic_service.h>
  25. #include <grpcpp/impl/codegen/async_stream.h>
  26. #include <grpcpp/impl/codegen/async_unary_call.h>
  27. #include <grpcpp/impl/codegen/client_callback.h>
  28. #include <grpcpp/impl/codegen/client_context.h>
  29. #include <grpcpp/impl/codegen/completion_queue.h>
  30. #include <grpcpp/impl/codegen/message_allocator.h>
  31. #include <grpcpp/impl/codegen/method_handler.h>
  32. #include <grpcpp/impl/codegen/proto_utils.h>
  33. #include <grpcpp/impl/codegen/rpc_method.h>
  34. #include <grpcpp/impl/codegen/server_callback.h>
  35. #include <grpcpp/impl/codegen/server_callback_handlers.h>
  36. #include <grpcpp/impl/codegen/server_context.h>
  37. #include <grpcpp/impl/codegen/service_type.h>
  38. #include <grpcpp/impl/codegen/status.h>
  39. #include <grpcpp/impl/codegen/stub_options.h>
  40. #include <grpcpp/impl/codegen/sync_stream.h>
  41. namespace iv {
  42. // The Upload service definition.
  43. class CommonRPC final {
  44. public:
  45. static constexpr char const* service_full_name() {
  46. return "iv.CommonRPC";
  47. }
  48. class StubInterface {
  49. public:
  50. virtual ~StubInterface() {}
  51. // Sends a Upload
  52. virtual ::grpc::Status rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::iv::queryrpcReply* response) = 0;
  53. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::iv::queryrpcReply>> Asyncrpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) {
  54. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::iv::queryrpcReply>>(AsyncrpcqueryRaw(context, request, cq));
  55. }
  56. std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::iv::queryrpcReply>> PrepareAsyncrpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) {
  57. return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::iv::queryrpcReply>>(PrepareAsyncrpcqueryRaw(context, request, cq));
  58. }
  59. class experimental_async_interface {
  60. public:
  61. virtual ~experimental_async_interface() {}
  62. // Sends a Upload
  63. virtual void rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response, std::function<void(::grpc::Status)>) = 0;
  64. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  65. virtual void rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response, ::grpc::ClientUnaryReactor* reactor) = 0;
  66. #else
  67. virtual void rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) = 0;
  68. #endif
  69. };
  70. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  71. typedef class experimental_async_interface async_interface;
  72. #endif
  73. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  74. async_interface* async() { return experimental_async(); }
  75. #endif
  76. virtual class experimental_async_interface* experimental_async() { return nullptr; }
  77. private:
  78. virtual ::grpc::ClientAsyncResponseReaderInterface< ::iv::queryrpcReply>* AsyncrpcqueryRaw(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) = 0;
  79. virtual ::grpc::ClientAsyncResponseReaderInterface< ::iv::queryrpcReply>* PrepareAsyncrpcqueryRaw(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) = 0;
  80. };
  81. class Stub final : public StubInterface {
  82. public:
  83. Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel);
  84. ::grpc::Status rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::iv::queryrpcReply* response) override;
  85. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::iv::queryrpcReply>> Asyncrpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) {
  86. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::iv::queryrpcReply>>(AsyncrpcqueryRaw(context, request, cq));
  87. }
  88. std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::iv::queryrpcReply>> PrepareAsyncrpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) {
  89. return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::iv::queryrpcReply>>(PrepareAsyncrpcqueryRaw(context, request, cq));
  90. }
  91. class experimental_async final :
  92. public StubInterface::experimental_async_interface {
  93. public:
  94. void rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response, std::function<void(::grpc::Status)>) override;
  95. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  96. void rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response, ::grpc::ClientUnaryReactor* reactor) override;
  97. #else
  98. void rpcquery(::grpc::ClientContext* context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response, ::grpc::experimental::ClientUnaryReactor* reactor) override;
  99. #endif
  100. private:
  101. friend class Stub;
  102. explicit experimental_async(Stub* stub): stub_(stub) { }
  103. Stub* stub() { return stub_; }
  104. Stub* stub_;
  105. };
  106. class experimental_async_interface* experimental_async() override { return &async_stub_; }
  107. private:
  108. std::shared_ptr< ::grpc::ChannelInterface> channel_;
  109. class experimental_async async_stub_{this};
  110. ::grpc::ClientAsyncResponseReader< ::iv::queryrpcReply>* AsyncrpcqueryRaw(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) override;
  111. ::grpc::ClientAsyncResponseReader< ::iv::queryrpcReply>* PrepareAsyncrpcqueryRaw(::grpc::ClientContext* context, const ::iv::queryrpcReq& request, ::grpc::CompletionQueue* cq) override;
  112. const ::grpc::internal::RpcMethod rpcmethod_rpcquery_;
  113. };
  114. static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
  115. class Service : public ::grpc::Service {
  116. public:
  117. Service();
  118. virtual ~Service();
  119. // Sends a Upload
  120. virtual ::grpc::Status rpcquery(::grpc::ServerContext* context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response);
  121. };
  122. template <class BaseClass>
  123. class WithAsyncMethod_rpcquery : public BaseClass {
  124. private:
  125. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  126. public:
  127. WithAsyncMethod_rpcquery() {
  128. ::grpc::Service::MarkMethodAsync(0);
  129. }
  130. ~WithAsyncMethod_rpcquery() override {
  131. BaseClassMustBeDerivedFromService(this);
  132. }
  133. // disable synchronous version of this method
  134. ::grpc::Status rpcquery(::grpc::ServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/) override {
  135. abort();
  136. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  137. }
  138. void Requestrpcquery(::grpc::ServerContext* context, ::iv::queryrpcReq* request, ::grpc::ServerAsyncResponseWriter< ::iv::queryrpcReply>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  139. ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
  140. }
  141. };
  142. typedef WithAsyncMethod_rpcquery<Service > AsyncService;
  143. template <class BaseClass>
  144. class ExperimentalWithCallbackMethod_rpcquery : public BaseClass {
  145. private:
  146. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  147. public:
  148. ExperimentalWithCallbackMethod_rpcquery() {
  149. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  150. ::grpc::Service::
  151. #else
  152. ::grpc::Service::experimental().
  153. #endif
  154. MarkMethodCallback(0,
  155. new ::grpc::internal::CallbackUnaryHandler< ::iv::queryrpcReq, ::iv::queryrpcReply>(
  156. [this](
  157. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  158. ::grpc::CallbackServerContext*
  159. #else
  160. ::grpc::experimental::CallbackServerContext*
  161. #endif
  162. context, const ::iv::queryrpcReq* request, ::iv::queryrpcReply* response) { return this->rpcquery(context, request, response); }));}
  163. void SetMessageAllocatorFor_rpcquery(
  164. ::grpc::experimental::MessageAllocator< ::iv::queryrpcReq, ::iv::queryrpcReply>* allocator) {
  165. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  166. ::grpc::internal::MethodHandler* const handler = ::grpc::Service::GetHandler(0);
  167. #else
  168. ::grpc::internal::MethodHandler* const handler = ::grpc::Service::experimental().GetHandler(0);
  169. #endif
  170. static_cast<::grpc::internal::CallbackUnaryHandler< ::iv::queryrpcReq, ::iv::queryrpcReply>*>(handler)
  171. ->SetMessageAllocator(allocator);
  172. }
  173. ~ExperimentalWithCallbackMethod_rpcquery() override {
  174. BaseClassMustBeDerivedFromService(this);
  175. }
  176. // disable synchronous version of this method
  177. ::grpc::Status rpcquery(::grpc::ServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/) override {
  178. abort();
  179. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  180. }
  181. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  182. virtual ::grpc::ServerUnaryReactor* rpcquery(
  183. ::grpc::CallbackServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/)
  184. #else
  185. virtual ::grpc::experimental::ServerUnaryReactor* rpcquery(
  186. ::grpc::experimental::CallbackServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/)
  187. #endif
  188. { return nullptr; }
  189. };
  190. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  191. typedef ExperimentalWithCallbackMethod_rpcquery<Service > CallbackService;
  192. #endif
  193. typedef ExperimentalWithCallbackMethod_rpcquery<Service > ExperimentalCallbackService;
  194. template <class BaseClass>
  195. class WithGenericMethod_rpcquery : public BaseClass {
  196. private:
  197. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  198. public:
  199. WithGenericMethod_rpcquery() {
  200. ::grpc::Service::MarkMethodGeneric(0);
  201. }
  202. ~WithGenericMethod_rpcquery() override {
  203. BaseClassMustBeDerivedFromService(this);
  204. }
  205. // disable synchronous version of this method
  206. ::grpc::Status rpcquery(::grpc::ServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/) override {
  207. abort();
  208. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  209. }
  210. };
  211. template <class BaseClass>
  212. class WithRawMethod_rpcquery : public BaseClass {
  213. private:
  214. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  215. public:
  216. WithRawMethod_rpcquery() {
  217. ::grpc::Service::MarkMethodRaw(0);
  218. }
  219. ~WithRawMethod_rpcquery() override {
  220. BaseClassMustBeDerivedFromService(this);
  221. }
  222. // disable synchronous version of this method
  223. ::grpc::Status rpcquery(::grpc::ServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/) override {
  224. abort();
  225. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  226. }
  227. void Requestrpcquery(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
  228. ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
  229. }
  230. };
  231. template <class BaseClass>
  232. class ExperimentalWithRawCallbackMethod_rpcquery : public BaseClass {
  233. private:
  234. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  235. public:
  236. ExperimentalWithRawCallbackMethod_rpcquery() {
  237. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  238. ::grpc::Service::
  239. #else
  240. ::grpc::Service::experimental().
  241. #endif
  242. MarkMethodRawCallback(0,
  243. new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
  244. [this](
  245. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  246. ::grpc::CallbackServerContext*
  247. #else
  248. ::grpc::experimental::CallbackServerContext*
  249. #endif
  250. context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response) { return this->rpcquery(context, request, response); }));
  251. }
  252. ~ExperimentalWithRawCallbackMethod_rpcquery() override {
  253. BaseClassMustBeDerivedFromService(this);
  254. }
  255. // disable synchronous version of this method
  256. ::grpc::Status rpcquery(::grpc::ServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/) override {
  257. abort();
  258. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  259. }
  260. #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL
  261. virtual ::grpc::ServerUnaryReactor* rpcquery(
  262. ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/)
  263. #else
  264. virtual ::grpc::experimental::ServerUnaryReactor* rpcquery(
  265. ::grpc::experimental::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/, ::grpc::ByteBuffer* /*response*/)
  266. #endif
  267. { return nullptr; }
  268. };
  269. template <class BaseClass>
  270. class WithStreamedUnaryMethod_rpcquery : public BaseClass {
  271. private:
  272. void BaseClassMustBeDerivedFromService(const Service* /*service*/) {}
  273. public:
  274. WithStreamedUnaryMethod_rpcquery() {
  275. ::grpc::Service::MarkMethodStreamed(0,
  276. new ::grpc::internal::StreamedUnaryHandler<
  277. ::iv::queryrpcReq, ::iv::queryrpcReply>(
  278. [this](::grpc::ServerContext* context,
  279. ::grpc::ServerUnaryStreamer<
  280. ::iv::queryrpcReq, ::iv::queryrpcReply>* streamer) {
  281. return this->Streamedrpcquery(context,
  282. streamer);
  283. }));
  284. }
  285. ~WithStreamedUnaryMethod_rpcquery() override {
  286. BaseClassMustBeDerivedFromService(this);
  287. }
  288. // disable regular version of this method
  289. ::grpc::Status rpcquery(::grpc::ServerContext* /*context*/, const ::iv::queryrpcReq* /*request*/, ::iv::queryrpcReply* /*response*/) override {
  290. abort();
  291. return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
  292. }
  293. // replace default version of method with streamed unary
  294. virtual ::grpc::Status Streamedrpcquery(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::iv::queryrpcReq,::iv::queryrpcReply>* server_unary_streamer) = 0;
  295. };
  296. typedef WithStreamedUnaryMethod_rpcquery<Service > StreamedUnaryService;
  297. typedef Service SplitStreamedService;
  298. typedef WithStreamedUnaryMethod_rpcquery<Service > StreamedService;
  299. };
  300. } // namespace iv
  301. #endif // GRPC_commonrpc_2eproto__INCLUDED