Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

update thrift files #69

Merged
merged 1 commit into from
Nov 19, 2021
Merged

update thrift files #69

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
50 changes: 0 additions & 50 deletions src/interface/gen-cpp2/MetaService.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -981,48 +981,6 @@ void MetaServiceSvIf::async_tm_heartBeat(std::unique_ptr<apache::thrift::Handler
});
}

void MetaServiceSvIf::balance( ::nebula::meta::cpp2::BalanceResp& /*_return*/, const ::nebula::meta::cpp2::BalanceReq& /*req*/) {
apache::thrift::detail::si::throw_app_exn_unimplemented("balance");
}

folly::SemiFuture< ::nebula::meta::cpp2::BalanceResp> MetaServiceSvIf::semifuture_balance(const ::nebula::meta::cpp2::BalanceReq& p_req) {
return apache::thrift::detail::si::semifuture_returning([&]( ::nebula::meta::cpp2::BalanceResp& _return) { balance(_return, p_req); });
}

folly::Future< ::nebula::meta::cpp2::BalanceResp> MetaServiceSvIf::future_balance(const ::nebula::meta::cpp2::BalanceReq& p_req) {
using Source = apache::thrift::concurrency::ThreadManager::Source;
auto scope = getRequestContext()->getRequestExecutionScope();
auto ka = getThreadManager()->getKeepAlive(std::move(scope), Source::INTERNAL);
return apache::thrift::detail::si::future(semifuture_balance(p_req), std::move(ka));
}

void MetaServiceSvIf::async_tm_balance(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::BalanceResp>> callback, const ::nebula::meta::cpp2::BalanceReq& p_req) {
apache::thrift::detail::si::async_tm(this, std::move(callback), [&] {
return future_balance(p_req);
});
}

void MetaServiceSvIf::leaderBalance( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::LeaderBalanceReq& /*req*/) {
apache::thrift::detail::si::throw_app_exn_unimplemented("leaderBalance");
}

folly::SemiFuture< ::nebula::meta::cpp2::ExecResp> MetaServiceSvIf::semifuture_leaderBalance(const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) {
return apache::thrift::detail::si::semifuture_returning([&]( ::nebula::meta::cpp2::ExecResp& _return) { leaderBalance(_return, p_req); });
}

folly::Future< ::nebula::meta::cpp2::ExecResp> MetaServiceSvIf::future_leaderBalance(const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) {
using Source = apache::thrift::concurrency::ThreadManager::Source;
auto scope = getRequestContext()->getRequestExecutionScope();
auto ka = getThreadManager()->getKeepAlive(std::move(scope), Source::INTERNAL);
return apache::thrift::detail::si::future(semifuture_leaderBalance(p_req), std::move(ka));
}

void MetaServiceSvIf::async_tm_leaderBalance(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::ExecResp>> callback, const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) {
apache::thrift::detail::si::async_tm(this, std::move(callback), [&] {
return future_leaderBalance(p_req);
});
}

void MetaServiceSvIf::regConfig( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::RegConfigReq& /*req*/) {
apache::thrift::detail::si::throw_app_exn_unimplemented("regConfig");
}
Expand Down Expand Up @@ -1997,10 +1955,6 @@ void MetaServiceSvNull::changePassword( ::nebula::meta::cpp2::ExecResp& /*_retur

void MetaServiceSvNull::heartBeat( ::nebula::meta::cpp2::HBResp& /*_return*/, const ::nebula::meta::cpp2::HBReq& /*req*/) {}

void MetaServiceSvNull::balance( ::nebula::meta::cpp2::BalanceResp& /*_return*/, const ::nebula::meta::cpp2::BalanceReq& /*req*/) {}

void MetaServiceSvNull::leaderBalance( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::LeaderBalanceReq& /*req*/) {}

void MetaServiceSvNull::regConfig( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::RegConfigReq& /*req*/) {}

void MetaServiceSvNull::getConfig( ::nebula::meta::cpp2::GetConfigResp& /*_return*/, const ::nebula::meta::cpp2::GetConfigReq& /*req*/) {}
Expand Down Expand Up @@ -2154,8 +2108,6 @@ const MetaServiceAsyncProcessor::ProcessMap MetaServiceAsyncProcessor::binaryPro
{"getUserRoles", &MetaServiceAsyncProcessor::setUpAndProcess_getUserRoles<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
{"changePassword", &MetaServiceAsyncProcessor::setUpAndProcess_changePassword<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
{"heartBeat", &MetaServiceAsyncProcessor::setUpAndProcess_heartBeat<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
{"balance", &MetaServiceAsyncProcessor::setUpAndProcess_balance<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
{"leaderBalance", &MetaServiceAsyncProcessor::setUpAndProcess_leaderBalance<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
{"regConfig", &MetaServiceAsyncProcessor::setUpAndProcess_regConfig<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
{"getConfig", &MetaServiceAsyncProcessor::setUpAndProcess_getConfig<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
{"setConfig", &MetaServiceAsyncProcessor::setUpAndProcess_setConfig<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>},
Expand Down Expand Up @@ -2251,8 +2203,6 @@ const MetaServiceAsyncProcessor::ProcessMap MetaServiceAsyncProcessor::compactPr
{"getUserRoles", &MetaServiceAsyncProcessor::setUpAndProcess_getUserRoles<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
{"changePassword", &MetaServiceAsyncProcessor::setUpAndProcess_changePassword<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
{"heartBeat", &MetaServiceAsyncProcessor::setUpAndProcess_heartBeat<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
{"balance", &MetaServiceAsyncProcessor::setUpAndProcess_balance<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
{"leaderBalance", &MetaServiceAsyncProcessor::setUpAndProcess_leaderBalance<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
{"regConfig", &MetaServiceAsyncProcessor::setUpAndProcess_regConfig<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
{"getConfig", &MetaServiceAsyncProcessor::setUpAndProcess_getConfig<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
{"setConfig", &MetaServiceAsyncProcessor::setUpAndProcess_setConfig<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>},
Expand Down
32 changes: 0 additions & 32 deletions src/interface/gen-cpp2/MetaService.h
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -166,12 +166,6 @@ class MetaServiceSvAsyncIf {
virtual void async_tm_heartBeat(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::HBResp>> callback, const ::nebula::meta::cpp2::HBReq& p_req) = 0;
virtual folly::Future< ::nebula::meta::cpp2::HBResp> future_heartBeat(const ::nebula::meta::cpp2::HBReq& p_req) = 0;
virtual folly::SemiFuture< ::nebula::meta::cpp2::HBResp> semifuture_heartBeat(const ::nebula::meta::cpp2::HBReq& p_req) = 0;
virtual void async_tm_balance(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::BalanceResp>> callback, const ::nebula::meta::cpp2::BalanceReq& p_req) = 0;
virtual folly::Future< ::nebula::meta::cpp2::BalanceResp> future_balance(const ::nebula::meta::cpp2::BalanceReq& p_req) = 0;
virtual folly::SemiFuture< ::nebula::meta::cpp2::BalanceResp> semifuture_balance(const ::nebula::meta::cpp2::BalanceReq& p_req) = 0;
virtual void async_tm_leaderBalance(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::ExecResp>> callback, const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) = 0;
virtual folly::Future< ::nebula::meta::cpp2::ExecResp> future_leaderBalance(const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) = 0;
virtual folly::SemiFuture< ::nebula::meta::cpp2::ExecResp> semifuture_leaderBalance(const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) = 0;
virtual void async_tm_regConfig(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::ExecResp>> callback, const ::nebula::meta::cpp2::RegConfigReq& p_req) = 0;
virtual folly::Future< ::nebula::meta::cpp2::ExecResp> future_regConfig(const ::nebula::meta::cpp2::RegConfigReq& p_req) = 0;
virtual folly::SemiFuture< ::nebula::meta::cpp2::ExecResp> semifuture_regConfig(const ::nebula::meta::cpp2::RegConfigReq& p_req) = 0;
Expand Down Expand Up @@ -492,14 +486,6 @@ class MetaServiceSvIf : public MetaServiceSvAsyncIf, public apache::thrift::Serv
folly::Future< ::nebula::meta::cpp2::HBResp> future_heartBeat(const ::nebula::meta::cpp2::HBReq& p_req) override;
folly::SemiFuture< ::nebula::meta::cpp2::HBResp> semifuture_heartBeat(const ::nebula::meta::cpp2::HBReq& p_req) override;
void async_tm_heartBeat(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::HBResp>> callback, const ::nebula::meta::cpp2::HBReq& p_req) override;
virtual void balance( ::nebula::meta::cpp2::BalanceResp& /*_return*/, const ::nebula::meta::cpp2::BalanceReq& /*req*/);
folly::Future< ::nebula::meta::cpp2::BalanceResp> future_balance(const ::nebula::meta::cpp2::BalanceReq& p_req) override;
folly::SemiFuture< ::nebula::meta::cpp2::BalanceResp> semifuture_balance(const ::nebula::meta::cpp2::BalanceReq& p_req) override;
void async_tm_balance(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::BalanceResp>> callback, const ::nebula::meta::cpp2::BalanceReq& p_req) override;
virtual void leaderBalance( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::LeaderBalanceReq& /*req*/);
folly::Future< ::nebula::meta::cpp2::ExecResp> future_leaderBalance(const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) override;
folly::SemiFuture< ::nebula::meta::cpp2::ExecResp> semifuture_leaderBalance(const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) override;
void async_tm_leaderBalance(std::unique_ptr<apache::thrift::HandlerCallback< ::nebula::meta::cpp2::ExecResp>> callback, const ::nebula::meta::cpp2::LeaderBalanceReq& p_req) override;
virtual void regConfig( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::RegConfigReq& /*req*/);
folly::Future< ::nebula::meta::cpp2::ExecResp> future_regConfig(const ::nebula::meta::cpp2::RegConfigReq& p_req) override;
folly::SemiFuture< ::nebula::meta::cpp2::ExecResp> semifuture_regConfig(const ::nebula::meta::cpp2::RegConfigReq& p_req) override;
Expand Down Expand Up @@ -718,8 +704,6 @@ class MetaServiceSvNull : public MetaServiceSvIf {
void getUserRoles( ::nebula::meta::cpp2::ListRolesResp& /*_return*/, const ::nebula::meta::cpp2::GetUserRolesReq& /*req*/) override;
void changePassword( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::ChangePasswordReq& /*req*/) override;
void heartBeat( ::nebula::meta::cpp2::HBResp& /*_return*/, const ::nebula::meta::cpp2::HBReq& /*req*/) override;
void balance( ::nebula::meta::cpp2::BalanceResp& /*_return*/, const ::nebula::meta::cpp2::BalanceReq& /*req*/) override;
void leaderBalance( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::LeaderBalanceReq& /*req*/) override;
void regConfig( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::RegConfigReq& /*req*/) override;
void getConfig( ::nebula::meta::cpp2::GetConfigResp& /*_return*/, const ::nebula::meta::cpp2::GetConfigReq& /*req*/) override;
void setConfig( ::nebula::meta::cpp2::ExecResp& /*_return*/, const ::nebula::meta::cpp2::SetConfigReq& /*req*/) override;
Expand Down Expand Up @@ -1153,22 +1137,6 @@ class MetaServiceAsyncProcessor : public ::apache::thrift::GeneratedAsyncProcess
template <class ProtocolIn_, class ProtocolOut_>
static void throw_wrapped_heartBeat(apache::thrift::ResponseChannelRequest::UniquePtr req,int32_t protoSeqId,apache::thrift::ContextStack* ctx,folly::exception_wrapper ew,apache::thrift::Cpp2RequestContext* reqCtx);
template <typename ProtocolIn_, typename ProtocolOut_>
void setUpAndProcess_balance(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedRequest&& serializedRequest, apache::thrift::Cpp2RequestContext* ctx, folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm);
template <typename ProtocolIn_, typename ProtocolOut_>
void process_balance(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedRequest&& serializedRequest, apache::thrift::Cpp2RequestContext* ctx,folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm);
template <class ProtocolIn_, class ProtocolOut_>
static folly::IOBufQueue return_balance(int32_t protoSeqId, apache::thrift::ContextStack* ctx, ::nebula::meta::cpp2::BalanceResp const& _return);
template <class ProtocolIn_, class ProtocolOut_>
static void throw_wrapped_balance(apache::thrift::ResponseChannelRequest::UniquePtr req,int32_t protoSeqId,apache::thrift::ContextStack* ctx,folly::exception_wrapper ew,apache::thrift::Cpp2RequestContext* reqCtx);
template <typename ProtocolIn_, typename ProtocolOut_>
void setUpAndProcess_leaderBalance(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedRequest&& serializedRequest, apache::thrift::Cpp2RequestContext* ctx, folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm);
template <typename ProtocolIn_, typename ProtocolOut_>
void process_leaderBalance(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedRequest&& serializedRequest, apache::thrift::Cpp2RequestContext* ctx,folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm);
template <class ProtocolIn_, class ProtocolOut_>
static folly::IOBufQueue return_leaderBalance(int32_t protoSeqId, apache::thrift::ContextStack* ctx, ::nebula::meta::cpp2::ExecResp const& _return);
template <class ProtocolIn_, class ProtocolOut_>
static void throw_wrapped_leaderBalance(apache::thrift::ResponseChannelRequest::UniquePtr req,int32_t protoSeqId,apache::thrift::ContextStack* ctx,folly::exception_wrapper ew,apache::thrift::Cpp2RequestContext* reqCtx);
template <typename ProtocolIn_, typename ProtocolOut_>
void setUpAndProcess_regConfig(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedRequest&& serializedRequest, apache::thrift::Cpp2RequestContext* ctx, folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm);
template <typename ProtocolIn_, typename ProtocolOut_>
void process_regConfig(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedRequest&& serializedRequest, apache::thrift::Cpp2RequestContext* ctx,folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm);
Expand Down
Loading