Package org.apache.pekko.persistence.testkit.scaladsl

Interface HasStorage<P,R>

All Known Implementing Classes:
PersistenceTestKit, SnapshotTestKit
public interface HasStorage<P,R>
Abstract persistent storage for tests. Has additional methods for keeping track of the indexes of last events persisted in the storage during test.

  • Method Details

    • addToIndex

      void addToIndex(String persistenceId, int add)

    • clearIndexStorage

      void clearIndexStorage()

    • nextIndex

      int nextIndex(String persistenceId)

    • nextIndexByPersistenceId_$eq

      void nextIndexByPersistenceId_$eq(scala.collection.immutable.Map<String,Object> x$1)

    • removeLastIndex

      void removeLastIndex(String persistenceId)

    • setIndex

      void setIndex(String persistenceId, int index)

    • storage

      TestKitStorage<P,R> storage()