Apache Pekko
1.1.5
API
Generated with
Apache Pekko/org.apache.pekko.persistence.testkit/org.apache.pekko.persistence.testkit.internal/InMemStorage

InMemStorage

org.apache.pekko.persistence.testkit.internal.InMemStorage
@InternalApi
sealed trait InMemStorage[K, R] extends InternalReprSupport[R]

INTERNAL API

Attributes

Source
TestKitStorage.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Type members

Inherited and Abstract types

type InternalRepr

Attributes

Inherited from:
InternalReprSupport
Source
TestKitStorage.scala

Value members

Abstract methods

def reprToSeqNum(repr: R): Long

Attributes

Source
TestKitStorage.scala

Concrete methods

def add(key: K, p: R): Unit

Attributes

Source
TestKitStorage.scala
def add(key: K, elems: Seq[R]): Unit

Adds elements ordered by seqnum, sets new seqnum as max(old, max(newElemsSeqNums)))

Adds elements ordered by seqnum, sets new seqnum as max(old, max(newElemsSeqNums)))

Attributes

Source
TestKitStorage.scala
def clearAll(): Unit

Attributes

Source
TestKitStorage.scala
def delete(key: K, needsToBeDeleted: R => Boolean): Vector[R]

Deletes elements preserving highest sequence number.

Deletes elements preserving highest sequence number.

Attributes

Source
TestKitStorage.scala
def deleteToSeqNumber(key: K, toSeqNumberInclusive: Long): Unit

Attributes

Source
TestKitStorage.scala
def findMany(key: K, fromInclusive: Int, maxNum: Int): Option[Vector[R]]

Attributes

Source
TestKitStorage.scala
def findOneByIndex(key: K, index: Int): Option[R]

Attributes

Source
TestKitStorage.scala
def firstInExpectNextQueue(key: K): Option[R]

Attributes

Source
TestKitStorage.scala
def getHighestSeqNumber(key: K): Long

Attributes

Source
TestKitStorage.scala
def keys(): Seq[K]

Attributes

Source
TestKitStorage.scala
def read(key: K): Option[Vector[R]]

Attributes

Source
TestKitStorage.scala
def read(key: K, fromInclusive: Long, toInclusive: Long, maxNumber: Long): Seq[R]

Reads elems within the range of seqnums.

Reads elems within the range of seqnums.

Attributes

Source
TestKitStorage.scala
def readAll(): Iterable[R]

Attributes

Source
TestKitStorage.scala
def removeFirstInExpectNextQueue(key: K): Unit

Attributes

Source
TestKitStorage.scala
def removeKey(key: K): Vector[R]

Removes key and the whole value including seqnum.

Removes key and the whole value including seqnum.

Attributes

Source
TestKitStorage.scala
def removePreservingSeqNumber(key: K): Unit

Attributes

Source
TestKitStorage.scala
def updateOrSetNew(key: K, updater: (Vector[R]) => Vector[R]): Vector[R]

Sets new elements returned by updater ordered by seqnum. Sets new seqnum as max(old, max(newElemsFromUpdaterSeqNums))

Sets new elements returned by updater ordered by seqnum. Sets new seqnum as max(old, max(newElemsFromUpdaterSeqNums))

Attributes

Source
TestKitStorage.scala
Generated with