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.
Methods inherited from interface akka.actor.Actor |
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, receive, self, sender, supervisorStrategy, unhandled |
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