Package org.apache.pekko.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.

  • Method Details

    • 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(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<String,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

      File leveldbDir()

    • leveldb

      org.iq80.leveldb.DB leveldb()

    • leveldb_$eq

      void leveldb_$eq(org.iq80.leveldb.DB x$1)

    • compactionIntervals

      scala.collection.immutable.Map<String,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<String,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(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<String> tags, org.iq80.leveldb.WriteBatch batch)

    • nextTagSequenceNr

      long nextTagSequenceNr(String tag)

    • tagNumericId

      int tagNumericId(String tag)

    • tagAsPersistenceId

      String tagAsPersistenceId(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, String persistenceId)

    • removeSubscriber

      void removeSubscriber(ActorRef subscriber)

    • hasTagSubscribers

      boolean hasTagSubscribers()

    • addTagSubscriber

      void addTagSubscriber(ActorRef subscriber, String tag)

    • hasAllPersistenceIdsSubscribers

      boolean hasAllPersistenceIdsSubscribers()

    • addAllPersistenceIdsSubscriber

      void addAllPersistenceIdsSubscriber(ActorRef subscriber)

    • notifyPersistenceIdChange

      void notifyPersistenceIdChange(String persistenceId)

    • notifyTagChange

      void notifyTagChange(String tag)

    • newPersistenceIdAdded

      void newPersistenceIdAdded(String id)
      Specified by:
      newPersistenceIdAdded in interface LeveldbIdMapping