Type Members

1.  class ACSReader extends NamedLogging

   Streams ACS events (active contracts) in a two step process consisting of:

   Streams ACS events (active contracts) in a two step process consisting of:

   1. fetching event sequential ids of the active contracts based on the filtering constraints,
   2. fetching the active contracts based on the fetched event sequential ids.

   Details: An input filtering constraint (consisting of parties and template ids) is converted into decomposed filtering constraints (a constraint with exactly one party and at most one template id). For each decomposed filter, the matching event sequential ids are fetched in parallel and then merged into a strictly increasing sequence. The elements from this sequence are then batched and the batch ids serve as the input to the payload fetching step.

2.  final case class CompressionStrategy(createArgumentCompression: FieldCompressionStrategy, createKeyValueCompression: FieldCompressionStrategy, exerciseArgumentCompression: FieldCompressionStrategy, exerciseResultCompression: FieldCompressionStrategy) extends Product with Serializable
3.  trait ContractLoader extends AnyRef

   Efficient cross-request batching contract loader

   Efficient cross-request batching contract loader

   Note that both loaders operate on an identifier -> offset basis. The given offset of a request serves as a lower bound for the states. The states can be newer, but not older. We still need to have an upper bound of the requests as we don't want to read dirty states (due to parallel insertion).

4.  sealed trait ContractStateEvent extends Product with Serializable
5.  final case class DecomposedFilter(party: Option[Party], templateId: Option[Identifier]) extends Product with Serializable
6.  final case class EventsRange(startInclusiveOffset: Offset, startInclusiveEventSeqId: Long, endInclusiveOffset: Offset, endInclusiveEventSeqId: Long) extends Product with Serializable
7.  final case class FieldCompressionStrategy(id: Option[Int], compress: (Array[Byte]) => Array[Byte]) extends Product with Serializable
8.  final case class IdPageSizing(minPageSize: Int, maxPageSize: Int) extends Product with Serializable

   The size of a page is the number of ids in the page.

9.  trait LfValueSerialization extends AnyRef

   Serializes and deserializes Daml-Lf values and events.

   Serializes and deserializes Daml-Lf values and events.

   Deserializing values in verbose mode involves loading packages in order to fill in missing type information. That's why these methods return Futures, while the serialization methods are synchronous.

10.  final class LfValueTranslation extends LfValueSerialization with NamedLogging
11.  trait Loader[KEY, VALUE] extends AnyRef
12.  class PekkoStreamParallelBatchedLoader[KEY, VALUE] extends Loader[KEY, VALUE] with NamedLogging
13.  trait QueryValidRange extends AnyRef
14.  final case class QueryValidRangeImpl(storageBackend: ParameterStorageBackend, loggerFactory: NamedLoggerFactory) extends QueryValidRange with NamedLogging with Product with Serializable
15.  final class ReassignmentPointwiseReader extends NamedLogging
16.  class ReassignmentStreamReader extends NamedLogging
17.  final class TopologyTransactionPointwiseReader extends NamedLogging
18.  class TopologyTransactionsStreamReader extends NamedLogging
19.  final class TransactionPointwiseReader extends NamedLogging
20.  sealed trait TransactionPointwiseReaderLegacy extends AnyRef
21.  final class TransactionTreePointwiseReader extends TransactionPointwiseReaderLegacy with NamedLogging

    Annotations

    @nowarn()

22.  class TransactionsTreeStreamReader extends NamedLogging

    Annotations

    @nowarn()

23.  final class UpdatePointwiseReader extends NamedLogging
24.  class UpdatesStreamReader extends NamedLogging