Packages

package indexer

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. indexer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Package Members

  1. package ha
  2. package parallel

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, 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.

  3. class IndexerState extends NamedLogging
    Annotations
    @SuppressWarnings()
  4. class RepairQueueProxy extends FutureQueue[RepairUpdate] with NamedLogging

Inherited from AnyRef

Inherited from Any

Ungrouped