Type Members

1.  class ACSReader extends NamedLogging

   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.

   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.  class CachedEventsReader extends LedgerDaoEventsReader with NamedLogging
3.  final case class CompressionStrategy(createArgumentCompression: FieldCompressionStrategy, createKeyValueCompression: FieldCompressionStrategy, exerciseArgumentCompression: FieldCompressionStrategy, exerciseResultCompression: FieldCompressionStrategy) extends Product with Serializable
4.  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).

5.  sealed trait ContractStateEvent extends Product with Serializable
6.  final case class DecomposedFilter(party: Party, templateId: Option[Identifier]) extends Product with Serializable
7.  final case class EventsRange(startExclusiveOffset: Offset, startExclusiveEventSeqId: Long, endInclusiveOffset: Offset, endInclusiveEventSeqId: Long) extends Product with Serializable
8.  final case class FieldCompressionStrategy(id: Option[Int], compress: (Array[Byte]) => Array[Byte]) extends Product with Serializable
9.  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.

10.  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.

11.  final class LfValueTranslation extends LfValueSerialization with NamedLogging
12.  trait Loader[KEY, VALUE] extends AnyRef
13.  class PekkoStreamParallelBatchedLoader[KEY, VALUE] extends Loader[KEY, VALUE] with NamedLogging
14.  trait QueryNonPruned extends AnyRef
15.  final case class QueryNonPrunedImpl(storageBackend: ParameterStorageBackend, loggerFactory: NamedLoggerFactory) extends QueryNonPruned with NamedLogging with Product with Serializable
16.  sealed trait Raw[+E] extends AnyRef

    An event as it's fetched from the participant index, before the deserialization the values contained therein.

    An event as it's fetched from the participant index, before the deserialization the values contained therein. Allows to wrap events from the database while delaying deserialization so that it doesn't happen on the database thread pool.

17.  final class TransactionFlatPointwiseReader extends TransactionPointwiseReader
18.  sealed trait TransactionPointwiseReader extends AnyRef
19.  final class TransactionTreePointwiseReader extends TransactionPointwiseReader
20.  class TransactionsFlatStreamReader extends NamedLogging
21.  class TransactionsTreeStreamReader extends NamedLogging