class PostgresEventStorageBackend extends EventStorageBackendTemplate
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- PostgresEventStorageBackend
- EventStorageBackendTemplate
- NamedLogging
- EventStorageBackend
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new PostgresEventStorageBackend(ledgerEndCache: LedgerEndCache, stringInterning: StringInterning, 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 activeContractBatch(eventSequentialIds: Iterable[Long], allFilterParties: Option[Set[Party]])(connection: Connection): Vector[RawThinActiveContract]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @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 fetchEventPayloadsAcsDelta(target: EventPayloadSourceForUpdatesAcsDelta)(eventSequentialIds: SequentialIdBatch, requestingPartiesForTx: Option[Set[Party]], requestingPartiesForReassignment: Option[Set[Party]])(connection: Connection): Vector[RawThinAcsDeltaEvent]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchEventPayloadsLedgerEffects(target: EventPayloadSourceForUpdatesLedgerEffects)(eventSequentialIds: SequentialIdBatch, requestingPartiesForTx: Option[Set[Party]], requestingPartiesForReassignment: Option[Set[Party]])(connection: Connection): Vector[RawThinLedgerEffectsEvent]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def fetchTopologyPartyEventIds(party: Option[Party])(connection: Connection): (PaginationInput) => Vector[Long]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def firstSynchronizerOffsetAfterOrAt(synchronizerId: SynchronizerId, afterOrAtRecordTimeInclusive: Timestamp)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def firstSynchronizerOffsetAfterOrAtPublicationTime(afterOrAtPublicationTimeInclusive: Timestamp)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def lastSynchronizerOffsetBeforeOrAt(synchronizerIdO: Option[SynchronizerId], beforeOrAtOffsetInclusive: Offset)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lastSynchronizerOffsetBeforeOrAtPublicationTime(beforeOrAtPublicationTimeInclusive: Timestamp)(connection: Connection): Option[SynchronizerOffset]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def lastSynchronizerOffsetBeforeOrAtRecordTime(synchronizerId: SynchronizerId, beforeOrAtRecordTimeInclusive: 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 lookupAssignSequentialIdByOffset(offsets: Iterable[Long])(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
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- def prunableContracts(fromExclusive: Option[Offset], toInclusive: Offset)(connection: Connection): Set[Long]
The contracts which were archived or participant-divulged in the specified range.
The contracts which were archived or participant-divulged in the specified range. These are the contracts in the ContractStore, which can be pruned in a single-synchronizer setup.
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def pruneEvents(previousPruneUpToInclusiveOffset: Option[Offset], previousIncompleteReassignmentOffsets: Vector[Offset], pruneUpToInclusiveOffset: Offset, incompleteReassignmentOffsets: Vector[Offset])(implicit connection: Connection, traceContext: TraceContext): Unit
Part of pruning process, this needs to be in the same transaction as the other pruning related database operations
Part of pruning process, this needs to be in the same transaction as the other pruning related database operations
- 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: SequentialIdBatch)(connection: Connection): Vector[RawParticipantAuthorization]
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def updatePointwiseQueries: UpdatePointwiseQueries
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- def updateStreamingQueries: UpdateStreamingQueries
- Definition Classes
- EventStorageBackendTemplate → EventStorageBackend
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- 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()