public abstract class DB
extends org.agilewiki.jactor.lpc.JLPCActor
Modifier and Type | Field and Description |
---|---|
protected java.nio.file.Path |
directoryPath |
protected String[] |
logFileNames |
Constructor and Description |
---|
DB() |
DB(org.agilewiki.jactor.MailboxFactory mailboxFactory,
org.agilewiki.jactor.Actor parent,
java.nio.file.Path directoryPath) |
Modifier and Type | Method and Description |
---|---|
void |
checkpoint(long logPosition,
long timestamp,
String logFileName,
org.agilewiki.jactor.RP rp) |
void |
clearDirectory() |
void |
closeDbFile() |
protected boolean |
generateCheckpoints() |
DurableTransactionLogger |
getDurableTransactionLogger() |
LogReader |
getLogReader(int maxSize)
Returns the transaction log reader.
|
TransactionAggregator |
getTransactionAggregator()
Returns the transaction aggregator.
|
protected void |
initializeDb(int logReaderMaxSize) |
protected LogReader |
newLogReader()
Create a transaction log reader.
|
protected TransactionAggregator |
newTransactionAggregator()
Create a transaction aggregator.
|
void |
openDbFile(int logReaderMaxSize,
org.agilewiki.jactor.RP rp) |
void |
processLogFile(long position,
int fileIndex,
org.agilewiki.jactor.RP rp) |
void |
setDirectoryPath(java.nio.file.Path path) |
acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity
protected java.nio.file.Path directoryPath
protected String[] logFileNames
public DB()
public DB(org.agilewiki.jactor.MailboxFactory mailboxFactory, org.agilewiki.jactor.Actor parent, java.nio.file.Path directoryPath) throws Exception
Exception
public void openDbFile(int logReaderMaxSize, org.agilewiki.jactor.RP rp) throws Exception
Exception
protected void initializeDb(int logReaderMaxSize)
public void processLogFile(long position, int fileIndex, org.agilewiki.jactor.RP rp) throws Exception
Exception
public void closeDbFile()
protected LogReader newLogReader()
protected TransactionAggregator newTransactionAggregator()
public LogReader getLogReader(int maxSize) throws Exception
maxSize
- The maximum possible block size.Exception
protected boolean generateCheckpoints()
public TransactionAggregator getTransactionAggregator() throws Exception
Exception
public DurableTransactionLogger getDurableTransactionLogger() throws Exception
Exception
public void checkpoint(long logPosition, long timestamp, String logFileName, org.agilewiki.jactor.RP rp) throws Exception
Exception
public void setDirectoryPath(java.nio.file.Path path) throws Exception
Exception
Copyright © 2013. All Rights Reserved.