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 TypeMethodDescriptionOResponseCollectorImpl.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) voidOCoordinatedDistributedOpsImpl.cancelSetState(ODatabaseId dbId, 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) voidOCoordinatedDistributedOps.confirmMerge(ONodeId node, OTransactionIdPromise promise, boolean accepted) voidOCoordinatedDistributedOpsImpl.confirmMerge(ONodeId node, OTransactionIdPromise promise, boolean 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) 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) 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) 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) voidOCoordinatedDistributedOpsImpl.unregisterNode(ONodeId node, long version) booleanOCoordinatedDistributedOps.validateMerge(OGroupId group, ONodeId coordinator) booleanOCoordinatedDistributedOpsImpl.validateMerge(OGroupId group, ONodeId coordinator) 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) Method parameters in com.orientechnologies.orient.distributed.context.coordination with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidOCoordinatedDistributedOps.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) OCoordinatedDistributedOps.startEstablish(Set<ONodeId> nodes, OCompleteAction action) OCoordinatedDistributedOpsImpl.startEstablish(Set<ONodeId> nodes, OCompleteAction action) 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.validateEstablish(OGroupId networkId, Set<ONodeId> candidates) OCoordinatedDistributedOpsImpl.validateEstablish(OGroupId groupId, Set<ONodeId> candidates) 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) 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) voidOStandardCompleteAction.complete(OTransactionIdPromise promise, Set<ONodeId> nodes, Optional<OAcceptResult> result) voidOCompleteAction.failure(OTransactionIdPromise promise, Set<ONodeId> all, Optional<OAcceptResult> optional) 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) OStandardCompleteAction.newResponseCollector(OTransactionIdPromise promise, int quorum, Set<ONodeId> nodes) voidOCompleteAction.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) voidODatabaseTopologyState.cancelSetState(ONodeId nodeId, long version) 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) voidODatabasesTopologyState.declareNode(ODatabaseId db, String name, ONodeId node, ONodeRole role, ODatabaseState state) voidODatabaseTopologyState.defineNode(ONodeId node, ONodeRole role, ODatabaseState state, long version) 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) 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) 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) booleanODatabasesTopologyState.waitOnline(ODatabaseId dbId, ONodeId nodeId) Method parameters in com.orientechnologies.orient.distributed.context.coordination.dbs with type arguments of type ONodeIdModifier and TypeMethodDescriptionvoidODatabasesTopologyState.declareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) ODatabasesTopologyState.validateDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum) Constructors in com.orientechnologies.orient.distributed.context.coordination.dbs with parameters of type ONodeIdModifierConstructorDescriptionONodeDatabaseState(ONodeId node, ONodeRole role, ODatabaseState state) Constructor parameters in com.orientechnologies.orient.distributed.context.coordination.dbs with type arguments of type ONodeIdModifierConstructorDescriptionODatabaseTopologyState(ODatabaseId db, String name, Set<ONodeId> partecipants, int quorum, ODatabaseStateChangeListener stateListener) -
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, boolean 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 ONodeIdModifier and TypeMethodDescriptionOEstablishTopology.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) OEstablishTopology(OGroupId groupId, Set<ONodeId> candidates) -
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.Constructors in com.orientechnologies.orient.distributed.context.coordination.result with parameters of type ONodeIdModifierConstructorDescriptionOMissingNode(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) 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 TypeMethodDescriptionbooleanOTopologyManager.acceptMerge(OGroupId group, ONodeId coordinator) protected booleanOTopologyEvents.nodeDiscovered(ONodeId node) OTopologyManager.nodeDiscovered(ONodeId node) OTopologyManager.nodeJoinStart(ONodeId node, OTopologyStateNetwork externState, boolean merge) OTopologyManager.promiseRegister(ONodeId toAdd, long version) voidvoidOTopologyManager.unregister(ONodeId node, long version) 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) OTopologyManager.validateEstablish(OGroupId groupId, Set<ONodeId> candidates) 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.Methods in com.orientechnologies.orient.distributed.context.retryable that return types with arguments of type ONodeIdModifier and TypeMethodDescriptionODeclareDatabaseRetryOperation.currentMembers()Returns the value of thecurrentMembersrecord 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.Constructor parameters in com.orientechnologies.orient.distributed.context.retryable with type arguments of type ONodeIdModifierConstructorDescriptionODeclareDatabaseRetryOperation(ODatabaseId dbId, String name, Set<ONodeId> currentMembers) Creates an instance of aODeclareDatabaseRetryOperationrecord 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, boolean accepted) voidvoidOrientDBDistributed.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) 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.declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum) voidOrientDBDistributed.promiseDeclare(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum) 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