Packages

package store

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package db
  2. package memory

Type Members

  1. trait AcsCommitmentLookup extends AnyRef

    Read interface for ACS commitments, with no usage restrictions.

  2. trait AcsCommitmentStore extends AcsCommitmentLookup with PrunableByTime[AcsCommitmentStoreError] with AutoCloseable

    Read and write interface for ACS commitments.

    Read and write interface for ACS commitments. Apart from pruning, should only be used by the ACS commitment processor

  3. trait ActiveContractSnapshot extends AnyRef

    Provides snapshotting for active contracts.

  4. trait ActiveContractStore extends ActiveContractSnapshot with ConflictDetectionStore[LfContractId, Status, AcsError]

    The active contract store (ACS) stores for every contract ID whether it is inexistent, ActiveContractStore.Active, ActiveContractStore.Archived, or ActiveContractStore.TransferredAway, along with the timestamp of the latest change.

    The active contract store (ACS) stores for every contract ID whether it is inexistent, ActiveContractStore.Active, ActiveContractStore.Archived, or ActiveContractStore.TransferredAway, along with the timestamp of the latest change. Every change is associated with the timestamp and request counter of the request that triggered the change. The changes are ordered first by timestamp, then by request counter, and finally by change type (activations before deactivations). Implementations must be thread-safe. Updates must be idempotent.

    Creations, transfers, and archivals can be mixed arbitrarily. A contract may be transferred in and out several times during its lifetime. It becomes active with every transfer-in and transferred away with every transfer-out. If the ACS detects irregularities, the change method reports them.

    These methods are supposed to be called by the ConflictDetector only, which coordinates the request journal updates and the updates to the ACS.

    Updates may be written asynchronously. Every implementation determines an order over all the changes and queries to the ACS. Each individual change must be applied atomically and the result is determined with respect to this order. This order need not be consistent with the order of the calls, though. However, the following is guaranteed: If the future returned by a call completes and observing the completion happens before another call, then all changes of the former call must be ordered before all changes of the later call.

    Bulk methods like ActiveContractStore.createContracts and ActiveContractStore.archiveContracts generate one individual change for each contract. So their changes may be interleaved with other calls.

    See also

    ActiveContractSnapshot for the ACS snapshot interface

  5. case class CommandDeduplicationData extends PrettyPrinting with Product with Serializable

    The command deduplication data associated with a com.daml.ledger.participant.state.v2.ChangeId.

  6. trait CommandDeduplicationStore extends AutoCloseable
  7. case class CommitTimeBeforeRequestTime(requestCounter: RequestCounter, requestTime: CantonTimestamp, commitTime: CantonTimestamp) extends RequestJournalStoreError with Product with Serializable
  8. trait CommitmentQueue extends AnyRef

    Manages the buffer (priority queue) for incoming commitments.

    Manages the buffer (priority queue) for incoming commitments.

    The priority is based on the timestamp of the end of the commitment's commitment period. Lower timestamps have higher priority.

  9. trait ConfigurationParamsDeserializer extends AnyRef
  10. trait ConflictDetectionStore[K, A <: PrettyPrinting, E] extends PrunableByTime[E]

    Common interface for stores used by conflict detection

  11. trait ContractAndKeyLookup extends ContractLookup
  12. trait ContractKeyJournal extends ConflictDetectionStore[LfGlobalKey, Status, ContractKeyJournalError]

    The contract key journal determines for each com.digitalasset.canton.protocol.LfGlobalKey whether it is considered to be allocated.

    The contract key journal determines for each com.digitalasset.canton.protocol.LfGlobalKey whether it is considered to be allocated. The store is organized as a journal, indexed by timestamp and request counter, so that crash recovery can remove all changes due to dirty request before replay starts.

    With unique contract key semantics and honest key maintainers, the allocation status reflects whether there is an active contract in the active contract store for the given key. However, if two or more contracts with the same key have been active, this correspondence no longer needs to hold. Then, the contract key journal has the authority over the allocation status of the key.

  13. trait ContractLookup extends AnyRef
  14. sealed trait ContractLookupError extends ContractStoreError
  15. trait ContractStore extends ContractLookup
  16. sealed trait ContractStoreError extends Product with Serializable with PrettyPrinting
  17. trait DamlPackageStore extends AutoCloseable

    For storing and retrieving Daml packages and DARs.

  18. case class DefiniteAnswerEvent(offset: GlobalOffset, publicationTime: CantonTimestamp, submissionId: Option[LedgerSubmissionId], traceContext: TraceContext) extends PrettyPrinting with Product with Serializable

    offset

    A completion offset in the MultiDomainEventLog

    publicationTime

    The publication time associated with the offset

    traceContext

    The trace context that created the completion offset.

  19. trait DomainAliasAndIdStore extends AutoCloseable

    Keeps track of domainIds of all domains the participant has previously connected to.

  20. trait DomainConnectionConfigStore extends AutoCloseable

    The configured domains and their connection configuration

  21. trait DomainParameterStore extends AnyRef
  22. final case class DuplicateContract(id: LfContractId, oldContract: StoredContract, newContract: StoredContract) extends ContractStoreError with Product with Serializable
  23. sealed trait EventLogId extends PrettyPrinting with Product with Serializable
  24. class ExtendedContractLookup extends ContractAndKeyLookup

    A contract lookup that adds a fixed set of contracts to a backingContractLookup.

    A contract lookup that adds a fixed set of contracts to a backingContractLookup.

    Exceptions thrown

    java.lang.IllegalArgumentException if additionalContracts stores a contract under a wrong id

  25. trait HasPrunable extends AnyRef
  26. trait InFlightSubmissionStore extends AutoCloseable

    Backing store for com.digitalasset.canton.participant.protocol.submission.InFlightSubmissionTracker.

    Backing store for com.digitalasset.canton.participant.protocol.submission.InFlightSubmissionTracker.

    An in-flight submission is uniquely identified by its com.daml.ledger.participant.state.v2.ChangeId. com.digitalasset.canton.sequencing.protocol.MessageIds should be unique too, but this is not enforced by the store.

    Every change to an individual submissions must execute atomically. Bulk operations may interleave arbitrarily the atomic changes of the affected individual submissions and therefore need not be atomic as a whole.

  27. case class InconsistentRequestState(requestCounter: RequestCounter, storedState: RequestState, expectedState: RequestState) extends RequestJournalStoreError with Product with Serializable
  28. case class InconsistentRequestTimestamp(requestCounter: RequestCounter, storedTimestamp: CantonTimestamp, expectedTimestamp: CantonTimestamp) extends RequestJournalStoreError with Product with Serializable
  29. trait IncrementalCommitmentStore extends AnyRef

    A key-value store with sets of parties as keys, and with LtHash16 values.

    A key-value store with sets of parties as keys, and with LtHash16 values. Keeps a watermark of the record time (a timestamp accompanied by a tie-breaker, to account for multiple changes with the same timestamp) of the last update.

    While the store is agnostic to its use, we use is as follows. For each set S of parties such that:

    • the parties are stakeholders on some contract C and
    • the participant stores C in its ACS

    the participant uses the store to store an LtHash16 commitment to all the contracts whose stakeholders are exactly S.

    To ensure that the commitments correspond to the ACSs, the caller(s) must jointly ensure that all ACS changes are delivered to this store exactly once. In particular, upon crashes, the caller(s) must send ALL ACS changes that are later - in the lexicographic order of (timestamp, request) - than the watermark returned by the store, but must not replay any changes lower or equal to the watermark.

  30. trait MultiDomainCausalityStore extends AutoCloseable
  31. trait MultiDomainEventLog extends AutoCloseable

    The multi domain event log merges the events from several SingleDimensionEventLogs to a single event stream.

    The multi domain event log merges the events from several SingleDimensionEventLogs to a single event stream.

    The underlying SingleDimensionEventLog either refer to a domain ("domain event log") or to the underlying participant ("participant event log").

    Ordering guarantees: 1. Events belonging to the same SingleDimensionEventLog have the same relative order in the MultiDomainEventLog 2. Events are globally ordered such that any two (unpruned) events appear in the same relative order in different subscriptions and lookups.

  32. trait ParticipantEventLog extends SingleDimensionEventLog[ParticipantEventLogId] with AutoCloseable
  33. class ParticipantNodeEphemeralState extends AnyRef

    Some of the state of a participant that is not tied to a domain and is kept only in memory.

  34. class ParticipantNodePersistentState extends AutoCloseable with NamedLogging

    Some of the state of a participant that is not tied to a domain and must survive restarts.

    Some of the state of a participant that is not tied to a domain and must survive restarts. Does not cover topology stores (as they are also present for domain nodes) nor the RegisteredDomainsStore (for initialization reasons)

  35. trait ParticipantPruningStore extends AutoCloseable

    The ParticipantPruningStore stores the last started / completed pruning operation.

  36. trait ParticipantSettingsLookup extends AnyRef

    Read-only interface for ParticipantSettingsStore

  37. trait ParticipantSettingsStore extends ParticipantSettingsLookup with AutoCloseable

    Stores misc settings for a participant.

    Stores misc settings for a participant. Allows clients to read settings without accessing the database. In turn, a client needs to call refreshCache before reading settings.

  38. trait RegisteredDomainsStore extends DomainAliasAndIdStore
  39. trait RequestJournalStore extends AnyRef
  40. sealed trait RequestJournalStoreError extends Product with Serializable
  41. case class SerializableBlindingInfo(blindingInfo: BlindingInfo) extends Product with Serializable
  42. case class SerializableCommandRejected(commandRejected: CommandRejected) extends Product with Serializable
  43. case class SerializableCompletionInfo(completionInfo: CompletionInfo) extends Product with Serializable
  44. case class SerializableConfiguration(configuration: Configuration) extends Product with Serializable
  45. case class SerializableConfigurationChangeRejected(configurationChangeRejected: ConfigurationChangeRejected) extends Product with Serializable
  46. case class SerializableConfigurationChanged(configurationChanged: ConfigurationChanged) extends Product with Serializable
  47. case class SerializableDivulgedContract(divulgedContract: DivulgedContract) extends Product with Serializable
  48. final case class SerializableLedgerSyncEvent(ledgerSyncEvent: LedgerSyncEvent)(representativeProtocolVersion: RepresentativeProtocolVersion[SerializableLedgerSyncEvent]) extends HasProtocolVersionedWrapper[SerializableLedgerSyncEvent] with Product with Serializable

    Wrapper for converting a LedgerSyncEvent to its protobuf companion.

    Wrapper for converting a LedgerSyncEvent to its protobuf companion. Currently only Intended only for storage due to the unusual exceptions which are thrown that are only permitted in a storage context.

    Exceptions thrown

    canton.store.db.DbDeserializationException if transactions or contracts fail to deserialize

    canton.store.db.DbSerializationException if transactions or contracts fail to serialize

  49. case class SerializableLfTimestamp(timestamp: Timestamp) extends Product with Serializable
  50. case class SerializableNodeSeed(nodeId: LfNodeId, seedHash: Hash) extends Product with Serializable
  51. case class SerializablePartyAddedToParticipant(partyAddedToParticipant: PartyAddedToParticipant) extends Product with Serializable
  52. case class SerializablePartyAllocationRejected(partyAllocationRejected: PartyAllocationRejected) extends Product with Serializable
  53. case class SerializablePublicPackageUpload(publicPackageUpload: PublicPackageUpload) extends Product with Serializable
  54. case class SerializablePublicPackageUploadRejected(publicPackageUploadRejected: PublicPackageUploadRejected) extends Product with Serializable
  55. case class SerializableRejectionReasonTemplate(rejectionReason: RejectionReasonTemplate) extends Product with Serializable
  56. case class SerializableSubmissionId(submissionId: LedgerSubmissionId) extends Product with Serializable
  57. case class SerializableTimeModel(timeModel: LedgerTimeModel) extends Product with Serializable
  58. case class SerializableTransactionAccepted(transactionAccepted: TransactionAccepted) extends Product with Serializable
  59. case class SerializableTransactionMeta(transactionMeta: TransactionMeta) extends Product with Serializable
  60. trait ServiceAgreementStore extends AutoCloseable
  61. trait SingleDimensionEventLog[+Id <: EventLogId] extends SingleDimensionEventLogLookup

    An event log for a single domain or for a domain-independent events (such as package uploads).

    An event log for a single domain or for a domain-independent events (such as package uploads). Supports out-of-order publication of events.

  62. trait SingleDimensionEventLogLookup extends AnyRef

    Read-only interface of SingleDimensionEventLog

  63. trait SingleDomainCausalDependencyStore extends AnyRef
  64. final case class StoredContract(contract: SerializableContract, requestCounter: RequestCounter, creatingTransactionIdO: Option[TransactionId]) extends PrettyPrinting with Product with Serializable

    Data to be stored for a contract.

    Data to be stored for a contract.

    contract

    The contract to be stored

    requestCounter

    The request counter of the latest request that stored the contract.

    creatingTransactionIdO

    The id of the transaction that created the contract. scala.None for divulged and witnessed contracts.

  65. class StoredContractManager extends NamedLogging with ContractLookup

    Manages a contract store by keeping pending contracts in memory.

    Manages a contract store by keeping pending contracts in memory. ContractLookup.lookup finds these pending contracts in addition to those in the backing ContractStore. A contract ceases to be pending as soon as first request writes it to the backing store using StoredContractManager.commitIfPending.

    Unlike ExtendedContractLookup, the pending contracts can be updated and committed to the backing store, concurrently with other contract lookups and additions.

  66. final case class StoredDomainConnectionConfig(config: DomainConnectionConfig, status: Status) extends Product with Serializable
  67. class SyncDomainEphemeralState extends SyncDomainEphemeralStateLookup with AutoCloseable with NamedLogging

    The state of a synchronization domain that is kept only in memory and must be reconstructed after crashes and fatal errors from the SyncDomainPersistentState.

    The state of a synchronization domain that is kept only in memory and must be reconstructed after crashes and fatal errors from the SyncDomainPersistentState. The ephemeral state can be kept across network disconnects provided that the local processing continues as far as possible.

  68. trait SyncDomainEphemeralStateFactory extends AnyRef
  69. class SyncDomainEphemeralStateFactoryImpl extends SyncDomainEphemeralStateFactory with NamedLogging
  70. trait SyncDomainEphemeralStateLookup extends AnyRef
  71. trait SyncDomainPersistentState extends NamedLogging with AutoCloseable

    The state of a synchronization domain that is independent of the connectivity to the domain.

  72. class SyncDomainPersistentStateFactory extends NamedLogging

    Factory for SyncDomainPersistentState.

    Factory for SyncDomainPersistentState. Tries to discover existing persistent states or create new ones and checks consistency of domain parameters and unique contract key domains

  73. trait TransferLookup extends AnyRef
  74. trait TransferStore extends TransferLookup
  75. final case class UnknownContract(contractId: LfContractId) extends ContractLookupError with Product with Serializable
  76. final case class UnknownContracts(contractIds: Set[LfContractId]) extends ContractLookupError with Product with Serializable
  77. case class UnknownRequestCounter(requestCounter: RequestCounter) extends RequestJournalStoreError with Product with Serializable

Value Members

  1. object AcsCommitmentStore
  2. object ActiveContractSnapshot
  3. object ActiveContractStore
  4. object CommandDeduplicationData extends Serializable
  5. object CommandDeduplicationStore
  6. object ContractAndKeyLookup
  7. object ContractKeyJournal
  8. object ContractLookup
  9. object DamlPackageStore
  10. object DefiniteAnswerEvent extends Serializable
  11. object DomainAliasAndIdStore
  12. object DomainConnectionConfigStore
  13. object DomainParameterStore
  14. object EventLogId extends Serializable
  15. object InFlightSubmissionStore
  16. object MultiDomainCausalityStore
  17. object MultiDomainEventLog
  18. object ParticipantEventLog
  19. object ParticipantNodeEphemeralState
  20. object ParticipantNodePersistentState extends HasLoggerName
  21. object ParticipantPruningStore
  22. object ParticipantSettingsStore
  23. object RegisteredDomainsStore
  24. object SerializableApplicationId extends SerializableStringModule[LedgerApplicationId, daml.lf.data.Ref.ApplicationId.type]
  25. object SerializableBlindingInfo extends Serializable
  26. object SerializableCommandId extends SerializableStringModule[daml.lf.data.Ref.CommandId, daml.lf.data.Ref.CommandId.type]
  27. object SerializableCommandRejected extends Serializable
  28. object SerializableCompletionInfo extends Serializable
  29. object SerializableConfiguration extends Serializable
  30. object SerializableConfigurationChangeRejected extends ConfigurationParamsDeserializer with Serializable
  31. object SerializableConfigurationChanged extends ConfigurationParamsDeserializer with Serializable
  32. object SerializableDivulgedContract extends Serializable
  33. object SerializableLedgerSyncEvent extends HasProtocolVersionedCompanion[SerializableLedgerSyncEvent] with ProtocolVersionedCompanionDbHelpers[SerializableLedgerSyncEvent] with Serializable
  34. object SerializableLfTimestamp extends Serializable
  35. object SerializableNodeSeed extends Serializable
  36. object SerializablePackageId extends SerializableStringModule[LfPackageId, LfPackageId.type]
  37. object SerializableParticipantId extends SerializableStringModule[LedgerParticipantId, LedgerParticipantId.type]
  38. object SerializablePartyAddedToParticipant extends Serializable
  39. object SerializablePartyAllocationRejected extends Serializable
  40. object SerializablePublicPackageUpload extends Serializable
  41. object SerializablePublicPackageUploadRejected extends Serializable
  42. object SerializableRejectionReasonTemplate extends Serializable
  43. object SerializableSubmissionId extends Serializable
  44. object SerializableTimeModel extends Serializable
  45. object SerializableTransactionAccepted extends Serializable
  46. object SerializableTransactionId extends SerializableStringModule[LedgerTransactionId, LedgerTransactionId.type]
  47. object SerializableTransactionMeta extends Serializable
  48. object SerializableWorkflowId extends SerializableStringModule[LfWorkflowId, daml.lf.data.Ref.WorkflowId.type]
  49. object ServiceAgreementStore
  50. object SingleDimensionEventLog
  51. object SingleDomainCausalDependencyStore
  52. object StoredContract extends Serializable
  53. object StoredContractManager
  54. object SyncDomainEphemeralStateFactory
  55. object SyncDomainPersistentState
  56. object TransferStore

Ungrouped