MCPcopy Create free account
hub / github.com/4paradigm/OpenMLDB / HandleNSClientSyncTable

Function HandleNSClientSyncTable

src/cmd/fedb.cc:835–858  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

833}
834
835void HandleNSClientSyncTable(const std::vector<std::string>& parts,
836 ::fedb::client::NsClient* client) {
837 if (parts.size() != 3 && parts.size() != 4) {
838 std::cout << "Bad format for synctable! eg. synctable table_name "
839 "cluster_alias [pid]"
840 << std::endl;
841 return;
842 }
843 uint32_t pid = UINT32_MAX;
844 try {
845 if (parts.size() == 4) {
846 pid = boost::lexical_cast<uint32_t>(parts[3]);
847 }
848 std::string msg;
849 bool ret = client->SyncTable(parts[1], parts[2], pid, msg);
850 if (!ret) {
851 std::cout << "failed to synctable. error msg: " << msg << std::endl;
852 return;
853 }
854 std::cout << "synctable ok" << std::endl;
855 } catch (std::exception const& e) {
856 std::cout << "Invalid args. pid should be uint32_t" << std::endl;
857 }
858}
859
860void HandleNSClientSetSdkEndpoint(const std::vector<std::string>& parts,
861 ::fedb::client::NsClient* client) {

Callers 1

StartNsClientFunction · 0.85

Calls 2

sizeMethod · 0.45
SyncTableMethod · 0.45

Tested by

no test coverage detected