// Generated by the gRPC C++ plugin. // If you make any local change, they will be lost. // source: faq_hook.proto #ifndef GRPC_faq_5fhook_2eproto__INCLUDED #define GRPC_faq_5fhook_2eproto__INCLUDED #include "faq_hook.pb.h" #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include namespace faq { class FaQSQLite final { public: static constexpr char const* service_full_name() { return "faq.FaQSQLite"; } class StubInterface { public: virtual ~StubInterface() {} std::unique_ptr< ::grpc::ClientReaderInterface< ::faq::SQLiteQueryRow>> Query(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request) { return std::unique_ptr< ::grpc::ClientReaderInterface< ::faq::SQLiteQueryRow>>(QueryRaw(context, request)); } std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::faq::SQLiteQueryRow>> AsyncQuery(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq, void* tag) { return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::faq::SQLiteQueryRow>>(AsyncQueryRaw(context, request, cq, tag)); } std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::faq::SQLiteQueryRow>> PrepareAsyncQuery(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr< ::grpc::ClientAsyncReaderInterface< ::faq::SQLiteQueryRow>>(PrepareAsyncQueryRaw(context, request, cq)); } class experimental_async_interface { public: virtual ~experimental_async_interface() {} #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL virtual void Query(::grpc::ClientContext* context, ::faq::SQLiteQueryString* request, ::grpc::ClientReadReactor< ::faq::SQLiteQueryRow>* reactor) = 0; #else virtual void Query(::grpc::ClientContext* context, ::faq::SQLiteQueryString* request, ::grpc::experimental::ClientReadReactor< ::faq::SQLiteQueryRow>* reactor) = 0; #endif }; #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL typedef class experimental_async_interface async_interface; #endif #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL async_interface* async() { return experimental_async(); } #endif virtual class experimental_async_interface* experimental_async() { return nullptr; } private: virtual ::grpc::ClientReaderInterface< ::faq::SQLiteQueryRow>* QueryRaw(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request) = 0; virtual ::grpc::ClientAsyncReaderInterface< ::faq::SQLiteQueryRow>* AsyncQueryRaw(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq, void* tag) = 0; virtual ::grpc::ClientAsyncReaderInterface< ::faq::SQLiteQueryRow>* PrepareAsyncQueryRaw(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq) = 0; }; class FAQ_PROTOS Stub final : public StubInterface { public: Stub(const std::shared_ptr<::grpc::ChannelInterface>& channel); std::unique_ptr<::grpc::ClientReader<::faq::SQLiteQueryRow>> Query(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request) { return std::unique_ptr<::grpc::ClientReader<::faq::SQLiteQueryRow>>(QueryRaw(context, request)); } std::unique_ptr<::grpc::ClientAsyncReader<::faq::SQLiteQueryRow>> AsyncQuery(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq, void* tag) { return std::unique_ptr<::grpc::ClientAsyncReader<::faq::SQLiteQueryRow>>( AsyncQueryRaw(context, request, cq, tag)); } std::unique_ptr<::grpc::ClientAsyncReader<::faq::SQLiteQueryRow>> PrepareAsyncQuery(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq) { return std::unique_ptr<::grpc::ClientAsyncReader<::faq::SQLiteQueryRow>>( PrepareAsyncQueryRaw(context, request, cq)); } class experimental_async final : public StubInterface::experimental_async_interface { public: #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL void Query(::grpc::ClientContext* context, ::faq::SQLiteQueryString* request, ::grpc::ClientReadReactor< ::faq::SQLiteQueryRow>* reactor) override; #else void Query(::grpc::ClientContext* context, ::faq::SQLiteQueryString* request, ::grpc::experimental::ClientReadReactor< ::faq::SQLiteQueryRow>* reactor) override; #endif private: friend class Stub; explicit experimental_async(Stub* stub): stub_(stub) { } Stub* stub() { return stub_; } Stub* stub_; }; class experimental_async_interface* experimental_async() override { return &async_stub_; } private: std::shared_ptr< ::grpc::ChannelInterface> channel_; class experimental_async async_stub_{this}; ::grpc::ClientReader< ::faq::SQLiteQueryRow>* QueryRaw(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request) override; ::grpc::ClientAsyncReader< ::faq::SQLiteQueryRow>* AsyncQueryRaw(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq, void* tag) override; ::grpc::ClientAsyncReader< ::faq::SQLiteQueryRow>* PrepareAsyncQueryRaw(::grpc::ClientContext* context, const ::faq::SQLiteQueryString& request, ::grpc::CompletionQueue* cq) override; const ::grpc::internal::RpcMethod rpcmethod_Query_; }; static std::unique_ptr NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options = ::grpc::StubOptions()); class FAQ_PROTOS Service : public ::grpc::Service { public: Service(); virtual ~Service(); Service(const Service&) = delete; Service& operator=(const Service&) = delete; virtual ::grpc::Status Query(::grpc::ServerContext* context, const ::faq::SQLiteQueryString* request, ::grpc::ServerWriter< ::faq::SQLiteQueryRow>* writer); }; template class WithAsyncMethod_Query : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithAsyncMethod_Query() { ::grpc::Service::MarkMethodAsync(0); } ~WithAsyncMethod_Query() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status Query(::grpc::ServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/, ::grpc::ServerWriter< ::faq::SQLiteQueryRow>* /*writer*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestQuery(::grpc::ServerContext* context, ::faq::SQLiteQueryString* request, ::grpc::ServerAsyncWriter< ::faq::SQLiteQueryRow>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { ::grpc::Service::RequestAsyncServerStreaming(0, context, request, writer, new_call_cq, notification_cq, tag); } }; typedef WithAsyncMethod_Query AsyncService; template class ExperimentalWithCallbackMethod_Query : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: ExperimentalWithCallbackMethod_Query() { #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL ::grpc::Service:: #else ::grpc::Service::experimental(). #endif MarkMethodCallback(0, new ::grpc::internal::CallbackServerStreamingHandler< ::faq::SQLiteQueryString, ::faq::SQLiteQueryRow>( [this]( #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL ::grpc::CallbackServerContext* #else ::grpc::experimental::CallbackServerContext* #endif context, const ::faq::SQLiteQueryString* request) { return this->Query(context, request); })); } ~ExperimentalWithCallbackMethod_Query() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status Query(::grpc::ServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/, ::grpc::ServerWriter< ::faq::SQLiteQueryRow>* /*writer*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL virtual ::grpc::ServerWriteReactor< ::faq::SQLiteQueryRow>* Query( ::grpc::CallbackServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/) #else virtual ::grpc::experimental::ServerWriteReactor< ::faq::SQLiteQueryRow>* Query( ::grpc::experimental::CallbackServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/) #endif { return nullptr; } }; #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL typedef ExperimentalWithCallbackMethod_Query CallbackService; #endif typedef ExperimentalWithCallbackMethod_Query ExperimentalCallbackService; template class WithGenericMethod_Query : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithGenericMethod_Query() { ::grpc::Service::MarkMethodGeneric(0); } ~WithGenericMethod_Query() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status Query(::grpc::ServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/, ::grpc::ServerWriter< ::faq::SQLiteQueryRow>* /*writer*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } }; template class WithRawMethod_Query : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithRawMethod_Query() { ::grpc::Service::MarkMethodRaw(0); } ~WithRawMethod_Query() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status Query(::grpc::ServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/, ::grpc::ServerWriter< ::faq::SQLiteQueryRow>* /*writer*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } void RequestQuery(::grpc::ServerContext* context, ::grpc::ByteBuffer* request, ::grpc::ServerAsyncWriter< ::grpc::ByteBuffer>* writer, ::grpc::CompletionQueue* new_call_cq, ::grpc::ServerCompletionQueue* notification_cq, void *tag) { ::grpc::Service::RequestAsyncServerStreaming(0, context, request, writer, new_call_cq, notification_cq, tag); } }; template class ExperimentalWithRawCallbackMethod_Query : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: ExperimentalWithRawCallbackMethod_Query() { #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL ::grpc::Service:: #else ::grpc::Service::experimental(). #endif MarkMethodRawCallback(0, new ::grpc::internal::CallbackServerStreamingHandler< ::grpc::ByteBuffer, ::grpc::ByteBuffer>( [this]( #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL ::grpc::CallbackServerContext* #else ::grpc::experimental::CallbackServerContext* #endif context, const::grpc::ByteBuffer* request) { return this->Query(context, request); })); } ~ExperimentalWithRawCallbackMethod_Query() override { BaseClassMustBeDerivedFromService(this); } // disable synchronous version of this method ::grpc::Status Query(::grpc::ServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/, ::grpc::ServerWriter< ::faq::SQLiteQueryRow>* /*writer*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } #ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL virtual ::grpc::ServerWriteReactor< ::grpc::ByteBuffer>* Query( ::grpc::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/) #else virtual ::grpc::experimental::ServerWriteReactor< ::grpc::ByteBuffer>* Query( ::grpc::experimental::CallbackServerContext* /*context*/, const ::grpc::ByteBuffer* /*request*/) #endif { return nullptr; } }; typedef Service StreamedUnaryService; template class WithSplitStreamingMethod_Query : public BaseClass { private: void BaseClassMustBeDerivedFromService(const Service* /*service*/) {} public: WithSplitStreamingMethod_Query() { ::grpc::Service::MarkMethodStreamed(0, new ::grpc::internal::SplitServerStreamingHandler< ::faq::SQLiteQueryString, ::faq::SQLiteQueryRow>( [this](::grpc::ServerContext* context, ::grpc::ServerSplitStreamer< ::faq::SQLiteQueryString, ::faq::SQLiteQueryRow>* streamer) { return this->StreamedQuery(context, streamer); })); } ~WithSplitStreamingMethod_Query() override { BaseClassMustBeDerivedFromService(this); } // disable regular version of this method ::grpc::Status Query(::grpc::ServerContext* /*context*/, const ::faq::SQLiteQueryString* /*request*/, ::grpc::ServerWriter< ::faq::SQLiteQueryRow>* /*writer*/) override { abort(); return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } // replace default version of method with split streamed virtual ::grpc::Status StreamedQuery(::grpc::ServerContext* context, ::grpc::ServerSplitStreamer< ::faq::SQLiteQueryString,::faq::SQLiteQueryRow>* server_split_streamer) = 0; }; typedef WithSplitStreamingMethod_Query SplitStreamedService; typedef WithSplitStreamingMethod_Query StreamedService; }; } // namespace faq #endif // GRPC_faq_5fhook_2eproto__INCLUDED