Interface LeveldbStore

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