/
smychkov
/
SStorage
Обзор
Документация
Войти
/
smychkov
/
SStorage
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
CI/CD
Аналитика
Безопасность
master
src/server/storage.grpc.pb.cc
332 строки
21 KB
Андрей Смычков
feat: HTTP + gRPC servers with new key-value API
25 апр 2026, 09:21
25 апр 2026, 09:21
1c6add8
Код
Авторство
О чём код?
// Generated by the gRPC C++ plugin. // If you make any local change, they will be lost. // source: storage.proto #include "storage.pb.h" #include "storage.grpc.pb.h" #include <functional> #include <grpcpp/support/async_stream.h> #include <grpcpp/support/async_unary_call.h> #include <grpcpp/impl/channel_interface.h> #include <grpcpp/impl/client_unary_call.h> #include <grpcpp/support/client_callback.h> #include <grpcpp/support/message_allocator.h> #include <grpcpp/support/method_handler.h> #include <grpcpp/impl/rpc_service_method.h> #include <grpcpp/support/server_callback.h> #include <grpcpp/impl/server_callback_handlers.h> #include <grpcpp/server_context.h> #include <grpcpp/impl/service_type.h> #include <grpcpp/support/sync_stream.h> #include <grpcpp/ports_def.inc> namespace sstorage { static const char* Storage_method_names[] = { "/sstorage.Storage/Put", "/sstorage.Storage/Get", "/sstorage.Storage/Delete", "/sstorage.Storage/Scan", "/sstorage.Storage/Stats", "/sstorage.Storage/Flush", "/sstorage.Storage/Compact", }; std::unique_ptr< Storage::Stub> Storage::NewStub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) { (void)options; std::unique_ptr< Storage::Stub> stub(new Storage::Stub(channel, options)); return stub; } Storage::Stub::Stub(const std::shared_ptr< ::grpc::ChannelInterface>& channel, const ::grpc::StubOptions& options) : channel_(channel), rpcmethod_Put_(Storage_method_names[0], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) , rpcmethod_Get_(Storage_method_names[1], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) , rpcmethod_Delete_(Storage_method_names[2], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) , rpcmethod_Scan_(Storage_method_names[3], options.suffix_for_stats(),::grpc::internal::RpcMethod::SERVER_STREAMING, channel) , rpcmethod_Stats_(Storage_method_names[4], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) , rpcmethod_Flush_(Storage_method_names[5], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) , rpcmethod_Compact_(Storage_method_names[6], options.suffix_for_stats(),::grpc::internal::RpcMethod::NORMAL_RPC, channel) {} ::grpc::Status Storage::Stub::Put(::grpc::ClientContext* context, const ::sstorage::PutRequest& request, ::sstorage::PutResponse* response) { return ::grpc::internal::BlockingUnaryCall< ::sstorage::PutRequest, ::sstorage::PutResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Put_, context, request, response); } void Storage::Stub::async::Put(::grpc::ClientContext* context, const ::sstorage::PutRequest* request, ::sstorage::PutResponse* response, std::function<void(::grpc::Status)> f) { ::grpc::internal::CallbackUnaryCall< ::sstorage::PutRequest, ::sstorage::PutResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Put_, context, request, response, std::move(f)); } void Storage::Stub::async::Put(::grpc::ClientContext* context, const ::sstorage::PutRequest* request, ::sstorage::PutResponse* response, ::grpc::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Put_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::sstorage::PutResponse>* Storage::Stub::PrepareAsyncPutRaw(::grpc::ClientContext* context, const ::sstorage::PutRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::sstorage::PutResponse, ::sstorage::PutRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Put_, context, request); } ::grpc::ClientAsyncResponseReader< ::sstorage::PutResponse>* Storage::Stub::AsyncPutRaw(::grpc::ClientContext* context, const ::sstorage::PutRequest& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncPutRaw(context, request, cq); result->StartCall(); return result; } ::grpc::Status Storage::Stub::Get(::grpc::ClientContext* context, const ::sstorage::GetRequest& request, ::sstorage::GetResponse* response) { return ::grpc::internal::BlockingUnaryCall< ::sstorage::GetRequest, ::sstorage::GetResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Get_, context, request, response); } void Storage::Stub::async::Get(::grpc::ClientContext* context, const ::sstorage::GetRequest* request, ::sstorage::GetResponse* response, std::function<void(::grpc::Status)> f) { ::grpc::internal::CallbackUnaryCall< ::sstorage::GetRequest, ::sstorage::GetResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Get_, context, request, response, std::move(f)); } void Storage::Stub::async::Get(::grpc::ClientContext* context, const ::sstorage::GetRequest* request, ::sstorage::GetResponse* response, ::grpc::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Get_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::sstorage::GetResponse>* Storage::Stub::PrepareAsyncGetRaw(::grpc::ClientContext* context, const ::sstorage::GetRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::sstorage::GetResponse, ::sstorage::GetRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Get_, context, request); } ::grpc::ClientAsyncResponseReader< ::sstorage::GetResponse>* Storage::Stub::AsyncGetRaw(::grpc::ClientContext* context, const ::sstorage::GetRequest& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncGetRaw(context, request, cq); result->StartCall(); return result; } ::grpc::Status Storage::Stub::Delete(::grpc::ClientContext* context, const ::sstorage::DeleteRequest& request, ::sstorage::DeleteResponse* response) { return ::grpc::internal::BlockingUnaryCall< ::sstorage::DeleteRequest, ::sstorage::DeleteResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Delete_, context, request, response); } void Storage::Stub::async::Delete(::grpc::ClientContext* context, const ::sstorage::DeleteRequest* request, ::sstorage::DeleteResponse* response, std::function<void(::grpc::Status)> f) { ::grpc::internal::CallbackUnaryCall< ::sstorage::DeleteRequest, ::sstorage::DeleteResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Delete_, context, request, response, std::move(f)); } void Storage::Stub::async::Delete(::grpc::ClientContext* context, const ::sstorage::DeleteRequest* request, ::sstorage::DeleteResponse* response, ::grpc::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Delete_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::sstorage::DeleteResponse>* Storage::Stub::PrepareAsyncDeleteRaw(::grpc::ClientContext* context, const ::sstorage::DeleteRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::sstorage::DeleteResponse, ::sstorage::DeleteRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Delete_, context, request); } ::grpc::ClientAsyncResponseReader< ::sstorage::DeleteResponse>* Storage::Stub::AsyncDeleteRaw(::grpc::ClientContext* context, const ::sstorage::DeleteRequest& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncDeleteRaw(context, request, cq); result->StartCall(); return result; } ::grpc::ClientReader< ::sstorage::ScanResponse>* Storage::Stub::ScanRaw(::grpc::ClientContext* context, const ::sstorage::ScanRequest& request) { return ::grpc::internal::ClientReaderFactory< ::sstorage::ScanResponse>::Create(channel_.get(), rpcmethod_Scan_, context, request); } void Storage::Stub::async::Scan(::grpc::ClientContext* context, const ::sstorage::ScanRequest* request, ::grpc::ClientReadReactor< ::sstorage::ScanResponse>* reactor) { ::grpc::internal::ClientCallbackReaderFactory< ::sstorage::ScanResponse>::Create(stub_->channel_.get(), stub_->rpcmethod_Scan_, context, request, reactor); } ::grpc::ClientAsyncReader< ::sstorage::ScanResponse>* Storage::Stub::AsyncScanRaw(::grpc::ClientContext* context, const ::sstorage::ScanRequest& request, ::grpc::CompletionQueue* cq, void* tag) { return ::grpc::internal::ClientAsyncReaderFactory< ::sstorage::ScanResponse>::Create(channel_.get(), cq, rpcmethod_Scan_, context, request, true, tag); } ::grpc::ClientAsyncReader< ::sstorage::ScanResponse>* Storage::Stub::PrepareAsyncScanRaw(::grpc::ClientContext* context, const ::sstorage::ScanRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncReaderFactory< ::sstorage::ScanResponse>::Create(channel_.get(), cq, rpcmethod_Scan_, context, request, false, nullptr); } ::grpc::Status Storage::Stub::Stats(::grpc::ClientContext* context, const ::sstorage::StatsRequest& request, ::sstorage::StatsResponse* response) { return ::grpc::internal::BlockingUnaryCall< ::sstorage::StatsRequest, ::sstorage::StatsResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Stats_, context, request, response); } void Storage::Stub::async::Stats(::grpc::ClientContext* context, const ::sstorage::StatsRequest* request, ::sstorage::StatsResponse* response, std::function<void(::grpc::Status)> f) { ::grpc::internal::CallbackUnaryCall< ::sstorage::StatsRequest, ::sstorage::StatsResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Stats_, context, request, response, std::move(f)); } void Storage::Stub::async::Stats(::grpc::ClientContext* context, const ::sstorage::StatsRequest* request, ::sstorage::StatsResponse* response, ::grpc::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Stats_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::sstorage::StatsResponse>* Storage::Stub::PrepareAsyncStatsRaw(::grpc::ClientContext* context, const ::sstorage::StatsRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::sstorage::StatsResponse, ::sstorage::StatsRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Stats_, context, request); } ::grpc::ClientAsyncResponseReader< ::sstorage::StatsResponse>* Storage::Stub::AsyncStatsRaw(::grpc::ClientContext* context, const ::sstorage::StatsRequest& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncStatsRaw(context, request, cq); result->StartCall(); return result; } ::grpc::Status Storage::Stub::Flush(::grpc::ClientContext* context, const ::sstorage::FlushRequest& request, ::sstorage::FlushResponse* response) { return ::grpc::internal::BlockingUnaryCall< ::sstorage::FlushRequest, ::sstorage::FlushResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Flush_, context, request, response); } void Storage::Stub::async::Flush(::grpc::ClientContext* context, const ::sstorage::FlushRequest* request, ::sstorage::FlushResponse* response, std::function<void(::grpc::Status)> f) { ::grpc::internal::CallbackUnaryCall< ::sstorage::FlushRequest, ::sstorage::FlushResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Flush_, context, request, response, std::move(f)); } void Storage::Stub::async::Flush(::grpc::ClientContext* context, const ::sstorage::FlushRequest* request, ::sstorage::FlushResponse* response, ::grpc::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Flush_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::sstorage::FlushResponse>* Storage::Stub::PrepareAsyncFlushRaw(::grpc::ClientContext* context, const ::sstorage::FlushRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::sstorage::FlushResponse, ::sstorage::FlushRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Flush_, context, request); } ::grpc::ClientAsyncResponseReader< ::sstorage::FlushResponse>* Storage::Stub::AsyncFlushRaw(::grpc::ClientContext* context, const ::sstorage::FlushRequest& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncFlushRaw(context, request, cq); result->StartCall(); return result; } ::grpc::Status Storage::Stub::Compact(::grpc::ClientContext* context, const ::sstorage::CompactRequest& request, ::sstorage::CompactResponse* response) { return ::grpc::internal::BlockingUnaryCall< ::sstorage::CompactRequest, ::sstorage::CompactResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), rpcmethod_Compact_, context, request, response); } void Storage::Stub::async::Compact(::grpc::ClientContext* context, const ::sstorage::CompactRequest* request, ::sstorage::CompactResponse* response, std::function<void(::grpc::Status)> f) { ::grpc::internal::CallbackUnaryCall< ::sstorage::CompactRequest, ::sstorage::CompactResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Compact_, context, request, response, std::move(f)); } void Storage::Stub::async::Compact(::grpc::ClientContext* context, const ::sstorage::CompactRequest* request, ::sstorage::CompactResponse* response, ::grpc::ClientUnaryReactor* reactor) { ::grpc::internal::ClientCallbackUnaryFactory::Create< ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(stub_->channel_.get(), stub_->rpcmethod_Compact_, context, request, response, reactor); } ::grpc::ClientAsyncResponseReader< ::sstorage::CompactResponse>* Storage::Stub::PrepareAsyncCompactRaw(::grpc::ClientContext* context, const ::sstorage::CompactRequest& request, ::grpc::CompletionQueue* cq) { return ::grpc::internal::ClientAsyncResponseReaderHelper::Create< ::sstorage::CompactResponse, ::sstorage::CompactRequest, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>(channel_.get(), cq, rpcmethod_Compact_, context, request); } ::grpc::ClientAsyncResponseReader< ::sstorage::CompactResponse>* Storage::Stub::AsyncCompactRaw(::grpc::ClientContext* context, const ::sstorage::CompactRequest& request, ::grpc::CompletionQueue* cq) { auto* result = this->PrepareAsyncCompactRaw(context, request, cq); result->StartCall(); return result; } Storage::Service::Service() { AddMethod(new ::grpc::internal::RpcServiceMethod( Storage_method_names[0], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Storage::Service, ::sstorage::PutRequest, ::sstorage::PutResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Storage::Service* service, ::grpc::ServerContext* ctx, const ::sstorage::PutRequest* req, ::sstorage::PutResponse* resp) { return service->Put(ctx, req, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Storage_method_names[1], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Storage::Service, ::sstorage::GetRequest, ::sstorage::GetResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Storage::Service* service, ::grpc::ServerContext* ctx, const ::sstorage::GetRequest* req, ::sstorage::GetResponse* resp) { return service->Get(ctx, req, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Storage_method_names[2], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Storage::Service, ::sstorage::DeleteRequest, ::sstorage::DeleteResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Storage::Service* service, ::grpc::ServerContext* ctx, const ::sstorage::DeleteRequest* req, ::sstorage::DeleteResponse* resp) { return service->Delete(ctx, req, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Storage_method_names[3], ::grpc::internal::RpcMethod::SERVER_STREAMING, new ::grpc::internal::ServerStreamingHandler< Storage::Service, ::sstorage::ScanRequest, ::sstorage::ScanResponse>( [](Storage::Service* service, ::grpc::ServerContext* ctx, const ::sstorage::ScanRequest* req, ::grpc::ServerWriter<::sstorage::ScanResponse>* writer) { return service->Scan(ctx, req, writer); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Storage_method_names[4], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Storage::Service, ::sstorage::StatsRequest, ::sstorage::StatsResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Storage::Service* service, ::grpc::ServerContext* ctx, const ::sstorage::StatsRequest* req, ::sstorage::StatsResponse* resp) { return service->Stats(ctx, req, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Storage_method_names[5], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Storage::Service, ::sstorage::FlushRequest, ::sstorage::FlushResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Storage::Service* service, ::grpc::ServerContext* ctx, const ::sstorage::FlushRequest* req, ::sstorage::FlushResponse* resp) { return service->Flush(ctx, req, resp); }, this))); AddMethod(new ::grpc::internal::RpcServiceMethod( Storage_method_names[6], ::grpc::internal::RpcMethod::NORMAL_RPC, new ::grpc::internal::RpcMethodHandler< Storage::Service, ::sstorage::CompactRequest, ::sstorage::CompactResponse, ::grpc::protobuf::MessageLite, ::grpc::protobuf::MessageLite>( [](Storage::Service* service, ::grpc::ServerContext* ctx, const ::sstorage::CompactRequest* req, ::sstorage::CompactResponse* resp) { return service->Compact(ctx, req, resp); }, this))); } Storage::Service::~Service() { } ::grpc::Status Storage::Service::Put(::grpc::ServerContext* context, const ::sstorage::PutRequest* request, ::sstorage::PutResponse* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Storage::Service::Get(::grpc::ServerContext* context, const ::sstorage::GetRequest* request, ::sstorage::GetResponse* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Storage::Service::Delete(::grpc::ServerContext* context, const ::sstorage::DeleteRequest* request, ::sstorage::DeleteResponse* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Storage::Service::Scan(::grpc::ServerContext* context, const ::sstorage::ScanRequest* request, ::grpc::ServerWriter< ::sstorage::ScanResponse>* writer) { (void) context; (void) request; (void) writer; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Storage::Service::Stats(::grpc::ServerContext* context, const ::sstorage::StatsRequest* request, ::sstorage::StatsResponse* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Storage::Service::Flush(::grpc::ServerContext* context, const ::sstorage::FlushRequest* request, ::sstorage::FlushResponse* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } ::grpc::Status Storage::Service::Compact(::grpc::ServerContext* context, const ::sstorage::CompactRequest* request, ::sstorage::CompactResponse* response) { (void) context; (void) request; (void) response; return ::grpc::Status(::grpc::StatusCode::UNIMPLEMENTED, ""); } } // namespace sstorage #include <grpcpp/ports_undef.inc>