Interface EventStorage

    • Method Detail

      • addAny

        void addAny​(java.lang.String key,
                    java.lang.Object elem)
      • addAny

        void addAny​(java.lang.String key,
                    scala.collection.immutable.Seq<java.lang.Object> elems)
      • add

        void add​(scala.collection.immutable.Seq<PersistentRepr> elems)
      • tryAdd

        scala.util.Try<scala.runtime.BoxedUnit> tryAdd​(scala.collection.immutable.Seq<PersistentRepr> elems)
        Throws:
        java.lang.Exception - from StorageFailure in the current writing policy
      • tryRead

        scala.collection.immutable.Seq<PersistentRepr> tryRead​(java.lang.String persistenceId,
                                                               long fromSequenceNr,
                                                               long toSequenceNr,
                                                               long max)
      • tryReadByTag

        scala.collection.immutable.Seq<PersistentRepr> tryReadByTag​(java.lang.String tag)
      • tryRead

        scala.collection.immutable.Seq<PersistentRepr> tryRead​(java.lang.String processId,
                                                               scala.Function1<PersistentRepr,​java.lang.Object> predicate)
      • tryReadSeqNumber

        long tryReadSeqNumber​(java.lang.String persistenceId)
      • tryDelete

        void tryDelete​(java.lang.String persistenceId,
                       long toSeqNumber)
      • currentPersistenceIds

        Source<java.lang.String,​NotUsed> currentPersistenceIds​(scala.Option<java.lang.String> afterId,
                                                                     long limit)
      • mapAny

        scala.collection.immutable.Seq<PersistentRepr> mapAny​(java.lang.String key,
                                                              scala.collection.immutable.Seq<java.lang.Object> elems)