SwayDbExactTxPipelineStore

org.sigilaris.node.jvm.storage.swaydb.SwayDbExactTxPipelineStore
See theSwayDbExactTxPipelineStore companion object

Attributes

Companion
object
Source
SwayDbExactTxPipelineStore.scala
Graph
Supertypes
class Object
trait Matchable
class Any

Members list

Value members

Concrete methods

override def countUnjournaled(journaledPipelineIds: Set[TxPipelineId], stopAt: Int): EitherT[IO, ExactTxPipelineStoreFailure, Int]

Counts admission rows that have not crossed into the application journal.

Counts admission rows that have not crossed into the application journal.

Implementations must perform one bounded primary-key scan rather than repeatedly decoding and sorting every record page.

Attributes

Definition Classes
Source
SwayDbExactTxPipelineStore.scala
override def get(pipelineId: TxPipelineId): EitherT[IO, ExactTxPipelineStoreFailure, Option[ExactTxPipelineRecord]]

Attributes

Definition Classes
Source
SwayDbExactTxPipelineStore.scala

Attributes

Definition Classes
Source
SwayDbExactTxPipelineStore.scala
override def list(offset: Int, limit: Int): EitherT[IO, ExactTxPipelineStoreFailure, Vector[ExactTxPipelineRecord]]

Returns a page in implementation-specific order. SwayDB uses serialized key order; the in-memory store uses pipeline-id string order. Callers must not assume the same ordering across stores or snapshot isolation between pages while writes are in progress. Startup reconciliation runs before admission and is order-independent.

Returns a page in implementation-specific order. SwayDB uses serialized key order; the in-memory store uses pipeline-id string order. Callers must not assume the same ordering across stores or snapshot isolation between pages while writes are in progress. Startup reconciliation runs before admission and is order-independent.

Attributes

Definition Classes
Source
SwayDbExactTxPipelineStore.scala