trait Environment extends NamedLogging with AutoCloseable with NoTracing

Holds all significant resources held by this process.

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Environment
  2. NoTracing
  3. AutoCloseable
  4. NamedLogging
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. abstract type Config <: CantonConfig
  2. abstract type Console <: ConsoleEnvironment

Abstract Value Members

  1. abstract def _createConsole(consoleOutput: ConsoleOutput = StandardConsoleOutput, createAdminCommandRunner: (ConsoleEnvironment) => ConsoleGrpcAdminCommandRunner = new ConsoleGrpcAdminCommandRunner(_)): Console
    Attributes
    protected
  2. abstract val config: Config
  3. abstract def createHealthDumpGenerator(commandRunner: GrpcAdminCommandRunner): HealthDumpGenerator[_]
    Attributes
    protected
  4. abstract def domainFactory: Factory[Config.DomainConfigType]
    Attributes
    protected
  5. abstract def isEnterprise: Boolean
  6. abstract val loggerFactory: NamedLoggerFactory
    Definition Classes
    EnvironmentNamedLogging
  7. abstract def migrationsFactory: DbMigrationsFactory
    Attributes
    protected
  8. abstract def participantNodeFactory: Factory[Config.ParticipantConfigType, ParticipantNodeBootstrap]
    Attributes
    protected
  9. abstract def participantNodeFactoryX: Factory[Config.ParticipantConfigType, ParticipantNodeBootstrapX]
    Attributes
    protected
  10. abstract val testingConfig: TestingConfigInternal

Concrete Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. implicit val actorSystem: ActorSystem
  5. def addUserCloseable(closeable: AutoCloseable): Unit
  6. def allNodes: List[Nodes[CantonNode, CantonNodeBootstrap[CantonNode]]]
    Attributes
    protected
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. val clock: Clock
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  10. def close(): Unit
    Definition Classes
    Environment → AutoCloseable
  11. lazy val configuredOpenTelemetry: ConfiguredOpenTelemetry
  12. def createClock(nodeTypeAndName: Option[(String, String)]): Clock
    Attributes
    protected
  13. def createConsole(consoleOutput: ConsoleOutput = StandardConsoleOutput, createAdminCommandRunner: (ConsoleEnvironment) => ConsoleGrpcAdminCommandRunner = new ConsoleGrpcAdminCommandRunner(_)): Console
  14. def createDomain(name: String, domainConfig: Config.DomainConfigType): DomainNodeBootstrap
    Attributes
    protected
    Annotations
    @VisibleForTesting()
  15. def createParticipant(name: String, participantConfig: Config.ParticipantConfigType): ParticipantNodeBootstrap
    Attributes
    protected
    Annotations
    @VisibleForTesting()
  16. def createParticipantX(name: String, participantConfig: Config.ParticipantConfigType): ParticipantNodeBootstrapX
    Attributes
    protected
  17. lazy val domains: DomainNodes[Config.DomainConfigType]
  18. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  19. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  20. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  21. implicit val executionContext: ExecutionContextIdlenessExecutorService
  22. implicit val executionSequencerFactory: ExecutionSequencerFactory
  23. val futureSupervisor: FutureSupervisor
    Attributes
    protected
  24. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  25. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  26. lazy val healthCheck: Option[HealthCheck]
    Attributes
    protected
  27. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  28. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  29. lazy val metricsFactory: MetricsFactory
  30. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  31. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  32. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  33. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  34. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  35. def now: CantonTimestamp

    Return current time of environment

  36. lazy val participants: ParticipantNodes[ParticipantNodeBootstrap, ParticipantNode, Config.ParticipantConfigType]
  37. lazy val participantsX: ParticipantNodes[ParticipantNodeBootstrapX, ParticipantNodeX, Config.ParticipantConfigType]
  38. implicit val scheduler: ScheduledExecutorService
  39. val simClock: Option[DelegatingSimClock]

    Sim-clock if environment is using static time

  40. def startAll()(implicit traceContext: TraceContext): Either[StartupError, Unit]

    Start all instances described in the configuration

  41. 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.

  42. def startNodes(nodes: Seq[(String, Nodes[CantonNode, CantonNodeBootstrap[CantonNode]])])(implicit traceContext: TraceContext): Either[StartupError, Unit]
  43. def stopAll()(implicit traceContext: TraceContext): Either[ShutdownError, Unit]
  44. def stopNodes(nodes: Seq[(String, Nodes[CantonNode, CantonNodeBootstrap[CantonNode]])])(implicit traceContext: TraceContext): Either[ShutdownError, Unit]
  45. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  46. def timeouts: ProcessingTimeout
    Attributes
    protected
  47. def toString(): String
    Definition Classes
    AnyRef → Any
  48. implicit def traceContext: TraceContext
    Attributes
    protected
    Definition Classes
    NoTracing
  49. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  50. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  51. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  52. val writeHealthDumpToFile: HealthDumpFunction

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from NoTracing

Inherited from AutoCloseable

Inherited from NamedLogging

Inherited from AnyRef

Inherited from Any

Ungrouped