akka.persistence.journal.leveldb

Interface LeveldbStore

All Superinterfaces:

Actor, AsyncRecovery, LeveldbIdMapping, LeveldbRecovery, WriteJournalBase

All Known Implementing Classes:

LeveldbJournal, SharedLeveldbStore

public interface LeveldbStore
extends Actor, WriteJournalBase, LeveldbIdMapping, LeveldbRecovery

INTERNAL API.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Method Summary

Modifier and Type	Method and 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)
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)
com.typesafe.config.Config	config()
boolean	hasAllPersistenceIdsSubscribers()
boolean	hasPersistenceIdSubscribers()
boolean	hasTagSubscribers()
org.iq80.leveldb.DB	leveldb()
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()
java.lang.String	tagAsPersistenceId(java.lang.String tag)
int	tagNumericId(java.lang.String tag)
<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.persistence.journal.WriteJournalBase

adaptFromJournal, adaptToJournal, persistence, preparePersistentBatch

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

allPersistenceIds, isNewPersistenceId, numericId, readIdMap, readIdMap, writeIdMapping

Methods inherited from interface akka.actor.Actor

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

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

asyncReadHighestSequenceNr, asyncReplayMessages, asyncReplayTaggedMessages, readHighestSequenceNr, replayMessages, replayTaggedMessages

Method Detail

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()

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