Package org.apache.pekko.persistence.testkit.internal

Interface InMemStorage<K,R>

All Superinterfaces:
InternalReprSupport<R>
All Known Subinterfaces:
EventStorage, SnapshotStorage, TestKitStorage<P,R>
public interface InMemStorage<K,R> extends InternalReprSupport<R>
INTERNAL API

  • Method Summary

    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,Object> needsToBeDeleted)
    Deletes elements preserving highest sequence number.
    void
    deleteToSeqNumber(K key, long toSeqNumberInclusive)
     
    void
    eventsMap_$eq(scala.collection.immutable.Map<K,scala.Tuple2<Object,scala.collection.immutable.Vector<Object>>> x$1)
     
    void
    expectNextQueue_$eq(scala.collection.immutable.Map<K,scala.collection.immutable.Vector<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.

    Methods inherited from interface org.apache.pekko.persistence.testkit.internal.InternalReprSupport

    toInternal, toRepr

  • Method Details

    • 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,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<Object,scala.collection.immutable.Vector<Object>>> x$1)

    • expectNextQueue_$eq

      void expectNextQueue_$eq(scala.collection.immutable.Map<K,scala.collection.immutable.Vector<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))