boolean |
OClusterOwnershipAssignmentStrategy.assignClusterOwnershipOfClass(ODatabaseInternal iDatabase,
ODistributedConfiguration cfg,
OClass iClass,
Set<String> availableNodes,
Set<String> clustersToReassign,
boolean rebalance) |
boolean |
ODefaultClusterOwnershipAssignmentStrategy.assignClusterOwnershipOfClass(ODatabaseInternal iDatabase,
ODistributedConfiguration cfg,
OClass iClass,
Set<String> availableNodes,
Set<String> clustersToReassign,
boolean rebalance) |
protected int |
ODistributedDatabaseImpl.calculateQuorum(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType,
Collection<String> clusterNames,
ODistributedConfiguration cfg,
int allAvailableNodes,
int masterAvailableNodes,
boolean checkNodesAreOnline) |
protected void |
ODistributedStorage.checkNodeIsMaster(String localNodeName,
ODistributedConfiguration dbCfg) |
int |
ODistributedDatabaseImpl.checkQuorumBeforeReplicate(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType,
Collection<String> iClusterNames,
Collection<String> iNodes,
ODistributedConfiguration cfg) |
protected boolean |
ODistributedAbstractPlugin.electCurrentNodeAsNewCoordinator(ODistributedConfiguration cfg,
String nodeLeftName,
String databaseName)
Elects current node as new coordinator.
|
protected boolean |
ODistributedAbstractPlugin.electCurrentNodeAsNewCoordinator(String nodeLeftName,
String nodeToElect,
String databaseName,
ODistributedConfiguration cfg) |
protected boolean |
ODistributedStorage.executeOnlyLocally(String localNodeName,
ODistributedConfiguration dbCfg,
OCommandExecutor exec,
Collection<String> involvedClusters,
Collection<String> nodes)
Only idempotent commands that don't involve any other node can be executed locally.
|
static String |
ODistributedOutput.formatClasses(ODistributedConfiguration cfg,
ODatabaseDocumentTx db) |
static String |
ODistributedOutput.formatClusterTable(ODistributedServerManager manager,
String databaseName,
ODistributedConfiguration cfg,
int availableNodes) |
protected Set<String> |
ODistributedTransactionManager.getAvailableNodesButLocal(ODistributedConfiguration dbCfg,
Set<String> involvedClusters,
String localNodeName) |
protected String |
ODistributedAbstractPlugin.getCoordinatorServer(ODistributedConfiguration cfg) |
protected Map<String,String> |
ODefaultClusterOwnershipAssignmentStrategy.reassignClusters(ODistributedConfiguration cfg,
Set<String> availableNodes,
Set<String> clustersOfClassToReassign,
Set<String> clusterNames,
boolean rebalance) |
protected boolean |
ODistributedAbstractPlugin.reassignClustersOwnership(String iNode,
ODistributedConfiguration cfg,
String databaseName,
Set<String> clustersWithNotAvailableOwner,
boolean rebalance) |
protected boolean |
ODistributedAbstractPlugin.rebalanceClusterOwnership(String iNode,
ODatabaseInternal iDatabase,
ODistributedConfiguration cfg,
Set<String> clustersWithNotAvailableOwner,
boolean rebalance) |
void |
ODistributedStorage.setDistributedConfiguration(ODistributedConfiguration distributedConfiguration) |
protected boolean |
ODistributedDatabaseImpl.waitForLocalNode(ODistributedConfiguration cfg,
Collection<String> iClusterNames,
Collection<String> iNodes) |