package journal

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. journal
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. trait DynamoDBHelper extends AnyRef
  2. class DynamoDBJournal extends AsyncWriteJournal with DynamoDBRecovery with DynamoDBJournalRequests with ActorLogging
  3. class DynamoDBJournalConfig extends DynamoDBConfig
  4. class DynamoDBJournalFailure extends RuntimeException
  5. class DynamoDBJournalRejection extends RuntimeException
  6. trait DynamoDBJournalRequests extends DynamoDBRequests
  7. trait DynamoDBRecovery extends AsyncRecovery
  8. case class LatencyReport(nanos: Long, retries: Int) extends Product with Serializable
  9. 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.

  10. 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.

  11. 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.

  12. 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

  1. val AtomEnd: String
  2. val AtomIndex: String
  3. val Event: String
  4. val Key: String
  5. val KeyPayloadOverhead: Int
  6. val Manifest: String
  7. val Payload: String
  8. val PersistentId: String
  9. val SequenceNr: String
  10. val SerializerId: String
  11. val SerializerManifest: String
  12. val Sort: String
  13. val WriterUuid: String
  14. val schema: CreateTableRequest
  15. object DynamoDBRecovery
  16. object RemoveIncompleteAtoms extends GraphStage[FlowShape[Item, List[Item]]]

Inherited from AnyRef

Inherited from Any

Ungrouped