Package org.apache.pekko.persistence.journal.leveldb

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

Modifier and Type	Method	Description
scala.collection.immutable.Set<String>	allPersistenceIds()
void	idMap_$eq(scala.collection.immutable.Map<String,Object> x$1)
boolean	isNewPersistenceId(String id)
void	newPersistenceIdAdded(String id)
int	numericId(String id)	Get the mapped numeric id for the specified persistent actor id.
void	preStart()	User overridable callback.
scala.collection.immutable.Map<String,Object>	readIdMap()
scala.collection.immutable.Map<String,Object>	readIdMap(scala.collection.immutable.Map<String,Object> pathMap, org.iq80.leveldb.DBIterator iter)
void	super$preStart()	Get the mapped numeric id for the specified persistent actor id.
int	writeIdMapping(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 Details

allPersistenceIds

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

idMap_$eq

void idMap_$eq(scala.collection.immutable.Map<String,Object> x$1)

isNewPersistenceId

boolean isNewPersistenceId(String id)

newPersistenceIdAdded

void newPersistenceIdAdded(String id)

numericId

int numericId(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 another thread than the actor's thread. That is necessary for Future composition, e.g. asyncReadHighestSequenceNr followed by asyncReplayMessages.

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

readIdMap

scala.collection.immutable.Map<String,Object> readIdMap()

readIdMap

scala.collection.immutable.Map<String,Object> readIdMap(scala.collection.immutable.Map<String,Object> pathMap,
 org.iq80.leveldb.DBIterator iter)

super$preStart

void super$preStart()

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 another thread than the actor's thread. That is necessary for Future composition, e.g. asyncReadHighestSequenceNr followed by asyncReplayMessages.

writeIdMapping

int writeIdMapping(String id,
 int numericId)