Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 1 | // Generated by the gRPC C++ plugin. |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 2 | // If you make any local change, they will be lost. |
| 3 | // source: monster_test |
| 4 | #ifndef GRPC_monster_5ftest__INCLUDED |
| 5 | #define GRPC_monster_5ftest__INCLUDED |
| 6 | |
CarsarSky | 69dc71b | 2016-12-29 03:50:41 +0800 | [diff] [blame] | 7 | #include "flatbuffers/grpc.h" |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 8 | #include "monster_test_generated.h" |
CarsarSky | 69dc71b | 2016-12-29 03:50:41 +0800 | [diff] [blame] | 9 | |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 10 | #include <grpc++/impl/codegen/async_stream.h> |
| 11 | #include <grpc++/impl/codegen/async_unary_call.h> |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 12 | #include <grpc++/impl/codegen/method_handler_impl.h> |
| 13 | #include <grpc++/impl/codegen/proto_utils.h> |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 14 | #include <grpc++/impl/codegen/rpc_method.h> |
| 15 | #include <grpc++/impl/codegen/service_type.h> |
| 16 | #include <grpc++/impl/codegen/status.h> |
| 17 | #include <grpc++/impl/codegen/stub_options.h> |
| 18 | #include <grpc++/impl/codegen/sync_stream.h> |
| 19 | |
| 20 | namespace grpc { |
| 21 | class CompletionQueue; |
| 22 | class Channel; |
| 23 | class RpcService; |
| 24 | class ServerCompletionQueue; |
| 25 | class ServerContext; |
| 26 | } // namespace grpc |
| 27 | |
| 28 | namespace MyGame { |
| 29 | namespace Example { |
| 30 | |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 31 | class MonsterStorage final { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 32 | public: |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 33 | static constexpr char const* service_full_name() { |
| 34 | return "MyGame.Example.MonsterStorage"; |
| 35 | } |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 36 | class StubInterface { |
| 37 | public: |
| 38 | virtual ~StubInterface() {} |
Lawrence Chan | 6a7ec85 | 2017-05-12 16:36:35 -0500 | [diff] [blame] | 39 | virtual ::grpc::Status Store(::grpc::ClientContext* context, const flatbuffers::BufferRef<Monster>& request, flatbuffers::BufferRef<Stat>* response) = 0; |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 40 | std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< flatbuffers::BufferRef<Stat>>> AsyncStore(::grpc::ClientContext* context, const flatbuffers::BufferRef<Monster>& request, ::grpc::CompletionQueue* cq) { |
| 41 | return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< flatbuffers::BufferRef<Stat>>>(AsyncStoreRaw(context, request, cq)); |
| 42 | } |
Lawrence Chan | 6a7ec85 | 2017-05-12 16:36:35 -0500 | [diff] [blame] | 43 | std::unique_ptr< ::grpc::ClientReaderInterface< flatbuffers::BufferRef<Monster>>> Retrieve(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request) { |
CarsarSky | 69dc71b | 2016-12-29 03:50:41 +0800 | [diff] [blame] | 44 | return std::unique_ptr< ::grpc::ClientReaderInterface< flatbuffers::BufferRef<Monster>>>(RetrieveRaw(context, request)); |
| 45 | } |
| 46 | std::unique_ptr< ::grpc::ClientAsyncReaderInterface< flatbuffers::BufferRef<Monster>>> AsyncRetrieve(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request, ::grpc::CompletionQueue* cq, void* tag) { |
| 47 | return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< flatbuffers::BufferRef<Monster>>>(AsyncRetrieveRaw(context, request, cq, tag)); |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 48 | } |
Lawrence Chan | 6a7ec85 | 2017-05-12 16:36:35 -0500 | [diff] [blame] | 49 | private: |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 50 | virtual ::grpc::ClientAsyncResponseReaderInterface< flatbuffers::BufferRef<Stat>>* AsyncStoreRaw(::grpc::ClientContext* context, const flatbuffers::BufferRef<Monster>& request, ::grpc::CompletionQueue* cq) = 0; |
CarsarSky | 69dc71b | 2016-12-29 03:50:41 +0800 | [diff] [blame] | 51 | virtual ::grpc::ClientReaderInterface< flatbuffers::BufferRef<Monster>>* RetrieveRaw(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request) = 0; |
| 52 | virtual ::grpc::ClientAsyncReaderInterface< flatbuffers::BufferRef<Monster>>* AsyncRetrieveRaw(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request, ::grpc::CompletionQueue* cq, void* tag) = 0; |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 53 | }; |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 54 | class Stub final : public StubInterface { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 55 | public: |
| 56 | Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel); |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 57 | ::grpc::Status Store(::grpc::ClientContext* context, const flatbuffers::BufferRef<Monster>& request, flatbuffers::BufferRef<Stat>* response) override; |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 58 | std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::BufferRef<Stat>>> AsyncStore(::grpc::ClientContext* context, const flatbuffers::BufferRef<Monster>& request, ::grpc::CompletionQueue* cq) { |
| 59 | return std::unique_ptr< ::grpc::ClientAsyncResponseReader< flatbuffers::BufferRef<Stat>>>(AsyncStoreRaw(context, request, cq)); |
| 60 | } |
CarsarSky | 69dc71b | 2016-12-29 03:50:41 +0800 | [diff] [blame] | 61 | std::unique_ptr< ::grpc::ClientReader< flatbuffers::BufferRef<Monster>>> Retrieve(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request) { |
| 62 | return std::unique_ptr< ::grpc::ClientReader< flatbuffers::BufferRef<Monster>>>(RetrieveRaw(context, request)); |
| 63 | } |
| 64 | std::unique_ptr< ::grpc::ClientAsyncReader< flatbuffers::BufferRef<Monster>>> AsyncRetrieve(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request, ::grpc::CompletionQueue* cq, void* tag) { |
| 65 | return std::unique_ptr< ::grpc::ClientAsyncReader< flatbuffers::BufferRef<Monster>>>(AsyncRetrieveRaw(context, request, cq, tag)); |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 66 | } |
| 67 | |
| 68 | private: |
| 69 | std::shared_ptr< ::grpc::ChannelInterface> channel_; |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 70 | ::grpc::ClientAsyncResponseReader< flatbuffers::BufferRef<Stat>>* AsyncStoreRaw(::grpc::ClientContext* context, const flatbuffers::BufferRef<Monster>& request, ::grpc::CompletionQueue* cq) override; |
| 71 | ::grpc::ClientReader< flatbuffers::BufferRef<Monster>>* RetrieveRaw(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request) override; |
| 72 | ::grpc::ClientAsyncReader< flatbuffers::BufferRef<Monster>>* AsyncRetrieveRaw(::grpc::ClientContext* context, const flatbuffers::BufferRef<Stat>& request, ::grpc::CompletionQueue* cq, void* tag) override; |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 73 | const ::grpc::RpcMethod rpcmethod_Store_; |
| 74 | const ::grpc::RpcMethod rpcmethod_Retrieve_; |
| 75 | }; |
| 76 | static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions()); |
| 77 | |
| 78 | class Service : public ::grpc::Service { |
| 79 | public: |
| 80 | Service(); |
| 81 | virtual ~Service(); |
Lawrence Chan | 6a7ec85 | 2017-05-12 16:36:35 -0500 | [diff] [blame] | 82 | virtual ::grpc::Status Store(::grpc::ServerContext* context, const flatbuffers::BufferRef<Monster>* request, flatbuffers::BufferRef<Stat>* response); |
| 83 | virtual ::grpc::Status Retrieve(::grpc::ServerContext* context, const flatbuffers::BufferRef<Stat>* request, ::grpc::ServerWriter< flatbuffers::BufferRef<Monster>>* writer); |
| 84 | }; |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 85 | template <class BaseClass> |
| 86 | class WithAsyncMethod_Store : public BaseClass { |
| 87 | private: |
| 88 | void BaseClassMustBeDerivedFromService(const Service *service) {} |
| 89 | public: |
| 90 | WithAsyncMethod_Store() { |
| 91 | ::grpc::Service::MarkMethodAsync(0); |
| 92 | } |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 93 | ~WithAsyncMethod_Store() override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 94 | BaseClassMustBeDerivedFromService(this); |
| 95 | } |
| 96 | // disable synchronous version of this method |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 97 | ::grpc::Status Store(::grpc::ServerContext* context, const flatbuffers::BufferRef<Monster>* request, flatbuffers::BufferRef<Stat>* response) final override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 98 | abort(); |
| 99 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); |
| 100 | } |
| 101 | void RequestStore(::grpc::ServerContext* context, flatbuffers::BufferRef<Monster>* request, ::grpc::ServerAsyncResponseWriter< flatbuffers::BufferRef<Stat>>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { |
| 102 | ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag); |
| 103 | } |
| 104 | }; |
| 105 | template <class BaseClass> |
| 106 | class WithAsyncMethod_Retrieve : public BaseClass { |
| 107 | private: |
| 108 | void BaseClassMustBeDerivedFromService(const Service *service) {} |
| 109 | public: |
| 110 | WithAsyncMethod_Retrieve() { |
| 111 | ::grpc::Service::MarkMethodAsync(1); |
| 112 | } |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 113 | ~WithAsyncMethod_Retrieve() override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 114 | BaseClassMustBeDerivedFromService(this); |
| 115 | } |
| 116 | // disable synchronous version of this method |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 117 | ::grpc::Status Retrieve(::grpc::ServerContext* context, const flatbuffers::BufferRef<Stat>* request, ::grpc::ServerWriter< flatbuffers::BufferRef<Monster>>* writer) final override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 118 | abort(); |
| 119 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); |
| 120 | } |
CarsarSky | 69dc71b | 2016-12-29 03:50:41 +0800 | [diff] [blame] | 121 | void RequestRetrieve(::grpc::ServerContext* context, flatbuffers::BufferRef<Stat>* request, ::grpc::ServerAsyncWriter< flatbuffers::BufferRef<Monster>>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { |
| 122 | ::grpc::Service::RequestAsyncServerStreaming(1, context, request, writer, new_call_cq, notification_cq, tag); |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 123 | } |
| 124 | }; |
| 125 | typedef WithAsyncMethod_Store< WithAsyncMethod_Retrieve< Service > > AsyncService; |
| 126 | template <class BaseClass> |
| 127 | class WithGenericMethod_Store : public BaseClass { |
| 128 | private: |
| 129 | void BaseClassMustBeDerivedFromService(const Service *service) {} |
| 130 | public: |
| 131 | WithGenericMethod_Store() { |
| 132 | ::grpc::Service::MarkMethodGeneric(0); |
| 133 | } |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 134 | ~WithGenericMethod_Store() override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 135 | BaseClassMustBeDerivedFromService(this); |
| 136 | } |
| 137 | // disable synchronous version of this method |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 138 | ::grpc::Status Store(::grpc::ServerContext* context, const flatbuffers::BufferRef<Monster>* request, flatbuffers::BufferRef<Stat>* response) final override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 139 | abort(); |
| 140 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); |
| 141 | } |
| 142 | }; |
| 143 | template <class BaseClass> |
| 144 | class WithGenericMethod_Retrieve : public BaseClass { |
| 145 | private: |
| 146 | void BaseClassMustBeDerivedFromService(const Service *service) {} |
| 147 | public: |
| 148 | WithGenericMethod_Retrieve() { |
| 149 | ::grpc::Service::MarkMethodGeneric(1); |
| 150 | } |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 151 | ~WithGenericMethod_Retrieve() override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 152 | BaseClassMustBeDerivedFromService(this); |
| 153 | } |
| 154 | // disable synchronous version of this method |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 155 | ::grpc::Status Retrieve(::grpc::ServerContext* context, const flatbuffers::BufferRef<Stat>* request, ::grpc::ServerWriter< flatbuffers::BufferRef<Monster>>* writer) final override { |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 156 | abort(); |
| 157 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); |
| 158 | } |
| 159 | }; |
Per Grön | 9aeeddf | 2017-05-12 18:48:17 +0200 | [diff] [blame] | 160 | template <class BaseClass> |
| 161 | class WithStreamedUnaryMethod_Store : public BaseClass { |
| 162 | private: |
| 163 | void BaseClassMustBeDerivedFromService(const Service *service) {} |
| 164 | public: |
| 165 | WithStreamedUnaryMethod_Store() { |
| 166 | ::grpc::Service::MarkMethodStreamed(0, |
| 167 | new ::grpc::StreamedUnaryHandler< flatbuffers::BufferRef<Monster>, flatbuffers::BufferRef<Stat>>(std::bind(&WithStreamedUnaryMethod_Store<BaseClass>::StreamedStore, this, std::placeholders::_1, std::placeholders::_2))); |
| 168 | } |
| 169 | ~WithStreamedUnaryMethod_Store() override { |
| 170 | BaseClassMustBeDerivedFromService(this); |
| 171 | } |
| 172 | // disable regular version of this method |
| 173 | ::grpc::Status Store(::grpc::ServerContext* context, const flatbuffers::BufferRef<Monster>* request, flatbuffers::BufferRef<Stat>* response) final override { |
| 174 | abort(); |
| 175 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); |
| 176 | } |
| 177 | // replace default version of method with streamed unary |
| 178 | virtual ::grpc::Status StreamedStore(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< flatbuffers::BufferRef<Monster>,flatbuffers::BufferRef<Stat>>* server_unary_streamer) = 0; |
| 179 | }; |
| 180 | typedef WithStreamedUnaryMethod_Store< Service > StreamedUnaryService; |
| 181 | template <class BaseClass> |
| 182 | class WithSplitStreamingMethod_Retrieve : public BaseClass { |
| 183 | private: |
| 184 | void BaseClassMustBeDerivedFromService(const Service *service) {} |
| 185 | public: |
| 186 | WithSplitStreamingMethod_Retrieve() { |
| 187 | ::grpc::Service::MarkMethodStreamed(1, |
| 188 | new ::grpc::SplitServerStreamingHandler< flatbuffers::BufferRef<Stat>, flatbuffers::BufferRef<Monster>>(std::bind(&WithSplitStreamingMethod_Retrieve<BaseClass>::StreamedRetrieve, this, std::placeholders::_1, std::placeholders::_2))); |
| 189 | } |
| 190 | ~WithSplitStreamingMethod_Retrieve() override { |
| 191 | BaseClassMustBeDerivedFromService(this); |
| 192 | } |
| 193 | // disable regular version of this method |
| 194 | ::grpc::Status Retrieve(::grpc::ServerContext* context, const flatbuffers::BufferRef<Stat>* request, ::grpc::ServerWriter< flatbuffers::BufferRef<Monster>>* writer) final override { |
| 195 | abort(); |
| 196 | return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); |
| 197 | } |
| 198 | // replace default version of method with split streamed |
| 199 | virtual ::grpc::Status StreamedRetrieve(::grpc::ServerContext* context, ::grpc::ServerSplitStreamer< flatbuffers::BufferRef<Stat>,flatbuffers::BufferRef<Monster>>* server_split_streamer) = 0; |
| 200 | }; |
| 201 | typedef WithSplitStreamingMethod_Retrieve< Service > SplitStreamedService; |
| 202 | typedef WithStreamedUnaryMethod_Store< WithSplitStreamingMethod_Retrieve< Service > > StreamedService; |
Wouter van Oortmerssen | 48f37f9 | 2016-04-13 18:16:05 -0700 | [diff] [blame] | 203 | }; |
| 204 | |
| 205 | } // namespace Example |
| 206 | } // namespace MyGame |
| 207 | |
| 208 | |
| 209 | #endif // GRPC_monster_5ftest__INCLUDED |