com.digitalasset.canton.participant.protocol.transfer
TransferCoordination
Companion object TransferCoordination
class TransferCoordination extends NamedLogging
- Alphabetic
- By Inheritance
- TransferCoordination
- NamedLogging
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new TransferCoordination(domainDataById: (DomainId) => Option[DomainData], inSubmissionById: (DomainId) => Option[TransferSubmissionHandle], syncCryptoApi: SyncCryptoApiProvider, 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
- def addTransferOutRequest(transferData: TransferData)(implicit traceContext: TraceContext): EitherT[Future, TransferProcessorError, Unit]
Stores the given transfer data on the target domain.
- def addTransferOutResult(domain: DomainId, transferOutResult: DeliveredTransferOutResult)(implicit traceContext: TraceContext): EitherT[Future, TransferProcessorError, Unit]
Adds the transfer-out result to the transfer stored on the given domain.
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def awaitTimestamp(domain: DomainId, timestamp: CantonTimestamp, waitForEffectiveTime: Boolean)(implicit traceContext: TraceContext): Either[TransferProcessorError, Option[Future[Unit]]]
Returns a future that completes when it is safe to take an identity snapshot for the given
timestampon the givendomain.Returns a future that completes when it is safe to take an identity snapshot for the given
timestampon the givendomain. scala.None$ indicates that this point has already been reached before the call. scala.Left$ if thedomainis unknown or the participant is not connected to the domain.- waitForEffectiveTime
if set to true, we'll wait for t+epsilon, which means we'll wait until we have observed the sequencing time t
- def awaitTransferOutTimestamp(domain: DomainId, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): Either[UnknownDomain, Future[Unit]]
Returns a future that completes when a snapshot can be taken on the given domain for the given timestamp.
Returns a future that completes when a snapshot can be taken on the given domain for the given timestamp.
This is used when a transfer-in blocks for the identity state at the transfer-out. For more general uses,
awaitTimestampshould be preferred as it triggers the progression of time ondomainby requesting a tick. - def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def cryptoSnapshot(domain: DomainId, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): EitherT[Future, TransferProcessorError, DomainSnapshotSyncCryptoApi]
Returns a crypto.DomainSnapshotSyncCryptoApi for the given
domainat the given timestamp.Returns a crypto.DomainSnapshotSyncCryptoApi for the given
domainat the given timestamp. The returned future fails with java.lang.IllegalArgumentException if thedomainhas not progressed far enough such that it can compute the snapshot. Use awaitTimestamp to ensure progression totimestamp. - def deleteTransfer(targetDomain: DomainId, transferId: TransferId)(implicit traceContext: TraceContext): EitherT[Future, TransferProcessorError, Unit]
Removes the given com.digitalasset.canton.protocol.TransferId from the given com.digitalasset.canton.topology.DomainId's store.TransferStore.
- 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 getTimeProofAndSnapshot(targetDomain: DomainId)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, TransferProcessorError, (TimeProof, DomainSnapshotSyncCryptoApi)]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- TransferCoordination → NamedLogging
- implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- 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 recentTimeProof(domain: DomainId): EitherT[FutureUnlessShutdown, TransferProcessorError, TimeProof]
Returns a recent time proof received from the given domain.
Returns a recent time proof received from the given domain.
- Annotations
- @SuppressWarnings()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def transferIn(id: DomainId, partyId: LfPartyId, transferId: TransferId)(implicit traceContext: TraceContext): EitherT[Future, TransferProcessorError, SubmissionResult]
Submits a transfer in.
Submits a transfer in. Used by the TransferOutProcessingSteps to automatically trigger the submission of a transfer in after the exclusivity timeout.
- 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])