Packages

t

akka.persistence.jdbc.journal.dao.legacy

BaseByteArrayJournalDao

trait BaseByteArrayJournalDao extends BaseDao[JournalRow] with JournalDaoWithUpdates with BaseJournalDaoWithReadMessages with H2Compat

The DefaultJournalDao contains all the knowledge to persist and load serialized journal entries

Source
ByteArrayJournalDao.scala
Linear Supertypes
H2Compat, BaseJournalDaoWithReadMessages, JournalDaoWithUpdates, JournalDao, JournalDaoWithReadMessages, BaseDao[JournalRow], AnyRef, Any
Known Subclasses
ByteArrayJournalDao
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BaseByteArrayJournalDao
  2. H2Compat
  3. BaseJournalDaoWithReadMessages
  4. JournalDaoWithUpdates
  5. JournalDao
  6. JournalDaoWithReadMessages
  7. BaseDao
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract val db: slick.jdbc.JdbcBackend.Database
  2. implicit abstract val ec: ExecutionContext
    Definition Classes
    BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao
  3. abstract val journalConfig: JournalConfig
  4. implicit abstract val mat: Materializer
    Definition Classes
    BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao
  5. abstract val profile: JdbcProfile
    Definition Classes
    BaseByteArrayJournalDao → H2Compat
  6. abstract val queries: JournalQueries
  7. abstract val serializer: FlowPersistentReprSerializer[JournalRow]
    Annotations
    @nowarn()

Concrete Value Members

  1. def asyncWriteMessages(messages: Seq[AtomicWrite]): Future[Seq[Try[Unit]]]

    Definition Classes
    BaseByteArrayJournalDao → JournalDao
    See also

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

  2. def baseDaoConfig: BaseDaoConfig
    Definition Classes
    BaseByteArrayJournalDao → BaseDao
  3. def correctMaxForH2Driver(max: Long): Long
    Definition Classes
    H2Compat
  4. 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
  5. 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
  6. val logger: Logger
  7. 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
  8. 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
  9. def queueWriteJournalRows(xs: Seq[JournalRow]): Future[Unit]
    Definition Classes
    BaseDao
  10. 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
  11. def writeJournalRows(xs: Seq[JournalRow]): Future[Unit]
    Definition Classes
    BaseByteArrayJournalDao → BaseDao
  12. val writeQueue: SourceQueueWithComplete[(Promise[Unit], Seq[JournalRow])]
    Definition Classes
    BaseDao