com.digitalasset.canton.domain.sequencing.sequencer.block.bftordering.framework
Module
Companion trait Module
object Module
- Alphabetic
- By Inheritance
- Module
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class SystemInitializationResult[P2PMessageT, InputMessageT](inputModuleRef: ModuleRef[InputMessageT], p2pNetworkInModuleRef: ModuleRef[P2PMessageT], outputModule: FlagCloseable) extends Product with Serializable
The result of initializing a module system independent of the actor framework, to be used during the actor framework-specific initialization.
The result of initializing a module system independent of the actor framework, to be used during the actor framework-specific initialization.
- inputModuleRef
A reference to the module of the initialized system that accepts client messages.
- p2pNetworkInModuleRef
A reference to the module of the initialized system that accepts P2P messages.
- outputModule
We currently need direct access to the output module in order to close it during shutdown.
- type SystemInitializer[E <: Env[E], P2PMessageT, InputMessageT] = (ModuleSystem[E], P2PNetworkManager[E, P2PMessageT]) => SystemInitializationResult[P2PMessageT, InputMessageT]
A system initializer defines how a specific modular distributed system is built independently from the concrete actors framework, such as Pekko or the simulation testing framework, as to further reduce the gap between what is run and what is deterministically simulation-tested.
A system initializer defines how a specific modular distributed system is built independently from the concrete actors framework, such as Pekko or the simulation testing framework, as to further reduce the gap between what is run and what is deterministically simulation-tested.
Inputs are a module system and a network manager; the latter defines how peers connect.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])