akka.persistence.journal.leveldb
Interface LeveldbStore

All Superinterfaces:

Actor, AsyncRecovery, LeveldbIdMapping, LeveldbRecovery

All Known Implementing Classes:

LeveldbJournal, SharedLeveldbStore

public interface LeveldbStore
extends Actor, LeveldbIdMapping, LeveldbRecovery

INTERNAL API.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$

Method Summary

void	addToConfirmationBatch(PersistentConfirmation confirmation, org.iq80.leveldb.WriteBatch batch)
void	addToMessageBatch(PersistentRepr persistent, org.iq80.leveldb.WriteBatch batch)
com.typesafe.config.Config	config()
java.lang.String	configPath()
void	deleteMessages(scala.collection.immutable.Seq<PersistentId> messageIds, boolean permanent)
void	deleteMessagesTo(java.lang.String persistenceId, long toSequenceNr, boolean permanent)
org.iq80.leveldb.DB	leveldb()
java.io.File	leveldbDir()
org.iq80.leveldb.DBFactory	leveldbFactory()
org.iq80.leveldb.Options	leveldbOptions()
org.iq80.leveldb.ReadOptions	leveldbReadOptions()
org.iq80.leveldb.ReadOptions	leveldbSnapshot()
org.iq80.leveldb.WriteOptions	leveldbWriteOptions()
boolean	nativeLeveldb()
PersistentRepr	persistentFromBytes(byte[] a)
byte[]	persistentToBytes(PersistentRepr p)
void	postStop() User overridable callback.
void	preStart() User overridable callback.
Serialization	serialization()
<R> R	withBatch(scala.Function1<org.iq80.leveldb.WriteBatch,R> body)
<R> R	withIterator(scala.Function1<org.iq80.leveldb.DBIterator,R> body)
void	writeConfirmations(scala.collection.immutable.Seq<PersistentConfirmation> confirmations)
void	writeMessages(scala.collection.immutable.Seq<PersistentRepr> messages)

Methods inherited from interface akka.persistence.journal.leveldb.LeveldbIdMapping

idMap, idOffset, numericId, readIdMap, readIdMap, writeIdMapping

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.persistence.journal.leveldb.LeveldbRecovery

asyncReadHighestSequenceNr, asyncReplayMessages, readHighestSequenceNr, replayDispatcher, replayDispatcherId, replayMessages

Method Detail

configPath

java.lang.String configPath()

config

com.typesafe.config.Config config()

nativeLeveldb

boolean nativeLeveldb()

leveldbOptions

org.iq80.leveldb.Options leveldbOptions()

leveldbReadOptions

org.iq80.leveldb.ReadOptions leveldbReadOptions()

leveldbWriteOptions

org.iq80.leveldb.WriteOptions leveldbWriteOptions()

leveldbDir

java.io.File leveldbDir()

leveldb

org.iq80.leveldb.DB leveldb()

leveldbFactory

org.iq80.leveldb.DBFactory leveldbFactory()

serialization

Serialization serialization()

writeMessages

void writeMessages(scala.collection.immutable.Seq<PersistentRepr> messages)

writeConfirmations

void writeConfirmations(scala.collection.immutable.Seq<PersistentConfirmation> confirmations)

deleteMessages

void deleteMessages(scala.collection.immutable.Seq<PersistentId> messageIds,
                    boolean permanent)

deleteMessagesTo

void deleteMessagesTo(java.lang.String persistenceId,
                      long toSequenceNr,
                      boolean permanent)

leveldbSnapshot

org.iq80.leveldb.ReadOptions leveldbSnapshot()

withIterator

<R> R withIterator(scala.Function1<org.iq80.leveldb.DBIterator,R> body)

withBatch

<R> R withBatch(scala.Function1<org.iq80.leveldb.WriteBatch,R> body)

persistentToBytes

byte[] persistentToBytes(PersistentRepr p)

persistentFromBytes

PersistentRepr persistentFromBytes(byte[] a)

addToMessageBatch

void addToMessageBatch(PersistentRepr persistent,
                       org.iq80.leveldb.WriteBatch batch)

addToConfirmationBatch

void addToConfirmationBatch(PersistentConfirmation confirmation,
                            org.iq80.leveldb.WriteBatch batch)

preStart

void preStart()

Description copied from interface: Actor

User overridable callback.

Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

Specified by:

preStart in interface Actor

Specified by:

preStart in interface LeveldbIdMapping

postStop

void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:

postStop in interface Actor