com.digitalasset.canton.platform.store.backend
ParameterStorageBackend
Companion object ParameterStorageBackend
trait ParameterStorageBackend extends AnyRef
- Alphabetic
- By Inheritance
- ParameterStorageBackend
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def initializeParameters(params: IdentityParams, loggerFactory: NamedLoggerFactory)(connection: Connection): Unit
Initializes the parameters table and verifies or updates ledger identity parameters.
Initializes the parameters table and verifies or updates ledger identity parameters. This method is idempotent:
- If no identity parameters are stored, then they are set to the given value.
- If identity parameters are stored, then they are compared to the given ones.
- Ledger identity parameters are written at most once, and are never overwritten. No significant CPU load, mostly blocking JDBC communication with the database backend.
This method is NOT safe to call concurrently.
- abstract def ledgerEnd(connection: Connection): LedgerEnd
Query the current ledger end, read from the parameters table.
Query the current ledger end, read from the parameters table. No significant CPU load, mostly blocking JDBC communication with the database backend.
- connection
to be used to get the LedgerEnd
- returns
the current LedgerEnd
- abstract def ledgerIdentity(connection: Connection): Option[IdentityParams]
Returns the ledger identity parameters, or None if the database hasn't been initialized yet.
- abstract def participantAllDivulgedContractsPrunedUpToInclusive(connection: Connection): Option[Offset]
- abstract def prunedUpToInclusive(connection: Connection): Option[Offset]
- abstract def updateLedgerEnd(ledgerEnd: LedgerEnd)(connection: Connection): Unit
This method is used to update the new observable ledger end.
This method is used to update the new observable ledger end. No significant CPU load, mostly blocking JDBC communication with the database backend.
- connection
to be used when updating the parameters table
- abstract def updatePrunedAllDivulgedContractsUpToInclusive(prunedUpToInclusive: Offset)(connection: Connection): Unit
- abstract def updatePrunedUptoInclusive(prunedUpToInclusive: Offset)(connection: Connection): Unit
Part of pruning process, this needs to be in the same transaction as the other pruning related database operations
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() @IntrinsicCandidate()
- 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() @IntrinsicCandidate()
- 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()
- 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])