c

com.digitalasset.canton.participant.store.memory

InMemoryRequestJournalStore

class InMemoryRequestJournalStore extends RequestJournalStore with NamedLogging

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

Instance Constructors

  1. new InMemoryRequestJournalStore(loggerFactory: NamedLoggerFactory)

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 advancePreheadCleanTo(newPrehead: RequestCounterCursorPrehead)(implicit traceContext: TraceContext, callerCloseContext: CloseContext): Future[Unit]

    Sets the prehead counter for clean requests to rc with timestamp timestamp unless it has previously been set to the same or a higher value.

    Sets the prehead counter for clean requests to rc with timestamp timestamp unless it has previously been set to the same or a higher value.

    Definition Classes
    RequestJournalStore
  5. def advancePreheadCleanToTransactionalUpdate(newPrehead: RequestCounterCursorPrehead)(implicit traceContext: TraceContext): TransactionalStoreUpdate

    advancePreheadCleanTo as a com.digitalasset.canton.resource.TransactionalStoreUpdate

  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  8. def delete(rc: RequestCounter)(implicit traceContext: TraceContext): Future[Unit]
  9. def deleteSince(fromInclusive: RequestCounter)(implicit traceContext: TraceContext): Future[Unit]

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

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

    Definition Classes
    InMemoryRequestJournalStoreRequestJournalStore
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  12. implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
    Attributes
    protected
    Definition Classes
    NamedLogging
  13. def firstRequestWithCommitTimeAfter(commitTimeExclusive: CantonTimestamp)(implicit traceContext: TraceContext): Future[Option[RequestData]]

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

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

    Definition Classes
    InMemoryRequestJournalStoreRequestJournalStore
  14. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  16. def insert(data: RequestData)(implicit traceContext: TraceContext): Future[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

    Definition Classes
    InMemoryRequestJournalStoreRequestJournalStore
  17. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  18. def logger: TracedLogger
    Attributes
    protected
    Definition Classes
    NamedLogging
  19. val loggerFactory: NamedLoggerFactory
    Attributes
    protected
    Definition Classes
    InMemoryRequestJournalStoreNamedLogging
  20. implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
    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() @IntrinsicCandidate()
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  25. def preheadClean(implicit traceContext: TraceContext): Future[Option[RequestCounterCursorPrehead]]

    Gets the prehead for the clean cursor.

    Gets the prehead for the clean cursor.

    Definition Classes
    RequestJournalStore
  26. def prune(beforeAndIncluding: CantonTimestamp, bypassAllSanityChecks: Boolean)(implicit traceContext: TraceContext): Future[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.

    beforeAndIncluding

    inclusive timestamp to prune up to

    bypassAllSanityChecks

    force if true, bypass all pre-condition sanity checks Pre-conditions for the call unless bypassAllSanityChecks is true:

    1. there must be a timestamp ts associated with the clean head 2. beforeAndIncluding < ts
    Definition Classes
    RequestJournalStore
    Exceptions thrown

    java.lang.IllegalArgumentException if the preconditions are violated.

  27. def query(rc: RequestCounter)(implicit traceContext: TraceContext): OptionT[Future, RequestData]

    Find request information by request counter

    Find request information by request counter

    Definition Classes
    InMemoryRequestJournalStoreRequestJournalStore
  28. def repairRequests(fromInclusive: RequestCounter)(implicit traceContext: TraceContext): Future[Seq[RequestData]]

    Returns all repair requests at or after fromInclusive in ascending order.

    Returns all repair requests at or after fromInclusive in ascending order. This method must not be called concurrently with other methods of the store.

    Definition Classes
    InMemoryRequestJournalStoreRequestJournalStore
  29. def replace(rc: RequestCounter, requestTimestamp: CantonTimestamp, newState: RequestState, commitTime: Option[CantonTimestamp])(implicit traceContext: TraceContext): EitherT[Future, 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.

    Definition Classes
    InMemoryRequestJournalStoreRequestJournalStore
  30. def size(start: CantonTimestamp, end: Option[CantonTimestamp])(implicit traceContext: TraceContext): Future[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

    Definition Classes
    InMemoryRequestJournalStoreRequestJournalStore
  31. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  32. def toString(): String
    Definition Classes
    AnyRef → Any
  33. def totalDirtyRequests()(implicit traceContext: TraceContext): Future[Int]

    Returns the number of dirty requests.

    Returns the number of dirty requests.

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

Inherited from NamedLogging

Inherited from RequestJournalStore

Inherited from AnyRef

Inherited from Any

Ungrouped