Packages

trait RequestJournalStore extends AnyRef

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RequestJournalStore
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def deleteSinceRequestTimestamp(fromInclusive: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]

    Deletes all the requests with a request timestamp equal to or higher than the given request timestamp.

  2. abstract def firstRequestWithCommitTimeAfter(commitTimeExclusive: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[RequestData]]

    Finds the request with the lowest request counter whose commit time is after the given timestamp

  3. abstract def insert(data: RequestData)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]

    Adds the initial request information to the store.

    Adds the initial request information to the store.

    returns

    A failed future, if a request is inserted more than once with differing data

  4. abstract def lastRequestTimeWithRequestTimestampBeforeOrAt(requestTimestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[TimeOfRequest]]

    Finds the highest request time before or equal to the given timestamp

  5. abstract def purge()(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]

    Purges all data from the request journal.

  6. abstract def query(rc: RequestCounter)(implicit traceContext: TraceContext): OptionT[FutureUnlessShutdown, RequestData]

    Find request information by request counter

  7. abstract def replace(rc: RequestCounter, requestTimestamp: CantonTimestamp, newState: RequestState, commitTime: Option[CantonTimestamp])(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, RequestJournalStoreError, Unit]

    Replaces the state of the request.

    Replaces the state of the request. The operation will only succeed if the current state is equal to the given oldState and the provided requestTimestamp matches the stored timestamp, or if the current state is already the new state. If so, the state gets replaced with newState and commitTime. If commitTime is scala.None$, the commit time will not be modified.

    The returned future may fail with a java.util.ConcurrentModificationException if the store detects a concurrent modification.

    requestTimestamp

    The sequencing time of the request.

  8. abstract def size(start: CantonTimestamp = CantonTimestamp.Epoch, end: Option[CantonTimestamp] = None)(implicit traceContext: TraceContext): FutureUnlessShutdown[Int]

    Counts requests whose timestamps lie between the given timestamps (inclusive).

    Counts requests whose timestamps lie between the given timestamps (inclusive).

    start

    Count all requests after or at the given timestamp

    end

    Count all requests before or at the given timestamp; use None to impose no upper limit

  9. abstract def totalDirtyRequests()(implicit traceContext: TraceContext): FutureUnlessShutdown[NonNegativeInt]

    Returns the number of dirty requests.

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]) @IntrinsicCandidate() @native()
  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
    @IntrinsicCandidate() @native()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  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
    @IntrinsicCandidate() @native()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  14. def prune(beforeInclusive: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]

    Deletes all request counters at or before the given timestamp.

    Deletes all request counters at or before the given timestamp. Calls to this method are idempotent, independent of the order.

    beforeInclusive

    inclusive timestamp to prune up to

  15. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  18. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  19. 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

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped