com.digitalasset.canton.synchronizer.sequencing.traffic.store
TrafficPurchasedStore
Companion object TrafficPurchasedStore
trait TrafficPurchasedStore extends AutoCloseable
Maintains the history of traffic purchased entries of sequencer members.
- Alphabetic
- By Inheritance
- TrafficPurchasedStore
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def close(): Unit
- Definition Classes
- AutoCloseable
- Annotations
- @throws(classOf[java.lang.Exception])
- abstract def getInitialTimestamp(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[CantonTimestamp]]
Gets the timestamp of the last sequenced event in the snapshot the sequencer is initialized with.
- abstract def lookup(member: Member)(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[TrafficPurchased]]
Looks up the traffic purchased entries for a member.
- abstract def lookupLatestBeforeInclusive(timestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Seq[TrafficPurchased]]
Looks up the latest traffic purchased entry for all members, that were sequenced before the given timestamp (inclusive).
- abstract def maxTsO(implicit traceContext: TraceContext): FutureUnlessShutdown[Option[CantonTimestamp]]
Returns the maximum timestamp present in a member balance.
- abstract def pruneBelowExclusive(upToExclusive: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[String]
Deletes all balances for a given member, if their timestamp is strictly lower than the maximum existing timestamp for that member that is lower or equal to the provided timestamp.
Deletes all balances for a given member, if their timestamp is strictly lower than the maximum existing timestamp for that member that is lower or equal to the provided timestamp. In practice this means that we will keep enough to provide the correct balance for any timestamp above or equal the provided timestamp, even if that means not pruning the first timestamp below the provided one. Keeps at least the latest balance if it exists, even if it's in the pruning window.
- returns
text information about the data that was pruned
- abstract def setInitialTimestamp(cantonTimestamp: CantonTimestamp)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Persists the timestamp of the last sequenced event in the snapshot with which the sequencer is initialized.
Persists the timestamp of the last sequenced event in the snapshot with which the sequencer is initialized. This allows to recover from a crash just after onboarding by reading back this timestamp to tick the balance manager.
- abstract def store(trafficPurchased: TrafficPurchased)(implicit traceContext: TraceContext): FutureUnlessShutdown[Unit]
Stores the traffic purchased entry.
Stores the traffic purchased entry. Updates for which there is already a balance for that member with the same sequencing timestamp are ignored.
Concrete 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 eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- 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
- 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])