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
Set<String>	getActiveServers()
OClusterConfiguration	getClusterConfiguration()
ODistributedDatabase	getDatabase(String name)
ODistributedConfiguration	getDatabaseConfiguration(String iDatabaseName)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(String iNode, String iDatabaseName)
File	getDefaultDatabaseConfigFile()
ODistributedStrategy	getDistributedStrategy()
long	getLastClusterChangeOn()
ONodeConfig	getLocalNodeConfiguration()
String	getLocalNodeName()
ODistributedMessageService	getMessageService()
long	getNextMessageIdCounter()
ONodeConfig	getNodeConfigurationByUuid(String iNode, boolean useCache)
ORemoteServerController	getRemoteServer(String nodeName)
OServer	getServerInstance()
boolean	isEnabled()
ODistributedRequestId	nextRequestId()
void	notifyClients(String databaseName)
ODistributedServerManager	registerLifecycleListener(ODistributedLifecycleListener iListener)
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	setDistributedStrategy(ODistributedStrategy streatgy)
ODistributedServerManager	unregisterLifecycleListener(ODistributedLifecycleListener iListener)
void	updateLastClusterChange()

Field Details

FILE_DISTRIBUTED_DB_CONFIG

static final String FILE_DISTRIBUTED_DB_CONFIG

See Also:

• Constant Field Values

Method Details

getServerInstance

OServer getServerInstance()

isEnabled

boolean isEnabled()

registerLifecycleListener

ODistributedServerManager registerLifecycleListener(ODistributedLifecycleListener iListener)

unregisterLifecycleListener

ODistributedServerManager unregisterLifecycleListener(ODistributedLifecycleListener iListener)

getRemoteServer

ORemoteServerController getRemoteServer(String nodeName)
                                 throws IOException

Throws:

IOException

getLastClusterChangeOn

long getLastClusterChangeOn()

getDatabaseStatus

ODistributedServerManager.DB_STATUS getDatabaseStatus(String iNode,
 String iDatabaseName)

getMessageService

ODistributedMessageService getMessageService()

getDatabase

ODistributedDatabase getDatabase(String name)

getDistributedStrategy

ODistributedStrategy getDistributedStrategy()

setDistributedStrategy

void setDistributedStrategy(ODistributedStrategy streatgy)

getNextMessageIdCounter

long getNextMessageIdCounter()

updateLastClusterChange

void updateLastClusterChange()

getLocalNodeName

String getLocalNodeName()

getClusterConfiguration

OClusterConfiguration getClusterConfiguration()

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)

getActiveServers

Set<String> getActiveServers()

getDefaultDatabaseConfigFile

File getDefaultDatabaseConfigFile()

notifyClients

void notifyClients(String databaseName)

nextRequestId

ODistributedRequestId nextRequestId()