class Environment extends NamedLogging with AutoCloseable with NoTracing
Holds all significant resources held by this process.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- Environment
- NoTracing
- AutoCloseable
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new Environment(initialConfig: CantonConfig, edition: CantonEdition, testingConfig: TestingConfigInternal, participantNodeFactory: ParticipantNodeBootstrapFactory, sequencerNodeFactory: SequencerNodeBootstrapFactory, mediatorNodeFactory: MediatorNodeBootstrapFactory, migrationsFactoryFactory: DbMigrationsMetaFactory, loggerFactory: NamedLoggerFactory)
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
- def addUserCloseable(closeable: AutoCloseable): Unit
- def allNodes: List[Nodes[CantonNode, CantonNodeBootstrap[CantonNode]]]
- Attributes
- protected
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val clock: Clock
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def close(): Unit
- Definition Classes
- Environment → AutoCloseable
- def config: CantonConfig
- lazy val configuredOpenTelemetry: ConfiguredOpenTelemetry
- def createClock(nodeTypeAndName: Option[(String, String)]): Clock
- Attributes
- protected
- def createConsole(consoleOutput: ConsoleOutput = StandardConsoleOutput): ConsoleEnvironment
- def createHealthDumpGenerator(commandRunner: GrpcAdminCommandRunner): HealthDumpGenerator
- Attributes
- protected
- Annotations
- @VisibleForTesting()
- def createMediator(name: String, mediatorConfig: MediatorNodeConfig): MediatorNodeBootstrap
- Attributes
- protected
- def createParticipant(name: String, participantConfig: ParticipantNodeConfig): ParticipantNodeBootstrap
- Attributes
- protected
- def createSequencer(name: String, sequencerConfig: SequencerNodeConfig): SequencerNodeBootstrap
- Attributes
- protected
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- implicit val executionContext: ExecutionContextIdlenessExecutorService
- implicit val executionSequencerFactory: ExecutionSequencerFactory
- val futureSupervisor: FutureSupervisor
- Attributes
- protected
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def isEnterprise: Boolean
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- Environment → NamedLogging
- val mediators: MediatorNodes
- lazy val metricsRegistry: MetricsRegistry
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- 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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def now: CantonTimestamp
Return current time of environment
- lazy val participants: ParticipantNodes[ParticipantNodeBootstrap, ParticipantNode]
- def pokeOrUpdateConfig(newConfig: Option[Either[String, CantonConfig]])(implicit traceContext: TraceContext): Unit
- implicit val scheduler: ScheduledExecutorService
- val sequencers: SequencerNodes
- val simClock: Option[DelegatingSimClock]
Sim-clock if environment is using static time
- def startAll()(implicit traceContext: TraceContext): Either[StartupError, Unit]
Start all instances described in the configuration
- def startAndReconnect(runner: => Unit = ()): Either[StartupError, Unit]
Try to startup all nodes in the configured environment and reconnect them to one another.
Try to startup all nodes in the configured environment and reconnect them to one another. The first error will prevent further nodes from being started. If an error is returned previously started nodes will not be stopped.
- def startNodes(nodes: Seq[(String, Nodes[CantonNode, CantonNodeBootstrap[CantonNode]])])(implicit traceContext: TraceContext): Either[StartupError, Unit]
- def stopAll()(implicit traceContext: TraceContext): Either[ShutdownError, Unit]
- def stopNodes(nodes: Seq[(String, Nodes[CantonNode, CantonNodeBootstrap[CantonNode]])])(implicit traceContext: TraceContext): Either[ShutdownError, Unit]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val testingConfig: TestingConfigInternal
- def timeouts: ProcessingTimeout
- Attributes
- protected
- def toString(): String
- Definition Classes
- AnyRef → Any
- implicit def traceContext: TraceContext
- Attributes
- protected
- Definition Classes
- NoTracing
- lazy val tracerProvider: TracerProvider
- 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])
- val writeHealthDumpToFile: HealthDumpFunction