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) OTransactionIdPromise.retrySequence(ONodeId node) 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()ODistributedResponse.getNode()ONodeState.getNodeId()Methods in com.orientechnologies.orient.distributed.context that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionONetworkTopologyStore.getMembers()ONodeState.getNetworkMembers()Methods in com.orientechnologies.orient.distributed.context with parameters of type ONodeIdModifier and TypeMethodDescriptionvoidONodeState.failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult) voidONodeState.success(ONodeId node, OTransactionIdPromise promise) Constructors in com.orientechnologies.orient.distributed.context with parameters of type ONodeIdModifierConstructorDescriptionODatabaseNodeStore(ONodeId id, ONodeRole role) ONodeState(ONodeId current, OGroupId groupId, int minimumQuorum, OStateStore store, ODatabaseStateChangeListener listener) Constructor parameters in com.orientechnologies.orient.distributed.context with type arguments of type ONodeIdModifierConstructorDescriptionONetworkTopologyStore(OGroupId groupId, OTopologyState state, Set<ONodeId> members, int quorum, long version) -
Uses of ONodeId in com.orientechnologies.orient.distributed.context.coordination
Methods in com.orientechnologies.orient.distributed.context.coordination that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionOCoordinatedDistributedOps.establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.establish(OGroupId groupId, Set<ONodeId> candidates, OTransactionIdPromise promise) OResponseCollectorImpl.getExpected()OResponseCollectorMerge.getExpected()OCoordinatedDistributedOps.getNetworkMembers()OCoordinatedDistributedOpsImpl.getNetworkMembers()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, ONodeId receiver, ODatabaseId dbId, OSyncId syncId) booleanOCoordinatedDistributedOpsImpl.acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId) voidOCoordinatedDistributedOps.cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version, OTransactionIdPromise promise) 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) voidOCoordinatedDistributedOps.confirmMerge(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted) voidOCoordinatedDistributedOpsImpl.confirmMerge(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted) 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) 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.nodeSuccess(ONodeId node, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.nodeSuccess(ONodeId node, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.registerNode(ONodeId node, long version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.registerNode(ONodeId node, long version, OTransactionIdPromise promise) voidOCoordinatedDistributedOps.setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version, OTransactionIdPromise promise) 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) voidOCoordinatedDistributedOps.unregisterNode(ONodeId node, long version, OTransactionIdPromise promise) voidOCoordinatedDistributedOpsImpl.unregisterNode(ONodeId node, long version, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateRegisterNode(ONodeId node, long version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateRegisterNode(ONodeId node, long version, OTransactionIdPromise promise) OCoordinatedDistributedOps.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version, OTransactionIdPromise promise) Method parameters in com.orientechnologies.orient.distributed.context.coordination with type arguments of type ONodeIdModifier and TypeMethodDescriptionOCoordinatedDistributedOps.establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise) OCoordinatedDistributedOpsImpl.establish(OGroupId groupId, Set<ONodeId> candidates, 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) 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) 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, 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.getOnlineNodes(ODatabaseId dbId) ODatabasesTopologyState.getOnlineNodes(ODatabaseId dbId) ODatabaseTopologyState.getOnlineNodes()Methods in com.orientechnologies.orient.distributed.context.coordination.dbs with parameters of type ONodeIdModifier and TypeMethodDescriptionbooleanODatabasesTopologyState.acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId) booleanODatabaseTopologyState.acceptSync(ONodeId sender, ONodeId receiver, OSyncId syncId) voidODatabasesTopologyState.cancelSetState(ODatabaseId dbId, ONodeId nodeId, long version, OTransactionIdPromise promise) voidODatabaseTopologyState.cancelSetState(ONodeId nodeId, long version, OTransactionIdPromise promise) 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) 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) voidODatabaseStateChangeListener.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state) ODatabaseTopologyState.promiseState(ODatabaseState state, ONodeId nodeId, long version, OTransactionIdPromise promise) voidODatabasesTopologyState.setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version, OTransactionIdPromise promise) voidODatabaseTopologyState.setState(ONodeId node, ODatabaseState state, long version, OTransactionIdPromise promise) booleanODatabasesTopology.shouldSink(ODatabaseId dbId, ONodeId nodeID) booleanODatabasesTopologyState.shouldSink(ODatabaseId dbId, ONodeId nodeID) booleanODatabaseTopologyState.shouldSink(ONodeId nodeID) 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) ODatabasesTopologyState.validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version, OTransactionIdPromise promise) booleanODatabasesTopologyState.waitOnline(ODatabaseId dbId, ONodeId nodeId) 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) -
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()OMergeResult.getNode()OFailPropose.getNodeId()ONodeFirstConnect.getNodeId()OSuccessPropose.getNodeId()OStartSync.getReceiver()OCanSync.getSender()Constructors 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) OFailPropose(ONodeId nodeId, OTransactionIdPromise promise, OAcceptResult acceptResult) OMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted) ONodeFirstConnect(ONodeId nodeId, ONodeStateNetwork state, boolean merge) 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) -
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 ONodeIdConstructors 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 ONodeId -
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, long 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 ONodeIdMethods 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, ONodeId receiver, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) Constructors in com.orientechnologies.orient.distributed.context.coordination.sync with parameters of type ONodeIdModifierConstructorDescriptionOSyncSession(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.coordination.sync with type arguments of type ONodeIdModifierConstructorDescriptionCreates an instance of aOSyncInforecord class.OSyncSession(ODatabaseId dbId, 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 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 TypeMethodDescriptionODiscoverAction.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 booleanOTopologyEvents.nodeDiscovered(ONodeId node) OTopologyManager.nodeDiscovered(ONodeId node) OTopologyManager.nodeJoinStart(ONodeId node, OTopologyStateNetwork externState, boolean merge) OTopologyManager.promiseRegister(ONodeId toAdd, long version, OTransactionIdPromise promise) voidOTopologyManager.register(ONodeId toRegister, long version, OTransactionIdPromise promise) voidOTopologyManager.unregister(ONodeId node, long version, OTransactionIdPromise promise) 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 TypeMethodDescriptionOSetDatabaseStateRetryOperation.node()Returns the value of thenoderecord component.Constructors in com.orientechnologies.orient.distributed.context.retryable with parameters of type ONodeIdModifierConstructorDescriptionOSetDatabaseStateRetryOperation(ONodeId node, ODatabaseId dbId, ODatabaseState state) Creates an instance of aOSetDatabaseStateRetryOperationrecord 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) voidOrientDBDistributed.confirmMerge(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted) voidvoidOrientDBDistributed.disconnected(ONodeId node) voidOrientDBDistributed.firstConnect(ONodeId nodeId, ONodeStateNetwork state, boolean merge) OrientDBDistributed.getDatabaseStatus(ONodeId nodeId, String dbName) voidOrientDBDistributed.onStateChange(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state) voidOrientDBDistributed.registerNode(ONodeId node, long version, OTransactionIdPromise promise) voidOrientDBDistributed.sendDatabase(ONodeId receiver, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voidOrientDBDistributed.sendMergeNodeAction(ONodeId node, OCompleteExecution execution) voidOrientDBDistributed.sendMergeOperation(ONodeId requestToMerge, OCompleteExecution execution) 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.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.distributed
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) voidvoidOLoggerDistributed.infoNode(ONodeId node, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributedImpl.infoNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributed.warnNode(ONodeId node, String message, Throwable exception, Object... additionalArgs) voidvoidOLoggerDistributedImpl.warnNode(ONodeId localNode, String message, Throwable exception, Object... additionalArgs) -
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