public interface LeveldbStore extends akka.actor.Actor, WriteJournalBase, LeveldbIdMapping, LeveldbRecovery
Modifier and Type | Method and Description |
---|---|
void |
addAllPersistenceIdsSubscriber(akka.actor.ActorRef subscriber) |
void |
addPersistenceIdSubscriber(akka.actor.ActorRef subscriber,
java.lang.String persistenceId) |
void |
addTagSubscriber(akka.actor.ActorRef subscriber,
java.lang.String tag) |
void |
addToMessageBatch(PersistentRepr persistent,
scala.collection.immutable.Set<java.lang.String> tags,
org.iq80.leveldb.WriteBatch batch) |
scala.collection.immutable.Set<akka.actor.ActorRef> |
allPersistenceIdsSubscribers() |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
asyncDeleteMessagesTo(java.lang.String persistenceId,
long toSequenceNr) |
scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>> |
asyncWriteMessages(scala.collection.immutable.Seq<AtomicWrite> messages) |
com.typesafe.config.Config |
config() |
java.lang.String |
configPath() |
boolean |
hasAllPersistenceIdsSubscribers() |
boolean |
hasPersistenceIdSubscribers() |
boolean |
hasTagSubscribers() |
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() |
void |
newPersistenceIdAdded(java.lang.String id) |
long |
nextTagSequenceNr(java.lang.String tag) |
void |
notifyPersistenceIdChange(java.lang.String persistenceId) |
void |
notifyTagChange(java.lang.String tag) |
scala.collection.mutable.HashMap<java.lang.String,scala.collection.mutable.Set<akka.actor.ActorRef>> |
persistenceIdSubscribers() |
PersistentRepr |
persistentFromBytes(byte[] a) |
byte[] |
persistentToBytes(PersistentRepr p) |
void |
postStop() |
void |
preStart() |
void |
removeSubscriber(akka.actor.ActorRef subscriber) |
akka.serialization.Serialization |
serialization() |
java.lang.String |
tagAsPersistenceId(java.lang.String tag) |
int |
tagNumericId(java.lang.String tag) |
java.lang.String |
tagPersistenceIdPrefix() |
scala.collection.immutable.Map<java.lang.String,java.lang.Object> |
tagSequenceNr() |
scala.collection.mutable.HashMap<java.lang.String,scala.collection.mutable.Set<akka.actor.ActorRef>> |
tagSubscribers() |
<R> R |
withBatch(scala.Function1<org.iq80.leveldb.WriteBatch,R> body) |
<R> R |
withIterator(scala.Function1<org.iq80.leveldb.DBIterator,R> body) |
adaptFromJournal, adaptToJournal, eventAdapters, persistence, preparePersistentBatch
allPersistenceIds, idMap, idMapLock, idOffset, isNewPersistenceId, numericId, readIdMap, readIdMap, writeIdMapping
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, receive, self, sender, supervisorStrategy, unhandled
asyncReadHighestSequenceNr, asyncReplayMessages, asyncReplayTaggedMessages, readHighestSequenceNr, replayDispatcher, replayDispatcherId, replayMessages, replayTaggedMessages
java.lang.String configPath()
com.typesafe.config.Config config()
boolean nativeLeveldb()
org.iq80.leveldb.Options leveldbOptions()
org.iq80.leveldb.ReadOptions leveldbReadOptions()
org.iq80.leveldb.WriteOptions leveldbWriteOptions()
java.io.File leveldbDir()
org.iq80.leveldb.DB leveldb()
scala.collection.mutable.HashMap<java.lang.String,scala.collection.mutable.Set<akka.actor.ActorRef>> persistenceIdSubscribers()
scala.collection.mutable.HashMap<java.lang.String,scala.collection.mutable.Set<akka.actor.ActorRef>> tagSubscribers()
scala.collection.immutable.Set<akka.actor.ActorRef> allPersistenceIdsSubscribers()
scala.collection.immutable.Map<java.lang.String,java.lang.Object> tagSequenceNr()
java.lang.String tagPersistenceIdPrefix()
org.iq80.leveldb.DBFactory leveldbFactory()
akka.serialization.Serialization serialization()
scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>> asyncWriteMessages(scala.collection.immutable.Seq<AtomicWrite> messages)
scala.concurrent.Future<scala.runtime.BoxedUnit> asyncDeleteMessagesTo(java.lang.String persistenceId, long toSequenceNr)
org.iq80.leveldb.ReadOptions leveldbSnapshot()
<R> R withIterator(scala.Function1<org.iq80.leveldb.DBIterator,R> body)
<R> R withBatch(scala.Function1<org.iq80.leveldb.WriteBatch,R> body)
byte[] persistentToBytes(PersistentRepr p)
PersistentRepr persistentFromBytes(byte[] a)
void addToMessageBatch(PersistentRepr persistent, scala.collection.immutable.Set<java.lang.String> tags, org.iq80.leveldb.WriteBatch batch)
long nextTagSequenceNr(java.lang.String tag)
int tagNumericId(java.lang.String tag)
java.lang.String tagAsPersistenceId(java.lang.String tag)
void preStart()
preStart
in interface akka.actor.Actor
preStart
in interface LeveldbIdMapping
void postStop()
postStop
in interface akka.actor.Actor
boolean hasPersistenceIdSubscribers()
void addPersistenceIdSubscriber(akka.actor.ActorRef subscriber, java.lang.String persistenceId)
void removeSubscriber(akka.actor.ActorRef subscriber)
boolean hasTagSubscribers()
void addTagSubscriber(akka.actor.ActorRef subscriber, java.lang.String tag)
boolean hasAllPersistenceIdsSubscribers()
void addAllPersistenceIdsSubscriber(akka.actor.ActorRef subscriber)
void notifyPersistenceIdChange(java.lang.String persistenceId)
void notifyTagChange(java.lang.String tag)
void newPersistenceIdAdded(java.lang.String id)
newPersistenceIdAdded
in interface LeveldbIdMapping