class H2EventStorageBackend extends EventStorageBackendTemplate
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- H2EventStorageBackend
- EventStorageBackendTemplate
- NamedLogging
- EventStorageBackend
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new H2EventStorageBackend(ledgerEndCache: LedgerEndCache, stringInterning: StringInterning, parameterStorageBackend: ParameterStorageBackend, loggerFactory: NamedLoggerFactory)
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: Option[Set[Party]], endInclusive: Long)(connection: Connection): Vector[RawActiveContract]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def activeContractCreateEventBatch(eventSequentialIds: Iterable[Long], allFilterParties: Option[Set[Party]], endInclusive: Long)(connection: Connection): Vector[RawActiveContract]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def archivals(fromExclusive: Option[Offset], toInclusive: Offset)(connection: Connection): Set[daml.lf.value.Value.ContractId]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def assignEventBatch(eventSequentialIds: Iterable[Long], allFilterParties: Option[Set[Party]])(connection: Connection): Vector[Entry[RawAssignEvent]]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- 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(stakeholderO: Option[Party], templateId: Option[Identifier], startExclusive: Long, endInclusive: Long, limit: Int)(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchEventPayloadsAcsDelta(target: EventPayloadSourceForUpdatesAcsDelta)(eventSequentialIds: Iterable[Long], requestingParties: Option[Set[daml.lf.data.Ref.Party]])(connection: Connection): Vector[Entry[RawFlatEvent]]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchEventPayloadsLedgerEffects(target: EventPayloadSourceForUpdatesLedgerEffects)(eventSequentialIds: Iterable[Long], requestingParties: Option[Set[daml.lf.data.Ref.Party]])(connection: Connection): Vector[Entry[RawTreeEvent]]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchTopologyPartyEventIds(party: Option[Party], startExclusive: Long, endInclusive: Long, limit: Int)(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchUnassignEventIdsForStakeholder(stakeholderO: Option[Party], templateId: Option[Identifier], startExclusive: Long, endInclusive: Long, limit: Int)(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def firstSynchronizerOffsetAfterOrAt(synchronizerId: SynchronizerId, afterOrAtRecordTime: Timestamp)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def firstSynchronizerOffsetAfterOrAtPublicationTime(afterOrAtPublicationTime: Timestamp)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def lastSynchronizerOffsetBeforeOrAt(synchronizerIdO: Option[SynchronizerId], beforeOrAtOffset: Offset)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lastSynchronizerOffsetBeforeOrAtPublicationTime(beforeOrAtPublicationTime: Timestamp)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lastSynchronizerOffsetBeforeOrAtRecordTime(synchronizerId: SynchronizerId, beforeOrAtRecordTime: Timestamp)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- EventStorageBackendTemplate → NamedLogging
- def lookupAssignSequentialIdBy(unassignProperties: Iterable[UnassignProperties])(connection: Connection): Map[UnassignProperties, Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lookupAssignSequentialIdByOffset(offsets: Iterable[Long])(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lookupCreateSequentialIdByContractId(contractIds: Iterable[daml.lf.value.Value.ContractId])(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lookupUnassignSequentialIdByOffset(offsets: Iterable[Long])(connection: Connection): Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def maxEventSequentialId(untilInclusiveOffset: Option[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
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- def pruneEvents(pruneUpToInclusive: Offset, pruneAllDivulgedContracts: Boolean, incompleteReassignmentOffsets: Vector[Offset])(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:
Deletes a subset of the indexed data (up to the pruning offset) in the following order and in the manner specified:
- entries from filter for create stakeholders for there is an archive for the corresponding create event,
- entries from filter for create non-stakeholder informees for there is an archive for the corresponding create event,
- all entries from filter for consuming stakeholders,
- all entries from filter for consuming non-stakeholders informees,
- all entries from filter for non-consuming informees,
- create events table for which there is an archive event,
- if pruning-all-divulged-contracts is enabled: create contracts which did not have a locally hosted party before their creation offset (immediate divulgence),
- all consuming events,
- all non-consuming events,
- 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 synchronizerOffset(offset: Offset)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def toString(): String
- Definition Classes
- AnyRef → Any
- def topologyEventOffsetPublishedOnRecordTime(synchronizerId: SynchronizerId, recordTime: CantonTimestamp)(connection: Connection): Option[Offset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def topologyPartyEventBatch(eventSequentialIds: Iterable[Long])(connection: Connection): Vector[RawParticipantAuthorization]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def unassignEventBatch(eventSequentialIds: Iterable[Long], allFilterParties: Option[Set[Party]])(connection: Connection): Vector[Entry[RawUnassignEvent]]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def updatePointwiseQueries: UpdatePointwiseQueries
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def updateStreamingQueries: UpdateStreamingQueries
- 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])