class InMemoryActiveContractStore extends ActiveContractStore with NamedLogging with InMemoryPrunableByTime

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. InMemoryActiveContractStore
  2. InMemoryPrunableByTime
  3. NamedLogging
  4. ActiveContractStore
  5. ConflictDetectionStore
  6. PrunableByTime
  7. ActiveContractSnapshot
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new InMemoryActiveContractStore(indexedStringStore: IndexedStringStore, protocolVersion: ProtocolVersion, loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def advancePruningTimestamp(phase: PruningPhase, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Unit]
    Attributes
    protected[canton]
    Definition Classes
    InMemoryPrunableByTimePrunableByTime
  5. def archiveContract(cid: LfContractId, toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Shorthand for archiveContracts(Seq(cid), toc)

    Shorthand for archiveContracts(Seq(cid), toc)

    Definition Classes
    ActiveContractStore
  6. def archiveContracts(contractIds: Seq[LfContractId], toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Marks the given contracts as archived from toc's timestamp (inclusive) onwards.

    Marks the given contracts as archived from toc's timestamp (inclusive) onwards.

    contractIds

    The contract IDs of the contracts to be archived

    toc

    The time of change consisting of

    • The request counter of the confirmation request that archives the contracts.
    • The timestamp on the confirmation request that archives the contracts.
    returns

    The future completes when all contract states have been updated. The following irregularities are reported for each contract:

    Definition Classes
    ActiveContractStore
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def batchingParameters: Option[PrunableByTimeParameters]

    Parameters to control prune batching

    Parameters to control prune batching

    If defined, then the pruning window will be computed such that it targets the ideal target batch size in order to optimize the load on the database.

    This is currently used with the journal stores. Normal pruning of other stores already does batching on its own.

    Attributes
    protected
    Definition Classes
    PrunableByTime
  9. def changesBetween(fromExclusive: TimeOfChange, toInclusive: TimeOfChange)(implicit traceContext: TraceContext): Future[LazyList[(TimeOfChange, ActiveContractIdsChange)]]
  10. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  11. def contractCount(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Int]

    Returns the total number of contracts whose states are stored at the given timestamp.

    Returns the total number of contracts whose states are stored at the given timestamp.

    To get a consistent snapshot, the caller must ensure that the timestamp specifies a time that is not in the future, i.e., not after the timestamp of the clean cursor in the com.digitalasset.canton.participant.protocol.RequestJournal Note that the result may change between two invocations if prune is called in the meantime.

    Definition Classes
    InMemoryActiveContractStoreActiveContractStore
  12. def contractSnapshot(contractIds: Set[LfContractId], timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[Map[LfContractId, CantonTimestamp]]

    Returns a map to the timestamp when the contract became active for the last time before or at the given timestamp.

    Returns a map to the timestamp when the contract became active for the last time before or at the given timestamp. Omits contracts that not active right after the given timestamp.

    timestamp

    The timestamp at which the activeness of the contracts shall be determined. Must be before the timestamp that corresponds to the head cursor in the com.digitalasset.canton.participant.protocol.RequestJournal for the state com.digitalasset.canton.participant.protocol.RequestJournal.RequestState.Clean. If this precondition is violated, the returned snapshot may be inconsistent, i.e., it may omit some contracts that were ActiveContractStore.Active at the given time and it may include contracts that were actually ActiveContractStore.Archived or ActiveContractStore.TransferredAway.

    Definition Classes
    InMemoryActiveContractStoreActiveContractSnapshot
  13. def deleteSince(criterion: RequestCounter)(implicit traceContext: TraceContext): Future[Unit]

    Deletes all activeness changes from requests whose request counter is at least the given one.

    Deletes all activeness changes from requests whose request counter is at least the given one. This method must not be called concurrently with creating, archiving, or transferring contracts.

    Therefore, this method need not be linearizable w.r.t. creating, archiving, or transferring contracts. For example, if a request rc1 creates a contract c and another request rc2 archives it while deleteSince is running for some rc <= rc1, rc2, then there are no guarantees which of the effects of rc1 and rc2 remain. For example, c could end up being inexistent, active, or archived but never created, even if the writes for rc1 and rc2 are successful.

    Definition Classes
    InMemoryActiveContractStoreActiveContractStore
  14. def doPrune(beforeAndIncluding: CantonTimestamp, lastPruning: Option[CantonTimestamp])(implicit traceContext: TraceContext): Future[Int]

    Deletes all entries about archived contracts whose status hasn't changed after the timestamp.

    Deletes all entries about archived contracts whose status hasn't changed after the timestamp.

    The caller must ensure that the given timestamp is at most the one of the clean cursor in the com.digitalasset.canton.participant.protocol.RequestJournal

    returns

    the approximate number of pruned rows, used to adjust the pruning windows to reach optimal batch sizes

    Definition Classes
    InMemoryActiveContractStoreActiveContractStorePrunableByTime
  15. def domainIdFromIdx(idx: Int)(implicit ec: ExecutionContext, loggingContext: ErrorLoggingContext): Future[DomainId]
    Attributes
    protected
    Definition Classes
    ActiveContractStore
  16. implicit val ec: ExecutionContext
  17. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  19. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  20. def fetchState(id: LfContractId)(implicit traceContext: TraceContext): Future[Option[StateChange[Status]]]

    Short-hand for fetchStates for a single identifier

    Short-hand for fetchStates for a single identifier

    Definition Classes
    ConflictDetectionStore
  21. def fetchStates(contractIds: Iterable[LfContractId])(implicit traceContext: TraceContext): Future[Map[LfContractId, ContractState]]

    Returns the latest com.digitalasset.canton.participant.store.ActiveContractStore.Status for the given contract IDs along with its com.digitalasset.canton.participant.util.TimeOfChange.

    Returns the latest com.digitalasset.canton.participant.store.ActiveContractStore.Status for the given contract IDs along with its com.digitalasset.canton.participant.util.TimeOfChange.

    This method is used by the protocol processors for conflict detection. In-flight transactions may have changesets not yet written to the ACS datastore. Since only the ConflictDetector tracks in-flight changesets, this method cannot be used as a source of valid data to other components.

    If a contract is created or transferred-in and archived or transferred-out at the same com.digitalasset.canton.participant.util.TimeOfChange, the contract is ActiveContractStore.Archived or ActiveContractStore.TransferredAway. A contract cannot be archived and transferred out at the same timestamp.

    returns

    The map from contracts in contractIds in the store to their latest state. Nonexistent contracts are excluded from the map.

    Definition Classes
    InMemoryActiveContractStoreActiveContractStoreConflictDetectionStore
    See also

    ActiveContractSnapshot!.snapshot

  22. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  23. def getDomainIndices(domains: Seq[DomainId]): CheckedT[Future, AcsError, AcsWarning, Map[DomainId, IndexedDomain]]
    Attributes
    protected
    Definition Classes
    ActiveContractStore
  24. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  25. val indexedStringStore: IndexedStringStore
  26. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  27. def kind: String
    Attributes
    protected
    Definition Classes
    ActiveContractStorePrunableByTime
  28. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  29. val loggerFactory: NamedLoggerFactory
  30. def markContractAdded(contract: LfContractId, toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Shorthand for markContractAdded(Seq(contract), toc)

    Shorthand for markContractAdded(Seq(contract), toc)

    Definition Classes
    ActiveContractStore
  31. def markContractCreated(contract: LfContractId, toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Shorthand for markContractsCreated(Seq(contract), toc)

    Shorthand for markContractsCreated(Seq(contract), toc)

    Definition Classes
    ActiveContractStore
  32. def markContractsAdded(contracts: Seq[LfContractId], toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Marks the given contracts as active from timestamp (inclusive) onwards.

    Marks the given contracts as active from timestamp (inclusive) onwards.

    Unlike creation, add can be done several times in the life of a contract. It is intended to use from the repair service.

    Definition Classes
    ActiveContractStore
  33. def markContractsCreated(contracts: Seq[LfContractId], toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Marks the given contracts as active from timestamp (inclusive) onwards.

    Marks the given contracts as active from timestamp (inclusive) onwards.

    contracts

    The contracts represented as a tuple of contract id and reassignment counter

    toc

    The time of change consisting of

    • The request counter of the confirmation request that created the contracts
    • The timestamp of the confirmation request that created the contracts.
    returns

    The future completes when all contract states have been updated. The following irregularities are reported for each contract:

    Definition Classes
    ActiveContractStore
  34. def markContractsCreatedOrAdded(contracts: Seq[LfContractId], toc: TimeOfChange, isCreation: Boolean)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]
  35. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  36. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  37. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  38. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  39. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  40. def packageUsage(pkg: PackageId, contractStore: ContractStore)(implicit traceContext: TraceContext): Future[Option[LfContractId]]

    Returns Some(contractId) if an active contract belonging to package pkg exists, otherwise returns None.

    Returns Some(contractId) if an active contract belonging to package pkg exists, otherwise returns None. The returned contractId may be any active contract from package pkg. The most recent contract state is used.

    Definition Classes
    InMemoryActiveContractStoreActiveContractSnapshot
  41. final def prune(limit: CantonTimestamp)(implicit errorLoggingContext: ErrorLoggingContext, closeContext: CloseContext): Future[Unit]

    Prune all unnecessary data relating to events before the given timestamp.

    Prune all unnecessary data relating to events before the given timestamp.

    The meaning of "unnecessary", and whether the limit is inclusive or exclusive both depend on the particular store. The store must implement the actual pruning logic in the doPrune method.

    Definition Classes
    PrunableByTime
  42. def pruningStatus(implicit traceContext: TraceContext): Future[Option[PruningStatus]]

    Returns the latest timestamp at which pruning was started or completed.

    Returns the latest timestamp at which pruning was started or completed. For com.digitalasset.canton.pruning.PruningPhase.Started, it is guaranteed that no pruning has been run on the store after the returned timestamp. For com.digitalasset.canton.pruning.PruningPhase.Completed, it is guaranteed that the store is pruned at least up to the returned timestamp (inclusive). That is, another pruning with the returned timestamp (or earlier) has no effect on the store. Returns scala.None$ if no pruning has ever been started on the store.

    Definition Classes
    InMemoryPrunableByTimePrunableByTime
  43. val pruningStatusF: AtomicReference[Option[PruningStatus]]
    Attributes
    protected[this]
    Definition Classes
    InMemoryPrunableByTime
  44. def purgeContract(cid: LfContractId, toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Shorthand for purgeContracts(Seq(cid), toc)

    Shorthand for purgeContracts(Seq(cid), toc)

    Definition Classes
    ActiveContractStore
  45. def purgeContracts(contractIds: Seq[LfContractId], toc: TimeOfChange)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Marks the given contracts as inactive from timestamp (inclusive) onwards.

    Marks the given contracts as inactive from timestamp (inclusive) onwards.

    Unlike archival, purge can be done several times in the life of a contract. It is intended to use from the repair service.

    Definition Classes
    ActiveContractStore
  46. def purgeOrArchiveContracts(archivals: Seq[LfContractId], toc: TimeOfChange, isArchival: Boolean)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Depending on the isArchival, will archive (effect of a Daml transaction) or purge (repair service)

    Depending on the isArchival, will archive (effect of a Daml transaction) or purge (repair service)

    Definition Classes
    InMemoryActiveContractStoreActiveContractStore
  47. def snapshot(rc: RequestCounter)(implicit traceContext: TraceContext): Future[SortedMap[LfContractId, RequestCounter]]

    Returns all contracts that were active right after the given request counter, and when the contract became active for the last time before or at the given request counter.

    Returns all contracts that were active right after the given request counter, and when the contract became active for the last time before or at the given request counter.

    rc

    The request counter at which the snapshot shall be taken. Must be before the request counter that corresponds to the head cursor in the com.digitalasset.canton.participant.protocol.RequestJournal for the state com.digitalasset.canton.participant.protocol.RequestJournal.RequestState.Clean. If this precondition is violated, the returned snapshot may be inconsistent, i.e., it may omit some contracts that were ActiveContractStore.Active at the given counter and it may include contracts that were actually ActiveContractStore.Archived or ActiveContractStore.TransferredAway.

    returns

    A map from contracts to the latest request counter (no later than the given rc) when they became active again. It contains exactly those contracts that were active right after the given request counter. If a contract is created or transferred-in and archived or transferred-out at the same request counter, it does not show up in any snapshot. The map is sorted by cats.kernel.Order[com.digitalasset.canton.protocol.LfContractId].

    Definition Classes
    InMemoryActiveContractStoreActiveContractSnapshot
  48. def snapshot(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Future[SortedMap[LfContractId, CantonTimestamp]]

    Returns all contracts that were active right after the given timestamp, and when the contract became active for the last time before or at the given timestamp.

    Returns all contracts that were active right after the given timestamp, and when the contract became active for the last time before or at the given timestamp.

    timestamp

    The timestamp at which the snapshot shall be taken. Must be before the timestamp that corresponds to the head cursor in the com.digitalasset.canton.participant.protocol.RequestJournal for the state com.digitalasset.canton.participant.protocol.RequestJournal.RequestState.Clean. If this precondition is violated, the returned snapshot may be inconsistent, i.e., it may omit some contracts that were ActiveContractStore.Active at the given time and it may include contracts that were actually ActiveContractStore.Archived or ActiveContractStore.TransferredAway.

    returns

    A map from contracts to the latest timestamp (no later than the given timestamp) when they became active again. It contains exactly those contracts that were active right after the given timestamp. If a contract is created or transferred-in and archived or transferred-out at the same timestamp, it does not show up in any snapshot. The map is sorted by cats.kernel.Order[com.digitalasset.canton.protocol.LfContractId].

    Definition Classes
    InMemoryActiveContractStoreActiveContractSnapshot
  49. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  50. def toString(): String
    Definition Classes
    AnyRef → Any
  51. def transferInContract(contractId: LfContractId, toc: TimeOfChange, sourceDomain: SourceDomainId)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]
    Definition Classes
    ActiveContractStore
  52. def transferInContracts(transferIns: Seq[(LfContractId, SourceDomainId, TimeOfChange)])(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Marks the given contracts as transferred in from toc's timestamp (inclusive) onwards.

    Marks the given contracts as transferred in from toc's timestamp (inclusive) onwards.

    transferIns

    The contract IDs to transfer-in, each with its source domain and time of change.

    returns

    The future completes when the contract states have been updated. The following irregularities are reported:

    Definition Classes
    InMemoryActiveContractStoreActiveContractStore
  53. def transferOutContract(contractId: LfContractId, toc: TimeOfChange, targetDomain: TargetDomainId)(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]
    Definition Classes
    ActiveContractStore
  54. def transferOutContracts(transferOuts: Seq[(LfContractId, TargetDomainId, TimeOfChange)])(implicit traceContext: TraceContext): CheckedT[Future, AcsError, AcsWarning, Unit]

    Marks the given contracts as ActiveContractStore.TransferredAway from toc's timestamp (inclusive) onwards.

    Marks the given contracts as ActiveContractStore.TransferredAway from toc's timestamp (inclusive) onwards.

    transferOuts

    The contract IDs to transfer out, each with its target domain and time of change.

    returns

    The future completes when the contract state has been updated. The following irregularities are reported:

    Definition Classes
    InMemoryActiveContractStoreActiveContractStore
  55. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  56. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  57. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated @Deprecated
    Deprecated

Inherited from InMemoryPrunableByTime

Inherited from NamedLogging

Inherited from ActiveContractStore

Inherited from PrunableByTime

Inherited from ActiveContractSnapshot

Inherited from AnyRef

Inherited from Any

Ungrouped