ODistributedConfiguration (OrientDB 3.1.2-SNAPSHOT API)

java.lang.Object
- com.orientechnologies.orient.server.distributed.ODistributedConfiguration

Direct Known Subclasses:

OModifiableDistributedConfiguration
```
public class ODistributedConfiguration
extends Object
```
Immutable Distributed configuration. It uses an ODocument object to store the configuration. Every changes must be done by obtaining a modifiable verson of the object through the method `modify()`.

Author:

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

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class ODistributedConfiguration.NEW_NODE_STRATEGIES

static class ODistributedConfiguration.ROLES

Nested Classes
Modifier and Type	Class and Description
`static class`	`ODistributedConfiguration.NEW_NODE_STRATEGIES`
`static class`	`ODistributedConfiguration.ROLES`

Field Summary

Fields
Modifier and Type	Field and Description
`static String`	`ALL_WILDCARD`
`protected static String`	`AUTO_DEPLOY`
`protected static String`	`CLUSTERS`
`protected ODocument`	`configuration`
`protected static String`	`DCS`
`protected static List<String>`	`DEFAULT_CLUSTER_NAME`
`static Integer`	`DEFAULT_READ_QUORUM`
`static String`	`DEFAULT_WRITE_QUORUM`
`protected static String`	`EXECUTION_MODE`
`protected static String`	`EXECUTION_MODE_SYNCHRONOUS`
`protected static String`	`NEW_NODE_STRATEGY`
`static String`	`NEW_NODE_TAG`
`protected static String`	`OWNER`
`static String`	`QUORUM_ALL`
`static String`	`QUORUM_LOCAL_DC`
`static String`	`QUORUM_MAJORITY`
`protected static String`	`READ_QUORUM`
`protected static String`	`READ_YOUR_WRITES`
`protected static String`	`SERVERS`
`protected static String`	`VERSION`
`protected static String`	`WRITE_QUORUM`

Constructor Summary

Constructors
Constructor and Description

ODistributedConfiguration(ODocument iConfiguration)

Constructors
Constructor and Description
`ODistributedConfiguration(ODocument iConfiguration)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`clearForceWriteQuorum()`
`void`	`forceWriteQuorum(int quorum)`
`Set<String>`	`getAllConfiguredServers()` Returns the complete list of servers found in configuration.
`protected ODocument`	`getClusterConfiguration(String iClusterName)` Gets the document representing the cluster configuration.
`String[]`	`getClusterNames()` Returns the array of configured clusters
`String`	`getClusterOwner(String iClusterName)` Returns the owner server for the given cluster excluding the passed node.
`Set<String>`	`getClustersOnServer(String iNodeName)` Returns the set of clusters managed by a server.
`Set<String>`	`getClustersOwnedByServer(String iNodeName)` Returns the set of clusters where server is the owner.
`String`	`getConfiguredClusterOwner(String iClusterName)` Returns the static owner server for the given cluster.
`List<String>`	`getConfiguredServers(String iClusterName)` Returns the configured server list for the requested cluster.
`String`	`getDataCenterOfServer(String server)` Returns the data center where the server belongs.
`Set<String>`	`getDataCenters()` Returns all the configured data centers' names, if any.
`List<String>`	`getDataCenterServers(String dataCenter)` Returns the list of servers in a data center.
`int`	`getDataCenterWriteQuorum(String dataCenter)` Returns the data center write quorum.
`ODistributedConfiguration.ROLES`	`getDefaultServerRole()` Returns the default server role between MASTER (default) and REPLICA.
`ODocument`	`getDocument()`
`Object`	`getGlobalReadQuorum(String iClusterName)` Returns the global read quorum.
`List<String>`	`getMasterServers()` Returns an ordered list of master server.
`ODistributedConfiguration.NEW_NODE_STRATEGIES`	`getNewNodeStrategy()` Returns the new node strategy between "dynamic" and "static".
`List<String>`	`getOwnedClustersByServer(Collection<String> iClusterNames, String iNode)` Returns the clusters where a server is owner.
`int`	`getReadQuorum(String clusterName, int totalConfiguredServers, String server)` Returns the read quorum.
`Set<String>`	`getRegisteredServers()` Returns the registered servers.
`Map<String,Collection<String>>`	`getServerClusterMap(Collection<String> iClusterNames, String iLocalNode, boolean optimizeForLocalOnly)` Returns the list of servers that can manage a list of clusters.
`ODistributedConfiguration.ROLES`	`getServerRole(String iServerName)` Returns the server role between MASTER (default) and REPLICA.
`Set<String>`	`getServers(Collection<String> iClusterNames)` Returns the set of server names involved on the passed cluster collection.
`List<String>`	`getServers(String iClusterName, String iExclude)` Returns the server list for the requested cluster cluster excluding any tags like and iExclude if any.
`int`	`getVersion()`
`int`	`getWriteQuorum(String clusterName, int totalConfiguredMasterServers, String server)` Returns the write quorum.
`boolean`	`hasDataCenterConfiguration()` Returns true if the configuration per data centers is specified.
`boolean`	`isAutoDeploy()`
`Boolean`	`isExecutionModeSynchronous(String iClusterName)` Returns the execution mode if synchronous.
`boolean`	`isLocalDataCenterWriteQuorum()` Returns true if the global write quorum is "localDataCenter".
`Boolean`	`isReadYourWrites(String iClusterName)` Reads your writes.
`boolean`	`isReplicationActive(String iClusterName, String iLocalNode)` Returns true if the replication is active, otherwise false.
`boolean`	`isServerContainingAllClusters(String server, Collection<String> clusters)` Returns true if the local server has all the requested clusters.
`boolean`	`isServerContainingCluster(String server, String cluster)` Returns true if the local server has the requested cluster.
`boolean`	`isSharded()` Returns true if the database is sharded across servers.
`OModifiableDistributedConfiguration`	`modify()`
`String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - NEW_NODE_TAG
```
public static final String NEW_NODE_TAG
```
    See Also:
    
    Constant Field Values
  - ALL_WILDCARD
```
public static final String ALL_WILDCARD
```
    See Also:
    
    Constant Field Values
  - SERVERS
```
protected static final String SERVERS
```
    See Also:
    
    Constant Field Values
  - DCS
```
protected static final String DCS
```
    See Also:
    
    Constant Field Values
  - OWNER
```
protected static final String OWNER
```
    See Also:
    
    Constant Field Values
  - CLUSTERS
```
protected static final String CLUSTERS
```
    See Also:
    
    Constant Field Values
  - VERSION
```
protected static final String VERSION
```
    See Also:
    
    Constant Field Values
  - AUTO_DEPLOY
```
protected static final String AUTO_DEPLOY
```
    See Also:
    
    Constant Field Values
  - READ_QUORUM
```
protected static final String READ_QUORUM
```
    See Also:
    
    Constant Field Values
  - WRITE_QUORUM
```
protected static final String WRITE_QUORUM
```
    See Also:
    
    Constant Field Values
  - QUORUM_MAJORITY
```
public static final String QUORUM_MAJORITY
```
    See Also:
    
    Constant Field Values
  - QUORUM_ALL
```
public static final String QUORUM_ALL
```
    See Also:
    
    Constant Field Values
  - QUORUM_LOCAL_DC
```
public static final String QUORUM_LOCAL_DC
```
    See Also:
    
    Constant Field Values
  - DEFAULT_READ_QUORUM
```
public static final Integer DEFAULT_READ_QUORUM
```
  - DEFAULT_WRITE_QUORUM
```
public static final String DEFAULT_WRITE_QUORUM
```
    See Also:
    
    Constant Field Values
  - NEW_NODE_STRATEGY
```
protected static final String NEW_NODE_STRATEGY
```
    See Also:
    
    Constant Field Values
  - READ_YOUR_WRITES
```
protected static final String READ_YOUR_WRITES
```
    See Also:
    
    Constant Field Values
  - EXECUTION_MODE
```
protected static final String EXECUTION_MODE
```
    See Also:
    
    Constant Field Values
  - EXECUTION_MODE_SYNCHRONOUS
```
protected static final String EXECUTION_MODE_SYNCHRONOUS
```
    See Also:
    
    Constant Field Values
  - configuration
```
protected final ODocument configuration
```
  - DEFAULT_CLUSTER_NAME
```
protected static final List<String> DEFAULT_CLUSTER_NAME
```
- Constructor Detail
  - ODistributedConfiguration
```
public ODistributedConfiguration(ODocument iConfiguration)
```
- Method Detail
  - modify
```
public OModifiableDistributedConfiguration modify()
```
  - isReplicationActive
```
public boolean isReplicationActive(String iClusterName,
                                   String iLocalNode)
```
    Returns true if the replication is active, otherwise false.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
  - hasDataCenterConfiguration
```
public boolean hasDataCenterConfiguration()
```
    Returns true if the configuration per data centers is specified.
  - isAutoDeploy
```
public boolean isAutoDeploy()
```
  - getNewNodeStrategy
```
public ODistributedConfiguration.NEW_NODE_STRATEGIES getNewNodeStrategy()
```
    Returns the new node strategy between "dynamic" and "static". If static, the node is registered under the "server" tag.
    
    Returns:
    
    NEW_NODE_STRATEGIES enum
  - isExecutionModeSynchronous
```
public Boolean isExecutionModeSynchronous(String iClusterName)
```
    Returns the execution mode if synchronous.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
    
    Returns:
    
    true = synchronous, false = asynchronous, null = undefined
  - isReadYourWrites
```
public Boolean isReadYourWrites(String iClusterName)
```
    Reads your writes.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
  - getServerClusterMap
```
public Map<String,Collection<String>> getServerClusterMap(Collection<String> iClusterNames,
                                                          String iLocalNode,
                                                          boolean optimizeForLocalOnly)
```
    Returns the list of servers that can manage a list of clusters. The algorithm makes its best to involve the less servers as it can.
    
    Parameters:
    
    iClusterNames - Set of cluster names to find
    
    iLocalNode - Local node name
  - getOwnedClustersByServer
```
public List<String> getOwnedClustersByServer(Collection<String> iClusterNames,
                                             String iNode)
```
    Returns the clusters where a server is owner. This is used when a cluster must be selected: locality is always the best choice.
    
    Parameters:
    
    iClusterNames - Set of cluster names
    
    iNode - Node
  - getServers
```
public Set<String> getServers(Collection<String> iClusterNames)
```
    Returns the set of server names involved on the passed cluster collection.
    
    Parameters:
    
    iClusterNames - Collection of cluster names to find
  - isServerContainingAllClusters
```
public boolean isServerContainingAllClusters(String server,
                                             Collection<String> clusters)
```
    Returns true if the local server has all the requested clusters.
    
    Parameters:
    
    server - Server name
    
    clusters - Collection of cluster names to find
  - isServerContainingCluster
```
public boolean isServerContainingCluster(String server,
                                         String cluster)
```
    Returns true if the local server has the requested cluster.
    
    Parameters:
    
    server - Server name
    
    cluster - cluster names to find
  - getServers
```
public List<String> getServers(String iClusterName,
                               String iExclude)
```
    Returns the server list for the requested cluster cluster excluding any tags like and iExclude if any.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
    
    iExclude - Node to exclude
  - getMasterServers
```
public List<String> getMasterServers()
```
    Returns an ordered list of master server. The first in the list is the first found in configuration. This is used to determine the cluster leader.
  - getAllConfiguredServers
```
public Set<String> getAllConfiguredServers()
```
    Returns the complete list of servers found in configuration.
  - getClustersOnServer
```
public Set<String> getClustersOnServer(String iNodeName)
```
    Returns the set of clusters managed by a server.
    
    Parameters:
    
    iNodeName - Server name
  - getClustersOwnedByServer
```
public Set<String> getClustersOwnedByServer(String iNodeName)
```
    Returns the set of clusters where server is the owner.
    
    Parameters:
    
    iNodeName - Server name
  - getClusterOwner
```
public String getClusterOwner(String iClusterName)
```
    Returns the owner server for the given cluster excluding the passed node. The Owner server is the first in server list.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
  - getConfiguredClusterOwner
```
public String getConfiguredClusterOwner(String iClusterName)
```
    Returns the static owner server for the given cluster.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
  - getConfiguredServers
```
public List<String> getConfiguredServers(String iClusterName)
```
    Returns the configured server list for the requested cluster.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
  - getClusterNames
```
public String[] getClusterNames()
```
    Returns the array of configured clusters
  - getDefaultServerRole
```
public ODistributedConfiguration.ROLES getDefaultServerRole()
```
    Returns the default server role between MASTER (default) and REPLICA.
  - getServerRole
```
public ODistributedConfiguration.ROLES getServerRole(String iServerName)
```
    Returns the server role between MASTER (default) and REPLICA.
  - getRegisteredServers
```
public Set<String> getRegisteredServers()
```
    Returns the registered servers.
  - getDocument
```
public ODocument getDocument()
```
  - getDataCenters
```
public Set<String> getDataCenters()
```
    Returns all the configured data centers' names, if any.
  - getDataCenterWriteQuorum
```
public int getDataCenterWriteQuorum(String dataCenter)
```
    Returns the data center write quorum.
    
    Parameters:
    
    dataCenter - Data center name
  - isSharded
```
public boolean isSharded()
```
    Returns true if the database is sharded across servers. False if it's completely replicated.
  - getDataCenterServers
```
public List<String> getDataCenterServers(String dataCenter)
```
    Returns the list of servers in a data center.
    
    Parameters:
    
    dataCenter - Data center name
    
    Throws:
    
    OConfigurationException - if the list of servers is not found in data center configuration
  - getDataCenterOfServer
```
public String getDataCenterOfServer(String server)
```
    Returns the data center where the server belongs.
    
    Parameters:
    
    server - Server name
  - getVersion
```
public int getVersion()
```
  - isLocalDataCenterWriteQuorum
```
public boolean isLocalDataCenterWriteQuorum()
```
    Returns true if the global write quorum is "localDataCenter".
  - getGlobalReadQuorum
```
public Object getGlobalReadQuorum(String iClusterName)
```
    Returns the global read quorum.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
  - getReadQuorum
```
public int getReadQuorum(String clusterName,
                         int totalConfiguredServers,
                         String server)
```
    Returns the read quorum.
    
    Parameters:
    
    clusterName - Cluster name, or null for *
    
    totalConfiguredServers - Total node available
  - getWriteQuorum
```
public int getWriteQuorum(String clusterName,
                          int totalConfiguredMasterServers,
                          String server)
```
    Returns the write quorum.
    
    Parameters:
    
    clusterName - Cluster name, or null for *
    
    totalConfiguredMasterServers - Total node available
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - getClusterConfiguration
```
protected ODocument getClusterConfiguration(String iClusterName)
```
    Gets the document representing the cluster configuration.
    
    Parameters:
    
    iClusterName - Cluster name, or null for *
    
    Returns:
    
    Always a ODocument
    
    Throws:
    
    OConfigurationException - in case "clusters" field is not found in configuration
  - forceWriteQuorum
```
public void forceWriteQuorum(int quorum)
```
  - clearForceWriteQuorum
```
public void clearForceWriteQuorum()
```

Class ODistributedConfiguration

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

NEW_NODE_TAG

ALL_WILDCARD

SERVERS

DCS

OWNER

CLUSTERS

VERSION

AUTO_DEPLOY

READ_QUORUM

WRITE_QUORUM

QUORUM_MAJORITY

QUORUM_ALL

QUORUM_LOCAL_DC

DEFAULT_READ_QUORUM

DEFAULT_WRITE_QUORUM

NEW_NODE_STRATEGY

READ_YOUR_WRITES

EXECUTION_MODE

EXECUTION_MODE_SYNCHRONOUS

configuration

DEFAULT_CLUSTER_NAME

Constructor Detail

ODistributedConfiguration

Method Detail

modify

isReplicationActive

hasDataCenterConfiguration

isAutoDeploy

getNewNodeStrategy

isExecutionModeSynchronous

isReadYourWrites

getServerClusterMap

getOwnedClustersByServer

getServers

isServerContainingAllClusters

isServerContainingCluster

getServers

getMasterServers

getAllConfiguredServers

getClustersOnServer

getClustersOwnedByServer

getClusterOwner

getConfiguredClusterOwner

getConfiguredServers

getClusterNames

getDefaultServerRole

getServerRole

getRegisteredServers

getDocument

getDataCenters

getDataCenterWriteQuorum

isSharded

getDataCenterServers

getDataCenterOfServer

getVersion

isLocalDataCenterWriteQuorum

getGlobalReadQuorum

getReadQuorum

getWriteQuorum

toString

getClusterConfiguration

forceWriteQuorum

clearForceWriteQuorum