Field Detail

• FILE_DISTRIBUTED_DB_CONFIG

  static final String FILE_DISTRIBUTED_DB_CONFIG

  See Also:

  Constant Field Values

Method Detail

• isNodeAvailable

  boolean isNodeAvailable(String iNodeName)

• getAvailableNodeNames

  Set<String> getAvailableNodeNames(String databaseName)

• waitUntilNodeOnline

  void waitUntilNodeOnline()
                    throws InterruptedException

  Throws:

  InterruptedException

• waitUntilNodeOnline

  void waitUntilNodeOnline(String nodeName,
                           String databaseName)
                    throws InterruptedException

  Throws:

  InterruptedException

• getServerInstance

  OServer getServerInstance()

• isEnabled

  boolean isEnabled()

• registerLifecycleListener

  ODistributedServerManager registerLifecycleListener(ODistributedLifecycleListener iListener)

• unregisterLifecycleListener

  ODistributedServerManager unregisterLifecycleListener(ODistributedLifecycleListener iListener)

• executeOnLocalNode

  Serializable executeOnLocalNode(ODistributedRequestId reqId,
                                  ORemoteTask task,
                                  ODatabaseDocumentTx database)

• getRemoteServer

  ORemoteServerController getRemoteServer(String nodeName)
                                   throws IOException

  Throws:

  IOException

• getConfigurationMap

  Map<String,Object> getConfigurationMap()

• getLastClusterChangeOn

  long getLastClusterChangeOn()

• getNodeStatus

  ODistributedServerManager.NODE_STATUS getNodeStatus()

• setNodeStatus

  void setNodeStatus(ODistributedServerManager.NODE_STATUS iStatus)

• checkNodeStatus

  boolean checkNodeStatus(ODistributedServerManager.NODE_STATUS string)

• getDatabaseStatus

  ODistributedServerManager.DB_STATUS getDatabaseStatus(String iNode,
                                                        String iDatabaseName)

• setDatabaseStatus

  void setDatabaseStatus(String iNode,
                         String iDatabaseName,
                         ODistributedServerManager.DB_STATUS iStatus)

• getMessageService

  ODistributedMessageService getMessageService()

• updateCachedDatabaseConfiguration

  void updateCachedDatabaseConfiguration(String iDatabaseName,
                                         ODocument cfg,
                                         boolean iSaveToDisk,
                                         boolean iDeployToCluster)

• getNextMessageIdCounter

  long getNextMessageIdCounter()

• updateLastClusterChange

  void updateLastClusterChange()

• isNodeAvailable

  boolean isNodeAvailable(String iNodeName,
                          String databaseName)

  Available means not OFFLINE, so ONLINE or SYNCHRONIZING.

• isNodeOnline

  boolean isNodeOnline(String iNodeName,
                       String databaseName)

  Returns true if the node status is ONLINE.

• getAvailableNodes

  int getAvailableNodes(String iDatabaseName)

• getAvailableNodes

  int getAvailableNodes(Collection<String> iNodes,
                        String databaseName)

• isOffline

  boolean isOffline()

• getLocalNodeId

  int getLocalNodeId()

• getLocalNodeName

  String getLocalNodeName()

• getClusterConfiguration

  ODocument getClusterConfiguration()

• getNodeNameById

  String getNodeNameById(int id)

• getNodeIdByName

  int getNodeIdByName(String node)

• getNodeConfigurationByUuid

  ODocument getNodeConfigurationByUuid(String iNode)

• getLocalNodeConfiguration

  ODocument getLocalNodeConfiguration()

• propagateSchemaChanges

  void propagateSchemaChanges(ODatabaseInternal iStorage)

• getLock

  Lock getLock(String iLockName)

  Gets a distributed lock

  Parameters:

  iLockName - name of the lock

  Returns:

• getDatabaseConfiguration

  ODistributedConfiguration getDatabaseConfiguration(String iDatabaseName)

• sendRequest

  ODistributedResponse sendRequest(String iDatabaseName,
                                   Collection<String> iClusterNames,
                                   Collection<String> iTargetNodeNames,
                                   ORemoteTask iTask,
                                   long messageId,
                                   ODistributedRequest.EXECUTION_MODE iExecutionMode,
                                   Object localResult,
                                   OCallable<Void,ODistributedRequestId> iAfterSentCallback)

  Sends a distributed request against multiple servers.

  Parameters:

  iDatabaseName -

  iClusterNames -

  iTargetNodeNames -

  iTask -

  messageId - Message Id as long

  iExecutionMode -

  localResult - It's the result of the request executed locally

  iAfterSentCallback -

  Returns:

• getStats

  ODocument getStats()

• convertException

  Throwable convertException(Throwable original)

• getTaskFactory

  ORemoteTaskFactory getTaskFactory()