diff --git a/src/graph/executor/admin/ShowTSClientsExecutor.cpp b/src/graph/executor/admin/ShowTSClientsExecutor.cpp deleted file mode 100644 index f5981a6c1f3..00000000000 --- a/src/graph/executor/admin/ShowTSClientsExecutor.cpp +++ /dev/null @@ -1,41 +0,0 @@ -/* Copyright (c) 2020 vesoft inc. All rights reserved. - * - * This source code is licensed under Apache 2.0 License. - */ - -#include "graph/executor/admin/ShowTSClientsExecutor.h" - -#include "graph/context/QueryContext.h" -#include "graph/planner/plan/Admin.h" -#include "graph/service/PermissionManager.h" -#include "interface/gen-cpp2/meta_types.h" - -namespace nebula { -namespace graph { - -folly::Future ShowTSClientsExecutor::execute() { - SCOPED_TIMER(&execTime_); - return showTSClients(); -} - -folly::Future ShowTSClientsExecutor::showTSClients() { - return qctx()->getMetaClient()->listFTClients().via(runner()).thenValue([this](auto &&resp) { - if (!resp.ok()) { - LOG(ERROR) << resp.status(); - return resp.status(); - } - auto value = std::move(resp).value(); - DataSet v({"Host", "Port", "Connection type"}); - for (const auto &client : value) { - nebula::Row r; - r.values.emplace_back(client.host.host); - r.values.emplace_back(client.host.port); - r.values.emplace_back(client.conn_type_ref().has_value() ? *client.get_conn_type() : "http"); - v.emplace_back(std::move(r)); - } - return finish(std::move(v)); - }); -} - -} // namespace graph -} // namespace nebula diff --git a/src/storage/InternalStorageServiceHandler.h b/src/storage/InternalStorageServiceHandler.h index 8f32bf7b937..63ed9105129 100644 --- a/src/storage/InternalStorageServiceHandler.h +++ b/src/storage/InternalStorageServiceHandler.h @@ -31,7 +31,7 @@ class InternalStorageServiceHandler final : public cpp2::InternalStorageServiceS folly::Future future_syncData(const cpp2::SyncDataRequest& req) override; folly::Future future_chainDeleteEdges( - const cpp2::ChainDeleteEdgesRequest& p_req); + const cpp2::ChainDeleteEdgesRequest& p_req) override; private: StorageEnv* env_{nullptr};