Interface LeveldbStore
-
- All Superinterfaces:
Actor
,ActorLogging
,AsyncRecovery
,CompactionSegmentManagement
,LeveldbCompaction
,LeveldbIdMapping
,LeveldbRecovery
,WriteJournalBase
- All Known Implementing Classes:
SharedLeveldbStore
public interface LeveldbStore extends Actor, WriteJournalBase, LeveldbIdMapping, LeveldbRecovery, LeveldbCompaction
INTERNAL API.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
Nested classes/interfaces inherited from interface org.apache.pekko.persistence.journal.leveldb.LeveldbCompaction
LeveldbCompaction.TryCompactLeveldb, LeveldbCompaction.TryCompactLeveldb$
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addAllPersistenceIdsSubscriber(ActorRef subscriber)
void
addPersistenceIdSubscriber(ActorRef subscriber, java.lang.String persistenceId)
void
addTagSubscriber(ActorRef subscriber, java.lang.String tag)
void
addToMessageBatch(PersistentRepr persistent, scala.collection.immutable.Set<java.lang.String> tags, org.iq80.leveldb.WriteBatch batch)
void
allPersistenceIdsSubscribers_$eq(scala.collection.immutable.Set<ActorRef> x$1)
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)
scala.collection.immutable.Map<java.lang.String,java.lang.Object>
compactionIntervals()
com.typesafe.config.Config
config()
boolean
hasAllPersistenceIdsSubscribers()
boolean
hasPersistenceIdSubscribers()
boolean
hasTagSubscribers()
org.iq80.leveldb.DB
leveldb()
void
leveldb_$eq(org.iq80.leveldb.DB x$1)
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)
void
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
void
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq(com.typesafe.config.Config x$1)
void
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq(java.io.File x$1)
void
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq(org.iq80.leveldb.Options x$1)
void
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq(org.iq80.leveldb.WriteOptions x$1)
void
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq(boolean x$1)
void
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq(Serialization x$1)
PersistentRepr
persistentFromBytes(byte[] a)
byte[]
persistentToBytes(PersistentRepr p)
void
postStop()
User overridable callback.com.typesafe.config.Config
prepareConfig()
void
preStart()
User overridable callback.void
removeSubscriber(ActorRef subscriber)
Serialization
serialization()
void
super$postStop()
void
super$preStart()
Get the mapped numeric id for the specified persistent actorid
.java.lang.String
tagAsPersistenceId(java.lang.String tag)
int
tagNumericId(java.lang.String tag)
void
tagSequenceNr_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
<R> R
withBatch(scala.Function1<org.iq80.leveldb.WriteBatch,R> body)
<R> R
withIterator(scala.Function1<org.iq80.leveldb.DBIterator,R> body)
-
Methods inherited from interface org.apache.pekko.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, preRestart, receive, self, sender, supervisorStrategy, unhandled
-
Methods inherited from interface org.apache.pekko.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface org.apache.pekko.persistence.journal.leveldb.CompactionSegmentManagement
compactionInterval, compactionLimit, compactionSegment, isCompactionEnabled, isCompactionRequired, latestCompactionSegment, latestCompactionSegments_$eq, mustCompact, updateCompactionSegment
-
Methods inherited from interface org.apache.pekko.persistence.journal.leveldb.LeveldbCompaction
receiveCompactionInternal, tryCompactOnDelete
-
Methods inherited from interface org.apache.pekko.persistence.journal.leveldb.LeveldbIdMapping
allPersistenceIds, idMap_$eq, isNewPersistenceId, numericId, readIdMap, readIdMap, writeIdMapping
-
Methods inherited from interface org.apache.pekko.persistence.journal.leveldb.LeveldbRecovery
asyncReadHighestSequenceNr, asyncReplayMessages, asyncReplayTaggedMessages, readHighestSequenceNr, replayMessages, replayTaggedMessages
-
Methods inherited from interface org.apache.pekko.persistence.journal.WriteJournalBase
adaptFromJournal, adaptToJournal, org$apache$pekko$persistence$journal$WriteJournalBase$_setter_$persistence_$eq, persistence, preparePersistentBatch
-
-
-
-
Method Detail
-
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq
void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq(com.typesafe.config.Config x$1)
-
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq
void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq(boolean x$1)
-
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq
void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq(org.iq80.leveldb.Options x$1)
-
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq
void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq(org.iq80.leveldb.WriteOptions x$1)
-
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq
void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq(java.io.File x$1)
-
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq
void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
-
org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq
void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq(Serialization x$1)
-
super$preStart
void super$preStart()
Description copied from interface:LeveldbIdMapping
Get the mapped numeric id for the specified persistent actorid
. Creates and stores a new mapping if necessary.This method is thread safe and it is allowed to call it from another thread than the actor's thread. That is necessary for Future composition, e.g.
asyncReadHighestSequenceNr
followed byasyncReplayMessages
.- Specified by:
super$preStart
in interfaceLeveldbIdMapping
-
super$postStop
void super$postStop()
-
prepareConfig
com.typesafe.config.Config prepareConfig()
-
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()
-
leveldb_$eq
void leveldb_$eq(org.iq80.leveldb.DB x$1)
-
compactionIntervals
scala.collection.immutable.Map<java.lang.String,java.lang.Object> compactionIntervals()
- Specified by:
compactionIntervals
in interfaceCompactionSegmentManagement
-
allPersistenceIdsSubscribers_$eq
void allPersistenceIdsSubscribers_$eq(scala.collection.immutable.Set<ActorRef> x$1)
-
tagSequenceNr_$eq
void tagSequenceNr_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
-
leveldbFactory
org.iq80.leveldb.DBFactory leveldbFactory()
-
serialization
Serialization serialization()
-
asyncWriteMessages
scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>> asyncWriteMessages(scala.collection.immutable.Seq<AtomicWrite> messages)
-
asyncDeleteMessagesTo
scala.concurrent.Future<scala.runtime.BoxedUnit> asyncDeleteMessagesTo(java.lang.String persistenceId, long toSequenceNr)
-
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, scala.collection.immutable.Set<java.lang.String> tags, org.iq80.leveldb.WriteBatch batch)
-
nextTagSequenceNr
long nextTagSequenceNr(java.lang.String tag)
-
tagNumericId
int tagNumericId(java.lang.String tag)
-
tagAsPersistenceId
java.lang.String tagAsPersistenceId(java.lang.String tag)
-
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 interfaceActor
- Specified by:
preStart
in interfaceLeveldbIdMapping
-
postStop
void postStop()
Description copied from interface:Actor
User overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
-
hasPersistenceIdSubscribers
boolean hasPersistenceIdSubscribers()
-
addPersistenceIdSubscriber
void addPersistenceIdSubscriber(ActorRef subscriber, java.lang.String persistenceId)
-
removeSubscriber
void removeSubscriber(ActorRef subscriber)
-
hasTagSubscribers
boolean hasTagSubscribers()
-
addTagSubscriber
void addTagSubscriber(ActorRef subscriber, java.lang.String tag)
-
hasAllPersistenceIdsSubscribers
boolean hasAllPersistenceIdsSubscribers()
-
addAllPersistenceIdsSubscriber
void addAllPersistenceIdsSubscriber(ActorRef subscriber)
-
notifyPersistenceIdChange
void notifyPersistenceIdChange(java.lang.String persistenceId)
-
notifyTagChange
void notifyTagChange(java.lang.String tag)
-
newPersistenceIdAdded
void newPersistenceIdAdded(java.lang.String id)
- Specified by:
newPersistenceIdAdded
in interfaceLeveldbIdMapping
-
-