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, inMemoryFanOutThreadPoolSize: Option[Int] = None, preparePackageMetadataTimeOutWarning: NonNegativeFiniteDuration = IndexServiceConfig.PreparePackageMetadataTimeOutWarning, completionsPageSize: Int = IndexServiceConfig.DefaultCompletionsPageSize, activeContractsServiceStreams: ActiveContractsServiceStreamsConfig = ActiveContractsServiceStreamsConfig.default, transactionFlatStreams: TransactionFlatStreamsConfig = TransactionFlatStreamsConfig.default, transactionTreeStreams: TransactionTreeStreamsConfig = TransactionTreeStreamsConfig.default, globalMaxEventIdQueries: Int = 20, globalMaxEventPayloadQueries: Int = 10) 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
- inMemoryFanOutThreadPoolSize
size of the thread-pool backing the Ledger API in-memory fan-out. 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"
- transactionFlatStreams
configurations pertaining to the ledger api server's streams of transaction trees
- transactionTreeStreams
configurations pertaining to the ledger api server's streams of flat transactions
- globalMaxEventIdQueries
maximum number of concurrent event id queries across all stream types
- globalMaxEventPayloadQueries
maximum number of concurrent event payload queries across all stream types
- 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, inMemoryFanOutThreadPoolSize: Option[Int] = None, preparePackageMetadataTimeOutWarning: NonNegativeFiniteDuration = IndexServiceConfig.PreparePackageMetadataTimeOutWarning, completionsPageSize: Int = IndexServiceConfig.DefaultCompletionsPageSize, activeContractsServiceStreams: ActiveContractsServiceStreamsConfig = ActiveContractsServiceStreamsConfig.default, transactionFlatStreams: TransactionFlatStreamsConfig = TransactionFlatStreamsConfig.default, transactionTreeStreams: TransactionTreeStreamsConfig = TransactionTreeStreamsConfig.default, globalMaxEventIdQueries: Int = 20, globalMaxEventPayloadQueries: Int = 10)
- 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
- inMemoryFanOutThreadPoolSize
size of the thread-pool backing the Ledger API in-memory fan-out. 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"
- transactionFlatStreams
configurations pertaining to the ledger api server's streams of transaction trees
- transactionTreeStreams
configurations pertaining to the ledger api server's streams of flat transactions
- globalMaxEventIdQueries
maximum number of concurrent event id queries across all stream types
- globalMaxEventPayloadQueries
maximum number of concurrent event payload queries across all stream types
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 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]) @native() @HotSpotIntrinsicCandidate()
- val completionsPageSize: Int
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val globalMaxEventIdQueries: Int
- val globalMaxEventPayloadQueries: Int
- val inMemoryFanOutThreadPoolSize: Option[Int]
- 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
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val preparePackageMetadataTimeOutWarning: NonNegativeFiniteDuration
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val transactionFlatStreams: TransactionFlatStreamsConfig
- val transactionTreeStreams: TransactionTreeStreamsConfig
- 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])