org.apache.ratis.server.raftlog.memory

类 MemoryRaftLog

java.lang.Object

org.apache.ratis.server.raftlog.RaftLogBase

org.apache.ratis.server.raftlog.memory.MemoryRaftLog

所有已实现的接口:

Closeable, AutoCloseable, RaftLog

public class MemoryRaftLog
extends RaftLogBase

A simple RaftLog implementation in memory. Used only for testing.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	RaftLogSequentialOps.Runner

从接口继承的嵌套类/接口 org.apache.ratis.server.raftlog.RaftLog

RaftLog.EntryWithData

字段概要

从类继承的字段 org.apache.ratis.server.raftlog.RaftLogBase

INVALID_LOG_INDEX, LEAST_VALID_LOG_INDEX

从接口继承的字段 org.apache.ratis.server.raftlog.RaftLog

LOG

构造器概要

构造器

构造器和说明
MemoryRaftLog(RaftGroupMemberId memberId, LongSupplier commitIndexSupplier, RaftProperties properties)

方法概要

限定符和类型	方法和说明
protected CompletableFuture<Long>	appendEntryImpl(org.apache.ratis.proto.RaftProtos.LogEntryProto entry)
List<CompletableFuture<Long>>	appendImpl(org.apache.ratis.proto.RaftProtos.LogEntryProto... logEntryProtos)
org.apache.ratis.proto.RaftProtos.LogEntryProto	get(long index)
LogEntryHeader[]	getEntries(long startIndex, long endIndex)
String	getEntryString()
RaftLog.EntryWithData	getEntryWithData(long index)
long	getFlushIndex()
TermIndex	getLastEntryTermIndex()
RaftLogMetricsBase	getRaftLogMetrics()
long	getStartIndex()
TermIndex	getTermIndex(long index)
RaftStorageMetadata	loadMetadata()
CompletableFuture<Long>	onSnapshotInstalled(long lastSnapshotIndex)
void	persistMetadata(RaftStorageMetadata newMetadata)
protected CompletableFuture<Long>	purgeImpl(long index)
protected CompletableFuture<Long>	truncateImpl(long index)

从类继承的方法 org.apache.ratis.server.raftlog.RaftLogBase

append, append, append, appendEntry, appendMetadata, checkLogState, close, getLastCommittedIndex, getName, getSnapshotIndex, hasReadLock, hasWriteLock, isOpened, newEntryWithData, open, openImpl, purge, readLock, toLogEntryString, toString, truncate, updateCommitIndex, updateSnapshotIndex, updateSnapshotIndexFromStateMachine, validateLogEntry, writeLock

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.ratis.server.raftlog.RaftLog

contains, getNextIndex

构造器详细资料

MemoryRaftLog

public MemoryRaftLog(RaftGroupMemberId memberId,
                     LongSupplier commitIndexSupplier,
                     RaftProperties properties)

方法详细资料

getRaftLogMetrics

public RaftLogMetricsBase getRaftLogMetrics()

get

public org.apache.ratis.proto.RaftProtos.LogEntryProto get(long index)

getEntryWithData

public RaftLog.EntryWithData getEntryWithData(long index)

getTermIndex

public TermIndex getTermIndex(long index)

getEntries

public LogEntryHeader[] getEntries(long startIndex,
                                   long endIndex)

truncateImpl

protected CompletableFuture<Long> truncateImpl(long index)

指定者:

truncateImpl 在类中 RaftLogBase

purgeImpl

protected CompletableFuture<Long> purgeImpl(long index)

指定者:

purgeImpl 在类中 RaftLogBase

getLastEntryTermIndex

public TermIndex getLastEntryTermIndex()

appendEntryImpl

protected CompletableFuture<Long> appendEntryImpl(org.apache.ratis.proto.RaftProtos.LogEntryProto entry)

指定者:

appendEntryImpl 在类中 RaftLogBase

getStartIndex

public long getStartIndex()

appendImpl

public List<CompletableFuture<Long>> appendImpl(org.apache.ratis.proto.RaftProtos.LogEntryProto... logEntryProtos)

指定者:

appendImpl 在类中 RaftLogBase

getEntryString

public String getEntryString()

getFlushIndex

public long getFlushIndex()

persistMetadata

public void persistMetadata(RaftStorageMetadata newMetadata)

loadMetadata

public RaftStorageMetadata loadMetadata()

onSnapshotInstalled

public CompletableFuture<Long> onSnapshotInstalled(long lastSnapshotIndex)