trait ContractStore extends ContractLookup
- Alphabetic
- By Inheritance
- ContractStore
- ContractLookup
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def contractCount()(implicit traceContext: TraceContext): Future[Int]
- abstract def deleteContract(id: LfContractId)(implicit traceContext: TraceContext): EitherT[Future, UnknownContract, Unit]
Removes the contract from the contract store.
- abstract def deleteDivulged(upTo: RequestCounter)(implicit traceContext: TraceContext): Future[Unit]
Deletes all divulged contracts up to a given request counter.
- abstract def deleteIgnoringUnknown(contractIds: Iterable[LfContractId])(implicit traceContext: TraceContext): Future[Unit]
Deletes multiple contracts from the contract store.
Deletes multiple contracts from the contract store.
Ignores errors due to a contract not being present in the store, fails on other errors.
- implicit abstract def ec: ExecutionContext
- Attributes
- protected
- Definition Classes
- ContractLookup
- abstract def find(filterId: Option[String], filterPackage: Option[String], filterTemplate: Option[String], limit: Int)(implicit traceContext: TraceContext): Future[List[SerializableContract]]
Debug find utility to search pcs
- abstract def logger: TracedLogger
- Attributes
- protected[store]
- Definition Classes
- ContractLookup
- abstract def lookup(id: LfContractId)(implicit traceContext: TraceContext): OptionT[Future, StoredContract]
- Definition Classes
- ContractLookup
- abstract def lookupStakeholders(ids: Set[LfContractId])(implicit traceContext: TraceContext): EitherT[Future, UnknownContracts, Map[LfContractId, Set[LfPartyId]]]
- Definition Classes
- ContractLookup
- abstract def storeCreatedContracts(requestCounter: RequestCounter, transactionId: TransactionId, creations: Seq[SerializableContract])(implicit traceContext: TraceContext): Future[Unit]
Stores contracts created by a request.
Stores contracts created by a request. If the same contract instance has been stored before, the request counter is set to the lower one.
- requestCounter
The request counter of the transaction creating the contracts.
- creations
The contracts to be created
- returns
DuplicateContract for the contracts that have been or are being inserted with different values for com.digitalasset.canton.protocol.SerializableContract.contractInstance or com.digitalasset.canton.protocol.SerializableContract.ledgerCreateTime.
- abstract def storeDivulgedContracts(requestCounter: RequestCounter, divulgences: Seq[SerializableContract])(implicit traceContext: TraceContext): Future[Unit]
Store divulged contracts.
Store divulged contracts.
- returns
DuplicateContract for the contracts that have been or are being inserted with a different contract instance or a different ledger time.
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hasActiveContracts(partyId: PartyId, contractIds: Vector[LfContractId], batchSize: Int = 10)(implicit traceContext: TraceContext): Future[Boolean]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def lookupContract(id: LfContractId)(implicit traceContext: TraceContext): OptionT[Future, SerializableContract]
- Definition Classes
- ContractLookup
- def lookupContractE(id: LfContractId)(implicit traceContext: TraceContext): EitherT[Future, UnknownContract, SerializableContract]
- Definition Classes
- ContractLookup
- def lookupE(id: LfContractId)(implicit traceContext: TraceContext): EitherT[Future, UnknownContract, StoredContract]
- Definition Classes
- ContractLookup
- def lookupLfInstance(lfId: LfContractId)(implicit traceContext: TraceContext): OptionT[Future, LfContractInst]
Yields
None(embedded in a Future) if the contract instance has not been stored or the id cannot be parsed.Yields
None(embedded in a Future) if the contract instance has not been stored or the id cannot be parsed.Discards the serialization.
- Definition Classes
- ContractLookup
- def lookupManyUncached(ids: Seq[LfContractId])(implicit traceContext: TraceContext): Future[List[Option[StoredContract]]]
- Definition Classes
- ContractLookup
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def storeCreatedContract(requestCounter: RequestCounter, transactionId: TransactionId, contract: SerializableContract)(implicit traceContext: TraceContext): Future[Unit]
- def storeDivulgedContract(requestCounter: RequestCounter, contract: SerializableContract)(implicit traceContext: TraceContext): Future[Unit]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])