io.openmessaging.storage.dledger.store.file

Class DLedgerMmapFileStore

java.lang.Object

io.openmessaging.storage.dledger.store.DLedgerStore

io.openmessaging.storage.dledger.store.file.DLedgerMmapFileStore

public class DLedgerMmapFileStore
extends DLedgerStore

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	DLedgerMmapFileStore.AppendHook

Field Summary

Fields

Modifier and Type	Field and Description
List<DLedgerMmapFileStore.AppendHook>	appendHooks
static String	CHECK_POINT_FILE
static String	COMMITTED_INDEX_KEY
static int	CURRENT_MAGIC
static String	END_INDEX_KEY
static int	INDEX_UNIT_SIZE
static int	MAGIC_1

Constructor Summary

Constructors

Constructor and Description
DLedgerMmapFileStore(DLedgerConfig dLedgerConfig, MemberState memberState)

Method Summary

Modifier and Type	Method and Description
void	addAppendHook(DLedgerMmapFileStore.AppendHook writeHook)
DLedgerEntry	appendAsFollower(DLedgerEntry entry, long leaderTerm, String leaderId)
DLedgerEntry	appendAsLeader(DLedgerEntry entry)
void	flush()
DLedgerEntry	get(Long index)
long	getCommittedIndex()
long	getCommittedPos()
MmapFileList	getDataFileList()
Pair<Long,Integer>	getEntryPosAndSize(Long index)
long	getFlushPos()
Set<String>	getFullStorePaths()
MmapFileList	getIndexFileList()
long	getLedgerBeginIndex()
long	getLedgerEndIndex()
long	getLedgerEndTerm()
MemberState	getMemberState()
long	getWritePos()
void	indexCheck(Long index)
void	load()
void	recover()
void	resetOffsetAfterSnapshot(DLedgerEntry entry)
void	setEnableCleanSpaceService(boolean enableCleanSpaceService)
void	setFullStorePaths(Set<String> fullStorePaths)
void	shutdown()
void	shutdownFlushService()
void	startup()
long	truncate(DLedgerEntry entry, long leaderTerm, String leaderId)
void	updateCommittedIndex(long term, long newCommittedIndex)

Methods inherited from class io.openmessaging.storage.dledger.store.DLedgerStore

updateLedgerEndIndexAndTerm

Methods inherited from class java.lang.Object

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

Field Detail

CHECK_POINT_FILE

public static final String CHECK_POINT_FILE

See Also:

Constant Field Values

END_INDEX_KEY

public static final String END_INDEX_KEY

See Also:

Constant Field Values

COMMITTED_INDEX_KEY

public static final String COMMITTED_INDEX_KEY

See Also:

Constant Field Values

MAGIC_1

public static final int MAGIC_1

See Also:

Constant Field Values

CURRENT_MAGIC

public static final int CURRENT_MAGIC

See Also:

Constant Field Values

INDEX_UNIT_SIZE

public static final int INDEX_UNIT_SIZE

See Also:

Constant Field Values

appendHooks

public List<DLedgerMmapFileStore.AppendHook> appendHooks

Constructor Detail

DLedgerMmapFileStore

public DLedgerMmapFileStore(DLedgerConfig dLedgerConfig,
                            MemberState memberState)

Method Detail

startup

public void startup()

Overrides:

startup in class DLedgerStore

shutdown

public void shutdown()

Overrides:

shutdown in class DLedgerStore

getWritePos

public long getWritePos()

getFlushPos

public long getFlushPos()

flush

public void flush()

Overrides:

flush in class DLedgerStore

load

public void load()

recover

public void recover()

appendAsLeader

public DLedgerEntry appendAsLeader(DLedgerEntry entry)

Specified by:

appendAsLeader in class DLedgerStore

truncate

public long truncate(DLedgerEntry entry,
                     long leaderTerm,
                     String leaderId)

Overrides:

truncate in class DLedgerStore

resetOffsetAfterSnapshot

public void resetOffsetAfterSnapshot(DLedgerEntry entry)

Overrides:

resetOffsetAfterSnapshot in class DLedgerStore

appendAsFollower

public DLedgerEntry appendAsFollower(DLedgerEntry entry,
                                     long leaderTerm,
                                     String leaderId)

Specified by:

appendAsFollower in class DLedgerStore

getLedgerEndIndex

public long getLedgerEndIndex()

Specified by:

getLedgerEndIndex in class DLedgerStore

getLedgerBeginIndex

public long getLedgerBeginIndex()

Specified by:

getLedgerBeginIndex in class DLedgerStore

get

public DLedgerEntry get(Long index)

Specified by:

get in class DLedgerStore

getEntryPosAndSize

public Pair<Long,Integer> getEntryPosAndSize(Long index)

indexCheck

public void indexCheck(Long index)

getCommittedIndex

public long getCommittedIndex()

Specified by:

getCommittedIndex in class DLedgerStore

updateCommittedIndex

public void updateCommittedIndex(long term,
                                 long newCommittedIndex)

Overrides:

updateCommittedIndex in class DLedgerStore

getLedgerEndTerm

public long getLedgerEndTerm()

Specified by:

getLedgerEndTerm in class DLedgerStore

getCommittedPos

public long getCommittedPos()

addAppendHook

public void addAppendHook(DLedgerMmapFileStore.AppendHook writeHook)

getMemberState

public MemberState getMemberState()

Overrides:

getMemberState in class DLedgerStore

getDataFileList

public MmapFileList getDataFileList()

getIndexFileList

public MmapFileList getIndexFileList()

getFullStorePaths

public Set<String> getFullStorePaths()

setFullStorePaths

public void setFullStorePaths(Set<String> fullStorePaths)

shutdownFlushService

public void shutdownFlushService()

setEnableCleanSpaceService

public void setEnableCleanSpaceService(boolean enableCleanSpaceService)