org.sigilaris.node.jvm.storage.swaydb.SwayDbTxPipelineStore
See theSwayDbTxPipelineStore companion object
final class SwayDbTxPipelineStore extends TxPipelineStore[IO]
Attributes
- Companion
- object
- Source
- SwayDbTxPipelineStore.scala
- Graph
-
- Supertypes
Members list
Value members
Concrete methods
override def addIdempotencyAlias(idempotencyKey: TxPipelineIdempotencyKey, binding: TxPipelineIdempotencyBinding): EitherT[IO, TxPipelineStoreFailure, TxPipelineRecord]
Attributes
- Definition Classes
- Source
- SwayDbTxPipelineStore.scala
override def create(record: TxPipelineRecord): EitherT[IO, TxPipelineStoreFailure, TxPipelineRecord]
Attributes
- Definition Classes
- Source
- SwayDbTxPipelineStore.scala
override def get(pipelineId: TxPipelineId): EitherT[IO, TxPipelineStoreFailure, Option[TxPipelineRecord]]
Attributes
- Definition Classes
- Source
- SwayDbTxPipelineStore.scala
override def getByIdempotencyKey(idempotencyKey: TxPipelineIdempotencyKey): EitherT[IO, TxPipelineStoreFailure, Option[TxPipelineRecord]]
Attributes
- Definition Classes
- Source
- SwayDbTxPipelineStore.scala
override def list(offset: Int, limit: Int): EitherT[IO, TxPipelineStoreFailure, Vector[TxPipelineRecord]]
Attributes
- Definition Classes
- Source
- SwayDbTxPipelineStore.scala
Attributes
- Definition Classes
- Source
- SwayDbTxPipelineStore.scala
override def update(pipelineId: TxPipelineId)(update: TxPipelineRecord => TxPipelineStoreUpdate): EitherT[IO, TxPipelineStoreFailure, Option[TxPipelineStoreUpdate]]
Attributes
- Definition Classes
- Source
- SwayDbTxPipelineStore.scala
In this article