object CantonLedgerApiServerWrapper extends NoTracing
Wrapper of ledger API server to manage start, stop, and erasing of state.
- Alphabetic
- By Inheritance
- CantonLedgerApiServerWrapper
- NoTracing
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class Config(serverConfig: LedgerApiServerConfig, jsonApiConfig: Option[JsonApiConfig], indexerConfig: IndexerConfig, indexerHaConfig: HaConfig, ledgerId: LedgerId, participantId: LedgerParticipantId, engine: Engine, syncService: CantonSyncService, storageConfig: StorageConfig, cantonParameterConfig: ParticipantNodeParameters, testingTimeService: Option[TimeServiceBackend], adminToken: CantonAdminToken, enableCommandInspection: Boolean, loggerFactory: NamedLoggerFactory, tracerProvider: TracerProvider, metrics: Metrics, jsonApiMetrics: HttpApiMetrics, meteringReportKey: MeteringReportKey) extends NamedLogging with Product with Serializable
Config for ledger API server and indexer
Config for ledger API server and indexer
- serverConfig
ledger API server configuration
- jsonApiConfig
JSON API configuration
- indexerConfig
indexer configuration
- indexerHaConfig
configuration for indexer HA
- ledgerId
unique ledger id used by the ledger API server
- participantId
unique participant id used e.g. for a unique ledger API server index db name
- engine
daml engine shared with Canton for performance reasons
- syncService
canton sync service implementing both read and write services
- storageConfig
canton storage config so that indexer can share the participant db
- cantonParameterConfig
configurations meant to be overridden primarily in tests (applying to all participants)
- testingTimeService
an optional service during testing for advancing time, participant-specific
- adminToken
canton admin token for ledger api auth
- enableCommandInspection
whether canton should support inspection service or not
- loggerFactory
canton logger factory
- tracerProvider
tracer provider for open telemetry grpc injection
- metrics
upstream metrics module
- final case class FailedToConfigureLedgerApiStorage(errorMessage: String) extends LedgerApiServerErrorWithoutCause with Product with Serializable
- final case class FailedToStartLedgerApiServer(cause: Throwable) extends LedgerApiServerError with Product with Serializable
- final case class FailedToStopLedgerApiServer(errorMessage: String, cause: Throwable) extends LedgerApiServerError with Product with Serializable
- final case class IndexerLockIds(mainLockId: Int, workerLockId: Int) extends Product with Serializable
- sealed trait LedgerApiServerError extends Product with Serializable with PrettyPrinting
- sealed trait LedgerApiServerErrorWithoutCause extends LedgerApiServerError
- final case class LedgerApiServerState(ledgerApiStorage: LedgerApiStorage, startableStoppableLedgerApi: StartableStoppableLedgerApiServer, logger: TracedLogger, timeouts: ProcessingTimeout) extends FlagCloseable with Product with Serializable
- final case class MigrateSchemaConfig(dbConfig: DbConfig, additionalMigrationPaths: Seq[String]) extends Product with Serializable
Config for indexer migrate schema entry point
Config for indexer migrate schema entry point
- dbConfig
canton DB storage config so that indexer can share the participant db
- additionalMigrationPaths
optional paths for extra migration files
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
- 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()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def initialize(config: Config, parameters: ParticipantNodeParameters, startLedgerApiServer: Boolean, futureSupervisor: FutureSupervisor, multiDomainEnabled: Boolean)(implicit ec: ExecutionContextIdlenessExecutorService, actorSystem: ActorSystem): EitherT[FutureUnlessShutdown, LedgerApiServerError, LedgerApiServerState]
Initialize a ledger API server asynchronously
Initialize a ledger API server asynchronously
- config
ledger API server configuration
- startLedgerApiServer
whether to start the ledger API server or not (i.e. when participant node is initialized in passive mode)
- returns
ledger API server state wrapper EitherT-future
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maximumToleranceTimeModel: LedgerTimeModel
- def migrateSchema(config: MigrateSchemaConfig, loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext): Future[Unit]
Migrates ledger API server database schema to latest flyway version
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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])