Package com.orientechnologies.orient.server.distributed

Interface ODistributedServerManager

All Known Implementing Classes:

ODistributedPlugin, OHazelcastPlugin

public interface ODistributedServerManager

Server cluster interface to abstract cluster behavior.

Author:

Luca Garulli (l.garulli--at--orientdb.com)

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static enum	ODistributedServerManager.DB_STATUS	Database status.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FILE_DISTRIBUTED_DB_CONFIG

Method Summary

Modifier and Type	Method	Description
<T> T	executeInDistributedDatabaseLock(String databaseName, long timeoutLocking, OModifiableDistributedConfiguration lastCfg, OCallable<T,OModifiableDistributedConfiguration> iCallback)	Executes an operation protected by a distributed lock (one per database).
Object	executeOnLocalNode(ODistributedRequestId reqId, ORemoteTask task, ODatabaseDocumentInternal database)
void	executeOnLocalNodeFromRemote(ODistributedRequest request)
Set<String>	getActiveServerNotLocal()
Set<String>	getActiveServers()
Set<String>	getAvailableNodeNames(String databaseName)
Set<String>	getAvailableNodeNotLocalNames(String databaseName)
int	getAvailableNodes(String iDatabaseName)
OClusterConfiguration	getClusterConfiguration()
ODistributedDatabase	getDatabase(String name)
ODistributedConfiguration	getDatabaseConfiguration(String iDatabaseName)
Set<String>	getDatabases()
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String iNode, String iDatabaseName)
File	getDefaultDatabaseConfigFile()
ODistributedStrategy	getDistributedStrategy()
long	getLastClusterChangeOn()
ONodeConfig	getLocalNodeConfiguration()
int	getLocalNodeId()
String	getLocalNodeName()
ODistributedMessageService	getMessageService()
long	getNextMessageIdCounter()
ONodeConfig	getNodeConfigurationByUuid(String iNode, boolean useCache)
int	getNodeIdByName(String node)
String	getNodeNameById(int id)
NODE_STATUS	getNodeStatus()
int	getNodesWithStatus(Collection<String> iNodes, String databaseName, ODistributedServerManager.DB_STATUS... statuses)
ODocument	getOnlineDatabaseConfiguration(String databaseName)
List<String>	getOnlineNodes(String iDatabaseName)
List<String>	getOnlineNodesNotLocal(String iDatabaseName)
ORemoteServerController	getRemoteServer(String nodeName)
OServer	getServerInstance()
ORemoteTaskFactoryManager	getTaskFactoryManager()	Returns the task factory manager.
boolean	installDatabase(boolean iStartup, String databaseName, boolean forceDeployment, boolean tryWithDeltaFirst)
boolean	isEnabled()
boolean	isNodeAvailable(String iNodeName)
boolean	isNodeAvailable(String iNodeName, String databaseName)	Available means not OFFLINE, so ONLINE or SYNCHRONIZING.
boolean	isNodeOnline(String iNodeName, String databaseName)	Returns true if the node status is ONLINE.
boolean	isNodeStatusEqualsTo(String iNodeName, String iDatabaseName, ODistributedServerManager.DB_STATUS... statuses)	Checks the node status if it's one of the statuses received as argument.
boolean	isOffline()
boolean	isSyncronizing(String databaseName)
boolean	isWriteQuorumPresent(String databaseName)	Returns true if the quorum is present in terms of number of available nodes for full replication only.
default void	messageAfterOp(String op, ODistributedRequestId requestId)
default void	messageBeforeOp(String op, ODistributedRequestId requestId)
default void	messageCurrentPayload(ODistributedRequestId requestId, Object responsePayload)
default void	messageProcessEnd(ODistributedRequest iRequest, Object responsePayload)
default void	messageProcessStart(ODistributedRequest message)
default void	messageReceived(ODistributedRequest request)
ODistributedRequestId	nextRequestId()
void	notifyClients(String databaseName)
void	publishDistributedConfiguration(String iDatabaseName, ODistributedConfiguration cfg)
void	reassignClustersOwnership(String iNode, String databaseName, boolean canCreateNewClusters)
ODistributedServerManager	registerLifecycleListener(ODistributedLifecycleListener iListener)
void	removeServer(String nodeLeftName, boolean removeOnlyDynamicServers)
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iTargetNodeNames, ORemoteTask iTask)	Sends a distributed request against multiple servers.
ODistributedResponse	sendRequest(String iDatabaseName, Collection<String> iTargetNodeNames, ORemoteTask iTask, ODistributedRequestId messageId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
ODistributedResponse	sendSingleRequest(String iDatabaseName, String node, ORemoteTask iTask)	Sends a distributed request against multiple servers.
void	setDatabaseStatus(String iNode, String iDatabaseName, ODistributedServerManager.DB_STATUS iStatus)
void	setDistributedStrategy(ODistributedStrategy streatgy)
void	setNodeStatus(NODE_STATUS iStatus)
ODistributedServerManager	unregisterLifecycleListener(ODistributedLifecycleListener iListener)
boolean	updateCachedDatabaseConfiguration(String iDatabaseName, OModifiableDistributedConfiguration cfg)
void	updateLastClusterChange()
void	waitUntilNodeOnline()
void	waitUntilNodeOnline(String nodeName, String databaseName)

Field Details

FILE_DISTRIBUTED_DB_CONFIG

static final String FILE_DISTRIBUTED_DB_CONFIG

See Also:

• Constant Field Values

Method Details

isNodeStatusEqualsTo

boolean isNodeStatusEqualsTo(String iNodeName,
 String iDatabaseName,
 ODistributedServerManager.DB_STATUS... statuses)

Checks the node status if it's one of the statuses received as argument.

Parameters:

iNodeName - Node name

iDatabaseName - Database name

statuses - vararg of statuses

Returns:

true if the node's status is equals to one of the passed statuses, otherwise false

isNodeAvailable

boolean isNodeAvailable(String iNodeName)

getAvailableNodeNames

Set<String> getAvailableNodeNames(String databaseName)

getAvailableNodeNotLocalNames

Set<String> getAvailableNodeNotLocalNames(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

Object executeOnLocalNode(ODistributedRequestId reqId,
 ORemoteTask task,
 ODatabaseDocumentInternal database)

executeOnLocalNodeFromRemote

void executeOnLocalNodeFromRemote(ODistributedRequest request)

getRemoteServer

ORemoteServerController getRemoteServer(String nodeName)
                                 throws IOException

Throws:

IOException

getLastClusterChangeOn

long getLastClusterChangeOn()

getNodeStatus

NODE_STATUS getNodeStatus()

setNodeStatus

void setNodeStatus(NODE_STATUS iStatus)

removeServer

void removeServer(String nodeLeftName,
 boolean removeOnlyDynamicServers)

getDatabaseStatus

ODistributedServerManager.DB_STATUS getDatabaseStatus(String iNode,
 String iDatabaseName)

setDatabaseStatus

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

getNodesWithStatus

int getNodesWithStatus(Collection<String> iNodes,
 String databaseName,
 ODistributedServerManager.DB_STATUS... statuses)

getMessageService

ODistributedMessageService getMessageService()

getDatabase

ODistributedDatabase getDatabase(String name)

getDistributedStrategy

ODistributedStrategy getDistributedStrategy()

setDistributedStrategy

void setDistributedStrategy(ODistributedStrategy streatgy)

updateCachedDatabaseConfiguration

boolean updateCachedDatabaseConfiguration(String iDatabaseName,
 OModifiableDistributedConfiguration cfg)

publishDistributedConfiguration

void publishDistributedConfiguration(String iDatabaseName,
 ODistributedConfiguration cfg)

getNextMessageIdCounter

long getNextMessageIdCounter()

updateLastClusterChange

void updateLastClusterChange()

reassignClustersOwnership

void reassignClustersOwnership(String iNode,
 String databaseName,
 boolean canCreateNewClusters)

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)

isOffline

boolean isOffline()

getLocalNodeId

int getLocalNodeId()

getLocalNodeName

String getLocalNodeName()

getClusterConfiguration

OClusterConfiguration getClusterConfiguration()

getNodeNameById

String getNodeNameById(int id)

getNodeIdByName

int getNodeIdByName(String node)

getNodeConfigurationByUuid

ONodeConfig getNodeConfigurationByUuid(String iNode,
 boolean useCache)

getLocalNodeConfiguration

ONodeConfig getLocalNodeConfiguration()

getDatabaseConfiguration

ODistributedConfiguration getDatabaseConfiguration(String iDatabaseName)

sendRequest

ODistributedResponse sendRequest(String iDatabaseName,
 Collection<String> iTargetNodeNames,
 ORemoteTask iTask)

Sends a distributed request against multiple servers.

Parameters:

iDatabaseName -

iTargetNodeNames -

iTask -

Returns:

sendSingleRequest

ODistributedResponse sendSingleRequest(String iDatabaseName,
 String node,
 ORemoteTask iTask)

Sends a distributed request against multiple servers.

Parameters:

iDatabaseName -

node -

iTask -

Returns:

sendRequest

ODistributedResponse sendRequest(String iDatabaseName,
 Collection<String> iTargetNodeNames,
 ORemoteTask iTask,
 ODistributedRequestId messageId,
 Object localResult,
 ODistributedResponseManagerFactory responseManagerFactory)

getOnlineNodes

List<String> getOnlineNodes(String iDatabaseName)

getOnlineNodesNotLocal

List<String> getOnlineNodesNotLocal(String iDatabaseName)

installDatabase

boolean installDatabase(boolean iStartup,
 String databaseName,
 boolean forceDeployment,
 boolean tryWithDeltaFirst)

getTaskFactoryManager

ORemoteTaskFactoryManager getTaskFactoryManager()

Returns the task factory manager. During first connect the minor version of the protocol is used.

getActiveServers

Set<String> getActiveServers()

getActiveServerNotLocal

Set<String> getActiveServerNotLocal()

getDefaultDatabaseConfigFile

File getDefaultDatabaseConfigFile()

executeInDistributedDatabaseLock

<T> T executeInDistributedDatabaseLock(String databaseName,
 long timeoutLocking,
 OModifiableDistributedConfiguration lastCfg,
 OCallable<T,OModifiableDistributedConfiguration> iCallback)

Executes an operation protected by a distributed lock (one per database).

Type Parameters:

T - Return type

Parameters:

databaseName - Database name

timeoutLocking -

iCallback - Operation @return The operation's result of type T

isWriteQuorumPresent

boolean isWriteQuorumPresent(String databaseName)

Returns true if the quorum is present in terms of number of available nodes for full replication only. With sharding, instead, the quorum may depend on the involved clusters.

Returns:

notifyClients

void notifyClients(String databaseName)

messageReceived

default void messageReceived(ODistributedRequest request)

messageBeforeOp

default void messageBeforeOp(String op,
 ODistributedRequestId requestId)

messageAfterOp

default void messageAfterOp(String op,
 ODistributedRequestId requestId)

messageCurrentPayload

default void messageCurrentPayload(ODistributedRequestId requestId,
 Object responsePayload)

messageProcessStart

default void messageProcessStart(ODistributedRequest message)

messageProcessEnd

default void messageProcessEnd(ODistributedRequest iRequest,
 Object responsePayload)

getOnlineDatabaseConfiguration

ODocument getOnlineDatabaseConfiguration(String databaseName)

getDatabases

Set<String> getDatabases()

isSyncronizing

boolean isSyncronizing(String databaseName)

nextRequestId

ODistributedRequestId nextRequestId()