Line data Source code
1 : // Generated by the gRPC C++ plugin.
2 : // If you make any local change, they will be lost.
3 : // source: registrar.proto
4 : #ifndef GRPC_registrar_2eproto__INCLUDED
5 : #define GRPC_registrar_2eproto__INCLUDED
6 :
7 : #include "registrar.pb.h"
8 :
9 : #include <functional>
10 : #include <grpcpp/impl/codegen/async_generic_service.h>
11 : #include <grpcpp/impl/codegen/async_stream.h>
12 : #include <grpcpp/impl/codegen/async_unary_call.h>
13 : #include <grpcpp/impl/codegen/client_callback.h>
14 : #include <grpcpp/impl/codegen/method_handler_impl.h>
15 : #include <grpcpp/impl/codegen/proto_utils.h>
16 : #include <grpcpp/impl/codegen/rpc_method.h>
17 : #include <grpcpp/impl/codegen/server_callback.h>
18 : #include <grpcpp/impl/codegen/service_type.h>
19 : #include <grpcpp/impl/codegen/status.h>
20 : #include <grpcpp/impl/codegen/stub_options.h>
21 : #include <grpcpp/impl/codegen/sync_stream.h>
22 :
23 : namespace grpc {
24 : class CompletionQueue;
25 : class Channel;
26 : class ServerCompletionQueue;
27 : class ServerContext;
28 : } // namespace grpc
29 :
30 : namespace casatools {
31 : namespace rpc {
32 :
33 : class Registrar final {
34 : public:
35 : static constexpr char const* service_full_name() {
36 : return "casatools.rpc.Registrar";
37 : }
38 : class StubInterface {
39 : public:
40 0 : virtual ~StubInterface() {}
41 : // arg provides proposed id while result supplies the offical id
42 : virtual ::grpc::Status add(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::casatools::rpc::ServiceId* response) = 0;
43 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceId>> Asyncadd(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
44 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceId>>(AsyncaddRaw(context, request, cq));
45 : }
46 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceId>> PrepareAsyncadd(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
47 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceId>>(PrepareAsyncaddRaw(context, request, cq));
48 : }
49 : // only ServiceId.id is used for finding service to be removed
50 : virtual ::grpc::Status remove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::google::protobuf::BoolValue* response) = 0;
51 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::BoolValue>> Asyncremove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
52 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::BoolValue>>(AsyncremoveRaw(context, request, cq));
53 : }
54 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::BoolValue>> PrepareAsyncremove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
55 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::BoolValue>>(PrepareAsyncremoveRaw(context, request, cq));
56 : }
57 : virtual ::grpc::Status services(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::casatools::rpc::ServiceIds* response) = 0;
58 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceIds>> Asyncservices(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) {
59 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceIds>>(AsyncservicesRaw(context, request, cq));
60 : }
61 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceIds>> PrepareAsyncservices(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) {
62 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceIds>>(PrepareAsyncservicesRaw(context, request, cq));
63 : }
64 : class experimental_async_interface {
65 : public:
66 0 : virtual ~experimental_async_interface() {}
67 : // arg provides proposed id while result supplies the offical id
68 : virtual void add(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response, std::function<void(::grpc::Status)>) = 0;
69 : // only ServiceId.id is used for finding service to be removed
70 : virtual void remove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response, std::function<void(::grpc::Status)>) = 0;
71 : virtual void services(::grpc::ClientContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response, std::function<void(::grpc::Status)>) = 0;
72 : };
73 0 : virtual class experimental_async_interface* experimental_async() { return nullptr; }
74 : private:
75 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceId>* AsyncaddRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) = 0;
76 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceId>* PrepareAsyncaddRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) = 0;
77 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::BoolValue>* AsyncremoveRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) = 0;
78 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::google::protobuf::BoolValue>* PrepareAsyncremoveRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) = 0;
79 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceIds>* AsyncservicesRaw(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) = 0;
80 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::casatools::rpc::ServiceIds>* PrepareAsyncservicesRaw(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) = 0;
81 : };
82 : class Stub final : public StubInterface {
83 : public:
84 : Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel);
85 : ::grpc::Status add(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::casatools::rpc::ServiceId* response) override;
86 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceId>> Asyncadd(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
87 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceId>>(AsyncaddRaw(context, request, cq));
88 : }
89 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceId>> PrepareAsyncadd(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
90 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceId>>(PrepareAsyncaddRaw(context, request, cq));
91 : }
92 : ::grpc::Status remove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::google::protobuf::BoolValue* response) override;
93 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::BoolValue>> Asyncremove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
94 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::BoolValue>>(AsyncremoveRaw(context, request, cq));
95 : }
96 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::BoolValue>> PrepareAsyncremove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) {
97 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::google::protobuf::BoolValue>>(PrepareAsyncremoveRaw(context, request, cq));
98 : }
99 : ::grpc::Status services(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::casatools::rpc::ServiceIds* response) override;
100 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceIds>> Asyncservices(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) {
101 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceIds>>(AsyncservicesRaw(context, request, cq));
102 : }
103 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceIds>> PrepareAsyncservices(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) {
104 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceIds>>(PrepareAsyncservicesRaw(context, request, cq));
105 : }
106 : class experimental_async final :
107 : public StubInterface::experimental_async_interface {
108 : public:
109 : void add(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response, std::function<void(::grpc::Status)>) override;
110 : void remove(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response, std::function<void(::grpc::Status)>) override;
111 : void services(::grpc::ClientContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response, std::function<void(::grpc::Status)>) override;
112 : private:
113 : friend class Stub;
114 0 : explicit experimental_async(Stub* stub): stub_(stub) { }
115 : Stub* stub() { return stub_; }
116 : Stub* stub_;
117 : };
118 0 : class experimental_async_interface* experimental_async() override { return &async_stub_; }
119 :
120 : private:
121 : std::shared_ptr< ::grpc::ChannelInterface> channel_;
122 : class experimental_async async_stub_{this};
123 : ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceId>* AsyncaddRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) override;
124 : ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceId>* PrepareAsyncaddRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) override;
125 : ::grpc::ClientAsyncResponseReader< ::google::protobuf::BoolValue>* AsyncremoveRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) override;
126 : ::grpc::ClientAsyncResponseReader< ::google::protobuf::BoolValue>* PrepareAsyncremoveRaw(::grpc::ClientContext* context, const ::casatools::rpc::ServiceId& request, ::grpc::CompletionQueue* cq) override;
127 : ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceIds>* AsyncservicesRaw(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) override;
128 : ::grpc::ClientAsyncResponseReader< ::casatools::rpc::ServiceIds>* PrepareAsyncservicesRaw(::grpc::ClientContext* context, const ::google::protobuf::Empty& request, ::grpc::CompletionQueue* cq) override;
129 : const ::grpc::internal::RpcMethod rpcmethod_add_;
130 : const ::grpc::internal::RpcMethod rpcmethod_remove_;
131 : const ::grpc::internal::RpcMethod rpcmethod_services_;
132 : };
133 : static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
134 :
135 : class Service : public ::grpc::Service {
136 : public:
137 : Service();
138 : virtual ~Service();
139 : // arg provides proposed id while result supplies the offical id
140 : virtual ::grpc::Status add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response);
141 : // only ServiceId.id is used for finding service to be removed
142 : virtual ::grpc::Status remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response);
143 : virtual ::grpc::Status services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response);
144 : };
145 : template <class BaseClass>
146 : class WithAsyncMethod_add : public BaseClass {
147 : private:
148 : void BaseClassMustBeDerivedFromService(const Service *service) {}
149 : public:
150 : WithAsyncMethod_add() {
151 : ::grpc::Service::MarkMethodAsync(0);
152 : }
153 : ~WithAsyncMethod_add() override {
154 : BaseClassMustBeDerivedFromService(this);
155 : }
156 : // disable synchronous version of this method
157 : ::grpc::Status add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response) override {
158 : abort();
159 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
160 : }
161 : void Requestadd(::grpc::ServerContext* context, ::casatools::rpc::ServiceId* request, ::grpc::ServerAsyncResponseWriter< ::casatools::rpc::ServiceId>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
162 : ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
163 : }
164 : };
165 : template <class BaseClass>
166 : class WithAsyncMethod_remove : public BaseClass {
167 : private:
168 : void BaseClassMustBeDerivedFromService(const Service *service) {}
169 : public:
170 : WithAsyncMethod_remove() {
171 : ::grpc::Service::MarkMethodAsync(1);
172 : }
173 : ~WithAsyncMethod_remove() override {
174 : BaseClassMustBeDerivedFromService(this);
175 : }
176 : // disable synchronous version of this method
177 : ::grpc::Status remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response) override {
178 : abort();
179 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
180 : }
181 : void Requestremove(::grpc::ServerContext* context, ::casatools::rpc::ServiceId* request, ::grpc::ServerAsyncResponseWriter< ::google::protobuf::BoolValue>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
182 : ::grpc::Service::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag);
183 : }
184 : };
185 : template <class BaseClass>
186 : class WithAsyncMethod_services : public BaseClass {
187 : private:
188 : void BaseClassMustBeDerivedFromService(const Service *service) {}
189 : public:
190 : WithAsyncMethod_services() {
191 : ::grpc::Service::MarkMethodAsync(2);
192 : }
193 : ~WithAsyncMethod_services() override {
194 : BaseClassMustBeDerivedFromService(this);
195 : }
196 : // disable synchronous version of this method
197 : ::grpc::Status services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response) override {
198 : abort();
199 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
200 : }
201 : void Requestservices(::grpc::ServerContext* context, ::google::protobuf::Empty* request, ::grpc::ServerAsyncResponseWriter< ::casatools::rpc::ServiceIds>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
202 : ::grpc::Service::RequestAsyncUnary(2, context, request, response, new_call_cq, notification_cq, tag);
203 : }
204 : };
205 : typedef WithAsyncMethod_add<WithAsyncMethod_remove<WithAsyncMethod_services<Service > > > AsyncService;
206 : template <class BaseClass>
207 : class ExperimentalWithCallbackMethod_add : public BaseClass {
208 : private:
209 : void BaseClassMustBeDerivedFromService(const Service *service) {}
210 : public:
211 : ExperimentalWithCallbackMethod_add() {
212 : ::grpc::Service::experimental().MarkMethodCallback(0,
213 : new ::grpc::internal::CallbackUnaryHandler< ::casatools::rpc::ServiceId, ::casatools::rpc::ServiceId>(
214 : [this](::grpc::ServerContext* context,
215 : const ::casatools::rpc::ServiceId* request,
216 : ::casatools::rpc::ServiceId* response,
217 : ::grpc::experimental::ServerCallbackRpcController* controller) {
218 : return this->add(context, request, response, controller);
219 : }));
220 : }
221 : ~ExperimentalWithCallbackMethod_add() override {
222 : BaseClassMustBeDerivedFromService(this);
223 : }
224 : // disable synchronous version of this method
225 : ::grpc::Status add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response) override {
226 : abort();
227 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
228 : }
229 : virtual void add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response, ::grpc::experimental::ServerCallbackRpcController* controller) { controller->Finish(::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "")); }
230 : };
231 : template <class BaseClass>
232 : class ExperimentalWithCallbackMethod_remove : public BaseClass {
233 : private:
234 : void BaseClassMustBeDerivedFromService(const Service *service) {}
235 : public:
236 : ExperimentalWithCallbackMethod_remove() {
237 : ::grpc::Service::experimental().MarkMethodCallback(1,
238 : new ::grpc::internal::CallbackUnaryHandler< ::casatools::rpc::ServiceId, ::google::protobuf::BoolValue>(
239 : [this](::grpc::ServerContext* context,
240 : const ::casatools::rpc::ServiceId* request,
241 : ::google::protobuf::BoolValue* response,
242 : ::grpc::experimental::ServerCallbackRpcController* controller) {
243 : return this->remove(context, request, response, controller);
244 : }));
245 : }
246 : ~ExperimentalWithCallbackMethod_remove() override {
247 : BaseClassMustBeDerivedFromService(this);
248 : }
249 : // disable synchronous version of this method
250 : ::grpc::Status remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response) override {
251 : abort();
252 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
253 : }
254 : virtual void remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response, ::grpc::experimental::ServerCallbackRpcController* controller) { controller->Finish(::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "")); }
255 : };
256 : template <class BaseClass>
257 : class ExperimentalWithCallbackMethod_services : public BaseClass {
258 : private:
259 : void BaseClassMustBeDerivedFromService(const Service *service) {}
260 : public:
261 : ExperimentalWithCallbackMethod_services() {
262 : ::grpc::Service::experimental().MarkMethodCallback(2,
263 : new ::grpc::internal::CallbackUnaryHandler< ::google::protobuf::Empty, ::casatools::rpc::ServiceIds>(
264 : [this](::grpc::ServerContext* context,
265 : const ::google::protobuf::Empty* request,
266 : ::casatools::rpc::ServiceIds* response,
267 : ::grpc::experimental::ServerCallbackRpcController* controller) {
268 : return this->services(context, request, response, controller);
269 : }));
270 : }
271 : ~ExperimentalWithCallbackMethod_services() override {
272 : BaseClassMustBeDerivedFromService(this);
273 : }
274 : // disable synchronous version of this method
275 : ::grpc::Status services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response) override {
276 : abort();
277 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
278 : }
279 : virtual void services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response, ::grpc::experimental::ServerCallbackRpcController* controller) { controller->Finish(::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "")); }
280 : };
281 : typedef ExperimentalWithCallbackMethod_add<ExperimentalWithCallbackMethod_remove<ExperimentalWithCallbackMethod_services<Service > > > ExperimentalCallbackService;
282 : template <class BaseClass>
283 : class WithGenericMethod_add : public BaseClass {
284 : private:
285 : void BaseClassMustBeDerivedFromService(const Service *service) {}
286 : public:
287 : WithGenericMethod_add() {
288 : ::grpc::Service::MarkMethodGeneric(0);
289 : }
290 : ~WithGenericMethod_add() override {
291 : BaseClassMustBeDerivedFromService(this);
292 : }
293 : // disable synchronous version of this method
294 : ::grpc::Status add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response) override {
295 : abort();
296 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
297 : }
298 : };
299 : template <class BaseClass>
300 : class WithGenericMethod_remove : public BaseClass {
301 : private:
302 : void BaseClassMustBeDerivedFromService(const Service *service) {}
303 : public:
304 : WithGenericMethod_remove() {
305 : ::grpc::Service::MarkMethodGeneric(1);
306 : }
307 : ~WithGenericMethod_remove() override {
308 : BaseClassMustBeDerivedFromService(this);
309 : }
310 : // disable synchronous version of this method
311 : ::grpc::Status remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response) override {
312 : abort();
313 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
314 : }
315 : };
316 : template <class BaseClass>
317 : class WithGenericMethod_services : public BaseClass {
318 : private:
319 : void BaseClassMustBeDerivedFromService(const Service *service) {}
320 : public:
321 : WithGenericMethod_services() {
322 : ::grpc::Service::MarkMethodGeneric(2);
323 : }
324 : ~WithGenericMethod_services() override {
325 : BaseClassMustBeDerivedFromService(this);
326 : }
327 : // disable synchronous version of this method
328 : ::grpc::Status services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response) override {
329 : abort();
330 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
331 : }
332 : };
333 : template <class BaseClass>
334 : class WithRawMethod_add : public BaseClass {
335 : private:
336 : void BaseClassMustBeDerivedFromService(const Service *service) {}
337 : public:
338 : WithRawMethod_add() {
339 : ::grpc::Service::MarkMethodRaw(0);
340 : }
341 : ~WithRawMethod_add() override {
342 : BaseClassMustBeDerivedFromService(this);
343 : }
344 : // disable synchronous version of this method
345 : ::grpc::Status add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response) override {
346 : abort();
347 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
348 : }
349 : void Requestadd(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
350 : ::grpc::Service::RequestAsyncUnary(0, context, request, response, new_call_cq, notification_cq, tag);
351 : }
352 : };
353 : template <class BaseClass>
354 : class WithRawMethod_remove : public BaseClass {
355 : private:
356 : void BaseClassMustBeDerivedFromService(const Service *service) {}
357 : public:
358 : WithRawMethod_remove() {
359 : ::grpc::Service::MarkMethodRaw(1);
360 : }
361 : ~WithRawMethod_remove() override {
362 : BaseClassMustBeDerivedFromService(this);
363 : }
364 : // disable synchronous version of this method
365 : ::grpc::Status remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response) override {
366 : abort();
367 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
368 : }
369 : void Requestremove(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
370 : ::grpc::Service::RequestAsyncUnary(1, context, request, response, new_call_cq, notification_cq, tag);
371 : }
372 : };
373 : template <class BaseClass>
374 : class WithRawMethod_services : public BaseClass {
375 : private:
376 : void BaseClassMustBeDerivedFromService(const Service *service) {}
377 : public:
378 : WithRawMethod_services() {
379 : ::grpc::Service::MarkMethodRaw(2);
380 : }
381 : ~WithRawMethod_services() override {
382 : BaseClassMustBeDerivedFromService(this);
383 : }
384 : // disable synchronous version of this method
385 : ::grpc::Status services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response) override {
386 : abort();
387 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
388 : }
389 : void Requestservices(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncResponseWriter< ::grpc::ByteBuffer>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) {
390 : ::grpc::Service::RequestAsyncUnary(2, context, request, response, new_call_cq, notification_cq, tag);
391 : }
392 : };
393 : template <class BaseClass>
394 : class ExperimentalWithRawCallbackMethod_add : public BaseClass {
395 : private:
396 : void BaseClassMustBeDerivedFromService(const Service *service) {}
397 : public:
398 : ExperimentalWithRawCallbackMethod_add() {
399 : ::grpc::Service::experimental().MarkMethodRawCallback(0,
400 : new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
401 : [this](::grpc::ServerContext* context,
402 : const ::grpc::ByteBuffer* request,
403 : ::grpc::ByteBuffer* response,
404 : ::grpc::experimental::ServerCallbackRpcController* controller) {
405 : this->add(context, request, response, controller);
406 : }));
407 : }
408 : ~ExperimentalWithRawCallbackMethod_add() override {
409 : BaseClassMustBeDerivedFromService(this);
410 : }
411 : // disable synchronous version of this method
412 : ::grpc::Status add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response) override {
413 : abort();
414 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
415 : }
416 : virtual void add(::grpc::ServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response, ::grpc::experimental::ServerCallbackRpcController* controller) { controller->Finish(::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "")); }
417 : };
418 : template <class BaseClass>
419 : class ExperimentalWithRawCallbackMethod_remove : public BaseClass {
420 : private:
421 : void BaseClassMustBeDerivedFromService(const Service *service) {}
422 : public:
423 : ExperimentalWithRawCallbackMethod_remove() {
424 : ::grpc::Service::experimental().MarkMethodRawCallback(1,
425 : new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
426 : [this](::grpc::ServerContext* context,
427 : const ::grpc::ByteBuffer* request,
428 : ::grpc::ByteBuffer* response,
429 : ::grpc::experimental::ServerCallbackRpcController* controller) {
430 : this->remove(context, request, response, controller);
431 : }));
432 : }
433 : ~ExperimentalWithRawCallbackMethod_remove() override {
434 : BaseClassMustBeDerivedFromService(this);
435 : }
436 : // disable synchronous version of this method
437 : ::grpc::Status remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response) override {
438 : abort();
439 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
440 : }
441 : virtual void remove(::grpc::ServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response, ::grpc::experimental::ServerCallbackRpcController* controller) { controller->Finish(::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "")); }
442 : };
443 : template <class BaseClass>
444 : class ExperimentalWithRawCallbackMethod_services : public BaseClass {
445 : private:
446 : void BaseClassMustBeDerivedFromService(const Service *service) {}
447 : public:
448 : ExperimentalWithRawCallbackMethod_services() {
449 : ::grpc::Service::experimental().MarkMethodRawCallback(2,
450 : new ::grpc::internal::CallbackUnaryHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>(
451 : [this](::grpc::ServerContext* context,
452 : const ::grpc::ByteBuffer* request,
453 : ::grpc::ByteBuffer* response,
454 : ::grpc::experimental::ServerCallbackRpcController* controller) {
455 : this->services(context, request, response, controller);
456 : }));
457 : }
458 : ~ExperimentalWithRawCallbackMethod_services() override {
459 : BaseClassMustBeDerivedFromService(this);
460 : }
461 : // disable synchronous version of this method
462 : ::grpc::Status services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response) override {
463 : abort();
464 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
465 : }
466 : virtual void services(::grpc::ServerContext* context, const ::grpc::ByteBuffer* request, ::grpc::ByteBuffer* response, ::grpc::experimental::ServerCallbackRpcController* controller) { controller->Finish(::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "")); }
467 : };
468 : template <class BaseClass>
469 : class WithStreamedUnaryMethod_add : public BaseClass {
470 : private:
471 : void BaseClassMustBeDerivedFromService(const Service *service) {}
472 : public:
473 : WithStreamedUnaryMethod_add() {
474 : ::grpc::Service::MarkMethodStreamed(0,
475 : new ::grpc::internal::StreamedUnaryHandler< ::casatools::rpc::ServiceId, ::casatools::rpc::ServiceId>(std::bind(&WithStreamedUnaryMethod_add<BaseClass>::Streamedadd, this, std::placeholders::_1, std::placeholders::_2)));
476 : }
477 : ~WithStreamedUnaryMethod_add() override {
478 : BaseClassMustBeDerivedFromService(this);
479 : }
480 : // disable regular version of this method
481 : ::grpc::Status add(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::casatools::rpc::ServiceId* response) override {
482 : abort();
483 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
484 : }
485 : // replace default version of method with streamed unary
486 : virtual ::grpc::Status Streamedadd(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::casatools::rpc::ServiceId,::casatools::rpc::ServiceId>* server_unary_streamer) = 0;
487 : };
488 : template <class BaseClass>
489 : class WithStreamedUnaryMethod_remove : public BaseClass {
490 : private:
491 : void BaseClassMustBeDerivedFromService(const Service *service) {}
492 : public:
493 : WithStreamedUnaryMethod_remove() {
494 : ::grpc::Service::MarkMethodStreamed(1,
495 : new ::grpc::internal::StreamedUnaryHandler< ::casatools::rpc::ServiceId, ::google::protobuf::BoolValue>(std::bind(&WithStreamedUnaryMethod_remove<BaseClass>::Streamedremove, this, std::placeholders::_1, std::placeholders::_2)));
496 : }
497 : ~WithStreamedUnaryMethod_remove() override {
498 : BaseClassMustBeDerivedFromService(this);
499 : }
500 : // disable regular version of this method
501 : ::grpc::Status remove(::grpc::ServerContext* context, const ::casatools::rpc::ServiceId* request, ::google::protobuf::BoolValue* response) override {
502 : abort();
503 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
504 : }
505 : // replace default version of method with streamed unary
506 : virtual ::grpc::Status Streamedremove(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::casatools::rpc::ServiceId,::google::protobuf::BoolValue>* server_unary_streamer) = 0;
507 : };
508 : template <class BaseClass>
509 : class WithStreamedUnaryMethod_services : public BaseClass {
510 : private:
511 : void BaseClassMustBeDerivedFromService(const Service *service) {}
512 : public:
513 : WithStreamedUnaryMethod_services() {
514 : ::grpc::Service::MarkMethodStreamed(2,
515 : new ::grpc::internal::StreamedUnaryHandler< ::google::protobuf::Empty, ::casatools::rpc::ServiceIds>(std::bind(&WithStreamedUnaryMethod_services<BaseClass>::Streamedservices, this, std::placeholders::_1, std::placeholders::_2)));
516 : }
517 : ~WithStreamedUnaryMethod_services() override {
518 : BaseClassMustBeDerivedFromService(this);
519 : }
520 : // disable regular version of this method
521 : ::grpc::Status services(::grpc::ServerContext* context, const ::google::protobuf::Empty* request, ::casatools::rpc::ServiceIds* response) override {
522 : abort();
523 : return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
524 : }
525 : // replace default version of method with streamed unary
526 : virtual ::grpc::Status Streamedservices(::grpc::ServerContext* context, ::grpc::ServerUnaryStreamer< ::google::protobuf::Empty,::casatools::rpc::ServiceIds>* server_unary_streamer) = 0;
527 : };
528 : typedef WithStreamedUnaryMethod_add<WithStreamedUnaryMethod_remove<WithStreamedUnaryMethod_services<Service > > > StreamedUnaryService;
529 : typedef Service SplitStreamedService;
530 : typedef WithStreamedUnaryMethod_add<WithStreamedUnaryMethod_remove<WithStreamedUnaryMethod_services<Service > > > StreamedService;
531 : };
532 :
533 : } // namespace rpc
534 : } // namespace casatools
535 :
536 :
537 : #endif // GRPC_registrar_2eproto__INCLUDED
|
