class TopUpQueue extends AutoCloseable
Stores top ups in memory and provides methods to retrieve them and prune them as they become obsolete.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- TopUpQueue
- AutoCloseable
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new TopUpQueue(initialTopUps: Seq[TopUpEvent])
- initialTopUps
initial list of top ups to start with
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 addOne(topUp: TopUpEvent): Unit
Add a new top up
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def close(): Unit
- Definition Classes
- TopUpQueue → AutoCloseable
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def getAllTopUps: List[TopUpEvent]
Return a list of all the top ups without modifying the internal state.
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def getTrafficLimit(timestamp: CantonTimestamp): NonNegativeLong
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- 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
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def pruneUntilAndGetAllTopUpsFor(cantonTimestamp: CantonTimestamp): List[TopUpEvent]
Prune until currentTimestamp and return the current and all following top ups
- def pruneUntilAndGetLimitFor(timestamp: CantonTimestamp): NonNegativeLong
Same as pruneUntilAndGetTopUpFor but if no top up is found, will return NonNegativeLong.zero
- def pruneUntilAndGetTopUpFor(timestamp: CantonTimestamp): (Option[TopUpEvent], Boolean)
Get the effective top up for the provided timestamp.
Get the effective top up for the provided timestamp. Earlier top ups will be pruned and won't be accessible anymore Also return a Boolean indicating if the top up has just became effective. Used for pruning.
- 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])