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