NodeImpl (jraft-core 1.3.14 1.3.14 API)

java.lang.Object
- com.alipay.sofa.jraft.core.NodeImpl

All Implemented Interfaces:

Lifecycle<NodeOptions>, Node, RaftServerService, Describer
```
public class NodeImpl
extends Object
implements Node, RaftServerService
```
The raft replica node implementation.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-03 4:26:51 PM

Nested Class Summary
- Nested classes/interfaces inherited from interface com.alipay.sofa.jraft.util.Describer
  Describer.DefaultPrinter, Describer.Printer

Field Summary

Fields
Modifier and Type Field and Description

static AtomicInteger GLOBAL_NUM_NODES

protected Lock readLock

static RaftTimerFactory TIMER_FACTORY

protected Lock writeLock

Fields
Modifier and Type	Field and Description
`static AtomicInteger`	`GLOBAL_NUM_NODES`
`protected Lock`	`readLock`
`static RaftTimerFactory`	`TIMER_FACTORY`
`protected Lock`	`writeLock`

Constructor Summary

Constructors
Constructor and Description

NodeImpl()

NodeImpl(String groupId, PeerId serverId)

Constructors
Constructor and Description
`NodeImpl()`
`NodeImpl(String groupId, PeerId serverId)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addLearners(List<PeerId> learners, Closure done)` Add some new learners to the raft group.
`void`	`addPeer(PeerId peer, Closure done)` Add a new peer to the raft group.
`void`	`addReplicatorStateListener(Replicator.ReplicatorStateListener replicatorStateListener)` SOFAJRaft users can implement the ReplicatorStateListener interface by themselves.
`void`	`apply(Task task)` [Thread-safe and wait-free] Apply task to the replicated-state-machine About the ownership: \|task.data\|: for the performance consideration, we will take away the content.
`boolean`	`bootstrap(BootstrapOptions opts)`
`void`	`changePeers(Configuration newPeers, Closure done)` Change the configuration of the raft group to \|newPeers\| , done.run() would be invoked after this operation finishes, describing the detailed result.
`void`	`clearReplicatorStateListeners()` Remove all the ReplicatorStateListeners which have been added by users.
`void`	`describe(Describer.Printer out)`
`Configuration`	`getCurrentConf()` Retrieve current configuration this node seen so far.
`String`	`getGroupId()` Get the raft group id.
`long`	`getLastAppliedLogIndex()` Retrieve the last log index that applied to state machine.
`long`	`getLastCommittedIndex()` Retrieve the last log index that committed to the raft group.
`long`	`getLastLogIndex()` Retrieve the last log index in log storage.
`PeerId`	`getLeaderId()` Get the leader peer id for redirect, null if absent.
`NodeId`	`getNodeId()` Get current node id.
`NodeMetrics`	`getNodeMetrics()` Returns the node metrics.
`State`	`getNodeState()` Get the node's state.
`int`	`getNodeTargetPriority()` Get the node's target election priority value.
`NodeOptions`	`getOptions()` Get the node options.
`RaftOptions`	`getRaftOptions()` Get the raft options
`List<Replicator.ReplicatorStateListener>`	`getReplicatorStatueListeners()` Get the ReplicatorStateListeners which have been added by users.
`RaftClientService`	`getRpcService()`
`PeerId`	`getServerId()`
`JRaftServiceFactory`	`getServiceFactory()` Returns the JRaft service factory for current node.
`Scheduler`	`getTimerManager()`
`com.google.protobuf.Message`	`handleAppendEntriesRequest(RpcRequests.AppendEntriesRequest request, RpcRequestClosure done)` Handle append-entries request, return response message or called done.run() with response.
`com.google.protobuf.Message`	`handleInstallSnapshot(RpcRequests.InstallSnapshotRequest request, RpcRequestClosure done)` Handle install-snapshot request, return response message or called done.run() with response.
`com.google.protobuf.Message`	`handlePreVoteRequest(RpcRequests.RequestVoteRequest request)` Handle pre-vote request.
`void`	`handlePreVoteResponse(PeerId peerId, long term, RpcRequests.RequestVoteResponse response)`
`void`	`handleReadIndexRequest(RpcRequests.ReadIndexRequest request, RpcResponseClosure<RpcRequests.ReadIndexResponse> done)` Handle read index request.
`com.google.protobuf.Message`	`handleRequestVoteRequest(RpcRequests.RequestVoteRequest request)` Handle request-vote request.
`void`	`handleRequestVoteResponse(PeerId peerId, long term, RpcRequests.RequestVoteResponse response)`
`com.google.protobuf.Message`	`handleTimeoutNowRequest(RpcRequests.TimeoutNowRequest request, RpcRequestClosure done)` Handle time-out-now request, return response message or called done.run() with response.
`boolean`	`init(NodeOptions opts)` Initialize the service.
`boolean`	`isLeader()` Returns true when the node is leader.
`boolean`	`isLeader(boolean blocking)` Returns true when the node is leader.
`void`	`join()` Block the thread until the node is successfully stopped.
`List<PeerId>`	`listAliveLearners()` List all alive learners of this raft group, only leader returns.
`List<PeerId>`	`listAlivePeers()` List all alive peers of this raft group, only leader returns.
`List<PeerId>`	`listLearners()` List all learners of this raft group, only leader returns.
`List<PeerId>`	`listPeers()` List peers of this raft group, only leader returns.
`void`	`onConfigurationChangeDone(long term)`
`void`	`onError(RaftException error)`
`UserLog`	`readCommittedUserLog(long index)` Read the first committed user log from the given index.
`void`	`readIndex(byte[] requestContext, ReadIndexClosure done)` [Thread-safe and wait-free] Starts a linearizable read-only query request with request context(optional, such as request id etc.) and closure.
`void`	`readIndex(ReadOnlyOption readOnlyOptions, byte[] requestContext, ReadIndexClosure done)` [Thread-safe and wait-free] Specify the ReadOnlyOption to execute a linearizable read-only query request.
`void`	`removeLearners(List<PeerId> learners, Closure done)` Remove some learners from the raft group.
`void`	`removePeer(PeerId peer, Closure done)` Remove the peer from the raft group.
`void`	`removeReplicatorStateListener(Replicator.ReplicatorStateListener replicatorStateListener)` End User can remove their implement the ReplicatorStateListener interface by themselves.
`void`	`resetElectionTimeoutMs(int electionTimeoutMs)` Reset the election_timeout for the every node.
`void`	`resetLearners(List<PeerId> learners, Closure done)` Reset learners in the raft group.
`Status`	`resetPeers(Configuration newPeers)` Reset the configuration of this node individually, without any replication to other peers before this node becomes the leader.
`void`	`shutdown()` Dispose the resources for service.
`void`	`shutdown(Closure done)` Shutdown local replica node.
`void`	`snapshot(Closure done)` Start a snapshot immediately if possible.
`void`	`snapshotSync(Closure done)` Start to snapshot StateMachine immediately with the latest log applied to state machine.
`String`	`toString()`
`Status`	`transferLeadershipTo(PeerId peer)` Try transferring leadership to \|peer\|.
`void`	`updateConfigurationAfterInstallingSnapshot()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - TIMER_FACTORY
```
public static final RaftTimerFactory TIMER_FACTORY
```
  - GLOBAL_NUM_NODES
```
public static final AtomicInteger GLOBAL_NUM_NODES
```
  - writeLock
```
protected final Lock writeLock
```
  - readLock
```
protected final Lock readLock
```
- Constructor Detail
  - NodeImpl
```
public NodeImpl()
```
  - NodeImpl
```
public NodeImpl(String groupId,
                PeerId serverId)
```
- Method Detail
  - bootstrap
```
public boolean bootstrap(BootstrapOptions opts)
                  throws InterruptedException
```
    Throws:
    
    InterruptedException
  - init
```
public boolean init(NodeOptions opts)
```
    Description copied from interface: Lifecycle
    
    Initialize the service.
    
    Specified by:
    
    init in interface Lifecycle<NodeOptions>
    
    Returns:
    
    true when successes.
  - getNodeMetrics
```
public NodeMetrics getNodeMetrics()
```
    Returns the node metrics.
    
    Specified by:
    
    getNodeMetrics in interface Node
    
    Returns:
    
    returns metrics of current node.
  - getServiceFactory
```
public JRaftServiceFactory getServiceFactory()
```
    Returns the JRaft service factory for current node.
    
    Returns:
    
    the service factory
    
    Since:
    
    1.2.6
  - readIndex
```
public void readIndex(byte[] requestContext,
                      ReadIndexClosure done)
```
    Description copied from interface: Node
    
    [Thread-safe and wait-free] Starts a linearizable read-only query request with request context(optional, such as request id etc.) and closure. The default value of ReadOnlyOption is ReadOnlyOption.ReadOnlySafe. The closure will be called when the request is completed, and user can read data from state machine if the result status is OK.
    
    Specified by:
    
    readIndex in interface Node
    
    Parameters:
    
    requestContext - the context of request
    
    done - callback
  - readIndex
```
public void readIndex(ReadOnlyOption readOnlyOptions,
                      byte[] requestContext,
                      ReadIndexClosure done)
```
    Description copied from interface: Node
    
    [Thread-safe and wait-free] Specify the ReadOnlyOption to execute a linearizable read-only query request.
    
    Specified by:
    
    readIndex in interface Node
    
    Parameters:
    
    readOnlyOptions - how the read only request is processed
    
    requestContext - the context of request
    
    done - callback
  - handleReadIndexRequest
```
public void handleReadIndexRequest(RpcRequests.ReadIndexRequest request,
                                   RpcResponseClosure<RpcRequests.ReadIndexResponse> done)
```
    Handle read index request.
    
    Specified by:
    
    handleReadIndexRequest in interface RaftServerService
    
    Parameters:
    
    request - data of the readIndex read
    
    done - callback
  - apply
```
public void apply(Task task)
```
    Description copied from interface: Node
    
    [Thread-safe and wait-free] Apply task to the replicated-state-machine About the ownership: |task.data|: for the performance consideration, we will take away the content. If you want keep the content, copy it before call this function |task.done|: If the data is successfully committed to the raft group. We will pass the ownership to #StateMachine.onApply(Iterator). Otherwise we will specify the error and call it.
    
    Specified by:
    
    apply in interface Node
    
    Parameters:
    
    task - task to apply
  - handlePreVoteRequest
```
public com.google.protobuf.Message handlePreVoteRequest(RpcRequests.RequestVoteRequest request)
```
    Description copied from interface: RaftServerService
    
    Handle pre-vote request.
    
    Specified by:
    
    handlePreVoteRequest in interface RaftServerService
    
    Parameters:
    
    request - data of the pre vote
    
    Returns:
    
    the response message
  - handleRequestVoteRequest
```
public com.google.protobuf.Message handleRequestVoteRequest(RpcRequests.RequestVoteRequest request)
```
    Description copied from interface: RaftServerService
    
    Handle request-vote request.
    
    Specified by:
    
    handleRequestVoteRequest in interface RaftServerService
    
    Parameters:
    
    request - data of the vote
    
    Returns:
    
    the response message
  - handleAppendEntriesRequest
```
public com.google.protobuf.Message handleAppendEntriesRequest(RpcRequests.AppendEntriesRequest request,
                                                              RpcRequestClosure done)
```
    Description copied from interface: RaftServerService
    
    Handle append-entries request, return response message or called done.run() with response.
    
    Specified by:
    
    handleAppendEntriesRequest in interface RaftServerService
    
    Parameters:
    
    request - data of the entries to append
    
    done - callback
    
    Returns:
    
    the response message
  - getOptions
```
public NodeOptions getOptions()
```
    Description copied from interface: Node
    
    Get the node options.
    
    Specified by:
    
    getOptions in interface Node
  - getTimerManager
```
public Scheduler getTimerManager()
```
  - getRaftOptions
```
public RaftOptions getRaftOptions()
```
    Description copied from interface: Node
    
    Get the raft options
    
    Specified by:
    
    getRaftOptions in interface Node
  - shutdown
```
public void shutdown()
```
    Description copied from interface: Lifecycle
    
    Dispose the resources for service.
    
    Specified by:
    
    shutdown in interface Lifecycle<NodeOptions>
  - onConfigurationChangeDone
```
public void onConfigurationChangeDone(long term)
```
  - getLeaderId
```
public PeerId getLeaderId()
```
    Description copied from interface: Node
    
    Get the leader peer id for redirect, null if absent.
    
    Specified by:
    
    getLeaderId in interface Node
  - getGroupId
```
public String getGroupId()
```
    Description copied from interface: Node
    
    Get the raft group id.
    
    Specified by:
    
    getGroupId in interface Node
  - getServerId
```
public PeerId getServerId()
```
  - getNodeId
```
public NodeId getNodeId()
```
    Description copied from interface: Node
    
    Get current node id.
    
    Specified by:
    
    getNodeId in interface Node
  - getRpcService
```
public RaftClientService getRpcService()
```
  - onError
```
public void onError(RaftException error)
```
  - handleRequestVoteResponse
```
public void handleRequestVoteResponse(PeerId peerId,
                                      long term,
                                      RpcRequests.RequestVoteResponse response)
```
  - handlePreVoteResponse
```
public void handlePreVoteResponse(PeerId peerId,
                                  long term,
                                  RpcRequests.RequestVoteResponse response)
```
  - isLeader
```
public boolean isLeader()
```
    Description copied from interface: Node
    
    Returns true when the node is leader.
    
    Specified by:
    
    isLeader in interface Node
  - isLeader
```
public boolean isLeader(boolean blocking)
```
    Description copied from interface: Node
    
    Returns true when the node is leader.
    
    Specified by:
    
    isLeader in interface Node
    
    Parameters:
    
    blocking - if true, will be blocked until the node finish it's state change
  - shutdown
```
public void shutdown(Closure done)
```
    Description copied from interface: Node
    
    Shutdown local replica node.
    
    Specified by:
    
    shutdown in interface Node
    
    Parameters:
    
    done - callback
  - join
```
public void join()
          throws InterruptedException
```
    Description copied from interface: Node
    
    Block the thread until the node is successfully stopped.
    
    Specified by:
    
    join in interface Node
    
    Throws:
    
    InterruptedException - if the current thread is interrupted while waiting
  - getCurrentConf
```
public Configuration getCurrentConf()
```
    Retrieve current configuration this node seen so far. It's not a reliable way to retrieve cluster peers info, you should use listPeers() instead.
    
    Returns:
    
    current configuration.
    
    Since:
    
    1.0.3
  - listPeers
```
public List<PeerId> listPeers()
```
    Description copied from interface: Node
    
    List peers of this raft group, only leader returns. [NOTE] when list_peers concurrency with Node.addPeer(PeerId, Closure)/Node.removePeer(PeerId, Closure), maybe return peers is staled. Because Node.addPeer(PeerId, Closure)/Node.removePeer(PeerId, Closure) immediately modify configuration in memory
    
    Specified by:
    
    listPeers in interface Node
    
    Returns:
    
    the peer list
  - listAlivePeers
```
public List<PeerId> listAlivePeers()
```
    Description copied from interface: Node
    
    List all alive peers of this raft group, only leader returns.
    [NOTE] list_alive_peers is just a transient data (snapshot) and a short-term loss of response by the follower will cause it to temporarily not exist in this list.
    
    Specified by:
    
    listAlivePeers in interface Node
    
    Returns:
    
    the alive peer list
  - listLearners
```
public List<PeerId> listLearners()
```
    Description copied from interface: Node
    
    List all learners of this raft group, only leader returns.
    [NOTE] when listLearners concurrency with Node.addLearners(List, Closure)/Node.removeLearners(List, Closure)/Node.resetLearners(List, Closure), maybe return peers is staled. Because Node.addLearners(List, Closure)/Node.removeLearners(List, Closure)/Node.resetLearners(List, Closure) immediately modify configuration in memory
    
    Specified by:
    
    listLearners in interface Node
    
    Returns:
    
    the learners set
  - listAliveLearners
```
public List<PeerId> listAliveLearners()
```
    Description copied from interface: Node
    
    List all alive learners of this raft group, only leader returns.
    [NOTE] when listAliveLearners concurrency with Node.addLearners(List, Closure)/Node.removeLearners(List, Closure)/Node.resetLearners(List, Closure), maybe return peers is staled. Because Node.addLearners(List, Closure)/Node.removeLearners(List, Closure)/Node.resetLearners(List, Closure) immediately modify configuration in memory
    
    Specified by:
    
    listAliveLearners in interface Node
    
    Returns:
    
    the alive learners set
  - addPeer
```
public void addPeer(PeerId peer,
                    Closure done)
```
    Description copied from interface: Node
    
    Add a new peer to the raft group. done.run() would be invoked after this operation finishes, describing the detailed result.
    
    Specified by:
    
    addPeer in interface Node
    
    Parameters:
    
    peer - peer to add
    
    done - callback
  - removePeer
```
public void removePeer(PeerId peer,
                       Closure done)
```
    Description copied from interface: Node
    
    Remove the peer from the raft group. done.run() would be invoked after operation finishes, describing the detailed result.
    
    Specified by:
    
    removePeer in interface Node
    
    Parameters:
    
    peer - peer to remove
    
    done - callback
  - changePeers
```
public void changePeers(Configuration newPeers,
                        Closure done)
```
    Description copied from interface: Node
    
    Change the configuration of the raft group to |newPeers| , done.run() would be invoked after this operation finishes, describing the detailed result.
    
    Specified by:
    
    changePeers in interface Node
    
    Parameters:
    
    newPeers - new peers to change
    
    done - callback
  - resetPeers
```
public Status resetPeers(Configuration newPeers)
```
    Description copied from interface: Node
    
    Reset the configuration of this node individually, without any replication to other peers before this node becomes the leader. This function is supposed to be invoked when the majority of the replication group are dead and you'd like to revive the service in the consideration of availability. Notice that neither consistency nor consensus are guaranteed in this case, BE CAREFUL when dealing with this method.
    
    Specified by:
    
    resetPeers in interface Node
    
    Parameters:
    
    newPeers - new peers
  - addLearners
```
public void addLearners(List<PeerId> learners,
                        Closure done)
```
    Description copied from interface: Node
    
    Add some new learners to the raft group. done.run() will be invoked after this operation finishes, describing the detailed result.
    
    Specified by:
    
    addLearners in interface Node
    
    Parameters:
    
    learners - learners to add
    
    done - callback
  - removeLearners
```
public void removeLearners(List<PeerId> learners,
                           Closure done)
```
    Description copied from interface: Node
    
    Remove some learners from the raft group. done.run() will be invoked after this operation finishes, describing the detailed result.
    
    Specified by:
    
    removeLearners in interface Node
    
    Parameters:
    
    learners - learners to remove
    
    done - callback
  - resetLearners
```
public void resetLearners(List<PeerId> learners,
                          Closure done)
```
    Description copied from interface: Node
    
    Reset learners in the raft group. done.run() will be invoked after this operation finishes, describing the detailed result.
    
    Specified by:
    
    resetLearners in interface Node
    
    Parameters:
    
    learners - learners to set
    
    done - callback
  - snapshot
```
public void snapshot(Closure done)
```
    Description copied from interface: Node
    
    Start a snapshot immediately if possible. done.run() would be invoked when the snapshot finishes, describing the detailed result.
    
    Specified by:
    
    snapshot in interface Node
    
    Parameters:
    
    done - callback
  - snapshotSync
```
public void snapshotSync(Closure done)
```
    Description copied from interface: Node
    
    Start to snapshot StateMachine immediately with the latest log applied to state machine. You MUST call this method in StateMachine callback methods to trigger a snapshot synchronously, otherwise throws IllegalStateException. And done.run() would be invoked when the snapshot finishes, describing the detailed result.
    
    Specified by:
    
    snapshotSync in interface Node
    
    Parameters:
    
    done - snapshot callback
  - resetElectionTimeoutMs
```
public void resetElectionTimeoutMs(int electionTimeoutMs)
```
    Description copied from interface: Node
    
    Reset the election_timeout for the every node.
    
    Specified by:
    
    resetElectionTimeoutMs in interface Node
    
    Parameters:
    
    electionTimeoutMs - the timeout millis of election
  - transferLeadershipTo
```
public Status transferLeadershipTo(PeerId peer)
```
    Description copied from interface: Node
    
    Try transferring leadership to |peer|. If peer is ANY_PEER, a proper follower will be chosen as the leader for the next term. Returns 0 on success, -1 otherwise.
    
    Specified by:
    
    transferLeadershipTo in interface Node
    
    Parameters:
    
    peer - the target peer of new leader
    
    Returns:
    
    operation status
  - handleTimeoutNowRequest
```
public com.google.protobuf.Message handleTimeoutNowRequest(RpcRequests.TimeoutNowRequest request,
                                                           RpcRequestClosure done)
```
    Description copied from interface: RaftServerService
    
    Handle time-out-now request, return response message or called done.run() with response.
    
    Specified by:
    
    handleTimeoutNowRequest in interface RaftServerService
    
    Parameters:
    
    request - data of the timeout now request
    
    done - callback
    
    Returns:
    
    the response message
  - handleInstallSnapshot
```
public com.google.protobuf.Message handleInstallSnapshot(RpcRequests.InstallSnapshotRequest request,
                                                         RpcRequestClosure done)
```
    Description copied from interface: RaftServerService
    
    Handle install-snapshot request, return response message or called done.run() with response.
    
    Specified by:
    
    handleInstallSnapshot in interface RaftServerService
    
    Parameters:
    
    request - data of the install snapshot request
    
    done - callback
    
    Returns:
    
    the response message
  - updateConfigurationAfterInstallingSnapshot
```
public void updateConfigurationAfterInstallingSnapshot()
```
  - readCommittedUserLog
```
public UserLog readCommittedUserLog(long index)
```
    Description copied from interface: Node
    
    Read the first committed user log from the given index. Return OK on success and user_log is assigned with the very data. Be awared that the user_log may be not the exact log at the given index, but the first available user log from the given index to lastCommittedIndex. Otherwise, appropriate errors are returned: - return ELOGDELETED when the log has been deleted; - return ENOMOREUSERLOG when we can't get a user log even reaching lastCommittedIndex. [NOTE] in consideration of safety, we use lastAppliedIndex instead of lastCommittedIndex in code implementation.
    
    Specified by:
    
    readCommittedUserLog in interface Node
    
    Parameters:
    
    index - log index
    
    Returns:
    
    user log entry
  - addReplicatorStateListener
```
public void addReplicatorStateListener(Replicator.ReplicatorStateListener replicatorStateListener)
```
    Description copied from interface: Node
    
    SOFAJRaft users can implement the ReplicatorStateListener interface by themselves. So users can do their own logical operator in this listener when replicator created, destroyed or had some errors.
    
    Specified by:
    
    addReplicatorStateListener in interface Node
    
    Parameters:
    
    replicatorStateListener - added ReplicatorStateListener which is implemented by users.
  - removeReplicatorStateListener
```
public void removeReplicatorStateListener(Replicator.ReplicatorStateListener replicatorStateListener)
```
    Description copied from interface: Node
    
    End User can remove their implement the ReplicatorStateListener interface by themselves.
    
    Specified by:
    
    removeReplicatorStateListener in interface Node
    
    Parameters:
    
    replicatorStateListener - need to remove the ReplicatorStateListener which has been added by users.
  - clearReplicatorStateListeners
```
public void clearReplicatorStateListeners()
```
    Description copied from interface: Node
    
    Remove all the ReplicatorStateListeners which have been added by users.
    
    Specified by:
    
    clearReplicatorStateListeners in interface Node
  - getReplicatorStatueListeners
```
public List<Replicator.ReplicatorStateListener> getReplicatorStatueListeners()
```
    Description copied from interface: Node
    
    Get the ReplicatorStateListeners which have been added by users.
    
    Specified by:
    
    getReplicatorStatueListeners in interface Node
    
    Returns:
    
    node's replicatorStatueListeners which have been added by users.
  - getNodeTargetPriority
```
public int getNodeTargetPriority()
```
    Description copied from interface: Node
    
    Get the node's target election priority value.
    
    Specified by:
    
    getNodeTargetPriority in interface Node
    
    Returns:
    
    node's target election priority value.
  - getNodeState
```
public State getNodeState()
```
    Description copied from interface: Node
    
    Get the node's state.
    
    Specified by:
    
    getNodeState in interface Node
    
    Returns:
    
    node's state.
  - getLastLogIndex
```
public long getLastLogIndex()
```
    Description copied from interface: Node
    
    Retrieve the last log index in log storage. Note: the last log may not be committed to raft group, and may be truncated in some cases.
    
    Specified by:
    
    getLastLogIndex in interface Node
    
    Returns:
    
    the last log index
  - getLastCommittedIndex
```
public long getLastCommittedIndex()
```
    Description copied from interface: Node
    
    Retrieve the last log index that committed to the raft group.
    
    Specified by:
    
    getLastCommittedIndex in interface Node
    
    Returns:
    
    the last committed log index
  - getLastAppliedLogIndex
```
public long getLastAppliedLogIndex()
```
    Description copied from interface: Node
    
    Retrieve the last log index that applied to state machine.
    
    Specified by:
    
    getLastAppliedLogIndex in interface Node
    
    Returns:
    
    the last applied log index
  - describe
```
public void describe(Describer.Printer out)
```
    Specified by:
    
    describe in interface Describer
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object

Class NodeImpl

Nested Class Summary

Nested classes/interfaces inherited from interface com.alipay.sofa.jraft.util.Describer

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

TIMER_FACTORY

GLOBAL_NUM_NODES

writeLock

readLock

Constructor Detail

NodeImpl

NodeImpl

Method Detail

bootstrap

init

getNodeMetrics

getServiceFactory

readIndex

readIndex

handleReadIndexRequest

apply

handlePreVoteRequest

handleRequestVoteRequest

handleAppendEntriesRequest

getOptions

getTimerManager

getRaftOptions

shutdown

onConfigurationChangeDone

getLeaderId

getGroupId

getServerId

getNodeId

getRpcService

onError

handleRequestVoteResponse

handlePreVoteResponse

isLeader

isLeader

shutdown

join

getCurrentConf

listPeers

listAlivePeers

listLearners

listAliveLearners

addPeer

removePeer

changePeers

resetPeers

addLearners

removeLearners

resetLearners

snapshot

snapshotSync

resetElectionTimeoutMs

transferLeadershipTo

handleTimeoutNowRequest

handleInstallSnapshot

updateConfigurationAfterInstallingSnapshot

readCommittedUserLog

addReplicatorStateListener

removeReplicatorStateListener

clearReplicatorStateListeners

getReplicatorStatueListeners

getNodeTargetPriority

getNodeState

getLastLogIndex

getLastCommittedIndex

getLastAppliedLogIndex

describe

toString