Packages

class ByteArrayJournalDao extends BaseDao[JournalRow] with BaseByteArrayJournalDao

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ByteArrayJournalDao
  2. BaseByteArrayJournalDao
  3. H2Compat
  4. BaseJournalDaoWithReadMessages
  5. JournalDaoWithUpdates
  6. JournalDao
  7. JournalDaoWithReadMessages
  8. BaseDao
  9. AnyRef
  10. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ByteArrayJournalDao(db: slick.jdbc.JdbcBackend.Database, profile: JdbcProfile, journalConfig: JournalConfig, serialization: Serialization)(implicit ec: ExecutionContext, mat: Materializer)

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. val db: slick.jdbc.JdbcBackend.Database
    Definition Classes
    ByteArrayJournalDao → BaseByteArrayJournalDao
  5. 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
  6. implicit val ec: ExecutionContext
    Definition Classes
    ByteArrayJournalDao → BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao
  7. 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
  8. val journalConfig: JournalConfig
    Definition Classes
    ByteArrayJournalDao → BaseByteArrayJournalDao
  9. val logger: Logger
    Definition Classes
    BaseByteArrayJournalDao
  10. implicit val mat: Materializer
    Definition Classes
    ByteArrayJournalDao → BaseByteArrayJournalDao → BaseJournalDaoWithReadMessages → BaseDao
  11. 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
  12. 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
  13. val profile: JdbcProfile
    Definition Classes
    ByteArrayJournalDao → BaseByteArrayJournalDao → H2Compat
  14. val queries: JournalQueries
    Definition Classes
    ByteArrayJournalDao → BaseByteArrayJournalDao
  15. def queueWriteJournalRows(xs: Seq[JournalRow]): Future[Unit]
    Definition Classes
    BaseDao
  16. val serializer: ByteArrayJournalSerializer
    Definition Classes
    ByteArrayJournalDao → BaseByteArrayJournalDao
  17. 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
  18. def writeJournalRows(xs: Seq[JournalRow]): Future[Unit]
    Definition Classes
    BaseByteArrayJournalDao → BaseDao
  19. val writeQueue: SourceQueueWithComplete[(Promise[Unit], Seq[JournalRow])]
    Definition Classes
    BaseDao