apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-06-03 03:41:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

Change option to repopulate_from_data_cluster

Browse Source
This commit is contained in:
Sagar Vemuri 2022-09-20 11:18:18 -07:00 committed by A.J. Beamon
parent 22d5546206
commit 226976f0a7
1 changed files with 11 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
fdbcli/MetaclusterCommands.actor.cpp
View File

@ -181,50 +181,28 @@ Optional<std::string> parseToken(StringRef token, const char* str) {
ACTOR Future<bool> metaclusterRestoreCommand(Reference<IDatabase> db, std::vector<StringRef> tokens) {
if (tokens.size() < 4 || tokens.size() > 6) {
fmt::print("Usage: metacluster restore <NAME> connection_string=<CONNECTION_STRING>\n"
"[<add_new_tenants=[true|false]>|<remove_missing_tenants=[true|false]>]\n\n");
"[repopulate_from_data_cluster]\n\n");
fmt::print("Restore a data cluster.\n");
return false;
}
state ClusterNameRef clusterName = tokens[3];
// connection string
ClusterConnectionString connectionString;
auto optVal = parseToken(tokens[4], "connection_string");
auto optVal = parseToken(tokens[3], "connection_string");
if (optVal.present()) {
connectionString = ClusterConnectionString(optVal.get());
}
AddNewTenants addNewTenants(AddNewTenants::True);
if (tokens.size() > 4) {
optVal = parseToken(tokens[4], "add_new_tenants");
if (optVal.present()) {
if (optVal.get() == "true") {
addNewTenants = AddNewTenants::True;
} else {
addNewTenants = AddNewTenants::False;
}
}
state bool restore_from_data_cluster = tokens.size() == 5;
if (restore_from_data_cluster) {
DataClusterEntry defaultEntry;
wait(MetaclusterAPI::restoreCluster(
db, tokens[2], connectionString, defaultEntry, AddNewTenants::False, RemoveMissingTenants::True));
fmt::print("The cluster `{}' has been restored\n", printable(tokens[2]).c_str());
return true;
}
RemoveMissingTenants removeMissingTenants(RemoveMissingTenants::True);
if (tokens.size() > 5) {
optVal = parseToken(tokens[4], "remove_missing_tenants");
if (optVal.present()) {
if (optVal.get() == "true") {
removeMissingTenants = RemoveMissingTenants::True;
} else {
removeMissingTenants = RemoveMissingTenants::False;
}
}
}
DataClusterEntry defaultEntry;
wait(MetaclusterAPI::restoreCluster(
db, clusterName, connectionString, defaultEntry, addNewTenants, removeMissingTenants));
fmt::print("The cluster `{}' has been restored\n", printable(clusterName).c_str());
return true;
return false;
}
// metacluster configure command