class InMemoryRequestJournalStore extends RequestJournalStore with NamedLogging
- Alphabetic
- By Inheritance
- InMemoryRequestJournalStore
- NamedLogging
- RequestJournalStore
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new InMemoryRequestJournalStore(loggerFactory: NamedLoggerFactory)
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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def crashRecoveryPruningBoundInclusive(cleanSynchronizerIndexO: Option[SynchronizerIndex])(implicit traceContext: TraceContext): FutureUnlessShutdown[CantonTimestamp]
Returns an upper bound for the timestamps up to which pruning may remove data from the store (inclusive) so that crash recovery will still work.
Returns an upper bound for the timestamps up to which pruning may remove data from the store (inclusive) so that crash recovery will still work.
- Definition Classes
- RequestJournalStore
- def delete(rc: RequestCounter)(implicit traceContext: TraceContext): Future[Unit]
- 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.
Deletes all the requests with a request timestamp equal to or higher than the given request timestamp.
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- 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
Finds the request with the lowest request counter whose commit time is after the given timestamp
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- 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
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def lastRequestTimeWithRequestTimestampBeforeOrAt(requestTimestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[TimeOfRequest]]
Finds the highest request time before or equal to the given timestamp
Finds the highest request time before or equal to the given timestamp
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- InMemoryRequestJournalStore → NamedLogging
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- 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
- Definition Classes
- RequestJournalStore
- def purge()(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Purges all data from the request journal.
Purges all data from the request journal.
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- def query(rc: RequestCounter)(implicit traceContext: TraceContext): OptionT[FutureUnlessShutdown, RequestData]
Find request information by request counter
Find request information by request counter
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- 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
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.
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- def size(start: CantonTimestamp, end: Option[CantonTimestamp])(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
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def totalDirtyRequests()(implicit traceContext: TraceContext): FutureUnlessShutdown[NonNegativeInt]
Returns the number of dirty requests.
Returns the number of dirty requests.
- Definition Classes
- InMemoryRequestJournalStore → RequestJournalStore
- 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])
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])