com.digitalasset.canton.participant.protocol.conflictdetection
RequestTracker
Companion trait RequestTracker
object RequestTracker
- Alphabetic
- By Inheritance
- RequestTracker
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- final case class AcsError(error: AcsBaseError) extends RequestTrackerStoreError with Product with Serializable
- final case class CommitSetAlreadyExists(requestCounter: RequestCounter) extends CommitSetError with Product with Serializable
Returned by RequestTracker!.addCommitSet if a different commit set has already been supplied for the given request counter.
- sealed trait CommitSetError extends RequestTrackerError
Trait for errors that can occur when adding a commit set
- final case class ContractKeyJournalError(error: store.ContractKeyJournal.ContractKeyJournalError) extends RequestTrackerStoreError with Product with Serializable
- final case class InvalidCommitSet(requestCounter: RequestCounter, commitSet: CommitSet, locked: LockedStates) extends RuntimeException with Product with Serializable
The commit set tries to activate or deactivate contracts that were not locked during the activeness check.
- final case class RequestAlreadyExists(requestCounter: RequestCounter, sequencerCounter: SequencerCounter, timestamp: CantonTimestamp) extends RequestTrackerError with Product with Serializable
Returned by RequestTracker!.addRequest if the same request was added before with different parameters (as given).
- final case class RequestFutures(activenessResult: FutureUnlessShutdown[ActivenessResult], timeoutResult: FutureUnlessShutdown[TimeoutResult]) extends Product with Serializable
Case class for the futures of RequestTracker.addRequest.
Case class for the futures of RequestTracker.addRequest.
- activenessResult
The future for the ActivenessResult that the activeness check completes with the activeness result
- timeoutResult
The future for the TimeoutResult that will be completed when the request times out or a transaction result is added.
- final case class RequestNotFound(requestCounter: RequestCounter) extends ResultError with CommitSetError with Product with Serializable
The request is not (any longer) tracked by the request tracker
- sealed trait RequestTrackerError extends Product with Serializable with PrettyPrinting
Trait for errors of the request tracker
- sealed trait RequestTrackerStoreError extends Product with Serializable
Errors while writing to the stores
- final case class ResultAlreadyExists(requestCounter: RequestCounter) extends ResultError with Product with Serializable
Returned by RequestTracker!.addResult if the result has been signalled beforehand with different parameters for the same request
- sealed trait ResultError extends RequestTrackerError
Trait for errors that can occur for a result
- final case class ResultNotFound(requestCounter: RequestCounter) extends CommitSetError with Product with Serializable
Returned by RequestTracker!.addCommitSet if no result has been signalled beforehand for the request
- sealed trait TimeoutResult extends AnyRef
Indicates whether the request has timed out.
- final case class TransferStoreError(error: store.TransferStore.TransferStoreError) extends RequestTrackerStoreError with Product with Serializable
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() @IntrinsicCandidate()
- 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() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- 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])
- case object NoTimeout extends TimeoutResult with Product with Serializable
- case object Timeout extends TimeoutResult with Product with Serializable