trait RequestJournalStore extends AnyRef
- Alphabetic
- By Inheritance
- RequestJournalStore
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract 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.
- abstract 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
- abstract 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
- abstract def query(rc: RequestCounter)(implicit traceContext: TraceContext): OptionT[Future, RequestData]
Find request information by request counter
- abstract def repairRequests(fromInclusive: RequestCounter)(implicit traceContext: TraceContext): Future[Seq[RequestData]]
Returns all repair requests at or after
fromInclusivein ascending order.Returns all repair requests at or after
fromInclusivein ascending order. This method must not be called concurrently with other methods of the store. - abstract 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
oldStateand the providedrequestTimestampmatches the stored timestamp, or if the current state is already the new state. If so, the state gets replaced withnewStateandcommitTime. IfcommitTimeis 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.
- abstract def size(start: CantonTimestamp = CantonTimestamp.Epoch, end: Option[CantonTimestamp] = None)(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
- abstract def totalDirtyRequests()(implicit traceContext: TraceContext): Future[Int]
Returns the number of dirty requests.
Concrete 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
- def advancePreheadCleanTo(newPrehead: RequestCounterCursorPrehead)(implicit traceContext: TraceContext, callerCloseContext: CloseContext): Future[Unit]
Sets the prehead counter for clean requests to
rcwith timestamptimestampunless it has previously been set to the same or a higher value. - def advancePreheadCleanToTransactionalUpdate(newPrehead: RequestCounterCursorPrehead)(implicit traceContext: TraceContext): TransactionalStoreUpdate
advancePreheadCleanTo as a com.digitalasset.canton.resource.TransactionalStoreUpdate
- 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()
- def preheadClean(implicit traceContext: TraceContext): Future[Option[RequestCounterCursorPrehead]]
Gets the prehead for the clean cursor.
- 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
bypassAllSanityChecksis true:- there must be a timestamp
tsassociated with the clean head 2. beforeAndIncluding <ts
- there must be a timestamp
- Exceptions thrown
java.lang.IllegalArgumentExceptionif the preconditions are violated.
- 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])