Package org.apache.pekko.persistence.journal

Interface WriteJournalBase

All Known Subinterfaces:

AsyncWriteJournal, AsyncWriteProxy, LeveldbStore

All Known Implementing Classes:

AsyncWriteJournal, PersistenceTestKitPlugin, SharedLeveldbStore

public interface WriteJournalBase

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.Seq<PersistentRepr>	adaptFromJournal(PersistentRepr repr)	INTERNAL API
PersistentRepr	adaptToJournal(PersistentRepr repr)	INTERNAL API
void	org$apache$pekko$persistence$journal$WriteJournalBase$_setter_$persistence_$eq(Persistence x$1)
Persistence	persistence()
scala.collection.immutable.Seq<AtomicWrite>	preparePersistentBatch(scala.collection.immutable.Seq<PersistentEnvelope> rb)

Method Detail

adaptFromJournal

scala.collection.immutable.Seq<PersistentRepr> adaptFromJournal(PersistentRepr repr)

INTERNAL API

adaptToJournal

PersistentRepr adaptToJournal(PersistentRepr repr)

INTERNAL API

org$apache$pekko$persistence$journal$WriteJournalBase$_setter_$persistence_$eq

void org$apache$pekko$persistence$journal$WriteJournalBase$_setter_$persistence_$eq(Persistence x$1)

persistence

Persistence persistence()

preparePersistentBatch

scala.collection.immutable.Seq<AtomicWrite> preparePersistentBatch(scala.collection.immutable.Seq<PersistentEnvelope> rb)