package journal
- Alphabetic
- By Inheritance
- journal
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- trait DynamoDBHelper extends AnyRef
- class DynamoDBJournal extends AsyncWriteJournal with DynamoDBRecovery with DynamoDBJournalRequests with ActorLogging
- class DynamoDBJournalConfig extends DynamoDBConfig
- class DynamoDBJournalFailure extends RuntimeException
- class DynamoDBJournalRejection extends RuntimeException
- trait DynamoDBJournalRequests extends DynamoDBRequests
- trait DynamoDBRecovery extends AsyncRecovery
- case class LatencyReport(nanos: Long, retries: Int) extends Product with Serializable
-
case class
ListAll(persistenceId: String, replyTo: ActorRef) extends Product with Serializable
Query the table for all sequence numbers of the given persistenceId, starting from zero upwards and finishing when encountering a run of at least MaxBatchGet missing entries.
Query the table for all sequence numbers of the given persistenceId, starting from zero upwards and finishing when encountering a run of at least MaxBatchGet missing entries. This is a potentially very expensive operation, use with care!
A response of type ListAllResult will be sent back to the given
replyTo
reference. -
case class
ListAllResult(persistenceId: String, lowest: Set[Long], highest: Set[Long], events: Seq[Long]) extends Product with Serializable
Response to the ListAll request, containing
Response to the ListAll request, containing
- the persistenceId
- the set of lowest sequence numbers stored in the sequence shards
- the set of highest sequence numbers stored in the sequence shards
- the sequence numbers of all stored events in ascending order
The lowest/highest sequence number is obtained by taking the maximum of either set.
-
case class
Purge(persistenceId: String, replyTo: ActorRef) extends Product with Serializable
Purge all information stored for the given
persistenceId
from the journal.Purge all information stored for the given
persistenceId
from the journal. Purging the information for a running actor results in undefined behavior.A confirmation of type Purged will be sent to the given
replyTo
reference. -
case class
Purged(persistenceId: String) extends Product with Serializable
Confirmation that all information stored for the given
persistenceId
has been purged from the journal.
Value Members
- val AtomEnd: String
- val AtomIndex: String
- val Event: String
- val Key: String
- val KeyPayloadOverhead: Int
- val Manifest: String
- val Payload: String
- val PersistentId: String
- val SequenceNr: String
- val SerializerId: String
- val SerializerManifest: String
- val Sort: String
- val WriterUuid: String
- val schema: CreateTableRequest
- object DynamoDBRecovery
- object RemoveIncompleteAtoms extends GraphStage[FlowShape[Item, List[Item]]]