root
API
Generated with
root/org.sigilaris/org.sigilaris.node/org.sigilaris.node.jvm/org.sigilaris.node.jvm.runtime/org.sigilaris.node.jvm.runtime.consensus.hotstuff/InMemoryHotStuffArtifactSink

InMemoryHotStuffArtifactSink

org.sigilaris.node.jvm.runtime.consensus.hotstuff.InMemoryHotStuffArtifactSink
See theInMemoryHotStuffArtifactSink companion class
object InMemoryHotStuffArtifactSink

Companion for InMemoryHotStuffArtifactSink.

Attributes

Companion
class
Source
InMemoryHotStuffGossipBridge.scala
Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def create[F[_]](validatorSet: ValidatorSet, relayPolicy: HotStuffRelayPolicy, relayPublisher: HotStuffArtifactPublisher[F], sinkRetention: HotStuffArtifactSinkRetention)(using evidence$1: Sync[F], clock: GossipClock[F]): F[InMemoryHotStuffArtifactSink[F]]
def createWithProposalValidation[F[_], TxRef, ResultRef, Event](validatorSet: ValidatorSet, relayPolicy: HotStuffRelayPolicy, relayPublisher: HotStuffArtifactPublisher[F], blockQuery: BlockQuery[F, TxRef, ResultRef, Event], sinkRetention: HotStuffArtifactSinkRetention)(classifyTx: TxRef => SchedulingClassification)(using evidence$1: Sync[F], evidence$2: ByteEncoder[TxRef], evidence$3: Hash[TxRef], evidence$4: ByteEncoder[ResultRef], evidence$5: ByteEncoder[Event], clock: GossipClock[F]): F[InMemoryHotStuffArtifactSink[F]]
def createWithValidationAndFinalizationObserver[F[_]](validatorSet: ValidatorSet, relayPolicy: HotStuffRelayPolicy, relayPublisher: HotStuffArtifactPublisher[F], sinkRetention: HotStuffArtifactSinkRetention, proposalValidation: Proposal => F[Either[HotStuffValidationFailure, Unit]], finalizedApplicationObserver: Map[ChainId, FinalizationTrackerSnapshot] => F[Unit])(using evidence$1: Sync[F], clock: GossipClock[F]): F[InMemoryHotStuffArtifactSink[F]]

Active v2 integration. The observer runs after the actual consensus Ref update, including duplicate-event retries, and outside its pure closure. A FinalizedApplicationRuntime observer retains typed application failures separately, so accepted consensus finality remains available for recovery.

Active v2 integration. The observer runs after the actual consensus Ref update, including duplicate-event retries, and outside its pure closure. A FinalizedApplicationRuntime observer retains typed application failures separately, so accepted consensus finality remains available for recovery.

Attributes

Source
InMemoryHotStuffGossipBridge.scala
Generated with