forked from BigfootDev/flatbuffers
239 lines
11 KiB
C++
239 lines
11 KiB
C++
// Generated by the gRPC C++ plugin.
|
|
// FlatBuffers modified generator: native gRPC callback client API enabled when
|
|
// --grpc-callback-api. source: monster_test
|
|
|
|
#include "monster_test_generated.h"
|
|
|
|
#include <grpcpp/impl/codegen/async_stream.h>
|
|
#include <grpcpp/impl/codegen/async_unary_call.h>
|
|
#include <grpcpp/impl/codegen/channel_interface.h>
|
|
#include <grpcpp/impl/codegen/client_unary_call.h>
|
|
#include <grpcpp/impl/codegen/method_handler.h>
|
|
#include <grpcpp/impl/codegen/rpc_service_method.h>
|
|
#include <grpcpp/impl/codegen/service_type.h>
|
|
#include <grpcpp/impl/codegen/sync_stream.h>
|
|
|
|
#include "monster_test.grpc.fb.h"
|
|
namespace MyGame {
|
|
namespace Example {
|
|
|
|
static const char* MonsterStorage_method_names[] = {
|
|
"/MyGame.Example.MonsterStorage/Store",
|
|
"/MyGame.Example.MonsterStorage/Retrieve",
|
|
"/MyGame.Example.MonsterStorage/GetMaxHitPoint",
|
|
"/MyGame.Example.MonsterStorage/GetMinMaxHitPoints",
|
|
};
|
|
|
|
std::unique_ptr<MonsterStorage::Stub> MonsterStorage::NewStub(
|
|
const std::shared_ptr<::grpc::ChannelInterface>& channel,
|
|
const ::grpc::StubOptions& /*options*/) {
|
|
std::unique_ptr<MonsterStorage::Stub> stub(new MonsterStorage::Stub(channel));
|
|
return stub;
|
|
}
|
|
|
|
MonsterStorage::Stub::Stub(
|
|
const std::shared_ptr<::grpc::ChannelInterface>& channel)
|
|
: channel_(channel),
|
|
rpcmethod_Store_(MonsterStorage_method_names[0],
|
|
::grpc::internal::RpcMethod::NORMAL_RPC, channel),
|
|
rpcmethod_Retrieve_(MonsterStorage_method_names[1],
|
|
::grpc::internal::RpcMethod::SERVER_STREAMING,
|
|
channel),
|
|
rpcmethod_GetMaxHitPoint_(MonsterStorage_method_names[2],
|
|
::grpc::internal::RpcMethod::CLIENT_STREAMING,
|
|
channel),
|
|
rpcmethod_GetMinMaxHitPoints_(MonsterStorage_method_names[3],
|
|
::grpc::internal::RpcMethod::BIDI_STREAMING,
|
|
channel) {}
|
|
|
|
::grpc::Status MonsterStorage::Stub::Store(
|
|
::grpc::ClientContext* context,
|
|
const flatbuffers::grpc::Message<Monster>& request,
|
|
flatbuffers::grpc::Message<Stat>* response) {
|
|
return ::grpc::internal::BlockingUnaryCall(channel_.get(), rpcmethod_Store_,
|
|
context, request, response);
|
|
}
|
|
|
|
::grpc::ClientAsyncResponseReader<flatbuffers::grpc::Message<Stat>>*
|
|
MonsterStorage::Stub::AsyncStoreRaw(
|
|
::grpc::ClientContext* context,
|
|
const flatbuffers::grpc::Message<Monster>& request,
|
|
::grpc::CompletionQueue* cq) {
|
|
return ::grpc::internal::ClientAsyncResponseReaderFactory<
|
|
flatbuffers::grpc::Message<Stat>>::Create(channel_.get(), cq,
|
|
rpcmethod_Store_, context,
|
|
request, true);
|
|
}
|
|
|
|
::grpc::ClientAsyncResponseReader<flatbuffers::grpc::Message<Stat>>*
|
|
MonsterStorage::Stub::PrepareAsyncStoreRaw(
|
|
::grpc::ClientContext* context,
|
|
const flatbuffers::grpc::Message<Monster>& request,
|
|
::grpc::CompletionQueue* cq) {
|
|
return ::grpc::internal::ClientAsyncResponseReaderFactory<
|
|
flatbuffers::grpc::Message<Stat>>::Create(channel_.get(), cq,
|
|
rpcmethod_Store_, context,
|
|
request, false);
|
|
}
|
|
|
|
::grpc::ClientReader<flatbuffers::grpc::Message<Monster>>*
|
|
MonsterStorage::Stub::RetrieveRaw(
|
|
::grpc::ClientContext* context,
|
|
const flatbuffers::grpc::Message<Stat>& request) {
|
|
return ::grpc::internal::ClientReaderFactory<
|
|
flatbuffers::grpc::Message<Monster>>::Create(channel_.get(),
|
|
rpcmethod_Retrieve_, context,
|
|
request);
|
|
}
|
|
|
|
::grpc::ClientAsyncReader<flatbuffers::grpc::Message<Monster>>*
|
|
MonsterStorage::Stub::AsyncRetrieveRaw(
|
|
::grpc::ClientContext* context,
|
|
const flatbuffers::grpc::Message<Stat>& request,
|
|
::grpc::CompletionQueue* cq, void* tag) {
|
|
return ::grpc::internal::ClientAsyncReaderFactory<
|
|
flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq,
|
|
rpcmethod_Retrieve_, context,
|
|
request, true, tag);
|
|
}
|
|
|
|
::grpc::ClientAsyncReader<flatbuffers::grpc::Message<Monster>>*
|
|
MonsterStorage::Stub::PrepareAsyncRetrieveRaw(
|
|
::grpc::ClientContext* context,
|
|
const flatbuffers::grpc::Message<Stat>& request,
|
|
::grpc::CompletionQueue* cq) {
|
|
return ::grpc::internal::ClientAsyncReaderFactory<
|
|
flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq,
|
|
rpcmethod_Retrieve_, context,
|
|
request, false, nullptr);
|
|
}
|
|
|
|
::grpc::ClientWriter<flatbuffers::grpc::Message<Monster>>*
|
|
MonsterStorage::Stub::GetMaxHitPointRaw(
|
|
::grpc::ClientContext* context,
|
|
flatbuffers::grpc::Message<Stat>* response) {
|
|
return ::grpc::internal::ClientWriterFactory<
|
|
flatbuffers::grpc::Message<Monster>>::Create(channel_.get(),
|
|
rpcmethod_GetMaxHitPoint_,
|
|
context, response);
|
|
}
|
|
|
|
::grpc::ClientAsyncWriter<flatbuffers::grpc::Message<Monster>>*
|
|
MonsterStorage::Stub::AsyncGetMaxHitPointRaw(
|
|
::grpc::ClientContext* context, flatbuffers::grpc::Message<Stat>* response,
|
|
::grpc::CompletionQueue* cq, void* tag) {
|
|
return ::grpc::internal::ClientAsyncWriterFactory<
|
|
flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq,
|
|
rpcmethod_GetMaxHitPoint_,
|
|
context, response, true,
|
|
tag);
|
|
}
|
|
|
|
::grpc::ClientAsyncWriter<flatbuffers::grpc::Message<Monster>>*
|
|
MonsterStorage::Stub::PrepareAsyncGetMaxHitPointRaw(
|
|
::grpc::ClientContext* context, flatbuffers::grpc::Message<Stat>* response,
|
|
::grpc::CompletionQueue* cq) {
|
|
return ::grpc::internal::ClientAsyncWriterFactory<
|
|
flatbuffers::grpc::Message<Monster>>::Create(channel_.get(), cq,
|
|
rpcmethod_GetMaxHitPoint_,
|
|
context, response, false,
|
|
nullptr);
|
|
}
|
|
|
|
::grpc::ClientReaderWriter<flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>*
|
|
MonsterStorage::Stub::GetMinMaxHitPointsRaw(::grpc::ClientContext* context) {
|
|
return ::grpc::internal::ClientReaderWriterFactory<
|
|
flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>::Create(channel_.get(),
|
|
rpcmethod_GetMinMaxHitPoints_,
|
|
context);
|
|
}
|
|
|
|
::grpc::ClientAsyncReaderWriter<flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>*
|
|
MonsterStorage::Stub::AsyncGetMinMaxHitPointsRaw(::grpc::ClientContext* context,
|
|
::grpc::CompletionQueue* cq,
|
|
void* tag) {
|
|
return ::grpc::internal::ClientAsyncReaderWriterFactory<
|
|
flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>::Create(channel_.get(), cq,
|
|
rpcmethod_GetMinMaxHitPoints_,
|
|
context, true, tag);
|
|
}
|
|
|
|
::grpc::ClientAsyncReaderWriter<flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>*
|
|
MonsterStorage::Stub::PrepareAsyncGetMinMaxHitPointsRaw(
|
|
::grpc::ClientContext* context, ::grpc::CompletionQueue* cq) {
|
|
return ::grpc::internal::ClientAsyncReaderWriterFactory<
|
|
flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>::Create(channel_.get(), cq,
|
|
rpcmethod_GetMinMaxHitPoints_,
|
|
context, false, nullptr);
|
|
}
|
|
|
|
MonsterStorage::Service::Service() {
|
|
AddMethod(new ::grpc::internal::RpcServiceMethod(
|
|
MonsterStorage_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC,
|
|
new ::grpc::internal::RpcMethodHandler<
|
|
MonsterStorage::Service, flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>(
|
|
std::mem_fn(&MonsterStorage::Service::Store), this)));
|
|
AddMethod(new ::grpc::internal::RpcServiceMethod(
|
|
MonsterStorage_method_names[1],
|
|
::grpc::internal::RpcMethod::SERVER_STREAMING,
|
|
new ::grpc::internal::ServerStreamingHandler<
|
|
MonsterStorage::Service, flatbuffers::grpc::Message<Stat>,
|
|
flatbuffers::grpc::Message<Monster>>(
|
|
std::mem_fn(&MonsterStorage::Service::Retrieve), this)));
|
|
AddMethod(new ::grpc::internal::RpcServiceMethod(
|
|
MonsterStorage_method_names[2],
|
|
::grpc::internal::RpcMethod::CLIENT_STREAMING,
|
|
new ::grpc::internal::ClientStreamingHandler<
|
|
MonsterStorage::Service, flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>(
|
|
std::mem_fn(&MonsterStorage::Service::GetMaxHitPoint), this)));
|
|
AddMethod(new ::grpc::internal::RpcServiceMethod(
|
|
MonsterStorage_method_names[3],
|
|
::grpc::internal::RpcMethod::BIDI_STREAMING,
|
|
new ::grpc::internal::BidiStreamingHandler<
|
|
MonsterStorage::Service, flatbuffers::grpc::Message<Monster>,
|
|
flatbuffers::grpc::Message<Stat>>(
|
|
std::mem_fn(&MonsterStorage::Service::GetMinMaxHitPoints), this)));
|
|
}
|
|
|
|
MonsterStorage::Service::~Service() {}
|
|
|
|
::grpc::Status MonsterStorage::Service::Store(
|
|
::grpc::ServerContext* /*context*/,
|
|
const flatbuffers::grpc::Message<Monster>* /*request*/,
|
|
flatbuffers::grpc::Message<Stat>* /*response*/) {
|
|
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
|
|
}
|
|
|
|
::grpc::Status MonsterStorage::Service::Retrieve(
|
|
::grpc::ServerContext* /*context*/,
|
|
const flatbuffers::grpc::Message<Stat>* /*request*/,
|
|
::grpc::ServerWriter<flatbuffers::grpc::Message<Monster>>* /*writer*/) {
|
|
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
|
|
}
|
|
|
|
::grpc::Status MonsterStorage::Service::GetMaxHitPoint(
|
|
::grpc::ServerContext* /*context*/,
|
|
::grpc::ServerReader<flatbuffers::grpc::Message<Monster>>* /*reader*/,
|
|
flatbuffers::grpc::Message<Stat>* /*response*/) {
|
|
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
|
|
}
|
|
|
|
::grpc::Status MonsterStorage::Service::GetMinMaxHitPoints(
|
|
::grpc::ServerContext* /*context*/,
|
|
::grpc::ServerReaderWriter<
|
|
flatbuffers::grpc::Message<Stat>,
|
|
flatbuffers::grpc::Message<Monster>>* /*stream*/) {
|
|
return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, "");
|
|
}
|
|
|
|
} // namespace Example
|
|
} // namespace MyGame
|