Packages

o

com.digitalasset.canton.platform.indexer.parallel

ParallelIndexerSubscription

object ParallelIndexerSubscription extends Serializable

Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ParallelIndexerSubscription
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final case class ActivationRef(eventSeqId: Long, internalContractId: Long) extends Product with Serializable
  2. final case class Batch[+T](ledgerEnd: LedgerEnd, batch: T, batchSize: Int, offsetsUpdates: Vector[(Offset, Update)], activeContracts: LinkedHashMap[SynCon, ActivationRef], missingDeactivatedActivations: Map[SynCon, Option[ActivationRef]], batchTraceContext: TraceContext) extends Product with Serializable

    Batch wraps around a T-typed batch, enriching it with processing relevant information.

    Batch wraps around a T-typed batch, enriching it with processing relevant information.

    ledgerEnd

    The LedgerEnd for the batch. Needed for tail ingestion.

    batch

    The batch of variable type.

    batchSize

    Size of the batch measured in number of updates. Needed for metrics population.

    offsetsUpdates

    The Updates with Offsets, the source of the batch.

    activeContracts

    The active contracts at the head of the ledger - the ones which are not persisted yet. Key is the Synchronizer ID of activation and the Contract ID, and the value is the event_sequential_id of the activation.

    missingDeactivatedActivations

    The set of deactivations need to be looked up at dbPrepare stage. It is optional as this is where the lookup-results are stored as well.

    batchTraceContext

    The TraceContext constructed for the whole batch.

  3. implicit final class RichActivate extends AnyVal
  4. implicit final class RichDeactivate extends AnyVal
  5. final case class SynCon(synchronizerId: SynchronizerId, contractId: daml.lf.value.Value.ContractId) extends Product with Serializable

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val EmptyActiveContracts: LinkedHashMap[SynCon, ActivationRef]
  5. val ZeroLedgerEnd: LedgerEnd
  6. def aggregateLedgerEndForRepair[DB_BATCH](aggregatedLedgerEnd: AtomicReference[Option[(LedgerEnd, Map[SynchronizerId, SynchronizerIndex])]]): (Vector[Batch[DB_BATCH]]) => Unit
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def batcher[DB_BATCH](batchF: (Vector[DbDto]) => DB_BATCH, logger: TracedLogger)(inBatch: Batch[Vector[DbDto]]): Batch[DB_BATCH]
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  10. def commitRepair[DB_BATCH](storeLedgerEnd: (LedgerEnd, Map[SynchronizerId, SynchronizerIndex]) => Future[Unit], storePostProcessingEnd: (Offset) => Future[Unit], updateInMemoryState: (LedgerEnd) => Unit, aggregatedLedgerEnd: AtomicReference[Option[(LedgerEnd, Map[SynchronizerId, SynchronizerIndex])]], logger: TracedLogger)(implicit traceContext: TraceContext): (Vector[(Offset, Update)]) => Future[Vector[(Offset, Update)]]
  11. def dbPrepare(lastActivations: (Iterable[(SynchronizerId, Long)]) => (Connection) => Map[(SynchronizerId, Long), Long], dbDispatcher: DbDispatcher, resolveInternalContractIds: (TraceContext) => (Iterable[daml.lf.value.Value.ContractId]) => Future[Map[daml.lf.value.Value.ContractId, Long]], metrics: LedgerApiServerMetrics, logger: TracedLogger): (Batch[Vector[DbDto]]) => Future[Batch[Vector[DbDto]]]
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. def ingestPostProcessEnd[DB_BATCH](storePostProcessingEnd: (Offset) => Future[Unit], logger: TracedLogger)(implicit traceContext: TraceContext): (Vector[Batch[DB_BATCH]]) => Future[Vector[Batch[DB_BATCH]]]
  17. def ingestTail[DB_BATCH](storeLedgerEnd: (LedgerEnd, Map[SynchronizerId, SynchronizerIndex]) => Future[Unit], logger: TracedLogger)(implicit traceContext: TraceContext): (Vector[Batch[DB_BATCH]]) => Future[Vector[Batch[DB_BATCH]]]
  18. def ingester[DB_BATCH](ingestFunction: (Connection, DB_BATCH) => Unit, reassignmentOffsetPersistence: ReassignmentOffsetPersistence, zeroDbBatch: DB_BATCH, dbDispatcher: DbDispatcher, metrics: LedgerApiServerMetrics, logger: TracedLogger): (Batch[DB_BATCH]) => Future[Batch[DB_BATCH]]
  19. def inputMapper(metrics: LedgerApiServerMetrics, toDbDto: (Offset) => (Update) => Iterator[DbDto], eventMetricsUpdater: (Iterable[(Offset, Update)]) => Unit, logger: TracedLogger): (Iterable[(Offset, Update)]) => Batch[Vector[DbDto]]
  20. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  21. def ledgerEndSynchronizerIndexFrom(synchronizerIndexes: Vector[(SynchronizerId, SynchronizerIndex)]): Map[SynchronizerId, SynchronizerIndex]
  22. def monotonicityValidator(initialOffset: Option[Offset], loadPreviousState: (SynchronizerId) => Future[Option[SynchronizerIndex]])(implicit logger: TracedLogger): Flow[(Offset, Update), (Offset, Update), NotUsed]
  23. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  25. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  26. def postProcess[DB_BATCH](processor: (Vector[PostPublishData], TraceContext) => Future[Unit], logger: TracedLogger): (Batch[DB_BATCH]) => Future[Batch[DB_BATCH]]
  27. def refillMissingDeactivatedActivations(logger: TracedLogger)(batch: Batch[Vector[DbDto]]): Batch[Vector[DbDto]]
  28. def seqMapper(internize: (Iterable[DbDto]) => Iterable[(Int, String)], metrics: LedgerApiServerMetrics, clock: Clock, logger: TracedLogger, ledgerEndCache: LedgerEndCache)(previous: Batch[Vector[DbDto]], current: Batch[Vector[DbDto]]): Batch[Vector[DbDto]]
  29. def seqMapperZero(initialLedgerEndO: Option[LedgerEnd]): Batch[Vector[DbDto]]
  30. def sequentialPostProcess[DB_BATCH](sequentialPostProcessor: (Update) => Unit): (Batch[DB_BATCH]) => Batch[DB_BATCH]
  31. def storePostProcessingEnd(storePostProcessEndFunction: (Offset) => (Connection) => Unit, dbDispatcher: DbDispatcher, metrics: LedgerApiServerMetrics, logger: TracedLogger)(implicit traceContext: TraceContext): (Offset) => Future[Unit]
  32. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  33. def toString(): String
    Definition Classes
    AnyRef → Any
  34. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  35. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  36. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped