Uses of Class
com.orientechnologies.orient.core.id.ONodeId

Packages that use ONodeId

Package	Description
com.orientechnologies.agent.operation
com.orientechnologies.orient.client.remote
com.orientechnologies.orient.core.db
com.orientechnologies.orient.core.db.config
com.orientechnologies.orient.core.id
com.orientechnologies.orient.core.metadata.schema
com.orientechnologies.orient.core.sql.executor
com.orientechnologies.orient.core.sql.parser
com.orientechnologies.orient.core.transaction
com.orientechnologies.orient.distributed
com.orientechnologies.orient.distributed.context
com.orientechnologies.orient.distributed.context.coordination
com.orientechnologies.orient.distributed.context.coordination.action
com.orientechnologies.orient.distributed.context.coordination.dbs
com.orientechnologies.orient.distributed.context.coordination.message
com.orientechnologies.orient.distributed.context.coordination.message.operation
com.orientechnologies.orient.distributed.context.coordination.message.state
com.orientechnologies.orient.distributed.context.coordination.result
com.orientechnologies.orient.distributed.context.coordination.sync
com.orientechnologies.orient.distributed.context.coordination.topology
com.orientechnologies.orient.distributed.context.retryable
com.orientechnologies.orient.distributed.db
com.orientechnologies.orient.server
com.orientechnologies.orient.server.distributed
com.orientechnologies.orient.server.distributed.impl
com.orientechnologies.orient.server.distributed.impl.task
com.orientechnologies.orient.server.hazelcast

Uses of ONodeId in com.orientechnologies.agent.operation

Methods in com.orientechnologies.agent.operation that return ONodeId

Modifier and Type	Method	Description
ONodeId	OperationResponseFromNode.getSenderNodeId()

Methods in com.orientechnologies.agent.operation that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	OperationResponseManager.getExpectedNodes()
List<ONodeId>	OperationResponseManager.getMissingNodes()
List<ONodeId>	OperationResponseManager.getRespondingNodes()

Methods in com.orientechnologies.agent.operation with parameters of type ONodeId

Modifier and Type	Method	Description
void	OperationResponseManager.removeServerBecauseUnreachable(ONodeId node)
boolean	OperationResponseManager.setLocalResult(ONodeId localNodeName, Object localResult)

Constructors in com.orientechnologies.agent.operation with parameters of type ONodeId

Modifier	Constructor	Description
	OperationResponseFromNode(ONodeId senderNodeName, NodeResponse nodeResponse)

Constructor parameters in com.orientechnologies.agent.operation with type arguments of type ONodeId

Modifier	Constructor	Description
	OperationResponseManager(Set<ONodeId> servers)

Uses of ONodeId in com.orientechnologies.orient.client.remote

Methods in com.orientechnologies.orient.client.remote that return ONodeId

Modifier and Type	Method	Description
ONodeId	OrientDBRemote.getNodeId()

Uses of ONodeId in com.orientechnologies.orient.core.db

Methods in com.orientechnologies.orient.core.db that return ONodeId

Modifier and Type	Method	Description
ONodeId	OrientDBEmbedded.getNodeId()
ONodeId	OrientDBEmbedded.getNodeId(String nodeName)
ONodeId	OrientDBInternal.getNodeId()
default ONodeId	OrientDBInternal.getNodeId(String nodeString)
ONodeId	OrientDBEmbedded.resolveNodeId(String name)

Methods in com.orientechnologies.orient.core.db with parameters of type ONodeId

Modifier and Type	Method	Description
default OExecutionStream	ODatabaseDocumentInternal.queryOnNode(ONodeId nodeName, OInternalExecutionPlan executionPlan, Map<Object,Object> inputParameters)	sends an execution plan to a remote node for a remote query execution

Uses of ONodeId in com.orientechnologies.orient.core.db.config

Methods in com.orientechnologies.orient.core.db.config that return ONodeId

Modifier and Type	Method	Description
ONodeId	OAddNodeInfo.node()	Returns the value of the node record component.

Methods in com.orientechnologies.orient.core.db.config with parameters of type ONodeId

Modifier and Type	Method	Description
static OAddNodeInfo	OAddNodeInfo.main(ONodeId node)

Constructors in com.orientechnologies.orient.core.db.config with parameters of type ONodeId

Modifier	Constructor	Description
	OAddNodeInfo(ONodeId node, ONodeRole role)	Creates an instance of a OAddNodeInfo record class.

Uses of ONodeId in com.orientechnologies.orient.core.id

Methods in com.orientechnologies.orient.core.id that return ONodeId

Modifier and Type	Method	Description
static ONodeId	ONodeId.readElement(OElement e)
static ONodeId	ONodeId.readNetwork(DataInput input)
static ONodeId	ONodeId.readResult(OResult e)

Methods in com.orientechnologies.orient.core.id with parameters of type ONodeId

Modifier and Type	Method	Description
int	ONodeId.compareTo(ONodeId o)

Uses of ONodeId in com.orientechnologies.orient.core.metadata.schema

Method parameters in com.orientechnologies.orient.core.metadata.schema with type arguments of type ONodeId

Modifier and Type	Method	Description
void	OClassEmbedded.autoAssignClusterOwnership(ODatabaseDocumentInternal db, Set<ONodeId> availableNodes, boolean canCreateNewClusters)
protected void	OClassEmbedded.reassignClusters(ODatabaseDocumentInternal db, Set<ONodeId> availableNodes, Set<String> clusterNames)

Uses of ONodeId in com.orientechnologies.orient.core.sql.executor

Fields in com.orientechnologies.orient.core.sql.executor with type parameters of type ONodeId

Modifier and Type	Field	Description
protected Map<ONodeId,OSelectExecutionPlan>	QueryPlanningInfo.distributedFetchExecutionPlans
protected Map<ONodeId,Set<String>>	QueryPlanningInfo.serverToClusters	in a sharded execution plan, this maps the single server to the clusters it will be queried for to execute the query.

Constructors in com.orientechnologies.orient.core.sql.executor with parameters of type ONodeId

Modifier	Constructor	Description
	DistributedExecutionStep(OSelectExecutionPlan subExecutionPlan, ONodeId nodeName)

Uses of ONodeId in com.orientechnologies.orient.core.sql.parser

Methods in com.orientechnologies.orient.core.sql.parser that return ONodeId

Modifier and Type	Method	Description
ONodeId	ONodeData.getNodeId(OAdminCommandContext ctx)

Uses of ONodeId in com.orientechnologies.orient.core.transaction

Methods in com.orientechnologies.orient.core.transaction that return ONodeId

Modifier and Type	Method	Description
ONodeId	OTransactionIdPromise.getCoordinator()

Methods in com.orientechnologies.orient.core.transaction with parameters of type ONodeId

Modifier and Type	Method	Description
void	OSequenceNodes.nodeUpdate(ONodeId nodeId, long newValue)
OTransactionIdPromise	OTransactionIdPromise.retrySequence(ONodeId node)
void	OMinimumSequenceStatus.updateNode(ONodeId nodeID, long[] sequences)

Constructors in com.orientechnologies.orient.core.transaction with parameters of type ONodeId

Modifier	Constructor	Description
	ODistributedSynchronizedSequence(ONodeId node, int size)
	OTransactionIdPromise(ONodeId node, OTransactionId id)
	OTransactionIdPromise(ONodeId node, OTransactionId id, int recoverSequence)
	OTransactionSequenceManager(ONodeId coordinator, int size)

Uses of ONodeId in com.orientechnologies.orient.distributed

Methods in com.orientechnologies.orient.distributed that return ONodeId

Modifier and Type	Method	Description
ONodeId	ONodeConfig.getNodeId()
ONodeId	ONodeLatencies.node()	Returns the value of the node record component.

Methods in com.orientechnologies.orient.distributed with parameters of type ONodeId

Modifier and Type	Method	Description
void	ONodeConfig.setNodeId(ONodeId nodeId)

Constructors in com.orientechnologies.orient.distributed with parameters of type ONodeId

Modifier	Constructor	Description
	ONodeConfig(ONodeId nodeIdPar)
	ONodeLatencies(ONodeId node, OProfilerEntrySnapshot stats)	Creates an instance of a ONodeLatencies record class.

Uses of ONodeId in com.orientechnologies.orient.distributed.context

Methods in com.orientechnologies.orient.distributed.context that return ONodeId

Modifier and Type	Method	Description
ONodeId	ODistributedResponse.getNode()
ONodeId	ONodeStats.getNode()
ONodeId	ONodeState.getNodeId()
ONodeId	ODatabaseNodeStore.id()	Returns the value of the id record component.

Methods in com.orientechnologies.orient.distributed.context that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	ONodeState.getNetworkMembers()
Set<ONodeId>	ONetworkTopologyStore.members()	Returns the value of the members record component.

Methods in com.orientechnologies.orient.distributed.context with parameters of type ONodeId

Modifier and Type	Method	Description
void	ONodeState.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
Optional<ONodeStats>	OStatsManager.getStats(ONodeId node)
void	OStatsManager.receiveStats(ONodeId nodeId, long bootTime, long maxMem, long totMem, long freeMem, long usedMem, List<ONodeLatencies> nodesLatencies, List<ONodeMessages> nodesMessages)
void	ONodeState.success(ONodeId node, OTransactionIdPromise promise)

Constructors in com.orientechnologies.orient.distributed.context with parameters of type ONodeId

Modifier	Constructor	Description
	ODatabaseNodeStore(ONodeId id, ONodeRole role)	Creates an instance of a ODatabaseNodeStore record class.
	ONodeState(ONodeId current, OGroupId groupId, int minimumQuorum, OStateStore store, ODatabaseStateChangeListener listener)
	ONodeStats(ONodeId node)

Constructor parameters in com.orientechnologies.orient.distributed.context with type arguments of type ONodeId

Modifier	Constructor	Description
	ONetworkTopologyStore(OGroupId groupId, OTopologyState state, Set<ONodeId> members, int quorum, OVersion version)	Creates an instance of a ONetworkTopologyStore record class.

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination

Methods in com.orientechnologies.orient.distributed.context.coordination that return ONodeId

Modifier and Type	Method	Description
ONodeId	OCoordinatedDistributedOps.getCurrent()
ONodeId	OCoordinatedDistributedOpsImpl.getCurrent()

Methods in com.orientechnologies.orient.distributed.context.coordination that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	OCoordinatedDistributedOps.checkOffline(long time)
Set<ONodeId>	OCoordinatedDistributedOpsImpl.checkOffline(long time)
Set<ONodeId>	OCoordinatedDistributedOps.establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Set<ONodeId>	OCoordinatedDistributedOpsImpl.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Set<ONodeId>	OResponseCollectorImpl.getExpected()
Set<ONodeId>	OResponseCollectorMerge.getExpected()
Set<ONodeId>	ONetworkTopology.getMembers()
Optional<ONodeId>	ONetworkTopology.getNodeId(String nodeName)
Set<ONodeId>	OOperationStart.nodes()	Returns the value of the nodes record component.
Set<ONodeId>	OResponseCollector.CompleteInfo.nodes()	Returns the value of the nodes record component.

Methods in com.orientechnologies.orient.distributed.context.coordination with parameters of type ONodeId

Modifier and Type	Method	Description
boolean	OCoordinatedDistributedOps.acceptSync(ONodeId sender, OSyncId syncId)
boolean	OCoordinatedDistributedOpsImpl.acceptSync(ONodeId sender, OSyncId syncId)
void	OCoordinatedDistributedOps.cancelMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
Optional<OCanSyncResult>	OCoordinatedDistributedOps.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
Optional<OCanSyncResult>	OCoordinatedDistributedOpsImpl.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
Optional<OResponseCollector.CompleteInfo>	OResponseCollector.disconnected(ONodeId node)
Optional<OResponseCollector.CompleteInfo>	OResponseCollectorImpl.disconnected(ONodeId node)
Optional<OResponseCollector.CompleteInfo>	OResponseCollectorMerge.disconnected(ONodeId node)
ODiscoverAction	OCoordinatedDistributedOps.discoverNode(ONodeId node)
ODiscoverAction	OCoordinatedDistributedOpsImpl.discoverNode(ONodeId node)
Optional<OResponseCollector.CompleteInfo>	OResponseCollector.fail(ONodeId node, OAcceptResult acceptResult)
Optional<OResponseCollector.CompleteInfo>	OResponseCollectorImpl.fail(ONodeId node, OAcceptResult acceptResult)
Optional<OResponseCollector.CompleteInfo>	OResponseCollectorMerge.fail(ONodeId node, OAcceptResult acceptResult)
Optional<Map<OTransactionId,ODistributedMessage>>	OPromisedDistributedOps.getPromised(ONodeId node)
Optional<Map<OTransactionId,ODistributedMessage>>	OPromisedDistributedOpsImpl.getPromised(ONodeId node)
void	OCoordinatedDistributedOps.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
ODisconnectAction	OCoordinatedDistributedOps.nodeDisconnected(ONodeId node)
ODisconnectAction	OCoordinatedDistributedOpsImpl.nodeDisconnected(ONodeId node)
ODisconnectAction	OPromisedDistributedOps.nodeDisconnected(ONodeId node)
ODisconnectAction	OPromisedDistributedOpsImpl.nodeDisconnected(ONodeId node)
void	OCoordinatedDistributedOps.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
void	OCoordinatedDistributedOpsImpl.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODiscoverAction	OCoordinatedDistributedOps.nodeJoinStart(ONodeId node, ONodeStateNetwork state, boolean merge)
ODiscoverAction	OCoordinatedDistributedOpsImpl.nodeJoinStart(ONodeId node, ONodeStateNetwork state, boolean merge)
void	OCoordinatedDistributedOps.nodeMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	OCoordinatedDistributedOpsImpl.nodeMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	OCoordinatedDistributedOps.nodeSuccess(ONodeId node, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.nodeSuccess(ONodeId node, OTransactionIdPromise promise)
Optional<OResponseCollector.CompleteInfo>	OResponseCollector.receive(ONodeId node)
Optional<OResponseCollector.CompleteInfo>	OResponseCollectorImpl.receive(ONodeId node)
Optional<OResponseCollector.CompleteInfo>	OResponseCollectorMerge.receive(ONodeId node)
List<OTransactionId>	OCoordinatedDistributedOps.receivePing(ONodeId nodeId, OTransactionSequenceStatus status)
List<OTransactionId>	OCoordinatedDistributedOpsImpl.receivePing(ONodeId nodeId, OTransactionSequenceStatus status)
void	OCoordinatedDistributedOps.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
Optional<OSyncState>	OCoordinatedDistributedOps.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode)
Optional<OSyncState>	OCoordinatedDistributedOpsImpl.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode)
ODisconnectAction	OCoordinatedDistributedOps.unregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
ODisconnectAction	OCoordinatedDistributedOpsImpl.unregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateRegisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateRegisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateUnregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateUnregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
boolean	OCoordinatedDistributedOps.waitNodeJoined(ONodeId dbId, Optional<Long> timeout)
boolean	OCoordinatedDistributedOpsImpl.waitNodeJoined(ONodeId dbId, Optional<Long> timeout)

Method parameters in com.orientechnologies.orient.distributed.context.coordination with type arguments of type ONodeId

Modifier and Type	Method	Description
void	OCoordinatedDistributedOps.cancelRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.cancelRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OTransactionIdPromise promise)
Set<ONodeId>	OCoordinatedDistributedOps.establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Set<ONodeId>	OCoordinatedDistributedOpsImpl.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	OCoordinatedDistributedOps.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	OCoordinatedDistributedOpsImpl.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OTransactionIdPromise>	OCoordinatedDistributedOps.startEstablish(Set<ONodeId> nodes, OCompleteAction action)
Optional<OTransactionIdPromise>	OCoordinatedDistributedOpsImpl.startEstablish(Set<ONodeId> nodes, OCompleteAction action)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateEstablish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOps.validateRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OCoordinatedDistributedOpsImpl.validateRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)

Constructors in com.orientechnologies.orient.distributed.context.coordination with parameters of type ONodeId

Modifier	Constructor	Description
	OCoordinatedDistributedOpsImpl(ONodeId current, OGroupId groupId, int minimumQuorum, ODatabaseStateChangeListener listener, ONodeStateUpdated updateLister)
	OResponseCollectorMerge(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes, ONodeId mergeNode)
	OVersionPromise(OVersion version, ONodeId current, String context)

Constructor parameters in com.orientechnologies.orient.distributed.context.coordination with type arguments of type ONodeId

Modifier	Constructor	Description
	CompleteInfo(OCompleteAction action, OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)	Creates an instance of a CompleteInfo record class.
	OOperationStart(OTransactionIdPromise promise, Set<ONodeId> nodes)	Creates an instance of a OOperationStart record class.
	OResponseCollectorImpl(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> activeNodes)
	OResponseCollectorMerge(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes, ONodeId mergeNode)

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.action

Method parameters in com.orientechnologies.orient.distributed.context.coordination.action with type arguments of type ONodeId

Modifier and Type	Method	Description
void	OCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)
void	ORecoordinateCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)
void	OStandardCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result)
void	OCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> optional)
void	OMergeCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result)
void	ORecoordinateCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result)
void	OStandardCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result)
OResponseCollector	OCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
OResponseCollector	OMergeCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
OResponseCollector	ORecoordinateCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
OResponseCollector	OStandardCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes)
void	OCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)
void	OMergeCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)
void	ORecoordinateCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)
void	OStandardCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all)

Constructors in com.orientechnologies.orient.distributed.context.coordination.action with parameters of type ONodeId

Modifier	Constructor	Description
	OMergeCompleteAction(OrientDBDistributed context, OOperationMessage operation, ONodeStateNetwork mergedState, ONodeStateNetwork original, OCompleteExecution execution, ONodeId mergeNode)

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.dbs

Methods in com.orientechnologies.orient.distributed.context.coordination.dbs that return ONodeId

Modifier and Type	Method	Description
ONodeId	ONodeDatabaseState.getId()

Methods in com.orientechnologies.orient.distributed.context.coordination.dbs that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	ODatabasesTopology.getMembers(ODatabaseId databaseId)
Set<ONodeId>	ODatabasesTopologyState.getMembers(ODatabaseId databaseId)
Set<ONodeId>	ODatabaseTopologyState.getMembers()
Set<ONodeId>	ODatabasesTopology.getOnlineNodes(ODatabaseId dbId)
Set<ONodeId>	ODatabasesTopologyState.getOnlineNodes(ODatabaseId dbId)
Set<ONodeId>	ODatabaseTopologyState.getOnlineNodes()
Set<ONodeId>	OCanSyncResult.others()	Returns the value of the others record component.

Methods in com.orientechnologies.orient.distributed.context.coordination.dbs with parameters of type ONodeId

Modifier and Type	Method	Description
boolean	ODatabasesTopologyState.acceptSync(ONodeId sender, OSyncId syncId)
boolean	ODatabaseTopologyState.acceptSync(ONodeId sender, OSyncId syncId)
void	ODatabaseTopologyState.cancelRole(ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.cancelSetState(ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
Optional<OCanSyncResult>	ODatabasesTopologyState.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
Optional<OCanSyncResult>	ODatabaseTopologyState.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
ONodeRole	ODatabasesTopology.getRole(ODatabaseId dbId, ONodeId node)
ONodeRole	ODatabasesTopologyState.getRole(ODatabaseId dbId, ONodeId nodeId)
ONodeRole	ODatabaseTopologyState.getRole(ONodeId nodeId)
ODatabaseState	ODatabasesTopology.getState(ODatabaseId dbId, ONodeId node)
ODatabaseState	ODatabasesTopologyState.getState(ODatabaseId dbId, ONodeId nodeID)
ODatabaseState	ODatabaseTopologyState.getState(ONodeId nodeId)
boolean	ODatabasesTopology.isMain(ODatabaseId dbId, ONodeId node)
boolean	ODatabasesTopologyState.isMain(ODatabaseId dbId, ONodeId nodeId)
boolean	ODatabaseTopologyState.isMain(ONodeId nodeId)
boolean	ODatabasesTopology.isOnline(ODatabaseId dbId, ONodeId nodeID)
boolean	ODatabasesTopologyState.isOnline(ODatabaseId dbId, ONodeId nodeID)
void	ODatabasesTopologyState.nodeDisconnected(ONodeId node)
void	ODatabaseTopologyState.nodeDisconnected(ONodeId node)
void	ODatabaseStateChangeListener.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state)
Optional<OAcceptResult>	ODatabaseTopologyState.promiseState(ODatabaseState state, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.setRole(ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.setState(ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
boolean	ODatabasesTopology.shouldSink(ODatabaseId dbId, ONodeId nodeID)
boolean	ODatabasesTopologyState.shouldSink(ODatabaseId dbId, ONodeId nodeID)
boolean	ODatabaseTopologyState.shouldSink(ONodeId nodeID)
Optional<OSyncState>	ODatabasesTopologyState.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode)
Optional<OSyncState>	ODatabaseTopologyState.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode)
Optional<OAcceptResult>	ODatabaseTopologyState.validateRole(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise)

Method parameters in com.orientechnologies.orient.distributed.context.coordination.dbs with type arguments of type ONodeId

Modifier and Type	Method	Description
Optional<OAcceptResult>	ODatabaseTopologyState.promiseRemoveMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	ODatabasesTopologyState.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	ODatabaseTopologyState.removeMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	ODatabasesTopologyState.validateRemoveMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)

Constructors in com.orientechnologies.orient.distributed.context.coordination.dbs with parameters of type ONodeId

Modifier	Constructor	Description
	ODatabasesTopologyState(ODatabaseStateChangeListener listener, ONodeId current)
	ODatabaseTopologyState(ODatabaseId db, String name, Set<OAddNodeInfo> partecipants, int quorum, ODatabaseStateChangeListener stateListener, ONodeId current)
	ODatabaseTopologyState(ODatabaseStateChangeListener listener, ODatabaseTopologyStore store, ONodeId current)
	ODatabaseTopologyState(ODatabaseStateNetwork state, ODatabaseStateChangeListener stateListener, ONodeId current)
	ONodeDatabaseState(ONodeId node, ONodeRole role, ODatabaseState state)

Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.dbs with type arguments of type ONodeId

Modifier	Constructor	Description
	OCanSyncResult(OSyncState state, Set<ONodeId> others)	Creates an instance of a OCanSyncResult record class.

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.message

Methods in com.orientechnologies.orient.distributed.context.coordination.message that return ONodeId

Modifier and Type	Method	Description
ONodeId	OMergeResult.getNode()
ONodeId	OFailPropose.getNodeId()
ONodeId	ONodeFirstConnect.getNodeId()
ONodeId	ONodeStatsNotify.getNodeId()
ONodeId	OSendTransactions.getNodeId()
ONodeId	OSuccessPropose.getNodeId()
ONodeId	OTopologyPing.getNodeId()
ONodeId	OCanSync.getSender()

Constructors in com.orientechnologies.orient.distributed.context.coordination.message with parameters of type ONodeId

Modifier	Constructor	Description
	OCanSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
	OFailPropose(ONodeId nodeId, OTransactionIdPromise promise, OAcceptResult acceptResult)
	OMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
	ONodeFirstConnect(ONodeId nodeId, ONodeInfo info, ONodeStateNetwork state, boolean merge)
	ONodeStatsNotify(ONodeId nodeId, long bootTime, long maxMem, long totMem, long freeMem, long usedMem, List<ONodeLatencies> nodesLatencies, List<ONodeMessages> nodesMessages)
	OSendTransactions(ONodeId nodeId, List<OTransactionId> transactions)
	OSuccessPropose(ONodeId nodeId, OTransactionIdPromise promise)
	OTopologyPing(ONodeId nodeId, OTransactionSequenceStatus status)

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.message.operation

Methods in com.orientechnologies.orient.distributed.context.coordination.message.operation that return ONodeId

Modifier and Type	Method	Description
ONodeId	OAddTopologyMember.getNode()
ONodeId	OMergeNode.getNode()
ONodeId	ORemoveTopologyMember.getNode()
ONodeId	OSetDatabaseMemberRole.getNode()
ONodeId	OSetDatabaseState.getNodeId()

Methods in com.orientechnologies.orient.distributed.context.coordination.message.operation that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	OEstablishTopology.getCandidates()
List<ONodeId>	ORemoveDatabaseMembers.getNodes()

Methods in com.orientechnologies.orient.distributed.context.coordination.message.operation with parameters of type ONodeId

Modifier and Type	Method	Description
void	OOperationContext.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OOperationContext.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)

Method parameters in com.orientechnologies.orient.distributed.context.coordination.message.operation with type arguments of type ONodeId

Modifier and Type	Method	Description
void	OOperationContext.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)

Constructors in com.orientechnologies.orient.distributed.context.coordination.message.operation with parameters of type ONodeId

Modifier	Constructor	Description
	OAddTopologyMember(OVersion version, ONodeId node)
	OMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original)
	ORemoveTopologyMember(ONodeId node, OVersion version)
	OSetDatabaseMemberRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version)
	OSetDatabaseState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version)

Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.message.operation with type arguments of type ONodeId

Modifier	Constructor	Description
	OEstablishTopology(OGroupId groupId, Set<ONodeId> candidates)
	ORemoveDatabaseMembers(ODatabaseId database, List<ONodeId> nodes, OVersion version)

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.message.state

Methods in com.orientechnologies.orient.distributed.context.coordination.message.state that return ONodeId

Modifier and Type	Method	Description
ONodeId	ODatabaseMemberNetwork.node()	Returns the value of the node record component.

Methods in com.orientechnologies.orient.distributed.context.coordination.message.state that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	OTopologyStateNetwork.members()	Returns the value of the members record component.

Constructors in com.orientechnologies.orient.distributed.context.coordination.message.state with parameters of type ONodeId

Modifier	Constructor	Description
	ODatabaseMemberNetwork(ONodeId node, ONodeRole role, ODatabaseState state)	Creates an instance of a ODatabaseMemberNetwork record class.

Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.message.state with type arguments of type ONodeId

Modifier	Constructor	Description
	OTopologyStateNetwork(OGroupId groupId, OTopologyState state, Set<ONodeId> members, int quorum, OVersion version)	Creates an instance of a OTopologyStateNetwork record class.

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.result

Methods in com.orientechnologies.orient.distributed.context.coordination.result that return ONodeId

Modifier and Type	Method	Description
ONodeId	ONodeAlreadyPresent.node()	Returns the value of the node record component.
ONodeId	OMissingNode.nodeId()	Returns the value of the nodeId record component.
ONodeId	OAlreadyPromised.promisedTo()	Returns the value of the promisedTo record component.

Constructors in com.orientechnologies.orient.distributed.context.coordination.result with parameters of type ONodeId

Modifier	Constructor	Description
	OAlreadyPromised(ONodeId promisedTo)	Creates an instance of a OAlreadyPromised record class.
	OMissingNode(ONodeId nodeId)	Creates an instance of a OMissingNode record class.
	ONodeAlreadyPresent(ODatabaseId db, ONodeId node)	Creates an instance of a ONodeAlreadyPresent record class.

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.sync

Methods in com.orientechnologies.orient.distributed.context.coordination.sync that return ONodeId

Modifier and Type	Method	Description
ONodeId	OSyncId.getReceiver()
ONodeId	OSyncState.getReceiver()
ONodeId	OSyncState.getSender()

Methods in com.orientechnologies.orient.distributed.context.coordination.sync that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	OSyncInfo.targets()	Returns the value of the targets record component.

Methods in com.orientechnologies.orient.distributed.context.coordination.sync with parameters of type ONodeId

Modifier and Type	Method	Description
Optional<OCanSyncResult>	OSyncSession.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
boolean	OSyncSession.nodeDisconnected(ONodeId node)
Optional<OSyncState>	OSyncSession.startSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)

Constructors in com.orientechnologies.orient.distributed.context.coordination.sync with parameters of type ONodeId

Modifier	Constructor	Description
	OSyncId(ODatabaseId dbId, ONodeId receiver)
	OSyncSession(ODatabaseId dbId, ONodeId current, Set<ONodeId> nodes)
	OSyncState(OSyncId syncId, ONodeId sender, OCanSyncAccept acceptMode)

Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.sync with type arguments of type ONodeId

Modifier	Constructor	Description
	OSyncInfo(OSyncId syncId, Set<ONodeId> targets, Future<Boolean> finished)	Creates an instance of a OSyncInfo record class.
	OSyncSession(ODatabaseId dbId, ONodeId current, Set<ONodeId> nodes)

Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.topology

Methods in com.orientechnologies.orient.distributed.context.coordination.topology that return ONodeId

Modifier and Type	Method	Description
ONodeId	OTopologyManager.getNodeId()
ONodeId	ODiscoverAction.OAddNodeAction.node()	Returns the value of the node record component.
ONodeId	ODiscoverAction.OMergeNodeAction.node()	Returns the value of the node record component.
ONodeId	ODiscoverAction.ORequestMergeAction.requestToMerge()	Returns the value of the requestToMerge record component.

Methods in com.orientechnologies.orient.distributed.context.coordination.topology that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	OTopologyManager.awayNodes(long time)
Set<ONodeId>	ODiscoverAction.OEstablishAction.candidates()	Returns the value of the candidates record component.
Set<ONodeId>	OTopologyManager.finalizeEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Set<ONodeId>	OTopologyManager.getMembers()
Optional<ONodeId>	OTopologyManager.getNodeId(String nodeName)
Set<ONodeId>	ODiscoverAction.ONotifySelf.nodes()	Returns the value of the nodes record component.

Methods in com.orientechnologies.orient.distributed.context.coordination.topology with parameters of type ONodeId

Modifier and Type	Method	Description
protected boolean	OTopologyManager.hasMember(ONodeId node)
void	OTopologyManager.mergeNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
ODiscoverAction	OTopologyEvents.nodeDiscovered(ONodeId node)
ODiscoverAction	OTopologyManager.nodeDiscovered(ONodeId node)
ODiscoverAction	OTopologyManager.nodeJoinStart(ONodeId node, OTopologyStateNetwork externState, boolean merge)
void	OTopologyManager.ping(ONodeId node)
Optional<OAcceptResult>	OTopologyManager.promiseRegister(ONodeId toAdd, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.promiseUnregister(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	OTopologyManager.register(ONodeId toRegister, OVersion version, OTransactionIdPromise promise)
void	OTopologyManager.unregister(ONodeId node, OVersion version, OTransactionIdPromise promise)
boolean	OTopologyManager.waitNodeJoined(ONodeId node, Optional<Long> timeout)

Method parameters in com.orientechnologies.orient.distributed.context.coordination.topology with type arguments of type ONodeId

Modifier and Type	Method	Description
void	OOperationMessageSender.establish(Set<ONodeId> nodes, OOperationMessage message)
Set<ONodeId>	OTopologyManager.finalizeEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	OTopologyManager.validateEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)

Constructors in com.orientechnologies.orient.distributed.context.coordination.topology with parameters of type ONodeId

Modifier	Constructor	Description
	OAddNodeAction(ONodeId node)	Creates an instance of a OAddNodeAction record class.
	OMergeNodeAction(ONodeId node)	Creates an instance of a OMergeNodeAction record class.
	ORequestMergeAction(ONodeId requestToMerge)	Creates an instance of a ORequestMergeAction record class.
	OTopologyManager(ONodeId current, OGroupId groupId, int minimumQuorum)

Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.topology with type arguments of type ONodeId

Modifier	Constructor	Description
	OEstablishAction(OGroupId groupId, Set<ONodeId> candidates)	Creates an instance of a OEstablishAction record class.
	ONotifySelf(Set<ONodeId> nodes)	Creates an instance of a ONotifySelf record class.

Uses of ONodeId in com.orientechnologies.orient.distributed.context.retryable

Methods in com.orientechnologies.orient.distributed.context.retryable that return ONodeId

Modifier and Type	Method	Description
ONodeId	OSetDatabaseNodeRoleRetryOperation.node()	Returns the value of the node record component.
ONodeId	OSetDatabaseStateRetryOperation.node()	Returns the value of the node record component.

Methods in com.orientechnologies.orient.distributed.context.retryable that return types with arguments of type ONodeId

Modifier and Type	Method	Description
List<ONodeId>	ORemoveMemberRetryOperation.nodes()	Returns the value of the nodes record component.

Constructors in com.orientechnologies.orient.distributed.context.retryable with parameters of type ONodeId

Modifier	Constructor	Description
	OSetDatabaseNodeRoleRetryOperation(ODatabaseId dbId, ONodeId node, ONodeRole role)	Creates an instance of a OSetDatabaseNodeRoleRetryOperation record class.
	OSetDatabaseStateRetryOperation(ONodeId node, ODatabaseId dbId, ODatabaseState state)	Creates an instance of a OSetDatabaseStateRetryOperation record class.

Constructor parameters in com.orientechnologies.orient.distributed.context.retryable with type arguments of type ONodeId

Modifier	Constructor	Description
	ORemoveMemberRetryOperation(ODatabaseId databaseId, List<ONodeId> nodes)	Creates an instance of a ORemoveMemberRetryOperation record class.

Uses of ONodeId in com.orientechnologies.orient.distributed.db

Methods in com.orientechnologies.orient.distributed.db that return ONodeId

Modifier and Type	Method	Description
ONodeId	OrientDBDistributed.getNodeId()
ONodeId	OrientDBDistributed.getNodeId(String name)
ONodeId	OrientDBDistributed.resolveNodeId(String name)

Methods in com.orientechnologies.orient.distributed.db that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	OrientDBDistributed.getAvailableNodeIds(String name)
Set<ONodeId>	OrientDBDistributed.getAvailableNodeNotLocalIds(String name)
Set<ONodeId>	OrientDBDistributed.getOnlineMainsId(ODatabaseId db)
List<ONodeId>	OrientDBDistributed.getOnlineNodesNotLocalId(String dbName)

Methods in com.orientechnologies.orient.distributed.db with parameters of type ONodeId

Modifier and Type	Method	Description
void	OrientDBDistributed.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
void	OrientDBDistributed.checkNodeIsMaster(ONodeId localNodeId, String name, String operation)
void	OrientDBDistributed.closeRemoteServer(ONodeId node)
void	ONetworkDiscover.connected(ONodeId node, String host)
void	OrientDBDistributed.connected(ONodeId node, String url)
ORemoteServerController	OrientDBDistributed.connectRemoteServer(ONodeId node, String url)
void	OrientDBDistributed.disconnected(ONodeId node)
void	OrientDBDistributed.firstConnect(ONodeId nodeId, ONodeStateNetwork state, boolean merge, ONodeInfo info)
ODatabaseState	OrientDBDistributed.getDatabaseState(ODatabaseId dbId, ONodeId node)
ODistributedServerManager.DB_STATUS	OrientDBDistributed.getDatabaseStatus(ONodeId nodeId, String dbName)
ONodeConfig	OrientDBDistributed.getNodeConfiguration(ONodeId member)
ORemoteServerController	OrientDBDistributed.getRemoteServer(ONodeId nodeId)
boolean	OrientDBDistributed.isNodeMaster(ONodeId node, String databaseName)
void	OrientDBDistributed.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	OrientDBDistributed.mergeNodeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	OrientDBDistributed.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state)
void	OrientDBDistributed.receivePing(ONodeId nodeId, OTransactionSequenceStatus status)
void	OrientDBDistributed.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
boolean	OrientDBDistributed.removeDatabaseMember(ODatabaseId databaseId, ONodeId node)
void	OrientDBDistributed.retryMergeOperationMessages(ONodeId mergeNode, ONodeStateNetwork mergedState, ONodeStateNetwork original, OOperationMessage operation, OCompleteAction action, int delay)
void	OrientDBDistributed.sendMergeNodeAction(ONodeId node, ONodeStateNetwork state, OCompleteExecution execution)
void	OrientDBDistributed.sendMergeOperation(ONodeId requestToMerge, OCompleteExecution execution)
void	OrientDBDistributed.sendMessage(ONodeId node, OStructuralMessage op)
void	OrientDBDistributed.sendTopologyTransactions(ONodeId nodeId, List<OTransactionId> transactions)
void	OrientDBDistributed.setDatabaseStatus(ONodeId nodeId, String dbName, ODistributedServerManager.DB_STATUS status)

Method parameters in com.orientechnologies.orient.distributed.db with type arguments of type ONodeId

Modifier and Type	Method	Description
void	OrientDBDistributed.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
int	OrientDBDistributed.getNodesWithStatus(Collection<ONodeId> iNodes, String databaseName, ODistributedServerManager.DB_STATUS... statuses)	Returns the nodes with the requested status.
void	OrientDBDistributed.sendEstablish(OGroupId groupId, Set<ONodeId> candidates, OCompleteExecution execution)
void	OrientDBDistributed.sendFirstConnects(Set<ONodeId> nodes)
void	OrientDBDistributed.sendMessage(Set<ONodeId> set, OStructuralMessage op)

Uses of ONodeId in com.orientechnologies.orient.server

Methods in com.orientechnologies.orient.server that return ONodeId

Modifier and Type	Method	Description
ONodeId	OServer.getNodeId()

Uses of ONodeId in com.orientechnologies.orient.server.distributed

Methods in com.orientechnologies.orient.server.distributed that return ONodeId

Modifier and Type	Method	Description
ONodeId	ODistributedResponse.getExecutorNodeName()
ONodeId	ODistributedRequestId.getNodeId()
ONodeId	ODistributedResponse.getSenderNodeName()
ONodeId	ORemoteServerChannel.getServer()

Methods in com.orientechnologies.orient.server.distributed that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	ODistributedResponseManager.getExpectedNodes()
Set<ONodeId>	ODistributedResponseManagerImpl.getExpectedNodes()
List<ONodeId>	ODistributedResponseManager.getMissingNodes()
List<ONodeId>	ODistributedResponseManagerImpl.getMissingNodes()	Returns the list of node names that didn't provide a response.
Set<ONodeId>	ODistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, String databaseName, ODistributedRequest request, Collection<ONodeId> iNodes)
List<ONodeId>	ODistributedResponseManager.getRespondingNodes()
List<ONodeId>	ODistributedResponseManagerImpl.getRespondingNodes()	Returns the list of node names that provided a response.

Methods in com.orientechnologies.orient.server.distributed with parameters of type ONodeId

Modifier and Type	Method	Description
void	OLoggerDistributed.debugNode(ONodeId node, String message, Object... additionalArgs)
void	OLoggerDistributed.debugNode(ONodeId node, String message, Throwable exception, Object... additionalArgs)
void	OLoggerDistributedImpl.debugNode(ONodeId localNode, String message, Object... additionalArgs)
void	OLoggerDistributedImpl.debugNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs)
void	OLoggerDistributed.errorNode(ONodeId node, String message, Object... additionalArgs)
void	OLoggerDistributed.errorNode(ONodeId node, String message, Throwable exception, Object... additionalArgs)
void	OLoggerDistributedImpl.errorNode(ONodeId localNode, String message, Object... additionalArgs)
void	OLoggerDistributedImpl.errorNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs)
protected static String	OLoggerDistributedImpl.formatMessage(ONodeId localNode, String message)
long	ODistributedMessageService.getCurrentLatency(ONodeId server)
ODistributedServerManager.DB_STATUS	ODistributedServerManager.getDatabaseStatus(ONodeId iNode, String iDatabaseName)
ORemoteTaskFactory	ORemoteTaskFactoryManager.getFactoryByServerId(ONodeId serverId)
void	ODistributedMessageService.handleUnreachableNode(ONodeId nodeName)
void	OLoggerDistributed.infoNode(ONodeId node, String message, Object... additionalArgs)
void	OLoggerDistributed.infoNode(ONodeId node, String message, Throwable exception, Object... additionalArgs)
void	OLoggerDistributedImpl.infoNode(ONodeId localNode, String message, Object... additionalArgs)
void	OLoggerDistributedImpl.infoNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs)
boolean	ORemoteServerAvailabilityCheck.isNodeAvailable(ONodeId node)
void	ORemoteServerAvailabilityCheck.nodeDisconnected(ONodeId node)
void	ODistributedResponseManager.removeServerBecauseUnreachable(ONodeId node)
void	ODistributedResponseManagerImpl.removeServerBecauseUnreachable(ONodeId node)
ODistributedResponse	ODistributedServerManager.sendSingleRequest(String iDatabaseName, ONodeId node, ORemoteTask iTask)	Sends a distributed request against multiple servers.
ODistributedResponse	ODistributedResponse.setExecutorNodeName(ONodeId executorNodeName)
boolean	ODistributedResponseManager.setLocalResult(ONodeId localNodeName, Object localResult)
boolean	ODistributedResponseManagerImpl.setLocalResult(ONodeId localNodeName, Object localResult)
void	ODistributedMessageService.updateLatency(ONodeId metricName, long sentOn)
void	OLoggerDistributed.warnNode(ONodeId node, String message, Object... additionalArgs)
void	OLoggerDistributed.warnNode(ONodeId node, String message, Throwable exception, Object... additionalArgs)
void	OLoggerDistributedImpl.warnNode(ONodeId localNode, String message, Object... additionalArgs)
void	OLoggerDistributedImpl.warnNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs)

Method parameters in com.orientechnologies.orient.server.distributed with type arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	ODistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, String databaseName, ODistributedRequest request, Collection<ONodeId> iNodes)
ODistributedResponseManager	ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<ONodeId> iNodes, ORemoteTask task, Set<ONodeId> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
ODistributedResponseManager	ODistributedResponseManagerFactory.newResponseManager(ODistributedRequest iRequest, Collection<ONodeId> iNodes, ORemoteTask task, Set<ONodeId> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
ODistributedResponse	ODistributedServerManager.sendRequest(String iDatabaseName, Collection<ONodeId> iTargetNodeNames, ORemoteTask iTask)	Sends a distributed request against multiple servers.
ODistributedResponse	ODistributedServerManager.sendRequest(String iDatabaseName, Collection<ONodeId> iTargetNodeNames, ORemoteTask iTask, ODistributedRequestId messageId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)

Constructors in com.orientechnologies.orient.server.distributed with parameters of type ONodeId

Modifier	Constructor	Description
	ODistributedRequestId(ONodeId iNodeId, long iMessageId)
	ODistributedResponse(ODistributedResponseManager msg, ODistributedRequestId iRequestId, ONodeId executorNodeName, ONodeId senderNodeName, Object payload)
	ORemoteServerChannel(ORemoteServerAvailabilityCheck check, ONodeId localNode, ONodeId iServer, String iURL, String user, String passwd, int currentProtocolVersion, ExecutorService exec)
	ORemoteServerController(ORemoteServerAvailabilityCheck check, ONodeId local, ONodeId remote, String url, String user, String passwd, ExecutorService executor)

Constructor parameters in com.orientechnologies.orient.server.distributed with type arguments of type ONodeId

Modifier	Constructor	Description
	ODistributedResponseManagerImpl(ODistributedServerManager iManager, OrientDBInternal ctx, ODistributedRequest iRequest, Collection<ONodeId> expectedResponses, Set<ONodeId> iNodesConcurInQuorum, int iQuorum, boolean iWaitForLocalNode, long iSynchTimeout, boolean iGroupResponsesByResult)
	ODistributedResponseManagerImpl(ODistributedServerManager iManager, OrientDBInternal ctx, ODistributedRequest iRequest, Collection<ONodeId> expectedResponses, Set<ONodeId> iNodesConcurInQuorum, int iQuorum, boolean iWaitForLocalNode, long iSynchTimeout, boolean iGroupResponsesByResult)

Uses of ONodeId in com.orientechnologies.orient.server.distributed.impl

Methods in com.orientechnologies.orient.server.distributed.impl that return ONodeId

Modifier and Type	Method	Description
ONodeId	ODatabaseDocumentDistributed.getLocalNodeId()
ONodeId	ODistributedTxResponseManager.getNodeNameFromPayload(OTransactionResultPayload payload)
ONodeId	ODistributedTxResponseManagerImpl.getNodeNameFromPayload(OTransactionResultPayload payload)
ONodeId	OAllocationInfoOClassNode.node()	Returns the value of the node record component.
ONodeId	OMemberInfo.node()	Returns the value of the node record component.

Methods in com.orientechnologies.orient.server.distributed.impl that return types with arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	ODistributedTxResponseManagerImpl.getExpectedNodes()
List<ONodeId>	ODistributedTxResponseManagerImpl.getMissingNodes()
Set<ONodeId>	ODefaultDistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, String databaseName, ODistributedRequest request, Collection<ONodeId> iNodes)
List<ONodeId>	ODistributedTxResponseManagerImpl.getRespondingNodes()

Methods in com.orientechnologies.orient.server.distributed.impl with parameters of type ONodeId

Modifier and Type	Method	Description
void	ODistributedPlugin.closeRemoteServer(ONodeId node)
void	ORemoteServerManager.closeRemoteServer(ONodeId node)
boolean	ODistributedTxResponseManager.collectResponse(OTransactionPhase1TaskResult response, ONodeId senderNodeName)
boolean	ODistributedTxResponseManagerImpl.collectResponse(OTransactionPhase1TaskResult response, ONodeId senderNodeName)
ORemoteServerController	ORemoteServerManager.connectRemoteServer(ONodeId rNodeName, String host)
ODistributedResponse	ODatabaseDocumentDistributed.executeTaskOnNode(ORemoteTask task, ONodeId nodeName)
long	ODistributedMessageServiceImpl.getCurrentLatency(ONodeId server)
ODistributedServerManager.DB_STATUS	ODistributedPlugin.getDatabaseStatus(ONodeId iNode, String iDatabaseName)
List<ORemoteAddress.OBinaryAddress>	ORemoteServerManager.getRemoteAddresses(ONodeId node)
ORemoteServerController	ORemoteServerManager.getRemoteServer(ONodeId rNodeName)
void	ODistributedMessageServiceImpl.handleUnreachableNode(ONodeId nodeName)
void	ODistributedPlugin.notifyNodeJoined(ONodeId joinedNodeName)
void	ODistributedPlugin.notifyNodeLeft(ONodeId joinedNodeName)
void	ODistributedPlugin.onNodeJoined(ONodeId joinedNodeId, String url)
void	ODistributedPlugin.onServerRemoved(ONodeId nodeName)
OExecutionStream	ODatabaseDocumentDistributed.queryOnNode(ONodeId nodeName, OInternalExecutionPlan executionPlan, Map<Object,Object> inputParameters)
void	ORemoteServerManager.registerRemoteAddresses(ONodeId nodeId, List<ONodeInfoListener> listeners)
void	ODistributedTxResponseManagerImpl.removeServerBecauseUnreachable(ONodeId node)
ODistributedResponse	ODistributedPlugin.sendSingleRequest(String databaseName, ONodeId node, ORemoteTask iTask)
boolean	ODistributedTxResponseManagerImpl.setLocalResult(ONodeId localNodeName, Object localResult)
void	ODistributedMessageServiceImpl.updateLatency(ONodeId server, long sentOn)

Method parameters in com.orientechnologies.orient.server.distributed.impl with type arguments of type ONodeId

Modifier and Type	Method	Description
Set<ONodeId>	ODefaultDistributedStrategy.getNodesConcurInQuorum(ODistributedServerManager manager, String databaseName, ODistributedRequest request, Collection<ONodeId> iNodes)
ODistributedResponse	ODistributedPlugin.send2Nodes(ODistributedRequest iRequest, Collection<ONodeId> iNodes, Object localResult)
ODistributedResponse	ODistributedPlugin.send2Nodes(ODistributedRequest request, Collection<ONodeId> nodes, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
ODistributedResponse	ODistributedPlugin.sendRequest(String iDatabaseName, Collection<ONodeId> iTargetNodes, ORemoteTask iTask)
ODistributedResponse	ODistributedPlugin.sendRequest(String iDatabaseName, Collection<ONodeId> iTargetNodes, ORemoteTask iTask, ODistributedRequestId reqId, Object localResult, ODistributedResponseManagerFactory responseManagerFactory)
protected boolean	ODistributedPlugin.waitForLocalNode(ODistributedConfiguration cfg, Collection<ONodeId> iNodes)

Constructors in com.orientechnologies.orient.server.distributed.impl with parameters of type ONodeId

Modifier	Constructor	Description
	OAllocationInfoOClassNode(ONodeId node, List<String> clusters)	Creates an instance of a OAllocationInfoOClassNode record class.
	ODistributedTxCoordinator(String dbName, ODistributedServerManager manager, ODistributedDatabase iDDatabase, ONodeId nodeName, int maxRetries, int retryDelay)
	OMemberInfo(ONodeId node, ONodeRole role)	Creates an instance of a OMemberInfo record class.
	ORemoteServerManager(ONodeId local, ORemoteServerAvailabilityCheck check, ExecutorService executor, String user, String password)

Constructor parameters in com.orientechnologies.orient.server.distributed.impl with type arguments of type ONodeId

Modifier	Constructor	Description
	ODistributedTxResponseManagerImpl(ORemoteTask iRequest, Collection<ONodeId> iNodes, Set<ONodeId> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum)
	ODistributedTxResponseManagerImpl(ORemoteTask iRequest, Collection<ONodeId> iNodes, Set<ONodeId> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum)

Uses of ONodeId in com.orientechnologies.orient.server.distributed.impl.task

Methods in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ONodeId

Modifier and Type	Method	Description
ORemoteTaskFactory	ORemoteTaskFactoryManagerImpl.getFactoryByServerId(ONodeId nodeId)

Constructors in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ONodeId

Modifier	Constructor	Description
	OExecutionStreamDistributedFetch(String queryId, ONodeId nodeName, OExecutionStream first, ODatabaseDocumentDistributed db)
	ORunQueryExecutionPlanTask(OInternalExecutionPlan executionPlan, Map<Object,Object> inputParameters, ONodeId nodeId)

Uses of ONodeId in com.orientechnologies.orient.server.hazelcast

Fields in com.orientechnologies.orient.server.hazelcast with type parameters of type ONodeId

Modifier and Type	Field	Description
protected ConcurrentMap<ONodeId,com.hazelcast.core.Member>	OHazelcastClusterMetadataManager.activeNodes
protected ConcurrentMap<String,ONodeId>	OHazelcastClusterMetadataManager.activeNodesNamesByUuid
protected ConcurrentMap<ONodeId,String>	OHazelcastClusterMetadataManager.activeNodesUuidByName

Methods in com.orientechnologies.orient.server.hazelcast that return ONodeId

Modifier and Type	Method	Description
ONodeId	OHazelcastClusterMetadataManager.getNodeId(com.hazelcast.core.Member iMember, boolean useCache)