class StartableStoppableLedgerApiDependentServices extends AutoCloseable with NamedLogging
Holds and manages the lifecycle of all Canton services that use the Ledger API and hence depend on the Ledger API server to be up.
The services are started on participant initialization iff the participant comes up as an active replica, otherwise they are started when the participant transitions to active. On transition to passive participant state, these services are shutdown.
It is also used to close and restart the services when the Ledger API server needs to be taken down temporarily (e.g. for ledger pruning).
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- StartableStoppableLedgerApiDependentServices
- NamedLogging
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new StartableStoppableLedgerApiDependentServices(config: LocalParticipantConfig, participantNodeParameters: ParticipantNodeParameters, packageService: PackageService, syncService: CantonSyncService, participantId: ParticipantId, clock: Clock, registry: CantonMutableHandlerRegistry, adminToken: CantonAdminToken, futureSupervisor: FutureSupervisor, loggerFactory: NamedLoggerFactory, tracerProvider: TracerProvider)(implicit ec: ExecutionContextExecutor, actorSystem: ActorSystem, tracer: Tracer, scheduler: ScheduledExecutorService, executionSequencerFactory: ExecutionSequencerFactory)
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
- def adminWorkflowServices(implicit traceContext: TraceContext): AdminWorkflowServices
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def close(): Unit
- Definition Classes
- StartableStoppableLedgerApiDependentServices → AutoCloseable
- 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
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- StartableStoppableLedgerApiDependentServices → NamedLogging
- 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() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def start()(implicit traceContext: TraceContext): Unit
- 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])