com.digitalasset.canton.participant.store
SyncDomainEphemeralState
Companion object SyncDomainEphemeralState
class SyncDomainEphemeralState extends SyncDomainEphemeralStateLookup with AutoCloseable with NamedLogging with ComponentHealth
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.
- Alphabetic
- By Inheritance
- SyncDomainEphemeralState
- ComponentHealth
- HealthElement
- NamedLogging
- AutoCloseable
- SyncDomainEphemeralStateLookup
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SyncDomainEphemeralState(persistentState: SyncDomainPersistentState, multiDomainEventLog: Eval[MultiDomainEventLog], singleDomainCausalTracker: SingleDomainCausalTracker, inFlightSubmissionTracker: InFlightSubmissionTracker, startingPoints: ProcessingStartingPoints, createTimeTracker: (NamedLoggerFactory) => DomainTimeTracker, metrics: SyncDomainMetrics, timeouts: ProcessingTimeout, useCausalityTracking: Boolean, loggerFactory: NamedLoggerFactory, futureSupervisor: FutureSupervisor)(implicit executionContext: ExecutionContext)
Type Members
- type HealthListener = (SyncDomainEphemeralState.this.type, State, TraceContext) => Unit
- Definition Classes
- HealthElement
- type State = ComponentState
- Definition Classes
- ComponentHealth → HealthElement
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
- def degradationOccurred(error: String)(implicit tc: TraceContext): Unit
Report that the component is now degraded.
Report that the component is now degraded. Note that this will override the component state, even if it is currently failed!
- Definition Classes
- ComponentHealth
- def degradationOccurred(error: CantonError)(implicit tc: TraceContext): Unit
Report that the component is now degraded.
Report that the component is now degraded. Note that this will override the component state, even if it is currently failed!
- Definition Classes
- ComponentHealth
- 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 failureOccurred(error: String)(implicit tc: TraceContext): Unit
Report that the component is now failed
Report that the component is now failed
- Definition Classes
- ComponentHealth
- def failureOccurred(error: CantonError)(implicit tc: TraceContext): Unit
Report that the component is now failed
Report that the component is now failed
- Definition Classes
- ComponentHealth
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getState: ComponentState
Current state
Current state
- Definition Classes
- ComponentHealth → HealthElement
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- val initialState: ComponentState
Initial state of the component
Initial state of the component
- Definition Classes
- SyncDomainEphemeralState → ComponentHealth
- def isFailed: Boolean
Whether the component is in a failed state.
Whether the component is in a failed state. Note: failed here means exactly _failed_, to know if the component is just unhealthy (i.e degraded or failed), use isUnhealthy.
- Definition Classes
- ComponentHealth
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isNotFailed: Boolean
Returns true when the component is not in a failed state (for components, degraded is still not failed)
Returns true when the component is not in a failed state (for components, degraded is still not failed)
- Definition Classes
- ComponentHealth → HealthElement
- val listeners: AtomicReference[List[HealthListener]]
- Attributes
- protected
- Definition Classes
- HealthElement
- def logger: TracedLogger
- Attributes
- protected
- Definition Classes
- NamedLogging
- val loggerFactory: NamedLoggerFactory
- Definition Classes
- SyncDomainEphemeralState → NamedLogging
- def markAsRecovered()(implicit tc: TraceContext): Unit
- val name: String
Name of the health element.
Name of the health element. Used for logging.
- Definition Classes
- SyncDomainEphemeralState → HealthElement
- 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 pendingTransferInSubmissions: TrieMap[RootHash, PendingTransferSubmission]
- val pendingTransferOutSubmissions: TrieMap[RootHash, PendingTransferSubmission]
- val phase37Synchronizer: Phase37Synchronizer
- val recordOrderPublisher: RecordOrderPublisher
- def registerOnHealthChange(listener: HealthListener): Unit
- Definition Classes
- HealthElement
- def reportHealthState(state: ComponentState)(implicit tc: TraceContext): Boolean
- Definition Classes
- ComponentHealth
- def reportHealthState_(state: ComponentState)(implicit tc: TraceContext): Unit
- Definition Classes
- ComponentHealth
- val requestCounterAllocator: RequestCounterAllocatorImpl
- val requestJournal: RequestJournal
- val requestTracker: RequestTracker
- def resolveUnhealthy(implicit traceContext: TraceContext): Boolean
Set the health state to Ok and if the previous state was unhealthy, log a message to inform about the resolution of the ongoing issue.
Set the health state to Ok and if the previous state was unhealthy, log a message to inform about the resolution of the ongoing issue.
- Definition Classes
- ComponentHealth
- def resolveUnhealthy_(implicit traceContext: TraceContext): Unit
- Definition Classes
- ComponentHealth
- 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])