final case class IndexServiceConfig(bufferedEventsProcessingParallelism: Int = IndexServiceConfig.DefaultBufferedEventsProcessingParallelism, bufferedStreamsPageSize: Int = IndexServiceConfig.DefaultBufferedStreamsPageSize, maxContractStateCacheSize: Long = IndexServiceConfig.DefaultMaxContractStateCacheSize, maxContractKeyStateCacheSize: Long = IndexServiceConfig.DefaultMaxContractKeyStateCacheSize, maxTransactionsInMemoryFanOutBufferSize: Int = IndexServiceConfig.DefaultMaxTransactionsInMemoryFanOutBufferSize, apiStreamShutdownTimeout: Duration = IndexServiceConfig.DefaultApiStreamShutdownTimeout, inMemoryStateUpdaterParallelism: Int = IndexServiceConfig.DefaultInMemoryStateUpdaterParallelism, apiQueryServicesThreadPoolSize: Option[Int] = None, preparePackageMetadataTimeOutWarning: NonNegativeFiniteDuration = IndexServiceConfig.PreparePackageMetadataTimeOutWarning, completionsPageSize: Int = IndexServiceConfig.DefaultCompletionsPageSize, activeContractsServiceStreams: ActiveContractsServiceStreamsConfig = ActiveContractsServiceStreamsConfig.default, updatesStreams: UpdatesStreamsConfig = UpdatesStreamsConfig.default, transactionTreeStreams: TransactionTreeStreamsConfig = TransactionTreeStreamsConfig.default, globalMaxEventIdQueries: Int = 20, globalMaxEventPayloadQueries: Int = 10, offsetCheckpointCacheUpdateInterval: NonNegativeFiniteDuration = IndexServiceConfig.OffsetCheckpointCacheUpdateInterval, idleStreamOffsetCheckpointTimeout: NonNegativeFiniteDuration = IndexServiceConfig.IdleStreamOffsetCheckpointTimeout) extends Product with Serializable
Ledger api index service specific configurations
- bufferedEventsProcessingParallelism
parallelism for loading and decoding ledger events for populating ledger api server's internal buffers
- bufferedStreamsPageSize
the page size for streams created from ledger api server's in-memory buffers
- maxContractStateCacheSize
maximum caffeine cache size of mutable state cache of contracts
- maxContractKeyStateCacheSize
maximum caffeine cache size of mutable state cache of contract keys
- maxTransactionsInMemoryFanOutBufferSize
maximum number of transactions to hold in the "in-memory fanout" (if enabled)
- apiStreamShutdownTimeout
shutdown timeout for a graceful completion of ledger api server's streams
- inMemoryStateUpdaterParallelism
the processing parallelism of the Ledger API server in-memory state updater
- apiQueryServicesThreadPoolSize
size of the thread-pool backing the Ledger API query-services (fe not the command submission/interpretation). If not set, defaults to ((number of thread)/4 + 1)
- preparePackageMetadataTimeOutWarning
timeout for package metadata preparation after which a warning will be logged
- completionsPageSize
database / pekko page size for batching of ledger api server index ledger completion queries
- activeContractsServiceStreams
configurations pertaining to the ledger api server's "active contracts service"
- updatesStreams
configurations pertaining to the ledger api server's streams of updates
- transactionTreeStreams
configurations pertaining to the ledger api server's streams of transaction trees
- globalMaxEventIdQueries
maximum number of concurrent event id queries across all stream types
- globalMaxEventPayloadQueries
maximum number of concurrent event payload queries across all stream types
- offsetCheckpointCacheUpdateInterval
the interval duration for OffsetCheckpoint cache updates
- idleStreamOffsetCheckpointTimeout
the timeout duration for checking if a new OffsetCheckpoint is created
- Alphabetic
- By Inheritance
- IndexServiceConfig
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new IndexServiceConfig(bufferedEventsProcessingParallelism: Int = IndexServiceConfig.DefaultBufferedEventsProcessingParallelism, bufferedStreamsPageSize: Int = IndexServiceConfig.DefaultBufferedStreamsPageSize, maxContractStateCacheSize: Long = IndexServiceConfig.DefaultMaxContractStateCacheSize, maxContractKeyStateCacheSize: Long = IndexServiceConfig.DefaultMaxContractKeyStateCacheSize, maxTransactionsInMemoryFanOutBufferSize: Int = IndexServiceConfig.DefaultMaxTransactionsInMemoryFanOutBufferSize, apiStreamShutdownTimeout: Duration = IndexServiceConfig.DefaultApiStreamShutdownTimeout, inMemoryStateUpdaterParallelism: Int = IndexServiceConfig.DefaultInMemoryStateUpdaterParallelism, apiQueryServicesThreadPoolSize: Option[Int] = None, preparePackageMetadataTimeOutWarning: NonNegativeFiniteDuration = IndexServiceConfig.PreparePackageMetadataTimeOutWarning, completionsPageSize: Int = IndexServiceConfig.DefaultCompletionsPageSize, activeContractsServiceStreams: ActiveContractsServiceStreamsConfig = ActiveContractsServiceStreamsConfig.default, updatesStreams: UpdatesStreamsConfig = UpdatesStreamsConfig.default, transactionTreeStreams: TransactionTreeStreamsConfig = TransactionTreeStreamsConfig.default, globalMaxEventIdQueries: Int = 20, globalMaxEventPayloadQueries: Int = 10, offsetCheckpointCacheUpdateInterval: NonNegativeFiniteDuration = IndexServiceConfig.OffsetCheckpointCacheUpdateInterval, idleStreamOffsetCheckpointTimeout: NonNegativeFiniteDuration = IndexServiceConfig.IdleStreamOffsetCheckpointTimeout)
- bufferedEventsProcessingParallelism
parallelism for loading and decoding ledger events for populating ledger api server's internal buffers
- bufferedStreamsPageSize
the page size for streams created from ledger api server's in-memory buffers
- maxContractStateCacheSize
maximum caffeine cache size of mutable state cache of contracts
- maxContractKeyStateCacheSize
maximum caffeine cache size of mutable state cache of contract keys
- maxTransactionsInMemoryFanOutBufferSize
maximum number of transactions to hold in the "in-memory fanout" (if enabled)
- apiStreamShutdownTimeout
shutdown timeout for a graceful completion of ledger api server's streams
- inMemoryStateUpdaterParallelism
the processing parallelism of the Ledger API server in-memory state updater
- apiQueryServicesThreadPoolSize
size of the thread-pool backing the Ledger API query-services (fe not the command submission/interpretation). If not set, defaults to ((number of thread)/4 + 1)
- preparePackageMetadataTimeOutWarning
timeout for package metadata preparation after which a warning will be logged
- completionsPageSize
database / pekko page size for batching of ledger api server index ledger completion queries
- activeContractsServiceStreams
configurations pertaining to the ledger api server's "active contracts service"
- updatesStreams
configurations pertaining to the ledger api server's streams of updates
- transactionTreeStreams
configurations pertaining to the ledger api server's streams of transaction trees
- globalMaxEventIdQueries
maximum number of concurrent event id queries across all stream types
- globalMaxEventPayloadQueries
maximum number of concurrent event payload queries across all stream types
- offsetCheckpointCacheUpdateInterval
the interval duration for OffsetCheckpoint cache updates
- idleStreamOffsetCheckpointTimeout
the timeout duration for checking if a new OffsetCheckpoint is created
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
- val activeContractsServiceStreams: ActiveContractsServiceStreamsConfig
- val apiQueryServicesThreadPoolSize: Option[Int]
- val apiStreamShutdownTimeout: Duration
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val bufferedEventsProcessingParallelism: Int
- val bufferedStreamsPageSize: Int
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- val completionsPageSize: Int
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- val globalMaxEventIdQueries: Int
- val globalMaxEventPayloadQueries: Int
- val idleStreamOffsetCheckpointTimeout: NonNegativeFiniteDuration
- val inMemoryStateUpdaterParallelism: Int
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxContractKeyStateCacheSize: Long
- val maxContractStateCacheSize: Long
- val maxTransactionsInMemoryFanOutBufferSize: Int
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- val offsetCheckpointCacheUpdateInterval: NonNegativeFiniteDuration
- val preparePackageMetadataTimeOutWarning: NonNegativeFiniteDuration
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val transactionTreeStreams: TransactionTreeStreamsConfig
- val updatesStreams: UpdatesStreamsConfig
- 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])