class AcsInspection extends AnyRef
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- AcsInspection
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new AcsInspection(synchronizerId: SynchronizerId, activeContractStore: ActiveContractStore, contractStore: ContractStore, ledgerApiStore: Eval[LedgerApiStore])
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
- val activeContractStore: ActiveContractStore
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def checkOffboardingSnapshot(participantId: ParticipantId, offboardedParties: Set[LfPartyId], allStakeholders: Set[LfPartyId], snapshotToc: TimeOfChange, topologyClient: SynchronizerTopologyClient)(implicit ec: ExecutionContext, traceContext: TraceContext): EitherT[FutureUnlessShutdown, AcsInspectionError, Unit]
Check that the ACS snapshot does not contain contracts that are still needed on the participant.
Check that the ACS snapshot does not contain contracts that are still needed on the participant. In the context of party offboarding, we want to avoid purging contracts that are needed for other parties hosted on the participant.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- val contractStore: ContractStore
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def findContractPayloads(contractIds: NonEmpty[Seq[LfContractId]], limit: Int)(implicit traceContext: TraceContext): FutureUnlessShutdown[Map[LfContractId, SerializableContract]]
- def findContracts(exactId: Option[String], filterPackage: Option[String], filterTemplate: Option[String], limit: Int)(implicit traceContext: TraceContext, ec: ExecutionContext): FutureUnlessShutdown[List[(Boolean, SerializableContract)]]
- def forEachVisibleActiveContract(synchronizerId: SynchronizerId, parties: Set[LfPartyId], timeOfSnapshotO: Option[TimeOfChange], skipCleanTocCheck: Boolean = false)(f: (SerializableContract, ReassignmentCounter) => Either[AcsInspectionError, Unit])(implicit traceContext: TraceContext, ec: ExecutionContext): EitherT[FutureUnlessShutdown, AcsInspectionError, Option[(Set[LfPartyId], TimeOfChange)]]
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def getCurrentSnapshot()(implicit traceContext: TraceContext, ec: ExecutionContext): FutureUnlessShutdown[Option[AcsSnapshot[SortedMap[LfContractId, (TimeOfChange, ReassignmentCounter)]]]]
Get the current snapshot
Get the current snapshot
- returns
A snapshot (with its timestamp) or None if no clean timestamp is known
- def hasActiveContracts(partyId: PartyId)(implicit traceContext: TraceContext, ec: ExecutionContext): FutureUnlessShutdown[Boolean]
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isSignatoryOnActiveContracts(partyId: PartyId)(implicit traceContext: TraceContext, ec: ExecutionContext): FutureUnlessShutdown[Boolean]
- val ledgerApiStore: Eval[LedgerApiStore]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- 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])