trait MeteringStorageWriteBackend extends AnyRef
- Alphabetic
- By Inheritance
- MeteringStorageWriteBackend
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def allParticipantMetering()(connection: Connection): Vector[ParticipantMetering]
Test Only - will be removed once reporting can be based if participant metering
- abstract def deleteTransactionMetering(from: Offset, to: Offset)(connection: Connection): Unit
This method will delete transaction metering records between the from offset (exclusive) and the to offset (inclusive).
This method will delete transaction metering records between the from offset (exclusive) and the to offset (inclusive). It is called following aggregation.
- abstract def insertParticipantMetering(metering: Vector[ParticipantMetering])(connection: Connection): Unit
- abstract def selectTransactionMetering(from: Offset, to: Offset)(connection: Connection): Map[ApplicationId, Int]
This method will return all transaction metering records between the from offset (exclusive) and the to offset (inclusive).
This method will return all transaction metering records between the from offset (exclusive) and the to offset (inclusive). It is called prior to aggregation.
- abstract def transactionMeteringMaxOffset(from: Offset, to: Timestamp)(connection: Connection): Option[Offset]
This method will return the maximum offset of the transaction_metering record which has an offset greater than the from offset and a timestamp prior to the to timestamp, if any.
This method will return the maximum offset of the transaction_metering record which has an offset greater than the from offset and a timestamp prior to the to timestamp, if any.
Note that the offset returned may not have been fully ingested. This is to allow the metering to wait if there are still un-fully ingested records withing the time window.
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]) @native() @HotSpotIntrinsicCandidate()
- 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
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- 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])