Packages

package store

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package db
  2. package memory
  3. package packagemeta

Type Members

  1. final case class ChangeWouldResultInGap(from: SequencerCounter, to: SequencerCounter) extends SequencedEventStoreError with Product with Serializable
  2. sealed trait ConfirmationRequestSessionKeyStore extends AnyRef

    These session key stores are to be used during the processing of a confirmation request.

    These session key stores are to be used during the processing of a confirmation request. They could either be used for a single transaction (i.e. SessionKeyStoreWithNoEviction) or for all transactions (i.e. SessionKeyStoreWithInMemoryCache). The latter, requires a size limit and an eviction policy to be specified.

  3. final case class CursorPrehead[Discr](counter: Counter[Discr], timestamp: CantonTimestamp) extends PrettyPrinting with Product with Serializable

    Information for the prehead of a cursor.

    Information for the prehead of a cursor. The prehead of a cursor is the counter before the cursors' head, if any.

    counter

    The counter corresponding to the prehead

    timestamp

    The timestamp corresponding to the prehead

  4. trait CursorPreheadStore[Discr] extends AutoCloseable

    Storage for a cursor prehead.

  5. final case class IndexedPhysicalSynchronizer extends Impl[PhysicalSynchronizerId] with Product with Serializable
  6. trait IndexedString[E] extends AnyRef
  7. class IndexedStringCache extends IndexedStringStore with NamedLogging
  8. abstract class IndexedStringFromDb[A <: IndexedString[B], B] extends AnyRef
  9. trait IndexedStringStore extends AutoCloseable

    uid index such that we can store integers instead of long strings in our database

  10. final case class IndexedStringType extends Product with Serializable
  11. final case class IndexedSynchronizer extends Impl[SynchronizerId] with Product with Serializable
  12. final case class IndexedTopologyStoreId extends Impl[TopologyStoreId] with Product with Serializable
  13. final case class PendingOperation[Op <: HasProtocolVersionedWrapper[Op]] extends Product with Serializable

    Op

    A protobuf message that implements com.digitalasset.canton.version.HasProtocolVersionedWrapper that contains the relevant data for executing the pending operation.

  14. trait PendingOperationStore[Op <: HasProtocolVersionedWrapper[Op]] extends AnyRef

    Op

    A protobuf message that implements com.digitalasset.canton.version.HasProtocolVersionedWrapper that contains the relevant data for executing the pending operation.

  15. trait PrunableByTime extends AnyRef

    Interface for a store that allows pruning and keeps track of when pruning has started and finished.

  16. final case class PrunableByTimeParameters(targetBatchSize: PositiveInt, initialInterval: NonNegativeFiniteDuration, maxBuckets: PositiveInt, controlFactors: Seq[ControlFactors] = PrunableByTimeParameters.DefaultControlFactors, maxItemsExpectedToPrunePerBatch: PositiveInt) extends Product with Serializable

    Various parameter to control prunable by time batching (used for journal pruning)

    Various parameter to control prunable by time batching (used for journal pruning)

    targetBatchSize

    Defines the ideal pruning batch size. If the batches are larger than the target pruning size, the number of buckets is doubled. If they are substantially smaller than the target pruning size, the number of buckets is reduced by 10%.

    initialInterval

    The start interval for the prune batching

    maxBuckets

    maximum number of buckets to split a batch into (limit the iterations when nodes are inactive for quite a while)

    controlFactors

    The adjustment parameters for the prune batch size computation (threshold, factor)

    maxItemsExpectedToPrunePerBatch

    The maximum on the number of items expected to prune per batch. Implemented by select stores (e.g. ActiveContractStore) to help motivate database filtered index selection. Should be at least an order of magnitude larger than targetBatchSize to not interfere with dynamic bucketing after a participant node has been inactive for a while, but not excessively large to discourage scanning the entire table.

  17. trait PruningSchedulerStore extends AutoCloseable

    Stores for the pruning scheduler parameters such as the cron schedule and pruning retention period

  18. trait Purgeable extends AnyRef
  19. sealed trait SavePendingSendError extends AnyRef
  20. trait SendTrackerStore extends AutoCloseable

    Keeps track of com.digitalasset.canton.sequencing.protocol.SubmissionRequests that have been sent to the sequencer but not yet witnessed.

  21. final case class SequencedEventNotFoundError(criterion: SearchCriterion) extends SequencedEventStoreError with Product with Serializable
  22. final case class SequencedEventRangeOverlapsWithPruning(criterion: RangeCriterion, pruningStatus: PruningStatus, foundEvents: Seq[PossiblyIgnoredSerializedEvent]) extends SequencedEventStoreError with PrettyPrinting with Product with Serializable
  23. trait SequencedEventStore extends PrunableByTime with NamedLogging with FlagCloseable with HasCloseContext

    Persistent store for com.digitalasset.canton.sequencing.protocol.SequencedEvents received from the sequencer.

    Persistent store for com.digitalasset.canton.sequencing.protocol.SequencedEvents received from the sequencer. The store may assume that sequencer counters strictly increase with timestamps without checking this precondition.

  24. sealed trait SequencedEventStoreError extends Product with Serializable
  25. trait SequencerCounterTrackerStore extends FlagCloseable

    Store for keeping track of the prehead for clean sequencer counters.

    Store for keeping track of the prehead for clean sequencer counters. A com.digitalasset.canton.SequencerCounter becomes clean when the corresponding com.digitalasset.canton.sequencing.protocol.SequencedEvent has been processed completely and successfully. The prehead of the cursor is advanced only so far that all sequencer counters up to the prehead are clean.

  26. sealed trait SessionKeyStore extends AutoCloseable
  27. final class SessionKeyStoreWithInMemoryCache extends SessionKeyStore with ConfirmationRequestSessionKeyStore with NamedLogging
  28. final class SessionKeyStoreWithNoEviction extends ConfirmationRequestSessionKeyStore

    This cache stores session key information for each recipient tree, which is later used to encrypt view messages.

    This cache stores session key information for each recipient tree, which is later used to encrypt view messages. However, in this implementation, the session keys have neither a size limit nor an eviction time. Therefore, this cache MUST only be used when it is local to each transaction and short-lived.

Ungrouped