abstract class CantonNodeBootstrapBase[T <: CantonNode, NodeConfig <: LocalNodeConfig, ParameterConfig <: LocalNodeParameters] extends CantonNodeBootstrap[T] with NoTracing
Bootstrapping class used to drive the initialization of a canton node (domain and participant)
(wait for unique id) -> receive initId -> notify actual implementation via idInitialized
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- CantonNodeBootstrapBase
- NoTracing
- CantonNodeBootstrap
- NamedLogging
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new CantonNodeBootstrapBase(name: LengthLimitedString, config: NodeConfig, parameterConfig: ParameterConfig, clock: Clock, nodeMetrics: NodeMetrics, storageFactory: StorageFactory, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContextIdlenessExecutorService, actorSystem: ActorSystem)
Abstract Value Members
- abstract def autoInitializeIdentity(): EitherT[Future, String, Unit]
Generate an identity for the node.
Generate an identity for the node.
- Attributes
- protected
- abstract def initialize(uid: NodeId): EitherT[Future, String, Unit]
Attempt to start the node with this identity.
Attempt to start the node with this identity.
- Attributes
- protected
- abstract def isActive: Boolean
- Attributes
- protected
Concrete 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
- implicit val actorSystem: ActorSystem
- val adminApiConfig: AdminServerConfig
- Attributes
- protected
- val adminServer: CloseableServer
- Attributes
- protected
- val adminServerRegistry: CantonMutableHandlerRegistry
- Attributes
- protected
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def authorizeDomainGovernance[E <: CantonError](manager: TopologyManager[E], key: PublicKey, mapping: DomainGovernanceMapping)(implicit traceContext: TraceContext): EitherT[Future, String, SignedTopologyTransaction[Replace]]
- Attributes
- protected
- def authorizeStateUpdate[E <: CantonError](manager: TopologyManager[E], key: PublicKey, mapping: TopologyStateUpdateMapping)(implicit traceContext: TraceContext): EitherT[Future, String, SignedTopologyTransaction[Add]]
- Attributes
- protected
- val certificateGenerator: X509CertificateGenerator
- val clock: Clock
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def close(): Unit
- Definition Classes
- CantonNodeBootstrapBase → AutoCloseable
- def connectionPoolForParticipant: Boolean
- Attributes
- protected
- val crypto: Crypto
Access to the private and public store to support local key inspection commands
Access to the private and public store to support local key inspection commands
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- val cryptoConfig: CryptoConfig
- Attributes
- protected
- val dbStorageMetrics: DbStorageMetrics
- Attributes
- protected
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit val executionContext: ExecutionContextIdlenessExecutorService
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getId: Option[NodeId]
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- def getNode: Option[T]
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val indexedStringStore: IndexedStringStore
- Attributes
- protected
- val initConfig: InitConfigBase
- Attributes
- protected
- val initializationStore: InitializationStore
- Attributes
- protected
- def initializeWithProvidedId(nodeId: NodeId): EitherT[Future, String, Unit]
Initialize the node with an externally provided identity.
Initialize the node with an externally provided identity.
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- def isInitialized: Boolean
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isRunning: Boolean
- Attributes
- protected
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- CantonNodeBootstrapBase → NamedLogging
- implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- val name: LengthLimitedString
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def setInstance(instance: T): Unit
- Attributes
- protected
- def start(): EitherT[Future, String, Unit]
Attempt to start the node.
Attempt to start the node. If a previously initialized identifier is available the node will be immediately initialized. If there is no existing identity and autoinit is enabled an identity will be automatically generated and then the node will initialize. If there is no existing identity and autoinit is disabled start will immediately exit to wait for an identity to be externally provided through initializeWithProvidedId.
- Definition Classes
- CantonNodeBootstrapBase → CantonNodeBootstrap
- def startWithStoredId(id: NodeId): EitherT[Future, String, Unit]
- Attributes
- protected
- val storage: Storage
- Attributes
- protected
- final def storeId(id: NodeId): EitherT[Future, String, Unit]
- val supportsReplicaInitialization: Boolean
Can this node be initialized by a replica
Can this node be initialized by a replica
- Attributes
- protected
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- val topologyStoreFactory: TopologyStoreFactory
- Attributes
- protected
- implicit def traceContext: TraceContext
- Attributes
- protected
- Definition Classes
- NoTracing
- implicit val tracer: Tracer
- val tracerProvider: TracerProvider
- Attributes
- protected
- 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])