c
com.digitalasset.canton.platform.store.backend.common
EventStorageBackendTemplate
Companion object EventStorageBackendTemplate
abstract class EventStorageBackendTemplate extends EventStorageBackend with NamedLogging
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- EventStorageBackendTemplate
- NamedLogging
- EventStorageBackend
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new EventStorageBackendTemplate(queryStrategy: QueryStrategy, ledgerEndCache: LedgerEndCache, stringInterning: StringInterning, participantAllDivulgedContractsPrunedUpToInclusive: (Connection) => Option[Offset], loggerFactory: NamedLoggerFactory)
Abstract Value Members
- abstract def isPruningOffsetValidAgainstMigration(pruneUpToInclusive: Offset, pruneAllDivulgedContracts: Boolean, connection: Connection): Boolean
- Definition Classes
- EventStorageBackend
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
- def activeContractAssignEventBatch(eventSequentialIds: Iterable[Long], allFilterParties: Set[Party], endInclusive: Long)(connection: Connection): Vector[RawActiveContract]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def activeContractCreateEventBatch(eventSequentialIds: Iterable[Long], allFilterParties: Set[daml.lf.data.Ref.Party], endInclusive: Long)(connection: Connection): Vector[Entry[FlatEvent]]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def activeContractCreateEventBatchV2(eventSequentialIds: Iterable[Long], allFilterParties: Set[Party], endInclusive: Long)(connection: Connection): Vector[RawActiveContract]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def assignEventBatch(eventSequentialIds: Iterable[Long], allFilterParties: Set[Party])(connection: Connection): Vector[RawAssignEvent]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- 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
- implicit def errorLoggingContext(implicit traceContext: TraceContext): ErrorLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- def eventReaderQueries: EventReaderQueries
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchAssignEventIdsForStakeholder(stakeholder: Party, templateId: Option[Identifier], startExclusive: Long, endInclusive: Long, limit: Int)(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchUnassignEventIdsForStakeholder(stakeholder: Party, templateId: Option[Identifier], startExclusive: Long, endInclusive: Long, limit: Int)(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- 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
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- EventStorageBackendTemplate → NamedLogging
- def lookupAssignSequentialIdByContractId(contractIds: Iterable[String])(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lookupAssignSequentialIdByOffset(offsets: Iterable[String])(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lookupCreateSequentialIdByContractId(contractIds: Iterable[String])(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lookupUnassignSequentialIdByOffset(offsets: Iterable[String])(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def maxEventSequentialId(untilInclusiveOffset: Offset)(connection: Connection): Long
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- implicit def namedLoggingContext(implicit traceContext: TraceContext): NamedLoggingContext
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def noTracingLogger: Logger
- Attributes
- protected
- Definition Classes
- NamedLogging
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def pruneEvents(pruneUpToInclusive: Offset, pruneAllDivulgedContracts: Boolean)(implicit connection: Connection, traceContext: TraceContext): Unit
Deletes a subset of the indexed data (up to the pruning offset) in the following order and in the manner specified: 1.a if pruning-all-divulged-contracts is enabled: all divulgence events (retroactive divulgence), 1.b otherwise: divulgence events for which there are archive events (retroactive divulgence), 2.
Deletes a subset of the indexed data (up to the pruning offset) in the following order and in the manner specified: 1.a if pruning-all-divulged-contracts is enabled: all divulgence events (retroactive divulgence), 1.b otherwise: divulgence events for which there are archive events (retroactive divulgence), 2. entries from filter for create stakeholders for there is an archive for the corresponding create event, 3. entries from filter for create non-stakeholder informees for there is an archive for the corresponding create event, 4. all entries from filter for consuming stakeholders, 5. all entries from filter for consuming non-stakeholders informees, 6. all entries from filter for non-consuming informees, 7. create events table for which there is an archive event, 8. if pruning-all-divulged-contracts is enabled: create contracts which did not have a locally hosted party before their creation offset (immediate divulgence), 9. all consuming events, 10. all non-consuming events, 11. transaction meta entries for which there exists at least one create event.
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- def transactionPointwiseQueries: TransactionPointwiseQueries
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def transactionStreamingQueries: TransactionStreamingQueries
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def unassignEventBatch(eventSequentialIds: Iterable[Long], allFilterParties: Set[Party])(connection: Connection): Vector[RawUnassignEvent]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- 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])