Package com.orientechnologies.orient.server.distributed

Interface ODistributedServerManager

All Known Implementing Classes:

ODistributedPlugin

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
OClusterConfiguration	getClusterConfiguration()
ODistributedDatabase	getDatabase(String name)
ODistributedServerManager.DB_STATUS	getDatabaseStatus(ONodeId iNode, String iDatabaseName)
File	getDefaultDatabaseConfigFile()
ODistributedStrategy	getDistributedStrategy()
String	getLocalNodeName()
ODistributedMessageService	getMessageService()
long	getNextMessageIdCounter()
ONodeConfig	getNodeConfigurationByUuid(String iNode, boolean useCache)
OServer	getServerInstance()
boolean	isEnabled()
ODistributedRequestId	nextRequestId()
void	notifyClients(String databaseName)
ODistributedServerManager	registerLifecycleListener(ODistributedLifecycleListener iListener)
ODistributedResponse	sendRequest(String iDatabaseName, Collection<ONodeId> iTargetNodeNames, ORemoteTask iTask)	Sends a distributed request against multiple servers.
ODistributedResponse	sendRequest(String iDatabaseName, Collection<ONodeId> iTargetNodeNames, ORemoteTask iTask, ODistributedRequestId messageId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
ODistributedResponse	sendSingleRequest(String iDatabaseName, ONodeId node, ORemoteTask iTask)	Sends a distributed request against multiple servers.
void	setDistributedStrategy(ODistributedStrategy streatgy)
ODistributedServerManager	unregisterLifecycleListener(ODistributedLifecycleListener iListener)

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)

getDatabaseStatus

ODistributedServerManager.DB_STATUS getDatabaseStatus(ONodeId iNode,
 String iDatabaseName)

getMessageService

ODistributedMessageService getMessageService()

getDatabase

ODistributedDatabase getDatabase(String name)

getDistributedStrategy

ODistributedStrategy getDistributedStrategy()

setDistributedStrategy

void setDistributedStrategy(ODistributedStrategy streatgy)

getNextMessageIdCounter

long getNextMessageIdCounter()

getLocalNodeName

String getLocalNodeName()

getClusterConfiguration

OClusterConfiguration getClusterConfiguration()

getNodeConfigurationByUuid

ONodeConfig getNodeConfigurationByUuid(String iNode,
 boolean useCache)

sendRequest

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

Sends a distributed request against multiple servers.

Parameters:

iDatabaseName -

iTargetNodeNames -

iTask -

Returns:

sendSingleRequest

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

Sends a distributed request against multiple servers.

Parameters:

iDatabaseName -

node -

iTask -

Returns:

sendRequest

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

getDefaultDatabaseConfigFile

File getDefaultDatabaseConfigFile()

notifyClients

void notifyClients(String databaseName)

nextRequestId

ODistributedRequestId nextRequestId()