class InMemoryReassignmentStore extends ReassignmentStore with NamedLogging
- Alphabetic
- By Inheritance
- InMemoryReassignmentStore
- NamedLogging
- ReassignmentStore
- ReassignmentLookup
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new InMemoryReassignmentStore(synchronizer: Target[SynchronizerId], loggerFactory: NamedLoggerFactory)(implicit executionContext: 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 addAssignmentDataIfAbsent(assignmentData: AssignmentData)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, ReassignmentStoreError, Unit]
In certain special cases, where an assignment starts before the unassignment has had a chance to write the reassignment data (either due to slow processing on the source synchronizer or simply because the participant is disconnected from the source synchronizer), we want to insert assignment data to allow the assignment to complete.
In certain special cases, where an assignment starts before the unassignment has had a chance to write the reassignment data (either due to slow processing on the source synchronizer or simply because the participant is disconnected from the source synchronizer), we want to insert assignment data to allow the assignment to complete.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentStore
- def addReassignmentsOffsets(offsets: Map[ReassignmentId, ReassignmentGlobalOffset])(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, ReassignmentStoreError, Unit]
Adds the given offsets to the reassignment data in the store.
Adds the given offsets to the reassignment data in the store.
The same offset can be added any number of times.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentStore
- def addReassignmentsOffsets(events: Seq[(ReassignmentId, ReassignmentGlobalOffset)])(implicit executionContext: ExecutionContext, traceContext: TraceContext): EitherT[FutureUnlessShutdown, ReassignmentStoreError, Unit]
Adds the given com.digitalasset.canton.data.Offset for the reassignment events to the reassignment data in the store, provided that the reassignment data has previously been stored.
Adds the given com.digitalasset.canton.data.Offset for the reassignment events to the reassignment data in the store, provided that the reassignment data has previously been stored.
The same com.digitalasset.canton.data.Offset can be added any number of times.
- Definition Classes
- ReassignmentStore
- def addUnassignmentData(reassignmentData: UnassignmentData)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, ReassignmentStoreError, Unit]
Adds the reassignment to the store.
Adds the reassignment to the store.
Calls to this method are idempotent, independent of the order. Differences in protocol.reassignment.UnassignmentData!.unassignmentResult between two calls are ignored if the field is scala.None$ in one of the calls. If applicable, the field content is merged.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentStore
- Exceptions thrown
java.lang.IllegalArgumentExceptionif the reassignment's target synchronizer is not the synchronizer this ReassignmentStore belongs to.
- def addUnassignmentResult(unassignmentResult: DeliveredUnassignmentResult)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, ReassignmentStoreError, Unit]
Adds the given com.digitalasset.canton.protocol.messages.ConfirmationResultMessage to the reassignment data in the store, provided that the reassignment data has previously been stored.
Adds the given com.digitalasset.canton.protocol.messages.ConfirmationResultMessage to the reassignment data in the store, provided that the reassignment data has previously been stored.
The same com.digitalasset.canton.protocol.messages.ConfirmationResultMessage can be added any number of times. This includes unassignment results that are in the protocol.reassignment.UnassignmentData!.unassignmentResult added with addUnassignmentData.
- unassignmentResult
The unassignment result to add
- returns
ReassignmentStore.UnknownReassignmentId if the reassignment has not previously been added with addUnassignmentData. ReassignmentStore.UnassignmentResultAlreadyExists if a different unassignment result for the same reassignment request has been added before, including as part of addUnassignmentData.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentStore
- 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()
- def completeReassignment(reassignmentId: ReassignmentId, ts: CantonTimestamp)(implicit traceContext: TraceContext): CheckedT[FutureUnlessShutdown, Nothing, ReassignmentStoreError, Unit]
Marks the reassignment as completed, i.e., an assignment request was committed.
Marks the reassignment as completed, i.e., an assignment request was committed. If the reassignment has already been completed then a ReassignmentStore.ReassignmentAlreadyCompleted is reported, and the com.digitalasset.canton.data.CantonTimestamp of the completion is not changed from the old value.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentStore
- def deleteCompletionsSince(criterionInclusive: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Removes all completions of reassignments that have been triggered by requests with at least the given timestamp.
Removes all completions of reassignments that have been triggered by requests with at least the given timestamp. This method must not be called concurrently with completeReassignment, but may be called concurrently with addUnassignmentData and addUnassignmentResult.
Therefore, this method need not be linearizable w.r.t. completeReassignment. For example, if two requests at
ts1andts2complete two reassignments while deleteCompletionsSince is running for somets <= ts1, ts2, then there are no guarantees which of the completions atts1andts2remain.- Definition Classes
- InMemoryReassignmentStore → ReassignmentStore
- def deleteReassignment(reassignmentId: ReassignmentId)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Removes the reassignment from the store, when the unassignment request is rejected or the reassignment is pruned.
Removes the reassignment from the store, when the unassignment request is rejected or the reassignment is pruned.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentStore
- 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 findAfter(requestAfter: Option[(CantonTimestamp, Source[SynchronizerId])], limit: Int)(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[UnassignmentData]]
Find utility to look for in-flight reassignments.
Find utility to look for in-flight reassignments. Reassignments are ordered by the tuple (request timestamp, source synchronizer id), ie reassignments are ordered by request timestamps and ties are broken with lexicographic ordering on synchronizer ids.
The ordering here has been chosen to allow a participant to fetch all the pending reassignments. The ordering has to be consistent accross calls and uniquely identify a pending reassignment, but is otherwise arbitrary.
- requestAfter
optionally, specify a strict lower bound for the reassignments returned, according to the (request timestamp, source synchronizer id) ordering
- limit
limit the number of results
- Definition Classes
- InMemoryReassignmentStore → ReassignmentLookup
- def findContractReassignmentId(contractIds: Seq[LfContractId], sourceSynchronizer: Option[Source[SynchronizerId]], unassignmentTs: Option[CantonTimestamp], completionTs: Option[CantonTimestamp])(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[LfContractId, Seq[ReassignmentId]]]
Queries the reassignment ids for the given contract ids.
Queries the reassignment ids for the given contract ids. Optional filtering by unassignment and completion (assignment) timestamps, and by source synchronizer.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentLookup
- def findEarliestIncomplete()(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[(Offset, ReassignmentId, Target[SynchronizerId])]]
Find utility to look for the earliest incomplete reassignment w.r.t.
Find utility to look for the earliest incomplete reassignment w.r.t. the ledger end. If an incomplete reassignment exists, the method returns the global offset of the incomplete reassignment for either the unassignment or the assignment, whichever of these is not null, the reassignment id and the target synchronizer id. It returns None if there is no incomplete reassignment (either because all reassignments are complete or are in-flight, or because there are no reassignments), or the reassignment table is empty.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentLookup
- def findIncomplete(sourceSynchronizer: Option[Source[SynchronizerId]], validAt: Offset, stakeholders: Option[NonEmpty[Set[LfPartyId]]], limit: NonNegativeInt)(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[IncompleteReassignmentData]]
Find utility to look for incomplete reassignments.
Find utility to look for incomplete reassignments. Reassignments are ordered by global offset.
A reassignment
tis considered as incomplete at offsetvalidAtif only one of the two reassignment events was emitted on the indexer atvalidAt. That is, one of the following hold:- Only unassignment was emitted
t.unassignmentGlobalOffsetis smaller or equal tovalidAtt.assignmentGlobalOffsetis null or greater thanvalidAt2. Only assignment was emittedt.assignmentGlobalOffsetis smaller or equal tovalidAtt.unassignmentGlobalOffsetis null or greater thanvalidAt
In particular, for a reassignment to be considered incomplete at
validAt, then exactly one of the two offsets (unassignmentGlobalOffset, assignmentGlobalOffset) is not null and smaller or equal tovalidAt.- sourceSynchronizer
if empty, select only reassignments whose source synchronizer matches the given one
- validAt
select only reassignments that are successfully unassigned
- stakeholders
if non-empty, select only reassignments of contracts whose set of stakeholders intersects
stakeholders.- limit
limit the number of results
- Definition Classes
- InMemoryReassignmentStore → ReassignmentLookup
- Only unassignment was emitted
- def findReassignmentEntry(reassignmentId: ReassignmentId)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, UnknownReassignmentId, ReassignmentEntry]
- Definition Classes
- InMemoryReassignmentStore → ReassignmentLookup
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def listInFlightReassignmentIds()(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[ReassignmentId]]
- Definition Classes
- InMemoryReassignmentStore → ReassignmentLookup
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Attributes
- protected
- Definition Classes
- InMemoryReassignmentStore → NamedLogging
- def lookup(reassignmentId: ReassignmentId)(implicit traceContext: TraceContext): EitherT[FutureUnlessShutdown, ReassignmentLookupError, UnassignmentData]
Looks up the given in-flight reassignment and returns the data associated with the reassignment.
Looks up the given in-flight reassignment and returns the data associated with the reassignment.
- returns
scala.Left$(ReassignmentStore.UnknownReassignmentId) if the reassignment is unknown; scala.Left$(ReassignmentStore.ReassignmentCompleted) if the reassignment has already been completed.
- Definition Classes
- InMemoryReassignmentStore → ReassignmentLookup
- 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()
- 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])