Type Members

1.  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)

2.  final case class IndexerConfig(batchingParallelism: NonNegativeInt = NonNegativeInt.tryCreate(DefaultBatchingParallelism), enableCompression: Boolean = DefaultEnableCompression, enableCompressionConsumingExercise: Boolean = DefaultEnableCompression, enableCompressionNonConsumingExercise: Boolean = DefaultEnableCompression, ingestionParallelism: NonNegativeInt = NonNegativeInt.tryCreate(DefaultIngestionParallelism), inputMappingParallelism: NonNegativeInt = NonNegativeInt.tryCreate(DefaultInputMappingParallelism), dbPrepareParallelism: NonNegativeInt = NonNegativeInt.tryCreate(DefaultDbPrepareParallelism), 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.

   See com.digitalasset.canton.platform.indexer.JdbcIndexer for semantics on these configurations.

   • enableCompression: switches on compression for both consuming and non-consuming exercises, equivalent to setting both enableCompressionConsumingExercise and enableCompressionNonConsumingExercise to true. This is to maintain backward compatibility with existing config files.
   • enableCompressionConsumingExercise: switches on compression for consuming exercises
   • enableCompressionNonConsumingExercise: switches on compression for non-consuming exercises
3.  class IndexerState extends NamedLogging

   Annotations

   @SuppressWarnings()

4.  class RepairQueueProxy extends FutureQueue[RepairUpdate] with NamedLogging