Packages

class TransferCoordination extends NamedLogging

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TransferCoordination
  2. NamedLogging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TransferCoordination(domainDataById: (DomainId) => Option[DomainData], inSubmissionById: (DomainId) => Option[TransferSubmissionHandle], syncCryptoApi: SyncCryptoApiProvider, 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 addTransferOutRequest(transferData: TransferData)(implicit traceContext: TraceContext): EitherT[Future, TransferProcessorError, Unit]

    Stores the given transfer data on the target domain.

  5. 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.

  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. 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 timestamp on the given domain.

    Returns a future that completes when it is safe to take an identity snapshot for the given timestamp on the given domain. scala.None$ indicates that this point has already been reached before the call. scala.Left$ if the domain is 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

  8. 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, awaitTimestamp should be preferred as it triggers the progression of time on domain by requesting a tick.

  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  10. def cryptoSnapshot(domain: DomainId, timestamp: CantonTimestamp)(implicit traceContext: TraceContext): EitherT[Future, TransferProcessorError, DomainSnapshotSyncCryptoApi]

    Returns a crypto.DomainSnapshotSyncCryptoApi for the given domain at the given timestamp.

    Returns a crypto.DomainSnapshotSyncCryptoApi for the given domain at the given timestamp. The returned future fails with java.lang.IllegalArgumentException if the domain has not progressed far enough such that it can compute the snapshot. Use awaitTimestamp to ensure progression to timestamp.

  11. 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.

  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. def getTimeProofAndSnapshot(targetDomain: DomainId)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, TransferProcessorError, (TimeProof, DomainSnapshotSyncCryptoApi)]
  16. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  19. val loggerFactory: NamedLoggerFactory
    Definition Classes
    TransferCoordinationNamedLogging
  20. implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  21. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  22. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  23. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  25. 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()
  26. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  27. def toString(): String
    Definition Classes
    AnyRef → Any
  28. 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.

  29. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  30. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  31. 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

Inherited from NamedLogging

Inherited from AnyRef

Inherited from Any

Ungrouped