Package akka.persistence.testkit.internal

Interface InMemStorage<K,​R>

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void add​(K key, R p)  
      void add​(K key, scala.collection.immutable.Seq<R> elems)
      Adds elements ordered by seqnum, sets new seqnum as max(old, max(newElemsSeqNums)))
      void clearAll()  
      void clearAllPreservingSeqNumbers()  
      scala.collection.immutable.Vector<R> delete​(K key, scala.Function1<R,​java.lang.Object> needsToBeDeleted)
      Deletes elements preserving highest sequence number.
      void deleteToSeqNumber​(K key, long toSeqNumberInclusive)  
      void eventsMap_$eq​(scala.collection.immutable.Map<K,​scala.Tuple2<java.lang.Object,​scala.collection.immutable.Vector<java.lang.Object>>> x$1)  
      void expectNextQueue_$eq​(scala.collection.immutable.Map<K,​scala.collection.immutable.Vector<java.lang.Object>> x$1)  
      scala.Option<scala.collection.immutable.Vector<R>> findMany​(K key, int fromInclusive, int maxNum)  
      scala.Option<R> findOneByIndex​(K key, int index)  
      scala.Option<R> firstInExpectNextQueue​(K key)  
      long getHighestSeqNumber​(K key)  
      long getLastSeqNumber​(scala.collection.immutable.Seq<R> elems)  
      scala.collection.immutable.Seq<K> keys()  
      scala.Option<scala.collection.immutable.Vector<R>> read​(K key)  
      scala.collection.immutable.Seq<R> read​(K key, long fromInclusive, long toInclusive, long maxNumber)
      Reads elems within the range of seqnums.
      scala.collection.Iterable<R> readAll()  
      void removeFirstInExpectNextQueue​(K key)  
      scala.collection.immutable.Vector<R> removeKey​(K key)
      Removes key and the whole value including seqnum.
      void removePreservingSeqNumber​(K key)  
      long reprToSeqNum​(R repr)  
      scala.collection.immutable.Vector<R> updateOrSetNew​(K key, scala.Function1<scala.collection.immutable.Vector<R>,​scala.collection.immutable.Vector<R>> updater)
      Sets new elements returned by updater ordered by seqnum.

    • Method Detail

      • add

        void add​(K key,
         R p)

      • add

        void add​(K key,
         scala.collection.immutable.Seq<R> elems)
        Adds elements ordered by seqnum, sets new seqnum as max(old, max(newElemsSeqNums)))

      • clearAll

        void clearAll()

      • clearAllPreservingSeqNumbers

        void clearAllPreservingSeqNumbers()

      • delete

        scala.collection.immutable.Vector<R> delete​(K key,
                                            scala.Function1<R,​java.lang.Object> needsToBeDeleted)
        Deletes elements preserving highest sequence number.

      • deleteToSeqNumber

        void deleteToSeqNumber​(K key,
                       long toSeqNumberInclusive)

      • eventsMap_$eq

        void eventsMap_$eq​(scala.collection.immutable.Map<K,​scala.Tuple2<java.lang.Object,​scala.collection.immutable.Vector<java.lang.Object>>> x$1)

      • expectNextQueue_$eq

        void expectNextQueue_$eq​(scala.collection.immutable.Map<K,​scala.collection.immutable.Vector<java.lang.Object>> x$1)

      • findMany

        scala.Option<scala.collection.immutable.Vector<R>> findMany​(K key,
                                                            int fromInclusive,
                                                            int maxNum)

      • findOneByIndex

        scala.Option<R> findOneByIndex​(K key,
                               int index)

      • firstInExpectNextQueue

        scala.Option<R> firstInExpectNextQueue​(K key)

      • getHighestSeqNumber

        long getHighestSeqNumber​(K key)

      • getLastSeqNumber

        long getLastSeqNumber​(scala.collection.immutable.Seq<R> elems)

      • keys

        scala.collection.immutable.Seq<K> keys()

      • read

        scala.Option<scala.collection.immutable.Vector<R>> read​(K key)

      • read

        scala.collection.immutable.Seq<R> read​(K key,
                                       long fromInclusive,
                                       long toInclusive,
                                       long maxNumber)
        Reads elems within the range of seqnums.

      • readAll

        scala.collection.Iterable<R> readAll()

      • removeFirstInExpectNextQueue

        void removeFirstInExpectNextQueue​(K key)

      • removeKey

        scala.collection.immutable.Vector<R> removeKey​(K key)
        Removes key and the whole value including seqnum.

      • removePreservingSeqNumber

        void removePreservingSeqNumber​(K key)

      • reprToSeqNum

        long reprToSeqNum​(R repr)

      • updateOrSetNew

        scala.collection.immutable.Vector<R> updateOrSetNew​(K key,
                                                    scala.Function1<scala.collection.immutable.Vector<R>,​scala.collection.immutable.Vector<R>> updater)
        Sets new elements returned by updater ordered by seqnum. Sets new seqnum as max(old, max(newElemsFromUpdaterSeqNums))