class SyncDomainEphemeralState extends SyncDomainEphemeralStateLookup with AutoCloseable with NamedLogging
The state of a synchronization domain that is kept only in memory and must be reconstructed after crashes and fatal errors from the SyncDomainPersistentState. The ephemeral state can be kept across network disconnects provided that the local processing continues as far as possible.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- SyncDomainEphemeralState
- NamedLogging
- AutoCloseable
- SyncDomainEphemeralStateLookup
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new SyncDomainEphemeralState(persistentState: SyncDomainPersistentState, multiDomainEventLog: MultiDomainEventLog, singleDomainCausalTracker: SingleDomainCausalTracker, inFlightSubmissionTracker: InFlightSubmissionTracker, startingPoints: ProcessingStartingPoints, createTimeTracker: (NamedLoggerFactory) => DomainTimeTracker, metrics: SyncDomainMetrics, timeouts: ProcessingTimeout, useCausalityTracking: Boolean, loggerFactory: NamedLoggerFactory)(implicit executionContext: ExecutionContext)
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 causalityLookup: SingleDomainCausalTracker
- Definition Classes
- SyncDomainEphemeralStateLookup
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- def close(): Unit
- Definition Classes
- SyncDomainEphemeralState → AutoCloseable
- def contractLookup: ContractLookup
- Definition Classes
- SyncDomainEphemeralStateLookup
- 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
- 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
- SyncDomainEphemeralState → NamedLogging
- def markAsRecovered(): Unit
- 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 observedTimestampLookup: WatermarkLookup[CantonTimestamp]
- Definition Classes
- SyncDomainEphemeralStateLookup
- val observedTimestampTracker: WatermarkTracker[CantonTimestamp]
- val pendingTransactions: TrieMap[RequestId, PendingRequestDataOrReplayData[PendingTransaction]]
- val pendingTransferInSubmissions: TrieMap[RootHash, PendingTransferSubmission]
- val pendingTransferIns: TrieMap[RequestId, PendingRequestDataOrReplayData[PendingTransferIn]]
- val pendingTransferOutSubmissions: TrieMap[RootHash, PendingTransferSubmission]
- val pendingTransferOuts: TrieMap[RequestId, PendingRequestDataOrReplayData[PendingTransferOut]]
- val phase37Synchronizer: Phase37Synchronizer
- val recordOrderPublisher: RecordOrderPublisher
- def recovered: Boolean
- val requestCounterAllocator: RequestCounterAllocatorImpl
- val requestJournal: RequestJournal
- val requestTracker: RequestTracker
- val singleDomainCausalTracker: SingleDomainCausalTracker
- val startingPoints: ProcessingStartingPoints
- val storedContractManager: StoredContractManager
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- val timeTracker: DomainTimeTracker
- def toString(): String
- Definition Classes
- AnyRef → Any
- val transferCache: TransferCache
- def transferLookup: TransferLookup
- Definition Classes
- SyncDomainEphemeralStateLookup
- 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])