Packages

c

com.digitalasset.canton.participant.store

SyncDomainEphemeralState

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
NamedLogging, AutoCloseable, SyncDomainEphemeralStateLookup, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SyncDomainEphemeralState
  2. NamedLogging
  3. AutoCloseable
  4. SyncDomainEphemeralStateLookup
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. 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

  1. def causalityLookup: SingleDomainCausalTracker
    Definition Classes
    SyncDomainEphemeralStateLookup
  2. def close(): Unit
    Definition Classes
    SyncDomainEphemeralState → AutoCloseable
  3. def contractLookup: ContractLookup
    Definition Classes
    SyncDomainEphemeralStateLookup
  4. val loggerFactory: NamedLoggerFactory
    Definition Classes
    SyncDomainEphemeralState → NamedLogging
  5. def markAsRecovered(): Unit
  6. def observedTimestampLookup: WatermarkLookup[CantonTimestamp]
    Definition Classes
    SyncDomainEphemeralStateLookup
  7. val observedTimestampTracker: WatermarkTracker[CantonTimestamp]
  8. val pendingTransferInSubmissions: TrieMap[RootHash, PendingTransferSubmission]
  9. val pendingTransferOutSubmissions: TrieMap[RootHash, PendingTransferSubmission]
  10. val phase37Synchronizer: Phase37Synchronizer
  11. val recordOrderPublisher: RecordOrderPublisher
  12. def recovered: Boolean
  13. val requestCounterAllocator: RequestCounterAllocatorImpl
  14. val requestJournal: RequestJournal
  15. val requestTracker: RequestTracker
  16. val singleDomainCausalTracker: SingleDomainCausalTracker
  17. val startingPoints: ProcessingStartingPoints
  18. val storedContractManager: StoredContractManager
  19. val timeTracker: DomainTimeTracker
  20. val transferCache: TransferCache
  21. def transferLookup: TransferLookup
    Definition Classes
    SyncDomainEphemeralStateLookup