c

com.digitalasset.canton.participant.store.memory

InMemoryInFlightSubmissionStore

class InMemoryInFlightSubmissionStore extends InFlightSubmissionStore with NamedLogging

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. InMemoryInFlightSubmissionStore
  2. NamedLogging
  3. InFlightSubmissionStore
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new InMemoryInFlightSubmissionStore(loggerFactory: NamedLoggerFactory)(implicit executionContext: 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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  6. def delete(submissions: Seq[InFlightReference])(implicit traceContext: TraceContext): Future[Unit]

    Deletes the referred to in-flight submissions if there are any.

    Deletes the referred to in-flight submissions if there are any.

    If the com.digitalasset.canton.sequencing.protocol.MessageId in com.digitalasset.canton.participant.store.InFlightSubmissionStore.InFlightByMessageId is not a UUID, there cannot be a matching in-flight submission because register forces a UUID for the message ID.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  13. val loggerFactory: NamedLoggerFactory
    Attributes
    protected
    Definition Classes
    InMemoryInFlightSubmissionStore → NamedLogging
  14. implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  15. def lookup(changeIdHash: ChangeIdHash)(implicit traceContext: TraceContext): OptionT[Future, InFlightSubmission[SubmissionSequencingInfo]]

    Retrieves the in-flight submission for the given com.daml.ledger.participant.state.v2.ChangeId if one exists.

    Retrieves the in-flight submission for the given com.daml.ledger.participant.state.v2.ChangeId if one exists.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  16. def lookupEarliest(domainId: DomainId)(implicit traceContext: TraceContext): Future[Option[CantonTimestamp]]

    Returns the earliest com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout or com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime in the store, if any, for the given domain.

    Returns the earliest com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout or com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime in the store, if any, for the given domain.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  17. def lookupSequencedUptoUnordered(domainId: DomainId, sequencingTimeInclusive: CantonTimestamp)(implicit traceContext: TraceContext): Future[Seq[InFlightSubmission[SequencedSubmission]]]

    Returns all sequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime is no later than sequencingTimeInclusive.

    Returns all sequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.sequencingTime is no later than sequencingTimeInclusive.

    The in-flight submissions are not returned in any specific order.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  18. def lookupSomeMessageId(domainId: DomainId, messageId: MessageId)(implicit traceContext: TraceContext): Future[Option[InFlightSubmission[SubmissionSequencingInfo]]]

    Returns one of the in-flight submissions with the given com.digitalasset.canton.DomainId and com.digitalasset.canton.sequencing.protocol.MessageId, if any.

    Returns one of the in-flight submissions with the given com.digitalasset.canton.DomainId and com.digitalasset.canton.sequencing.protocol.MessageId, if any.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  19. def lookupUnsequencedUptoUnordered(domainId: DomainId, observedSequencingTime: CantonTimestamp)(implicit traceContext: TraceContext): Future[Seq[InFlightSubmission[UnsequencedSubmission]]]

    Returns all unsequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is no later than observedSequencingTime.

    Returns all unsequenced in-flight submissions on the given domain whose com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is no later than observedSequencingTime.

    The in-flight submissions are not returned in any specific order.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  20. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  21. def noTracingLogger: Logger
    Attributes
    protected
    Definition Classes
    NamedLogging
  22. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  23. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  24. def observeSequencing(domainId: DomainId, submissions: Map[MessageId, SequencedSubmission])(implicit traceContext: TraceContext): Future[Unit]

    Moves the submissions to the given domain with the given com.digitalasset.canton.sequencing.protocol.MessageIds from com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission to com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.

    Moves the submissions to the given domain with the given com.digitalasset.canton.sequencing.protocol.MessageIds from com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission to com.digitalasset.canton.participant.protocol.submission.SequencedSubmission.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  25. def register(submission: InFlightSubmission[UnsequencedSubmission]): EitherT[FutureUnlessShutdown, InFlightSubmission[SubmissionSequencingInfo], Unit]

    Registers the given submission as being in flight and unsequenced unless there already is an in-flight submission for the same change ID.

    Registers the given submission as being in flight and unsequenced unless there already is an in-flight submission for the same change ID.

    This method MUST NOT run concurrently with a delete query for the same change ID and message ID. When this method fails with an exception, it is unknown whether the submission was registered.

    returns

    A scala.Left$ of the existing in-flight submission with the same change ID and a different com.digitalasset.canton.sequencing.protocol.MessageId if there is any.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  26. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  27. def toString(): String
    Definition Classes
    AnyRef → Any
  28. def updateUnsequenced(changeIdHash: ChangeIdHash, submissionDomain: DomainId, messageId: MessageId, newSequencingInfo: UnsequencedSubmission)(implicit traceContext: TraceContext): Future[Unit]

    Update the in-flight submission identified by the given changeId if submissionDomain and messageId match and it is unsequenced and the existing com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is not earlier than the newSequencingInfo's com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout.

    Update the in-flight submission identified by the given changeId if submissionDomain and messageId match and it is unsequenced and the existing com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout is not earlier than the newSequencingInfo's com.digitalasset.canton.participant.protocol.submission.UnsequencedSubmission.timeout. Only the field com.digitalasset.canton.participant.protocol.submission.InFlightSubmission.sequencingInfo is updated.

    This is useful to change when and how a rejection is reported, e.g., if the submission logic decided to not send the com.digitalasset.canton.sequencing.protocol.SubmissionRequest to the sequencer after all.

    Definition Classes
    InMemoryInFlightSubmissionStore → InFlightSubmissionStore
  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 InFlightSubmissionStore

Inherited from AnyRef

Inherited from Any

Ungrouped