This is an automated email from the ASF dual-hosted git repository. yuchenhe pushed a commit to branch v2.1.2 in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
commit da4ee098c8d04298106bc78874161a376da2e261 Author: HeYuchen <[email protected]> AuthorDate: Mon Dec 28 15:14:34 2020 +0800 feat: add query app data_version (#663) --- src/server/pegasus_server_impl.cpp | 2 ++ src/server/pegasus_server_impl.h | 2 ++ 2 files changed, 4 insertions(+) diff --git a/src/server/pegasus_server_impl.cpp b/src/server/pegasus_server_impl.cpp index 456d964..5d410fa 100644 --- a/src/server/pegasus_server_impl.cpp +++ b/src/server/pegasus_server_impl.cpp @@ -2817,5 +2817,7 @@ void pegasus_server_impl::set_ingestion_status(dsn::replication::ingestion_statu _ingestion_status = status; } +uint32_t pegasus_server_impl::query_data_version() const { return _pegasus_data_version; } + } // namespace server } // namespace pegasus diff --git a/src/server/pegasus_server_impl.h b/src/server/pegasus_server_impl.h index 032e8f8..9edff46 100644 --- a/src/server/pegasus_server_impl.h +++ b/src/server/pegasus_server_impl.h @@ -333,6 +333,8 @@ private: ::dsn::error_code flush_all_family_columns(bool wait); + uint32_t query_data_version() const override; + private: static const std::chrono::seconds kServerStatUpdateTimeSec; static const std::string COMPRESSION_HEADER; --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
