com.digitalasset.canton.domain.sequencing.sequencer
SequencerPruningStatus
Companion object SequencerPruningStatus
case class SequencerPruningStatus(lowerBound: CantonTimestamp, now: CantonTimestamp, members: Seq[SequencerMemberStatus]) extends HasProtoV0[admin.v0.SequencerPruningStatus] with Product with Serializable
Pruning status of a Sequencer.
- lowerBound
the earliest timestamp that can be read
- now
the current time of the sequencer clock
- members
details of registered members
- Alphabetic
- By Inheritance
- SequencerPruningStatus
- Serializable
- Product
- Equals
- HasProtoV0
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SequencerPruningStatus(lowerBound: CantonTimestamp, now: CantonTimestamp, members: Seq[SequencerMemberStatus])
- lowerBound
the earliest timestamp that can be read
- now
the current time of the sequencer clock
- members
details of registered members
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 clientsPreventingPruning(timestamp: CantonTimestamp): SequencerClients
List clients that would need to be disabled to allow pruning at the given timestamp.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- lazy val disabledClients: SequencerClients
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val lowerBound: CantonTimestamp
- val members: Seq[SequencerMemberStatus]
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val now: CantonTimestamp
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- lazy val safePruningTimestamp: CantonTimestamp
Using the member details, calculate based on their acknowledgements when is the latest point we can safely prune without losing any data that may still be read.
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toProtoV0: admin.v0.SequencerPruningStatus
Yields the proto representation of the class.
Yields the proto representation of the class.
Subclasses should make this method public by default, as this supports composing proto serializations. Keep it protected, if there are good reasons for it (e.g. com.digitalasset.canton.serialization.MemoizedEvidence).
- Definition Classes
- SequencerPruningStatus → HasProtoV0
- def unauthenticatedMembersToDisable(retentionPeriod: NonNegativeFiniteDuration): Set[Member]
- 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])