sealed trait InMemStorage[K, R] extends InternalReprSupport[R]
Ordering
- Alphabetic
- By Inheritance
Inherited
- InMemStorage
- InternalReprSupport
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- abstract type InternalRepr
- Definition Classes
- InternalReprSupport
Concrete Value Members
- def add(key: K, elems: Seq[R]): Unit
Adds elements ordered by seqnum, sets new seqnum as max(old, max(newElemsSeqNums)))
- def add(key: K, p: R): Unit
- def clearAll(): Unit
- def clearAllPreservingSeqNumbers(): Unit
- def delete(key: K, needsToBeDeleted: (R) => Boolean): Vector[R]
Deletes elements preserving highest sequence number.
- def deleteToSeqNumber(key: K, toSeqNumberInclusive: Long): Unit
- def findMany(key: K, fromInclusive: Int, maxNum: Int): Option[Vector[R]]
- def findOneByIndex(key: K, index: Int): Option[R]
- def firstInExpectNextQueue(key: K): Option[R]
- def getHighestSeqNumber(key: K): Long
- def keys(): Seq[K]
- def read(key: K, fromInclusive: Long, toInclusive: Long, maxNumber: Long): Seq[R]
Reads elems within the range of seqnums.
- def read(key: K): Option[Vector[R]]
- def readAll(): Iterable[R]
- def removeFirstInExpectNextQueue(key: K): Unit
- def removeKey(key: K): Vector[R]
Removes key and the whole value including seqnum.
- def removePreservingSeqNumber(key: K): Unit
- def updateOrSetNew(key: K, updater: (Vector[R]) => Vector[R]): Vector[R]
Sets new elements returned by updater ordered by seqnum.
Sets new elements returned by updater ordered by seqnum. Sets new seqnum as max(old, max(newElemsFromUpdaterSeqNums))
INTERNAL API