com.alipay.sofa.jraft.core

Class IteratorImpl

java.lang.Object

com.alipay.sofa.jraft.core.IteratorImpl

public class IteratorImpl
extends Object

The iterator implementation.

Author:

boyan (boyan@alibaba-inc.com) 2018-Apr-03 3:28:37 PM

Constructor Summary

Constructors

Constructor and Description
IteratorImpl(FSMCallerImpl fsmCaller, LogManager logManager, List<Closure> closures, long firstClosureIndex, long lastAppliedIndex, long committedIndex, AtomicLong applyingIndex)

Method Summary

Modifier and Type	Method and Description
boolean	commit()
void	commitAndSnapshotSync(Closure done)
Closure	done()
LogEntry	entry()
boolean	getAutoCommitPerLog()
RaftException	getError()
long	getIndex()
boolean	hasError()
boolean	isGood()
void	next() Move to next
protected void	runTheRestClosureWithError()
void	setAutoCommitPerLog(boolean status)
void	setErrorAndRollback(long ntail, Status st)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

IteratorImpl

public IteratorImpl(FSMCallerImpl fsmCaller,
                    LogManager logManager,
                    List<Closure> closures,
                    long firstClosureIndex,
                    long lastAppliedIndex,
                    long committedIndex,
                    AtomicLong applyingIndex)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

entry

public LogEntry entry()

getError

public RaftException getError()

isGood

public boolean isGood()

hasError

public boolean hasError()

setAutoCommitPerLog

public void setAutoCommitPerLog(boolean status)

getAutoCommitPerLog

public boolean getAutoCommitPerLog()

next

public void next()

Move to next

getIndex

public long getIndex()

done

public Closure done()

runTheRestClosureWithError

protected void runTheRestClosureWithError()

commit

public boolean commit()

commitAndSnapshotSync

public void commitAndSnapshotSync(Closure done)

setErrorAndRollback

public void setErrorAndRollback(long ntail,
                                Status st)