TxGossipRuntime

org.sigilaris.node.gossip.tx.TxGossipRuntime
See theTxGossipRuntime companion class

Attributes

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

Members list

Value members

Concrete methods

def configured[F[_] : Sync, A](peerAuthenticator: PeerAuthenticator[F], clock: GossipClock[F], source: GossipArtifactSource[F, A], sink: GossipArtifactSink[F, A], topicContracts: GossipTopicContractRegistry[A], stateStore: TxGossipStateStore[F], policy: TxRuntimePolicy, cascadeStrategy: TxCascadeStrategy[A], sidecarPlanner: Option[GossipSidecarPlanner[F, A]], wakeupBus: Option[TxGossipWakeupBus[F]]): TxGossipRuntime[F, A]

Creates a fully configured runtime with custom policy and cascade strategy.

Creates a fully configured runtime with custom policy and cascade strategy.

Type parameters

A

the artifact payload type

F

the effect type

Attributes

Source
TxGossipRuntime.scala
def default[F[_] : Sync, A](peerAuthenticator: PeerAuthenticator[F], clock: GossipClock[F], source: GossipArtifactSource[F, A], sink: GossipArtifactSink[F, A], topicContracts: GossipTopicContractRegistry[A], stateStore: TxGossipStateStore[F], wakeupBus: Option[TxGossipWakeupBus[F]]): TxGossipRuntime[F, A]

Creates a runtime with the default policy and cascade strategy.

Creates a runtime with the default policy and cascade strategy.

Type parameters

A

the artifact payload type

F

the effect type

Attributes

Source
TxGossipRuntime.scala
def withPolicy[F[_] : Sync, A](peerAuthenticator: PeerAuthenticator[F], clock: GossipClock[F], source: GossipArtifactSource[F, A], sink: GossipArtifactSink[F, A], topicContracts: GossipTopicContractRegistry[A], stateStore: TxGossipStateStore[F], policy: TxRuntimePolicy, wakeupBus: Option[TxGossipWakeupBus[F]]): TxGossipRuntime[F, A]

Creates a runtime with a custom policy and the default cascade strategy.

Creates a runtime with a custom policy and the default cascade strategy.

Type parameters

A

the artifact payload type

F

the effect type

Attributes

Source
TxGossipRuntime.scala