Package akka.persistence.journal.leveldb

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Nested classes/interfaces inherited from interface akka.persistence.journal.leveldb.LeveldbCompaction

LeveldbCompaction.TryCompactLeveldb, LeveldbCompaction.TryCompactLeveldb$

Method Summary

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	akka$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)
void	akka$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq(com.typesafe.config.Config x$1)
void	akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq(java.io.File x$1)
void	akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq(org.iq80.leveldb.Options x$1)
void	akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq(org.iq80.leveldb.WriteOptions x$1)
void	akka$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq(boolean x$1)
void	akka$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq(Serialization x$1)
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)
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 actor id.
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 akka.actor.Actor

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

Methods inherited from interface akka.actor.ActorLogging

_log_$eq, log

Methods inherited from interface akka.persistence.journal.leveldb.CompactionSegmentManagement

compactionInterval, compactionLimit, compactionSegment, isCompactionEnabled, isCompactionRequired, latestCompactionSegment, latestCompactionSegments_$eq, mustCompact, updateCompactionSegment

Methods inherited from interface akka.persistence.journal.leveldb.LeveldbCompaction

receiveCompactionInternal, tryCompactOnDelete

Methods inherited from interface akka.persistence.journal.leveldb.LeveldbIdMapping

allPersistenceIds, idMap_$eq, isNewPersistenceId, numericId, readIdMap, readIdMap, writeIdMapping

Methods inherited from interface akka.persistence.journal.leveldb.LeveldbRecovery

asyncReadHighestSequenceNr, asyncReplayMessages, asyncReplayTaggedMessages, readHighestSequenceNr, replayMessages, replayTaggedMessages

Methods inherited from interface akka.persistence.journal.WriteJournalBase

adaptFromJournal, adaptToJournal, akka$persistence$journal$WriteJournalBase$_setter_$persistence_$eq, persistence, preparePersistentBatch

Method Detail

akka$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq

void akka$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq(com.typesafe.config.Config x$1)

akka$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq

void akka$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq(boolean x$1)

akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq

void akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq(org.iq80.leveldb.Options x$1)

akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq

void akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq(org.iq80.leveldb.WriteOptions x$1)

akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq

void akka$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq(java.io.File x$1)

akka$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq

void akka$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq(scala.collection.immutable.Map<java.lang.String,java.lang.Object> x$1)

akka$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq

void akka$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 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.

Specified by:

super$preStart in interface LeveldbIdMapping

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 interface CompactionSegmentManagement

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 interface Actor

Specified by:

preStart in interface LeveldbIdMapping

postStop

void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:

postStop in interface Actor

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 interface LeveldbIdMapping