Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def aroundPostRestart(reason: Throwable): Unit

   Attributes

   protected[akka]

   Definition Classes

   Actor

   Annotations

   @InternalApi()

5.  def aroundPostStop(): Unit

   Attributes

   protected[akka]

   Definition Classes

   Actor

   Annotations

   @InternalApi()

6.  def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

   Attributes

   protected[akka]

   Definition Classes

   Actor

   Annotations

   @InternalApi()

7.  def aroundPreStart(): Unit

   Attributes

   protected[akka]

   Definition Classes

   Actor

   Annotations

   @InternalApi()

8.  def aroundReceive(receive: actor.Actor.Receive, msg: Any): Unit

   Attributes

   protected[akka]

   Definition Classes

   Actor

   Annotations

   @InternalApi()

9.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

10.  def asyncDeleteMessagesTo(persistenceId: String, toSequenceNr: Long): Future[Unit]

    Delete messages up to a given sequence number.

    Delete messages up to a given sequence number. The range to which this applies first capped by the lowest and highest sequence number for this persistenceId since DynamoDB requires individual deletes to be issued for every single event. The procedure is to first update the lowest sequence number to the new value and then delete the now unreplayable events—this is desirable because in the other order a replay may see partially deleted history.

    Failures during purging are only logged and do not contribute to the call’s result.

    TODO in principle replays should be inhibited while the purge is ongoing

    Definition Classes

    DynamoDBJournal → AsyncWriteJournal

11.  def asyncReadHighestSequenceNr(persistenceId: String, fromSequenceNr: Long): Future[Long]

    Definition Classes

    DynamoDBJournal → AsyncRecovery

12.  def asyncReplayMessages(persistenceId: String, fromSequenceNr: Long, toSequenceNr: Long, max: Long)(replayCallback: (PersistentRepr) ⇒ Unit): Future[Unit]

    Definition Classes

    DynamoDBRecovery → AsyncRecovery

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

    Definition Classes

    DynamoDBJournal → AsyncWriteJournal

14.  def batchGetReq(items: Map[String, KeysAndAttributes]): BatchGetItemRequest

    Definition Classes

    DynamoDBRecovery

15.  def batchWriteReq(items: Map[String, List[WriteRequest]]): BatchWriteItemRequest

    Definition Classes

    DynamoDBRequests

16.  def batchWriteReq(writes: Seq[WriteRequest]): BatchWriteItemRequest

    Definition Classes

    DynamoDBRequests

17.  def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

18.  implicit val context: ActorContext

    Definition Classes

    Actor

19.  def deleteMessages(persistenceId: String, start: Long, end: Long): Future[Done]

    Definition Classes

    DynamoDBJournalRequests

20.  def doBatch(desc: (Seq[WriteRequest]) ⇒ String, writes: Seq[WriteRequest]): Future[Done]

    Execute the given WriteRequests in batches of MaxBatchWrite, ignoring and logging all errors.

    Execute the given WriteRequests in batches of MaxBatchWrite, ignoring and logging all errors. The returned Future never fails.

    Definition Classes

    DynamoDBRequests

21.  val dynamo: DynamoDBHelper

    Definition Classes

    DynamoDBJournal → DynamoDBRequests

22.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

23.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

24.  def eventQuery(persistenceId: String, sequenceNr: Long): QueryRequest

    Definition Classes

    DynamoDBRecovery

25.  val extension: Persistence
26.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

27.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

28.  def getRemainingQueryItems(request: QueryRequest, result: QueryResult): Future[QueryResult]

    Definition Classes

    DynamoDBRecovery

29.  def getReplayBatch(persistenceId: String, seqNrs: Seq[Long]): Future[ReplayBatch]

    Definition Classes

    DynamoDBRecovery

30.  def getUnprocessedItems(result: BatchGetItemResult, retriesRemaining: Int = 10): Future[BatchGetItemResult]

    Definition Classes

    DynamoDBRecovery

31.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

32.  def highSeqKey(persistenceId: String, shard: Long): Item
33.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

34.  def keyLength(persistenceId: String, sequenceNr: Long): Int
35.  def listAllSeqNr(persistenceId: String): Future[Seq[Long]]

    Definition Classes

    DynamoDBRecovery

36.  def log: LoggingAdapter

    Definition Classes

    ActorLogging

37.  def logFailure[T](desc: String)(f: Future[T]): Future[T]
38.  def lowSeqKey(persistenceId: String, shard: Long): Item
39.  implicit val materializer: ActorMaterializer
40.  def messageKey(persistenceId: String, sequenceNr: Long): Item
41.  def messagePartitionKey(persistenceId: String, sequenceNr: Long): String
42.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

43.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

44.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

45.  val persistence: Persistence

    Definition Classes

    WriteJournalBase

46.  def postRestart(reason: Throwable): Unit

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

47.  def postStop(): Unit

    Definition Classes

    DynamoDBJournal → Actor

48.  def preRestart(reason: Throwable, message: Option[Any]): Unit

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

49.  def preStart(): Unit

    Definition Classes

    Actor

    Annotations

    @throws( classOf[java.lang.Exception] )

50.  def preparePersistentBatch(rb: Seq[PersistentEnvelope]): Seq[AtomicWrite]

    Attributes

    protected

    Definition Classes

    WriteJournalBase

51.  def putItem(item: Item): PutItemRequest

    Definition Classes

    DynamoDBRequests

52.  def readAllSequenceNr(persistenceId: String, highest: Boolean): Future[Set[Long]]

    Definition Classes

    DynamoDBRecovery

53.  def readPersistentRepr(item: Map[String, AttributeValue], async: Boolean): Future[PersistentRepr]

    Definition Classes

    DynamoDBRecovery

54.  def readSequenceNr(persistenceId: String, highest: Boolean): Future[Long]

    Definition Classes

    DynamoDBRecovery

55.  def readSequenceNrBatches(persistenceId: String, highest: Boolean): Iterator[Future[BatchGetItemResult]]

    Definition Classes

    DynamoDBRecovery

56.  final def receive: PartialFunction[Any, Unit]

    Definition Classes

    AsyncWriteJournal → Actor

57.  def receivePluginInternal: PartialFunction[Any, Unit]

    Definition Classes

    DynamoDBJournal → AsyncWriteJournal

58.  final val receiveWriteJournal: actor.Actor.Receive

    Definition Classes

    AsyncWriteJournal

59.  def removeHS(persistenceId: String): Future[Done]

    Definition Classes

    DynamoDBJournalRequests

60.  def removeLS(persistenceId: String): Future[Done]

    Definition Classes

    DynamoDBJournalRequests

61.  implicit lazy val replayDispatcher: MessageDispatcher

    Definition Classes

    DynamoDBRecovery

62.  implicit final val self: ActorRef

    Definition Classes

    Actor

63.  final def sender(): ActorRef

    Definition Classes

    Actor

64.  val serialization: Serialization
65.  def setHS(persistenceId: String, to: Long): Future[PutItemResult]

    Definition Classes

    DynamoDBJournalRequests

66.  def setLS(persistenceId: String, to: Long): Future[PutItemResult]

    Definition Classes

    DynamoDBJournalRequests

67.  val settings: DynamoDBJournalConfig

    Definition Classes

    DynamoDBJournal → DynamoDBRequests

68.  def supervisorStrategy: SupervisorStrategy

    Definition Classes

    Actor

69.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

70.  def toString(): String

    Definition Classes

    AnyRef → Any

71.  def unhandled(message: Any): Unit

    Definition Classes

    Actor

72.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

73.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

74.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

75.  def writeMessages(atomicWrite: AtomicWrite): Future[Try[Unit]]

    Write all PersistentRepr in the AtomicWrite provided

    Write all PersistentRepr in the AtomicWrite provided

    If there are any errors serializing (preparing the batch writes), then we must return a Future.success(Failure) as the result. This is needed to be compliant with Akka Persistence 2.4

    atomicWrite

    Contains a list of persistentRepr that need to be persisted atomically

    returns

    a successfully completed Future that contains either a Success or Failure

    Definition Classes

    DynamoDBJournalRequests

76.  def writeMessages(writes: Seq[AtomicWrite]): Future[List[Try[Unit]]]

    Write all messages in a sequence of AtomicWrites.

    Write all messages in a sequence of AtomicWrites. Care must be taken to not have concurrent writes happening that touch the highest sequence number. The current implementation is the simplest with this guarantee in that it will run each AtomicWrite in sequence without even batching those that could be batched. The most common case is that there is just one message in total anyway.

    Definition Classes

    DynamoDBJournalRequests