Class LeveldbJournal

    • Constructor Detail

      • LeveldbJournal

        public LeveldbJournal​(com.typesafe.config.Config cfg)
      • LeveldbJournal

        public LeveldbJournal()
    • Method Detail

      • sender

        public static final ActorRef sender()
      • aroundReceive

        protected static void aroundReceive​(scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive,
                                            java.lang.Object msg)
      • aroundPreStart

        protected static void aroundPreStart()
      • aroundPostStop

        protected static void aroundPostStop()
      • aroundPreRestart

        protected static void aroundPreRestart​(java.lang.Throwable reason,
                                               scala.Option<java.lang.Object> message)
      • aroundPostRestart

        protected static void aroundPostRestart​(java.lang.Throwable reason)
      • preRestart

        public static void preRestart​(java.lang.Throwable reason,
                                      scala.Option<java.lang.Object> message)
                               throws java.lang.Exception
        Throws:
        java.lang.Exception
      • postRestart

        public static void postRestart​(java.lang.Throwable reason)
                                throws java.lang.Exception
        Throws:
        java.lang.Exception
      • unhandled

        public static void unhandled​(java.lang.Object message)
      • akka$persistence$journal$WriteJournalBase$$eventAdapters

        public static EventAdapters akka$persistence$journal$WriteJournalBase$$eventAdapters()
      • preparePersistentBatch

        protected static scala.collection.immutable.Seq<AtomicWrite> preparePersistentBatch​(scala.collection.immutable.Seq<PersistentEnvelope> rb)
      • akka$persistence$journal$WriteJournalBase$_setter_$akka$persistence$journal$WriteJournalBase$$eventAdapters_$eq

        protected abstract static void akka$persistence$journal$WriteJournalBase$_setter_$akka$persistence$journal$WriteJournalBase$$eventAdapters_$eq​(EventAdapters x$1)
      • akka$persistence$journal$AsyncWriteJournal$$extension

        public static Persistence akka$persistence$journal$AsyncWriteJournal$$extension()
      • akka$persistence$journal$AsyncWriteJournal$$publish

        public static boolean akka$persistence$journal$AsyncWriteJournal$$publish()
      • akka$persistence$journal$AsyncWriteJournal$$config

        public static com.typesafe.config.Config akka$persistence$journal$AsyncWriteJournal$$config()
      • akka$persistence$journal$AsyncWriteJournal$$breaker

        public static CircuitBreaker akka$persistence$journal$AsyncWriteJournal$$breaker()
      • akka$persistence$journal$AsyncWriteJournal$$replayFilterMode

        public static ReplayFilter.Mode akka$persistence$journal$AsyncWriteJournal$$replayFilterMode()
      • akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize

        public static int akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize()
      • akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters

        public static int akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters()
      • akka$persistence$journal$AsyncWriteJournal$$resequencer

        public static ActorRef akka$persistence$journal$AsyncWriteJournal$$resequencer()
      • akka$persistence$journal$AsyncWriteJournal$$resequencerCounter

        public static long akka$persistence$journal$AsyncWriteJournal$$resequencerCounter()
      • akka$persistence$journal$AsyncWriteJournal$$resequencerCounter_$eq

        public static void akka$persistence$journal$AsyncWriteJournal$$resequencerCounter_$eq​(long x$1)
      • receive

        public static final scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
      • asyncWriteMessages

        public abstract static scala.concurrent.Future<scala.collection.immutable.Seq<scala.util.Try<scala.runtime.BoxedUnit>>> asyncWriteMessages​(scala.collection.immutable.Seq<AtomicWrite> messages)
      • asyncDeleteMessagesTo

        public abstract static scala.concurrent.Future<scala.runtime.BoxedUnit> asyncDeleteMessagesTo​(java.lang.String persistenceId,
                                                                                                      long toSequenceNr)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$extension_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$extension_$eq​(Persistence x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$publish_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$publish_$eq​(boolean x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$config_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$config_$eq​(com.typesafe.config.Config x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$breaker_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$breaker_$eq​(CircuitBreaker x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMode_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMode_$eq​(ReplayFilter.Mode x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterWindowSize_$eq​(int x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$replayFilterMaxOldWriters_$eq​(int x$1)
      • akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$resequencer_$eq

        protected abstract static void akka$persistence$journal$AsyncWriteJournal$_setter_$akka$persistence$journal$AsyncWriteJournal$$resequencer_$eq​(ActorRef x$1)
      • akka$persistence$journal$leveldb$LeveldbIdMapping$$idOffset

        public static int akka$persistence$journal$leveldb$LeveldbIdMapping$$idOffset()
      • akka$persistence$journal$leveldb$LeveldbIdMapping$$idMap

        public static scala.collection.immutable.Map<java.lang.String,​java.lang.Object> akka$persistence$journal$leveldb$LeveldbIdMapping$$idMap()
      • akka$persistence$journal$leveldb$LeveldbIdMapping$$idMap_$eq

        public static void akka$persistence$journal$leveldb$LeveldbIdMapping$$idMap_$eq​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> x$1)
      • akka$persistence$journal$leveldb$LeveldbIdMapping$$idMapLock

        public static java.lang.Object akka$persistence$journal$leveldb$LeveldbIdMapping$$idMapLock()
      • numericId

        public static int numericId​(java.lang.String id)
      • isNewPersistenceId

        public static boolean isNewPersistenceId​(java.lang.String id)
      • allPersistenceIds

        public static scala.collection.immutable.Set<java.lang.String> allPersistenceIds()
      • akka$persistence$journal$leveldb$LeveldbIdMapping$_setter_$akka$persistence$journal$leveldb$LeveldbIdMapping$$idOffset_$eq

        protected abstract static void akka$persistence$journal$leveldb$LeveldbIdMapping$_setter_$akka$persistence$journal$leveldb$LeveldbIdMapping$$idOffset_$eq​(int x$1)
      • akka$persistence$journal$leveldb$LeveldbIdMapping$_setter_$akka$persistence$journal$leveldb$LeveldbIdMapping$$idMapLock_$eq

        protected abstract static void akka$persistence$journal$leveldb$LeveldbIdMapping$_setter_$akka$persistence$journal$leveldb$LeveldbIdMapping$$idMapLock_$eq​(java.lang.Object x$1)
      • akka$persistence$journal$leveldb$LeveldbRecovery$$replayDispatcherId

        public static java.lang.String akka$persistence$journal$leveldb$LeveldbRecovery$$replayDispatcherId()
      • akka$persistence$journal$leveldb$LeveldbRecovery$$replayDispatcher

        public static MessageDispatcher akka$persistence$journal$leveldb$LeveldbRecovery$$replayDispatcher()
      • asyncReadHighestSequenceNr

        public static scala.concurrent.Future<java.lang.Object> asyncReadHighestSequenceNr​(java.lang.String persistenceId,
                                                                                           long fromSequenceNr)
      • asyncReplayMessages

        public static scala.concurrent.Future<scala.runtime.BoxedUnit> asyncReplayMessages​(java.lang.String persistenceId,
                                                                                           long fromSequenceNr,
                                                                                           long toSequenceNr,
                                                                                           long max,
                                                                                           scala.Function1<PersistentRepr,​scala.runtime.BoxedUnit> replayCallback)
      • replayMessages

        public static void replayMessages​(int persistenceId,
                                          long fromSequenceNr,
                                          long toSequenceNr,
                                          long max,
                                          scala.Function1<PersistentRepr,​scala.runtime.BoxedUnit> replayCallback)
      • asyncReplayTaggedMessages

        public static scala.concurrent.Future<scala.runtime.BoxedUnit> asyncReplayTaggedMessages​(java.lang.String tag,
                                                                                                 long fromSequenceNr,
                                                                                                 long toSequenceNr,
                                                                                                 long max,
                                                                                                 scala.Function1<LeveldbJournal.ReplayedTaggedMessage,​scala.runtime.BoxedUnit> replayCallback)
      • replayTaggedMessages

        public static void replayTaggedMessages​(java.lang.String tag,
                                                int tagNid,
                                                long fromSequenceNr,
                                                long toSequenceNr,
                                                long max,
                                                scala.Function1<LeveldbJournal.ReplayedTaggedMessage,​scala.runtime.BoxedUnit> replayCallback)
      • readHighestSequenceNr

        public static long readHighestSequenceNr​(int persistenceId)
      • akka$actor$ActorLogging$$_log

        public static LoggingAdapter akka$actor$ActorLogging$$_log()
      • akka$actor$ActorLogging$$_log_$eq

        public static void akka$actor$ActorLogging$$_log_$eq​(LoggingAdapter x$1)
      • akka$persistence$journal$leveldb$CompactionSegmentManagement$$latestCompactionSegments

        public static scala.collection.immutable.Map<java.lang.String,​java.lang.Object> akka$persistence$journal$leveldb$CompactionSegmentManagement$$latestCompactionSegments()
      • akka$persistence$journal$leveldb$CompactionSegmentManagement$$latestCompactionSegments_$eq

        public static void akka$persistence$journal$leveldb$CompactionSegmentManagement$$latestCompactionSegments_$eq​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> x$1)
      • updateCompactionSegment

        public static void updateCompactionSegment​(java.lang.String persistenceId,
                                                   long compactionSegment)
      • compactionLimit

        public static long compactionLimit​(java.lang.String persistenceId,
                                           long toSeqNr)
      • compactionSegment

        public static long compactionSegment​(java.lang.String persistenceId,
                                             long toSeqNr)
      • mustCompact

        public static boolean mustCompact​(java.lang.String persistenceId,
                                          long toSeqNr)
      • receiveCompactionInternal

        public static scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveCompactionInternal()
      • leveldbReadOptions

        public static org.iq80.leveldb.ReadOptions leveldbReadOptions()
      • akka$persistence$journal$leveldb$LeveldbStore$$persistenceIdSubscribers

        public static scala.collection.mutable.HashMap<java.lang.String,​scala.collection.mutable.Set<ActorRef>> akka$persistence$journal$leveldb$LeveldbStore$$persistenceIdSubscribers()
      • akka$persistence$journal$leveldb$LeveldbStore$$tagSubscribers

        public static scala.collection.mutable.HashMap<java.lang.String,​scala.collection.mutable.Set<ActorRef>> akka$persistence$journal$leveldb$LeveldbStore$$tagSubscribers()
      • akka$persistence$journal$leveldb$LeveldbStore$$allPersistenceIdsSubscribers

        public static scala.collection.immutable.Set<ActorRef> akka$persistence$journal$leveldb$LeveldbStore$$allPersistenceIdsSubscribers()
      • akka$persistence$journal$leveldb$LeveldbStore$$allPersistenceIdsSubscribers_$eq

        public static void akka$persistence$journal$leveldb$LeveldbStore$$allPersistenceIdsSubscribers_$eq​(scala.collection.immutable.Set<ActorRef> x$1)
      • akka$persistence$journal$leveldb$LeveldbStore$$tagSequenceNr

        public static scala.collection.immutable.Map<java.lang.String,​java.lang.Object> akka$persistence$journal$leveldb$LeveldbStore$$tagSequenceNr()
      • akka$persistence$journal$leveldb$LeveldbStore$$tagSequenceNr_$eq

        public static void akka$persistence$journal$leveldb$LeveldbStore$$tagSequenceNr_$eq​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> x$1)
      • akka$persistence$journal$leveldb$LeveldbStore$$tagPersistenceIdPrefix

        public static java.lang.String akka$persistence$journal$leveldb$LeveldbStore$$tagPersistenceIdPrefix()
      • leveldbFactory

        public static org.iq80.leveldb.DBFactory leveldbFactory()
      • leveldbSnapshot

        public static org.iq80.leveldb.ReadOptions leveldbSnapshot()
      • withIterator

        public static <R> R withIterator​(scala.Function1<org.iq80.leveldb.DBIterator,​R> body)
      • withBatch

        public static <R> R withBatch​(scala.Function1<org.iq80.leveldb.WriteBatch,​R> body)
      • persistentToBytes

        public static byte[] persistentToBytes​(PersistentRepr p)
      • persistentFromBytes

        public static PersistentRepr persistentFromBytes​(byte[] a)
      • tagNumericId

        public static int tagNumericId​(java.lang.String tag)
      • tagAsPersistenceId

        public static java.lang.String tagAsPersistenceId​(java.lang.String tag)
      • preStart

        public static void preStart()
      • postStop

        public static void postStop()
      • hasPersistenceIdSubscribers

        protected static boolean hasPersistenceIdSubscribers()
      • addPersistenceIdSubscriber

        protected static void addPersistenceIdSubscriber​(ActorRef subscriber,
                                                         java.lang.String persistenceId)
      • removeSubscriber

        protected static void removeSubscriber​(ActorRef subscriber)
      • hasTagSubscribers

        protected static boolean hasTagSubscribers()
      • addTagSubscriber

        protected static void addTagSubscriber​(ActorRef subscriber,
                                               java.lang.String tag)
      • hasAllPersistenceIdsSubscribers

        protected static boolean hasAllPersistenceIdsSubscribers()
      • addAllPersistenceIdsSubscriber

        protected static void addAllPersistenceIdsSubscriber​(ActorRef subscriber)
      • newPersistenceIdAdded

        protected static void newPersistenceIdAdded​(java.lang.String id)
      • akka$persistence$journal$leveldb$LeveldbStore$_setter_$akka$persistence$journal$leveldb$LeveldbStore$$persistenceIdSubscribers_$eq

        protected abstract static void akka$persistence$journal$leveldb$LeveldbStore$_setter_$akka$persistence$journal$leveldb$LeveldbStore$$persistenceIdSubscribers_$eq​(scala.collection.mutable.HashMap<java.lang.String,​scala.collection.mutable.Set<ActorRef>> x$1)
      • akka$persistence$journal$leveldb$LeveldbStore$_setter_$akka$persistence$journal$leveldb$LeveldbStore$$tagSubscribers_$eq

        protected abstract static void akka$persistence$journal$leveldb$LeveldbStore$_setter_$akka$persistence$journal$leveldb$LeveldbStore$$tagSubscribers_$eq​(scala.collection.mutable.HashMap<java.lang.String,​scala.collection.mutable.Set<ActorRef>> x$1)
      • akka$persistence$journal$leveldb$LeveldbStore$_setter_$akka$persistence$journal$leveldb$LeveldbStore$$tagPersistenceIdPrefix_$eq

        protected abstract static void akka$persistence$journal$leveldb$LeveldbStore$_setter_$akka$persistence$journal$leveldb$LeveldbStore$$tagPersistenceIdPrefix_$eq​(java.lang.String x$1)
      • config

        public com.typesafe.config.Config config()
        Specified by:
        config in interface LeveldbStore
      • leveldb

        public org.iq80.leveldb.DB leveldb()
        Specified by:
        leveldb in interface LeveldbStore
      • leveldb_$eq

        public void leveldb_$eq​(org.iq80.leveldb.DB x$1)
        Specified by:
        leveldb_$eq in interface LeveldbStore
      • receiveWriteJournal

        public final scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveWriteJournal()
        Specified by:
        receiveWriteJournal in interface AsyncWriteJournal
      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Returns:
        (undocumented)
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Returns:
        (undocumented)
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
        Parameters:
        x$1 - (undocumented)
      • receivePluginInternal

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receivePluginInternal()
        Description copied from interface: AsyncWriteJournal
        Plugin API

        Allows plugin implementers to use f pipeTo self and handle additional messages for implementing advanced features

        Specified by:
        receivePluginInternal in interface AsyncWriteJournal
        Returns:
        (undocumented)