org.agilewiki.jfile.transactions.db.inMemory

Class IMDB

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jfile.transactions.db.DB

org.agilewiki.jfile.transactions.db.inMemory.IMDB

All Implemented Interfaces:

org.agilewiki.jactor.Actor, org.agilewiki.jactor.apc.APCRequestSource, org.agilewiki.jactor.apc.RequestProcessor, org.agilewiki.jactor.lpc.RequestSource, org.agilewiki.jactor.lpc.TargetActor

public class IMDB
extends DB

In-memory database.

Nested Class Summary

Nested classes/interfaces inherited from class org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jactor.lpc.JLPCActor.SMBuilder

Field Summary

Fields

Modifier and Type	Field and Description
static String	LOG_FILE_NAME
static String	LOG_POSITION
int	maxSize

Fields inherited from class org.agilewiki.jfile.transactions.db.DB

directoryPath, logFileNames

Constructor Summary

Constructors

Constructor and Description
IMDB()
IMDB(org.agilewiki.jactor.MailboxFactory mailboxFactory, org.agilewiki.jactor.Actor parent, java.nio.file.Path directoryPath)

Method Summary

Methods

Modifier and Type	Method and Description
Integer	addInteger(String key, Integer increment)
void	checkpoint(long logPosition, long timestamp, String logFileName, org.agilewiki.jactor.RP rp)
void	closeDbFile()
protected boolean	generateCheckpoints()
org.agilewiki.jid.scalar.vlens.actor.ActorJid	getActorJid(String key)
Boolean	getBoolean(String key)
org.agilewiki.jid.scalar.flens.bool.BooleanJid	getBooleanJid(String key)
byte[]	getBytes(String key)
org.agilewiki.jid.scalar.vlens.bytes.BytesJid	getBytesJid(String key)
Double	getDouble(String key)
org.agilewiki.jid.scalar.flens.dbl.DoubleJid	getDoubleJid(String key)
Float	getFloat(String key)
org.agilewiki.jid.scalar.flens.flt.FloatJid	getFloatJid(String key)
Integer	getInteger(String key)
org.agilewiki.jid.scalar.flens.integer.IntegerJid	getIntegerJid(String key)
org.agilewiki.jid._Jid	getJid(String key)
Long	getLong(String key)
org.agilewiki.jid.scalar.flens.lng.LongJid	getLongJid(String key)
String	getString(String key)
org.agilewiki.jid.scalar.vlens.string.StringJid	getStringJid(String key)
org.agilewiki.jid.collection.vlenc.map.StringMapJid	getStringMapJid()
Integer	incrementInteger(String key)
org.agilewiki.jid.scalar.vlens.actor.ActorJid	makeActorJid(String key)
org.agilewiki.jid.scalar.flens.bool.BooleanJid	makeBooleanJid(String key)
org.agilewiki.jid.scalar.vlens.bytes.BytesJid	makeBytesJid(String key)
org.agilewiki.jid.scalar.flens.dbl.DoubleJid	makeDoubleJid(String key)
org.agilewiki.jid.scalar.flens.flt.FloatJid	makeFloatJid(String key)
org.agilewiki.jid.scalar.flens.integer.IntegerJid	makeIntegerJid(String key)
org.agilewiki.jid._Jid	makeJid(String key, String factoryName)
org.agilewiki.jid.scalar.flens.lng.LongJid	makeLongJid(String key)
protected org.agilewiki.jid.scalar.vlens.actor.RootJid	makeRootJid()
org.agilewiki.jid.scalar.vlens.string.StringJid	makeStringJid(String key)
org.agilewiki.jid.collection.vlenc.map.StringMapJid	makeStringMapJid()
protected Block	newDbBlock()
void	openDbFile(int logReaderMaxSize, org.agilewiki.jactor.RP rp)

Methods inherited from class org.agilewiki.jfile.transactions.db.DB

clearDirectory, getDurableTransactionLogger, getLogReader, getTransactionAggregator, initializeDb, newLogReader, newTransactionAggregator, processLogFile, setDirectoryPath

Methods inherited from class org.agilewiki.jactor.lpc.JLPCActor

acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity

Methods inherited from class java.lang.Object

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

Field Detail

LOG_POSITION

public static final String LOG_POSITION

See Also:

Constant Field Values

LOG_FILE_NAME

public static final String LOG_FILE_NAME

See Also:

Constant Field Values

maxSize

public int maxSize

Constructor Detail

IMDB

public IMDB()

IMDB

public IMDB(org.agilewiki.jactor.MailboxFactory mailboxFactory,
    org.agilewiki.jactor.Actor parent,
    java.nio.file.Path directoryPath)
     throws Exception

Throws:

Exception

Method Detail

generateCheckpoints

protected boolean generateCheckpoints()

Overrides:

generateCheckpoints in class DB

openDbFile

public void openDbFile(int logReaderMaxSize,
              org.agilewiki.jactor.RP rp)
                throws Exception

Overrides:

openDbFile in class DB

Throws:

Exception

closeDbFile

public void closeDbFile()

Overrides:

closeDbFile in class DB

newDbBlock

protected Block newDbBlock()

makeRootJid

protected org.agilewiki.jid.scalar.vlens.actor.RootJid makeRootJid()
                                                            throws Exception

Throws:

Exception

getStringMapJid

public org.agilewiki.jid.collection.vlenc.map.StringMapJid getStringMapJid()
                                                                    throws Exception

Throws:

Exception

makeStringMapJid

public org.agilewiki.jid.collection.vlenc.map.StringMapJid makeStringMapJid()
                                                                     throws Exception

Throws:

Exception

getActorJid

public org.agilewiki.jid.scalar.vlens.actor.ActorJid getActorJid(String key)
                                                          throws Exception

Throws:

Exception

makeActorJid

public org.agilewiki.jid.scalar.vlens.actor.ActorJid makeActorJid(String key)
                                                           throws Exception

Throws:

Exception

getJid

public org.agilewiki.jid._Jid getJid(String key)
                              throws Exception

Throws:

Exception

makeJid

public org.agilewiki.jid._Jid makeJid(String key,
                             String factoryName)
                               throws Exception

Throws:

Exception

getBooleanJid

public org.agilewiki.jid.scalar.flens.bool.BooleanJid getBooleanJid(String key)
                                                             throws Exception

Throws:

Exception

getBoolean

public Boolean getBoolean(String key)
                   throws Exception

Throws:

Exception

makeBooleanJid

public org.agilewiki.jid.scalar.flens.bool.BooleanJid makeBooleanJid(String key)
                                                              throws Exception

Throws:

Exception

getIntegerJid

public org.agilewiki.jid.scalar.flens.integer.IntegerJid getIntegerJid(String key)
                                                                throws Exception

Throws:

Exception

getInteger

public Integer getInteger(String key)
                   throws Exception

Throws:

Exception

makeIntegerJid

public org.agilewiki.jid.scalar.flens.integer.IntegerJid makeIntegerJid(String key)
                                                                 throws Exception

Throws:

Exception

incrementInteger

public Integer incrementInteger(String key)
                         throws Exception

Throws:

Exception

addInteger

public Integer addInteger(String key,
                 Integer increment)
                   throws Exception

Throws:

Exception

getLongJid

public org.agilewiki.jid.scalar.flens.lng.LongJid getLongJid(String key)
                                                      throws Exception

Throws:

Exception

getLong

public Long getLong(String key)
             throws Exception

Throws:

Exception

makeLongJid

public org.agilewiki.jid.scalar.flens.lng.LongJid makeLongJid(String key)
                                                       throws Exception

Throws:

Exception

getFloatJid

public org.agilewiki.jid.scalar.flens.flt.FloatJid getFloatJid(String key)
                                                        throws Exception

Throws:

Exception

getFloat

public Float getFloat(String key)
               throws Exception

Throws:

Exception

makeFloatJid

public org.agilewiki.jid.scalar.flens.flt.FloatJid makeFloatJid(String key)
                                                         throws Exception

Throws:

Exception

getDoubleJid

public org.agilewiki.jid.scalar.flens.dbl.DoubleJid getDoubleJid(String key)
                                                          throws Exception

Throws:

Exception

getDouble

public Double getDouble(String key)
                 throws Exception

Throws:

Exception

makeDoubleJid

public org.agilewiki.jid.scalar.flens.dbl.DoubleJid makeDoubleJid(String key)
                                                           throws Exception

Throws:

Exception

getStringJid

public org.agilewiki.jid.scalar.vlens.string.StringJid getStringJid(String key)
                                                             throws Exception

Throws:

Exception

getString

public String getString(String key)
                 throws Exception

Throws:

Exception

makeStringJid

public org.agilewiki.jid.scalar.vlens.string.StringJid makeStringJid(String key)
                                                              throws Exception

Throws:

Exception

getBytesJid

public org.agilewiki.jid.scalar.vlens.bytes.BytesJid getBytesJid(String key)
                                                          throws Exception

Throws:

Exception

getBytes

public byte[] getBytes(String key)
                throws Exception

Throws:

Exception

makeBytesJid

public org.agilewiki.jid.scalar.vlens.bytes.BytesJid makeBytesJid(String key)
                                                           throws Exception

Throws:

Exception

checkpoint

public void checkpoint(long logPosition,
              long timestamp,
              String logFileName,
              org.agilewiki.jactor.RP rp)
                throws Exception

Overrides:

checkpoint in class DB

Throws:

Exception