TxGossipRuntimeBootstrap
org.sigilaris.node.jvm.runtime.gossip.tx.TxGossipRuntimeBootstrap
object TxGossipRuntimeBootstrap
Attributes
- Source
- TxGossipRuntimeBootstrap.scala
- Graph
-
- Supertypes
-
class Objecttrait Matchableclass Any
- Self type
Members list
Value members
Concrete methods
def fromConfig[F[_] : Sync, A](config: Config, clock: GossipClock[F], source: GossipArtifactSource[F, A], sink: GossipArtifactSink[F, A], topicContracts: GossipTopicContractRegistry[A], runtimePolicy: TxRuntimePolicy, handshakePolicy: HandshakePolicy, configPath: String, sidecarPlanner: Option[GossipSidecarPlanner[F, A]], wakeupBus: Option[TxGossipWakeupBus[F]]): F[Either[String, TxGossipBootstrap[F, A]]]
Bootstraps a transaction gossip runtime from Typesafe Config.
Bootstraps a transaction gossip runtime from Typesafe Config.
Type parameters
- A
-
the artifact payload type
- F
-
the effect type
Value parameters
- clock
-
the gossip clock
- config
-
the root config
- configPath
-
the config path to read topology from
- handshakePolicy
-
the handshake policy
- runtimePolicy
-
the runtime policy
- sink
-
the artifact sink
- source
-
the artifact source
- topicContracts
-
the topic contract registry
Attributes
- Returns
-
the bootstrap bundle, or an error
- Source
- TxGossipRuntimeBootstrap.scala
def fromTopology[F[_] : Sync, A](topology: StaticPeerTopology, transportAuth: StaticPeerTransportAuth, clock: GossipClock[F], source: GossipArtifactSource[F, A], sink: GossipArtifactSink[F, A], topicContracts: GossipTopicContractRegistry[A], runtimePolicy: TxRuntimePolicy, handshakePolicy: HandshakePolicy, sidecarPlanner: Option[GossipSidecarPlanner[F, A]], wakeupBus: Option[TxGossipWakeupBus[F]]): F[TxGossipBootstrap[F, A]]
Bootstraps a transaction gossip runtime from a pre-parsed topology.
Bootstraps a transaction gossip runtime from a pre-parsed topology.
Type parameters
- A
-
the artifact payload type
- F
-
the effect type
Value parameters
- clock
-
the gossip clock
- handshakePolicy
-
the handshake policy
- runtimePolicy
-
the runtime policy
- sink
-
the artifact sink
- source
-
the artifact source
- topicContracts
-
the topic contract registry
- topology
-
the static peer topology
- transportAuth
-
the transport authentication configuration
Attributes
- Returns
-
the bootstrap bundle
- Source
- TxGossipRuntimeBootstrap.scala
In this article