akka.persistence.journal.leveldb

Interface LeveldbIdMapping

All Superinterfaces:

Actor

All Known Subinterfaces:

LeveldbStore

All Known Implementing Classes:

LeveldbJournal, 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 akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Method Summary

Modifier and Type	Method and Description
scala.collection.immutable.Set<java.lang.String>	allPersistenceIds()
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 actor id.
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)
int	writeIdMapping(java.lang.String id, int numericId)

Methods inherited from interface akka.actor.Actor

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

Method Detail

numericId

int numericId(java.lang.String id)

Get the mapped numeric id for the specified persistent actor id. Creates and stores a new mapping if necessary.

This method is thread safe and it is allowed to call it from a another thread than the actor's thread. That is necessary for Future composition, e.g. asyncReadHighestSequenceNr followed by asyncReplayMessages.

Parameters:

id - (undocumented)

Returns:

(undocumented)

isNewPersistenceId

boolean isNewPersistenceId(java.lang.String id)

allPersistenceIds

scala.collection.immutable.Set<java.lang.String> allPersistenceIds()

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)

writeIdMapping

int writeIdMapping(java.lang.String id,
                   int numericId)

newPersistenceIdAdded

void newPersistenceIdAdded(java.lang.String id)

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