class InMemoryContractStore extends ContractStore with NamedLogging
An in-memory contract store. This class is thread-safe.
- Alphabetic
- By Inheritance
- InMemoryContractStore
- NamedLogging
- ContractStore
- ContractLookup
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new InMemoryContractStore(loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)
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()
- def contractCount()(implicit traceContext: TraceContext): Future[Int]
- Definition Classes
- InMemoryContractStore → ContractStore
- def deleteContract(id: LfContractId)(implicit traceContext: TraceContext): EitherT[Future, UnknownContract, Unit]
Removes the contract from the contract store.
Removes the contract from the contract store.
- Definition Classes
- InMemoryContractStore → ContractStore
- def deleteDivulged(upTo: RequestCounter)(implicit traceContext: TraceContext): Future[Unit]
Deletes all divulged contracts up to a given request counter.
Deletes all divulged contracts up to a given request counter.
- Definition Classes
- InMemoryContractStore → ContractStore
- def deleteIgnoringUnknown(ids: 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.
- Definition Classes
- InMemoryContractStore → ContractStore
- implicit val ec: ExecutionContext
- Attributes
- protected
- Definition Classes
- InMemoryContractStore → ContractLookup
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- 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
Debug find utility to search pcs
- Definition Classes
- InMemoryContractStore → ContractStore
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hasActiveContracts(partyId: PartyId, contractIds: Iterator[LfContractId], batchSize: Int = 10)(implicit traceContext: TraceContext): Future[Boolean]
- Definition Classes
- ContractStore
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected[participant.store]
- Definition Classes
- InMemoryContractStore → NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- InMemoryContractStore → NamedLogging
- def lookup(id: LfContractId)(implicit traceContext: TraceContext): OptionT[Future, StoredContract]
- Definition Classes
- InMemoryContractStore → ContractLookup
- 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): EitherT[Future, LfContractId, List[StoredContract]]
- Definition Classes
- ContractLookup
- def lookupStakeholders(ids: Set[LfContractId])(implicit traceContext: TraceContext): EitherT[Future, UnknownContracts, Map[LfContractId, Set[LfPartyId]]]
- Definition Classes
- InMemoryContractStore → ContractLookup
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- 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]
- Definition Classes
- ContractStore
- def storeCreatedContracts(requestCounter: RequestCounter, creations: Seq[WithTransactionId[SerializableContract]])(implicit traceContext: TraceContext): Future[Unit]
Stores contracts created by a request.
Stores contracts created by a request. Assumes the contract data has been authenticated against the contract id using com.digitalasset.canton.participant.protocol.SerializableContractAuthenticator. If the same contract instance has been stored before, the fields not covered by the contract id authentication will be updated.
- requestCounter
The request counter of the transaction creating the contracts.
- creations
The contracts to be created together with the transaction id
- Definition Classes
- InMemoryContractStore → ContractStore
- def storeDivulgedContract(requestCounter: RequestCounter, contract: SerializableContract)(implicit traceContext: TraceContext): Future[Unit]
- Definition Classes
- ContractStore
- def storeDivulgedContracts(requestCounter: RequestCounter, divulgences: Seq[SerializableContract])(implicit traceContext: TraceContext): Future[Unit]
Store divulged contracts.
Store divulged contracts. Assumes the contract data has been authenticated against the contract id using com.digitalasset.canton.participant.protocol.SerializableContractAuthenticator.
If the same contract instance has been stored before, the fields not covered by the contract id authentication will be updated. The method will however not override a contract that has previously been stored as created contract.
- Definition Classes
- InMemoryContractStore → ContractStore
- 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])