ExactTxPipelineStore

org.sigilaris.node.jvm.runtime.txpipeline.ExactTxPipelineStore
trait ExactTxPipelineStore[F[_]]

Attributes

Source
ExactTxPipelineStore.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def countUnjournaled(journaledPipelineIds: Set[TxPipelineId], stopAt: Int): EitherT[F, 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

Source
ExactTxPipelineStore.scala
def get(pipelineId: TxPipelineId): EitherT[F, ExactTxPipelineStoreFailure, Option[ExactTxPipelineRecord]]

Attributes

Source
ExactTxPipelineStore.scala
def list(offset: Int, limit: Int): EitherT[F, 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

Source
ExactTxPipelineStore.scala