trait Environment extends NamedLogging with AutoCloseable with NoTracing
Holds all significant resources held by this process.
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- Environment
- NoTracing
- AutoCloseable
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- abstract type Config <: CantonConfig
- abstract type Console <: ConsoleEnvironment
Abstract Value Members
- abstract def _createConsole(consoleOutput: ConsoleOutput = StandardConsoleOutput, createAdminCommandRunner: (ConsoleEnvironment) => ConsoleGrpcAdminCommandRunner = new ConsoleGrpcAdminCommandRunner(_)): Console
- Attributes
- protected
- abstract val config: Config
- abstract def createHealthDumpGenerator(commandRunner: GrpcAdminCommandRunner): HealthDumpGenerator[_]
- Attributes
- protected
- abstract def domainFactory: Factory[Config.DomainConfigType]
- Attributes
- protected
- abstract def isEnterprise: Boolean
- abstract val loggerFactory: NamedLoggerFactory
- Definition Classes
- Environment → NamedLogging
- abstract def migrationsFactory: DbMigrationsFactory
- Attributes
- protected
- abstract def participantNodeFactory: Factory[Config.ParticipantConfigType]
- Attributes
- protected
- abstract val testingConfig: TestingConfigInternal
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
- 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]) @native() @HotSpotIntrinsicCandidate()
- def close(): Unit
- Definition Classes
- Environment → AutoCloseable
- lazy val configuredOpenTelemetry: ConfiguredOpenTelemetry
- def createClock(nodeTypeAndName: Option[(String, String)]): Clock
- Attributes
- protected
- def createConsole(consoleOutput: ConsoleOutput = StandardConsoleOutput, createAdminCommandRunner: (ConsoleEnvironment) => ConsoleGrpcAdminCommandRunner = new ConsoleGrpcAdminCommandRunner(_)): Console
- def createDomain(name: String, domainConfig: Config.DomainConfigType): DomainNodeBootstrap
- Attributes
- protected
- Annotations
- @VisibleForTesting()
- def createParticipant(name: String, participantConfig: Config.ParticipantConfigType): ParticipantNodeBootstrap
- Attributes
- protected
- Annotations
- @VisibleForTesting()
- lazy val domains: DomainNodes[Config.DomainConfigType]
- 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
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- lazy val healthCheck: Option[HealthCheck]
- Attributes
- protected
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- lazy val metricsFactory: MetricsFactory
- 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
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def now: CantonTimestamp
Return current time of environment
- lazy val participants: ParticipantNodes[Config.ParticipantConfigType]
- implicit val scheduler: ScheduledExecutorService
- val simClock: Option[DelegatingSimClock]
Sim-clock if environment is using static time
- def startAll(): Either[Seq[StartupError], Unit]
Start all instances described in the configuration
- def startAndReconnect(autoConnectLocal: Boolean): 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.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def timeouts: ProcessingTimeout
- Attributes
- protected
- def toString(): String
- Definition Classes
- AnyRef → Any
- implicit def traceContext: TraceContext
- Attributes
- protected
- Definition Classes
- NoTracing
- 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