Line data Source code
1 : // Generated by the gRPC protobuf plugin.
2 : // If you make any local change, they will be lost.
3 : // source: test/proto/test.proto
4 : #ifndef GRPC_test_2fproto_2ftest_2eproto__INCLUDED
5 : #define GRPC_test_2fproto_2ftest_2eproto__INCLUDED
6 :
7 : #include "test/proto/test.pb.h"
8 :
9 : #include <grpc++/support/async_stream.h>
10 : #include <grpc++/impl/rpc_method.h>
11 : #include <grpc++/impl/proto_utils.h>
12 : #include <grpc++/impl/service_type.h>
13 : #include <grpc++/support/async_unary_call.h>
14 : #include <grpc++/support/status.h>
15 : #include <grpc++/support/stub_options.h>
16 : #include <grpc++/support/sync_stream.h>
17 :
18 : namespace grpc {
19 : class CompletionQueue;
20 : class Channel;
21 : class RpcService;
22 : class ServerCompletionQueue;
23 : class ServerContext;
24 : } // namespace grpc
25 :
26 : namespace grpc {
27 : namespace testing {
28 :
29 : class TestService GRPC_FINAL {
30 : public:
31 4 : class StubInterface {
32 : public:
33 4 : virtual ~StubInterface() {}
34 : virtual ::grpc::Status EmptyCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) = 0;
35 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>> AsyncEmptyCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
36 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>>(AsyncEmptyCallRaw(context, request, cq));
37 : }
38 : virtual ::grpc::Status UnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::testing::SimpleResponse* response) = 0;
39 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::SimpleResponse>> AsyncUnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) {
40 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::SimpleResponse>>(AsyncUnaryCallRaw(context, request, cq));
41 : }
42 : std::unique_ptr< ::grpc::ClientReaderInterface< ::grpc::testing::StreamingOutputCallResponse>> StreamingOutputCall(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request) {
43 : return std::unique_ptr< ::grpc::ClientReaderInterface< ::grpc::testing::StreamingOutputCallResponse>>(StreamingOutputCallRaw(context, request));
44 : }
45 : std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::grpc::testing::StreamingOutputCallResponse>> AsyncStreamingOutputCall(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request, ::grpc::CompletionQueue* cq, void* tag) {
46 : return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::grpc::testing::StreamingOutputCallResponse>>(AsyncStreamingOutputCallRaw(context, request, cq, tag));
47 : }
48 : std::unique_ptr< ::grpc::ClientWriterInterface< ::grpc::testing::StreamingInputCallRequest>> StreamingInputCall(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response) {
49 : return std::unique_ptr< ::grpc::ClientWriterInterface< ::grpc::testing::StreamingInputCallRequest>>(StreamingInputCallRaw(context, response));
50 : }
51 : std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::grpc::testing::StreamingInputCallRequest>> AsyncStreamingInputCall(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
52 : return std::unique_ptr< ::grpc::ClientAsyncWriterInterface< ::grpc::testing::StreamingInputCallRequest>>(AsyncStreamingInputCallRaw(context, response, cq, tag));
53 : }
54 : std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> FullDuplexCall(::grpc::ClientContext* context) {
55 : return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(FullDuplexCallRaw(context));
56 : }
57 : std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> AsyncFullDuplexCall(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
58 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(AsyncFullDuplexCallRaw(context, cq, tag));
59 : }
60 : std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> HalfDuplexCall(::grpc::ClientContext* context) {
61 : return std::unique_ptr< ::grpc::ClientReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(HalfDuplexCallRaw(context));
62 : }
63 : std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> AsyncHalfDuplexCall(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
64 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(AsyncHalfDuplexCallRaw(context, cq, tag));
65 : }
66 : private:
67 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>* AsyncEmptyCallRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) = 0;
68 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::SimpleResponse>* AsyncUnaryCallRaw(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) = 0;
69 : virtual ::grpc::ClientReaderInterface< ::grpc::testing::StreamingOutputCallResponse>* StreamingOutputCallRaw(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request) = 0;
70 : virtual ::grpc::ClientAsyncReaderInterface< ::grpc::testing::StreamingOutputCallResponse>* AsyncStreamingOutputCallRaw(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request, ::grpc::CompletionQueue* cq, void* tag) = 0;
71 : virtual ::grpc::ClientWriterInterface< ::grpc::testing::StreamingInputCallRequest>* StreamingInputCallRaw(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response) = 0;
72 : virtual ::grpc::ClientAsyncWriterInterface< ::grpc::testing::StreamingInputCallRequest>* AsyncStreamingInputCallRaw(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response, ::grpc::CompletionQueue* cq, void* tag) = 0;
73 : virtual ::grpc::ClientReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* FullDuplexCallRaw(::grpc::ClientContext* context) = 0;
74 : virtual ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* AsyncFullDuplexCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0;
75 : virtual ::grpc::ClientReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* HalfDuplexCallRaw(::grpc::ClientContext* context) = 0;
76 : virtual ::grpc::ClientAsyncReaderWriterInterface< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* AsyncHalfDuplexCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) = 0;
77 : };
78 8 : class Stub GRPC_FINAL : public StubInterface {
79 : public:
80 : Stub(const std::shared_ptr< ::grpc::Channel>& channel);
81 : ::grpc::Status EmptyCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) GRPC_OVERRIDE;
82 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>> AsyncEmptyCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
83 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>>(AsyncEmptyCallRaw(context, request, cq));
84 : }
85 : ::grpc::Status UnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::testing::SimpleResponse* response) GRPC_OVERRIDE;
86 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>> AsyncUnaryCall(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) {
87 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>>(AsyncUnaryCallRaw(context, request, cq));
88 : }
89 0 : std::unique_ptr< ::grpc::ClientReader< ::grpc::testing::StreamingOutputCallResponse>> StreamingOutputCall(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request) {
90 0 : return std::unique_ptr< ::grpc::ClientReader< ::grpc::testing::StreamingOutputCallResponse>>(StreamingOutputCallRaw(context, request));
91 : }
92 : std::unique_ptr< ::grpc::ClientAsyncReader< ::grpc::testing::StreamingOutputCallResponse>> AsyncStreamingOutputCall(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request, ::grpc::CompletionQueue* cq, void* tag) {
93 : return std::unique_ptr< ::grpc::ClientAsyncReader< ::grpc::testing::StreamingOutputCallResponse>>(AsyncStreamingOutputCallRaw(context, request, cq, tag));
94 : }
95 0 : std::unique_ptr< ::grpc::ClientWriter< ::grpc::testing::StreamingInputCallRequest>> StreamingInputCall(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response) {
96 0 : return std::unique_ptr< ::grpc::ClientWriter< ::grpc::testing::StreamingInputCallRequest>>(StreamingInputCallRaw(context, response));
97 : }
98 : std::unique_ptr< ::grpc::ClientAsyncWriter< ::grpc::testing::StreamingInputCallRequest>> AsyncStreamingInputCall(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response, ::grpc::CompletionQueue* cq, void* tag) {
99 : return std::unique_ptr< ::grpc::ClientAsyncWriter< ::grpc::testing::StreamingInputCallRequest>>(AsyncStreamingInputCallRaw(context, response, cq, tag));
100 : }
101 0 : std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> FullDuplexCall(::grpc::ClientContext* context) {
102 0 : return std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(FullDuplexCallRaw(context));
103 : }
104 : std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> AsyncFullDuplexCall(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
105 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(AsyncFullDuplexCallRaw(context, cq, tag));
106 : }
107 0 : std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> HalfDuplexCall(::grpc::ClientContext* context) {
108 0 : return std::unique_ptr< ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(HalfDuplexCallRaw(context));
109 : }
110 : std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>> AsyncHalfDuplexCall(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) {
111 : return std::unique_ptr< ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>>(AsyncHalfDuplexCallRaw(context, cq, tag));
112 : }
113 :
114 : private:
115 : std::shared_ptr< ::grpc::Channel> channel_;
116 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>* AsyncEmptyCallRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) GRPC_OVERRIDE;
117 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::SimpleResponse>* AsyncUnaryCallRaw(::grpc::ClientContext* context, const ::grpc::testing::SimpleRequest& request, ::grpc::CompletionQueue* cq) GRPC_OVERRIDE;
118 : ::grpc::ClientReader< ::grpc::testing::StreamingOutputCallResponse>* StreamingOutputCallRaw(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request) GRPC_OVERRIDE;
119 : ::grpc::ClientAsyncReader< ::grpc::testing::StreamingOutputCallResponse>* AsyncStreamingOutputCallRaw(::grpc::ClientContext* context, const ::grpc::testing::StreamingOutputCallRequest& request, ::grpc::CompletionQueue* cq, void* tag) GRPC_OVERRIDE;
120 : ::grpc::ClientWriter< ::grpc::testing::StreamingInputCallRequest>* StreamingInputCallRaw(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response) GRPC_OVERRIDE;
121 : ::grpc::ClientAsyncWriter< ::grpc::testing::StreamingInputCallRequest>* AsyncStreamingInputCallRaw(::grpc::ClientContext* context, ::grpc::testing::StreamingInputCallResponse* response, ::grpc::CompletionQueue* cq, void* tag) GRPC_OVERRIDE;
122 : ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* FullDuplexCallRaw(::grpc::ClientContext* context) GRPC_OVERRIDE;
123 : ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* AsyncFullDuplexCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) GRPC_OVERRIDE;
124 : ::grpc::ClientReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* HalfDuplexCallRaw(::grpc::ClientContext* context) GRPC_OVERRIDE;
125 : ::grpc::ClientAsyncReaderWriter< ::grpc::testing::StreamingOutputCallRequest, ::grpc::testing::StreamingOutputCallResponse>* AsyncHalfDuplexCallRaw(::grpc::ClientContext* context, ::grpc::CompletionQueue* cq, void* tag) GRPC_OVERRIDE;
126 : const ::grpc::RpcMethod rpcmethod_EmptyCall_;
127 : const ::grpc::RpcMethod rpcmethod_UnaryCall_;
128 : const ::grpc::RpcMethod rpcmethod_StreamingOutputCall_;
129 : const ::grpc::RpcMethod rpcmethod_StreamingInputCall_;
130 : const ::grpc::RpcMethod rpcmethod_FullDuplexCall_;
131 : const ::grpc::RpcMethod rpcmethod_HalfDuplexCall_;
132 : };
133 : static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
134 :
135 : class Service : public ::grpc::SynchronousService {
136 : public:
137 1 : Service() : service_(nullptr) {}
138 : virtual ~Service();
139 : virtual ::grpc::Status EmptyCall(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::Empty* response);
140 : virtual ::grpc::Status UnaryCall(::grpc::ServerContext* context, const ::grpc::testing::SimpleRequest* request, ::grpc::testing::SimpleResponse* response);
141 : virtual ::grpc::Status StreamingOutputCall(::grpc::ServerContext* context, const ::grpc::testing::StreamingOutputCallRequest* request, ::grpc::ServerWriter< ::grpc::testing::StreamingOutputCallResponse>* writer);
142 : virtual ::grpc::Status StreamingInputCall(::grpc::ServerContext* context, ::grpc::ServerReader< ::grpc::testing::StreamingInputCallRequest>* reader, ::grpc::testing::StreamingInputCallResponse* response);
143 : virtual ::grpc::Status FullDuplexCall(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream);
144 : virtual ::grpc::Status HalfDuplexCall(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream);
145 : ::grpc::RpcService* service() GRPC_OVERRIDE GRPC_FINAL;
146 : private:
147 : ::grpc::RpcService* service_;
148 : };
149 : class AsyncService GRPC_FINAL : public ::grpc::AsynchronousService {
150 : public:
151 : explicit AsyncService();
152 : ~AsyncService() {};
153 : void RequestEmptyCall(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::Empty>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
154 : void RequestUnaryCall(::grpc::ServerContext* context, ::grpc::testing::SimpleRequest* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::SimpleResponse>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
155 : void RequestStreamingOutputCall(::grpc::ServerContext* context, ::grpc::testing::StreamingOutputCallRequest* request, ::grpc::ServerAsyncWriter< ::grpc::testing::StreamingOutputCallResponse>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
156 : void RequestStreamingInputCall(::grpc::ServerContext* context, ::grpc::ServerAsyncReader< ::grpc::testing::StreamingInputCallResponse, ::grpc::testing::StreamingInputCallRequest>* reader, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
157 : void RequestFullDuplexCall(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
158 : void RequestHalfDuplexCall(::grpc::ServerContext* context, ::grpc::ServerAsyncReaderWriter< ::grpc::testing::StreamingOutputCallResponse, ::grpc::testing::StreamingOutputCallRequest>* stream, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
159 : };
160 : };
161 :
162 : class UnimplementedService GRPC_FINAL {
163 : public:
164 0 : class StubInterface {
165 : public:
166 0 : virtual ~StubInterface() {}
167 : virtual ::grpc::Status UnimplementedCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) = 0;
168 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>> AsyncUnimplementedCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
169 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>>(AsyncUnimplementedCallRaw(context, request, cq));
170 : }
171 : private:
172 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>* AsyncUnimplementedCallRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) = 0;
173 : };
174 0 : class Stub GRPC_FINAL : public StubInterface {
175 : public:
176 : Stub(const std::shared_ptr< ::grpc::Channel>& channel);
177 : ::grpc::Status UnimplementedCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) GRPC_OVERRIDE;
178 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>> AsyncUnimplementedCall(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
179 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>>(AsyncUnimplementedCallRaw(context, request, cq));
180 : }
181 :
182 : private:
183 : std::shared_ptr< ::grpc::Channel> channel_;
184 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>* AsyncUnimplementedCallRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) GRPC_OVERRIDE;
185 : const ::grpc::RpcMethod rpcmethod_UnimplementedCall_;
186 : };
187 : static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
188 :
189 : class Service : public ::grpc::SynchronousService {
190 : public:
191 : Service() : service_(nullptr) {}
192 : virtual ~Service();
193 : virtual ::grpc::Status UnimplementedCall(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::Empty* response);
194 : ::grpc::RpcService* service() GRPC_OVERRIDE GRPC_FINAL;
195 : private:
196 : ::grpc::RpcService* service_;
197 : };
198 : class AsyncService GRPC_FINAL : public ::grpc::AsynchronousService {
199 : public:
200 : explicit AsyncService();
201 : ~AsyncService() {};
202 : void RequestUnimplementedCall(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::Empty>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
203 : };
204 : };
205 :
206 : class ReconnectService GRPC_FINAL {
207 : public:
208 0 : class StubInterface {
209 : public:
210 0 : virtual ~StubInterface() {}
211 : virtual ::grpc::Status Start(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) = 0;
212 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>> AsyncStart(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
213 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>>(AsyncStartRaw(context, request, cq));
214 : }
215 : virtual ::grpc::Status Stop(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::ReconnectInfo* response) = 0;
216 : std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::ReconnectInfo>> AsyncStop(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
217 : return std::unique_ptr< ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::ReconnectInfo>>(AsyncStopRaw(context, request, cq));
218 : }
219 : private:
220 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::Empty>* AsyncStartRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) = 0;
221 : virtual ::grpc::ClientAsyncResponseReaderInterface< ::grpc::testing::ReconnectInfo>* AsyncStopRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) = 0;
222 : };
223 0 : class Stub GRPC_FINAL : public StubInterface {
224 : public:
225 : Stub(const std::shared_ptr< ::grpc::Channel>& channel);
226 : ::grpc::Status Start(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::Empty* response) GRPC_OVERRIDE;
227 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>> AsyncStart(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
228 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>>(AsyncStartRaw(context, request, cq));
229 : }
230 : ::grpc::Status Stop(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::testing::ReconnectInfo* response) GRPC_OVERRIDE;
231 : std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::ReconnectInfo>> AsyncStop(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) {
232 : return std::unique_ptr< ::grpc::ClientAsyncResponseReader< ::grpc::testing::ReconnectInfo>>(AsyncStopRaw(context, request, cq));
233 : }
234 :
235 : private:
236 : std::shared_ptr< ::grpc::Channel> channel_;
237 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::Empty>* AsyncStartRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) GRPC_OVERRIDE;
238 : ::grpc::ClientAsyncResponseReader< ::grpc::testing::ReconnectInfo>* AsyncStopRaw(::grpc::ClientContext* context, const ::grpc::testing::Empty& request, ::grpc::CompletionQueue* cq) GRPC_OVERRIDE;
239 : const ::grpc::RpcMethod rpcmethod_Start_;
240 : const ::grpc::RpcMethod rpcmethod_Stop_;
241 : };
242 : static std::unique_ptr<Stub> NewStub(const std::shared_ptr< ::grpc::Channel>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions());
243 :
244 : class Service : public ::grpc::SynchronousService {
245 : public:
246 : Service() : service_(nullptr) {}
247 : virtual ~Service();
248 : virtual ::grpc::Status Start(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::Empty* response);
249 : virtual ::grpc::Status Stop(::grpc::ServerContext* context, const ::grpc::testing::Empty* request, ::grpc::testing::ReconnectInfo* response);
250 : ::grpc::RpcService* service() GRPC_OVERRIDE GRPC_FINAL;
251 : private:
252 : ::grpc::RpcService* service_;
253 : };
254 : class AsyncService GRPC_FINAL : public ::grpc::AsynchronousService {
255 : public:
256 : explicit AsyncService();
257 : ~AsyncService() {};
258 : void RequestStart(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::Empty>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
259 : void RequestStop(::grpc::ServerContext* context, ::grpc::testing::Empty* request, ::grpc::ServerAsyncResponseWriter< ::grpc::testing::ReconnectInfo>* response, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag);
260 : };
261 : };
262 :
263 : } // namespace testing
264 : } // namespace grpc
265 :
266 :
267 : #endif // GRPC_test_2fproto_2ftest_2eproto__INCLUDED
|
