package events
- Alphabetic
- Public
- Protected
Type Members
- 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.
- class CachedEventsReader extends LedgerDaoEventsReader with NamedLogging
- final case class CompressionStrategy(createArgumentCompression: FieldCompressionStrategy, createKeyValueCompression: FieldCompressionStrategy, exerciseArgumentCompression: FieldCompressionStrategy, exerciseResultCompression: FieldCompressionStrategy) extends Product with Serializable
- trait ContractLoader extends Loader[(daml.lf.value.Value.ContractId, Offset), RawContractState]
- sealed trait ContractStateEvent extends Product with Serializable
- final case class DecomposedFilter(party: Party, templateId: Option[Identifier]) extends Product with Serializable
- final case class EventsRange(startExclusiveOffset: Offset, startExclusiveEventSeqId: Long, endInclusiveOffset: Offset, endInclusiveEventSeqId: Long) extends Product with Serializable
- final case class FieldCompressionStrategy(id: Option[Int], compress: (Array[Byte]) => Array[Byte]) extends Product with Serializable
- 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.
- 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.
- final class LfValueTranslation extends LfValueSerialization with NamedLogging
- trait Loader[KEY, VALUE] extends AnyRef
- class PekkoStreamParallelBatchedLoader[KEY, VALUE] extends Loader[KEY, VALUE] with NamedLogging
- trait QueryNonPruned extends AnyRef
- final case class QueryNonPrunedImpl(storageBackend: ParameterStorageBackend, loggerFactory: NamedLoggerFactory) extends QueryNonPruned with NamedLogging with Product with Serializable
- 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.
- class ReassignmentStreamReader extends NamedLogging
- final class TransactionFlatPointwiseReader extends TransactionPointwiseReader
- sealed trait TransactionPointwiseReader extends AnyRef
- final class TransactionTreePointwiseReader extends TransactionPointwiseReader
- class TransactionsFlatStreamReader extends NamedLogging
- class TransactionsTreeStreamReader extends NamedLogging
Value Members
- object ACSReader
- object CompressionMetrics
- object CompressionStrategy extends Serializable
- object ContractLoader
- object ContractStateEvent extends Serializable
- object EventIdsUtils
- object EventsTable
- object FieldCompressionStrategy extends Serializable
- object FilterUtils
- object IdPageSizing extends Serializable
- object LfValueTranslation
- object Raw
- object ReassignmentStreamReader
- object Utils