com.digitalasset.canton.participant.store.db
DbRequestJournalStore
Companion object DbRequestJournalStore
class DbRequestJournalStore extends RequestJournalStore with NamedLogging
- Alphabetic
- By Inheritance
- DbRequestJournalStore
- NamedLogging
- RequestJournalStore
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new DbRequestJournalStore(domainId: IndexedDomain, storage: DbStorage, maxItemsInSqlInClause: PositiveNumeric[Int], insertBatchAggregatorConfig: BatchAggregatorConfig, replaceBatchAggregatorConfig: BatchAggregatorConfig, enableAdditionalConsistencyChecksInOracle: Boolean, loggerFactory: NamedLoggerFactory)(implicit ec: ExecutionContext)
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: CursorPrehead[RequestCounter])(implicit traceContext: TraceContext): Future[Unit]
Sets the prehead counter for clean requests to
rcwith timestamptimestampunless it has previously been set to the same or a higher value.Sets the prehead counter for clean requests to
rcwith timestamptimestampunless it has previously been set to the same or a higher value.- Definition Classes
- RequestJournalStore
- def advancePreheadCleanToTransactionalUpdate(newPrehead: CursorPrehead[RequestCounter])(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() @HotSpotIntrinsicCandidate()
- 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
- DbRequestJournalStore → RequestJournalStore
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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
- DbRequestJournalStore → RequestJournalStore
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- implicit val getResultRequestData: GetResult[RequestData]
- implicit val getResultRequestState: GetResult[RequestState]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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
- DbRequestJournalStore → RequestJournalStore
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- DbRequestJournalStore → NamedLogging
- implicit def loggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- 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
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def preheadClean(implicit traceContext: TraceContext): Future[Option[CursorPrehead[RequestCounter]]]
Gets the prehead for the clean cursor.
Gets the prehead for the clean cursor.
- Definition Classes
- RequestJournalStore
- def prune(beforeAndIncluding: CantonTimestamp)(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.
Pre-conditions for the call:
- there must be a timestamp
tsassociated with the clean head 2. beforeAndIncluding <ts
- Definition Classes
- RequestJournalStore
- Exceptions thrown
java.lang.IllegalArgumentExceptionif the preconditions are violated.
- there must be a timestamp
- def query(rc: RequestCounter)(implicit traceContext: TraceContext): OptionT[Future, RequestData]
Find request information by request counter
Find request information by request counter
- Definition Classes
- DbRequestJournalStore → RequestJournalStore
- 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.- Definition Classes
- DbRequestJournalStore → RequestJournalStore
- def replace(rc: RequestCounter, requestTimestamp: CantonTimestamp, oldState: RequestState, 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.
- Definition Classes
- DbRequestJournalStore → RequestJournalStore
- implicit val setParameterRequestState: SetParameter[RequestState]
- 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
- DbRequestJournalStore → RequestJournalStore
- 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])