final case class LedgerTimeModel(avgTransactionLatency: Duration, minSkew: Duration, maxSkew: Duration) extends Product with Serializable
The ledger time model and associated validations. Some values are given by constructor args; others are derived.
- avgTransactionLatency
The expected average latency of a transaction, i.e., the average time from submitting the transaction to a write service and the transaction being assigned a record time.
- minSkew
The minimum skew between ledger time and record time: lt_TX >= rt_TX - minSkew
- maxSkew
The maximum skew between ledger time and record time: lt_TX <= rt_TX + maxSkew
- Exceptions thrown
java.lang.IllegalArgumentExceptionif the parameters aren't valid
- Alphabetic
- By Inheritance
- LedgerTimeModel
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new LedgerTimeModel(avgTransactionLatency: Duration, minSkew: Duration, maxSkew: Duration)
- avgTransactionLatency
The expected average latency of a transaction, i.e., the average time from submitting the transaction to a write service and the transaction being assigned a record time.
- minSkew
The minimum skew between ledger time and record time: lt_TX >= rt_TX - minSkew
- maxSkew
The maximum skew between ledger time and record time: lt_TX <= rt_TX + maxSkew
- Exceptions thrown
java.lang.IllegalArgumentExceptionif the parameters aren't valid
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
- val avgTransactionLatency: Duration
- def checkTime(ledgerTime: Timestamp, recordTime: Timestamp): Either[OutOfRange, Unit]
Verifies whether the given ledger time and record time are valid under the ledger time model.
Verifies whether the given ledger time and record time are valid under the ledger time model. In particular, checks the skew condition: rt_TX - s_min <= lt_TX <= rt_TX + s_max.
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- 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
- def maxLedgerTime(recordTime: Timestamp): Timestamp
- def maxRecordTime(ledgerTime: Timestamp): Timestamp
- val maxSkew: Duration
- def minLedgerTime(recordTime: Timestamp): Timestamp
- def minRecordTime(ledgerTime: Timestamp): Timestamp
- val minSkew: Duration
- 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()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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])