com.alipay.sofa.jraft.storage.impl

Class BDBLogStorage

java.lang.Object

com.alipay.sofa.jraft.storage.impl.BDBLogStorage

All Implemented Interfaces:

Lifecycle<LogStorageOptions>, LogStorage, Storage, Describer

public class BDBLogStorage
extends Object
implements LogStorage, Describer

Log storage based on bdb.

Author:

cff

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 byte[]	FIRST_LOG_IDX_KEY First log index and last log index key in configuration column family.

Constructor Summary

Constructors

Constructor and Description
BDBLogStorage(String homePath, RaftOptions raftOptions)

Method Summary

Modifier and Type	Method and Description
int	appendEntries(List<LogEntry> entries)
boolean	appendEntry(LogEntry entry)
void	describe(Describer.Printer out)
LogEntry	getEntry(long index)
long	getFirstLogIndex()
protected byte[]	getKeyBytes(long index)
protected com.sleepycat.je.DatabaseEntry	getKeyDatabaseEntry(long index)
long	getLastLogIndex()
long	getTerm(long index)
boolean	init(LogStorageOptions opts)
protected boolean	isSuccessOperation(com.sleepycat.je.OperationStatus status)
boolean	reset(long nextLogIndex)
void	shutdown()
protected com.sleepycat.je.DatabaseEntry	toDatabaseEntry(LogEntry logEntry)
protected LogEntry	toLogEntry(com.sleepycat.je.DatabaseEntry logEntry)
boolean	truncatePrefix(long firstIndexKept)
boolean	truncateSuffix(long lastIndexKept)

Methods inherited from class java.lang.Object

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

Field Detail

FIRST_LOG_IDX_KEY

public static final byte[] FIRST_LOG_IDX_KEY

First log index and last log index key in configuration column family.

Constructor Detail

BDBLogStorage

public BDBLogStorage(String homePath,
                     RaftOptions raftOptions)

Method Detail

init

public boolean init(LogStorageOptions opts)

Specified by:

init in interface Lifecycle<LogStorageOptions>

shutdown

public void shutdown()

Specified by:

shutdown in interface Lifecycle<LogStorageOptions>

describe

public void describe(Describer.Printer out)

Specified by:

describe in interface Describer

getFirstLogIndex

public long getFirstLogIndex()

Specified by:

getFirstLogIndex in interface LogStorage

getLastLogIndex

public long getLastLogIndex()

Specified by:

getLastLogIndex in interface LogStorage

getEntry

public LogEntry getEntry(long index)

Specified by:

getEntry in interface LogStorage

getTerm

public long getTerm(long index)

Specified by:

getTerm in interface LogStorage

appendEntry

public boolean appendEntry(LogEntry entry)

Specified by:

appendEntry in interface LogStorage

appendEntries

public int appendEntries(List<LogEntry> entries)

Specified by:

appendEntries in interface LogStorage

truncatePrefix

public boolean truncatePrefix(long firstIndexKept)

Specified by:

truncatePrefix in interface LogStorage

truncateSuffix

public boolean truncateSuffix(long lastIndexKept)

Specified by:

truncateSuffix in interface LogStorage

reset

public boolean reset(long nextLogIndex)

Specified by:

reset in interface LogStorage

getKeyBytes

protected byte[] getKeyBytes(long index)

getKeyDatabaseEntry

protected com.sleepycat.je.DatabaseEntry getKeyDatabaseEntry(long index)

isSuccessOperation

protected boolean isSuccessOperation(com.sleepycat.je.OperationStatus status)

toLogEntry

protected LogEntry toLogEntry(com.sleepycat.je.DatabaseEntry logEntry)

toDatabaseEntry

protected com.sleepycat.je.DatabaseEntry toDatabaseEntry(LogEntry logEntry)