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 Batch[+T](lastOffset: Offset, lastSeqEventId: Long, lastStringInterningId: Int, lastRecordTime: Long, lastTraceContext: TraceContext, batch: T, batchSize: Int, offsetsUpdates: Vector[(Offset, Traced[Update])]) 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.

    lastOffset

    The latest offset available in the batch. Needed for tail ingestion.

    lastSeqEventId

    The latest sequential-event-id in the batch, or if none present there, then the latest from before. Needed for tail ingestion.

    lastStringInterningId

    The latest string interning id in the batch, or if none present there, then the latest from before. Needed for tail ingestion.

    lastRecordTime

    The latest record time in the batch, in milliseconds since Epoch. Needed for metrics population.

    lastTraceContext

    The latest trace context contained in the batch. Needed for logging.

    batch

    The batch of variable type.

    batchSize

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

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def batcher[DB_BATCH](batchF: (Vector[DbDto]) => DB_BATCH): (Batch[Vector[DbDto]]) => Batch[DB_BATCH]
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. def ingestTail[DB_BATCH](ingestTailFunction: (LedgerEnd) => (Connection) => Unit, dbDispatcher: DbDispatcher, metrics: Metrics, logger: TracedLogger)(implicit traceContext: TraceContext): (Vector[Batch[DB_BATCH]]) => Future[Vector[Batch[DB_BATCH]]]
  12. def ingester[DB_BATCH](ingestFunction: (Connection, DB_BATCH) => Unit, zeroDbBatch: DB_BATCH, dbDispatcher: DbDispatcher, metrics: Metrics)(implicit traceContext: TraceContext): (Batch[DB_BATCH]) => Future[Batch[DB_BATCH]]
  13. def inputMapper(metrics: Metrics, toDbDto: (Offset) => (Traced[Update]) => Iterator[DbDto], toMeteringDbDto: (Iterable[(Offset, Traced[Update])]) => Vector[TransactionMetering], logger: TracedLogger): (Iterable[(Offset, Traced[Update])]) => Batch[Vector[DbDto]]
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. def ledgerEndFrom(batch: Batch[_]): LedgerEnd
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  19. def seqMapper(internize: (Iterable[DbDto]) => Iterable[(Int, String)], metrics: Metrics)(previous: Batch[Vector[DbDto]], current: Batch[Vector[DbDto]]): Batch[Vector[DbDto]]
  20. def seqMapperZero(initialSeqId: Long, initialStringInterningId: Int): Batch[Vector[DbDto]]
    Annotations
    @SuppressWarnings()
  21. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  22. def toString(): String
    Definition Classes
    AnyRef → Any
  23. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  24. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  25. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

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

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped