Uses of Class
com.orientechnologies.orient.core.transaction.ONodeId
Packages that use ONodeId
Package
Description
-
Uses of ONodeId in com.orientechnologies.agent.operation
Constructor parameters in com.orientechnologies.agent.operation with type arguments of type ONodeId -
Uses of ONodeId in com.orientechnologies.orient.client.remote
Methods in com.orientechnologies.orient.client.remote that return ONodeId -
Uses of ONodeId in com.orientechnologies.orient.core.db
Methods in com.orientechnologies.orient.core.db that return ONodeId -
Uses of ONodeId in com.orientechnologies.orient.core.transaction
Methods in com.orientechnologies.orient.core.transaction that return ONodeIdModifier and TypeMethodDescriptionOTransactionIdPromise.getCoordinator()static ONodeIdONodeId.readNetwork(DataInput input) static ONodeIdONodeId.readResult(OResult e) Methods in com.orientechnologies.orient.core.transaction with parameters of type ONodeIdModifier and TypeMethodDescriptionvoidOSequenceNodes.nodeUpdate(ONodeId nodeId, long newValue) OTransactionIdPromise.retrySequence(ONodeId node) voidOMinimumSequenceStatus.updateNode(ONodeId nodeID, long[] sequences) Constructors in com.orientechnologies.orient.core.transaction with parameters of type ONodeIdModifierConstructorDescriptionODistributedSynchronizedSequence(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 ONodeIdModifier and TypeMethodDescriptionONodeLatencies.node()Returns the value of thenoderecord component.Constructors in com.orientechnologies.orient.distributed with parameters of type ONodeIdModifierConstructorDescriptionONodeLatencies(ONodeId node, OProfilerEntrySnapshot stats) Creates an instance of aONodeLatenciesrecord class. -
Uses of ONodeId in com.orientechnologies.orient.distributed.context
Methods in com.orientechnologies.orient.distributed.context that return ONodeIdModifier and TypeMethodDescriptionODistributedResponse.getNode()ONodeStats.getNode()ONodeState.getNodeId()ODatabaseNodeStore.id()Returns the value of theidrecord component.Methods in com.orientechnologies.orient.distributed.context that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionONodeState.getNetworkMembers()ONetworkTopologyStore.members()Returns the value of themembersrecord component.Methods in com.orientechnologies.orient.distributed.context with parameters of type ONodeIdModifier and TypeMethodDescriptionvoidONodeState.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) voidOStatsManager.receiveStats(ONodeId nodeId, long bootTime, long maxMem, long totMem, long freeMem, long usedMem, List<ONodeLatencies> nodesLatencies, List<ONodeMessages> nodesMessages) voidONodeState.success(ONodeId node, OTransactionIdPromise promise) Constructors in com.orientechnologies.orient.distributed.context with parameters of type ONodeIdModifierConstructorDescriptionODatabaseNodeStore(ONodeId id, ONodeRole role) Creates an instance of aODatabaseNodeStorerecord 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 ONodeIdModifierConstructorDescriptionONetworkTopologyStore(OGroupId groupId, OTopologyState state, Set<ONodeId> members, int quorum, OVersion version) Creates an instance of aONetworkTopologyStorerecord class. -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination
Methods in com.orientechnologies.orient.distributed.context.coordination that return ONodeIdModifier and TypeMethodDescriptionOCoordinatedDistributedOps.getCurrent()OCoordinatedDistributedOpsImpl.getCurrent()Methods in com.orientechnologies.orient.distributed.context.coordination that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionOCoordinatedDistributedOps.checkOffline(long time) OCoordinatedDistributedOpsImpl.checkOffline(long time) OCoordinatedDistributedOps.establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) OResponseCollectorImpl.getExpected()OResponseCollectorMerge.getExpected()ONetworkTopology.getMembers()OOperationStart.nodes()Returns the value of thenodesrecord component.OResponseCollector.CompleteInfo.nodes()Returns the value of thenodesrecord component.Methods in com.orientechnologies.orient.distributed.context.coordination with parameters of type ONodeIdModifier and TypeMethodDescriptionbooleanOCoordinatedDistributedOps.acceptSync(ONodeId sender, OSyncId syncId) booleanOCoordinatedDistributedOpsImpl.acceptSync(ONodeId sender, OSyncId syncId) voidOCoordinatedDistributedOps.cancelMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.cancelMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOps.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync) OCoordinatedDistributedOpsImpl.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync) OResponseCollector.disconnected(ONodeId node) OResponseCollectorImpl.disconnected(ONodeId node) OResponseCollectorMerge.disconnected(ONodeId node) OCoordinatedDistributedOps.discoverNode(ONodeId node) OCoordinatedDistributedOpsImpl.discoverNode(ONodeId node) OResponseCollector.fail(ONodeId node, OAcceptResult acceptResult) OResponseCollectorImpl.fail(ONodeId node, OAcceptResult acceptResult) OResponseCollectorMerge.fail(ONodeId node, OAcceptResult acceptResult) OPromisedDistributedOps.getPromised(ONodeId node) OPromisedDistributedOpsImpl.getPromised(ONodeId node) voidOCoordinatedDistributedOps.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) OCoordinatedDistributedOps.nodeDisconnected(ONodeId node) OCoordinatedDistributedOpsImpl.nodeDisconnected(ONodeId node) OPromisedDistributedOps.nodeDisconnected(ONodeId node) OPromisedDistributedOpsImpl.nodeDisconnected(ONodeId node) voidOCoordinatedDistributedOps.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) voidOCoordinatedDistributedOpsImpl.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) OCoordinatedDistributedOps.nodeJoinStart(ONodeId node, ONodeStateNetwork state, boolean merge) OCoordinatedDistributedOpsImpl.nodeJoinStart(ONodeId node, ONodeStateNetwork state, boolean merge) voidOCoordinatedDistributedOps.nodeMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted) voidOCoordinatedDistributedOpsImpl.nodeMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted) voidOCoordinatedDistributedOps.nodeSuccess(ONodeId node, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.nodeSuccess(ONodeId node, OTransactionIdPromise promise) OCoordinatedDistributedOps.receivePing(ONodeId nodeId, OTransactionSequenceStatus status) OCoordinatedDistributedOpsImpl.receivePing(ONodeId nodeId, OTransactionSequenceStatus status) voidOCoordinatedDistributedOps.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOps.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode) OCoordinatedDistributedOpsImpl.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode) OCoordinatedDistributedOps.unregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.unregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateRegisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateRegisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateUnregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateUnregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise) booleanOCoordinatedDistributedOps.waitNodeJoined(ONodeId dbId, Optional<Long> timeout) booleanOCoordinatedDistributedOpsImpl.waitNodeJoined(ONodeId dbId, Optional<Long> timeout) Method parameters in com.orientechnologies.orient.distributed.context.coordination with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidOCoordinatedDistributedOps.cancelRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.cancelRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OTransactionIdPromise promise) OCoordinatedDistributedOps.establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOps.startEstablish(Set<ONodeId> nodes, OCompleteAction action) OCoordinatedDistributedOpsImpl.startEstablish(Set<ONodeId> nodes, OCompleteAction action) OCoordinatedDistributedOps.validateEstablish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) Constructors in com.orientechnologies.orient.distributed.context.coordination with parameters of type ONodeIdModifierConstructorDescriptionOCoordinatedDistributedOpsImpl(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 ONodeIdModifierConstructorDescriptionCompleteInfo(OCompleteAction action, OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) Creates an instance of aCompleteInforecord class.OOperationStart(OTransactionIdPromise promise, Set<ONodeId> nodes) Creates an instance of aOOperationStartrecord 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 ONodeIdModifier and TypeMethodDescriptionvoidOCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) voidORecoordinateCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) voidOStandardCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) voidOCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> optional) voidOMergeCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result) voidORecoordinateCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result) voidOStandardCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result) OCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes) OMergeCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes) ORecoordinateCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes) OStandardCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes) voidOCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all) voidOMergeCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all) voidORecoordinateCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all) voidOStandardCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all) Constructors in com.orientechnologies.orient.distributed.context.coordination.action with parameters of type ONodeIdModifierConstructorDescriptionOMergeCompleteAction(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 ONodeIdMethods in com.orientechnologies.orient.distributed.context.coordination.dbs that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionODatabasesTopology.getMembers(ODatabaseId databaseId) ODatabasesTopologyState.getMembers(ODatabaseId databaseId) ODatabaseTopologyState.getMembers()ODatabasesTopology.getOnlineNodes(ODatabaseId dbId) ODatabasesTopologyState.getOnlineNodes(ODatabaseId dbId) ODatabaseTopologyState.getOnlineNodes()OCanSyncResult.others()Returns the value of theothersrecord component.Methods in com.orientechnologies.orient.distributed.context.coordination.dbs with parameters of type ONodeIdModifier and TypeMethodDescriptionbooleanODatabasesTopologyState.acceptSync(ONodeId sender, OSyncId syncId) booleanODatabaseTopologyState.acceptSync(ONodeId sender, OSyncId syncId) voidODatabaseTopologyState.cancelRole(ONodeId nodeId, OVersion version, OTransactionIdPromise promise) voidODatabasesTopologyState.cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) voidODatabasesTopologyState.cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise) voidODatabaseTopologyState.cancelSetState(ONodeId nodeId, OVersion version, OTransactionIdPromise promise) ODatabasesTopologyState.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync) ODatabaseTopologyState.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync) ODatabasesTopology.getRole(ODatabaseId dbId, ONodeId node) ODatabasesTopologyState.getRole(ODatabaseId dbId, ONodeId nodeId) ODatabasesTopology.getState(ODatabaseId dbId, ONodeId node) ODatabasesTopologyState.getState(ODatabaseId dbId, ONodeId nodeID) booleanODatabasesTopology.isMain(ODatabaseId dbId, ONodeId node) booleanODatabasesTopologyState.isMain(ODatabaseId dbId, ONodeId nodeId) booleanbooleanODatabasesTopology.isOnline(ODatabaseId dbId, ONodeId nodeID) booleanODatabasesTopologyState.isOnline(ODatabaseId dbId, ONodeId nodeID) voidODatabasesTopologyState.nodeDisconnected(ONodeId node) voidODatabaseTopologyState.nodeDisconnected(ONodeId node) voidODatabaseStateChangeListener.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state) ODatabaseTopologyState.promiseState(ODatabaseState state, ONodeId nodeId, OVersion version, OTransactionIdPromise promise) voidODatabasesTopologyState.setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) voidODatabaseTopologyState.setRole(ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) voidODatabasesTopologyState.setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise) voidODatabaseTopologyState.setState(ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise) booleanODatabasesTopology.shouldSink(ODatabaseId dbId, ONodeId nodeID) booleanODatabasesTopologyState.shouldSink(ODatabaseId dbId, ONodeId nodeID) booleanODatabaseTopologyState.shouldSink(ONodeId nodeID) ODatabasesTopologyState.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode) ODatabaseTopologyState.startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode) ODatabaseTopologyState.validateRole(ONodeId node, OVersion version, OTransactionIdPromise promise) ODatabasesTopologyState.validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise) 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 ONodeIdModifier and TypeMethodDescriptionODatabaseTopologyState.promiseRemoveMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) voidODatabasesTopologyState.removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) voidODatabaseTopologyState.removeMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) ODatabasesTopologyState.validateRemoveMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise) Constructors in com.orientechnologies.orient.distributed.context.coordination.dbs with parameters of type ONodeIdModifierConstructorDescriptionODatabasesTopologyState(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 ONodeIdModifierConstructorDescriptionOCanSyncResult(OSyncState state, Set<ONodeId> others) Creates an instance of aOCanSyncResultrecord class. -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.message
Methods in com.orientechnologies.orient.distributed.context.coordination.message that return ONodeIdModifier and TypeMethodDescriptionOMergeResult.getNode()OFailPropose.getNodeId()ONodeFirstConnect.getNodeId()ONodeStatsNotify.getNodeId()OSendTransactions.getNodeId()OSuccessPropose.getNodeId()OTopologyPing.getNodeId()OCanSync.getSender()Constructors in com.orientechnologies.orient.distributed.context.coordination.message with parameters of type ONodeIdModifierConstructorDescriptionOCanSync(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 ONodeIdModifier and TypeMethodDescriptionOAddTopologyMember.getNode()OMergeNode.getNode()ORemoveTopologyMember.getNode()OSetDatabaseMemberRole.getNode()OSetDatabaseState.getNodeId()OAddNodeInfo.node()Returns the value of thenoderecord component.Methods in com.orientechnologies.orient.distributed.context.coordination.message.operation that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionOEstablishTopology.getCandidates()ORemoveDatabaseMembers.getNodes()Methods in com.orientechnologies.orient.distributed.context.coordination.message.operation with parameters of type ONodeIdModifier and TypeMethodDescriptionstatic OAddNodeInfovoidOOperationContext.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) voidOOperationContext.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise) Method parameters in com.orientechnologies.orient.distributed.context.coordination.message.operation with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidOOperationContext.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) Constructors in com.orientechnologies.orient.distributed.context.coordination.message.operation with parameters of type ONodeIdModifierConstructorDescriptionOAddNodeInfo(ONodeId node, ONodeRole role) Creates an instance of aOAddNodeInforecord class.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 ONodeIdModifierConstructorDescriptionOEstablishTopology(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 ONodeIdModifier and TypeMethodDescriptionODatabaseMemberNetwork.node()Returns the value of thenoderecord component.Methods in com.orientechnologies.orient.distributed.context.coordination.message.state that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionOTopologyStateNetwork.members()Returns the value of themembersrecord component.Constructors in com.orientechnologies.orient.distributed.context.coordination.message.state with parameters of type ONodeIdModifierConstructorDescriptionODatabaseMemberNetwork(ONodeId node, ONodeRole role, ODatabaseState state) Creates an instance of aODatabaseMemberNetworkrecord class.Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.message.state with type arguments of type ONodeIdModifierConstructorDescriptionOTopologyStateNetwork(OGroupId groupId, OTopologyState state, Set<ONodeId> members, int quorum, OVersion version) Creates an instance of aOTopologyStateNetworkrecord class. -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.result
Methods in com.orientechnologies.orient.distributed.context.coordination.result that return ONodeIdModifier and TypeMethodDescriptionONodeAlreadyPresent.node()Returns the value of thenoderecord component.OMissingNode.nodeId()Returns the value of thenodeIdrecord component.OAlreadyPromised.promisedTo()Returns the value of thepromisedTorecord component.Constructors in com.orientechnologies.orient.distributed.context.coordination.result with parameters of type ONodeIdModifierConstructorDescriptionOAlreadyPromised(ONodeId promisedTo) Creates an instance of aOAlreadyPromisedrecord class.OMissingNode(ONodeId nodeId) Creates an instance of aOMissingNoderecord class.ONodeAlreadyPresent(ODatabaseId db, ONodeId node) Creates an instance of aONodeAlreadyPresentrecord class. -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.sync
Methods in com.orientechnologies.orient.distributed.context.coordination.sync that return ONodeIdModifier and TypeMethodDescriptionOSyncId.getReceiver()OSyncState.getReceiver()OSyncState.getSender()Methods in com.orientechnologies.orient.distributed.context.coordination.sync that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionOSyncInfo.targets()Returns the value of thetargetsrecord component.Methods in com.orientechnologies.orient.distributed.context.coordination.sync with parameters of type ONodeIdModifier and TypeMethodDescriptionOSyncSession.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync) booleanOSyncSession.nodeDisconnected(ONodeId node) OSyncSession.startSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync) Constructors in com.orientechnologies.orient.distributed.context.coordination.sync with parameters of type ONodeIdModifierConstructorDescriptionOSyncId(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 -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.topology
Methods in com.orientechnologies.orient.distributed.context.coordination.topology that return ONodeIdModifier and TypeMethodDescriptionOTopologyManager.getNodeId()ODiscoverAction.OAddNodeAction.node()Returns the value of thenoderecord component.ODiscoverAction.OMergeNodeAction.node()Returns the value of thenoderecord component.ODiscoverAction.ORequestMergeAction.requestToMerge()Returns the value of therequestToMergerecord component.Methods in com.orientechnologies.orient.distributed.context.coordination.topology that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionOTopologyManager.awayNodes(long time) ODiscoverAction.OEstablishAction.candidates()Returns the value of thecandidatesrecord component.OTopologyManager.finalizeEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) OTopologyManager.getMembers()ODiscoverAction.ONotifySelf.nodes()Returns the value of thenodesrecord component.Methods in com.orientechnologies.orient.distributed.context.coordination.topology with parameters of type ONodeIdModifier and TypeMethodDescriptionprotected booleanvoidOTopologyManager.mergeNode(ONodeId node, OVersion version, OTransactionIdPromise promise) OTopologyEvents.nodeDiscovered(ONodeId node) OTopologyManager.nodeDiscovered(ONodeId node) OTopologyManager.nodeJoinStart(ONodeId node, OTopologyStateNetwork externState, boolean merge) voidOTopologyManager.promiseRegister(ONodeId toAdd, OVersion version, OTransactionIdPromise promise) OTopologyManager.promiseUnregister(ONodeId node, OVersion version, OTransactionIdPromise promise) voidOTopologyManager.register(ONodeId toRegister, OVersion version, OTransactionIdPromise promise) voidOTopologyManager.unregister(ONodeId node, OVersion version, OTransactionIdPromise promise) booleanOTopologyManager.waitNodeJoined(ONodeId node, Optional<Long> timeout) Method parameters in com.orientechnologies.orient.distributed.context.coordination.topology with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidOOperationMessageSender.establish(Set<ONodeId> nodes, OOperationMessage message) OTopologyManager.finalizeEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) OTopologyManager.validateEstablish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) Constructors in com.orientechnologies.orient.distributed.context.coordination.topology with parameters of type ONodeIdModifierConstructorDescriptionOAddNodeAction(ONodeId node) Creates an instance of aOAddNodeActionrecord class.OMergeNodeAction(ONodeId node) Creates an instance of aOMergeNodeActionrecord class.ORequestMergeAction(ONodeId requestToMerge) Creates an instance of aORequestMergeActionrecord class.OTopologyManager(ONodeId current, OGroupId groupId, int minimumQuorum) Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.topology with type arguments of type ONodeIdModifierConstructorDescriptionOEstablishAction(OGroupId groupId, Set<ONodeId> candidates) Creates an instance of aOEstablishActionrecord class.ONotifySelf(Set<ONodeId> nodes) Creates an instance of aONotifySelfrecord class. -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.retryable
Methods in com.orientechnologies.orient.distributed.context.retryable that return ONodeIdModifier and TypeMethodDescriptionOSetDatabaseNodeRoleRetryOperation.node()Returns the value of thenoderecord component.OSetDatabaseStateRetryOperation.node()Returns the value of thenoderecord component.Methods in com.orientechnologies.orient.distributed.context.retryable that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionORemoveMemberRetryOperation.nodes()Returns the value of thenodesrecord component.Constructors in com.orientechnologies.orient.distributed.context.retryable with parameters of type ONodeIdModifierConstructorDescriptionOSetDatabaseNodeRoleRetryOperation(ODatabaseId dbId, ONodeId node, ONodeRole role) Creates an instance of aOSetDatabaseNodeRoleRetryOperationrecord class.OSetDatabaseStateRetryOperation(ONodeId node, ODatabaseId dbId, ODatabaseState state) Creates an instance of aOSetDatabaseStateRetryOperationrecord class.Constructor parameters in com.orientechnologies.orient.distributed.context.retryable with type arguments of type ONodeIdModifierConstructorDescriptionORemoveMemberRetryOperation(ODatabaseId databaseId, List<ONodeId> nodes) Creates an instance of aORemoveMemberRetryOperationrecord class. -
Uses of ONodeId in com.orientechnologies.orient.distributed.db
Methods in com.orientechnologies.orient.distributed.db that return ONodeIdMethods in com.orientechnologies.orient.distributed.db with parameters of type ONodeIdModifier and TypeMethodDescriptionvoidOrientDBDistributed.canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync) voidOrientDBDistributed.checkNodeIsMaster(ONodeId localNodeId, String name, String operation) voidOrientDBDistributed.closeRemoteServer(ONodeId node) voidvoidOrientDBDistributed.connectRemoteServer(ONodeId node, String url) voidOrientDBDistributed.disconnected(ONodeId node) voidOrientDBDistributed.firstConnect(ONodeId nodeId, ONodeStateNetwork state, boolean merge, ONodeInfo info) OrientDBDistributed.getDatabaseState(ODatabaseId dbId, ONodeId node) OrientDBDistributed.getDatabaseStatus(ONodeId nodeId, String dbName) OrientDBDistributed.getRemoteServer(ONodeId nodeId) voidOrientDBDistributed.mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise) voidOrientDBDistributed.mergeNodeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted) voidOrientDBDistributed.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state) voidOrientDBDistributed.receivePing(ONodeId nodeId, OTransactionSequenceStatus status) voidOrientDBDistributed.registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise) booleanOrientDBDistributed.removeDatabaseMember(ODatabaseId databaseId, ONodeId node) voidOrientDBDistributed.retryMergeOperationMessages(ONodeId mergeNode, ONodeStateNetwork mergedState, ONodeStateNetwork original, OOperationMessage operation, OCompleteAction action, int delay) voidOrientDBDistributed.sendMergeNodeAction(ONodeId node, ONodeStateNetwork state, OCompleteExecution execution) voidOrientDBDistributed.sendMergeOperation(ONodeId requestToMerge, OCompleteExecution execution) voidOrientDBDistributed.sendMessage(ONodeId node, OStructuralMessage op) voidOrientDBDistributed.sendTopologyTransactions(ONodeId nodeId, List<OTransactionId> transactions) voidOrientDBDistributed.setDatabaseStatus(ONodeId nodeId, String dbName, ODistributedServerManager.DB_STATUS status) Method parameters in com.orientechnologies.orient.distributed.db with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidOrientDBDistributed.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) voidOrientDBDistributed.sendEstablish(OGroupId groupId, Set<ONodeId> candidates, OCompleteExecution execution) voidOrientDBDistributed.sendFirstConnects(Set<ONodeId> nodes) voidOrientDBDistributed.sendMessage(Set<ONodeId> set, OStructuralMessage op) -
Uses of ONodeId in com.orientechnologies.orient.server
Methods in com.orientechnologies.orient.server that return ONodeId -
Uses of ONodeId in com.orientechnologies.orient.server.distributed
Methods in com.orientechnologies.orient.server.distributed that return ONodeIdModifier and TypeMethodDescriptionODistributedRequestId.getNodeId()ORemoteServerChannel.getServer()Methods in com.orientechnologies.orient.server.distributed with parameters of type ONodeIdModifier and TypeMethodDescriptionvoidvoidOLoggerDistributed.debugNode(ONodeId node, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributedImpl.debugNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributed.errorNode(ONodeId node, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributedImpl.errorNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs) protected static StringOLoggerDistributedImpl.formatMessage(ONodeId localNode, String message) ORemoteTaskFactoryManager.getFactoryByServerId(ONodeId serverId) voidvoidOLoggerDistributed.infoNode(ONodeId node, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributedImpl.infoNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs) booleanORemoteServerAvailabilityCheck.isNodeAvailable(ONodeId node) voidORemoteServerAvailabilityCheck.nodeDisconnected(ONodeId node) voidvoidOLoggerDistributed.warnNode(ONodeId node, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributedImpl.warnNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs) Constructors in com.orientechnologies.orient.server.distributed with parameters of type ONodeIdModifierConstructorDescriptionODistributedRequestId(ONodeId iNodeId, long iMessageId) 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) -
Uses of ONodeId in com.orientechnologies.orient.server.distributed.impl
Methods in com.orientechnologies.orient.server.distributed.impl that return ONodeIdModifier and TypeMethodDescriptionODatabaseDocumentDistributed.getLocalNodeId()OAllocationInfoOClassNode.node()Returns the value of thenoderecord component.OMemberInfo.node()Returns the value of thenoderecord component.Methods in com.orientechnologies.orient.server.distributed.impl with parameters of type ONodeIdModifier and TypeMethodDescriptionvoidORemoteServerManager.closeRemoteServer(ONodeId node) ORemoteServerManager.connectRemoteServer(ONodeId rNodeName, String host) ORemoteServerManager.getRemoteAddresses(ONodeId node) ORemoteServerManager.getRemoteServer(ONodeId rNodeName) voidORemoteServerManager.registerRemoteAddresses(ONodeId nodeId, List<ONodeInfoListener> listeners) Constructors in com.orientechnologies.orient.server.distributed.impl with parameters of type ONodeIdModifierConstructorDescriptionOAllocationInfoOClassNode(ONodeId node, List<String> clusters) Creates an instance of aOAllocationInfoOClassNoderecord class.OMemberInfo(ONodeId node, ONodeRole role) Creates an instance of aOMemberInforecord class.ORemoteServerManager(ONodeId local, ORemoteServerAvailabilityCheck check, ExecutorService executor, String user, String password) -
Uses of ONodeId in com.orientechnologies.orient.server.distributed.impl.task
Methods in com.orientechnologies.orient.server.distributed.impl.task with parameters of type ONodeIdModifier and TypeMethodDescriptionORemoteTaskFactoryManagerImpl.getFactoryByServerId(ONodeId nodeId)