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

Interface LeveldbStore

    • Method Detail

      • org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq

        void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$config_$eq​(com.typesafe.config.Config x$1)

      • org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq

        void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$nativeLeveldb_$eq​(boolean x$1)

      • org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbOptions_$eq

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

      • org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbWriteOptions_$eq

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

      • org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq

        void org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$leveldbDir_$eq​(java.io.File x$1)

      • org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$compactionIntervals_$eq

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

      • org$apache$pekko$persistence$journal$leveldb$LeveldbStore$_setter_$serialization_$eq

        void org$apache$pekko$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 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)