Uses of Class
com.orientechnologies.orient.core.transaction.ONodeId
Packages that use ONodeId
Package
Description
-
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) voidOMinimumSequenceStatus.updateNode(ONodeId nodeID, long[] sequences) Constructors in com.orientechnologies.orient.core.transaction with parameters of type ONodeIdModifierConstructorDescriptionOTransactionIdPromise(ONodeId node, OTransactionId id) OTransactionIdPromise(ONodeId node, OTransactionId id, int recoverSequence) OTransactionSequenceManager(ONodeId coordinator, int size) -
Uses of ONodeId in com.orientechnologies.orient.distributed.context
Methods in com.orientechnologies.orient.distributed.context that return ONodeIdModifier and TypeMethodDescriptionODatabaseNodeStore.getId()ONodeDatabaseState.getId()ODistributedResponse.getNode()ONodeState.getNodeId()OSyncState.getReceiver()OSyncState.getSender()Methods in com.orientechnologies.orient.distributed.context that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionOCoordinatedDistributedOps.enstablish(OGroupId networkId, Set<ONodeId> candidates) OCoordinatedDistributedOpsImpl.enstablish(OGroupId groupId, Set<ONodeId> candidates) OResponseCollector.getExpected()ONetworkTopologyStore.getMembers()OCoordinatedDistributedOps.getNetworkMembers()OCoordinatedDistributedOpsImpl.getNetworkMembers()ONodeState.getNetworkMembers()ODatabasesTopology.getOnlineNodes(ODatabaseId dbId) ODatabasesTopologyState.getOnlineNodes(ODatabaseId dbId) ODatabaseTopologyState.getOnlineNodes()OOperationStart.nodes()Returns the value of thenodesrecord component.OResponseCollector.CompleteInfo.nodes()Returns the value of thenodesrecord component.OSyncInfo.targets()Returns the value of thetargetsrecord component.Methods in com.orientechnologies.orient.distributed.context with parameters of type ONodeIdModifier and TypeMethodDescriptionbooleanOCoordinatedDistributedOps.acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId) booleanOCoordinatedDistributedOpsImpl.acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId) booleanODatabasesTopologyState.acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId) booleanODatabaseTopologyState.acceptSync(ONodeId sender, ONodeId receiver, OSyncId syncId) voidOCoordinatedDistributedOps.cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version) voidOCoordinatedDistributedOpsImpl.cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version) voidODatabasesTopologyState.cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version) voidODatabaseTopologyState.cancelSetState(ONodeId nodeId, long version) OCoordinatedDistributedOps.canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) OCoordinatedDistributedOpsImpl.canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) ODatabasesTopologyState.canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) ODatabaseTopologyState.canSync(ONodeId sender, ONodeId receiver, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) OSyncSession.canSync(ONodeId sender, ONodeId receiver, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voidODatabasesTopologyState.declareNode(ODatabaseId db, String name, ONodeId node, ONodeRole role, ODatabaseState state) voidODatabaseTopologyState.defineNode(ONodeId node, ONodeRole role, ODatabaseState state, long version) OResponseCollector.disconnected(ONodeId node) OCoordinatedDistributedOps.discoverNode(ONodeId node) OCoordinatedDistributedOpsImpl.discoverNode(ONodeId node) OResponseCollector.fail(ONodeId node, OAcceptResult acceptResult) voidONodeState.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) OPromisedDistributedOps.getPromised(ONodeId node) OPromisedDistributedOpsImpl.getPromised(ONodeId node) 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) voidOCoordinatedDistributedOps.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) voidOCoordinatedDistributedOpsImpl.nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) OCoordinatedDistributedOps.nodeJoinStart(ONodeId node, ONodeStateNetwork state) OCoordinatedDistributedOpsImpl.nodeJoinStart(ONodeId node, ONodeStateNetwork state) voidOCoordinatedDistributedOps.nodeSuccess(ONodeId node, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.nodeSuccess(ONodeId node, OTransactionIdPromise promise) voidODatabaseStateChangeListener.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state) ODatabaseTopologyState.promiseState(ODatabaseState state, ONodeId nodeId, long version) voidOCoordinatedDistributedOps.registerNode(ONodeId node, long version) voidOCoordinatedDistributedOpsImpl.registerNode(ONodeId node, long version) voidOCoordinatedDistributedOps.setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version) voidOCoordinatedDistributedOpsImpl.setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version) voidODatabasesTopologyState.setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version) voidODatabaseTopologyState.setState(ONodeId node, ODatabaseState state, long version) booleanODatabasesTopology.shouldSink(ODatabaseId dbId, ONodeId nodeID) booleanODatabasesTopologyState.shouldSink(ODatabaseId dbId, ONodeId nodeID) booleanODatabaseTopologyState.shouldSink(ONodeId nodeID) OCoordinatedDistributedOps.startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) OCoordinatedDistributedOpsImpl.startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) ODatabasesTopologyState.startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) ODatabaseTopologyState.startSend(ONodeId from, ONodeId to, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voidONodeState.success(ONodeId node, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.unregisterNode(ONodeId node, long version) voidOCoordinatedDistributedOpsImpl.unregisterNode(ONodeId node, long version) OCoordinatedDistributedOps.validateRegisterNode(ONodeId node, long version) OCoordinatedDistributedOpsImpl.validateRegisterNode(ONodeId node, long version) OCoordinatedDistributedOps.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version) OCoordinatedDistributedOpsImpl.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version) ODatabasesTopologyState.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version) booleanODatabasesTopologyState.waitOnline(ODatabaseId dbId, ONodeId nodeId) Method parameters in com.orientechnologies.orient.distributed.context with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidOCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) voidOStandardCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) voidOCoordinatedDistributedOps.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum) voidOCoordinatedDistributedOpsImpl.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum) voidODatabasesTopologyState.declareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) OCoordinatedDistributedOps.enstablish(OGroupId networkId, Set<ONodeId> candidates) OCoordinatedDistributedOpsImpl.enstablish(OGroupId groupId, Set<ONodeId> candidates) voidOCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> optional) voidOStandardCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> result) OCoordinatedDistributedOps.startEstablish(Set<ONodeId> nodes, OCompleteAction action) OCoordinatedDistributedOpsImpl.startEstablish(Set<ONodeId> nodes, OCompleteAction action) voidOCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all) voidOStandardCompleteAction.success(OTransactionIdPromise promise, Set<ONodeId> all) ODatabasesTopologyState.validateDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) OCoordinatedDistributedOps.validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum) OCoordinatedDistributedOpsImpl.validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum) OCoordinatedDistributedOps.validateEnstablish(OGroupId networkId, Set<ONodeId> candidates) OCoordinatedDistributedOpsImpl.validateEnstablish(OGroupId groupId, Set<ONodeId> candidates) Constructors in com.orientechnologies.orient.distributed.context with parameters of type ONodeIdModifierConstructorDescriptionOCoordinatedDistributedOpsImpl(ONodeId current, OGroupId groupId, int minimumQuorum, ODatabaseStateChangeListener listener, ONodeStateUpdated updateLister) ODatabaseNodeStore(ONodeId id, ONodeRole role) ONodeDatabaseState(ONodeId node, ONodeRole role, ODatabaseState state) ONodeState(ONodeId current, OGroupId groupId, int minimumQuorum, OStateStore store, ODatabaseStateChangeListener listener) OSyncSession(ODatabaseId dbId, OSyncId syncId, ONodeId from, ONodeId to, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) OSyncState(ODatabaseId dbId, OSyncId syncId, ONodeId sender, ONodeId receiver, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) Constructor parameters in com.orientechnologies.orient.distributed.context with type arguments of type ONodeIdModifierConstructorDescriptionCompleteInfo(OCompleteAction action, OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) Creates an instance of aCompleteInforecord class.ODatabaseTopologyState(ODatabaseId db, String name, Set<ONodeId> partecipants, int quorum, ODatabaseStateChangeListener stateListener) ONetworkTopologyStore(OGroupId groupId, OTopologyState state, Set<ONodeId> members, int quorum, long version) OOperationStart(OTransactionIdPromise promise, Set<ONodeId> nodes) Creates an instance of aOOperationStartrecord class.OResponseCollector(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> activeNodes) Creates an instance of aOSyncInforecord class.OSyncSession(ODatabaseId dbId, Set<ONodeId> nodes) -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination.message
Methods in com.orientechnologies.orient.distributed.context.coordination.message that return ONodeIdModifier and TypeMethodDescriptionOSyncRequest.getFrom()ODatabaseMemberNetwork.getNode()OFailPropose.getNodeId()ONodeFirstConnect.getNodeId()OSuccessPropose.getNodeId()OStartSync.getReceiver()OCanSync.getSender()Methods in com.orientechnologies.orient.distributed.context.coordination.message that return types with arguments of type ONodeIdConstructors in com.orientechnologies.orient.distributed.context.coordination.message with parameters of type ONodeIdModifierConstructorDescriptionOCanSync(ONodeId sender, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus, boolean canSync) ODatabaseMemberNetwork(ONodeId node, ONodeRole role, ODatabaseState state) OFailPropose(ONodeId nodeId, OTransactionIdPromise promise, OAcceptResult acceptResult) ONodeFirstConnect(ONodeId nodeId, ONodeStateNetwork state) OStartSync(ONodeId receiver, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) OSuccessPropose(ONodeId nodeId, OTransactionIdPromise promise) OSyncRequest(ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.message with type arguments of type ONodeIdModifierConstructorDescriptionOTopologyStateNetwork(OGroupId groupId, OTopologyState state, Set<ONodeId> members, int quorum, long version) -
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()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 TypeMethodDescriptionOEnstablishTopology.getCandidates()ODeclareDbMessage.getPartecipants()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(long version, ONodeId node) OSetDatabaseState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version) Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.message.operation with type arguments of type ONodeIdModifierConstructorDescriptionODeclareDbMessage(String name, ODatabaseId id, Set<ONodeId> partecipants, int minimumQuorum) OEnstablishTopology(OGroupId groupId, Set<ONodeId> candidates) -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.topology
Methods in com.orientechnologies.orient.distributed.context.topology that return ONodeIdModifier and TypeMethodDescriptionOTopologyManager.getNodeId()ODiscoverAction.OAddNodeAction.node()Returns the value of thenoderecord component.Methods in com.orientechnologies.orient.distributed.context.topology that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionODiscoverAction.OEstablishAction.candidates()Returns the value of thecandidatesrecord component.OTopologyManager.finalizeEnstablish(OGroupId groupId, Set<ONodeId> candidates) OTopologyManager.getMembers()ODiscoverAction.OMergeAction.members()Returns the value of themembersrecord component.ODiscoverAction.ONotifySelf.nodes()Returns the value of thenodesrecord component.Methods in com.orientechnologies.orient.distributed.context.topology with parameters of type ONodeIdModifier and TypeMethodDescriptionprotected booleanOTopologyEvents.nodeDiscovered(ONodeId node) OTopologyManager.nodeDiscovered(ONodeId node) OTopologyManager.nodeJoinStart(ONodeId node, OTopologyStateNetwork externState) OTopologyManager.promiseRegister(ONodeId toAdd, long version) voidvoidOTopologyManager.unregister(ONodeId node, long version) Method parameters in com.orientechnologies.orient.distributed.context.topology with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidOOperationMessageSender.enstablish(Set<ONodeId> nodes, OOperationMessage message) OTopologyManager.finalizeEnstablish(OGroupId groupId, Set<ONodeId> candidates) OTopologyManager.validateEnstablish(OGroupId groupId, Set<ONodeId> candidates) Constructors in com.orientechnologies.orient.distributed.context.topology with parameters of type ONodeIdModifierConstructorDescriptionOAddNodeAction(ONodeId node, long version) Creates an instance of aOAddNodeActionrecord class.OTopologyManager(ONodeId current, OGroupId groupId, int minimumQuorum) Constructor parameters in com.orientechnologies.orient.distributed.context.topology with type arguments of type ONodeIdModifierConstructorDescriptionOEstablishAction(OGroupId groupId, Set<ONodeId> candidates) Creates an instance of aOEstablishActionrecord class.OMergeAction(Set<ONodeId> members) Creates an instance of aOMergeActionrecord class.ONotifySelf(Set<ONodeId> nodes) Creates an instance of aONotifySelfrecord 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.acceptSync(ONodeId receiver, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voidOrientDBDistributed.canSync(ONodeId sender, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voidvoidOrientDBDistributed.firstConnect(ONodeId nodeId, ONodeStateNetwork state) OrientDBDistributed.getDatabaseStatus(ONodeId nodeId, String dbName) voidOrientDBDistributed.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state) voidOrientDBDistributed.registerNode(ONodeId node, long version) voidOrientDBDistributed.sendDatabase(ONodeId receiver, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voidOrientDBDistributed.sendMessage(ONodeId node, OStructuralMessage op) 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.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum) voidOrientDBDistributed.enstablish(OGroupId groupId, Set<ONodeId> candidates) OrientDBDistributed.promiseDeclare(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum) voidOrientDBDistributed.sendFirstConnects(Set<ONodeId> nodes) voidOrientDBDistributed.sendMergeOperation(Set<ONodeId> members, OCompleteExecution execution, ONodeStateNetwork otherState) voidOrientDBDistributed.sendMessage(Set<ONodeId> set, OStructuralMessage op) -
Uses of ONodeId in com.orientechnologies.orient.server.distributed.impl
Methods in com.orientechnologies.orient.server.distributed.impl that return ONodeIdConstructors in com.orientechnologies.orient.server.distributed.impl with parameters of type ONodeId