package indexer
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- indexer
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Type Members
- type Indexer = (Boolean) => (Commit) => Future[FutureQueueConsumer[Update]]
Indexer is a factory for indexing.
Indexer is a factory for indexing. Future[Unit] is the completion Future, as it completes indexing is completed with results accordingly (Success/Failure)
- final case class IndexerConfig(batchingParallelism: NonNegativeInt = NonNegativeInt.tryCreate(DefaultBatchingParallelism), enableCompression: Boolean = DefaultEnableCompression, ingestionParallelism: NonNegativeInt = NonNegativeInt.tryCreate(DefaultIngestionParallelism), inputMappingParallelism: NonNegativeInt = NonNegativeInt.tryCreate(DefaultInputMappingParallelism), maxInputBufferSize: NonNegativeInt = NonNegativeInt.tryCreate(DefaultMaxInputBufferSize), restartDelay: NonNegativeFiniteDuration = NonNegativeFiniteDuration.ofSeconds(DefaultRestartDelay.toSeconds), submissionBatchSize: Long = DefaultSubmissionBatchSize, maxOutputBatchedBufferSize: Int = DefaultMaxOutputBatchedBufferSize, maxTailerBatchSize: Int = DefaultMaxTailerBatchSize, postProcessingParallelism: Int = DefaultPostProcessingParallelism, queueMaxBlockedOffer: Int = DefaultQueueMaxBlockedOffer, queueBufferSize: Int = DefaultQueueBufferSize, queueUncommittedWarnThreshold: Int = DefaultQueueUncommittedWarnThreshold, queueRecoveryRetryMinWaitMillis: Int = DefaultQueueRecoveryRetryMinWaitMillis, queueRecoveryRetryMaxWaitMillis: Int = DefaultQueueRecoveryRetryMaxWaitMillis, queueRecoveryRetryAttemptWarnThreshold: Int = DefaultQueueRecoveryRetryAttemptWarnThreshold, queueRecoveryRetryAttemptErrorThreshold: Int = DefaultQueueRecoveryRetryAttemptErrorThreshold, disableMonotonicityChecks: Boolean = false) extends Product with Serializable
See com.digitalasset.canton.platform.indexer.JdbcIndexer for semantics on these configurations.
- class IndexerState extends NamedLogging
- Annotations
- @SuppressWarnings()
- class RepairQueueProxy extends FutureQueue[RepairUpdate] with NamedLogging
Value Members
- object IndexerConfig extends Serializable
- object IndexerQueueProxy
- object IndexerState
- object JdbcIndexer
- object TransactionTraversalUtils