ExactPipelineExecutionRuntime
org.sigilaris.node.jvm.runtime.txpipeline.ExactPipelineExecutionRuntime
final class ExactPipelineExecutionRuntime[F[_]](exactStore: ExactTxPipelineStore[F], safety: ApplicationSafetyRuntime[F])(using evidence$1: Monad[F])
Attributes
- Source
- ExactPipelineExecutionRuntime.scala
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
Members list
Value members
Concrete methods
def executeOrderedAtomic[S](pipelineId: TxPipelineId, initialState: S, certificates: Vector[CertifiedEffectCertificate], candidateHeight: InclusionHeight, blockId: UInt256)(execute: (S, ExecutionId, TxPipelineTransactionPayload) => Either[ApplicationSafetyRuntimeFailure, ExactPipelineReducerResult[S]]): EitherT[F, ApplicationSafetyRuntimeFailure, ExactOrderedAtomicResult[S]]
Attributes
def finalizeConsumer(pipelineId: TxPipelineId): EitherT[F, ApplicationSafetyRuntimeFailure, ExactTxPipelineRecord]
Attributes
def materialize(pipelineId: TxPipelineId): EitherT[F, ApplicationSafetyRuntimeFailure, ExactTxPipelineRecord]
Attributes
def orderedAtomicPlan(pipelineId: TxPipelineId): EitherT[F, ApplicationSafetyRuntimeFailure, ExecutionPlan]
Attributes
def recordCertifiedAncestorConsumer(pipelineId: TxPipelineId, application: ExactCertifiedApplication, branchContext: HotStuffProposalInputBranchContext): EitherT[F, ApplicationSafetyRuntimeFailure, AppliedExecutionRecord]
Attributes
def recordCertifiedAncestorProducer(pipelineId: TxPipelineId, application: ExactCertifiedApplication): EitherT[F, ApplicationSafetyRuntimeFailure, AppliedExecutionRecord]
Attributes
def register(pipelineId: TxPipelineId): EitherT[F, ApplicationSafetyRuntimeFailure, ExactTxPipelineRecord]
Attributes
def validateCertifiedAncestorConsumerVote(pipelineId: TxPipelineId, subject: CertifiedEffectVoteSubject, candidateHeight: InclusionHeight, branchContext: HotStuffProposalInputBranchContext): EitherT[F, ApplicationSafetyRuntimeFailure, Unit]
Attributes
In this article