Packages

trait AcsCommitmentLookup extends AnyRef

Read interface for ACS commitments, with no usage restrictions.

Linear Supertypes
AnyRef, Any
Known Subclasses
AcsCommitmentStore, DbAcsCommitmentStore, InMemoryAcsCommitmentStore
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AcsCommitmentLookup
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def getComputed(period: CommitmentPeriod, counterParticipant: ParticipantId)(implicit traceContext: TraceContext): Future[Iterable[(CommitmentPeriod, CommitmentType)]]

    Finds all stored computed commitments whose period overlaps with the given period.

    Finds all stored computed commitments whose period overlaps with the given period.

    No guarantees on the order of the returned commitments.

  2. abstract def lastComputedAndSent(implicit traceContext: TraceContext): Future[Option[CantonTimestampSecond]]

    Last locally processed timestamp.

    Last locally processed timestamp.

    Upon crash-recovery, it is safe to resubscribe to the sequencer starting after the returned timestamp.

  3. abstract def noOutstandingCommitments(beforeOrAt: CantonTimestamp)(implicit traceContext: TraceContext): Future[Option[CantonTimestamp]]

    The latest timestamp before or at the given timestamp for which no commitments are outstanding.

    The latest timestamp before or at the given timestamp for which no commitments are outstanding. It is safe to prune the domain at the returned timestamp as long as it is not before the last timestamp needed for crash recovery (see com.digitalasset.canton.participant.pruning.AcsCommitmentProcessor.safeToPrune)

    Returns None if no such tick is known.

  4. abstract def outstanding(start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId])(implicit traceContext: TraceContext): Future[Iterable[(CommitmentPeriod, ParticipantId)]]

    Inspection: find periods for which commitments are still outstanding, and from whom.

    Inspection: find periods for which commitments are still outstanding, and from whom.

    The returned periods may overlap.

  5. abstract def searchComputedBetween(start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Future[Iterable[(CommitmentPeriod, ParticipantId, CommitmentType)]]

    Inspection: search computed commitments applicable to the specified period (start/end are inclusive)

  6. abstract def searchReceivedBetween(start: CantonTimestamp, end: CantonTimestamp, counterParticipant: Option[ParticipantId] = None)(implicit traceContext: TraceContext): Future[Iterable[SignedProtocolMessage[AcsCommitment]]]

    Inspection: search received commitments applicable to the specified period (start/end are inclusive)

Concrete 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. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. def toString(): String
    Definition Classes
    AnyRef → Any
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  18. 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 AnyRef

Inherited from Any

Ungrouped