Interface LeveldbIdMapping
-
- All Superinterfaces:
Actor
- All Known Subinterfaces:
LeveldbStore
- All Known Implementing Classes:
SharedLeveldbStore
public interface LeveldbIdMapping extends Actor
INTERNAL API.LevelDB backed persistent mapping of
String
-based persistent actor ids to numeric ids.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description scala.collection.immutable.Set<java.lang.String>
allPersistenceIds()
void
idMap_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
boolean
isNewPersistenceId(java.lang.String id)
void
newPersistenceIdAdded(java.lang.String id)
int
numericId(java.lang.String id)
Get the mapped numeric id for the specified persistent actorid
.void
preStart()
User overridable callback.scala.collection.immutable.Map<java.lang.String,java.lang.Object>
readIdMap()
scala.collection.immutable.Map<java.lang.String,java.lang.Object>
readIdMap(scala.collection.immutable.Map<java.lang.String,java.lang.Object> pathMap, org.iq80.leveldb.DBIterator iter)
void
super$preStart()
Get the mapped numeric id for the specified persistent actorid
.int
writeIdMapping(java.lang.String id, int numericId)
-
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, postStop, preRestart, receive, self, sender, supervisorStrategy, unhandled
-
-
-
-
Method Detail
-
allPersistenceIds
scala.collection.immutable.Set<java.lang.String> allPersistenceIds()
-
idMap_$eq
void idMap_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
-
isNewPersistenceId
boolean isNewPersistenceId(java.lang.String id)
-
newPersistenceIdAdded
void newPersistenceIdAdded(java.lang.String id)
-
numericId
int numericId(java.lang.String id)
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
.
-
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.
-
readIdMap
scala.collection.immutable.Map<java.lang.String,java.lang.Object> readIdMap()
-
readIdMap
scala.collection.immutable.Map<java.lang.String,java.lang.Object> readIdMap(scala.collection.immutable.Map<java.lang.String,java.lang.Object> pathMap, org.iq80.leveldb.DBIterator iter)
-
super$preStart
void super$preStart()
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
.
-
writeIdMapping
int writeIdMapping(java.lang.String id, int numericId)
-
-