Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##: Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def asyncWriteMessages(messages: Seq[AtomicWrite]): Future[Seq[Try[Unit]]]
   Definition Classes

   BaseByteArrayJournalDao → JournalDao

   See also

   pekko.persistence.journal.AsyncWriteJournal.asyncWriteMessages(messages)

6.  def baseDaoConfig: BaseDaoConfig

   Definition Classes

   BaseByteArrayJournalDao → BaseDao

7.  def clone(): AnyRef

   Attributes

   protected[lang]

   Definition Classes

   AnyRef

   Annotations

   @throws(classOf[java.lang.CloneNotSupportedException]) @native()

8.  def correctMaxForH2Driver(max: Long): Long

   Definition Classes

   H2Compat

9.  val db: slick.jdbc.JdbcBackend.Database

   Definition Classes

   ByteArrayJournalDao → BaseByteArrayJournalDao

10.  def delete(persistenceId: String, maxSequenceNr: Long): Future[Unit]

    Deletes all persistent messages up to toSequenceNr (inclusive) for the persistenceId

    Deletes all persistent messages up to toSequenceNr (inclusive) for the persistenceId

    Definition Classes

    BaseByteArrayJournalDao → JournalDao

11.  implicit val ec: ExecutionContext

    Definition Classes

    ByteArrayJournalDao → BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao

12.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

13.  def equals(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef → Any

14.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.Throwable])

15.  final def getClass(): Class[_ <: AnyRef]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

16.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

17.  def highestSequenceNr(persistenceId: String, fromSequenceNr: Long): Future[Long]

    Returns the highest sequence number for the events that are stored for that persistenceId.

    Returns the highest sequence number for the events that are stored for that persistenceId. When no events are found for the persistenceId, 0L will be the highest sequence number

    Definition Classes

    BaseByteArrayJournalDao → JournalDao

18.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

19.  val journalConfig: JournalConfig

    Definition Classes

    ByteArrayJournalDao → BaseByteArrayJournalDao

20.  val logger: Logger

    Definition Classes

    BaseByteArrayJournalDao

21.  implicit val mat: Materializer

    Definition Classes

    ByteArrayJournalDao → BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao

22.  def messages(persistenceId: String, fromSequenceNr: Long, toSequenceNr: Long, max: Long): Source[Try[(PersistentRepr, Long)], NotUsed]

    Returns a Source of PersistentRepr and ordering number for a certain persistenceId.

    Returns a Source of PersistentRepr and ordering number for a certain persistenceId. It includes the events with sequenceNr between fromSequenceNr (inclusive) and toSequenceNr (inclusive).

    Definition Classes

    BaseByteArrayJournalDao → JournalDaoWithReadMessages

23.  def messagesWithBatch(persistenceId: String, fromSequenceNr: Long, toSequenceNr: Long, batchSize: Int, refreshInterval: Option[(FiniteDuration, Scheduler)]): Source[Try[(PersistentRepr, Long)], NotUsed]

    Returns a Source of PersistentRepr and ordering number for a certain persistenceId.

    Returns a Source of PersistentRepr and ordering number for a certain persistenceId. It includes the events with sequenceNr between fromSequenceNr (inclusive) and toSequenceNr (inclusive).

    Definition Classes

    BaseJournalDaoWithReadMessages → JournalDaoWithReadMessages

24.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

25.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

26.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

27.  val profile: JdbcProfile

    Definition Classes

    ByteArrayJournalDao → BaseByteArrayJournalDao → H2Compat

28.  val queries: JournalQueries

    Definition Classes

    ByteArrayJournalDao → BaseByteArrayJournalDao

29.  def queueWriteJournalRows(xs: Seq[JournalRow]): Future[Unit]

    Definition Classes

    BaseDao

30.  val serializer: ByteArrayJournalSerializer

    Definition Classes

    ByteArrayJournalDao → BaseByteArrayJournalDao

31.  final def synchronized[T0](arg0: => T0): T0

    Definition Classes

    AnyRef

32.  def toString(): String

    Definition Classes

    AnyRef → Any

33.  def update(persistenceId: String, sequenceNr: Long, payload: AnyRef): Future[Done]

    Update (!) an existing event with the passed in data.

    Update (!) an existing event with the passed in data.

    Definition Classes

    BaseByteArrayJournalDao → JournalDaoWithUpdates

34.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

35.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException])

36.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws(classOf[java.lang.InterruptedException]) @native()

37.  def writeJournalRows(xs: Seq[JournalRow]): Future[Unit]

    Definition Classes

    BaseByteArrayJournalDao → BaseDao